diff options
Diffstat (limited to 'test/node/download-tracker-torrent.js')
-rw-r--r-- | test/node/download-tracker-torrent.js | 48 |
1 files changed, 24 insertions, 24 deletions
diff --git a/test/node/download-tracker-torrent.js b/test/node/download-tracker-torrent.js index c1d3bcd..9ba0760 100644 --- a/test/node/download-tracker-torrent.js +++ b/test/node/download-tracker-torrent.js @@ -6,11 +6,11 @@ const test = require('tape') const TrackerServer = require('bittorrent-tracker/server') const WebTorrent = require('../../') -test('Download using UDP tracker (via .torrent file)', function (t) { +test('Download using UDP tracker (via .torrent file)', t => { torrentDownloadTest(t, 'udp') }) -test('Download using HTTP tracker (via .torrent file)', function (t) { +test('Download using HTTP tracker (via .torrent file)', t => { torrentDownloadTest(t, 'http') }) @@ -24,35 +24,35 @@ function torrentDownloadTest (t, serverType) { serverType === 'udp' ? { http: false, ws: false } : { udp: false, ws: false } ) - tracker.on('error', function (err) { t.fail(err) }) - tracker.on('warning', function (err) { t.fail(err) }) + tracker.on('error', err => { t.fail(err) }) + tracker.on('warning', err => { t.fail(err) }) - tracker.on('start', function () { + tracker.on('start', () => { trackerStartCount += 1 }) let client1, client2 series([ - function (cb) { + cb => { tracker.listen(cb) }, - function (cb) { + cb => { client1 = new WebTorrent({ dht: false, lsd: false }) - client1.on('error', function (err) { t.fail(err) }) - client1.on('warning', function (err) { t.fail(err) }) + client1.on('error', err => { t.fail(err) }) + client1.on('warning', err => { t.fail(err) }) const port = tracker[serverType].address().port const announceUrl = serverType === 'http' - ? 'http://127.0.0.1:' + port + '/announce' - : 'udp://127.0.0.1:' + port + ? `http://127.0.0.1:${port}/announce` + : `udp://127.0.0.1:${port}` // Overwrite announce with our local tracker parsedTorrent.announce = [announceUrl] - client1.on('torrent', function (torrent) { + client1.on('torrent', torrent => { // torrent metadata has been fetched -- sanity check it t.equal(torrent.name, 'Leaves of Grass by Walt Whitman.epub') @@ -60,7 +60,7 @@ function torrentDownloadTest (t, serverType) { 'Leaves of Grass by Walt Whitman.epub' ] - t.deepEqual(torrent.files.map(function (file) { return file.name }), names) + t.deepEqual(torrent.files.map(file => file.name), names) torrent.load(fs.createReadStream(fixtures.leaves.contentPath), cb) }) @@ -68,19 +68,19 @@ function torrentDownloadTest (t, serverType) { client1.add(parsedTorrent, { store: MemoryChunkStore }) }, - function (cb) { + cb => { client2 = new WebTorrent({ dht: false, lsd: false }) - client2.on('error', function (err) { t.fail(err) }) - client2.on('warning', function (err) { t.fail(err) }) + client2.on('error', err => { t.fail(err) }) + client2.on('warning', err => { t.fail(err) }) client2.add(parsedTorrent, { store: MemoryChunkStore }) - client2.on('torrent', function (torrent) { + client2.on('torrent', torrent => { let gotBuffer = false let torrentDone = false - torrent.files.forEach(function (file) { - file.getBuffer(function (err, buf) { + torrent.files.forEach(file => { + file.getBuffer((err, buf) => { if (err) throw err t.deepEqual(buf, fixtures.leaves.content, 'downloaded correct content') gotBuffer = true @@ -88,7 +88,7 @@ function torrentDownloadTest (t, serverType) { }) }) - torrent.once('done', function () { + torrent.once('done', () => { t.pass('client2 downloaded torrent from client1') torrentDone = true maybeDone() @@ -100,17 +100,17 @@ function torrentDownloadTest (t, serverType) { }) } - ], function (err) { + ], err => { t.error(err) t.equal(trackerStartCount, 2) - tracker.close(function () { + tracker.close(() => { t.pass('tracker closed') }) - client1.destroy(function (err) { + client1.destroy(err => { t.error(err, 'client1 destroyed') }) - client2.destroy(function (err) { + client2.destroy(err => { t.error(err, 'client2 destroyed') }) }) |