ParticipantTest.kt
5.0 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
package io.livekit.android.room.participant
import io.livekit.android.coroutines.TestCoroutineRule
import io.livekit.android.events.EventCollector
import io.livekit.android.events.ParticipantEvent
import io.livekit.android.room.track.TrackPublication
import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.test.runTest
import livekit.LivekitModels
import org.junit.Assert
import org.junit.Assert.assertEquals
import org.junit.Assert.assertTrue
import org.junit.Before
import org.junit.Rule
import org.junit.Test
@ExperimentalCoroutinesApi
class ParticipantTest {
@get:Rule
var coroutineRule = TestCoroutineRule()
lateinit var participant: Participant
@Before
fun setup() {
participant = Participant("", null, coroutineRule.dispatcher)
}
@Test
fun updateFromInfo() = runTest {
participant.updateFromInfo(INFO)
assertTrue(participant.hasInfo)
assertEquals(INFO.sid, participant.sid)
assertEquals(INFO.identity, participant.identity)
assertEquals(INFO.metadata, participant.metadata)
assertEquals(INFO.name, participant.name)
assertEquals(INFO, participant.participantInfo)
}
@Test
fun setMetadataCallsListeners() = runTest {
class MetadataListener : ParticipantListener {
var wasCalled = false
lateinit var participantValue: Participant
var prevMetadataValue: String? = null
override fun onMetadataChanged(participant: Participant, prevMetadata: String?) {
wasCalled = true
participantValue = participant
prevMetadataValue = prevMetadata
}
}
val publicListener = MetadataListener()
val internalListener = MetadataListener()
participant.listener = publicListener
participant.internalListener = internalListener
val prevMetadata = participant.metadata
val metadata = "metadata"
participant.metadata = metadata
fun checkValues(listener: MetadataListener) {
assertTrue(listener.wasCalled)
assertEquals(participant, listener.participantValue)
assertEquals(prevMetadata, listener.prevMetadataValue)
}
checkValues(publicListener)
checkValues(internalListener)
}
@Test
fun setMetadataChangedEvent() = runTest {
val eventCollector = EventCollector(participant.events, coroutineRule.scope)
val prevMetadata = participant.metadata
val metadata = "metadata"
participant.metadata = metadata
val events = eventCollector.stopCollecting()
assertEquals(1, events.size)
assertEquals(true, events[0] is ParticipantEvent.MetadataChanged)
val event = events[0] as ParticipantEvent.MetadataChanged
assertEquals(prevMetadata, event.prevMetadata)
assertEquals(participant, event.participant)
}
@Test
fun setIsSpeakingChangedEvent() = runTest {
val eventCollector = EventCollector(participant.events, coroutineRule.scope)
val newIsSpeaking = !participant.isSpeaking
participant.isSpeaking = newIsSpeaking
val events = eventCollector.stopCollecting()
assertEquals(1, events.size)
assertEquals(true, events[0] is ParticipantEvent.SpeakingChanged)
val event = events[0] as ParticipantEvent.SpeakingChanged
assertEquals(participant, event.participant)
assertEquals(newIsSpeaking, event.isSpeaking)
}
@Test
fun addTrackPublication() = runTest {
val audioPublication = TrackPublication(TRACK_INFO, null, participant)
participant.addTrackPublication(audioPublication)
assertEquals(1, participant.tracks.values.size)
assertEquals(audioPublication, participant.tracks.values.first())
assertEquals(1, participant.audioTracks.size)
assertEquals(audioPublication, participant.audioTracks.first().first)
}
@Test
fun dispose() = runTest {
val audioPublication = TrackPublication(TRACK_INFO, null, participant)
participant.addTrackPublication(audioPublication)
participant.dispose()
assertEquals("", participant.sid)
Assert.assertNull(participant.name)
Assert.assertNull(participant.identity)
Assert.assertNull(participant.metadata)
Assert.assertNull(participant.permissions)
Assert.assertNull(participant.participantInfo)
Assert.assertFalse(participant.isSpeaking)
assertEquals(ConnectionQuality.UNKNOWN, participant.connectionQuality)
}
companion object {
val INFO = LivekitModels.ParticipantInfo.newBuilder()
.setSid("sid")
.setIdentity("identity")
.setMetadata("metadata")
.setName("name")
.build()
val TRACK_INFO = LivekitModels.TrackInfo.newBuilder()
.setSid("sid")
.setName("name")
.setType(LivekitModels.TrackType.AUDIO)
.setMuted(false)
.setMimeType("audio/mpeg")
.build()
}
}