#!/usr/bin/env python3 """ dashboard_server.py — Live Trading Bot Dashboard ================================================= Serves a real-time HTML dashboard on HTTP (default port 8080). Endpoints: GET / → dashboard HTML (JS auto-refreshes data every 60 s) GET /api/data → JSON snapshot (process info + agent PnL + log tail) Managed by watcher_v4.py alongside trading_bot and shadow_bot. Access via: http://:8080/ SSH tunnel: ssh -L 8080:localhost:8080 user@jackal """ import os, json, subprocess from datetime import datetime, timezone, timedelta from http.server import HTTPServer, BaseHTTPRequestHandler PORT = 8080 WORK_DIR = "/opt/services/bots/trading_bot/Stock_Bot" SHADOW_DIR = "/opt/services/bots/shadow_bot/Stock_Bot" HANDOFF = os.path.join(WORK_DIR, "logs/claude_handoff.json") SHADOW_HANDOFF = os.path.join(SHADOW_DIR, "logs/claude_handoff.json") BOT_LOG = os.path.join(WORK_DIR, "trading.log") SHADOW_LOG = os.path.join(SHADOW_DIR, "trading.log") # ── System helpers ───────────────────────────────────────────────────────────── def proc_info(pattern): """Return process info dict for the first PID matching pattern.""" try: r = subprocess.run(["pgrep", "-f", pattern], capture_output=True, timeout=5) if r.returncode != 0: return {"running": False} pid = int(r.stdout.decode().strip().split()[0]) ram_mb = 0 try: with open(f"/proc/{pid}/status") as f: for line in f: if line.startswith("VmRSS:"): ram_mb = int(line.split()[1]) // 1024 break except Exception: pass cpu_pct = 0.0 try: c = subprocess.run(["ps", "-p", str(pid), "-o", "pcpu="], capture_output=True, text=True, timeout=5) cpu_pct = float(c.stdout.strip()) if c.stdout.strip() else 0.0 except Exception: pass return {"running": True, "pid": pid, "ram_mb": ram_mb, "cpu_pct": round(cpu_pct, 1)} except Exception: return {"running": False} def sys_mem(): try: mem = {} with open("/proc/meminfo") as f: for line in f: p = line.split() if len(p) >= 2: mem[p[0].rstrip(":")] = int(p[1]) total_mb = mem.get("MemTotal", 0) // 1024 avail_mb = mem.get("MemAvailable", 0) // 1024 used_mb = total_mb - avail_mb return { "total_mb": total_mb, "used_mb": used_mb, "avail_mb": avail_mb, "used_pct": round(used_mb / total_mb * 100, 1) if total_mb else 0, } except Exception: return {"total_mb": 0, "used_mb": 0, "avail_mb": 0, "used_pct": 0} def load_handoff(path): try: with open(path) as f: return json.load(f) except Exception: return {} def tail_log(path, n=50): try: r = subprocess.run(["tail", "-n", str(n), path], capture_output=True, text=True, timeout=5) lines = r.stdout.strip().split("\n") if r.stdout.strip() else [] return [l for l in lines if l.strip()] except Exception: return [] def market_status(): try: import pytz tz = pytz.timezone("America/New_York") now = datetime.now(tz) if now.weekday() >= 5: open_flag = False else: t = (now.hour, now.minute) open_flag = (9, 30) <= t <= (16, 0) if open_flag: return {"is_open": True, "label": "OPEN", "next": ""} # next open nxt = now.replace(hour=9, minute=30, second=0, microsecond=0) if now >= nxt: nxt += timedelta(days=1) while nxt.weekday() >= 5: nxt += timedelta(days=1) diff = nxt - now h, rem = divmod(int(diff.total_seconds()), 3600) m = rem // 60 return {"is_open": False, "label": "CLOSED", "next": f"{h}h {m}m"} except Exception: return {"is_open": False, "label": "UNKNOWN", "next": ""} def agents_stats(handoff): agents = handoff.get("agents", []) if not agents: return {"total_pnl": 0, "total_capital": 0, "total_trades": 0, "win_rate": 0, "count": 0, "agents": []} total_pnl = sum(a.get("total_pnl", 0) for a in agents) total_cap = sum(a.get("capital", 1000) for a in agents) total_trades = sum(a.get("trades", 0) for a in agents) total_wins = sum(a.get("wins", 0) for a in agents) rows = [] for a in sorted(agents, key=lambda x: x.get("total_pnl", 0), reverse=True): t = a.get("trades", 0) w = a.get("wins", 0) rows.append({ "name": a.get("name", "?"), "type": a.get("type", "base"), "pnl": round(a.get("total_pnl", 0), 2), "capital": round(a.get("capital", 1000), 2), "trades": t, "wins": w, "win_rate": round(w / t * 100, 1) if t else 0, "train_count":a.get("train_count", 0), "val_acc": round(a.get("val_acc", 0) * 100, 1), "gross_profit": round(a.get("gross_profit", 0), 2), "gross_loss": round(a.get("gross_loss", 0), 2), }) return { "total_pnl": round(total_pnl, 2), "total_capital": round(total_cap, 2), "total_trades": total_trades, "win_rate": round(total_wins / total_trades * 100, 1) if total_trades else 0, "count": len(agents), "agents": rows, } def build_data(): now_utc = datetime.now(timezone.utc) t_hand = load_handoff(HANDOFF) s_hand = load_handoff(SHADOW_HANDOFF) watcher = proc_info("watcher_v4") trading = proc_info("trading_bot/Stock_Bot/StockTrading") shadow = proc_info("shadow_bot/Stock_Bot/StockTrading") dash = proc_info("dashboard_server") return { "timestamp": now_utc.strftime("%Y-%m-%dT%H:%M:%SZ"), "market": market_status(), "processes": { "watcher": watcher, "trading": trading, "shadow": shadow, "dashboard": dash, }, "system": sys_mem(), "trading": agents_stats(t_hand), "shadow": agents_stats(s_hand), "trading_log": tail_log(BOT_LOG, 50), "shadow_log": tail_log(SHADOW_LOG, 30), } # ── Embedded HTML ────────────────────────────────────────────────────────────── DASHBOARD_HTML = r""" Trading Bot — Live Dashboard
Live
—
Next update in 60s
Process Status
Trading Bot — Summary
Live vs Shadow
System Resources
Agent Leaderboard — Trading Bot
Agent Leaderboard — Shadow Bot
Log Tails
Trading Bot
Shadow Bot
""" # ── HTTP Handler ─────────────────────────────────────────────────────────────── class Handler(BaseHTTPRequestHandler): def log_message(self, fmt, *args): pass # suppress per-request stdout noise def do_GET(self): if self.path in ('/', '/index.html'): body = DASHBOARD_HTML.encode('utf-8') self.send_response(200) self.send_header('Content-Type', 'text/html; charset=utf-8') self.send_header('Content-Length', str(len(body))) self.end_headers() self.wfile.write(body) elif self.path == '/api/data': try: data = build_data() body = json.dumps(data, default=str).encode('utf-8') except Exception as e: body = json.dumps({"error": str(e)}).encode('utf-8') self.send_response(200) self.send_header('Content-Type', 'application/json') self.send_header('Access-Control-Allow-Origin', '*') self.send_header('Cache-Control', 'no-cache') self.send_header('Content-Length', str(len(body))) self.end_headers() self.wfile.write(body) else: self.send_response(404) self.end_headers() # ── Entry point ──────────────────────────────────────────────────────────────── def main(): server = HTTPServer(('0.0.0.0', PORT), Handler) ts = datetime.now(timezone.utc).strftime('%Y-%m-%d %H:%M:%S') print(f"[{ts}] Dashboard server listening on http://0.0.0.0:{PORT}", flush=True) try: server.serve_forever() except KeyboardInterrupt: pass if __name__ == '__main__': main()