From 770832dc6ab62bc2ad260bfbd46e1d0a26cc9865 Mon Sep 17 00:00:00 2001
From: metamuffin <metamuffin@disroot.org>
Date: Sat, 14 Jun 2025 17:16:50 +0200
Subject: fix retry failed not running on interval

---
 scripts/enqueue.ts | 51 +++++++++++++++++++++++++--------------------------
 1 file changed, 25 insertions(+), 26 deletions(-)

diff --git a/scripts/enqueue.ts b/scripts/enqueue.ts
index 0c99a79..306797f 100644
--- a/scripts/enqueue.ts
+++ b/scripts/enqueue.ts
@@ -12,34 +12,33 @@ async function run_enqueue(eqt: EnqueueTask) {
             data: { failed: eqt.filter ?? null },
             cookie: "for_enqueue"
         }))
-        return
-    }
-
-    if (!eqt.list_file) throw new Error("need either list_file or retry_failed");
-    const file = await Deno.readTextFile(eqt.list_file)
-    for (const line of file.split("\n")) {
-        if (!line.trim().length) continue
-        let [name, rest] = line.split("=", 2)
-        let [id, flags_raw] = rest.split(";", 2)
-        let flags = flags_raw.split(" ")
+    } else {
+        if (!eqt.list_file) throw new Error("need either list_file or retry_failed");
+        const file = await Deno.readTextFile(eqt.list_file)
+        for (const line of file.split("\n")) {
+            if (!line.trim().length) continue
+            let [name, rest] = line.split("=", 2)
+            let [id, flags_raw] = rest.split(";", 2)
+            let flags = flags_raw.split(" ")
 
-        if (eqt.filter && !flags.includes(eqt.filter)) continue
-        name = name.trim()
-        id = id.trim()
-        for (const f of eqt.default_flags ?? [])
-            if (!flags.includes(`-${f}`)) flags.push(f)
-        flags = flags.filter(e => e.length && !e.startsWith("-") && e != eqt.filter)
+            if (eqt.filter && !flags.includes(eqt.filter)) continue
+            name = name.trim()
+            id = id.trim()
+            for (const f of eqt.default_flags ?? [])
+                if (!flags.includes(`-${f}`)) flags.push(f)
+            flags = flags.filter(e => e.length && !e.startsWith("-") && e != eqt.filter)
 
-        const key = `${eqt.kind}:${id}`;
-        ws.send(JSON.stringify({
-            t: "metadata", key, data: {
-                ...eqt.data,
-                output: (eqt.data.output ?? ".") + "/" + name,
-                title: name,
-                flags,
-            }
-        }))
-        ws.send(JSON.stringify({ t: "enqueue", key, ignore_complete: !(eqt.oneshot ?? false) }))
+            const key = `${eqt.kind}:${id}`;
+            ws.send(JSON.stringify({
+                t: "metadata", key, data: {
+                    ...eqt.data,
+                    output: (eqt.data.output ?? ".") + "/" + name,
+                    title: name,
+                    flags,
+                }
+            }))
+            ws.send(JSON.stringify({ t: "enqueue", key, ignore_complete: !(eqt.oneshot ?? false) }))
+        }
     }
     ws.send(JSON.stringify({ t: "save" }))
     console.log("done");
-- 
cgit v1.2.3-70-g09d2