|
@@ -79,6 +79,9 @@ PeerServer.prototype._initializeWSS = function() {
|
|
|
self._clients[key][id] = { token: token, ip: ip };
|
|
|
self._ips[ip]++;
|
|
|
socket.send(JSON.stringify({ type: 'OPEN' }));
|
|
|
+ // We're going to emit here, because for XHR we don't *know* when someone
|
|
|
+ // disconnects.
|
|
|
+ self.emit('connection', id);
|
|
|
}
|
|
|
self._configureWS(socket, key, id, token);
|
|
|
} else {
|
|
@@ -345,6 +348,7 @@ PeerServer.prototype._removePeer = function(key, id) {
|
|
|
if (this._clients[key] && this._clients[key][id]) {
|
|
|
this._ips[this._clients[key][id].ip]--;
|
|
|
delete this._clients[key][id];
|
|
|
+ this.emit('disconnect', id);
|
|
|
}
|
|
|
};
|
|
|
|