feat: add sequence number to TopicItem

momentohq · Aug 22, 2024 · 18e0f4a · 18e0f4a
1 parent 7940999
commit 18e0f4a
Show file tree

Hide file tree

Showing 2 changed files with 29 additions and 7 deletions.
diff --git a/packages/client-sdk-nodejs/src/internal/pubsub-client.ts b/packages/client-sdk-nodejs/src/internal/pubsub-client.ts
@@ -216,15 +216,23 @@ export class PubsubClient extends AbstractPubsubClient<ServiceError> {
         );
         if (resp.item.value.text) {
           options.onItem(
-            new TopicItem(resp.item.value.text, {
-              tokenId: resp.item.publisher_id,
-            })
+            new TopicItem(
+              resp.item.value.text,
+              resp.item.topic_sequence_number,
+              {
+                tokenId: resp.item.publisher_id,
+              }
+            )
           );
         } else if (resp.item.value.binary) {
           options.onItem(
-            new TopicItem(resp.item.value.binary, {
-              tokenId: resp.item.publisher_id,
-            })
+            new TopicItem(
+              resp.item.value.binary,
+              resp.item.topic_sequence_number,
+              {
+                tokenId: resp.item.publisher_id,
+              }
+            )
           );
         } else {
           this.getLogger().error(

diff --git a/packages/core/src/messages/responses/topic-item.ts b/packages/core/src/messages/responses/topic-item.ts
@@ -14,10 +14,16 @@ export interface TopicItemOptions {
 export class TopicItem {
   private readonly _value: string | Uint8Array;
   private readonly _tokenId?: string;
+  private readonly _sequenceNumber: number;
 
-  constructor(_value: string | Uint8Array, options?: TopicItemOptions) {
+  constructor(
+    _value: string | Uint8Array,
+    _sequenceNumber: number,
+    options?: TopicItemOptions
+  ) {
     this._value = _value;
     this._tokenId = options?.tokenId;
+    this._sequenceNumber = _sequenceNumber;
   }
 
   /**
@@ -52,6 +58,14 @@ export class TopicItem {
     return this._tokenId;
   }
 
+  /**
+   * Returns the sequence number of the item.
+   * @returns string | undefined
+   */
+  public sequenceNumber(): number {
+    return this._sequenceNumber;
+  }
+
   public toString(): string {
     const displayValue = truncateString(this.value().toString());
     let displayString = `${this.constructor.name}: ${displayValue}`;