[Fix]Tests and Warnings on Xcode 26 (#953)

Author: ipavlidakis

Sources/StreamVideo/CallKit/CallKitService.swift

@@ -121,7 +121,7 @@ open class CallKitService: NSObject, CXProviderDelegate, @unchecked Sendable {
         localizedCallerName: String,
         callerId: String,
         hasVideo: Bool = false,
-        completion: @escaping (Error?) -> Void
+        completion: @Sendable @escaping (Error?) -> Void
     ) {
         let (callUUID, callUpdate) = buildCallUpdate(
             cid: cid,

Sources/StreamVideo/Utils/Extensions/Combine/Publisher+AsyncStream.swift

@@ -53,14 +53,13 @@ public extension Publisher where Output: Sendable {
         function: StaticString = #function,
         line: UInt = #line
     ) async throws -> Output {
-        nonisolated(unsafe) let selfReference = self
-        return try await Task(
+        try await Task(
             timeoutInSeconds: timeoutInSeconds,
             file: file,
             function: function,
             line: line
-        ) {
-            try await selfReference.firstValue(file: file, line: line)
+        ) { [self] in
+            try await self.firstValue(file: file, line: line)
         }.value
     }
 

Sources/StreamVideo/Utils/Logger/Logger.swift

@@ -239,18 +239,19 @@ public enum LogConfig {
         }
     }
 
-    nonisolated(unsafe) private static var _destinations: [LogDestination]?
+    private static let _destinations: AtomicStorage<[LogDestination]?> = .init(nil)
 
     /// Destinations for the default logger. Please see `LogDestination`.
     /// Defaults to only `ConsoleLogDestination`, which only prints the messages.
     ///
     /// - Important: Other options in `ChatClientConfig.Logging` will not take affect if this is changed.
     public static var destinations: [LogDestination] {
         get {
-            if let destinations = _destinations {
+            if let destinations = _destinations.get() {
                 return destinations
             } else {
-                _destinations = destinationTypes.map {
+                let _destinationTypes = destinationTypes
+                let newDestinations = _destinationTypes.map {
                     $0.init(
                         identifier: identifier,
                         level: level,
@@ -266,12 +267,13 @@ public enum LogConfig {
                         showFunctionName: showFunctionName
                     )
                 }
-                return _destinations!
+                _destinations.set(newDestinations)
+                return newDestinations
             }
         }
         set {
             invalidateLogger()
-            _destinations = newValue
+            _destinations.set(newValue)
         }
     }
 
@@ -303,25 +305,29 @@ public enum LogConfig {
     /// Invalidates the current logger instance so it can be recreated.
     private static func invalidateLogger() {
         _logger = nil
-        _destinations = nil
+        _destinations.set(nil)
     }
 }
 
 /// Entity used for logging messages.
-public class Logger {
+public class Logger: @unchecked Sendable {
     /// Identifier of the Logger. Will be visible if a destination has `showIdentifiers` enabled.
     public let identifier: String
 
     /// Destinations for this logger.
     /// See `LogDestination` protocol for details.
-    public var destinations: [LogDestination]
-    
+    @Atomic private var _destinations: [LogDestination]
+    public var destinations: [LogDestination] {
+        get { _destinations }
+        set { _destinations = newValue }
+    }
+
     private let loggerQueue = DispatchQueue(label: "LoggerQueue \(UUID())")
 
     /// Init a logger with a given identifier and destinations.
     public init(identifier: String = "", destinations: [LogDestination] = []) {
         self.identifier = identifier
-        self.destinations = destinations
+        _destinations = destinations
     }
 
     /// Allows logger to be called as function.
@@ -371,23 +377,33 @@ public class Logger {
         subsystems: LogSubsystem = .other,
         error: Error?
     ) {
-        let enabledDestinations = destinations.filter { $0.isEnabled(level: level, subsystems: subsystems) }
-        guard !enabledDestinations.isEmpty else { return }
-        
-        let logDetails = LogDetails(
-            loggerIdentifier: identifier,
-            subsystem: subsystems,
-            level: level,
-            date: Date(),
-            message: String(describing: message()),
-            threadName: threadName,
-            functionName: functionName,
-            fileName: fileName,
-            lineNumber: lineNumber,
-            error: error
-        )
-        for destination in enabledDestinations {
-            loggerQueue.async {
+        let resolvedMessage = String(describing: message())
+        let resolvedError = error
+        let resolvedThreadName = threadName
+        let timestamp = Date()
+        let loggerIdentifier = identifier
+        let destinations = self.destinations
+
+        loggerQueue.async {
+            let enabledDestinations = destinations.filter {
+                $0.isEnabled(level: level, subsystems: subsystems)
+            }
+            guard !enabledDestinations.isEmpty else { return }
+
+            let logDetails = LogDetails(
+                loggerIdentifier: loggerIdentifier,
+                subsystem: subsystems,
+                level: level,
+                date: timestamp,
+                message: resolvedMessage,
+                threadName: resolvedThreadName,
+                functionName: functionName,
+                fileName: fileName,
+                lineNumber: lineNumber,
+                error: resolvedError
+            )
+
+            for destination in enabledDestinations {
                 destination.process(logDetails: logDetails)
             }
         }
@@ -588,3 +604,15 @@ extension Data {
         }
     }
 }
+
+final class AtomicStorage<Element>: @unchecked Sendable {
+
+    private let queue = UnfairQueue()
+    private var value: Element
+
+    init(_ initial: Element) { value = initial }
+
+    func get() -> Element { queue.sync { value } }
+
+    func set(_ newValue: Element) { queue.sync { value = newValue } }
+}

Sources/StreamVideo/Utils/PermissionsStore/Namespace/Components/CameraPermissionProvider.swift

@@ -13,7 +13,7 @@ protocol CameraPermissionProviding {
 
     /// Requests camera permission from the user.
     /// - Parameter completion: Called with `true` if permission granted.
-    func requestPermission(_ completion: @escaping (Bool) -> Void)
+    func requestPermission(_ completion: @Sendable @escaping (Bool) -> Void)
 }
 
 /// Default implementation for camera permission management using AVFoundation.
@@ -33,7 +33,7 @@ final class StreamCameraPermissionProvider: CameraPermissionProviding {
         }
     }
 
-    func requestPermission(_ completion: @escaping (Bool) -> Void) {
+    func requestPermission(_ completion: @Sendable @escaping (Bool) -> Void) {
         AVCaptureDevice
             .requestAccess(for: .video, completionHandler: completion)
     }

Sources/StreamVideo/Utils/PermissionsStore/Namespace/Components/MicrophonePermissionProvider.swift

@@ -13,7 +13,7 @@ protocol MicrophonePermissionProviding {
 
     /// Requests microphone permission from the user.
     /// - Parameter completion: Called with `true` if permission granted.
-    func requestPermission(_ completion: @escaping (Bool) -> Void)
+    func requestPermission(_ completion: @Sendable @escaping (Bool) -> Void)
 }
 
 /// Default implementation for microphone permission management using
@@ -45,7 +45,7 @@ final class StreamMicrophonePermissionProvider: MicrophonePermissionProviding {
         }
     }
 
-    func requestPermission(_ completion: @escaping (Bool) -> Void) {
+    func requestPermission(_ completion: @Sendable @escaping (Bool) -> Void) {
         if #available(iOS 17.0, *) {
             AVAudioApplication
                 .requestRecordPermission(completionHandler: completion)

Sources/StreamVideo/Utils/PermissionsStore/Namespace/Components/PushNotificationsPermissionProvider.swift

@@ -18,7 +18,7 @@ protocol PushNotificationsPermissionProviding {
     ///   - completion: Called with grant status and optional error.
     func requestPermission(
         with options: UNAuthorizationOptions,
-        _ completion: @escaping (Bool, Error?) -> Void
+        _ completion: @Sendable @escaping (Bool, Error?) -> Void
     )
 }
 
@@ -56,7 +56,7 @@ final class StreamPushNotificationsPermissionProvider: PushNotificationsPermissi
 
     func requestPermission(
         with options: UNAuthorizationOptions,
-        _ completion: @escaping (Bool, Error?) -> Void
+        _ completion: @Sendable @escaping (Bool, Error?) -> Void
     ) {
         UNUserNotificationCenter
             .current()

Sources/StreamVideo/Utils/Store/StoreNamespace.swift

@@ -39,7 +39,7 @@ import Foundation
 /// ```swift
 /// let store = MyFeature.store(initialState: .default)
 /// ```
-protocol StoreNamespace {
+protocol StoreNamespace: Sendable {
     /// The state type managed by this store.
     ///
     /// Must be `Equatable` to enable change detection for publishers.

Sources/StreamVideo/WebRTC/Screensharing/BroadcastBufferReader.swift

@@ -8,7 +8,7 @@ import Foundation
 import StreamWebRTC
 
 private class Message {
-    nonisolated(unsafe) static let imageContextVar: CIContext? = {
+    static let imageContextVar: CIContext? = {
         var imageContext = CIContext(options: nil)
         return imageContext
     }()

Sources/StreamVideo/WebRTC/v2/Extensions/AVFoundation/AVAudioRecorder+Sendable.swift

@@ -5,8 +5,6 @@
 import AVFoundation
 import Combine
 
-#if compiler(>=6.0)
-extension AVAudioRecorder: @retroactive @unchecked Sendable {}
-#else
+#if compiler(<6.0)
 extension AVAudioRecorder: @unchecked Sendable {}
 #endif

Sources/StreamVideo/WebRTC/v2/VideoCapturing/ActionHandlers/Camera/CameraInterruptionsHandler.swift

@@ -134,6 +134,10 @@ extension AVCaptureSession.InterruptionReason {
             return ".videoDeviceNotAvailableWithMultipleForegroundApps"
         case .videoDeviceNotAvailableDueToSystemPressure:
             return ".videoDeviceNotAvailableDueToSystemPressure"
+        #if compiler(>=6.2)
+        case .sensitiveContentMitigationActivated:
+            return ".sensitiveContentMitigationActivated"
+        #endif
         @unknown default:
             return "\(self)"
         }