Update recursive_context.py

recursive_context.py

@@ -699,4 +699,59 @@ class RecursiveContextManager:
             })
             
         # 3. Push the entire manifest back to your PRO storage dataset
-        self.persistence.save_conversations(full_data)
+        self.persistence.save_conversations(full_data)
+
+    # =====================================================================
+    # WORKING MEMORY & GIT TOOLS (Paste this at the end of the class)
+    # =====================================================================
+    def push_to_github(self, commit_message="Auto-backup from Clawdbot"):
+        """Pushes the current workspace to the configured GitHub repository."""
+        token = os.getenv("GITHUB_TOKEN")
+        repo = os.getenv("GITHUB_REPO")
+        if not token or not repo: return "❌ Error: GITHUB_TOKEN or GITHUB_REPO secret is missing."
+        remote_url = f"https://{token}@github.com/{repo}.git"
+        try:
+            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", "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)
+            return f"✅ Pushed to GitHub: https://github.com/{repo}" if push_res.returncode == 0 else f"⚠️ Push Failed: {push_res.stderr}"
+        except Exception as e: return f"❌ Critical Git Error: {e}"
+
+    def pull_from_github(self, branch="main"):
+        """Hard reset: Destroys local changes and pulls clean code from GitHub."""
+        token = os.getenv("GITHUB_TOKEN")
+        repo = os.getenv("GITHUB_REPO")
+        if not token or not repo: return "❌ Error: GITHUB_TOKEN or GITHUB_REPO secret is missing."
+        remote_url = f"https://{token}@github.com/{repo}.git"
+        try:
+            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)
+            res = subprocess.run(["git", "reset", "--hard", f"origin/{branch}"], cwd=self.repo_path, capture_output=True, text=True)
+            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 ""
+
+    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"
+        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}"