fluencelabs/js-libp2p-tcp
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p-tcp synced 2025-07-31 20:32:01 +00:00
Code Issues Projects Releases Wiki Activity

test: add upgrader to remaining tests

Browse Source 
License: MIT
Signed-off-by: Jacob Heun <jacobheun@gmail.com>
This commit is contained in:
Jacob Heun
2019-09-06 11:30:15 +02:00
parent d65f3ce228
commit 6f04526083
10 changed files with 25 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/adapter.js
View File

@@ -6,8 +6,8 @@ const TCP = require('.')
// Legacy adapter to old transport & connection interface
class TcpAdapter extends Adapter {
constructor () {
super(new TCP())
constructor (options) {
super(new TCP(options))
}
}

2
src/index.js
View File

@@ -18,7 +18,7 @@ function noop () {}
class TCP {
constructor(options) {
assert(options.upgrader, 'An Upgrader must be provided')
assert(options && options.upgrader, 'An Upgrader must be provided')
this.upgrader = options.upgrader
}

3
test/adapter/connection-wrap.spec.js
View File

@@ -9,6 +9,7 @@ chai.use(dirtyChai)
const TCP = require('../../src/adapter')
const multiaddr = require('multiaddr')
const Connection = require('interface-connection').Connection
const upgrader = require('../utils/upgrader')
describe('Connection Wrap', () => {
let tcp
@@ -16,7 +17,7 @@ describe('Connection Wrap', () => {
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090')
beforeEach((done) => {
tcp = new TCP()
tcp = new TCP({ upgrader })
listener = tcp.createListener((conn) => {
pull(conn, conn)
})

3
test/adapter/connection.spec.js
View File

@@ -8,12 +8,13 @@ const expect = chai.expect
chai.use(dirtyChai)
const TCP = require('../../src/adapter')
const multiaddr = require('multiaddr')
const upgrader = require('../utils/upgrader')
describe('valid Connection', () => {
let tcp
beforeEach(() => {
tcp = new TCP()
tcp = new TCP({ upgrader })
})
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090')

5
test/adapter/listen-dial.spec.js
View File

@@ -9,13 +9,14 @@ chai.use(dirtyChai)
const TCP = require('../../src/adapter')
const net = require('net')
const multiaddr = require('multiaddr')
const upgrader = require('../utils/upgrader')
const isCI = process.env.CI
describe('listen', () => {
let tcp
beforeEach(() => {
tcp = new TCP()
tcp = new TCP({ upgrader })
})
it('close listener with connections, through timeout', (done) => {
@@ -134,7 +135,7 @@ describe('dial', () => {
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090')
beforeEach((done) => {
tcp = new TCP()
tcp = new TCP({ upgrader })
listener = tcp.createListener((conn) => {
pull(
conn,

3
test/connection.spec.js
View File

@@ -7,12 +7,13 @@ const expect = chai.expect
chai.use(dirtyChai)
const TCP = require('../src')
const multiaddr = require('multiaddr')
const upgrader = require('./utils/upgrader')
describe('valid Connection', () => {
let tcp
beforeEach(() => {
tcp = new TCP()
tcp = new TCP({ upgrader })
})
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090')

3
test/constructor.spec.js
View File

@@ -6,10 +6,11 @@ const dirtyChai = require('dirty-chai')
const expect = chai.expect
chai.use(dirtyChai)
const TCP = require('../src')
const upgrader = require('./utils/upgrader')
describe('Constructor', () => {
it('create an instance', () => {
const tcp = new TCP()
const tcp = new TCP({ upgrader })
expect(tcp).to.exist()
})
})

3
test/filter.spec.js
View File

@@ -7,6 +7,7 @@ const expect = chai.expect
chai.use(dirtyChai)
const TCP = require('../src')
const multiaddr = require('multiaddr')
const upgrader = require('./utils/upgrader')
describe('filter addrs', () => {
const base = '/ip4/127.0.0.1'
@@ -15,7 +16,7 @@ describe('filter addrs', () => {
let tcp
before(() => {
tcp = new TCP()
tcp = new TCP({ upgrader })
})
it('filter valid addrs for this transport', () => {

5
test/listen-dial.spec.js
View File

@@ -12,12 +12,13 @@ const multiaddr = require('multiaddr')
const pipe = require('it-pipe')
const { collect, map } = require('streaming-iterables')
const isCI = process.env.CI
const upgrader = require('./utils/upgrader')
describe('listen', () => {
let tcp
beforeEach(() => {
tcp = new TCP()
tcp = new TCP({ upgrader })
})
it('close listener with connections, through timeout', async () => {
@@ -134,7 +135,7 @@ describe('dial', () => {
const ma = multiaddr('/ip4/127.0.0.1/tcp/9090')
beforeEach(async () => {
tcp = new TCP()
tcp = new TCP({ upgrader })
listener = tcp.createListener((conn) => {
pipe(
conn,

6
test/utils/upgrader.js Normal file
View File

@@ -0,0 +1,6 @@
'use strict'
module.exports = {
upgradeOutbound: (conn) => conn,
upgradeInbound: (conn) => conn,
}