瀏覽代碼

cleanup connections hash

Michelle Bu 12 年之前
父節點
當前提交
a6c5fd96b8
共有 2 個文件被更改,包括 6 次插入9 次删除
  1. 1 1
      lib/connectionmanager.js
  2. 5 8
      lib/peer.js

+ 1 - 1
lib/connectionmanager.js

@@ -298,7 +298,7 @@ ConnectionManager.prototype.connect = function(options) {
   }
 
   this._lock = true
-  return [options.label, connection];
+  return connection;
 };
 
 /** Updates label:[serialization, reliable, metadata] pairs from offer. */

+ 5 - 8
lib/peer.js

@@ -140,7 +140,7 @@ Peer.prototype._handleServerJSONMessage = function(message) {
         manager = new ConnectionManager(this.id, peer, this._socket, options);
         this._attachManagerListeners(manager);
         this.managers[peer] = manager;
-        this.connections[peer] = {};
+        this.connections[peer] = manager.connections;
       }
       manager.update(options.labels);
       manager.handleSDP(payload.sdp, message.type);
@@ -193,13 +193,13 @@ Peer.prototype._attachManagerListeners = function(manager) {
   var self = this;
   // Handle receiving a connection.
   manager.on('connection', function(connection) {
-    self.connections[connection.peer][connection.label] = connection;
     self.emit('connection', connection);
   });
   // Handle a connection closing.
   manager.on('close', function() {
     if (!!self.managers[manager.peer]) {
-      delete self.managers[manager.peer]
+      delete self.managers[manager.peer];
+      delete self.connections[manager.peer];
     }
   });
   manager.on('error', function(err) {
@@ -253,15 +253,12 @@ Peer.prototype.connect = function(peer, options) {
     this.connections[peer] = {};
   }
 
-  var connectionInfo = manager.connect(options);
-  if (!!connectionInfo) {
-    this.connections[peer][connectionInfo[0]] = connectionInfo[1];
-  }
+  var connection = manager.connect(options);
 
   if (!this.id) {
     this._queued.push(manager);
   }
-  return connectionInfo[1];
+  return connection;
 };
 
 /**