1 /* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await,@typescript-eslint/no-floating-promises */
3 import { decode as magnetUriDecode, encode as magnetUriEncode } from 'magnet-uri'
4 import WebTorrent from 'webtorrent'
5 import { cleanupTests, createSingleServer, killallServers, PeerTubeServer, setAccessTokensToServers } from '@shared/server-commands'
7 describe('Test tracker', function () {
8 let server: PeerTubeServer
10 let goodMagnet: string
12 before(async function () {
14 server = await createSingleServer(1)
15 await setAccessTokensToServers([ server ])
18 const { uuid } = await server.videos.upload()
19 const video = await server.videos.get({ id: uuid })
20 goodMagnet = video.files[0].magnetUri
22 const parsed = magnetUriDecode(goodMagnet)
23 parsed.infoHash = '010597bb88b1968a5693a4fa8267c592ca65f2e9'
25 badMagnet = magnetUriEncode(parsed)
29 it('Should succeed with the correct infohash', function (done) {
30 const webtorrent = new WebTorrent()
32 const torrent = webtorrent.add(goodMagnet)
34 torrent.on('error', done)
35 torrent.on('warning', warn => {
36 const message = typeof warn === 'string' ? warn : warn.message
37 if (message.includes('Unknown infoHash ')) return done(new Error('Error on infohash'))
40 torrent.on('done', done)
43 it('Should disable the tracker', function (done) {
46 const errCb = () => done(new Error('Tracker is enabled'))
48 killallServers([ server ])
49 .then(() => server.run({ tracker: { enabled: false } }))
51 const webtorrent = new WebTorrent()
53 const torrent = webtorrent.add(goodMagnet)
55 torrent.on('error', done)
56 torrent.on('warning', warn => {
57 const message = typeof warn === 'string' ? warn : warn.message
58 if (message.includes('disabled ')) {
59 torrent.off('done', errCb)
65 torrent.on('done', errCb)
69 it('Should return an error when adding an incorrect infohash', function (done) {
72 killallServers([ server ])
73 .then(() => server.run())
75 const webtorrent = new WebTorrent()
77 const torrent = webtorrent.add(badMagnet)
79 torrent.on('error', done)
80 torrent.on('warning', warn => {
81 const message = typeof warn === 'string' ? warn : warn.message
82 if (message.includes('Unknown infoHash ')) return done()
85 torrent.on('done', () => done(new Error('No error on infohash')))
89 it('Should block the IP after the failed infohash', function (done) {
90 const webtorrent = new WebTorrent()
92 const torrent = webtorrent.add(goodMagnet)
94 torrent.on('error', done)
95 torrent.on('warning', warn => {
96 const message = typeof warn === 'string' ? warn : warn.message
97 if (message.includes('Unsupported tracker protocol')) return done()
101 after(async function () {
102 await cleanupTests([ server ])