Fixed bug

Author: kerstinersson

lib/jsflow-tracker.js

@@ -104,45 +104,52 @@ jsFlowTracker.prototype._onData = function (payload, from) {
   // Handle received peers
   if (Array.isArray(payload.peers)) {
     payload.peers.forEach(function (peerInfo) { //For all peers we receive - Open a WebRTC peer connection
+
       var peerId = peerInfo.peerId;
 
-      console.log('Will handle connection for peer: ', peerId);
-
-      var peer = self._peers[peerId] = new Peer({
-        initiator: true,
-        trickle: true,
-        config: self.client._rtcConfig,
-        wrtc: self.client._wrtc
-      })
-      peer.id = peerId
-      peer.on('close', function () {
-        console.info('Peer connection destroyed, will remove from list of peers!')
-        delete self._peers[from]
-      })
-
-      peer.on('signal', function (signalObject) {
-        console.log('GOT SIGNAL, expecting offer/ice', signalObject);
-        if(signalObject.candidate) { // The signalling is for ICE
-          console.log('We have an ice candidate!')
-          var params = {
+      if (!self._peers[peerId]) {
+
+        console.log('Will handle connection for peer: ', peerId);
+
+        var peer = self._peers[peerId] = new Peer({
+          initiator: true,
+          trickle: true,
+          config: self.client._rtcConfig,
+          wrtc: self.client._wrtc
+        })
+        peer.id = peerId
+        peer.on('close', function () {
+          console.info('Peer connection destroyed, will remove from list of peers!')
+          delete self._peers[from]
+        })
+
+        peer.on('signal', function (signalObject) {
+          console.log('GOT SIGNAL, expecting offer/ice', signalObject);
+          if(signalObject.candidate) { // The signalling is for ICE
+            console.log('We have an ice candidate!')
+            var params = {
+                info_hash: self.client._infoHash.toString('base64'),
+                peer_id: self._peerID,
+                candidate: signalObject.candidate
+              }
+            jsFlow.messageUser(peerId, params, 'webrtc_ice');
+          }
+          else { // The signalling is for an OFFER
+            offer = signalObject;
+            console.log('We got an offer', offer)
+            var params = {
               info_hash: self.client._infoHash.toString('base64'),
               peer_id: self._peerID,
-              candidate: signalObject.candidate
+              offer: offer
             }
-          jsFlow.messageUser(peerId, params, 'webrtc_ice');
-        }
-        else { // The signalling is for an OFFER
-          offer = signalObject;
-          console.log('We got an offer', offer)
-          var params = {
-            info_hash: self.client._infoHash.toString('base64'),
-            peer_id: self._peerID,
-            offer: offer
+
+            jsFlow.messageUser(peerId, params, 'webrtc_offer');          
           }
+        })
 
-          jsFlow.messageUser(peerId, params, 'webrtc_offer');          
-        }
-      })
+      } else {
+        console.log("Ignore peer, connection already exists.")
+      }
     })
   };
 }