mirror of
https://github.com/fluencelabs/js-libp2p-tcp
synced 2025-07-02 01:21:45 +00:00
Compare commits
3 Commits
feat/async
...
v0.13.2
Author | SHA1 | Date | |
---|---|---|---|
2cd7736e06 | |||
453b40a358 | |||
37cea53ec0 |
1
.gitignore
vendored
1
.gitignore
vendored
@ -12,7 +12,6 @@ logs
|
|||||||
*.log
|
*.log
|
||||||
|
|
||||||
coverage
|
coverage
|
||||||
.nyc_output
|
|
||||||
|
|
||||||
# Runtime data
|
# Runtime data
|
||||||
pids
|
pids
|
||||||
|
@ -27,6 +27,7 @@ jobs:
|
|||||||
os: linux
|
os: linux
|
||||||
script:
|
script:
|
||||||
- npx aegir build --bundlesize
|
- npx aegir build --bundlesize
|
||||||
|
- npx aegir commitlint --travis
|
||||||
- npx aegir dep-check
|
- npx aegir dep-check
|
||||||
- npm run lint
|
- npm run lint
|
||||||
|
|
||||||
|
10
CHANGELOG.md
10
CHANGELOG.md
@ -1,3 +1,13 @@
|
|||||||
|
<a name="0.13.2"></a>
|
||||||
|
## [0.13.2](https://github.com/libp2p/js-libp2p-tcp/compare/v0.13.1...v0.13.2) (2019-09-24)
|
||||||
|
|
||||||
|
|
||||||
|
### Bug Fixes
|
||||||
|
|
||||||
|
* support multiaddr 7 ([#115](https://github.com/libp2p/js-libp2p-tcp/issues/115)) ([37cea53](https://github.com/libp2p/js-libp2p-tcp/commit/37cea53))
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
<a name="0.13.1"></a>
|
<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)
|
## [0.13.1](https://github.com/libp2p/js-libp2p-tcp/compare/v0.13.0...v0.13.1) (2019-08-08)
|
||||||
|
|
||||||
|
40
README.md
40
README.md
@ -13,7 +13,7 @@
|
|||||||
[](https://github.com/libp2p/interface-connection)
|
[](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 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 different transports.
|
||||||
|
|
||||||
## Lead Maintainer
|
## Lead Maintainer
|
||||||
|
|
||||||
@ -41,33 +41,37 @@
|
|||||||
```js
|
```js
|
||||||
const TCP = require('libp2p-tcp')
|
const TCP = require('libp2p-tcp')
|
||||||
const multiaddr = require('multiaddr')
|
const multiaddr = require('multiaddr')
|
||||||
const pipe = require('it-pipe')
|
const pull = require('pull-stream')
|
||||||
const { collect } = require('streaming-iterables')
|
|
||||||
|
|
||||||
const addr = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
const mh = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
||||||
|
|
||||||
const tcp = new TCP()
|
const tcp = new TCP()
|
||||||
|
|
||||||
const listener = tcp.createListener((socket) => {
|
const listener = tcp.createListener((socket) => {
|
||||||
console.log('new connection opened')
|
console.log('new connection opened')
|
||||||
pipe(
|
pull(
|
||||||
['hello'],
|
pull.values(['hello']),
|
||||||
socket
|
socket
|
||||||
)
|
)
|
||||||
})
|
})
|
||||||
|
|
||||||
await listener.listen(addr)
|
listener.listen(mh, () => {
|
||||||
console.log('listening')
|
console.log('listening')
|
||||||
|
|
||||||
const socket = await tcp.dial(addr)
|
pull(
|
||||||
const values = await pipe(
|
tcp.dial(mh),
|
||||||
socket,
|
pull.collect((err, values) => {
|
||||||
collect
|
if (!err) {
|
||||||
)
|
console.log(`Value: ${values.toString()}`)
|
||||||
console.log(`Value: ${values.toString()}`)
|
} else {
|
||||||
|
console.log(`Error: ${err}`)
|
||||||
|
}
|
||||||
|
|
||||||
// Close connection after reading
|
// Close connection after reading
|
||||||
await listener.close()
|
listener.close()
|
||||||
|
}),
|
||||||
|
)
|
||||||
|
})
|
||||||
```
|
```
|
||||||
|
|
||||||
Outputs:
|
Outputs:
|
||||||
@ -84,12 +88,12 @@ Value: hello
|
|||||||
|
|
||||||
[](https://github.com/libp2p/interface-transport)
|
[](https://github.com/libp2p/interface-transport)
|
||||||
|
|
||||||
`libp2p-tcp` accepts TCP addresses as both IPFS and non IPFS encapsulated addresses, i.e:
|
`libp2p-tcp` accepts TCP addresses both IPFS and non IPFS encapsulated addresses, i.e:
|
||||||
|
|
||||||
`/ip4/127.0.0.1/tcp/4001`
|
`/ip4/127.0.0.1/tcp/4001`
|
||||||
`/ip4/127.0.0.1/tcp/4001/ipfs/QmHash`
|
`/ip4/127.0.0.1/tcp/4001/ipfs/QmHash`
|
||||||
|
|
||||||
(both for dialing and listening)
|
Both for dialing and listening.
|
||||||
|
|
||||||
### Connection
|
### Connection
|
||||||
|
|
||||||
|
24
package.json
24
package.json
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "libp2p-tcp",
|
"name": "libp2p-tcp",
|
||||||
"version": "0.13.1",
|
"version": "0.13.2",
|
||||||
"description": "Node.js implementation of the TCP module that libp2p uses, which implements the interface-connection and interface-transport interfaces",
|
"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>",
|
"leadMaintainer": "Jacob Heun <jacobheun@gmail.com>",
|
||||||
"main": "src/index.js",
|
"main": "src/index.js",
|
||||||
@ -8,15 +8,15 @@
|
|||||||
"lint": "aegir lint",
|
"lint": "aegir lint",
|
||||||
"test": "aegir test -t node",
|
"test": "aegir test -t node",
|
||||||
"test:node": "aegir test -t node",
|
"test:node": "aegir test -t node",
|
||||||
"build": "aegir build",
|
|
||||||
"docs": "aegir docs",
|
|
||||||
"release": "aegir release -t node --no-build",
|
"release": "aegir release -t node --no-build",
|
||||||
"release-minor": "aegir release -t node --type minor --no-build",
|
"release-minor": "aegir release -t node --type minor --no-build",
|
||||||
"release-major": "aegir-release -t node --type major --no-build",
|
"release-major": "aegir-release -t node --type major --no-build",
|
||||||
"coverage": "nyc --reporter=text --reporter=lcov npm run test:node"
|
"coverage": "aegir coverage",
|
||||||
|
"coverage-publish": "aegir coverage --provider coveralls"
|
||||||
},
|
},
|
||||||
"pre-push": [
|
"pre-push": [
|
||||||
"lint"
|
"lint",
|
||||||
|
"test"
|
||||||
],
|
],
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
@ -38,23 +38,21 @@
|
|||||||
"aegir": "^20.0.0",
|
"aegir": "^20.0.0",
|
||||||
"chai": "^4.2.0",
|
"chai": "^4.2.0",
|
||||||
"dirty-chai": "^2.0.1",
|
"dirty-chai": "^2.0.1",
|
||||||
"pull-stream": "^3.6.9",
|
"interface-transport": "~0.3.6",
|
||||||
"sinon": "^7.4.1"
|
"pull-stream": "^3.6.14",
|
||||||
|
"multiaddr7": "npm:multiaddr@^7.0.0"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"abortable-iterator": "^2.1.0",
|
|
||||||
"class-is": "^1.1.0",
|
"class-is": "^1.1.0",
|
||||||
"debug": "^4.1.1",
|
"debug": "^4.1.1",
|
||||||
"err-code": "^1.1.2",
|
|
||||||
"interface-connection": "~0.3.3",
|
"interface-connection": "~0.3.3",
|
||||||
"interface-transport": "~0.5.2",
|
|
||||||
"ip-address": "^6.1.0",
|
"ip-address": "^6.1.0",
|
||||||
"it-pipe": "^1.0.1",
|
|
||||||
"lodash.includes": "^4.3.0",
|
"lodash.includes": "^4.3.0",
|
||||||
"lodash.isfunction": "^3.0.9",
|
"lodash.isfunction": "^3.0.9",
|
||||||
"mafmt": "^6.0.8",
|
"mafmt": "^6.0.7",
|
||||||
"multiaddr": "^6.1.0",
|
"multiaddr": "^6.1.0",
|
||||||
"streaming-iterables": "^4.1.0"
|
"once": "^1.4.0",
|
||||||
|
"stream-to-pull-stream": "^1.7.3"
|
||||||
},
|
},
|
||||||
"contributors": [
|
"contributors": [
|
||||||
"Alan Shaw <alan@tableflip.io>",
|
"Alan Shaw <alan@tableflip.io>",
|
||||||
|
@ -1,17 +0,0 @@
|
|||||||
'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 () {
|
|
||||||
super(new TCP())
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
module.exports = withIs(TcpAdapter, {
|
|
||||||
className: 'TCP',
|
|
||||||
symbolName: '@libp2p/js-libp2p-tcp/tcp'
|
|
||||||
})
|
|
@ -1,8 +0,0 @@
|
|||||||
'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
|
|
92
src/index.js
92
src/index.js
@ -1,76 +1,55 @@
|
|||||||
'use strict'
|
'use strict'
|
||||||
|
|
||||||
const net = require('net')
|
const net = require('net')
|
||||||
|
const toPull = require('stream-to-pull-stream')
|
||||||
const mafmt = require('mafmt')
|
const mafmt = require('mafmt')
|
||||||
const withIs = require('class-is')
|
const withIs = require('class-is')
|
||||||
const includes = require('lodash.includes')
|
const includes = require('lodash.includes')
|
||||||
const isFunction = require('lodash.isfunction')
|
const isFunction = require('lodash.isfunction')
|
||||||
const errcode = require('err-code')
|
const Connection = require('interface-connection').Connection
|
||||||
|
const once = require('once')
|
||||||
const debug = require('debug')
|
const debug = require('debug')
|
||||||
const log = debug('libp2p:tcp:dial')
|
const log = debug('libp2p:tcp:dial')
|
||||||
|
|
||||||
const Libp2pSocket = require('./socket')
|
|
||||||
const createListener = require('./listener')
|
const createListener = require('./listener')
|
||||||
const { AbortError } = require('interface-transport')
|
|
||||||
|
|
||||||
function noop () {}
|
function noop () {}
|
||||||
|
|
||||||
class TCP {
|
class TCP {
|
||||||
async dial (ma, options) {
|
dial (ma, options, callback) {
|
||||||
|
if (isFunction(options)) {
|
||||||
|
callback = options
|
||||||
|
options = {}
|
||||||
|
}
|
||||||
|
|
||||||
|
callback = once(callback || noop)
|
||||||
|
|
||||||
const cOpts = ma.toOptions()
|
const cOpts = ma.toOptions()
|
||||||
log('Dialing %s:%s', cOpts.host, cOpts.port)
|
log('Connecting to %s %s', cOpts.port, cOpts.host)
|
||||||
|
|
||||||
const rawSocket = await this._connect(cOpts, options)
|
const rawSocket = net.connect(cOpts)
|
||||||
return new Libp2pSocket(rawSocket, ma, options)
|
|
||||||
}
|
|
||||||
|
|
||||||
_connect (cOpts, options = {}) {
|
rawSocket.once('timeout', () => {
|
||||||
return new Promise((resolve, reject) => {
|
log('timeout')
|
||||||
if ((options.signal || {}).aborted) {
|
rawSocket.emit('error', new Error('Timeout'))
|
||||||
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) {
|
createListener (options, handler) {
|
||||||
@ -80,6 +59,7 @@ class TCP {
|
|||||||
}
|
}
|
||||||
|
|
||||||
handler = handler || noop
|
handler = handler || noop
|
||||||
|
|
||||||
return createListener(handler)
|
return createListener(handler)
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -93,7 +73,9 @@ class TCP {
|
|||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
if (includes(ma.protoNames(), 'ipfs')) {
|
if (typeof ma.decapsulateCode === 'function') {
|
||||||
|
ma = ma.decapsulateCode(421) // multiaddr 7
|
||||||
|
} else if (includes(ma.protoNames(), 'ipfs')) {
|
||||||
ma = ma.decapsulate('ipfs')
|
ma = ma.decapsulate('ipfs')
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1,26 +1,28 @@
|
|||||||
'use strict'
|
'use strict'
|
||||||
|
|
||||||
const multiaddr = require('multiaddr')
|
const multiaddr = require('multiaddr')
|
||||||
|
const Connection = require('interface-connection').Connection
|
||||||
const os = require('os')
|
const os = require('os')
|
||||||
const includes = require('lodash.includes')
|
const includes = require('lodash.includes')
|
||||||
const net = require('net')
|
const net = require('net')
|
||||||
|
const toPull = require('stream-to-pull-stream')
|
||||||
const EventEmitter = require('events').EventEmitter
|
const EventEmitter = require('events').EventEmitter
|
||||||
const debug = require('debug')
|
const debug = require('debug')
|
||||||
const log = debug('libp2p:tcp:listen')
|
const log = debug('libp2p:tcp:listen')
|
||||||
const logError = debug('libp2p:tcp:listen:error')
|
|
||||||
|
|
||||||
const Libp2pSocket = require('./socket')
|
|
||||||
const getMultiaddr = require('./get-multiaddr')
|
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) => {
|
||||||
const listener = new EventEmitter()
|
const listener = new EventEmitter()
|
||||||
|
|
||||||
const server = net.createServer((socket) => {
|
const server = net.createServer((socket) => {
|
||||||
// Avoid uncaught errors caused by unstable connections
|
// Avoid uncaught errors cause by unstable connections
|
||||||
socket.on('error', (err) => {
|
socket.on('error', noop)
|
||||||
logError('Error emitted by server handler socket: ' + err.message)
|
|
||||||
})
|
|
||||||
|
|
||||||
const addr = getMultiaddr(socket)
|
const addr = getMultiaddr(socket)
|
||||||
if (!addr) {
|
if (!addr) {
|
||||||
@ -34,11 +36,17 @@ module.exports = (handler) => {
|
|||||||
|
|
||||||
log('new connection', addr.toString())
|
log('new connection', addr.toString())
|
||||||
|
|
||||||
const s = new Libp2pSocket(socket, addr)
|
const s = toPull.duplex(socket)
|
||||||
|
|
||||||
|
s.getObservedAddrs = (cb) => {
|
||||||
|
cb(null, [addr])
|
||||||
|
}
|
||||||
|
|
||||||
trackSocket(server, socket)
|
trackSocket(server, socket)
|
||||||
|
|
||||||
handler && handler(s)
|
const conn = new Connection(s)
|
||||||
listener.emit('connection', s)
|
handler(conn)
|
||||||
|
listener.emit('connection', conn)
|
||||||
})
|
})
|
||||||
|
|
||||||
server.on('listening', () => listener.emit('listening'))
|
server.on('listening', () => listener.emit('listening'))
|
||||||
@ -48,60 +56,53 @@ module.exports = (handler) => {
|
|||||||
// Keep track of open connections to destroy in case of timeout
|
// Keep track of open connections to destroy in case of timeout
|
||||||
server.__connections = {}
|
server.__connections = {}
|
||||||
|
|
||||||
listener.close = (options = {}) => {
|
listener.close = (options, callback) => {
|
||||||
if (!server.listening) {
|
if (typeof options === 'function') {
|
||||||
return
|
callback = options
|
||||||
|
options = {}
|
||||||
}
|
}
|
||||||
|
callback = callback || noop
|
||||||
|
options = options || {}
|
||||||
|
|
||||||
return new Promise((resolve, reject) => {
|
const timeout = setTimeout(() => {
|
||||||
const start = Date.now()
|
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)
|
||||||
|
|
||||||
// Attempt to stop the server. If it takes longer than the timeout,
|
server.close(callback)
|
||||||
// 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 ipfsId
|
||||||
let listeningAddr
|
let listeningAddr
|
||||||
|
|
||||||
listener.listen = (ma) => {
|
listener.listen = (ma, callback) => {
|
||||||
listeningAddr = ma
|
listeningAddr = ma
|
||||||
if (includes(ma.protoNames(), 'ipfs')) {
|
if (typeof ma.decapsulateCode === 'function') {
|
||||||
|
ipfsId = getIpfsId(ma)
|
||||||
|
listeningAddr = ma.decapsulateCode(IPFS_CODE)
|
||||||
|
} else if (includes(ma.protoNames(), 'ipfs')) {
|
||||||
ipfsId = getIpfsId(ma)
|
ipfsId = getIpfsId(ma)
|
||||||
listeningAddr = ma.decapsulate('ipfs')
|
listeningAddr = ma.decapsulate('ipfs')
|
||||||
}
|
}
|
||||||
|
|
||||||
const lOpts = listeningAddr.toOptions()
|
const lOpts = listeningAddr.toOptions()
|
||||||
return new Promise((resolve, reject) => {
|
log('Listening on %s %s', lOpts.port, lOpts.host)
|
||||||
server.listen(lOpts.port, lOpts.host, (err) => {
|
return server.listen(lOpts.port, lOpts.host, callback)
|
||||||
if (err) {
|
|
||||||
return reject(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
log('Listening on %s %s', lOpts.port, lOpts.host)
|
|
||||||
resolve()
|
|
||||||
})
|
|
||||||
})
|
|
||||||
}
|
}
|
||||||
|
|
||||||
listener.getAddrs = () => {
|
listener.getAddrs = (callback) => {
|
||||||
const multiaddrs = []
|
const multiaddrs = []
|
||||||
const address = server.address()
|
const address = server.address()
|
||||||
|
|
||||||
if (!address) {
|
if (!address) {
|
||||||
throw new Error('Listener is not ready yet')
|
return callback(new Error('Listener is not ready yet'))
|
||||||
}
|
}
|
||||||
|
|
||||||
// Because TCP will only return the IPv6 version
|
// Because TCP will only return the IPv6 version
|
||||||
@ -136,7 +137,7 @@ module.exports = (handler) => {
|
|||||||
multiaddrs.push(ma)
|
multiaddrs.push(ma)
|
||||||
}
|
}
|
||||||
|
|
||||||
return multiaddrs
|
callback(null, multiaddrs)
|
||||||
}
|
}
|
||||||
|
|
||||||
return listener
|
return listener
|
||||||
@ -144,7 +145,7 @@ module.exports = (handler) => {
|
|||||||
|
|
||||||
function getIpfsId (ma) {
|
function getIpfsId (ma) {
|
||||||
return ma.stringTuples().filter((tuple) => {
|
return ma.stringTuples().filter((tuple) => {
|
||||||
return tuple[0] === c.IPFS_MA_CODE
|
return tuple[0] === IPFS_CODE
|
||||||
})[0][1]
|
})[0][1]
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -152,7 +153,7 @@ function trackSocket (server, socket) {
|
|||||||
const key = `${socket.remoteAddress}:${socket.remotePort}`
|
const key = `${socket.remoteAddress}:${socket.remotePort}`
|
||||||
server.__connections[key] = socket
|
server.__connections[key] = socket
|
||||||
|
|
||||||
socket.once('close', () => {
|
socket.on('close', () => {
|
||||||
delete server.__connections[key]
|
delete server.__connections[key]
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
@ -1,85 +0,0 @@
|
|||||||
'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.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
|
|
@ -1,111 +0,0 @@
|
|||||||
/* 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')
|
|
||||||
|
|
||||||
describe('valid Connection', () => {
|
|
||||||
let tcp
|
|
||||||
|
|
||||||
beforeEach(() => {
|
|
||||||
tcp = new TCP()
|
|
||||||
})
|
|
||||||
|
|
||||||
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)
|
|
||||||
})
|
|
||||||
}
|
|
||||||
})
|
|
||||||
})
|
|
||||||
})
|
|
@ -1,259 +0,0 @@
|
|||||||
/* 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 net = require('net')
|
|
||||||
const multiaddr = require('multiaddr')
|
|
||||||
const isCI = process.env.CI
|
|
||||||
|
|
||||||
describe('listen', () => {
|
|
||||||
let tcp
|
|
||||||
|
|
||||||
beforeEach(() => {
|
|
||||||
tcp = new TCP()
|
|
||||||
})
|
|
||||||
|
|
||||||
it('close listener with connections, through timeout', (done) => {
|
|
||||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
|
||||||
const listener = tcp.createListener((conn) => {
|
|
||||||
pull(conn, conn)
|
|
||||||
})
|
|
||||||
|
|
||||||
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', () => {})
|
|
||||||
socket1.on('connect', () => {
|
|
||||||
listener.close(done)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('listen on port 0', (done) => {
|
|
||||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/0')
|
|
||||||
const listener = tcp.createListener((conn) => {})
|
|
||||||
listener.listen(mh, () => {
|
|
||||||
listener.close(done)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('listen on IPv6 addr', (done) => {
|
|
||||||
if (isCI) { return done() }
|
|
||||||
const mh = multiaddr('/ip6/::/tcp/9090')
|
|
||||||
const listener = tcp.createListener((conn) => {})
|
|
||||||
listener.listen(mh, () => {
|
|
||||||
listener.close(done)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('listen on any Interface', (done) => {
|
|
||||||
const mh = multiaddr('/ip4/0.0.0.0/tcp/9090')
|
|
||||||
const listener = tcp.createListener((conn) => {})
|
|
||||||
listener.listen(mh, () => {
|
|
||||||
listener.close(done)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('getAddrs', (done) => {
|
|
||||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
|
||||||
const listener = tcp.createListener((conn) => {})
|
|
||||||
listener.listen(mh, () => {
|
|
||||||
listener.getAddrs((err, multiaddrs) => {
|
|
||||||
expect(err).to.not.exist()
|
|
||||||
expect(multiaddrs.length).to.equal(1)
|
|
||||||
expect(multiaddrs[0]).to.deep.equal(mh)
|
|
||||||
listener.close(done)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('getAddrs on port 0 listen', (done) => {
|
|
||||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/0')
|
|
||||||
const listener = tcp.createListener((conn) => {})
|
|
||||||
listener.listen(mh, () => {
|
|
||||||
listener.getAddrs((err, multiaddrs) => {
|
|
||||||
expect(err).to.not.exist()
|
|
||||||
expect(multiaddrs.length).to.equal(1)
|
|
||||||
listener.close(done)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('getAddrs from listening on 0.0.0.0', (done) => {
|
|
||||||
const mh = multiaddr('/ip4/0.0.0.0/tcp/9090')
|
|
||||||
const listener = tcp.createListener((conn) => {})
|
|
||||||
listener.listen(mh, () => {
|
|
||||||
listener.getAddrs((err, multiaddrs) => {
|
|
||||||
expect(err).to.not.exist()
|
|
||||||
expect(multiaddrs.length > 0).to.equal(true)
|
|
||||||
expect(multiaddrs[0].toString().indexOf('0.0.0.0')).to.equal(-1)
|
|
||||||
listener.close(done)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('getAddrs from listening on 0.0.0.0 and port 0', (done) => {
|
|
||||||
const mh = multiaddr('/ip4/0.0.0.0/tcp/0')
|
|
||||||
const listener = tcp.createListener((conn) => {})
|
|
||||||
listener.listen(mh, () => {
|
|
||||||
listener.getAddrs((err, multiaddrs) => {
|
|
||||||
expect(err).to.not.exist()
|
|
||||||
expect(multiaddrs.length > 0).to.equal(true)
|
|
||||||
expect(multiaddrs[0].toString().indexOf('0.0.0.0')).to.equal(-1)
|
|
||||||
listener.close(done)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('getAddrs preserves IPFS Id', (done) => {
|
|
||||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
|
||||||
const listener = tcp.createListener((conn) => {})
|
|
||||||
listener.listen(mh, () => {
|
|
||||||
listener.getAddrs((err, multiaddrs) => {
|
|
||||||
expect(err).to.not.exist()
|
|
||||||
expect(multiaddrs.length).to.equal(1)
|
|
||||||
expect(multiaddrs[0]).to.deep.equal(mh)
|
|
||||||
listener.close(done)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
describe('dial', () => {
|
|
||||||
let tcp
|
|
||||||
let listener
|
|
||||||
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
|
||||||
|
|
||||||
beforeEach((done) => {
|
|
||||||
tcp = new TCP()
|
|
||||||
listener = tcp.createListener((conn) => {
|
|
||||||
pull(
|
|
||||||
conn,
|
|
||||||
pull.map((x) => Buffer.from(x.toString() + '!')),
|
|
||||||
conn
|
|
||||||
)
|
|
||||||
})
|
|
||||||
listener.listen(ma, done)
|
|
||||||
})
|
|
||||||
|
|
||||||
afterEach((done) => {
|
|
||||||
listener.close(done)
|
|
||||||
})
|
|
||||||
|
|
||||||
it('dial on IPv4', (done) => {
|
|
||||||
pull(
|
|
||||||
pull.values(['hey']),
|
|
||||||
tcp.dial(ma),
|
|
||||||
pull.collect((err, values) => {
|
|
||||||
expect(err).to.not.exist()
|
|
||||||
expect(values).to.eql([Buffer.from('hey!')])
|
|
||||||
done()
|
|
||||||
})
|
|
||||||
)
|
|
||||||
})
|
|
||||||
|
|
||||||
it('dial to non existent listener', (done) => {
|
|
||||||
const ma = multiaddr('/ip4/127.0.0.1/tcp/8989')
|
|
||||||
pull(
|
|
||||||
tcp.dial(ma),
|
|
||||||
pull.onEnd((err) => {
|
|
||||||
expect(err).to.exist()
|
|
||||||
done()
|
|
||||||
})
|
|
||||||
)
|
|
||||||
})
|
|
||||||
|
|
||||||
it('dial on IPv6', (done) => {
|
|
||||||
if (isCI) { return done() }
|
|
||||||
|
|
||||||
const ma = multiaddr('/ip6/::/tcp/9066')
|
|
||||||
const listener = tcp.createListener((conn) => {
|
|
||||||
pull(conn, conn)
|
|
||||||
})
|
|
||||||
listener.listen(ma, () => {
|
|
||||||
pull(
|
|
||||||
pull.values(['hey']),
|
|
||||||
tcp.dial(ma),
|
|
||||||
pull.collect((err, values) => {
|
|
||||||
expect(err).to.not.exist()
|
|
||||||
|
|
||||||
expect(values).to.be.eql([Buffer.from('hey')])
|
|
||||||
|
|
||||||
listener.close(done)
|
|
||||||
})
|
|
||||||
)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
it('dial and destroy on listener', (done) => {
|
|
||||||
let count = 0
|
|
||||||
const closed = () => ++count === 2 ? finish() : null
|
|
||||||
|
|
||||||
const ma = multiaddr('/ip6/::/tcp/9067')
|
|
||||||
|
|
||||||
const listener = tcp.createListener((conn) => {
|
|
||||||
pull(
|
|
||||||
pull.empty(),
|
|
||||||
conn,
|
|
||||||
pull.onEnd(closed)
|
|
||||||
)
|
|
||||||
})
|
|
||||||
|
|
||||||
listener.listen(ma, () => {
|
|
||||||
pull(tcp.dial(ma), pull.onEnd(closed))
|
|
||||||
})
|
|
||||||
|
|
||||||
function finish () {
|
|
||||||
listener.close(done)
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
it('dial and destroy on dialer', (done) => {
|
|
||||||
if (isCI) { return done() }
|
|
||||||
|
|
||||||
let count = 0
|
|
||||||
const destroyed = () => ++count === 2 ? finish() : null
|
|
||||||
|
|
||||||
const ma = multiaddr('/ip6/::/tcp/9068')
|
|
||||||
|
|
||||||
const listener = tcp.createListener((conn) => {
|
|
||||||
pull(conn, pull.onEnd(destroyed))
|
|
||||||
})
|
|
||||||
|
|
||||||
listener.listen(ma, () => {
|
|
||||||
pull(
|
|
||||||
pull.empty(),
|
|
||||||
tcp.dial(ma),
|
|
||||||
pull.onEnd(destroyed)
|
|
||||||
)
|
|
||||||
})
|
|
||||||
|
|
||||||
function finish () {
|
|
||||||
listener.close(done)
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
it('dial on IPv4 with IPFS Id', (done) => {
|
|
||||||
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
|
||||||
const conn = tcp.dial(ma)
|
|
||||||
|
|
||||||
pull(
|
|
||||||
pull.values(['hey']),
|
|
||||||
conn,
|
|
||||||
pull.collect((err, res) => {
|
|
||||||
expect(err).to.not.exist()
|
|
||||||
expect(res).to.be.eql([Buffer.from('hey!')])
|
|
||||||
done()
|
|
||||||
})
|
|
||||||
)
|
|
||||||
})
|
|
||||||
})
|
|
@ -1,15 +1,13 @@
|
|||||||
/* eslint-env mocha */
|
/* eslint-env mocha */
|
||||||
'use strict'
|
'use strict'
|
||||||
|
|
||||||
const sinon = require('sinon')
|
|
||||||
const tests = require('interface-transport')
|
const tests = require('interface-transport')
|
||||||
const multiaddr = require('multiaddr')
|
const multiaddr = require('multiaddr')
|
||||||
const net = require('net')
|
|
||||||
const TCP = require('../src')
|
const TCP = require('../src')
|
||||||
|
|
||||||
describe('interface-transport compliance', () => {
|
describe('interface-transport compliance', () => {
|
||||||
tests({
|
tests({
|
||||||
setup () {
|
setup (cb) {
|
||||||
const tcp = new TCP()
|
const tcp = new TCP()
|
||||||
const addrs = [
|
const addrs = [
|
||||||
multiaddr('/ip4/127.0.0.1/tcp/9091'),
|
multiaddr('/ip4/127.0.0.1/tcp/9091'),
|
||||||
@ -17,27 +15,10 @@ describe('interface-transport compliance', () => {
|
|||||||
multiaddr('/ip4/127.0.0.1/tcp/9093'),
|
multiaddr('/ip4/127.0.0.1/tcp/9093'),
|
||||||
multiaddr('/dns4/ipfs.io')
|
multiaddr('/dns4/ipfs.io')
|
||||||
]
|
]
|
||||||
|
cb(null, tcp, addrs)
|
||||||
// Used by the dial tests to simulate a delayed connect
|
},
|
||||||
const connector = {
|
teardown (cb) {
|
||||||
delay (delayMs) {
|
cb()
|
||||||
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 }
|
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
@ -6,7 +6,7 @@ const chai = require('chai')
|
|||||||
const dirtyChai = require('dirty-chai')
|
const dirtyChai = require('dirty-chai')
|
||||||
const expect = chai.expect
|
const expect = chai.expect
|
||||||
chai.use(dirtyChai)
|
chai.use(dirtyChai)
|
||||||
const TCP = require('../../src/adapter')
|
const TCP = require('../src')
|
||||||
const multiaddr = require('multiaddr')
|
const multiaddr = require('multiaddr')
|
||||||
const Connection = require('interface-connection').Connection
|
const Connection = require('interface-connection').Connection
|
||||||
|
|
@ -1,6 +1,7 @@
|
|||||||
/* eslint-env mocha */
|
/* eslint-env mocha */
|
||||||
'use strict'
|
'use strict'
|
||||||
|
|
||||||
|
const pull = require('pull-stream')
|
||||||
const chai = require('chai')
|
const chai = require('chai')
|
||||||
const dirtyChai = require('dirty-chai')
|
const dirtyChai = require('dirty-chai')
|
||||||
const expect = chai.expect
|
const expect = chai.expect
|
||||||
@ -17,39 +18,94 @@ describe('valid Connection', () => {
|
|||||||
|
|
||||||
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
||||||
|
|
||||||
it('get observed addrs', async () => {
|
it('get observed addrs', (done) => {
|
||||||
// Create a Promise that resolves when a connection is handled
|
let dialerObsAddrs
|
||||||
let handled
|
|
||||||
const handlerPromise = new Promise((resolve) => {
|
const listener = tcp.createListener((conn) => {
|
||||||
handled = resolve
|
expect(conn).to.exist()
|
||||||
|
conn.getObservedAddrs((err, addrs) => {
|
||||||
|
expect(err).to.not.exist()
|
||||||
|
dialerObsAddrs = addrs
|
||||||
|
pull(pull.empty(), conn)
|
||||||
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
const handler = async (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()
|
expect(conn).to.exist()
|
||||||
const dialerObsAddrs = await conn.getObservedAddrs()
|
conn.getPeerInfo((err, peerInfo) => {
|
||||||
handled(dialerObsAddrs)
|
expect(err).to.exist()
|
||||||
}
|
expect(peerInfo).to.not.exist()
|
||||||
|
pull(pull.empty(), conn)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
// Create a listener with the handler
|
listener.listen(ma, () => {
|
||||||
const listener = tcp.createListener(handler)
|
const conn = tcp.dial(ma)
|
||||||
|
|
||||||
// Listen on the multi-address
|
pull(conn, pull.onEnd(endHandler))
|
||||||
await listener.listen(ma)
|
|
||||||
|
|
||||||
// Dial to that same address
|
function endHandler () {
|
||||||
const conn = await tcp.dial(ma)
|
conn.getPeerInfo((err, peerInfo) => {
|
||||||
const addrs = await conn.getObservedAddrs()
|
expect(err).to.exist()
|
||||||
|
expect(peerInfo).to.not.exist()
|
||||||
|
|
||||||
// Wait for the incoming dial to be handled
|
listener.close(done)
|
||||||
const dialerObsAddrs = await handlerPromise
|
})
|
||||||
|
}
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
// Close the listener
|
it('set Peer Info', (done) => {
|
||||||
await listener.close()
|
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)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
// The addresses should match
|
listener.listen(ma, () => {
|
||||||
expect(addrs.length).to.equal(1)
|
const conn = tcp.dial(ma)
|
||||||
expect(addrs[0]).to.deep.equal(ma)
|
|
||||||
expect(dialerObsAddrs.length).to.equal(1)
|
pull(conn, pull.onEnd(endHandler))
|
||||||
expect(dialerObsAddrs[0]).to.exist()
|
|
||||||
|
function endHandler () {
|
||||||
|
conn.setPeerInfo('arroz')
|
||||||
|
conn.getPeerInfo((err, peerInfo) => {
|
||||||
|
expect(err).to.not.exist()
|
||||||
|
expect(peerInfo).to.equal('arroz')
|
||||||
|
|
||||||
|
listener.close(done)
|
||||||
|
})
|
||||||
|
}
|
||||||
|
})
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
@ -7,6 +7,7 @@ const expect = chai.expect
|
|||||||
chai.use(dirtyChai)
|
chai.use(dirtyChai)
|
||||||
const TCP = require('../src')
|
const TCP = require('../src')
|
||||||
const multiaddr = require('multiaddr')
|
const multiaddr = require('multiaddr')
|
||||||
|
const multiaddr7 = require('multiaddr7')
|
||||||
|
|
||||||
describe('filter addrs', () => {
|
describe('filter addrs', () => {
|
||||||
const base = '/ip4/127.0.0.1'
|
const base = '/ip4/127.0.0.1'
|
||||||
@ -27,11 +28,13 @@ describe('filter addrs', () => {
|
|||||||
const ma6 = multiaddr('/ip4/127.0.0.1/tcp/9090/p2p-circuit' + ipfs)
|
const ma6 = multiaddr('/ip4/127.0.0.1/tcp/9090/p2p-circuit' + ipfs)
|
||||||
const ma7 = multiaddr('/dns4/libp2p.io/tcp/9090')
|
const ma7 = multiaddr('/dns4/libp2p.io/tcp/9090')
|
||||||
const ma8 = multiaddr('/dnsaddr/libp2p.io/tcp/9090')
|
const ma8 = multiaddr('/dnsaddr/libp2p.io/tcp/9090')
|
||||||
|
const ma9 = multiaddr7(base + '/tcp/9090/p2p/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
||||||
|
|
||||||
const valid = tcp.filter([ma1, ma2, ma3, ma4, ma5, ma6, ma7, ma8])
|
const valid = tcp.filter([ma1, ma2, ma3, ma4, ma5, ma6, ma7, ma8, ma9])
|
||||||
expect(valid.length).to.equal(4)
|
expect(valid.length).to.equal(5)
|
||||||
expect(valid[0]).to.deep.equal(ma1)
|
expect(valid[0]).to.deep.equal(ma1)
|
||||||
expect(valid[1]).to.deep.equal(ma4)
|
expect(valid[1]).to.deep.equal(ma4)
|
||||||
|
expect(valid[4]).to.deep.equal(ma9)
|
||||||
})
|
})
|
||||||
|
|
||||||
it('filter a single addr for this transport', () => {
|
it('filter a single addr for this transport', () => {
|
||||||
|
@ -1,16 +1,15 @@
|
|||||||
/* eslint-env mocha */
|
/* eslint-env mocha */
|
||||||
'use strict'
|
'use strict'
|
||||||
|
|
||||||
|
const pull = require('pull-stream')
|
||||||
const chai = require('chai')
|
const chai = require('chai')
|
||||||
const dirtyChai = require('dirty-chai')
|
const dirtyChai = require('dirty-chai')
|
||||||
const expect = chai.expect
|
const expect = chai.expect
|
||||||
chai.use(dirtyChai)
|
chai.use(dirtyChai)
|
||||||
|
|
||||||
const TCP = require('../src')
|
const TCP = require('../src')
|
||||||
const net = require('net')
|
const net = require('net')
|
||||||
const multiaddr = require('multiaddr')
|
const multiaddr = require('multiaddr')
|
||||||
const pipe = require('it-pipe')
|
const multiaddr7 = require('multiaddr7')
|
||||||
const { collect, map } = require('streaming-iterables')
|
|
||||||
const isCI = process.env.CI
|
const isCI = process.env.CI
|
||||||
|
|
||||||
describe('listen', () => {
|
describe('listen', () => {
|
||||||
@ -20,111 +19,126 @@ describe('listen', () => {
|
|||||||
tcp = new TCP()
|
tcp = new TCP()
|
||||||
})
|
})
|
||||||
|
|
||||||
it('close listener with connections, through timeout', async () => {
|
it('close listener with connections, through timeout', (done) => {
|
||||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
const mh = multiaddr('/ip4/127.0.0.1/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
||||||
const listener = tcp.createListener((conn) => {
|
const listener = tcp.createListener((conn) => {
|
||||||
pipe(conn, conn)
|
pull(conn, conn)
|
||||||
})
|
})
|
||||||
|
|
||||||
await listener.listen(mh)
|
listener.listen(mh, () => {
|
||||||
|
const socket1 = net.connect(9090)
|
||||||
|
const socket2 = net.connect(9090)
|
||||||
|
|
||||||
const socket1 = net.connect(9090)
|
socket1.write('Some data that is never handled')
|
||||||
const socket2 = net.connect(9090)
|
socket1.end()
|
||||||
|
socket1.on('error', () => {})
|
||||||
socket1.write('Some data that is never handled')
|
socket2.on('error', () => {})
|
||||||
socket1.end()
|
socket1.on('connect', () => {
|
||||||
socket1.on('error', () => {})
|
listener.close(done)
|
||||||
socket2.on('error', () => {})
|
|
||||||
|
|
||||||
await new Promise((resolve) => {
|
|
||||||
socket1.on('connect', async () => {
|
|
||||||
await listener.close({ timeout: 100 })
|
|
||||||
resolve()
|
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
it('listen on port 0', async () => {
|
it('listen on port 0', (done) => {
|
||||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/0')
|
const mh = multiaddr('/ip4/127.0.0.1/tcp/0')
|
||||||
const listener = tcp.createListener((conn) => {})
|
const listener = tcp.createListener((conn) => {})
|
||||||
await listener.listen(mh)
|
listener.listen(mh, () => {
|
||||||
await listener.close()
|
listener.close(done)
|
||||||
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
it('listen on IPv6 addr', async () => {
|
it('listen on IPv6 addr', (done) => {
|
||||||
if (isCI) {
|
if (isCI) { return done() }
|
||||||
return
|
|
||||||
}
|
|
||||||
const mh = multiaddr('/ip6/::/tcp/9090')
|
const mh = multiaddr('/ip6/::/tcp/9090')
|
||||||
const listener = tcp.createListener((conn) => {})
|
const listener = tcp.createListener((conn) => {})
|
||||||
await listener.listen(mh)
|
listener.listen(mh, () => {
|
||||||
await listener.close()
|
listener.close(done)
|
||||||
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
it('listen on any Interface', async () => {
|
it('listen on any Interface', (done) => {
|
||||||
const mh = multiaddr('/ip4/0.0.0.0/tcp/9090')
|
const mh = multiaddr('/ip4/0.0.0.0/tcp/9090')
|
||||||
const listener = tcp.createListener((conn) => {})
|
const listener = tcp.createListener((conn) => {})
|
||||||
await listener.listen(mh)
|
listener.listen(mh, () => {
|
||||||
await listener.close()
|
listener.close(done)
|
||||||
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
it('getAddrs', async () => {
|
it('getAddrs', (done) => {
|
||||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
const mh = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
||||||
const listener = tcp.createListener((conn) => {})
|
const listener = tcp.createListener((conn) => {})
|
||||||
await listener.listen(mh)
|
listener.listen(mh, () => {
|
||||||
|
listener.getAddrs((err, multiaddrs) => {
|
||||||
const multiaddrs = listener.getAddrs()
|
expect(err).to.not.exist()
|
||||||
expect(multiaddrs.length).to.equal(1)
|
expect(multiaddrs.length).to.equal(1)
|
||||||
expect(multiaddrs[0]).to.deep.equal(mh)
|
expect(multiaddrs[0]).to.deep.equal(mh)
|
||||||
|
listener.close(done)
|
||||||
await listener.close()
|
})
|
||||||
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
it('getAddrs on port 0 listen', async () => {
|
it('getAddrs on port 0 listen', (done) => {
|
||||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/0')
|
const mh = multiaddr('/ip4/127.0.0.1/tcp/0')
|
||||||
const listener = tcp.createListener((conn) => {})
|
const listener = tcp.createListener((conn) => {})
|
||||||
await listener.listen(mh)
|
listener.listen(mh, () => {
|
||||||
|
listener.getAddrs((err, multiaddrs) => {
|
||||||
const multiaddrs = listener.getAddrs()
|
expect(err).to.not.exist()
|
||||||
expect(multiaddrs.length).to.equal(1)
|
expect(multiaddrs.length).to.equal(1)
|
||||||
|
listener.close(done)
|
||||||
await listener.close()
|
})
|
||||||
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
it('getAddrs from listening on 0.0.0.0', async () => {
|
it('getAddrs from listening on 0.0.0.0', (done) => {
|
||||||
const mh = multiaddr('/ip4/0.0.0.0/tcp/9090')
|
const mh = multiaddr('/ip4/0.0.0.0/tcp/9090')
|
||||||
const listener = tcp.createListener((conn) => {})
|
const listener = tcp.createListener((conn) => {})
|
||||||
await listener.listen(mh)
|
listener.listen(mh, () => {
|
||||||
|
listener.getAddrs((err, multiaddrs) => {
|
||||||
const multiaddrs = listener.getAddrs()
|
expect(err).to.not.exist()
|
||||||
expect(multiaddrs.length > 0).to.equal(true)
|
expect(multiaddrs.length > 0).to.equal(true)
|
||||||
expect(multiaddrs[0].toString().indexOf('0.0.0.0')).to.equal(-1)
|
expect(multiaddrs[0].toString().indexOf('0.0.0.0')).to.equal(-1)
|
||||||
|
listener.close(done)
|
||||||
await listener.close()
|
})
|
||||||
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
it('getAddrs from listening on 0.0.0.0 and port 0', async () => {
|
it('getAddrs from listening on 0.0.0.0 and port 0', (done) => {
|
||||||
const mh = multiaddr('/ip4/0.0.0.0/tcp/0')
|
const mh = multiaddr('/ip4/0.0.0.0/tcp/0')
|
||||||
const listener = tcp.createListener((conn) => {})
|
const listener = tcp.createListener((conn) => {})
|
||||||
await listener.listen(mh)
|
listener.listen(mh, () => {
|
||||||
|
listener.getAddrs((err, multiaddrs) => {
|
||||||
const multiaddrs = listener.getAddrs()
|
expect(err).to.not.exist()
|
||||||
expect(multiaddrs.length > 0).to.equal(true)
|
expect(multiaddrs.length > 0).to.equal(true)
|
||||||
expect(multiaddrs[0].toString().indexOf('0.0.0.0')).to.equal(-1)
|
expect(multiaddrs[0].toString().indexOf('0.0.0.0')).to.equal(-1)
|
||||||
|
listener.close(done)
|
||||||
await listener.close()
|
})
|
||||||
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
it('getAddrs preserves IPFS Id', async () => {
|
it('getAddrs preserves IPFS Id', (done) => {
|
||||||
const mh = multiaddr('/ip4/127.0.0.1/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
const mh = multiaddr('/ip4/127.0.0.1/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
||||||
const listener = tcp.createListener((conn) => {})
|
const listener = tcp.createListener((conn) => {})
|
||||||
await listener.listen(mh)
|
listener.listen(mh, () => {
|
||||||
|
listener.getAddrs((err, multiaddrs) => {
|
||||||
|
expect(err).to.not.exist()
|
||||||
|
expect(multiaddrs.length).to.equal(1)
|
||||||
|
expect(multiaddrs[0]).to.deep.equal(mh)
|
||||||
|
listener.close(done)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
const multiaddrs = listener.getAddrs()
|
it('getAddrs preserves IPFS Id (multiaddr 7)', (done) => {
|
||||||
expect(multiaddrs.length).to.equal(1)
|
const mh = multiaddr7('/ip4/127.0.0.1/tcp/9090/p2p/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
||||||
expect(multiaddrs[0]).to.deep.equal(mh)
|
const listener = tcp.createListener((conn) => {})
|
||||||
|
listener.listen(mh, () => {
|
||||||
await listener.close()
|
listener.getAddrs((err, multiaddrs) => {
|
||||||
|
expect(err).to.not.exist()
|
||||||
|
expect(multiaddrs.length).to.equal(1)
|
||||||
|
expect(multiaddrs[0]).to.deep.equal(mh)
|
||||||
|
listener.close(done)
|
||||||
|
})
|
||||||
|
})
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
@ -133,109 +147,142 @@ describe('dial', () => {
|
|||||||
let listener
|
let listener
|
||||||
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090')
|
||||||
|
|
||||||
beforeEach(async () => {
|
beforeEach((done) => {
|
||||||
tcp = new TCP()
|
tcp = new TCP()
|
||||||
listener = tcp.createListener((conn) => {
|
listener = tcp.createListener((conn) => {
|
||||||
pipe(
|
pull(
|
||||||
conn,
|
conn,
|
||||||
map((x) => Buffer.from(x.toString() + '!')),
|
pull.map((x) => Buffer.from(x.toString() + '!')),
|
||||||
conn
|
conn
|
||||||
)
|
)
|
||||||
})
|
})
|
||||||
await listener.listen(ma)
|
listener.listen(ma, done)
|
||||||
})
|
})
|
||||||
|
|
||||||
afterEach(() => listener.close())
|
afterEach((done) => {
|
||||||
|
listener.close(done)
|
||||||
|
})
|
||||||
|
|
||||||
it('dial on IPv4', async () => {
|
it('dial on IPv4', (done) => {
|
||||||
const values = await pipe(
|
pull(
|
||||||
['hey'],
|
pull.values(['hey']),
|
||||||
await tcp.dial(ma),
|
tcp.dial(ma),
|
||||||
collect
|
pull.collect((err, values) => {
|
||||||
|
expect(err).to.not.exist()
|
||||||
|
expect(values).to.eql([Buffer.from('hey!')])
|
||||||
|
done()
|
||||||
|
})
|
||||||
)
|
)
|
||||||
expect(values).to.eql([Buffer.from('hey!')])
|
|
||||||
})
|
})
|
||||||
|
|
||||||
it('dial on IPv6', async () => {
|
it('dial to non existent listener', (done) => {
|
||||||
if (isCI) {
|
const ma = multiaddr('/ip4/127.0.0.1/tcp/8989')
|
||||||
return
|
pull(
|
||||||
}
|
tcp.dial(ma),
|
||||||
|
pull.onEnd((err) => {
|
||||||
|
expect(err).to.exist()
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial on IPv6', (done) => {
|
||||||
|
if (isCI) { return done() }
|
||||||
|
|
||||||
const ma = multiaddr('/ip6/::/tcp/9066')
|
const ma = multiaddr('/ip6/::/tcp/9066')
|
||||||
const listener = tcp.createListener((conn) => {
|
const listener = tcp.createListener((conn) => {
|
||||||
pipe(conn, conn)
|
pull(conn, conn)
|
||||||
})
|
})
|
||||||
await listener.listen(ma)
|
listener.listen(ma, () => {
|
||||||
|
pull(
|
||||||
|
pull.values(['hey']),
|
||||||
|
tcp.dial(ma),
|
||||||
|
pull.collect((err, values) => {
|
||||||
|
expect(err).to.not.exist()
|
||||||
|
|
||||||
const values = await pipe(
|
expect(values).to.be.eql([Buffer.from('hey')])
|
||||||
['hey'],
|
|
||||||
await tcp.dial(ma),
|
|
||||||
collect
|
|
||||||
)
|
|
||||||
expect(values).to.be.eql([Buffer.from('hey')])
|
|
||||||
|
|
||||||
await listener.close()
|
listener.close(done)
|
||||||
})
|
})
|
||||||
|
|
||||||
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 () => {
|
it('dial and destroy on listener', (done) => {
|
||||||
if (isCI) {
|
let count = 0
|
||||||
return
|
const closed = () => ++count === 2 ? finish() : null
|
||||||
|
|
||||||
|
const ma = multiaddr('/ip6/::/tcp/9067')
|
||||||
|
|
||||||
|
const listener = tcp.createListener((conn) => {
|
||||||
|
pull(
|
||||||
|
pull.empty(),
|
||||||
|
conn,
|
||||||
|
pull.onEnd(closed)
|
||||||
|
)
|
||||||
|
})
|
||||||
|
|
||||||
|
listener.listen(ma, () => {
|
||||||
|
pull(tcp.dial(ma), pull.onEnd(closed))
|
||||||
|
})
|
||||||
|
|
||||||
|
function finish () {
|
||||||
|
listener.close(done)
|
||||||
}
|
}
|
||||||
|
|
||||||
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 () => {
|
it('dial and destroy on dialer', (done) => {
|
||||||
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
if (isCI) { return done() }
|
||||||
const conn = await tcp.dial(ma)
|
|
||||||
|
|
||||||
const res = await pipe(
|
let count = 0
|
||||||
['hey'],
|
const destroyed = () => ++count === 2 ? finish() : null
|
||||||
|
|
||||||
|
const ma = multiaddr('/ip6/::/tcp/9068')
|
||||||
|
|
||||||
|
const listener = tcp.createListener((conn) => {
|
||||||
|
pull(conn, pull.onEnd(destroyed))
|
||||||
|
})
|
||||||
|
|
||||||
|
listener.listen(ma, () => {
|
||||||
|
pull(
|
||||||
|
pull.empty(),
|
||||||
|
tcp.dial(ma),
|
||||||
|
pull.onEnd(destroyed)
|
||||||
|
)
|
||||||
|
})
|
||||||
|
|
||||||
|
function finish () {
|
||||||
|
listener.close(done)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial on IPv4 with IPFS Id', (done) => {
|
||||||
|
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
||||||
|
const conn = tcp.dial(ma)
|
||||||
|
|
||||||
|
pull(
|
||||||
|
pull.values(['hey']),
|
||||||
conn,
|
conn,
|
||||||
collect
|
pull.collect((err, res) => {
|
||||||
|
expect(err).to.not.exist()
|
||||||
|
expect(res).to.be.eql([Buffer.from('hey!')])
|
||||||
|
done()
|
||||||
|
})
|
||||||
|
)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('dial on IPv4 with IPFS Id multiaddr7', (done) => {
|
||||||
|
const ma = multiaddr7('/ip4/127.0.0.1/tcp/9090/p2p/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
||||||
|
const conn = tcp.dial(ma)
|
||||||
|
|
||||||
|
pull(
|
||||||
|
pull.values(['hey']),
|
||||||
|
conn,
|
||||||
|
pull.collect((err, res) => {
|
||||||
|
expect(err).to.not.exist()
|
||||||
|
expect(res).to.be.eql([Buffer.from('hey!')])
|
||||||
|
done()
|
||||||
|
})
|
||||||
)
|
)
|
||||||
expect(res).to.be.eql([Buffer.from('hey!')])
|
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
Reference in New Issue
Block a user