mirror of
https://github.com/fluencelabs/js-libp2p
synced 2025-05-11 18:27:14 +00:00
cd97abfcc3
* test: remove all tests for a clean slate The refactor will require a large number of updates to the tests. In order to ensure we have done a decent deduplication, and have a cleaner suite of tests we've removed all tests. This will also allow us to more easily see tests for the refactored systems. We have a record of the latest test suites in master, so we are not losing any history. * chore: update tcp and websockets * chore: remove other transports until they are converted * chore: use mafmt and multiaddr async versions * chore: add and fix dependencies * chore: clean up travis file * feat: add new transport manager * docs: add constructor jsdocs * refactor(config): check that transports exist This also removes the other logic, it can be added when those subsystems are refactored * chore(deps): use async peer-id and peer-info * feat: wire up the transport manager with libp2p * chore: remove superstruct dep
57 lines
1.6 KiB
JavaScript
57 lines
1.6 KiB
JavaScript
'use strict'
|
|
/* eslint-env mocha */
|
|
|
|
const chai = require('chai')
|
|
chai.use(require('dirty-chai'))
|
|
const { expect } = chai
|
|
const TransportManager = require('../../src/transport-manager')
|
|
const Transport = require('libp2p-tcp')
|
|
const multiaddr = require('multiaddr')
|
|
const mockUpgrader = require('../utils/mockUpgrader')
|
|
const addrs = [
|
|
multiaddr('/ip4/127.0.0.1/tcp/0'),
|
|
multiaddr('/ip4/127.0.0.1/tcp/0')
|
|
]
|
|
|
|
describe('Transport Manager (TCP)', () => {
|
|
let tm
|
|
|
|
before(() => {
|
|
tm = new TransportManager({
|
|
libp2p: {},
|
|
upgrader: mockUpgrader,
|
|
onConnection: () => {}
|
|
})
|
|
})
|
|
|
|
afterEach(async () => {
|
|
await tm.removeAll()
|
|
expect(tm._transports.size).to.equal(0)
|
|
})
|
|
|
|
it('should be able to add and remove a transport', async () => {
|
|
tm.add(Transport.prototype[Symbol.toStringTag], Transport)
|
|
expect(tm._transports.size).to.equal(1)
|
|
await tm.remove(Transport.prototype[Symbol.toStringTag])
|
|
})
|
|
|
|
it('should be able to listen', async () => {
|
|
tm.add(Transport.prototype[Symbol.toStringTag], Transport)
|
|
await tm.listen(addrs)
|
|
expect(tm._listeners.size).to.equal(1)
|
|
// Ephemeral ip addresses may result in multiple listeners
|
|
expect(tm.getAddrs().length).to.equal(addrs.length)
|
|
await tm.close()
|
|
expect(tm._listeners.size).to.equal(0)
|
|
})
|
|
|
|
it('should be able to dial', async () => {
|
|
tm.add(Transport.prototype[Symbol.toStringTag], Transport)
|
|
await tm.listen(addrs)
|
|
const addr = tm.getAddrs().shift()
|
|
const connection = await tm.dial(addr)
|
|
expect(connection).to.exist()
|
|
await connection.close()
|
|
})
|
|
})
|