feat(p2p): life peers exchange
This commit is contained in:
@ -65,6 +65,11 @@ class p2p {
|
|||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|
||||||
|
// new peer with peer exchange
|
||||||
|
this.on('peer', (peer) => {
|
||||||
|
this.add(peer)
|
||||||
|
})
|
||||||
|
|
||||||
// ignore local addresses
|
// ignore local addresses
|
||||||
const ifaces = os.networkInterfaces();
|
const ifaces = os.networkInterfaces();
|
||||||
Object.keys(ifaces).forEach((ifname) => {
|
Object.keys(ifaces).forEach((ifname) => {
|
||||||
@ -154,6 +159,10 @@ class p2p {
|
|||||||
|
|
||||||
// success
|
// success
|
||||||
clearTimeout(protocolTimeout)
|
clearTimeout(protocolTimeout)
|
||||||
|
|
||||||
|
// send some peers with pears exchange
|
||||||
|
this.emit('peer', address)
|
||||||
|
|
||||||
// add to peers
|
// add to peers
|
||||||
address.emit = emit
|
address.emit = emit
|
||||||
address.disconnect = () => rawSocket.destroy()
|
address.disconnect = () => rawSocket.destroy()
|
||||||
|
Reference in New Issue
Block a user