통화중 webrtc control 가능하도록 처리

Author: lyh990517

app/src/main/java/com/example/webrtc/WebRTCConnectActivity.kt

@@ -64,6 +64,7 @@ class WebRTCConnectActivity : AppCompatActivity() {
                             viewModel.connect()
                         }
                     }
+                    is WebRTCEvent.CloseSession -> finish()
                 }
             }
         }

data/src/main/java/com/example/data/client/WebRTCClientImpl.kt

@@ -9,8 +9,10 @@ import com.google.firebase.firestore.FirebaseFirestore
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.flow.MutableSharedFlow
+import kotlinx.coroutines.flow.MutableStateFlow
 import kotlinx.coroutines.flow.SharedFlow
 import kotlinx.coroutines.flow.asSharedFlow
+import kotlinx.coroutines.flow.collect
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.runBlocking
 import org.webrtc.*
@@ -47,6 +49,26 @@ internal class WebRTCClientImpl @Inject constructor(
 
     val eventFlow = _eventFlow
 
+    private val isMicEnabled = MutableStateFlow(true)
+    private val isVideoEnabled = MutableStateFlow(true)
+
+
+    init {
+        collectState()
+    }
+
+    private fun collectState() {
+        CoroutineScope(Dispatchers.IO).launch {
+            isMicEnabled.collect{
+                localAudioTrack?.setEnabled(it)
+            }
+        }
+        CoroutineScope(Dispatchers.IO).launch {
+            isVideoEnabled.collect{
+                localVideoTrack?.setEnabled(it)
+            }
+        }
+    }
 
     override fun getVideoCapture(context: Context) =
         Camera2Enumerator(context).run {
@@ -188,6 +210,19 @@ internal class WebRTCClientImpl @Inject constructor(
     }
 
     override fun getEvent(): SharedFlow<PeerConnectionEvent> = eventFlow.asSharedFlow()
+    override fun toggleVoice() {
+        isMicEnabled.value = !isMicEnabled.value
+    }
+
+    override fun toggleVideo() {
+        isVideoEnabled.value = !isVideoEnabled.value
+    }
+
+    override fun closeSession() {
+        localAudioTrack?.dispose()
+        localVideoTrack?.dispose()
+        peerConnection?.close()
+    }
 
     override fun answer(roomID: String) =
         peerConnection?.answer(roomID)

domain/src/main/java/com/example/domain/client/WebRTCClient.kt

@@ -54,4 +54,10 @@ interface WebRTCClient {
 
     fun getEvent(): SharedFlow<PeerConnectionEvent>
 
+    fun toggleVoice()
+
+    fun toggleVideo()
+
+    fun closeSession()
+
 }

domain/src/main/java/com/example/domain/event/WebRTCEvent.kt

@@ -5,4 +5,6 @@ import com.example.domain.client.WebRTCClient
 sealed class WebRTCEvent {
     data class Initialize(val webRTCClient: WebRTCClient) : WebRTCEvent()
 
+    object CloseSession : WebRTCEvent()
+
 }

presentaion/src/main/java/com/example/presentaion/viewmodel/ConnectionViewModel.kt

@@ -92,15 +92,16 @@ class ConnectionViewModel @Inject constructor(
         if (!isJoin.value) webRTCClient.call(roomId.value)
     }
 
-    fun toggleVoice() {
-
+    fun toggleVoice() = viewModelScope.launch {
+        webRTCClient.toggleVoice()
     }
 
-    fun toggleVideo() {
-
+    fun toggleVideo() = viewModelScope.launch {
+        webRTCClient.toggleVideo()
     }
 
-    fun closeSession() {
-
+    fun closeSession() = viewModelScope.launch {
+        webRTCClient.closeSession()
+        _webRTCEvent.emit(WebRTCEvent.CloseSession)
     }
 }