bb

app.py

@@ -74,18 +74,20 @@ def get_wecom_token() -> str:
             params={"corpid": WECOM_CORPID, "corpsecret": WECOM_SECRET},
             timeout=10,
         ).json()
+        log.info("[WECOM] get_token response: %s", r)
         _wx_cache["token"] = r.get("access_token", "")
         _wx_cache["expires"] = time.time() + r.get("expires_in", 7200)
         return _wx_cache["token"]
 
 def send_wecom_message(to_user: str, content: str):
     token = get_wecom_token()
-    httpx.post(
+    payload = {"touser": to_user, "msgtype": "text",
+               "agentid": int(WECOM_AGENTID), "text": {"content": content}}
+    r = httpx.post(
         f"https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token={token}",
-        json={"touser": to_user, "msgtype": "text",
-              "agentid": int(WECOM_AGENTID), "text": {"content": content}},
-        timeout=10,
-    )
+        json=payload, timeout=10,
+    ).json()
+    log.info("[WECOM] send_message to=%s result=%s", to_user, r)
 
 def decrypt_msg(encrypted: str) -> str:
     aes_key = base64.b64decode(WECOM_AES_KEY + "=")
@@ -108,36 +110,62 @@ demo = gr.ChatInterface(
 # ── 挂载企业微信路由到 Gradio 内置 FastAPI app ────────────────
 @demo.app.get("/gateway/wecom")
 async def wecom_verify(request: Request):
+    p = request.query_params
+    log.info("[WECOM] GET verify params: %s", dict(p))
     try:
-        p = request.query_params
         sig = verify_sig(p.get("timestamp",""), p.get("nonce",""), p.get("echostr",""))
-        if sig != p.get("msg_signature",""):
+        expected = p.get("msg_signature","")
+        log.info("[WECOM] verify sig=%s expected=%s match=%s", sig, expected, sig==expected)
+        if sig != expected:
             return PlainTextResponse("")
-        return PlainTextResponse(decrypt_msg(p.get("echostr","")))
-    except Exception:
+        plain = decrypt_msg(p.get("echostr",""))
+        log.info("[WECOM] verify ok, echostr plain=%s", plain)
+        return PlainTextResponse(plain)
+    except Exception as e:
+        log.exception("[WECOM] verify error: %s", e)
         return PlainTextResponse("")
 
 @demo.app.post("/gateway/wecom")
 async def wecom_message(request: Request):
+    p = request.query_params
+    log.info("[WECOM] POST params: %s", dict(p))
     try:
-        p = request.query_params
         body = await request.body()
+        log.info("[WECOM] POST body: %s", body.decode())
         encrypt = ET.fromstring(body.decode()).findtext("Encrypt", "")
         sig = verify_sig(p.get("timestamp",""), p.get("nonce",""), encrypt)
-        if sig != p.get("msg_signature",""):
+        expected = p.get("msg_signature","")
+        log.info("[WECOM] msg sig=%s expected=%s match=%s", sig, expected, sig==expected)
+        if sig != expected:
             return PlainTextResponse("success")
         root = ET.fromstring(decrypt_msg(encrypt))
-        if root.findtext("MsgType") == "text":
-            from_user = root.findtext("FromUserName", "")
+        msg_type = root.findtext("MsgType")
+        from_user = root.findtext("FromUserName", "")
+        log.info("[WECOM] msg_type=%s from=%s", msg_type, from_user)
+        if msg_type == "text":
             content = root.findtext("Content", "").strip()
+            log.info("[WECOM] user=%s msg=%s", from_user, content)
             if content:
                 def reply():
-                    send_wecom_message(from_user, chat_with_hermes(content, []))
+                    try:
+                        answer = chat_with_hermes(content, [])
+                        log.info("[WECOM] reply to=%s answer=%s", from_user, answer)
+                        send_wecom_message(from_user, answer)
+                    except Exception as e:
+                        log.exception("[WECOM] reply error: %s", e)
                 threading.Thread(target=reply, daemon=True).start()
-    except Exception:
-        pass
+    except Exception as e:
+        log.exception("[WECOM] message error: %s", e)
     return PlainTextResponse("success")
 
 # ── 启动 ──────────────────────────────────────────────────────
 if __name__ == "__main__":
+    log.info("Starting Hermes Agent...")
+    log.info("WECOM_TOKEN set: %s", bool(WECOM_TOKEN))
+    log.info("WECOM_AES_KEY set: %s", bool(WECOM_AES_KEY))
+    log.info("WECOM_CORPID set: %s", bool(WECOM_CORPID))
+    log.info("WECOM_SECRET set: %s", bool(WECOM_SECRET))
+    log.info("NVIDIA_API_KEY set: %s", bool(NVIDIA_API_KEY))
+    routes = [r.path for r in demo.app.routes]
+    log.info("Registered routes: %s", routes)
     demo.launch(server_name="0.0.0.0", server_port=7860)