api: implement connectionstatechange event

RTCPeerConnection.js

@@ -31,6 +31,14 @@ type RTCIceGatheringState =
   'gathering' |
   'complete';
 
+type RTCPeerConnectionState =
+  'new' |
+  'connecting' |
+  'connected' |
+  'disconnected' |
+  'failed' |
+  'closed';
+
 type RTCIceConnectionState =
   'new' |
   'checking' |
@@ -63,6 +71,7 @@ export default class RTCPeerConnection extends EventTarget(PEER_CONNECTION_EVENT
 
   signalingState: RTCSignalingState = 'stable';
   iceGatheringState: RTCIceGatheringState = 'new';
+  connectionState: RTCPeerConnectionState = 'new';
   iceConnectionState: RTCIceConnectionState = 'new';
 
   onconnectionstatechange: ?Function;
@@ -267,6 +276,17 @@ export default class RTCPeerConnection extends EventTarget(PEER_CONNECTION_EVENT
           this._unregisterEvents();
         }
       }),
+      EventEmitter.addListener('peerConnectionStateChanged', ev => {
+        if (ev.id !== this._peerConnectionId) {
+          return;
+        }
+        this.connectionState = ev.connectionState;
+        this.dispatchEvent(new RTCEvent('connectionstatechange'));
+        if (ev.connectionState === 'closed') {
+          // This PeerConnection is done, clean up event handlers.
+          this._unregisterEvents();
+        }
+      }),
       EventEmitter.addListener('peerConnectionSignalingStateChanged', ev => {
         if (ev.id !== this._peerConnectionId) {
           return;

android/src/main/java/com/oney/WebRTCModule/PeerConnectionObserver.java

@@ -310,6 +310,15 @@ public void onIceConnectionChange(PeerConnection.IceConnectionState iceConnectio
         webRTCModule.sendEvent("peerConnectionIceConnectionChanged", params);
     }
 
+    @Override
+    public void onConnectionChange(PeerConnection.PeerConnectionState peerConnectionState) {
+        WritableMap params = Arguments.createMap();
+        params.putInt("id", id);
+        params.putString("connectionState", peerConnectionStateString(peerConnectionState));
+
+        webRTCModule.sendEvent("peerConnectionStateChanged", params);
+    }
+
     @Override
     public void onIceConnectionReceivingChange(boolean var1) {
     }
@@ -474,6 +483,25 @@ public void onAddTrack(final RtpReceiver receiver, final MediaStream[] mediaStre
         Log.d(TAG, "onAddTrack");
     }
 
+    @Nullable
+    private String peerConnectionStateString(PeerConnection.PeerConnectionState peerConnectionState) {
+        switch (peerConnectionState) {
+            case NEW:
+                return "new";
+            case CONNECTING:
+                return "connecting";
+            case CONNECTED:
+                return "connected";
+            case DISCONNECTED:
+                return "disconnected";
+            case FAILED:
+                return "failed";
+            case CLOSED:
+                return "closed";
+        }
+        return null;
+    }
+
     @Nullable
     private String iceConnectionStateString(PeerConnection.IceConnectionState iceConnectionState) {
         switch (iceConnectionState) {

ios/RCTWebRTC/WebRTCModule+RTCPeerConnection.m

@@ -375,6 +375,18 @@ - (NSString *)statsToJSON:(NSArray<RTCLegacyStatsReport *> *)reports
   return s;
 }
 
+- (NSString *)stringForPeerConnectionState:(RTCPeerConnectionState)state {
+  switch (state) {
+    case RTCPeerConnectionStateNew: return @"new";
+    case RTCPeerConnectionStateConnecting: return @"connecting";
+    case RTCPeerConnectionStateConnected: return @"connected";
+    case RTCPeerConnectionStateDisconnected: return @"disconnected";
+    case RTCPeerConnectionStateFailed: return @"failed";
+    case RTCPeerConnectionStateClosed: return @"closed";
+  }
+  return nil;
+}
+
 - (NSString *)stringForICEConnectionState:(RTCIceConnectionState)state {
   switch (state) {
     case RTCIceConnectionStateNew: return @"new";
@@ -479,6 +491,11 @@ - (void)peerConnectionShouldNegotiate:(RTCPeerConnection *)peerConnection {
                      body:@{ @"id": peerConnection.reactTag }];
 }
 
+- (void)peerConnection:(RTCPeerConnection *)peerConnection didChangeConnectionState:(RTCPeerConnectionState)newState {
+  [self sendEventWithName:kEventPeerConnectionStateChanged
+                     body:@{@"id": peerConnection.reactTag, @"connectionState": [self stringForPeerConnectionState:newState]}];
+}
+
 - (void)peerConnection:(RTCPeerConnection *)peerConnection didChangeIceConnectionState:(RTCIceConnectionState)newState {
   [self sendEventWithName:kEventPeerConnectionIceConnectionChanged
                      body:@{

ios/RCTWebRTC/WebRTCModule.h

@@ -21,6 +21,7 @@
 #import <WebRTC/RTCVideoEncoderFactory.h>
 
 static NSString *const kEventPeerConnectionSignalingStateChanged = @"peerConnectionSignalingStateChanged";
+static NSString *const kEventPeerConnectionStateChanged = @"peerConnectionStateChanged";
 static NSString *const kEventPeerConnectionAddedStream = @"peerConnectionAddedStream";
 static NSString *const kEventPeerConnectionRemovedStream = @"peerConnectionRemovedStream";
 static NSString *const kEventPeerConnectionOnRenegotiationNeeded = @"peerConnectionOnRenegotiationNeeded";

ios/RCTWebRTC/WebRTCModule.m

@@ -101,6 +101,7 @@ - (dispatch_queue_t)methodQueue
 - (NSArray<NSString *> *)supportedEvents {
   return @[
     kEventPeerConnectionSignalingStateChanged,
+    kEventPeerConnectionStateChanged,
     kEventPeerConnectionAddedStream,
     kEventPeerConnectionRemovedStream,
     kEventPeerConnectionOnRenegotiationNeeded,