Add tests

Author: ipavlidakis

Sources/StreamVideo/Utils/AudioSession/Policies/LivestreamAudioSessionPolicy.swift

@@ -11,8 +11,9 @@ public struct LivestreamAudioSessionPolicy: AudioSessionPolicy {
     public init() {}
 
     /// Builds the configuration used when a call toggles livestream mode.
-    /// Stereo playout is preferred, but the policy falls back to playback if
-    /// the current user cannot transmit audio.
+    /// Stereo playout is preferred (thus the category and the options), but the policy falls back to playback
+    /// category if the current user cannot transmit audio. A2DP is required to allow external devices
+    /// to play stereo.
     public func configuration(
         for callSettings: CallSettings,
         ownCapabilities: Set<OwnCapability>

Sources/StreamVideo/Utils/AudioSession/RTCAudioStore/Components/RTCAudioSessionPublisher.swift

@@ -28,7 +28,6 @@ final class RTCAudioSessionPublisher: NSObject, RTCAudioSessionDelegate, @unchec
 
     private let source: RTCAudioSession
     private let subject: PassthroughSubject<Event, Never> = .init()
-    private let disposableBag = DisposableBag()
 
     /// Creates a publisher for the provided WebRTC audio session.
     /// - Parameter source: The session to observe.

Sources/StreamVideo/Utils/AudioSession/RTCAudioStore/Namespace/Middleware/RTCAudioStore+InterruptionsMiddleware.swift renamed to Sources/StreamVideo/Utils/AudioSession/RTCAudioStore/Namespace/Effects/RTCAudioStore+InterruptionsEffect.swift

@@ -10,7 +10,7 @@ extension RTCAudioStore {
 
     /// Converts audio session interruption callbacks into store actions so the
     /// audio pipeline can gracefully pause and resume.
-    final class InterruptionsMiddleware: Middleware<RTCAudioStore.Namespace>, @unchecked Sendable {
+    final class InterruptionsEffect: StoreEffect<RTCAudioStore.Namespace>, @unchecked Sendable {
 
         private let audioSessionObserver: RTCAudioSessionPublisher
         private let disposableBag = DisposableBag()

Sources/StreamVideo/Utils/AudioSession/RTCAudioStore/Namespace/Effects/RTCAudioStore+StereoPlayoutEffect.swift

@@ -21,6 +21,8 @@ extension RTCAudioStore {
         ) {
             audioDeviceModuleCancellable?.cancel()
             audioDeviceModuleCancellable = nil
+            processingQueue.cancelAllOperations()
+            disposableBag.removeAll()
 
             guard let statePublisher else {
                 return

Sources/StreamVideo/Utils/AudioSession/RTCAudioStore/Namespace/RTCAudioStore+Namespace.swift

@@ -27,13 +27,13 @@ extension RTCAudioStore {
 
         static func middleware(audioSession: RTCAudioSession) -> [Middleware<RTCAudioStore.Namespace>] {
             [
-                InterruptionsMiddleware(audioSession),
                 AudioDeviceModuleMiddleware()
             ]
         }
 
         static func effects(audioSession: RTCAudioSession) -> Set<StoreEffect<RTCAudioStore.Namespace>> {
             [
+                InterruptionsEffect(audioSession),
                 StereoPlayoutEffect(),
                 RouteChangeEffect(audioSession),
                 AVAudioSessionEffect()

StreamVideo.xcodeproj/project.pbxproj

@@ -0,0 +1,28 @@
+//
+// Copyright © 2025 Stream.io Inc. All rights reserved.
+//
+
+import Combine
+import Foundation
+@testable import StreamVideo
+
+extension StoreNamespace {
+
+    static func makeMockDispatcher() -> MockStoreDispatcher<Self> {
+        .init()
+    }
+}
+
+struct MockStoreDispatcher<Namespace: StoreNamespace>: @unchecked Sendable {
+
+    var recordedActions: [StoreActionBox<Namespace.Action>] { subject.value }
+    var publisher: AnyPublisher<[StoreActionBox<Namespace.Action>], Never> { subject.eraseToAnyPublisher() }
+    private let subject: CurrentValueSubject<[StoreActionBox<Namespace.Action>], Never> = .init([])
+
+    func handle(
+        actions: [StoreActionBox<Namespace.Action>]
+    ) {
+        let value = subject.value
+        subject.send(value + actions)
+    }
+}

StreamVideoTests/Mock/MockStoreDispatcher.swift

@@ -0,0 +1,130 @@
+//
+// Copyright © 2025 Stream.io Inc. All rights reserved.
+//
+
+import AVFoundation
+import Foundation
+@testable import StreamVideo
+
+extension RTCAudioStore.StoreState.AudioRoute {
+
+    static func dummy(
+        inputs: [RTCAudioStore.StoreState.AudioRoute.Port] = [],
+        outputs: [RTCAudioStore.StoreState.AudioRoute.Port] = [],
+        reason: AVAudioSession.RouteChangeReason = .unknown
+    ) -> RTCAudioStore.StoreState.AudioRoute {
+        .init(
+            inputs: inputs,
+            outputs: outputs,
+            reason: reason
+        )
+    }
+}
+
+extension RTCAudioStore.StoreState.AudioRoute.Port {
+
+    static func dummy(
+        type: String = .unique,
+        name: String = .unique,
+        id: String = .unique,
+        isExternal: Bool = false,
+        isSpeaker: Bool = false,
+        isReceiver: Bool = false,
+        channels: Int = 0
+    ) -> RTCAudioStore.StoreState.AudioRoute.Port {
+        .init(
+            type: type,
+            name: name,
+            id: id,
+            isExternal: isExternal,
+            isSpeaker: isSpeaker,
+            isReceiver: isReceiver,
+            channels: channels
+        )
+    }
+}
+
+extension RTCAudioStore.StoreState.AVAudioSessionConfiguration {
+
+    static func dummy(
+        category: AVAudioSession.Category = .soloAmbient,
+        mode: AVAudioSession.Mode = .default,
+        options: AVAudioSession.CategoryOptions = [],
+        overrideOutputAudioPort: AVAudioSession.PortOverride = .none
+    ) -> RTCAudioStore.StoreState.AVAudioSessionConfiguration {
+        .init(
+            category: category,
+            mode: mode,
+            options: options,
+            overrideOutputAudioPort: overrideOutputAudioPort
+        )
+    }
+}
+
+extension RTCAudioStore.StoreState.WebRTCAudioSessionConfiguration {
+
+    static func dummy(
+        isAudioEnabled: Bool = false,
+        useManualAudio: Bool = false,
+        prefersNoInterruptionsFromSystemAlerts: Bool = false
+    ) -> RTCAudioStore.StoreState.WebRTCAudioSessionConfiguration {
+        .init(
+            isAudioEnabled: isAudioEnabled,
+            useManualAudio: useManualAudio,
+            prefersNoInterruptionsFromSystemAlerts: prefersNoInterruptionsFromSystemAlerts
+        )
+    }
+}
+
+extension RTCAudioStore.StoreState.StereoConfiguration {
+
+    static func dummy(
+        playout: RTCAudioStore.StoreState.StereoConfiguration.Playout = .dummy()
+    ) -> RTCAudioStore.StoreState.StereoConfiguration {
+        .init(
+            playout: playout
+        )
+    }
+}
+
+extension RTCAudioStore.StoreState.StereoConfiguration.Playout {
+
+    static func dummy(
+        preferred: Bool = false,
+        enabled: Bool = false
+    ) -> RTCAudioStore.StoreState.StereoConfiguration.Playout {
+        .init(
+            preferred: preferred,
+            enabled: enabled
+        )
+    }
+}
+
+extension RTCAudioStore.StoreState {
+
+    static func dummy(
+        isActive: Bool = false,
+        isInterrupted: Bool = false,
+        isRecording: Bool = false,
+        isMicrophoneMuted: Bool = false,
+        hasRecordingPermission: Bool = false,
+        audioDeviceModule: AudioDeviceModule? = nil,
+        currentRoute: AudioRoute = .dummy(),
+        audioSessionConfiguration: AVAudioSessionConfiguration = .dummy(),
+        webRTCAudioSessionConfiguration: WebRTCAudioSessionConfiguration = .dummy(),
+        stereoConfiguration: StereoConfiguration = .dummy()
+    ) -> RTCAudioStore.StoreState {
+        .init(
+            isActive: isActive,
+            isInterrupted: isInterrupted,
+            isRecording: isRecording,
+            isMicrophoneMuted: isMicrophoneMuted,
+            hasRecordingPermission: hasRecordingPermission,
+            audioDeviceModule: audioDeviceModule,
+            currentRoute: currentRoute,
+            audioSessionConfiguration: audioSessionConfiguration,
+            webRTCAudioSessionConfiguration: webRTCAudioSessionConfiguration,
+            stereoConfiguration: stereoConfiguration
+        )
+    }
+}