feat(mnemosyne): trust-based crystal rendering (#1166)

Wire crystal visual properties to fact trust scores:
- Trust > 0.8: bright glow, full opacity
- Trust 0.5-0.8: medium glow, 80% opacity
- Trust < 0.5: dim, 40% opacity
- Trust < 0.3: near-invisible, pulsing red

Adds:
- _getTrustVisuals() helper computes material props from trust
- updateMemoryVisual() for runtime trust updates
- trust persisted in exportIndex and localStorage
- Low-trust crystals pulse red in update() loop

Closes #1166

bin/nexus_watchdog.py

@@ -60,23 +60,6 @@ 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.
@@ -121,10 +104,6 @@ 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")
@@ -366,93 +345,6 @@ 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:
@@ -554,7 +446,6 @@ 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)
 
@@ -654,14 +545,6 @@ 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

@@ -140,6 +140,47 @@ const SpatialMemory = (() => {
     return new THREE.OctahedronGeometry(size, 0);
   }
 
+  // ─── TRUST-BASED VISUALS ─────────────────────────────
+  // Wire crystal visual properties to fact trust score (0.0-1.0).
+  // Issue #1166: Trust > 0.8 = bright glow/full opacity,
+  // 0.5-0.8 = medium/80%, < 0.5 = dim/40%, < 0.3 = near-invisible pulsing red.
+  function _getTrustVisuals(trust, regionColor) {
+    const t = Math.max(0, Math.min(1, trust));
+    if (t >= 0.8) {
+      return {
+        opacity: 1.0,
+        emissiveIntensity: 2.0 * t,
+        emissiveColor: regionColor,
+        lightIntensity: 1.2,
+        glowDesc: 'high'
+      };
+    } else if (t >= 0.5) {
+      return {
+        opacity: 0.8,
+        emissiveIntensity: 1.2 * t,
+        emissiveColor: regionColor,
+        lightIntensity: 0.6,
+        glowDesc: 'medium'
+      };
+    } else if (t >= 0.3) {
+      return {
+        opacity: 0.4,
+        emissiveIntensity: 0.5 * t,
+        emissiveColor: regionColor,
+        lightIntensity: 0.2,
+        glowDesc: 'dim'
+      };
+    } else {
+      return {
+        opacity: 0.15,
+        emissiveIntensity: 0.3,
+        emissiveColor: 0xff2200,
+        lightIntensity: 0.1,
+        glowDesc: 'untrusted'
+      };
+    }
+  }
+
   // ─── REGION MARKER ───────────────────────────────────
   function createRegionMarker(regionKey, region) {
     const cx = region.center[0];
@@ -216,17 +257,20 @@ const SpatialMemory = (() => {
     const region = REGIONS[mem.category] || REGIONS.working;
     const pos = mem.position || _assignPosition(mem.category, mem.id);
     const strength = Math.max(0.05, Math.min(1, mem.strength != null ? mem.strength : 0.7));
+    const trust = mem.trust != null ? Math.max(0, Math.min(1, mem.trust)) : 0.7;
     const size = 0.2 + strength * 0.3;
 
+    const tv = _getTrustVisuals(trust, region.color);
+
     const geo = createCrystalGeometry(size);
     const mat = new THREE.MeshStandardMaterial({
       color: region.color,
-      emissive: region.color,
-      emissiveIntensity: 1.5 * strength,
+      emissive: tv.emissiveColor,
+      emissiveIntensity: tv.emissiveIntensity,
       metalness: 0.6,
       roughness: 0.15,
       transparent: true,
-      opacity: 0.5 + strength * 0.4
+      opacity: tv.opacity
     });
 
     const crystal = new THREE.Mesh(geo, mat);
@@ -239,10 +283,12 @@ const SpatialMemory = (() => {
       region: mem.category,
       pulse: Math.random() * Math.PI * 2,
       strength: strength,
+      trust: trust,
+      glowDesc: tv.glowDesc,
       createdAt: mem.timestamp || new Date().toISOString()
     };
 
-    const light = new THREE.PointLight(region.color, 0.8 * strength, 5);
+    const light = new THREE.PointLight(tv.emissiveColor, tv.lightIntensity, 5);
     crystal.add(light);
 
     _scene.add(crystal);
@@ -337,8 +383,16 @@ const SpatialMemory = (() => {
       mesh.scale.setScalar(pulse);
 
       if (mesh.material) {
+        const trust = mesh.userData.trust != null ? mesh.userData.trust : 0.7;
         const base = mesh.userData.strength || 0.7;
-        mesh.material.emissiveIntensity = 1.0 + Math.sin(mesh.userData.pulse * 0.7) * 0.5 * base;
+        if (trust < 0.3) {
+          // Low trust: pulsing red — visible warning
+          const pulseAlpha = 0.15 + Math.sin(mesh.userData.pulse * 2.0) * 0.15;
+          mesh.material.emissiveIntensity = 0.3 + Math.sin(mesh.userData.pulse * 2.0) * 0.3;
+          mesh.material.opacity = pulseAlpha;
+        } else {
+          mesh.material.emissiveIntensity = 1.0 + Math.sin(mesh.userData.pulse * 0.7) * 0.5 * base;
+        }
       }
     });
 
@@ -368,6 +422,42 @@ const SpatialMemory = (() => {
     return REGIONS;
   }
 
+  // ─── UPDATE VISUAL PROPERTIES ────────────────────────
+  // Re-render crystal when trust/strength change (no position move).
+  function updateMemoryVisual(memId, updates) {
+    const obj = _memoryObjects[memId];
+    if (!obj) return false;
+
+    const mesh = obj.mesh;
+    const region = REGIONS[obj.region] || REGIONS.working;
+
+    if (updates.trust != null) {
+      const trust = Math.max(0, Math.min(1, updates.trust));
+      mesh.userData.trust = trust;
+      obj.data.trust = trust;
+      const tv = _getTrustVisuals(trust, region.color);
+      mesh.material.emissive = new THREE.Color(tv.emissiveColor);
+      mesh.material.emissiveIntensity = tv.emissiveIntensity;
+      mesh.material.opacity = tv.opacity;
+      mesh.userData.glowDesc = tv.glowDesc;
+      if (mesh.children.length > 0 && mesh.children[0].isPointLight) {
+        mesh.children[0].intensity = tv.lightIntensity;
+        mesh.children[0].color = new THREE.Color(tv.emissiveColor);
+      }
+    }
+
+    if (updates.strength != null) {
+      const strength = Math.max(0.05, Math.min(1, updates.strength));
+      mesh.userData.strength = strength;
+      obj.data.strength = strength;
+    }
+
+    _dirty = true;
+    saveToStorage();
+    console.info('[Mnemosyne] Visual updated:', memId, 'trust:', mesh.userData.trust, 'glow:', mesh.userData.glowDesc);
+    return true;
+  }
+
   // ─── QUERY ───────────────────────────────────────────
   function getMemoryAtPosition(position, maxDist) {
     maxDist = maxDist || 2;
@@ -507,6 +597,7 @@ const SpatialMemory = (() => {
         source: o.data.source || 'unknown',
         timestamp: o.data.timestamp || o.mesh.userData.createdAt,
         strength: o.mesh.userData.strength || 0.7,
+        trust: o.mesh.userData.trust != null ? o.mesh.userData.trust : 0.7,
         connections: o.data.connections || []
       }))
     };
@@ -653,7 +744,7 @@ const SpatialMemory = (() => {
   }
 
   return {
-    init, placeMemory, removeMemory, update,
+    init, placeMemory, removeMemory, update, updateMemoryVisual,
     getMemoryAtPosition, getRegionAtPosition, getMemoriesInRegion, getAllMemories,
     getCrystalMeshes, getMemoryFromMesh, highlightMemory, clearHighlight, getSelectedId,
     exportIndex, importIndex, searchNearby, REGIONS,