refactor: use separate interface

Author: cloudwebrtc

lib/dart_webrtc.dart

@@ -1,20 +1,9 @@
-export 'src/enums.dart';
-export 'src/event.dart';
+library dart_webrtc;
+
+export 'package:webrtc_interface/webrtc_interface.dart'
+    hide MediaDevices, MediaRecorder, Navigator;
+
 export 'src/media_devices.dart';
-export 'src/media_stream.dart';
-export 'src/media_stream_track.dart';
-export 'src/navigator.dart';
-export 'src/rtc_data_channel.dart';
-export 'src/rtc_dtmf_sender.dart';
-export 'src/rtc_ice_candidate.dart';
-export 'src/rtc_peerconnection.dart';
-export 'src/rtc_peerconnection.dart';
-export 'src/rtc_rtcp_parameters.dart';
-export 'src/rtc_rtp_parameters.dart';
-export 'src/rtc_rtp_receiver.dart';
-export 'src/rtc_rtp_sender.dart';
-export 'src/rtc_rtp_transceiver.dart';
-export 'src/rtc_session_description.dart';
-export 'src/rtc_stats_resport.dart';
-export 'src/rtc_track_event.dart';
+export 'src/media_recorder.dart';
+export 'src/rtc_peerconnection_factory.dart';
 export 'src/video_element.dart';

lib/src/enums.dart

@@ -0,0 +1,50 @@
+import 'dart:async';
+import 'dart:convert';
+import 'dart:html' as html;
+import 'package:webrtc_interface/webrtc_interface.dart';
+
+import 'media_recorder_impl.dart';
+import 'media_stream_impl.dart';
+import 'navigator_impl.dart';
+import 'rtc_peerconnection_impl.dart';
+
+class RTCFactoryWeb extends RTCFactory {
+  RTCFactoryWeb._internal();
+  static final instance = RTCFactoryWeb._internal();
+
+  @override
+  Future<RTCPeerConnection> createPeerConnection(
+      Map<String, dynamic> configuration,
+      [Map<String, dynamic>? constraints]) async {
+    final constr = (constraints != null && constraints.isNotEmpty)
+        ? constraints
+        : {
+            'mandatory': {},
+            'optional': [
+              {'DtlsSrtpKeyAgreement': true},
+            ],
+          };
+    final jsRtcPc = html.RtcPeerConnection({...constr, ...configuration});
+    final _peerConnectionId = base64Encode(jsRtcPc.toString().codeUnits);
+    return RTCPeerConnectionWeb(_peerConnectionId, jsRtcPc);
+  }
+
+  @override
+  Future<MediaStream> createLocalMediaStream(String label) async {
+    final jsMs = html.MediaStream();
+    return MediaStreamWeb(jsMs, 'local');
+  }
+
+  @override
+  MediaRecorder mediaRecorder() {
+    return MediaRecorderWeb();
+  }
+
+  @override
+  VideoRenderer videoRenderer() {
+    throw UnimplementedError();
+  }
+
+  @override
+  Navigator get navigator => NavigatorWeb();
+}

lib/src/event.dart

@@ -1,69 +1,25 @@
-@JS()
-library dart_webrtc;
-
-import 'package:js/js.dart';
-import 'package:js/js_util.dart';
-
-import 'event.dart';
-import 'media_stream.dart';
-
-@JS()
-@anonymous
-class MediaStreamConstraints {
-  external factory MediaStreamConstraints({dynamic audio, dynamic video});
-  external dynamic get audio;
-  external dynamic get video;
-}
-
-@JS('MediaDeviceInfo')
-class MediaDeviceInfo {
-  external String get deviceId;
-  external String get groupId;
-  external String get kind;
-  external String get label;
-}
-
-@JS('MediaDevices')
-class MediaDevicesJs {
-  external factory MediaDevicesJs();
-  external dynamic enumerateDevices();
-  external dynamic getUserMedia(MediaStreamConstraints constraints);
-  external dynamic getDisplayMedia(MediaStreamConstraints constraints);
-  external set devicechange(Function(Event<MediaDevicesJs> event) func);
-}
+import 'package:webrtc_interface/webrtc_interface.dart';
+import '../dart_webrtc.dart';
+import 'rtc_peerconnection_factory.dart';
 
 class MediaDevices {
-  MediaDevices(this._js);
-
-  Future<List<MediaDeviceInfo>> enumerateDevices() async {
-    try {
-      var jsList = await promiseToFuture<List<dynamic>>(_js.enumerateDevices());
-      return jsList.map((e) => e as MediaDeviceInfo).toList();
-    } catch (e) {
-      rethrow;
-    }
+  @Deprecated(
+      'Use the navigator.mediaDevices.getUserMedia(Map<String, dynamic>) provide from the facrory instead')
+  static Future<MediaStream> getUserMedia(
+      Map<String, dynamic> mediaConstraints) async {
+    return navigator.mediaDevices.getUserMedia(mediaConstraints);
   }
 
-  Future<MediaStream> getUserMedia({MediaStreamConstraints constraints}) async {
-    try {
-      var jsStream =
-          await promiseToFuture<MediaStreamJs>(_js.getUserMedia(constraints));
-      return MediaStream(jsStream);
-    } catch (e) {
-      rethrow;
-    }
+  @Deprecated(
+      'Use the navigator.mediaDevices.getDisplayMedia(Map<String, dynamic>) provide from the facrory instead')
+  static Future<MediaStream> getDisplayMedia(
+      Map<String, dynamic> mediaConstraints) async {
+    return navigator.mediaDevices.getDisplayMedia(mediaConstraints);
   }
 
-  Future<MediaStream> getDisplayMedia(
-      {MediaStreamConstraints constraints}) async {
-    try {
-      var jsStream = await promiseToFuture<MediaStreamJs>(
-          _js.getDisplayMedia(constraints));
-      return MediaStream(jsStream);
-    } catch (e) {
-      rethrow;
-    }
+  @Deprecated(
+      'Use the navigator.mediaDevices.getSources() provide from the facrory instead')
+  static Future<List<dynamic>> getSources() {
+    return navigator.mediaDevices.getSources();
   }
-
-  final MediaDevicesJs _js;
 }

lib/src/factory_impl.dart

@@ -0,0 +1,27 @@
+import 'package:webrtc_interface/src/media_recorder.dart' as _interface;
+import 'package:webrtc_interface/webrtc_interface.dart';
+
+import '../dart_webrtc.dart';
+import 'rtc_peerconnection_factory.dart';
+
+class MediaRecorder extends _interface.MediaRecorder {
+  MediaRecorder() : _delegate = mediaRecorder();
+  final _interface.MediaRecorder _delegate;
+
+  @override
+  Future<void> start(String path,
+          {MediaStreamTrack? videoTrack, RecorderAudioChannel? audioChannel}) =>
+      _delegate.start(path, videoTrack: videoTrack, audioChannel: audioChannel);
+
+  @override
+  Future stop() => _delegate.stop();
+
+  @override
+  void startWeb(
+    MediaStream stream, {
+    Function(dynamic blob, bool isLastOne)? onDataChunk,
+    String? mimeType,
+  }) =>
+      _delegate.startWeb(stream,
+          onDataChunk: onDataChunk, mimeType: mimeType ?? 'video/webm');
+}