Avoid importing Kotlin in interface

Author: simolus3

Package.swift

@@ -32,8 +32,8 @@ if let kotlinSdkPath = localKotlinSdkOverride {
     // Not using a local build, so download from releases
     conditionalTargets.append(.binaryTarget(
         name: "PowerSyncKotlin",
-        url: "https://github.com/powersync-ja/powersync-kotlin/releases/download/v1.5.1/PowersyncKotlinRelease.zip",
-        checksum: "3a2de1863d2844d49cebf4428d0ab49956ba384dcab9f3cc2ddbc7836013c434"
+        url: "https://github.com/powersync-ja/powersync-kotlin/releases/download/v1.6.0/PowersyncKotlinRelease.zip",
+        checksum: "4f70331c11e30625eecf4ebcebe7b562e2e0165774890d2a43480ebc3a9081cc"
     ))
 }
 

Sources/PowerSync/Kotlin/KotlinPowerSyncDatabaseImpl.swift

@@ -75,8 +75,8 @@ final class KotlinPowerSyncDatabaseImpl: PowerSyncDatabaseProtocol,
         )
     }
 
-    func getCrudTransactions() -> CrudTransactions {
-        return CrudTransactions(db: kotlinDatabase)
+    func getCrudTransactions() -> any CrudTransactions {
+        return KotlinCrudTransactions(db: kotlinDatabase)
     }
 
     func getPowerSyncVersion() async throws -> String {

Sources/PowerSync/Kotlin/db/KotlinCrudTransactions.swift

@@ -0,0 +1,39 @@
+import PowerSyncKotlin
+
+struct KotlinCrudTransactions: CrudTransactions {
+    typealias Element = KotlinCrudTransaction
+    
+    private let db: KotlinPowerSyncDatabase
+    
+    init(db: KotlinPowerSyncDatabase) {
+        self.db = db
+    }
+    
+    public func makeAsyncIterator() -> CrudTransactionIterator {
+        let kotlinIterator = errorHandledCrudTransactions(db: self.db).makeAsyncIterator()
+        return CrudTransactionIterator(inner: kotlinIterator)
+    }
+    
+    struct CrudTransactionIterator: CrudTransactionsIterator {
+        private var inner: PowerSyncKotlin.SkieSwiftFlowIterator<PowerSyncKotlin.PowerSyncResult>
+        
+        internal init(inner: PowerSyncKotlin.SkieSwiftFlowIterator<PowerSyncKotlin.PowerSyncResult>) {
+            self.inner = inner
+        }
+        
+        public mutating func next() async throws -> KotlinCrudTransaction? {
+            if let innerTx = await self.inner.next() {
+                if let success = innerTx as? PowerSyncResult.Success {
+                    let tx = success.value as! PowerSyncKotlin.CrudTransaction
+                    return try KotlinCrudTransaction(transaction: tx)
+                } else if let failure = innerTx as? PowerSyncResult.Failure {
+                    try throwPowerSyncException(exception: failure.exception)
+                }
+            
+                fatalError("unreachable")
+            } else {
+                return nil
+            }
+        }
+    }
+}

Sources/PowerSync/Protocol/PowerSyncDatabaseProtocol.swift

@@ -205,7 +205,7 @@ public protocol PowerSyncDatabaseProtocol: Queries, Sendable {
     /// ```Swift
     ///
     /// ```
-    func getCrudTransactions() -> CrudTransactions
+    func getCrudTransactions() -> any CrudTransactions
 
     /// Convenience method to get the current version of PowerSync.
     func getPowerSyncVersion() async throws -> String

Sources/PowerSync/Protocol/db/CrudTransaction.swift

@@ -1,5 +1,4 @@
 import Foundation
-import PowerSyncKotlin
 
 /// A transaction of client-side changes.
 public protocol CrudTransaction: Sendable {
@@ -29,40 +28,7 @@ public extension CrudTransaction {
 /// A sequence of crud transactions in a PowerSync database.
 ///
 /// For details, see ``PowerSyncDatabaseProtocol/getCrudTransactions()``.
-public struct CrudTransactions: AsyncSequence {
-    private let db: KotlinPowerSyncDatabase
-    
-    init(db: KotlinPowerSyncDatabase) {
-        self.db = db
-    }
-    
-    public func makeAsyncIterator() -> CrudTransactionIterator {
-        let kotlinIterator = errorHandledCrudTransactions(db: self.db).makeAsyncIterator()
-        return CrudTransactionIterator(inner: kotlinIterator)
-    }
-    
-    public struct CrudTransactionIterator: AsyncIteratorProtocol {
-        public typealias Element = any CrudTransaction
-        
-        private var inner: PowerSyncKotlin.SkieSwiftFlowIterator<PowerSyncKotlin.PowerSyncResult>
-        
-        internal init(inner: PowerSyncKotlin.SkieSwiftFlowIterator<PowerSyncKotlin.PowerSyncResult>) {
-            self.inner = inner
-        }
-        
-        public mutating func next() async throws -> (any CrudTransaction)? {
-            if let innerTx = await self.inner.next() {
-                if let success = innerTx as? PowerSyncResult.Success {
-                    let tx = success.value as! PowerSyncKotlin.CrudTransaction
-                    return try KotlinCrudTransaction(transaction: tx)
-                } else if let failure = innerTx as? PowerSyncResult.Failure {
-                    try throwPowerSyncException(exception: failure.exception)
-                }
-            
-                fatalError("unreachable")
-            } else {
-                return nil
-            }
-        }
-    }
-}
+public protocol CrudTransactions: AsyncSequence where Element: CrudTransaction, AsyncIterator: CrudTransactionsIterator {}
+
+/// The iterator returned by ``CrudTransactions``.
+public protocol CrudTransactionsIterator: AsyncIteratorProtocol where Element: CrudTransaction {}