mirror of
https://github.com/fluencelabs/js-libp2p-tcp
synced 2025-04-25 12:22:37 +00:00
44 lines
1.2 KiB
JavaScript
44 lines
1.2 KiB
JavaScript
/* 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 () {
|
|
const tcp = new TCP()
|
|
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('/dns4/ipfs.io')
|
|
]
|
|
|
|
// 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 }
|
|
}
|
|
})
|
|
})
|