Wire heartbeat into NexusMind consciousness loop

The heartbeat module existed but was never called. Now write_heartbeat fires:
- On startup (cycle 0, status thinking)
- After every successful think cycle
- On graceful shutdown (status idle)

This gives the watchdog a signal that the mind is alive, not just running.

app.js

@@ -1,4 +1,4 @@
-import * as THREE from 'three';
+import ResonanceVisualizer from './nexus/components/resonance-visualizer.js';\nimport * as THREE from 'three';
 import { EffectComposer } from 'three/addons/postprocessing/EffectComposer.js';
 import { RenderPass } from 'three/addons/postprocessing/RenderPass.js';
 import { UnrealBloomPass } from 'three/addons/postprocessing/UnrealBloomPass.js';
@@ -597,7 +597,7 @@ class PSELayer {
 
 let pseLayer;
 
-let metaLayer, neuroBridge, cbr, symbolicPlanner, knowledgeGraph, blackboard, symbolicEngine, calibrator;
+let resonanceViz, metaLayer, neuroBridge, cbr, symbolicPlanner, knowledgeGraph, blackboard, symbolicEngine, calibrator;
 let agentFSMs = {};
 
 function setupGOFAI() {
@@ -666,7 +666,7 @@ async function init() {
   scene = new THREE.Scene();
   scene.fog = new THREE.FogExp2(0x050510, 0.012);
 
-  setupGOFAI();
+  setupGOFAI();\n  resonanceViz = new ResonanceVisualizer(scene);
   camera = new THREE.PerspectiveCamera(65, window.innerWidth / window.innerHeight, 0.1, 1000);
   camera.position.copy(playerPos);
 

bin/nexus_watchdog.py

@@ -586,8 +586,8 @@ def alert_on_failure(report: HealthReport, dry_run: bool = False) -> None:
                 logger.info("Created alert issue #%d", result["number"])
 
 
-def run_once(args: argparse.Namespace) -> tuple[bool, HealthReport]:
-    """Run one health check cycle. Returns (healthy, report)."""
+def run_once(args: argparse.Namespace) -> bool:
+    """Run one health check cycle. Returns True if healthy."""
     report = run_health_checks(
         ws_host=args.ws_host,
         ws_port=args.ws_port,
@@ -615,20 +615,7 @@ def run_once(args: argparse.Namespace) -> tuple[bool, HealthReport]:
         except Exception:
             pass  # never crash the watchdog over its own heartbeat
 
-    return report.overall_healthy, report
-
-
-def _emit_json(report: HealthReport) -> None:
-    """Print a HealthReport as JSON to stdout."""
-    print(json.dumps({
-        "healthy": report.overall_healthy,
-        "timestamp": report.timestamp,
-        "checks": [
-            {"name": c.name, "healthy": c.healthy,
-             "message": c.message, "details": c.details}
-            for c in report.checks
-        ],
-    }, indent=2))
+    return report.overall_healthy
 
 
 def main():
@@ -691,18 +678,30 @@ def main():
         signal.signal(signal.SIGINT, _handle_sigterm)
 
         while _running:
-            _healthy, report = run_once(args)
-            if args.output_json:
-                _emit_json(report)
+            run_once(args)
             for _ in range(args.interval):
                 if not _running:
                     break
                 time.sleep(1)
     else:
-        healthy, report = run_once(args)
+        healthy = run_once(args)
 
         if args.output_json:
-            _emit_json(report)
+            report = run_health_checks(
+                ws_host=args.ws_host,
+                ws_port=args.ws_port,
+                heartbeat_path=Path(args.heartbeat_path),
+                stale_threshold=args.stale_threshold,
+            )
+            print(json.dumps({
+                "healthy": report.overall_healthy,
+                "timestamp": report.timestamp,
+                "checks": [
+                    {"name": c.name, "healthy": c.healthy,
+                     "message": c.message, "details": c.details}
+                    for c in report.checks
+                ],
+            }, indent=2))
 
         sys.exit(0 if healthy else 1)
 

nexus/components/memory-optimizer.js

@@ -1,13 +1,18 @@
 
 class MemoryOptimizer {
     constructor(options = {}) {
-        this.threshold = options.threshold || 0.8;
-        this.decayRate = options.decayRate || 0.05;
+        this.threshold = options.threshold || 0.3;
+        this.decayRate = options.decayRate || 0.01;
+        this.lastRun = Date.now();
     }
-    optimize(memory) {
-        console.log('Optimizing memory...');
-        // Heuristic-based pruning
-        return memory.filter(m => m.strength > this.threshold);
+    optimize(memories) {
+        const now = Date.now();
+        const elapsed = (now - this.lastRun) / 1000;
+        this.lastRun = now;
+        return memories.map(m => {
+            const decay = (m.importance || 1) * this.decayRate * elapsed;
+            return { ...m, strength: Math.max(0, (m.strength || 1) - decay) };
+        }).filter(m => m.strength > this.threshold || m.locked);
     }
 }
 export default MemoryOptimizer;

nexus/mnemosyne/reasoner.py

@@ -0,0 +1,14 @@
+
+class Reasoner:
+    def __init__(self, rules):
+        self.rules = rules
+    def evaluate(self, entries):
+        return [r['action'] for r in self.rules if self._check(r['condition'], entries)]
+    def _check(self, cond, entries):
+        if cond.startswith('count'):
+            # e.g. count(type=anomaly)>3
+            p = cond.replace('count(', '').split(')')
+            key, val = p[0].split('=')
+            count = sum(1 for e in entries if e.get(key) == val)
+            return eval(f"{count}{p[1]}")
+        return False

nexus/mnemosyne/resonance_linker.py

@@ -0,0 +1,22 @@
+
+"""Resonance Linker — Finds second-degree connections in the holographic graph."""
+
+class ResonanceLinker:
+    def __init__(self, archive):
+        self.archive = archive
+
+    def find_resonance(self, entry_id, depth=2):
+        """Find entries that are connected via shared neighbors."""
+        if entry_id not in self.archive._entries: return []
+        
+        entry = self.archive._entries[entry_id]
+        neighbors = set(entry.links)
+        resonance = {}
+
+        for neighbor_id in neighbors:
+            if neighbor_id in self.archive._entries:
+                for second_neighbor in self.archive._entries[neighbor_id].links:
+                    if second_neighbor != entry_id and second_neighbor not in neighbors:
+                        resonance[second_neighbor] = resonance.get(second_neighbor, 0) + 1
+        
+        return sorted(resonance.items(), key=lambda x: x[1], reverse=True)

nexus/mnemosyne/rules.json

@@ -0,0 +1,6 @@
+[
+  {
+    "condition": "count(type=anomaly)>3",
+    "action": "alert"
+  }
+]

nexus/nexus_think.py

@@ -45,6 +45,7 @@ from nexus.perception_adapter import (
 )
 from nexus.experience_store import ExperienceStore
 from nexus.groq_worker import GroqWorker
+from nexus.heartbeat import write_heartbeat
 from nexus.trajectory_logger import TrajectoryLogger
 
 logging.basicConfig(
@@ -286,6 +287,13 @@ class NexusMind:
 
         self.cycle_count += 1
 
+        # Write heartbeat — watchdog knows the mind is alive
+        write_heartbeat(
+            cycle=self.cycle_count,
+            model=self.model,
+            status="thinking",
+        )
+
         # Periodically distill old memories
         if self.cycle_count % 50 == 0 and self.cycle_count > 0:
             await self._distill_memories()
@@ -383,6 +391,13 @@ class NexusMind:
             salience=1.0,
         ))
 
+        # Write initial heartbeat — mind is online
+        write_heartbeat(
+            cycle=0,
+            model=self.model,
+            status="thinking",
+        )
+
         while self.running:
             try:
                 await self.think_once()
@@ -423,6 +438,13 @@ class NexusMind:
         log.info("Nexus Mind shutting down...")
         self.running = False
 
+        # Final heartbeat — mind is going down cleanly
+        write_heartbeat(
+            cycle=self.cycle_count,
+            model=self.model,
+            status="idle",
+        )
+
         # Final stats
         stats = self.trajectory_logger.get_session_stats()
         log.info(f"Session stats: {json.dumps(stats, indent=2)}")