[Enhancement]Stereo Playout integration

DemoApp/Sources/Components/AppEnvironment.swift

@@ -554,14 +554,16 @@ extension AppEnvironment {
 extension AppEnvironment {
 
     enum AudioSessionPolicyDebugConfiguration: Hashable, Debuggable, Sendable {
-        case `default`, ownCapabilities
+        case `default`, ownCapabilities, livestream
 
         var title: String {
             switch self {
             case .default:
                 return "Default"
             case .ownCapabilities:
                 return "OwnCapabilities"
+            case .livestream:
+                return "Livestream"
             }
         }
 
@@ -571,12 +573,14 @@ extension AppEnvironment {
                 return DefaultAudioSessionPolicy()
             case .ownCapabilities:
                 return OwnCapabilitiesAudioSessionPolicy()
+            case .livestream:
+                return LivestreamAudioSessionPolicy()
             }
         }
     }
 
     static var audioSessionPolicy: AudioSessionPolicyDebugConfiguration = {
-        .default
+        .livestream
     }()
 }
 
@@ -616,7 +620,7 @@ extension AppEnvironment {
     }
 
     static var proximityPolicies: Set<ProximityPolicyDebugConfiguration> = {
-        [.speaker, .video]
+        []
     }()
 }
 

DemoApp/Sources/Components/MemoryLogDestination/LogQueue.swift

