Fix getStats.

Author: cloudwebrtc

CHANGELOG.md

@@ -1,6 +1,10 @@
 # Changelog
 
 --------------------------------------------
+0.2.1
+
+* Fix getStats.
+
 0.2.0
 
 * Implement basic functions.

lib/src/rtc_peerconnection.dart

@@ -119,7 +119,7 @@ class RTCPeerConnectionJs {
   external List<RTCRtpTransceiver> getTransceivers();
   external RTCRtpTransceiver addTransceiver(
       dynamic trackOrKind, RTCRtpTransceiverInit init);
-  external Map<String, RTCStats> getStats();
+  external RTCStatsReportJs getStats();
   external void restartIce();
   external RTCDTMFSender createDTMFSender();
   external set onaddstream(Function(MediaStreamEvent stream) func);
@@ -176,7 +176,15 @@ class RTCPeerConnection {
     return RTCSessionDescription(type: desc.type, sdp: desc.sdp);
   }
 
-  Map<String, RTCStats> getStats() => _internal.getStats();
+  Future<RTCStatsReport> getStats() async {
+    try {
+      var jsStats =
+          await promiseToFuture<RTCStatsReportJs>(_internal.getStats());
+      return RTCStatsReport(jsStats);
+    } catch (e) {
+      rethrow;
+    }
+  }
 
   List<MediaStreamJs> getLocalStreams() => _internal.getLocalStreams();
 

lib/src/rtc_rtp_receiver.dart

@@ -12,6 +12,6 @@ class RTCRtpReceiver {
   external factory RTCRtpReceiver();
   external MediaStreamTrack get track;
   external RTCRtpEncodingParameters getParameters();
-  external RTCStatsReport getStats();
+  external RTCStatsReportJs getStats();
   external static dynamic getCapabilities();
 }

lib/src/rtc_rtp_sender.dart

@@ -7,6 +7,7 @@ import 'media_stream.dart';
 import 'media_stream_track.dart';
 import 'rtc_dtmf_sender.dart';
 import 'rtc_rtp_parameters.dart';
+import 'rtc_stats_resport.dart';
 
 @JS('RTCRtpSender')
 class RTCRtpSender {
@@ -15,7 +16,7 @@ class RTCRtpSender {
   external RTCDTMFSender get dtmf;
   external RTCRtpEncodingParameters getParameters();
   external bool setParameters(RTCRtpEncodingParameters parameters);
-  external dynamic getStats();
+  external RTCStatsReportJs getStats();
   external void setStreams(List<MediaStream> streams);
   external void replaceTrack(MediaStreamTrack track);
   external static dynamic getCapabilities();

lib/src/rtc_stats_resport.dart

@@ -1,18 +1,57 @@
 @JS()
 library dart_webrtc;
 
-import 'dart:collection';
+import 'dart:convert';
 
 import 'package:js/js.dart';
 
-@JS('RTCStats')
-abstract class RTCStats extends Object {
-  external dynamic get timestamp;
-  external String get type;
-  external String get id;
+class RTCStats {
+  RTCStats({this.type, this.id, this.timestamp, this.values});
+  factory RTCStats.fromMap(Map<String, dynamic> map) => RTCStats(
+      id: map['id'],
+      type: map['type'],
+      timestamp: map['timestamp'],
+      values: map);
+  String type;
+
+  String id;
+
+  dynamic timestamp;
+
+  List<String> names() => values.entries.map((e) => e.key).toList();
+
+  Map<String, dynamic> values;
+}
+
+class RTCStatsReport {
+  RTCStatsReport(this._jsStats) {
+    _jsStats.forEach(allowInterop((dynamic value, String key, dynamic array) {
+      _stats[key] = RTCStats.fromMap(statsToMap(value));
+    }));
+  }
+  final RTCStatsReportJs _jsStats;
+  Map<String, RTCStats> _stats = {};
+
+  int get size => _jsStats.size;
+
+  RTCStats operator [](String key) => _stats[key];
+
+  List<String> keys() => _stats.entries.map((e) => e.key).toList();
+
+  Map<String, RTCStats> get values => _stats;
 }
 
 @JS('RTCStatsReport')
-abstract class RTCStatsReport extends ListBase<RTCStats> {
+abstract class RTCStatsReportJs {
   external int get size;
+  external void forEach(
+      void Function(dynamic stats, String key, dynamic _) func);
 }
+
+// Calls invoke JavaScript `JSON.stringify(obj)`.
+@JS('JSON.stringify')
+external String stringify(Object obj);
+final JsonDecoder decoder = JsonDecoder();
+
+Map<String, dynamic> statsToMap(dynamic stats) =>
+    decoder.convert(stringify(stats));

pubspec.yaml

@@ -1,6 +1,6 @@
 name: dart_webrtc
 description: Use the dart/js library to re-wrap the webrtc js interface of the browser, to adapted common browsers.
-version: 0.2.0
+version: 0.2.1
 homepage: https://github.com/flutter-webrtc/dart-webrtc
 
 environment:

web/test_peerconnection.dart

@@ -35,13 +35,13 @@ void addStateCallbacks(RTCPeerConnection pc, String title) {
         '$title: ontrack => ${event.track.id}, \nkind =>  ${event.track.kind}\nstream.length => ${event.streams.length}');
     var params = event.receiver.getParameters();
     print('reducedSize => ${params.rtcp.reducedSize}');
-    var stats =
-        await promiseToFuture<RTCStatsReport>(event.receiver.getStats());
+    var stats = RTCStatsReport(
+        await promiseToFuture<RTCStatsReportJs>(event.receiver.getStats()));
     print('getStats => ');
-    stats.forEach((RTCStats report) {
+    stats.values.forEach((String key, RTCStats stats) {
       print(
-          '   type => ${report.type}, id => ${report.id}, timestamp => ${report.timestamp}');
-      print('        report => ${report.toString()}');
+          '   type => ${stats.type}, id => ${stats.id}, timestamp => ${stats.timestamp}');
+      print('        report => ${stats.values.toString()}');
     });
   };
 }