add simulcast confit to added track event

MembraneRTC/src/main/java/org/membraneframework/rtc/InternalMembraneRTC.kt

@@ -9,6 +9,7 @@ import kotlinx.coroutines.*
 import kotlinx.coroutines.sync.Mutex
 import kotlinx.coroutines.sync.withLock
 import org.membraneframework.rtc.events.OfferData
+import org.membraneframework.rtc.events.TracksAdded
 import org.membraneframework.rtc.media.*
 import org.membraneframework.rtc.models.EncodingReason
 import org.membraneframework.rtc.models.Endpoint
@@ -48,7 +49,7 @@ constructor(
     )
 
     private var localEndpoint: Endpoint =
-        Endpoint(id = "", type = "webrtc", metadata = mapOf(), trackIdToMetadata = mapOf())
+        Endpoint(id = "", type = "webrtc", metadata = mapOf(), trackIdToMetadata = mapOf(), tracks = mapOf())
 
     // mapping from endpoint's id to the endpoint himself
     private val remoteEndpoints = HashMap<String, Endpoint>()
@@ -230,7 +231,7 @@ constructor(
             this.remoteEndpoints[it.id] = it
 
             for ((trackId, metadata) in it.trackIdToMetadata) {
-                val context = TrackContext(track = null, endpoint = it, trackId = trackId, metadata = metadata)
+                val context = TrackContext(track = null, endpoint = it, trackId = trackId, metadata = metadata, simulcastConfig = it.tracks[trackId]?.simulcastConfig)
 
                 this.trackContexts[trackId] = context
 
@@ -337,20 +338,20 @@ constructor(
         }
     }
 
-    override fun onTracksAdded(endpointId: String, trackIdToMetadata: Map<String, Metadata>) {
+    override fun onTracksAdded(endpointId: String, trackIdToMetadata: Map<String, Metadata>, tracks: Map<String, TracksAdded.Data.TrackData>) {
         if (localEndpoint.id == endpointId) return
 
         val endpoint = remoteEndpoints.remove(endpointId) ?: run {
             Timber.e("Failed to process TracksAdded event: Endpoint not found: $endpointId")
             return
         }
 
-        val updatedEndpoint = endpoint.copy(trackIdToMetadata = trackIdToMetadata)
+        val updatedEndpoint = endpoint.copy(trackIdToMetadata = trackIdToMetadata, tracks = tracks)
 
         remoteEndpoints[updatedEndpoint.id] = updatedEndpoint
 
         for ((trackId, metadata) in updatedEndpoint.trackIdToMetadata) {
-            val context = TrackContext(track = null, endpoint = endpoint, trackId = trackId, metadata = metadata)
+            val context = TrackContext(track = null, endpoint = endpoint, trackId = trackId, metadata = metadata, simulcastConfig = updatedEndpoint.tracks[trackId]?.simulcastConfig)
 
             this.trackContexts[trackId] = context
 

MembraneRTC/src/main/java/org/membraneframework/rtc/RTCEngineCommunication.kt

@@ -100,7 +100,7 @@ constructor(
             is OfferData -> engineListener.onOfferData(event.data.integratedTurnServers, event.data.tracksTypes)
             is EndpointRemoved -> engineListener.onEndpointRemoved(event.data.id)
             is EndpointAdded -> engineListener.onEndpointAdded(
-                Endpoint(event.data.id, event.data.type, event.data.metadata, mapOf())
+                Endpoint(event.data.id, event.data.type, event.data.metadata, mapOf(), mapOf())
             )
             is EndpointUpdated -> engineListener.onEndpointUpdated(event.data.id, event.data.metadata)
             is RemoteCandidate -> engineListener.onRemoteCandidate(
@@ -114,7 +114,7 @@ constructor(
                 event.data.trackId,
                 event.data.metadata
             )
-            is TracksAdded -> engineListener.onTracksAdded(event.data.endpointId, event.data.trackIdToMetadata)
+            is TracksAdded -> engineListener.onTracksAdded(event.data.endpointId, event.data.trackIdToMetadata, event.data.tracks)
             is TracksRemoved -> engineListener.onTracksRemoved(event.data.endpointId, event.data.trackIds)
             is EncodingSwitched -> engineListener.onTrackEncodingChanged(
                 event.data.endpointId,

MembraneRTC/src/main/java/org/membraneframework/rtc/RTCEngineListener.kt

@@ -1,6 +1,7 @@
 package org.membraneframework.rtc
 
 import org.membraneframework.rtc.events.OfferData
+import org.membraneframework.rtc.events.TracksAdded
 import org.membraneframework.rtc.models.Endpoint
 import org.membraneframework.rtc.utils.Metadata
 import org.membraneframework.rtc.utils.SerializedMediaEvent
@@ -14,7 +15,7 @@ internal interface RTCEngineListener {
     fun onOfferData(integratedTurnServers: List<OfferData.TurnServer>, tracksTypes: Map<String, Int>)
     fun onSdpAnswer(type: String, sdp: String, midToTrackId: Map<String, String>)
     fun onRemoteCandidate(candidate: String, sdpMLineIndex: Int, sdpMid: String?)
-    fun onTracksAdded(endpointId: String, trackIdToMetadata: Map<String, Metadata>)
+    fun onTracksAdded(endpointId: String, trackIdToMetadata: Map<String, Metadata>, tracks: Map<String, TracksAdded.Data.TrackData>)
     fun onTracksRemoved(endpointId: String, trackIds: List<String>)
     fun onTrackUpdated(endpointId: String, trackId: String, metadata: Metadata)
     fun onTrackEncodingChanged(endpointId: String, trackId: String, encoding: String, encodingReason: String)

MembraneRTC/src/main/java/org/membraneframework/rtc/events/Event.kt

@@ -4,6 +4,7 @@ import com.google.gson.Gson
 import com.google.gson.JsonParseException
 import com.google.gson.annotations.SerializedName
 import com.google.gson.reflect.TypeToken
+import org.membraneframework.rtc.SimulcastConfig
 import org.membraneframework.rtc.models.Endpoint
 import org.membraneframework.rtc.utils.Metadata
 import org.membraneframework.rtc.utils.Payload
@@ -255,7 +256,9 @@ data class OfferData(val type: ReceivableEventType, val data: Data) : Receivable
 }
 
 data class TracksAdded(val type: ReceivableEventType, val data: Data) : ReceivableEvent() {
-    data class Data(val endpointId: String, val trackIdToMetadata: Map<String, Metadata>)
+    data class Data(val endpointId: String, val trackIdToMetadata: Map<String, Metadata>, val tracks: Map<String, TrackData>){
+        data class TrackData(val metadata: Metadata, val simulcastConfig: SimulcastConfig)
+    }
 }
 
 data class TracksRemoved(val type: ReceivableEventType, val data: Data) : ReceivableEvent() {

MembraneRTC/src/main/java/org/membraneframework/rtc/models/Endpoint.kt

@@ -1,12 +1,14 @@
 package org.membraneframework.rtc.models
 
+import org.membraneframework.rtc.events.TracksAdded
 import org.membraneframework.rtc.utils.Metadata
 
 data class Endpoint(
     val id: String,
     val type: String,
     val metadata: Metadata = mapOf(),
-    val trackIdToMetadata: Map<String, Metadata> = mapOf()
+    val trackIdToMetadata: Map<String, Metadata> = mapOf(),
+    val tracks: Map<String, TracksAdded.Data.TrackData>,
 ) {
     fun withTrack(trackId: String, metadata: Metadata?): Endpoint {
         val newTrackIdToMetadata = this.trackIdToMetadata.toMutableMap()

MembraneRTC/src/main/java/org/membraneframework/rtc/models/TrackContext.kt

@@ -1,5 +1,6 @@
 package org.membraneframework.rtc.models
 
+import org.membraneframework.rtc.SimulcastConfig
 import org.membraneframework.rtc.TrackEncoding
 import org.membraneframework.rtc.media.RemoteTrack
 import org.membraneframework.rtc.utils.Metadata
@@ -19,7 +20,7 @@ fun interface OnVoiceActivityChangedListener {
  * @property trackId Track id. It is generated by RTC engine and takes form `endpoint_id:<random_uuidv4>`.
  * @property metadata Any info that was passed in MembraneWebRTC.createVideoTrack/MembraneWebRTC.createAudioTrack
  */
-class TrackContext(track: RemoteTrack?, val endpoint: Endpoint, val trackId: String, metadata: Metadata) {
+class TrackContext(track: RemoteTrack?, val endpoint: Endpoint, val trackId: String, metadata: Metadata, simulcastConfig: SimulcastConfig?) {
     private var onTrackEncodingChangeListener: (OnEncodingChangedListener)? = null
     private var onVadNotificationListener: (OnVoiceActivityChangedListener)? = null
 
@@ -28,6 +29,9 @@ class TrackContext(track: RemoteTrack?, val endpoint: Endpoint, val trackId: Str
     var metadata: Metadata = metadata
         internal set
 
+    var simulcastConfig: SimulcastConfig? = simulcastConfig
+        internal set
+
     var vadStatus: VadStatus = VadStatus.SILENCE
         internal set(value) {
             field = value