Fix withAllConnections issue

Author: stevensJourney

Sources/PowerSync/Kotlin/KotlinSQLiteConnectionPool.swift

@@ -71,12 +71,12 @@ final class SwiftSQLiteConnectionPoolAdapter: PowerSyncKotlin.SwiftPoolAdapter {
         // We currently only use this for schema updates
         return try await wrapExceptions {
             let sendableCallback = SendableAllLeaseCallback(callback)
-            try await pool.write { lease in
+            try await pool.withAllConnections { writer, readers in
                 try sendableCallback.execute(
                     writeLease: KotlinLeaseAdapter(
-                        lease: lease
+                        lease: writer
                     ),
-                    readLeases: []
+                    readLeases: readers.map { KotlinLeaseAdapter(lease: $0) }
                 )
             }
         }

Sources/PowerSyncGRDB/Connections/GRDBConnectionPool.swift

@@ -63,25 +63,29 @@ actor GRDBConnectionPool: SQLiteConnectionPoolProtocol {
                     GRDBConnectionLease(database: database)
                 )
             }
-           
+
             return sessionResult
         }
         // Notify PowerSync of these changes
         tableUpdatesContinuation?.yield(result.affectedTables)
         // Notify GRDB, this needs to be a write (transaction)
-        try await  pool.write { database in
+        try await pool.write { database in
             // Notify GRDB about these changes
             for table in result.affectedTables {
                 try database.notifyChanges(in: Table(table))
             }
         }
+
+        if case let .failure(error) = result.blockResult {
+            throw error
+        }
     }
 
     func withAllConnections(
         onConnection: @Sendable @escaping (SQLiteConnectionLease, [SQLiteConnectionLease]) throws -> Void
     ) async throws {
         // FIXME, we currently don't support updating the schema
-        try await pool.write { database in
+        try await pool.writeWithoutTransaction { database in
             let lease = try GRDBConnectionLease(database: database)
             try onConnection(lease, [])
         }