Line data    Source code

       1              : import 'package:webrtc_interface/webrtc_interface.dart';
       2              : 
       3              : import 'package:matrix/matrix.dart';
       4              : import 'package:matrix/src/utils/cached_stream_controller.dart';
       5              : import 'package:matrix/src/voip/utils/stream_helper.dart';
       6              : 
       7              : /// Wrapped MediaStream, used to adapt Widget to display
       8              : class WrappedMediaStream {
       9              :   MediaStream? stream;
      10              :   final CallParticipant participant;
      11              :   final Room room;
      12              :   final VoIP voip;
      13              : 
      14              :   /// Current stream type, usermedia or screen-sharing
      15              :   String purpose;
      16              :   bool audioMuted;
      17              :   bool videoMuted;
      18              :   final Client client;
      19              :   final bool isGroupCall;
      20              :   final RTCPeerConnection? pc;
      21              : 
      22              :   /// for debug
      23            0 :   String get title =>
      24            0 :       '${client.userID!}:${client.deviceID!} $displayName:$purpose:a[$audioMuted]:v[$videoMuted]';
      25              :   bool stopped = false;
      26              : 
      27              :   final CachedStreamController<WrappedMediaStream> onMuteStateChanged =
      28              :       CachedStreamController();
      29              : 
      30              :   final CachedStreamController<MediaStream> onStreamChanged =
      31              :       CachedStreamController();
      32              : 
      33            2 :   WrappedMediaStream({
      34              :     this.stream,
      35              :     this.pc,
      36              :     required this.room,
      37              :     required this.participant,
      38              :     required this.purpose,
      39              :     required this.client,
      40              :     required this.audioMuted,
      41              :     required this.videoMuted,
      42              :     required this.isGroupCall,
      43              :     required this.voip,
      44              :   });
      45              : 
      46            0 :   String get id => '${stream?.id}: $title';
      47              : 
      48            2 :   Future<void> dispose() async {
      49              :     // AOT it
      50              :     const isWeb = bool.fromEnvironment('dart.library.js_util');
      51              : 
      52              :     // libwebrtc does not provide a way to clone MediaStreams. So stopping the
      53              :     // local stream here would break calls with all other participants if anyone
      54              :     // leaves. The local stream is manually disposed when user leaves. On web
      55              :     // streams are actually cloned.
      56            2 :     if (!isGroupCall || isWeb) {
      57            4 :       await stopMediaStream(stream);
      58              :     }
      59              : 
      60            2 :     stream = null;
      61              :   }
      62              : 
      63            0 :   Uri? get avatarUrl => getUser().avatarUrl;
      64              : 
      65            0 :   String get avatarName =>
      66            0 :       getUser().calcDisplayname(mxidLocalPartFallback: false);
      67              : 
      68            0 :   String? get displayName => getUser().displayName;
      69              : 
      70            0 :   User getUser() {
      71            0 :     return room.unsafeGetUserFromMemoryOrFallback(participant.userId);
      72              :   }
      73              : 
      74            2 :   bool isLocal() {
      75            8 :     return participant == voip.localParticipant;
      76              :   }
      77              : 
      78            0 :   bool isAudioMuted() {
      79            0 :     return (stream != null && stream!.getAudioTracks().isEmpty) || audioMuted;
      80              :   }
      81              : 
      82            0 :   bool isVideoMuted() {
      83            0 :     return (stream != null && stream!.getVideoTracks().isEmpty) || videoMuted;
      84              :   }
      85              : 
      86            0 :   void setNewStream(MediaStream newStream) {
      87            0 :     stream = newStream;
      88            0 :     onStreamChanged.add(stream!);
      89              :   }
      90              : 
      91            0 :   void setAudioMuted(bool muted) {
      92            0 :     audioMuted = muted;
      93            0 :     onMuteStateChanged.add(this);
      94              :   }
      95              : 
      96            0 :   void setVideoMuted(bool muted) {
      97            0 :     videoMuted = muted;
      98            0 :     onMuteStateChanged.add(this);
      99              :   }
     100              : }