update demo and changelog

Author: stevensJourney

CHANGELOG.md

@@ -2,9 +2,74 @@
 
 # 1.0.0-Beta.14
 
-- Removed references to the PowerSync Kotlin SDK from all public API protocols.
 - Improved the stability of watched queries. Watched queries were previously susceptible to runtime crashes if an exception was thrown in the update stream. Errors are now gracefully handled.
 
+- Removed references to the PowerSync Kotlin SDK from all public API protocols. Dedicated Swift protocols are now defined. These protocols align better with Swift primitives.
+
+- Database and transaction/lock level query `execute` methods now have `@discardableResult` annotation.
+
+- `AttachmentContext`, `AttachmentQueue`, `AttachmentService` and `SyncingService` are are now explicitly declared as `open` classes, allowing them to be subclassed outside the defining module.
+
+**BREAKING CHANGES**:
+
+- Completing CRUD transactions or CRUD batches, in the `PowerSyncBackendConnector` `uploadData` handler, now has a simpler invocation.
+
+```diff
+- _ = try await transaction.complete.invoke(p1: nil)
++ try await transaction.complete()
+```
+
+- `index` based `SqlCursor` getters now throw if the query result column value is `nil`. This is now consistent with the behaviour of named column getter operations. New `getXxxxxOptional(index: index)` methods are available if the query result value could be `nil`.
+
+```diff
+let results = try transaction.getAll(
+                sql: "SELECT * FROM my_table",
+                parameters: [id]
+            ) { cursor in
+-                 cursor.getString(index: 0)!
++                 cursor.getStringOptional(index: 0)
++                 // OR
++                 // try cursor.getString(index: 0) // if the value should be required
+            }
+```
+
+- `SqlCursor` getters now directly return Swift types. `getLong` has been replaced with `getInt64`.
+
+```diff
+let results = try transaction.getAll(
+                sql: "SELECT * FROM my_table",
+                parameters: [id]
+            ) { cursor in
+-                 cursor.getBoolean(index: 0)?.boolValue,
++                 cursor.getBooleanOptional(index: 0),
+-                 cursor.getLong(index: 0)?.int64Value,
++                 cursor.getInt64Optional(index: 0)
++                 // OR
++                 // try cursor.getInt64(index: 0) // if the value should be required
+            }
+```
+
+- Client parameters now need to be specified with strictly typed `JsonParam` enums.
+
+```diff
+try await database.connect(
+    connector: PowerSyncBackendConnector(),
+    params: [
+-        "foo": "bar"
++        "foo": .string("bar")
+    ]
+)
+```
+
+- `SyncStatus` values now use Swift primitives for status attributes. `lastSyncedAt` now is of `Date` type.
+
+```diff
+- let lastTime: Date? = db.currentStatus.lastSyncedAt?.flatMap {
+-     Date(timeIntervalSince1970: $0.epochSeconds)
+- }
++ let time: Date? = db.currentStatus.lastSyncedAt
+```
+
 # 1.0.0-Beta.13
 
 - Update `powersync-kotlin` dependency to version `1.0.0-BETA32`, which includes:

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

@@ -101,19 +101,18 @@ class SupabaseConnector: PowerSyncBackendConnector {
 
                 switch entry.op {
                 case .put:
-                    var data: [String: AnyCodable] = entry.opData?.mapValues { AnyCodable($0) } ?? [:]
-                    data["id"] = AnyCodable(entry.id)
+                    var data = entry.opData ?? [:]
+                    data["id"] = entry.id
                     try await table.upsert(data).execute()
                 case .patch:
                     guard let opData = entry.opData else { continue }
-                    let encodableData = opData.mapValues { AnyCodable($0) }
-                    try await table.update(encodableData).eq("id", value: entry.id).execute()
+                    try await table.update(opData).eq("id", value: entry.id).execute()
                 case .delete:
                     try await table.delete().eq("id", value: entry.id).execute()
                 }
             }
 
-            _ = try await transaction.complete.invoke(p1: nil)
+            try await transaction.complete()
 
         } catch {
             if let errorCode = PostgresFatalCodes.extractErrorCode(from: error),
@@ -127,7 +126,7 @@ class SupabaseConnector: PowerSyncBackendConnector {
                 /// elsewhere instead of discarding, and/or notify the user.
                 print("Data upload error: \(error)")
                 print("Discarding entry: \(lastEntry!)")
-                _ = try await transaction.complete.invoke(p1: nil)
+                try await transaction.complete()
                 return
             }
 

Demo/PowerSyncExample/PowerSync/SupabaseConnector.swift

@@ -127,9 +127,9 @@ class SystemManager {
                 sql: "SELECT photo_id FROM \(TODOS_TABLE) WHERE list_id = ? AND photo_id IS NOT NULL",
                 parameters: [id]
             ) { cursor in
-                // FIXME Transactions should allow throwing in the mapper and should use generics correctly
-                cursor.getString(index: 0) ?? "invalid" // :(
-            } as? [String] // :(
+
+                try cursor.getString(index: 0)
+            }
 
             _ = try transaction.execute(
                 sql: "DELETE FROM \(LISTS_TABLE) WHERE id = ?",
@@ -141,7 +141,7 @@ class SystemManager {
                 parameters: [id]
             )
 
-            return attachmentIDs ?? [] // :(
+            return attachmentIDs
         })
 
         if let attachments {