Method FetchMessages

internal/cmd/gmail_watch_source.go:70–123

(ctx context.Context, ids []string)

}

func (s *gmailWatchSource) FetchMessages(ctx context.Context, ids []string) (gmailwatch.MessageBatch, error) {
	batch := gmailwatch.MessageBatch{
		Messages: make([]gmailwatch.Message, 0, len(ids)),
	}
	format := gmailWatchFormatMetadata
	if s.includeBody {
		format = gmailFormatFull
	}

	for _, id := range ids {
		if strings.TrimSpace(id) == "" {
			continue
		}
		message, err := s.service.Users.Messages.Get("me", id).
			Format(format).
			MetadataHeaders(gmailBasicMetadataHeaders...).
			Context(ctx).
			Do()
		if err != nil {
			if isNotFoundAPIError(err) {
				continue
			}
			return gmailwatch.MessageBatch{}, err
		}
		if message == nil {
			continue
		}
		if labelSetContains(s.excludeLabelIDs, message.LabelIds) {
			batch.Excluded++
			if s.verbose && s.logf != nil {
				s.logf("watch: excluded message %s labels=%v", message.Id, message.LabelIds)
			}
			continue
		}

		item := gmailwatch.Message{
			ID:       message.Id,
			ThreadID: message.ThreadId,
			From:     headerValue(message.Payload, "From"),
			To:       headerValue(message.Payload, "To"),
			Subject:  headerValue(message.Payload, "Subject"),
			Date:     formatGmailDateInLocation(headerValue(message.Payload, "Date"), s.dateLocation),
			Snippet:  message.Snippet,
			Labels:   message.LabelIds,
		}
		if s.includeBody {
			body := gmailcontent.BestBodyText(message.Payload)
			item.Body, item.BodyTruncated = truncateUTF8Bytes(body, s.maxBodyBytes)
		}
		batch.Messages = append(batch.Messages, item)
	}

	return batch, nil
}

func historyPageFromGmail(response *gmail.ListHistoryResponse) gmailwatch.HistoryPage {
	if response == nil {