mirror of
https://github.com/fluencelabs/js-libp2p
synced 2025-04-28 12:02:15 +00:00
fix issue pointed out here - https://github.com/diasdavid/node-ipfs-swarm/pull/7#discussion_r36044035
This commit is contained in:
parent
cfa37e8d98
commit
c6ae35026b
@ -60,7 +60,6 @@ function Identify (swarm, peerSelf) {
|
|||||||
var ps = self.createProtoStream()
|
var ps = self.createProtoStream()
|
||||||
|
|
||||||
ps.on('identify', function (msg) {
|
ps.on('identify', function (msg) {
|
||||||
// console.log('RECEIVED PROTOBUF - SIDE ZZ ', msg)
|
|
||||||
var peerId = Id.createFromPubKey(msg.publicKey)
|
var peerId = Id.createFromPubKey(msg.publicKey)
|
||||||
|
|
||||||
updateSelf(peerSelf, msg.observedAddr)
|
updateSelf(peerSelf, msg.observedAddr)
|
||||||
@ -119,13 +118,13 @@ function updateSelf (peerSelf, observedAddr) {
|
|||||||
|
|
||||||
for (var i = 0; i < peerSelf.previousObservedAddrs.length; i++) {
|
for (var i = 0; i < peerSelf.previousObservedAddrs.length; i++) {
|
||||||
if (peerSelf.previousObservedAddrs[i].toString() === omh.toString()) {
|
if (peerSelf.previousObservedAddrs[i].toString() === omh.toString()) {
|
||||||
peerSelf.previousObserveredAddrs.splice(i, 1)
|
peerSelf.previousObservedAddrs.splice(i, 1)
|
||||||
addToSelf()
|
addToSelf()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
peerSelf.previousObservedAddrs.push(observedAddr)
|
peerSelf.previousObservedAddrs.push(omh)
|
||||||
|
|
||||||
function addToSelf () {
|
function addToSelf () {
|
||||||
var isIn = false
|
var isIn = false
|
||||||
|
Loading…
x
Reference in New Issue
Block a user