Merge pull request #1836 from famedly/td/participantChangeStreams

feat: add participant changed streams
famedly · May 30, 2024 · 0330d9b · 0330d9b
2 parents 579546b + 2e1e3a4
commit 0330d9b
Show file tree

Hide file tree

Showing 3 changed files with 28 additions and 0 deletions.
diff --git a/lib/matrix.dart b/lib/matrix.dart
@@ -42,6 +42,7 @@ export 'src/voip/models/call_events.dart';
 export 'src/voip/models/webrtc_delegate.dart';
 export 'src/voip/models/call_participant.dart';
 export 'src/voip/models/key_provider.dart';
+export 'src/voip/models/matrixrtc_call_event.dart';
 export 'src/voip/utils/conn_tester.dart';
 export 'src/voip/utils/voip_constants.dart';
 export 'src/voip/utils/rtc_candidate_extension.dart';

diff --git a/lib/src/voip/group_call_session.dart b/lib/src/voip/group_call_session.dart
@@ -58,6 +58,9 @@ class GroupCallSession {
   final CachedStreamController<GroupCallStateChange> onGroupCallEvent =
       CachedStreamController();
 
+  final CachedStreamController<MatrixRTCCallEvent> matrixRTCEventStream =
+      CachedStreamController();
+
   Timer? _resendMemberStateEventTimer;
 
   factory GroupCallSession.withAutoGenId(
@@ -254,6 +257,8 @@ class GroupCallSession {
           await backend.onNewParticipant(this, nonLocalAnyJoined.toList());
         }
         _participants.addAll(anyJoined);
+        matrixRTCEventStream
+            .add(ParticipantsJoinEvent(participants: anyJoined.toList()));
       }
       if (anyLeft.isNotEmpty) {
         final nonLocalAnyLeft = Set<CallParticipant>.from(anyLeft)
@@ -264,6 +269,8 @@ class GroupCallSession {
           await backend.onLeftParticipant(this, nonLocalAnyLeft.toList());
         }
         _participants.removeAll(anyLeft);
+        matrixRTCEventStream
+            .add(ParticipantsLeftEvent(participants: anyLeft.toList()));
       }
 
       onGroupCallEvent.add(GroupCallStateChange.participantsChanged);

diff --git a/lib/src/voip/models/matrixrtc_call_event.dart b/lib/src/voip/models/matrixrtc_call_event.dart
@@ -0,0 +1,20 @@
+import 'package:matrix/matrix.dart';
+
+/// UNSTABLE API WARNING
+/// The class herirachy is currently experimental and could have breaking changes
+/// often.
+sealed class MatrixRTCCallEvent {}
+
+sealed class ParticipantsChangeEvent implements MatrixRTCCallEvent {}
+
+final class ParticipantsJoinEvent implements ParticipantsChangeEvent {
+  final List<CallParticipant> participants;
+
+  ParticipantsJoinEvent({required this.participants});
+}
+
+final class ParticipantsLeftEvent implements ParticipantsChangeEvent {
+  final List<CallParticipant> participants;
+
+  ParticipantsLeftEvent({required this.participants});
+}