aboutsummaryrefslogtreecommitdiffhomepage
path: root/shared/models/runners
diff options
context:
space:
mode:
Diffstat (limited to 'shared/models/runners')
-rw-r--r--shared/models/runners/abort-runner-job-body.model.ts6
-rw-r--r--shared/models/runners/accept-runner-job-body.model.ts3
-rw-r--r--shared/models/runners/accept-runner-job-result.model.ts6
-rw-r--r--shared/models/runners/error-runner-job-body.model.ts6
-rw-r--r--shared/models/runners/index.ts21
-rw-r--r--shared/models/runners/list-runner-jobs-query.model.ts9
-rw-r--r--shared/models/runners/list-runner-registration-tokens.model.ts5
-rw-r--r--shared/models/runners/list-runners-query.model.ts5
-rw-r--r--shared/models/runners/register-runner-body.model.ts6
-rw-r--r--shared/models/runners/register-runner-result.model.ts4
-rw-r--r--shared/models/runners/request-runner-job-body.model.ts3
-rw-r--r--shared/models/runners/request-runner-job-result.model.ts10
-rw-r--r--shared/models/runners/runner-job-payload.model.ts79
-rw-r--r--shared/models/runners/runner-job-private-payload.model.ts45
-rw-r--r--shared/models/runners/runner-job-state.model.ts11
-rw-r--r--shared/models/runners/runner-job-success-body.model.ts46
-rw-r--r--shared/models/runners/runner-job-type.type.ts6
-rw-r--r--shared/models/runners/runner-job-update-body.model.ts28
-rw-r--r--shared/models/runners/runner-job.model.ts45
-rw-r--r--shared/models/runners/runner-registration-token.ts10
-rw-r--r--shared/models/runners/runner.model.ts12
-rw-r--r--shared/models/runners/unregister-runner-body.model.ts3
22 files changed, 0 insertions, 369 deletions
diff --git a/shared/models/runners/abort-runner-job-body.model.ts b/shared/models/runners/abort-runner-job-body.model.ts
deleted file mode 100644
index 0b9c46c91..000000000
--- a/shared/models/runners/abort-runner-job-body.model.ts
+++ /dev/null
@@ -1,6 +0,0 @@
1export interface AbortRunnerJobBody {
2 runnerToken: string
3 jobToken: string
4
5 reason: string
6}
diff --git a/shared/models/runners/accept-runner-job-body.model.ts b/shared/models/runners/accept-runner-job-body.model.ts
deleted file mode 100644
index cb266c4e6..000000000
--- a/shared/models/runners/accept-runner-job-body.model.ts
+++ /dev/null
@@ -1,3 +0,0 @@
1export interface AcceptRunnerJobBody {
2 runnerToken: string
3}
diff --git a/shared/models/runners/accept-runner-job-result.model.ts b/shared/models/runners/accept-runner-job-result.model.ts
deleted file mode 100644
index f2094b945..000000000
--- a/shared/models/runners/accept-runner-job-result.model.ts
+++ /dev/null
@@ -1,6 +0,0 @@
1import { RunnerJobPayload } from './runner-job-payload.model'
2import { RunnerJob } from './runner-job.model'
3
4export interface AcceptRunnerJobResult <T extends RunnerJobPayload = RunnerJobPayload> {
5 job: RunnerJob<T> & { jobToken: string }
6}
diff --git a/shared/models/runners/error-runner-job-body.model.ts b/shared/models/runners/error-runner-job-body.model.ts
deleted file mode 100644
index ac8568409..000000000
--- a/shared/models/runners/error-runner-job-body.model.ts
+++ /dev/null
@@ -1,6 +0,0 @@
1export interface ErrorRunnerJobBody {
2 runnerToken: string
3 jobToken: string
4
5 message: string
6}
diff --git a/shared/models/runners/index.ts b/shared/models/runners/index.ts
deleted file mode 100644
index a52b82d2e..000000000
--- a/shared/models/runners/index.ts
+++ /dev/null
@@ -1,21 +0,0 @@
1export * from './abort-runner-job-body.model'
2export * from './accept-runner-job-body.model'
3export * from './accept-runner-job-result.model'
4export * from './error-runner-job-body.model'
5export * from './list-runner-jobs-query.model'
6export * from './list-runner-registration-tokens.model'
7export * from './list-runners-query.model'
8export * from './register-runner-body.model'
9export * from './register-runner-result.model'
10export * from './request-runner-job-body.model'
11export * from './request-runner-job-result.model'
12export * from './runner-job-payload.model'
13export * from './runner-job-private-payload.model'
14export * from './runner-job-state.model'
15export * from './runner-job-success-body.model'
16export * from './runner-job-type.type'
17export * from './runner-job-update-body.model'
18export * from './runner-job.model'
19export * from './runner-registration-token'
20export * from './runner.model'
21export * from './unregister-runner-body.model'
diff --git a/shared/models/runners/list-runner-jobs-query.model.ts b/shared/models/runners/list-runner-jobs-query.model.ts
deleted file mode 100644
index ef19b31fa..000000000
--- a/shared/models/runners/list-runner-jobs-query.model.ts
+++ /dev/null
@@ -1,9 +0,0 @@
1import { RunnerJobState } from './runner-job-state.model'
2
3export interface ListRunnerJobsQuery {
4 start?: number
5 count?: number
6 sort?: string
7 search?: string
8 stateOneOf?: RunnerJobState[]
9}
diff --git a/shared/models/runners/list-runner-registration-tokens.model.ts b/shared/models/runners/list-runner-registration-tokens.model.ts
deleted file mode 100644
index 872e059cf..000000000
--- a/shared/models/runners/list-runner-registration-tokens.model.ts
+++ /dev/null
@@ -1,5 +0,0 @@
1export interface ListRunnerRegistrationTokensQuery {
2 start?: number
3 count?: number
4 sort?: string
5}
diff --git a/shared/models/runners/list-runners-query.model.ts b/shared/models/runners/list-runners-query.model.ts
deleted file mode 100644
index d4362e4c5..000000000
--- a/shared/models/runners/list-runners-query.model.ts
+++ /dev/null
@@ -1,5 +0,0 @@
1export interface ListRunnersQuery {
2 start?: number
3 count?: number
4 sort?: string
5}
diff --git a/shared/models/runners/register-runner-body.model.ts b/shared/models/runners/register-runner-body.model.ts
deleted file mode 100644
index 969bb35e1..000000000
--- a/shared/models/runners/register-runner-body.model.ts
+++ /dev/null
@@ -1,6 +0,0 @@
1export interface RegisterRunnerBody {
2 registrationToken: string
3
4 name: string
5 description?: string
6}
diff --git a/shared/models/runners/register-runner-result.model.ts b/shared/models/runners/register-runner-result.model.ts
deleted file mode 100644
index e31776c6a..000000000
--- a/shared/models/runners/register-runner-result.model.ts
+++ /dev/null
@@ -1,4 +0,0 @@
1export interface RegisterRunnerResult {
2 id: number
3 runnerToken: string
4}
diff --git a/shared/models/runners/request-runner-job-body.model.ts b/shared/models/runners/request-runner-job-body.model.ts
deleted file mode 100644
index 0970d9007..000000000
--- a/shared/models/runners/request-runner-job-body.model.ts
+++ /dev/null
@@ -1,3 +0,0 @@
1export interface RequestRunnerJobBody {
2 runnerToken: string
3}
diff --git a/shared/models/runners/request-runner-job-result.model.ts b/shared/models/runners/request-runner-job-result.model.ts
deleted file mode 100644
index 98601c42c..000000000
--- a/shared/models/runners/request-runner-job-result.model.ts
+++ /dev/null
@@ -1,10 +0,0 @@
1import { RunnerJobPayload } from './runner-job-payload.model'
2import { RunnerJobType } from './runner-job-type.type'
3
4export interface RequestRunnerJobResult <P extends RunnerJobPayload = RunnerJobPayload> {
5 availableJobs: {
6 uuid: string
7 type: RunnerJobType
8 payload: P
9 }[]
10}
diff --git a/shared/models/runners/runner-job-payload.model.ts b/shared/models/runners/runner-job-payload.model.ts
deleted file mode 100644
index 3dda6c51f..000000000
--- a/shared/models/runners/runner-job-payload.model.ts
+++ /dev/null
@@ -1,79 +0,0 @@
1import { VideoStudioTaskPayload } from '../server'
2
3export type RunnerJobVODPayload =
4 RunnerJobVODWebVideoTranscodingPayload |
5 RunnerJobVODHLSTranscodingPayload |
6 RunnerJobVODAudioMergeTranscodingPayload
7
8export type RunnerJobPayload =
9 RunnerJobVODPayload |
10 RunnerJobLiveRTMPHLSTranscodingPayload |
11 RunnerJobStudioTranscodingPayload
12
13// ---------------------------------------------------------------------------
14
15export interface RunnerJobVODWebVideoTranscodingPayload {
16 input: {
17 videoFileUrl: string
18 }
19
20 output: {
21 resolution: number
22 fps: number
23 }
24}
25
26export interface RunnerJobVODHLSTranscodingPayload {
27 input: {
28 videoFileUrl: string
29 }
30
31 output: {
32 resolution: number
33 fps: number
34 }
35}
36
37export interface RunnerJobVODAudioMergeTranscodingPayload {
38 input: {
39 audioFileUrl: string
40 previewFileUrl: string
41 }
42
43 output: {
44 resolution: number
45 fps: number
46 }
47}
48
49export interface RunnerJobStudioTranscodingPayload {
50 input: {
51 videoFileUrl: string
52 }
53
54 tasks: VideoStudioTaskPayload[]
55}
56
57// ---------------------------------------------------------------------------
58
59export function isAudioMergeTranscodingPayload (payload: RunnerJobPayload): payload is RunnerJobVODAudioMergeTranscodingPayload {
60 return !!(payload as RunnerJobVODAudioMergeTranscodingPayload).input.audioFileUrl
61}
62
63// ---------------------------------------------------------------------------
64
65export interface RunnerJobLiveRTMPHLSTranscodingPayload {
66 input: {
67 rtmpUrl: string
68 }
69
70 output: {
71 toTranscode: {
72 resolution: number
73 fps: number
74 }[]
75
76 segmentDuration: number
77 segmentListSize: number
78 }
79}
diff --git a/shared/models/runners/runner-job-private-payload.model.ts b/shared/models/runners/runner-job-private-payload.model.ts
deleted file mode 100644
index 529034db8..000000000
--- a/shared/models/runners/runner-job-private-payload.model.ts
+++ /dev/null
@@ -1,45 +0,0 @@
1import { VideoStudioTaskPayload } from '../server'
2
3export type RunnerJobVODPrivatePayload =
4 RunnerJobVODWebVideoTranscodingPrivatePayload |
5 RunnerJobVODAudioMergeTranscodingPrivatePayload |
6 RunnerJobVODHLSTranscodingPrivatePayload
7
8export type RunnerJobPrivatePayload =
9 RunnerJobVODPrivatePayload |
10 RunnerJobLiveRTMPHLSTranscodingPrivatePayload |
11 RunnerJobVideoStudioTranscodingPrivatePayload
12
13// ---------------------------------------------------------------------------
14
15export interface RunnerJobVODWebVideoTranscodingPrivatePayload {
16 videoUUID: string
17 isNewVideo: boolean
18}
19
20export interface RunnerJobVODAudioMergeTranscodingPrivatePayload {
21 videoUUID: string
22 isNewVideo: boolean
23}
24
25export interface RunnerJobVODHLSTranscodingPrivatePayload {
26 videoUUID: string
27 isNewVideo: boolean
28 deleteWebVideoFiles: boolean
29}
30
31// ---------------------------------------------------------------------------
32
33export interface RunnerJobLiveRTMPHLSTranscodingPrivatePayload {
34 videoUUID: string
35 masterPlaylistName: string
36 outputDirectory: string
37 sessionId: string
38}
39
40// ---------------------------------------------------------------------------
41
42export interface RunnerJobVideoStudioTranscodingPrivatePayload {
43 videoUUID: string
44 originalTasks: VideoStudioTaskPayload[]
45}
diff --git a/shared/models/runners/runner-job-state.model.ts b/shared/models/runners/runner-job-state.model.ts
deleted file mode 100644
index 7ed34b3bf..000000000
--- a/shared/models/runners/runner-job-state.model.ts
+++ /dev/null
@@ -1,11 +0,0 @@
1export enum RunnerJobState {
2 PENDING = 1,
3 PROCESSING = 2,
4 COMPLETED = 3,
5 ERRORED = 4,
6 WAITING_FOR_PARENT_JOB = 5,
7 CANCELLED = 6,
8 PARENT_ERRORED = 7,
9 PARENT_CANCELLED = 8,
10 COMPLETING = 9
11}
diff --git a/shared/models/runners/runner-job-success-body.model.ts b/shared/models/runners/runner-job-success-body.model.ts
deleted file mode 100644
index f45336b05..000000000
--- a/shared/models/runners/runner-job-success-body.model.ts
+++ /dev/null
@@ -1,46 +0,0 @@
1export interface RunnerJobSuccessBody {
2 runnerToken: string
3 jobToken: string
4
5 payload: RunnerJobSuccessPayload
6}
7
8// ---------------------------------------------------------------------------
9
10export type RunnerJobSuccessPayload =
11 VODWebVideoTranscodingSuccess |
12 VODHLSTranscodingSuccess |
13 VODAudioMergeTranscodingSuccess |
14 LiveRTMPHLSTranscodingSuccess |
15 VideoStudioTranscodingSuccess
16
17export interface VODWebVideoTranscodingSuccess {
18 videoFile: Blob | string
19}
20
21export interface VODHLSTranscodingSuccess {
22 videoFile: Blob | string
23 resolutionPlaylistFile: Blob | string
24}
25
26export interface VODAudioMergeTranscodingSuccess {
27 videoFile: Blob | string
28}
29
30export interface LiveRTMPHLSTranscodingSuccess {
31
32}
33
34export interface VideoStudioTranscodingSuccess {
35 videoFile: Blob | string
36}
37
38export function isWebVideoOrAudioMergeTranscodingPayloadSuccess (
39 payload: RunnerJobSuccessPayload
40): payload is VODHLSTranscodingSuccess | VODAudioMergeTranscodingSuccess {
41 return !!(payload as VODHLSTranscodingSuccess | VODAudioMergeTranscodingSuccess)?.videoFile
42}
43
44export function isHLSTranscodingPayloadSuccess (payload: RunnerJobSuccessPayload): payload is VODHLSTranscodingSuccess {
45 return !!(payload as VODHLSTranscodingSuccess)?.resolutionPlaylistFile
46}
diff --git a/shared/models/runners/runner-job-type.type.ts b/shared/models/runners/runner-job-type.type.ts
deleted file mode 100644
index 91b92a729..000000000
--- a/shared/models/runners/runner-job-type.type.ts
+++ /dev/null
@@ -1,6 +0,0 @@
1export type RunnerJobType =
2 'vod-web-video-transcoding' |
3 'vod-hls-transcoding' |
4 'vod-audio-merge-transcoding' |
5 'live-rtmp-hls-transcoding' |
6 'video-studio-transcoding'
diff --git a/shared/models/runners/runner-job-update-body.model.ts b/shared/models/runners/runner-job-update-body.model.ts
deleted file mode 100644
index ed94bbe63..000000000
--- a/shared/models/runners/runner-job-update-body.model.ts
+++ /dev/null
@@ -1,28 +0,0 @@
1export interface RunnerJobUpdateBody {
2 runnerToken: string
3 jobToken: string
4
5 progress?: number
6 payload?: RunnerJobUpdatePayload
7}
8
9// ---------------------------------------------------------------------------
10
11export type RunnerJobUpdatePayload = LiveRTMPHLSTranscodingUpdatePayload
12
13export interface LiveRTMPHLSTranscodingUpdatePayload {
14 type: 'add-chunk' | 'remove-chunk'
15
16 masterPlaylistFile?: Blob | string
17
18 resolutionPlaylistFilename?: string
19 resolutionPlaylistFile?: Blob | string
20
21 videoChunkFilename: string
22 videoChunkFile?: Blob | string
23}
24
25export function isLiveRTMPHLSTranscodingUpdatePayload (value: RunnerJobUpdatePayload): value is LiveRTMPHLSTranscodingUpdatePayload {
26 // eslint-disable-next-line @typescript-eslint/no-unnecessary-type-assertion
27 return !!(value as LiveRTMPHLSTranscodingUpdatePayload)?.videoChunkFilename
28}
diff --git a/shared/models/runners/runner-job.model.ts b/shared/models/runners/runner-job.model.ts
deleted file mode 100644
index 080093563..000000000
--- a/shared/models/runners/runner-job.model.ts
+++ /dev/null
@@ -1,45 +0,0 @@
1import { VideoConstant } from '../videos'
2import { RunnerJobPayload } from './runner-job-payload.model'
3import { RunnerJobPrivatePayload } from './runner-job-private-payload.model'
4import { RunnerJobState } from './runner-job-state.model'
5import { RunnerJobType } from './runner-job-type.type'
6
7export interface RunnerJob <T extends RunnerJobPayload = RunnerJobPayload> {
8 uuid: string
9
10 type: RunnerJobType
11
12 state: VideoConstant<RunnerJobState>
13
14 payload: T
15
16 failures: number
17 error: string | null
18
19 progress: number
20 priority: number
21
22 startedAt: Date | string
23 createdAt: Date | string
24 updatedAt: Date | string
25 finishedAt: Date | string
26
27 parent?: {
28 type: RunnerJobType
29 state: VideoConstant<RunnerJobState>
30 uuid: string
31 }
32
33 // If associated to a runner
34 runner?: {
35 id: number
36 name: string
37
38 description: string
39 }
40}
41
42// eslint-disable-next-line max-len
43export interface RunnerJobAdmin <T extends RunnerJobPayload = RunnerJobPayload, U extends RunnerJobPrivatePayload = RunnerJobPrivatePayload> extends RunnerJob<T> {
44 privatePayload: U
45}
diff --git a/shared/models/runners/runner-registration-token.ts b/shared/models/runners/runner-registration-token.ts
deleted file mode 100644
index 0a157aa51..000000000
--- a/shared/models/runners/runner-registration-token.ts
+++ /dev/null
@@ -1,10 +0,0 @@
1export interface RunnerRegistrationToken {
2 id: number
3
4 registrationToken: string
5
6 createdAt: Date
7 updatedAt: Date
8
9 registeredRunnersCount: number
10}
diff --git a/shared/models/runners/runner.model.ts b/shared/models/runners/runner.model.ts
deleted file mode 100644
index 3284f2992..000000000
--- a/shared/models/runners/runner.model.ts
+++ /dev/null
@@ -1,12 +0,0 @@
1export interface Runner {
2 id: number
3
4 name: string
5 description: string
6
7 ip: string
8 lastContact: Date | string
9
10 createdAt: Date | string
11 updatedAt: Date | string
12}
diff --git a/shared/models/runners/unregister-runner-body.model.ts b/shared/models/runners/unregister-runner-body.model.ts
deleted file mode 100644
index d3465c5d6..000000000
--- a/shared/models/runners/unregister-runner-body.model.ts
+++ /dev/null
@@ -1,3 +0,0 @@
1export interface UnregisterRunnerBody {
2 runnerToken: string
3}
generated by cgit v1.2.3 (git 2.25.1) at 2025-04-23 22:13:41 +0000