Update recursive_context.py

recursive_context.py

@@ -701,8 +701,8 @@ class RecursiveContextManager:
         # 3. Push the entire manifest back to your PRO storage dataset
         self.persistence.save_conversations(full_data)
 
-    # =====================================================================
-    # WORKING MEMORY & GIT TOOLS (Paste this at the end of the class)
+        # =====================================================================
+    # GIT TOOLS
     # =====================================================================
     def push_to_github(self, commit_message="Auto-backup from Clawdbot"):
         """Pushes the current workspace to the configured GitHub repository."""
@@ -714,7 +714,7 @@ class RecursiveContextManager:
             if not (self.repo_path / ".git").exists():
                 subprocess.run(["git", "init"], cwd=self.repo_path, check=True)
                 subprocess.run(["git", "remote", "add", "origin", remote_url], cwd=self.repo_path)
-            subprocess.run(["git", "fetch", "origin"], cwd=self.repo_path, check=True) # Fetch first to avoid conflicts
+            subprocess.run(["git", "fetch", "origin"], cwd=self.repo_path, check=True)
             subprocess.run(["git", "add", "."], cwd=self.repo_path, check=True)
             subprocess.run(["git", "commit", "-m", commit_message], cwd=self.repo_path, capture_output=True, text=True)
             push_res = subprocess.run(["git", "push", "-u", "origin", "main", "--force"], cwd=self.repo_path, capture_output=True, text=True)
@@ -736,22 +736,54 @@ class RecursiveContextManager:
             return f"✅ RESTORED from GitHub/{branch}" if res.returncode == 0 else f"⚠️ Pull Failed: {res.stderr}"
         except Exception as e: return f"❌ Critical Git Error: {e}"
 
-    def read_working_memory(self) -> str:
-        """Reads the active working memory (whiteboard) content."""
-        memory_file = self.repo_path / "memory" / "active_context.md"
-        return memory_file.read_text(encoding='utf-8', errors='ignore') if memory_file.exists() else ""
+    # =====================================================================
+    # WORKING MEMORY NOTEBOOK (Structured List)
+    # =====================================================================
+    def _load_notebook(self) -> List[Dict]:
+        """Internal helper to load notebook JSON."""
+        notebook_path = self.repo_path / "memory" / "notebook.json"
+        if not notebook_path.exists(): return []
+        try: return json.loads(notebook_path.read_text(encoding='utf-8'))
+        except: return []
 
-    def update_working_memory(self, content: str, mode: str = "append") -> str:
-        """Updates the working memory. Modes: 'append' or 'overwrite'."""
-        memory_file = self.repo_path / "memory" / "active_context.md"
+    def _save_notebook(self, notes: List[Dict]):
+        """Internal helper to save notebook JSON with audit logging."""
+        notebook_path = self.repo_path / "memory" / "notebook.json"
+        log_path = self.repo_path / "memory" / "history.log"
+        notebook_path.parent.mkdir(parents=True, exist_ok=True)
+        notebook_path.write_text(json.dumps(notes, indent=2), encoding='utf-8')
         try:
-            memory_file.parent.mkdir(parents=True, exist_ok=True)
             timestamp = time.strftime("%Y-%m-%d %H:%M:%S")
-            if mode == "overwrite":
-                final_content = content
-            else:
-                current = memory_file.read_text(encoding='utf-8', errors='ignore') if memory_file.exists() else ""
-                final_content = f"{current}\n- [{timestamp}] {content}"
-            memory_file.write_text(final_content, encoding='utf-8')
-            return f"✅ Memory updated ({mode})."
-        except Exception as e: return f"❌ Error: {e}"
+            with open(log_path, "a") as f: f.write(f"[{timestamp}] NOTEBOOK UPDATED | Count: {len(notes)}\n")
+        except: pass
+
+    def notebook_read(self) -> str:
+        """Reads the Working Memory notebook."""
+        notes = self._load_notebook()
+        if not notes: return ""
+        display = []
+        for i, note in enumerate(notes):
+            display.append(f"{i+1}. [{note['timestamp']}] {note['content']}")
+        return "\n".join(display)
+
+    def notebook_add(self, content: str) -> str:
+        """Adds a new note to the notebook."""
+        notes = self._load_notebook()
+        if len(notes) >= 25: return "⚠️ Notebook full (25/25 slots). Please delete obsolete notes first."
+        timestamp = time.strftime("%Y-%m-%d %H:%M")
+        notes.append({"timestamp": timestamp, "content": content})
+        self._save_notebook(notes)
+        return f"✅ Note added. ({len(notes)}/25 slots used)"
+
+    def notebook_delete(self, index: int) -> str:
+        """Deletes a note by its number (1-based index)."""
+        notes = self._load_notebook()
+        try:
+            idx = int(index) - 1
+            if 0 <= idx < len(notes):
+                removed = notes.pop(idx)
+                self._save_notebook(notes)
+                return f"✅ Deleted note #{index}: '{removed['content'][:30]}...'"
+            else: return f"❌ Invalid index: {index}. Valid range: 1-{len(notes)}"
+        except ValueError: return "❌ Index must be a number."
+