Fix source_tag not propagating through exit gate to permanent memories

Memories persisted via exit gate flush and FIFO prune were missing
source_tag (user input vs agent response indistinguishable). Now
extracts source_tag from scratch metadata and passes it through
store_memory to the source_tag column.

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

Author: stonks-git

src/loop.py

@@ -215,6 +215,16 @@ async def _flush_scratch_through_exit_gate(
         if should_persist:
             source_info = entry.get("source", "conversation")
             tags = entry.get("tags", [])
+            # Extract source_tag from scratch metadata
+            scratch_meta = entry.get("metadata")
+            if isinstance(scratch_meta, str):
+                import json as _json
+                try:
+                    scratch_meta = _json.loads(scratch_meta)
+                except (ValueError, TypeError):
+                    scratch_meta = {}
+            scratch_meta = scratch_meta or {}
+            entry_source_tag = scratch_meta.get("source_tag")
             await memory.store_memory(
                 content=content,
                 memory_type="episodic",
@@ -229,6 +239,7 @@ async def _flush_scratch_through_exit_gate(
                         for k, v in meta.items()
                     },
                 },
+                source_tag=entry_source_tag,
             )
             persisted += 1
         else:
@@ -526,6 +537,7 @@ async def cognitive_loop(config, layers, memory, shutdown_event, input_queue: as
                                 confidence=score,
                                 importance=score,
                                 metadata={"gate_score": score, "pruned_from": "fifo"},
+                                source_tag=msg.get("source_tag"),
                             )
                 conversation = kept
 

src/memory.py

@@ -164,6 +164,7 @@ async def store_memory(
         importance: float = 0.5,
         evidence_count: int = 0,
         metadata: dict | None = None,
+        source_tag: str | None = None,
     ) -> str:
         """Embed and store a memory chunk. Returns the memory ID."""
         memory_id = f"mem_{uuid.uuid4().hex[:12]}"
@@ -176,8 +177,9 @@ async def store_memory(
         await self.pool.execute(
             """
             INSERT INTO memories (id, content, type, embedding, created_at, updated_at,
-                                  source, tags, confidence, importance, evidence_count, metadata)
-            VALUES ($1, $2, $3, $4::halfvec, $5, $6, $7, $8, $9, $10, $11, $12)
+                                  source, tags, confidence, importance, evidence_count, metadata,
+                                  source_tag)
+            VALUES ($1, $2, $3, $4::halfvec, $5, $6, $7, $8, $9, $10, $11, $12, $13)
             """,
             memory_id,
             content,
@@ -191,6 +193,7 @@ async def store_memory(
             importance,
             evidence_count,
             json.dumps(metadata or {}),
+            source_tag,
         )
 
         logger.info(f"Stored memory {memory_id}: {content[:80]}...")