Upload jarvis_core/episodic.py with huggingface_hub

jarvis_core/episodic.py

@@ -0,0 +1,41 @@
+"""jarvis_core.episodic — mission/episodic memory (Firebase: jarvis_episodes).
+
+Remembers work, not just facts: {mission, decision, reason, outcome, next_step}.
+Answers: "What did we try before?" / "Why did we choose this?" / "What failed?"
+"""
+import time
+
+from .store import get_store, redact
+
+COL = "jarvis_episodes"
+
+
+def record_episode(mission, decision="", reason="", outcome="", next_step=""):
+    eid = get_store().add(COL, {
+        "mission": mission, "decision": redact(decision)[:500],
+        "reason": redact(reason)[:500], "outcome": redact(outcome)[:500],
+        "next_step": redact(next_step)[:500], "ts": time.time(),
+    })
+    return get_store().get(COL, eid)
+
+
+def recall_episodes(mission="", limit=5):
+    items = get_store().all(COL)
+    if mission:
+        m = mission.lower()
+        items = [e for e in items if m in (e.get("mission") or "").lower()]
+    return sorted(items, key=lambda e: e.get("ts", 0), reverse=True)[:limit]
+
+
+def failures(mission="", limit=5):
+    items = recall_episodes(mission, 200)
+    bad = [e for e in items
+           if any(w in ((e.get("outcome") or "") + (e.get("decision") or "")).lower()
+                  for w in ["fail", "error", "broke", "wrong", "blocked"])]
+    return bad[:limit]
+
+
+def format_episode(e):
+    return (f"{e.get('mission')}: decided '{e.get('decision')}' because "
+            f"'{e.get('reason')}'. Outcome: '{e.get('outcome')}'. "
+            f"Next: '{e.get('next_step')}'.")