@@ -6,7 +6,12 @@ import Foundation
 import StreamVideo
 
 enum LogQueue {
-    static let queue: Queue<LogDetails> = .init(maxCount: 3000)
+    #if DEBUG
+    private static let queueCapaity = 10000
+    #else
+    private static let queueCapaity = 1000
+    #endif
+    static let queue: Queue<LogDetails> = .init(maxCount: queueCapaity)
 
     static func insert(_ element: LogDetails) { queue.insert(element) }
 

DemoApp/Sources/Views/Login/DebugMenu.swift

@@ -231,7 +231,7 @@ struct DebugMenu: View {
             }
 
             makeMenu(
-                for: [.default, .ownCapabilities],
+                for: [.default, .ownCapabilities, .livestream],
                 currentValue: audioSessionPolicy,
                 label: "AudioSession policy"
             ) { self.audioSessionPolicy = $0 }

Package.swift

@@ -23,7 +23,7 @@ let package = Package(
     ],
     dependencies: [
         .package(url: "https://github.com/apple/swift-protobuf.git", exact: "1.30.0"),
-        .package(url: "https://github.com/GetStream/stream-video-swift-webrtc.git", exact: "137.0.43")
+        .package(url: "https://github.com/GetStream/stream-video-swift-webrtc.git", exact: "137.0.51")
     ],
     targets: [
         .target(

Sources/StreamVideo/Utils/AudioSession/AudioDeviceModule/AudioEngineLevelNodeAdapter.swift

@@ -32,7 +32,6 @@ final class AudioEngineLevelNodeAdapter: AudioEngineNodeAdapting {
 
     var subject: CurrentValueSubject<Float, Never>?
 
-//    private let publisher: (Float) -> Void
     private var inputTap: AVAudioMixerNode?
 
     /// Installs a tap on the supplied audio node to monitor input levels.

Sources/StreamVideo/Utils/AudioSession/AudioDeviceModule/RTCAudioDeviceModuleControlling.swift

@@ -6,22 +6,40 @@ import Combine
 import StreamWebRTC
 
 /// Abstraction over `RTCAudioDeviceModule` so tests can provide fakes while
-/// production code keeps using the WebRTC implementation.
+/// production code continues to rely on the WebRTC-backed implementation.
 protocol RTCAudioDeviceModuleControlling: AnyObject {
     var observer: RTCAudioDeviceModuleDelegate? { get set }
+    var isPlaying: Bool { get }
+    var isRecording: Bool { get }
+    var isPlayoutInitialized: Bool { get }
+    var isRecordingInitialized: Bool { get }
     var isMicrophoneMuted: Bool { get }
+    var isStereoPlayoutEnabled: Bool { get }
+    var isVoiceProcessingBypassed: Bool { get set }
+    var isVoiceProcessingEnabled: Bool { get }
+    var isVoiceProcessingAGCEnabled: Bool { get }
+    var prefersStereoPlayout: Bool { get set }
 
+    func reset() -> Int
+    func initAndStartPlayout() -> Int
+    func startPlayout() -> Int
+    func stopPlayout() -> Int
     func initAndStartRecording() -> Int
     func setMicrophoneMuted(_ isMuted: Bool) -> Int
+    func startRecording() -> Int
     func stopRecording() -> Int
-
-    /// Publisher that emits whenever the microphone mute state changes.
-    func microphoneMutedPublisher() -> AnyPublisher<Bool, Never>
+    func refreshStereoPlayoutState()
 }
 
 extension RTCAudioDeviceModule: RTCAudioDeviceModuleControlling {
-    func microphoneMutedPublisher() -> AnyPublisher<Bool, Never> {
-        publisher(for: \.isMicrophoneMuted)
-            .eraseToAnyPublisher()
+    /// Convenience wrapper that mirrors the old `initPlayout` and
+    /// `startPlayout` sequence so the caller can request playout in one call.
+    func initAndStartPlayout() -> Int {
+        let result = initPlayout()
+        if result == 0 {
+            return startPlayout()
+        } else {
+            return result
+        }
     }
 }

Sources/StreamVideo/Utils/AudioSession/AudioRecorder/Namespace/Middleware/StreamCallAudioRecorder+AVAudioRecorderMiddleware.swift

@@ -22,6 +22,8 @@ extension StreamCallAudioRecorder.Namespace {
     /// ensure thread safety when accessing the recorder instance.
     final class AVAudioRecorderMiddleware: Middleware<StreamCallAudioRecorder.Namespace>, @unchecked Sendable {
 
+        /// Tracks which metering backend is active so we can flip between
+        /// `AVAudioRecorder` and the audio device module seamlessly.
         enum Mode: Equatable {
             case invalid
             case audioRecorder(AVAudioRecorder)
@@ -39,6 +41,8 @@ extension StreamCallAudioRecorder.Namespace {
 
         /// Subscription for publishing meter updates at refresh rate.
         private var updateMetersCancellable: AnyCancellable?
+        /// Listens for ADM availability and pivots the metering source on the
+        /// fly when stereo playout is enabled.
         private var audioDeviceModuleCancellable: AnyCancellable?
 
         init(audioRecorder: AVAudioRecorder? = nil) {

Sources/StreamVideo/Utils/AudioSession/AudioRecorder/Namespace/Middleware/StreamCallAudioRecorder+CategoryMiddleware.swift

@@ -33,6 +33,8 @@ extension StreamCallAudioRecorder.Namespace {
 
             // Monitor for category changes that are incompatible with recording
             cancellable = audioStore
+                // Observe the derived configuration so system-driven category
+                // changes also stop the local recorder.
                 .publisher(\.audioSessionConfiguration.category)
                 .filter { $0 != .playAndRecord && $0 != .record }
                 .sink { [weak self] _ in

Sources/StreamVideo/Utils/AudioSession/AudioSessionConfiguration.swift

@@ -5,7 +5,7 @@
 import AVFoundation
 
 /// Represents the audio session configuration.
-public struct AudioSessionConfiguration: ReflectiveStringConvertible, Equatable, Sendable {
+public struct AudioSessionConfiguration: CustomStringConvertible, Equatable, Sendable {
     var isActive: Bool
     /// The audio session category.
     var category: AVAudioSession.Category
@@ -16,6 +16,17 @@ public struct AudioSessionConfiguration: ReflectiveStringConvertible, Equatable,
     /// The audio session port override.
     var overrideOutputAudioPort: AVAudioSession.PortOverride?
 
+    public var description: String {
+        var result = "{ "
+        result += "isActive:\(isActive)"
+        result += ", category:\(category)"
+        result += ", mode:\(mode)"
+        result += ", options:\(options)"
+        result += ", overrideOutputAudioPort:\(overrideOutputAudioPort)"
+        result += " }"
+        return result
+    }
+
     /// Compares two `AudioSessionConfiguration` instances for equality.
     public static func == (lhs: Self, rhs: Self) -> Bool {
         lhs.isActive == rhs.isActive &&