add can update metadata flag in InternalMembraneRTC

fishjam-dev · Jun 5, 2024 · 5302aaa · 5302aaa
1 parent e80328d
commit 5302aaa
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/FishjamClient/src/main/java/org/membraneframework/rtc/InternalMembraneRTC.kt b/FishjamClient/src/main/java/org/membraneframework/rtc/InternalMembraneRTC.kt
@@ -49,6 +49,7 @@ internal class InternalMembraneRTC(
 
     private val localTracks = mutableListOf<LocalTrack>()
     private val localTracksMutex = Mutex()
+    private var canUpdateMetadata = false
 
     private val coroutineScope: CoroutineScope =
         ClosableCoroutineScope(SupervisorJob() + defaultDispatcher)
@@ -74,6 +75,7 @@ internal class InternalMembraneRTC(
                 localTracks.forEach { it.stop() }
             }
             peerConnectionManager.close()
+            canUpdateMetadata=false
         }
     }
 
@@ -210,6 +212,7 @@ internal class InternalMembraneRTC(
     }
 
     fun updateEndpointMetadata(endpointMetadata: Metadata) {
+        if(!canUpdateMetadata)return
         coroutineScope.launch {
             rtcEngineCommunication.updateEndpointMetadata(endpointMetadata)
             localEndpoint = localEndpoint.copy(metadata = endpointMetadata)
@@ -220,6 +223,7 @@ internal class InternalMembraneRTC(
         trackId: String,
         trackMetadata: Metadata
     ) {
+        if(!canUpdateMetadata)return
         coroutineScope.launch {
             rtcEngineCommunication.updateTrackMetadata(trackId, trackMetadata)
             localEndpoint = localEndpoint.withTrack(trackId, trackMetadata)
@@ -347,6 +351,7 @@ internal class InternalMembraneRTC(
                         }
                     }
                 }
+                canUpdateMetadata = true
             }
         }
     }