Support runtime audio usage resolution (#1544)

* Replace audioUsage with audioUsageProvider

* refactor

* refactor

Author: rahul-lohra

stream-video-android-core/api/stream-video-android-core.api

@@ -7618,12 +7618,13 @@ public final class io/getstream/video/android/core/LocalStats {
 }
 
 public final class io/getstream/video/android/core/MediaManagerImpl {
-	public fun <init> (Landroid/content/Context;Lio/getstream/video/android/core/Call;Lkotlinx/coroutines/CoroutineScope;Lorg/webrtc/EglBase$Context;I)V
-	public synthetic fun <init> (Landroid/content/Context;Lio/getstream/video/android/core/Call;Lkotlinx/coroutines/CoroutineScope;Lorg/webrtc/EglBase$Context;IILkotlin/jvm/internal/DefaultConstructorMarker;)V
+	public fun <init> (Landroid/content/Context;Lio/getstream/video/android/core/Call;Lkotlinx/coroutines/CoroutineScope;Lorg/webrtc/EglBase$Context;ILkotlin/jvm/functions/Function0;)V
+	public synthetic fun <init> (Landroid/content/Context;Lio/getstream/video/android/core/Call;Lkotlinx/coroutines/CoroutineScope;Lorg/webrtc/EglBase$Context;ILkotlin/jvm/functions/Function0;ILkotlin/jvm/internal/DefaultConstructorMarker;)V
 	public final fun cleanup ()V
 	public final fun getAudioSource ()Lorg/webrtc/AudioSource;
 	public final fun getAudioTrack ()Lorg/webrtc/AudioTrack;
 	public final fun getAudioUsage ()I
+	public final fun getAudioUsageProvider ()Lkotlin/jvm/functions/Function0;
 	public final fun getCall ()Lio/getstream/video/android/core/Call;
 	public final fun getContext ()Landroid/content/Context;
 	public final fun getEglBaseContext ()Lorg/webrtc/EglBase$Context;
@@ -7694,12 +7695,13 @@ public final class io/getstream/video/android/core/MemberState {
 }
 
 public final class io/getstream/video/android/core/MicrophoneManager {
-	public fun <init> (Lio/getstream/video/android/core/MediaManagerImpl;I)V
+	public fun <init> (Lio/getstream/video/android/core/MediaManagerImpl;ILkotlin/jvm/functions/Function0;)V
 	public final fun canHandleDeviceSwitch ()Z
 	public final fun cleanup ()V
 	public final fun disable (Z)V
 	public static synthetic fun disable$default (Lio/getstream/video/android/core/MicrophoneManager;ZILjava/lang/Object;)V
 	public final fun getAudioUsage ()I
+	public final fun getAudioUsageProvider ()Lkotlin/jvm/functions/Function0;
 	public final fun getDevices ()Lkotlinx/coroutines/flow/StateFlow;
 	public final fun getMediaManager ()Lio/getstream/video/android/core/MediaManagerImpl;
 	public final fun getSelectedDevice ()Lkotlinx/coroutines/flow/StateFlow;
@@ -8292,8 +8294,8 @@ public class io/getstream/video/android/core/call/connection/StreamPeerConnectio
 }
 
 public final class io/getstream/video/android/core/call/connection/StreamPeerConnectionFactory {
-	public fun <init> (Landroid/content/Context;ILorg/webrtc/ManagedAudioProcessingFactory;)V
-	public synthetic fun <init> (Landroid/content/Context;ILorg/webrtc/ManagedAudioProcessingFactory;ILkotlin/jvm/internal/DefaultConstructorMarker;)V
+	public fun <init> (Landroid/content/Context;ILkotlin/jvm/functions/Function0;Lorg/webrtc/ManagedAudioProcessingFactory;)V
+	public synthetic fun <init> (Landroid/content/Context;ILkotlin/jvm/functions/Function0;Lorg/webrtc/ManagedAudioProcessingFactory;ILkotlin/jvm/internal/DefaultConstructorMarker;)V
 	public final fun getEglBase ()Lorg/webrtc/EglBase;
 	public final fun getSenderCapabilities (Lorg/webrtc/MediaStreamTrack$MediaType;)Lorg/webrtc/RtpCapabilities;
 	public final fun isAudioProcessingEnabled ()Z

stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/Call.kt

@@ -233,11 +233,13 @@ public class Call(
     internal var connectStartTime = 0L
     internal var reconnectStartTime = 0L
 
-    internal var peerConnectionFactory: StreamPeerConnectionFactory = StreamPeerConnectionFactory(
-        context = clientImpl.context,
-        audioProcessing = clientImpl.audioProcessing,
-        audioUsage = clientImpl.callServiceConfigRegistry.get(type).audioUsage,
-    )
+    internal var peerConnectionFactory: StreamPeerConnectionFactory =
+        StreamPeerConnectionFactory(
+            context = clientImpl.context,
+            audioProcessing = clientImpl.audioProcessing,
+            audioUsage = clientImpl.callServiceConfigRegistry.get(type).audioUsage,
+            audioUsageProvider = { clientImpl.callServiceConfigRegistry.get(type).audioUsage },
+        )
 
     internal val clientCapabilities = ConcurrentHashMap<String, ClientCapability>().apply {
         put(
@@ -256,7 +258,7 @@ public class Call(
                 scope,
                 peerConnectionFactory.eglBase.eglBaseContext,
                 clientImpl.callServiceConfigRegistry.get(type).audioUsage,
-            )
+            ) { clientImpl.callServiceConfigRegistry.get(type).audioUsage }
         }
     }
 

stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/MediaManager.kt

@@ -357,7 +357,9 @@ class ScreenShareManager(
  */
 class MicrophoneManager(
     val mediaManager: MediaManagerImpl,
+    @Deprecated("Use audioUsageProvider instead", replaceWith = ReplaceWith("audioUsageProvider"))
     val audioUsage: Int,
+    val audioUsageProvider: (() -> Int),
 ) {
     // Internal data
     private val logger by taggedLogger("Media:MicrophoneManager")
@@ -474,7 +476,7 @@ class MicrophoneManager(
         setupCompleted = false
     }
 
-    fun canHandleDeviceSwitch() = audioUsage != AudioAttributes.USAGE_MEDIA
+    fun canHandleDeviceSwitch() = audioUsageProvider.invoke() != AudioAttributes.USAGE_MEDIA
 
     // Internal logic
     internal fun setup(preferSpeaker: Boolean = false, onAudioDevicesUpdate: (() -> Unit)? = null) {
@@ -1005,7 +1007,9 @@ class MediaManagerImpl(
     val call: Call,
     val scope: CoroutineScope,
     val eglBaseContext: EglBase.Context,
+    @Deprecated("Use audioUsageProvider instead", replaceWith = ReplaceWith("audioUsageProvider"))
     val audioUsage: Int = defaultAudioUsage,
+    val audioUsageProvider: (() -> Int) = { audioUsage },
 ) {
     private val filterVideoProcessor =
         FilterVideoProcessor({ call.videoFilter }, { camera.surfaceTextureHelper })
@@ -1040,7 +1044,7 @@ class MediaManagerImpl(
 
     internal val camera =
         CameraManager(this, eglBaseContext, DefaultCameraCharacteristicsValidator())
-    internal val microphone = MicrophoneManager(this, audioUsage)
+    internal val microphone = MicrophoneManager(this, audioUsage, audioUsageProvider)
     internal val speaker = SpeakerManager(this, microphone)
     internal val screenShare = ScreenShareManager(this, eglBaseContext)
 

stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/call/connection/StreamPeerConnectionFactory.kt

@@ -62,7 +62,9 @@ import java.nio.ByteBuffer
  */
 public class StreamPeerConnectionFactory(
     private val context: Context,
+    @Deprecated("Use audioUsageProvider instead")
     private val audioUsage: Int = defaultAudioUsage,
+    private val audioUsageProvider: (() -> Int) = { audioUsage },
     private var audioProcessing: ManagedAudioProcessingFactory? = null,
 ) {
 
@@ -174,9 +176,9 @@ public class StreamPeerConnectionFactory(
                     .setUseHardwareAcousticEchoCanceler(
                         Build.VERSION.SDK_INT >= Build.VERSION_CODES.Q,
                     ).apply {
-                        if (audioUsage != defaultAudioUsage) {
+                        if (audioUsageProvider.invoke() != defaultAudioUsage) {
                             setAudioAttributes(
-                                AudioAttributes.Builder().setUsage(audioUsage)
+                                AudioAttributes.Builder().setUsage(audioUsageProvider.invoke())
                                     .build(),
                             )
                         }

stream-video-android-core/src/test/kotlin/io/getstream/video/android/core/MicrophoneManagerTest.kt

@@ -34,12 +34,13 @@ import org.junit.Test
 class MicrophoneManagerTest {
 
     private val audioUsage = AudioAttributes.USAGE_VOICE_COMMUNICATION
+    private val audioUsageProvider = { AudioAttributes.USAGE_VOICE_COMMUNICATION }
 
     @Test
     fun `Ensure setup is called prior to any action onto the microphone manager`() = runTest {
         // Given
         val mediaManager = mockk<MediaManagerImpl>(relaxed = true)
-        val actual = MicrophoneManager(mediaManager, audioUsage)
+        val actual = MicrophoneManager(mediaManager, audioUsage, audioUsageProvider)
         val context = mockk<Context>(relaxed = true)
         every { mediaManager.context } returns context
         every { context.getSystemService(any()) } returns mockk<AudioManager>(relaxed = true)
@@ -86,6 +87,7 @@ class MicrophoneManagerTest {
             MicrophoneManager(
                 mediaManager,
                 audioUsage = AudioAttributes.USAGE_VOICE_COMMUNICATION,
+                audioUsageProvider = { AudioAttributes.USAGE_VOICE_COMMUNICATION },
             )
         val context = mockk<Context>(relaxed = true)
         val microphoneManager = spyk(actual)
@@ -106,7 +108,7 @@ class MicrophoneManagerTest {
     fun `Ensure setup if ever the manager was cleaned`() {
         // Given
         val mediaManager = mockk<MediaManagerImpl>(relaxed = true)
-        val actual = MicrophoneManager(mediaManager, audioUsage)
+        val actual = MicrophoneManager(mediaManager, audioUsage, audioUsageProvider)
         val context = mockk<Context>(relaxed = true)
         val microphoneManager = spyk(actual)
         every { mediaManager.context } returns context
@@ -137,7 +139,7 @@ class MicrophoneManagerTest {
     fun `Resume will call enable only if prior status was DeviceStatus#enabled`() {
         // Given
         val mediaManager = mockk<MediaManagerImpl>(relaxed = true)
-        val microphoneManager = MicrophoneManager(mediaManager, audioUsage)
+        val microphoneManager = MicrophoneManager(mediaManager, audioUsage, audioUsageProvider)
         val spyMicrophoneManager = spyk(microphoneManager)
         val mockContext = mockk<Context>(relaxed = true)
         val mockCallState = mockk<CallState>(relaxed = true)