Current job
Queue
-Queue
+Recent events
@@ -127,105 +146,175 @@ ({ "&":"&", "<":"<", ">":">", '"':""", "'":"'" }[c])); } - function fmtDur(sec) { - sec = Math.max(0, Math.floor(sec || 0)); - if (sec <= 0) return "--"; - const h = Math.floor(sec / 3600), m = Math.floor(sec % 3600 / 60), s = sec % 60; - if (h) return `${h}h${String(m).padStart(2,"0")}m`; - if (m) return `${m}m${String(s).padStart(2,"0")}s`; - return `${s}s`; - } - - // "17:49 (3h52m)" — wall-clock finish time plus remaining duration. - function etaText(sec) { - if (!sec || sec <= 0) return "--"; - const done = new Date(Date.now() + sec * 1000); - const p = n => String(n).padStart(2, "0"); - return `${p(done.getHours())}:${p(done.getMinutes())} (${fmtDur(sec)})`; - } - - function chLabel(n) { return ({1:"mono",2:"2.0",6:"5.1",8:"7.1"})[n] || (n ? n+"ch" : ""); } function base(path) { return (path || "").split("/").pop(); } function pad2(s) { return String(s || "").padStart(2, "0"); } - function jobHeading(c) { + // "3h 53m" / "53m 20s" / "20s" — remaining time, spelled for the hero. + function fmtDurLong(sec) { + sec = Math.max(0, Math.floor(sec || 0)); + if (sec <= 0) return "—"; + const h = Math.floor(sec / 3600), m = Math.floor(sec % 3600 / 60), s = sec % 60; + if (h) return `${h}h ${pad2(m)}m`; + if (m) return `${m}m ${pad2(s)}s`; + return `${s}s`; + } + // wall-clock finish time, "21:35" + function clockAt(sec) { + if (!sec || sec <= 0) return "—"; + const d = new Date(Date.now() + sec * 1000), p = n => String(n).padStart(2, "0"); + return `${p(d.getHours())}:${p(d.getMinutes())}`; + } + function chLabel(n) { return ({1:"mono",2:"2.0",6:"5.1",8:"7.1"})[n] || (n ? n+"ch" : ""); } + + // ---- signature: throughput sparkline, fed by the 1 s poll ---- + let speedHist = [], histFile = null; + function pushSpeed(c) { + if (!c || c.file !== histFile) { speedHist = []; histFile = c ? c.file : null; } + if (c && c.phase === "encoding" && c.speed > 0) { + speedHist.push(c.speed); + if (speedHist.length > 90) speedHist.shift(); // ~90 s window + } + } + // Trace of recent speed against a fixed 1.0× realtime reference. The reference + // stays fixed on purpose — autoscaling would hide how far below realtime we run. + function sparkSVG(hist, ref) { + const W = 300, H = 54; + if (hist.length < 2) + return ``; + const max = Math.max(ref * 1.3, ...hist); + const y = v => H - (v / max) * H; + const pts = hist.map((v, i) => `${(i/(hist.length-1)*W).toFixed(1)},${y(v).toFixed(1)}`).join(" "); + const refY = y(ref).toFixed(1); + const below = hist[hist.length-1] < ref; + const col = below ? "var(--red)" : "var(--green)"; + return ``; + } + function trendLabel(hist) { + if (hist.length < 4) return ["—", "var(--dim)"]; + const last = hist[hist.length-1], prev = hist[hist.length-3]; + if (last < prev - 0.01) return ["slowing", "var(--red)"]; + if (last > prev + 0.01) return ["recovering", "var(--green)"]; + return ["holding", "var(--dim)"]; + } + function speedClass(v) { return v <= 0 ? "" : v < 0.5 ? "bad" : v < 1 ? "warn" : "good"; } + + function jobTitleHTML(c) { const m = c.meta; if (m && m.is_series && m.collection) { const se = (m.season && m.episode) ? `S${pad2(m.season)}E${pad2(m.episode)}` : ""; - return { title: m.collection, sub: [se, m.title].filter(Boolean).join(" · ") }; + const ep = (m.title && m.title !== "Unknown") ? ` — “${esc(m.title)}”` : ""; + return `${se ? `${se}` : ""}${esc(m.collection)}${ep}`; } - if (m && m.title && m.title !== "Unknown") return { title: m.title, sub: "" }; - return { title: base(c.file), sub: "" }; + if (m && m.title && m.title !== "Unknown") return esc(m.title); + return esc(base(c.file)); } - function renderStreams(streams) { + function streamsHTML(streams) { if (!streams || !streams.length) return ""; - const audio = streams.filter(s => s.kind === "audio"); - const subs = streams.filter(s => s.kind === "subtitle"); - let html = ""; - if (audio.length) { - html += `Waiting for files in input/.
Waiting for files in input/.