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

web/queue: add support for "remux" task type

Browse Source
This commit is contained in:
jj 2025-04-30 14:49:04 +00:00
parent 0716f97a3a
commit 72857e64a8
No known key found for this signature in database
1 changed files with 37 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -58,7 +58,9 @@ export const createRemuxPipeline = (file: File) => {
export const createSavePipeline = (info: CobaltLocalProcessingResponse, request: CobaltSaveRequestBody) => {
// TODO: proper error here
if (!(info.output?.filename && info.output?.type)) return;
if (!info.output?.filename || !info.output?.type) {
return;
}
const parentId = crypto.randomUUID();
const pipeline: CobaltPipelineItem[] = [];
@ -103,9 +105,41 @@ export const createSavePipeline = (info: CobaltLocalProcessingResponse, request:
},
},
});
}
} else if (info.type === "audio") {
if (!info.audio) return; // TODO: proper error
if (["audio", "gif"].includes(info.type)) {
const ffargs = [
"-vn",
...(info.audio.copy ? ["-c:a", "copy"] : ["-b:a", `${info.audio.bitrate}k`]),
...(info.output.metadata ? ffmpegMetadataArgs(info.output.metadata) : [])
];
if (info.audio.format === "mp3" && info.audio.bitrate === "8") {
ffargs.push("-ar", "12000");
}
if (info.audio.format === "opus") {
ffargs.push("-vbr", "off")
}
const outFormat = info.audio.format === "m4a" ? "ipod" : info.audio.format;
ffargs.push('-f', outFormat);
pipeline.push({
worker: "encode",
workerId: crypto.randomUUID(),
parentId,
workerArgs: {
files: [],
ffargs,
output: {
type: info.output.type,
format: info.output.filename.split(".").pop(),
},
},
});
} else if ("gif" === info.type) {
return createDialog({
id: "save-error",
type: "small",