Improve Telecom and Bluetooth Headset connectivity (#1841)

* temp

* Here’s a cleaner commit message:

Bump AudioSwitch and fix dropped Telecom actions

1. Bump AudioSwitch to 1.1.0, which includes Twilio 1.2.5 with BLE listener support.
2. Fix dropped Telecom actions by buffering the channel. Previously, the Bluetooth request could take up to 2 seconds, causing the call accept action to be dropped when both events arrived simultaneously.

* private val

* add ut

* remove ut

Author: rahul-lohra

gradle/libs.versions.toml

@@ -40,7 +40,7 @@ coil = "2.6.0"
 landscapist = "2.4.2"
 accompanist = "0.34.0"
 telephoto = "0.3.0"
-audioswitch = "1.0.0"
+audioswitch = "1.1.0"
 libyuv = "0.36.0"
 
 wire = "4.7.0"

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

@@ -710,7 +710,7 @@ class MicrophoneManager(
      * Select a specific device
      */
     fun select(device: StreamAudioDevice?) {
-        logger.i { "selecting device $device" }
+        logger.i { "[select] selecting device $device" }
         ifAudioHandlerInitialized { it.selectDevice(device?.toAudioDevice()) }
         _selectedDevice.value = device
 

stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/notifications/internal/telecom/TelecomCallController.kt

@@ -19,6 +19,7 @@ package io.getstream.video.android.core.notifications.internal.telecom
 import android.content.Context
 import android.telecom.DisconnectCause
 import io.getstream.android.video.generated.models.OwnCapability
+import io.getstream.log.taggedLogger
 import io.getstream.video.android.core.Call
 import io.getstream.video.android.core.StreamVideoClient
 import io.getstream.video.android.core.notifications.internal.telecom.jetpack.InteractionSource
@@ -29,6 +30,7 @@ import io.getstream.video.android.core.notifications.internal.telecom.jetpack.Te
  * Valid disconnected cause: [DisconnectCause.LOCAL, DisconnectCause.REMOTE, DisconnectCause.MISSED, or DisconnectCause.REJECTED]
  */
 class TelecomCallController(val context: Context) {
+    private val logger by taggedLogger("TelecomCallController")
     private val telecomPermissions = TelecomPermissions()
     private val telecomHelper = TelecomHelper()
 
@@ -65,6 +67,9 @@ class TelecomCallController(val context: Context) {
             if (telecomHelper.canUseJetpackTelecom()) {
                 val telecomCall =
                     call.state.jetpackTelecomRepository?.currentCall?.value
+                if (telecomCall == null) {
+                    logger.w { "[performAction] unable to perform action as currentCall is null" }
+                }
                 telecomCall?.let {
                     block(telecomCall)
                 }

stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/notifications/internal/telecom/jetpack/JetpackTelecomRepository.kt

@@ -108,7 +108,9 @@ internal class JetpackTelecomRepository(
         )
 
         // Creates a channel to send actions to the call scope.
-        val actionSource = Channel<TelecomCallAction>()
+        val actionSource = Channel<TelecomCallAction>(
+            capacity = Channel.BUFFERED,
+        )
         // Register the call and handle actions in the scope
         try {
             logger.d { "[registerCall] addCall" }
@@ -269,7 +271,14 @@ internal class JetpackTelecomRepository(
 
         if (newEndpoint != null) {
             requestEndpointChange(newEndpoint).also {
-                logger.d { "[doSwitchEndpoint] Endpoint ${newEndpoint.name} changed: $it " }
+                when (it) {
+                    is CallControlResult.Success -> {
+                        logger.d { "[doSwitchEndpoint] Endpoint ${newEndpoint.name} changed successfully: $it " }
+                    }
+                    is CallControlResult.Error -> {
+                        logger.w { "[doSwitchEndpoint] Endpoint ${newEndpoint.name} changed with error: $it " }
+                    }
+                }
             }
         }
     }
@@ -296,6 +305,7 @@ internal class JetpackTelecomRepository(
             }
 
             is CallControlResult.Error -> {
+                logger.w { "[CallControlScope.doAnswer] error with ${result.errorCode}" }
                 updateCurrentCall {
                     TelecomCall.Unregistered(
                         id = id,

stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/notifications/internal/telecom/jetpack/TelecomCall.kt

@@ -20,12 +20,14 @@ import android.os.ParcelUuid
 import android.telecom.DisconnectCause
 import androidx.core.telecom.CallAttributesCompat
 import androidx.core.telecom.CallEndpointCompat
+import io.getstream.log.taggedLogger
 import kotlinx.coroutines.channels.Channel
 
 /**
  * Custom representation of a call state.
  */
 internal sealed class TelecomCall {
+    val logger by taggedLogger("TelecomCall")
 
     /**
      * There is no current or past calls in the stack
@@ -59,7 +61,9 @@ internal sealed class TelecomCall {
          * @return true if the action was sent, false otherwise
          */
         fun processAction(action: TelecomCallAction): Boolean {
-            return actionSource.trySend(action).isSuccess
+            val result = actionSource.trySend(action).isSuccess
+            logger.d { "[processAction] action:$action, result = $result" }
+            return result
         }
     }
 

stream-video-android-core/src/test/kotlin/io/getstream/video/android/core/notifications/internal/telecom/jetpack/JetpackTelecomRepositoryTest.kt

@@ -31,6 +31,7 @@ import io.mockk.slot
 import io.mockk.verify
 import kotlinx.coroutines.CancellationException
 import kotlinx.coroutines.flow.emptyFlow
+import kotlinx.coroutines.test.StandardTestDispatcher
 import kotlinx.coroutines.test.runTest
 import org.junit.Before
 import org.junit.runner.RunWith
@@ -101,6 +102,39 @@ class JetpackTelecomRepositoryTest {
         assertTrue(repository.currentCall.value is TelecomCall.None)
     }
 
+    @Test
+    fun `registerCall buffers actions until collector starts`() = runTest {
+        val callControlScope = mockk<CallControlScope>(relaxed = true) {
+            every { coroutineContext } returns
+                backgroundScope.coroutineContext + StandardTestDispatcher(testScheduler)
+            every { getCallId() } returns ParcelUuid(UUID.randomUUID())
+            every { currentCallEndpoint } returns emptyFlow()
+            every { availableEndpoints } returns emptyFlow()
+            every { isMuted } returns emptyFlow()
+        }
+        coEvery {
+            callsManager.addCall(any(), any(), any(), any(), any(), any())
+        } coAnswers {
+            arg<CallControlScope.() -> Unit>(5).invoke(callControlScope)
+        }
+        val sendResults = mutableListOf<Boolean>()
+
+        repository.registerCall(
+            displayName = "Caller",
+            address = Uri.parse("stream:call-id"),
+            isIncoming = true,
+            isVideoCall = false,
+            onRegistered = {
+                val registeredCall = repository.currentCall.value as TelecomCall.Registered
+                sendResults += registeredCall.processAction(TelecomCallAction.ToggleMute(true))
+                sendResults += registeredCall.processAction(TelecomCallAction.ToggleMute(false))
+            },
+            onException = { throw AssertionError("Unexpected registration failure", it) },
+        )
+
+        assertEquals(listOf(true, true), sendResults)
+    }
+
     @Test
     fun `registerCall reports non-cancellation failures`() = runTest {
         val failure = IllegalStateException("Telecom rejected call")