fluencelabs/js-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p synced 2025-04-01 23:31:04 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #75 from libp2p/feat/update-peer-events

Browse Source 
feat: Feat/update peer events
This commit is contained in:
David Dias 2017-03-29 08:03:13 +01:00 committed by GitHub
commit 9ff04779f5
2 changed files with 17 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
README.md
View File

@ -158,12 +158,24 @@ class Node extends libp2p {
- `protocol`: String that defines the protocol (e.g '/ipfs/bitswap/1.1.0') - `protocol`: String that defines the protocol (e.g '/ipfs/bitswap/1.1.0')
#### `libp2p.on('peer', (peer) => {})` #### `libp2p.on('peer:discovery', (peer) => {})`
> Peer has been discovered. > Peer has been discovered.
- `peer`: instance of [PeerInfo][] - `peer`: instance of [PeerInfo][]
#### `libp2p.on('peer:connect', (peer) => {})`
> We connected to a new peer
- `peer`: instance of [PeerInfo][]
#### `libp2p.on('peer:disconnect', (peer) => {})`
> We disconnected from Peer
- `peer`: instance of [PeerInfo][]
#### `libp2p.isOn()` #### `libp2p.isOn()`
> Check if libp2p is started > Check if libp2p is started

5
src/index.js
View File

@ -41,10 +41,12 @@ class Node extends EventEmitter {
// Received incommind dial and muxer upgrade happened, reuse this // Received incommind dial and muxer upgrade happened, reuse this
// muxed connection // muxed connection
this.swarm.on('peer-mux-established', (peerInfo) => { this.swarm.on('peer-mux-established', (peerInfo) => {
this.emit('peer:connect', peerInfo)
this.peerBook.put(peerInfo) this.peerBook.put(peerInfo)
}) })
this.swarm.on('peer-mux-closed', (peerInfo) => { this.swarm.on('peer-mux-closed', (peerInfo) => {
this.emit('peer:disconnect', peerInfo)
this.peerBook.removeByB58String(peerInfo.id.toB58String()) this.peerBook.removeByB58String(peerInfo.id.toB58String())
}) })
} }
@ -62,8 +64,9 @@ class Node extends EventEmitter {
if (this.modules.discovery) { if (this.modules.discovery) {
let discoveries = this.modules.discovery let discoveries = this.modules.discovery
discoveries = Array.isArray(discoveries) ? discoveries : [discoveries] discoveries = Array.isArray(discoveries) ? discoveries : [discoveries]
discoveries.forEach((discovery) => { discoveries.forEach((discovery) => {
discovery.on('peer', (peerInfo) => this.emit('peer', peerInfo)) discovery.on('peer', (peerInfo) => this.emit('peer:discovery', peerInfo))
}) })
} }