From 931a815c293213bc57e4195315d987d89a493f1f Mon Sep 17 00:00:00 2001
From: wukko <me@wukko.me>
Date: Wed, 30 Apr 2025 22:02:00 +0600
Subject: [PATCH] web/queue: add gif pipeline & proper media type icons

---
 web/src/lib/task-manager/queue.ts | 45 ++++++++++++++++++-------------
 1 file changed, 27 insertions(+), 18 deletions(-)

diff --git a/web/src/lib/task-manager/queue.ts b/web/src/lib/task-manager/queue.ts
index f2455b01..b6b3e4c6 100644
--- a/web/src/lib/task-manager/queue.ts
+++ b/web/src/lib/task-manager/queue.ts
@@ -1,11 +1,8 @@
-import { get } from "svelte/store";
-import { t } from "$lib/i18n/translations";
-import { addItem } from "$lib/state/task-manager/queue";
-import { createDialog } from "$lib/state/dialogs";
-import { openQueuePopover } from "$lib/state/queue-visibility";
 import { ffmpegMetadataArgs } from "$lib/util";
+import { addItem } from "$lib/state/task-manager/queue";
+import { openQueuePopover } from "$lib/state/queue-visibility";
 
-import type { CobaltPipelineItem } from "$lib/types/workers";
+import type { CobaltPipelineItem, CobaltPipelineResultFileType } from "$lib/types/workers";
 import type { CobaltLocalProcessingResponse, CobaltSaveRequestBody } from "$lib/types/api";
 
 export const getMediaType = (type: string) => {
@@ -56,6 +53,13 @@ export const createRemuxPipeline = (file: File) => {
     }
 }
 
+const mediaIcons: { [key: string]: CobaltPipelineResultFileType } = {
+    merge: "video",
+    mute: "video",
+    audio: "audio",
+    gif: "image"
+}
+
 export const createSavePipeline = (info: CobaltLocalProcessingResponse, request: CobaltSaveRequestBody) => {
     // TODO: proper error here
     if (!info.output?.filename || !info.output?.type) {
@@ -140,18 +144,23 @@ export const createSavePipeline = (info: CobaltLocalProcessingResponse, request:
             },
         });
     } else if (info.type === "gif") {
-        return createDialog({
-            id: "save-error",
-            type: "small",
-            meowbalt: "error",
-            buttons: [
-                {
-                    text: get(t)("button.gotit"),
-                    main: true,
-                    action: () => { },
+        pipeline.push({
+            worker: "encode",
+            workerId: crypto.randomUUID(),
+            parentId,
+            workerArgs: {
+                files: [],
+                ffargs: [
+                    "-vf",
+                    "scale=-1:-1:flags=lanczos,split[s0][s1];[s0]palettegen[p];[s1][p]paletteuse",
+                    "-loop", "0",
+                    "-f", "gif"
+                ],
+                output: {
+                    type: info.output.type,
+                    format: info.output.filename.split(".").pop(),
                 },
-            ],
-            bodyText: "audio and gif processing isn't implemented yet!",
+            },
         });
     }
 
@@ -163,7 +172,7 @@ export const createSavePipeline = (info: CobaltLocalProcessingResponse, request:
         originalRequest: request,
         filename: info.output.filename,
         mimeType: info.output.type,
-        mediaType: "video",
+        mediaType: mediaIcons[info.type],
     });
 
     openQueuePopover();