Calls: create data channel only on the caller's side.

Removes redundancy and a memory leak (and thus an error upon closing).

src/widgets/call-panel.jsx

@@ -121,7 +121,8 @@ class CallPanel extends React.PureComponent {
 
   handleVideoCallAccepted(info) {
     RING_SOUND.pause();
-    const pc = this.createPeerConnection();
+    // Create peer connection with a data channel.
+    const pc = this.createPeerConnection(true);
     const stream = this.state.localStream;
     stream.getTracks().forEach(track => {
       pc.addTrack(track, stream);
@@ -230,7 +231,7 @@ class CallPanel extends React.PureComponent {
       this.state.pc.onicecandidateerror = null;
       this.state.pc.ondatachannel = null;
 
-      if (this.state.dataChannel) {
+      if (this.state.dataChannel && (this.state.dataChannel.readyState == 'open' || this.state.dataChannel.readyState == 'connecting')) {
         this.state.dataChannel.close();
       }
       this.state.pc.close();
@@ -284,11 +285,12 @@ class CallPanel extends React.PureComponent {
     }
   }
 
-  handleDataChannelClose() {
+  handleDataChannelClose(event) {
-    /* no action */
+    console.log('close data channel:', event);
   }
 
   handleDataChannelEvent(event) {
+    console.log('data channel event:', event);
     const channel = event.channel;
     channel.onerror = this.handleDataChannelError;
     channel.onmessage = this.handleDataChannelMessage;
@@ -297,7 +299,7 @@ class CallPanel extends React.PureComponent {
     this.setState({dataChannel: channel});
   }
 
-  createPeerConnection() {
+  createPeerConnection(withDataChannel) {
     const iceServers = this.props.tinode.getServerParam('iceServers', null);
     const pc = iceServers ? new RTCPeerConnection({iceServers: iceServers}) : new RTCPeerConnection();
 
@@ -310,15 +312,17 @@ class CallPanel extends React.PureComponent {
     pc.ontrack = this.handleTrackEvent;
     pc.ondatachannel = this.handleDataChannelEvent;
 
-    // creating data channel events
+    let stateUpdate = {pc: pc, waitingForPeer: false};
+    if (withDataChannel) {
+      // Create data channel for exchanging events.
       const channel = pc.createDataChannel("events", {ordered: true});
       channel.onerror = this.handleDataChannelError;
       channel.onmessage = this.handleDataChannelMessage;
       channel.onopen = this.handleDataChannelOpen;
       channel.onclose = this.handleDataChannelClose;
-
+      stateUpdate.dataChannel = channel;
-    this.setState({pc: pc, dataChannel: channel, waitingForPeer: false});
+    }
-
+    this.setState(stateUpdate);
     return pc;
   }
 
@@ -441,7 +445,9 @@ class CallPanel extends React.PureComponent {
 
   handleVideoOfferMsg(info) {
     let localStream = null;
-    const pc = this.state.pc ? this.state.pc : this.createPeerConnection();
+    // If needed, create peer connection.
+    // Not creating data channel since it should be created by the peer.
+    const pc = this.state.pc ? this.state.pc : this.createPeerConnection(false);
     const desc = new RTCSessionDescription(info.payload);
 
     pc.setRemoteDescription(desc).then(_ => {

umd/index.dev.js

@@ -10372,7 +10372,7 @@ class CallPanel extends (react__WEBPACK_IMPORTED_MODULE_0___default().PureCompon
   }
   handleVideoCallAccepted(info) {
     RING_SOUND.pause();
-    const pc = this.createPeerConnection();
+    const pc = this.createPeerConnection(true);
     const stream = this.state.localStream;
     stream.getTracks().forEach(track => {
       pc.addTrack(track, stream);
@@ -10466,7 +10466,7 @@ class CallPanel extends (react__WEBPACK_IMPORTED_MODULE_0___default().PureCompon
       this.state.pc.onnegotiationneeded = null;
       this.state.pc.onicecandidateerror = null;
       this.state.pc.ondatachannel = null;
-      if (this.state.dataChannel) {
+      if (this.state.dataChannel && (this.state.dataChannel.readyState == 'open' || this.state.dataChannel.readyState == 'connecting')) {
         this.state.dataChannel.close();
       }
       this.state.pc.close();
@@ -10523,8 +10523,11 @@ class CallPanel extends (react__WEBPACK_IMPORTED_MODULE_0___default().PureCompon
       event.target.send(VIDEO_UNMUTED_EVENT);
     }
   }
-  handleDataChannelClose() {}
+  handleDataChannelClose(event) {
+    console.log('close data channel:', event);
+  }
   handleDataChannelEvent(event) {
+    console.log('data channel event:', event);
     const channel = event.channel;
     channel.onerror = this.handleDataChannelError;
     channel.onmessage = this.handleDataChannelMessage;
@@ -10534,7 +10537,7 @@ class CallPanel extends (react__WEBPACK_IMPORTED_MODULE_0___default().PureCompon
       dataChannel: channel
     });
   }
-  createPeerConnection() {
+  createPeerConnection(withDataChannel) {
     const iceServers = this.props.tinode.getServerParam('iceServers', null);
     const pc = iceServers ? new RTCPeerConnection({
       iceServers: iceServers
@@ -10547,6 +10550,11 @@ class CallPanel extends (react__WEBPACK_IMPORTED_MODULE_0___default().PureCompon
     pc.onicecandidateerror = this.handleIceCandidateErrorEvent;
     pc.ontrack = this.handleTrackEvent;
     pc.ondatachannel = this.handleDataChannelEvent;
+    let stateUpdate = {
+      pc: pc,
+      waitingForPeer: false
+    };
+    if (withDataChannel) {
       const channel = pc.createDataChannel("events", {
         ordered: true
       });
@@ -10554,11 +10562,9 @@ class CallPanel extends (react__WEBPACK_IMPORTED_MODULE_0___default().PureCompon
       channel.onmessage = this.handleDataChannelMessage;
       channel.onopen = this.handleDataChannelOpen;
       channel.onclose = this.handleDataChannelClose;
-    this.setState({
+      stateUpdate.dataChannel = channel;
-      pc: pc,
+    }
-      dataChannel: channel,
+    this.setState(stateUpdate);
-      waitingForPeer: false
-    });
     return pc;
   }
   handleVideoAnswerMsg(info) {
@@ -10655,7 +10661,7 @@ class CallPanel extends (react__WEBPACK_IMPORTED_MODULE_0___default().PureCompon
   }
   handleVideoOfferMsg(info) {
     let localStream = null;
-    const pc = this.state.pc ? this.state.pc : this.createPeerConnection();
+    const pc = this.state.pc ? this.state.pc : this.createPeerConnection(false);
     const desc = new RTCSessionDescription(info.payload);
     pc.setRemoteDescription(desc).then(_ => {
       return navigator.mediaDevices.getUserMedia(this.localStreamConstraints);