Added ice buffering

Author: kerstinersson

lib/jsflow-tracker.js

@@ -15,6 +15,7 @@ function jsFlowTracker (client, announceUrl, opts) {
 	EventEmitter.call(self)
 
   self.client = client
+  self.storeIce = []
   self._opts = opts
   self._announceUrl = announceUrl
   self._peers = {} // peers (peer id -> peer)
@@ -122,15 +123,18 @@ jsFlowTracker.prototype._onData = function (payload, from) {
         console.log('GOT SIGNAL, expecting offer/ice', signalObject);
         if(signalObject.candidate) { // The signalling is for ICE
           var params = {
-            info_hash: self.client._infoHash.toString('base64'),
-            peer_id: self._peerID,
-            candidate: signalObject.candidate
-          }
+              info_hash: self.client._infoHash.toString('base64'),
+              peer_id: self._peerID,
+              candidate: signalObject.candidate
+            }
 
-          jsFlow.messageUser(peerId, params, 'webrtc_ice');
+            jsFlow.messageUser(peerId, params, 'webrtc_ice');
         }
         else { // The signalling is for an OFFER
           offer = signalObject;
+          if (peer.readyForIce) {
+            processStoredCandidates(self)
+          }
           var params = {
             info_hash: self.client._infoHash.toString('base64'),
             peer_id: self._peerID,
@@ -159,7 +163,7 @@ jsFlowTracker.prototype._onWebRtcOffer = function (payload, from) {
     })
 
     peer.on('signal', function (signalObject) {
-        console.log('GOT SIGNAL, expecting answer/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'),
@@ -205,25 +209,40 @@ jsFlowTracker.prototype._onWebRtcAnswer = function (payload, from) {
 
 jsFlowTracker.prototype._onWebRtcIce = function (payload, from) {
   var self = this
-  //TODO: Buffer ICE ? 
+  
+  if (from.readyForIce) {
 
-  console.log('WILL ADD ICE CANDIDATE!!!');
+    console.log('WILL ADD ICE CANDIDATE!!!');
 
-  var peer = self._peers[from]
-  if(peer) {
-    if(payload.candidate) {
-      peer.signal(payload)
-    }      
+    var peer = self._peers[from]
+    if(peer) {
+      if(payload.candidate) {
+        peer.signal(payload)
+      }      
     else {
       console.error('Candidate did not exist as expected in payload', payload);
     }    
   }
   else {
     console.error('Candidate refers to a peer not yet created. TODO: Buffer ICE!', payload);
+    self.storeIce.push(payload.candidate)
   }
 }
 
 jsFlowTracker.prototype._sendAnnounce = function (params) {
   var self = this
   jsFlow.messageUser(params.trackerid, params, 'announce')
 }
+
+function processStoredCandidates (tracker) {
+  console.log("Processing stored candidates.")
+  var peer = tracker._peers[from]
+  if(peer) {
+    if(payload.candidate) {
+      peer.signal(payload)
+    }      
+    else {
+    console.error('Candidate did not exist as expected in payload', payload);
+    } 
+  }
+}