fix: remove need for main thread

Author: DominicGBauer

Sources/PowerSyncSwift/Kotlin/KotlinPowerSyncDatabaseImpl.swift

@@ -117,14 +117,12 @@ final class KotlinPowerSyncDatabaseImpl: PowerSyncDatabaseProtocol {
         }
     }
 
-    @MainActor
     public func writeTransaction<R>(callback: @escaping (any PowerSyncTransaction) async throws -> R) async throws -> R {
         return try await kmpDatabase.writeTransaction(callback: SuspendTaskWrapper { transaction in
             return try await callback(transaction)
         }) as! R
     }
 
-    @MainActor
     public func readTransaction<R>(callback: @escaping (any PowerSyncTransaction) async throws -> R) async throws -> R {
         return try await kmpDatabase.writeTransaction(callback: SuspendTaskWrapper { transaction in
             return try await callback(transaction)
@@ -136,24 +134,22 @@ enum PowerSyncError: Error {
     case invalidTransaction
 }
 
-@MainActor
 class SuspendTaskWrapper: KotlinSuspendFunction1 {
     let handle: (any PowerSyncTransaction) async throws -> Any
 
     init(_ handle: @escaping (any PowerSyncTransaction) async throws -> Any) {
         self.handle = handle
     }
 
-    nonisolated func __invoke(p1: Any?, completionHandler: @escaping (Any?, Error?) -> Void) {
-        DispatchQueue.main.async {
-            Task { @MainActor in
-                do {
-                    let result = try await self.handle(p1 as! any PowerSyncTransaction)
-                    completionHandler(result, nil)
-                } catch {
-                    completionHandler(nil, error)
-                }
+    func __invoke(p1: Any?, completionHandler: @escaping (Any?, Error?) -> Void) {
+        Task {
+            do {
+                let result = try await self.handle(p1 as! any PowerSyncTransaction)
+                completionHandler(result, nil)
+            } catch {
+                completionHandler(nil, error)
             }
         }
     }
 }
+

Sources/PowerSyncSwift/PowerSyncDatabase.swift

@@ -8,7 +8,6 @@ public let DEFAULT_DB_FILENAME = "powersync.db"
 ///   - schema: The database schema
 ///   - dbFilename: The database filename. Defaults to "powersync.db"
 /// - Returns: A configured PowerSyncDatabase instance
-@MainActor
 public func PowerSyncDatabase(
     schema: Schema,
     dbFilename: String = DEFAULT_DB_FILENAME

Tests/PowerSyncSwiftTests/Kotlin/KotlinPowerSyncDatabaseImplTests.swift

@@ -18,6 +18,7 @@ final class KotlinPowerSyncDatabaseImplTests: XCTestCase {
             schema: schema,
             dbFilename: ":memory:"
         )
+        try await database.disconnectAndClear()
     }
 
     override func tearDown() async throws {
@@ -130,13 +131,17 @@ final class KotlinPowerSyncDatabaseImplTests: XCTestCase {
          XCTAssertEqual(results[1], ["User 1", "User 2"])
      }
 
-    @MainActor
     func testWriteTransaction() async throws {
         try await database.writeTransaction { transaction in
             _ = try await transaction.execute(
                 sql: "INSERT INTO users (id, name, email) VALUES (?, ?, ?)",
                 parameters: ["1", "Test User", "test@example.com"]
             )
+            
+            _ = try await transaction.execute(
+                sql: "INSERT INTO users (id, name, email) VALUES (?, ?, ?)",
+                parameters: ["2", "Test User 2", "test2@example.com"]
+            )
         }
 
 
@@ -147,10 +152,9 @@ final class KotlinPowerSyncDatabaseImplTests: XCTestCase {
             cursor.getLong(index: 0)
         }
 
-        XCTAssertEqual(result as! Int, 1)
+        XCTAssertEqual(result as! Int, 2)
     }
 
-    @MainActor
     func testReadTransaction() async throws {
         _ = try await database.execute(
             sql: "INSERT INTO users (id, name, email) VALUES (?, ?, ?)",