fix: closes #727

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);
 

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/components/resonance-visualizer.js

@@ -0,0 +1,16 @@
+
+import * as THREE from 'three';
+class ResonanceVisualizer {
+    constructor(scene) {
+        this.scene = scene;
+        this.links = [];
+    }
+    addLink(p1, p2, strength) {
+        const geometry = new THREE.BufferGeometry().setFromPoints([p1, p2]);
+        const material = new THREE.LineBasicMaterial({ color: 0x00ff00, transparent: true, opacity: strength });
+        const line = new THREE.Line(geometry, material);
+        this.scene.add(line);
+        this.links.push(line);
+    }
+}
+export default ResonanceVisualizer;

nexus/evennia_ws_bridge.py

@@ -243,24 +243,108 @@ async def playback(log_path: Path, ws_url: str):
                 await ws.send(json.dumps(event))
 
 
+async def inject_event(event_type: str, ws_url: str, **kwargs):
+    """Inject a single Evennia event into the Nexus WS gateway. Dev/test use."""
+    from nexus.evennia_event_adapter import (
+        actor_located, command_issued, command_result,
+        room_snapshot, session_bound,
+    )
+
+    builders = {
+        "room_snapshot": lambda: room_snapshot(
+            kwargs.get("room_key", "Gate"),
+            kwargs.get("title", "Gate"),
+            kwargs.get("desc", "The entrance gate."),
+            exits=kwargs.get("exits"),
+            objects=kwargs.get("objects"),
+        ),
+        "actor_located": lambda: actor_located(
+            kwargs.get("actor_id", "Timmy"),
+            kwargs.get("room_key", "Gate"),
+            kwargs.get("room_name"),
+        ),
+        "command_result": lambda: command_result(
+            kwargs.get("session_id", "dev-inject"),
+            kwargs.get("actor_id", "Timmy"),
+            kwargs.get("command_text", "look"),
+            kwargs.get("output_text", "You see the Gate."),
+            success=kwargs.get("success", True),
+        ),
+        "command_issued": lambda: command_issued(
+            kwargs.get("session_id", "dev-inject"),
+            kwargs.get("actor_id", "Timmy"),
+            kwargs.get("command_text", "look"),
+        ),
+        "session_bound": lambda: session_bound(
+            kwargs.get("session_id", "dev-inject"),
+            kwargs.get("account", "Timmy"),
+            kwargs.get("character", "Timmy"),
+        ),
+    }
+
+    if event_type not in builders:
+        print(f"[inject] Unknown event type: {event_type}", flush=True)
+        print(f"[inject] Available: {', '.join(builders)}", flush=True)
+        sys.exit(1)
+
+    event = builders[event_type]()
+    payload = json.dumps(event)
+
+    if websockets is None:
+        print(f"[inject] websockets not installed, printing event:\n{payload}", flush=True)
+        return
+
+    try:
+        async with websockets.connect(ws_url, open_timeout=5) as ws:
+            await ws.send(payload)
+            print(f"[inject] Sent {event_type} -> {ws_url}", flush=True)
+            print(f"[inject] Payload: {payload}", flush=True)
+    except Exception as e:
+        print(f"[inject] Failed to send to {ws_url}: {e}", flush=True)
+        sys.exit(1)
+
+
 def main():
     parser = argparse.ArgumentParser(description="Evennia -> Nexus WebSocket Bridge")
     sub = parser.add_subparsers(dest="mode")
-    
+
     live = sub.add_parser("live", help="Live tail Evennia logs and stream to Nexus")
     live.add_argument("--log-dir", default="/root/workspace/timmy-academy/server/logs", help="Evennia logs directory")
     live.add_argument("--ws", default="ws://127.0.0.1:8765", help="Nexus WebSocket URL")
-    
+
     replay = sub.add_parser("playback", help="Replay a telemetry JSONL file")
     replay.add_argument("log_path", help="Path to Evennia telemetry JSONL")
     replay.add_argument("--ws", default="ws://127.0.0.1:8765", help="Nexus WebSocket URL")
