paulhobbel
diff --git a/‎README.md
Lines changed: 8 additions & 0 deletions b/‎README.md
Lines changed: 8 additions & 0 deletions
diff --git a/‎lib/src/interface/rtc_rtp_receiver.dart
Lines changed: 3 additions & 0 deletions b/‎lib/src/interface/rtc_rtp_receiver.dart
Lines changed: 3 additions & 0 deletions
diff --git a/‎lib/src/interface/rtc_rtp_sender.dart
Lines changed: 3 additions & 0 deletions b/‎lib/src/interface/rtc_rtp_sender.dart
Lines changed: 3 additions & 0 deletions
diff --git a/‎lib/src/native/rtc_peerconnection_impl.dart
Lines changed: 4 additions & 2 deletions b/‎lib/src/native/rtc_peerconnection_impl.dart
Lines changed: 4 additions & 2 deletions
diff --git a/‎lib/src/native/rtc_rtp_receiver_impl.dart
Lines changed: 41 additions & 5 deletions b/‎lib/src/native/rtc_rtp_receiver_impl.dart
Lines changed: 41 additions & 5 deletions
diff --git a/‎lib/src/native/rtc_rtp_sender_impl.dart
Lines changed: 24 additions & 0 deletions b/‎lib/src/native/rtc_rtp_sender_impl.dart
Lines changed: 24 additions & 0 deletions
diff --git a/‎lib/src/native/rtc_rtp_transceiver_impl.dart
Lines changed: 2 additions & 1 deletion b/‎lib/src/native/rtc_rtp_transceiver_impl.dart
Lines changed: 2 additions & 1 deletion
diff --git a/‎lib/src/native/rtc_track_event_impl.dart
Lines changed: 2 additions & 1 deletion b/‎lib/src/native/rtc_track_event_impl.dart
Lines changed: 2 additions & 1 deletion
diff --git a/‎lib/src/web/rtc_rtp_receiver_impl.dart
Lines changed: 13 additions & 0 deletions b/‎lib/src/web/rtc_rtp_receiver_impl.dart
Lines changed: 13 additions & 0 deletions
diff --git a/‎lib/src/web/rtc_rtp_sender_impl.dart
Lines changed: 13 additions & 0 deletions b/‎lib/src/web/rtc_rtp_sender_impl.dart
Lines changed: 13 additions & 0 deletions
@@ -1,9 +1,11 @@
 # Flutter-WebRTC
