1 import { Job } from 'bullmq'
2 import { createOptimizeOrMergeAudioJobs } from '@server/lib/transcoding/create-transcoding-job'
3 import { UserModel } from '@server/models/user/user'
4 import { VideoModel } from '@server/models/video/video'
5 import { VideoJobInfoModel } from '@server/models/video/video-job-info'
6 import { pick } from '@shared/core-utils'
7 import { TranscodingJobBuilderPayload } from '@shared/models'
8 import { logger } from '../../../helpers/logger'
9 import { JobQueue } from '../job-queue'
11 async function processTranscodingJobBuilder (job: Job) {
12 const payload = job.data as TranscodingJobBuilderPayload
14 logger.info('Processing transcoding job builder in job %s.', job.id)
16 if (payload.optimizeJob) {
17 const video = await VideoModel.loadFull(payload.videoUUID)
18 const user = await UserModel.loadByVideoId(video.id)
19 const videoFile = video.getMaxQualityFile()
21 await createOptimizeOrMergeAudioJobs({
22 ...pick(payload.optimizeJob, [ 'isNewVideo' ]),
27 videoFileAlreadyLocked: false
31 for (const job of (payload.jobs || [])) {
32 await JobQueue.Instance.createJob(job)
34 await VideoJobInfoModel.increaseOrCreate(payload.videoUUID, 'pendingTranscode')
37 for (const sequentialJobs of (payload.sequentialJobs || [])) {
38 await JobQueue.Instance.createSequentialJobFlow(...sequentialJobs)
40 await VideoJobInfoModel.increaseOrCreate(payload.videoUUID, 'pendingTranscode', sequentialJobs.filter(s => !!s).length)
44 // ---------------------------------------------------------------------------
47 processTranscodingJobBuilder