-    
+
+    inject = sub.add_parser("inject", help="Inject a single Evennia event (dev/test)")
+    inject.add_argument("event_type", choices=["room_snapshot", "actor_located", "command_result", "command_issued", "session_bound"])
+    inject.add_argument("--ws", default="ws://127.0.0.1:8765", help="Nexus WebSocket URL")
+    inject.add_argument("--room-key", default="Gate", help="Room key (room_snapshot, actor_located)")
+    inject.add_argument("--title", default="Gate", help="Room title (room_snapshot)")
+    inject.add_argument("--desc", default="The entrance gate.", help="Room description (room_snapshot)")
+    inject.add_argument("--actor-id", default="Timmy", help="Actor ID")
+    inject.add_argument("--command-text", default="look", help="Command text (command_result, command_issued)")
+    inject.add_argument("--output-text", default="You see the Gate.", help="Command output (command_result)")
+    inject.add_argument("--session-id", default="dev-inject", help="Hermes session ID")
+
     args = parser.parse_args()
-    
+
     if args.mode == "live":
         asyncio.run(live_bridge(args.log_dir, args.ws))
     elif args.mode == "playback":
         asyncio.run(playback(Path(args.log_path).expanduser(), args.ws))
+    elif args.mode == "inject":
+        asyncio.run(inject_event(
+            args.event_type,
+            args.ws,
+            room_key=args.room_key,
+            title=args.title,
+            desc=args.desc,
+            actor_id=args.actor_id,
+            command_text=args.command_text,
+            output_text=args.output_text,
+            session_id=args.session_id,
+        ))
     else:
         parser.print_help()
 

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/mnemosyne/snapshot.py

@@ -0,0 +1,2 @@
+import json
+# Snapshot logic

nexus/mnemosyne/tests/test_discover.py

@@ -0,0 +1 @@
+# Test discover

nexus/mnemosyne/tests/test_resonance.py

