update sync status sendable status. Update logger usage in tests.

Author: stevensJourney

Sources/PowerSync/Kotlin/sync/KotlinSyncStatusData.swift

@@ -103,11 +103,17 @@ extension KotlinProgressWithOperationsProtocol {
     }
 }
 
-struct KotlinProgressWithOperations: KotlinProgressWithOperationsProtocol {
+struct KotlinProgressWithOperations: KotlinProgressWithOperationsProtocol,
+    // We can't mark  PowerSyncKotlin.ProgressWithOperations as Sendable
+    @unchecked Sendable
+{
     let base: PowerSyncKotlin.ProgressWithOperations
 }
 
-struct KotlinSyncDownloadProgress: KotlinProgressWithOperationsProtocol, SyncDownloadProgress {
+struct KotlinSyncDownloadProgress: KotlinProgressWithOperationsProtocol, SyncDownloadProgress,
+    // We can't mark  PowerSyncKotlin.SyncDownloadProgress as Sendable
+    @unchecked Sendable
+{
     let progress: PowerSyncKotlin.SyncDownloadProgress
 
     var base: any PowerSyncKotlin.ProgressWithOperations {

Sources/PowerSync/Logger.swift

@@ -3,15 +3,10 @@ import OSLog
 /// A log writer which prints to the standard output
 ///
 /// This writer uses `os.Logger` on iOS/macOS/tvOS/watchOS 14+ and falls back to `print` for earlier versions.
-public class PrintLogWriter: LogWriterProtocol {
+public final class PrintLogWriter: LogWriterProtocol {
     private let subsystem: String
     private let category: String
-    private lazy var logger: Any? = {
-        if #available(iOS 14.0, macOS 11.0, tvOS 14.0, watchOS 7.0, *) {
-            return Logger(subsystem: subsystem, category: category)
-        }
-        return nil
-    }()
+    private let logger: Sendable?
 
     /// Creates a new PrintLogWriter
     /// - Parameters:
@@ -22,6 +17,12 @@ public class PrintLogWriter: LogWriterProtocol {
     {
         self.subsystem = subsystem
         self.category = category
+
+        if #available(iOS 14.0, macOS 11.0, tvOS 14.0, watchOS 7.0, *) {
+            logger = Logger(subsystem: subsystem, category: category)
+        } else {
+            logger = nil
+        }
     }
 
     /// Logs a message with a given severity and optional tag.

Tests/PowerSyncTests/Kotlin/KotlinPowerSyncDatabaseImplTests.swift

@@ -521,7 +521,7 @@ final class KotlinPowerSyncDatabaseImplTests: XCTestCase {
 
         try await db2.close()
 
-        let warningIndex = testWriter.logs.firstIndex(
+        let warningIndex = testWriter.getLogs().firstIndex(
             where: { value in
                 value.contains("warning: Multiple PowerSync instances for the same database have been detected")
             }
@@ -542,7 +542,7 @@ final class KotlinPowerSyncDatabaseImplTests: XCTestCase {
 
         try await db2.close()
 
-        let warningIndex = testWriter.logs.firstIndex(
+        let warningIndex = testWriter.getLogs().firstIndex(
             where: { value in
                 value.contains("warning: Multiple PowerSync instances for the same database have been detected")
             }

Tests/PowerSyncTests/Kotlin/TestLogger.swift

@@ -1,11 +1,23 @@
+import Foundation
 @testable import PowerSync
 
+final class TestLogWriterAdapter: LogWriterProtocol,
+    // The shared state is guarded by the DispatchQueue
+    @unchecked Sendable
+{
+    private let queue = DispatchQueue(label: "TestLogWriterAdapter")
+
+    private var logs = [String]()
+
+    func getLogs() -> [String] {
+        queue.sync {
+            logs
+        }
+    }
 
-class TestLogWriterAdapter: LogWriterProtocol {
-    var logs = [String]()
-    
     func log(severity: LogSeverity, message: String, tag: String?) {
-        logs.append("\(severity): \(message) \(tag != nil ? "\(tag!)" : "")")
+        queue.sync {
+            logs.append("\(severity): \(message) \(tag != nil ? "\(tag!)" : "")")
+        }
     }
 }
-