diff --git a/bridge/aria_bridge.py b/bridge/aria_bridge.py index 95b95de..efd385e 100644 --- a/bridge/aria_bridge.py +++ b/bridge/aria_bridge.py @@ -2806,8 +2806,18 @@ class ARIABridge: "message": payload.get("message", ""), "stack": payload.get("stack", ""), } - with (log_dir / "app.log").open("a", encoding="utf-8") as f: + log_path = log_dir / "app.log" + with log_path.open("a", encoding="utf-8") as f: f.write(json.dumps(line, ensure_ascii=False) + "\n") + # Rotation: app.log waechst sonst unbegrenzt (jede App-Log-Zeile + # haengt an). Bei >5 MB die letzten 2000 Zeilen behalten. + try: + if log_path.stat().st_size > 5 * 1024 * 1024: + tail = log_path.read_text(encoding="utf-8", + errors="ignore").splitlines()[-2000:] + log_path.write_text("\n".join(tail) + "\n", encoding="utf-8") + except Exception: + pass logger.info("[app-log] %s %s: %s", line["level"], line["scope"], line["message"][:120]) except Exception as exc: diff --git a/diagnostic/server.js b/diagnostic/server.js index 34968a6..788c3d5 100644 --- a/diagnostic/server.js +++ b/diagnostic/server.js @@ -1018,12 +1018,6 @@ function connectRVS(forcePlain) { ws.on("message", (raw) => { try { const msg = JSON.parse(raw.toString()); - // DEFINITIVE Roh-Diagnose: jede worker_*/sat_hello-Nachricht loggen, BEVOR - // irgendein Handler greift — zeigt eindeutig, ob sie ueberhaupt ankommt. - if (msg.type && (msg.type.indexOf("worker") === 0 || msg.type === "sat_hello")) { - const p = msg.payload || {}; - log("info", "rvs", `RX ${msg.type} <- ${p.instanceId || p.id || "?"} (svc=${p.service || "-"})`); - } if (msg.type === "chat" && msg.payload) { const sender = msg.payload.sender || "?"; // Eigene Nachrichten ignorieren (Echo) @@ -1080,7 +1074,6 @@ function connectRVS(forcePlain) { } else if (msg.type === "worker_hello") { // Ein Compute-Worker (GPU-Dienst) meldet sich mit seiner Identitaet. const p = msg.payload || {}; - log("info", "rvs", `worker_hello empfangen: ${p.instanceId || "?"} (service=${p.service || "?"}, models=${JSON.stringify(p.models || [])})`); if (p.instanceId) { const prev = workers.get(p.instanceId) || {}; // War die Box vor diesem hello schon frisch gesehen? worker_hello wird