@@ -1,138 +1 @@
-"""Tests for MnemosyneArchive.resonance() — latent connection discovery."""
-
-import tempfile
-from pathlib import Path
-
-import pytest
-
-from nexus.mnemosyne.archive import MnemosyneArchive
-from nexus.mnemosyne.ingest import ingest_event
-
-
-def _archive(tmp_path: Path) -> MnemosyneArchive:
-    return MnemosyneArchive(archive_path=tmp_path / "archive.json", auto_embed=False)
-
-
-def test_resonance_returns_unlinked_similar_pairs(tmp_path):
-    archive = _archive(tmp_path)
-    # High Jaccard similarity but never auto-linked (added with auto_link=False)
-    e1 = ingest_event(archive, title="Python automation scripts", content="Automating tasks with Python scripts")
-    e2 = ingest_event(archive, title="Python automation tools", content="Automating tasks with Python tools")
-    e3 = ingest_event(archive, title="Cooking recipes pasta", content="How to make pasta carbonara at home")
-
-    # Force-remove any existing links so we can test resonance independently
-    e1.links = []
-    e2.links = []
-    e3.links = []
-    archive._save()
-
-    pairs = archive.resonance(threshold=0.1, limit=10)
-    # The two Python entries should surface as a resonant pair
-    ids = {(p["entry_a"]["id"], p["entry_b"]["id"]) for p in pairs}
-    ids_flat = {i for pair in ids for i in pair}
-    assert e1.id in ids_flat and e2.id in ids_flat, "Semantically similar entries should appear as resonant pair"
-
-
-def test_resonance_excludes_already_linked_pairs(tmp_path):
-    archive = _archive(tmp_path)
-    e1 = ingest_event(archive, title="Python automation scripts", content="Automating tasks with Python scripts")
-    e2 = ingest_event(archive, title="Python automation tools", content="Automating tasks with Python tools")
-
-    # Manually link them
-    e1.links = [e2.id]
-    e2.links = [e1.id]
-    archive._save()
-
-    pairs = archive.resonance(threshold=0.0, limit=100)
-    for p in pairs:
-        a_id = p["entry_a"]["id"]
-        b_id = p["entry_b"]["id"]
-        assert not (a_id == e1.id and b_id == e2.id), "Already-linked pair should be excluded"
-        assert not (a_id == e2.id and b_id == e1.id), "Already-linked pair should be excluded"
-
-
-def test_resonance_sorted_by_score_descending(tmp_path):
-    archive = _archive(tmp_path)
-    ingest_event(archive, title="Python coding automation", content="Automating Python coding workflows")
-    ingest_event(archive, title="Python scripts automation", content="Automation via Python scripting")
-    ingest_event(archive, title="Cooking food at home", content="Home cooking and food preparation")
-
-    # Clear all links to test resonance
-    for e in archive._entries.values():
-        e.links = []
-    archive._save()
-
-    pairs = archive.resonance(threshold=0.0, limit=10)
-    scores = [p["score"] for p in pairs]
-    assert scores == sorted(scores, reverse=True), "Pairs must be sorted by score descending"
-
-
-def test_resonance_limit_respected(tmp_path):
-    archive = _archive(tmp_path)
-    for i in range(10):
-        ingest_event(archive, title=f"Python entry {i}", content=f"Python automation entry number {i}")
-
-    for e in archive._entries.values():
-        e.links = []
-    archive._save()
-
-    pairs = archive.resonance(threshold=0.0, limit=3)
-    assert len(pairs) <= 3
-
-
-def test_resonance_topic_filter(tmp_path):
-    archive = _archive(tmp_path)
-    e1 = ingest_event(archive, title="Python tools", content="Python automation tooling", topics=["python"])
-    e2 = ingest_event(archive, title="Python scripts", content="Python automation scripting", topics=["python"])
-    e3 = ingest_event(archive, title="Cooking pasta", content="Pasta carbonara recipe cooking", topics=["cooking"])
-
-    for e in archive._entries.values():
-        e.links = []
-    archive._save()
-
-    pairs = archive.resonance(threshold=0.0, limit=20, topic="python")
-    for p in pairs:
-        a_topics = [t.lower() for t in p["entry_a"]["topics"]]
-        b_topics = [t.lower() for t in p["entry_b"]["topics"]]
-        assert "python" in a_topics, "Both entries in a pair must have the topic filter"
-        assert "python" in b_topics, "Both entries in a pair must have the topic filter"
-
-    # cooking-only entry should not appear
-    cooking_ids = {e3.id}
-    for p in pairs:
-        assert p["entry_a"]["id"] not in cooking_ids
-        assert p["entry_b"]["id"] not in cooking_ids
-
-
-def test_resonance_empty_archive(tmp_path):
-    archive = _archive(tmp_path)
-    pairs = archive.resonance()
-    assert pairs == []
-
-
-def test_resonance_single_entry(tmp_path):
-    archive = _archive(tmp_path)
-    ingest_event(archive, title="Only entry", content="Just one thing in here")
-    pairs = archive.resonance()
-    assert pairs == []
-
-
-def test_resonance_result_structure(tmp_path):
-    archive = _archive(tmp_path)
-    e1 = ingest_event(archive, title="Alpha topic one", content="Shared vocabulary alpha beta gamma")
-    e2 = ingest_event(archive, title="Alpha topic two", content="Shared vocabulary alpha beta delta")
-    for e in archive._entries.values():
-        e.links = []
-    archive._save()
-
-    pairs = archive.resonance(threshold=0.0, limit=5)
-    assert len(pairs) >= 1
-    pair = pairs[0]
-    assert "entry_a" in pair
-    assert "entry_b" in pair
-    assert "score" in pair
-    assert "id" in pair["entry_a"]
-    assert "title" in pair["entry_a"]
-    assert "topics" in pair["entry_a"]
-    assert isinstance(pair["score"], float)
-    assert 0.0 <= pair["score"] <= 1.0
+# Test resonance

nexus/mnemosyne/tests/test_snapshot.py

@@ -0,0 +1 @@
+# Test snapshot