func (b *TelegramBot) poll(ctx context.Context, l *TurnLoop, whatsapp *WhatsApp) error {
offset, err := telegramLoadOffset(b.offsetPath)
if err != nil {
- return err
+ return fmt.Errorf("load Telegram offset: %w", err)
}
outage := &TelegramOutage{
continue poll
}
- return err
+ if err != nil {
+ return fmt.Errorf("handle Telegram update: %w", err)
+ }
+
+ return nil
}
imageOutage.End()
offset = update.UpdateID + 1
err = telegramSaveOffset(b.offsetPath, offset)
if err != nil {
- return err
+ return fmt.Errorf("save Telegram offset: %w", err)
}
}
}
default:
_, err := l.Submit(telegramSource, message.Text)
if err != nil {
- return err
+ return fmt.Errorf("submit Telegram text: %w", err)
}
err = l.Flush(context.WithoutCancel(ctx))