Mirrors/cobalt
1
0
Fork 0
mirror of https://github.com/wukko/cobalt.git synced 2025-05-24 18:42:09 +02:00
Code Issues Packages Projects Releases Wiki Activity

web/types: create uuid alias for worker ids

Browse Source
This commit is contained in:
jj 2025-05-23 17:05:17 +00:00
parent 78cf73b34e
commit 47683cecec
No known key found for this signature in database
3 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
web/src/lib/types/queue.ts
View File

@ -1,8 +1,10 @@
import type { CobaltSaveRequestBody } from "$lib/types/api"; import type { CobaltSaveRequestBody } from "$lib/types/api";
import type { CobaltPipelineItem, CobaltPipelineResultFileType } from "$lib/types/workers"; import type { CobaltPipelineItem, CobaltPipelineResultFileType } from "$lib/types/workers";
export type UUID = string;
type CobaltQueueBaseItem = { type CobaltQueueBaseItem = {
id: string, id: UUID,
pipeline: CobaltPipelineItem[], pipeline: CobaltPipelineItem[],
canRetry?: boolean, canRetry?: boolean,
originalRequest?: CobaltSaveRequestBody, originalRequest?: CobaltSaveRequestBody,
@ -17,7 +19,7 @@ type CobaltQueueItemWaiting = CobaltQueueBaseItem & {
export type CobaltQueueItemRunning = CobaltQueueBaseItem & { export type CobaltQueueItemRunning = CobaltQueueBaseItem & {
state: "running", state: "running",
completedWorkers: Set<string>, completedWorkers: Set<UUID>,
pipelineResults: File[], pipelineResults: File[],
}; };
@ -37,5 +39,5 @@ export type CobaltQueueItem = CobaltQueueItemWaiting
| CobaltQueueItemError; | CobaltQueueItemError;
export type CobaltQueue = { export type CobaltQueue = {
[id: string]: CobaltQueueItem, [id: UUID]: CobaltQueueItem,
}; };

5
web/src/lib/types/task-manager.ts
View File

@ -1,11 +1,12 @@
import type { CobaltPipelineItem, CobaltWorkerProgress } from "$lib/types/workers"; import type { CobaltPipelineItem, CobaltWorkerProgress } from "$lib/types/workers";
import type { UUID } from "./queue";
export type CobaltCurrentTaskItem = { export type CobaltCurrentTaskItem = {
type: CobaltPipelineItem['worker'], type: CobaltPipelineItem['worker'],
parentId: string, parentId: UUID,
progress?: CobaltWorkerProgress, progress?: CobaltWorkerProgress,
} }
export type CobaltCurrentTasks = { export type CobaltCurrentTasks = {
[id: string]: CobaltCurrentTaskItem, [id: UUID]: CobaltCurrentTaskItem,
} }

7
web/src/lib/types/workers.ts
View File

@ -1,4 +1,5 @@
import type { FileInfo } from "$lib/types/libav"; import type { FileInfo } from "$lib/types/libav";
import type { UUID } from "./queue";
export const resultFileTypes = ["video", "audio", "image"] as const; export const resultFileTypes = ["video", "audio", "image"] as const;
@ -17,9 +18,9 @@ type CobaltFFmpegWorkerArgs = {
}; };
type CobaltPipelineItemBase = { type CobaltPipelineItemBase = {
workerId: string, workerId: UUID,
parentId: string, parentId: UUID,
dependsOn?: string[], dependsOn?: UUID[],
}; };
type CobaltRemuxPipelineItem = CobaltPipelineItemBase & { type CobaltRemuxPipelineItem = CobaltPipelineItemBase & {