Mirror/bittorrent-tracker
1
0
Fork 0
mirror of https://github.com/webtorrent/bittorrent-tracker.git synced 2025-01-18 12:11:36 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Add pruning to server tests.

Browse Source 
Issue #4
This commit is contained in:
Yoann Ciabaud 2016-06-09 01:28:49 +02:00
parent ca522c0c4b
commit 1dbc95cbdc
1 changed files with 41 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
test/server.js
View File

@ -12,9 +12,10 @@ var test = require('tape')
var infoHash = '4cb67059ed6bd08362da625b3ae77f6f4a075705'
var peerId = Buffer.from('01234567890123456789')
var peerId2 = Buffer.from('12345678901234567890')
var peerId3 = Buffer.from('23456789012345678901')
function serverTest (t, serverType, serverFamily) {
t.plan(30)
t.plan(32)
var hostname = serverFamily === 'inet6'
? '[::1]'
@ -23,7 +24,12 @@ function serverTest (t, serverType, serverFamily) {
? '::1'
: '127.0.0.1'
common.createServer(t, serverType, function (server) {
var opts = {
serverType: serverType,
peersCacheLength: 2
}
common.createServer(t, opts, function (server) {
var port = server[serverType].address().port
var announceUrl = serverType + '://' + hostname + ':' + port + '/announce'
@ -103,22 +109,42 @@ function serverTest (t, serverType, serverFamily) {
client2.once('peer', function (addr) {
t.ok(addr === hostname + ':6881' || addr === hostname + ':6882' || addr.id === peerId.toString('hex'))
client2.stop()
client2.once('update', function (data) {
t.equal(data.announce, announceUrl)
t.equal(data.complete, 1)
t.equal(data.incomplete, 0)
client2.destroy()
swarm.peers.once('evict', function (evicted) {
t.equals(evicted.value.peerId, peerId.toString('hex'))
})
var client3 = new Client({
infoHash: infoHash,
announce: [ announceUrl ],
peerId: peerId3,
port: 6880
// wrtc: wrtc
})
client3.start()
client1.stop()
client1.once('update', function (data) {
server.once('start', function () {
t.pass('got start message from client3')
})
client3.once('update', function () {
client2.stop()
client2.once('update', function (data) {
t.equal(data.announce, announceUrl)
t.equal(data.complete, 0)
t.equal(data.incomplete, 0)
t.equal(data.complete, 1)
t.equal(data.incomplete, 1)
client2.destroy()
client1.destroy(function () {
server.close()
// if (serverType === 'ws') wrtc.close()
client3.stop()
client3.once('update', function (data) {
t.equal(data.announce, announceUrl)
t.equal(data.complete, 1)
t.equal(data.incomplete, 0)
client3.destroy(function () {
client1.destroy(function () {
server.close()
})
// if (serverType === 'ws') wrtc.close()
})
})
})
})