Cleanup

Author: ipavlidakis

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

@@ -181,7 +181,6 @@ final class AudioDeviceModule: NSObject, RTCAudioDeviceModuleDelegate, Encodable
             ", isVoiceProcessingAGCEnabled:\(isVoiceProcessingAGCEnabled)" +
             ", audioLevel:\(audioLevel)" +
             ", source:\(source)" +
-            ", engineOutput: \(engine?.outputDescription ?? "-")" +
             " }"
     }
 
@@ -321,10 +320,6 @@ final class AudioDeviceModule: NSObject, RTCAudioDeviceModuleDelegate, Encodable
         source.refreshStereoPlayoutState()
     }
 
-    func setVoiceProcessingBypassed(_ value: Bool) {
-        source.isVoiceProcessingBypassed = value
-    }
-
     // MARK: - RTCAudioDeviceModuleDelegate
 
     /// Receives speech activity notifications emitted by WebRTC VAD.
@@ -569,32 +564,3 @@ final class AudioDeviceModule: NSObject, RTCAudioDeviceModuleDelegate, Encodable
         )
     }
 }
-
-extension AVAudioEngine {
-
-    /// Human-readable description of the current output node format, used in
-    /// logs when debugging device routing issues.
-    var outputDescription: String {
-        guard let remoteIO = outputNode.audioUnit else {
-            return "not available"
-        }
-
-        var asbd = AudioStreamBasicDescription()
-        var size = UInt32(MemoryLayout<AudioStreamBasicDescription>.size)
-
-        let status = AudioUnitGetProperty(
-            remoteIO,
-            kAudioUnitProperty_StreamFormat,
-            kAudioUnitScope_Output,
-            0,
-            &asbd,
-            &size
-        )
-
-        guard status == noErr else {
-            return "failed to fetch information"
-        }
-
-        return "\(asbd.mChannelsPerFrame) ch @ \(asbd.mSampleRate) Hz"
-    }
-}

StreamVideoTests/Mock/MockAudioSession.swift

@@ -21,6 +21,7 @@ final class MockAudioSession: AudioSessionProtocol, Mockable, @unchecked Sendabl
         case setActive
         case overrideOutputAudioPort
         case setConfiguration
+        case setPreferredOutputNumberOfChannels
     }
 
     enum MockFunctionInputKey: Payloadable {
@@ -33,6 +34,7 @@ final class MockAudioSession: AudioSessionProtocol, Mockable, @unchecked Sendabl
         case setActive(Bool)
         case overrideOutputAudioPort(AVAudioSession.PortOverride)
         case setConfiguration(RTCAudioSessionConfiguration)
+        case setPreferredOutputNumberOfChannels(Int)
 
         var payload: Any {
             switch self {
@@ -62,6 +64,9 @@ final class MockAudioSession: AudioSessionProtocol, Mockable, @unchecked Sendabl
 
             case let .setConfiguration(configuration):
                 return configuration
+
+            case let .setPreferredOutputNumberOfChannels(value):
+                return value
             }
         }
     }
@@ -183,4 +188,13 @@ final class MockAudioSession: AudioSessionProtocol, Mockable, @unchecked Sendabl
         mode = configuration.mode
         categoryOptions = configuration.categoryOptions
     }
+
+    func setPreferredOutputNumberOfChannels(_ noOfChannels: Int) throws {
+        stubbedFunctionInput[.setPreferredOutputNumberOfChannels]?
+            .append(.setPreferredOutputNumberOfChannels(noOfChannels))
+
+        if let error = stubbedFunction[.setPreferredOutputNumberOfChannels] as? Error {
+            throw error
+        }
+    }
 }

StreamVideoTests/Mock/MockRTCAudioDeviceModule.swift

