Fix cron tests (#952)

Author: ipavlidakis

Sources/StreamVideo/Utils/IdleTimerAdapter/IdleTimerAdapter.swift

@@ -4,37 +4,41 @@
 
 // swiftlint:disable discourage_task_init
 
+import Combine
 import Foundation
 #if canImport(UIKit)
 import UIKit
 #endif
 
 final class IdleTimerAdapter: @unchecked Sendable {
 
+    private var observationCancellable: AnyCancellable?
     private(set) var isIdleTimerDisabled: Bool = false
-    private let disposableBag = DisposableBag()
 
-    init(_ streamVideo: StreamVideo) {
+    convenience init(_ streamVideo: StreamVideo) {
+        self.init(streamVideo.state.$activeCall.eraseToAnyPublisher())
+    }
+
+    init(_ publisher: AnyPublisher<Call?, Never>) {
         #if canImport(UIKit)
         Task { @MainActor in
             self.isIdleTimerDisabled = UIApplication.shared.isIdleTimerDisabled
         }
-        streamVideo
-            .state
-            .$activeCall
+        observationCancellable = publisher
             .map { $0 != nil }
-            .sinkTask(storeIn: disposableBag) { @MainActor [weak self] in self?.didUpdate(hasActiveCall: $0) }
-            .store(in: disposableBag)
+            .receive(on: DispatchQueue.main)
+            .sink { [weak self] hasActiveCall in
+                MainActor.assumeIsolated { [weak self] in
+                    UIApplication.shared.isIdleTimerDisabled = hasActiveCall
+                    self?.isIdleTimerDisabled = hasActiveCall
+                }
+            }
         #endif
     }
 
-    // MARK: - Private helpers
-
-    @MainActor
-    private func didUpdate(hasActiveCall: Bool) {
+    deinit {
         #if canImport(UIKit)
-        UIApplication.shared.isIdleTimerDisabled = hasActiveCall
-        isIdleTimerDisabled = hasActiveCall
+        Task { @MainActor in UIApplication.shared.isIdleTimerDisabled = false }
         #endif
     }
 }

StreamVideoTests/Utils/AudioSession/AudioRecorder/Namespace/Middleware/StreamCallAudioRecorder_ShouldRecordMiddlewareTests.swift

@@ -14,6 +14,12 @@ final class StreamCallAudioRecorder_ShouldRecordMiddlewareTests: StreamVideoTest
 
     private lazy var mockAudioStore: MockRTCAudioStore! = .init()
 
+    override func setUp() {
+        super.setUp()
+        _ = PermissionStore.currentValue
+        _ = mockAudioStore
+    }
+
     override func tearDown() {
         mockAudioStore?.dismantle()
         mockAudioStore = nil
@@ -41,6 +47,7 @@ final class StreamCallAudioRecorder_ShouldRecordMiddlewareTests: StreamVideoTest
 
         let call = await MockCall(.dummy())
         try await call.microphone.enable()
+        await fulfilmentInMainActor { call.state.callSettings.audioOn }
         streamVideo.state.activeCall = call
 
         await safeFulfillment(of: [validation])
@@ -64,6 +71,7 @@ final class StreamCallAudioRecorder_ShouldRecordMiddlewareTests: StreamVideoTest
 
         let call = await MockCall(.dummy())
         try await call.microphone.enable()
+        await fulfilmentInMainActor { call.state.callSettings.audioOn }
         streamVideo.state.activeCall = call
 
         await wait(for: 0.1)
@@ -100,6 +108,7 @@ final class StreamCallAudioRecorder_ShouldRecordMiddlewareTests: StreamVideoTest
 
         let call = await MockCall(.dummy())
         try await call.microphone.enable()
+        await fulfilmentInMainActor { call.state.callSettings.audioOn }
         streamVideo.state.activeCall = call
 
         await safeFulfillment(of: [validation])

StreamVideoTests/Utils/IdleTimerAdapter/IdleTimerAdapter_Tests.swift

@@ -2,14 +2,15 @@
 // Copyright © 2025 Stream.io Inc. All rights reserved.
 //
 
+import Combine
 import Foundation
 @testable import StreamVideo
 import XCTest
 
 final class IdleTimerAdapter_Tests: XCTestCase, @unchecked Sendable {
 
-    private var mockStreamVideo: MockStreamVideo! = .init()
-    private lazy var subject: IdleTimerAdapter! = .init(mockStreamVideo)
+    private var activeCallSubject: CurrentValueSubject<Call?, Never>! = .init(nil)
+    private lazy var subject: IdleTimerAdapter! = .init(activeCallSubject.eraseToAnyPublisher())
 
     override func setUp() {
         super.setUp()
@@ -18,37 +19,40 @@ final class IdleTimerAdapter_Tests: XCTestCase, @unchecked Sendable {
 
     override func tearDown() {
         subject = nil
-        mockStreamVideo = nil
+        activeCallSubject.send(nil)
+        activeCallSubject = nil
         super.tearDown()
     }
 
     // MARK: - hasActiveCall
 
     func test_hasActiveCall_isTrue_IdleTimerIsDisabled() async {
-        mockStreamVideo.state.activeCall = .dummy()
+        activeCallSubject.send(.dummy())
 
-        await fulfilmentInMainActor { self.subject.isIdleTimerDisabled == true }
+        await fulfilmentInMainActor {
+            let result = self.subject.isIdleTimerDisabled == true
+            return result
+        }
     }
 
     func test_hasActiveCall_isFalse_IdleTimerIsEnabled() async {
-        mockStreamVideo.state.activeCall = nil
+        activeCallSubject.send(nil)
 
         await fulfilmentInMainActor { self.subject.isIdleTimerDisabled == false }
     }
 
     func test_hasActiveCall_changesFromFalseToTrue_firstIsEnabledThenDisabled() async {
-        mockStreamVideo.state.activeCall = nil
+        activeCallSubject.send(nil)
         await fulfilmentInMainActor { self.subject.isIdleTimerDisabled == false }
 
-        mockStreamVideo.state.activeCall = .dummy()
+        activeCallSubject.send(.dummy())
         await fulfilmentInMainActor { self.subject.isIdleTimerDisabled == true }
     }
 
     func test_hasActiveCall_changesFromTrueToFalse_firstIsDisabledThenEnabled() async {
-        mockStreamVideo.state.activeCall = .dummy()
-        await fulfilmentInMainActor { self.subject.isIdleTimerDisabled == true }
+        activeCallSubject.send(.dummy())
+        activeCallSubject.send(nil)
 
-        mockStreamVideo.state.activeCall = nil
         await fulfilmentInMainActor { self.subject.isIdleTimerDisabled == false }
     }
 }

StreamVideoTests/WebRTC/v2/WebRTCAuthenticator_Tests.swift

@@ -157,11 +157,10 @@ final class WebRTCAuthenticator_Tests: XCTestCase, @unchecked Sendable {
             options: options
         )
 
-        let callSettings = await mockCoordinatorStack
-            .coordinator
-            .stateAdapter
-            .callSettings
-        XCTAssertEqual(callSettings, .init(expected.call.settings))
+        await fulfillment {
+            let callSettings = await self.mockCoordinatorStack.coordinator.stateAdapter.callSettings
+            return callSettings == .init(expected.call.settings)
+        }
     }
 
     func test_authenticate_withCreateFalseAndInitialCallSettings_shouldSetInitialCallSettings() async throws {
@@ -190,11 +189,10 @@ final class WebRTCAuthenticator_Tests: XCTestCase, @unchecked Sendable {
             options: options
         )
 
-        let callSettings = await mockCoordinatorStack
-            .coordinator
-            .stateAdapter
-            .callSettings
-        XCTAssertEqual(callSettings, initialCallSettings)
+        await fulfillment {
+            let callSettings = await self.mockCoordinatorStack.coordinator.stateAdapter.callSettings
+            return callSettings == initialCallSettings
+        }
     }
 
     func test_authenticate_withCreateFalseWithoutInitialCallSettings_shouldSetCallSettingsFromResponse() async throws {
@@ -214,11 +212,10 @@ final class WebRTCAuthenticator_Tests: XCTestCase, @unchecked Sendable {
             options: options
         )
 
-        let callSettings = await mockCoordinatorStack
-            .coordinator
-            .stateAdapter
-            .callSettings
-        XCTAssertEqual(callSettings, .init(expected.call.settings))
+        await fulfillment {
+            let callSettings = await self.mockCoordinatorStack.coordinator.stateAdapter.callSettings
+            return callSettings == .init(expected.call.settings)
+        }
     }
 
     func test_authenticate_updatesVideoOptions() async throws {