diff options
| -rw-r--r-- | scripts/enqueue.ts | 51 |
1 files 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"); |