mirror of
https://github.com/fluencelabs/js-libp2p
synced 2025-07-11 14:51:34 +00:00
Compare commits
81 Commits
Author | SHA1 | Date | |
---|---|---|---|
631dad8647 | |||
3eac0e0dd6 | |||
30d4bb641e | |||
b0aeff8f53 | |||
998c71fc84 | |||
b31245adc8 | |||
85a064765a | |||
fb56cc3c30 | |||
03d0c52d4d | |||
0aa7bb72e7 | |||
e9b3d3496f | |||
58e18dd01b | |||
fb017ebb07 | |||
08c4c169d6 | |||
de927e8052 | |||
df8e61632b | |||
b453bd4f83 | |||
0143ab6449 | |||
02dd32e7df | |||
4fe91796cd | |||
352876cade | |||
41b700f509 | |||
eea7e91b15 | |||
b11a7972f5 | |||
15d5bc53fb | |||
9d911af8e0 | |||
9f1f3c82dc | |||
d6a1f52962 | |||
7b536819b1 | |||
7158aaf702 | |||
bc87fad5f9 | |||
c9418399a7 | |||
2cac123405 | |||
ff47a9c228 | |||
f86a981eb2 | |||
674d68000b | |||
ae371085c1 | |||
770bee3c66 | |||
6943e3e90b | |||
a008ebd5b9 | |||
20108d2de8 | |||
15fcfb737c | |||
0fa14c9608 | |||
ac7c8a150e | |||
851c8ee2a3 | |||
7a3f9d08d5 | |||
52d60a7391 | |||
165068d05c | |||
9baae15dcf | |||
b87524f36a | |||
b0484c678e | |||
b6c498055f | |||
93fdedf67b | |||
9e3b6a80af | |||
997c275139 | |||
ba33f2ecd8 | |||
c74e2594f8 | |||
61757793ed | |||
01bd659ee8 | |||
f8cbc89d1a | |||
7906f059f7 | |||
cea42f54cd | |||
71c6242a10 | |||
d7a0246d54 | |||
1344caa4d2 | |||
52519cd4e9 | |||
5bfbd8d972 | |||
28bd4ab187 | |||
35b5ac6573 | |||
2bd536e861 | |||
a2084f01e3 | |||
8c6ef52504 | |||
72f205e2b9 | |||
e41694d308 | |||
caf3a0180a | |||
879d736686 | |||
c726c252df | |||
f2df5586d5 | |||
9d149caf15 | |||
689bd4b190 | |||
9a29b01ad3 |
5
.gitignore
vendored
5
.gitignore
vendored
@ -29,5 +29,6 @@ node_modules
|
|||||||
|
|
||||||
|
|
||||||
coverage
|
coverage
|
||||||
.jshintrc
|
|
||||||
.jshintignore
|
dist
|
||||||
|
lib
|
35
.npmignore
Normal file
35
.npmignore
Normal file
@ -0,0 +1,35 @@
|
|||||||
|
test
|
||||||
|
|
||||||
|
# Logs
|
||||||
|
logs
|
||||||
|
*.log
|
||||||
|
npm-debug.log*
|
||||||
|
|
||||||
|
# Runtime data
|
||||||
|
pids
|
||||||
|
*.pid
|
||||||
|
*.seed
|
||||||
|
|
||||||
|
# Directory for instrumented libs generated by jscoverage/JSCover
|
||||||
|
lib-cov
|
||||||
|
|
||||||
|
# Coverage directory used by tools like istanbul
|
||||||
|
coverage
|
||||||
|
|
||||||
|
# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
|
||||||
|
.grunt
|
||||||
|
|
||||||
|
# node-waf configuration
|
||||||
|
.lock-wscript
|
||||||
|
|
||||||
|
# Compiled binary addons (http://nodejs.org/api/addons.html)
|
||||||
|
build/Release
|
||||||
|
|
||||||
|
# Dependency directory
|
||||||
|
node_modules
|
||||||
|
|
||||||
|
# Optional npm cache directory
|
||||||
|
.npm
|
||||||
|
|
||||||
|
# Optional REPL history
|
||||||
|
.node_repl_history
|
14
.travis.yml
14
.travis.yml
@ -1,7 +1,8 @@
|
|||||||
sudo: false
|
sudo: false
|
||||||
language: node_js
|
language: node_js
|
||||||
node_js:
|
node_js:
|
||||||
- "4.0"
|
- 4
|
||||||
|
- 5
|
||||||
|
|
||||||
# Make sure we have new NPM.
|
# Make sure we have new NPM.
|
||||||
before_install:
|
before_install:
|
||||||
@ -10,3 +11,14 @@ before_install:
|
|||||||
script:
|
script:
|
||||||
- npm run lint
|
- npm run lint
|
||||||
- npm test
|
- npm test
|
||||||
|
- npm run coverage
|
||||||
|
|
||||||
|
addons:
|
||||||
|
firefox: 'latest'
|
||||||
|
|
||||||
|
before_script:
|
||||||
|
- export DISPLAY=:99.0
|
||||||
|
- sh -e /etc/init.d/xvfb start
|
||||||
|
|
||||||
|
after_success:
|
||||||
|
- npm run coverage-publish
|
||||||
|
17
README.md
17
README.md
@ -1,10 +1,13 @@
|
|||||||
libp2p-swarm JavaScript implementation
|
libp2p-swarm JavaScript implementation
|
||||||
======================================
|
======================================
|
||||||
|
|
||||||
[](http://ipn.io)
|
[](http://ipn.io)
|
||||||
[](http://ipfs.io/)
|
[](http://ipfs.io/)
|
||||||
[](http://webchat.freenode.net/?channels=%23ipfs)
|
[](http://webchat.freenode.net/?channels=%23ipfs)
|
||||||
[](https://travis-ci.org/diasdavid/js-libp2p-swarm)
|
[](https://travis-ci.org/diasdavid/js-libp2p-swarm)
|
||||||
|
[](https://coveralls.io/github/diasdavid/js-libp2p-swarm?branch=master)
|
||||||
|
[](https://david-dm.org/ipfs/js-libp2p-swarm)
|
||||||
|
[](https://github.com/feross/standard)
|
||||||
|
|
||||||
> libp2p swarm implementation in JavaScript
|
> libp2p swarm implementation in JavaScript
|
||||||
|
|
||||||
@ -16,7 +19,7 @@ libp2p-swarm is used by libp2p but it can be also used as a standalone module.
|
|||||||
|
|
||||||
# Usage
|
# Usage
|
||||||
|
|
||||||
## Install
|
## Install
|
||||||
|
|
||||||
libp2p-swarm is available on npm and so, like any other npm module, just:
|
libp2p-swarm is available on npm and so, like any other npm module, just:
|
||||||
|
|
||||||
@ -45,7 +48,7 @@ peerInfo is a [PeerInfo](https://github.com/diasdavid/js-peer-info) object that
|
|||||||
libp2p-swarm expects transports that implement [interface-transport](https://github.com/diasdavid/abstract-transport). For example [libp2p-tcp](https://github.com/diasdavid/js-libp2p-tcp).
|
libp2p-swarm expects transports that implement [interface-transport](https://github.com/diasdavid/abstract-transport). For example [libp2p-tcp](https://github.com/diasdavid/js-libp2p-tcp).
|
||||||
|
|
||||||
- `key` - the transport identifier
|
- `key` - the transport identifier
|
||||||
- `transport` -
|
- `transport` -
|
||||||
- `options`
|
- `options`
|
||||||
- `callback`
|
- `callback`
|
||||||
|
|
||||||
@ -106,6 +109,12 @@ handle a new protocol.
|
|||||||
- `protocol`
|
- `protocol`
|
||||||
- `handler` - function called when we receive a dial on `protocol. Signature must be `function (conn) {}`
|
- `handler` - function called when we receive a dial on `protocol. Signature must be `function (conn) {}`
|
||||||
|
|
||||||
|
### `swarm.unhandle(protocol)`
|
||||||
|
|
||||||
|
unhandle a protocol.
|
||||||
|
|
||||||
|
- `protocol`
|
||||||
|
|
||||||
### `swarm.close(callback)`
|
### `swarm.close(callback)`
|
||||||
|
|
||||||
close all the listeners and muxers.
|
close all the listeners and muxers.
|
||||||
|
12
circle.yml
Normal file
12
circle.yml
Normal file
@ -0,0 +1,12 @@
|
|||||||
|
machine:
|
||||||
|
node:
|
||||||
|
version: stable
|
||||||
|
|
||||||
|
dependencies:
|
||||||
|
pre:
|
||||||
|
- google-chrome --version
|
||||||
|
- wget -q -O - https://dl-ssl.google.com/linux/linux_signing_key.pub | sudo apt-key add -
|
||||||
|
- sudo sh -c 'echo "deb [arch=amd64] http://dl.google.com/linux/chrome/deb/ stable main" >> /etc/apt/sources.list.d/google.list'
|
||||||
|
- sudo apt-get update
|
||||||
|
- sudo apt-get --only-upgrade install google-chrome-stable
|
||||||
|
- google-chrome --version
|
58
gulpfile.js
Normal file
58
gulpfile.js
Normal file
@ -0,0 +1,58 @@
|
|||||||
|
'use strict'
|
||||||
|
|
||||||
|
const gulp = require('gulp')
|
||||||
|
const Peer = require('peer-info')
|
||||||
|
const Id = require('peer-id')
|
||||||
|
const WebSockets = require('libp2p-websockets')
|
||||||
|
|
||||||
|
const Swarm = require('./src')
|
||||||
|
const multiaddr = require('multiaddr')
|
||||||
|
|
||||||
|
let swarmA
|
||||||
|
let swarmB
|
||||||
|
|
||||||
|
gulp.task('test:browser:before', (done) => {
|
||||||
|
function createListenerA (cb) {
|
||||||
|
const b58IdA = 'QmWg2L4Fucx1x4KXJTfKHGixBJvveubzcd7DdhB2Mqwfh1'
|
||||||
|
const peerA = new Peer(Id.createFromB58String(b58IdA))
|
||||||
|
const maA = multiaddr('/ip4/127.0.0.1/tcp/9100/websockets')
|
||||||
|
|
||||||
|
peerA.multiaddr.add(maA)
|
||||||
|
swarmA = new Swarm(peerA)
|
||||||
|
swarmA.transport.add('ws', new WebSockets())
|
||||||
|
swarmA.transport.listen('ws', {}, echo, cb)
|
||||||
|
}
|
||||||
|
|
||||||
|
function createListenerB (cb) {
|
||||||
|
const b58IdB = 'QmRy1iU6BHmG5Hd8rnPhPL98cy1W1przUSTAMcGDq9yAAV'
|
||||||
|
const maB = multiaddr('/ip4/127.0.0.1/tcp/9200/websockets')
|
||||||
|
const peerB = new Peer(Id.createFromB58String(b58IdB))
|
||||||
|
peerB.multiaddr.add(maB)
|
||||||
|
swarmB = new Swarm(peerB)
|
||||||
|
|
||||||
|
swarmB.transport.add('ws', new WebSockets())
|
||||||
|
swarmB.transport.listen('ws', {}, null, cb)
|
||||||
|
|
||||||
|
swarmB.handle('/echo/1.0.0', echo)
|
||||||
|
}
|
||||||
|
|
||||||
|
let count = 0
|
||||||
|
const ready = () => ++count === 2 ? done() : null
|
||||||
|
|
||||||
|
createListenerA(ready)
|
||||||
|
createListenerB(ready)
|
||||||
|
|
||||||
|
function echo (conn) {
|
||||||
|
conn.pipe(conn)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
gulp.task('test:browser:after', (done) => {
|
||||||
|
let count = 0
|
||||||
|
const ready = () => ++count === 2 ? done() : null
|
||||||
|
|
||||||
|
swarmA.transport.close('ws', ready)
|
||||||
|
swarmB.transport.close('ws', ready)
|
||||||
|
})
|
||||||
|
|
||||||
|
require('aegir/gulp')(gulp)
|
70
package.json
70
package.json
@ -1,12 +1,20 @@
|
|||||||
{
|
{
|
||||||
"name": "libp2p-swarm",
|
"name": "libp2p-swarm",
|
||||||
"version": "0.8.1",
|
"version": "0.12.7",
|
||||||
"description": "libp2p swarm implementation in Node.js",
|
"description": "libp2p swarm implementation in JavaScript",
|
||||||
"main": "src/index.js",
|
"main": "lib/index.js",
|
||||||
|
"jsnext:main": "src/index.js",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"test": "mocha tests/*-test.js",
|
"lint": "gulp lint",
|
||||||
"coverage": "istanbul cover --print both -- _mocha tests/*-test.js",
|
"build": "gulp build",
|
||||||
"lint": "standard"
|
"test": "gulp test",
|
||||||
|
"test:node": "gulp test:node",
|
||||||
|
"test:browser": "gulp test:browser",
|
||||||
|
"release": "gulp release",
|
||||||
|
"release-minor": "gulp release --type minor",
|
||||||
|
"release-major": "gulp release --type major",
|
||||||
|
"coverage": "gulp coverage",
|
||||||
|
"coverage-publish": "aegir-coverage publish"
|
||||||
},
|
},
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
@ -30,23 +38,45 @@
|
|||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"bl": "^1.1.2",
|
"bl": "^1.1.2",
|
||||||
|
"buffer-loader": "0.0.1",
|
||||||
"chai": "^3.5.0",
|
"chai": "^3.5.0",
|
||||||
"istanbul": "^0.4.2",
|
"aegir": "^3.0.0",
|
||||||
"libp2p-spdy": "^0.2.3",
|
"gulp": "^3.9.1",
|
||||||
"libp2p-tcp": "^0.4.0",
|
"istanbul": "^0.4.3",
|
||||||
"libp2p-websockets": "^0.2.0",
|
"libp2p-multiplex": "^0.2.1",
|
||||||
"mocha": "^2.4.5",
|
"libp2p-spdy": "^0.3.1",
|
||||||
"multiaddr": "^1.3.0",
|
"libp2p-tcp": "^0.5.0",
|
||||||
"peer-id": "^0.6.0",
|
"libp2p-websockets": "^0.4.1",
|
||||||
"peer-info": "^0.6.0",
|
"multiaddr": "^1.4.0",
|
||||||
|
"peer-id": "^0.6.6",
|
||||||
|
"peer-info": "^0.6.2",
|
||||||
"pre-commit": "^1.1.2",
|
"pre-commit": "^1.1.2",
|
||||||
"standard": "^6.0.7",
|
|
||||||
"stream-pair": "^1.0.3"
|
"stream-pair": "^1.0.3"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
|
"async": "^2.0.0-rc.4",
|
||||||
|
"babel-runtime": "^6.6.1",
|
||||||
"duplex-passthrough": "github:diasdavid/duplex-passthrough",
|
"duplex-passthrough": "github:diasdavid/duplex-passthrough",
|
||||||
"ip-address": "^5.0.2",
|
"ip-address": "^5.8.0",
|
||||||
"multistream-select": "^0.6.1",
|
"lodash.contains": "^2.4.3",
|
||||||
"protocol-buffers-stream": "^1.2.0"
|
"multistream-select": "^0.6.5",
|
||||||
}
|
"protocol-buffers-stream": "^1.3.1"
|
||||||
}
|
},
|
||||||
|
"aegir": {
|
||||||
|
"webpack": {
|
||||||
|
"resolve": {
|
||||||
|
"alias": {
|
||||||
|
"node-forge": "../vendor/forge.bundle.js"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
},
|
||||||
|
"contributors": [
|
||||||
|
"David Dias <daviddias.p@gmail.com>",
|
||||||
|
"David Dias <mail@daviddias.me>",
|
||||||
|
"Francisco Baio Dias <xicombd@gmail.com>",
|
||||||
|
"Friedel Ziegelmayer <dignifiedquire@gmail.com>",
|
||||||
|
"Pau Ramon Revilla <masylum@gmail.com>",
|
||||||
|
"Richard Littauer <richard.littauer@gmail.com>"
|
||||||
|
]
|
||||||
|
}
|
@ -5,15 +5,19 @@
|
|||||||
* established, so a conn can be reused
|
* established, so a conn can be reused
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
'use strict'
|
||||||
|
|
||||||
const multistream = require('multistream-select')
|
const multistream = require('multistream-select')
|
||||||
const fs = require('fs')
|
const fs = require('fs')
|
||||||
const path = require('path')
|
const path = require('path')
|
||||||
const pbStream = require('protocol-buffers-stream')(
|
|
||||||
fs.readFileSync(path.join(__dirname, 'identify.proto')))
|
|
||||||
const Info = require('peer-info')
|
const Info = require('peer-info')
|
||||||
const Id = require('peer-id')
|
const Id = require('peer-id')
|
||||||
const multiaddr = require('multiaddr')
|
const multiaddr = require('multiaddr')
|
||||||
|
|
||||||
|
const identity = fs.readFileSync(path.join(__dirname, 'identify.proto'))
|
||||||
|
|
||||||
|
const pbStream = require('protocol-buffers-stream')(identity)
|
||||||
|
|
||||||
exports = module.exports
|
exports = module.exports
|
||||||
exports.multicodec = '/ipfs/identify/1.0.0'
|
exports.multicodec = '/ipfs/identify/1.0.0'
|
||||||
|
|
||||||
@ -36,7 +40,9 @@ exports.exec = (rawConn, muxer, peerInfo, callback) => {
|
|||||||
var pbs = pbStream()
|
var pbs = pbStream()
|
||||||
|
|
||||||
pbs.on('identify', (msg) => {
|
pbs.on('identify', (msg) => {
|
||||||
peerInfo.multiaddr.addSafe(msg.observedAddr)
|
if (msg.observedAddr.length > 0) {
|
||||||
|
peerInfo.multiaddr.addSafe(multiaddr(msg.observedAddr))
|
||||||
|
}
|
||||||
|
|
||||||
const peerId = Id.createFromPubKey(msg.publicKey)
|
const peerId = Id.createFromPubKey(msg.publicKey)
|
||||||
const otherPeerInfo = new Info(peerId)
|
const otherPeerInfo = new Info(peerId)
|
||||||
@ -53,8 +59,8 @@ exports.exec = (rawConn, muxer, peerInfo, callback) => {
|
|||||||
protocolVersion: 'na',
|
protocolVersion: 'na',
|
||||||
agentVersion: 'na',
|
agentVersion: 'na',
|
||||||
publicKey: peerInfo.id.pubKey,
|
publicKey: peerInfo.id.pubKey,
|
||||||
listenAddrs: peerInfo.multiaddrs.map((mh) => { return mh.buffer }),
|
listenAddrs: peerInfo.multiaddrs.map((mh) => mh.buffer),
|
||||||
observedAddr: obsMultiaddr ? obsMultiaddr.buffer : null
|
observedAddr: obsMultiaddr ? obsMultiaddr.buffer : new Buffer('')
|
||||||
})
|
})
|
||||||
|
|
||||||
pbs.pipe(ds).pipe(pbs)
|
pbs.pipe(ds).pipe(pbs)
|
||||||
@ -64,14 +70,16 @@ exports.exec = (rawConn, muxer, peerInfo, callback) => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
exports.handler = (peerInfo, swarm) => {
|
exports.handler = (peerInfo, swarm) => {
|
||||||
return function (conn) {
|
return (conn) => {
|
||||||
// 1. receive incoming observed info about me
|
// 1. receive incoming observed info about me
|
||||||
// 2. update my own information (on peerInfo)
|
// 2. update my own information (on peerInfo)
|
||||||
// 3. send back what I see from the other (get from swarm.muxedConns[incPeerID].conn.getObservedAddrs()
|
// 3. send back what I see from the other (get from swarm.muxedConns[incPeerID].conn.getObservedAddrs()
|
||||||
var pbs = pbStream()
|
var pbs = pbStream()
|
||||||
|
|
||||||
pbs.on('identify', function (msg) {
|
pbs.on('identify', (msg) => {
|
||||||
peerInfo.multiaddr.addSafe(msg.observedAddr)
|
if (msg.observedAddr.length > 0) {
|
||||||
|
peerInfo.multiaddr.addSafe(multiaddr(msg.observedAddr))
|
||||||
|
}
|
||||||
|
|
||||||
const peerId = Id.createFromPubKey(msg.publicKey)
|
const peerId = Id.createFromPubKey(msg.publicKey)
|
||||||
const conn = swarm.muxedConns[peerId.toB58String()].conn
|
const conn = swarm.muxedConns[peerId.toB58String()].conn
|
||||||
@ -81,10 +89,8 @@ exports.handler = (peerInfo, swarm) => {
|
|||||||
protocolVersion: 'na',
|
protocolVersion: 'na',
|
||||||
agentVersion: 'na',
|
agentVersion: 'na',
|
||||||
publicKey: peerInfo.id.pubKey,
|
publicKey: peerInfo.id.pubKey,
|
||||||
listenAddrs: peerInfo.multiaddrs.map(function (ma) {
|
listenAddrs: peerInfo.multiaddrs.map((ma) => ma.buffer),
|
||||||
return ma.buffer
|
observedAddr: obsMultiaddr ? obsMultiaddr.buffer : new Buffer('')
|
||||||
}),
|
|
||||||
observedAddr: obsMultiaddr ? obsMultiaddr.buffer : null
|
|
||||||
})
|
})
|
||||||
pbs.finalize()
|
pbs.finalize()
|
||||||
})
|
})
|
||||||
|
97
src/index.js
97
src/index.js
@ -1,9 +1,17 @@
|
|||||||
|
'use strict'
|
||||||
|
|
||||||
|
const async = require('async')
|
||||||
const multistream = require('multistream-select')
|
const multistream = require('multistream-select')
|
||||||
const identify = require('./identify')
|
const identify = require('./identify')
|
||||||
const DuplexPassThrough = require('duplex-passthrough')
|
const DuplexPassThrough = require('duplex-passthrough')
|
||||||
|
const contains = require('lodash.contains')
|
||||||
|
const util = require('util')
|
||||||
|
const EE = require('events').EventEmitter
|
||||||
|
|
||||||
exports = module.exports = Swarm
|
exports = module.exports = Swarm
|
||||||
|
|
||||||
|
util.inherits(Swarm, EE)
|
||||||
|
|
||||||
function Swarm (peerInfo) {
|
function Swarm (peerInfo) {
|
||||||
if (!(this instanceof Swarm)) {
|
if (!(this instanceof Swarm)) {
|
||||||
return new Swarm(peerInfo)
|
return new Swarm(peerInfo)
|
||||||
@ -85,11 +93,16 @@ function Swarm (peerInfo) {
|
|||||||
// if no callback is passed, we pass conns to connHandler
|
// if no callback is passed, we pass conns to connHandler
|
||||||
if (!handler) { handler = connHandler }
|
if (!handler) { handler = connHandler }
|
||||||
|
|
||||||
const multiaddrs = peerInfo.multiaddrs.filter((m) => {
|
const multiaddrs = this.transports[key].filter(
|
||||||
if (m.toString().indexOf('tcp') !== -1) {
|
peerInfo.multiaddrs.map((addr) => {
|
||||||
return m
|
// ipfs multiaddrs are not dialable so we drop them here
|
||||||
}
|
if (contains(addr.protoNames(), 'ipfs')) {
|
||||||
})
|
return addr.decapsulate('ipfs')
|
||||||
|
}
|
||||||
|
|
||||||
|
return addr
|
||||||
|
})
|
||||||
|
)
|
||||||
|
|
||||||
this.transports[key].createListener(multiaddrs, handler, (err, maUpdate) => {
|
this.transports[key].createListener(multiaddrs, handler, (err, maUpdate) => {
|
||||||
if (err) {
|
if (err) {
|
||||||
@ -136,7 +149,23 @@ function Swarm (peerInfo) {
|
|||||||
// for listening
|
// for listening
|
||||||
this.handle(muxer.multicodec, (conn) => {
|
this.handle(muxer.multicodec, (conn) => {
|
||||||
const muxedConn = muxer(conn, true)
|
const muxedConn = muxer(conn, true)
|
||||||
|
|
||||||
|
var peerIdForConn
|
||||||
|
|
||||||
muxedConn.on('stream', (conn) => {
|
muxedConn.on('stream', (conn) => {
|
||||||
|
function gotId () {
|
||||||
|
if (peerIdForConn) {
|
||||||
|
conn.peerId = peerIdForConn
|
||||||
|
connHandler(conn)
|
||||||
|
} else {
|
||||||
|
setTimeout(gotId, 100)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (this.identify) {
|
||||||
|
return gotId()
|
||||||
|
}
|
||||||
|
|
||||||
connHandler(conn)
|
connHandler(conn)
|
||||||
})
|
})
|
||||||
|
|
||||||
@ -146,9 +175,18 @@ function Swarm (peerInfo) {
|
|||||||
if (err) {
|
if (err) {
|
||||||
return console.log('Identify exec failed', err)
|
return console.log('Identify exec failed', err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
peerIdForConn = pi.id
|
||||||
this.muxedConns[pi.id.toB58String()] = {}
|
this.muxedConns[pi.id.toB58String()] = {}
|
||||||
this.muxedConns[pi.id.toB58String()].muxer = muxedConn
|
this.muxedConns[pi.id.toB58String()].muxer = muxedConn
|
||||||
this.muxedConns[pi.id.toB58String()].conn = conn // to be able to extract addrs
|
this.muxedConns[pi.id.toB58String()].conn = conn // to be able to extract addrs
|
||||||
|
|
||||||
|
self.emit('peer-mux-established', pi)
|
||||||
|
|
||||||
|
muxedConn.on('close', () => {
|
||||||
|
delete self.muxedConns[pi.id.toB58String()]
|
||||||
|
self.emit('peer-mux-closed', pi)
|
||||||
|
})
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
@ -175,15 +213,19 @@ function Swarm (peerInfo) {
|
|||||||
|
|
||||||
// higher level (public) API
|
// higher level (public) API
|
||||||
this.dial = (pi, protocol, callback) => {
|
this.dial = (pi, protocol, callback) => {
|
||||||
var pt = null
|
|
||||||
if (typeof protocol === 'function') {
|
if (typeof protocol === 'function') {
|
||||||
callback = protocol
|
callback = protocol
|
||||||
protocol = null
|
protocol = null
|
||||||
} else {
|
|
||||||
pt = new DuplexPassThrough()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (!callback) {
|
||||||
|
callback = function noop () {}
|
||||||
|
}
|
||||||
|
|
||||||
|
const pt = new DuplexPassThrough()
|
||||||
|
|
||||||
const b58Id = pi.id.toB58String()
|
const b58Id = pi.id.toB58String()
|
||||||
|
|
||||||
if (!this.muxedConns[b58Id]) {
|
if (!this.muxedConns[b58Id]) {
|
||||||
if (!this.conns[b58Id]) {
|
if (!this.conns[b58Id]) {
|
||||||
attemptDial(pi, (err, conn) => {
|
attemptDial(pi, (err, conn) => {
|
||||||
@ -201,6 +243,8 @@ function Swarm (peerInfo) {
|
|||||||
gotMuxer(this.muxedConns[b58Id].muxer)
|
gotMuxer(this.muxedConns[b58Id].muxer)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
return pt
|
||||||
|
|
||||||
function gotWarmedUpConn (conn) {
|
function gotWarmedUpConn (conn) {
|
||||||
attemptMuxerUpgrade(conn, (err, muxer) => {
|
attemptMuxerUpgrade(conn, (err, muxer) => {
|
||||||
if (!protocol) {
|
if (!protocol) {
|
||||||
@ -274,14 +318,25 @@ function Swarm (peerInfo) {
|
|||||||
self.muxedConns[b58Id].muxer = muxedConn
|
self.muxedConns[b58Id].muxer = muxedConn
|
||||||
self.muxedConns[b58Id].conn = conn
|
self.muxedConns[b58Id].conn = conn
|
||||||
|
|
||||||
|
self.emit('peer-mux-established', pi)
|
||||||
|
|
||||||
|
muxedConn.on('close', () => {
|
||||||
|
delete self.muxedConns[pi.id.toB58String()]
|
||||||
|
self.emit('peer-mux-closed', pi)
|
||||||
|
})
|
||||||
|
|
||||||
// in case identify is on
|
// in case identify is on
|
||||||
muxedConn.on('stream', connHandler)
|
muxedConn.on('stream', (conn) => {
|
||||||
|
conn.peerId = pi.id
|
||||||
|
connHandler(conn)
|
||||||
|
})
|
||||||
|
|
||||||
cb(null, muxedConn)
|
cb(null, muxedConn)
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
function openConnInMuxedConn (muxer, cb) {
|
function openConnInMuxedConn (muxer, cb) {
|
||||||
cb(muxer.newStream())
|
cb(muxer.newStream())
|
||||||
}
|
}
|
||||||
@ -295,6 +350,7 @@ function Swarm (peerInfo) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
pt.wrapStream(conn)
|
pt.wrapStream(conn)
|
||||||
|
pt.peerId = pi.id
|
||||||
callback(null, pt)
|
callback(null, pt)
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
@ -305,20 +361,25 @@ function Swarm (peerInfo) {
|
|||||||
this.protocols[protocol] = handler
|
this.protocols[protocol] = handler
|
||||||
}
|
}
|
||||||
|
|
||||||
this.close = (callback) => {
|
this.unhandle = (protocol, handler) => {
|
||||||
var count = 0
|
if (this.protocols[protocol]) {
|
||||||
|
delete this.protocols[protocol]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
this.close = (callback) => {
|
||||||
Object.keys(this.muxedConns).forEach((key) => {
|
Object.keys(this.muxedConns).forEach((key) => {
|
||||||
this.muxedConns[key].muxer.end()
|
this.muxedConns[key].muxer.end()
|
||||||
})
|
})
|
||||||
|
|
||||||
Object.keys(this.transports).forEach((key) => {
|
async.each(
|
||||||
this.transports[key].close(() => {
|
Object.keys(this.transports),
|
||||||
if (++count === Object.keys(this.transports).length) {
|
(key, cb) => this.transports[key].close(cb),
|
||||||
callback()
|
() => {
|
||||||
}
|
// Ignoring close errors
|
||||||
})
|
callback()
|
||||||
})
|
}
|
||||||
|
)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
13
test/00-basic.node.js
Normal file
13
test/00-basic.node.js
Normal file
@ -0,0 +1,13 @@
|
|||||||
|
/* eslint-env mocha */
|
||||||
|
'use strict'
|
||||||
|
|
||||||
|
const expect = require('chai').expect
|
||||||
|
|
||||||
|
const Swarm = require('../src')
|
||||||
|
|
||||||
|
describe('basics', () => {
|
||||||
|
it('throws on missing peerInfo', (done) => {
|
||||||
|
expect(Swarm).to.throw(Error)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
})
|
178
test/01-transport-tcp.node.js
Normal file
178
test/01-transport-tcp.node.js
Normal file
@ -0,0 +1,178 @@
|
|||||||
|
/* eslint-env mocha */
|
||||||
|
'use strict'
|
||||||
|
|
||||||
|
const expect = require('chai').expect
|
||||||
|
|
||||||
|
const multiaddr = require('multiaddr')
|
||||||
|
const Peer = require('peer-info')
|
||||||
|
const Swarm = require('../src')
|
||||||
|
const TCP = require('libp2p-tcp')
|
||||||
|
const bl = require('bl')
|
||||||
|
|
||||||
|
describe('transport - tcp', function () {
|
||||||
|
this.timeout(10000)
|
||||||
|
|
||||||
|
var swarmA
|
||||||
|
var swarmB
|
||||||
|
var peerA = new Peer()
|
||||||
|
var peerB = new Peer()
|
||||||
|
|
||||||
|
before((done) => {
|
||||||
|
peerA.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9888'))
|
||||||
|
peerB.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9999'))
|
||||||
|
swarmA = new Swarm(peerA)
|
||||||
|
swarmB = new Swarm(peerB)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
|
||||||
|
it('add', (done) => {
|
||||||
|
swarmA.transport.add('tcp', new TCP())
|
||||||
|
expect(Object.keys(swarmA.transports).length).to.equal(1)
|
||||||
|
swarmB.transport.add('tcp', new TCP(), () => {
|
||||||
|
expect(Object.keys(swarmB.transports).length).to.equal(1)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('listen', (done) => {
|
||||||
|
var count = 0
|
||||||
|
swarmA.transport.listen('tcp', {}, (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
}, ready)
|
||||||
|
swarmB.transport.listen('tcp', {}, (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
}, ready)
|
||||||
|
|
||||||
|
function ready () {
|
||||||
|
if (++count === 2) {
|
||||||
|
expect(peerA.multiaddrs.length).to.equal(1)
|
||||||
|
expect(
|
||||||
|
peerA.multiaddrs[0].equals(multiaddr('/ip4/127.0.0.1/tcp/9888'))
|
||||||
|
).to.be.equal(
|
||||||
|
true
|
||||||
|
)
|
||||||
|
expect(peerB.multiaddrs.length).to.equal(1)
|
||||||
|
expect(
|
||||||
|
peerB.multiaddrs[0].equals(multiaddr('/ip4/127.0.0.1/tcp/9999'))
|
||||||
|
).to.be.equal(
|
||||||
|
true
|
||||||
|
)
|
||||||
|
done()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial to a multiaddr', (done) => {
|
||||||
|
const conn = swarmA.transport.dial('tcp', multiaddr('/ip4/127.0.0.1/tcp/9999'), (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
})
|
||||||
|
conn.pipe(bl((err, data) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
done()
|
||||||
|
}))
|
||||||
|
conn.write('hey')
|
||||||
|
conn.end()
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial to set of multiaddr, only one is available', (done) => {
|
||||||
|
const conn = swarmA.transport.dial('tcp', [
|
||||||
|
multiaddr('/ip4/127.0.0.1/tcp/9910/websockets'), // not valid on purpose
|
||||||
|
multiaddr('/ip4/127.0.0.1/tcp/9910'),
|
||||||
|
multiaddr('/ip4/127.0.0.1/tcp/9999'),
|
||||||
|
multiaddr('/ip4/127.0.0.1/tcp/9309')
|
||||||
|
], (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
})
|
||||||
|
conn.pipe(bl((err, data) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
done()
|
||||||
|
}))
|
||||||
|
conn.write('hey')
|
||||||
|
conn.end()
|
||||||
|
})
|
||||||
|
|
||||||
|
it('close', (done) => {
|
||||||
|
var count = 0
|
||||||
|
swarmA.transport.close('tcp', closed)
|
||||||
|
swarmB.transport.close('tcp', closed)
|
||||||
|
|
||||||
|
function closed () {
|
||||||
|
if (++count === 2) {
|
||||||
|
done()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it('support port 0', (done) => {
|
||||||
|
var swarm
|
||||||
|
var peer = new Peer()
|
||||||
|
peer.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/0'))
|
||||||
|
swarm = new Swarm(peer)
|
||||||
|
swarm.transport.add('tcp', new TCP())
|
||||||
|
swarm.transport.listen('tcp', {}, (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
}, ready)
|
||||||
|
|
||||||
|
function ready () {
|
||||||
|
expect(peer.multiaddrs.length).to.equal(1)
|
||||||
|
expect(peer.multiaddrs[0]).to.not.deep.equal(multiaddr('/ip4/127.0.0.1/tcp/0'))
|
||||||
|
swarm.close(done)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it('support addr /ip4/0.0.0.0/tcp/9050', (done) => {
|
||||||
|
var swarm
|
||||||
|
var peer = new Peer()
|
||||||
|
peer.multiaddr.add(multiaddr('/ip4/0.0.0.0/tcp/9050'))
|
||||||
|
swarm = new Swarm(peer)
|
||||||
|
swarm.transport.add('tcp', new TCP())
|
||||||
|
swarm.transport.listen('tcp', {}, (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
}, ready)
|
||||||
|
|
||||||
|
function ready () {
|
||||||
|
expect(peer.multiaddrs.length).to.equal(1)
|
||||||
|
expect(
|
||||||
|
peer.multiaddrs[0].equals(multiaddr('/ip4/0.0.0.0/tcp/9050'))
|
||||||
|
).to.be.equal(
|
||||||
|
true
|
||||||
|
)
|
||||||
|
swarm.close(done)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it('support addr /ip4/0.0.0.0/tcp/0', (done) => {
|
||||||
|
var swarm
|
||||||
|
var peer = new Peer()
|
||||||
|
peer.multiaddr.add(multiaddr('/ip4/0.0.0.0/tcp/0'))
|
||||||
|
swarm = new Swarm(peer)
|
||||||
|
swarm.transport.add('tcp', new TCP())
|
||||||
|
swarm.transport.listen('tcp', {}, (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
}, ready)
|
||||||
|
|
||||||
|
function ready () {
|
||||||
|
expect(peer.multiaddrs.length).to.equal(1)
|
||||||
|
expect(peer.multiaddrs[0]).to.not.deep.equal(multiaddr('/ip4/0.0.0.0/tcp/0'))
|
||||||
|
swarm.close(done)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it('listen in several addrs', (done) => {
|
||||||
|
var swarm
|
||||||
|
var peer = new Peer()
|
||||||
|
peer.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9001'))
|
||||||
|
peer.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9002'))
|
||||||
|
peer.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9003'))
|
||||||
|
swarm = new Swarm(peer)
|
||||||
|
swarm.transport.add('tcp', new TCP())
|
||||||
|
swarm.transport.listen('tcp', {}, (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
}, ready)
|
||||||
|
|
||||||
|
function ready () {
|
||||||
|
expect(peer.multiaddrs.length).to.equal(3)
|
||||||
|
swarm.close(done)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
})
|
13
test/02-transport-utp.node.js
Normal file
13
test/02-transport-utp.node.js
Normal file
@ -0,0 +1,13 @@
|
|||||||
|
/* eslint-env mocha */
|
||||||
|
'use strict'
|
||||||
|
|
||||||
|
describe('transport - utp', function () {
|
||||||
|
this.timeout(10000)
|
||||||
|
|
||||||
|
before((done) => { done() })
|
||||||
|
|
||||||
|
it.skip('add', (done) => {})
|
||||||
|
it.skip('listen', (done) => {})
|
||||||
|
it.skip('dial', (done) => {})
|
||||||
|
it.skip('close', (done) => {})
|
||||||
|
})
|
101
test/03-transport-websockets.node.js
Normal file
101
test/03-transport-websockets.node.js
Normal file
@ -0,0 +1,101 @@
|
|||||||
|
/* eslint-env mocha */
|
||||||
|
'use strict'
|
||||||
|
|
||||||
|
const expect = require('chai').expect
|
||||||
|
|
||||||
|
const multiaddr = require('multiaddr')
|
||||||
|
const Peer = require('peer-info')
|
||||||
|
const Swarm = require('../src')
|
||||||
|
const WebSockets = require('libp2p-websockets')
|
||||||
|
const bl = require('bl')
|
||||||
|
|
||||||
|
describe('transport - websockets', function () {
|
||||||
|
this.timeout(10000)
|
||||||
|
|
||||||
|
var swarmA
|
||||||
|
var swarmB
|
||||||
|
var peerA = new Peer()
|
||||||
|
var peerB = new Peer()
|
||||||
|
|
||||||
|
before((done) => {
|
||||||
|
peerA.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9888/websockets'))
|
||||||
|
peerB.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9999/websockets'))
|
||||||
|
swarmA = new Swarm(peerA)
|
||||||
|
swarmB = new Swarm(peerB)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
|
||||||
|
it('add', (done) => {
|
||||||
|
swarmA.transport.add('ws', new WebSockets())
|
||||||
|
expect(Object.keys(swarmA.transports).length).to.equal(1)
|
||||||
|
swarmB.transport.add('ws', new WebSockets(), () => {
|
||||||
|
expect(Object.keys(swarmB.transports).length).to.equal(1)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('listen', (done) => {
|
||||||
|
var count = 0
|
||||||
|
swarmA.transport.listen('ws', {}, (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
}, ready)
|
||||||
|
swarmB.transport.listen('ws', {}, (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
}, ready)
|
||||||
|
|
||||||
|
function ready () {
|
||||||
|
if (++count === 2) {
|
||||||
|
expect(peerA.multiaddrs.length).to.equal(1)
|
||||||
|
expect(
|
||||||
|
peerA.multiaddrs[0].equals(multiaddr('/ip4/127.0.0.1/tcp/9888/websockets'))
|
||||||
|
).to.be.equal(
|
||||||
|
true
|
||||||
|
)
|
||||||
|
expect(peerB.multiaddrs.length).to.equal(1)
|
||||||
|
expect(
|
||||||
|
peerB.multiaddrs[0].equals(multiaddr('/ip4/127.0.0.1/tcp/9999/websockets'))
|
||||||
|
).to.equal(
|
||||||
|
true
|
||||||
|
)
|
||||||
|
done()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial', (done) => {
|
||||||
|
const conn = swarmA.transport.dial('ws', multiaddr('/ip4/127.0.0.1/tcp/9999/websockets'), (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
})
|
||||||
|
conn.pipe(bl((err, data) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
done()
|
||||||
|
}))
|
||||||
|
conn.write('hey')
|
||||||
|
conn.end()
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial (conn from callback)', (done) => {
|
||||||
|
swarmA.transport.dial('ws', multiaddr('/ip4/127.0.0.1/tcp/9999/websockets'), (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
|
||||||
|
conn.pipe(bl((err, data) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
done()
|
||||||
|
}))
|
||||||
|
conn.write('hey')
|
||||||
|
conn.end()
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('close', (done) => {
|
||||||
|
var count = 0
|
||||||
|
swarmA.transport.close('ws', closed)
|
||||||
|
swarmB.transport.close('ws', closed)
|
||||||
|
|
||||||
|
function closed () {
|
||||||
|
if (++count === 2) {
|
||||||
|
done()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
})
|
131
test/04-muxing-multiplex.node.js
Normal file
131
test/04-muxing-multiplex.node.js
Normal file
@ -0,0 +1,131 @@
|
|||||||
|
/* eslint-env mocha */
|
||||||
|
'use strict'
|
||||||
|
|
||||||
|
const expect = require('chai').expect
|
||||||
|
|
||||||
|
const multiaddr = require('multiaddr')
|
||||||
|
const Peer = require('peer-info')
|
||||||
|
const Swarm = require('../src')
|
||||||
|
const TCP = require('libp2p-tcp')
|
||||||
|
const multiplex = require('libp2p-spdy')
|
||||||
|
|
||||||
|
describe('stream muxing with multiplex (on TCP)', function () {
|
||||||
|
this.timeout(20000)
|
||||||
|
|
||||||
|
var swarmA
|
||||||
|
var peerA
|
||||||
|
var swarmB
|
||||||
|
var peerB
|
||||||
|
var swarmC
|
||||||
|
var peerC
|
||||||
|
|
||||||
|
before((done) => {
|
||||||
|
peerA = new Peer()
|
||||||
|
peerB = new Peer()
|
||||||
|
peerC = new Peer()
|
||||||
|
|
||||||
|
// console.log('peer A', peerA.id.toB58String())
|
||||||
|
// console.log('peer B', peerB.id.toB58String())
|
||||||
|
// console.log('peer C', peerC.id.toB58String())
|
||||||
|
|
||||||
|
peerA.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9001'))
|
||||||
|
peerB.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9002'))
|
||||||
|
peerC.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9003'))
|
||||||
|
|
||||||
|
swarmA = new Swarm(peerA)
|
||||||
|
swarmB = new Swarm(peerB)
|
||||||
|
swarmC = new Swarm(peerC)
|
||||||
|
|
||||||
|
swarmA.transport.add('tcp', new TCP())
|
||||||
|
swarmA.transport.listen('tcp', {}, null, ready)
|
||||||
|
|
||||||
|
swarmB.transport.add('tcp', new TCP())
|
||||||
|
swarmB.transport.listen('tcp', {}, null, ready)
|
||||||
|
|
||||||
|
swarmC.transport.add('tcp', new TCP())
|
||||||
|
swarmC.transport.listen('tcp', {}, null, ready)
|
||||||
|
|
||||||
|
var counter = 0
|
||||||
|
|
||||||
|
function ready () {
|
||||||
|
if (++counter === 3) {
|
||||||
|
done()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
after((done) => {
|
||||||
|
var counter = 0
|
||||||
|
|
||||||
|
swarmA.close(closed)
|
||||||
|
swarmB.close(closed)
|
||||||
|
swarmC.close(closed)
|
||||||
|
|
||||||
|
function closed () {
|
||||||
|
if (++counter === 3) {
|
||||||
|
done()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it('add', (done) => {
|
||||||
|
swarmA.connection.addStreamMuxer(multiplex)
|
||||||
|
swarmB.connection.addStreamMuxer(multiplex)
|
||||||
|
swarmC.connection.addStreamMuxer(multiplex)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
|
||||||
|
it('handle + dial on protocol', (done) => {
|
||||||
|
swarmB.handle('/abacaxi/1.0.0', (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
})
|
||||||
|
|
||||||
|
swarmA.dial(peerB, '/abacaxi/1.0.0', (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
expect(Object.keys(swarmA.muxedConns).length).to.equal(1)
|
||||||
|
conn.end()
|
||||||
|
|
||||||
|
conn.on('data', () => {}) // let it flow.. let it flooooow
|
||||||
|
conn.on('end', done)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial to warm conn', (done) => {
|
||||||
|
swarmB.dial(peerA, (err) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
expect(Object.keys(swarmB.conns).length).to.equal(0)
|
||||||
|
expect(Object.keys(swarmB.muxedConns).length).to.equal(1)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial on protocol, reuse warmed conn', (done) => {
|
||||||
|
swarmA.handle('/papaia/1.0.0', (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
})
|
||||||
|
|
||||||
|
swarmB.dial(peerA, '/papaia/1.0.0', (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
expect(Object.keys(swarmB.conns).length).to.equal(0)
|
||||||
|
expect(Object.keys(swarmB.muxedConns).length).to.equal(1)
|
||||||
|
conn.end()
|
||||||
|
|
||||||
|
conn.on('data', () => {}) // let it flow.. let it flooooow
|
||||||
|
conn.on('end', done)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('enable identify to reuse incomming muxed conn', (done) => {
|
||||||
|
swarmA.connection.reuse()
|
||||||
|
swarmC.connection.reuse()
|
||||||
|
|
||||||
|
swarmC.dial(peerA, (err) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
setTimeout(() => {
|
||||||
|
expect(Object.keys(swarmC.muxedConns).length).to.equal(1)
|
||||||
|
expect(Object.keys(swarmA.muxedConns).length).to.equal(2)
|
||||||
|
done()
|
||||||
|
}, 500)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
})
|
138
test/05-muxing-spdy.node.js
Normal file
138
test/05-muxing-spdy.node.js
Normal file
@ -0,0 +1,138 @@
|
|||||||
|
/* eslint-env mocha */
|
||||||
|
'use strict'
|
||||||
|
|
||||||
|
const expect = require('chai').expect
|
||||||
|
|
||||||
|
const multiaddr = require('multiaddr')
|
||||||
|
const Peer = require('peer-info')
|
||||||
|
const Swarm = require('../src')
|
||||||
|
const TCP = require('libp2p-tcp')
|
||||||
|
const spdy = require('libp2p-spdy')
|
||||||
|
|
||||||
|
describe('stream muxing with spdy (on TCP)', function () {
|
||||||
|
this.timeout(20000)
|
||||||
|
|
||||||
|
var swarmA
|
||||||
|
var peerA
|
||||||
|
var swarmB
|
||||||
|
var peerB
|
||||||
|
var swarmC
|
||||||
|
var peerC
|
||||||
|
|
||||||
|
before((done) => {
|
||||||
|
peerA = new Peer()
|
||||||
|
peerB = new Peer()
|
||||||
|
peerC = new Peer()
|
||||||
|
|
||||||
|
// console.log('peer A', peerA.id.toB58String())
|
||||||
|
// console.log('peer B', peerB.id.toB58String())
|
||||||
|
// console.log('peer C', peerC.id.toB58String())
|
||||||
|
|
||||||
|
peerA.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9001'))
|
||||||
|
peerB.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9002'))
|
||||||
|
peerC.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9003'))
|
||||||
|
|
||||||
|
swarmA = new Swarm(peerA)
|
||||||
|
swarmB = new Swarm(peerB)
|
||||||
|
swarmC = new Swarm(peerC)
|
||||||
|
|
||||||
|
swarmA.transport.add('tcp', new TCP())
|
||||||
|
swarmA.transport.listen('tcp', {}, null, ready)
|
||||||
|
|
||||||
|
swarmB.transport.add('tcp', new TCP())
|
||||||
|
swarmB.transport.listen('tcp', {}, null, ready)
|
||||||
|
|
||||||
|
swarmC.transport.add('tcp', new TCP())
|
||||||
|
swarmC.transport.listen('tcp', {}, null, ready)
|
||||||
|
|
||||||
|
var counter = 0
|
||||||
|
|
||||||
|
function ready () {
|
||||||
|
if (++counter === 3) {
|
||||||
|
done()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
after((done) => {
|
||||||
|
var counter = 0
|
||||||
|
|
||||||
|
swarmA.close(closed)
|
||||||
|
swarmB.close(closed)
|
||||||
|
// swarmC.close(closed)
|
||||||
|
|
||||||
|
function closed () {
|
||||||
|
if (++counter === 2) {
|
||||||
|
done()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it('add', (done) => {
|
||||||
|
swarmA.connection.addStreamMuxer(spdy)
|
||||||
|
swarmB.connection.addStreamMuxer(spdy)
|
||||||
|
swarmC.connection.addStreamMuxer(spdy)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
|
||||||
|
it('handle + dial on protocol', (done) => {
|
||||||
|
swarmB.handle('/abacaxi/1.0.0', (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
})
|
||||||
|
|
||||||
|
swarmA.dial(peerB, '/abacaxi/1.0.0', (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
expect(Object.keys(swarmA.muxedConns).length).to.equal(1)
|
||||||
|
conn.end()
|
||||||
|
|
||||||
|
conn.on('data', () => {}) // let it flow.. let it flooooow
|
||||||
|
conn.on('end', done)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial to warm conn', (done) => {
|
||||||
|
swarmB.dial(peerA, (err) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
expect(Object.keys(swarmB.conns).length).to.equal(0)
|
||||||
|
expect(Object.keys(swarmB.muxedConns).length).to.equal(1)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial on protocol, reuse warmed conn', (done) => {
|
||||||
|
swarmA.handle('/papaia/1.0.0', (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
})
|
||||||
|
|
||||||
|
swarmB.dial(peerA, '/papaia/1.0.0', (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
expect(Object.keys(swarmB.conns).length).to.equal(0)
|
||||||
|
expect(Object.keys(swarmB.muxedConns).length).to.equal(1)
|
||||||
|
conn.end()
|
||||||
|
|
||||||
|
conn.on('data', () => {}) // let it flow.. let it flooooow
|
||||||
|
conn.on('end', done)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('enable identify to reuse incomming muxed conn', (done) => {
|
||||||
|
swarmA.connection.reuse()
|
||||||
|
swarmC.connection.reuse()
|
||||||
|
|
||||||
|
swarmC.dial(peerA, (err) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
setTimeout(() => {
|
||||||
|
expect(Object.keys(swarmC.muxedConns).length).to.equal(1)
|
||||||
|
expect(Object.keys(swarmA.muxedConns).length).to.equal(2)
|
||||||
|
done()
|
||||||
|
}, 500)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('close one end, make sure the other does not blow', (done) => {
|
||||||
|
swarmC.close(() => {
|
||||||
|
// to make sure it has time to propagate
|
||||||
|
setTimeout(done, 1000)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
})
|
13
test/06-conn-upgrade-secio.node.js
Normal file
13
test/06-conn-upgrade-secio.node.js
Normal file
@ -0,0 +1,13 @@
|
|||||||
|
/* eslint-env mocha */
|
||||||
|
'use strict'
|
||||||
|
|
||||||
|
describe('secio conn upgrade (on TCP)', function () {
|
||||||
|
this.timeout(20000)
|
||||||
|
|
||||||
|
before((done) => { done() })
|
||||||
|
after((done) => { done() })
|
||||||
|
|
||||||
|
it.skip('add', (done) => {})
|
||||||
|
it.skip('dial', (done) => {})
|
||||||
|
it.skip('tls on a muxed stream (not the full conn)', (done) => {})
|
||||||
|
})
|
11
test/07-conn-upgrade-tls.node.js
Normal file
11
test/07-conn-upgrade-tls.node.js
Normal file
@ -0,0 +1,11 @@
|
|||||||
|
/* eslint-env mocha */
|
||||||
|
'use strict'
|
||||||
|
|
||||||
|
describe('tls conn upgrade (on TCP)', function () {
|
||||||
|
before((done) => { done() })
|
||||||
|
after((done) => { done() })
|
||||||
|
|
||||||
|
it.skip('add', (done) => {})
|
||||||
|
it.skip('dial', (done) => {})
|
||||||
|
it.skip('tls on a muxed stream (not the full conn)', (done) => {})
|
||||||
|
})
|
113
test/08-swarm-without-muxing.node.js
Normal file
113
test/08-swarm-without-muxing.node.js
Normal file
@ -0,0 +1,113 @@
|
|||||||
|
/* eslint-env mocha */
|
||||||
|
'use strict'
|
||||||
|
|
||||||
|
const expect = require('chai').expect
|
||||||
|
|
||||||
|
const multiaddr = require('multiaddr')
|
||||||
|
const Peer = require('peer-info')
|
||||||
|
const Swarm = require('../src')
|
||||||
|
const TCP = require('libp2p-tcp')
|
||||||
|
|
||||||
|
describe('high level API - 1st without stream multiplexing (on TCP)', function () {
|
||||||
|
this.timeout(20000)
|
||||||
|
|
||||||
|
var swarmA
|
||||||
|
var peerA
|
||||||
|
var swarmB
|
||||||
|
var peerB
|
||||||
|
|
||||||
|
before((done) => {
|
||||||
|
peerA = new Peer()
|
||||||
|
peerB = new Peer()
|
||||||
|
|
||||||
|
peerA.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9001'))
|
||||||
|
peerB.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9002/ipfs/QmcgpsyWgH8Y8ajJz1Cu72KnS5uo2Aa2LpzU7kinSupNKC'))
|
||||||
|
|
||||||
|
swarmA = new Swarm(peerA)
|
||||||
|
swarmB = new Swarm(peerB)
|
||||||
|
|
||||||
|
swarmA.transport.add('tcp', new TCP())
|
||||||
|
swarmA.transport.listen('tcp', {}, null, ready)
|
||||||
|
|
||||||
|
swarmB.transport.add('tcp', new TCP())
|
||||||
|
swarmB.transport.listen('tcp', {}, null, ready)
|
||||||
|
|
||||||
|
var counter = 0
|
||||||
|
|
||||||
|
function ready () {
|
||||||
|
if (++counter === 2) {
|
||||||
|
done()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
after((done) => {
|
||||||
|
var counter = 0
|
||||||
|
|
||||||
|
swarmA.close(closed)
|
||||||
|
swarmB.close(closed)
|
||||||
|
|
||||||
|
function closed () {
|
||||||
|
if (++counter === 2) {
|
||||||
|
done()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it('handle a protocol', (done) => {
|
||||||
|
swarmB.handle('/bananas/1.0.0', (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
})
|
||||||
|
expect(Object.keys(swarmB.protocols).length).to.equal(1)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial on protocol', (done) => {
|
||||||
|
swarmB.handle('/pineapple/1.0.0', (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
})
|
||||||
|
|
||||||
|
swarmA.dial(peerB, '/pineapple/1.0.0', (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
conn.end()
|
||||||
|
conn.on('data', () => {}) // let it flow.. let it flooooow
|
||||||
|
conn.on('end', done)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial on protocol (returned conn)', (done) => {
|
||||||
|
swarmB.handle('/apples/1.0.0', (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
})
|
||||||
|
|
||||||
|
const conn = swarmA.dial(peerB, '/apples/1.0.0', (err) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
})
|
||||||
|
conn.end()
|
||||||
|
conn.on('data', () => {}) // let it flow.. let it flooooow
|
||||||
|
conn.on('end', done)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial to warm a conn', (done) => {
|
||||||
|
swarmA.dial(peerB, (err) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial on protocol, reuse warmed conn', (done) => {
|
||||||
|
swarmA.dial(peerB, '/bananas/1.0.0', (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
conn.end()
|
||||||
|
conn.on('data', () => {}) // let it flow.. let it flooooow
|
||||||
|
conn.on('end', done)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('unhandle', (done) => {
|
||||||
|
const proto = '/bananas/1.0.0'
|
||||||
|
swarmA.unhandle(proto)
|
||||||
|
expect(swarmA.protocols[proto]).to.not.exist
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
})
|
222
test/09-swarm-with-muxing.node.js
Normal file
222
test/09-swarm-with-muxing.node.js
Normal file
@ -0,0 +1,222 @@
|
|||||||
|
/* eslint-env mocha */
|
||||||
|
'use strict'
|
||||||
|
|
||||||
|
const expect = require('chai').expect
|
||||||
|
|
||||||
|
const multiaddr = require('multiaddr')
|
||||||
|
const Peer = require('peer-info')
|
||||||
|
const Swarm = require('../src')
|
||||||
|
const TCP = require('libp2p-tcp')
|
||||||
|
const WebSockets = require('libp2p-websockets')
|
||||||
|
const spdy = require('libp2p-spdy')
|
||||||
|
|
||||||
|
describe('high level API - with everything mixed all together!', function () {
|
||||||
|
this.timeout(100000)
|
||||||
|
|
||||||
|
var swarmA // tcp
|
||||||
|
var peerA
|
||||||
|
var swarmB // tcp+ws
|
||||||
|
var peerB
|
||||||
|
var swarmC // tcp+ws
|
||||||
|
var peerC
|
||||||
|
var swarmD // ws
|
||||||
|
var peerD
|
||||||
|
var swarmE // ws
|
||||||
|
var peerE
|
||||||
|
|
||||||
|
before((done) => {
|
||||||
|
peerA = new Peer()
|
||||||
|
peerB = new Peer()
|
||||||
|
peerC = new Peer()
|
||||||
|
peerD = new Peer()
|
||||||
|
peerE = new Peer()
|
||||||
|
|
||||||
|
// console.log('peer A', peerA.id.toB58String())
|
||||||
|
// console.log('peer B', peerB.id.toB58String())
|
||||||
|
// console.log('peer C', peerC.id.toB58String())
|
||||||
|
|
||||||
|
swarmA = new Swarm(peerA)
|
||||||
|
swarmB = new Swarm(peerB)
|
||||||
|
swarmC = new Swarm(peerC)
|
||||||
|
swarmD = new Swarm(peerD)
|
||||||
|
swarmE = new Swarm(peerE)
|
||||||
|
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
|
||||||
|
after((done) => {
|
||||||
|
var counter = 0
|
||||||
|
|
||||||
|
swarmA.close(closed)
|
||||||
|
swarmB.close(closed)
|
||||||
|
// swarmC.close(closed)
|
||||||
|
swarmD.close(closed)
|
||||||
|
swarmE.close(closed)
|
||||||
|
|
||||||
|
function closed () {
|
||||||
|
if (++counter === 4) {
|
||||||
|
done()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it('add tcp', (done) => {
|
||||||
|
peerA.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/0'))
|
||||||
|
peerB.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/0'))
|
||||||
|
peerC.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/0'))
|
||||||
|
|
||||||
|
swarmA.transport.add('tcp', new TCP())
|
||||||
|
swarmA.transport.listen('tcp', {}, null, ready)
|
||||||
|
|
||||||
|
swarmB.transport.add('tcp', new TCP())
|
||||||
|
swarmB.transport.listen('tcp', {}, null, ready)
|
||||||
|
|
||||||
|
swarmC.transport.add('tcp', new TCP())
|
||||||
|
swarmC.transport.listen('tcp', {}, null, ready)
|
||||||
|
|
||||||
|
var counter = 0
|
||||||
|
|
||||||
|
function ready () {
|
||||||
|
if (++counter === 3) {
|
||||||
|
done()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it.skip('add utp', (done) => {})
|
||||||
|
|
||||||
|
it('add websockets', (done) => {
|
||||||
|
peerB.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9012/websockets'))
|
||||||
|
peerC.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9022/websockets'))
|
||||||
|
peerD.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9032/websockets'))
|
||||||
|
peerE.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9042/websockets'))
|
||||||
|
|
||||||
|
swarmB.transport.add('ws', new WebSockets())
|
||||||
|
swarmB.transport.listen('ws', {}, null, ready)
|
||||||
|
|
||||||
|
swarmC.transport.add('ws', new WebSockets())
|
||||||
|
swarmC.transport.listen('ws', {}, null, ready)
|
||||||
|
|
||||||
|
swarmD.transport.add('ws', new WebSockets())
|
||||||
|
swarmD.transport.listen('ws', {}, null, ready)
|
||||||
|
|
||||||
|
swarmE.transport.add('ws', new WebSockets())
|
||||||
|
swarmE.transport.listen('ws', {}, null, ready)
|
||||||
|
|
||||||
|
var counter = 0
|
||||||
|
|
||||||
|
function ready () {
|
||||||
|
if (++counter === 4) {
|
||||||
|
done()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it('add spdy', (done) => {
|
||||||
|
swarmA.connection.addStreamMuxer(spdy)
|
||||||
|
swarmB.connection.addStreamMuxer(spdy)
|
||||||
|
swarmC.connection.addStreamMuxer(spdy)
|
||||||
|
swarmD.connection.addStreamMuxer(spdy)
|
||||||
|
swarmE.connection.addStreamMuxer(spdy)
|
||||||
|
|
||||||
|
swarmA.connection.reuse()
|
||||||
|
swarmB.connection.reuse()
|
||||||
|
swarmC.connection.reuse()
|
||||||
|
swarmD.connection.reuse()
|
||||||
|
swarmE.connection.reuse()
|
||||||
|
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
|
||||||
|
it.skip('add multiplex', (done) => {})
|
||||||
|
|
||||||
|
it('dial from tcp to tcp+ws', (done) => {
|
||||||
|
swarmB.handle('/anona/1.0.0', (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
})
|
||||||
|
|
||||||
|
swarmB.once('peer-mux-established', (peerInfo) => {
|
||||||
|
expect(peerInfo.id.toB58String()).to.equal(peerA.id.toB58String())
|
||||||
|
})
|
||||||
|
|
||||||
|
swarmA.once('peer-mux-established', (peerInfo) => {
|
||||||
|
expect(peerInfo.id.toB58String()).to.equal(peerB.id.toB58String())
|
||||||
|
})
|
||||||
|
|
||||||
|
swarmA.dial(peerB, '/anona/1.0.0', (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
expect(Object.keys(swarmA.muxedConns).length).to.equal(1)
|
||||||
|
conn.end()
|
||||||
|
|
||||||
|
conn.on('data', () => {}) // let it flow.. let it flooooow
|
||||||
|
conn.on('end', done)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial from ws to ws no proto', (done) => {
|
||||||
|
swarmD.dial(peerE, (err) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
expect(Object.keys(swarmD.muxedConns).length).to.equal(1)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial from ws to ws', (done) => {
|
||||||
|
swarmE.handle('/abacaxi/1.0.0', (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
})
|
||||||
|
|
||||||
|
swarmD.dial(peerE, '/abacaxi/1.0.0', (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
expect(Object.keys(swarmD.muxedConns).length).to.equal(1)
|
||||||
|
|
||||||
|
conn.end()
|
||||||
|
conn.on('data', () => {}) // let it flow.. let it flooooow
|
||||||
|
conn.on('end', () => {
|
||||||
|
setTimeout(() => {
|
||||||
|
expect(Object.keys(swarmE.muxedConns).length).to.equal(1)
|
||||||
|
done()
|
||||||
|
}, 1000)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial from tcp to tcp+ws (returned conn)', (done) => {
|
||||||
|
swarmB.handle('/grapes/1.0.0', (conn) => {
|
||||||
|
conn.pipe(conn)
|
||||||
|
})
|
||||||
|
|
||||||
|
const conn = swarmA.dial(peerB, '/grapes/1.0.0', (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
expect(Object.keys(swarmA.muxedConns).length).to.equal(1)
|
||||||
|
})
|
||||||
|
conn.end()
|
||||||
|
|
||||||
|
conn.on('data', () => {}) // let it flow.. let it flooooow
|
||||||
|
conn.on('end', done)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial from tcp+ws to tcp+ws', (done) => {
|
||||||
|
swarmC.handle('/mamao/1.0.0', (conn) => {
|
||||||
|
expect(conn.peerId).to.exist
|
||||||
|
conn.pipe(conn)
|
||||||
|
})
|
||||||
|
|
||||||
|
swarmA.dial(peerC, '/mamao/1.0.0', (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
expect(conn.peerId).to.exist
|
||||||
|
expect(Object.keys(swarmA.muxedConns).length).to.equal(2)
|
||||||
|
conn.end()
|
||||||
|
|
||||||
|
conn.on('data', () => {}) // let it flow.. let it flooooow
|
||||||
|
conn.on('end', done)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('close a muxer emits event', (done) => {
|
||||||
|
swarmC.close(() => {})
|
||||||
|
swarmA.once('peer-mux-closed', (peerInfo) => {
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
})
|
||||||
|
})
|
125
test/browser.js
Normal file
125
test/browser.js
Normal file
@ -0,0 +1,125 @@
|
|||||||
|
/* eslint-env mocha */
|
||||||
|
'use strict'
|
||||||
|
|
||||||
|
const expect = require('chai').expect
|
||||||
|
const multiaddr = require('multiaddr')
|
||||||
|
const Id = require('peer-id')
|
||||||
|
const Peer = require('peer-info')
|
||||||
|
const WebSockets = require('libp2p-websockets')
|
||||||
|
const bl = require('bl')
|
||||||
|
|
||||||
|
const Swarm = require('../src')
|
||||||
|
|
||||||
|
describe('basics', () => {
|
||||||
|
it('throws on missing peerInfo', (done) => {
|
||||||
|
expect(Swarm).to.throw(Error)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
describe('transport - websockets', function () {
|
||||||
|
this.timeout(10000)
|
||||||
|
|
||||||
|
var swarm
|
||||||
|
|
||||||
|
before((done) => {
|
||||||
|
const b58IdSrc = 'QmYzgdesgjdvD3okTPGZT9NPmh1BuH5FfTVNKjsvaAprhb'
|
||||||
|
// use a pre generated Id to save time
|
||||||
|
const idSrc = Id.createFromB58String(b58IdSrc)
|
||||||
|
const peerSrc = new Peer(idSrc)
|
||||||
|
swarm = new Swarm(peerSrc)
|
||||||
|
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
|
||||||
|
it('add', (done) => {
|
||||||
|
swarm.transport.add('ws', new WebSockets(), () => {
|
||||||
|
expect(Object.keys(swarm.transports).length).to.equal(1)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial', (done) => {
|
||||||
|
const ma = multiaddr('/ip4/127.0.0.1/tcp/9100/websockets')
|
||||||
|
|
||||||
|
const conn = swarm.transport.dial('ws', ma, (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
})
|
||||||
|
|
||||||
|
conn.pipe(bl((err, data) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
expect(data.toString()).to.equal('hey')
|
||||||
|
done()
|
||||||
|
}))
|
||||||
|
conn.write('hey')
|
||||||
|
conn.end()
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
describe('high level API - 1st without stream multiplexing (on websockets)', function () {
|
||||||
|
this.timeout(10000)
|
||||||
|
|
||||||
|
var swarm
|
||||||
|
var peerDst
|
||||||
|
|
||||||
|
before((done) => {
|
||||||
|
const b58IdSrc = 'QmYzgdesgjdvD3okTPGZT9NPmh1BuH5FfTVNKjsvaAprhb'
|
||||||
|
// use a pre generated Id to save time
|
||||||
|
const idSrc = Id.createFromB58String(b58IdSrc)
|
||||||
|
const peerSrc = new Peer(idSrc)
|
||||||
|
swarm = new Swarm(peerSrc)
|
||||||
|
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
|
||||||
|
after((done) => {
|
||||||
|
done()
|
||||||
|
// swarm.close(done)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('add ws', (done) => {
|
||||||
|
swarm.transport.add('ws', new WebSockets())
|
||||||
|
expect(Object.keys(swarm.transports).length).to.equal(1)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
|
||||||
|
it('create Dst peer info', (done) => {
|
||||||
|
const b58IdDst = 'QmYzgdesgjdvD3okTPGZT9NPmh1BuH5FfTVNKjsvaAprhb'
|
||||||
|
// use a pre generated Id to save time
|
||||||
|
const idDst = Id.createFromB58String(b58IdDst)
|
||||||
|
peerDst = new Peer(idDst)
|
||||||
|
|
||||||
|
const ma = multiaddr('/ip4/127.0.0.1/tcp/9200/websockets')
|
||||||
|
peerDst.multiaddr.add(ma)
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial on protocol', (done) => {
|
||||||
|
swarm.dial(peerDst, '/echo/1.0.0', (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
conn.pipe(bl((err, data) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
expect(data.toString()).to.equal('hey')
|
||||||
|
done()
|
||||||
|
}))
|
||||||
|
conn.write('hey')
|
||||||
|
conn.end()
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial to warm a conn', (done) => {
|
||||||
|
swarm.dial(peerDst, (err) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial on protocol, reuse warmed conn', (done) => {
|
||||||
|
swarm.dial(peerDst, '/echo/1.0.0', (err, conn) => {
|
||||||
|
expect(err).to.not.exist
|
||||||
|
conn.end()
|
||||||
|
conn.on('data', () => {}) // let it flow.. let it flooooow
|
||||||
|
conn.on('end', done)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
})
|
12
test/node.js
Normal file
12
test/node.js
Normal file
@ -0,0 +1,12 @@
|
|||||||
|
/* eslint-env mocha */
|
||||||
|
'use strict'
|
||||||
|
|
||||||
|
const fs = require('fs')
|
||||||
|
|
||||||
|
describe('libp2p-swarm', () => {
|
||||||
|
fs.readdirSync(__dirname)
|
||||||
|
.filter((file) => file.match(/\.node\.js$/))
|
||||||
|
.forEach((file) => {
|
||||||
|
require(`./${file}`)
|
||||||
|
})
|
||||||
|
})
|
@ -1,507 +0,0 @@
|
|||||||
/* eslint-env mocha */
|
|
||||||
|
|
||||||
const expect = require('chai').expect
|
|
||||||
// const async = require('async')
|
|
||||||
|
|
||||||
const multiaddr = require('multiaddr')
|
|
||||||
// const Id = require('peer-id')
|
|
||||||
const Peer = require('peer-info')
|
|
||||||
const Swarm = require('../src')
|
|
||||||
const TCP = require('libp2p-tcp')
|
|
||||||
const WebSockets = require('libp2p-websockets')
|
|
||||||
const bl = require('bl')
|
|
||||||
const spdy = require('libp2p-spdy')
|
|
||||||
|
|
||||||
describe('basics', () => {
|
|
||||||
it('throws on missing peerInfo', (done) => {
|
|
||||||
expect(Swarm).to.throw(Error)
|
|
||||||
done()
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
describe('transport - tcp', function () {
|
|
||||||
this.timeout(10000)
|
|
||||||
|
|
||||||
var swarmA
|
|
||||||
var swarmB
|
|
||||||
var peerA = new Peer()
|
|
||||||
var peerB = new Peer()
|
|
||||||
|
|
||||||
before((done) => {
|
|
||||||
peerA.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9888'))
|
|
||||||
peerB.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9999'))
|
|
||||||
swarmA = new Swarm(peerA)
|
|
||||||
swarmB = new Swarm(peerB)
|
|
||||||
done()
|
|
||||||
})
|
|
||||||
|
|
||||||
it('add', (done) => {
|
|
||||||
swarmA.transport.add('tcp', new TCP())
|
|
||||||
expect(Object.keys(swarmA.transports).length).to.equal(1)
|
|
||||||
swarmB.transport.add('tcp', new TCP(), () => {
|
|
||||||
expect(Object.keys(swarmB.transports).length).to.equal(1)
|
|
||||||
done()
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('listen', (done) => {
|
|
||||||
var count = 0
|
|
||||||
swarmA.transport.listen('tcp', {}, (conn) => {
|
|
||||||
conn.pipe(conn)
|
|
||||||
}, ready)
|
|
||||||
swarmB.transport.listen('tcp', {}, (conn) => {
|
|
||||||
conn.pipe(conn)
|
|
||||||
}, ready)
|
|
||||||
|
|
||||||
function ready () {
|
|
||||||
if (++count === 2) {
|
|
||||||
expect(peerA.multiaddrs.length).to.equal(1)
|
|
||||||
expect(peerA.multiaddrs[0]).to.deep.equal(multiaddr('/ip4/127.0.0.1/tcp/9888'))
|
|
||||||
expect(peerB.multiaddrs.length).to.equal(1)
|
|
||||||
expect(peerB.multiaddrs[0]).to.deep.equal(multiaddr('/ip4/127.0.0.1/tcp/9999'))
|
|
||||||
done()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
it('dial to a multiaddr', (done) => {
|
|
||||||
const conn = swarmA.transport.dial('tcp', multiaddr('/ip4/127.0.0.1/tcp/9999'), (err, conn) => {
|
|
||||||
expect(err).to.not.exist
|
|
||||||
})
|
|
||||||
conn.pipe(bl((err, data) => {
|
|
||||||
expect(err).to.not.exist
|
|
||||||
done()
|
|
||||||
}))
|
|
||||||
conn.write('hey')
|
|
||||||
conn.end()
|
|
||||||
})
|
|
||||||
|
|
||||||
it('dial to set of multiaddr, only one is available', (done) => {
|
|
||||||
const conn = swarmA.transport.dial('tcp', [
|
|
||||||
multiaddr('/ip4/127.0.0.1/tcp/9910/websockets'), // not valid on purpose
|
|
||||||
multiaddr('/ip4/127.0.0.1/tcp/9910'),
|
|
||||||
multiaddr('/ip4/127.0.0.1/tcp/9999'),
|
|
||||||
multiaddr('/ip4/127.0.0.1/tcp/9309')
|
|
||||||
], (err, conn) => {
|
|
||||||
expect(err).to.not.exist
|
|
||||||
})
|
|
||||||
conn.pipe(bl((err, data) => {
|
|
||||||
expect(err).to.not.exist
|
|
||||||
done()
|
|
||||||
}))
|
|
||||||
conn.write('hey')
|
|
||||||
conn.end()
|
|
||||||
})
|
|
||||||
|
|
||||||
it('close', (done) => {
|
|
||||||
var count = 0
|
|
||||||
swarmA.transport.close('tcp', closed)
|
|
||||||
swarmB.transport.close('tcp', closed)
|
|
||||||
|
|
||||||
function closed () {
|
|
||||||
if (++count === 2) {
|
|
||||||
done()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
it('support port 0', (done) => {
|
|
||||||
var swarm
|
|
||||||
var peer = new Peer()
|
|
||||||
peer.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/0'))
|
|
||||||
swarm = new Swarm(peer)
|
|
||||||
swarm.transport.add('tcp', new TCP())
|
|
||||||
swarm.transport.listen('tcp', {}, (conn) => {
|
|
||||||
conn.pipe(conn)
|
|
||||||
}, ready)
|
|
||||||
|
|
||||||
function ready () {
|
|
||||||
expect(peer.multiaddrs.length).to.equal(1)
|
|
||||||
expect(peer.multiaddrs[0]).to.not.deep.equal(multiaddr('/ip4/127.0.0.1/tcp/0'))
|
|
||||||
swarm.close(done)
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
it('support addr /ip4/0.0.0.0/tcp/9050', (done) => {
|
|
||||||
var swarm
|
|
||||||
var peer = new Peer()
|
|
||||||
peer.multiaddr.add(multiaddr('/ip4/0.0.0.0/tcp/9050'))
|
|
||||||
swarm = new Swarm(peer)
|
|
||||||
swarm.transport.add('tcp', new TCP())
|
|
||||||
swarm.transport.listen('tcp', {}, (conn) => {
|
|
||||||
conn.pipe(conn)
|
|
||||||
}, ready)
|
|
||||||
|
|
||||||
function ready () {
|
|
||||||
expect(peer.multiaddrs.length).to.equal(1)
|
|
||||||
expect(peer.multiaddrs[0]).to.deep.equal(multiaddr('/ip4/0.0.0.0/tcp/9050'))
|
|
||||||
swarm.close(done)
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
it('support addr /ip4/0.0.0.0/tcp/0', (done) => {
|
|
||||||
var swarm
|
|
||||||
var peer = new Peer()
|
|
||||||
peer.multiaddr.add(multiaddr('/ip4/0.0.0.0/tcp/0'))
|
|
||||||
swarm = new Swarm(peer)
|
|
||||||
swarm.transport.add('tcp', new TCP())
|
|
||||||
swarm.transport.listen('tcp', {}, (conn) => {
|
|
||||||
conn.pipe(conn)
|
|
||||||
}, ready)
|
|
||||||
|
|
||||||
function ready () {
|
|
||||||
expect(peer.multiaddrs.length).to.equal(1)
|
|
||||||
expect(peer.multiaddrs[0]).to.not.deep.equal(multiaddr('/ip4/0.0.0.0/tcp/0'))
|
|
||||||
swarm.close(done)
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
it('listen in several addrs', (done) => {
|
|
||||||
var swarm
|
|
||||||
var peer = new Peer()
|
|
||||||
peer.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9001'))
|
|
||||||
peer.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9002'))
|
|
||||||
peer.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9003'))
|
|
||||||
swarm = new Swarm(peer)
|
|
||||||
swarm.transport.add('tcp', new TCP())
|
|
||||||
swarm.transport.listen('tcp', {}, (conn) => {
|
|
||||||
conn.pipe(conn)
|
|
||||||
}, ready)
|
|
||||||
|
|
||||||
function ready () {
|
|
||||||
expect(peer.multiaddrs.length).to.equal(3)
|
|
||||||
swarm.close(done)
|
|
||||||
}
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
describe('transport - websockets', function () {
|
|
||||||
this.timeout(10000)
|
|
||||||
|
|
||||||
var swarmA
|
|
||||||
var swarmB
|
|
||||||
var peerA = new Peer()
|
|
||||||
var peerB = new Peer()
|
|
||||||
|
|
||||||
before((done) => {
|
|
||||||
peerA.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9888/websockets'))
|
|
||||||
peerB.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9999/websockets'))
|
|
||||||
swarmA = new Swarm(peerA)
|
|
||||||
swarmB = new Swarm(peerB)
|
|
||||||
done()
|
|
||||||
})
|
|
||||||
|
|
||||||
it('add', (done) => {
|
|
||||||
swarmA.transport.add('ws', new WebSockets())
|
|
||||||
expect(Object.keys(swarmA.transports).length).to.equal(1)
|
|
||||||
swarmB.transport.add('ws', new WebSockets(), () => {
|
|
||||||
expect(Object.keys(swarmB.transports).length).to.equal(1)
|
|
||||||
done()
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('listen', (done) => {
|
|
||||||
var count = 0
|
|
||||||
swarmA.transport.listen('ws', {}, (conn) => {
|
|
||||||
conn.pipe(conn)
|
|
||||||
}, ready)
|
|
||||||
swarmB.transport.listen('ws', {}, (conn) => {
|
|
||||||
conn.pipe(conn)
|
|
||||||
}, ready)
|
|
||||||
|
|
||||||
function ready () {
|
|
||||||
if (++count === 2) {
|
|
||||||
expect(peerA.multiaddrs.length).to.equal(1)
|
|
||||||
expect(peerA.multiaddrs[0]).to.deep.equal(multiaddr('/ip4/127.0.0.1/tcp/9888/websockets'))
|
|
||||||
expect(peerB.multiaddrs.length).to.equal(1)
|
|
||||||
expect(peerB.multiaddrs[0]).to.deep.equal(multiaddr('/ip4/127.0.0.1/tcp/9999/websockets'))
|
|
||||||
done()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
it('dial', (done) => {
|
|
||||||
const conn = swarmA.transport.dial('ws', multiaddr('/ip4/127.0.0.1/tcp/9999/websockets'), (err, conn) => {
|
|
||||||
expect(err).to.not.exist
|
|
||||||
})
|
|
||||||
conn.pipe(bl((err, data) => {
|
|
||||||
expect(err).to.not.exist
|
|
||||||
done()
|
|
||||||
}))
|
|
||||||
conn.write('hey')
|
|
||||||
conn.end()
|
|
||||||
})
|
|
||||||
|
|
||||||
it('close', (done) => {
|
|
||||||
var count = 0
|
|
||||||
swarmA.transport.close('ws', closed)
|
|
||||||
swarmB.transport.close('ws', closed)
|
|
||||||
|
|
||||||
function closed () {
|
|
||||||
if (++count === 2) {
|
|
||||||
done()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
describe('transport - utp', function () {
|
|
||||||
this.timeout(10000)
|
|
||||||
|
|
||||||
before((done) => { done() })
|
|
||||||
|
|
||||||
it.skip('add', (done) => {})
|
|
||||||
it.skip('listen', (done) => {})
|
|
||||||
it.skip('dial', (done) => {})
|
|
||||||
it.skip('close', (done) => {})
|
|
||||||
})
|
|
||||||
|
|
||||||
describe('high level API - 1st without stream multiplexing (on TCP)', function () {
|
|
||||||
this.timeout(20000)
|
|
||||||
|
|
||||||
var swarmA
|
|
||||||
var peerA
|
|
||||||
var swarmB
|
|
||||||
var peerB
|
|
||||||
|
|
||||||
before((done) => {
|
|
||||||
peerA = new Peer()
|
|
||||||
peerB = new Peer()
|
|
||||||
|
|
||||||
peerA.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9001'))
|
|
||||||
peerB.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9002'))
|
|
||||||
|
|
||||||
swarmA = new Swarm(peerA)
|
|
||||||
swarmB = new Swarm(peerB)
|
|
||||||
|
|
||||||
swarmA.transport.add('tcp', new TCP())
|
|
||||||
swarmA.transport.listen('tcp', {}, null, ready)
|
|
||||||
|
|
||||||
swarmB.transport.add('tcp', new TCP())
|
|
||||||
swarmB.transport.listen('tcp', {}, null, ready)
|
|
||||||
|
|
||||||
var counter = 0
|
|
||||||
|
|
||||||
function ready () {
|
|
||||||
if (++counter === 2) {
|
|
||||||
done()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
after((done) => {
|
|
||||||
var counter = 0
|
|
||||||
|
|
||||||
swarmA.close(closed)
|
|
||||||
swarmB.close(closed)
|
|
||||||
|
|
||||||
function closed () {
|
|
||||||
if (++counter === 2) {
|
|
||||||
done()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
it('handle a protocol', (done) => {
|
|
||||||
swarmB.handle('/bananas/1.0.0', (conn) => {
|
|
||||||
conn.pipe(conn)
|
|
||||||
})
|
|
||||||
expect(Object.keys(swarmB.protocols).length).to.equal(1)
|
|
||||||
done()
|
|
||||||
})
|
|
||||||
|
|
||||||
it('dial on protocol', (done) => {
|
|
||||||
swarmB.handle('/pineapple/1.0.0', (conn) => {
|
|
||||||
conn.pipe(conn)
|
|
||||||
})
|
|
||||||
|
|
||||||
swarmA.dial(peerB, '/pineapple/1.0.0', (err, conn) => {
|
|
||||||
expect(err).to.not.exist
|
|
||||||
conn.end()
|
|
||||||
conn.on('data', () => {}) // let it flow.. let it flooooow
|
|
||||||
conn.on('end', done)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('dial to warm a conn', (done) => {
|
|
||||||
swarmA.dial(peerB, (err) => {
|
|
||||||
expect(err).to.not.exist
|
|
||||||
done()
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('dial on protocol, reuse warmed conn', (done) => {
|
|
||||||
swarmA.dial(peerB, '/bananas/1.0.0', (err, conn) => {
|
|
||||||
expect(err).to.not.exist
|
|
||||||
conn.end()
|
|
||||||
conn.on('data', () => {}) // let it flow.. let it flooooow
|
|
||||||
conn.on('end', done)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
describe('stream muxing (on TCP)', function () {
|
|
||||||
this.timeout(20000)
|
|
||||||
|
|
||||||
describe('multiplex', () => {
|
|
||||||
before((done) => { done() })
|
|
||||||
after((done) => { done() })
|
|
||||||
|
|
||||||
it.skip('add', (done) => {})
|
|
||||||
it.skip('handle + dial on protocol', (done) => {})
|
|
||||||
it.skip('dial to warm conn', (done) => {})
|
|
||||||
it.skip('dial on protocol, reuse warmed conn', (done) => {})
|
|
||||||
it.skip('enable identify to reuse incomming muxed conn', (done) => {})
|
|
||||||
})
|
|
||||||
describe('spdy', () => {
|
|
||||||
var swarmA
|
|
||||||
var peerA
|
|
||||||
var swarmB
|
|
||||||
var peerB
|
|
||||||
var swarmC
|
|
||||||
var peerC
|
|
||||||
|
|
||||||
before((done) => {
|
|
||||||
peerA = new Peer()
|
|
||||||
peerB = new Peer()
|
|
||||||
peerC = new Peer()
|
|
||||||
|
|
||||||
// console.log('peer A', peerA.id.toB58String())
|
|
||||||
// console.log('peer B', peerB.id.toB58String())
|
|
||||||
// console.log('peer C', peerC.id.toB58String())
|
|
||||||
|
|
||||||
peerA.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9001'))
|
|
||||||
peerB.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9002'))
|
|
||||||
peerC.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/9003'))
|
|
||||||
|
|
||||||
swarmA = new Swarm(peerA)
|
|
||||||
swarmB = new Swarm(peerB)
|
|
||||||
swarmC = new Swarm(peerC)
|
|
||||||
|
|
||||||
swarmA.transport.add('tcp', new TCP())
|
|
||||||
swarmA.transport.listen('tcp', {}, null, ready)
|
|
||||||
|
|
||||||
swarmB.transport.add('tcp', new TCP())
|
|
||||||
swarmB.transport.listen('tcp', {}, null, ready)
|
|
||||||
|
|
||||||
swarmC.transport.add('tcp', new TCP())
|
|
||||||
swarmC.transport.listen('tcp', {}, null, ready)
|
|
||||||
|
|
||||||
var counter = 0
|
|
||||||
|
|
||||||
function ready () {
|
|
||||||
if (++counter === 3) {
|
|
||||||
done()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
after((done) => {
|
|
||||||
var counter = 0
|
|
||||||
|
|
||||||
swarmA.close(closed)
|
|
||||||
swarmB.close(closed)
|
|
||||||
swarmC.close(closed)
|
|
||||||
|
|
||||||
function closed () {
|
|
||||||
if (++counter === 3) {
|
|
||||||
done()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
it('add', (done) => {
|
|
||||||
swarmA.connection.addStreamMuxer(spdy)
|
|
||||||
swarmB.connection.addStreamMuxer(spdy)
|
|
||||||
swarmC.connection.addStreamMuxer(spdy)
|
|
||||||
done()
|
|
||||||
})
|
|
||||||
|
|
||||||
it('handle + dial on protocol', (done) => {
|
|
||||||
swarmB.handle('/abacaxi/1.0.0', (conn) => {
|
|
||||||
conn.pipe(conn)
|
|
||||||
})
|
|
||||||
|
|
||||||
swarmA.dial(peerB, '/abacaxi/1.0.0', (err, conn) => {
|
|
||||||
expect(err).to.not.exist
|
|
||||||
expect(Object.keys(swarmA.muxedConns).length).to.equal(1)
|
|
||||||
conn.end()
|
|
||||||
|
|
||||||
conn.on('data', () => {}) // let it flow.. let it flooooow
|
|
||||||
conn.on('end', done)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('dial to warm conn', (done) => {
|
|
||||||
swarmB.dial(peerA, (err) => {
|
|
||||||
expect(err).to.not.exist
|
|
||||||
expect(Object.keys(swarmB.conns).length).to.equal(0)
|
|
||||||
expect(Object.keys(swarmB.muxedConns).length).to.equal(1)
|
|
||||||
done()
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('dial on protocol, reuse warmed conn', (done) => {
|
|
||||||
swarmA.handle('/papaia/1.0.0', (conn) => {
|
|
||||||
conn.pipe(conn)
|
|
||||||
})
|
|
||||||
|
|
||||||
swarmB.dial(peerA, '/papaia/1.0.0', (err, conn) => {
|
|
||||||
expect(err).to.not.exist
|
|
||||||
expect(Object.keys(swarmB.conns).length).to.equal(0)
|
|
||||||
expect(Object.keys(swarmB.muxedConns).length).to.equal(1)
|
|
||||||
conn.end()
|
|
||||||
|
|
||||||
conn.on('data', () => {}) // let it flow.. let it flooooow
|
|
||||||
conn.on('end', done)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('enable identify to reuse incomming muxed conn', (done) => {
|
|
||||||
swarmA.connection.reuse()
|
|
||||||
swarmC.connection.reuse()
|
|
||||||
|
|
||||||
swarmC.dial(peerA, (err) => {
|
|
||||||
expect(err).to.not.exist
|
|
||||||
setTimeout(() => {
|
|
||||||
expect(Object.keys(swarmC.muxedConns).length).to.equal(1)
|
|
||||||
expect(Object.keys(swarmA.muxedConns).length).to.equal(2)
|
|
||||||
done()
|
|
||||||
}, 500)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
describe('conn upgrades', function () {
|
|
||||||
this.timeout(20000)
|
|
||||||
|
|
||||||
describe('secio on tcp', () => {
|
|
||||||
// before((done) => { done() })
|
|
||||||
// after((done) => { done() })
|
|
||||||
|
|
||||||
it.skip('add', (done) => {})
|
|
||||||
it.skip('dial', (done) => {})
|
|
||||||
it.skip('tls on a muxed stream (not the full conn)', (done) => {})
|
|
||||||
})
|
|
||||||
describe('tls on tcp', () => {
|
|
||||||
// before((done) => { done() })
|
|
||||||
// after((done) => { done() })
|
|
||||||
|
|
||||||
it.skip('add', (done) => {})
|
|
||||||
it.skip('dial', (done) => {})
|
|
||||||
it.skip('tls on a muxed stream (not the full conn)', (done) => {})
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
describe('high level API - with everything mixed all together!', function () {
|
|
||||||
this.timeout(20000)
|
|
||||||
|
|
||||||
// before((done) => { done() })
|
|
||||||
// after((done) => { done() })
|
|
||||||
|
|
||||||
it.skip('add tcp', (done) => {})
|
|
||||||
it.skip('add utp', (done) => {})
|
|
||||||
it.skip('add websockets', (done) => {})
|
|
||||||
it.skip('dial', (done) => {})
|
|
||||||
})
|
|
29552
vendor/forge.bundle.js
vendored
Normal file
29552
vendor/forge.bundle.js
vendored
Normal file
File diff suppressed because it is too large
Load Diff
Reference in New Issue
Block a user