Method resync

internal/gmailwatch/processor.go:219–246

(ctx context.Context, source Source, notification Notification)

}

func (p *Processor) resync(ctx context.Context, source Source, notification Notification) (*Payload, error) {
	ids, err := source.ListRecentMessageIDs(ctx, p.Config.ResyncMax)
	if err != nil {
		return nil, p.openRateLimitCircuitIfNeeded(err)
	}

	batch, err := source.FetchMessages(ctx, ids)
	if err != nil {
		return nil, p.openRateLimitCircuitIfNeeded(err)
	}

	p.advanceHistory(notification.HistoryID, notification.MessageID, "watch: failed to update state after resync: %v")

	if batch.Excluded > 0 && len(batch.Messages) == 0 {
		if p.Config.Verbose {
			p.logf("watch: skipping hook; all messages excluded")
		}

		return nil, ErrNoNewMessages
	}

	return &Payload{
		Source:    "gmail",
		Account:   p.Config.Account,
		HistoryID: notification.HistoryID,
		Messages:  batch.Messages,
	}, nil
}

func (p *Processor) advanceHistory(historyID, messageID, warning string) {
	if err := p.Repository.AdvanceHistory(historyID, messageID, p.currentTime()); err != nil {