docs: mark memory_pulse as shipped, add memory_path feature

BFS-based pathfinding between memories through the connection graph.
Enables 'how is X related to Y?' queries across the holographic archive.

app.js

@@ -7,6 +7,7 @@ import { SpatialMemory } from './nexus/components/spatial-memory.js';
 import { MemoryBirth } from './nexus/components/memory-birth.js';
 import { MemoryOptimizer } from './nexus/components/memory-optimizer.js';
 import { MemoryInspect } from './nexus/components/memory-inspect.js';
+import { MemoryPulse } from './nexus/components/memory-pulse.js';
 
 // ═══════════════════════════════════════════
 // NEXUS v1.1 — Portal System Update
@@ -715,6 +716,7 @@ async function init() {
   MemoryBirth.wrapSpatialMemory(SpatialMemory);
   SpatialMemory.setCamera(camera);
   MemoryInspect.init({ onNavigate: _navigateToMemory });
+  MemoryPulse.init(SpatialMemory);
   updateLoad(90);
 
   loadSession();
@@ -1945,6 +1947,7 @@ function setupControls() {
         const entry = SpatialMemory.getMemoryFromMesh(hits[0].object);
         if (entry) {
           SpatialMemory.highlightMemory(entry.data.id);
+          MemoryPulse.triggerPulse(entry.data.id);
           const regionDef = SpatialMemory.REGIONS[entry.region] || SpatialMemory.REGIONS.working;
           MemoryInspect.show(entry.data, regionDef);
         }
@@ -2924,6 +2927,7 @@ function gameLoop() {
   if (typeof animateMemoryOrbs === 'function') {
     SpatialMemory.update(delta);
     MemoryBirth.update(delta);
+    MemoryPulse.update();
     animateMemoryOrbs(delta);
   }
 

nexus/components/memory-pulse.js

@@ -0,0 +1,160 @@
+// ═══════════════════════════════════════════════════
+// PROJECT MNEMOSYNE — MEMORY PULSE
+// ═══════════════════════════════════════════════════
+//
+// BFS wave animation triggered on crystal click.
+// When a memory crystal is clicked, a visual pulse
+// radiates through the connection graph — illuminating
+// linked memories hop-by-hop with a glow that rises
+// sharply and then fades.
+//
+// Usage:
+//   MemoryPulse.init(SpatialMemory);
+//   MemoryPulse.triggerPulse(memId);
+//   MemoryPulse.update();  // called each frame
+// ═══════════════════════════════════════════════════
+
+const MemoryPulse = (() => {
+
+  let _sm = null;
+
+  // [{mesh, startTime, delay, duration, peakIntensity, baseIntensity}]
+  const _activeEffects = [];
+
+  // ── Config ───────────────────────────────────────
+  const HOP_DELAY_MS   = 180;   // ms between hops
+  const PULSE_DURATION = 650;   // ms for glow rise + fade per node
+  const PEAK_INTENSITY = 5.5;   // emissiveIntensity at pulse peak
+  const MAX_HOPS       = 8;     // BFS depth limit
+
+  // ── Helpers ──────────────────────────────────────
+
+  // Build memId -> mesh from SpatialMemory public API
+  function _buildMeshMap() {
+    const map = {};
+    const meshes = _sm.getCrystalMeshes();
+    for (const mesh of meshes) {
+      const entry = _sm.getMemoryFromMesh(mesh);
+      if (entry) map[entry.data.id] = mesh;
+    }
+    return map;
+  }
+
+  // Build bidirectional adjacency graph from memory connection data
+  function _buildGraph() {
+    const graph = {};
+    const memories = _sm.getAllMemories();
+    for (const mem of memories) {
+      if (!graph[mem.id]) graph[mem.id] = [];
+      if (mem.connections) {
+        for (const targetId of mem.connections) {
+          graph[mem.id].push(targetId);
+          if (!graph[targetId]) graph[targetId] = [];
+          graph[targetId].push(mem.id);
+        }
+      }
+    }
+    return graph;
+  }
+
+  // ── Public API ───────────────────────────────────
+
+  function init(spatialMemory) {
+    _sm = spatialMemory;
+  }
+
+  /**
+   * Trigger a BFS pulse wave originating from memId.
+   * Each hop level illuminates after HOP_DELAY_MS * hop ms.
+   * @param {string} memId - ID of the clicked memory crystal
+   */
+  function triggerPulse(memId) {
+    if (!_sm) return;
+
+    const meshMap = _buildMeshMap();
+    const graph   = _buildGraph();
+
+    if (!meshMap[memId]) return;
+
+    // Cancel any existing effects on the same meshes (avoids stacking)
+    _activeEffects.length = 0;
+
+    // BFS
+    const visited = new Set([memId]);
+    const queue   = [{ id: memId, hop: 0 }];
+    const now     = performance.now();
+    const scheduled = [];
+
+    while (queue.length > 0) {
+      const { id, hop } = queue.shift();
+      if (hop > MAX_HOPS) continue;
+
+      const mesh = meshMap[id];
+      if (mesh) {
+        const strength      = mesh.userData.strength || 0.7;
+        const baseIntensity = 1.0 + Math.sin(mesh.userData.pulse || 0) * 0.5 * strength;
+
+        scheduled.push({
+          mesh,
+          startTime:     now,
+          delay:         hop * HOP_DELAY_MS,
+          duration:      PULSE_DURATION,
+          peakIntensity: PEAK_INTENSITY,
+          baseIntensity: Math.max(0.5, baseIntensity)
+        });
+      }
+
+      for (const neighborId of (graph[id] || [])) {
+        if (!visited.has(neighborId)) {
+          visited.add(neighborId);
+          queue.push({ id: neighborId, hop: hop + 1 });
+        }
+      }
+    }
+
+    for (const effect of scheduled) {
+      _activeEffects.push(effect);
+    }
+
+    console.info('[MemoryPulse] Pulse triggered from', memId, '—', scheduled.length, 'nodes in wave');
+  }
+
+  /**
+   * Advance all active pulse animations. Call once per frame.
+   */
+  function update() {
+    if (_activeEffects.length === 0) return;
+
+    const now = performance.now();
+
+    for (let i = _activeEffects.length - 1; i >= 0; i--) {
+      const e = _activeEffects[i];
+      const elapsed = now - e.startTime - e.delay;
+
+      if (elapsed < 0) continue;  // waiting for its hop delay
+
+      if (elapsed >= e.duration) {
+        // Animation complete — restore base intensity
+        if (e.mesh.material) {
+          e.mesh.material.emissiveIntensity = e.baseIntensity;
+        }
+        _activeEffects.splice(i, 1);
+        continue;
+      }
+
+      // t: 0 → 1 over duration
+      const t    = elapsed / e.duration;
+      // sin curve over [0, π]: smooth rise then fall
+      const glow = Math.sin(t * Math.PI);
+
+      if (e.mesh.material) {
+        e.mesh.material.emissiveIntensity =
+          e.baseIntensity + glow * (e.peakIntensity - e.baseIntensity);
+      }
+    }
+  }
+
+  return { init, triggerPulse, update };
+})();
+
+export { MemoryPulse };

nexus/mnemosyne/FEATURES.yaml

@@ -163,12 +163,15 @@ planned:
       - "#TBD"  # Will be filled when PR is created
 
   memory_pulse:
-    status: planned
+    status: shipped
+    files: [nexus/components/memory-pulse.js]
     description: >
       Visual pulse wave radiates through connection graph when
       a crystal is clicked, illuminating linked memories by BFS
-      hop distance. Was attempted in PR #1226 — needs rebasing.
+      hop distance.
     priority: medium
+    merged_prs:
+      - "#1263"
 
   embedding_backend:
     status: shipped
@@ -181,6 +184,19 @@ planned:
     merged_prs:
       - "#TBD"  # Will be filled when PR is created
 
+
+  memory_path:
+    status: shipped
+    files: [archive.py, cli.py, tests/test_path.py]
+    description: >
+      BFS shortest path between two memories through the connection graph.
+      Answers "how is memory X related to memory Y?" by finding the chain
+      of connections. Includes path_explanation for human-readable output.
+      CLI command: mnemosyne path <start_id> <end_id>
+    priority: medium
+    merged_prs:
+      - "#TBD"
+
   memory_consolidation:
     status: shipped
     files: [archive.py, cli.py, tests/test_consolidation.py]

nexus/mnemosyne/archive.py

@@ -1059,6 +1059,52 @@ class MnemosyneArchive:
 
         return merges
 
+
+    def shortest_path(self, start_id: str, end_id: str) -> list[str] | None:
+        """Find shortest path between two entries through the connection graph.
+
+        Returns list of entry IDs from start to end (inclusive), or None if
+        no path exists. Uses BFS for unweighted shortest path.
+        """
+        if start_id == end_id:
+            return [start_id] if start_id in self._entries else None
+        if start_id not in self._entries or end_id not in self._entries:
+            return None
+
+        adj = self._build_adjacency()
+        visited = {start_id}
+        queue = [(start_id, [start_id])]
+
+        while queue:
+            current, path = queue.pop(0)
+            for neighbor in adj.get(current, []):
+                if neighbor == end_id:
+                    return path + [neighbor]
+                if neighbor not in visited:
+                    visited.add(neighbor)
+                    queue.append((neighbor, path + [neighbor]))
+
+        return None
+
+    def path_explanation(self, path: list[str]) -> list[dict]:
+        """Convert a path of entry IDs into human-readable step descriptions.
+
+        Returns list of dicts with 'id', 'title', and 'topics' for each step.
+        """
+        steps = []
+        for entry_id in path:
+            entry = self._entries.get(entry_id)
+            if entry:
+                steps.append({
+                    "id": entry.id,
+                    "title": entry.title,
+                    "topics": entry.topics,
+                    "content_preview": entry.content[:120] + "..." if len(entry.content) > 120 else entry.content,
+                })
+            else:
+                steps.append({"id": entry_id, "title": "[unknown]", "topics": []})
+        return steps
+
     def rebuild_links(self, threshold: Optional[float] = None) -> int:
         """Recompute all links from scratch.
 

nexus/mnemosyne/cli.py

@@ -206,6 +206,21 @@ def cmd_timeline(args):
         print()
 
 
+
+def cmd_path(args):
+    archive = _load(args.archive)
+    path = archive.shortest_path(args.start, args.end)
+    if path is None:
+        print(f"No path found between {args.start} and {args.end}")
+        return
+    steps = archive.path_explanation(path)
+    print(f"Path ({len(steps)} hops):")
+    for i, step in enumerate(steps):
+        arrow = " → " if i > 0 else "   "
+        print(f"{arrow}{step['id']}: {step['title']}")
+        if step['topics']:
+            print(f"     topics: {', '.join(step['topics'])}")
+
 def cmd_consolidate(args):
     archive = MnemosyneArchive()
     merges = archive.consolidate(threshold=args.threshold, dry_run=args.dry_run)
@@ -300,6 +315,12 @@ def main():
     nb.add_argument("entry_id", help="Anchor entry ID")
     nb.add_argument("--days", type=int, default=7, help="Window in days (default: 7)")
 
+
+    pa = sub.add_parser("path", help="Find shortest path between two memories")
+    pa.add_argument("start", help="Starting entry ID")
+    pa.add_argument("end", help="Target entry ID")
+    pa.add_argument("--archive", default=None, help="Archive path")
+
     co = sub.add_parser("consolidate", help="Merge duplicate/near-duplicate entries")
     co.add_argument("--dry-run", action="store_true", help="Show what would be merged without applying")
     co.add_argument("--threshold", type=float, default=0.9, help="Similarity threshold (default: 0.9)")

nexus/mnemosyne/tests/test_path.py

@@ -0,0 +1,106 @@
+"""Tests for MnemosyneArchive.shortest_path and path_explanation."""
+
+from nexus.mnemosyne.archive import MnemosyneArchive
+from nexus.mnemosyne.entry import ArchiveEntry
+
+
+def _make_archive(tmp_path):
+    archive = MnemosyneArchive(str(tmp_path / "test_archive.json"))
+    return archive
+
+
+class TestShortestPath:
+    def test_direct_connection(self, tmp_path):
+        archive = _make_archive(tmp_path)
+        a = archive.add("Alpha", "first entry", topics=["start"])
+        b = archive.add("Beta", "second entry", topics=["end"])
+        # Manually link
+        a.links.append(b.id)
+        b.links.append(a.id)
+        archive._entries[a.id] = a
+        archive._entries[b.id] = b
+        archive._save()
+
+        path = archive.shortest_path(a.id, b.id)
+        assert path == [a.id, b.id]
+
+    def test_multi_hop_path(self, tmp_path):
+        archive = _make_archive(tmp_path)
+        a = archive.add("A", "alpha", topics=["x"])
+        b = archive.add("B", "beta", topics=["y"])
+        c = archive.add("C", "gamma", topics=["z"])
+        # Chain: A -> B -> C
+        a.links.append(b.id)
+        b.links.extend([a.id, c.id])
+        c.links.append(b.id)
+        archive._entries[a.id] = a
+        archive._entries[b.id] = b
+        archive._entries[c.id] = c
+        archive._save()
+
+        path = archive.shortest_path(a.id, c.id)
+        assert path == [a.id, b.id, c.id]
+
+    def test_no_path(self, tmp_path):
+        archive = _make_archive(tmp_path)
+        a = archive.add("A", "isolated", topics=[])
+        b = archive.add("B", "also isolated", topics=[])
+        path = archive.shortest_path(a.id, b.id)
+        assert path is None
+
+    def test_same_entry(self, tmp_path):
+        archive = _make_archive(tmp_path)
+        a = archive.add("A", "lonely", topics=[])
+        path = archive.shortest_path(a.id, a.id)
+        assert path == [a.id]
+
+    def test_nonexistent_entry(self, tmp_path):
+        archive = _make_archive(tmp_path)
+        a = archive.add("A", "exists", topics=[])
+        path = archive.shortest_path("fake-id", a.id)
+        assert path is None
+
+    def test_shortest_of_multiple(self, tmp_path):
+        """When multiple paths exist, BFS returns shortest."""
+        archive = _make_archive(tmp_path)
+        a = archive.add("A", "a", topics=[])
+        b = archive.add("B", "b", topics=[])
+        c = archive.add("C", "c", topics=[])
+        d = archive.add("D", "d", topics=[])
+        # A -> B -> D (short)
+        # A -> C -> B -> D (long)
+        a.links.extend([b.id, c.id])
+        b.links.extend([a.id, d.id, c.id])
+        c.links.extend([a.id, b.id])
+        d.links.append(b.id)
+        for e in [a, b, c, d]:
+            archive._entries[e.id] = e
+        archive._save()
+
+        path = archive.shortest_path(a.id, d.id)
+        assert len(path) == 3  # A -> B -> D, not A -> C -> B -> D
+
+
+class TestPathExplanation:
+    def test_returns_step_details(self, tmp_path):
+        archive = _make_archive(tmp_path)
+        a = archive.add("Alpha", "the beginning", topics=["origin"])
+        b = archive.add("Beta", "the middle", topics=["process"])
+        a.links.append(b.id)
+        b.links.append(a.id)
+        archive._entries[a.id] = a
+        archive._entries[b.id] = b
+        archive._save()
+
+        path = [a.id, b.id]
+        steps = archive.path_explanation(path)
+        assert len(steps) == 2
+        assert steps[0]["title"] == "Alpha"
+        assert steps[1]["title"] == "Beta"
+        assert "origin" in steps[0]["topics"]
+
+    def test_content_preview_truncation(self, tmp_path):
+        archive = _make_archive(tmp_path)
+        a = archive.add("A", "x" * 200, topics=[])
+        steps = archive.path_explanation([a.id])
+        assert len(steps[0]["content_preview"]) <= 123  # 120 + "..."