Minor fix

Author: magnuslundstedt

lib/jsflow-tracker.js

@@ -103,7 +103,7 @@ jsFlowTracker.prototype._onData = function (payload, from) {
   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({
@@ -150,7 +150,7 @@ jsFlowTracker.prototype._onWebRtcOffer = function (payload, from) {
     peer.id = from
 
     peer.on('signal', function (signalObject) {
-        console.log('GOT SIGNAL, expecting offer/ice', signalObject);
+        console.log('GOT SIGNAL, expecting answer/ice', signalObject);
       if(signalObject.candidate) { // The signalling is for ICE
         var params = {
           info_hash: self.client._infoHash.toString('base64'),
@@ -182,7 +182,7 @@ jsFlowTracker.prototype._onWebRtcOffer = function (payload, from) {
 }
 
 jsFlowTracker.prototype._onWebRtcAnswer = function (payload, from) {
-  peer = self._peers[from]
+  var peer = self._peers[from]
   if(peer) {
     peer.id = from
     peer.signal(payload.answer)
@@ -196,11 +196,18 @@ jsFlowTracker.prototype._onWebRtcAnswer = function (payload, from) {
 jsFlowTracker.prototype._onWebRtcIce = function (payload, from) {
   //TODO: Buffer ICE ? 
   console.log('WILL ADD ICE CANDIDATE!!!');
-  if(payload.candidate) {
-    peer.signal(payload.candidate)
+  if(!self._peers[from]) {
+    var peer = self._peers[from]
+
+    if(payload.candidate) {
+      peer.signal(payload.candidate)
+    }
+    else {
+      console.error('Candidate did not exist as expected in payload', payload);
+    }    
   }
   else {
-    console.error('Candidate did not exist as expected in payload', payload);
+    console.error('Candidate refers to a peer not yet created. TODO: Buffer ICE!', payload);
   }
 }