fix: [PANELS] Add heartbeat / morning briefing panel tied to Hermes state (closes #698)

.gitignore

@@ -7,3 +7,6 @@ mempalace/__pycache__/
 
 # Prevent agents from writing to wrong path (see issue #1145)
 public/nexus/
+
+__pycache__/
+*.pyc

app.js

@@ -713,6 +713,8 @@ async function init() {
   connectHermes();
   fetchGiteaData();
   setInterval(fetchGiteaData, 30000); // Refresh every 30s
+  updateHeartbeatBriefing(); // Initial briefing load
+  setInterval(updateHeartbeatBriefing, 60000); // Refresh briefing every 60s
 
   composer = new EffectComposer(renderer);
   composer.addPass(new RenderPass(scene, camera));
@@ -1140,6 +1142,7 @@ async function fetchGiteaData() {
       const worldState = JSON.parse(atob(content.content));
       updateNexusCommand(worldState);
       updateSovereignHealth();
+      updateHeartbeatBriefing();
     }
   } catch (e) {
     console.error('Failed to fetch Gitea data:', e);
@@ -1235,6 +1238,127 @@ function updateNexusCommand(state) {
   terminal.updatePanelText(lines);
 }
 
+// ═══ HEARTBEAT BRIEFING PANEL ═════════════════════════════════════════
+async function updateHeartbeatBriefing() {
+  const container = document.getElementById('heartbeat-briefing-content');
+  const pulseDot = document.querySelector('.hb-pulse-dot');
+  if (!container) return;
+
+  let data = null;
+  try {
+    // Derive briefing endpoint from current location or fallback to localhost
+    const briefingUrl = window.location.protocol === 'file:'
+      ? 'http://localhost:8766/api/briefing'
+      : `${window.location.protocol}//${window.location.hostname}:8766/api/briefing`;
+    const res = await fetch(briefingUrl);
+    if (res.ok) data = await res.json();
+  } catch (e) {
+    // Server not reachable — show honest offline state
+  }
+
+  if (!data) {
+    if (pulseDot) pulseDot.classList.add('offline');
+    container.innerHTML = '<div class="hb-empty">Briefing offline<br>No connection to Nexus gateway</div>';
+    return;
+  }
+
+  if (pulseDot) pulseDot.classList.remove('offline');
+
+  let html = '';
+
+  // ── Core Heartbeat ──
+  html += '<div class="briefing-section">';
+  html += '<div class="briefing-section-label">Nexus Core</div>';
+  const hb = data.core_heartbeat;
+  if (hb) {
+    const age = hb.age_secs != null ? hb.age_secs : '?';
+    const ageLabel = typeof age === 'number'
+      ? (age < 60 ? `${age.toFixed(0)}s ago` : `${(age / 60).toFixed(1)}m ago`)
+      : age;
+    const isAlive = typeof age === 'number' && age < 120;
+    html += `<div class="hb-core-row">
+      <span class="hb-core-status ${isAlive ? 'alive' : 'dead'}">${isAlive ? '● ALIVE' : '○ STALE'}</span>
+      <span class="hb-core-meta">cycle ${hb.cycle || '?'} · ${hb.model || 'unknown'} · ${ageLabel}</span>
+    </div>`;
+    html += `<div class="hb-core-meta">status: ${hb.status || '?'}</div>`;
+  } else {
+    html += '<div class="hb-core-row"><span class="hb-core-status dead">○ NO DATA</span></div>';
+  }
+  html += '</div>';
+
+  // ── Cron Heartbeats ──
+  const cron = data.cron_heartbeat;
+  if (cron && cron.jobs && cron.jobs.length > 0) {
+    html += '<div class="briefing-section">';
+    html += '<div class="briefing-section-label">Cron Heartbeats</div>';
+    html += `<div class="hb-cron-row">
+      <span class="hb-cron-healthy">● ${cron.healthy_count} healthy</span>
+      ${cron.stale_count > 0 ? `<span class="hb-cron-stale">⚠ ${cron.stale_count} stale</span>` : ''}
+    </div>`;
+    for (const job of cron.jobs.slice(0, 5)) {
+      const cls = job.healthy ? 'healthy' : 'stale';
+      html += `<div class="hb-cron-job">
+        <span class="hb-cron-job-name">${esc(job.job)}</span>
+        <span class="hb-cron-job-status ${cls}">${esc(job.message)}</span>
+      </div>`;
+    }
+    if (cron.jobs.length > 5) {
+      html += `<div class="hb-core-meta">+${cron.jobs.length - 5} more jobs</div>`;
+    }
+    html += '</div>';
+  }
+
+  // ── Morning Report ──
+  const report = data.morning_report;
+  if (report) {
+    html += '<div class="briefing-section">';
+    html += '<div class="briefing-section-label">Latest Report</div>';
+
+    // Aggregate stats
+    let totalClosed = 0, totalMerged = 0;
+    if (report.repos) {
+      for (const r of Object.values(report.repos)) {
+        totalClosed += r.closed_issues || 0;
+        totalMerged += r.merged_prs || 0;
+      }
+    }
+    html += `<div class="hb-stats-row">
+      <div class="hb-stat"><span class="hb-stat-value" style="color:#4af0c0">${totalClosed}</span><span class="hb-stat-label">Closed</span></div>
+      <div class="hb-stat"><span class="hb-stat-value" style="color:#7b5cff">${totalMerged}</span><span class="hb-stat-label">Merged</span></div>
+      <div class="hb-stat"><span class="hb-stat-value" style="color:#ffd700">${(report.blockers || []).length}</span><span class="hb-stat-label">Blockers</span></div>
+    </div>`;
+
+    // Highlights (up to 3)
+    if (report.highlights && report.highlights.length > 0) {
+      for (const h of report.highlights.slice(0, 3)) {
+        html += `<div class="hb-core-meta">+ ${esc(h)}</div>`;
+      }
+    }
+
+    // Blockers
+    if (report.blockers && report.blockers.length > 0) {
+      for (const b of report.blockers) {
+        html += `<div class="hb-blocker">⚠ ${esc(b)}</div>`;
+      }
+    }
+
+    html += `<div class="hb-timestamp">Report: ${esc(report.generated_at || '?')}</div>`;
+    html += '</div>';
+  }
+
+  // ── Timestamp ──
+  html += `<div class="hb-timestamp">Briefing updated: ${new Date().toLocaleTimeString('en-US', { hour12: false })}</div>`;
+
+  container.innerHTML = html;
+}
+
+function esc(str) {
+  if (!str) return '';
+  const d = document.createElement('div');
+  d.textContent = String(str);
+  return d.innerHTML;
+}
+
 // ═══ AGENT PRESENCE SYSTEM ═══
 function createAgentPresences() {
   const agentData = [

index.html

@@ -96,6 +96,12 @@
       <div class="panel-header">SOVEREIGN HEALTH</div>
       <div id="sovereign-health-content" class="panel-content"></div>
     </div>
+    <div class="hud-panel hud-panel-briefing" id="heartbeat-briefing-log">
+      <div class="panel-header">
+        <span class="hb-pulse-dot"></span> HEARTBEAT BRIEFING
+      </div>
+      <div id="heartbeat-briefing-content" class="panel-content"></div>
+    </div>
     <div class="hud-panel" id="calibrator-log">
       <div class="panel-header">ADAPTIVE CALIBRATOR</div>
       <div id="calibrator-log-content" class="panel-content"></div>

nexus/bannerlord_harness.py

@@ -29,8 +29,6 @@ from typing import Any, Callable, Optional
 
 import websockets
 
-from bannerlord_trace import BannerlordTraceLogger
-
 # ═══════════════════════════════════════════════════════════════════════════
 # CONFIGURATION
 # ═══════════════════════════════════════════════════════════════════════════
@@ -267,13 +265,11 @@ class BannerlordHarness:
         desktop_command: Optional[list[str]] = None,
         steam_command: Optional[list[str]] = None,
         enable_mock: bool = False,
-        enable_trace: bool = False,
     ):
         self.hermes_ws_url = hermes_ws_url
         self.desktop_command = desktop_command or DEFAULT_MCP_DESKTOP_COMMAND
         self.steam_command = steam_command or DEFAULT_MCP_STEAM_COMMAND
         self.enable_mock = enable_mock
-        self.enable_trace = enable_trace
 
         # MCP clients
         self.desktop_mcp: Optional[MCPClient] = None
@@ -288,9 +284,6 @@ class BannerlordHarness:
         self.cycle_count = 0
         self.running = False
 
-        # Session trace logger
-        self.trace_logger: Optional[BannerlordTraceLogger] = None
-
     # ═══ LIFECYCLE ═══
 
     async def start(self) -> bool:
@@ -321,15 +314,6 @@ class BannerlordHarness:
         # Connect to Hermes WebSocket
         await self._connect_hermes()
 
-        # Initialize trace logger if enabled
-        if self.enable_trace:
-            self.trace_logger = BannerlordTraceLogger(
-                harness_session_id=self.session_id,
-                hermes_session_id=self.session_id,
-            )
-            self.trace_logger.start_session()
-            log.info(f"Trace logger started: {self.trace_logger.trace_id}")
-
         log.info("Harness initialized successfully")
         return True
 
@@ -338,12 +322,6 @@ class BannerlordHarness:
         self.running = False
         log.info("Shutting down harness...")
 
-        # Finalize trace logger
-        if self.trace_logger:
-            manifest = self.trace_logger.finish_session()
-            log.info(f"Trace saved: {manifest.trace_file}")
-            log.info(f"Manifest: {self.trace_logger.manifest_file}")
-
         if self.desktop_mcp:
             self.desktop_mcp.stop()
         if self.steam_mcp:
@@ -729,11 +707,6 @@ class BannerlordHarness:
             self.cycle_count = iteration
             log.info(f"\n--- ODA Cycle {iteration + 1}/{max_iterations} ---")
 
-            # Start trace cycle
-            trace_cycle = None
-            if self.trace_logger:
-                trace_cycle = self.trace_logger.begin_cycle(iteration)
-
             # 1. OBSERVE: Capture state
             log.info("[OBSERVE] Capturing game state...")
             state = await self.capture_state()
@@ -742,24 +715,11 @@ class BannerlordHarness:
             log.info(f"  Screen: {state.visual.screen_size}")
             log.info(f"  Players online: {state.game_context.current_players_online}")
 
-            # Populate trace with observation data
-            if trace_cycle:
-                trace_cycle.screenshot_path = state.visual.screenshot_path or ""
-                trace_cycle.window_found = state.visual.window_found
-                trace_cycle.screen_size = list(state.visual.screen_size)
-                trace_cycle.mouse_position = list(state.visual.mouse_position)
-                trace_cycle.playtime_hours = state.game_context.playtime_hours
-                trace_cycle.players_online = state.game_context.current_players_online
-                trace_cycle.is_running = state.game_context.is_running
-
             # 2. DECIDE: Get actions from decision function
             log.info("[DECIDE] Getting actions...")
             actions = decision_fn(state)
             log.info(f"  Decision returned {len(actions)} actions")
 
-            if trace_cycle:
-                trace_cycle.actions_planned = actions
-
             # 3. ACT: Execute actions
             log.info("[ACT] Executing actions...")
             results = []
@@ -771,13 +731,6 @@ class BannerlordHarness:
                 if result.error:
                     log.info(f"    Error: {result.error}")
 
-                if trace_cycle:
-                    trace_cycle.actions_executed.append(result.to_dict())
-
-            # Finalize trace cycle
-            if trace_cycle:
-                self.trace_logger.finish_cycle(trace_cycle)
-
             # Send cycle summary telemetry
             await self._send_telemetry({
                 "type": "oda_cycle_complete",
@@ -883,18 +836,12 @@ async def main():
         default=1.0,
         help="Delay between iterations in seconds (default: 1.0)",
     )
-    parser.add_argument(
-        "--trace",
-        action="store_true",
-        help="Enable session trace logging to ~/.timmy/traces/bannerlord/",
-    )
     args = parser.parse_args()
 
     # Create harness
     harness = BannerlordHarness(
         hermes_ws_url=args.hermes_ws,
         enable_mock=args.mock,
-        enable_trace=args.trace,
     )
 
     try:

nexus/bannerlord_trace.py

@@ -1,234 +0,0 @@
-#!/usr/bin/env python3
-"""
-Bannerlord Session Trace Logger — First-Replayable Training Material
-
-Captures one Bannerlord session as a replayable trace:
-  - Timestamps on every cycle
-  - Actions executed with success/failure
-  - World-state evidence (screenshots, Steam stats)
-  - Hermes session/log ID mapping
-
-Storage: ~/.timmy/traces/bannerlord/trace_<session_id>.jsonl
-Manifest: ~/.timmy/traces/bannerlord/manifest_<session_id>.json
-
-Each JSONL line is one ODA cycle with full context.
-The manifest bundles metadata for replay/eval.
-"""
-
-from __future__ import annotations
-
-import json
-import time
-import uuid
-from dataclasses import dataclass, field, asdict
-from datetime import datetime, timezone
-from pathlib import Path
-from typing import Optional
-
-# Storage root — local-first under ~/.timmy/
-DEFAULT_TRACE_DIR = Path.home() / ".timmy" / "traces" / "bannerlord"
-
-
-@dataclass
-class CycleTrace:
-    """One ODA cycle captured in full."""
-    cycle_index: int
-    timestamp_start: str
-    timestamp_end: str = ""
-    duration_ms: int = 0
-
-    # Observe
-    screenshot_path: str = ""
-    window_found: bool = False
-    screen_size: list[int] = field(default_factory=lambda: [1920, 1080])
-    mouse_position: list[int] = field(default_factory=lambda: [0, 0])
-    playtime_hours: float = 0.0
-    players_online: int = 0
-    is_running: bool = False
-
-    # Decide
-    actions_planned: list[dict] = field(default_factory=list)
-    decision_note: str = ""
-
-    # Act
-    actions_executed: list[dict] = field(default_factory=list)
-    actions_succeeded: int = 0
-    actions_failed: int = 0
-
-    # Metadata
-    hermes_session_id: str = ""
-    hermes_log_id: str = ""
-    harness_session_id: str = ""
-
-    def to_dict(self) -> dict:
-        return asdict(self)
-
-
-@dataclass
-class SessionManifest:
-    """Top-level metadata for a captured session trace."""
-    trace_id: str
-    harness_session_id: str
-    hermes_session_id: str
-    hermes_log_id: str
-    game: str = "Mount & Blade II: Bannerlord"
-    app_id: int = 261550
-    started_at: str = ""
-    finished_at: str = ""
-    total_cycles: int = 0
-    total_actions: int = 0
-    total_succeeded: int = 0
-    total_failed: int = 0
-    trace_file: str = ""
-    trace_dir: str = ""
-    replay_command: str = ""
-    eval_note: str = ""
-
-    def to_dict(self) -> dict:
-        return asdict(self)
-
-
-class BannerlordTraceLogger:
-    """
-    Captures a single Bannerlord session as a replayable trace.
-
-    Usage:
-        logger = BannerlordTraceLogger(hermes_session_id="abc123")
-        logger.start_session()
-        cycle = logger.begin_cycle(0)
-        # ... populate cycle fields ...
-        logger.finish_cycle(cycle)
-        manifest = logger.finish_session()
-    """
-
-    def __init__(
-        self,
-        trace_dir: Optional[Path] = None,
-        harness_session_id: str = "",
-        hermes_session_id: str = "",
-        hermes_log_id: str = "",
-    ):
-        self.trace_dir = trace_dir or DEFAULT_TRACE_DIR
-        self.trace_dir.mkdir(parents=True, exist_ok=True)
-
-        self.trace_id = f"bl_{datetime.now(timezone.utc).strftime('%Y%m%d_%H%M%S')}_{uuid.uuid4().hex[:6]}"
-        self.harness_session_id = harness_session_id or str(uuid.uuid4())[:8]
-        self.hermes_session_id = hermes_session_id
-        self.hermes_log_id = hermes_log_id
-
-        self.trace_file = self.trace_dir / f"trace_{self.trace_id}.jsonl"
-        self.manifest_file = self.trace_dir / f"manifest_{self.trace_id}.json"
-
-        self.cycles: list[CycleTrace] = []
-        self.started_at: str = ""
-        self.finished_at: str = ""
-
-    def start_session(self) -> str:
-        """Begin a trace session. Returns trace_id."""
-        self.started_at = datetime.now(timezone.utc).isoformat()
-        return self.trace_id
-
-    def begin_cycle(self, cycle_index: int) -> CycleTrace:
-        """Start recording one ODA cycle."""
-        cycle = CycleTrace(
-            cycle_index=cycle_index,
-            timestamp_start=datetime.now(timezone.utc).isoformat(),
-            harness_session_id=self.harness_session_id,
-            hermes_session_id=self.hermes_session_id,
-            hermes_log_id=self.hermes_log_id,
-        )
-        return cycle
-
-    def finish_cycle(self, cycle: CycleTrace) -> None:
-        """Finalize and persist one cycle to the trace file."""
-        cycle.timestamp_end = datetime.now(timezone.utc).isoformat()
-        # Compute duration
-        try:
-            t0 = datetime.fromisoformat(cycle.timestamp_start)
-            t1 = datetime.fromisoformat(cycle.timestamp_end)
-            cycle.duration_ms = int((t1 - t0).total_seconds() * 1000)
-        except (ValueError, TypeError):
-            cycle.duration_ms = 0
-
-        # Count successes/failures
-        cycle.actions_succeeded = sum(
-            1 for a in cycle.actions_executed if a.get("success", False)
-        )
-        cycle.actions_failed = sum(
-            1 for a in cycle.actions_executed if not a.get("success", True)
-        )
-
-        self.cycles.append(cycle)
-
-        # Append to JSONL
-        with open(self.trace_file, "a") as f:
-            f.write(json.dumps(cycle.to_dict()) + "\n")
-
-    def finish_session(self) -> SessionManifest:
-        """Finalize the session and write the manifest."""
-        self.finished_at = datetime.now(timezone.utc).isoformat()
-
-        total_actions = sum(len(c.actions_executed) for c in self.cycles)
-        total_succeeded = sum(c.actions_succeeded for c in self.cycles)
-        total_failed = sum(c.actions_failed for c in self.cycles)
-
-        manifest = SessionManifest(
-            trace_id=self.trace_id,
-            harness_session_id=self.harness_session_id,
-            hermes_session_id=self.hermes_session_id,
-            hermes_log_id=self.hermes_log_id,
-            started_at=self.started_at,
-            finished_at=self.finished_at,
-            total_cycles=len(self.cycles),
-            total_actions=total_actions,
-            total_succeeded=total_succeeded,
-            total_failed=total_failed,
-            trace_file=str(self.trace_file),
-            trace_dir=str(self.trace_dir),
-            replay_command=(
-                f"python -m nexus.bannerlord_harness --mock --replay {self.trace_file}"
-            ),
-            eval_note=(
-                "To replay: load this trace, re-execute each cycle's actions_planned "
-                "against a fresh harness in mock mode, compare actions_executed outcomes. "
-                "Success metric: >=90% action parity between original and replay runs."
-            ),
-        )
-
-        with open(self.manifest_file, "w") as f:
-            json.dump(manifest.to_dict(), f, indent=2)
-
-        return manifest
-
-    @classmethod
-    def load_trace(cls, trace_file: Path) -> list[dict]:
-        """Load a trace JSONL file for replay or analysis."""
-        cycles = []
-        with open(trace_file) as f:
-            for line in f:
-                line = line.strip()
-                if line:
-                    cycles.append(json.loads(line))
-        return cycles
-
-    @classmethod
-    def load_manifest(cls, manifest_file: Path) -> dict:
-        """Load a session manifest."""
-        with open(manifest_file) as f:
-            return json.load(f)
-
-    @classmethod
-    def list_traces(cls, trace_dir: Optional[Path] = None) -> list[dict]:
-        """List all available trace sessions."""
-        d = trace_dir or DEFAULT_TRACE_DIR
-        if not d.exists():
-            return []
-
-        traces = []
-        for mf in sorted(d.glob("manifest_*.json")):
-            try:
-                manifest = cls.load_manifest(mf)
-                traces.append(manifest)
-            except (json.JSONDecodeError, IOError):
-                continue
-        return traces

nexus/traces/bannerlord/REPLAY.md

@@ -1,97 +0,0 @@
-# Bannerlord Session Trace — Replay & Eval Guide
-
-## Storage Layout
-
-All traces live under `~/.timmy/traces/bannerlord/`:
-
-```
-~/.timmy/traces/bannerlord/
-  trace_<trace_id>.jsonl    # One line per ODA cycle (full state + actions)
-  manifest_<trace_id>.json  # Session metadata, counts, replay command
-```
-
-## Trace Format (JSONL)
-
-Each line is one ODA cycle:
-
-```json
-{
-  "cycle_index": 0,
-  "timestamp_start": "2026-04-10T20:15:00+00:00",
-  "timestamp_end": "2026-04-10T20:15:45+00:00",
-  "duration_ms": 45000,
-
-  "screenshot_path": "/tmp/bannerlord_capture_1744320900.png",
-  "window_found": true,
-  "screen_size": [1920, 1080],
-  "mouse_position": [960, 540],
-  "playtime_hours": 142.5,
-  "players_online": 8421,
-  "is_running": true,
-
-  "actions_planned": [{"type": "move_to", "x": 960, "y": 540}],
-  "actions_executed": [{"success": true, "action": "move_to", ...}],
-  "actions_succeeded": 1,
-  "actions_failed": 0,
-
-  "hermes_session_id": "f47ac10b",
-  "hermes_log_id": "",
-  "harness_session_id": "f47ac10b"
-}
-```
-
-## Capturing a Trace
-
-```bash
-# Run harness with trace logging enabled
-cd /path/to/the-nexus
-python -m nexus.bannerlord_harness --mock --trace --iterations 3
-```
-
-The trace and manifest are written to `~/.timmy/traces/bannerlord/` on harness shutdown.
-
-## Replay Protocol
-
-1. Load a trace: `BannerlordTraceLogger.load_trace(trace_file)`
-2. Create a fresh harness in mock mode
-3. For each cycle in the trace:
-   - Re-execute the `actions_planned` list
-   - Compare actual `actions_executed` outcomes against the recorded ones
-4. Score: `(matching_actions / total_actions) * 100`
-
-### Eval Criteria
-
-| Score   | Grade    | Meaning                                    |
-|---------|----------|--------------------------------------------|
-| >= 90%  | PASS     | Replay matches original closely            |
-| 70-89%  | PARTIAL  | Some divergence, investigate differences   |
-| < 70%   | FAIL     | Significant drift, review action semantics |
-
-## Replay Script (sketch)
-
-```python
-from nexus.bannerlord_trace import BannerlordTraceLogger
-from nexus.bannerlord_harness import BannerlordHarness
-
-# Load trace
-cycles = BannerlordTraceLogger.load_trace(
-    Path.home() / ".timmy" / "traces" / "bannerlord" / "trace_bl_xxx.jsonl"
-)
-
-# Replay
-harness = BannerlordHarness(enable_mock=True, enable_trace=False)
-await harness.start()
-
-for cycle in cycles:
-    for action in cycle["actions_planned"]:
-        result = await harness.execute_action(action)
-        # Compare result against cycle["actions_executed"]
-
-await harness.stop()
-```
-
-## Hermes Session Mapping
-
-The `hermes_session_id` and `hermes_log_id` fields link traces to Hermes session logs.
-When a trace is captured during a live Hermes session, populate these fields so
-the trace can be correlated with the broader agent conversation context.

nexus/traces/bannerlord/sample_manifest.json

@@ -1,18 +0,0 @@
-{
-  "trace_id": "bl_20260410_201500_a1b2c3",
-  "harness_session_id": "f47ac10b",
-  "hermes_session_id": "f47ac10b",
-  "hermes_log_id": "",
-  "game": "Mount & Blade II: Bannerlord",
-  "app_id": 261550,
-  "started_at": "2026-04-10T20:15:00+00:00",
-  "finished_at": "2026-04-10T20:17:30+00:00",
-  "total_cycles": 3,
-  "total_actions": 6,
-  "total_succeeded": 6,
-  "total_failed": 0,
-  "trace_file": "~/.timmy/traces/bannerlord/trace_bl_20260410_201500_a1b2c3.jsonl",
-  "trace_dir": "~/.timmy/traces/bannerlord",
-  "replay_command": "python -m nexus.bannerlord_harness --mock --replay ~/.timmy/traces/bannerlord/trace_bl_20260410_201500_a1b2c3.jsonl",
-  "eval_note": "To replay: load trace, re-execute each cycle's actions_planned against a fresh harness in mock mode, compare actions_executed outcomes. Success metric: >=90% action parity between original and replay runs."
-}

nexus/traces/bannerlord/sample_trace.jsonl

@@ -1,3 +0,0 @@
-{"cycle_index": 0, "timestamp_start": "2026-04-10T20:15:00+00:00", "timestamp_end": "2026-04-10T20:15:45+00:00", "duration_ms": 45000, "screenshot_path": "/tmp/bannerlord_capture_1744320900.png", "window_found": true, "screen_size": [1920, 1080], "mouse_position": [960, 540], "playtime_hours": 142.5, "players_online": 8421, "is_running": true, "actions_planned": [{"type": "move_to", "x": 960, "y": 540}, {"type": "press_key", "key": "space"}], "decision_note": "Initial state capture. Move to screen center and press space to advance.", "actions_executed": [{"success": true, "action": "move_to", "params": {"type": "move_to", "x": 960, "y": 540}, "timestamp": "2026-04-10T20:15:30+00:00", "error": null}, {"success": true, "action": "press_key", "params": {"type": "press_key", "key": "space"}, "timestamp": "2026-04-10T20:15:45+00:00", "error": null}], "actions_succeeded": 2, "actions_failed": 0, "hermes_session_id": "f47ac10b", "hermes_log_id": "", "harness_session_id": "f47ac10b"}
-{"cycle_index": 1, "timestamp_start": "2026-04-10T20:15:45+00:00", "timestamp_end": "2026-04-10T20:16:30+00:00", "duration_ms": 45000, "screenshot_path": "/tmp/bannerlord_capture_1744320945.png", "window_found": true, "screen_size": [1920, 1080], "mouse_position": [960, 540], "playtime_hours": 142.5, "players_online": 8421, "is_running": true, "actions_planned": [{"type": "press_key", "key": "p"}], "decision_note": "Open party screen to inspect troops.", "actions_executed": [{"success": true, "action": "press_key", "params": {"type": "press_key", "key": "p"}, "timestamp": "2026-04-10T20:16:00+00:00", "error": null}], "actions_succeeded": 1, "actions_failed": 0, "hermes_session_id": "f47ac10b", "hermes_log_id": "", "harness_session_id": "f47ac10b"}
-{"cycle_index": 2, "timestamp_start": "2026-04-10T20:16:30+00:00", "timestamp_end": "2026-04-10T20:17:30+00:00", "duration_ms": 60000, "screenshot_path": "/tmp/bannerlord_capture_1744321020.png", "window_found": true, "screen_size": [1920, 1080], "mouse_position": [960, 540], "playtime_hours": 142.5, "players_online": 8421, "is_running": true, "actions_planned": [{"type": "press_key", "key": "escape"}, {"type": "move_to", "x": 500, "y": 300}, {"type": "click", "x": 500, "y": 300}], "decision_note": "Close party screen, click on campaign map settlement.", "actions_executed": [{"success": true, "action": "press_key", "params": {"type": "press_key", "key": "escape"}, "timestamp": "2026-04-10T20:16:45+00:00", "error": null}, {"success": true, "action": "move_to", "params": {"type": "move_to", "x": 500, "y": 300}, "timestamp": "2026-04-10T20:17:00+00:00", "error": null}, {"success": true, "action": "click", "params": {"type": "click", "x": 500, "y": 300}, "timestamp": "2026-04-10T20:17:30+00:00", "error": null}], "actions_succeeded": 3, "actions_failed": 0, "hermes_session_id": "f47ac10b", "hermes_log_id": "", "harness_session_id": "f47ac10b"}

server.py

@@ -3,17 +3,156 @@
 The Nexus WebSocket Gateway — Robust broadcast bridge for Timmy's consciousness.
 This server acts as the central hub for the-nexus, connecting the mind (nexus_think.py),
 the body (Evennia/Morrowind), and the visualization surface.
+
+Serves HTTP alongside WebSocket:
+  GET /api/briefing  — heartbeat + morning report data for the HUD briefing panel
 """
 import asyncio
 import json
 import logging
+import os
 import signal
 import sys
-from typing import Set
+from datetime import datetime, timezone
+from http.server import HTTPServer, SimpleHTTPRequestHandler
+from pathlib import Path
+from threading import Thread
+from typing import Any, Dict, Set
 
 # Branch protected file - see POLICY.md
 import websockets
 
+
+# ── HTTP Briefing Endpoint ─────────────────────────────────────────────
+
+HEARTBEAT_PATH = Path.home() / ".nexus" / "heartbeat.json"
+REPORTS_DIR = Path.home() / ".local" / "timmy" / "reports"
+CRON_HEARTBEAT_DIR_PRIMARY = Path("/var/run/bezalel/heartbeats")
+CRON_HEARTBEAT_DIR_FALLBACK = Path.home() / ".bezalel" / "heartbeats"
+
+
+def _read_json_file(path: Path) -> Any:
+    """Read and parse a JSON file. Returns None on failure."""
+    try:
+        return json.loads(path.read_text(encoding="utf-8"))
+    except Exception:
+        return None
+
+
+def _resolve_cron_dir() -> Path:
+    """Return the first writable cron heartbeat directory."""
+    for d in [CRON_HEARTBEAT_DIR_PRIMARY, CRON_HEARTBEAT_DIR_FALLBACK]:
+        if d.exists() and os.access(str(d), os.R_OK):
+            return d
+    return CRON_HEARTBEAT_DIR_FALLBACK
+
+
+def _read_cron_heartbeats() -> list:
+    """Read all .last files from the cron heartbeat directory."""
+    hb_dir = _resolve_cron_dir()
+    if not hb_dir.exists():
+        return []
+    now = datetime.now(timezone.utc).timestamp()
+    jobs = []
+    for f in sorted(hb_dir.glob("*.last")):
+        data = _read_json_file(f)
+        if data is None:
+            jobs.append({"job": f.stem, "healthy": False, "message": "corrupt"})
+            continue
+        ts = float(data.get("timestamp", 0))
+        interval = int(data.get("interval", 3600))
+        age = now - ts
+        is_stale = age > (2 * interval)
+        jobs.append({
+            "job": f.stem,
+            "healthy": not is_stale,
+            "age_secs": round(age, 1),
+            "interval": interval,
+            "last_seen": datetime.fromtimestamp(ts, tz=timezone.utc).isoformat() if ts else None,
+            "message": f"{'STALE' if is_stale else 'OK'} ({age:.0f}s / {interval}s)" if ts else "no timestamp",
+        })
+    return jobs
+
+
+def _latest_morning_report() -> Dict[str, Any] | None:
+    """Find the most recent morning report file."""
+    if not REPORTS_DIR.exists():
+        return None
+    reports = sorted(REPORTS_DIR.glob("morning-*.json"), reverse=True)
+    if not reports:
+        return None
+    return _read_json_file(reports[0])
+
+
+def _build_briefing() -> Dict[str, Any]:
+    """Assemble the full briefing payload from real files."""
+    now = datetime.now(timezone.utc)
+
+    # Core heartbeat
+    core_hb = _read_json_file(HEARTBEAT_PATH)
+    if core_hb:
+        beat_ts = float(core_hb.get("timestamp", 0))
+        core_hb["age_secs"] = round(now.timestamp() - beat_ts, 1) if beat_ts else None
+
+    # Cron heartbeats
+    cron_jobs = _read_cron_heartbeats()
+    healthy_count = sum(1 for j in cron_jobs if j.get("healthy"))
+    stale_count = sum(1 for j in cron_jobs if not j.get("healthy"))
+
+    # Morning report
+    report = _latest_morning_report()
+
+    return {
+        "generated_at": now.isoformat(),
+        "core_heartbeat": core_hb,
+        "cron_heartbeat": {
+            "jobs": cron_jobs,
+            "healthy_count": healthy_count,
+            "stale_count": stale_count,
+        },
+        "morning_report": report,
+    }
+
+
+class BriefingHandler(SimpleHTTPRequestHandler):
+    """Minimal HTTP handler that only serves /api/briefing."""
+
+    def do_GET(self):
+        if self.path == "/api/briefing":
+            try:
+                data = _build_briefing()
+                body = json.dumps(data).encode("utf-8")
+                self.send_response(200)
+                self.send_header("Content-Type", "application/json")
+                self.send_header("Content-Length", str(len(body)))
+                self.send_header("Access-Control-Allow-Origin", "*")
+                self.end_headers()
+                self.wfile.write(body)
+            except Exception as e:
+                self.send_error(500, str(e))
+        elif self.path == "/api/health":
+            body = json.dumps({"status": "ok"}).encode("utf-8")
+            self.send_response(200)
+            self.send_header("Content-Type", "application/json")
+            self.send_header("Access-Control-Allow-Origin", "*")
+            self.end_headers()
+            self.wfile.write(body)
+        else:
+            self.send_error(404)
+
+    def log_message(self, fmt, *args):
+        pass  # Suppress HTTP access logs — WS gateway logs are enough
+
+
+def start_http_server(port: int = 8766):
+    """Run the HTTP server in a daemon thread."""
+    server = HTTPServer(("0.0.0.0", port), BriefingHandler)
+    thread = Thread(target=server.serve_forever, daemon=True)
+    thread.start()
+    logger = logging.getLogger("nexus-gateway")
+    logger.info(f"Briefing HTTP server started on http://0.0.0.0:{port}")
+    return server
+
 # Configuration
 PORT = 8765
 HOST = "0.0.0.0"  # Allow external connections if needed
@@ -80,6 +219,9 @@ async def broadcast_handler(websocket: websockets.WebSocketServerProtocol):
 
 async def main():
     """Main server loop with graceful shutdown."""
+    # Start HTTP briefing endpoint alongside WS
+    http_server = start_http_server(port=8766)
+
     logger.info(f"Starting Nexus WS gateway on ws://{HOST}:{PORT}")
     
     # Set up signal handlers for graceful shutdown

style.css

@@ -1224,6 +1224,138 @@ canvas#nexus-canvas {
 
 .pse-status { color: #4af0c0; font-weight: 600; }
 
+/* ═══ HEARTBEAT BRIEFING PANEL ═════════════════════════════════════ */
+.hud-panel-briefing {
+  width: 320px;
+  max-height: 420px;
+  border-left-color: #7b5cff;
+}
+.hud-panel-briefing .panel-header {
+  display: flex;
+  align-items: center;
+  gap: 6px;
+  color: #7b5cff;
+}
+.hud-panel-briefing .panel-content {
+  max-height: 360px;
+  overflow-y: auto;
+}
+/* Pulse dot */
+.hb-pulse-dot {
+  width: 6px;
+  height: 6px;
+  border-radius: 50%;
+  background: #4af0c0;
+  box-shadow: 0 0 6px #4af0c0;
+  animation: hb-dot-pulse 2s ease-in-out infinite;
+  flex-shrink: 0;
+}
+.hb-pulse-dot.offline {
+  background: #ff4466;
+  box-shadow: 0 0 6px #ff4466;
+  animation: none;
+}
+@keyframes hb-dot-pulse {
+  0%, 100% { opacity: 0.4; }
+  50%       { opacity: 1; }
+}
+/* Briefing sections */
+.briefing-section {
+  margin-bottom: 8px;
+  padding-bottom: 6px;
+  border-bottom: 1px solid rgba(123, 92, 255, 0.12);
+}
+.briefing-section:last-child { border-bottom: none; margin-bottom: 0; }
+.briefing-section-label {
+  font-size: 9px;
+  letter-spacing: 0.12em;
+  text-transform: uppercase;
+  color: #8a9ab8;
+  margin-bottom: 4px;
+}
+/* Core heartbeat row */
+.hb-core-row {
+  display: flex;
+  gap: 10px;
+  align-items: center;
+  margin-bottom: 4px;
+}
+.hb-core-status {
+  font-weight: 700;
+  font-size: 11px;
+}
+.hb-core-status.alive { color: #4af0c0; }
+.hb-core-status.dead  { color: #ff4466; }
+.hb-core-meta {
+  font-size: 10px;
+  color: #8a9ab8;
+}
+/* Cron jobs */
+.hb-cron-row {
+  display: flex;
+  gap: 8px;
+  font-size: 10px;
+  margin-bottom: 2px;
+}
+.hb-cron-healthy { color: #4af0c0; }
+.hb-cron-stale   { color: #ff4466; font-weight: 700; }
+.hb-cron-job {
+  display: flex;
+  justify-content: space-between;
+  font-size: 10px;
+  padding: 1px 0;
+}
+.hb-cron-job-name { color: #e0f0ff; }
+.hb-cron-job-status.healthy { color: #4af0c0; }
+.hb-cron-job-status.stale   { color: #ff4466; font-weight: 700; }
+/* Morning report stats */
+.hb-stats-row {
+  display: flex;
+  gap: 12px;
+  font-size: 10px;
+}
+.hb-stat {
+  display: flex;
+  flex-direction: column;
+  gap: 1px;
+}
+.hb-stat-value {
+  font-family: 'Orbitron', sans-serif;
+  font-weight: 700;
+  font-size: 14px;
+}
+.hb-stat-label {
+  font-size: 9px;
+  color: #8a9ab8;
+  letter-spacing: 0.08em;
+  text-transform: uppercase;
+}
+/* Blockers */
+.hb-blocker {
+  font-size: 10px;
+  color: #ff4466;
+  padding: 1px 0;
+}
+/* Narrative */
+.hb-narrative {
+  font-size: 10px;
+  color: #8a9ab8;
+  line-height: 1.5;
+  font-style: italic;
+}
+/* Empty / offline state */
+.hb-empty {
+  font-size: 10px;
+  color: #8a9ab8;
+  text-align: center;
+  padding: 12px 0;
+}
+/* Timestamp */
+.hb-timestamp {
+  font-size: 9px;
+  color: rgba(138, 154, 184, 0.6);
+  margin-top: 4px;
+}
 
 /* ═══════════════════════════════════════════
    MNEMOSYNE — MEMORY CRYSTAL INSPECTION PANEL