Start by always sending an invalidation event.

powersync-ja · Feb 6, 2025 · 0368e19 · 0368e19
1 parent bfbcdd3
commit 0368e19
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 2 deletions.
diff --git a/modules/module-mongodb-storage/src/storage/MongoBucketStorage.ts b/modules/module-mongodb-storage/src/storage/MongoBucketStorage.ts
@@ -530,11 +530,19 @@ export class MongoBucketStorage
       lastWriteCheckpoint = currentWriteCheckpoint;
       lastCheckpoint = checkpoint;
 
+      const syncRules = bucketStorage.getParsedSyncRules(options.parseOptions);
+
+      // We do not track individual bucket updates yet, always send an invalidation event.
+      filter?.({
+        syncRules,
+        invalidate: true
+      });
+
       yield {
         base: cp,
         writeCheckpoint: currentWriteCheckpoint,
         storage: bucketStorage,
-        syncRules: bucketStorage.getParsedSyncRules(options.parseOptions)
+        syncRules
       };
     }
   }

diff --git a/modules/module-postgres-storage/src/storage/PostgresBucketStorageFactory.ts b/modules/module-postgres-storage/src/storage/PostgresBucketStorageFactory.ts
@@ -396,7 +396,7 @@ export class PostgresBucketStorageFactory
     let lastCheckpoint: utils.OpId | null = null;
     let lastWriteCheckpoint: bigint | null = null;
 
-    const { signal, user_id, parseOptions } = options;
+    const { signal, user_id, parseOptions, filter } = options;
 
     const iter = wrapWithAbort(this.sharedIterator, signal);
     for await (const cp of iter) {
@@ -433,6 +433,12 @@ export class PostgresBucketStorageFactory
       lastWriteCheckpoint = currentWriteCheckpoint;
       lastCheckpoint = checkpoint;
 
+      // We do not track individual bucket updates yet, always send an invalidation event.
+      filter?.({
+        syncRules,
+        invalidate: true
+      });
+
       yield { base: cp, writeCheckpoint: currentWriteCheckpoint, syncRules, storage: bucketStorage };
     }
   }