Adopt in demo

Author: simolus3

Demo/PowerSyncExample.xcodeproj/project.pbxproj

@@ -3,7 +3,7 @@
 	archiveVersion = 1;
 	classes = {
 	};
-	objectVersion = 56;
+	objectVersion = 60;
 	objects = {
 
 /* Begin PBXBuildFile section */

Demo/PowerSyncExample.xcodeproj/project.xcworkspace/xcshareddata/swiftpm/Package.resolved

@@ -1,5 +1,6 @@
 import AVFoundation
 import IdentifiedCollections
+import PowerSync
 import SwiftUI
 import SwiftUINavigation
 
@@ -11,6 +12,7 @@ struct TodoListView: View {
     @State private var error: Error?
     @State private var newTodo: NewTodo?
     @State private var editing: Bool = false
+    @State private var loadingListItems: Bool = false
 
 #if os(iOS)
     // Called when a photo has been captured. Individual widgets should register the listener
@@ -33,6 +35,10 @@ struct TodoListView: View {
                     }
                 }
             }
+            
+            if (loadingListItems) {
+                ProgressView()
+            }
 
             ForEach(todos) { todo in
 #if os(iOS)
@@ -142,6 +148,22 @@ struct TodoListView: View {
                 }
             }
         }
+        .task {
+            if (Secrets.previewSyncStreams) {
+                // With sync streams, todo items are not loaded by default. We have to request them while we need them.
+                // Thanks to builtin caching, navingating to the same list multiple times does not have to fetch items again.
+                loadingListItems = true
+                do {
+                    // This will make the sync client request items from this list as long as we keep a reference to the stream subscription,
+                    // and a default TTL of one day afterwards.
+                    let streamSubscription = try await system.db.syncStream(name: "todos", params: ["list": JsonValue.string(listId)]).subscribe()
+                    try await streamSubscription.waitForFirstSync()
+                } catch {
+                    print("Error subscribing to list stream \(error)")
+                }
+                loadingListItems = false
+            }
+        }
     }
 
     func toggleCompletion(of todo: Todo) async {

Demo/PowerSyncExample/Components/TodoListView.swift

@@ -78,11 +78,12 @@ final class SystemManager {
                 options: ConnectOptions(
                     clientConfiguration: SyncClientConfiguration(
                         requestLogger: SyncRequestLoggerConfiguration(
-                            requestLevel: .headers
+                            requestLevel: .all
                         ) { message in
                             self.db.logger.debug(message, tag: "SyncRequest")
                         }
-                    )
+                    ),
+                    newClientImplementation: true,
                 )
             )
             try await attachments?.startSync()

Demo/PowerSyncExample/PowerSync/SystemManager.swift

@@ -8,7 +8,6 @@ struct HomeScreen: View {
 
 
     var body: some View {
-        
         ListView()
             .toolbar {
                 ToolbarItem(placement: .cancellationAction) {

Demo/PowerSyncExample/Screens/HomeScreen.swift

@@ -17,4 +17,24 @@ extension Secrets {
     static var supabaseStorageBucket: String? {
         return nil
     }
+
+    static var previewSyncStreams: Bool {
+        /* 
+        Set to true to preview https://docs.powersync.com/usage/sync-streams.
+        When enabling this, also set your sync rules to the following:
+
+        streams:
+          lists:
+            query: SELECT * FROM lists WHERE owner_id = auth.user_id()
+            auto_subscribe: true
+          todos:
+            query: SELECT * FROM todos WHERE list_id = subscription.parameter('list') AND list_id IN (SELECT id FROM lists WHERE owner_id = auth.user_id())
+
+        config:
+          edition: 2
+
+        */
+
+        false
+    }
 }

Demo/PowerSyncExample/Secrets.template.swift

@@ -6,6 +6,7 @@ protocol SecretsProvider {
     static var supabaseURL: URL { get }
     static var supabaseAnonKey: String { get }
     static var supabaseStorageBucket: String? { get }
+    static var previewSyncStreams: Bool { get }
 }
 
 // Default conforming type

Demo/PowerSyncExample/_Secrets.swift

@@ -81,27 +81,14 @@ public struct ConnectOptions: Sendable {
     ///   - retryDelay: Delay TimeInterval between retry attempts in milliseconds. Defaults to `5` seconds.
     ///   - params: Custom sync parameters to send to the server. Defaults to an empty dictionary.
     ///   - clientConfiguration: Configuration for the HTTP client used to connect to PowerSync.
+    ///   - newClientImplementation: Whether to use a new sync client implemented in Rust. Currently defaults to
+    ///   `false`, but we encourage users to try it out.
     public init(
         crudThrottle: TimeInterval = 1,
         retryDelay: TimeInterval = 5,
         params: JsonParam = [:],
-        clientConfiguration: SyncClientConfiguration? = nil
-    ) {
-        self.crudThrottle = crudThrottle
-        self.retryDelay = retryDelay
-        self.params = params
-        newClientImplementation = false
-        self.clientConfiguration = clientConfiguration
-    }
-
-    /// Initializes a ``ConnectOptions`` instance with optional values, including experimental options.
-    @_spi(PowerSyncExperimental)
-    public init(
-        crudThrottle: TimeInterval = 1,
-        retryDelay: TimeInterval = 5,
-        params: JsonParam = [:],
+        clientConfiguration: SyncClientConfiguration? = nil,
         newClientImplementation: Bool = false,
-        clientConfiguration: SyncClientConfiguration? = nil
     ) {
         self.crudThrottle = crudThrottle
         self.retryDelay = retryDelay