fix: [MONITORING] Integrate Kimi Heartbeat status into Nexus Watchdog (closes #800)

app.js

@@ -3355,11 +3355,20 @@ init().then(() => {
 
   // Project Mnemosyne — seed demo spatial memories
   const demoMemories = [
-    { id: 'mem_nexus_birth',     content: 'The Nexus came online — first render of the 3D world',         category: 'knowledge',   strength: 0.95, connections: ['mem_mnemosyne_start'] },
-    { id: 'mem_first_portal',    content: 'First portal deployed — connection to external service',        category: 'engineering', strength: 0.85, connections: ['mem_nexus_birth'] },
-    { id: 'mem_hermes_chat',     content: 'First conversation through the Hermes gateway',                 category: 'social',      strength: 0.70, connections: [] },
-    { id: 'mem_mnemosyne_start', content: 'Project Mnemosyne began — the living archive awakens',          category: 'projects',    strength: 0.90, connections: ['mem_nexus_birth', 'mem_spatial_schema'] },
-    { id: 'mem_spatial_schema',  content: 'Spatial Memory Schema defined — memories gain permanent homes', category: 'engineering', strength: 0.80, connections: ['mem_mnemosyne_start'] },
+    { id: 'mem_nexus_birth', content: 'The Nexus came online — first render of the 3D world', category: 'knowledge', strength: 0.95, connections: ['mem_mnemosyne_start'] },
+    { id: 'mem_first_portal', content: 'First portal deployed — connection to external service', category: 'engineering', strength: 0.85, connections: ['mem_nexus_birth'] },
+    { id: 'mem_hermes_chat', content: 'First conversation through the Hermes gateway', category: 'social', strength: 0.7, connections: [] },
+    { id: 'mem_mnemosyne_start', content: 'Project Mnemosyne began — the living archive awakens', category: 'projects', strength: 0.9, connections: ['mem_nexus_birth', 'mem_spatial_schema'] },
+    { id: 'mem_spatial_schema', content: 'Spatial Memory Schema defined — memories gain permanent homes', category: 'engineering', strength: 0.8, connections: ['mem_mnemosyne_start'] },
+    // MemPalace category zone demos — issue #1168
+    { id: 'mem_pref_dark_mode', content: 'User prefers dark mode and monospace fonts', category: 'user_pref', strength: 0.9, connections: [] },
+    { id: 'mem_pref_verbose_logs', content: 'User prefers verbose logging during debug sessions', category: 'user_pref', strength: 0.7, connections: [] },
+    { id: 'mem_proj_nexus_goal', content: 'The Nexus goal: local-first 3D training ground for Timmy', category: 'project', strength: 0.95, connections: ['mem_proj_mnemosyne'] },
+    { id: 'mem_proj_mnemosyne', content: 'Project Mnemosyne: holographic living archive of facts', category: 'project', strength: 0.85, connections: ['mem_proj_nexus_goal'] },
+    { id: 'mem_tool_three_js', content: 'Three.js — 3D rendering library used for the Nexus world', category: 'tool', strength: 0.8, connections: [] },
+    { id: 'mem_tool_gitea', content: 'Gitea API at forge.alexanderwhitestone.com for issue tracking', category: 'tool', strength: 0.75, connections: [] },
+    { id: 'mem_gen_websocket', content: 'WebSocket bridge (server.py) connects Timmy cognition to the browser', category: 'general', strength: 0.7, connections: [] },
+    { id: 'mem_gen_hermes', content: 'Hermes harness: telemetry and durable truth pipeline', category: 'general', strength: 0.65, connections: [] },
   ];
   demoMemories.forEach(m => SpatialMemory.placeMemory(m));
 

bin/nexus_watchdog.py

@@ -60,6 +60,23 @@ If the heartbeat is older than --stale-threshold seconds, the
 mind is considered dead even if the process is still running
 (e.g., hung on a blocking call).
 
+KIMI HEARTBEAT
+==============
+The Kimi triage pipeline writes a cron heartbeat file after each run:
+
+  /var/run/bezalel/heartbeats/kimi-heartbeat.last
+  (fallback: ~/.bezalel/heartbeats/kimi-heartbeat.last)
+  {
+    "job": "kimi-heartbeat",
+    "timestamp": 1711843200.0,
+    "interval_seconds": 900,
+    "pid": 12345,
+    "status": "ok"
+  }
+
+If the heartbeat is stale (>2x declared interval), the watchdog reports
+a Kimi Heartbeat failure alongside the other checks.
+
 ZERO DEPENDENCIES
 =================
 Pure stdlib. No pip installs. Same machine as the nexus.
@@ -104,6 +121,10 @@ DEFAULT_HEARTBEAT_PATH = Path.home() / ".nexus" / "heartbeat.json"
 DEFAULT_STALE_THRESHOLD = 300  # 5 minutes without a heartbeat = dead
 DEFAULT_INTERVAL = 60  # seconds between checks in watch mode
 
+# Kimi Heartbeat — cron job heartbeat file written by the triage pipeline
+KIMI_HEARTBEAT_JOB = "kimi-heartbeat"
+KIMI_HEARTBEAT_STALE_MULTIPLIER = 2.0  # stale at 2x declared interval
+
 GITEA_URL = os.environ.get("GITEA_URL", "https://forge.alexanderwhitestone.com")
 GITEA_TOKEN = os.environ.get("GITEA_TOKEN", "")
 GITEA_REPO = os.environ.get("NEXUS_REPO", "Timmy_Foundation/the-nexus")
@@ -345,6 +366,93 @@ def check_syntax_health() -> CheckResult:
         )
 
 
+def check_kimi_heartbeat(
+    job: str = KIMI_HEARTBEAT_JOB,
+    stale_multiplier: float = KIMI_HEARTBEAT_STALE_MULTIPLIER,
+) -> CheckResult:
+    """Check if the Kimi Heartbeat cron job is alive.
+
+    Reads the ``<job>.last`` file from the standard Bezalel heartbeat
+    directory (``/var/run/bezalel/heartbeats/`` or fallback
+    ``~/.bezalel/heartbeats/``).  The file is written atomically by the
+    cron_heartbeat module after each successful triage pipeline run.
+
+    A job is stale when:
+      ``time.time() - timestamp > stale_multiplier * interval_seconds``
+    (same rule used by ``check_cron_heartbeats.py``).
+    """
+    # Resolve heartbeat directory — same logic as cron_heartbeat._resolve
+    primary = Path("/var/run/bezalel/heartbeats")
+    fallback = Path.home() / ".bezalel" / "heartbeats"
+    env_dir = os.environ.get("BEZALEL_HEARTBEAT_DIR")
+    if env_dir:
+        hb_dir = Path(env_dir)
+    elif primary.exists():
+        hb_dir = primary
+    elif fallback.exists():
+        hb_dir = fallback
+    else:
+        return CheckResult(
+            name="Kimi Heartbeat",
+            healthy=False,
+            message="Heartbeat directory not found — no triage pipeline deployed yet",
+            details={"searched": [str(primary), str(fallback)]},
+        )
+
+    hb_file = hb_dir / f"{job}.last"
+    if not hb_file.exists():
+        return CheckResult(
+            name="Kimi Heartbeat",
+            healthy=False,
+            message=f"No heartbeat file at {hb_file} — Kimi triage pipeline has never reported",
+            details={"path": str(hb_file)},
+        )
+
+    try:
+        data = json.loads(hb_file.read_text())
+    except (json.JSONDecodeError, OSError) as e:
+        return CheckResult(
+            name="Kimi Heartbeat",
+            healthy=False,
+            message=f"Heartbeat file corrupt: {e}",
+            details={"path": str(hb_file), "error": str(e)},
+        )
+
+    timestamp = float(data.get("timestamp", 0))
+    interval = int(data.get("interval_seconds", 0))
+    raw_status = data.get("status", "unknown")
+    age = time.time() - timestamp
+
+    if interval <= 0:
+        # No declared interval — use raw timestamp age (30 min default)
+        interval = 1800
+
+    threshold = stale_multiplier * interval
+    is_stale = age > threshold
+
+    age_str = f"{int(age)}s" if age < 3600 else f"{int(age // 3600)}h {int((age % 3600) // 60)}m"
+    interval_str = f"{int(interval)}s" if interval < 3600 else f"{int(interval // 3600)}h {int((interval % 3600) // 60)}m"
+
+    if is_stale:
+        return CheckResult(
+            name="Kimi Heartbeat",
+            healthy=False,
+            message=(
+                f"Silent for {age_str} "
+                f"(threshold: {stale_multiplier}x {interval_str} = {int(threshold)}s). "
+                f"Status: {raw_status}"
+            ),
+            details=data,
+        )
+
+    return CheckResult(
+        name="Kimi Heartbeat",
+        healthy=True,
+        message=f"Alive — last beat {age_str} ago (interval {interval_str}, status={raw_status})",
+        details=data,
+    )
+
+
 # ── Gitea alerting ───────────────────────────────────────────────────
 
 def _gitea_request(method: str, path: str, data: Optional[dict] = None) -> Any:
@@ -446,6 +554,7 @@ def run_health_checks(
         check_mind_process(),
         check_heartbeat(heartbeat_path, stale_threshold),
         check_syntax_health(),
+        check_kimi_heartbeat(),
     ]
     return HealthReport(timestamp=time.time(), checks=checks)
 
@@ -545,6 +654,14 @@ def main():
         "--json", action="store_true", dest="output_json",
         help="Output results as JSON (for integration with other tools)",
     )
+    parser.add_argument(
+        "--kimi-job", default=KIMI_HEARTBEAT_JOB,
+        help=f"Kimi heartbeat job name (default: {KIMI_HEARTBEAT_JOB})",
+    )
+    parser.add_argument(
+        "--kimi-stale-multiplier", type=float, default=KIMI_HEARTBEAT_STALE_MULTIPLIER,
+        help=f"Kimi heartbeat staleness multiplier (default: {KIMI_HEARTBEAT_STALE_MULTIPLIER})",
+    )
 
     args = parser.parse_args()
 

nexus/components/spatial-memory.js

@@ -8,12 +8,20 @@
 // holographic archive.
 //
 // World layout (hex cylinder, radius 25):
-//   North (z-)  → Documents & Knowledge
-//   South (z+)  → Projects & Tasks
-//   East  (x+)  → Code & Engineering
-//   West  (x-)  → Conversations & Social
-//   Center      → Active Working Memory
-//   Below (y-)  → Archive (cold storage)
+//
+//   Inner ring — original Mnemosyne taxonomy (radius 15):
+//     North (z-)  → Documents & Knowledge
+//     South (z+)  → Projects & Tasks
+//     East  (x+)  → Code & Engineering
+//     West  (x-)  → Conversations & Social
+//     Center      → Active Working Memory
+//     Below (y-)  → Archive (cold storage)
+//
+//   Outer ring — MemPalace category zones (radius 20, issue #1168):
+//     North (z-)  → User Preferences   [golden]
+//     East  (x+)  → Project facts      [blue]
+//     South (z+)  → Tool knowledge     [green]
+//     West  (x-)  → General facts      [gray]
 //
 // Usage from app.js:
 //   SpatialMemory.init(scene);
@@ -73,6 +81,44 @@ const SpatialMemory = (() => {
       color: 0x334455,
       glyph: '\uD83D\uDDC4',
       description: 'Cold storage — rarely accessed, aged-out memories'
+    },
+
+    // ── MemPalace category zones — outer ring, issue #1168 ────────────
+    user_pref: {
+      label: 'User Preferences',
+      center: [0, 0, -20],
+      radius: 10,
+      color: 0xffd700,
+      glyph: '\u2605',
+      description: 'Personal preferences, habits, user-specific settings',
+      labelY: 5
+    },
+    project: {
+      label: 'Project Facts',
+      center: [20, 0, 0],
+      radius: 10,
+      color: 0x4488ff,
+      glyph: '\uD83D\uDCC1',
+      description: 'Project-specific knowledge, goals, context',
+      labelY: 5
+    },
+    tool: {
+      label: 'Tool Knowledge',
+      center: [0, 0, 20],
+      radius: 10,
+      color: 0x44cc66,
+      glyph: '\uD83D\uDD27',
+      description: 'Tools, commands, APIs, and how to use them',
+      labelY: 5
+    },
+    general: {
+      label: 'General Facts',
+      center: [-20, 0, 0],
+      radius: 10,
+      color: 0x8899aa,
+      glyph: '\uD83D\uDCDD',
+      description: 'Miscellaneous facts not fitting other categories',
+      labelY: 5
     }
   };
 
@@ -99,6 +145,7 @@ const SpatialMemory = (() => {
     const cx = region.center[0];
     const cy = region.center[1] + 0.06;
     const cz = region.center[2];
+    const labelY = region.labelY || 3;
 
     const ringGeo = new THREE.RingGeometry(region.radius - 0.5, region.radius, 6);
     const ringMat = new THREE.MeshBasicMaterial({
@@ -126,6 +173,22 @@ const SpatialMemory = (() => {
     _scene.add(ring);
     _scene.add(disc);
 
+    // Ground glow — brighter disc for MemPalace zones (labelY > 3 signals outer ring)
+    let glowDisc = null;
+    if (labelY > 3) {
+      const glowGeo = new THREE.CircleGeometry(region.radius, 32);
+      const glowMat = new THREE.MeshBasicMaterial({
+        color: region.color,
+        transparent: true,
+        opacity: 0.06,
+        side: THREE.DoubleSide
+      });
+      glowDisc = new THREE.Mesh(glowGeo, glowMat);
+      glowDisc.rotation.x = -Math.PI / 2;
+      glowDisc.position.set(cx, cy - 0.02, cz);
+      _scene.add(glowDisc);
+    }
+
     // Floating label
     const canvas = document.createElement('canvas');
     canvas.width = 256;
@@ -139,11 +202,11 @@ const SpatialMemory = (() => {
     const texture = new THREE.CanvasTexture(canvas);
     const spriteMat = new THREE.SpriteMaterial({ map: texture, transparent: true, opacity: 0.6 });
     const sprite = new THREE.Sprite(spriteMat);
-    sprite.position.set(cx, 3, cz);
+    sprite.position.set(cx, labelY, cz);
     sprite.scale.set(4, 1, 1);
     _scene.add(sprite);
 
-    return { ring, disc, sprite };
+    return { ring, disc, glowDisc, sprite };
   }
 
   // ─── PLACE A MEMORY ──────────────────────────────────
@@ -283,6 +346,9 @@ const SpatialMemory = (() => {
       if (marker.ring && marker.ring.material) {
         marker.ring.material.opacity = 0.1 + Math.sin(now * 0.001) * 0.05;
       }
+      if (marker.glowDisc && marker.glowDisc.material) {
+        marker.glowDisc.material.opacity = 0.04 + Math.sin(now * 0.0008) * 0.02;
+      }
     });
   }