feat: implement database self-healing daemon to clean corrupted session directories

Dockerfile

@@ -2,11 +2,12 @@ FROM debian:bookworm-slim
 
 ARG OPENCODE_VERSION=1.18.3
 
-# Install dependencies (including git for project initialization)
+# Install dependencies (including git for project initialization and python3 for DB self-healing)
 RUN apt-get update && apt-get install -y --no-install-recommends \
     curl \
     ca-certificates \
     git \
+    python3 \
  && rm -rf /var/lib/apt/lists/*
 
 # Download opencode binary
@@ -19,9 +20,11 @@ RUN useradd -m -s /bin/bash opencode
 # Working directory for projects
 RUN mkdir -p /projects/default && chown -R opencode:opencode /projects
 
+COPY cleaner.py /cleaner.py
+
 WORKDIR /projects/default
 
 EXPOSE 4096
 
-# Default: check if git is initialized (in case of persistent volume mount) and serve
-CMD ["sh", "-c", "if [ ! -d .git ]; then git init && git config user.email 'opencode@local.com' && git config user.name 'OpenCode' && git commit --allow-empty -m 'Initial commit'; fi; exec opencode serve --port 4096 --hostname 0.0.0.0"]
+# Default: start database self-healing daemon, check if git is initialized, and serve opencode
+CMD ["sh", "-c", "python3 /cleaner.py & if [ ! -d .git ]; then git init && git config user.email 'opencode@local.com' && git config user.name 'OpenCode' && git commit --allow-empty -m 'Initial commit'; fi; exec opencode serve --port 4096 --hostname 0.0.0.0"]

cleaner.py

@@ -0,0 +1,64 @@
+import sqlite3
+import time
+import os
+
+db_paths = [
+    "/root/.local/share/opencode/opencode.db",
+    "/home/opencode/.local/share/opencode/opencode.db",
+]
+
+# Find the active database file
+db_path = None
+for path in db_paths:
+    if os.path.exists(path):
+        db_path = path
+        break
+
+if not db_path:
+    db_path = os.path.expanduser("~/.local/share/opencode/opencode.db")
+
+print(f"OpenCode Self-Healing Daemon: watching database {db_path}...", flush=True)
+
+while True:
+    time.sleep(5)
+    if not os.path.exists(db_path):
+        continue
+    try:
+        conn = sqlite3.connect(db_path)
+        cursor = conn.cursor()
+        
+        # Check if session table exists
+        cursor.execute("SELECT name FROM sqlite_master WHERE type='table' AND name='session'")
+        if not cursor.fetchone():
+            conn.close()
+            continue
+            
+        # 1. Update directory to a safe path if it contains invalid characters
+        cursor.execute("SELECT id, directory FROM session")
+        rows = cursor.fetchall()
+        for row_id, directory in rows:
+            if directory and ("\ufffd" in directory or "\xef\xbf\xbd" in directory or "??#y" in directory):
+                print(f"[Self-Healing] Found corrupted directory '{directory}' in session '{row_id}'. Fixing to '/projects/default'...", flush=True)
+                cursor.execute(
+                    "UPDATE session SET directory = ? WHERE id = ?",
+                    ("/projects/default", row_id)
+                )
+                conn.commit()
+                
+        # 2. Clean up project_directory table if it exists
+        cursor.execute("SELECT name FROM sqlite_master WHERE type='table' AND name='project_directory'")
+        if cursor.fetchone():
+            cursor.execute("SELECT project_id, directory FROM project_directory")
+            p_rows = cursor.fetchall()
+            for p_id, directory in p_rows:
+                if directory and ("\ufffd" in directory or "\xef\xbf\xbd" in directory or "??#y" in directory):
+                    print(f"[Self-Healing] Found corrupted directory '{directory}' in project_directory '{p_id}'. Deleting...", flush=True)
+                    cursor.execute(
+                        "DELETE FROM project_directory WHERE project_id = ? AND directory = ?",
+                        (p_id, directory)
+                    )
+                    conn.commit()
+                    
+        conn.close()
+    except Exception as e:
+        print("[Self-Healing Error]:", e, flush=True)