Skip to content

Commit f73c045

Browse files
committed
feat: update events to conform with #74
1 parent 8840c9b commit f73c045

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/index.js

+4-1
Original file line numberDiff line numberDiff line change
@@ -41,10 +41,12 @@ class Node extends EventEmitter {
4141
// Received incommind dial and muxer upgrade happened, reuse this
4242
// muxed connection
4343
this.swarm.on('peer-mux-established', (peerInfo) => {
44+
this.emit('peer:connect', peerInfo)
4445
this.peerBook.put(peerInfo)
4546
})
4647

4748
this.swarm.on('peer-mux-closed', (peerInfo) => {
49+
this.emit('peer:disconnect', peerInfo)
4850
this.peerBook.removeByB58String(peerInfo.id.toB58String())
4951
})
5052
}
@@ -62,8 +64,9 @@ class Node extends EventEmitter {
6264
if (this.modules.discovery) {
6365
let discoveries = this.modules.discovery
6466
discoveries = Array.isArray(discoveries) ? discoveries : [discoveries]
67+
6568
discoveries.forEach((discovery) => {
66-
discovery.on('peer', (peerInfo) => this.emit('peer', peerInfo))
69+
discovery.on('peer', (peerInfo) => this.emit('peer:discovery', peerInfo))
6770
})
6871
}
6972

0 commit comments

Comments
 (0)