Grotti 3.5.2: Zu wenig Rest blockiert den Start nicht mehr, und ein anlaufender Druck wird nicht als Neustart neu eingereiht.

2026-10-21 21:04:28 +02:00
13 changed files with 98 additions and 77 deletions
@@ -4,6 +4,16 @@ Alle Änderungen an Grotti. Format nach [Keep a Changelog](https://keepachangelo

 ## [Unreleased]

+## [3.5.2] – 2026-10-21
+
+### Geändert
+
+- **Wenig Rest:** ACE oder Spule unter dem Dateigewicht warnt unter Dateien, bricht Start und Warteschlange nicht mehr ab. Falsche Sorte bleibt ein Wartegrund.
+
+### Behoben
+
+- **Queue „Nochmal — Start abgebrochen (Neustart)“ während der Drucker anläuft:** Nach dem Upload bleibt der Auftrag in `await_print`, bis Moonraker druckt. Die 45-Sekunden-Regel gilt nur noch, wenn der Upload-Thread weg ist. Wand und Seitenleiste zeigen „startet“ und dass es etwa eine Minute dauern kann.
+
 ## [3.5.1] – 2026-10-20

 ### Geändert
@@ -9,7 +9,7 @@
 </p>

 <p align="center">
-  <a href="https://git.gundel.dev/dg/grotti"><img src="https://img.shields.io/badge/Version-3.5.1-e85d04?style=flat-square" alt="Version 3.5.1"></a>
+  <a href="https://git.gundel.dev/dg/grotti"><img src="https://img.shields.io/badge/Version-3.5.2-e85d04?style=flat-square" alt="Version 3.5.2"></a>
  <img src="https://img.shields.io/badge/Python-3.11+-3776AB?style=flat-square&logo=python&logoColor=white" alt="Python 3.11+">
  <img src="https://img.shields.io/badge/PostgreSQL-14+-4169E1?style=flat-square&logo=postgresql&logoColor=white" alt="PostgreSQL">
  <img src="https://img.shields.io/badge/Moonraker-Klipper-2ecc71?style=flat-square" alt="Moonraker">
@@ -1,6 +1,6 @@
 # ACE und Spulen

-Stand **18.10.2026**. Mehrfarb-Drucke brauchen vor dem Start eine Zuordnung Datei-Farbe → ACE-Platz und eine passende Spule am Drucker.
+Stand **21.10.2026**. Mehrfarb-Drucke brauchen vor dem Start eine Zuordnung Datei-Farbe → ACE-Platz und eine passende Spule am Drucker.

 ![ACE-Zuordnung beim Senden](../web/static/doku/ace-zuordnung.png)

@@ -44,7 +44,7 @@ Nach einem Grotti-Update mit ACE-Farben: unter Dateien **neu lesen**, damit alte
 | „T… fehlt in der Map“ | Datei neu lesen, Zuordnung erneut setzen (Slicer-T ≠ ACE-Platz) |
 | **invalid filament id** (10011700) | Alte Grotti-Version ohne T-Verdichtung, oder Map nicht neu gesetzt. Grotti neu starten, Datei neu lesen, nochmal senden. |
 | Material-Warnung | Eingelegte Sorte ≠ Datei. Der Start geht trotzdem. PA12-CF steht in Grotti so, an den ACE geht PA6-CF. |
-| Rest zu gering | Andere Spule oder leichteres Teil |
+| Rest zu gering | Warnung unter Dateien („nur … g, Datei braucht … g“). Der Start geht trotzdem; leer pausiert der Drucker. |
 | ACE blinkt nicht / kein Wechsel | Spule und Platz prüfen, ggf. Druck neu starten |
 | Drucker hängt kurz nach Multi-Color-Start | Oft falsche Map (T10 gemappt als Platz 0). Neu lesen + Zuordnung. |

@@ -255,13 +255,17 @@ def build(conn, watcher_latest, printers=None, send_jobs=None):
            live_by_host[host]["display_step_index"] = job.get("display_step_index")
            live_by_host[host]["step_index"] = job.get("step_index")
        else:
+            phase = (job.get("phase") or "").lower()
+            starting = phase in ("starting", "await_print")
            running.append({
                "host": host,
                "name": job.get("printer_name") or host,
-                "state": "running",
+                "state": "starting" if starting else "running",
+                "starting": starting,
                "progress": job.get("progress") or 0,
                "remain": job.get("remain") or 0,
                "filename": job.get("filename") or "",
+                "message": job.get("message") or "",
                "queue_id": job.get("id"),
                "is_ablauf": bool(job.get("is_ablauf")),
            })
@@ -415,44 +415,8 @@ def sync_history(conn, cfg):


 def assert_filament_enough(conn, file_row, spool_id=None, ace_map=None, host=""):
-    """Dateien-Gewicht gegen Spule oder ACE-Plätze prüfen."""
-    need = float((file_row or {}).get("weight_g") or 0)
-    if need <= 0:
-        return
-    mapping = acm.normalize_mapping(ace_map)
-    if mapping and host:
-        leftovers = []
-        for item in mapping:
-            slot = int(item["ams_index"]) + 1
-            row = conn.execute(
-                """
-                SELECT remaining_g, name FROM spools
-                WHERE printer_host = %s AND ace_slot = %s
-                ORDER BY id LIMIT 1
-                """,
-                (host, slot),
-            ).fetchone()
-            if row:
-                leftovers.append(float(row["remaining_g"] or 0))
-        if leftovers and sum(leftovers) + 0.5 < need:
-            raise GrottiError(
-                "ACE-Plätze haben nur %.0f g, Datei braucht %.0f g."
-                % (sum(leftovers), need),
-                "spule",
-            )
-        return
-    if not spool_id:
-        return
-    spool = store.get_spool_row(conn, spool_id)
-    if not spool:
-        return
-    left = float(spool["remaining_g"] or 0)
-    if left + 0.5 < need:
-        raise GrottiError(
-            "Spule „%s“ hat nur %.0f g, Datei braucht %.0f g."
-            % (spool["name"], left, need),
-            "spule",
-        )
+    """Zu wenig Rest bricht den Start nicht ab. Die Oberfläche warnt vorher."""
+    return


 def prepare_send(conn, file_id, host, confirm, override, spool_id, ace_map=None):
@@ -30,7 +30,9 @@ BUSY = {"printing", "paused", "heating", "error"}
 KEEPALIVE_S = 120
 # Nach Start ohne print_active: Upload/MQTT/LeviQ brauchen Zeit, aber nicht ewig
 PRINT_START_TIMEOUT_S = 600
-# Einfacher Queue-Start ohne Worker (typisch Grotti-Neustart)
+# Upload-Worker weg (typisch Grotti-Neustart mitten im Hochladen).
+# Nach erfolgreichem Senden ist die Phase await_print — dort gilt das nicht,
+# sonst wird ein noch anlaufender Druck als „Neustart“ neu eingereiht.
 SIMPLE_START_STUCK_S = 45


@@ -421,16 +423,18 @@ class PrintQueueDispatcher:
                        from grotti import orders

                        orders.attach_order_item_to_live_run(wconn, host, name, oid)
-                    # Phase „starting“ lassen, bis Moonraker printing meldet.
-                    # Sofort print_active + alter complete/standby → fälschlich „Fertig.“
+                    # await_print: Datei ist raus, Drucker meldet printing oft erst
+                    # nach einer Minute. Nicht bei starting lassen — sonst gilt nach
+                    # 45 s der Neustart-Retry und der zweite Start trifft „druckt schon“.
                    store.update_print_queue(
                        wconn,
                        item_id,
                        {
                            "status": "running",
-                            "message": "Startet auf %s: %s" % (printer_copy["name"], name),
+                            "message": "Datei ist auf %s. Druckstart kann etwa eine Minute dauern."
+                            % printer_copy["name"],
                            "host": host,
-                            "phase": "starting",
+                            "phase": "await_print",
                            "phase_started_at": "now",
                        },
                    )
@@ -487,7 +491,7 @@ class PrintQueueDispatcher:
        """Einfach-Druck: running bleiben bis Moonraker fertig/abgebrochen."""
        phase = (item.get("phase") or "").lower()
        state = (live.get("state") or "").lower()
-        if phase == "starting":
+        if phase in ("starting", "await_print"):
            if state in ("printing", "paused", "heating") or live.get("print_active"):
                store.update_print_queue(
                    conn,
@@ -498,6 +502,20 @@ class PrintQueueDispatcher:
                        "message": "Druckt…",
                    },
                )
