update connector for swift 6 in tests

Author: stevensJourney

Sources/PowerSync/Kotlin/KotlinTypes.swift

@@ -1,6 +1,6 @@
 import PowerSyncKotlin
 
-typealias KotlinPowerSyncBackendConnector = PowerSyncKotlin.SwiftPowerSyncBackendConnector
+typealias KotlinPowerSyncBackendConnector = PowerSyncKotlin.PowerSyncBackendConnector
 typealias KotlinPowerSyncCredentials = PowerSyncKotlin.PowerSyncCredentials
 typealias KotlinPowerSyncDatabase = PowerSyncKotlin.PowerSyncDatabase
 

Sources/PowerSync/Kotlin/PowerSyncBackendConnectorAdapter.swift

@@ -29,7 +29,7 @@ final class PowerSyncBackendConnectorAdapter: KotlinPowerSyncBackendConnector,
         }
     }
 
-    override func __performUpload() async throws {
+    override func __uploadData(database _: KotlinPowerSyncDatabase) async throws {
         do {
             // Pass the Swift DB protocal to the connector
             return try await swiftBackendConnector.uploadData(database: db)

Tests/PowerSyncTests/ConnectTests.swift

@@ -38,7 +38,7 @@ final class ConnectTests: XCTestCase {
         /// This is an example of specifying JSON client params.
         /// The test here just ensures that the Kotlin SDK accepts these params and does not crash
         try await database.connect(
-            connector: PowerSyncBackendConnector(),
+            connector: MockConnector(),
             params: [
                 "foo": .string("bar"),
             ]
@@ -50,67 +50,69 @@ final class ConnectTests: XCTestCase {
         XCTAssert(database.currentStatus.connecting == false)
 
         try await database.connect(
-            connector: PowerSyncBackendConnector()
+            connector: MockConnector()
         )
 
         try await waitFor(timeout: 10) {
             guard database.currentStatus.connecting == true else {
                 throw WaitForMatchError.predicateFail(message: "Should be connecting")
             }
         }
-        
+
         try await database.disconnect()
-        
+
         try await waitFor(timeout: 10) {
             guard database.currentStatus.connecting == false else {
                 throw WaitForMatchError.predicateFail(message: "Should not be connecting after disconnect")
             }
         }
     }
-    
+
     func testSyncStatusUpdates() async throws {
         let expectation = XCTestExpectation(
             description: "Watch Sync Status"
         )
-        
+
         let watchTask = Task { [database] in
             for try await _ in database!.currentStatus.asFlow() {
                 expectation.fulfill()
             }
         }
-        
+
         // Do some connecting operations
         try await database.connect(
-            connector: PowerSyncBackendConnector()
+            connector: MockConnector()
         )
-        
+
         // We should get an update
         await fulfillment(of: [expectation], timeout: 5)
         watchTask.cancel()
     }
-    
+
     func testSyncHTTPLogs() async throws {
         let expectation = XCTestExpectation(
             description: "Should log a request to the PowerSync endpoint"
         )
-        
+
         let fakeUrl = "https://fakepowersyncinstance.fakepowersync.local"
-        
-        class TestConnector: PowerSyncBackendConnector {
+
+        final class TestConnector: PowerSyncBackendConnectorProtocol {
             let url: String
-            
+
             init(url: String) {
                 self.url = url
             }
-            
-            override func fetchCredentials() async throws -> PowerSyncCredentials? {
+
+            func fetchCredentials() async throws -> PowerSyncCredentials? {
                 PowerSyncCredentials(
                     endpoint: url,
                     token: "123"
                 )
             }
+
+            func uploadData(database _: PowerSyncDatabaseProtocol) async throws {}
         }
-        
+
         try await database.connect(
             connector: TestConnector(url: fakeUrl),
             options: ConnectOptions(
@@ -126,9 +128,9 @@ final class ConnectTests: XCTestCase {
                 )
             )
         )
-        
+
         await fulfillment(of: [expectation], timeout: 5)
-        
+
         try await database.disconnectAndClear()
     }
 }

Tests/PowerSyncTests/test-utils/MockConnector.swift

@@ -1,5 +1,9 @@
 import PowerSync
 
-class MockConnector: PowerSyncBackendConnector {
-    
+final class MockConnector: PowerSyncBackendConnectorProtocol {
+    func fetchCredentials() async throws -> PowerSync.PowerSyncCredentials? {
+        return nil
+    }
+
+    func uploadData(database _: any PowerSync.PowerSyncDatabaseProtocol) async throws {}
 }