+
 [![Financial Contributors on Open Collective](https://opencollective.com/flutter-webrtc/all/badge.svg?label=financial+contributors)](https://opencollective.com/flutter-webrtc) [![pub package](https://img.shields.io/pub/v/flutter_webrtc.svg)](https://pub.dartlang.org/packages/flutter_webrtc) [![Gitter](https://badges.gitter.im/flutter-webrtc/Lobby.svg)](https://gitter.im/flutter-webrtc/Lobby?utm_source=badge&utm_medium=badge&utm_campaign=pr-badge)
 
 WebRTC plugin for Flutter Mobile/Desktop/Web
 
 ## Functionality
+
 | Feature | Android | iOS | [Web](https://flutter.dev/web) | macOS | Windows | Linux | [Fuchsia](https://fuchsia.googlesource.com/) |
 | :-------------: | :-------------:| :-----: | :-----: | :-----: | :-----: | :-----: | :-----: |
 | Audio/Video | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | :heavy_check_mark: | [WIP] | [WIP] | |
@@ -14,6 +16,7 @@ WebRTC plugin for Flutter Mobile/Desktop/Web
 | MediaRecorder| :warning: | :warning: | :heavy_check_mark: | | | | |
 
 ## Usage
+
 Add `flutter_webrtc` as a [dependency in your pubspec.yaml file](https://flutter.io/using-packages/).
 
 ### iOS
@@ -44,6 +47,7 @@ Ensure the following permission is present in your Android Manifest file, locate
 ```
 
 If you need to use a Bluetooth device, please add:
+
 ```xml
 <uses-permission android:name="android.permission.BLUETOOTH" />
 <uses-permission android:name="android.permission.BLUETOOTH_ADMIN" />
@@ -52,6 +56,7 @@ If you need to use a Bluetooth device, please add:
 The Flutter project template adds it, so it may already be there.
 
 Also you will need to set your build settings to Java 8, because official WebRTC jar now uses static methods in `EglBase` interface. Just add this to your app level `build.gradle`:
+
 ```groovy
 android {
     //...
@@ -65,13 +70,16 @@ android {
 If necessary, in the same `build.gradle` you will need to increase `minSdkVersion` of `defaultConfig` up to `18` (currently default Flutter generator set it to `16`).
 
 ## Contributing
+
 The project is inseparable from the contributors of the community.
+
 - [CloudWebRTC](https://github.com/cloudwebrtc) - Original Author
 - [RainwayApp](https://github.com/rainwayapp) - Sponsor
 - [亢少军](https://github.com/kangshaojun) - Sponsor
 - [ION](https://github.com/pion/ion) - Sponsor
 
 ### Example
+
 For more examples, please refer to [flutter-webrtc-demo](https://github.com/cloudwebrtc/flutter-webrtc-demo/).
 
 ## Contributors
 
@@ -1,13 +1,16 @@
 import 'enums.dart';
 import 'media_stream_track.dart';
 import 'rtc_rtp_parameters.dart';
+import 'rtc_stats_report.dart';
 
 typedef OnFirstPacketReceivedCallback = void Function(
     RTCRtpReceiver rtpReceiver, RTCRtpMediaType mediaType);
 
 abstract class RTCRtpReceiver {
   RTCRtpReceiver();
 
+  Future<List<StatsReport>> getStats();
+
   /// public:
   OnFirstPacketReceivedCallback onFirstPacketReceived;
 
 
@@ -5,6 +5,7 @@ import 'package:flutter/material.dart';
 import 'media_stream_track.dart';
 import 'rtc_dtmf_sender.dart';
 import 'rtc_rtp_parameters.dart';
+import 'rtc_stats_report.dart';
 
 abstract class RTCRtpSender {
   RTCRtpSender();
@@ -15,6 +16,8 @@ abstract class RTCRtpSender {
 
   Future<void> setTrack(MediaStreamTrack track, {bool takeOwnership = true});
 
+  Future<List<StatsReport>> getStats();
+
   RTCRtpParameters get parameters;
 
   MediaStreamTrack get track;
 
@@ -180,7 +180,8 @@ class RTCPeerConnectionNative extends RTCPeerConnection {
                 peerConnectionId: _peerConnectionId)
             : null;
         onTrack?.call(RTCTrackEvent(
-            receiver: RTCRtpReceiverNative.fromMap(map['receiver']),
+            receiver: RTCRtpReceiverNative.fromMap(map['receiver'],
+                peerConnectionId: _peerConnectionId),
             streams: streams,
             track: MediaStreamTrackNative.fromMap(map['track']),
             transceiver: transceiver));
@@ -447,7 +448,8 @@ class RTCPeerConnectionNative extends RTCPeerConnection {
     try {
       final response = await _channel.invokeMethod('getReceivers',
           <String, dynamic>{'peerConnectionId': _peerConnectionId});
-      return RTCRtpReceiverNative.fromMaps(response['receivers']);
+      return RTCRtpReceiverNative.fromMaps(response['receivers'],
+          peerConnectionId: _peerConnectionId);
     } on PlatformException catch (e) {
       throw 'Unable to RTCPeerConnection::addTrack: ${e.message}';
     }
 
@@ -1,23 +1,59 @@
+import 'package:flutter/services.dart';
+
 import '../interface/media_stream_track.dart';
 import '../interface/rtc_rtp_parameters.dart';
 import '../interface/rtc_rtp_receiver.dart';
+import '../interface/rtc_stats_report.dart';
+
 import 'media_stream_track_impl.dart';
+import 'utils.dart';
 
 class RTCRtpReceiverNative extends RTCRtpReceiver {
-  RTCRtpReceiverNative(this._id, this._track, this._parameters);
+  RTCRtpReceiverNative(
+      this._id, this._track, this._parameters, this._peerConnectionId);
 
-  factory RTCRtpReceiverNative.fromMap(Map<dynamic, dynamic> map) {
+  factory RTCRtpReceiverNative.fromMap(Map<dynamic, dynamic> map,
+      {String peerConnectionId}) {
     var track = MediaStreamTrackNative.fromMap(map['track']);
     var parameters = RTCRtpParameters.fromMap(map['rtpParameters']);
-    return RTCRtpReceiverNative(map['receiverId'], track, parameters);
+    return RTCRtpReceiverNative(
+        map['receiverId'], track, parameters, peerConnectionId);
   }
 
-  static List<RTCRtpReceiverNative> fromMaps(List<dynamic> map) {
-    return map.map((e) => RTCRtpReceiverNative.fromMap(e)).toList();
+  static List<RTCRtpReceiverNative> fromMaps(List<dynamic> map,
+      {String peerConnectionId}) {
+    return map
+        .map((e) =>
+            RTCRtpReceiverNative.fromMap(e, peerConnectionId: peerConnectionId))
+        .toList();
+  }
+
+  @override
+  Future<List<StatsReport>> getStats() async {
+    try {
+      final response = await _channel.invokeMethod<Map<dynamic, dynamic>>(
+          'getStats', <String, dynamic>{
+        'peerConnectionId': _peerConnectionId,
+        'track': track.id
+      });
+      var stats = <StatsReport>[];
+      if (response != null) {
+        List<dynamic> reports = response['stats'];
+        reports.forEach((report) {
+          stats.add(StatsReport(report['id'], report['type'],
+              report['timestamp'], report['values']));
+        });
+      }
+      return stats;
+    } on PlatformException catch (e) {
+      throw 'Unable to RTCPeerConnection::getStats: ${e.message}';
+    }
   }
 
   /// private:
+  final _channel = WebRTC.methodChannel();
   String _id;
+  String _peerConnectionId;
   MediaStreamTrack _track;
   RTCRtpParameters _parameters;
 
 
@@ -7,6 +7,7 @@ import '../interface/media_stream_track.dart';
 import '../interface/rtc_dtmf_sender.dart';
 import '../interface/rtc_rtp_parameters.dart';
 import '../interface/rtc_rtp_sender.dart';
+import '../interface/rtc_stats_report.dart';
 import 'media_stream_track_impl.dart';
 import 'rtc_dtmf_sender_impl.dart';
 import 'utils.dart';
@@ -41,6 +42,29 @@ class RTCRtpSenderNative extends RTCRtpSender {
   RTCDTMFSender _dtmf;
   RTCRtpParameters _parameters;
   bool _ownsTrack = false;
+
+  @override
+  Future<List<StatsReport>> getStats() async {
+    try {
+      final response = await _channel.invokeMethod<Map<dynamic, dynamic>>(
+          'getStats', <String, dynamic>{
+        'peerConnectionId': _peerConnectionId,
+        'track': track.id
+      });
+      var stats = <StatsReport>[];
+      if (response != null) {
+        List<dynamic> reports = response['stats'];
+        reports.forEach((report) {
+          stats.add(StatsReport(report['id'], report['type'],
+              report['timestamp'], report['values']));
+        });
+      }
+      return stats;
+    } on PlatformException catch (e) {
+      throw 'Unable to RTCPeerConnection::getStats: ${e.message}';
+    }
+  }
+
   @override
   Future<bool> setParameters(RTCRtpParameters parameters) async {
     _parameters = parameters;
 
@@ -66,7 +66,8 @@ class RTCRtpTransceiverNative extends RTCRtpTransceiver {
         map['mid'],
         RTCRtpSenderNative.fromMap(map['sender'],
             peerConnectionId: peerConnectionId),
-        RTCRtpReceiverNative.fromMap(map['receiver']),
+        RTCRtpReceiverNative.fromMap(map['receiver'],
+            peerConnectionId: peerConnectionId),
         peerConnectionId);
     return transceiver;
   }
 
@@ -23,7 +23,8 @@ class RTCTrackEventNative extends RTCTrackEvent {
     var streams =
         streamsParams.map((e) => MediaStreamNative.fromMap(e)).toList();
     return RTCTrackEventNative(
-        RTCRtpReceiverNative.fromMap(map['receiver']),
+        RTCRtpReceiverNative.fromMap(map['receiver'],
+            peerConnectionId: peerConnectionId),
         streams,
         MediaStreamTrackNative.fromMap(map['track']),
         RTCRtpTransceiverNative.fromMap(map['transceiver'],
 
@@ -3,6 +3,7 @@ import 'dart:js_util' as jsutil;
 import '../interface/media_stream_track.dart';
 import '../interface/rtc_rtp_parameters.dart';
 import '../interface/rtc_rtp_receiver.dart';
+import '../interface/rtc_stats_report.dart';
 import 'media_stream_track_impl.dart';
 import 'rtc_rtp_parameters_impl.dart';
 
@@ -12,6 +13,18 @@ class RTCRtpReceiverWeb extends RTCRtpReceiver {
   /// private:
   final Object _jsRtpReceiver;
 
+  @override
+  Future<List<StatsReport>> getStats() async {
+    var stats = await jsutil.promiseToFuture<dynamic>(
+        jsutil.callMethod(_jsRtpReceiver, 'getStats', []));
+    var report = <StatsReport>[];
+    stats.forEach((key, value) {
+      report.add(
+          StatsReport(value['id'], value['type'], value['timestamp'], value));
+    });
+    return report;
+  }
+
   /// The WebRTC specification only defines RTCRtpParameters in terms of senders,
   /// but this API also applies them to receivers, similar to ORTC:
   /// http://ortc.org/wp-content/uploads/2016/03/ortc.html#rtcrtpparameters*.
 
@@ -3,6 +3,7 @@ import 'dart:html';
 import 'dart:js_util' as jsutil;
 
 import 'package:flutter/services.dart';
+import 'package:flutter_webrtc/flutter_webrtc.dart';
 
 import '../interface/media_stream_track.dart';
 import '../interface/rtc_dtmf_sender.dart';
@@ -62,6 +63,18 @@ class RTCRtpSenderWeb extends RTCRtpSender {
     }
   }
 
+  @override
+  Future<List<StatsReport>> getStats() async {
+    var stats = await jsutil.promiseToFuture<dynamic>(
+        jsutil.callMethod(_jsRtpSender, 'getStats', []));
+    var report = <StatsReport>[];
+    stats.forEach((key, value) {
+      report.add(
+          StatsReport(value['id'], value['type'], value['timestamp'], value));
+    });
+    return report;
+  }
+
   @override
   MediaStreamTrack get track =>
       MediaStreamTrackWeb(jsutil.getProperty(_jsRtpSender, 'track'));