fix: add wing param to diary_write/diary_read, derive from transcript path

Without a wing override, all diary entries from the stop hook land in
wing_session-hook regardless of which project the session is in, making
per-project diary search impossible.

- tool_diary_write(): add optional `wing` param; sanitize and use it when
  provided, fall back to wing_{agent_name} when omitted
- tool_diary_read(): add optional `wing` param for filtering by target wing
- TOOLS dict: expose `wing` in input_schema for both diary tools
- hooks_cli: add _wing_from_transcript_path() helper that extracts the
  project name from Claude Code paths like
  ~/.claude/projects/-home-jp-Projects-kiyo-xhci-fix/... → kiyo-xhci-fix
- hook_stop: derive project wing and append wing= hint to block reason so
  Claude writes diary entries to the correct per-project wing

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: jphein

mempalace/hooks_cli.py

@@ -126,6 +126,19 @@ def _parse_harness_input(data: dict, harness: str) -> dict:
     }
 
 
+def _wing_from_transcript_path(transcript_path: str) -> str:
+    """Derive a project wing name from a Claude Code transcript path.
+
+    Claude Code stores transcripts at:
+        ~/.claude/projects/-home-<user>-Projects-<project>/session.jsonl
+    We extract <project> as the wing name.  Falls back to "sessions".
+    """
+    match = re.search(r"-Projects-([^/]+?)(?:/|$)", transcript_path)
+    if match:
+        return match.group(1).lower().replace(" ", "_")
+    return "sessions"
+
+
 def hook_stop(data: dict, harness: str):
     """Stop hook: block every N messages for auto-save."""
     parsed = _parse_harness_input(data, harness)
@@ -167,7 +180,9 @@ def hook_stop(data: dict, harness: str):
         # Optional: auto-ingest if MEMPAL_DIR is set
         _maybe_auto_ingest()
 
-        _output({"decision": "block", "reason": STOP_BLOCK_REASON})
+        project_wing = _wing_from_transcript_path(transcript_path)
+        reason = STOP_BLOCK_REASON + f" Write diary entry to wing={project_wing}."
+        _output({"decision": "block", "reason": reason})
     else:
         _output({})
 

mempalace/mcp_server.py

@@ -539,10 +539,10 @@ def tool_kg_stats():
 # ==================== AGENT DIARY ====================
 
 
-def tool_diary_write(agent_name: str, entry: str, topic: str = "general"):
+def tool_diary_write(agent_name: str, entry: str, topic: str = "general", wing: str = ""):
     """
-    Write a diary entry for this agent. Each agent gets its own wing
-    with a diary room. Entries are timestamped and accumulate over time.
+    Write a diary entry for this agent. Entries are timestamped and
+    accumulate over time in a diary room.
 
     This is the agent's personal journal — observations, thoughts,
     what it worked on, what it noticed, what it thinks matters.
@@ -553,7 +553,10 @@ def tool_diary_write(agent_name: str, entry: str, topic: str = "general"):
     except ValueError as e:
         return {"success": False, "error": str(e)}
 
-    wing = f"wing_{agent_name.lower().replace(' ', '_')}"
+    if wing:
+        wing = wing.lower().replace(" ", "_")
+    else:
+        wing = f"wing_{agent_name.lower().replace(' ', '_')}"
     room = "diary"
     col = _get_collection(create=True)
     if not col:
@@ -605,12 +608,15 @@ def tool_diary_write(agent_name: str, entry: str, topic: str = "general"):
         return {"success": False, "error": str(e)}
 
 
-def tool_diary_read(agent_name: str, last_n: int = 10):
+def tool_diary_read(agent_name: str, last_n: int = 10, wing: str = ""):
     """
     Read an agent's recent diary entries. Returns the last N entries
     in chronological order — the agent's personal journal.
     """
-    wing = f"wing_{agent_name.lower().replace(' ', '_')}"
+    if wing:
+        wing = wing.lower().replace(" ", "_")
+    else:
+        wing = f"wing_{agent_name.lower().replace(' ', '_')}"
     col = _get_collection()
     if not col:
         return _no_palace()
@@ -884,6 +890,10 @@ def tool_diary_read(agent_name: str, last_n: int = 10):
                     "type": "string",
                     "description": "Topic tag (optional, default: general)",
                 },
+                "wing": {
+                    "type": "string",
+                    "description": "Target wing for this diary entry (optional). If omitted, uses wing_{agent_name}. Use this to write diary entries to a project wing instead of an agent-specific wing.",
+                },
             },
             "required": ["agent_name", "entry"],
         },
@@ -902,6 +912,10 @@ def tool_diary_read(agent_name: str, last_n: int = 10):
                     "type": "integer",
                     "description": "Number of recent entries to read (default: 10)",
                 },
+                "wing": {
+                    "type": "string",
+                    "description": "Wing to read diary entries from (optional). If omitted, reads from wing_{agent_name}.",
+                },
             },
             "required": ["agent_name"],
         },

tests/test_hooks_cli.py

@@ -169,7 +169,7 @@ def test_stop_hook_blocks_at_interval(tmp_path):
         state_dir=tmp_path,
     )
     assert result["decision"] == "block"
-    assert result["reason"] == STOP_BLOCK_REASON
+    assert result["reason"].startswith(STOP_BLOCK_REASON)
 
 
 def test_stop_hook_tracks_save_point(tmp_path):