mirror of
https://github.com/webtorrent/bittorrent-tracker.git
synced 2024-12-14 19:36:24 +00:00
2966165a8f
To use the client, you used to pass in four arguments: `new Client(peerId, port, parsedTorrent, opts)` Now, passing in the torrent is no longer required, just the `announce` and `infoHash` properties. This decouples this package from `parse-torrent`. All options get passed in together now: new Client({ infoHash: '', // hex string or Buffer peerId: '', // hex string or Buffer announce: [], // list of tracker server urls port: 6881 // torrent client port, (in browser, optional) }) All the normal optional arguments (rtcConfig, wrtc, etc.) can still be passed in with the rest of these options. Fixes #118. Fixes #115. Added ws tests for scrape.
67 lines
1.7 KiB
JavaScript
67 lines
1.7 KiB
JavaScript
var Client = require('../')
|
|
var common = require('./common')
|
|
var fixtures = require('webtorrent-fixtures')
|
|
var magnet = require('magnet-uri')
|
|
var test = require('tape')
|
|
|
|
var peerId = new Buffer('01234567890123456789')
|
|
|
|
function testMagnet (t, serverType) {
|
|
t.plan(9)
|
|
|
|
var parsedTorrent = magnet(fixtures.leaves.magnetURI)
|
|
|
|
common.createServer(t, serverType, function (server, announceUrl) {
|
|
var client = new Client({
|
|
infoHash: parsedTorrent.infoHash,
|
|
announce: announceUrl,
|
|
peerId: peerId,
|
|
port: 6881,
|
|
wrtc: {}
|
|
})
|
|
|
|
if (serverType === 'ws') common.mockWebsocketTracker(client)
|
|
client.on('error', function (err) { t.error(err) })
|
|
client.on('warning', 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.update()
|
|
|
|
client.once('update', function (data) {
|
|
t.equal(data.announce, announceUrl)
|
|
t.equal(typeof data.complete, 'number')
|
|
t.equal(typeof data.incomplete, 'number')
|
|
|
|
client.stop()
|
|
|
|
client.once('update', function (data) {
|
|
t.equal(data.announce, announceUrl)
|
|
t.equal(typeof data.complete, 'number')
|
|
t.equal(typeof data.incomplete, 'number')
|
|
|
|
server.close()
|
|
client.destroy()
|
|
})
|
|
})
|
|
})
|
|
|
|
client.start()
|
|
})
|
|
}
|
|
|
|
test('http: magnet: client.start/update/stop()', function (t) {
|
|
testMagnet(t, 'http')
|
|
})
|
|
|
|
test('udp: magnet: client.start/update/stop()', function (t) {
|
|
testMagnet(t, 'udp')
|
|
})
|
|
|
|
test('ws: magnet: client.start/update/stop()', function (t) {
|
|
testMagnet(t, 'ws')
|
|
})
|