mirror of
https://github.com/fluencelabs/js-libp2p-tcp
synced 2025-04-26 12:52:15 +00:00
use duplexify fork while PR is not up yet
This commit is contained in:
parent
d2f91814b6
commit
cf0e9a1a8f
@ -39,8 +39,7 @@
|
|||||||
"tape": "^4.5.1"
|
"tape": "^4.5.1"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"duplexify": "^3.4.3",
|
"interface-connection": "0.1.6",
|
||||||
"interface-connection": "0.1.2",
|
|
||||||
"ip-address": "^5.8.0",
|
"ip-address": "^5.8.0",
|
||||||
"lodash.contains": "^2.4.3",
|
"lodash.contains": "^2.4.3",
|
||||||
"mafmt": "^2.1.0",
|
"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) => {
|
it('dial on IPv4 with IPFS Id', (done) => {
|
||||||
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090/ipfs/Qmb6owHp6eaWArVbcJJbQSyifyJBttMMjYV76N2hMbf5Vw')
|
||||||
const conn = tcp.dial(ma)
|
const conn = tcp.dial(ma)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user