fix: unbuffered logging + ThreadingHTTPServer for real-time SSE

entry.py

@@ -16,11 +16,17 @@ import logging
 import psutil
 from datetime import datetime, timezone
 from http.server import HTTPServer, BaseHTTPRequestHandler
+from socketserver import ThreadingMixIn
 from pathlib import Path
 from urllib.parse import urlparse, parse_qs
 from queue import Queue, Empty
 from io import BytesIO
 
+
+class ThreadingHTTPServer(ThreadingMixIn, HTTPServer):
+    daemon_threads = True
+    allow_reuse_address = True
+
 # ---------------------------------------------------------------------------
 # Paths
 # ---------------------------------------------------------------------------
@@ -421,10 +427,11 @@ class DashboardHandler(BaseHTTPRequestHandler):
             env = os.environ.copy()
             env["HERMES_ACCEPT_HOOKS"] = "1"
             env["MEMPALACE_PALACE_PATH"] = os.path.join(DATA_DIR, "palace")
+            env["PYTHONUNBUFFERED"] = "1"
 
             _gateway_process = subprocess.Popen(
-                [sys.executable, "-m", "hermes_cli.main", "gateway", "run", "-v"],
-                stdout=open(LOG_FILE, "a"),
+                [sys.executable, "-u", "-m", "hermes_cli.main", "gateway", "run", "-v"],
+                stdout=open(LOG_FILE, "a", buffering=1),
                 stderr=subprocess.STDOUT,
                 env=env,
                 cwd="/app/hermes-agent",
@@ -488,12 +495,13 @@ def main():
     env = os.environ.copy()
     env["HERMES_ACCEPT_HOOKS"] = "1"
     env["MEMPALACE_PALACE_PATH"] = os.path.join(DATA_DIR, "palace")
+    env["PYTHONUNBUFFERED"] = "1"  # 关键：禁用输出缓冲，日志实时写入文件
 
     os.makedirs(LOG_DIR, exist_ok=True)
-    log_fh = open(LOG_FILE, "a")
+    log_fh = open(LOG_FILE, "a", buffering=1)  # 行缓冲
 
     _gateway_process = subprocess.Popen(
-        [sys.executable, "-m", "hermes_cli.main", "gateway", "run", "-v"],
+        [sys.executable, "-u", "-m", "hermes_cli.main", "gateway", "run", "-v"],
         stdout=log_fh,
         stderr=subprocess.STDOUT,
         env=env,
@@ -502,7 +510,7 @@ def main():
     logger.info("Gateway started (PID: %d)", _gateway_process.pid)
 
     # Start dashboard HTTP server
-    server = HTTPServer(("0.0.0.0", 7860), DashboardHandler)
+    server = ThreadingHTTPServer(("0.0.0.0", 7860), DashboardHandler)
     logger.info("Dashboard listening on :7860")
     server.serve_forever()