mirror of
https://github.com/fluencelabs/js-libp2p
synced 2025-03-30 22:31:03 +00:00
docs(examples): fix dial function name and multiaddr variable name in echo and chat dialer/listener examples (#109)
This commit is contained in:
parent
f877609a58
commit
019cd4715d
@ -30,12 +30,12 @@ async.parallel([
|
|||||||
], (err, ids) => {
|
], (err, ids) => {
|
||||||
if (err) throw err
|
if (err) throw err
|
||||||
const peerDialer = new PeerInfo(ids[0])
|
const peerDialer = new PeerInfo(ids[0])
|
||||||
peerDialer.multiaddr.add('/ip4/0.0.0.0/tcp/0')
|
peerDialer.multiaddrs.add('/ip4/0.0.0.0/tcp/0')
|
||||||
const nodeDialer = new Node(peerDialer)
|
const nodeDialer = new Node(peerDialer)
|
||||||
|
|
||||||
const peerListener = new PeerInfo(ids[1])
|
const peerListener = new PeerInfo(ids[1])
|
||||||
idListener = ids[1]
|
idListener = ids[1]
|
||||||
peerListener.multiaddr.add('/ip4/127.0.0.1/tcp/10333')
|
peerListener.multiaddrs.add('/ip4/127.0.0.1/tcp/10333')
|
||||||
nodeDialer.start((err) => {
|
nodeDialer.start((err) => {
|
||||||
if (err) {
|
if (err) {
|
||||||
throw err
|
throw err
|
||||||
@ -47,7 +47,7 @@ async.parallel([
|
|||||||
console.log(ma.toString() + '/ipfs/' + idListener.toB58String())
|
console.log(ma.toString() + '/ipfs/' + idListener.toB58String())
|
||||||
})
|
})
|
||||||
|
|
||||||
nodeDialer.dialByPeerInfo(peerListener, '/chat/1.0.0', (err, conn) => {
|
nodeDialer.dial(peerListener, '/chat/1.0.0', (err, conn) => {
|
||||||
if (err) {
|
if (err) {
|
||||||
throw err
|
throw err
|
||||||
}
|
}
|
||||||
|
@ -8,7 +8,7 @@ const spdy = require('libp2p-spdy')
|
|||||||
const KadDHT = require('libp2p-kad-dht')
|
const KadDHT = require('libp2p-kad-dht')
|
||||||
const multiplex = require('libp2p-multiplex')
|
const multiplex = require('libp2p-multiplex')
|
||||||
const secio = require('libp2p-secio')
|
const secio = require('libp2p-secio')
|
||||||
const libp2p = require('../..')
|
const libp2p = require('../../..')
|
||||||
|
|
||||||
function mapMuxers (list) {
|
function mapMuxers (list) {
|
||||||
return list.map((pref) => {
|
return list.map((pref) => {
|
||||||
|
@ -13,7 +13,7 @@ PeerId.createFromJSON(require('./peer-id-listener'), (err, idListener) => {
|
|||||||
throw err
|
throw err
|
||||||
}
|
}
|
||||||
const peerListener = new PeerInfo(idListener)
|
const peerListener = new PeerInfo(idListener)
|
||||||
peerListener.multiaddr.add('/ip4/0.0.0.0/tcp/10333')
|
peerListener.multiaddrs.add('/ip4/0.0.0.0/tcp/10333')
|
||||||
const nodeListener = new Node(peerListener)
|
const nodeListener = new Node(peerListener)
|
||||||
|
|
||||||
nodeListener.start((err) => {
|
nodeListener.start((err) => {
|
||||||
|
@ -20,7 +20,7 @@ async.parallel([
|
|||||||
// Dialer
|
// Dialer
|
||||||
const dialerId = ids[0]
|
const dialerId = ids[0]
|
||||||
const dialerPeerInfo = new PeerInfo(dialerId)
|
const dialerPeerInfo = new PeerInfo(dialerId)
|
||||||
dialerPeerInfo.multiaddr.add('/ip4/0.0.0.0/tcp/0')
|
dialerPeerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0')
|
||||||
const dialerNode = new Node(dialerPeerInfo)
|
const dialerNode = new Node(dialerPeerInfo)
|
||||||
|
|
||||||
// Peer to Dial
|
// Peer to Dial
|
||||||
@ -28,7 +28,7 @@ async.parallel([
|
|||||||
const listenerId = ids[1]
|
const listenerId = ids[1]
|
||||||
const listenerMultiaddr = '/ip4/127.0.0.1/tcp/10333/ipfs/' +
|
const listenerMultiaddr = '/ip4/127.0.0.1/tcp/10333/ipfs/' +
|
||||||
listenerId.toB58String()
|
listenerId.toB58String()
|
||||||
listenerPeerInfo.multiaddr.add(listenerMultiaddr)
|
listenerPeerInfo.multiaddrs.add(listenerMultiaddr)
|
||||||
|
|
||||||
dialerNode.start((err) => {
|
dialerNode.start((err) => {
|
||||||
if (err) { throw err }
|
if (err) { throw err }
|
||||||
@ -38,7 +38,7 @@ async.parallel([
|
|||||||
'/ipfs/' + dialerId.toB58String()))
|
'/ipfs/' + dialerId.toB58String()))
|
||||||
|
|
||||||
console.log('Dialing to peer:', listenerMultiaddr.toString())
|
console.log('Dialing to peer:', listenerMultiaddr.toString())
|
||||||
dialerNode.dialByPeerInfo(listenerPeerInfo, '/echo/1.0.0', (err, conn) => {
|
dialerNode.dial(listenerPeerInfo, '/echo/1.0.0', (err, conn) => {
|
||||||
if (err) { throw err }
|
if (err) { throw err }
|
||||||
|
|
||||||
console.log('nodeA dialed to nodeB on protocol: /echo/1.0.0')
|
console.log('nodeA dialed to nodeB on protocol: /echo/1.0.0')
|
||||||
|
@ -24,7 +24,7 @@ series([
|
|||||||
},
|
},
|
||||||
(cb) => {
|
(cb) => {
|
||||||
const listenerPeerInfo = new PeerInfo(listenerId)
|
const listenerPeerInfo = new PeerInfo(listenerId)
|
||||||
listenerPeerInfo.multiaddr.add('/ip4/0.0.0.0/tcp/10333')
|
listenerPeerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/10333')
|
||||||
listenerNode = new Node(listenerPeerInfo)
|
listenerNode = new Node(listenerPeerInfo)
|
||||||
|
|
||||||
listenerNode.swarm.on('peer-mux-established', (peerInfo) => {
|
listenerNode.swarm.on('peer-mux-established', (peerInfo) => {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user