]> git.immae.eu Git - github/Chocobozzz/PeerTube.git/blob - server/tests/cli/update-host.ts
Implement video transcoding on server side
[github/Chocobozzz/PeerTube.git] / server / tests / cli / update-host.ts
1 import 'mocha'
2 import * as chai from 'chai'
3 const expect = chai.expect
4
5 import {
6 execCLI,
7 flushTests,
8 getEnvCli,
9 getVideosList,
10 killallServers,
11 parseTorrentVideo,
12 runServer,
13 ServerInfo,
14 setAccessTokensToServers,
15 uploadVideo,
16 wait
17 } from '../utils'
18
19 describe('Test update host scripts', function () {
20 let server: ServerInfo
21
22 before(async function () {
23 this.timeout(60000)
24
25 await flushTests()
26
27 const overrideConfig = {
28 webserver: {
29 port: 9256
30 }
31 }
32 // Run server 2 to have transcoding enabled
33 server = await runServer(2, overrideConfig)
34 await setAccessTokensToServers([ server ])
35
36 // Upload two videos for our needs
37 const videoAttributes = {}
38 await uploadVideo(server.url, server.accessToken, videoAttributes)
39 await uploadVideo(server.url, server.accessToken, videoAttributes)
40 await wait(30000)
41 })
42
43 it('Should update torrent hosts', async function () {
44 this.timeout(30000)
45
46 killallServers([ server ])
47 // Run server with standard configuration
48 server = await runServer(2)
49
50 const env = getEnvCli(server)
51 await execCLI(`${env} npm run update-host`)
52
53 const res = await getVideosList(server.url)
54 const videos = res.body.data
55 expect(videos).to.have.lengthOf(2)
56
57 for (const video of videos) {
58 expect(video.files).to.have.lengthOf(5)
59
60 for (const file of video.files) {
61 expect(file.magnetUri).to.contain('localhost%3A9002%2Ftracker%2Fsocket')
62 expect(file.magnetUri).to.contain('localhost%3A9002%2Fstatic%2Fwebseed%2F')
63
64 const torrent = await parseTorrentVideo(server, video.uuid, file.resolutionLabel)
65 expect(torrent.announce[0]).to.equal('ws://localhost:9002/tracker/socket')
66 expect(torrent.urlList[0]).to.contain('http://localhost:9002/static/webseed')
67 }
68 }
69 })
70
71 after(async function () {
72 killallServers([ server ])
73
74 // Keep the logs if the test failed
75 if (this['ok']) {
76 await flushTests()
77 }
78 })
79 })