fluencelabs/js-libp2p-websockets
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p-websockets synced 2025-05-13 16:21:35 +00:00
Code Issues Projects Releases Wiki Activity

test: Add failing test for #68

Browse Source
This commit is contained in:
mkg20001 2018-02-27 19:56:53 +01:00 committed by Maciej Krüger
parent 11b62d62a2
commit 17daae05ca
No known key found for this signature in database
GPG Key ID: 0D948CE19CF49C5F
1 changed files with 39 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
test/node.js
View File

@ -86,8 +86,7 @@ describe('listen', () => {
})
it('getAddrs', (done) => {
const listener = ws.createListener((conn) => {
})
const listener = ws.createListener((conn) => {})
listener.listen(ma, () => {
listener.getAddrs((err, addrs) => {
expect(err).to.not.exist()
@ -100,8 +99,7 @@ describe('listen', () => {
it('getAddrs on port 0 listen', (done) => {
const addr = multiaddr(`/ip4/127.0.0.1/tcp/0/ws`)
const listener = ws.createListener((conn) => {
})
const listener = ws.createListener((conn) => {})
listener.listen(addr, () => {
listener.getAddrs((err, addrs) => {
expect(err).to.not.exist()
@ -114,8 +112,7 @@ describe('listen', () => {
it('getAddrs from listening on 0.0.0.0', (done) => {
const addr = multiaddr(`/ip4/0.0.0.0/tcp/9003/ws`)
const listener = ws.createListener((conn) => {
})
const listener = ws.createListener((conn) => {})
listener.listen(addr, () => {
listener.getAddrs((err, addrs) => {
expect(err).to.not.exist()
@ -127,8 +124,7 @@ describe('listen', () => {
it('getAddrs from listening on 0.0.0.0 and port 0', (done) => {
const addr = multiaddr(`/ip4/0.0.0.0/tcp/0/ws`)
const listener = ws.createListener((conn) => {
})
const listener = ws.createListener((conn) => {})
listener.listen(addr, () => {
listener.getAddrs((err, addrs) => {
expect(err).to.not.exist()
@ -210,6 +206,41 @@ describe('dial', () => {
})
})
const connect = require('pull-ws/client')
const Reader = require('pull-reader')
describe('dont crash', () => {
let ws
let listener
const ma = multiaddr('/ip4/127.0.0.1/tcp/9091/ws')
beforeEach((done) => {
ws = new WS()
const reader = Reader(10000)
listener = ws.createListener((conn) => {
pull(conn, reader) // simulate mss-listener
})
listener.listen(ma, done)
reader.read(1, console.log)
})
afterEach((done) => {
listener.close(done)
})
it('try to crash the node', (done) => {
const conn = connect('ws://localhost:9091')
pull(
pull.values(['This should not crash the node']),
conn,
pull.drain()
)
setTimeout(() => done(), 100) // wait for the crash
})
})
describe('filter addrs', () => {
let ws