Line data    Source code

       1             : import 'package:collection/collection.dart';
       2             : import 'package:random_string/random_string.dart';
       3             : import 'package:webrtc_interface/webrtc_interface.dart';
       4             : 
       5             : import 'package:matrix/matrix.dart';
       6             : 
       7           2 : Future<void> stopMediaStream(MediaStream? stream) async {
       8             :   if (stream != null) {
       9           2 :     for (final track in stream.getTracks()) {
      10             :       try {
      11           0 :         await track.stop();
      12             :       } catch (e, s) {
      13           0 :         Logs().e('[VOIP] stopping track ${track.id} failed', e, s);
      14             :       }
      15             :     }
      16             :     try {
      17           2 :       await stream.dispose();
      18             :     } catch (e, s) {
      19           0 :       Logs().e('[VOIP] disposing stream ${stream.id} failed', e, s);
      20             :     }
      21             :   }
      22             : }
      23             : 
      24           0 : void setTracksEnabled(List<MediaStreamTrack> tracks, bool enabled) {
      25           0 :   for (final element in tracks) {
      26           0 :     element.enabled = enabled;
      27             :   }
      28             : }
      29             : 
      30           0 : Future<bool> hasMediaDevice(
      31             :   WebRTCDelegate delegate,
      32             :   MediaInputKind mediaInputKind,
      33             : ) async {
      34           0 :   final devices = await delegate.mediaDevices.enumerateDevices();
      35             :   return devices
      36           0 :       .where((device) => device.kind == mediaInputKind.name)
      37           0 :       .isNotEmpty;
      38             : }
      39             : 
      40           0 : Future<void> updateMediaDevice(
      41             :   WebRTCDelegate delegate,
      42             :   MediaKind kind,
      43             :   List<RTCRtpSender> userRtpSenders, [
      44             :   MediaStreamTrack? track,
      45             : ]) async {
      46             :   final sender = userRtpSenders
      47           0 :       .firstWhereOrNull((element) => element.track!.kind == kind.name);
      48           0 :   await sender?.track?.stop();
      49             :   if (track != null) {
      50           0 :     await sender?.replaceTrack(track);
      51             :   } else {
      52           0 :     final stream = await delegate.mediaDevices.getUserMedia({kind.name: true});
      53             :     MediaStreamTrack? track;
      54           0 :     if (kind == MediaKind.audio) {
      55           0 :       track = stream.getAudioTracks().firstOrNull;
      56           0 :     } else if (kind == MediaKind.video) {
      57           0 :       track = stream.getVideoTracks().firstOrNull;
      58             :     }
      59             :     if (track != null) {
      60           0 :       await sender?.replaceTrack(track);
      61             :     }
      62             :   }
      63             : }
      64             : 
      65           2 : String genCallID() {
      66           8 :   return '${DateTime.now().millisecondsSinceEpoch}${randomAlphaNumeric(16)}';
      67             : }