Skip to content

Commit 7dc6ee5

Browse files
committed
fix(*): fix srt Media Descriptor packages
1 parent 5260b90 commit 7dc6ee5

File tree

5 files changed

+20
-19
lines changed

5 files changed

+20
-19
lines changed

demos/camera/src/main/java/io/github/thibaultbee/streampack/app/data/storage/DataStoreRepository.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ import io.github.thibaultbee.streampack.core.configuration.mediadescriptor.Media
2121
import io.github.thibaultbee.streampack.core.configuration.mediadescriptor.UriMediaDescriptor
2222
import io.github.thibaultbee.streampack.core.streamers.single.AudioConfig
2323
import io.github.thibaultbee.streampack.core.streamers.single.VideoConfig
24-
import io.github.thibaultbee.streampack.ext.srt.data.mediadescriptor.SrtMediaDescriptor
24+
import io.github.thibaultbee.streampack.ext.srt.configuration.mediadescriptor.SrtMediaDescriptor
2525
import kotlinx.coroutines.flow.Flow
2626
import kotlinx.coroutines.flow.distinctUntilChanged
2727
import kotlinx.coroutines.flow.map

demos/screenrecorder/src/main/java/io/github/thibaultbee/streampack/screenrecorder/MainActivity.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ import io.github.thibaultbee.streampack.core.streamers.single.ISingleStreamer
5151
import io.github.thibaultbee.streampack.core.streamers.single.IVideoSingleStreamer
5252
import io.github.thibaultbee.streampack.core.streamers.single.VideoConfig
5353
import io.github.thibaultbee.streampack.core.streamers.utils.MediaProjectionUtils
54-
import io.github.thibaultbee.streampack.ext.srt.data.mediadescriptor.SrtMediaDescriptor
54+
import io.github.thibaultbee.streampack.ext.srt.configuration.mediadescriptor.SrtMediaDescriptor
5555
import io.github.thibaultbee.streampack.screenrecorder.databinding.ActivityMainBinding
5656
import io.github.thibaultbee.streampack.screenrecorder.models.EndpointType
5757
import io.github.thibaultbee.streampack.screenrecorder.services.DemoMediaProjectionService
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (C) 2023 Thibault B.
2+
* Copyright (C) 2025 Thibault B.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -13,46 +13,44 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package io.github.thibaultbee.streampack.ext.srt.data
16+
package io.github.thibaultbee.streampack.ext.srt.configuration.mediadescriptor
1717

18-
import io.github.thibaultbee.streampack.ext.srt.data.mediadescriptor.SrtMediaDescriptor
19-
import org.junit.Assert.assertEquals
20-
import org.junit.Assert.fail
18+
import org.junit.Assert
2119
import org.junit.Test
2220

2321
class SrtMediaDescriptorTest {
2422
@Test
2523
fun fromUrl() {
2624
val url = "srt://broadcast.host.com:1234"
2725
val connection = SrtMediaDescriptor(url)
28-
assertEquals("broadcast.host.com", connection.host)
29-
assertEquals(1234, connection.port)
26+
Assert.assertEquals("broadcast.host.com", connection.host)
27+
Assert.assertEquals(1234, connection.port)
3028
}
3129

3230
@Test
3331
fun fromIp() {
3432
val url = "srt://192.168.1.12:1234"
3533
val connection = SrtMediaDescriptor(url)
36-
assertEquals("192.168.1.12", connection.host)
37-
assertEquals(1234, connection.port)
34+
Assert.assertEquals("192.168.1.12", connection.host)
35+
Assert.assertEquals(1234, connection.port)
3836
}
3937

4038
@Test
4139
fun fromUrlWithParameters() {
4240
val url = "srt://host.com:1234?streamid=streamId&passphrase=passPhrase"
4341
val connection = SrtMediaDescriptor(url)
44-
assertEquals("host.com", connection.host)
45-
assertEquals(1234, connection.port)
46-
assertEquals("streamId", connection.streamId)
47-
assertEquals("passPhrase", connection.passphrase)
42+
Assert.assertEquals("host.com", connection.host)
43+
Assert.assertEquals(1234, connection.port)
44+
Assert.assertEquals("streamId", connection.streamId)
45+
Assert.assertEquals("passPhrase", connection.passphrase)
4846
}
4947

5048
@Test
5149
fun fromUrlWithBadScheme() {
5250
val url = "srtp://broadcast.host.com:1234"
5351
try {
5452
SrtMediaDescriptor(url)
55-
fail("Should throw an exception")
53+
Assert.fail("Should throw an exception")
5654
} catch (_: Throwable) {
5755
}
5856
}
@@ -63,7 +61,10 @@ class SrtMediaDescriptorTest {
6361
try {
6462
SrtMediaDescriptor(url)
6563
} catch (t: Throwable) {
66-
assertEquals("Failed to parse URL $url: unknown parameter(s): unknown", t.message)
64+
Assert.assertEquals(
65+
"Failed to parse URL $url: unknown parameter(s): unknown",
66+
t.message
67+
)
6768
}
6869
}
6970
}
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package io.github.thibaultbee.streampack.ext.srt.data.mediadescriptor
16+
package io.github.thibaultbee.streampack.ext.srt.configuration.mediadescriptor
1717

1818
import android.net.Uri
1919
import io.github.thibaultbee.srtdroid.core.models.SrtUrl

extensions/srt/src/main/java/io/github/thibaultbee/streampack/ext/srt/elements/endpoints/composites/sinks/SrtSink.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ import io.github.thibaultbee.streampack.core.elements.endpoints.MediaSinkType
3030
import io.github.thibaultbee.streampack.core.elements.endpoints.composites.sinks.AbstractSink
3131
import io.github.thibaultbee.streampack.core.elements.endpoints.composites.sinks.ClosedException
3232
import io.github.thibaultbee.streampack.core.elements.endpoints.composites.sinks.SinkConfiguration
33-
import io.github.thibaultbee.streampack.ext.srt.data.mediadescriptor.SrtMediaDescriptor
33+
import io.github.thibaultbee.streampack.ext.srt.configuration.mediadescriptor.SrtMediaDescriptor
3434
import kotlinx.coroutines.flow.MutableStateFlow
3535
import kotlinx.coroutines.flow.asStateFlow
3636
import kotlinx.coroutines.runBlocking

0 commit comments

Comments
 (0)