diff options
Diffstat (limited to 'packages/peertube-runner/server/process/process.ts')
-rw-r--r-- | packages/peertube-runner/server/process/process.ts | 34 |
1 files changed, 0 insertions, 34 deletions
diff --git a/packages/peertube-runner/server/process/process.ts b/packages/peertube-runner/server/process/process.ts deleted file mode 100644 index 1caafda8c..000000000 --- a/packages/peertube-runner/server/process/process.ts +++ /dev/null | |||
@@ -1,34 +0,0 @@ | |||
1 | import { logger } from 'packages/peertube-runner/shared/logger' | ||
2 | import { | ||
3 | RunnerJobLiveRTMPHLSTranscodingPayload, | ||
4 | RunnerJobStudioTranscodingPayload, | ||
5 | RunnerJobVODAudioMergeTranscodingPayload, | ||
6 | RunnerJobVODHLSTranscodingPayload, | ||
7 | RunnerJobVODWebVideoTranscodingPayload | ||
8 | } from '@shared/models' | ||
9 | import { processAudioMergeTranscoding, processHLSTranscoding, ProcessOptions, processWebVideoTranscoding } from './shared' | ||
10 | import { ProcessLiveRTMPHLSTranscoding } from './shared/process-live' | ||
11 | import { processStudioTranscoding } from './shared/process-studio' | ||
12 | |||
13 | export async function processJob (options: ProcessOptions) { | ||
14 | const { server, job } = options | ||
15 | |||
16 | logger.info(`[${server.url}] Processing job of type ${job.type}: ${job.uuid}`, { payload: job.payload }) | ||
17 | |||
18 | if (job.type === 'vod-audio-merge-transcoding') { | ||
19 | await processAudioMergeTranscoding(options as ProcessOptions<RunnerJobVODAudioMergeTranscodingPayload>) | ||
20 | } else if (job.type === 'vod-web-video-transcoding') { | ||
21 | await processWebVideoTranscoding(options as ProcessOptions<RunnerJobVODWebVideoTranscodingPayload>) | ||
22 | } else if (job.type === 'vod-hls-transcoding') { | ||
23 | await processHLSTranscoding(options as ProcessOptions<RunnerJobVODHLSTranscodingPayload>) | ||
24 | } else if (job.type === 'live-rtmp-hls-transcoding') { | ||
25 | await new ProcessLiveRTMPHLSTranscoding(options as ProcessOptions<RunnerJobLiveRTMPHLSTranscodingPayload>).process() | ||
26 | } else if (job.type === 'video-studio-transcoding') { | ||
27 | await processStudioTranscoding(options as ProcessOptions<RunnerJobStudioTranscodingPayload>) | ||
28 | } else { | ||
29 | logger.error(`Unknown job ${job.type} to process`) | ||
30 | return | ||
31 | } | ||
32 | |||
33 | logger.info(`[${server.url}] Finished processing job of type ${job.type}: ${job.uuid}`) | ||
34 | } | ||