Fix AudioSource reuse after PeerConnection close (#159)

Additionally:
- fix passing `nullptr` `AudioProcessing` to `AudioDeviceModule::Create`

Author: evdokimovs

crates/libwebrtc-sys/include/adm.h

@@ -76,7 +76,7 @@ class OpenALAudioDeviceModule : public ExtendedADM {
   static rtc::scoped_refptr<OpenALAudioDeviceModule> Create(
       AudioLayer audio_layer,
       webrtc::TaskQueueFactory* task_queue_factory,
-      webrtc::AudioProcessing* audio_processing);
+      const std::unique_ptr<rtc::scoped_refptr<webrtc::AudioProcessing>>& audio_processing);
 
   // Main initialization and termination.
   int32_t Init() override;

crates/libwebrtc-sys/include/bridge.h

@@ -128,7 +128,7 @@ std::unique_ptr<AudioDeviceModule> create_audio_device_module(
     Thread& worker_thread,
     AudioLayer audio_layer,
     TaskQueueFactory& task_queue_factory,
-    const AudioProcessing& ap);
+    const std::unique_ptr<AudioProcessing>& ap);
 
 // Initializes the native audio parts required for each platform.
 int32_t init_audio_device_module(const AudioDeviceModule& audio_device_module);

crates/libwebrtc-sys/src/bridge.rs

@@ -1488,7 +1488,7 @@ pub(crate) mod webrtc {
             worker_thread: Pin<&mut Thread>,
             audio_layer: AudioLayer,
             task_queue_factory: Pin<&mut TaskQueueFactory>,
-            ap: &AudioProcessing,
+            ap: &UniquePtr<AudioProcessing>,
         ) -> UniquePtr<AudioDeviceModule>;
 
         /// Initializes the given [`AudioDeviceModule`].

crates/libwebrtc-sys/src/cpp/adm.cc

@@ -165,10 +165,14 @@ int32_t OpenALAudioDeviceModule::ActiveAudioLayer(
 rtc::scoped_refptr<OpenALAudioDeviceModule> OpenALAudioDeviceModule::Create(
     AudioLayer audio_layer,
     webrtc::TaskQueueFactory* task_queue_factory,
-    webrtc::AudioProcessing* audio_processing) {
+    const std::unique_ptr<rtc::scoped_refptr<webrtc::AudioProcessing>>& audio_processing) {
   auto adm = rtc::make_ref_counted<OpenALAudioDeviceModule>();
 
-  adm->audio_processing_ = audio_processing;
+  if (!audio_processing.get()) {
+    adm->audio_processing_ = nullptr;
+  } else {
+    adm->audio_processing_ = audio_processing.get()->get();
+  }
   adm->audio_device_buffer_ =
       std::make_unique<webrtc::AudioDeviceBuffer>(task_queue_factory);
 
@@ -843,6 +847,12 @@ bool OpenALAudioDeviceModule::RecordingIsInitialized() const {
 }
 
 int32_t OpenALAudioDeviceModule::StartRecording() {
+  for (const auto& [_, recorder] : _recorders) {
+    recorder->StartCapture();
+  }
+  ensureThreadStarted();
+  startCaptureOnThread();
+
   return 0;
 }
 

crates/libwebrtc-sys/src/cpp/bridge.cc

@@ -113,13 +113,13 @@ std::unique_ptr<AudioDeviceModule> create_audio_device_module(
     Thread& worker_thread,
     AudioLayer audio_layer,
     TaskQueueFactory& task_queue_factory,
-    const AudioProcessing& ap) {
+    const std::unique_ptr<AudioProcessing>& ap) {
   AudioDeviceModule adm = worker_thread.BlockingCall([audio_layer,
                                                       &task_queue_factory,
                                                       &ap] {
     return ::OpenALAudioDeviceModule::Create(audio_layer,
                                              &task_queue_factory,
-                                             ap.get());
+                                             ap);
   });
 
   if (adm == nullptr) {