diff --git a/VERSION b/VERSION index 9d4b911c3..cf1590537 100644 --- a/VERSION +++ b/VERSION @@ -1 +1 @@ -0.91.8 +0.91.9 \ No newline at end of file diff --git a/protocol/messenger_mailserver.go b/protocol/messenger_mailserver.go index 1737f66f0..fa6bcaf2c 100644 --- a/protocol/messenger_mailserver.go +++ b/protocol/messenger_mailserver.go @@ -419,12 +419,13 @@ func (m *Messenger) processMailserverBatch(batch MailserverBatch) error { if err != nil { return err } + for len(cursor) != 0 || storeCursor != nil { logger.Info("retrieved cursor", zap.String("cursor", types.EncodeHex(cursor))) ctx, cancel := context.WithTimeout(context.Background(), mailserverRequestTimeout) defer cancel() - cursor, storeCursor, err = m.transport.SendMessagesRequest(ctx, m.mailserver, batch.From, batch.To, cursor, storeCursor, true) + cursor, storeCursor, err = m.transport.SendMessagesRequestForTopics(ctx, m.mailserver, batch.From, batch.To, cursor, storeCursor, batch.Topics, true) if err != nil { return err }