Update app.py

app.py

@@ -23,8 +23,12 @@ MAX_MESSAGES = int(os.getenv("MAX_MESSAGES", "200"))
 PERSIST_TO_FILE = os.getenv("PERSIST_TO_FILE", "0").strip() == "1"
 PERSIST_PATH = os.getenv("PERSIST_PATH", "webhook_messages.jsonl").strip()
 
-# Downstream wakeup server (IMPORTANT: this must be the base path, not ".../wakeup/wakeup")
-WAKEUP_URL = os.getenv("WAKEUP_URL", "http://163.245.192.149:8080/wakeup").strip().rstrip("/")
+# Downstream wakeup server
+# IMPORTANT: This must be the *actual* endpoint. Example:
+#   http://163.245.192.149:8080/wakeup
+WAKEUP_URL = os.getenv("WAKEUP_URL", "http://163.245.192.149:8080/wakeup").strip()
+WAKEUP_URL = WAKEUP_URL.rstrip("/")  # normalize to no trailing slash
+
 RELAY_TIMEOUT = int(os.getenv("RELAY_TIMEOUT", "30"))
 
 # Dedupe window
@@ -114,6 +118,7 @@ def _norm(v: Any) -> str:
 
 
 def compute_fingerprint(payload: Dict[str, Any]) -> str:
+    # MVP fingerprint. Upgrade later to sha256(file_bytes) when you have file URL/bytes.
     parts = {
         "event_type": _norm(payload.get("event_type")),
         "rid": _norm(payload.get("rid")),
@@ -205,14 +210,17 @@ async def webhook(
     now = _now_ts()
     _gc_seen(now)
 
+    # Default state
     if not _norm(payload.get("sa_processing_state")):
         payload["sa_processing_state"] = "new"
 
+    # Fingerprint
     fp = _norm(payload.get("sa_fingerprint"))
     if not fp:
         fp = compute_fingerprint(payload)
         payload["sa_fingerprint"] = fp
 
+    # Dedupe
     duplicate = fp in SEEN
     if not duplicate:
         SEEN[fp] = now
@@ -229,10 +237,6 @@ async def webhook(
         meta = {
             "client": request.client.host if request.client else None,
             "path": str(request.url.path),
-            "headers": {
-                "user-agent": request.headers.get("user-agent"),
-                "content-type": request.headers.get("content-type"),
-            },
         }
         _append_message(payload=payload, meta=meta, relay=relay_info)
         return JSONResponse(status_code=200, content=relay_info)
@@ -249,10 +253,6 @@ async def webhook(
         meta = {
             "client": request.client.host if request.client else None,
             "path": str(request.url.path),
-            "headers": {
-                "user-agent": request.headers.get("user-agent"),
-                "content-type": request.headers.get("content-type"),
-            },
         }
         _append_message(payload=payload, meta=meta, relay=relay_info)
         return JSONResponse(status_code=200, content=relay_info)
@@ -282,12 +282,6 @@ async def webhook(
     meta = {
         "client": request.client.host if request.client else None,
         "path": str(request.url.path),
-        "headers": {
-            "user-agent": request.headers.get("user-agent"),
-            "content-type": request.headers.get("content-type"),
-            WEBHOOK_TOKEN_HEADER: "***" if request.headers.get(WEBHOOK_TOKEN_HEADER) else None,
-            "x-sa-signature": "***" if request.headers.get("x-sa-signature") else None,
-        },
     }
 
     _append_message(payload=payload, meta=meta, relay=relay_info)
@@ -295,7 +289,7 @@ async def webhook(
 
 
 # -----------------------------------------------------------------------------
-# Gradio dashboard (mounted at /ui so it cannot break API routes)
+# Gradio dashboard mounted at /ui (doesn't interfere with API routes)
 # -----------------------------------------------------------------------------
 def ui_status() -> str:
     return _safe_json_dumps(