import { pick } from 'lodash' import { logger } from '@server/helpers/logger' import { VideoJobInfoModel } from '@server/models/video/video-job-info' import { MVideo } from '@server/types/models' import { MRunnerJob } from '@server/types/models/runners' import { buildUUID } from '@shared/extra-utils' import { RunnerJobUpdatePayload, RunnerJobVODWebVideoTranscodingPayload, RunnerJobVODWebVideoTranscodingPrivatePayload, VODWebVideoTranscodingSuccess } from '@shared/models' import { generateRunnerTranscodingVideoInputFileUrl } from '../runner-urls' import { AbstractVODTranscodingJobHandler } from './abstract-vod-transcoding-job-handler' import { loadTranscodingRunnerVideo, onVODWebVideoOrAudioMergeTranscodingJob } from './shared' type CreateOptions = { video: MVideo isNewVideo: boolean resolution: number fps: number priority: number dependsOnRunnerJob?: MRunnerJob } // eslint-disable-next-line max-len export class VODWebVideoTranscodingJobHandler extends AbstractVODTranscodingJobHandler { async create (options: CreateOptions) { const { video, resolution, fps, priority, dependsOnRunnerJob } = options const jobUUID = buildUUID() const payload: RunnerJobVODWebVideoTranscodingPayload = { input: { videoFileUrl: generateRunnerTranscodingVideoInputFileUrl(jobUUID, video.uuid) }, output: { resolution, fps } } const privatePayload: RunnerJobVODWebVideoTranscodingPrivatePayload = { ...pick(options, [ 'isNewVideo' ]), videoUUID: video.uuid } const job = await this.createRunnerJob({ type: 'vod-web-video-transcoding', jobUUID, payload, privatePayload, dependsOnRunnerJob, priority }) await VideoJobInfoModel.increaseOrCreate(video.uuid, 'pendingTranscode') return job } // --------------------------------------------------------------------------- async specificComplete (options: { runnerJob: MRunnerJob resultPayload: VODWebVideoTranscodingSuccess }) { const { runnerJob, resultPayload } = options const privatePayload = runnerJob.privatePayload as RunnerJobVODWebVideoTranscodingPrivatePayload const video = await loadTranscodingRunnerVideo(runnerJob, this.lTags) if (!video) return const videoFilePath = resultPayload.videoFile as string await onVODWebVideoOrAudioMergeTranscodingJob({ video, videoFilePath, privatePayload }) logger.info( 'Runner VOD web video transcoding job %s for %s ended.', runnerJob.uuid, video.uuid, this.lTags(video.uuid, runnerJob.uuid) ) } }