var Client = require('../').Client var fs = require('fs') var magnet = require('magnet-uri') var portfinder = require('portfinder') var Server = require('../').Server var test = require('tape') var uri = 'magnet:?xt=urn:btih:d2474e86c95b19b8bcfdb92bc12c9d44667cfa36&dn=Leaves+of+Grass+by+Walt+Whitman.epub&tr=udp%3A%2F%2Ftracker.openbittorrent.com%3A80' var parsedTorrent = magnet(uri) var peerId = new Buffer('01234567890123456789') test('magnet + udp: client.start/update/stop()', function (t) { t.plan(12) var server = new Server({ http: false }) server.on('error', function (err) { t.fail(err.message) }) server.on('warning', function (err) { t.fail(err.message) }) portfinder.getPort(function (err, port) { t.error(err, 'found free port') server.listen(port) var announceUrl = 'udp://127.0.0.1:' + port // TODO: shouldn't rely on an external server! // remove all tracker servers except a single UDP one, for now parsedTorrent.announce = [ announceUrl ] var client = new Client(peerId, 6881, parsedTorrent) client.on('error', function (err) { t.error(err) }) client.once('update', function (data) { t.equal(data.announce, announceUrl) t.equal(typeof data.complete, 'number') t.equal(typeof data.incomplete, 'number') }) client.start() client.once('peer', function (addr) { t.pass('there is at least one peer') // TODO: this shouldn't rely on an external server! client.update() client.once('update', function (data) { // receive one final update after calling stop t.equal(data.announce, announceUrl) t.equal(typeof data.complete, 'number') t.equal(typeof data.incomplete, 'number') client.stop() client.once('update', function (data) { // received an update! t.equal(data.announce, announceUrl) t.equal(typeof data.complete, 'number') t.equal(typeof data.incomplete, 'number') server.close(function () { t.pass('server closed') }) }) }) }) }) })