fix: set topic sequence number and page to subscription state on disc…

…ontinuity
momentohq · Nov 15, 2024 · a088947 · a088947
1 parent 5ead127
commit a088947
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/packages/client-sdk-nodejs/src/internal/pubsub-client.ts b/packages/client-sdk-nodejs/src/internal/pubsub-client.ts
@@ -262,6 +262,10 @@ export class PubsubClient extends AbstractPubsubClient<ServiceError> {
           truncateString(options.topicName),
           topicDiscontinuity.toString()
         );
+        options.subscriptionState.lastTopicSequenceNumber =
+          resp.discontinuity.new_topic_sequence;
+        options.subscriptionState.lastTopicSequencePage =
+          resp.discontinuity.new_sequence_page;
         options.onDiscontinuity(topicDiscontinuity);
       } else {
         this.getLogger().error(

diff --git a/packages/client-sdk-web/src/internal/pubsub-client.ts b/packages/client-sdk-web/src/internal/pubsub-client.ts
@@ -236,6 +236,10 @@ export class PubsubClient<
             options.topicName
           )}; ${topicDiscontinuity.toString()}`
         );
+        options.subscriptionState.lastTopicSequenceNumber =
+          discontinuity.getNewTopicSequence();
+        options.subscriptionState.lastTopicSequencePage =
+          discontinuity.getNewSequencePage();
         options.onDiscontinuity(topicDiscontinuity);
       } else {
         this.getLogger().error(