mirror of
https://github.com/fluencelabs/js-libp2p
synced 2025-05-02 14:02:14 +00:00
4ed5c039fc
https://github.com/multiformats/js-multiaddr/pull/76 changed the default protocol from ipfs to p2p. js-multiaddr is a transitive dependency of peer-info, so in order to get this change, we had to bump the version of peer-info. * fix: revert ipfs -> p2p change for some tests As per PR feedback. Needed for backwards-compatibility.
59 lines
1.5 KiB
JavaScript
59 lines
1.5 KiB
JavaScript
'use strict'
|
|
/* eslint-disable no-console */
|
|
|
|
/*
|
|
* Dialer Node
|
|
*/
|
|
|
|
const PeerId = require('peer-id')
|
|
const PeerInfo = require('peer-info')
|
|
const Node = require('./libp2p-bundle')
|
|
const pull = require('pull-stream')
|
|
const async = require('async')
|
|
|
|
async.parallel([
|
|
(cb) => PeerId.createFromJSON(require('./id-d'), cb),
|
|
(cb) => PeerId.createFromJSON(require('./id-l'), cb)
|
|
], (err, ids) => {
|
|
if (err) { throw err }
|
|
|
|
// Dialer
|
|
const dialerId = ids[0]
|
|
const dialerPeerInfo = new PeerInfo(dialerId)
|
|
dialerPeerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0')
|
|
const dialerNode = new Node({
|
|
peerInfo: dialerPeerInfo
|
|
})
|
|
|
|
// Peer to Dial
|
|
const listenerPeerInfo = new PeerInfo(ids[1])
|
|
const listenerId = ids[1]
|
|
const listenerMultiaddr = '/ip4/127.0.0.1/tcp/10333/p2p/' +
|
|
listenerId.toB58String()
|
|
listenerPeerInfo.multiaddrs.add(listenerMultiaddr)
|
|
|
|
dialerNode.start((err) => {
|
|
if (err) { throw err }
|
|
|
|
console.log('Dialer ready, listening on:')
|
|
dialerPeerInfo.multiaddrs.forEach((ma) => console.log(ma.toString() +
|
|
'/p2p/' + dialerId.toB58String()))
|
|
|
|
console.log('Dialing to peer:', listenerMultiaddr.toString())
|
|
dialerNode.dialProtocol(listenerPeerInfo, '/echo/1.0.0', (err, conn) => {
|
|
if (err) { throw err }
|
|
|
|
console.log('nodeA dialed to nodeB on protocol: /echo/1.0.0')
|
|
|
|
pull(
|
|
pull.values(['hey']),
|
|
conn,
|
|
pull.collect((err, data) => {
|
|
if (err) { throw err }
|
|
console.log('received echo:', data.toString())
|
|
})
|
|
)
|
|
})
|
|
})
|
|
})
|