From ddfe16f56fa9791e5a98ab211aacc91660e487e4 Mon Sep 17 00:00:00 2001 From: Richard Ramos Date: Fri, 27 Jan 2023 14:58:14 -0400 Subject: [PATCH] fix: add cursors to store queries --- protocol/messenger_mailserver.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/protocol/messenger_mailserver.go b/protocol/messenger_mailserver.go index 46d620ccc..c276a1b17 100644 --- a/protocol/messenger_mailserver.go +++ b/protocol/messenger_mailserver.go @@ -584,7 +584,7 @@ func (m *Messenger) processMailserverBatch(batch MailserverBatch) error { } ctx, cancel := context.WithTimeout(m.ctx, mailserverRequestTimeout) - cursor, storeCursor, err := m.transport.SendMessagesRequestForTopics(ctx, mailserverID, batch.From, batch.To, nil, nil, w.topics, true) + cursor, storeCursor, err := m.transport.SendMessagesRequestForTopics(ctx, mailserverID, batch.From, batch.To, w.cursor, w.storeCursor, w.topics, true) if err != nil { logger.Error("failed to send request", zap.Error(err)) wg.Done()