refactor(*): introduce streamer pipeline to enable multiple output

Author: ThibaultBee

core/src/androidTest/java/io/github/thibaultbee/streampack/core/elements/endpoints/DummyEndpoint.kt

@@ -0,0 +1,98 @@
+/*
+ * Copyright (C) 2025 Thibault B.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.github.thibaultbee.streampack.core.elements.endpoints
+
+import android.util.Log
+import io.github.thibaultbee.streampack.core.configuration.mediadescriptor.MediaDescriptor
+import io.github.thibaultbee.streampack.core.elements.data.Frame
+import io.github.thibaultbee.streampack.core.elements.encoders.CodecConfig
+import kotlinx.coroutines.flow.MutableStateFlow
+import kotlinx.coroutines.flow.StateFlow
+import kotlinx.coroutines.runBlocking
+
+class DummyEndpoint : IEndpointInternal {
+    private val _isOpenFlow = MutableStateFlow(false)
+    override val isOpenFlow: StateFlow<Boolean> = _isOpenFlow
+
+    private val _frameFlow = MutableStateFlow<Frame?>(null)
+    val frameFlow: StateFlow<Frame?> = _frameFlow
+
+    var numOfAudioFramesWritten = 0
+        private set
+    var numOfVideoFramesWritten = 0
+        private set
+    val numOfFramesWritten: Int
+        get() = numOfAudioFramesWritten + numOfVideoFramesWritten
+
+    private val _isStreamingFlow = MutableStateFlow(false)
+    val isStreamingFlow: StateFlow<Boolean> = _isStreamingFlow
+
+    private val _configFlow = MutableStateFlow<CodecConfig?>(null)
+    val configFlow: StateFlow<CodecConfig?> = _configFlow
+
+    override val info: IEndpoint.IEndpointInfo
+        get() = TODO("Not yet implemented")
+
+    override fun getInfo(type: MediaDescriptor.Type): IEndpoint.IEndpointInfo {
+        TODO("Not yet implemented")
+    }
+
+    override val metrics: Any
+        get() = TODO("Not yet implemented")
+
+    override suspend fun open(descriptor: MediaDescriptor) {
+        _isOpenFlow.emit(true)
+    }
+
+    override suspend fun close() {
+        _isOpenFlow.emit(false)
+    }
+
+    override suspend fun write(frame: Frame, streamPid: Int) {
+        Log.i(TAG, "write: $frame")
+        _frameFlow.emit(frame)
+        when {
+            frame.isAudio -> numOfAudioFramesWritten++
+            frame.isVideo -> numOfVideoFramesWritten++
+        }
+    }
+
+    override fun addStreams(streamConfigs: List<CodecConfig>): Map<CodecConfig, Int> {
+        runBlocking {
+            streamConfigs.forEach { _configFlow.emit(it) }
+        }
+        return streamConfigs.associateWith { it.hashCode() }
+    }
+
+    override fun addStream(streamConfig: CodecConfig): Int {
+        runBlocking {
+            _configFlow.emit(streamConfig)
+        }
+        return streamConfig.hashCode()
+    }
+
+    override suspend fun startStream() {
+        _isStreamingFlow.emit(true)
+    }
+
+    override suspend fun stopStream() {
+        _isStreamingFlow.emit(false)
+    }
+
+    companion object {
+        private const val TAG = "DummyEndpoint"
+    }
+}

core/src/androidTest/java/io/github/thibaultbee/streampack/core/elements/sources/StubAudioSource.kt

@@ -0,0 +1,50 @@
+package io.github.thibaultbee.streampack.core.elements.sources
+
+import android.media.MediaFormat
+import io.github.thibaultbee.streampack.core.elements.data.Frame
+import io.github.thibaultbee.streampack.core.elements.sources.audio.AudioSourceConfig
+import io.github.thibaultbee.streampack.core.elements.sources.audio.IAudioSourceInternal
+import kotlinx.coroutines.flow.MutableStateFlow
+import kotlinx.coroutines.flow.StateFlow
+import java.nio.ByteBuffer
+
+class StubAudioSource : IAudioSourceInternal {
+    override var isMuted: Boolean
+        get() = TODO("Not yet implemented")
+        set(value) {}
+
+    private val _isStreamingFlow = MutableStateFlow(false)
+    val isStreamingFlow: StateFlow<Boolean> = _isStreamingFlow
+
+    private val _configurationFlow = MutableStateFlow<AudioSourceConfig?>(null)
+    val configurationFlow: StateFlow<AudioSourceConfig?> = _configurationFlow
+
+    override fun getAudioFrame(inputBuffer: ByteBuffer?): Frame {
+        return Frame(
+            inputBuffer ?: ByteBuffer.allocate(8192),
+            0,
+            format = MediaFormat().apply {
+                setString(
+                    MediaFormat.KEY_MIME,
+                    MediaFormat.MIMETYPE_AUDIO_RAW
+                )
+            })
+    }
+
+    override fun startStream() {
+        _isStreamingFlow.value = true
+    }
+
+    override fun stopStream() {
+        _isStreamingFlow.value = false
+    }
+
+    override fun configure(config: AudioSourceConfig) {
+        _configurationFlow.value = config
+    }
+
+
+    override fun release() {
+
+    }
+}

core/src/androidTest/java/io/github/thibaultbee/streampack/core/elements/sources/StubVideoSource.kt

@@ -0,0 +1,61 @@
+package io.github.thibaultbee.streampack.core.elements.sources
+
+import android.media.MediaFormat
+import android.view.Surface
+import io.github.thibaultbee.streampack.core.elements.data.Frame
+import io.github.thibaultbee.streampack.core.elements.processing.video.source.DefaultSourceInfoProvider
+import io.github.thibaultbee.streampack.core.elements.processing.video.source.ISourceInfoProvider
+import io.github.thibaultbee.streampack.core.elements.sources.video.ISurfaceSource
+import io.github.thibaultbee.streampack.core.elements.sources.video.IVideoFrameSource
+import io.github.thibaultbee.streampack.core.elements.sources.video.IVideoSourceInternal
+import io.github.thibaultbee.streampack.core.elements.sources.video.VideoSourceConfig
+import kotlinx.coroutines.flow.MutableStateFlow
+import kotlinx.coroutines.flow.StateFlow
+import java.nio.ByteBuffer
+
+class StubVideoSurfaceSource(override val timestampOffset: Long = 0) : StubVideoSource(),
+    ISurfaceSource {
+    override var outputSurface: Surface? = null
+}
+
+class StubVideoFrameSource : StubVideoSource(), IVideoFrameSource {
+    override fun getVideoFrame(buffer: ByteBuffer): Frame {
+        return Frame(
+            buffer,
+            0L,
+            format = MediaFormat().apply {
+                setString(
+                    MediaFormat.KEY_MIME,
+                    MediaFormat.MIMETYPE_VIDEO_RAW
+                )
+            })
+    }
+}
+
+
+abstract class StubVideoSource : IVideoSourceInternal {
+    override val infoProviderFlow: StateFlow<ISourceInfoProvider> =
+        MutableStateFlow(DefaultSourceInfoProvider())
+
+    private val _isStreamingFlow = MutableStateFlow(false)
+    override val isStreamingFlow: StateFlow<Boolean> = _isStreamingFlow
+
+    private val _configurationFlow = MutableStateFlow<VideoSourceConfig?>(null)
+    val configurationFlow: StateFlow<VideoSourceConfig?> = _configurationFlow
+
+    override suspend fun startStream() {
+        _isStreamingFlow.emit(true)
+    }
+
+    override suspend fun stopStream() {
+        _isStreamingFlow.emit(false)
+    }
+
+    override fun configure(config: VideoSourceConfig) {
+        _configurationFlow.value = config
+    }
+
+    override fun release() {
+
+    }
+}