Fix torrent creation
This commit is contained in:
parent
f012319a64
commit
52fe4b671a
|
@ -28,6 +28,8 @@ async function doCreateAction (payload: ManageVideoTorrentPayload & { action: 'c
|
||||||
loadFileOrLog(payload.videoFileId)
|
loadFileOrLog(payload.videoFileId)
|
||||||
])
|
])
|
||||||
|
|
||||||
|
if (!video || !file) return
|
||||||
|
|
||||||
await createTorrentAndSetInfoHash(video, file)
|
await createTorrentAndSetInfoHash(video, file)
|
||||||
|
|
||||||
// Refresh videoFile because the createTorrentAndSetInfoHash could be long
|
// Refresh videoFile because the createTorrentAndSetInfoHash could be long
|
||||||
|
@ -48,6 +50,8 @@ async function doUpdateMetadataAction (payload: ManageVideoTorrentPayload & { ac
|
||||||
loadFileOrLog(payload.videoFileId)
|
loadFileOrLog(payload.videoFileId)
|
||||||
])
|
])
|
||||||
|
|
||||||
|
if ((!video && !streamingPlaylist) || !file) return
|
||||||
|
|
||||||
await updateTorrentMetadata(video || streamingPlaylist, file)
|
await updateTorrentMetadata(video || streamingPlaylist, file)
|
||||||
|
|
||||||
await file.save()
|
await file.save()
|
||||||
|
|
|
@ -122,10 +122,11 @@ describe('Test video editor API validator', function () {
|
||||||
})
|
})
|
||||||
|
|
||||||
it('Should fail with an already in transcoding state video', async function () {
|
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' })
|
const { uuid } = await server.videos.quickUpload({ name: 'transcoded video' })
|
||||||
|
|
||||||
|
await server.jobs.pauseJobQueue()
|
||||||
|
await server.videos.runTranscoding({ videoId: uuid, transcodingType: 'hls' })
|
||||||
|
|
||||||
await command.createEditionTasks({
|
await command.createEditionTasks({
|
||||||
videoId: uuid,
|
videoId: uuid,
|
||||||
tasks: VideoEditorCommand.getComplexTask(),
|
tasks: VideoEditorCommand.getComplexTask(),
|
||||||
|
|
|
@ -12,6 +12,7 @@ import {
|
||||||
waitJobs
|
waitJobs
|
||||||
} from '@shared/server-commands'
|
} from '@shared/server-commands'
|
||||||
import { wait } from '@shared/core-utils'
|
import { wait } from '@shared/core-utils'
|
||||||
|
import { uuid } from 'short-uuid'
|
||||||
|
|
||||||
const expect = chai.expect
|
const expect = chai.expect
|
||||||
|
|
||||||
|
@ -95,14 +96,16 @@ describe('Test jobs', function () {
|
||||||
it('Should pause the job queue', async function () {
|
it('Should pause the job queue', async function () {
|
||||||
this.timeout(120000)
|
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)
|
await wait(5000)
|
||||||
|
|
||||||
const body = await servers[1].jobs.list({ state: 'waiting', jobType: 'video-transcoding' })
|
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 () {
|
it('Should resume the job queue', async function () {
|
||||||
|
|
Loading…
Reference in New Issue