Only verify relevant buckets

powersync-ja · Feb 4, 2025 · 7ed6945 · 7ed6945
1 parent c99c043
commit 7ed6945
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/packages/powersync_core/lib/src/bucket_storage.dart b/packages/powersync_core/lib/src/bucket_storage.dart
@@ -176,7 +176,7 @@ class BucketStorage {
     final rs =
         await select("SELECT powersync_validate_checkpoint(?) as result", [
       jsonEncode({
-        ...checkpoint.toJson(),
+        ...checkpoint.toJson(priority: priority),
         if (priority != null) 'priority': priority,
       })
     ]);

diff --git a/packages/powersync_core/lib/src/sync_types.dart b/packages/powersync_core/lib/src/sync_types.dart
@@ -52,11 +52,12 @@ final class Checkpoint extends StreamingSyncLine {
             .map((b) => BucketChecksum.fromJson(b))
             .toList();
 
-  Map<String, dynamic> toJson() {
+  Map<String, dynamic> toJson({int? priority}) {
     return {
       'last_op_id': lastOpId,
       'write_checkpoint': writeCheckpoint,
       'buckets': checksums
+          .where((c) => priority == null || c.priority <= priority)
           .map((c) => {'bucket': c.bucket, 'checksum': c.checksum})
           .toList(growable: false)
     };