Update hub_dashboard_service.py

hub_dashboard_service.py

@@ -4,11 +4,13 @@
 ║  K1RL QUASAR — HUB DASHBOARD SERVICE (with Trade Log Parser) — FIXED v2.5           ║
 ║  ──────────────────────────────────────────────────────────────────────────────────  ║
 ║  Architecture role: READ-ONLY subscriber → serves dashboard UI                      ║
-║  VERSION: v2.5 (PORT FIX)  |  2026-04-04                                            ║
+║  VERSION: v2.5 (PORT + LOG PATH FIX)  |  2026-04-04                                 ║
 ║                                                                                      ║
 ║  FIXES APPLIED:                                                                    ║
-║  ✅ FIX v2.5: Default port changed 8051→7860 (HF Spaces only exposes 7860)         ║
-║  ✅ FIX v2.5: WebSocket URL changed ws://host:7860 → wss://host (HF proxy TLS)     ║
+║  ✅ FIX v2.5: Default port 8051→7860 (HF Spaces only exposes port 7860)            ║
+║  ✅ FIX v2.5: WebSocket ws://host:7860 → wss://host (HF Spaces TLS proxy)          ║
+║  ✅ FIX v2.5: _find_files() searches all likely HF Spaces log paths                 ║
+║  ✅ FIX v2.5: Added /api/debug endpoint for live diagnostics                        ║
 ║  ✅ FIX v2.4: All /api/ranker/logs/* routes inline — no Blueprint dependency        ║
 ║  ✅ FIX v2.4: Training KPI enrichment (_enrich_training) applied on /recent         ║
 ║  ✅ FIX #1:  Include rotated log files (*.log, *.log.1, *.log.2, etc.)             ║
@@ -439,16 +441,42 @@ class FileBasedLoggerAdapter:
 
     def _find_files(self) -> list:
         candidate_dirs = [
-            self._log_dir,
-            str(Path(__file__).parent / "ranker_logs"),
-            "./ranker_logs",
-            str(Path.home() / "ranker_logs"),
+            self._log_dir,                                    # env-configured (default /app/ranker_logs)
+            str(Path(__file__).parent / "ranker_logs"),       # alongside this script
+            "./ranker_logs",                                  # cwd
+            "/app/ranker_logs",                               # HF Spaces default app dir
+            "/home/user/ranker_logs",                         # HF Spaces user home
+            "/tmp/ranker_logs",                               # fallback tmp
+            str(Path.home() / "ranker_logs"),                 # user home
+            str(Path(__file__).parent),                       # script dir itself (*.log*)
         ]
-        for cdir in candidate_dirs:
+        # Deduplicate while preserving order
+        seen = set()
+        unique_dirs = []
+        for d in candidate_dirs:
+            if d not in seen:
+                seen.add(d)
+                unique_dirs.append(d)
+
+        all_files = []
+        for cdir in unique_dirs:
             found = sorted(glob.glob(str(Path(cdir) / "*.log*")))
             if found:
-                return found
-        return []
+                all_files.extend(found)
+        # Also check for any .log* directly in /app and /home/user
+        for root_dir in ["/app", "/home/user", "."]:
+            found = sorted(glob.glob(str(Path(root_dir) / "*.log*")))
+            all_files.extend(found)
+
+        # Deduplicate file list
+        seen_files = set()
+        unique_files = []
+        for f in all_files:
+            if f not in seen_files:
+                seen_files.add(f)
+                unique_files.append(f)
+
+        return sorted(unique_files)
 
     def _read_lines(self, n_tail: int = 500) -> list:
         """Return up to n_tail most-recent lines across the 3 newest log files."""
@@ -888,17 +916,52 @@ def health():
     return jsonify({"status": "ok", "version": "v2.5-port-fix"})
 
 
+@app.route("/api/debug")
+def api_debug():
+    """GET /api/debug — diagnostics: log files found, paths searched, env vars."""
+    import glob as _glob
+    candidate_dirs = [
+        _LOG_DIR,
+        str(Path(__file__).parent / "ranker_logs"),
+        "./ranker_logs",
+        "/app/ranker_logs",
+        "/home/user/ranker_logs",
+        "/tmp/ranker_logs",
+        str(Path.home() / "ranker_logs"),
+        str(Path(__file__).parent),
+        "/app", "/home/user", ".",
+    ]
+    dir_scan = {}
+    for d in candidate_dirs:
+        files = sorted(_glob.glob(str(Path(d) / "*.log*")))
+        dir_scan[d] = {"exists": Path(d).exists(), "log_files": files}
+
+    adapter_files = _log_adapter._find_files()
+    return jsonify({
+        "version": "v2.5-port-fix",
+        "env": {
+            "DASHBOARD_PORT": os.environ.get("DASHBOARD_PORT", "(not set, using 7860)"),
+            "RANKER_LOG_DIR": os.environ.get("RANKER_LOG_DIR", "(not set, using /app/ranker_logs)"),
+            "QUASAR_HUB_HOST": os.environ.get("QUASAR_HUB_HOST", "(not set)"),
+            "cwd": str(Path.cwd()),
+            "script_dir": str(Path(__file__).parent),
+        },
+        "adapter_files_found": adapter_files,
+        "directory_scan": dir_scan,
+        "adapter_stats": _log_adapter.get_stats(),
+    })
+
+
 if __name__ == "__main__":
-    logger.info("=== K1RL QUASAR HUB DASHBOARD SERVICE v2.5 (PORT FIX) ===")
-    logger.info(f"Dashboard: http://localhost:{_DASHBOARD_PORT}")
-    logger.info(f"Log directory: {_LOG_DIR}")
+    logger.info("=== K1RL QUASAR HUB DASHBOARD SERVICE v2.5 (PORT + LOG PATH FIX) ===")
+    logger.info(f"Dashboard port: {_DASHBOARD_PORT}  (HF Spaces public port)")
+    logger.info(f"Log directory:  {_LOG_DIR}")
     logger.info("Fixes applied:")
-    logger.info("  ✅ FIX v2.5: Default port 8051→7860 (HF Spaces public port)")
-    logger.info("  ✅ FIX v2.5: WebSocket URL wss:// (no explicit port — HF proxy handles TLS)")
-    logger.info("  ✅ FIX v2.4: All /api/ranker/logs/* routes inline — no Blueprint dependency")
-    logger.info("  ✅ FIX v2.4: Training KPI enrichment (_enrich_training) applied on /recent")
-    logger.info("  ✅ FIX #1: Now reading *.log* (includes rotated files)")
-    logger.info("  ✅ FIX #2: Improved regex to catch all trade close formats")
-    logger.info("  ✅ FIX #4: Dedicated exit_price regex (no optional-group ambiguity)")
+    logger.info("  ✅ FIX v2.5: Default port 8051→7860 (HF Spaces only exposes 7860)")
+    logger.info("  ✅ FIX v2.5: WebSocket wss:// with no explicit port")
+    logger.info("  ✅ FIX v2.5: _find_files() scans all likely HF Spaces log paths")
+    logger.info("  ✅ FIX v2.5: /api/debug endpoint for live diagnostics")
+    logger.info("  ✅ FIX v2.4: All /api/ranker/logs/* routes inline")
+    logger.info(f"  → Visit /api/debug to inspect log file discovery live")
 
     app.run(host="0.0.0.0", port=_DASHBOARD_PORT, debug=False, use_reloader=False)