cleanup

Author: stevensJourney

Sources/PowerSync/Kotlin/PowerSyncBackendConnectorAdapter.swift

@@ -1,25 +1,25 @@
 import OSLog
 
-internal class PowerSyncBackendConnectorAdapter: KotlinPowerSyncBackendConnector {
+class PowerSyncBackendConnectorAdapter: KotlinPowerSyncBackendConnector {
     let swiftBackendConnector: PowerSyncBackendConnector
     let db: any PowerSyncDatabaseProtocol
     let logTag = "PowerSyncBackendConnector"
-    
+
     init(
         swiftBackendConnector: PowerSyncBackendConnector,
         db: any PowerSyncDatabaseProtocol
     ) {
         self.swiftBackendConnector = swiftBackendConnector
         self.db = db
     }
-    
+
     override func __fetchCredentials() async throws -> KotlinPowerSyncCredentials? {
         do {
             let result = try await swiftBackendConnector.fetchCredentials()
             return result?.kotlinCredentials
         } catch {
             db.logger.error("Error while fetching credentials", tag: logTag)
-            /// We can't use throwKotlinPowerSyncError here since the Kotlin connector 
+            /// We can't use throwKotlinPowerSyncError here since the Kotlin connector
             /// runs this in a Job - this seems to break the SKIEE error propagation.
             /// returning nil here should still cause a retry
             return nil
@@ -35,7 +35,7 @@ internal class PowerSyncBackendConnectorAdapter: KotlinPowerSyncBackendConnector
             // Relay the error to the Kotlin SDK
             try throwKotlinPowerSyncError(
                 message: "Connector errored while uploading data: \(error.localizedDescription)",
-                cause: error.localizedDescription,
+                cause: error.localizedDescription
             )
         }
     }

Tests/PowerSyncTests/AttachmentTests.swift

@@ -208,10 +208,10 @@ public func waitForMatch<T, E: Error>(
     }
 }
 
-internal func waitFor(
+func waitFor(
     timeout: TimeInterval = 0.5,
     interval: TimeInterval = 0.1,
-    predicate: () async throws -> Void,
+    predicate: () async throws -> Void
 ) async throws {
     let intervalNanoseconds = UInt64(interval * 1_000_000_000)
 
@@ -221,14 +221,14 @@ internal func waitFor(
 
     var lastError: Error?
 
-   while (Date() < timeoutDate) {
-       do {
-           try await predicate()
-           return
-       } catch {
+    while Date() < timeoutDate {
+        do {
+            try await predicate()
+            return
+        } catch {
             lastError = error
-       }
-       try await Task.sleep(nanoseconds: intervalNanoseconds)
+        }
+        try await Task.sleep(nanoseconds: intervalNanoseconds)
     }
 
     throw WaitForMatchError.timeout(