Validate partial checksums

Author: simolus3

demos/django-todolist/.gitignore

@@ -5,9 +5,11 @@
 *.swp
 .DS_Store
 .atom/
+.build/
 .buildlog/
 .history
 .svn/
+.swiftpm/
 migrate_working_dir/
 
 # IntelliJ related

demos/django-todolist/macos/Podfile.lock

@@ -3,10 +3,10 @@ PODS:
   - path_provider_foundation (0.0.1):
     - Flutter
     - FlutterMacOS
-  - powersync-sqlite-core (0.1.6)
+  - powersync-sqlite-core (0.3.9)
   - powersync_flutter_libs (0.0.1):
     - FlutterMacOS
-    - powersync-sqlite-core (~> 0.1.6)
+    - powersync-sqlite-core (~> 0.3.8)
   - shared_preferences_foundation (0.0.1):
     - Flutter
     - FlutterMacOS
@@ -55,13 +55,13 @@ EXTERNAL SOURCES:
 
 SPEC CHECKSUMS:
   FlutterMacOS: 8f6f14fa908a6fb3fba0cd85dbd81ec4b251fb24
-  path_provider_foundation: 2b6b4c569c0fb62ec74538f866245ac84301af46
-  powersync-sqlite-core: 4c38c8f470f6dca61346789fd5436a6826d1e3dd
-  powersync_flutter_libs: 1eb1c6790a72afe08e68d4cc489d71ab61da32ee
-  shared_preferences_foundation: fcdcbc04712aee1108ac7fda236f363274528f78
+  path_provider_foundation: 080d55be775b7414fd5a5ef3ac137b97b097e564
+  powersync-sqlite-core: 7515d321eb8e3c08b5259cdadb9d19b1876fe13a
+  powersync_flutter_libs: 330d8309223a121ec15a7334d9edc105053e5f82
+  shared_preferences_foundation: 9e1978ff2562383bd5676f64ec4e9aa8fa06a6f7
   sqlite3: 292c3e1bfe89f64e51ea7fc7dab9182a017c8630
-  sqlite3_flutter_libs: 5ca46c1a04eddfbeeb5b16566164aa7ad1616e7b
+  sqlite3_flutter_libs: 03311aede9d32fb2d24e32bebb8cd01c3b2e6239
 
 PODFILE CHECKSUM: 236401fc2c932af29a9fcf0e97baeeb2d750d367
 
-COCOAPODS: 1.15.2
+COCOAPODS: 1.16.2

demos/django-todolist/macos/Runner/AppDelegate.swift

@@ -1,9 +1,13 @@
 import Cocoa
 import FlutterMacOS
 
-@NSApplicationMain
+@main
 class AppDelegate: FlutterAppDelegate {
   override func applicationShouldTerminateAfterLastWindowClosed(_ sender: NSApplication) -> Bool {
     return true
   }
+
+  override func applicationSupportsSecureRestorableState(_ app: NSApplication) -> Bool {
+    return true
+  }
 }

demos/django-todolist/macos/Runner/Configs/AppInfo.xcconfig

@@ -8,7 +8,7 @@
 PRODUCT_NAME = PowerSync Django Demo
 
 // The application's bundle identifier
-PRODUCT_BUNDLE_IDENTIFIER = co.powersync.demotodolist
+PRODUCT_BUNDLE_IDENTIFIER = co.powersync.demotodolist.django
 
 // The copyright displayed in application information
 PRODUCT_COPYRIGHT = Copyright © 2023 Journey Mobile, Inc. All rights reserved.

demos/django-todolist/pubspec.lock

@@ -5,10 +5,10 @@ packages:
     dependency: transitive
     description:
       name: args
-      sha256: "7cf60b9f0cc88203c5a190b4cd62a99feea42759a7fa695010eb5de1c0b2252a"
+      sha256: bf9f5caeea8d8fe6721a9c358dd8a5c1947b27f1cfaa18b39c301273594919e6
       url: "https://pub.dev"
     source: hosted
-    version: "2.5.0"
+    version: "2.6.0"
   async:
     dependency: transitive
     description:
@@ -152,14 +152,6 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "4.0.2"
-  js:
-    dependency: transitive
-    description:
-      name: js
-      sha256: c1b2e9b5ea78c45e1a0788d29606ba27dc5f71f019f32ca5140f61ef071838cf
-      url: "https://pub.dev"
-    source: hosted
-    version: "0.7.1"
   json_annotation:
     dependency: transitive
     description:
