1 files changed, 0 insertions, 165 deletions

diff --git a/packages/peertube-runner/server/process/shared/process-studio.ts b/packages/peertube-runner/server/process/shared/process-studio.ts
deleted file mode 100644
index 7bb209e80..000000000
--- a/packages/peertube-runner/server/process/shared/process-studio.ts
+++ /dev/null
@@ -1,165 +0,0 @@
-import { remove } from 'fs-extra'
-import { logger } from 'packages/peertube-runner/shared'
-import { join } from 'path'
-import { pick } from '@shared/core-utils'
-import { buildUUID } from '@shared/extra-utils'
-import {
-  RunnerJobStudioTranscodingPayload,
-  VideoStudioTask,
-  VideoStudioTaskCutPayload,
-  VideoStudioTaskIntroPayload,
-  VideoStudioTaskOutroPayload,
-  VideoStudioTaskPayload,
-  VideoStudioTaskWatermarkPayload,
-  VideoStudioTranscodingSuccess
-} from '@shared/models'
-import { ConfigManager } from '../../../shared/config-manager'
-import { buildFFmpegEdition, downloadInputFile, JobWithToken, ProcessOptions, scheduleTranscodingProgress } from './common'
-
-export async function processStudioTranscoding (options: ProcessOptions<RunnerJobStudioTranscodingPayload>) {
-  const { server, job, runnerToken } = options
-  const payload = job.payload
-
-  let inputPath: string
-  let outputPath: string
-  let tmpInputFilePath: string
-
-  let tasksProgress = 0
-
-  const updateProgressInterval = scheduleTranscodingProgress({
-    job,
-    server,
-    runnerToken,
-    progressGetter: () => tasksProgress
-  })
-
-  try {
-    logger.info(`Downloading input file ${payload.input.videoFileUrl} for job ${job.jobToken}`)
-
-    inputPath = await downloadInputFile({ url: payload.input.videoFileUrl, runnerToken, job })
-    tmpInputFilePath = inputPath
-
-    logger.info(`Input file ${payload.input.videoFileUrl} downloaded for job ${job.jobToken}. Running studio transcoding tasks.`)
-
-    for (const task of payload.tasks) {
-      const outputFilename = 'output-edition-' + buildUUID() + '.mp4'
-      outputPath = join(ConfigManager.Instance.getTranscodingDirectory(), outputFilename)
-
-      await processTask({
-        inputPath: tmpInputFilePath,
-        outputPath,
-        task,
-        job,
-        runnerToken
-      })
-
-      if (tmpInputFilePath) await remove(tmpInputFilePath)
-
-      // For the next iteration
-      tmpInputFilePath = outputPath
-
-      tasksProgress += Math.floor(100 / payload.tasks.length)
-    }
-
-    const successBody: VideoStudioTranscodingSuccess = {
-      videoFile: outputPath
-    }
-
-    await server.runnerJobs.success({
-      jobToken: job.jobToken,
-      jobUUID: job.uuid,
-      runnerToken,
-      payload: successBody
-    })
-  } finally {
-    if (tmpInputFilePath) await remove(tmpInputFilePath)
-    if (outputPath) await remove(outputPath)
-    if (updateProgressInterval) clearInterval(updateProgressInterval)
-  }
-}
-
-// ---------------------------------------------------------------------------
-// Private
-// ---------------------------------------------------------------------------
-
-type TaskProcessorOptions <T extends VideoStudioTaskPayload = VideoStudioTaskPayload> = {
-  inputPath: string
-  outputPath: string
-  task: T
-  runnerToken: string
-  job: JobWithToken
-}
-
-const taskProcessors: { [id in VideoStudioTask['name']]: (options: TaskProcessorOptions) => Promise<any> } = {
-  'add-intro': processAddIntroOutro,
-  'add-outro': processAddIntroOutro,
-  'cut': processCut,
-  'add-watermark': processAddWatermark
-}
-
-async function processTask (options: TaskProcessorOptions) {
-  const { task } = options
-
-  const processor = taskProcessors[options.task.name]
-  if (!process) throw new Error('Unknown task ' + task.name)
-
-  return processor(options)
-}
-
-async function processAddIntroOutro (options: TaskProcessorOptions<VideoStudioTaskIntroPayload | VideoStudioTaskOutroPayload>) {
-  const { inputPath, task, runnerToken, job } = options
-
-  logger.debug('Adding intro/outro to ' + inputPath)
-
-  const introOutroPath = await downloadInputFile({ url: task.options.file, runnerToken, job })
-
-  try {
-    await buildFFmpegEdition().addIntroOutro({
-      ...pick(options, [ 'inputPath', 'outputPath' ]),
-
-      introOutroPath,
-      type: task.name === 'add-intro'
-        ? 'intro'
-        : 'outro'
-    })
-  } finally {
-    await remove(introOutroPath)
-  }
-}
-
-function processCut (options: TaskProcessorOptions<VideoStudioTaskCutPayload>) {
-  const { inputPath, task } = options
-
-  logger.debug(`Cutting ${inputPath}`)
-
-  return buildFFmpegEdition().cutVideo({
-    ...pick(options, [ 'inputPath', 'outputPath' ]),
-
-    start: task.options.start,
-    end: task.options.end
-  })
-}
-
-async function processAddWatermark (options: TaskProcessorOptions<VideoStudioTaskWatermarkPayload>) {
-  const { inputPath, task, runnerToken, job } = options
-
-  logger.debug('Adding watermark to ' + inputPath)
-
-  const watermarkPath = await downloadInputFile({ url: task.options.file, runnerToken, job })
-
-  try {
-    await buildFFmpegEdition().addWatermark({
-      ...pick(options, [ 'inputPath', 'outputPath' ]),
-
-      watermarkPath,
-
-      videoFilters: {
-        watermarkSizeRatio: task.options.watermarkSizeRatio,
-        horitonzalMarginRatio: task.options.horitonzalMarginRatio,
-        verticalMarginRatio: task.options.verticalMarginRatio
-      }
-    })
-  } finally {
-    await remove(watermarkPath)
-  }
-}