@@ -15,30 +15,61 @@ final class MockRTCAudioDeviceModule: RTCAudioDeviceModuleControlling, Mockable,
     typealias FunctionInputKey = MockFunctionInputKey
 
     enum MockFunctionKey: Hashable, CaseIterable {
-        case initAndStartRecording
-        case stopRecording
         case setMicrophoneMuted
         case microphoneMutedPublisher
+        case reset
+        case initAndStartPlayout
+        case startPlayout
+        case stopPlayout
+        case initAndStartRecording
+        case startRecording
+        case stopRecording
+        case refreshStereoPlayoutState
     }
 
     enum MockFunctionInputKey: Payloadable {
-        case initAndStartRecording
-        case stopRecording
         case setMicrophoneMuted(Bool)
         case microphoneMutedPublisher
+        case reset
+        case initAndStartPlayout
+        case startPlayout
+        case stopPlayout
+        case initAndStartRecording
+        case startRecording
+        case stopRecording
+        case refreshStereoPlayoutState
 
         var payload: Any {
             switch self {
+
+            case .setMicrophoneMuted(let value):
+                return value
+
+            case .microphoneMutedPublisher:
+                return ()
+
+            case .reset:
+                return ()
+
+            case .initAndStartPlayout:
+                return ()
+
+            case .startPlayout:
+                return ()
+
+            case .stopPlayout:
+                return ()
+
             case .initAndStartRecording:
                 return ()
 
-            case .stopRecording:
+            case .startRecording:
                 return ()
 
-            case .setMicrophoneMuted(let value):
-                return value
+            case .stopRecording:
+                return ()
 
-            case .microphoneMutedPublisher:
+            case .refreshStereoPlayoutState:
                 return ()
             }
         }
@@ -59,6 +90,26 @@ final class MockRTCAudioDeviceModule: RTCAudioDeviceModuleControlling, Mockable,
 
     init() {
         stub(for: \.isMicrophoneMuted, with: false)
+        stub(for: \.isPlaying, with: false)
+        stub(for: \.isRecording, with: false)
+        stub(for: \.isPlayoutInitialized, with: false)
+        stub(for: \.isRecordingInitialized, with: false)
+        stub(for: \.isMicrophoneMuted, with: false)
+        stub(for: \.isStereoPlayoutEnabled, with: false)
+        stub(for: \.isVoiceProcessingBypassed, with: false)
+        stub(for: \.isVoiceProcessingEnabled, with: false)
+        stub(for: \.isVoiceProcessingAGCEnabled, with: false)
+        stub(for: \.prefersStereoPlayout, with: false)
+
+        stub(for: .initAndStartRecording, with: 0)
+        stub(for: .setMicrophoneMuted, with: 0)
+        stub(for: .stopRecording, with: 0)
+        stub(for: .reset, with: 0)
+        stub(for: .initAndStartPlayout, with: 0)
+        stub(for: .startPlayout, with: 0)
+        stub(for: .stopPlayout, with: 0)
+        stub(for: .startRecording, with: 0)
+        stub(for: .refreshStereoPlayoutState, with: 0)
     }
 
     // MARK: - RTCAudioDeviceModuleControlling
@@ -67,9 +118,46 @@ final class MockRTCAudioDeviceModule: RTCAudioDeviceModuleControlling, Mockable,
 
     var observer: (any RTCAudioDeviceModuleDelegate)?
 
+    var isPlaying: Bool {
+        self[dynamicMember: \.isPlaying]
+    }
+
+    var isRecording: Bool {
+        self[dynamicMember: \.isRecording]
+    }
+
+    var isPlayoutInitialized: Bool {
+        self[dynamicMember: \.isPlayoutInitialized]
+    }
+
+    var isRecordingInitialized: Bool {
+        self[dynamicMember: \.isRecordingInitialized]
+    }
+
     var isMicrophoneMuted: Bool {
-        get { self[dynamicMember: \.isMicrophoneMuted] }
-        set { _ = newValue }
+        self[dynamicMember: \.isMicrophoneMuted]
+    }
+
+    var isStereoPlayoutEnabled: Bool {
+        self[dynamicMember: \.isStereoPlayoutEnabled]
+    }
+
+    var isVoiceProcessingBypassed: Bool {
+        get { self[dynamicMember: \.isVoiceProcessingBypassed] }
+        set { stub(for: \.isVoiceProcessingBypassed, with: newValue) }
+    }
+
+    var isVoiceProcessingEnabled: Bool {
+        self[dynamicMember: \.isVoiceProcessingEnabled]
+    }
+
+    var isVoiceProcessingAGCEnabled: Bool {
+        self[dynamicMember: \.isVoiceProcessingAGCEnabled]
+    }
+
+    var prefersStereoPlayout: Bool {
+        get { self[dynamicMember: \.prefersStereoPlayout] }
+        set { stub(for: \.prefersStereoPlayout, with: newValue) }
     }
 
     func initAndStartRecording() -> Int {
@@ -81,7 +169,7 @@ final class MockRTCAudioDeviceModule: RTCAudioDeviceModuleControlling, Mockable,
     func setMicrophoneMuted(_ isMuted: Bool) -> Int {
         stubbedFunctionInput[.setMicrophoneMuted]?
             .append(.setMicrophoneMuted(isMuted))
-        return stubbedFunction[.setMicrophoneMuted] as? Int ?? 0
+        return stubbedFunction[.setMicrophoneMuted] as! Int
     }
 
     func stopRecording() -> Int {
@@ -95,4 +183,39 @@ final class MockRTCAudioDeviceModule: RTCAudioDeviceModuleControlling, Mockable,
             .append(.microphoneMutedPublisher)
         return microphoneMutedSubject.eraseToAnyPublisher()
     }
+
+    func reset() -> Int {
+        stubbedFunctionInput[.reset]?
+            .append(.reset)
+        return stubbedFunction[.reset] as! Int
+    }
+
+    func initAndStartPlayout() -> Int {
+        stubbedFunctionInput[.initAndStartPlayout]?
+            .append(.initAndStartPlayout)
+        return stubbedFunction[.initAndStartPlayout] as! Int
+    }
+
+    func startPlayout() -> Int {
+        stubbedFunctionInput[.startPlayout]?
+            .append(.startPlayout)
+        return stubbedFunction[.startPlayout] as! Int
+    }
+
+    func stopPlayout() -> Int {
+        stubbedFunctionInput[.stopPlayout]?
+            .append(.stopPlayout)
+        return stubbedFunction[.stopPlayout] as! Int
+    }
+
+    func startRecording() -> Int {
+        stubbedFunctionInput[.startRecording]?
+            .append(.startRecording)
+        return stubbedFunction[.startRecording] as! Int
+    }
+
+    func refreshStereoPlayoutState() {
+        stubbedFunctionInput[.refreshStereoPlayoutState]?
+            .append(.refreshStereoPlayoutState)
+    }
 }