Fix startLocalRecording()

Package.swift

@@ -18,7 +18,7 @@ let package = Package(
     ],
     dependencies: [
         // LK-Prefixed Dynamic WebRTC XCFramework
-        .package(url: "https://github.com/livekit/webrtc-xcframework.git", exact: "125.6422.16"),
+        .package(url: "https://github.com/livekit/webrtc-xcframework.git", exact: "125.6422.17"),
         .package(url: "https://github.com/apple/swift-protobuf.git", from: "1.26.0"),
         .package(url: "https://github.com/apple/swift-log.git", from: "1.5.4"),
         // Only used for DocC generation

Package@swift-5.9.swift

@@ -20,7 +20,7 @@ let package = Package(
     ],
     dependencies: [
         // LK-Prefixed Dynamic WebRTC XCFramework
-        .package(url: "https://github.com/livekit/webrtc-xcframework.git", exact: "125.6422.16"),
+        .package(url: "https://github.com/livekit/webrtc-xcframework.git", exact: "125.6422.17"),
         .package(url: "https://github.com/apple/swift-protobuf.git", from: "1.26.0"),
         .package(url: "https://github.com/apple/swift-log.git", from: "1.5.4"),
         // Only used for DocC generation

Sources/LiveKit/Track/AudioManager.swift

@@ -101,10 +101,10 @@
         public var localTracksCount: Int = 0
         public var remoteTracksCount: Int = 0
         public var isSpeakerOutputPreferred: Bool = true
         public var customConfigureFunc: ConfigureAudioSessionFunc?
         public var sessionConfiguration: AudioSessionConfiguration?
 
         public var trackState: TrackState {
             switch (localTracksCount > 0, remoteTracksCount > 0) {
             case (true, false): return .localOnly
             case (false, true): return .remoteOnly
@@ -241,6 +241,9 @@
     /// Starts mic input to the SDK even without any ``Room`` or a connection.
     /// Audio buffers will flow into ``LocalAudioTrack/add(audioRenderer:)`` and ``capturePostProcessingDelegate``.
     public func startLocalRecording() {
+        // Always unmute APM if muted by last session.
+        RTC.audioProcessingModule.isMuted = false
+        // Start recording on the ADM.
         RTC.audioDeviceModule.initAndStartRecording()
     }
 

Tests/LiveKitTests/AudioEngineTests.swift

@@ -106,32 +106,55 @@
     }
 
     // Test start generating local audio buffer without joining to room.
-    func testPrejoinLocalAudioBuffer() async throws {
-        // Set up expectation...
-        let didReceiveAudioFrame = expectation(description: "Did receive audio frame")
-        didReceiveAudioFrame.assertForOverFulfill = false
-
-        // Start watching for audio frame...
-        let audioFrameWatcher = AudioTrackWatcher(id: "notifier01") { _ in
-            didReceiveAudioFrame.fulfill()
+    func testPreconnectAudioBuffer() async throws {
+        print("Setting recording always prepared mode...")
+        AudioManager.shared.isRecordingAlwaysPrepared = true
+
+        var counter = 0
+        // Executes 10 times by default.
+        measure {
+            counter += 1
+            print("Measuring attempt \(counter)...")
+            // Set up expectation...
+            let didReceiveAudioFrame = expectation(description: "Did receive audio frame")
+            didReceiveAudioFrame.assertForOverFulfill = false
+
+            let didConnectToRoom = expectation(description: "Did connect to room")
+            didConnectToRoom.assertForOverFulfill = false
+
+            // Create an audio frame watcher...
+            let audioFrameWatcher = AudioTrackWatcher(id: "notifier01") { _ in
+                didReceiveAudioFrame.fulfill()
+            }
+
+            let localMicTrack = LocalAudioTrack.createTrack()
+            // Attach audio frame watcher...
+            localMicTrack.add(audioRenderer: audioFrameWatcher)
+
+            Task.detached {
+                print("Starting local recording...")
+                AudioManager.shared.startLocalRecording()
+            }
+
+            // Wait for audio frame...
+            print("Waiting for first audio frame...")
+            // await fulfillment(of: [didReceiveAudioFrame], timeout: 10)
+            wait(for: [didReceiveAudioFrame], timeout: 30)
+
+            Task.detached {
+                print("Connecting to room...")
+                try await self.withRooms([RoomTestingOptions(canPublish: true)]) { rooms in
+                    print("Publishing mic...")
+                    try await rooms[0].localParticipant.setMicrophone(enabled: true)
+                    didConnectToRoom.fulfill()
+                }
+            }
+
+            print("Waiting for room to connect & disconnect...")
+            wait(for: [didConnectToRoom], timeout: 30)
+
+            localMicTrack.remove(audioRenderer: audioFrameWatcher)
         }
-
-        let localMicTrack = LocalAudioTrack.createTrack()
-        // Attach audio frame watcher...
-        localMicTrack.add(audioRenderer: audioFrameWatcher)
-
-        Task.detached {
-            print("Starting audio track in 3 seconds...")
-            try? await Task.sleep(nanoseconds: 3 * 1_000_000_000)
-            AudioManager.shared.startLocalRecording()
-        }
-
-        // Wait for audio frame...
-        print("Waiting for first audio frame...")
-        await fulfillment(of: [didReceiveAudioFrame], timeout: 10)
-
-        // Remove audio frame watcher...
-        localMicTrack.remove(audioRenderer: audioFrameWatcher)
     }
 
     // Test the manual rendering mode (no-device mode) of AVAudioEngine based AudioDeviceModule.
@@ -282,7 +305,7 @@
 }
 
 final class SineWaveNodeHook: AudioEngineObserver {
     var next: (any LiveKit.AudioEngineObserver)?
 
     let sineWaveNode = SineWaveSourceNode()
 
@@ -301,7 +324,7 @@
 }
 
 final class PlayerNodeHook: AudioEngineObserver {
     var next: (any LiveKit.AudioEngineObserver)?
 
     public let playerNode = AVAudioPlayerNode()
     public let playerMixerNode = AVAudioMixerNode()

Tests/LiveKitTests/Support/Tracks.swift

@@ -186,10 +186,9 @@ class AudioTrackWatcher: AudioRenderer {
     }
 
     func render(pcmBuffer: AVAudioPCMBuffer) {
-        print("did receive first audio frame: \(String(describing: pcmBuffer))")
-
         _state.mutate {
             if !$0.didRenderFirstFrame {
+                print("did receive first audio frame: \(String(describing: pcmBuffer))")
                 $0.didRenderFirstFrame = true
                 onDidRenderFirstFrame?(id)
             }