feat: add sovereign conversation artifacts slice (#1117)

agent/memory.py

@@ -285,6 +285,49 @@ class AgentMemory:
             logger.warning(f"Failed to store memory: {e}")
             return None
 
+    def remember_alexander_request_response(
+        self,
+        *,
+        request_text: str,
+        response_text: str,
+        requester: str = "Alexander Whitestone",
+        source: str = "",
+        metadata: Optional[dict] = None,
+    ) -> Optional[str]:
+        """Store an Alexander request + wizard response artifact in the sovereign room."""
+        if not self._check_available():
+            logger.warning("Cannot store Alexander artifact — MemPalace unavailable")
+            return None
+
+        try:
+            from nexus.mempalace.searcher import add_memory
+            from nexus.mempalace.conversation_artifacts import build_request_response_artifact
+
+            artifact = build_request_response_artifact(
+                requester=requester,
+                responder=self.agent_name,
+                request_text=request_text,
+                response_text=response_text,
+                source=source,
+            )
+            extra_metadata = dict(artifact.metadata)
+            if metadata:
+                extra_metadata.update(metadata)
+
+            doc_id = add_memory(
+                text=artifact.text,
+                room=artifact.room,
+                wing=self.wing,
+                palace_path=self.palace_path,
+                source_file=source,
+                extra_metadata=extra_metadata,
+            )
+            logger.debug("Stored Alexander request/response artifact in sovereign room")
+            return doc_id
+        except Exception as e:
+            logger.warning(f"Failed to store Alexander artifact: {e}")
+            return None
+
     def write_diary(
         self,
         summary: Optional[str] = None,

mempalace/rooms.yaml

@@ -62,6 +62,15 @@ core_rooms:
       - proof-of-concept code snippets
       - benchmark data
 
+  - key: sovereign
+    label: Sovereign
+    purpose: Artifacts of Alexander Whitestone's requests, directives, and wizard responses
+    examples:
+      - dated request/response artifacts
+      - conversation summaries with speaker tags
+      - directive ledgers
+      - response follow-through notes
+
 optional_rooms:
   - key: evennia
     label: Evennia
@@ -98,15 +107,6 @@ optional_rooms:
     purpose: Catch-all for artefacts not yet assigned to a named room
     wizards: ["*"]
 
-  - key: sovereign
-    label: Sovereign
-    purpose: Artifacts of Alexander Whitestone's requests, directives, and conversation history
-    wizards: ["*"]
-    conventions:
-      naming: "YYYY-MM-DD_HHMMSS_<topic>.md"
-      index: "INDEX.md"
-      description: "Each artifact is a dated record of a request from Alexander and the wizard's response. The running INDEX.md provides a chronological catalog."
-
 # Tunnel routing table
 # Defines which room pairs are connected across wizard wings.
 # A tunnel lets `recall <query> --fleet` search both wings at once.

nexus/mempalace/__init__.py

@@ -13,6 +13,12 @@ from __future__ import annotations
 
 from nexus.mempalace.config import MEMPALACE_PATH, FLEET_WING
 from nexus.mempalace.searcher import search_memories, add_memory, MemPalaceResult
+from nexus.mempalace.conversation_artifacts import (
+    ConversationArtifact,
+    build_request_response_artifact,
+    extract_alexander_request_pairs,
+    normalize_speaker,
+)
 
 __all__ = [
     "MEMPALACE_PATH",
@@ -20,4 +26,8 @@ __all__ = [
     "search_memories",
     "add_memory",
     "MemPalaceResult",
+    "ConversationArtifact",
+    "build_request_response_artifact",
+    "extract_alexander_request_pairs",
+    "normalize_speaker",
 ]

nexus/mempalace/config.py

@@ -40,6 +40,7 @@ CORE_ROOMS: list[str] = [
     "nexus",       # reports, docs, KT
     "issues",      # tickets, backlog
     "experiments", # prototypes, spikes
+    "sovereign",   # Alexander request/response artifacts
 ]
 
 # ── ChromaDB collection name ──────────────────────────────────────────────────

nexus/mempalace/conversation_artifacts.py

@@ -0,0 +1,122 @@
+"""Helpers for preserving Alexander request/response artifacts in MemPalace.
+
+This module provides a small, typed bridge between raw conversation turns and
+MemPalace drawers stored in the shared `sovereign` room. The goal is not to
+solve all future speaker-tagging needs at once; it gives the Nexus one
+canonical artifact shape that other miners and bridges can reuse.
+"""
+
+from __future__ import annotations
+
+from dataclasses import dataclass, field
+from datetime import datetime, timezone
+from typing import Iterable
+
+_ALEXANDER_ALIASES = {
+    "alexander",
+    "alexander whitestone",
+    "rockachopa",
+    "triptimmy",
+}
+
+
+@dataclass(frozen=True)
+class ConversationArtifact:
+    requester: str
+    responder: str
+    request_text: str
+    response_text: str
+    room: str = "sovereign"
+    timestamp: str = field(default_factory=lambda: datetime.now(timezone.utc).strftime("%Y-%m-%dT%H:%M:%SZ"))
+    metadata: dict = field(default_factory=dict)
+
+    @property
+    def text(self) -> str:
+        return (
+            f"# Conversation Artifact\n\n"
+            f"## Alexander Request\n{self.request_text.strip()}\n\n"
+            f"## Wizard Response\n{self.response_text.strip()}\n"
+        )
+
+
+def normalize_speaker(name: str | None) -> str:
+    cleaned = " ".join((name or "").strip().lower().split())
+    if cleaned in _ALEXANDER_ALIASES:
+        return "alexander"
+    return cleaned.replace(" ", "_") or "unknown"
+
+
+def build_request_response_artifact(
+    *,
+    requester: str,
+    responder: str,
+    request_text: str,
+    response_text: str,
+    source: str = "",
+    timestamp: str | None = None,
+    request_timestamp: str | None = None,
+    response_timestamp: str | None = None,
+) -> ConversationArtifact:
+    requester_slug = normalize_speaker(requester)
+    responder_slug = normalize_speaker(responder)
+    ts = timestamp or datetime.now(timezone.utc).strftime("%Y-%m-%dT%H:%M:%SZ")
+    metadata = {
+        "artifact_type": "alexander_request_response",
+        "requester": requester_slug,
+        "responder": responder_slug,
+        "speaker_tags": [f"speaker:{requester_slug}", f"speaker:{responder_slug}"],
+        "source": source,
+        "timestamp": ts,
+    }
+    if request_timestamp:
+        metadata["request_timestamp"] = request_timestamp
+    if response_timestamp:
+        metadata["response_timestamp"] = response_timestamp
+    return ConversationArtifact(
+        requester=requester_slug,
+        responder=responder_slug,
+        request_text=request_text,
+        response_text=response_text,
+        timestamp=ts,
+        metadata=metadata,
+    )
+
+
+def extract_alexander_request_pairs(
+    turns: Iterable[dict],
+    *,
+    responder: str,
+    source: str = "",
+) -> list[ConversationArtifact]:
+    responder_slug = normalize_speaker(responder)
+    pending_request: dict | None = None
+    artifacts: list[ConversationArtifact] = []
+
+    for turn in turns:
+        speaker = normalize_speaker(
+            turn.get("speaker") or turn.get("username") or turn.get("author") or turn.get("name")
+        )
+        text = (turn.get("text") or turn.get("content") or "").strip()
+        if not text:
+            continue
+
+        if speaker == "alexander":
+            pending_request = turn
+            continue
+
+        if speaker == responder_slug and pending_request is not None:
+            artifacts.append(
+                build_request_response_artifact(
+                    requester="alexander",
+                    responder=responder_slug,
+                    request_text=(pending_request.get("text") or pending_request.get("content") or "").strip(),
+                    response_text=text,
+                    source=source,
+                    request_timestamp=pending_request.get("timestamp"),
+                    response_timestamp=turn.get("timestamp"),
+                    timestamp=turn.get("timestamp") or pending_request.get("timestamp"),
+                )
+            )
+            pending_request = None
+
+    return artifacts

tests/test_agent_memory.py

@@ -20,6 +20,7 @@ from agent.memory import (
     SessionTranscript,
     create_agent_memory,
 )
+from nexus.mempalace.conversation_artifacts import ConversationArtifact
 from agent.memory_hooks import MemoryHooks
 
 
@@ -184,6 +185,24 @@ class TestAgentMemory:
         doc_id = mem.write_diary()
         assert doc_id is None  # MemPalace unavailable
 
+    def test_remember_alexander_request_response_uses_sovereign_room(self):
+        mem = AgentMemory(agent_name="allegro")
+        mem._available = True
+        with patch("nexus.mempalace.searcher.add_memory", return_value="doc-123") as add_memory:
+            doc_id = mem.remember_alexander_request_response(
+                request_text="Catalog my requests.",
+                response_text="I will preserve them as artifacts.",
+                requester="Alexander Whitestone",
+                source="telegram:timmy-time",
+            )
+
+        assert doc_id == "doc-123"
+        kwargs = add_memory.call_args.kwargs
+        assert kwargs["room"] == "sovereign"
+        assert kwargs["wing"] == mem.wing
+        assert kwargs["extra_metadata"]["artifact_type"] == "alexander_request_response"
+        assert kwargs["extra_metadata"]["speaker_tags"] == ["speaker:alexander", "speaker:allegro"]
+
 
 # ---------------------------------------------------------------------------
 # MemoryHooks tests

tests/test_conversation_artifacts.py

@@ -0,0 +1,58 @@
+from pathlib import Path
+
+import yaml
+
+from nexus.mempalace.config import CORE_ROOMS
+from nexus.mempalace.conversation_artifacts import (
+    ConversationArtifact,
+    build_request_response_artifact,
+    extract_alexander_request_pairs,
+    normalize_speaker,
+)
+
+
+def test_sovereign_room_is_core_room() -> None:
+    assert "sovereign" in CORE_ROOMS
+    rooms_yaml = yaml.safe_load(Path("mempalace/rooms.yaml").read_text())
+    assert any(room["key"] == "sovereign" for room in rooms_yaml["core_rooms"])
+
+
+def test_normalize_speaker_maps_alexander_variants() -> None:
+    assert normalize_speaker("Alexander Whitestone") == "alexander"
+    assert normalize_speaker("Rockachopa") == "alexander"
+    assert normalize_speaker("  ALEXANDER  ") == "alexander"
+    assert normalize_speaker("Bezalel") == "bezalel"
+
+
+def test_build_request_response_artifact_creates_sovereign_metadata() -> None:
+    artifact = build_request_response_artifact(
+        requester="Alexander Whitestone",
+        responder="Allegro",
+        request_text="Please organize my conversation artifacts.",
+        response_text="I will catalog them under a sovereign room.",
+        source="telegram:timmy-time",
+        timestamp="2026-04-16T01:30:00Z",
+    )
+
+    assert isinstance(artifact, ConversationArtifact)
+    assert artifact.room == "sovereign"
+    assert artifact.metadata["speaker_tags"] == ["speaker:alexander", "speaker:allegro"]
+    assert artifact.metadata["artifact_type"] == "alexander_request_response"
+    assert artifact.metadata["responder"] == "allegro"
+    assert "## Alexander Request" in artifact.text
+    assert "## Wizard Response" in artifact.text
+
+
+def test_extract_alexander_request_pairs_finds_following_wizard_response() -> None:
+    turns = [
+        {"speaker": "Alexander Whitestone", "text": "Catalog my requests as artifacts.", "timestamp": "2026-04-16T01:00:00Z"},
+        {"speaker": "Allegro", "text": "I'll build a sovereign room contract.", "timestamp": "2026-04-16T01:01:00Z"},
+        {"speaker": "Alexander", "text": "Make sure my words are easy to recall.", "timestamp": "2026-04-16T01:02:00Z"},
+        {"speaker": "Allegro", "text": "I will tag them with speaker metadata.", "timestamp": "2026-04-16T01:03:00Z"},
+    ]
+
+    artifacts = extract_alexander_request_pairs(turns, responder="Allegro", source="telegram")
+
+    assert len(artifacts) == 2
+    assert artifacts[0].metadata["request_timestamp"] == "2026-04-16T01:00:00Z"
+    assert artifacts[1].metadata["response_timestamp"] == "2026-04-16T01:03:00Z"