87 lines
1.9 KiB
JavaScript
Raw Permalink Normal View History

/* eslint-disable no-console */
2017-07-20 19:42:32 -07:00
'use strict'
const libp2p = require('../../')
2017-07-20 19:42:32 -07:00
const TCP = require('libp2p-tcp')
const Mplex = require('libp2p-mplex')
2017-07-20 19:42:32 -07:00
const SECIO = require('libp2p-secio')
const PeerInfo = require('peer-info')
const MulticastDNS = require('libp2p-mdns')
const defaultsDeep = require('@nodeutils/defaults-deep')
2017-07-20 19:42:32 -07:00
const waterfall = require('async/waterfall')
const parallel = require('async/parallel')
const series = require('async/series')
class MyBundle extends libp2p {
constructor (_options) {
const defaults = {
modules: {
transport: [ TCP ],
streamMuxer: [ Mplex ],
connEncryption: [ SECIO ],
peerDiscovery: [ MulticastDNS ]
2017-07-20 19:42:32 -07:00
},
config: {
peerDiscovery: {
mdns: {
interval: 2000,
enabled: true
}
},
EXPERIMENTAL: {
pubsub: true
}
}
2017-07-20 19:42:32 -07:00
}
super(defaultsDeep(_options, defaults))
2017-07-20 19:42:32 -07:00
}
}
function createNode (callback) {
let node
waterfall([
(cb) => PeerInfo.create(cb),
(peerInfo, cb) => {
peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0')
node = new MyBundle({
peerInfo
})
2017-07-20 19:42:32 -07:00
node.start(cb)
}
], (err) => callback(err, node))
}
parallel([
(cb) => createNode(cb),
(cb) => createNode(cb)
], (err, nodes) => {
if (err) { throw err }
const node1 = nodes[0]
const node2 = nodes[1]
series([
(cb) => node1.once('peer:discovery', (peer) => node1.dial(peer, cb)),
(cb) => setTimeout(cb, 500)
], (err) => {
if (err) { throw err }
2018-02-22 07:06:21 +00:00
// Subscribe to the topic 'news'
2018-02-15 20:15:18 +01:00
node1.pubsub.subscribe('news',
(msg) => console.log(msg.from, msg.data.toString()),
2018-02-15 20:15:18 +01:00
() => {
setInterval(() => {
2018-02-22 07:06:21 +00:00
// Publish the message on topic 'news'
node2.pubsub.publish(
'news',
Buffer.from('Bird bird bird, bird is the word!'),
() => {}
)
2018-02-15 20:15:18 +01:00
}, 1000)
}
2018-02-15 20:15:18 +01:00
)
2017-07-20 19:42:32 -07:00
})
})