Comparing version 4.2.0 to 4.2.1
12
index.js
@@ -77,3 +77,3 @@ var socket = require('k-rpc-socket') | ||
function addNode (data, peer) { | ||
if (data && isNodeId(data.id, self._idLength) && !self.nodes.get(data.id)) { | ||
if (data && isNodeId(data.id, self._idLength) && !self.nodes.get(data.id) && !equals(data.id, self.id)) { | ||
self._addNode({ | ||
@@ -257,9 +257,11 @@ id: data.id, | ||
var r = res && res.r | ||
if (!r) return | ||
if (peer && peer.id && self.nodes.get(peer.id)) { | ||
if (err && err.code === 'ETIMEDOUT') self.nodes.remove(peer.id) | ||
if (err && (err.code === 'EUNEXPECTEDNODE' || err.code === 'ETIMEDOUT')) { | ||
self.nodes.remove(peer.id) | ||
} | ||
} | ||
var r = res && res.r | ||
if (!r) return kick() | ||
if (!err && isNodeId(r.id, self._idLength)) { | ||
@@ -266,0 +268,0 @@ count++ |
{ | ||
"name": "k-rpc", | ||
"version": "4.2.0", | ||
"version": "4.2.1", | ||
"description": "Low-level implementation of the k-rpc protocol used the BitTorrent DHT.", | ||
@@ -8,6 +8,6 @@ "main": "index.js", | ||
"buffer-equals": "^1.0.3", | ||
"k-bucket": "^3.0.1", | ||
"k-rpc-socket": "^1.7.0", | ||
"safe-buffer": "^5.1.1", | ||
"randombytes": "^2.0.5" | ||
"k-bucket": "^3.3.0", | ||
"k-rpc-socket": "^1.7.2", | ||
"randombytes": "^2.0.5", | ||
"safe-buffer": "^5.1.1" | ||
}, | ||
@@ -14,0 +14,0 @@ "devDependencies": { |
@@ -59,3 +59,3 @@ var krpc = require('./') | ||
var client = krpc({ | ||
nodes: ['localhost:' + server.address().port] | ||
nodes: ['localhost:' + server.address().port, 'localhost:' + other.address().port] | ||
}) | ||
@@ -62,0 +62,0 @@ |
18089
390
Updatedk-bucket@^3.3.0
Updatedk-rpc-socket@^1.7.2