bittorrent-tracker/test/server.js

103 lines
2.7 KiB
JavaScript
Raw Normal View History

var Client = require('../').Client
var portfinder = require('portfinder')
var Server = require('../').Server
var test = require('tape')
// TODO: add tests to verify that the correct downloaded/left/uploaded numbers are
// being sent
2014-04-19 06:00:40 +00:00
var infoHash = '4cb67059ed6bd08362da625b3ae77f6f4a075705'
var peerId = '12345678901234567890'
var torrentLength = 50000
test('server', function (t) {
2014-05-18 16:41:42 +00:00
t.plan(23)
var server = new Server() // { interval: 50000, compactOnly: false }
server.on('error', function (err) {
t.fail(err.message)
})
server.on('start', function () {
t.pass('got start message')
})
server.on('complete', function () {})
server.on('update', function () {})
server.on('stop', function () {})
server.on('listening', function () {
t.pass('server listening')
})
portfinder.getPort(function (err, port) {
t.error(err, 'found free port')
server.listen(port)
var announceUrl = 'http://127.0.0.1:' + port + '/announce'
var client = new Client(peerId, 6881, {
infoHash: infoHash,
length: torrentLength,
announce: [ announceUrl ]
})
client.start()
client.once('update', function (data) {
t.equal(data.announce, announceUrl)
t.equal(data.complete, 0)
t.equal(data.incomplete, 1)
2014-04-19 06:00:40 +00:00
t.equal(Object.keys(server.torrents).length, 1)
t.equal(server.torrents[infoHash].complete, 0)
t.equal(server.torrents[infoHash].incomplete, 1)
t.equal(Object.keys(server.torrents[infoHash].peers).length, 1)
t.deepEqual(server.torrents[infoHash].peers['127.0.0.1:6881'], {
ip: '127.0.0.1',
port: 6881,
peerId: peerId
})
client.complete()
client.once('update', function (data) {
t.equal(data.announce, announceUrl)
t.equal(data.complete, 1)
t.equal(data.incomplete, 0)
client.scrape()
2014-05-12 00:32:57 +00:00
client.once('scrape', function (data) {
t.equal(data.announce, announceUrl)
t.equal(typeof data.complete, 'number')
t.equal(typeof data.incomplete, 'number')
t.equal(typeof data.downloaded, 'number')
2014-05-18 16:15:20 +00:00
var client2 = new Client(peerId.split('').reverse().join(''), 6882, {
infoHash: infoHash,
length: torrentLength,
announce: [ announceUrl ]
})
client2.once('peer', function (addr) {
t.equal(addr, '127.0.0.1:6881')
2014-05-18 16:41:42 +00:00
client2.stop()
2014-05-18 16:15:20 +00:00
client.stop()
2014-05-12 00:32:57 +00:00
2014-05-18 16:15:20 +00:00
client.once('update', function (data) {
t.equal(data.announce, announceUrl)
t.equal(data.complete, 0)
t.equal(data.incomplete, 0)
2014-05-18 16:15:20 +00:00
server.close()
})
})
2014-05-18 16:15:20 +00:00
client2.start()
})
})
})
})
})