handle case where a new miniblock contains a snapshot (#341)

river-build · Aug 8, 2024 · 060f9e7 · 060f9e7
1 parent d7de045
commit 060f9e7
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/packages/sdk/src/syncedStream.ts b/packages/sdk/src/syncedStream.ts
@@ -182,9 +182,14 @@ export class SyncedStream extends Stream {
             .map((e) => e.remoteEvent)
             .filter(isDefined)
 
+        const lastSnapshotMiniblockNum =
+            miniblock.header.snapshot !== undefined
+                ? miniblock.header.miniblockNum
+                : miniblock.header.prevSnapshotMiniblockNum
+
         const cachedSyncedStream = new PersistedSyncedStream({
             syncCookie: syncCookie,
-            lastSnapshotMiniblockNum: miniblock.header.prevSnapshotMiniblockNum,
+            lastSnapshotMiniblockNum: lastSnapshotMiniblockNum,
             minipoolEvents: minipoolEvents,
             lastMiniblockNum: miniblock.header.miniblockNum,
         })