From fcb22f60d3467db4f5dce95b06cc16257d83ddaf Mon Sep 17 00:00:00 2001
From: duffyduck <info@hacker-net.de>
Date: Fri, 13 Mar 2026 08:05:26 +0100
Subject: [PATCH] expanded logs with catch all

---
 aria-setup.sh        |  2 +-
 diagnostic/server.js | 34 +++++++++++++++++++++++++++++-----
 2 files changed, 30 insertions(+), 6 deletions(-)

diff --git a/aria-setup.sh b/aria-setup.sh
index f00d189..141e825 100755
--- a/aria-setup.sh
+++ b/aria-setup.sh
@@ -58,7 +58,7 @@ docker exec aria-core sh -c 'cat > /home/node/.openclaw/openclaw.json << '"'"'IN
     }
   },
   "messages": {
-    "ackReactionScope": "group-mentions"
+    "ackReactionScope": "all"
   },
   "commands": {
     "native": "auto",
diff --git a/diagnostic/server.js b/diagnostic/server.js
index daf6d28..608ef99 100644
--- a/diagnostic/server.js
+++ b/diagnostic/server.js
@@ -201,10 +201,12 @@ async function connectGateway() {
     gatewayWs = ws;
     broadcastState();
 
-    // Nachrichten-Loop
+    // Nachrichten-Loop — RAW logging fuer Debugging
     ws.on("message", (raw) => {
       try {
-        const msg = JSON.parse(raw.toString());
+        const rawStr = raw.toString();
+        log("debug", "gateway", `RAW <<< ${rawStr.slice(0, 300)}`);
+        const msg = JSON.parse(rawStr);
         handleGatewayMessage(msg);
       } catch (err) {
         log("error", "gateway", `Parse-Fehler: ${err.message}`);
@@ -281,8 +283,28 @@ function handleGatewayMessage(msg) {
       return;
     }
 
-    // Andere Events (presence, tick, etc.)
-    log("debug", "gateway", `Event: ${event}`);
+    // Alle anderen Events — vollstaendig loggen fuer Debugging
+    const payloadStr = JSON.stringify(payload).slice(0, 500);
+    log("info", "gateway", `Event: ${event} | ${payloadStr}`);
+    if (pipelineActive) plog(`Gateway Event: ${event} | ${payloadStr.slice(0, 200)}`);
+
+    // "chat" Event koennte die Antwort sein (anderes Format als erwartet)
+    if (event === "chat") {
+      const text = payload.text || payload.message || payload.content || "";
+      const delta = payload.delta || "";
+      const error = payload.error || "";
+      if (error) {
+        log("error", "gateway", `Chat-Fehler (event:chat): ${error}`);
+        if (pipelineActive) pipelineEnd(false, error);
+        broadcast({ type: "chat_error", error, payload });
+      } else if (text) {
+        log("info", "gateway", `ANTWORT (event:chat): "${text.slice(0, 200)}"`);
+        if (pipelineActive) pipelineEnd(true, `"${text.slice(0, 120)}"`);
+        broadcast({ type: "chat_final", text, payload });
+      } else if (delta) {
+        broadcast({ type: "chat_delta", delta, payload });
+      }
+    }
   }
 }
 
@@ -305,7 +327,9 @@ function sendToGateway(text, isPipeline) {
     },
   };
 
-  gatewayWs.send(JSON.stringify(msg));
+  const payload = JSON.stringify(msg);
+  log("debug", "gateway", `RAW >>> ${payload}`);
+  gatewayWs.send(payload);
   log("info", "gateway", `chat.send [${reqId}]: "${text}"`);
   if (isPipeline) plog(`chat.send [${reqId}] an Gateway gesendet — warte auf ACK...`);
   return true;