|
6 | 6 | */ |
7 | 7 | package com.nextcloud.talk.call |
8 | 8 |
|
| 9 | +import com.nextcloud.talk.activities.ParticipantUiState |
9 | 10 | import com.nextcloud.talk.models.json.signaling.DataChannelMessage |
10 | 11 | import com.nextcloud.talk.models.json.signaling.NCMessagePayload |
11 | 12 | import com.nextcloud.talk.models.json.signaling.NCSignalingMessage |
@@ -92,9 +93,18 @@ class LocalStateBroadcasterMcuTest { |
92 | 93 | mockedMessageSender |
93 | 94 | ) |
94 | 95 |
|
95 | | - val callParticipantModel = MutableCallParticipantModel("theSessionId") |
| 96 | + val participantUiState = ParticipantUiState( |
| 97 | + sessionKey = "theSessionId", |
| 98 | + nick = "Guest", |
| 99 | + isConnected = false, |
| 100 | + isAudioEnabled = false, |
| 101 | + isStreamEnabled = false, |
| 102 | + isScreenStreamEnabled = false, |
| 103 | + raisedHand = false, |
| 104 | + isInternal = false |
| 105 | + ) |
96 | 106 |
|
97 | | - localStateBroadcasterMcu!!.handleCallParticipantAdded(callParticipantModel) |
| 107 | + localStateBroadcasterMcu!!.handleCallParticipantAdded(participantUiState) |
98 | 108 |
|
99 | 109 | // Sending will be done in another thread, so just adding the participant does not send anything until that |
100 | 110 | // other thread could run. |
@@ -185,9 +195,18 @@ class LocalStateBroadcasterMcuTest { |
185 | 195 | mockedMessageSender |
186 | 196 | ) |
187 | 197 |
|
188 | | - val callParticipantModel = MutableCallParticipantModel("theSessionId") |
| 198 | + val participantUiState = ParticipantUiState( |
| 199 | + sessionKey = "theSessionId", |
| 200 | + nick = "Guest", |
| 201 | + isConnected = false, |
| 202 | + isAudioEnabled = false, |
| 203 | + isStreamEnabled = false, |
| 204 | + isScreenStreamEnabled = false, |
| 205 | + raisedHand = false, |
| 206 | + isInternal = false |
| 207 | + ) |
189 | 208 |
|
190 | | - localStateBroadcasterMcu!!.handleCallParticipantAdded(callParticipantModel) |
| 209 | + localStateBroadcasterMcu!!.handleCallParticipantAdded(participantUiState) |
191 | 210 |
|
192 | 211 | // Sending will be done in another thread, so just adding the participant does not send anything until that |
193 | 212 | // other thread could run. |
@@ -296,9 +315,18 @@ class LocalStateBroadcasterMcuTest { |
296 | 315 | mockedMessageSender |
297 | 316 | ) |
298 | 317 |
|
299 | | - val callParticipantModel = MutableCallParticipantModel("theSessionId") |
| 318 | + val participantUiState = ParticipantUiState( |
| 319 | + sessionKey = "theSessionId", |
| 320 | + nick = "Guest", |
| 321 | + isConnected = false, |
| 322 | + isAudioEnabled = false, |
| 323 | + isStreamEnabled = false, |
| 324 | + isScreenStreamEnabled = false, |
| 325 | + raisedHand = false, |
| 326 | + isInternal = false |
| 327 | + ) |
300 | 328 |
|
301 | | - localStateBroadcasterMcu!!.handleCallParticipantAdded(callParticipantModel) |
| 329 | + localStateBroadcasterMcu!!.handleCallParticipantAdded(participantUiState) |
302 | 330 |
|
303 | 331 | // Sending will be done in another thread, so just adding the participant does not send anything until that |
304 | 332 | // other thread could run. |
@@ -355,9 +383,18 @@ class LocalStateBroadcasterMcuTest { |
355 | 383 | Mockito.verify(mockedMessageSender!!, times(signalingMessageCount1)).send(expectedUnmuteVideo, "theSessionId") |
356 | 384 | Mockito.verifyNoMoreInteractions(mockedMessageSender) |
357 | 385 |
|
358 | | - val callParticipantModel2 = MutableCallParticipantModel("theSessionId2") |
| 386 | + val participantUiState2 = ParticipantUiState( |
| 387 | + sessionKey = "theSessionId", |
| 388 | + nick = "Guest", |
| 389 | + isConnected = false, |
| 390 | + isAudioEnabled = false, |
| 391 | + isStreamEnabled = false, |
| 392 | + isScreenStreamEnabled = false, |
| 393 | + raisedHand = false, |
| 394 | + isInternal = false |
| 395 | + ) |
359 | 396 |
|
360 | | - localStateBroadcasterMcu!!.handleCallParticipantAdded(callParticipantModel2) |
| 397 | + localStateBroadcasterMcu!!.handleCallParticipantAdded(participantUiState2) |
361 | 398 |
|
362 | 399 | testScheduler.advanceTimeBy(0, TimeUnit.SECONDS) |
363 | 400 |
|
@@ -483,9 +520,18 @@ class LocalStateBroadcasterMcuTest { |
483 | 520 | mockedMessageSender |
484 | 521 | ) |
485 | 522 |
|
486 | | - val callParticipantModel = MutableCallParticipantModel("theSessionId") |
| 523 | + val participantUiState = ParticipantUiState( |
| 524 | + sessionKey = "theSessionId", |
| 525 | + nick = "Guest", |
| 526 | + isConnected = false, |
| 527 | + isAudioEnabled = false, |
| 528 | + isStreamEnabled = false, |
| 529 | + isScreenStreamEnabled = false, |
| 530 | + raisedHand = false, |
| 531 | + isInternal = false |
| 532 | + ) |
487 | 533 |
|
488 | | - localStateBroadcasterMcu!!.handleCallParticipantAdded(callParticipantModel) |
| 534 | + localStateBroadcasterMcu!!.handleCallParticipantAdded(participantUiState) |
489 | 535 |
|
490 | 536 | // Sending will be done in another thread, so just adding the participant does not send anything until that |
491 | 537 | // other thread could run. |
@@ -542,7 +588,7 @@ class LocalStateBroadcasterMcuTest { |
542 | 588 | Mockito.verify(mockedMessageSender!!, times(signalingMessageCount)).send(expectedUnmuteVideo, "theSessionId") |
543 | 589 | Mockito.verifyNoMoreInteractions(mockedMessageSender) |
544 | 590 |
|
545 | | - localStateBroadcasterMcu!!.handleCallParticipantRemoved(callParticipantModel) |
| 591 | + localStateBroadcasterMcu!!.handleCallParticipantRemoved(participantUiState.sessionKey) |
546 | 592 |
|
547 | 593 | testScheduler.advanceTimeBy(8, TimeUnit.SECONDS) |
548 | 594 |
|
@@ -579,11 +625,30 @@ class LocalStateBroadcasterMcuTest { |
579 | 625 | mockedMessageSender |
580 | 626 | ) |
581 | 627 |
|
582 | | - val callParticipantModel = MutableCallParticipantModel("theSessionId") |
583 | | - val callParticipantModel2 = MutableCallParticipantModel("theSessionId2") |
| 628 | + val participantUiState = ParticipantUiState( |
| 629 | + sessionKey = "theSessionId", |
| 630 | + nick = "Guest", |
| 631 | + isConnected = false, |
| 632 | + isAudioEnabled = false, |
| 633 | + isStreamEnabled = false, |
| 634 | + isScreenStreamEnabled = false, |
| 635 | + raisedHand = false, |
| 636 | + isInternal = false |
| 637 | + ) |
| 638 | + |
| 639 | + val participantUiState2 = ParticipantUiState( |
| 640 | + sessionKey = "theSessionId2", |
| 641 | + nick = "Guest", |
| 642 | + isConnected = false, |
| 643 | + isAudioEnabled = false, |
| 644 | + isStreamEnabled = false, |
| 645 | + isScreenStreamEnabled = false, |
| 646 | + raisedHand = false, |
| 647 | + isInternal = false |
| 648 | + ) |
584 | 649 |
|
585 | | - localStateBroadcasterMcu!!.handleCallParticipantAdded(callParticipantModel) |
586 | | - localStateBroadcasterMcu!!.handleCallParticipantAdded(callParticipantModel2) |
| 650 | + localStateBroadcasterMcu!!.handleCallParticipantAdded(participantUiState) |
| 651 | + localStateBroadcasterMcu!!.handleCallParticipantAdded(participantUiState2) |
587 | 652 |
|
588 | 653 | // Sending will be done in another thread, so just adding the participant does not send anything until that |
589 | 654 | // other thread could run. |
|
0 commit comments