X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=scripts%2Fcreate-transcoding-job.ts;h=27170299d657e76a94d9254d6dd9ec1b81c98498;hb=cf59a2a0c367683ba35758419499bf6087c192ec;hp=2b7cb5177e2e4c0ec790a3a97010a81d023baeff;hpb=a41b9da1a9ce49df82ea10c82de4c2fbc6d1b189;p=github%2FChocobozzz%2FPeerTube.git diff --git a/scripts/create-transcoding-job.ts b/scripts/create-transcoding-job.ts index 2b7cb5177..27170299d 100755 --- a/scripts/create-transcoding-job.ts +++ b/scripts/create-transcoding-job.ts @@ -1,12 +1,17 @@ +import { registerTSPaths } from '../server/helpers/register-ts-paths' +registerTSPaths() + import * as program from 'commander' import { VideoModel } from '../server/models/video/video' import { initDatabaseModels } from '../server/initializers' import { JobQueue } from '../server/lib/job-queue' import { VideoTranscodingPayload } from '../server/lib/job-queue/handlers/video-transcoding' +import { computeResolutionsToTranscode } from '@server/helpers/ffmpeg-utils' program .option('-v, --video [videoUUID]', 'Video UUID') .option('-r, --resolution [resolution]', 'Video resolution (integer)') + .option('--generate-hls', 'Generate HLS playlist') .parse(process.argv) if (program['video'] === undefined) { @@ -29,14 +34,45 @@ run() async function run () { await initDatabaseModels(true) - const video = await VideoModel.loadByUUIDWithFile(program['video']) + const video = await VideoModel.loadAndPopulateAccountAndServerAndTags(program['video']) if (!video) throw new Error('Video not found.') - const dataInput: VideoTranscodingPayload = program.resolution !== undefined - ? { type: 'new-resolution' as 'new-resolution', videoUUID: video.uuid, isNewVideo: false, resolution: program.resolution } - : { type: 'optimize' as 'optimize', videoUUID: video.uuid, isNewVideo: false } + const dataInput: VideoTranscodingPayload[] = [] + const { videoFileResolution } = await video.getMaxQualityResolution() + + if (program.generateHls) { + const resolutionsEnabled = program.resolution + ? [ program.resolution ] + : computeResolutionsToTranscode(videoFileResolution).concat([ videoFileResolution ]) + + for (const resolution of resolutionsEnabled) { + dataInput.push({ + type: 'hls', + videoUUID: video.uuid, + resolution, + isPortraitMode: false, + copyCodecs: false + }) + } + } else if (program.resolution !== undefined) { + dataInput.push({ + type: 'new-resolution' as 'new-resolution', + videoUUID: video.uuid, + isNewVideo: false, + resolution: program.resolution + }) + } else { + dataInput.push({ + type: 'optimize' as 'optimize', + videoUUID: video.uuid, + isNewVideo: false + }) + } await JobQueue.Instance.init() - await JobQueue.Instance.createJob({ type: 'video-transcoding', payload: dataInput }) - console.log('Transcoding job for video %s created.', video.uuid) + + for (const d of dataInput) { + await JobQueue.Instance.createJob({ type: 'video-transcoding', payload: d }) + console.log('Transcoding job for video %s created.', video.uuid) + } }