mirror of
https://github.com/fluencelabs/js-libp2p-tcp
synced 2025-07-01 18:31:33 +00:00
Compare commits
8 Commits
Author | SHA1 | Date | |
---|---|---|---|
e01046eb03 | |||
918b9df322 | |||
31b47fbfd2 | |||
26e9268bb5 | |||
676b5f3dbf | |||
ad7a331d9a | |||
a00c38437e | |||
cf0e9a1a8f |
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "libp2p-tcp",
|
||||
"version": "0.7.2",
|
||||
"version": "0.7.4",
|
||||
"description": "Node.js implementation of the TCP module that libp2p uses, which implements the interface-connection and interface-transport interfaces",
|
||||
"main": "lib/index.js",
|
||||
"jsnext:main": "src/index.js",
|
||||
@ -32,15 +32,14 @@
|
||||
},
|
||||
"homepage": "https://github.com/diasdavid/js-libp2p-tcp",
|
||||
"devDependencies": {
|
||||
"aegir": "^3.0.4",
|
||||
"aegir": "^4.0.0",
|
||||
"chai": "^3.5.0",
|
||||
"interface-transport": "^0.2.0",
|
||||
"pre-commit": "^1.1.2",
|
||||
"tape": "^4.5.1"
|
||||
},
|
||||
"dependencies": {
|
||||
"duplexify": "^3.4.3",
|
||||
"interface-connection": "0.1.2",
|
||||
"interface-connection": "0.1.8",
|
||||
"ip-address": "^5.8.0",
|
||||
"lodash.contains": "^2.4.3",
|
||||
"mafmt": "^2.1.0",
|
||||
|
@ -243,6 +243,61 @@ describe('dial', () => {
|
||||
}
|
||||
})
|
||||
|
||||
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) => {
|
||||
conn.on('close', closed)
|
||||
conn.destroy()
|
||||
})
|
||||
|
||||
listener.listen(ma, dialStep)
|
||||
|
||||
function dialStep () {
|
||||
const conn = tcp.dial(ma)
|
||||
conn.on('close', closed)
|
||||
}
|
||||
|
||||
function finish () {
|
||||
listener.close(done)
|
||||
}
|
||||
})
|
||||
|
||||
it('dial and destroy on dialer', (done) => {
|
||||
let count = 0
|
||||
const destroyed = () => ++count === 2 ? finish() : null
|
||||
|
||||
const ma = multiaddr('/ip6/::/tcp/9068')
|
||||
|
||||
const listener = tcp.createListener((conn) => {
|
||||
conn.on('close', () => {
|
||||
console.log('closed on the listener socket')
|
||||
destroyed()
|
||||
})
|
||||
})
|
||||
|
||||
listener.listen(ma, dialStep)
|
||||
|
||||
function dialStep () {
|
||||
const conn = tcp.dial(ma)
|
||||
conn.on('close', () => {
|
||||
console.log('closed on the dialer socket')
|
||||
destroyed()
|
||||
})
|
||||
conn.resume()
|
||||
setTimeout(() => {
|
||||
conn.destroy()
|
||||
}, 10)
|
||||
}
|
||||
|
||||
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)
|
||||
|
Reference in New Issue
Block a user