mirror of
https://github.com/fluencelabs/js-libp2p-tcp
synced 2025-07-01 15:21:50 +00:00
Compare commits
34 Commits
v0.12.0
...
fix/interf
| Author | SHA1 | Date | |
|---|---|---|---|
| 99f237bba1 | |||
| 6f04526083 | |||
| d65f3ce228 | |||
| 0d1c454ce0 | |||
| 3b162207b0 | |||
| 1c6500141b | |||
| fb50de5cc6 | |||
| 4a86c353e0 | |||
| a96c612071 | |||
| 1c1dfa65d3 | |||
| 1a2fd636eb | |||
| fb206cfd66 | |||
| ff9123d53c | |||
| c60897fbd8 | |||
| bba2084476 | |||
| d5be5ba7ed | |||
| b977a59fb8 | |||
| 5c8c6afea6 | |||
| e18a3d51a6 | |||
| bc1aeefd0d | |||
| 49c7f33375 | |||
| 89bceb461f | |||
| 44f9e32d07 | |||
| c26cc70c65 | |||
| 3ab43a3604 | |||
| 3aad2ed243 | |||
| 01cfbda2e7 | |||
| eba0b48744 | |||
| a0c23e49f7 | |||
| 66ab208182 | |||
| 168d111158 | |||
| 4b04b17dfa | |||
| 6c36a46831 | |||
| d39ec2db40 |
1
.gitignore
vendored
1
.gitignore
vendored
@ -12,6 +12,7 @@ logs
|
||||
*.log
|
||||
|
||||
coverage
|
||||
.nyc_output
|
||||
|
||||
# Runtime data
|
||||
pids
|
||||
|
||||
52
.travis.yml
52
.travis.yml
@ -1,32 +1,34 @@
|
||||
# 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
|
||||
cache: npm
|
||||
sudo: false
|
||||
|
||||
matrix:
|
||||
include:
|
||||
- node_js: 6
|
||||
env: CXX=g++-4.8
|
||||
- node_js: 8
|
||||
env: CXX=g++-4.8
|
||||
# - node_js: stable
|
||||
# env: CXX=g++-4.8
|
||||
stages:
|
||||
- check
|
||||
- test
|
||||
- cov
|
||||
|
||||
script:
|
||||
- npm run lint
|
||||
- npm run test
|
||||
- npm run coverage
|
||||
node_js:
|
||||
- '10'
|
||||
- '12'
|
||||
|
||||
os:
|
||||
- linux
|
||||
- osx
|
||||
- windows
|
||||
|
||||
before_script:
|
||||
- export DISPLAY=:99.0
|
||||
- sh -e /etc/init.d/xvfb start
|
||||
- if [ "$TRAVIS_OS_NAME" = "linux" ]; then sudo sh -c 'echo 0 > /proc/sys/net/ipv6/conf/all/disable_ipv6'; fi
|
||||
script: npx nyc -s npm run test:node -- --bail
|
||||
after_success: npx nyc report --reporter=text-lcov > coverage.lcov && npx codecov
|
||||
|
||||
after_success:
|
||||
- npm run coverage-publish
|
||||
jobs:
|
||||
include:
|
||||
- stage: check
|
||||
os: linux
|
||||
script:
|
||||
- npx aegir build --bundlesize
|
||||
- npx aegir dep-check
|
||||
- npm run lint
|
||||
|
||||
addons:
|
||||
firefox: 'latest'
|
||||
apt:
|
||||
sources:
|
||||
- ubuntu-toolchain-r-test
|
||||
packages:
|
||||
- g++-4.8
|
||||
notifications:
|
||||
email: false
|
||||
|
||||
25
CHANGELOG.md
25
CHANGELOG.md
@ -1,3 +1,28 @@
|
||||
<a name="0.13.1"></a>
|
||||
## [0.13.1](https://github.com/libp2p/js-libp2p-tcp/compare/v0.13.0...v0.13.1) (2019-08-08)
|
||||
|
||||
|
||||
|
||||
<a name="0.13.0"></a>
|
||||
# [0.13.0](https://github.com/libp2p/js-libp2p-tcp/compare/v0.12.1...v0.13.0) (2018-09-12)
|
||||
|
||||
|
||||
### Features
|
||||
|
||||
* add support for dialing over dns ([eba0b48](https://github.com/libp2p/js-libp2p-tcp/commit/eba0b48))
|
||||
|
||||
|
||||
|
||||
<a name="0.12.1"></a>
|
||||
## [0.12.1](https://github.com/libp2p/js-libp2p-tcp/compare/v0.12.0...v0.12.1) (2018-07-31)
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* invalid ip address and daemon can be crashed by remote user ([4b04b17](https://github.com/libp2p/js-libp2p-tcp/commit/4b04b17))
|
||||
|
||||
|
||||
|
||||
<a name="0.12.0"></a>
|
||||
# [0.12.0](https://github.com/libp2p/js-libp2p-tcp/compare/v0.11.6...v0.12.0) (2018-04-05)
|
||||
|
||||
|
||||
56
README.md
56
README.md
@ -1,19 +1,23 @@
|
||||
# js-libp2p-tcp
|
||||
|
||||
[](http://ipn.io)
|
||||
[](http://webchat.freenode.net/?channels=%23ipfs)
|
||||
[](https://travis-ci.org/libp2p/js-libp2p-tcp)
|
||||
[](https://coveralls.io/github/libp2p/js-libp2p-tcp?branch=master)
|
||||
[](http://protocol.ai)
|
||||
[](http://libp2p.io/)
|
||||
[](http://webchat.freenode.net/?channels=%23libp2p)
|
||||
[](https://discuss.libp2p.io)
|
||||
[](https://codecov.io/gh/libp2p/js-libp2p-tcp)
|
||||
[](https://travis-ci.com/libp2p/js-libp2p-tcp)
|
||||
[](https://david-dm.org/libp2p/js-libp2p-tcp)
|
||||
[](https://github.com/feross/standard)
|
||||
|
||||
|
||||
|
||||
[](https://github.com/libp2p/interface-transport)
|
||||
[](https://github.com/libp2p/interface-connection)
|
||||
|
||||
|
||||
> JavaScript implementation of the TCP module for libp2p. It exposes the [interface-transport](https://github.com/libp2p/interface-connection) for dial/listen. `libp2p-tcp` is a very thin shim that adds support for dialing to a `multiaddr`. This small shim will enable libp2p to use other different transports.
|
||||
> JavaScript implementation of the TCP module for libp2p. It exposes the [interface-transport](https://github.com/libp2p/interface-connection) for dial/listen. `libp2p-tcp` is a very thin shim that adds support for dialing to a `multiaddr`. This small shim will enable libp2p to use other transports.
|
||||
|
||||
## Lead Maintainer
|
||||
|
||||
[Jacob Heun](https://github.com/jacobheun)
|
||||
|
||||
## Table of Contents
|
||||
|
||||
@ -37,37 +41,33 @@
|
||||
```js
|
||||
const TCP = require('libp2p-tcp')
|
||||
const multiaddr = require('multiaddr')
|
||||
const pull = require('pull-stream')
|
||||
const pipe = require('it-pipe')
|
||||
const { collect } = require('streaming-iterables')
|
||||
|
||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
||||
const addr = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
||||
|
||||
const tcp = new TCP()
|
||||
|
||||
const listener = tcp.createListener((socket) => {
|
||||
console.log('new connection opened')
|
||||
pull(
|
||||
pull.values(['hello']),
|
||||
pipe(
|
||||
['hello'],
|
||||
socket
|
||||
)
|
||||
})
|
||||
|
||||
listener.listen(mh, () => {
|
||||
console.log('listening')
|
||||
await listener.listen(addr)
|
||||
console.log('listening')
|
||||
|
||||
pull(
|
||||
tcp.dial(mh),
|
||||
pull.collect((err, values) => {
|
||||
if (!err) {
|
||||
console.log(`Value: ${values.toString()}`)
|
||||
} else {
|
||||
console.log(`Error: ${err}`)
|
||||
}
|
||||
const socket = await tcp.dial(addr)
|
||||
const values = await pipe(
|
||||
socket,
|
||||
collect
|
||||
)
|
||||
console.log(`Value: ${values.toString()}`)
|
||||
|
||||
// Close connection after reading
|
||||
listener.close()
|
||||
}),
|
||||
)
|
||||
})
|
||||
// Close connection after reading
|
||||
await listener.close()
|
||||
```
|
||||
|
||||
Outputs:
|
||||
@ -84,12 +84,12 @@ Value: hello
|
||||
|
||||
[](https://github.com/libp2p/interface-transport)
|
||||
|
||||
`libp2p-tcp` accepts TCP addresses both IPFS and non IPFS encapsulated addresses, i.e:
|
||||
`libp2p-tcp` accepts TCP addresses as both IPFS and non IPFS encapsulated addresses, i.e:
|
||||
|
||||
`/ip4/127.0.0.1/tcp/4001`
|
||||
`/ip4/127.0.0.1/tcp/4001/ipfs/QmHash`
|
||||
|
||||
Both for dialing and listening.
|
||||
(both for dialing and listening)
|
||||
|
||||
### Connection
|
||||
|
||||
|
||||
29
appveyor.yml
29
appveyor.yml
@ -1,29 +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.
|
||||
version: "{build}"
|
||||
|
||||
environment:
|
||||
matrix:
|
||||
- nodejs_version: "6"
|
||||
- nodejs_version: "8"
|
||||
|
||||
matrix:
|
||||
fast_finish: true
|
||||
|
||||
install:
|
||||
# Install Node.js
|
||||
- ps: Install-Product node $env:nodejs_version
|
||||
|
||||
# Upgrade npm
|
||||
- npm install -g npm
|
||||
|
||||
# Output our current versions for debugging
|
||||
- node --version
|
||||
- npm --version
|
||||
|
||||
# Install our package dependencies
|
||||
- npm install
|
||||
|
||||
test_script:
|
||||
- npm run test:node
|
||||
|
||||
build: off
|
||||
2
ci/Jenkinsfile
vendored
2
ci/Jenkinsfile
vendored
@ -1,2 +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.
|
||||
javascript()
|
||||
15
circle.yml
15
circle.yml
@ -1,15 +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.
|
||||
machine:
|
||||
node:
|
||||
version: stable
|
||||
|
||||
dependencies:
|
||||
pre:
|
||||
- google-chrome --version
|
||||
- curl -L -o google-chrome.deb https://dl.google.com/linux/direct/google-chrome-stable_current_amd64.deb
|
||||
- sudo dpkg -i google-chrome.deb || true
|
||||
- sudo apt-get update
|
||||
- sudo apt-get install -f
|
||||
- sudo apt-get install --only-upgrade lsb-base
|
||||
- sudo dpkg -i google-chrome.deb
|
||||
- google-chrome --version
|
||||
47
package.json
47
package.json
@ -1,20 +1,22 @@
|
||||
{
|
||||
"name": "libp2p-tcp",
|
||||
"version": "0.12.0",
|
||||
"version": "0.13.1",
|
||||
"description": "Node.js implementation of the TCP module that libp2p uses, which implements the interface-connection and interface-transport interfaces",
|
||||
"leadMaintainer": "Jacob Heun <jacobheun@gmail.com>",
|
||||
"main": "src/index.js",
|
||||
"scripts": {
|
||||
"lint": "aegir lint",
|
||||
"test": "aegir test -t node",
|
||||
"test:node": "aegir test -t node",
|
||||
"build": "aegir build",
|
||||
"docs": "aegir docs",
|
||||
"release": "aegir release -t node --no-build",
|
||||
"release-minor": "aegir release -t node --type minor --no-build",
|
||||
"release-major": "aegir-release -t node --type major --no-build",
|
||||
"coverage": "aegir coverage",
|
||||
"coverage-publish": "aegir coverage --provider coveralls"
|
||||
"coverage": "nyc --reporter=text --reporter=lcov npm run test:node"
|
||||
},
|
||||
"pre-push": [
|
||||
"lint",
|
||||
"test"
|
||||
"lint"
|
||||
],
|
||||
"repository": {
|
||||
"type": "git",
|
||||
@ -23,7 +25,6 @@
|
||||
"keywords": [
|
||||
"IPFS"
|
||||
],
|
||||
"author": "David Dias <daviddias@ipfs.io>",
|
||||
"license": "MIT",
|
||||
"bugs": {
|
||||
"url": "https://github.com/libp2p/js-libp2p-tcp/issues"
|
||||
@ -34,25 +35,26 @@
|
||||
"npm": ">=3.0.0"
|
||||
},
|
||||
"devDependencies": {
|
||||
"aegir": "^13.0.6",
|
||||
"chai": "^4.1.2",
|
||||
"aegir": "^20.0.0",
|
||||
"chai": "^4.2.0",
|
||||
"dirty-chai": "^2.0.1",
|
||||
"interface-transport": "~0.3.6",
|
||||
"lodash.isfunction": "^3.0.9",
|
||||
"pre-commit": "^1.2.2",
|
||||
"pull-stream": "^3.6.7"
|
||||
"pull-stream": "^3.6.9",
|
||||
"sinon": "^7.4.1"
|
||||
},
|
||||
"dependencies": {
|
||||
"abortable-iterator": "^2.1.0",
|
||||
"class-is": "^1.1.0",
|
||||
"debug": "^3.1.0",
|
||||
"interface-connection": "~0.3.2",
|
||||
"ip-address": "^5.8.9",
|
||||
"debug": "^4.1.1",
|
||||
"err-code": "^1.1.2",
|
||||
"interface-connection": "~0.3.3",
|
||||
"interface-transport": "~0.6.0",
|
||||
"ip-address": "^6.1.0",
|
||||
"it-pipe": "^1.0.1",
|
||||
"lodash.includes": "^4.3.0",
|
||||
"lodash.isfunction": "^3.0.9",
|
||||
"mafmt": "^6.0.0",
|
||||
"multiaddr": "^4.0.0",
|
||||
"once": "^1.4.0",
|
||||
"stream-to-pull-stream": "^1.7.2"
|
||||
"mafmt": "^6.0.8",
|
||||
"multiaddr": "^6.1.0",
|
||||
"streaming-iterables": "^4.1.0"
|
||||
},
|
||||
"contributors": [
|
||||
"Alan Shaw <alan@tableflip.io>",
|
||||
@ -63,10 +65,15 @@
|
||||
"Evan Schwartz <evan.mark.schwartz@gmail.com>",
|
||||
"Friedel Ziegelmayer <dignifiedquire@gmail.com>",
|
||||
"Greenkeeper <support@greenkeeper.io>",
|
||||
"Jacob Heun <jacobheun@gmail.com>",
|
||||
"Jacob Heun <jake@andyet.net>",
|
||||
"João Antunes <j.goncalo.antunes@gmail.com>",
|
||||
"Linus Unnebäck <linus@folkdatorn.se>",
|
||||
"Pedro Teixeira <i@pgte.me>",
|
||||
"Prashanth Chandra <coolshanth94@gmail.com>",
|
||||
"Richard Littauer <richard.littauer@gmail.com>",
|
||||
"Stephen Whitmore <stephen.whitmore@gmail.com>"
|
||||
"Stephen Whitmore <stephen.whitmore@gmail.com>",
|
||||
"TomCoded <tomtinkerer@gmail.com>",
|
||||
"Vasco Santos <vasco.santos@moxy.studio>"
|
||||
]
|
||||
}
|
||||
|
||||
17
src/adapter.js
Normal file
17
src/adapter.js
Normal file
@ -0,0 +1,17 @@
|
||||
'use strict'
|
||||
|
||||
const { Adapter } = require('interface-transport')
|
||||
const withIs = require('class-is')
|
||||
const TCP = require('.')
|
||||
|
||||
// Legacy adapter to old transport & connection interface
|
||||
class TcpAdapter extends Adapter {
|
||||
constructor (options) {
|
||||
super(new TCP(options))
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = withIs(TcpAdapter, {
|
||||
className: 'TCP',
|
||||
symbolName: '@libp2p/js-libp2p-tcp/tcp'
|
||||
})
|
||||
8
src/constants.js
Normal file
8
src/constants.js
Normal file
@ -0,0 +1,8 @@
|
||||
'use strict'
|
||||
|
||||
// IPFS multi-address code
|
||||
module.exports.IPFS_MA_CODE = 421
|
||||
|
||||
// Time to wait for a connection to close gracefully before destroying it
|
||||
// manually
|
||||
module.exports.CLOSE_TIMEOUT = 2000
|
||||
@ -2,27 +2,32 @@
|
||||
|
||||
const multiaddr = require('multiaddr')
|
||||
const Address6 = require('ip-address').Address6
|
||||
const debug = require('debug')
|
||||
const log = debug('libp2p:tcp:get-multiaddr')
|
||||
|
||||
module.exports = (socket) => {
|
||||
let ma
|
||||
|
||||
if (socket.remoteFamily === 'IPv6') {
|
||||
const addr = new Address6(socket.remoteAddress)
|
||||
try {
|
||||
if (socket.remoteFamily === 'IPv6') {
|
||||
const addr = new Address6(socket.remoteAddress)
|
||||
|
||||
if (addr.v4) {
|
||||
const ip4 = addr.to4().correctForm()
|
||||
ma = multiaddr('/ip4/' + ip4 +
|
||||
'/tcp/' + socket.remotePort
|
||||
)
|
||||
if (addr.v4) {
|
||||
const ip4 = addr.to4().correctForm()
|
||||
ma = multiaddr('/ip4/' + ip4 +
|
||||
'/tcp/' + socket.remotePort
|
||||
)
|
||||
} else {
|
||||
ma = multiaddr('/ip6/' + socket.remoteAddress +
|
||||
'/tcp/' + socket.remotePort
|
||||
)
|
||||
}
|
||||
} else {
|
||||
ma = multiaddr('/ip6/' + socket.remoteAddress +
|
||||
'/tcp/' + socket.remotePort
|
||||
)
|
||||
ma = multiaddr('/ip4/' + socket.remoteAddress +
|
||||
'/tcp/' + socket.remotePort)
|
||||
}
|
||||
} else {
|
||||
ma = multiaddr('/ip4/' + socket.remoteAddress +
|
||||
'/tcp/' + socket.remotePort)
|
||||
} catch (err) {
|
||||
log(err)
|
||||
}
|
||||
|
||||
return ma
|
||||
}
|
||||
|
||||
94
src/index.js
94
src/index.js
@ -1,55 +1,82 @@
|
||||
'use strict'
|
||||
|
||||
const net = require('net')
|
||||
const toPull = require('stream-to-pull-stream')
|
||||
const mafmt = require('mafmt')
|
||||
const withIs = require('class-is')
|
||||
const includes = require('lodash.includes')
|
||||
const isFunction = require('lodash.isfunction')
|
||||
const Connection = require('interface-connection').Connection
|
||||
const once = require('once')
|
||||
const errcode = require('err-code')
|
||||
const debug = require('debug')
|
||||
const log = debug('libp2p:tcp:dial')
|
||||
const assert = require('assert')
|
||||
|
||||
const Libp2pSocket = require('./socket')
|
||||
const createListener = require('./listener')
|
||||
const { AbortError } = require('interface-transport')
|
||||
|
||||
function noop () {}
|
||||
|
||||
class TCP {
|
||||
dial (ma, options, callback) {
|
||||
if (isFunction(options)) {
|
||||
callback = options
|
||||
options = {}
|
||||
}
|
||||
|
||||
callback = once(callback || noop)
|
||||
constructor (options) {
|
||||
assert(options && options.upgrader, 'An Upgrader must be provided')
|
||||
this.upgrader = options.upgrader
|
||||
}
|
||||
|
||||
async dial (ma, options) {
|
||||
const cOpts = ma.toOptions()
|
||||
log('Connecting to %s %s', cOpts.port, cOpts.host)
|
||||
log('Dialing %s:%s', cOpts.host, cOpts.port)
|
||||
|
||||
const rawSocket = net.connect(cOpts)
|
||||
const rawSocket = await this._connect(cOpts, options)
|
||||
return this.upgrader.upgradeOutbound(new Libp2pSocket(rawSocket, ma, options))
|
||||
}
|
||||
|
||||
rawSocket.once('timeout', () => {
|
||||
log('timeout')
|
||||
rawSocket.emit('error', new Error('Timeout'))
|
||||
_connect (cOpts, options = {}) {
|
||||
return new Promise((resolve, reject) => {
|
||||
if ((options.signal || {}).aborted) {
|
||||
return reject(new AbortError())
|
||||
}
|
||||
|
||||
const start = Date.now()
|
||||
const rawSocket = net.connect(cOpts)
|
||||
|
||||
const onError = (err) => {
|
||||
const msg = `Error dialing ${cOpts.host}:${cOpts.port}: ${err.message}`
|
||||
done(errcode(msg, err.code))
|
||||
}
|
||||
|
||||
const onTimeout = () => {
|
||||
log('Timeout dialing %s:%s', cOpts.host, cOpts.port)
|
||||
const err = errcode(`Timeout after ${Date.now() - start}ms`, 'ETIMEDOUT')
|
||||
// Note: this will result in onError() being called
|
||||
rawSocket.emit('error', err)
|
||||
}
|
||||
|
||||
const onConnect = () => {
|
||||
log('Connected to %s:%s', cOpts.host, cOpts.port)
|
||||
done(null, rawSocket)
|
||||
}
|
||||
|
||||
const onAbort = () => {
|
||||
log('Dial to %s:%s aborted', cOpts.host, cOpts.port)
|
||||
rawSocket.destroy()
|
||||
done(new AbortError())
|
||||
}
|
||||
|
||||
const done = (err, res) => {
|
||||
rawSocket.removeListener('error', onError)
|
||||
rawSocket.removeListener('timeout', onTimeout)
|
||||
rawSocket.removeListener('connect', onConnect)
|
||||
|
||||
options.signal && options.signal.removeEventListener('abort', onAbort)
|
||||
|
||||
err ? reject(err) : resolve(res)
|
||||
}
|
||||
|
||||
rawSocket.once('error', onError)
|
||||
rawSocket.once('timeout', onTimeout)
|
||||
rawSocket.once('connect', onConnect)
|
||||
options.signal && options.signal.addEventListener('abort', onAbort)
|
||||
})
|
||||
|
||||
rawSocket.once('error', callback)
|
||||
|
||||
rawSocket.once('connect', () => {
|
||||
rawSocket.removeListener('error', callback)
|
||||
callback()
|
||||
})
|
||||
|
||||
const socket = toPull.duplex(rawSocket)
|
||||
|
||||
const conn = new Connection(socket)
|
||||
|
||||
conn.getObservedAddrs = (callback) => {
|
||||
return callback(null, [ma])
|
||||
}
|
||||
|
||||
return conn
|
||||
}
|
||||
|
||||
createListener (options, handler) {
|
||||
@ -59,8 +86,7 @@ class TCP {
|
||||
}
|
||||
|
||||
handler = handler || noop
|
||||
|
||||
return createListener(handler)
|
||||
return createListener(handler, this.upgrader)
|
||||
}
|
||||
|
||||
filter (multiaddrs) {
|
||||
|
||||
@ -1,42 +1,44 @@
|
||||
'use strict'
|
||||
|
||||
const multiaddr = require('multiaddr')
|
||||
const Connection = require('interface-connection').Connection
|
||||
const os = require('os')
|
||||
const includes = require('lodash.includes')
|
||||
const net = require('net')
|
||||
const toPull = require('stream-to-pull-stream')
|
||||
const EventEmitter = require('events').EventEmitter
|
||||
const debug = require('debug')
|
||||
const log = debug('libp2p:tcp:listen')
|
||||
const logError = debug('libp2p:tcp:listen:error')
|
||||
|
||||
const Libp2pSocket = require('./socket')
|
||||
const getMultiaddr = require('./get-multiaddr')
|
||||
const c = require('./constants')
|
||||
|
||||
const IPFS_CODE = 421
|
||||
const CLOSE_TIMEOUT = 2000
|
||||
|
||||
function noop () {}
|
||||
|
||||
module.exports = (handler) => {
|
||||
module.exports = (handler, upgrader) => {
|
||||
const listener = new EventEmitter()
|
||||
|
||||
const server = net.createServer((socket) => {
|
||||
// Avoid uncaught errors cause by unstable connections
|
||||
socket.on('error', noop)
|
||||
// Avoid uncaught errors caused by unstable connections
|
||||
socket.on('error', (err) => {
|
||||
logError('Error emitted by server handler socket: ' + err.message)
|
||||
})
|
||||
|
||||
const addr = getMultiaddr(socket)
|
||||
log('new connection', addr.toString())
|
||||
|
||||
const s = toPull.duplex(socket)
|
||||
|
||||
s.getObservedAddrs = (cb) => {
|
||||
cb(null, [addr])
|
||||
if (!addr) {
|
||||
if (socket.remoteAddress === undefined) {
|
||||
log('connection closed before p2p connection made')
|
||||
} else {
|
||||
log('error interpreting incoming p2p connection')
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
log('new connection', addr.toString())
|
||||
|
||||
const s = new Libp2pSocket(socket, addr)
|
||||
trackSocket(server, socket)
|
||||
|
||||
const conn = new Connection(s)
|
||||
handler(conn)
|
||||
const conn = upgrader.upgradeInbound(s)
|
||||
handler && handler(conn)
|
||||
listener.emit('connection', conn)
|
||||
})
|
||||
|
||||
@ -47,33 +49,35 @@ module.exports = (handler) => {
|
||||
// Keep track of open connections to destroy in case of timeout
|
||||
server.__connections = {}
|
||||
|
||||
listener.close = (options, callback) => {
|
||||
if (typeof options === 'function') {
|
||||
callback = options
|
||||
options = {}
|
||||
listener.close = (options = {}) => {
|
||||
if (!server.listening) {
|
||||
return
|
||||
}
|
||||
callback = callback || noop
|
||||
options = options || {}
|
||||
|
||||
const timeout = setTimeout(() => {
|
||||
log('unable to close graciously, destroying conns')
|
||||
Object.keys(server.__connections).forEach((key) => {
|
||||
log('destroying %s', key)
|
||||
server.__connections[key].destroy()
|
||||
})
|
||||
}, options.timeout || CLOSE_TIMEOUT)
|
||||
return new Promise((resolve, reject) => {
|
||||
const start = Date.now()
|
||||
|
||||
server.close(callback)
|
||||
// Attempt to stop the server. If it takes longer than the timeout,
|
||||
// destroy all the underlying sockets manually.
|
||||
const timeout = setTimeout(() => {
|
||||
log('Timeout closing server after %dms, destroying connections manually', Date.now() - start)
|
||||
Object.keys(server.__connections).forEach((key) => {
|
||||
log('destroying %s', key)
|
||||
server.__connections[key].destroy()
|
||||
})
|
||||
resolve()
|
||||
}, options.timeout || c.CLOSE_TIMEOUT)
|
||||
|
||||
server.once('close', () => {
|
||||
clearTimeout(timeout)
|
||||
server.once('close', () => clearTimeout(timeout))
|
||||
|
||||
server.close((err) => err ? reject(err) : resolve())
|
||||
})
|
||||
}
|
||||
|
||||
let ipfsId
|
||||
let listeningAddr
|
||||
|
||||
listener.listen = (ma, callback) => {
|
||||
listener.listen = (ma) => {
|
||||
listeningAddr = ma
|
||||
if (includes(ma.protoNames(), 'ipfs')) {
|
||||
ipfsId = getIpfsId(ma)
|
||||
@ -81,16 +85,24 @@ module.exports = (handler) => {
|
||||
}
|
||||
|
||||
const lOpts = listeningAddr.toOptions()
|
||||
log('Listening on %s %s', lOpts.port, lOpts.host)
|
||||
return server.listen(lOpts.port, lOpts.host, callback)
|
||||
return new Promise((resolve, reject) => {
|
||||
server.listen(lOpts.port, lOpts.host, (err) => {
|
||||
if (err) {
|
||||
return reject(err)
|
||||
}
|
||||
|
||||
log('Listening on %s %s', lOpts.port, lOpts.host)
|
||||
resolve()
|
||||
})
|
||||
})
|
||||
}
|
||||
|
||||
listener.getAddrs = (callback) => {
|
||||
listener.getAddrs = () => {
|
||||
const multiaddrs = []
|
||||
const address = server.address()
|
||||
|
||||
if (!address) {
|
||||
return callback(new Error('Listener is not ready yet'))
|
||||
throw new Error('Listener is not ready yet')
|
||||
}
|
||||
|
||||
// Because TCP will only return the IPv6 version
|
||||
@ -125,7 +137,7 @@ module.exports = (handler) => {
|
||||
multiaddrs.push(ma)
|
||||
}
|
||||
|
||||
callback(null, multiaddrs)
|
||||
return multiaddrs
|
||||
}
|
||||
|
||||
return listener
|
||||
@ -133,7 +145,7 @@ module.exports = (handler) => {
|
||||
|
||||
function getIpfsId (ma) {
|
||||
return ma.stringTuples().filter((tuple) => {
|
||||
return tuple[0] === IPFS_CODE
|
||||
return tuple[0] === c.IPFS_MA_CODE
|
||||
})[0][1]
|
||||
}
|
||||
|
||||
@ -141,7 +153,7 @@ function trackSocket (server, socket) {
|
||||
const key = `${socket.remoteAddress}:${socket.remotePort}`
|
||||
server.__connections[key] = socket
|
||||
|
||||
socket.on('close', () => {
|
||||
socket.once('close', () => {
|
||||
delete server.__connections[key]
|
||||
})
|
||||
}
|
||||
|
||||
87
src/socket.js
Normal file
87
src/socket.js
Normal file
@ -0,0 +1,87 @@
|
||||
'use strict'
|
||||
|
||||
const abortable = require('abortable-iterator')
|
||||
const debug = require('debug')
|
||||
const log = debug('libp2p:tcp:socket')
|
||||
|
||||
const c = require('./constants')
|
||||
|
||||
class Libp2pSocket {
|
||||
constructor (rawSocket, ma, opts = {}) {
|
||||
this._rawSocket = rawSocket
|
||||
this._ma = ma
|
||||
this.remoteAddr = ma
|
||||
this.conn = rawSocket
|
||||
|
||||
this.sink = this._sink(opts)
|
||||
this.source = opts.signal ? abortable(rawSocket, opts.signal) : rawSocket
|
||||
}
|
||||
|
||||
_sink (opts) {
|
||||
// By default, close when the source is exhausted
|
||||
const closeOnEnd = opts.closeOnEnd !== false
|
||||
|
||||
return async (source) => {
|
||||
try {
|
||||
const src = opts.signal ? abortable(source, opts.signal) : source
|
||||
await this._write(src, closeOnEnd)
|
||||
} catch (err) {
|
||||
// If the connection is aborted just close the socket
|
||||
if (err.type === 'aborted') {
|
||||
return this.close()
|
||||
}
|
||||
|
||||
throw err
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
async _write (source, closeOnEnd) {
|
||||
for await (const data of source) {
|
||||
if (this._rawSocket.destroyed) {
|
||||
const cOpts = this._ma.toOptions()
|
||||
throw new Error('Cannot write %d bytes to destroyed socket %s:%s',
|
||||
data.length, cOpts.host, cOpts.port)
|
||||
}
|
||||
|
||||
const flushed = this._rawSocket.write(data)
|
||||
if (!flushed) {
|
||||
await new Promise((resolve) => this._rawSocket.once('drain', resolve))
|
||||
}
|
||||
}
|
||||
|
||||
if (closeOnEnd) {
|
||||
await this.close()
|
||||
}
|
||||
}
|
||||
|
||||
close (opts = {}) {
|
||||
if (this._rawSocket.pending || this._rawSocket.destroyed) {
|
||||
return
|
||||
}
|
||||
|
||||
return new Promise((resolve, reject) => {
|
||||
const start = Date.now()
|
||||
|
||||
// Attempt to end the socket. If it takes longer to close than the
|
||||
// timeout, destroy it manually.
|
||||
const timeout = setTimeout(() => {
|
||||
const cOpts = this._ma.toOptions()
|
||||
log('Timeout closing socket to %s:%s after %dms, destroying it manually',
|
||||
cOpts.host, cOpts.port, Date.now() - start)
|
||||
this._rawSocket.destroy()
|
||||
resolve()
|
||||
}, opts.timeout || c.CLOSE_TIMEOUT)
|
||||
|
||||
this._rawSocket.once('close', () => clearTimeout(timeout))
|
||||
|
||||
this._rawSocket.end((err) => err ? reject(err) : resolve())
|
||||
})
|
||||
}
|
||||
|
||||
getObservedAddrs () {
|
||||
return [this._ma]
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = Libp2pSocket
|
||||
@ -6,9 +6,10 @@ const chai = require('chai')
|
||||
const dirtyChai = require('dirty-chai')
|
||||
const expect = chai.expect
|
||||
chai.use(dirtyChai)
|
||||
const TCP = require('../src')
|
||||
const TCP = require('../../src/adapter')
|
||||
const multiaddr = require('multiaddr')
|
||||
const Connection = require('interface-connection').Connection
|
||||
const upgrader = require('../utils/upgrader')
|
||||
|
||||
describe('Connection Wrap', () => {
|
||||
let tcp
|
||||
@ -16,7 +17,7 @@ describe('Connection Wrap', () => {
|
||||
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
||||
|
||||
beforeEach((done) => {
|
||||
tcp = new TCP()
|
||||
tcp = new TCP({ upgrader })
|
||||
listener = tcp.createListener((conn) => {
|
||||
pull(conn, conn)
|
||||
})
|
||||
112
test/adapter/connection.spec.js
Normal file
112
test/adapter/connection.spec.js
Normal file
@ -0,0 +1,112 @@
|
||||
/* eslint-env mocha */
|
||||
'use strict'
|
||||
|
||||
const pull = require('pull-stream')
|
||||
const chai = require('chai')
|
||||
const dirtyChai = require('dirty-chai')
|
||||
const expect = chai.expect
|
||||
chai.use(dirtyChai)
|
||||
const TCP = require('../../src/adapter')
|
||||
const multiaddr = require('multiaddr')
|
||||
const upgrader = require('../utils/upgrader')
|
||||
|
||||
describe('valid Connection', () => {
|
||||
let tcp
|
||||
|
||||
beforeEach(() => {
|
||||
tcp = new TCP({ upgrader })
|
||||
})
|
||||
|
||||
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
||||
|
||||
it('get observed addrs', (done) => {
|
||||
let dialerObsAddrs
|
||||
|
||||
const listener = tcp.createListener((conn) => {
|
||||
expect(conn).to.exist()
|
||||
conn.getObservedAddrs((err, addrs) => {
|
||||
expect(err).to.not.exist()
|
||||
dialerObsAddrs = addrs
|
||||
pull(pull.empty(), conn)
|
||||
})
|
||||
})
|
||||
|
||||
listener.listen(ma, () => {
|
||||
const conn = tcp.dial(ma)
|
||||
pull(
|
||||
conn,
|
||||
pull.onEnd(endHandler)
|
||||
)
|
||||
|
||||
function endHandler () {
|
||||
conn.getObservedAddrs((err, addrs) => {
|
||||
expect(err).to.not.exist()
|
||||
pull(pull.empty(), conn)
|
||||
closeAndAssert(listener, addrs)
|
||||
})
|
||||
}
|
||||
|
||||
function closeAndAssert (listener, addrs) {
|
||||
listener.close(() => {
|
||||
expect(addrs[0]).to.deep.equal(ma)
|
||||
expect(dialerObsAddrs.length).to.equal(1)
|
||||
done()
|
||||
})
|
||||
}
|
||||
})
|
||||
})
|
||||
|
||||
it('get Peer Info', (done) => {
|
||||
const listener = tcp.createListener((conn) => {
|
||||
expect(conn).to.exist()
|
||||
conn.getPeerInfo((err, peerInfo) => {
|
||||
expect(err).to.exist()
|
||||
expect(peerInfo).to.not.exist()
|
||||
pull(pull.empty(), conn)
|
||||
})
|
||||
})
|
||||
|
||||
listener.listen(ma, () => {
|
||||
const conn = tcp.dial(ma)
|
||||
|
||||
pull(conn, pull.onEnd(endHandler))
|
||||
|
||||
function endHandler () {
|
||||
conn.getPeerInfo((err, peerInfo) => {
|
||||
expect(err).to.exist()
|
||||
expect(peerInfo).to.not.exist()
|
||||
|
||||
listener.close(done)
|
||||
})
|
||||
}
|
||||
})
|
||||
})
|
||||
|
||||
it('set Peer Info', (done) => {
|
||||
const listener = tcp.createListener((conn) => {
|
||||
expect(conn).to.exist()
|
||||
conn.setPeerInfo('batatas')
|
||||
conn.getPeerInfo((err, peerInfo) => {
|
||||
expect(err).to.not.exist()
|
||||
expect(peerInfo).to.equal('batatas')
|
||||
pull(pull.empty(), conn)
|
||||
})
|
||||
})
|
||||
|
||||
listener.listen(ma, () => {
|
||||
const conn = tcp.dial(ma)
|
||||
|
||||
pull(conn, pull.onEnd(endHandler))
|
||||
|
||||
function endHandler () {
|
||||
conn.setPeerInfo('arroz')
|
||||
conn.getPeerInfo((err, peerInfo) => {
|
||||
expect(err).to.not.exist()
|
||||
expect(peerInfo).to.equal('arroz')
|
||||
|
||||
listener.close(done)
|
||||
})
|
||||
}
|
||||
})
|
||||
})
|
||||
})
|
||||
@ -6,16 +6,17 @@ const chai = require('chai')
|
||||
const dirtyChai = require('dirty-chai')
|
||||
const expect = chai.expect
|
||||
chai.use(dirtyChai)
|
||||
const TCP = require('../src')
|
||||
const TCP = require('../../src/adapter')
|
||||
const net = require('net')
|
||||
const multiaddr = require('multiaddr')
|
||||
const upgrader = require('../utils/upgrader')
|
||||
const isCI = process.env.CI
|
||||
|
||||
describe('listen', () => {
|
||||
let tcp
|
||||
|
||||
beforeEach(() => {
|
||||
tcp = new TCP()
|
||||
tcp = new TCP({ upgrader })
|
||||
})
|
||||
|
||||
it('close listener with connections, through timeout', (done) => {
|
||||
@ -134,7 +135,7 @@ describe('dial', () => {
|
||||
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
||||
|
||||
beforeEach((done) => {
|
||||
tcp = new TCP()
|
||||
tcp = new TCP({ upgrader })
|
||||
listener = tcp.createListener((conn) => {
|
||||
pull(
|
||||
conn,
|
||||
@ -194,10 +195,9 @@ describe('dial', () => {
|
||||
})
|
||||
})
|
||||
|
||||
// TODO: figure out why is this failing
|
||||
it.skip('dial and destroy on listener', (done) => {
|
||||
it('dial and destroy on listener', (done) => {
|
||||
let count = 0
|
||||
const closed = ++count === 2 ? finish() : null
|
||||
const closed = () => ++count === 2 ? finish() : null
|
||||
|
||||
const ma = multiaddr('/ip6/::/tcp/9067')
|
||||
|
||||
@ -1,23 +1,43 @@
|
||||
/* eslint-env mocha */
|
||||
'use strict'
|
||||
|
||||
const sinon = require('sinon')
|
||||
const tests = require('interface-transport')
|
||||
const multiaddr = require('multiaddr')
|
||||
const net = require('net')
|
||||
const TCP = require('../src')
|
||||
|
||||
describe('interface-transport compliance', () => {
|
||||
tests({
|
||||
setup (cb) {
|
||||
let tcp = new TCP()
|
||||
setup (options) {
|
||||
const tcp = new TCP(options)
|
||||
const addrs = [
|
||||
multiaddr('/ip4/127.0.0.1/tcp/9091'),
|
||||
multiaddr('/ip4/127.0.0.1/tcp/9092'),
|
||||
multiaddr('/ip4/127.0.0.1/tcp/9093')
|
||||
multiaddr('/ip4/127.0.0.1/tcp/9093'),
|
||||
multiaddr('/dns4/ipfs.io')
|
||||
]
|
||||
cb(null, tcp, addrs)
|
||||
},
|
||||
teardown (cb) {
|
||||
cb()
|
||||
|
||||
// Used by the dial tests to simulate a delayed connect
|
||||
const connector = {
|
||||
delay (delayMs) {
|
||||
const netConnect = net.connect
|
||||
sinon.replace(net, 'connect', (opts) => {
|
||||
const socket = netConnect(opts)
|
||||
const socketEmit = socket.emit.bind(socket)
|
||||
sinon.replace(socket, 'emit', (...args) => {
|
||||
const time = args[0] === 'connect' ? delayMs : 0
|
||||
setTimeout(() => socketEmit(...args), time)
|
||||
})
|
||||
return socket
|
||||
})
|
||||
},
|
||||
restore () {
|
||||
sinon.restore()
|
||||
}
|
||||
}
|
||||
|
||||
return { transport: tcp, addrs, connector }
|
||||
}
|
||||
})
|
||||
})
|
||||
|
||||
@ -1,111 +1,56 @@
|
||||
/* eslint-env mocha */
|
||||
'use strict'
|
||||
|
||||
const pull = require('pull-stream')
|
||||
const chai = require('chai')
|
||||
const dirtyChai = require('dirty-chai')
|
||||
const expect = chai.expect
|
||||
chai.use(dirtyChai)
|
||||
const TCP = require('../src')
|
||||
const multiaddr = require('multiaddr')
|
||||
const upgrader = require('./utils/upgrader')
|
||||
|
||||
describe('valid Connection', () => {
|
||||
let tcp
|
||||
|
||||
beforeEach(() => {
|
||||
tcp = new TCP()
|
||||
tcp = new TCP({ upgrader })
|
||||
})
|
||||
|
||||
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
||||
|
||||
it('get observed addrs', (done) => {
|
||||
let dialerObsAddrs
|
||||
it('get observed addrs', async () => {
|
||||
// Create a Promise that resolves when a connection is handled
|
||||
let handled
|
||||
const handlerPromise = new Promise((resolve) => {
|
||||
handled = resolve
|
||||
})
|
||||
|
||||
const listener = tcp.createListener((conn) => {
|
||||
const handler = async (conn) => {
|
||||
expect(conn).to.exist()
|
||||
conn.getObservedAddrs((err, addrs) => {
|
||||
expect(err).to.not.exist()
|
||||
dialerObsAddrs = addrs
|
||||
pull(pull.empty(), conn)
|
||||
})
|
||||
})
|
||||
const dialerObsAddrs = await conn.getObservedAddrs()
|
||||
handled(dialerObsAddrs)
|
||||
}
|
||||
|
||||
listener.listen(ma, () => {
|
||||
const conn = tcp.dial(ma)
|
||||
pull(
|
||||
conn,
|
||||
pull.onEnd(endHandler)
|
||||
)
|
||||
// Create a listener with the handler
|
||||
const listener = tcp.createListener(handler)
|
||||
|
||||
function endHandler () {
|
||||
conn.getObservedAddrs((err, addrs) => {
|
||||
expect(err).to.not.exist()
|
||||
pull(pull.empty(), conn)
|
||||
closeAndAssert(listener, addrs)
|
||||
})
|
||||
}
|
||||
// Listen on the multi-address
|
||||
await listener.listen(ma)
|
||||
|
||||
function closeAndAssert (listener, addrs) {
|
||||
listener.close(() => {
|
||||
expect(addrs[0]).to.deep.equal(ma)
|
||||
expect(dialerObsAddrs.length).to.equal(1)
|
||||
done()
|
||||
})
|
||||
}
|
||||
})
|
||||
})
|
||||
// Dial to that same address
|
||||
const conn = await tcp.dial(ma)
|
||||
const addrs = await conn.getObservedAddrs()
|
||||
|
||||
it('get Peer Info', (done) => {
|
||||
const listener = tcp.createListener((conn) => {
|
||||
expect(conn).to.exist()
|
||||
conn.getPeerInfo((err, peerInfo) => {
|
||||
expect(err).to.exist()
|
||||
expect(peerInfo).to.not.exist()
|
||||
pull(pull.empty(), conn)
|
||||
})
|
||||
})
|
||||
// Wait for the incoming dial to be handled
|
||||
const dialerObsAddrs = await handlerPromise
|
||||
|
||||
listener.listen(ma, () => {
|
||||
const conn = tcp.dial(ma)
|
||||
// Close the listener
|
||||
await listener.close()
|
||||
|
||||
pull(conn, pull.onEnd(endHandler))
|
||||
|
||||
function endHandler () {
|
||||
conn.getPeerInfo((err, peerInfo) => {
|
||||
expect(err).to.exist()
|
||||
expect(peerInfo).to.not.exist()
|
||||
|
||||
listener.close(done)
|
||||
})
|
||||
}
|
||||
})
|
||||
})
|
||||
|
||||
it('set Peer Info', (done) => {
|
||||
const listener = tcp.createListener((conn) => {
|
||||
expect(conn).to.exist()
|
||||
conn.setPeerInfo('batatas')
|
||||
conn.getPeerInfo((err, peerInfo) => {
|
||||
expect(err).to.not.exist()
|
||||
expect(peerInfo).to.equal('batatas')
|
||||
pull(pull.empty(), conn)
|
||||
})
|
||||
})
|
||||
|
||||
listener.listen(ma, () => {
|
||||
const conn = tcp.dial(ma)
|
||||
|
||||
pull(conn, pull.onEnd(endHandler))
|
||||
|
||||
function endHandler () {
|
||||
conn.setPeerInfo('arroz')
|
||||
conn.getPeerInfo((err, peerInfo) => {
|
||||
expect(err).to.not.exist()
|
||||
expect(peerInfo).to.equal('arroz')
|
||||
|
||||
listener.close(done)
|
||||
})
|
||||
}
|
||||
})
|
||||
// The addresses should match
|
||||
expect(addrs.length).to.equal(1)
|
||||
expect(addrs[0]).to.deep.equal(ma)
|
||||
expect(dialerObsAddrs.length).to.equal(1)
|
||||
expect(dialerObsAddrs[0]).to.exist()
|
||||
})
|
||||
})
|
||||
|
||||
@ -6,10 +6,11 @@ const dirtyChai = require('dirty-chai')
|
||||
const expect = chai.expect
|
||||
chai.use(dirtyChai)
|
||||
const TCP = require('../src')
|
||||
const upgrader = require('./utils/upgrader')
|
||||
|
||||
describe('Constructor', () => {
|
||||
it('create an instance', () => {
|
||||
const tcp = new TCP()
|
||||
const tcp = new TCP({ upgrader })
|
||||
expect(tcp).to.exist()
|
||||
})
|
||||
})
|
||||
|
||||
@ -7,6 +7,7 @@ const expect = chai.expect
|
||||
chai.use(dirtyChai)
|
||||
const TCP = require('../src')
|
||||
const multiaddr = require('multiaddr')
|
||||
const upgrader = require('./utils/upgrader')
|
||||
|
||||
describe('filter addrs', () => {
|
||||
const base = '/ip4/127.0.0.1'
|
||||
@ -15,7 +16,7 @@ describe('filter addrs', () => {
|
||||
let tcp
|
||||
|
||||
before(() => {
|
||||
tcp = new TCP()
|
||||
tcp = new TCP({ upgrader })
|
||||
})
|
||||
|
||||
it('filter valid addrs for this transport', () => {
|
||||
@ -25,9 +26,11 @@ describe('filter addrs', () => {
|
||||
const ma4 = multiaddr(base + '/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
||||
const ma5 = multiaddr(base + '/tcp/9090/http' + ipfs)
|
||||
const ma6 = multiaddr('/ip4/127.0.0.1/tcp/9090/p2p-circuit' + ipfs)
|
||||
const ma7 = multiaddr('/dns4/libp2p.io/tcp/9090')
|
||||
const ma8 = multiaddr('/dnsaddr/libp2p.io/tcp/9090')
|
||||
|
||||
const valid = tcp.filter([ma1, ma2, ma3, ma4, ma5, ma6])
|
||||
expect(valid.length).to.equal(2)
|
||||
const valid = tcp.filter([ma1, ma2, ma3, ma4, ma5, ma6, ma7, ma8])
|
||||
expect(valid.length).to.equal(4)
|
||||
expect(valid[0]).to.deep.equal(ma1)
|
||||
expect(valid[1]).to.deep.equal(ma4)
|
||||
})
|
||||
|
||||
54
test/get-multiaddr.spec.js
Normal file
54
test/get-multiaddr.spec.js
Normal file
@ -0,0 +1,54 @@
|
||||
/* eslint-env mocha */
|
||||
'use strict'
|
||||
|
||||
const chai = require('chai')
|
||||
const dirtyChai = require('dirty-chai')
|
||||
const expect = chai.expect
|
||||
chai.use(dirtyChai)
|
||||
const getMultiaddr = require('../src/get-multiaddr')
|
||||
|
||||
const goodSocket4 = {
|
||||
remoteAddress: '127.0.0.1',
|
||||
remotePort: '9090',
|
||||
remoteFamily: 'IPv4'
|
||||
}
|
||||
|
||||
const goodSocket6 = {
|
||||
remoteAddress: '::1',
|
||||
remotePort: '9090',
|
||||
remoteFamily: 'IPv6'
|
||||
}
|
||||
|
||||
const badSocket = {}
|
||||
|
||||
const badSocketData = {
|
||||
remoteAddress: 'aewmrn4awoew',
|
||||
remotePort: '234',
|
||||
remoteFamily: 'Hufflepuff'
|
||||
}
|
||||
|
||||
describe('getMultiaddr multiaddr creation', () => {
|
||||
it('creates multiaddr from valid socket data', (done) => {
|
||||
expect(getMultiaddr(goodSocket4))
|
||||
.to.exist()
|
||||
done()
|
||||
})
|
||||
|
||||
it('creates multiaddr from valid IPv6 socket data', (done) => {
|
||||
expect(getMultiaddr(goodSocket6))
|
||||
.to.exist()
|
||||
done()
|
||||
})
|
||||
|
||||
it('returns undefined multiaddr from missing socket data', (done) => {
|
||||
expect(getMultiaddr(badSocket))
|
||||
.to.equal(undefined)
|
||||
done()
|
||||
})
|
||||
|
||||
it('returns undefined multiaddr from unparseable socket data', (done) => {
|
||||
expect(getMultiaddr(badSocketData))
|
||||
.to.equal(undefined)
|
||||
done()
|
||||
})
|
||||
})
|
||||
242
test/listen-dial.spec.js
Normal file
242
test/listen-dial.spec.js
Normal file
@ -0,0 +1,242 @@
|
||||
/* eslint-env mocha */
|
||||
'use strict'
|
||||
|
||||
const chai = require('chai')
|
||||
const dirtyChai = require('dirty-chai')
|
||||
const expect = chai.expect
|
||||
chai.use(dirtyChai)
|
||||
|
||||
const TCP = require('../src')
|
||||
const net = require('net')
|
||||
const multiaddr = require('multiaddr')
|
||||
const pipe = require('it-pipe')
|
||||
const { collect, map } = require('streaming-iterables')
|
||||
const isCI = process.env.CI
|
||||
const upgrader = require('./utils/upgrader')
|
||||
|
||||
describe('listen', () => {
|
||||
let tcp
|
||||
|
||||
beforeEach(() => {
|
||||
tcp = new TCP({ upgrader })
|
||||
})
|
||||
|
||||
it('close listener with connections, through timeout', async () => {
|
||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
||||
const listener = tcp.createListener((conn) => {
|
||||
pipe(conn, conn)
|
||||
})
|
||||
|
||||
await listener.listen(mh)
|
||||
|
||||
const socket1 = net.connect(9090)
|
||||
const socket2 = net.connect(9090)
|
||||
|
||||
socket1.write('Some data that is never handled')
|
||||
socket1.end()
|
||||
socket1.on('error', () => {})
|
||||
socket2.on('error', () => {})
|
||||
|
||||
await new Promise((resolve) => {
|
||||
socket1.on('connect', async () => {
|
||||
await listener.close({ timeout: 100 })
|
||||
resolve()
|
||||
})
|
||||
})
|
||||
})
|
||||
|
||||
it('listen on port 0', async () => {
|
||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/0')
|
||||
const listener = tcp.createListener((conn) => {})
|
||||
await listener.listen(mh)
|
||||
await listener.close()
|
||||
})
|
||||
|
||||
it('listen on IPv6 addr', async () => {
|
||||
if (isCI) {
|
||||
return
|
||||
}
|
||||
const mh = multiaddr('/ip6/::/tcp/9090')
|
||||
const listener = tcp.createListener((conn) => {})
|
||||
await listener.listen(mh)
|
||||
await listener.close()
|
||||
})
|
||||
|
||||
it('listen on any Interface', async () => {
|
||||
const mh = multiaddr('/ip4/0.0.0.0/tcp/9090')
|
||||
const listener = tcp.createListener((conn) => {})
|
||||
await listener.listen(mh)
|
||||
await listener.close()
|
||||
})
|
||||
|
||||
it('getAddrs', async () => {
|
||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
||||
const listener = tcp.createListener((conn) => {})
|
||||
await listener.listen(mh)
|
||||
|
||||
const multiaddrs = listener.getAddrs()
|
||||
expect(multiaddrs.length).to.equal(1)
|
||||
expect(multiaddrs[0]).to.deep.equal(mh)
|
||||
|
||||
await listener.close()
|
||||
})
|
||||
|
||||
it('getAddrs on port 0 listen', async () => {
|
||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/0')
|
||||
const listener = tcp.createListener((conn) => {})
|
||||
await listener.listen(mh)
|
||||
|
||||
const multiaddrs = listener.getAddrs()
|
||||
expect(multiaddrs.length).to.equal(1)
|
||||
|
||||
await listener.close()
|
||||
})
|
||||
|
||||
it('getAddrs from listening on 0.0.0.0', async () => {
|
||||
const mh = multiaddr('/ip4/0.0.0.0/tcp/9090')
|
||||
const listener = tcp.createListener((conn) => {})
|
||||
await listener.listen(mh)
|
||||
|
||||
const multiaddrs = listener.getAddrs()
|
||||
expect(multiaddrs.length > 0).to.equal(true)
|
||||
expect(multiaddrs[0].toString().indexOf('0.0.0.0')).to.equal(-1)
|
||||
|
||||
await listener.close()
|
||||
})
|
||||
|
||||
it('getAddrs from listening on 0.0.0.0 and port 0', async () => {
|
||||
const mh = multiaddr('/ip4/0.0.0.0/tcp/0')
|
||||
const listener = tcp.createListener((conn) => {})
|
||||
await listener.listen(mh)
|
||||
|
||||
const multiaddrs = listener.getAddrs()
|
||||
expect(multiaddrs.length > 0).to.equal(true)
|
||||
expect(multiaddrs[0].toString().indexOf('0.0.0.0')).to.equal(-1)
|
||||
|
||||
await listener.close()
|
||||
})
|
||||
|
||||
it('getAddrs preserves IPFS Id', async () => {
|
||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
||||
const listener = tcp.createListener((conn) => {})
|
||||
await listener.listen(mh)
|
||||
|
||||
const multiaddrs = listener.getAddrs()
|
||||
expect(multiaddrs.length).to.equal(1)
|
||||
expect(multiaddrs[0]).to.deep.equal(mh)
|
||||
|
||||
await listener.close()
|
||||
})
|
||||
})
|
||||
|
||||
describe('dial', () => {
|
||||
let tcp
|
||||
let listener
|
||||
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
||||
|
||||
beforeEach(async () => {
|
||||
tcp = new TCP({ upgrader })
|
||||
listener = tcp.createListener((conn) => {
|
||||
pipe(
|
||||
conn,
|
||||
map((x) => Buffer.from(x.toString() + '!')),
|
||||
conn
|
||||
)
|
||||
})
|
||||
await listener.listen(ma)
|
||||
})
|
||||
|
||||
afterEach(() => listener.close())
|
||||
|
||||
it('dial on IPv4', async () => {
|
||||
const values = await pipe(
|
||||
['hey'],
|
||||
await tcp.dial(ma),
|
||||
collect
|
||||
)
|
||||
expect(values).to.eql([Buffer.from('hey!')])
|
||||
})
|
||||
|
||||
it('dial on IPv6', async () => {
|
||||
if (isCI) {
|
||||
return
|
||||
}
|
||||
|
||||
const ma = multiaddr('/ip6/::/tcp/9066')
|
||||
const listener = tcp.createListener((conn) => {
|
||||
pipe(conn, conn)
|
||||
})
|
||||
await listener.listen(ma)
|
||||
|
||||
const values = await pipe(
|
||||
['hey'],
|
||||
await tcp.dial(ma),
|
||||
collect
|
||||
)
|
||||
expect(values).to.be.eql([Buffer.from('hey')])
|
||||
|
||||
await listener.close()
|
||||
})
|
||||
|
||||
it('dial and destroy on listener', async () => {
|
||||
let handled
|
||||
const handledPromise = new Promise((resolve) => {
|
||||
handled = resolve
|
||||
})
|
||||
|
||||
const ma = multiaddr('/ip6/::/tcp/0')
|
||||
|
||||
const listener = tcp.createListener(async (conn) => {
|
||||
await pipe(
|
||||
[],
|
||||
conn
|
||||
)
|
||||
handled()
|
||||
})
|
||||
|
||||
await listener.listen(ma)
|
||||
const addrs = listener.getAddrs()
|
||||
await pipe(await tcp.dial(addrs[0]))
|
||||
|
||||
await handledPromise
|
||||
await listener.close()
|
||||
})
|
||||
|
||||
it('dial and destroy on dialer', async () => {
|
||||
if (isCI) {
|
||||
return
|
||||
}
|
||||
|
||||
let handled
|
||||
const handledPromise = new Promise((resolve) => {
|
||||
handled = resolve
|
||||
})
|
||||
|
||||
const ma = multiaddr('/ip6/::/tcp/0')
|
||||
|
||||
const listener = tcp.createListener(async (conn) => {
|
||||
// pull(conn, pull.onEnd(destroyed))
|
||||
await pipe(conn)
|
||||
handled()
|
||||
})
|
||||
|
||||
await listener.listen(ma)
|
||||
const addrs = listener.getAddrs()
|
||||
await pipe(await tcp.dial(addrs[0]))
|
||||
|
||||
await handledPromise
|
||||
await listener.close()
|
||||
})
|
||||
|
||||
it('dial on IPv4 with IPFS Id', async () => {
|
||||
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
||||
const conn = await tcp.dial(ma)
|
||||
|
||||
const res = await pipe(
|
||||
['hey'],
|
||||
conn,
|
||||
collect
|
||||
)
|
||||
expect(res).to.be.eql([Buffer.from('hey!')])
|
||||
})
|
||||
})
|
||||
6
test/utils/upgrader.js
Normal file
6
test/utils/upgrader.js
Normal file
@ -0,0 +1,6 @@
|
||||
'use strict'
|
||||
|
||||
module.exports = {
|
||||
upgradeOutbound: (conn) => conn,
|
||||
upgradeInbound: (conn) => conn
|
||||
}
|
||||
Reference in New Issue
Block a user