@@ -318,21 +310,21 @@ packages:
       path: "../../packages/powersync"
       relative: true
     source: path
-    version: "1.10.0"
+    version: "1.11.2"
   powersync_core:
     dependency: "direct overridden"
     description:
       path: "../../packages/powersync_core"
       relative: true
     source: path
-    version: "1.0.0"
+    version: "1.1.2"
   powersync_flutter_libs:
     dependency: "direct overridden"
     description:
       path: "../../packages/powersync_flutter_libs"
       relative: true
     source: path
-    version: "0.4.3"
+    version: "0.4.4"
   pub_semver:
     dependency: transitive
     description:
@@ -430,10 +422,10 @@ packages:
     dependency: transitive
     description:
       name: sqlite3
-      sha256: bb174b3ec2527f9c5f680f73a89af8149dd99782fbb56ea88ad0807c5638f2ed
+      sha256: "35d3726fe18ab1463403a5cc8d97dbc81f2a0b08082e8173851363fcc97b6627"
       url: "https://pub.dev"
     source: hosted
-    version: "2.4.7"
+    version: "2.7.2"
   sqlite3_flutter_libs:
     dependency: transitive
     description:
@@ -446,18 +438,18 @@ packages:
     dependency: transitive
     description:
       name: sqlite3_web
-      sha256: f22d1dda7a40be0867984f55cdf5c2d599e5f05d3be4a642d78f38b38983f554
+      sha256: "870f287c2375117af1f769893c5ea0941882ee820444af5c3dcceec3b217aab1"
       url: "https://pub.dev"
     source: hosted
-    version: "0.2.0"
+    version: "0.3.0"
   sqlite_async:
     dependency: "direct main"
     description:
       name: sqlite_async
-      sha256: d66fb6e6d07c1a834743326c033029f75becbb1fad6823d709f921872abc3d5b
+      sha256: "70836e6a5dae2d14ce585934d1d6ce22433c1be825e78908a4b2a18333f7073c"
       url: "https://pub.dev"
     source: hosted
-    version: "0.11.0"
+    version: "0.11.2"
   stack_trace:
     dependency: transitive
     description:
@@ -563,5 +555,5 @@ packages:
     source: hosted
     version: "3.1.2"
 sdks:
-  dart: ">=3.4.0 <4.0.0"
+  dart: ">=3.5.0 <4.0.0"
   flutter: ">=3.22.0"

packages/powersync_core/lib/src/bucket_storage.dart

@@ -114,7 +114,7 @@ class BucketStorage {
 
   Future<SyncLocalDatabaseResult> syncLocalDatabase(Checkpoint checkpoint,
       {int? forPriority}) async {
-    final r = await validateChecksums(checkpoint);
+    final r = await validateChecksums(checkpoint, priority: forPriority);
 
     if (!r.checkpointValid) {
       for (String b in r.checkpointFailures ?? []) {
@@ -165,10 +165,15 @@ class BucketStorage {
     }, flush: true);
   }
 
-  Future<SyncLocalDatabaseResult> validateChecksums(
-      Checkpoint checkpoint) async {
-    final rs = await select("SELECT powersync_validate_checkpoint(?) as result",
-        [jsonEncode(checkpoint)]);
+  Future<SyncLocalDatabaseResult> validateChecksums(Checkpoint checkpoint,
+      {int? priority}) async {
+    final rs =
+        await select("SELECT powersync_validate_checkpoint(?) as result", [
+      jsonEncode({
+        ...checkpoint.toJson(),
+        if (priority != null) 'priority': priority,
+      })
+    ]);
     final result = jsonDecode(rs[0]['result']);
     if (result['valid']) {
       return SyncLocalDatabaseResult(ready: true);

packages/powersync_core/lib/src/sync_types.dart

@@ -13,6 +13,9 @@ sealed class StreamingSyncLine {
     } else if (line.containsKey('checkpoint_complete')) {
       return StreamingSyncCheckpointComplete.fromJson(
           line['checkpoint_complete']);
+    } else if (line.containsKey('partial_checkpoint_complete')) {
+      return StreamingSyncCheckpointPartiallyComplete.fromJson(
+          line['partial_checkpoint_complete']);
     } else if (line.containsKey('data')) {
       return SyncBucketData.fromJson(line['data']);
     } else if (line.containsKey('token_expires_in')) {