diff --git a/.aegir.js b/.aegir.js index fa915ef4fe..ab0e020c8c 100644 --- a/.aegir.js +++ b/.aegir.js @@ -5,10 +5,11 @@ const PeerId = require('peer-id') const pull = require('pull-stream') const parallel = require('async/parallel') -const rawPeer = require('./test/fixtures/test-peer.json') -const Node = require('./test/utils/bundle.node.js') -const sigServer = require('libp2p-webrtc-star/src/sig-server') const WebSocketStarRendezvous = require('libp2p-websocket-star-rendezvous') +const sigServer = require('libp2p-webrtc-star/src/sig-server') + +const rawPeer = require('./test/fixtures/test-peer.json') +const Node = require('./test/utils/bundle-nodejs.js') let wrtcRendezvous let wsRendezvous @@ -21,7 +22,9 @@ const before = (done) => { port: 15555 // cryptoChallenge: true TODO: needs https://github.com/libp2p/js-libp2p-webrtc-star/issues/128 }, (err, server) => { - if (err) { return cb(err) } + if (err) { + return cb(err) + } wrtcRendezvous = server cb() }) @@ -33,7 +36,9 @@ const before = (done) => { strictMultiaddr: false, cryptoChallenge: true }, (err, _server) => { - if (err) { return cb(err) } + if (err) { + return cb(err) + } wsRendezvous = _server cb() }) @@ -47,7 +52,9 @@ const before = (done) => { peer.multiaddrs.add('/ip4/127.0.0.1/tcp/9200/ws') - node = new Node(peer) + node = new Node({ + peerInfo: peer + }) node.handle('/echo/1.0.0', (protocol, conn) => pull(conn, conn)) node.start(cb) }) @@ -56,11 +63,11 @@ const before = (done) => { } const after = (done) => { - setTimeout(() => parallel( - [node, wrtcRendezvous, wsRendezvous].map((s) => { - return (cb) => s.stop(cb) - }) - , done), 2000) + setTimeout(() => + parallel( + [node, wrtcRendezvous, wsRendezvous].map((s) => (cb) => s.stop(cb)), + done), + 2000) } module.exports = { diff --git a/.travis.yml b/.travis.yml deleted file mode 100644 index da80251cf7..0000000000 --- a/.travis.yml +++ /dev/null @@ -1,23 +0,0 @@ -# Warning: This file is automatically synced from https://github.com/ipfs/ci-sync so if you want to change it, please change it there and ask someone to sync all repositories. -sudo: false -language: node_js - -matrix: - include: - - node_js: 8.11.1 - env: CXX=g++-4.8 - -script: - - npm run test - -before_script: - - export DISPLAY=:99.0 - - sh -e /etc/init.d/xvfb start - -addons: - firefox: 'latest' - apt: - sources: - - ubuntu-toolchain-r-test - packages: - - g++-4.8 diff --git a/README.md b/README.md index 099109505f..dc59ec9754 100644 --- a/README.md +++ b/README.md @@ -103,47 +103,83 @@ libp2p becomes very simple and basically acts as a glue for every module that co ```JavaScript // Creating a bundle that adds: // transport: websockets + tcp -// stream-muxing: SPDY +// stream-muxing: spdy & mplex // crypto-channel: secio // discovery: multicast-dns const libp2p = require('libp2p') const TCP = require('libp2p-tcp') const WS = require('libp2p-websockets') -const spdy = require('libp2p-spdy') -const secio = require('libp2p-secio') +const SPDY = require('libp2p-spdy') +const MPLEX = require('libp2p-mplex') +const SECIO = require('libp2p-secio') const MulticastDNS = require('libp2p-mdns') const DHT = require('libp2p-kad-dht') +const defaultsDeep = require('@nodeutils/defaults-deep') class Node extends libp2p { - constructor (peerInfo, peerBook, options) { - options = options || {} - - const modules = { - transport: [ - new TCP(), - new WS() - ], - connection: { - muxer: [ - spdy + constructor (_peerInfo, _peerBook, _options) { + const defaults = { + peerInfo: _peerInfo // The Identity of your Peer + peerBook: _peerBook, // Where peers get tracked, if undefined libp2p will create one instance + + // The libp2p modules for this libp2p bundle + modules: { + transport: [ + TCP, + new WS() // It can take instances too! ], - crypto: [ - secio + streamMuxer: [ + SPDY, + MPLEX + ], + connEncryption: [ + SECIO ] + peerDiscovery: [ + MulticastDNS + ], + peerRouting: {}, // Currently both peerRouting and contentRouting are patched through the DHT, + contentRouting: {} // this will change once we factor that into two modules, for now do the following line: + dht: DHT // DHT enables PeerRouting, ContentRouting and DHT itself components + }, + + // libp2p config options (typically found on a config.json) + config: { // The config object is the part of the config that can go into a file, config.json. + peerDiscovery: { + mdns: { // mdns options + interval: 1000 // ms + enabled: true + }, + webrtcStar: { // webrtc-star options + interval: 1000 // ms + enabled: false + } + // .. other discovery module options. + }, + peerRouting: {}, + contentRouting: {}, + relay: { // Circuit Relay options + enabled: false, + hop: { + enabled: false, + active: false + } + } + // Enable/Disable Experimental features + EXPERIMENTAL: { // Experimental features ("behind a flag") + pubsub: false, + dht: false + } }, - discovery: [ - new MulticastDNS(peerInfo) - ], - // DHT is passed as its own enabling PeerRouting, ContentRouting and DHT itself components - dht: DHT } - super(modules, peerInfo, peerBook, options) + // overload any defaults of your bundle using https://github.com/nodeutils/defaults-deep + super(defaultsDeep(_options, defaults)) } } -// Now all the nodes you create, will have TCP, WebSockets, SPDY, SECIO and MulticastDNS support. +// Now all the nodes you create, will have TCP, WebSockets, SPDY, MPLEX, SECIO and MulticastDNS support. ``` ### API diff --git a/ci/Jenkinsfile b/ci/Jenkinsfile index a7da2e54f3..c128776f7a 100644 --- a/ci/Jenkinsfile +++ b/ci/Jenkinsfile @@ -1,2 +1,2 @@ // Warning: This file is automatically synced from https://github.com/ipfs/ci-sync so if you want to change it, please change it there and ask someone to sync all repositories. -javascript() +javascript(['nodejs_versions': ['8.11.3']]) diff --git a/circle.yml b/circle.yml index 9d5f7cade0..9019b1b1cb 100644 --- a/circle.yml +++ b/circle.yml @@ -1,6 +1,6 @@ machine: node: - version: 8.11.1 + version: 8.11.3 test: post: diff --git a/examples/chat/README.md b/examples/chat/README.md index 905f1f083f..c63582a2fa 100644 --- a/examples/chat/README.md +++ b/examples/chat/README.md @@ -1 +1,13 @@ # Chat example with libp2p + +This example creates a simple chat app in your terminal. + +## Setup +1. Install the modules, `npm install`. +2. Open 2 terminal windows in the `./src` directory. + +## Running +1. Run the listener in window 1, `node listener.js` +2. Run the dialer in window 2, `node dialer.js` +3. Type a message in either window and hit _enter_ +4. Tell youself secrets to your hearts content! diff --git a/examples/chat/src/dialer.js b/examples/chat/src/dialer.js index 9410f20d2a..47fe9b18ae 100644 --- a/examples/chat/src/dialer.js +++ b/examples/chat/src/dialer.js @@ -31,7 +31,9 @@ async.parallel([ if (err) throw err const peerDialer = new PeerInfo(ids[0]) peerDialer.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - const nodeDialer = new Node(peerDialer) + const nodeDialer = new Node({ + peerInfo: peerDialer + }) const peerListener = new PeerInfo(ids[1]) idListener = ids[1] diff --git a/examples/chat/src/libp2p-bundle.js b/examples/chat/src/libp2p-bundle.js index f76f8b7207..8f84e9d5bb 100644 --- a/examples/chat/src/libp2p-bundle.js +++ b/examples/chat/src/libp2p-bundle.js @@ -3,11 +3,12 @@ const TCP = require('libp2p-tcp') const MulticastDNS = require('libp2p-mdns') const WS = require('libp2p-websockets') -const Railing = require('libp2p-railing') +const Bootstrap = require('libp2p-railing') const spdy = require('libp2p-spdy') const KadDHT = require('libp2p-kad-dht') const mplex = require('libp2p-mplex') const secio = require('libp2p-secio') +const defaultsDeep = require('@nodeutils/defaults-deep') const libp2p = require('../../..') function mapMuxers (list) { @@ -36,44 +37,40 @@ function getMuxers (muxers) { } class Node extends libp2p { - constructor (peerInfo, peerBook, options) { - options = options || {} - - const modules = { - transport: [ - new TCP(), - new WS() - ], - connection: { - muxer: getMuxers(options.muxer), - crypto: [ secio ] + constructor (_options) { + const defaults = { + modules: { + transport: [ + TCP, + WS + ], + streamMuxer: getMuxers(_options.muxer), + connEncryption: [ secio ], + peerDiscovery: [ + MulticastDNS, + Bootstrap + ], + dht: KadDHT }, - discovery: [] - } - - if (options.dht) { - modules.DHT = KadDHT - } - - if (options.mdns) { - const mdns = new MulticastDNS(peerInfo, 'ipfs.local') - modules.discovery.push(mdns) - } - - if (options.bootstrap) { - const r = new Railing(options.bootstrap) - modules.discovery.push(r) - } - - if (options.modules && options.modules.transport) { - options.modules.transport.forEach((t) => modules.transport.push(t)) - } - - if (options.modules && options.modules.discovery) { - options.modules.discovery.forEach((d) => modules.discovery.push(d)) + config: { + peerDiscovery: { + mdns: { + interval: 10000, + enabled: false + }, + bootstrap: { + interval: 10000, + enabled: false, + list: _options.bootstrapList + } + }, + dht: { + kBucketSize: 20 + } + } } - super(modules, peerInfo, peerBook, options) + super(defaultsDeep(_options, defaults)) } } diff --git a/examples/chat/src/listener.js b/examples/chat/src/listener.js index 51ac9090b5..d286d458ad 100644 --- a/examples/chat/src/listener.js +++ b/examples/chat/src/listener.js @@ -14,14 +14,16 @@ PeerId.createFromJSON(require('./peer-id-listener'), (err, idListener) => { } const peerListener = new PeerInfo(idListener) peerListener.multiaddrs.add('/ip4/0.0.0.0/tcp/10333') - const nodeListener = new Node(peerListener) + const nodeListener = new Node({ + peerInfo: peerListener + }) nodeListener.start((err) => { if (err) { throw err } - nodeListener.switch.on('peer-mux-established', (peerInfo) => { + nodeListener.on('peer:connect', (peerInfo) => { console.log(peerInfo.id.toB58String()) }) diff --git a/examples/discovery-mechanisms/1.js b/examples/discovery-mechanisms/1.js index a0eb566489..444973db2c 100644 --- a/examples/discovery-mechanisms/1.js +++ b/examples/discovery-mechanisms/1.js @@ -1,12 +1,13 @@ 'use strict' -const libp2p = require('libp2p') +const libp2p = require('../../') const TCP = require('libp2p-tcp') const Mplex = require('libp2p-mplex') const SECIO = require('libp2p-secio') const PeerInfo = require('peer-info') -const Railing = require('libp2p-railing') +const Bootstrap = require('libp2p-railing') const waterfall = require('async/waterfall') +const defaultsDeep = require('@nodeutils/defaults-deep') // Find this list at: https://github.com/ipfs/js-ipfs/blob/master/src/core/runtime/config-nodejs.json const bootstrapers = [ @@ -22,16 +23,26 @@ const bootstrapers = [ ] class MyBundle extends libp2p { - constructor (peerInfo) { - const modules = { - transport: [new TCP()], - connection: { - muxer: [Mplex], - crypto: [SECIO] + constructor (_options) { + const defaults = { + modules: { + transport: [ TCP ], + streamMuxer: [ Mplex ], + connEncryption: [ SECIO ], + peerDiscovery: [ Bootstrap ] }, - discovery: [new Railing(bootstrapers)] + config: { + peerDiscovery: { + bootstrap: { + interval: 2000, + enabled: true, + list: bootstrapers + } + } + } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } @@ -41,7 +52,9 @@ waterfall([ (cb) => PeerInfo.create(cb), (peerInfo, cb) => { peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - node = new MyBundle(peerInfo) + node = new MyBundle({ + peerInfo + }) node.start(cb) } ], (err) => { diff --git a/examples/discovery-mechanisms/2.js b/examples/discovery-mechanisms/2.js index 2758352ff5..10bcf168e2 100644 --- a/examples/discovery-mechanisms/2.js +++ b/examples/discovery-mechanisms/2.js @@ -1,6 +1,6 @@ 'use strict' -const libp2p = require('libp2p') +const libp2p = require('../../') const TCP = require('libp2p-tcp') const Mplex = require('libp2p-mplex') const SECIO = require('libp2p-secio') @@ -8,18 +8,28 @@ const PeerInfo = require('peer-info') const MulticastDNS = require('libp2p-mdns') const waterfall = require('async/waterfall') const parallel = require('async/parallel') +const defaultsDeep = require('@nodeutils/defaults-deep') class MyBundle extends libp2p { - constructor (peerInfo) { - const modules = { - transport: [new TCP()], - connection: { - muxer: [Mplex], - crypto: [SECIO] + constructor (_options) { + const defaults = { + modules: { + transport: [ TCP ], + streamMuxer: [ Mplex ], + connEncryption: [ SECIO ], + peerDiscovery: [ MulticastDNS ] }, - discovery: [new MulticastDNS(peerInfo, { interval: 1000 })] + config: { + peerDiscovery: { + mdns: { + interval: 1000, + enabled: true + } + } + } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } @@ -30,7 +40,9 @@ function createNode (callback) { (cb) => PeerInfo.create(cb), (peerInfo, cb) => { peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - node = new MyBundle(peerInfo) + node = new MyBundle({ + peerInfo + }) node.start(cb) } ], (err) => callback(err, node)) diff --git a/examples/discovery-mechanisms/README.md b/examples/discovery-mechanisms/README.md index 0c3b96ec5e..4346b9a2dd 100644 --- a/examples/discovery-mechanisms/README.md +++ b/examples/discovery-mechanisms/README.md @@ -13,17 +13,28 @@ For this demo, we will connect to IPFS default bootstrapper nodes and so, we wil First, we create our libp2p bundle. ```JavaScript +const Bootstrap = require('libp2p-railing') class MyBundle extends libp2p { constructor (peerInfo) { - const modules = { - transport: [new TCP()], - connection: { - muxer: [Mplex], - crypto: [SECIO] + const defaults = { + modules: { + transport: [ TCP ], + streamMuxer: [ Mplex ], + connEncryption: [ SECIO ], + peerDiscovery: [ Bootstrap ] }, - discovery: [new Railing(bootstrapers)] + config: { + peerDiscovery: { + bootstrap: { + interval: 2000, + enabled: true, + list: bootstrapers + } + } + } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } ``` @@ -53,7 +64,9 @@ waterfall([ (cb) => PeerInfo.create(cb), (peerInfo, cb) => { peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - node = new MyBundle(peerInfo) + node = new MyBundle({ + peerInfo + }) node.start(cb) } ], (err) => { @@ -108,17 +121,25 @@ Update your libp2p bundle to include MulticastDNS. ```JavaScript class MyBundle extends libp2p { constructor (peerInfo) { - const modules = { - transport: [new TCP()], - connection: { - muxer: [Mplex], - crypto: [SECIO] + const defaults = { + modules: { + transport: [ TCP ], + streamMuxer: [ Mplex ], + connEncryption: [ SECIO ], + peerDiscovery: [ MulticastDNS ] }, - // We set the interval here to 1 second so that is faster to observe. The - // default is 10 seconds. - discovery: [new MulticastDNS(peerInfo, { interval: 1000 })] + config: { + peerDiscovery: { + mdns: { + // Run at 1s so we can observe more quickly, default is 10s + interval: 1000, + enabled: true + } + } + } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } ``` diff --git a/examples/echo/README.md b/examples/echo/README.md index f848b46538..01c672c90d 100644 --- a/examples/echo/README.md +++ b/examples/echo/README.md @@ -1 +1,13 @@ # Echo example with libp2p + +This example performs a simple echo from the listener to the dialer. + +## Setup +1. Install the modules, `npm install`. +2. Open 2 terminal windows in the `./src` directory. + +## Running +1. Run the listener in window 1, `node listener.js` +2. Run the dialer in window 2, `node dialer.js` +3. You should see console logs showing the dial, and the received echo of _hey_ +4. If you look at the listener window, you will see it receiving the dial diff --git a/examples/echo/src/dialer.js b/examples/echo/src/dialer.js index b882511baf..71f8cbf74f 100644 --- a/examples/echo/src/dialer.js +++ b/examples/echo/src/dialer.js @@ -21,7 +21,9 @@ async.parallel([ const dialerId = ids[0] const dialerPeerInfo = new PeerInfo(dialerId) dialerPeerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - const dialerNode = new Node(dialerPeerInfo) + const dialerNode = new Node({ + peerInfo: dialerPeerInfo + }) // Peer to Dial const listenerPeerInfo = new PeerInfo(ids[1]) diff --git a/examples/echo/src/libp2p-bundle.js b/examples/echo/src/libp2p-bundle.js index f76f8b7207..8f84e9d5bb 100644 --- a/examples/echo/src/libp2p-bundle.js +++ b/examples/echo/src/libp2p-bundle.js @@ -3,11 +3,12 @@ const TCP = require('libp2p-tcp') const MulticastDNS = require('libp2p-mdns') const WS = require('libp2p-websockets') -const Railing = require('libp2p-railing') +const Bootstrap = require('libp2p-railing') const spdy = require('libp2p-spdy') const KadDHT = require('libp2p-kad-dht') const mplex = require('libp2p-mplex') const secio = require('libp2p-secio') +const defaultsDeep = require('@nodeutils/defaults-deep') const libp2p = require('../../..') function mapMuxers (list) { @@ -36,44 +37,40 @@ function getMuxers (muxers) { } class Node extends libp2p { - constructor (peerInfo, peerBook, options) { - options = options || {} - - const modules = { - transport: [ - new TCP(), - new WS() - ], - connection: { - muxer: getMuxers(options.muxer), - crypto: [ secio ] + constructor (_options) { + const defaults = { + modules: { + transport: [ + TCP, + WS + ], + streamMuxer: getMuxers(_options.muxer), + connEncryption: [ secio ], + peerDiscovery: [ + MulticastDNS, + Bootstrap + ], + dht: KadDHT }, - discovery: [] - } - - if (options.dht) { - modules.DHT = KadDHT - } - - if (options.mdns) { - const mdns = new MulticastDNS(peerInfo, 'ipfs.local') - modules.discovery.push(mdns) - } - - if (options.bootstrap) { - const r = new Railing(options.bootstrap) - modules.discovery.push(r) - } - - if (options.modules && options.modules.transport) { - options.modules.transport.forEach((t) => modules.transport.push(t)) - } - - if (options.modules && options.modules.discovery) { - options.modules.discovery.forEach((d) => modules.discovery.push(d)) + config: { + peerDiscovery: { + mdns: { + interval: 10000, + enabled: false + }, + bootstrap: { + interval: 10000, + enabled: false, + list: _options.bootstrapList + } + }, + dht: { + kBucketSize: 20 + } + } } - super(modules, peerInfo, peerBook, options) + super(defaultsDeep(_options, defaults)) } } diff --git a/examples/echo/src/listener.js b/examples/echo/src/listener.js index 8888071fed..d738250951 100644 --- a/examples/echo/src/listener.js +++ b/examples/echo/src/listener.js @@ -25,9 +25,11 @@ series([ (cb) => { const listenerPeerInfo = new PeerInfo(listenerId) listenerPeerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/10333') - listenerNode = new Node(listenerPeerInfo) + listenerNode = new Node({ + peerInfo: listenerPeerInfo + }) - listenerNode.switch.on('peer-mux-established', (peerInfo) => { + listenerNode.on('peer:connect', (peerInfo) => { console.log('received dial to me from:', peerInfo.id.toB58String()) }) diff --git a/examples/encrypted-communications/1.js b/examples/encrypted-communications/1.js index 5342a96f43..d15b811d8c 100644 --- a/examples/encrypted-communications/1.js +++ b/examples/encrypted-communications/1.js @@ -1,6 +1,6 @@ 'use strict' -const libp2p = require('libp2p') +const libp2p = require('../../') const TCP = require('libp2p-tcp') const SPDY = require('libp2p-spdy') const SECIO = require('libp2p-secio') @@ -8,17 +8,19 @@ const PeerInfo = require('peer-info') const waterfall = require('async/waterfall') const parallel = require('async/parallel') const pull = require('pull-stream') +const defaultsDeep = require('@nodeutils/defaults-deep') class MyBundle extends libp2p { - constructor (peerInfo) { - const modules = { - transport: [new TCP()], - connection: { - muxer: [SPDY], - crypto: [SECIO] + constructor (_options) { + const defaults = { + modules: { + transport: [ TCP ], + streamMuxer: [ SPDY ], + connEncryption: [ SECIO ] } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } @@ -29,7 +31,9 @@ function createNode (callback) { (cb) => PeerInfo.create(cb), (peerInfo, cb) => { peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - node = new MyBundle(peerInfo) + node = new MyBundle({ + peerInfo + }) node.start(cb) } ], (err) => callback(err, node)) diff --git a/examples/encrypted-communications/README.md b/examples/encrypted-communications/README.md index 21ec26cc9a..a1ec9b3348 100644 --- a/examples/encrypted-communications/README.md +++ b/examples/encrypted-communications/README.md @@ -19,15 +19,16 @@ const SECIO = require('libp2p-secio') class MyBundle extends libp2p { constructor (peerInfo) { - const modules = { - transport: [new TCP()], - connection: { - muxer: [SPDY], + const defaults = { + modules: { + transport: [ TCP ], + streamMuxer: [ SPDY ], // Attach secio as the crypto channel to use - crypto: [SECIO] + connEncryption: [ SECIO ] } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } ``` diff --git a/examples/libp2p-in-the-browser/1/package.json b/examples/libp2p-in-the-browser/1/package.json index efaa19cc83..c4651ec5c8 100644 --- a/examples/libp2p-in-the-browser/1/package.json +++ b/examples/libp2p-in-the-browser/1/package.json @@ -13,17 +13,16 @@ "browserify": "^14.5.0", "concat-stream": "^1.6.0", "detect-dom-ready": "^1.0.2", - "node-static": "^0.7.10" + "node-static": "~0.7.10" }, "dependencies": { "detect-dom-ready": "^1.0.2", - "libp2p": "^0.13.0", - "libp2p-mplex": "^0.6.0", - "libp2p-railing": "^0.7.1", - "libp2p-secio": "^0.8.1", - "libp2p-spdy": "^0.11.0", - "libp2p-webrtc-star": "^0.13.2", - "libp2p-websockets": "^0.10.4", - "peer-info": "^0.11.0" + "libp2p-mplex": "~0.8.0", + "libp2p-railing": "~0.9.1", + "libp2p-secio": "~0.10.0", + "libp2p-spdy": "~0.12.1", + "libp2p-webrtc-star": "~0.15.3", + "libp2p-websockets": "~0.12.0", + "peer-info": "~0.14.1" } } diff --git a/examples/libp2p-in-the-browser/1/src/browser-bundle.js b/examples/libp2p-in-the-browser/1/src/browser-bundle.js index 92a2838649..80017c175b 100644 --- a/examples/libp2p-in-the-browser/1/src/browser-bundle.js +++ b/examples/libp2p-in-the-browser/1/src/browser-bundle.js @@ -2,13 +2,12 @@ const WebRTCStar = require('libp2p-webrtc-star') const WebSockets = require('libp2p-websockets') - const Mplex = require('libp2p-mplex') const SPDY = require('libp2p-spdy') const SECIO = require('libp2p-secio') - -const Railing = require('libp2p-railing') -const libp2p = require('libp2p') +const Bootstrap = require('libp2p-railing') +const defaultsDeep = require('@nodeutils/defaults-deep') +const libp2p = require('../../../../') // Find this list at: https://github.com/ipfs/js-ipfs/blob/master/src/core/runtime/config-browser.json const bootstrapers = [ @@ -25,30 +24,56 @@ const bootstrapers = [ ] class Node extends libp2p { - constructor (peerInfo, peerBook, options) { - options = options || {} - - const wstar = new WebRTCStar() + constructor (_options) { + const wrtcStar = new WebRTCStar({ id: _options.peerInfo.id }) - const modules = { - transport: [ - wstar, - new WebSockets() - ], - connection: { - muxer: [ + const defaults = { + modules: { + transport: [ + wrtcStar, + new WebSockets() + ], + streamMuxer: [ Mplex, SPDY ], - crypto: [SECIO] + connEncryption: [ + SECIO + ], + peerDiscovery: [ + wrtcStar.discovery, + Bootstrap + ] }, - discovery: [ - wstar.discovery, - new Railing(bootstrapers) - ] + config: { + peerDiscovery: { + webRTCStar: { + enabled: true + }, + websocketStar: { + enabled: true + }, + bootstrap: { + interval: 10000, + enabled: false, + list: bootstrapers + } + }, + relay: { + enabled: false, + hop: { + enabled: false, + active: false + } + }, + EXPERIMENTAL: { + dht: false, + pubsub: false + } + } } - super(modules, peerInfo, peerBook, options) + super(defaultsDeep(_options, defaults)) } } diff --git a/examples/libp2p-in-the-browser/1/src/create-node.js b/examples/libp2p-in-the-browser/1/src/create-node.js index 3afdad8fc5..dd2530ea11 100644 --- a/examples/libp2p-in-the-browser/1/src/create-node.js +++ b/examples/libp2p-in-the-browser/1/src/create-node.js @@ -14,7 +14,9 @@ function createNode (callback) { peerInfo.multiaddrs.add(ma) - const node = new Node(peerInfo) + const node = new Node({ + peerInfo + }) node.idStr = peerIdStr callback(null, node) diff --git a/examples/peer-and-content-routing/1.js b/examples/peer-and-content-routing/1.js index 056f78f5c8..bf121d7dea 100644 --- a/examples/peer-and-content-routing/1.js +++ b/examples/peer-and-content-routing/1.js @@ -1,27 +1,36 @@ 'use strict' -const libp2p = require('libp2p') +const libp2p = require('../../') const TCP = require('libp2p-tcp') const Mplex = require('libp2p-mplex') const SECIO = require('libp2p-secio') const PeerInfo = require('peer-info') const KadDHT = require('libp2p-kad-dht') - +const defaultsDeep = require('@nodeutils/defaults-deep') const waterfall = require('async/waterfall') const parallel = require('async/parallel') class MyBundle extends libp2p { - constructor (peerInfo) { - const modules = { - transport: [new TCP()], - connection: { - muxer: [Mplex], - crypto: [SECIO] + constructor (_options) { + const defaults = { + modules: { + transport: [ TCP ], + streamMuxer: [ Mplex ], + connEncryption: [ SECIO ], + // we add the DHT module that will enable Peer and Content Routing + dht: KadDHT }, - // we add the DHT module that will enable Peer and Content Routing - DHT: KadDHT + config: { + dht: { + kBucketSize: 20 + }, + EXPERIMENTAL: { + dht: true + } + } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } @@ -32,7 +41,9 @@ function createNode (callback) { (cb) => PeerInfo.create(cb), (peerInfo, cb) => { peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - node = new MyBundle(peerInfo) + node = new MyBundle({ + peerInfo + }) node.start(cb) } ], (err) => callback(err, node)) diff --git a/examples/peer-and-content-routing/2.js b/examples/peer-and-content-routing/2.js index 330e4901ae..acd508d48e 100644 --- a/examples/peer-and-content-routing/2.js +++ b/examples/peer-and-content-routing/2.js @@ -1,28 +1,37 @@ 'use strict' -const libp2p = require('libp2p') +const libp2p = require('../../') const TCP = require('libp2p-tcp') const Mplex = require('libp2p-mplex') const SECIO = require('libp2p-secio') const PeerInfo = require('peer-info') const CID = require('cids') const KadDHT = require('libp2p-kad-dht') - +const defaultsDeep = require('@nodeutils/defaults-deep') const waterfall = require('async/waterfall') const parallel = require('async/parallel') class MyBundle extends libp2p { - constructor (peerInfo) { - const modules = { - transport: [new TCP()], - connection: { - muxer: [Mplex], - crypto: [SECIO] + constructor (_options) { + const defaults = { + modules: { + transport: [ TCP ], + streamMuxer: [ Mplex ], + connEncryption: [ SECIO ], + // we add the DHT module that will enable Peer and Content Routing + dht: KadDHT }, - // we add the DHT module that will enable Peer and Content Routing - DHT: KadDHT + config: { + dht: { + kBucketSize: 20 + }, + EXPERIMENTAL: { + dht: true + } + } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } @@ -33,7 +42,9 @@ function createNode (callback) { (cb) => PeerInfo.create(cb), (peerInfo, cb) => { peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - node = new MyBundle(peerInfo) + node = new MyBundle({ + peerInfo + }) node.start(cb) } ], (err) => callback(err, node)) diff --git a/examples/peer-and-content-routing/README.md b/examples/peer-and-content-routing/README.md index 06ce9471e0..27e1849631 100644 --- a/examples/peer-and-content-routing/README.md +++ b/examples/peer-and-content-routing/README.md @@ -14,17 +14,27 @@ First, let's update our bundle to support Peer Routing and Content Routing. ```JavaScript class MyBundle extends libp2p { - constructor (peerInfo) { - const modules = { - transport: [new TCP()], - connection: { - muxer: [Mplex], - crypto: [SECIO] + constructor (_options) { + const defaults = { + modules: { + transport: [ TCP ], + streamMuxer: [ Mplex ], + connEncryption: [ SECIO ], + // we add the DHT module that will enable Peer and Content Routing + dht: KadDHT }, - // we add the DHT module that will enable Peer and Content Routing - DHT: KadDHT + config: { + dht: { + kBucketSize: 20 + }, + EXPERIMENTAL: { + // dht must be enabled + dht: true + } + } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } ``` @@ -44,7 +54,7 @@ parallel([ ], (err) => { if (err) { throw err } - // + // node1.peerRouting.findPeer(node3.peerInfo.id, (err, peer) => { if (err) { throw err } diff --git a/examples/protocol-and-stream-muxing/1.js b/examples/protocol-and-stream-muxing/1.js index 59c050fa6b..a4475b01e5 100644 --- a/examples/protocol-and-stream-muxing/1.js +++ b/examples/protocol-and-stream-muxing/1.js @@ -1,18 +1,22 @@ 'use strict' -const libp2p = require('libp2p') +const libp2p = require('../../') const TCP = require('libp2p-tcp') const PeerInfo = require('peer-info') const waterfall = require('async/waterfall') const parallel = require('async/parallel') const pull = require('pull-stream') +const defaultsDeep = require('@nodeutils/defaults-deep') class MyBundle extends libp2p { - constructor (peerInfo) { - const modules = { - transport: [new TCP()] + constructor (_options) { + const defaults = { + modules: { + transport: [ TCP ] + } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } @@ -23,7 +27,9 @@ function createNode (callback) { (cb) => PeerInfo.create(cb), (peerInfo, cb) => { peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - node = new MyBundle(peerInfo) + node = new MyBundle({ + peerInfo + }) node.start(cb) } ], (err) => callback(err, node)) diff --git a/examples/protocol-and-stream-muxing/2.js b/examples/protocol-and-stream-muxing/2.js index a8f2f63200..89e86d8c52 100644 --- a/examples/protocol-and-stream-muxing/2.js +++ b/examples/protocol-and-stream-muxing/2.js @@ -1,6 +1,6 @@ 'use strict' -const libp2p = require('libp2p') +const libp2p = require('../../') const TCP = require('libp2p-tcp') const SPDY = require('libp2p-spdy') const PeerInfo = require('peer-info') @@ -8,16 +8,18 @@ const waterfall = require('async/waterfall') const parallel = require('async/parallel') const series = require('async/series') const pull = require('pull-stream') +const defaultsDeep = require('@nodeutils/defaults-deep') class MyBundle extends libp2p { - constructor (peerInfo) { - const modules = { - transport: [new TCP()], - connection: { - muxer: [SPDY] + constructor (_options) { + const defaults = { + modules: { + transport: [ TCP ], + streamMuxer: [ SPDY ] } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } @@ -28,7 +30,9 @@ function createNode (callback) { (cb) => PeerInfo.create(cb), (peerInfo, cb) => { peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - node = new MyBundle(peerInfo) + node = new MyBundle({ + peerInfo + }) node.start(cb) } ], (err) => callback(err, node)) diff --git a/examples/protocol-and-stream-muxing/3.js b/examples/protocol-and-stream-muxing/3.js index 86c6e686f9..730bf01ecc 100644 --- a/examples/protocol-and-stream-muxing/3.js +++ b/examples/protocol-and-stream-muxing/3.js @@ -1,6 +1,6 @@ 'use strict' -const libp2p = require('libp2p') +const libp2p = require('../../') const TCP = require('libp2p-tcp') const SPDY = require('libp2p-spdy') const PeerInfo = require('peer-info') @@ -8,16 +8,18 @@ const waterfall = require('async/waterfall') const parallel = require('async/parallel') const series = require('async/series') const pull = require('pull-stream') +const defaultsDeep = require('@nodeutils/defaults-deep') class MyBundle extends libp2p { - constructor (peerInfo) { - const modules = { - transport: [new TCP()], - connection: { - muxer: [SPDY] + constructor (_options) { + const defaults = { + modules: { + transport: [ TCP ], + streamMuxer: [ SPDY ] } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } @@ -28,7 +30,9 @@ function createNode (callback) { (cb) => PeerInfo.create(cb), (peerInfo, cb) => { peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - node = new MyBundle(peerInfo) + node = new MyBundle({ + peerInfo + }) node.start(cb) } ], (err) => callback(err, node)) @@ -60,12 +64,12 @@ parallel([ }) series([ - (cb) => node1.dial(node2.peerInfo, '/node-2', (err, conn) => { + (cb) => node1.dialProtocol(node2.peerInfo, '/node-2', (err, conn) => { if (err) { throw err } pull(pull.values(['from 1 to 2']), conn) cb() }), - (cb) => node2.dial(node1.peerInfo, '/node-1', (err, conn) => { + (cb) => node2.dialProtocol(node1.peerInfo, '/node-1', (err, conn) => { if (err) { throw err } pull(pull.values(['from 2 to 1']), conn) cb() diff --git a/examples/protocol-and-stream-muxing/README.md b/examples/protocol-and-stream-muxing/README.md index 3abe138bd0..1507372f67 100644 --- a/examples/protocol-and-stream-muxing/README.md +++ b/examples/protocol-and-stream-muxing/README.md @@ -8,7 +8,7 @@ The feature of agreeing on a protocol over an established connection is what we Let's see _protocol multiplexing_ in action! You will need the following modules for this example: `libp2p`, `libp2p-tcp`, `peer-info`, `async` and `pull-stream`. This example reuses the base left by the [Transports](../transports) example. You can see the complete solution at [1.js](./1.js). -After creating the nodes, we need to tell libp2p which protocols to handle. +After creating the nodes, we need to tell libp2p which protocols to handle. ```JavaScript // ... @@ -55,7 +55,7 @@ node1.dialProtocol(node2.peerInfo, '/another-protocol/1.0.0', (err, conn) => { This feature is super power for network protocols. It works in the same way as versioning your RPC/REST API, but for anything that goes in the wire. We had to use this feature to upgrade protocols within the IPFS Stack (i.e Bitswap) and we successfully managed to do so without any network splits. -There is still one last feature, you can create your custom match functions. +There is still one last feature, you can create your custom match functions. ```JavaScript node2.handle('/custom-match-func', (protocol, conn) => { @@ -94,17 +94,18 @@ Currently, we have two available [libp2p-spdy](https://github.com/libp2p/js-libp const SPDY = require('libp2p-spdy') //... class MyBundle extends libp2p { - constructor (peerInfo) { - const modules = { - transport: [new TCP()], - // Here we are adding the SPDY muxer to our libp2p bundle. + constructor (_options) { + const defaults = { + modules: { + transport: [ TCP ], + // Here we are adding the SPDY muxer to our libp2p bundle. // Thanks to protocol muxing, a libp2p bundle can support multiple Stream Muxers at the same // time and pick the right one when dialing to a node - connection: { - muxer: [SPDY] + streamMuxer: [ SPDY ] } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } ``` diff --git a/examples/pubsub/1.js b/examples/pubsub/1.js index e6e93fbf23..7331de180f 100644 --- a/examples/pubsub/1.js +++ b/examples/pubsub/1.js @@ -1,28 +1,39 @@ 'use strict' -const libp2p = require('libp2p') +const libp2p = require('../../') const TCP = require('libp2p-tcp') const Mplex = require('libp2p-mplex') const SECIO = require('libp2p-secio') const PeerInfo = require('peer-info') const MulticastDNS = require('libp2p-mdns') +const defaultsDeep = require('@nodeutils/defaults-deep') const waterfall = require('async/waterfall') const parallel = require('async/parallel') const series = require('async/series') class MyBundle extends libp2p { - constructor (peerInfo) { - const modules = { - transport: [new TCP()], - connection: { - muxer: [Mplex], - crypto: [SECIO] + constructor (_options) { + const defaults = { + modules: { + transport: [ TCP ], + streamMuxer: [ Mplex ], + connEncryption: [ SECIO ], + peerDiscovery: [ MulticastDNS ] }, - discovery: [ - new MulticastDNS(peerInfo, { interval: 2000 }) - ] + config: { + peerDiscovery: { + mdns: { + interval: 2000, + enabled: true + } + }, + EXPERIMENTAL: { + pubsub: true + } + } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } @@ -33,7 +44,9 @@ function createNode (callback) { (cb) => PeerInfo.create(cb), (peerInfo, cb) => { peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - node = new MyBundle(peerInfo) + node = new MyBundle({ + peerInfo + }) node.start(cb) } ], (err) => callback(err, node)) diff --git a/examples/transports/1.js b/examples/transports/1.js index 952f933d62..58b279cb01 100644 --- a/examples/transports/1.js +++ b/examples/transports/1.js @@ -1,16 +1,22 @@ 'use strict' -const libp2p = require('libp2p') +const libp2p = require('../../') const TCP = require('libp2p-tcp') const PeerInfo = require('peer-info') const waterfall = require('async/waterfall') +const defaultsDeep = require('@nodeutils/defaults-deep') class MyBundle extends libp2p { - constructor (peerInfo) { - const modules = { - transport: [new TCP()] + constructor (_options) { + const defaults = { + modules: { + transport: [ + TCP + ] + } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } @@ -20,7 +26,7 @@ waterfall([ (cb) => PeerInfo.create(cb), (peerInfo, cb) => { peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - node = new MyBundle(peerInfo) + node = new MyBundle({ peerInfo: peerInfo }) node.start(cb) } ], (err) => { diff --git a/examples/transports/2.js b/examples/transports/2.js index 5ebfc622f6..508c01d628 100644 --- a/examples/transports/2.js +++ b/examples/transports/2.js @@ -1,18 +1,24 @@ 'use strict' -const libp2p = require('libp2p') +const libp2p = require('../../') const TCP = require('libp2p-tcp') const PeerInfo = require('peer-info') const waterfall = require('async/waterfall') +const defaultsDeep = require('@nodeutils/defaults-deep') const parallel = require('async/parallel') const pull = require('pull-stream') class MyBundle extends libp2p { - constructor (peerInfo) { - const modules = { - transport: [new TCP()] + constructor (_options) { + const defaults = { + modules: { + transport: [ + TCP + ] + } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } @@ -23,7 +29,7 @@ function createNode (callback) { (cb) => PeerInfo.create(cb), (peerInfo, cb) => { peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - node = new MyBundle(peerInfo) + node = new MyBundle({ peerInfo: peerInfo }) node.start(cb) } ], (err) => callback(err, node)) diff --git a/examples/transports/3.js b/examples/transports/3.js index 5f96f9b81c..9bce138108 100644 --- a/examples/transports/3.js +++ b/examples/transports/3.js @@ -1,19 +1,26 @@ 'use strict' -const libp2p = require('libp2p') +const libp2p = require('../../') const TCP = require('libp2p-tcp') const WebSockets = require('libp2p-websockets') const PeerInfo = require('peer-info') const waterfall = require('async/waterfall') +const defaultsDeep = require('@nodeutils/defaults-deep') const parallel = require('async/parallel') const pull = require('pull-stream') class MyBundle extends libp2p { - constructor (peerInfo) { - const modules = { - transport: [new TCP(), new WebSockets()] + constructor (_options) { + const defaults = { + modules: { + transport: [ + TCP, + WebSockets + ] + } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } @@ -28,7 +35,7 @@ function createNode (addrs, callback) { (cb) => PeerInfo.create(cb), (peerInfo, cb) => { addrs.forEach((addr) => peerInfo.multiaddrs.add(addr)) - node = new MyBundle(peerInfo) + node = new MyBundle({ peerInfo: peerInfo }) node.start(cb) } ], (err) => callback(err, node)) diff --git a/examples/transports/README.md b/examples/transports/README.md index 5400f0ea3b..8f1e5d6de0 100644 --- a/examples/transports/README.md +++ b/examples/transports/README.md @@ -10,10 +10,10 @@ A more complete definition of what is a transport can be found on the [interface When using libp2p, you always want to create your own libp2p Bundle, that is, pick your set of modules and create your network stack with the properties you need. In this example, we will create a bundle with TCP. You can find the complete solution on the file [1.js](./1.js). -You will need 4 deps total, so go ahead and install all of them with: +You will need 5 deps total, so go ahead and install all of them with: ```bash -> npm install libp2p libp2p-tcp peer-info async +> npm install libp2p libp2p-tcp peer-info async @nodeutils/defaults-deep ``` Then, on your favorite text editor create a file with the `.js` extension. I've called mine `1.js`. @@ -27,16 +27,22 @@ const libp2p = require('libp2p') const TCP = require('libp2p-tcp') const PeerInfo = require('peer-info') const waterfall = require('async/waterfall') +const defaultsDeep = require('@nodeutils/defaults-deep') // This MyBundle class is your libp2p bundle packed with TCP class MyBundle extends libp2p { - constructor (peerInfo) { - // modules is a JS object that will describe the components - // we want for our libp2p bundle - const modules = { - transport: [new TCP()] + constructor (_options) { + const defaults = { + // modules is a JS object that will describe the components + // we want for our libp2p bundle + modules: { + transport: [ + TCP + ] + } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } ``` @@ -57,7 +63,7 @@ waterfall([ // the multiaddr format, a self describable address peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') // Now we can create a node with that PeerInfo object - node = new MyBundle(peerInfo) + node = new MyBundle({ peerInfo: peerInfo }) // Last, we start the node! node.start(cb) } @@ -114,7 +120,7 @@ function createNode (callback) { (cb) => PeerInfo.create(cb), (peerInfo, cb) => { peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - node = new MyBundle(peerInfo) + node = new MyBundle({ peerInfo: peerInfo }) node.start(cb) } ], (err) => callback(err, node)) @@ -133,7 +139,7 @@ Now we are going to use `async/parallel` to create two nodes, print their addres const parallel = require('async/parallel') ``` -Then, +Then, ```js parallel([ @@ -196,11 +202,17 @@ const WebSockets = require('libp2p-websockets') // ... class MyBundle extends libp2p { - constructor (peerInfo) { - const modules = { - transport: [new TCP(), new WebSockets()] + constructor (_options) { + const defaults = { + modules: { + transport: [ + TCP, + WebSockets + ] + } } - super(modules, peerInfo) + + super(defaultsDeep(_options, defaults)) } } ``` @@ -219,7 +231,7 @@ function createNode (addrs, callback) { (cb) => PeerInfo.create(cb), (peerInfo, cb) => { addrs.forEach((addr) => peerInfo.multiaddrs.add(addr)) - node = new MyBundle(peerInfo) + node = new MyBundle({ peerInfo: peerInfo }) node.start(cb) } ], (err) => callback(err, node)) diff --git a/package.json b/package.json index d47dafe873..62dfe4e057 100644 --- a/package.json +++ b/package.json @@ -36,13 +36,18 @@ "url": "https://github.com/libp2p/js-libp2p/issues" }, "homepage": "https://github.com/libp2p/js-libp2p", + "browser": { + "joi": "joi-browser" + }, "dependencies": { "async": "^2.6.0", + "joi": "^13.4.0", + "joi-browser": "^13.4.0", "libp2p-connection-manager": "~0.0.2", - "libp2p-floodsub": "^0.15.0", + "libp2p-floodsub": "~0.15.0", "libp2p-ping": "~0.8.0", "libp2p-switch": "~0.40.4", - "libp2p-websockets": "^0.12.0", + "libp2p-websockets": "~0.12.0", "mafmt": "^6.0.0", "multiaddr": "^5.0.0", "peer-book": "~0.8.0", @@ -50,21 +55,22 @@ "peer-info": "~0.14.1" }, "devDependencies": { - "aegir": "^13.1.0", + "@nodeutils/defaults-deep": "^1.1.0", + "aegir": "^14.0.0", "chai": "^4.1.2", "cids": "~0.5.3", "dirty-chai": "^2.0.1", "electron-webrtc": "~0.3.0", "libp2p-circuit": "~0.2.0", "libp2p-kad-dht": "~0.10.0", - "libp2p-mdns": "~0.11.0", + "libp2p-mdns": "~0.12.0", "libp2p-mplex": "~0.7.0", - "libp2p-railing": "~0.8.1", + "libp2p-railing": "~0.9.1", "libp2p-secio": "~0.10.0", "libp2p-spdy": "~0.12.1", "libp2p-tcp": "~0.12.0", - "libp2p-webrtc-star": "~0.15.0", - "libp2p-websocket-star": "~0.8.0", + "libp2p-webrtc-star": "~0.15.3", + "libp2p-websocket-star": "~0.8.1", "libp2p-websocket-star-rendezvous": "~0.2.3", "lodash.times": "^4.3.2", "pull-goodbye": "0.0.2", diff --git a/src/config.js b/src/config.js new file mode 100644 index 0000000000..7f57e50c0d --- /dev/null +++ b/src/config.js @@ -0,0 +1,83 @@ +'use strict' + +const Joi = require('joi') + +const schema = Joi.object({ + // TODO: create proper validators for the generics + connectionManager: Joi.object(), + peerInfo: Joi.object().required(), + peerBook: Joi.object(), + modules: Joi.object().keys({ + transport: Joi.array().items( + Joi.alternatives().try( + Joi.func(), + Joi.object() + ) + ).min(1).required(), + streamMuxer: Joi.array().items( + Joi.alternatives().try( + Joi.func(), + Joi.object() + ) + ).allow(null), + connEncryption: Joi.array().items( + Joi.alternatives().try( + Joi.func(), + Joi.object() + ) + ).allow(null), + peerDiscovery: Joi.array().items( + Joi.alternatives().try( + Joi.func(), + Joi.object() + ) + ).allow(null), + dht: Joi.alternatives().try( + Joi.func(), + Joi.object() + ).allow(null) + }).required(), + config: Joi.object().keys({ + peerDiscovery: Joi.object().allow(null), + relay: Joi.object().keys({ + enabled: Joi.boolean().default(false), + hop: Joi.object().keys({ + enabled: Joi.boolean().default(false), + active: Joi.boolean().default(false) + }) + }).default(), + dht: Joi.object().keys({ + kBucketSize: Joi.number().allow(null) + }), + EXPERIMENTAL: Joi.object().keys({ + dht: Joi.boolean().default(false), + pubsub: Joi.boolean().default(false) + }).default() + }).default() +}) + +module.exports.validate = (options) => { + let newSchema = schema + // Throw an intial error early for required props + let config = Joi.attempt(options, newSchema) + + // Ensure discoveries are properly configured + if (config.modules.peerDiscovery) { + config.modules.peerDiscovery.forEach((discovery) => { + // If it's a function, validate we have configs for it + if (typeof discovery === 'function') { + Joi.reach(schema, 'config.peerDiscovery').keys({ + [discovery.tag]: Joi.object().required() + }) + } + }) + } + + // Ensure dht is correct + if (config.config.EXPERIMENTAL && config.config.EXPERIMENTAL.dht) { + newSchema = newSchema.requiredKeys('modules.dht') + } + + // Finish validation and return the updated config + return Joi.attempt(config, newSchema) +} diff --git a/src/index.js b/src/index.js index bbc2342b81..0a5c1f1475 100644 --- a/src/index.js +++ b/src/index.js @@ -3,9 +3,9 @@ const EventEmitter = require('events').EventEmitter const assert = require('assert') -const setImmediate = require('async/setImmediate') const each = require('async/each') const series = require('async/series') +const parallel = require('async/parallel') const PeerBook = require('peer-book') const Switch = require('libp2p-switch') @@ -18,88 +18,88 @@ const contentRouting = require('./content-routing') const dht = require('./dht') const pubsub = require('./pubsub') const getPeerInfo = require('./get-peer-info') +const validateConfig = require('./config').validate exports = module.exports const NOT_STARTED_ERROR_MESSAGE = 'The libp2p node is not started yet' class Node extends EventEmitter { - constructor (_modules, _peerInfo, _peerBook, _options) { + constructor (_options) { super() - assert(_modules, 'requires modules to equip libp2p with features') - assert(_peerInfo, 'requires a PeerInfo instance') + // validateConfig will ensure the config is correct, + // and add default values where appropriate + _options = validateConfig(_options) - this.modules = _modules - this.peerInfo = _peerInfo - this.peerBook = _peerBook || new PeerBook() - _options = _options || {} + this.peerInfo = _options.peerInfo + this.peerBook = _options.peerBook || new PeerBook() + this._modules = _options.modules + this._config = _options.config this._isStarted = false + this._transport = [] // Transport instances/references + this._discovery = [] // Discovery service instances/references - this.switch = new Switch(this.peerInfo, this.peerBook, _options.switch) - this.stats = this.switch.stats + this._switch = new Switch(this.peerInfo, this.peerBook, _options.switch) + this.stats = this._switch.stats this.connectionManager = new ConnectionManager(this, _options.connectionManager) // Attach stream multiplexers - if (this.modules.connection && this.modules.connection.muxer) { - let muxers = this.modules.connection.muxer - muxers = Array.isArray(muxers) ? muxers : [muxers] - muxers.forEach((muxer) => this.switch.connection.addStreamMuxer(muxer)) + if (this._modules.streamMuxer) { + let muxers = this._modules.streamMuxer + muxers.forEach((muxer) => this._switch.connection.addStreamMuxer(muxer)) - // If muxer exists, we can use Identify - this.switch.connection.reuse() + // If muxer exists + // we can use Identify + this._switch.connection.reuse() + // we can use Relay for listening/dialing + this._switch.connection.enableCircuitRelay(this._config.relay) - // If muxer exists, we can use Relay for listening/dialing - this.switch.connection.enableCircuitRelay(_options.relay) - - // Received incommind dial and muxer upgrade happened, + // Received incomming dial and muxer upgrade happened, // reuse this muxed connection - this.switch.on('peer-mux-established', (peerInfo) => { + this._switch.on('peer-mux-established', (peerInfo) => { this.emit('peer:connect', peerInfo) this.peerBook.put(peerInfo) }) - this.switch.on('peer-mux-closed', (peerInfo) => { + this._switch.on('peer-mux-closed', (peerInfo) => { this.emit('peer:disconnect', peerInfo) }) } // Attach crypto channels - if (this.modules.connection && this.modules.connection.crypto) { - let cryptos = this.modules.connection.crypto - cryptos = Array.isArray(cryptos) ? cryptos : [cryptos] + if (this._modules.connEncryption) { + let cryptos = this._modules.connEncryption cryptos.forEach((crypto) => { - this.switch.connection.crypto(crypto.tag, crypto.encrypt) + this._switch.connection.crypto(crypto.tag, crypto.encrypt) }) } - // Attach discovery mechanisms - if (this.modules.discovery) { - let discoveries = this.modules.discovery - discoveries = Array.isArray(discoveries) ? discoveries : [discoveries] - - discoveries.forEach((discovery) => { - discovery.on('peer', (peerInfo) => this.emit('peer:discovery', peerInfo)) + // dht provided components (peerRouting, contentRouting, dht) + if (this._config.EXPERIMENTAL.dht) { + const DHT = this._modules.dht + this._dht = new DHT(this._switch, { + kBucketSize: this._config.dht.kBucketSize || 20, + // TODO make datastore an option of libp2p itself so + // that other things can use it as well + datastore: dht.datastore }) } - // dht provided components (peerRouting, contentRouting, dht) - if (_modules.DHT) { - this._dht = new this.modules.DHT(this.switch, { - kBucketSize: 20, - datastore: _options.DHT && _options.DHT.datastore - }) + // enable/disable pubsub + if (this._config.EXPERIMENTAL && this._config.EXPERIMENTAL.pubsub) { + this.pubsub = pubsub(this) } + // Attach remaining APIs this.peerRouting = peerRouting(this) this.contentRouting = contentRouting(this) this.dht = dht(this) - this.pubsub = pubsub(this) this._getPeerInfo = getPeerInfo(this) // Mount default protocols - Ping.mount(this.switch) + Ping.mount(this._switch) } /* @@ -107,14 +107,11 @@ class Node extends EventEmitter { * - create listeners on the multiaddrs the Peer wants to listen */ start (callback) { - if (!this.modules.transport) { + if (!this._modules.transport) { return callback(new Error('no transports were present')) } let ws - let transports = this.modules.transport - - transports = Array.isArray(transports) ? transports : [transports] // so that we can have webrtc-star addrs without adding manually the id const maOld = [] @@ -128,30 +125,58 @@ class Node extends EventEmitter { this.peerInfo.multiaddrs.replace(maOld, maNew) const multiaddrs = this.peerInfo.multiaddrs.toArray() - transports.forEach((transport) => { - if (transport.filter(multiaddrs).length > 0) { - this.switch.transport.add( - transport.tag || transport.constructor.name, transport) - } else if (WebSockets.isWebSockets(transport)) { - // TODO find a cleaner way to signal that a transport is always - // used for dialing, even if no listener - ws = transport + + this._modules.transport.forEach((Transport) => { + let t + + if (typeof Transport === 'function') { + t = new Transport() + } else { + t = Transport + } + + if (t.filter(multiaddrs).length > 0) { + this._switch.transport.add(t.tag || t.constructor.name, t) + } else if (WebSockets.isWebSockets(t)) { + // TODO find a cleaner way to signal that a transport is always used + // for dialing, even if no listener + ws = t } + this._transport.push(t) }) series([ - (cb) => this.switch.start(cb), + (cb) => this._switch.start(cb), (cb) => { if (ws) { // always add dialing on websockets - this.switch.transport.add(ws.tag || ws.constructor.name, ws) + this._switch.transport.add(ws.tag || ws.constructor.name, ws) } // all transports need to be setup before discover starts - if (this.modules.discovery) { - return each(this.modules.discovery, (d, cb) => d.start(cb), cb) + if (this._modules.peerDiscovery && this._config.peerDiscovery) { + each(this._modules.peerDiscovery, (D, _cb) => { + // If enabled then start it + if (this._config.peerDiscovery[D.tag].enabled) { + let d + + if (typeof D === 'function') { + this._config.peerDiscovery[D.tag].peerInfo = this.peerInfo + d = new D(this._config.peerDiscovery[D.tag]) + } else { + d = D + } + + d.on('peer', (peerInfo) => this.emit('peer:discovery', peerInfo)) + this._discovery.push(d) + d.start(_cb) + } else { + _cb() + } + }, cb) + } else { + cb() } - cb() }, (cb) => { // TODO: chicken-and-egg problem #1: @@ -166,7 +191,7 @@ class Node extends EventEmitter { (cb) => { // TODO: chicken-and-egg problem #2: // have to set started here because FloodSub requires libp2p is already started - if (this._options !== false) { + if (this._floodSub) { this._floodSub.start(cb) } else { cb() @@ -177,13 +202,11 @@ class Node extends EventEmitter { // detect which multiaddrs we don't have a transport for and remove them const multiaddrs = this.peerInfo.multiaddrs.toArray() - transports.forEach((transport) => { - multiaddrs.forEach((multiaddr) => { - if (!multiaddr.toString().match(/\/p2p-circuit($|\/)/) && - !transports.find((transport) => transport.filter(multiaddr).length > 0)) { - this.peerInfo.multiaddrs.delete(multiaddr) - } - }) + multiaddrs.forEach((multiaddr) => { + if (!multiaddr.toString().match(/\/p2p-circuit($|\/)/) && + !this._transport.find((transport) => transport.filter(multiaddr).length > 0)) { + this.peerInfo.multiaddrs.delete(multiaddr) + } }) cb() }, @@ -198,17 +221,24 @@ class Node extends EventEmitter { * Stop the libp2p node by closing its listeners and open connections */ stop (callback) { - if (this.modules.discovery) { - this.modules.discovery.forEach((discovery) => { - setImmediate(() => discovery.stop(() => {})) - }) - } - series([ (cb) => { - if (this._floodSub.started) { - this._floodSub.stop(cb) + if (this._modules.peerDiscovery) { + // stop all discoveries before continuing with shutdown + return parallel( + this._discovery.map((d) => { + return (_cb) => d.stop(() => { _cb() }) + }), + cb + ) } + cb() + }, + (cb) => { + if (this._floodSub) { + return this._floodSub.stop(cb) + } + cb() }, (cb) => { if (this._dht) { @@ -216,7 +246,7 @@ class Node extends EventEmitter { } cb() }, - (cb) => this.switch.stop(cb), + (cb) => this._switch.stop(cb), (cb) => { this.emit('stop') cb() @@ -237,7 +267,7 @@ class Node extends EventEmitter { this._getPeerInfo(peer, (err, peerInfo) => { if (err) { return callback(err) } - this.switch.dial(peerInfo, (err) => { + this._switch.dial(peerInfo, (err) => { if (err) { return callback(err) } this.peerBook.put(peerInfo) @@ -257,7 +287,7 @@ class Node extends EventEmitter { this._getPeerInfo(peer, (err, peerInfo) => { if (err) { return callback(err) } - this.switch.dial(peerInfo, protocol, (err, conn) => { + this._switch.dial(peerInfo, protocol, (err, conn) => { if (err) { return callback(err) } this.peerBook.put(peerInfo) callback(null, conn) @@ -271,25 +301,28 @@ class Node extends EventEmitter { this._getPeerInfo(peer, (err, peerInfo) => { if (err) { return callback(err) } - this.switch.hangUp(peerInfo, callback) + this._switch.hangUp(peerInfo, callback) }) } ping (peer, callback) { - assert(this.isStarted(), NOT_STARTED_ERROR_MESSAGE) + if (!this.isStarted()) { + return callback(new Error(NOT_STARTED_ERROR_MESSAGE)) + } + this._getPeerInfo(peer, (err, peerInfo) => { if (err) { return callback(err) } - callback(null, new Ping(this.switch, peerInfo)) + callback(null, new Ping(this._switch, peerInfo)) }) } handle (protocol, handlerFunc, matchFunc) { - this.switch.handle(protocol, handlerFunc, matchFunc) + this._switch.handle(protocol, handlerFunc, matchFunc) } unhandle (protocol) { - this.switch.unhandle(protocol) + this._switch.unhandle(protocol) } } diff --git a/test/base.js b/test/base.js deleted file mode 100644 index 91a3af0922..0000000000 --- a/test/base.js +++ /dev/null @@ -1,14 +0,0 @@ -/* eslint-env mocha */ -'use strict' - -const chai = require('chai') -chai.use(require('dirty-chai')) -const expect = chai.expect - -const libp2p = require('../src') - -describe('libp2p', () => { - it('the skeleton is fine, now go build your own libp2p bundle', () => { - expect(libp2p).to.exist() - }) -}) diff --git a/test/browser.js b/test/browser.js index 41357c9e57..3b05294fc5 100644 --- a/test/browser.js +++ b/test/browser.js @@ -1,4 +1,3 @@ 'use strict' -require('./base') require('./transports.browser') diff --git a/test/circuit-relay.node.js b/test/circuit-relay.node.js index 9fa45d6480..2c80636a23 100644 --- a/test/circuit-relay.node.js +++ b/test/circuit-relay.node.js @@ -1,20 +1,21 @@ /* eslint-env mocha */ 'use strict' +const chai = require('chai') +chai.use(require('dirty-chai')) +const expect = chai.expect +const sinon = require('sinon') const waterfall = require('async/waterfall') const series = require('async/series') const parallel = require('async/parallel') -const utils = require('./utils/node') const Circuit = require('libp2p-circuit') const multiaddr = require('multiaddr') -const tryEcho = require('./utils/try-echo') -const chai = require('chai') -chai.use(require('dirty-chai')) -const expect = chai.expect -const sinon = require('sinon') +const createNode = require('./utils/create-node') +const tryEcho = require('./utils/try-echo') +const echo = require('./utils/echo') -describe('circuit relay', function () { +describe('circuit relay', () => { let handlerSpies = [] let relayNode1 let relayNode2 @@ -23,29 +24,32 @@ describe('circuit relay', function () { let nodeTCP1 let nodeTCP2 - function setupNode (addrs, options, cb) { + function setupNode (addrs, options, callback) { if (typeof options === 'function') { - cb = options + callback = options options = {} } options = options || {} - return utils.createNode(addrs, options, (err, node) => { + return createNode(addrs, options, (err, node) => { expect(err).to.not.exist() - node.handle('/echo/1.0.0', utils.echo) + node.handle('/echo/1.0.0', echo) node.start((err) => { expect(err).to.not.exist() - handlerSpies.push(sinon.spy(node.switch.transports[Circuit.tag].listeners[0].hopHandler, 'handle')) - cb(node) + handlerSpies.push(sinon.spy( + node._switch.transports[Circuit.tag].listeners[0].hopHandler, 'handle' + )) + + callback(node) }) }) } before(function (done) { - this.timeout(20000) + this.timeout(20 * 1000) waterfall([ // set up passive relay @@ -53,11 +57,13 @@ describe('circuit relay', function () { '/ip4/0.0.0.0/tcp/0/ws', '/ip4/0.0.0.0/tcp/0' ], { - relay: { - enabled: true, - hop: { + config: { + relay: { enabled: true, - active: false // passive relay + hop: { + enabled: true, + active: false // passive relay + } } } }, (node) => { @@ -69,11 +75,13 @@ describe('circuit relay', function () { '/ip4/0.0.0.0/tcp/0/ws', '/ip4/0.0.0.0/tcp/0' ], { - relay: { - enabled: true, - hop: { + config: { + relay: { enabled: true, - active: false // passive relay + hop: { + enabled: true, + active: false // passive relay + } } } }, (node) => { @@ -84,8 +92,10 @@ describe('circuit relay', function () { (cb) => setupNode([ '/ip4/0.0.0.0/tcp/0/ws' ], { - relay: { - enabled: true + config: { + relay: { + enabled: true + } } }, (node) => { nodeWS1 = node @@ -95,8 +105,10 @@ describe('circuit relay', function () { (cb) => setupNode([ '/ip4/0.0.0.0/tcp/0/ws' ], { - relay: { - enabled: true + config: { + relay: { + enabled: true + } } }, (node) => { nodeWS2 = node @@ -107,8 +119,10 @@ describe('circuit relay', function () { '/ip4/0.0.0.0/tcp/0', `/ipfs/${relayNode1.peerInfo.id.toB58String()}/p2p-circuit` ], { - relay: { - enabled: true + config: { + relay: { + enabled: true + } } }, (node) => { nodeTCP1 = node @@ -119,8 +133,10 @@ describe('circuit relay', function () { '/ip4/0.0.0.0/tcp/0', `/ip4/0.0.0.0/tcp/0/ipfs/${relayNode2.peerInfo.id.toB58String()}/p2p-circuit` ], { - relay: { - enabled: true + config: { + relay: { + enabled: true + } } }, (node) => { nodeTCP2 = node diff --git a/test/config.spec.js b/test/config.spec.js new file mode 100644 index 0000000000..9f64afd7fe --- /dev/null +++ b/test/config.spec.js @@ -0,0 +1,133 @@ +/* eslint-env mocha */ +'use strict' + +const chai = require('chai') +chai.use(require('dirty-chai')) +const expect = chai.expect +const PeerInfo = require('peer-info') +const PeerId = require('peer-id') +const waterfall = require('async/waterfall') +const WS = require('libp2p-websockets') +const Bootstrap = require('libp2p-railing') + +const validateConfig = require('../src/config').validate + +describe('configuration', () => { + let peerInfo + + before((done) => { + waterfall([ + (cb) => PeerId.create({ bits: 512 }, cb), + (peerId, cb) => PeerInfo.create(peerId, cb), + (info, cb) => { + peerInfo = info + cb() + } + ], () => done()) + }) + + it('should throw an error if peerInfo is missing', () => { + expect(() => { + validateConfig({ + modules: { + transport: [ WS ] + } + }) + }).to.throw() + }) + + it('should throw an error if modules is missing', () => { + expect(() => { + validateConfig({ + peerInfo + }) + }).to.throw() + }) + + it('should throw an error if there are no transports', () => { + expect(() => { + validateConfig({ + peerInfo, + modules: { + transport: [ ] + } + }) + }).to.throw() + }) + + it('should add defaults to missing items', () => { + const options = { + peerInfo, + modules: { + transport: [ WS ], + peerDiscovery: [ Bootstrap ] + }, + config: { + peerDiscovery: { + bootstrap: { + interval: 1000, + enabled: true + } + } + } + } + + const expected = { + peerInfo, + modules: { + transport: [ WS ], + peerDiscovery: [ Bootstrap ] + }, + config: { + peerDiscovery: { + bootstrap: { + interval: 1000, + enabled: true + } + }, + EXPERIMENTAL: { + pubsub: false, + dht: false + }, + relay: { + enabled: false + } + } + } + + expect(validateConfig(options)).to.deep.equal(expected) + }) + + it('should not allow for dht to be enabled without it being provided', () => { + const options = { + peerInfo, + modules: { + transport: [ WS ] + }, + config: { + EXPERIMENTAL: { + dht: true + } + } + } + + expect(() => validateConfig(options)).to.throw() + }) + + it('should require a non instanced peerDiscovery module to have associated options', () => { + const options = { + peerInfo, + modules: { + transport: [ WS ], + peerDiscover: [ Bootstrap ] + }, + config: { + EXPERIMENTAL: { + dht: true + } + } + } + + expect(() => validateConfig(options)).to.throw() + }) +}) diff --git a/test/content-routing.node.js b/test/content-routing.node.js index 389dc0e59f..3414a6174c 100644 --- a/test/content-routing.node.js +++ b/test/content-routing.node.js @@ -9,8 +9,8 @@ const expect = chai.expect const parallel = require('async/parallel') const _times = require('lodash.times') const CID = require('cids') -const utils = require('./utils/node') -const createNode = utils.createNode + +const createNode = require('./utils/create-node') describe('.contentRouting', () => { let nodeA @@ -23,8 +23,11 @@ describe('.contentRouting', () => { this.timeout(5 * 1000) const tasks = _times(5, () => (cb) => { createNode('/ip4/0.0.0.0/tcp/0', { - mdns: false, - dht: true + config: { + EXPERIMENTAL: { + dht: true + } + } }, (err, node) => { expect(err).to.not.exist() node.start((err) => cb(err, node)) diff --git a/test/multiaddr-trim.js b/test/multiaddr-trim.node.js similarity index 73% rename from test/multiaddr-trim.js rename to test/multiaddr-trim.node.js index 9dc93715b2..bb8e4cd500 100644 --- a/test/multiaddr-trim.js +++ b/test/multiaddr-trim.node.js @@ -5,7 +5,8 @@ const chai = require('chai') chai.use(require('dirty-chai')) const expect = chai.expect const series = require('async/series') -const createNode = require('./utils/node').createNode + +const createNode = require('./utils/create-node') describe('multiaddr trim', () => { it('non used multiaddrs get trimmed', (done) => { @@ -20,7 +21,6 @@ describe('multiaddr trim', () => { expect(err).to.not.exist() node = _node const multiaddrs = node.peerInfo.multiaddrs.toArray() - // multiaddrs.forEach((ma) => console.log(ma.toString())) expect(multiaddrs).to.have.length(3) cb() }), @@ -29,11 +29,10 @@ describe('multiaddr trim', () => { expect(err).to.not.exist() const multiaddrs = node.peerInfo.multiaddrs.toArray() - // console.log('--') - // multiaddrs.forEach((ma) => console.log(ma.toString())) expect(multiaddrs.length).to.at.least(2) - expect(multiaddrs[0].toString()).to.match(/^\/ip4\/127\.0\.0\.1\/tcp\/[0-9]+\/ws\/ipfs\/\w+$/) + expect(multiaddrs[0].toString()) + .to.match(/^\/ip4\/127\.0\.0\.1\/tcp\/[0-9]+\/ws\/ipfs\/\w+$/) node.stop(done) }) }) diff --git a/test/node.js b/test/node.js index 84807201dc..095906a529 100644 --- a/test/node.js +++ b/test/node.js @@ -1,6 +1,5 @@ 'use strict' -require('./base') require('./transports.node') require('./stream-muxing.node') require('./peer-discovery.node') @@ -8,5 +7,5 @@ require('./pubsub.node') require('./peer-routing.node') require('./content-routing.node') require('./circuit-relay.node') -require('./multiaddr-trim') +require('./multiaddr-trim.node') require('./stats') diff --git a/test/peer-discovery.node.js b/test/peer-discovery.node.js index d82b4e4c95..f1eec24a9e 100644 --- a/test/peer-discovery.node.js +++ b/test/peer-discovery.node.js @@ -6,9 +6,9 @@ chai.use(require('dirty-chai')) const expect = chai.expect const signalling = require('libp2p-webrtc-star/src/sig-server') const parallel = require('async/parallel') -const utils = require('./utils/node') -const createNode = utils.createNode -const echo = utils.echo + +const createNode = require('./utils/create-node') +const echo = require('./utils/echo') describe('peer discovery', () => { let nodeA @@ -52,13 +52,21 @@ describe('peer discovery', () => { parallel([ (cb) => nodeA.stop(cb), (cb) => nodeB.stop(cb), - (cb) => ss.stop(done) + (cb) => ss.stop(cb) ], done) }) } describe('MulticastDNS', () => { - setup({ mdns: true }) + setup({ + config: { + peerDiscovery: { + mdns: { + enabled: true + } + } + } + }) it('find a peer', function (done) { this.timeout(15 * 1000) @@ -87,8 +95,16 @@ describe('peer discovery', () => { describe('MulticastDNS + WebRTCStar', () => { setup({ - webRTCStar: true, - mdns: true + config: { + peerDiscovery: { + mdns: { + enabled: true + }, + webRTCStar: { + enabled: true + } + } + } }) it('find a peer', function (done) { diff --git a/test/peer-routing.node.js b/test/peer-routing.node.js index ec34eb7f24..b232e423ca 100644 --- a/test/peer-routing.node.js +++ b/test/peer-routing.node.js @@ -8,8 +8,8 @@ chai.use(require('dirty-chai')) const expect = chai.expect const parallel = require('async/parallel') const _times = require('lodash.times') -const utils = require('./utils/node') -const createNode = utils.createNode + +const createNode = require('./utils/create-node') describe('.peerRouting', () => { let nodeA @@ -23,8 +23,11 @@ describe('.peerRouting', () => { const tasks = _times(5, () => (cb) => { createNode('/ip4/0.0.0.0/tcp/0', { - mdns: false, - dht: true + config: { + EXPERIMENTAL: { + dht: true + } + } }, (err, node) => { expect(err).to.not.exist() node.start((err) => cb(err, node)) diff --git a/test/pubsub.node.js b/test/pubsub.node.js index 310c675307..0aaa75c99e 100644 --- a/test/pubsub.node.js +++ b/test/pubsub.node.js @@ -9,13 +9,22 @@ const expect = chai.expect const parallel = require('async/parallel') const waterfall = require('async/waterfall') const _times = require('lodash.times') -const utils = require('./utils/node') -const createNode = utils.createNode + +const createNode = require('./utils/create-node') function startTwo (callback) { const tasks = _times(2, () => (cb) => { createNode('/ip4/0.0.0.0/tcp/0', { - mdns: false + config: { + peerDiscovery: { + mdns: { + enabled: false + } + }, + EXPERIMENTAL: { + pubsub: true + } + } }, (err, node) => { expect(err).to.not.exist() node.start((err) => cb(err, node)) @@ -69,18 +78,20 @@ describe('.pubsub', () => { describe('.pubsub off', () => { it('fail to use pubsub if disabled', (done) => { createNode('/ip4/0.0.0.0/tcp/0', { - mdns: false, - pubsub: false + config: { + peerDiscovery: { + mdns: { + enabled: false + } + }, + EXPERIMENTAL: { + pubsub: false + } + } }, (err, node) => { expect(err).to.not.exist() - - node.pubsub.subscribe('news', - (msg) => {}, - (err) => { - expect(err).to.exist() - done() - } - ) + expect(node.pubsub).to.not.exist() + done() }) }) }) diff --git a/test/stats.js b/test/stats.js index 1ac1afa5b5..ac3628ce14 100644 --- a/test/stats.js +++ b/test/stats.js @@ -5,13 +5,21 @@ const chai = require('chai') chai.use(require('dirty-chai')) const expect = chai.expect -const createNode = require('./utils/node').createNode +const createNode = require('./utils/create-node') -describe('libp2p', (done) => { - it('has stats', () => { +describe('libp2p', () => { + it('has stats', (done) => { createNode('/ip4/127.0.0.1/tcp/0', { - mdns: false, - dht: true + config: { + peerDiscovery: { + mdns: { + enabled: false + } + }, + EXPERIMENTAL: { + dht: true + } + } }, (err, node) => { expect(err).to.not.exist() node.start((err) => { diff --git a/test/stream-muxing.node.js b/test/stream-muxing.node.js index c887aa71a1..bb7fe02170 100644 --- a/test/stream-muxing.node.js +++ b/test/stream-muxing.node.js @@ -6,10 +6,11 @@ chai.use(require('dirty-chai')) const expect = chai.expect const parallel = require('async/parallel') const series = require('async/series') -const utils = require('./utils/node') +const Mplex = require('libp2p-mplex') +const SPDY = require('libp2p-spdy') +const createNode = require('./utils/create-node') const tryEcho = require('./utils/try-echo') -const createNode = utils.createNode -const echo = utils.echo +const echo = require('./utils/echo') function test (nodeA, nodeB, callback) { nodeA.dialProtocol(nodeB.peerInfo, '/echo/1.0.0', (err, conn) => { @@ -35,7 +36,9 @@ describe('stream muxing', () => { function setup (callback) { parallel([ (cb) => createNode('/ip4/0.0.0.0/tcp/0', { - muxer: ['spdy'] + modules: { + streamMuxer: [ SPDY ] + } }, (err, node) => { expect(err).to.not.exist() nodeA = node @@ -43,7 +46,9 @@ describe('stream muxing', () => { node.start(cb) }), (cb) => createNode('/ip4/0.0.0.0/tcp/0', { - muxer: ['spdy'] + modules: { + streamMuxer: [ SPDY ] + } }, (err, node) => { expect(err).to.not.exist() nodeB = node @@ -67,7 +72,9 @@ describe('stream muxing', () => { function setup (callback) { parallel([ (cb) => createNode('/ip4/0.0.0.0/tcp/0', { - muxer: ['mplex'] + modules: { + streamMuxer: [ Mplex ] + } }, (err, node) => { expect(err).to.not.exist() nodeA = node @@ -75,7 +82,9 @@ describe('stream muxing', () => { node.start(cb) }), (cb) => createNode('/ip4/0.0.0.0/tcp/0', { - muxer: ['mplex'] + modules: { + streamMuxer: [ Mplex ] + } }, (err, node) => { expect(err).to.not.exist() nodeB = node @@ -101,7 +110,9 @@ describe('stream muxing', () => { function setup (callback) { parallel([ (cb) => createNode('/ip4/0.0.0.0/tcp/0', { - muxer: ['spdy', 'mplex'] + modules: { + streamMuxer: [ Mplex ] + } }, (err, node) => { expect(err).to.not.exist() nodeA = node @@ -109,7 +120,9 @@ describe('stream muxing', () => { node.start(cb) }), (cb) => createNode('/ip4/0.0.0.0/tcp/0', { - muxer: ['spdy', 'mplex'] + modules: { + streamMuxer: [ SPDY, Mplex ] + } }, (err, node) => { expect(err).to.not.exist() nodeB = node @@ -135,7 +148,9 @@ describe('stream muxing', () => { function setup (callback) { parallel([ (cb) => createNode('/ip4/0.0.0.0/tcp/0', { - muxer: ['spdy', 'mplex'] + modules: { + streamMuxer: [ SPDY, Mplex ] + } }, (err, node) => { expect(err).to.not.exist() nodeA = node @@ -143,7 +158,9 @@ describe('stream muxing', () => { node.start(cb) }), (cb) => createNode('/ip4/0.0.0.0/tcp/0', { - muxer: ['mplex', 'spdy'] + modules: { + streamMuxer: [ Mplex, SPDY ] + } }, (err, node) => { expect(err).to.not.exist() nodeB = node @@ -169,7 +186,9 @@ describe('stream muxing', () => { function setup (callback) { parallel([ (cb) => createNode('/ip4/0.0.0.0/tcp/0', { - muxer: ['spdy'] + modules: { + streamMuxer: [ SPDY ] + } }, (err, node) => { expect(err).to.not.exist() nodeA = node @@ -177,7 +196,9 @@ describe('stream muxing', () => { node.start(cb) }), (cb) => createNode('/ip4/0.0.0.0/tcp/0', { - muxer: ['mplex'] + modules: { + streamMuxer: [ Mplex ] + } }, (err, node) => { expect(err).to.not.exist() nodeB = node @@ -191,12 +212,12 @@ describe('stream muxing', () => { (cb) => setup(cb), (cb) => { // it will just 'warm up a conn' - expect(Object.keys(nodeA.switch.muxers)).to.have.length(1) - expect(Object.keys(nodeB.switch.muxers)).to.have.length(1) + expect(Object.keys(nodeA._switch.muxers)).to.have.length(1) + expect(Object.keys(nodeB._switch.muxers)).to.have.length(1) nodeA.dial(nodeB.peerInfo, (err) => { expect(err).to.not.exist() - expect(Object.keys(nodeA.switch.muxedConns)).to.have.length(0) + expect(Object.keys(nodeA._switch.muxedConns)).to.have.length(0) cb() }) }, diff --git a/test/transports.browser.js b/test/transports.browser.js index 50f7b60c63..bf8db2b721 100644 --- a/test/transports.browser.js +++ b/test/transports.browser.js @@ -7,6 +7,7 @@ chai.use(require('dirty-chai')) const expect = chai.expect const PeerInfo = require('peer-info') const PeerId = require('peer-id') +const Mplex = require('libp2p-mplex') const pull = require('pull-stream') const parallel = require('async/parallel') const goodbye = require('pull-goodbye') @@ -14,46 +15,49 @@ const serializer = require('pull-serializer') const w = require('webrtcsupport') const tryEcho = require('./utils/try-echo') -const Node = require('./utils/bundle.browser') -const rawPeer = require('./fixtures/test-peer.json') +const Node = require('./utils/bundle-browser') +const jsonPeerId = require('./fixtures/test-peer.json') describe('transports', () => { describe('websockets', () => { let peerB + let peerBMultiaddr = '/ip4/127.0.0.1/tcp/9200/ws/ipfs/' + jsonPeerId.id let nodeA before((done) => { - const ma = '/ip4/127.0.0.1/tcp/9200/ws/ipfs/' + rawPeer.id - - PeerId.createFromPrivKey(rawPeer.privKey, (err, id) => { - if (err) { - return done(err) - } + PeerId.createFromPrivKey(jsonPeerId.privKey, (err, id) => { + expect(err).to.not.exist() peerB = new PeerInfo(id) - peerB.multiaddrs.add(ma) + peerB.multiaddrs.add(peerBMultiaddr) done() }) }) after((done) => nodeA.stop(done)) - it('create libp2pNode', (done) => { + it('create a libp2p Node', (done) => { PeerInfo.create((err, peerInfo) => { expect(err).to.not.exist() - peerInfo.multiaddrs.add('/ip4/0.0.0.0/tcp/0') - nodeA = new Node(peerInfo) + nodeA = new Node({ + peerInfo: peerInfo + }) done() }) }) - it('create libp2pNode with mplex only', (done) => { + it('create a libp2p Node with mplex only', (done) => { PeerInfo.create((err, peerInfo) => { expect(err).to.not.exist() - const b = new Node(peerInfo, null, { muxer: ['mplex'] }) - expect(b.modules.connection.muxer).to.eql([require('libp2p-mplex')]) + const b = new Node({ + peerInfo: peerInfo, + modules: { + streamMuxer: [ Mplex ] + } + }) + expect(b._modules.streamMuxer).to.eql([require('libp2p-mplex')]) done() }) }) @@ -65,7 +69,7 @@ describe('transports', () => { // General connectivity tests it('.dial using Multiaddr', (done) => { - nodeA.dial(peerB.multiaddrs.toArray()[0], (err) => { + nodeA.dial(peerBMultiaddr, (err) => { expect(err).to.not.exist() setTimeout(check, 500) // Some time for Identify to finish @@ -79,7 +83,7 @@ describe('transports', () => { }) it('.dialProtocol using Multiaddr', (done) => { - nodeA.dialProtocol(peerB.multiaddrs.toArray()[0], '/echo/1.0.0', (err, conn) => { + nodeA.dialProtocol(peerBMultiaddr, '/echo/1.0.0', (err, conn) => { expect(err).to.not.exist() const peers = nodeA.peerBook.getAll() @@ -90,7 +94,7 @@ describe('transports', () => { }) it('.hangUp using Multiaddr', (done) => { - nodeA.hangUp(peerB.multiaddrs.toArray()[0], (err) => { + nodeA.hangUp(peerBMultiaddr, (err) => { expect(err).to.not.exist() setTimeout(check, 500) @@ -98,7 +102,7 @@ describe('transports', () => { function check () { const peers = nodeA.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeA.switch.muxedConns)).to.have.length(0) + expect(Object.keys(nodeA._switch.muxedConns)).to.have.length(0) done() } }) @@ -138,7 +142,7 @@ describe('transports', () => { const peers = nodeA.peerBook.getAll() expect(err).to.not.exist() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeA.switch.muxedConns)).to.have.length(0) + expect(Object.keys(nodeA._switch.muxedConns)).to.have.length(0) done() } }) @@ -197,8 +201,8 @@ describe('transports', () => { it('create two peerInfo with webrtc-star addrs', (done) => { parallel([ - (cb) => PeerId.create({ bits: 1024 }, cb), - (cb) => PeerId.create({ bits: 1024 }, cb) + (cb) => PeerId.create({ bits: 512 }, cb), + (cb) => PeerId.create({ bits: 512 }, cb) ], (err, ids) => { expect(err).to.not.exist() @@ -215,8 +219,12 @@ describe('transports', () => { }) it('create two libp2p nodes with those peers', (done) => { - node1 = new Node(peer1, null, { webRTCStar: true }) - node2 = new Node(peer2, null, { webRTCStar: true }) + node1 = new Node({ + peerInfo: peer1 + }) + node2 = new Node({ + peerInfo: peer2 + }) done() }) @@ -256,24 +264,26 @@ describe('transports', () => { function check () { const peers = node1.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(node1.switch.muxedConns)).to.have.length(0) + expect(Object.keys(node1._switch.muxedConns)).to.have.length(0) done() } }) }) - it('create a third node and check that discovery works', (done) => { + it('create a third node and check that discovery works', function (done) { + this.timeout(60 * 1000) + let counter = 0 function check () { if (++counter === 3) { - expect(Object.keys(node1.switch.muxedConns).length).to.equal(1) - expect(Object.keys(node2.switch.muxedConns).length).to.equal(1) + expect(Object.keys(node1._switch.muxedConns).length).to.equal(1) + expect(Object.keys(node2._switch.muxedConns).length).to.equal(1) done() } } - PeerId.create((err, id3) => { + PeerId.create({ bits: 512 }, (err, id3) => { expect(err).to.not.exist() const peer3 = new PeerInfo(id3) @@ -283,7 +293,9 @@ describe('transports', () => { node1.on('peer:discovery', (peerInfo) => node1.dial(peerInfo, check)) node2.on('peer:discovery', (peerInfo) => node2.dial(peerInfo, check)) - const node3 = new Node(peer3, null, { webRTCStar: true }) + const node3 = new Node({ + peerInfo: peer3 + }) node3.start(check) }) }) @@ -297,8 +309,8 @@ describe('transports', () => { it('create two peerInfo with websocket-star addrs', (done) => { parallel([ - (cb) => PeerId.create({ bits: 1024 }, cb), - (cb) => PeerId.create({ bits: 1024 }, cb) + (cb) => PeerId.create({ bits: 512 }, cb), + (cb) => PeerId.create({ bits: 512 }, cb) ], (err, ids) => { expect(err).to.not.exist() @@ -315,8 +327,12 @@ describe('transports', () => { }) it('create two libp2p nodes with those peers', (done) => { - node1 = new Node(peer1, null, { wsStar: true }) - node2 = new Node(peer2, null, { wsStar: true }) + node1 = new Node({ + peerInfo: peer1 + }) + node2 = new Node({ + peerInfo: peer2 + }) done() }) @@ -356,19 +372,21 @@ describe('transports', () => { function check () { const peers = node1.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(node1.switch.muxedConns)).to.have.length(0) + expect(Object.keys(node1._switch.muxedConns)).to.have.length(0) done() } }) }) - it('create a third node and check that discovery works', (done) => { + it('create a third node and check that discovery works', function (done) { + this.timeout(10 * 1000) + let counter = 0 function check () { if (++counter === 3) { - expect(Object.keys(node1.switch.muxedConns).length).to.equal(1) - expect(Object.keys(node2.switch.muxedConns).length).to.equal(1) + expect(Object.keys(node1._switch.muxedConns).length).to.equal(1) + expect(Object.keys(node2._switch.muxedConns).length).to.equal(1) done() } } @@ -383,7 +401,9 @@ describe('transports', () => { node1.on('peer:discovery', (peerInfo) => node1.dial(peerInfo, check)) node2.on('peer:discovery', (peerInfo) => node2.dial(peerInfo, check)) - const node3 = new Node(peer3, null, { wsStar: true }) + const node3 = new Node({ + peerInfo: peer3 + }) node3.start(check) }) }) diff --git a/test/transports.node.js b/test/transports.node.js index ca17810ccb..ac71c979df 100644 --- a/test/transports.node.js +++ b/test/transports.node.js @@ -6,16 +6,17 @@ chai.use(require('dirty-chai')) const expect = chai.expect const parallel = require('async/parallel') const series = require('async/series') -const utils = require('./utils/node.js') const signalling = require('libp2p-webrtc-star/src/sig-server') const rendezvous = require('libp2p-websocket-star-rendezvous') +const TCP = require('libp2p-tcp') +const WS = require('libp2p-websockets') const WSStar = require('libp2p-websocket-star') const WRTCStar = require('libp2p-webrtc-star') const wrtc = require('wrtc') -const tryEcho = require('./utils/try-echo') -const createNode = utils.createNode -const echo = utils.echo +const createNode = require('./utils/create-node.js') +const tryEcho = require('./utils/try-echo') +const echo = require('./utils/echo') describe('transports', () => { describe('TCP only', () => { @@ -90,14 +91,14 @@ describe('transports', () => { (cb) => { const peers = nodeA.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeA.switch.muxedConns)).to.have.length(0) + expect(Object.keys(nodeA._switch.muxedConns)).to.have.length(0) cb() }, (cb) => { const peers = nodeB.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeB.switch.muxedConns)).to.have.length(0) + expect(Object.keys(nodeB._switch.muxedConns)).to.have.length(0) cb() } ], done) @@ -117,14 +118,14 @@ describe('transports', () => { const peers = nodeA.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeA.switch.muxedConns)).to.have.length(1) + expect(Object.keys(nodeA._switch.muxedConns)).to.have.length(1) cb() }, (cb) => { const peers = nodeB.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeA.switch.muxedConns)).to.have.length(1) + expect(Object.keys(nodeA._switch.muxedConns)).to.have.length(1) cb() } ], () => tryEcho(conn, done)) @@ -143,14 +144,14 @@ describe('transports', () => { const peers = nodeA.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeA.switch.muxedConns)).to.have.length(0) + expect(Object.keys(nodeA._switch.muxedConns)).to.have.length(0) cb() }, (cb) => { const peers = nodeB.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeB.switch.muxedConns)).to.have.length(0) + expect(Object.keys(nodeB._switch.muxedConns)).to.have.length(0) cb() } ], done) @@ -169,13 +170,13 @@ describe('transports', () => { (cb) => { const peers = nodeA.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeA.switch.muxedConns)).to.have.length(1) + expect(Object.keys(nodeA._switch.muxedConns)).to.have.length(1) cb() }, (cb) => { const peers = nodeB.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeA.switch.muxedConns)).to.have.length(1) + expect(Object.keys(nodeA._switch.muxedConns)).to.have.length(1) cb() } ], () => tryEcho(conn, done)) @@ -193,13 +194,13 @@ describe('transports', () => { (cb) => { const peers = nodeA.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeA.switch.muxedConns)).to.have.length(0) + expect(Object.keys(nodeA._switch.muxedConns)).to.have.length(0) cb() }, (cb) => { const peers = nodeB.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeB.switch.muxedConns)).to.have.length(0) + expect(Object.keys(nodeB._switch.muxedConns)).to.have.length(0) cb() } ], done) @@ -263,13 +264,13 @@ describe('transports', () => { (cb) => { const peers = nodeTCP.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeTCP.switch.muxedConns)).to.have.length(1) + expect(Object.keys(nodeTCP._switch.muxedConns)).to.have.length(1) cb() }, (cb) => { const peers = nodeTCPnWS.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeTCPnWS.switch.muxedConns)).to.have.length(1) + expect(Object.keys(nodeTCPnWS._switch.muxedConns)).to.have.length(1) cb() } ], done) @@ -287,14 +288,14 @@ describe('transports', () => { (cb) => { const peers = nodeTCP.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeTCP.switch.muxedConns)).to.have.length(0) + expect(Object.keys(nodeTCP._switch.muxedConns)).to.have.length(0) cb() }, (cb) => { const peers = nodeTCPnWS.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeTCPnWS.switch.muxedConns)).to.have.length(0) + expect(Object.keys(nodeTCPnWS._switch.muxedConns)).to.have.length(0) cb() } ], done) @@ -314,13 +315,13 @@ describe('transports', () => { (cb) => { const peers = nodeTCPnWS.peerBook.getAll() expect(Object.keys(peers)).to.have.length(2) - expect(Object.keys(nodeTCPnWS.switch.muxedConns)).to.have.length(1) + expect(Object.keys(nodeTCPnWS._switch.muxedConns)).to.have.length(1) cb() }, (cb) => { const peers = nodeWS.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeWS.switch.muxedConns)).to.have.length(1) + expect(Object.keys(nodeWS._switch.muxedConns)).to.have.length(1) cb() } ], done) @@ -338,14 +339,14 @@ describe('transports', () => { (cb) => { const peers = nodeTCPnWS.peerBook.getAll() expect(Object.keys(peers)).to.have.length(2) - expect(Object.keys(nodeTCPnWS.switch.muxedConns)).to.have.length(0) + expect(Object.keys(nodeTCPnWS._switch.muxedConns)).to.have.length(0) cb() }, (cb) => { const peers = nodeWS.peerBook.getAll() expect(Object.keys(peers)).to.have.length(1) - expect(Object.keys(nodeWS.switch.muxedConns)).to.have.length(0) + expect(Object.keys(nodeWS._switch.muxedConns)).to.have.length(0) cb() } ], done) @@ -367,7 +368,7 @@ describe('transports', () => { let nodeAll let nodeTCP let nodeWS - let nodeWStar + let nodeWebRTCStar let ss @@ -375,23 +376,33 @@ describe('transports', () => { this.timeout(5 * 1000) parallel([ - (cb) => { - signalling.start({ port: 24642 }, (err, server) => { - expect(err).to.not.exist() - ss = server - cb() - }) - }, + (cb) => signalling.start({ port: 24642 }, (err, server) => { + expect(err).to.not.exist() + ss = server + cb() + }), (cb) => { const wstar = new WRTCStar({wrtc: wrtc}) + createNode([ '/ip4/0.0.0.0/tcp/0', '/ip4/127.0.0.1/tcp/25011/ws', '/ip4/127.0.0.1/tcp/24642/ws/p2p-webrtc-star' ], { modules: { - transport: [wstar], - discovery: [wstar.discovery] + transport: [ + TCP, + WS, + wstar + ], + peerDiscovery: [wstar.discovery] + }, + config: { + peerDiscovery: { + [wstar.discovery.tag]: { + enabled: true + } + } } }, (err, node) => { expect(err).to.not.exist() @@ -425,11 +436,18 @@ describe('transports', () => { ], { modules: { transport: [wstar], - discovery: [wstar.discovery] + peerDiscovery: [wstar.discovery] + }, + config: { + peerDiscovery: { + [wstar.discovery.tag]: { + enabled: true + } + } } }, (err, node) => { expect(err).to.not.exist() - nodeWStar = node + nodeWebRTCStar = node node.handle('/echo/1.0.0', echo) node.start(cb) }) @@ -444,7 +462,7 @@ describe('transports', () => { (cb) => nodeAll.stop(cb), (cb) => nodeTCP.stop(cb), (cb) => nodeWS.stop(cb), - (cb) => nodeWStar.stop(cb), + (cb) => nodeWebRTCStar.stop(cb), (cb) => ss.stop(cb) ], done) }) @@ -453,7 +471,7 @@ describe('transports', () => { let i = 1; [nodeAll, otherNode].forEach((node) => { expect(Object.keys(node.peerBook.getAll())).to.have.length(i-- ? peers : 1) - expect(Object.keys(node.switch.muxedConns)).to.have.length(muxed) + expect(Object.keys(node._switch.muxedConns)).to.have.length(muxed) }) callback() } @@ -490,20 +508,20 @@ describe('transports', () => { }) }) - it('nodeAll.dial nodeWStar using PeerInfo', function (done) { + it('nodeAll.dial nodeWebRTCStar using PeerInfo', function (done) { this.timeout(40 * 1000) - nodeAll.dial(nodeWStar.peerInfo, (err) => { + nodeAll.dial(nodeWebRTCStar.peerInfo, (err) => { expect(err).to.not.exist() // Some time for Identify to finish - setTimeout(() => check(nodeWStar, 1, 3, done), 500) + setTimeout(() => check(nodeWebRTCStar, 1, 3, done), 500) }) }) - it('nodeAll.hangUp nodeWStar using PeerInfo', (done) => { - nodeAll.hangUp(nodeWStar.peerInfo, (err) => { + it('nodeAll.hangUp nodeWebRTCStar using PeerInfo', (done) => { + nodeAll.hangUp(nodeWebRTCStar.peerInfo, (err) => { expect(err).to.not.exist() - setTimeout(() => check(nodeWStar, 0, 3, done), 500) + setTimeout(() => check(nodeWebRTCStar, 0, 3, done), 500) }) }) }) @@ -512,7 +530,7 @@ describe('transports', () => { let nodeAll let nodeTCP let nodeWS - let nodeWStar + let nodeWebSocketStar let ss @@ -527,14 +545,26 @@ describe('transports', () => { }, (cb) => { const wstar = new WSStar() + createNode([ '/ip4/0.0.0.0/tcp/0', '/ip4/127.0.0.1/tcp/25011/ws', '/ip4/127.0.0.1/tcp/24642/ws/p2p-websocket-star' ], { modules: { - transport: [wstar], - discovery: [wstar.discovery] + transport: [ + TCP, + WS, + wstar + ], + peerDiscovery: [wstar.discovery] + }, + config: { + peerDiscovery: { + [wstar.discovery.tag]: { + enabled: true + } + } } }, (err, node) => { expect(err).to.not.exist() @@ -569,11 +599,18 @@ describe('transports', () => { ], { modules: { transport: [wstar], - discovery: [wstar.discovery] + peerDiscovery: [wstar.discovery] + }, + config: { + peerDiscovery: { + [wstar.discovery.tag]: { + enabled: true + } + } } }, (err, node) => { expect(err).to.not.exist() - nodeWStar = node + nodeWebSocketStar = node wstar.lazySetId(node.peerInfo.id) node.handle('/echo/1.0.0', echo) node.start(cb) @@ -587,7 +624,7 @@ describe('transports', () => { (cb) => nodeAll.stop(cb), (cb) => nodeTCP.stop(cb), (cb) => nodeWS.stop(cb), - (cb) => nodeWStar.stop(cb), + (cb) => nodeWebSocketStar.stop(cb), (cb) => ss.stop(cb) ], done) }) @@ -596,7 +633,7 @@ describe('transports', () => { let i = 1; [nodeAll, otherNode].forEach((node) => { expect(Object.keys(node.peerBook.getAll())).to.have.length(i-- ? peers : 1) - expect(Object.keys(node.switch.muxedConns)).to.have.length(muxed) + expect(Object.keys(node._switch.muxedConns)).to.have.length(muxed) }) done() } @@ -633,19 +670,19 @@ describe('transports', () => { }) }) - it('nodeAll.dial nodeWStar using PeerInfo', (done) => { - nodeAll.dial(nodeWStar.peerInfo, (err) => { + it('nodeAll.dial nodeWebSocketStar using PeerInfo', (done) => { + nodeAll.dial(nodeWebSocketStar.peerInfo, (err) => { expect(err).to.not.exist() // Some time for Identify to finish - setTimeout(() => check(nodeWStar, 1, 3, done), 500) + setTimeout(() => check(nodeWebSocketStar, 1, 3, done), 500) }) }) - it('nodeAll.hangUp nodeWStar using PeerInfo', (done) => { - nodeAll.hangUp(nodeWStar.peerInfo, (err) => { + it('nodeAll.hangUp nodeWebSocketStar using PeerInfo', (done) => { + nodeAll.hangUp(nodeWebSocketStar.peerInfo, (err) => { expect(err).to.not.exist() // Some time for Identify to finish - setTimeout(() => check(nodeWStar, 0, 3, done), 500) + setTimeout(() => check(nodeWebSocketStar, 0, 3, done), 500) }) }) }) diff --git a/test/utils/bundle-browser.js b/test/utils/bundle-browser.js new file mode 100644 index 0000000000..d90334649d --- /dev/null +++ b/test/utils/bundle-browser.js @@ -0,0 +1,92 @@ +'use strict' + +const WS = require('libp2p-websockets') +const WebRTCStar = require('libp2p-webrtc-star') +const WebSocketStar = require('libp2p-websocket-star') +const Bootstrap = require('libp2p-railing') +const SPDY = require('libp2p-spdy') +const MPLEX = require('libp2p-mplex') +const KadDHT = require('libp2p-kad-dht') +const SECIO = require('libp2p-secio') +const defaultsDeep = require('@nodeutils/defaults-deep') +const libp2p = require('../..') + +function mapMuxers (list) { + return list.map((pref) => { + if (typeof pref !== 'string') { return pref } + switch (pref.trim().toLowerCase()) { + case 'spdy': return SPDY + case 'mplex': return MPLEX + default: + throw new Error(pref + ' muxer not available') + } + }) +} + +function getMuxers (options) { + if (options) { + return mapMuxers(options) + } else { + return [MPLEX, SPDY] + } +} + +class Node extends libp2p { + constructor (_options) { + _options = _options || {} + + const starOpts = { id: _options.peerInfo.id } + const wrtcStar = new WebRTCStar(starOpts) + const wsStar = new WebSocketStar(starOpts) + + const defaults = { + modules: { + transport: [ + wrtcStar, + wsStar, + new WS() + ], + streamMuxer: getMuxers(_options.muxer), + connEncryption: [ + SECIO + ], + peerDiscovery: [ + wrtcStar.discovery, + wsStar.discovery, + Bootstrap + ], + dht: KadDHT + }, + config: { + peerDiscovery: { + webRTCStar: { + enabled: true + }, + websocketStar: { + enabled: true + }, + bootstrap: { + interval: 10000, + enabled: false, + list: _options.boostrapList + } + }, + relay: { + enabled: false, + hop: { + enabled: false, + active: false + } + }, + EXPERIMENTAL: { + dht: false, + pubsub: false + } + } + } + + super(defaultsDeep(_options, defaults)) + } +} + +module.exports = Node diff --git a/test/utils/bundle-nodejs.js b/test/utils/bundle-nodejs.js new file mode 100644 index 0000000000..4086d25b8f --- /dev/null +++ b/test/utils/bundle-nodejs.js @@ -0,0 +1,88 @@ +'use strict' + +const TCP = require('libp2p-tcp') +const MulticastDNS = require('libp2p-mdns') +const WS = require('libp2p-websockets') +const Bootstrap = require('libp2p-railing') +const SPDY = require('libp2p-spdy') +const KadDHT = require('libp2p-kad-dht') +const MPLEX = require('libp2p-mplex') +const SECIO = require('libp2p-secio') +const defaultsDeep = require('@nodeutils/defaults-deep') +const libp2p = require('../..') + +function mapMuxers (list) { + return list.map((pref) => { + if (typeof pref !== 'string') { return pref } + switch (pref.trim().toLowerCase()) { + case 'spdy': return SPDY + case 'mplex': return MPLEX + default: + throw new Error(pref + ' muxer not available') + } + }) +} + +function getMuxers (muxers) { + const muxerPrefs = process.env.LIBP2P_MUXER + if (muxerPrefs && !muxers) { + return mapMuxers(muxerPrefs.split(',')) + } else if (muxers) { + return mapMuxers(muxers) + } else { + return [MPLEX, SPDY] + } +} + +class Node extends libp2p { + constructor (_options) { + const defaults = { + modules: { + transport: [ + TCP, + WS + ], + streamMuxer: getMuxers(_options.muxer), + connEncryption: [ + SECIO + ], + peerDiscovery: [ + MulticastDNS, + Bootstrap + ], + dht: KadDHT + }, + config: { + peerDiscovery: { + mdns: { + interval: 10000, + enabled: false + }, + bootstrap: { + interval: 10000, + enabled: false, + list: _options.bootstrapList + } + }, + relay: { + enabled: false, + hop: { + enabled: false, + active: false + } + }, + dht: { + kBucketSize: 20 + }, + EXPERIMENTAL: { + dht: false, + pubsub: false + } + } + } + + super(defaultsDeep(_options, defaults)) + } +} + +module.exports = Node diff --git a/test/utils/bundle.browser.js b/test/utils/bundle.browser.js deleted file mode 100644 index 5e26f8669b..0000000000 --- a/test/utils/bundle.browser.js +++ /dev/null @@ -1,74 +0,0 @@ -'use strict' - -const WS = require('libp2p-websockets') -const WebRTCStar = require('libp2p-webrtc-star') -const WebSocketStar = require('libp2p-websocket-star') -const spdy = require('libp2p-spdy') -const mplex = require('libp2p-mplex') -const secio = require('libp2p-secio') -const Railing = require('libp2p-railing') -const libp2p = require('../..') - -function mapMuxers (list) { - return list.map((pref) => { - if (typeof pref !== 'string') { - return pref - } - switch (pref.trim().toLowerCase()) { - case 'spdy': - return spdy - case 'mplex': - return mplex - default: - throw new Error(pref + ' muxer not available') - } - }) -} - -function getMuxers (options) { - if (options) { - return mapMuxers(options) - } else { - return [mplex, spdy] - } -} - -class Node extends libp2p { - constructor (peerInfo, peerBook, options) { - options = options || {} - const wrtcStar = new WebRTCStar({ id: peerInfo.id }) - const wsStar = new WebSocketStar({ id: peerInfo.id }) - - const modules = { - transport: [ - new WS(), - wrtcStar, - wsStar - ], - connection: { - muxer: getMuxers(options.muxer), - crypto: [ - secio - ] - }, - discovery: [] - } - - if (options.webRTCStar) { - modules.discovery.push(wrtcStar.discovery) - } - - if (options.wsStar) { - modules.discovery.push(wsStar.discovery) - } - - if (options.bootstrap) { - const r = new Railing(options.bootstrap) - modules.discovery.push(r) - } - - super(modules, peerInfo, peerBook, options) - } -} - -module.exports = Node diff --git a/test/utils/bundle.node.js b/test/utils/bundle.node.js deleted file mode 100644 index 061377f321..0000000000 --- a/test/utils/bundle.node.js +++ /dev/null @@ -1,80 +0,0 @@ -'use strict' - -const TCP = require('libp2p-tcp') -const MulticastDNS = require('libp2p-mdns') -const WS = require('libp2p-websockets') -const Railing = require('libp2p-railing') -const spdy = require('libp2p-spdy') -const KadDHT = require('libp2p-kad-dht') -const mplex = require('libp2p-mplex') -const secio = require('libp2p-secio') -const libp2p = require('../..') - -function mapMuxers (list) { - return list.map((pref) => { - if (typeof pref !== 'string') { - return pref - } - switch (pref.trim().toLowerCase()) { - case 'spdy': return spdy - case 'mplex': return mplex - default: - throw new Error(pref + ' muxer not available') - } - }) -} - -function getMuxers (muxers) { - const muxerPrefs = process.env.LIBP2P_MUXER - if (muxerPrefs && !muxers) { - return mapMuxers(muxerPrefs.split(',')) - } else if (muxers) { - return mapMuxers(muxers) - } else { - return [mplex, spdy] - } -} - -class Node extends libp2p { - constructor (peerInfo, peerBook, options) { - options = options || {} - - const modules = { - transport: [ - new TCP(), - new WS() - ], - connection: { - muxer: getMuxers(options.muxer), - crypto: [ secio ] - }, - discovery: [] - } - - if (options.dht) { - modules.DHT = KadDHT - } - - if (options.mdns) { - const mdns = new MulticastDNS(peerInfo, 'ipfs.local') - modules.discovery.push(mdns) - } - - if (options.bootstrap) { - const r = new Railing(options.bootstrap) - modules.discovery.push(r) - } - - if (options.modules && options.modules.transport) { - options.modules.transport.forEach((t) => modules.transport.push(t)) - } - - if (options.modules && options.modules.discovery) { - options.modules.discovery.forEach((d) => modules.discovery.push(d)) - } - - super(modules, peerInfo, peerBook, options) - } -} - -module.exports = Node diff --git a/test/utils/node.js b/test/utils/create-node.js similarity index 67% rename from test/utils/node.js rename to test/utils/create-node.js index 9831963569..11564bfe85 100644 --- a/test/utils/node.js +++ b/test/utils/create-node.js @@ -3,11 +3,10 @@ const chai = require('chai') chai.use(require('dirty-chai')) -const Node = require('./bundle.node') const PeerInfo = require('peer-info') const PeerId = require('peer-id') const waterfall = require('async/waterfall') -const pull = require('pull-stream') +const Node = require('./bundle-nodejs') function createNode (multiaddrs, options, callback) { if (typeof options === 'function') { @@ -26,20 +25,10 @@ function createNode (multiaddrs, options, callback) { (peerId, cb) => PeerInfo.create(peerId, cb), (peerInfo, cb) => { multiaddrs.map((ma) => peerInfo.multiaddrs.add(ma)) - cb(null, peerInfo) - }, - (peerInfo, cb) => { - const node = new Node(peerInfo, undefined, options) - cb(null, node) + options.peerInfo = peerInfo + cb(null, new Node(options)) } ], callback) } -function echo (protocol, conn) { - pull(conn, conn) -} - -module.exports = { - createNode: createNode, - echo: echo -} +module.exports = createNode diff --git a/test/utils/echo.js b/test/utils/echo.js new file mode 100644 index 0000000000..4bef5617c2 --- /dev/null +++ b/test/utils/echo.js @@ -0,0 +1,10 @@ +/* eslint-env mocha */ +'use strict' + +const pull = require('pull-stream') + +function echo (protocol, conn) { + pull(conn, conn) +} + +module.exports = echo