+                return
+            if phase == "await_print" and self._print_start_timed_out(item):
+                store.update_print_queue(
+                    conn,
+                    item["id"],
+                    {
+                        "status": "error",
+                        "message": "Druckstart-Timeout: Drucker hat nach %d min nicht angefangen."
+                        % (PRINT_START_TIMEOUT_S // 60),
+                        "phase": "",
+                        "phase_started_at": None,
+                    },
+                )
+                return
            # complete/standby vom vorherigen Auftrag: noch warten, nicht „Fertig.“
            return
        if phase != "print_active":
@@ -2858,7 +2858,10 @@ def _match_spools_for_need(need, have, used_ids=None):


 def material_fit_score(conn, host, file_id):
-    """Höher = besser. -1 = warten (falsche Sorte mit Profil, oder zu wenig Rest)."""
+    """Höher = besser. -1 = warten (falsche Sorte mit Profil).
+
+    Zu wenig Rest blockiert nicht; genug Rest gibt Zusatzpunkte.
+    """
    need, weight = _file_needs(conn, file_id)
    have = _spool_material_set(conn, host)
    if not need:
@@ -2883,11 +2886,6 @@ def material_fit_score(conn, host, file_id):
                score += 5
            if weight and best["remaining_g"] + 1e-6 >= weight:
                score += 5
-            elif weight and all(h["remaining_g"] + 1e-6 < weight for h in matched):
-                return -1, "braucht %s (%s g fehlen)" % (
-                    _need_label(n),
-                    int(max(0, weight - max(h["remaining_g"] for h in matched))),
-                )
        return score, ""

    have_types = {h["material_type"] for h in have if h["material_type"]}
@@ -2900,11 +2898,6 @@ def material_fit_score(conn, host, file_id):
            score += 5
            if weight and any(h["remaining_g"] + 1e-6 >= weight for h in matched):
                score += 5
-            elif weight and all(h["remaining_g"] + 1e-6 < weight for h in matched):
-                return -1, "braucht %s (%s g fehlen)" % (
-                    _need_label(n),
-                    int(max(0, weight - max(h["remaining_g"] for h in matched))),
-                )
    return score, ""


@@ -1,3 +1,3 @@
 """Version von Grotti (SemVer). Bei jeder Änderung CHANGELOG.md mitführen."""

-__version__ = "3.5.1"
+__version__ = "3.5.2"
@@ -4,7 +4,7 @@ const CSRF = document.querySelector('meta[name="csrf"]')?.content || "";
 const STATE_LABELS = {
  printing: "druckt", paused: "pausiert", complete: "fertig", standby: "bereit",
  heating: "heizt", error: "Fehler", cancelled: "abgebrochen", offline: "offline",
-  waiting: "wartet", running: "läuft",
+  waiting: "wartet", running: "läuft", starting: "startet",
 };

 function escapeHtml(value) {
@@ -49,7 +49,7 @@
      <dt>Auftrag</dt><dd>Ein Eintrag in der Warteschlange: eine Datei für einen Drucker oder für den nächsten freien.</dd>
      <dt>Ablauf</dt><dd>Auftrag mit mehreren Schritten und Wiederholungen. Nur Kobra 3.</dd>
      <dt>Dieser Drucker</dt><dd>Frei und Platte klar → sofort; sonst Warteschlange für genau diesen Drucker.</dd>
-      <dt>Nächster passender</dt><dd>Grotti claimt den nächsten freien Drucker mit passender Katalog-Sorte und Restfilament.</dd>
+      <dt>Nächster passender</dt><dd>Grotti claimt den nächsten freien Drucker mit passender Katalog-Sorte. Zu wenig Rest warnt nur und hält den Start nicht auf.</dd>
      <dt>Platte belegt</dt><dd>Nach jedem Druck gesetzt. Blockiert den nächsten Auftrag auf diesem Drucker.</dd>
      <dt>Alert</dt><dd>Wichtiges Ereignis (Fertig, Fehler, Abbruch, offline). Steht in der Seitenleiste und geht auf Wunsch an Telegram.</dd>
      <dt>Ereignis</dt><dd>Jeder Eintrag unter Aktivität. Ablauf-Schritte und Starts sind Ereignisse, aber keine Alerts.</dd>
@@ -160,7 +160,7 @@
  {% endif %}
  <form method="dialog"><button class="ghost" value="cancel">Schließen</button></form>
 </dialog>
-<script src="{{ url_for('static', filename='api.js') }}?v=32"></script>
+<script src="{{ url_for('static', filename='api.js') }}?v=33"></script>
 <script src="{{ url_for('static', filename='ui.js') }}?v=6"></script>
 <script>
 async function doLogout() {
@@ -315,9 +315,9 @@ function runLineHtml({ name, progress, remain, filename, tipExtra, cancelId, hos
  const pct = Math.max(0, Math.min(100, Math.round((Number(progress) || 0) * 100)));
  const finish = remain > 0 ? finishClock(remain) : "";
  const bits = [name];
-  if (pct > 0 || remain > 0) bits.push(pct + " %");
-  if (finish) bits.push(finish);
  if (tipExtra) bits.push(tipExtra);
+  else if (pct > 0 || remain > 0) bits.push(pct + " %");
+  if (finish) bits.push(finish);
  const tip = [
    filename ? jobLabel(filename) : "",
    remain > 0 ? "noch " + hours(remain) : "",
@@ -375,9 +375,10 @@ function renderLiveChips({ actionItems, running, activeSends, alertCount, etaTex
    const pct = Math.max(0, Math.min(100, Math.round((Number(p.progress) || 0) * 100)));
    const finish = p.remain > 0 ? finishClock(p.remain) : "";
    const pausedFil = p.state === "paused" && (p.filament_empty || p.pause_reason);
+    const starting = p.starting || p.state === "starting";
    const label = [
      shortPrinter(p.name || p.host),
-      pausedFil ? "Material!" : (pct ? pct + "%" : ""),
+      pausedFil ? "Material!" : (starting ? "startet" : (pct ? pct + "%" : "")),
      finish,
    ].filter(Boolean).join(" · ");
    const tip = [p.name || "", p.pause_reason || ""].filter(Boolean).join(" — ");
@@ -479,6 +480,7 @@ async function refreshJetzt() {
        progress: p.progress,
        remain: p.remain,
        filename: p.filename,
+        tipExtra: (p.starting || p.state === "starting") ? "wird gestartet" : "",
        cancelId: p.queue_id,
      })).join(""),
    );
@@ -322,6 +322,14 @@ function actionsHtml(state, printer) {
 function flowHtml(printer) {
  const job = printer.queue_running;
  const bits = [];
+  const pending = startingJob(printer);
+  if (pending) {
+    const name = jobName(pending.filename || "") || "Datei";
+    bits.push(`<div class="strip flow">
+      <div class="flow-head">${icon("play")}<span class="grow">Startet ${escapeHtml(name)}</span></div>
+      <div class="flow-msg">Die Datei ist auf dem Drucker. Bis der Druck läuft, kann es etwa eine Minute dauern — der Auftrag bleibt hier.</div>
+    </div>`);
+  }
  // Nur Ablauf braucht den Strip (Schritte). Einfacher Queue-Druck: Karte zeigt schon DRUCKT.
  if (job && job.is_ablauf) {
    const rep = repeatText(job);
@@ -511,6 +519,16 @@ function steerPanelHtml(printer) {
  </div>`;
 }

+function startingJob(printer) {
+  const job = printer && printer.queue_running;
+  if (!job || job.is_ablauf) return null;
+  const phase = String(job.phase || "").toLowerCase();
+  if (phase !== "starting" && phase !== "await_print") return null;
+  const state = shownState(printer);
+  if (state === "printing" || state === "paused" || state === "heating") return null;
+  return job;
+}
+
 function heroHtml(printer, state) {
  const remain = hours(printer.remain);
  const eta = finishClock(printer.remain);
@@ -532,6 +550,11 @@ function heroHtml(printer, state) {
  if (state === "offline") {
    return `<div class="hero idle"><span class="hero-main">nicht erreichbar</span></div>`;
  }
+  const pending = startingJob(printer);
+  if (pending) {
+    const name = jobName(pending.filename || "") || "Datei";
+    return `<div class="hero"><span class="hero-main"><small>startet</small>${escapeHtml(name)}</span><span class="hero-side">kann eine Minute dauern</span></div>`;
+  }
  if (state === "complete") {
    const took = hours(printer.elapsed);
    const last = jobLabel(printer.filename || "");
@@ -541,7 +564,7 @@ function heroHtml(printer, state) {
  if (state === "cancelled") {
    return `<div class="hero idle"><span class="hero-main">abgebrochen</span></div>`;
  }
-  const busyQueue = printer.queue_running ? "Ablauf läuft" : "";
+  const busyQueue = printer.queue_running && printer.queue_running.is_ablauf ? "Ablauf läuft" : "";
  return `<div class="hero idle"><span class="hero-main">${needsClear(printer) ? "Platte belegt" : "bereit"}</span>${busyQueue ? `<span class="hero-side">${busyQueue}</span>` : ""}</div>`;
 }

@@ -809,13 +832,15 @@ function patchCard(article, printer) {
  else runningJobs.delete(printer.host);

  const role = (name) => article.querySelector(`[data-role=${name}]`);
-  setHtml(role("chip"), chipHtml(state, labels[state]));
+  const pendingStart = startingJob(printer);
+  setHtml(role("chip"), chipHtml(pendingStart ? "heating" : state, pendingStart ? "startet" : labels[state]));
  setHtml(role("hero"), heroHtml(printer, state));
  patchBar(role("bar"), printer, state);
  setHtml(role("stats"), statsHtml(printer, state));
  setHtml(role("temps"), tempbarsHtml(printer, state));
  const jobline = role("jobline");
-  const jobVisible = jobLineVisible(printer, state, shownFile);
+  const startName = pendingStart ? (pendingStart.filename || "") : "";
+  const jobVisible = jobLineVisible(printer, state, shownFile || startName) || !!pendingStart;
  const hasThumb = !!(jobVisible && printer.preview);
  if (jobline) {
    jobline.hidden = !jobVisible;
@@ -847,8 +872,8 @@ function patchCard(article, printer) {
  }
  const job = role("job");
  if (job) {
-    setText(job, jobName(shownFile) || "");
-    job.title = shownFile || "";
+    setText(job, jobName(shownFile || startName) || "");
+    job.title = shownFile || startName || "";
  }
  setHtml(role("swatches"), swatchesHtml(printer));
  setHtml(role("flow"), flowHtml(printer));
@@ -976,7 +1001,8 @@ function patchDesk(printer) {
  const nameEl = role("name");
  if (nameEl) nameEl.textContent = printer.name || printer.host;
  setHtml(role("badge"), printer.family_label ? `<span class="badge">${escapeHtml(printer.family_label)}</span>` : "");
-  setHtml(role("chip"), chipHtml(state, labels[state]));
+  const pendingStart = startingJob(printer);
+  setHtml(role("chip"), chipHtml(pendingStart ? "heating" : state, pendingStart ? "startet" : labels[state]));
  setHtml(role("pills"), pillsHtml(printer.host));
  const mainsail = role("mainsail");
  if (mainsail) {
@@ -989,12 +1015,13 @@ function patchDesk(printer) {
  setHtml(role("temps"), tempbarsHtml(printer, state));

  const jobline = role("jobline");
-  const jobVisible = jobLineVisible(printer, state, shownFile);
+  const startName = pendingStart ? (pendingStart.filename || "") : "";
+  const jobVisible = jobLineVisible(printer, state, shownFile || startName) || !!pendingStart;
  if (jobline) jobline.hidden = !jobVisible && !printer.preview;
  const job = role("job");
  if (job) {
-    setText(job, jobName(shownFile) || (jobVisible ? "" : "Kein Auftrag"));
-    job.title = shownFile || "";
+    setText(job, jobName(shownFile || startName) || (jobVisible ? "" : "Kein Auftrag"));
+    job.title = shownFile || startName || "";
  }
  const preview = role("preview");
  if (preview) {
@@ -136,9 +136,12 @@ function render() {
    } else if (st === "waiting" || st === "running") {
      tools.push(`<button type="button" class="icon-btn danger" data-cancel="${job.id}" title="Abbrechen">${icon("x")}</button>`);
    }
-    const chipState = st === "running" ? "printing" : st === "waiting" ? "waiting" : st === "error" ? "error" : st === "done" ? "done" : st === "cancelled" || st === "dismissed" ? "dismissed" : "complete";
+    const phase = String(job.phase || "").toLowerCase();
+    const starting = st === "running" && (phase === "starting" || phase === "await_print");
+    const chipState = starting ? "heating" : st === "running" ? "printing" : st === "waiting" ? "waiting" : st === "error" ? "error" : st === "done" ? "done" : st === "cancelled" || st === "dismissed" ? "dismissed" : "complete";
+    const chipLabel = starting ? "startet" : (STATUS_LABEL[st] || st);
    return `<tr data-id="${job.id}">
-      <td>${chipHtml(chipState, STATUS_LABEL[st] || st)}</td>
+      <td>${chipHtml(chipState, chipLabel)}</td>
      <td><span class="cell-file" title="${escapeHtml(job.filename || "")}">${escapeHtml(jobLabel(job.filename))}</span>${rep ? " · " + escapeHtml(rep) : ""}</td>
      <td>${job.host ? `<a href="/#${encodeURIComponent(job.host)}">${escapeHtml(targetOf(job))}</a>` : escapeHtml(targetOf(job))}</td>
      <td>${steps || "—"}</td>