Skip to content

Commit b1e4a00

Browse files
Fix a rare crash when creating the publisher peer connection (#1507)
* Introduce PR quality checks * Remove `localParticipant`from publisher and thus the dependency towards `call.state.me` * Spotless * Update tests
1 parent 5b10694 commit b1e4a00

File tree

5 files changed

+0
-8
lines changed

5 files changed

+0
-8
lines changed

stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/call/RtcSession.kt

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -935,7 +935,6 @@ public class RtcSession internal constructor(
935935
internal fun createPublisher(publishOptions: List<PublishOption>): Publisher {
936936
return call.peerConnectionFactory.makePublisher(
937937
sessionId = sessionId,
938-
me = call.state.me.value!!,
939938
sfuClient = sfuConnectionModule.api,
940939
mediaManager = call.mediaManager,
941940
configuration = connectionConfiguration,

stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/call/connection/Publisher.kt

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@ package io.getstream.video.android.core.call.connection
1919
import androidx.annotation.VisibleForTesting
2020
import io.getstream.result.onErrorSuspend
2121
import io.getstream.video.android.core.MediaManagerImpl
22-
import io.getstream.video.android.core.ParticipantState
2322
import io.getstream.video.android.core.api.SignalServerService
2423
import io.getstream.video.android.core.call.connection.job.RestartIceJobDelegate
2524
import io.getstream.video.android.core.call.connection.stats.ComputedStats
@@ -65,7 +64,6 @@ import stream.video.sfu.signal.SetPublisherRequest
6564
import java.util.UUID
6665

6766
internal class Publisher(
68-
private val localParticipant: ParticipantState,
6967
private val mediaManager: MediaManagerImpl,
7068
private val peerConnectionFactory: StreamPeerConnectionFactory,
7169
private val publishOptions: List<PublishOption>,

stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/call/connection/StreamPeerConnectionFactory.kt

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@ import android.media.AudioAttributes
2121
import android.os.Build
2222
import io.getstream.log.taggedLogger
2323
import io.getstream.video.android.core.MediaManagerImpl
24-
import io.getstream.video.android.core.ParticipantState
2524
import io.getstream.video.android.core.api.SignalServerService
2625
import io.getstream.video.android.core.call.connection.coding.SelectiveVideoDecoderFactory
2726
import io.getstream.video.android.core.call.video.FilterVideoProcessor
@@ -349,7 +348,6 @@ public class StreamPeerConnectionFactory(
349348
}
350349

351350
internal fun makePublisher(
352-
me: ParticipantState,
353351
mediaManager: MediaManagerImpl,
354352
publishOptions: List<PublishOption>,
355353
coroutineScope: CoroutineScope,
@@ -368,7 +366,6 @@ public class StreamPeerConnectionFactory(
368366
sessionId = sessionId,
369367
sfuClient = sfuClient,
370368
peerConnectionFactory = this,
371-
localParticipant = me,
372369
mediaManager = mediaManager,
373370
publishOptions = publishOptions,
374371
coroutineScope = coroutineScope,

stream-video-android-core/src/test/kotlin/io/getstream/video/android/core/call/connection/PublisherTest.kt

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -152,7 +152,6 @@ class PublisherTest {
152152
// Construct a "real" Publisher but spy it, so we can mock or verify inherited calls.
153153
publisher = spyk(
154154
Publisher(
155-
localParticipant = mockParticipantState,
156155
mediaManager = mockMediaManager,
157156
peerConnectionFactory = mockPeerConnectionFactory,
158157
publishOptions = listOf(videoPublishOption, audioPublishOption),

stream-video-android-core/src/test/kotlin/io/getstream/video/android/core/call/connection/StreamPeerConnectionFactoryTest.kt

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -105,7 +105,6 @@ class StreamPeerConnectionFactoryTest {
105105

106106
// We're testing makePublisher, so we pass in all required arguments
107107
val publisher = factory.makePublisher(
108-
me = mockParticipantState,
109108
mediaManager = mockMediaManager,
110109
publishOptions = fakePublishOptions,
111110
coroutineScope = testScope,

0 commit comments

Comments
 (0)