1 /* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */
3 import { expect } from 'chai'
4 import { expectStartWith, FIXTURE_URLS } from '@server/tests/shared'
5 import { areMockObjectStorageTestsDisabled } from '@shared/core-utils'
6 import { HttpStatusCode, VideoPrivacy } from '@shared/models'
13 setAccessTokensToServers,
14 setDefaultVideoChannel,
16 } from '@shared/server-commands'
18 async function importVideo (server: PeerTubeServer) {
21 privacy: VideoPrivacy.PUBLIC,
22 channelId: server.store.channel.id,
23 targetUrl: FIXTURE_URLS.goodVideo720
26 const { video: { uuid } } = await server.imports.importVideo({ attributes })
31 describe('Object storage for video import', function () {
32 if (areMockObjectStorageTestsDisabled()) return
34 let server: PeerTubeServer
35 const objectStorage = new ObjectStorageCommand()
37 before(async function () {
40 await objectStorage.prepareDefaultMockBuckets()
42 server = await createSingleServer(1, objectStorage.getDefaultMockConfig())
44 await setAccessTokensToServers([ server ])
45 await setDefaultVideoChannel([ server ])
47 await server.config.enableImports()
50 describe('Without transcoding', async function () {
52 before(async function () {
53 await server.config.disableTranscoding()
56 it('Should import a video and have sent it to object storage', async function () {
59 const uuid = await importVideo(server)
60 await waitJobs(server)
62 const video = await server.videos.get({ id: uuid })
64 expect(video.files).to.have.lengthOf(1)
65 expect(video.streamingPlaylists).to.have.lengthOf(0)
67 const fileUrl = video.files[0].fileUrl
68 expectStartWith(fileUrl, objectStorage.getMockWebVideosBaseUrl())
70 await makeRawRequest({ url: fileUrl, expectedStatus: HttpStatusCode.OK_200 })
74 describe('With transcoding', async function () {
76 before(async function () {
77 await server.config.enableTranscoding()
80 it('Should import a video and have sent it to object storage', async function () {
83 const uuid = await importVideo(server)
84 await waitJobs(server)
86 const video = await server.videos.get({ id: uuid })
88 expect(video.files).to.have.lengthOf(5)
89 expect(video.streamingPlaylists).to.have.lengthOf(1)
90 expect(video.streamingPlaylists[0].files).to.have.lengthOf(5)
92 for (const file of video.files) {
93 expectStartWith(file.fileUrl, objectStorage.getMockWebVideosBaseUrl())
95 await makeRawRequest({ url: file.fileUrl, expectedStatus: HttpStatusCode.OK_200 })
98 for (const file of video.streamingPlaylists[0].files) {
99 expectStartWith(file.fileUrl, objectStorage.getMockPlaylistBaseUrl())
101 await makeRawRequest({ url: file.fileUrl, expectedStatus: HttpStatusCode.OK_200 })
106 after(async function () {
107 await objectStorage.cleanupMock()
109 await cleanupTests([ server ])