Fix missing filter when setting last_op

simolus3 · simolus3 · commit c30cbef745bd · 2025-05-06T11:02:22.000+02:00
diff --git a/.changeset/polite-news-sneeze.md b/.changeset/polite-news-sneeze.md
@@ -0,0 +1,5 @@
+---
+'@powersync/common': patch
+---
+
+Fix applying bucket state around partial syncs.
diff --git a/packages/common/src/client/sync/bucket/SqliteBucketStorage.ts b/packages/common/src/client/sync/bucket/SqliteBucketStorage.ts
@@ -154,9 +154,9 @@ export class SqliteBucketStorage extends BaseObserver<BucketStorageListener> imp
       return { ready: false, checkpointValid: false, checkpointFailures: r.checkpointFailures };
     }
 
-    const buckets = checkpoint.buckets;
+    let buckets = checkpoint.buckets;
     if (priority !== undefined) {
-      buckets.filter((b) => hasMatchingPriority(priority, b));
+      buckets = buckets.filter((b) => hasMatchingPriority(priority, b));
     }
     const bucketNames = buckets.map((b) => b.bucket);
     await this.writeTransaction(async (tx) => {

-Original file line number
+Diff line change
@@ @@ -0,0 +1,5 @@ @@
 +---
 +'@powersync/common': patch
 +---
++
 +Fix applying bucket state around partial syncs.
Original file line number	Diff line number	Diff line change
`@@ -154,9 +154,9 @@ export class SqliteBucketStorage extends BaseObserver<BucketStorageListener> imp`
`154`	`154`	`return { ready: false, checkpointValid: false, checkpointFailures: r.checkpointFailures };`
`155`	`155`	`}`
`156`	`156`
`157`		`- const buckets = checkpoint.buckets;`
	`157`	`+ let buckets = checkpoint.buckets;`
`158`	`158`	`if (priority !== undefined) {`
`159`		`- buckets.filter((b) => hasMatchingPriority(priority, b));`
	`159`	`+ buckets = buckets.filter((b) => hasMatchingPriority(priority, b));`
`160`	`160`	`}`
`161`	`161`	`const bucketNames = buckets.map((b) => b.bucket);`
`162`	`162`	`await this.writeTransaction(async (tx) => {`