server/tests/api/check-params/video-files.ts

   1 /* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */
   2
   3 import { getAllFiles } from '@shared/core-utils'
   4 import { HttpStatusCode, UserRole, VideoDetails, VideoPrivacy } from '@shared/models'
   5 import {
   6   cleanupTests,
   7   createMultipleServers,
   8   doubleFollow,
   9   makeRawRequest,
  10   PeerTubeServer,
  11   setAccessTokensToServers,
  12   waitJobs
  13 } from '@shared/server-commands'
  14
  15 describe('Test videos files', function () {
  16   let servers: PeerTubeServer[]
  17
  18   let userToken: string
  19   let moderatorToken: string
  20
  21   // ---------------------------------------------------------------
  22
  23   before(async function () {
  24     this.timeout(300_000)
  25
  26     servers = await createMultipleServers(2)
  27     await setAccessTokensToServers(servers)
  28
  29     await doubleFollow(servers[0], servers[1])
  30
  31     userToken = await servers[0].users.generateUserAndToken('user', UserRole.USER)
  32     moderatorToken = await servers[0].users.generateUserAndToken('moderator', UserRole.MODERATOR)
  33   })
  34
  35   describe('Getting metadata', function () {
  36     let video: VideoDetails
  37
  38     before(async function () {
  39       const { uuid } = await servers[0].videos.quickUpload({ name: 'video', privacy: VideoPrivacy.PRIVATE })
  40       video = await servers[0].videos.getWithToken({ id: uuid })
  41     })
  42
  43     it('Should not get metadata of private video without token', async function () {
  44       for (const file of getAllFiles(video)) {
  45         await makeRawRequest({ url: file.metadataUrl, expectedStatus: HttpStatusCode.UNAUTHORIZED_401 })
  46       }
  47     })
  48
  49     it('Should not get metadata of private video without the appropriate token', async function () {
  50       for (const file of getAllFiles(video)) {
  51         await makeRawRequest({ url: file.metadataUrl, token: userToken, expectedStatus: HttpStatusCode.FORBIDDEN_403 })
  52       }
  53     })
  54
  55     it('Should get metadata of private video with the appropriate token', async function () {
  56       for (const file of getAllFiles(video)) {
  57         await makeRawRequest({ url: file.metadataUrl, token: servers[0].accessToken, expectedStatus: HttpStatusCode.OK_200 })
  58       }
  59     })
  60   })
  61
  62   describe('Deleting files', function () {
  63     let webtorrentId: string
  64     let hlsId: string
  65     let remoteId: string
  66
  67     let validId1: string
  68     let validId2: string
  69
  70     let hlsFileId: number
  71     let webtorrentFileId: number
  72
  73     let remoteHLSFileId: number
  74     let remoteWebtorrentFileId: number
  75
  76     before(async function () {
  77       this.timeout(300_000)
  78
  79       {
  80         const { uuid } = await servers[1].videos.quickUpload({ name: 'remote video' })
  81         await waitJobs(servers)
  82
  83         const video = await servers[1].videos.get({ id: uuid })
  84         remoteId = video.uuid
  85         remoteHLSFileId = video.streamingPlaylists[0].files[0].id
  86         remoteWebtorrentFileId = video.files[0].id
  87       }
  88
  89       {
  90         await servers[0].config.enableTranscoding(true, true)
  91
  92         {
  93           const { uuid } = await servers[0].videos.quickUpload({ name: 'both 1' })
  94           await waitJobs(servers)
  95
  96           const video = await servers[0].videos.get({ id: uuid })
  97           validId1 = video.uuid
  98           hlsFileId = video.streamingPlaylists[0].files[0].id
  99           webtorrentFileId = video.files[0].id
 100         }
 101
 102         {
 103           const { uuid } = await servers[0].videos.quickUpload({ name: 'both 2' })
 104           validId2 = uuid
 105         }
 106       }
 107
 108       await waitJobs(servers)
 109
 110       {
 111         await servers[0].config.enableTranscoding(false, true)
 112         const { uuid } = await servers[0].videos.quickUpload({ name: 'hls' })
 113         hlsId = uuid
 114       }
 115
 116       await waitJobs(servers)
 117
 118       {
 119         await servers[0].config.enableTranscoding(false, true)
 120         const { uuid } = await servers[0].videos.quickUpload({ name: 'webtorrent' })
 121         webtorrentId = uuid
 122       }
 123
 124       await waitJobs(servers)
 125     })
 126
 127     it('Should not delete files of a unknown video', async function () {
 128       const expectedStatus = HttpStatusCode.NOT_FOUND_404
 129
 130       await servers[0].videos.removeHLSPlaylist({ videoId: 404, expectedStatus })
 131       await servers[0].videos.removeAllWebTorrentFiles({ videoId: 404, expectedStatus })
 132
 133       await servers[0].videos.removeHLSFile({ videoId: 404, fileId: hlsFileId, expectedStatus })
 134       await servers[0].videos.removeWebTorrentFile({ videoId: 404, fileId: webtorrentFileId, expectedStatus })
 135     })
 136
 137     it('Should not delete unknown files', async function () {
 138       const expectedStatus = HttpStatusCode.NOT_FOUND_404
 139
 140       await servers[0].videos.removeHLSFile({ videoId: validId1, fileId: webtorrentFileId, expectedStatus })
 141       await servers[0].videos.removeWebTorrentFile({ videoId: validId1, fileId: hlsFileId, expectedStatus })
 142     })
 143
 144     it('Should not delete files of a remote video', async function () {
 145       const expectedStatus = HttpStatusCode.BAD_REQUEST_400
 146
 147       await servers[0].videos.removeHLSPlaylist({ videoId: remoteId, expectedStatus })
 148       await servers[0].videos.removeAllWebTorrentFiles({ videoId: remoteId, expectedStatus })
 149
 150       await servers[0].videos.removeHLSFile({ videoId: remoteId, fileId: remoteHLSFileId, expectedStatus })
 151       await servers[0].videos.removeWebTorrentFile({ videoId: remoteId, fileId: remoteWebtorrentFileId, expectedStatus })
 152     })
 153
 154     it('Should not delete files by a non admin user', async function () {
 155       const expectedStatus = HttpStatusCode.FORBIDDEN_403
 156
 157       await servers[0].videos.removeHLSPlaylist({ videoId: validId1, token: userToken, expectedStatus })
 158       await servers[0].videos.removeHLSPlaylist({ videoId: validId1, token: moderatorToken, expectedStatus })
 159
 160       await servers[0].videos.removeAllWebTorrentFiles({ videoId: validId1, token: userToken, expectedStatus })
 161       await servers[0].videos.removeAllWebTorrentFiles({ videoId: validId1, token: moderatorToken, expectedStatus })
 162
 163       await servers[0].videos.removeHLSFile({ videoId: validId1, fileId: hlsFileId, token: userToken, expectedStatus })
 164       await servers[0].videos.removeHLSFile({ videoId: validId1, fileId: hlsFileId, token: moderatorToken, expectedStatus })
 165
 166       await servers[0].videos.removeWebTorrentFile({ videoId: validId1, fileId: webtorrentFileId, token: userToken, expectedStatus })
 167       await servers[0].videos.removeWebTorrentFile({ videoId: validId1, fileId: webtorrentFileId, token: moderatorToken, expectedStatus })
 168     })
 169
 170     it('Should not delete files if the files are not available', async function () {
 171       await servers[0].videos.removeHLSPlaylist({ videoId: hlsId, expectedStatus: HttpStatusCode.BAD_REQUEST_400 })
 172       await servers[0].videos.removeAllWebTorrentFiles({ videoId: webtorrentId, expectedStatus: HttpStatusCode.BAD_REQUEST_400 })
 173
 174       await servers[0].videos.removeHLSFile({ videoId: hlsId, fileId: 404, expectedStatus: HttpStatusCode.NOT_FOUND_404 })
 175       await servers[0].videos.removeWebTorrentFile({ videoId: webtorrentId, fileId: 404, expectedStatus: HttpStatusCode.NOT_FOUND_404 })
 176     })
 177
 178     it('Should not delete files if no both versions are available', async function () {
 179       await servers[0].videos.removeHLSPlaylist({ videoId: hlsId, expectedStatus: HttpStatusCode.BAD_REQUEST_400 })
 180       await servers[0].videos.removeAllWebTorrentFiles({ videoId: webtorrentId, expectedStatus: HttpStatusCode.BAD_REQUEST_400 })
 181     })
 182
 183     it('Should delete files if both versions are available', async function () {
 184       await servers[0].videos.removeHLSFile({ videoId: validId1, fileId: hlsFileId })
 185       await servers[0].videos.removeWebTorrentFile({ videoId: validId1, fileId: webtorrentFileId })
 186
 187       await servers[0].videos.removeHLSPlaylist({ videoId: validId1 })
 188       await servers[0].videos.removeAllWebTorrentFiles({ videoId: validId2 })
 189     })
 190   })
 191
 192   after(async function () {
 193     await cleanupTests(servers)
 194   })
 195 })