Support bucket priorities

Author: simolus3

Demo/PowerSyncExample/Components/ListView.swift

@@ -9,8 +9,18 @@ struct ListView: View {
     @State private var error: Error?
     @State private var newList: NewListContent?
     @State private var editing: Bool = false
+    @State private var didSync: Bool = false
 
     var body: some View {
+        if !didSync {
+            Text("Busy with sync!").task {
+                do {
+                    try await system.db.waitForFirstSync(priority: 1)
+                    didSync = true;
+                } catch {}
+            }
+        }
+        
         List {
             if let error {
                 ErrorText(error)

Package.resolved

@@ -17,7 +17,7 @@ let package = Package(
     ],
     dependencies: [
         .package(url: "https://github.com/powersync-ja/powersync-kotlin.git", exact: "1.0.0-BETA23.0"),
-        .package(url: "https://github.com/powersync-ja/powersync-sqlite-core-swift.git", "0.3.9"..<"0.4.0")
+        .package(url: "https://github.com/powersync-ja/powersync-sqlite-core-swift.git", "0.3.11"..<"0.4.0")
     ],
     targets: [
         // Targets are the basic building blocks of a package, defining a module or a test suite.

Package.swift

@@ -25,6 +25,10 @@ final class KotlinPowerSyncDatabaseImpl: PowerSyncDatabaseProtocol {
     func waitForFirstSync() async throws {
         try await kotlinDatabase.waitForFirstSync()
     }
+    
+    func waitForFirstSync(priority: Int32) async throws {
+        try await kotlinDatabase.waitForFirstSync(priority: priority)
+    }
 
     func connect(
         connector: PowerSyncBackendConnector,

Sources/PowerSync/Kotlin/KotlinPowerSyncDatabaseImpl.swift

@@ -13,6 +13,9 @@ public protocol PowerSyncDatabaseProtocol: Queries {
 
     /// Wait for the first sync to occur
     func waitForFirstSync() async throws
+   
+    /// Wait for the first (possibly partial) sync to occur that contains all buckets in the given priority.
+    func waitForFirstSync(priority: Int32) async throws
 
     /// Connect to the PowerSync service, and keep the databases in sync.
     ///