server/tests/api/videos/video-files.ts

   1 /* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */
   2
   3 import 'mocha'
   4 import { expect } from 'chai'
   5 import { HttpStatusCode } from '@shared/models'
   6 import {
   7   cleanupTests,
   8   createMultipleServers,
   9   doubleFollow,
  10   makeRawRequest,
  11   PeerTubeServer,
  12   setAccessTokensToServers,
  13   waitJobs
  14 } from '@shared/server-commands'
  15
  16 describe('Test videos files', function () {
  17   let servers: PeerTubeServer[]
  18
  19   // ---------------------------------------------------------------
  20
  21   before(async function () {
  22     this.timeout(150_000)
  23
  24     servers = await createMultipleServers(2)
  25     await setAccessTokensToServers(servers)
  26
  27     await doubleFollow(servers[0], servers[1])
  28
  29     await servers[0].config.enableTranscoding(true, true)
  30   })
  31
  32   describe('When deleting all files', function () {
  33     let validId1: string
  34     let validId2: string
  35
  36     before(async function () {
  37       this.timeout(120_000)
  38
  39       {
  40         const { uuid } = await servers[0].videos.quickUpload({ name: 'video 1' })
  41         validId1 = uuid
  42       }
  43
  44       {
  45         const { uuid } = await servers[0].videos.quickUpload({ name: 'video 2' })
  46         validId2 = uuid
  47       }
  48
  49       await waitJobs(servers)
  50     })
  51
  52     it('Should delete webtorrent files', async function () {
  53       this.timeout(30_000)
  54
  55       await servers[0].videos.removeAllWebTorrentFiles({ videoId: validId1 })
  56
  57       await waitJobs(servers)
  58
  59       for (const server of servers) {
  60         const video = await server.videos.get({ id: validId1 })
  61
  62         expect(video.files).to.have.lengthOf(0)
  63         expect(video.streamingPlaylists).to.have.lengthOf(1)
  64       }
  65     })
  66
  67     it('Should delete HLS files', async function () {
  68       this.timeout(30_000)
  69
  70       await servers[0].videos.removeHLSPlaylist({ videoId: validId2 })
  71
  72       await waitJobs(servers)
  73
  74       for (const server of servers) {
  75         const video = await server.videos.get({ id: validId2 })
  76
  77         expect(video.files).to.have.length.above(0)
  78         expect(video.streamingPlaylists).to.have.lengthOf(0)
  79       }
  80     })
  81   })
  82
  83   describe('When deleting a specific file', function () {
  84     let webtorrentId: string
  85     let hlsId: string
  86
  87     before(async function () {
  88       this.timeout(120_000)
  89
  90       {
  91         const { uuid } = await servers[0].videos.quickUpload({ name: 'webtorrent' })
  92         webtorrentId = uuid
  93       }
  94
  95       {
  96         const { uuid } = await servers[0].videos.quickUpload({ name: 'hls' })
  97         hlsId = uuid
  98       }
  99
 100       await waitJobs(servers)
 101     })
 102
 103     it('Shoulde delete a webtorrent file', async function () {
 104       this.timeout(30_000)
 105
 106       const video = await servers[0].videos.get({ id: webtorrentId })
 107       const files = video.files
 108
 109       await servers[0].videos.removeWebTorrentFile({ videoId: webtorrentId, fileId: files[0].id })
 110
 111       await waitJobs(servers)
 112
 113       for (const server of servers) {
 114         const video = await server.videos.get({ id: webtorrentId })
 115
 116         expect(video.files).to.have.lengthOf(files.length - 1)
 117         expect(video.files.find(f => f.id === files[0].id)).to.not.exist
 118       }
 119     })
 120
 121     it('Should delete all webtorrent files', async function () {
 122       this.timeout(30_000)
 123
 124       const video = await servers[0].videos.get({ id: webtorrentId })
 125       const files = video.files
 126
 127       for (const file of files) {
 128         await servers[0].videos.removeWebTorrentFile({ videoId: webtorrentId, fileId: file.id })
 129       }
 130
 131       await waitJobs(servers)
 132
 133       for (const server of servers) {
 134         const video = await server.videos.get({ id: webtorrentId })
 135
 136         expect(video.files).to.have.lengthOf(0)
 137       }
 138     })
 139
 140     it('Should delete a hls file', async function () {
 141       this.timeout(30_000)
 142
 143       const video = await servers[0].videos.get({ id: hlsId })
 144       const files = video.streamingPlaylists[0].files
 145       const toDelete = files[0]
 146
 147       await servers[0].videos.removeHLSFile({ videoId: hlsId, fileId: toDelete.id })
 148
 149       await waitJobs(servers)
 150
 151       for (const server of servers) {
 152         const video = await server.videos.get({ id: hlsId })
 153
 154         expect(video.streamingPlaylists[0].files).to.have.lengthOf(files.length - 1)
 155         expect(video.streamingPlaylists[0].files.find(f => f.id === toDelete.id)).to.not.exist
 156
 157         const { text } = await makeRawRequest(video.streamingPlaylists[0].playlistUrl)
 158
 159         expect(text.includes(`-${toDelete.resolution.id}.m3u8`)).to.be.false
 160         expect(text.includes(`-${video.streamingPlaylists[0].files[0].resolution.id}.m3u8`)).to.be.true
 161       }
 162     })
 163
 164     it('Should delete all hls files', async function () {
 165       this.timeout(30_000)
 166
 167       const video = await servers[0].videos.get({ id: hlsId })
 168       const files = video.streamingPlaylists[0].files
 169
 170       for (const file of files) {
 171         await servers[0].videos.removeHLSFile({ videoId: hlsId, fileId: file.id })
 172       }
 173
 174       await waitJobs(servers)
 175
 176       for (const server of servers) {
 177         const video = await server.videos.get({ id: hlsId })
 178
 179         expect(video.streamingPlaylists).to.have.lengthOf(0)
 180       }
 181     })
 182
 183     it('Should not delete last file of a video', async function () {
 184       this.timeout(60_000)
 185
 186       const webtorrentOnly = await servers[0].videos.get({ id: hlsId })
 187       const hlsOnly = await servers[0].videos.get({ id: webtorrentId })
 188
 189       for (let i = 0; i < 4; i++) {
 190         await servers[0].videos.removeWebTorrentFile({ videoId: webtorrentOnly.id, fileId: webtorrentOnly.files[i].id })
 191         await servers[0].videos.removeHLSFile({ videoId: hlsOnly.id, fileId: hlsOnly.streamingPlaylists[0].files[i].id })
 192       }
 193
 194       const expectedStatus = HttpStatusCode.BAD_REQUEST_400
 195       await servers[0].videos.removeWebTorrentFile({ videoId: webtorrentOnly.id, fileId: webtorrentOnly.files[4].id, expectedStatus })
 196       await servers[0].videos.removeHLSFile({ videoId: hlsOnly.id, fileId: hlsOnly.streamingPlaylists[0].files[4].id, expectedStatus })
 197     })
 198   })
 199
 200   after(async function () {
 201     await cleanupTests(servers)
 202   })
 203 })