|
@@ -73,7 +73,7 @@ PeerServer.prototype._initializeWSS = function() {
|
|
socket.close();
|
|
socket.close();
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
-
|
|
|
|
|
|
+
|
|
if (!self._clients[key] || !self._clients[key][id]) {
|
|
if (!self._clients[key] || !self._clients[key][id]) {
|
|
self._checkKey(key, ip, function(err) {
|
|
self._checkKey(key, ip, function(err) {
|
|
if (!err) {
|
|
if (!err) {
|
|
@@ -203,7 +203,7 @@ PeerServer.prototype._initializeHTTP = function() {
|
|
var id = req.params.id;
|
|
var id = req.params.id;
|
|
var token = req.params.token;
|
|
var token = req.params.token;
|
|
var key = req.params.key;
|
|
var key = req.params.key;
|
|
- var ip = req.ip;
|
|
|
|
|
|
+ var ip = req.connection.remoteAddress;
|
|
|
|
|
|
if (!self._clients[key] || !self._clients[key][id]) {
|
|
if (!self._clients[key] || !self._clients[key][id]) {
|
|
self._checkKey(key, ip, function(err) {
|
|
self._checkKey(key, ip, function(err) {
|
|
@@ -307,7 +307,7 @@ PeerServer.prototype._pruneOutstanding = function() {
|
|
var keys = Object.keys(this._outstanding);
|
|
var keys = Object.keys(this._outstanding);
|
|
for (var k = 0, kk = keys.length; k < kk; k += 1) {
|
|
for (var k = 0, kk = keys.length; k < kk; k += 1) {
|
|
var key = keys[k];
|
|
var key = keys[k];
|
|
- var dsts = Object.keys(this._outstanding[key]);
|
|
|
|
|
|
+ var dsts = Object.keys(this._outstanding[key]);
|
|
for (var i = 0, ii = dsts.length; i < ii; i += 1) {
|
|
for (var i = 0, ii = dsts.length; i < ii; i += 1) {
|
|
var offers = this._outstanding[key][dsts[i]];
|
|
var offers = this._outstanding[key][dsts[i]];
|
|
var seen = {};
|
|
var seen = {};
|