loadFileOrLog(payload.videoFileId)
])
+ if (!video || !file) return
+
await createTorrentAndSetInfoHash(video, file)
// Refresh videoFile because the createTorrentAndSetInfoHash could be long
loadFileOrLog(payload.videoFileId)
])
+ if ((!video && !streamingPlaylist) || !file) return
+
await updateTorrentMetadata(video || streamingPlaylist, file)
await file.save()
})
it('Should fail with an already in transcoding state video', async function () {
- await server.jobs.pauseJobQueue()
-
const { uuid } = await server.videos.quickUpload({ name: 'transcoded video' })
+ await server.jobs.pauseJobQueue()
+ await server.videos.runTranscoding({ videoId: uuid, transcodingType: 'hls' })
+
await command.createEditionTasks({
videoId: uuid,
tasks: VideoEditorCommand.getComplexTask(),
waitJobs
} from '@shared/server-commands'
import { wait } from '@shared/core-utils'
+import { uuid } from 'short-uuid'
const expect = chai.expect
it('Should pause the job queue', async function () {
this.timeout(120000)
- await servers[1].jobs.pauseJobQueue()
+ const { uuid } = await servers[1].videos.upload({ attributes: { name: 'video2' } })
+ await waitJobs(servers)
- await servers[1].videos.upload({ attributes: { name: 'video2' } })
+ await servers[1].jobs.pauseJobQueue()
+ await servers[1].videos.runTranscoding({ videoId: uuid, transcodingType: 'hls' })
await wait(5000)
const body = await servers[1].jobs.list({ state: 'waiting', jobType: 'video-transcoding' })
- expect(body.data).to.have.lengthOf(1)
+ expect(body.data).to.have.lengthOf(4)
})
it('Should resume the job queue', async function () {