Fold Space 4 backup daemon loop into backend.py

backend.py

@@ -15,6 +15,8 @@ The agentic loop:
 """
 
 import os
+import shutil
+import threading
 import json
 import uuid
 import subprocess
@@ -54,6 +56,7 @@ NIM_API_KEY = os.environ.get("NVIDIA_NIM_API_KEY", "")
 BACKEND_API_KEY = os.environ.get("BACKEND_API_KEY", "")
 DATABASE_URL = os.environ.get("DATABASE_URL", "")
 WORKSPACE_DIR = os.environ.get("WORKSPACE_DIR", "/tmp/workspace")
+BACKUP_GIT_REPO = os.environ.get("BACKUP_GIT_REPO", "")
 MAX_TOOL_ROUNDS = int(os.environ.get("MAX_TOOL_ROUNDS", "10"))
 
 # NIM models that reliably support tool/function calling
@@ -1536,10 +1539,69 @@ async def db_heartbeat_loop():
         await asyncio.sleep(240) # Every 4 minutes
 
 
+def run_backup_loop():
+    log_activity("Local Git Backup Loop started")
+    while True:
+        # Wait 5 minutes between runs
+        time.sleep(300)
+        if not BACKUP_GIT_REPO:
+            continue
+        try:
+            log_activity("[Backup] Starting local workspace backup...")
+            # 1. Clean local backup directory
+            backup_local_dir = "/tmp/git_backup_repo"
+            if os.path.exists(backup_local_dir):
+                shutil.rmtree(backup_local_dir)
+            os.makedirs(backup_local_dir, exist_ok=True)
+            
+            # 2. Point-in-time snapshot copy
+            snapshot_dir = "/tmp/workspace_snapshot"
+            if os.path.exists(snapshot_dir):
+                shutil.rmtree(snapshot_dir)
+            shutil.copytree(WORKSPACE_DIR, snapshot_dir, symlinks=True, ignore=shutil.ignore_patterns('.git', 'node_modules', '.next'))
+            
+            # 3. Zip snapshot
+            archive_base = "/tmp/workspace_backup_download"
+            archive_zip = archive_base + ".zip"
+            if os.path.exists(archive_zip):
+                os.unlink(archive_zip)
+            shutil.make_archive(archive_base, 'zip', snapshot_dir)
+            shutil.rmtree(snapshot_dir)
+            
+            # 4. Handle Split if needed
+            target_dest = os.path.join(backup_local_dir, "workspace_backup.zip")
+            zip_size = os.path.getsize(archive_zip)
+            max_part_size = 50 * 1024 * 1024 # 50MB
+            if zip_size > max_part_size:
+                subprocess.run(f"split -b 50M {archive_zip} {target_dest}.part", shell=True)
+            else:
+                shutil.copy(archive_zip, target_dest)
+            os.unlink(archive_zip)
+            
+            # 5. Git commit and force push
+            subprocess.run("git init", shell=True, cwd=backup_local_dir, stdout=subprocess.DEVNULL)
+            subprocess.run("git config user.name 'Backup Agent'", shell=True, cwd=backup_local_dir, stdout=subprocess.DEVNULL)
+            subprocess.run("git config user.email 'backup@agent.internal'", shell=True, cwd=backup_local_dir, stdout=subprocess.DEVNULL)
+            subprocess.run(f"git remote add origin {BACKUP_GIT_REPO}", shell=True, cwd=backup_local_dir, stdout=subprocess.DEVNULL)
+            subprocess.run("git checkout -b main", shell=True, cwd=backup_local_dir, stdout=subprocess.DEVNULL)
+            subprocess.run("git add -A", shell=True, cwd=backup_local_dir, stdout=subprocess.DEVNULL)
+            subprocess.run('git commit -m "Auto-backup: ' + time.strftime("%Y-%m-%d %H:%M:%S") + '"', shell=True, cwd=backup_local_dir, stdout=subprocess.DEVNULL)
+            
+            result = subprocess.run("git push origin main --force", shell=True, cwd=backup_local_dir, stdout=subprocess.DEVNULL)
+            if result.returncode == 0:
+                log_activity("[Backup] Sync completed successfully (git history purged)")
+            else:
+                log_activity("[Backup Error] Git push failed")
+        except Exception as e:
+            log_activity(f"[Backup Error] {e}")
+
+
 @app.on_event("startup")
 async def startup_event():
     # Start the watchdog thread on startup
     threading.Thread(target=run_watchdog, daemon=True).start()
+    # Start the local backup loop thread
+    threading.Thread(target=run_backup_loop, daemon=True).start()
     # Start the db keep-alive loop on FastAPI event loop
     asyncio.create_task(db_heartbeat_loop())
     # Start the db nightly retention cleanup loop