refactor(core): add an API to retrieve the streamConfigs in IMuxerInternal

Author: ThibaultBee

core/src/main/java/io/github/thibaultbee/streampack/core/elements/endpoints/composites/CompositeEndpoint.kt

@@ -26,7 +26,6 @@ import io.github.thibaultbee.streampack.core.elements.endpoints.composites.muxer
 import io.github.thibaultbee.streampack.core.elements.endpoints.composites.muxers.IMuxerInternal
 import io.github.thibaultbee.streampack.core.elements.endpoints.composites.sinks.ISinkInternal
 import io.github.thibaultbee.streampack.core.elements.endpoints.composites.sinks.SinkConfiguration
-import io.github.thibaultbee.streampack.core.logger.Logger
 import kotlinx.coroutines.flow.StateFlow
 import kotlinx.coroutines.runBlocking
 
@@ -79,18 +78,16 @@ class CompositeEndpoint(
 
     override fun addStreams(streamConfigs: List<CodecConfig>): Map<CodecConfig, Int> {
         val streamIds = muxer.addStreams(streamConfigs)
-        configurations.addAll(streamConfigs)
         return streamIds
     }
 
     override fun addStream(streamConfig: CodecConfig): Int {
         val streamId = muxer.addStream(streamConfig)
-        configurations.add(streamConfig)
         return streamId
     }
 
     override suspend fun startStream() {
-        sink.configure(SinkConfiguration(configurations))
+        sink.configure(SinkConfiguration(muxer.streamConfigs))
         sink.startStream()
         muxer.startStream()
     }
@@ -103,7 +100,6 @@ class CompositeEndpoint(
     override suspend fun stopStream() {
         muxer.stopStream()
         sink.stopStream()
-        configurations.clear()
     }
 
     class EndpointInfo(

core/src/main/java/io/github/thibaultbee/streampack/core/elements/endpoints/composites/muxers/IMuxerInternal.kt

@@ -26,6 +26,8 @@ interface IMuxerInternal :
     Releasable {
     var listener: IMuxerListener?
 
+    val streamConfigs: List<CodecConfig>
+
     interface IMuxerListener {
         fun onOutputFrame(packet: Packet)
     }

core/src/main/java/io/github/thibaultbee/streampack/core/elements/endpoints/composites/muxers/flv/FlvMuxer.kt

@@ -39,6 +39,9 @@ class FlvMuxer(
     private var startUpTime: Long? = null
     private var hasFirstFrame = false
 
+    override val streamConfigs: List<CodecConfig>
+        get() = streams.map { it.config }
+    
     override fun write(frame: Frame, streamPid: Int) {
         synchronized(this) {
             if (!hasFirstFrame) {

core/src/main/java/io/github/thibaultbee/streampack/core/elements/endpoints/composites/muxers/mp4/Mp4Muxer.kt

@@ -54,6 +54,9 @@ class Mp4Muxer(
     private var dataOffset: Long = 0
     private var sequenceNumber = DEFAULT_SEQUENCE_NUMBER
 
+    override val streamConfigs: List<CodecConfig>
+        get() = tracks.map { it.config }
+    
     override fun write(frame: Frame, streamPid: Int) {
         synchronized(this) {
             if (segmenter!!.mustWriteSegment(frame)) {
@@ -64,16 +67,13 @@ class Mp4Muxer(
     }
 
     override fun addStreams(streamsConfig: List<CodecConfig>): Map<CodecConfig, Int> {
-        val newTracks = mutableListOf<Track>()
         streamsConfig.forEach { config ->
             val track = Track(getNewId(), config, timescale)
-            newTracks.add(track)
             tracks.add(track)
         }
 
         val streamMap = mutableMapOf<CodecConfig, Int>()
-        newTracks.forEach { streamMap[it.config] = it.id }
-        return streamMap
+        return streamsConfig.associateWith { streamMap[it]!! }
     }
 
     override fun addStream(streamConfig: CodecConfig): Int {

core/src/main/java/io/github/thibaultbee/streampack/core/elements/endpoints/composites/muxers/ts/TsMuxer.kt

@@ -62,6 +62,9 @@ class TsMuxer : IMuxerInternal {
         listener, tsServices, tsId, packetCount = 0
     )
 
+    override val streamConfigs: List<CodecConfig>
+        get() = tsServices.flatMap { it.streams }.map { it.config }
+
     /**
      * Encodes a frame to MPEG-TS format.
      * Each audio frames and each video key frames must come with an extra buffer containing sps, pps,...