Skip to content

Commit bf88451

Browse files
committed
Adds unit testing for websocket server
1 parent 1f4a68a commit bf88451

File tree

2 files changed

+23
-12
lines changed

2 files changed

+23
-12
lines changed

package.json

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,8 @@
4545
"magnet-uri": "^5.0.0",
4646
"parse-torrent": "^5.0.0",
4747
"standard": "^6.0.4",
48-
"tape": "^4.0.0"
48+
"tape": "^4.0.0",
49+
"wrtc": "0.0.59"
4950
},
5051
"keywords": [
5152
"bittorrent",

test/server.js

Lines changed: 21 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
var Client = require('../')
22
var common = require('./common')
33
var test = require('tape')
4+
var wrtc = require('wrtc')
45

56
var infoHash = '4cb67059ed6bd08362da625b3ae77f6f4a075705'
67
var peerId = new Buffer('01234567890123456789')
@@ -25,7 +26,7 @@ function serverTest (t, serverType, serverFamily) {
2526
infoHash: infoHash,
2627
length: torrentLength,
2728
announce: [ announceUrl ]
28-
})
29+
}, { wrtc: wrtc })
2930

3031
client1.start()
3132

@@ -45,14 +46,19 @@ function serverTest (t, serverType, serverFamily) {
4546
t.equal(swarm.complete, 0)
4647
t.equal(swarm.incomplete, 1)
4748
t.equal(Object.keys(swarm.peers).length, 1)
48-
t.deepEqual(swarm.peers[hostname + ':6881'], {
49-
type: serverType,
50-
ip: clientIp,
51-
port: 6881,
52-
peerId: peerId.toString('hex'),
53-
complete: false,
54-
socket: undefined
55-
})
49+
50+
if (serverType !== 'ws') {
51+
t.deepEqual(swarm.peers[hostname + ':6881'], {
52+
type: serverType,
53+
ip: clientIp,
54+
port: 6881,
55+
peerId: peerId.toString('hex'),
56+
complete: false,
57+
socket: undefined
58+
})
59+
} else {
60+
t.equal(swarm.peers[peerId.toString('hex')].complete, false)
61+
}
5662

5763
client1.complete()
5864

@@ -73,7 +79,7 @@ function serverTest (t, serverType, serverFamily) {
7379
infoHash: infoHash,
7480
length: torrentLength,
7581
announce: [ announceUrl ]
76-
})
82+
}, { wrtc: wrtc })
7783

7884
client2.start()
7985

@@ -82,7 +88,7 @@ function serverTest (t, serverType, serverFamily) {
8288
})
8389

8490
client2.once('peer', function (addr) {
85-
t.ok(addr === hostname + ':6881' || addr === hostname + ':6882')
91+
t.ok(addr === hostname + ':6881' || addr === hostname + ':6882' || addr.id === peerId.toString('hex'))
8692

8793
client2.stop()
8894
client2.once('update', function (data) {
@@ -109,6 +115,10 @@ function serverTest (t, serverType, serverFamily) {
109115
})
110116
}
111117

118+
test('websocket server', function (t) {
119+
serverTest(t, 'ws', 'inet')
120+
})
121+
112122
test('http ipv4 server', function (t) {
113123
serverTest(t, 'http', 'inet')
114124
})

0 commit comments

Comments
 (0)