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

web/queue: move error() out of createSavePipeline closure

Browse Source
This commit is contained in:
jj 2025-05-16 14:58:23 +00:00
parent 3d92a85ba2
commit 426c073d5f
No known key found for this signature in database
1 changed files with 20 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
web/src/lib/task-manager/queue.ts
View File

@ -109,11 +109,7 @@ const makeGifArgs = () => {
]; ];
} }
export const createSavePipeline = (info: CobaltLocalProcessingResponse, request: CobaltSaveRequestBody) => { const showError = (errorCode: string) => {
// this is a pre-queue part of processing,
// so errors have to be returned via a regular dialog
const error = (errorCode: string) => {
return createDialog({ return createDialog({
id: "pipeline-error", id: "pipeline-error",
type: "small", type: "small",
@ -129,8 +125,12 @@ export const createSavePipeline = (info: CobaltLocalProcessingResponse, request:
}); });
} }
export const createSavePipeline = (info: CobaltLocalProcessingResponse, request: CobaltSaveRequestBody) => {
// this is a pre-queue part of processing,
// so errors have to be returned via a regular dialog
if (!info.output?.filename || !info.output?.type) { if (!info.output?.filename || !info.output?.type) {
return error("pipeline.missing_response_data"); return showError("pipeline.missing_response_data");
} }
const parentId = crypto.randomUUID(); const parentId = crypto.randomUUID();
@ -160,7 +160,7 @@ export const createSavePipeline = (info: CobaltLocalProcessingResponse, request:
const args = makeAudioArgs(info); const args = makeAudioArgs(info);
if (!args) { if (!args) {
return error("pipeline.missing_response_data"); return showError("pipeline.missing_response_data");
} }
workerType = "encode"; workerType = "encode";
@ -169,7 +169,8 @@ export const createSavePipeline = (info: CobaltLocalProcessingResponse, request:
workerType = "encode"; workerType = "encode";
ffargs = makeGifArgs(); ffargs = makeGifArgs();
} else { } else {
throw new Error("unknown work type: " + info.type); console.error("unknown work type: " + info.type);
return showError("pipeline.missing_response_data");
} }
pipeline.push({ pipeline.push({