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

chore: update to latest peer-info, peer-book and libp2p-swarm

Browse Source
This commit is contained in:
David Dias 2017-03-31 15:52:20 +01:00
parent a4b41b0f9a
commit dee0340806
2 changed files with 13 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
package.json
View File

@ -41,12 +41,12 @@
}, },
"dependencies": { "dependencies": {
"libp2p-ping": "~0.3.2", "libp2p-ping": "~0.3.2",
"libp2p-swarm": "~0.28.0", "libp2p-swarm": "~0.29.0",
"mafmt": "^2.1.8", "mafmt": "^2.1.8",
"multiaddr": "^2.3.0", "multiaddr": "^2.3.0",
"peer-book": "~0.3.2", "peer-book": "~0.4.0",
"peer-id": "~0.8.5", "peer-id": "~0.8.6",
"peer-info": "~0.8.5" "peer-info": "~0.9.2"
}, },
"contributors": [ "contributors": [
"David Dias <daviddias.p@gmail.com>", "David Dias <daviddias.p@gmail.com>",

15
src/index.js
View File

@ -26,7 +26,7 @@ class Node extends EventEmitter {
this.peerBook = _peerBook || new PeerBook() this.peerBook = _peerBook || new PeerBook()
this.isOnline = false this.isOnline = false
this.swarm = new Swarm(this.peerInfo) this.swarm = new Swarm(this.peerInfo, this.peerBook)
// Attach stream multiplexers // Attach stream multiplexers
if (this.modules.connection.muxer) { if (this.modules.connection.muxer) {
@ -93,14 +93,17 @@ class Node extends EventEmitter {
transports = Array.isArray(transports) ? transports : [transports] transports = Array.isArray(transports) ? transports : [transports]
// so that we can have webrtc-star addrs without adding manually the id // so that we can have webrtc-star addrs without adding manually the id
this.peerInfo.multiaddrs = this.peerInfo.multiaddrs.map((ma) => { const maOld = []
const maNew = []
this.peerInfo.multiaddrs.forEach((ma) => {
if (!mafmt.IPFS.matches(ma)) { if (!mafmt.IPFS.matches(ma)) {
ma = ma.encapsulate('/ipfs/' + this.peerInfo.id.toB58String()) maOld.push(ma)
maNew.push(ma.encapsulate('/ipfs/' + this.peerInfo.id.toB58String()))
} }
return ma
}) })
this.peerInfo.multiaddrs.replace(maOld, maNew)
const multiaddrs = this.peerInfo.multiaddrs const multiaddrs = this.peerInfo.multiaddrs.toArray()
transports.forEach((transport) => { transports.forEach((transport) => {
if (transport.filter(multiaddrs).length > 0) { if (transport.filter(multiaddrs).length > 0) {
@ -212,7 +215,7 @@ class Node extends EventEmitter {
} catch (err) { } catch (err) {
p = new PeerInfo(PeerId.createFromB58String(peerIdB58Str)) p = new PeerInfo(PeerId.createFromB58String(peerIdB58Str))
} }
p.multiaddr.add(peer) p.multiaddrs.add(peer)
} else if (PeerId.isPeerId(peer)) { } else if (PeerId.isPeerId(peer)) {
const peerIdB58Str = peer.toB58String() const peerIdB58Str = peer.toB58String()
try { try {