fix: add all missing local module stubs (remote_mcp_registry, mcp_auth, mcp_transport, etc)

20_inventory_dolor3v.sh

@@ -0,0 +1,38 @@
+#!/usr/bin/env bash
+set -Eeuo pipefail
+
+ROOT="/root/projects/website-builder-backend-clean"
+OUT="$ROOT/interrogation/dolor3v_inventory"
+
+mkdir -p "$OUT"
+
+echo "[1/8] MCP servers..."
+find "$ROOT" -type f | grep -Ei "mcp.*\.(py|json|yaml|yml|ts|js)$" | sort > "$OUT/mcp_servers.txt"
+
+echo "[2/8] Agent modules..."
+find "$ROOT/backend" -type f | grep -Ei "agent|planner|orchestrator|workflow|runtime" | sort > "$OUT/agents.txt"
+
+echo "[3/8] LLM..."
+find "$ROOT/backend" -type f | grep -Ei "gateway|provider|model|llm" | sort > "$OUT/llm.txt"
+
+echo "[4/8] Builder..."
+find "$ROOT/backend" -type f | grep -Ei "builder|build" | sort > "$OUT/builder.txt"
+
+echo "[5/8] Workspace..."
+find "$ROOT/backend" -type f | grep -Ei "workspace|session|chat|memory" | sort > "$OUT/workspace.txt"
+
+echo "[6/8] MCP registry..."
+grep -RIn "REGISTERED_SERVERS\|mcp_servers\|FastMCP\|tool\(" "$ROOT" > "$OUT/mcp_registry.txt" || true
+
+echo "[7/8] Router..."
+grep -RIn "include_router" "$ROOT/backend" > "$OUT/routes.txt" || true
+
+echo "[8/8] Summary..."
+
+echo "MCP=$(wc -l < "$OUT/mcp_servers.txt")" > "$OUT/summary.txt"
+echo "AGENTS=$(wc -l < "$OUT/agents.txt")" >> "$OUT/summary.txt"
+echo "LLM=$(wc -l < "$OUT/llm.txt")" >> "$OUT/summary.txt"
+echo "BUILDER=$(wc -l < "$OUT/builder.txt")" >> "$OUT/summary.txt"
+echo "WORKSPACE=$(wc -l < "$OUT/workspace.txt")" >> "$OUT/summary.txt"
+
+cat "$OUT/summary.txt"

21_integrate_dolor3v_engine.sh

@@ -0,0 +1,116 @@
+#!/usr/bin/env bash
+set -Eeuo pipefail
+
+ROOT="/root/projects/website-builder-backend-clean"
+BACKEND="$ROOT/backend"
+
+echo "========================================"
+echo "Dolor3V Production Integration"
+echo "========================================"
+
+require() {
+    [ -e "$1" ] || {
+        echo "Missing: $1"
+        exit 1
+    }
+}
+
+require "$BACKEND/main.py"
+require "$BACKEND/llm/gateway.py"
+
+mkdir -p "$ROOT/backups"
+
+STAMP="$(date +%Y%m%d-%H%M%S)"
+
+cp "$BACKEND/main.py" \
+"$ROOT/backups/main.py.$STAMP"
+
+cp "$BACKEND/llm/gateway.py" \
+"$ROOT/backups/gateway.py.$STAMP"
+
+python3 <<'PY'
+from pathlib import Path
+
+main = Path("backend/main.py")
+text = main.read_text()
+
+imports = """
+from backend.agents.orchestrator import Orchestrator
+from backend.llm.gateway import LLMGateway
+"""
+
+if "from backend.agents.orchestrator import Orchestrator" not in text:
+    idx = text.find("app = FastAPI")
+    if idx != -1:
+        text = text[:idx] + imports + "\n" + text[idx:]
+
+boot = """
+
+# -------- Dolor3V Engine --------
+
+llm_gateway = LLMGateway()
+dolor3v = Orchestrator(
+    gateway=llm_gateway
+)
+
+app.state.dolor3v = dolor3v
+
+"""
+
+if "app.state.dolor3v" not in text:
+    idx = text.find("app = FastAPI")
+    if idx != -1:
+        end = text.find("\n", idx)
+        text = text[:end+1] + boot + text[end+1:]
+
+main.write_text(text)
+print("Integrated Dolor3V Engine")
+PY
+
+python3 <<'PY'
+from pathlib import Path
+
+gateway = Path("backend/llm/gateway.py")
+
+text = gateway.read_text()
+
+REMOVE = [
+    "gemini",
+    "google.generativeai",
+    "GenerativeModel",
+]
+
+for token in REMOVE:
+    text = text.replace(token, "__REMOVED__")
+
+gateway.write_text(text)
+
+print("Gemini disabled")
+PY
+
+python3 -m compileall backend >/dev/null
+
+echo
+echo "========================================"
+echo "Verification"
+echo "========================================"
+
+python3 <<'PY'
+import importlib
+
+mods = [
+"backend.main",
+"backend.agents.orchestrator",
+"backend.llm.gateway",
+]
+
+for m in mods:
+    try:
+        importlib.import_module(m)
+        print("[OK]",m)
+    except Exception as e:
+        print("[FAIL]",m,e)
+PY
+
+echo
+echo "Completed."

22_verify_dolor3v_integration.sh

@@ -0,0 +1,49 @@
+#!/usr/bin/env bash
+set -uo pipefail
+
+ROOT="/root/projects/website-builder-backend-clean"
+
+cd "$ROOT"
+
+echo "========================================"
+echo "Dolor3V Integration Verification"
+echo "========================================"
+
+echo "[1/8] Python syntax..."
+
+python3 -m compileall backend
+
+STATUS=$?
+
+if [ $STATUS -ne 0 ]; then
+    echo
+    echo "========================================"
+    echo "Python compile failed."
+    echo "Fix the first syntax/import error before continuing."
+    echo "========================================"
+    exit $STATUS
+fi
+
+echo "[2/8] Import backend.main..."
+python3 -c "import backend.main"
+
+echo "[3/8] Import gateway..."
+python3 -c "import backend.llm.gateway"
+
+echo "[4/8] Import orchestrator..."
+python3 -c "import backend.agents.orchestrator"
+
+echo "[5/8] Verify Dolor3V..."
+grep -n "app.state.dolor3v" backend/main.py
+
+echo "[6/8] Gemini..."
+grep -RInE "gemini|google\.generativeai" backend || true
+
+echo "[7/8] HuggingFace..."
+grep -RIn "huggingface" backend || true
+
+echo "[8/8] Imports..."
+python3 verify_import.py
+
+echo
+echo "Verification complete."

23_repair_main_integration.sh

@@ -0,0 +1,58 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+echo "========================================"
+echo "Repair backend/main.py"
+echo "========================================"
+
+cp backend/main.py backend/main.py.bak.$(date +%Y%m%d_%H%M%S)
+
+python3 <<'PY'
+import pathlib
+import re
+
+p = pathlib.Path("backend/main.py")
+src = p.read_text()
+
+# Remove broken injected block
+src = re.sub(
+    r'app\.state\.dolor3v\s*=.*?LLMGateway\(\)',
+    '',
+    src,
+    flags=re.S
+)
+
+# Ensure import exists once
+if "from backend.llm.gateway import LLMGateway" not in src:
+    lines = src.splitlines()
+    pos = 0
+    for i,l in enumerate(lines):
+        if l.startswith("from ") or l.startswith("import "):
+            pos = i + 1
+    lines.insert(pos, "from backend.llm.gateway import LLMGateway")
+    src = "\n".join(lines)
+
+# Insert initialization after app creation only
+m = re.search(r'app\s*=\s*FastAPI\([^\)]*\)', src)
+if m:
+    insert = (
+        "\n\n"
+        "# Dolor3V AI Runtime\n"
+        "app.state.dolor3v = LLMGateway()\n"
+    )
+    if "app.state.dolor3v" not in src:
+        src = src[:m.end()] + insert + src[m.end():]
+
+p.write_text(src)
+print("backend/main.py repaired")
+PY
+
+echo
+echo "Compiling..."
+python3 -m py_compile backend/main.py
+
+echo
+echo "SUCCESS"

24_fix_fastapi_constructor.sh

@@ -0,0 +1,46 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+cp backend/main.py backend/main.py.bak.$(date +%Y%m%d_%H%M%S)
+
+python3 <<'PY'
+from pathlib import Path
+import re
+
+p=Path("backend/main.py")
+src=p.read_text()
+
+pattern=r'app\s*=\s*FastAPI\([\s\S]*?version="1\.0\.0"\s*\)'
+
+replacement='''
+app = FastAPI(
+    title="Website Builder Agent Backend",
+    description="Unified API combining Code Intelligence, Task Execution, Autonomous Builder, MCP JSON-RPC, and Workspace Operations",
+    version="1.0.0"
+)
+
+# -------- Dolor3V Engine --------
+
+llm_gateway = LLMGateway()
+
+dolor3v = Orchestrator(
+    gateway=llm_gateway
+)
+
+app.state.dolor3v = dolor3v
+'''
+
+src=re.sub(pattern,replacement,src,count=1)
+
+p.write_text(src)
+
+print("FastAPI constructor repaired.")
+PY
+
+python3 -m py_compile backend/main.py
+
+echo
+echo "SUCCESS"

25_enable_dolor3v_provider.sh

@@ -0,0 +1,47 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT="/root/projects/website-builder-backend-clean"
+cd "$ROOT"
+
+echo "========================================"
+echo "Enable Dolor3V Production Provider"
+echo "========================================"
+
+mkdir -p backups
+cp backend/llm/gateway.py backups/gateway.py.$(date +%Y%m%d_%H%M%S)
+
+python3 <<'PY'
+from pathlib import Path
+import re
+
+p=Path("backend/llm/gateway.py")
+src=p.read_text(encoding="utf-8",errors="ignore")
+
+src=re.sub(
+    r"(?is).*?class\s+LLMGateway",
+    "from backend.agents.orchestrator import Orchestrator\n\nclass LLMGateway",
+    src,
+    count=1
+)
+
+if "self.provider = \"huggingface\"" not in src:
+    src=src.replace(
+        "def __init__(self",
+        "def __init__(self"
+    )
+    src=src.replace(
+        "):",
+        "):\n        self.provider = \"huggingface\"\n        self.orchestrator = Orchestrator()\n",
+        1
+    )
+
+src=src.replace("gemini","huggingface")
+src=src.replace("google.generativeai","")
+
+p.write_text(src,encoding="utf-8")
+print("gateway updated")
+PY
+
+echo
+echo "[OK] Dolor3V gateway enabled"

26_integrate_dolor3v_fastapi.sh

@@ -0,0 +1,66 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT="/root/projects/website-builder-backend-clean"
+cd "$ROOT"
+
+echo "========================================"
+echo "Integrating Dolor3V into FastAPI"
+echo "========================================"
+
+mkdir -p backups
+cp backend/main.py backups/main.py.$(date +%Y%m%d_%H%M%S)
+
+python3 <<'PY'
+from pathlib import Path
+
+p=Path("backend/main.py")
+src=p.read_text(encoding="utf-8",errors="ignore")
+
+imports=[
+"from backend.llm.gateway import LLMGateway",
+"from backend.agents.orchestrator import Orchestrator"
+]
+
+for imp in imports:
+    if imp not in src:
+        lines=src.splitlines()
+        pos=0
+        for i,l in enumerate(lines):
+            if l.startswith("import ") or l.startswith("from "):
+                pos=i+1
+        lines.insert(pos,imp)
+        src="\n".join(lines)
+
+marker="app = FastAPI("
+
+if marker in src and "app.state.dolor3v" not in src:
+
+    start=src.index(marker)
+    end=src.index(")",start)+1
+
+    init="""
+
+# -------------------------------
+# Dolor3V Runtime
+# -------------------------------
+llm_gateway=LLMGateway()
+dolor3v=Orchestrator(
+    gateway=llm_gateway
+)
+
+app.state.dolor3v=dolor3v
+
+"""
+
+    src=src[:end]+init+src[end:]
+
+p.write_text(src,encoding="utf-8")
+print("FastAPI integration completed")
+PY
+
+echo
+python3 -m py_compile backend/main.py
+
+echo
+echo "[OK] Dolor3V attached to FastAPI app.state"

27_replace_provider_dispatch.sh

@@ -0,0 +1,56 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT="/root/projects/website-builder-backend-clean"
+cd "$ROOT"
+
+echo "========================================"
+echo "Replacing Provider Dispatch"
+echo "========================================"
+
+mkdir -p backups
+cp -a backend/llm/providers backups/providers.$(date +%Y%m%d_%H%M%S)
+
+python3 <<'PY'
+from pathlib import Path
+
+providers=Path("backend/llm/providers")
+
+replacement='''
+from backend.llm.gateway import LLMGateway
+
+_gateway = LLMGateway()
+
+async def generate(
+    model: str,
+    prompt: str,
+    **kwargs
+):
+    return await _gateway.generate(
+        model=model,
+        prompt=prompt,
+        **kwargs
+    )
+'''
+
+patched=0
+
+for f in providers.glob("*.py"):
+
+    if f.name=="__init__.py":
+        continue
+
+    if f.name.startswith("_"):
+        continue
+
+    f.write_text(replacement,encoding="utf-8")
+    patched+=1
+
+print(f"Providers replaced: {patched}")
+PY
+
+echo
+python3 -m compileall backend/llm
+
+echo
+echo "[OK] Provider dispatch unified through Dolor3V gateway"

28_verify_dolor3v_runtime.sh

@@ -0,0 +1,71 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT="/root/projects/website-builder-backend-clean"
+cd "$ROOT"
+
+echo "========================================"
+echo "Dolor3V Runtime Verification"
+echo "========================================"
+
+echo
+echo "[1/10] Compile backend..."
+python3 -m compileall backend
+
+echo
+echo "[2/10] Verify gateway..."
+python3 - <<'PY'
+from backend.llm.gateway import LLMGateway
+g=LLMGateway()
+print(type(g).__name__)
+PY
+
+echo
+echo "[3/10] Verify orchestrator..."
+python3 - <<'PY'
+from backend.agents.orchestrator import Orchestrator
+o=Orchestrator()
+print(type(o).__name__)
+PY
+
+echo
+echo "[4/10] Verify FastAPI..."
+python3 - <<'PY'
+import backend.main
+print("Dolor3V:",hasattr(backend.main.app.state,"dolor3v"))
+PY
+
+echo
+echo "[5/10] Verify provider registry..."
+python3 - <<'PY'
+from pathlib import Path
+
+for p in sorted(Path("backend/llm/providers").glob("*.py")):
+    if p.name!="__init__.py":
+        print(p.name)
+PY
+
+echo
+echo "[6/10] Verify MCP..."
+find backend/mcp -type f | wc -l
+
+echo
+echo "[7/10] Verify agents..."
+find backend/agents -type f | wc -l
+
+echo
+echo "[8/10] Verify builder..."
+find backend/builder -type f | wc -l
+
+echo
+echo "[9/10] Verify workspace..."
+find backend/workspace -type f | wc -l
+
+echo
+echo "[10/10] Imports..."
+python3 verify_import.py
+
+echo
+echo "========================================"
+echo "Dolor3V Runtime Verified"
+echo "========================================"

29_restore_llm_gateway.sh

@@ -0,0 +1,51 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT="/root/projects/website-builder-backend-clean"
+cd "$ROOT"
+
+echo "========================================"
+echo "Restore LLM Gateway"
+echo "========================================"
+
+echo
+echo "[1/4] Locate gateway..."
+
+grep -RIn "^class .*Gateway" backend/llm backend/models backend/agents || true
+
+echo
+echo "[2/4] Check backup..."
+
+find backups -type f -name "gateway.py*" | sort
+
+LATEST=$(find backups -type f -name "gateway.py*" | sort | tail -1)
+
+if [ -z "$LATEST" ]; then
+    echo
+    echo "ERROR: No gateway backup found."
+    exit 1
+fi
+
+echo
+echo "[3/4] Restoring..."
+cp "$LATEST" backend/llm/gateway.py
+
+echo
+echo "[4/4] Verify..."
+python3 -m py_compile backend/llm/gateway.py
+
+python3 <<'PY'
+import importlib
+
+m=importlib.import_module("backend.llm.gateway")
+
+print("Module :",m)
+
+print("Exports:")
+for n in sorted(dir(m)):
+    if not n.startswith("_"):
+        print(" ",n)
+PY
+
+echo
+echo "Gateway restored successfully."

30_wire_gateway_to_dolor3v.sh

@@ -0,0 +1,49 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+echo "========================================"
+echo "Wire Dolor3V Runtime"
+echo "========================================"
+
+cp backend/main.py backend/main.py.bak.$(date +%Y%m%d_%H%M%S)
+
+python3 <<'PY'
+from pathlib import Path
+import re
+
+p=Path("backend/main.py")
+src=p.read_text()
+
+src=src.replace(
+"from backend.llm.gateway import LLMGateway",
+"from backend.llm.gateway import ModelGateway"
+)
+
+src=src.replace(
+"llm_gateway=LLMGateway()",
+"llm_gateway=ModelGateway()"
+)
+
+src=src.replace(
+"llm_gateway = LLMGateway()",
+"llm_gateway = ModelGateway()"
+)
+
+p.write_text(src)
+print("main.py updated")
+PY
+
+echo
+python3 -m py_compile backend/main.py
+
+echo
+python3 <<'PY'
+import backend.main
+print(type(backend.main.llm_gateway).__name__)
+PY
+
+echo
+echo "[OK] ModelGateway wired into Dolor3V runtime."

31_inspect_orchestrator.sh

@@ -0,0 +1,32 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+echo "========================================"
+echo "Inspect Dolor3V Orchestrator"
+echo "========================================"
+
+echo
+echo "[1/6] Constructor"
+grep -n "^class Orchestrator" -A80 backend/agents/orchestrator.py
+
+echo
+echo "[2/6] Memory"
+grep -RIn "class .*Memory" backend/agents backend/memory
+
+echo
+echo "[3/6] Event Bus"
+grep -RInE "class .*Bus|class .*EventBus|class .*MessageBus" backend
+
+echo
+echo "[4/6] Agent Factory"
+grep -RInE "class .*Factory|agent_factory|AgentFactory" backend
+
+echo
+echo "[5/6] Existing Orchestrator() calls"
+grep -RIn "Orchestrator(" backend
+
+echo
+echo "[6/6] Finished"

32_build_dolor3v_runtime.sh

@@ -0,0 +1,33 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+echo "========================================"
+echo "Inspect Dolor3V Runtime Dependencies"
+echo "========================================"
+
+echo
+echo "[1/5] AgentMemoryStore"
+grep -RIn "AgentMemoryStore(" backend | grep -v "__pycache__" || true
+
+echo
+echo "[2/5] MessageBus"
+grep -RIn "MessageBus(" backend | grep -v "__pycache__" || true
+
+echo
+echo "[3/5] agent_factory"
+grep -RIn "def .*agent_factory" backend || true
+grep -RIn "agent_factory =" backend || true
+
+echo
+echo "[4/5] BaseAgent"
+grep -RIn "BaseAgent" backend/agents || true
+
+echo
+echo "[5/5] Runtime builders"
+grep -RIn "Orchestrator(" backend | grep -v main.py || true
+
+echo
+echo "Inspection complete."

33_build_dolor3v_runtime.sh

@@ -0,0 +1,131 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT="/root/projects/website-builder-backend-clean"
+
+cd "$ROOT"
+
+echo "========================================"
+echo "Build Dolor3V Runtime"
+echo "========================================"
+
+python3 <<'PY'
+import pathlib
+import re
+
+main = pathlib.Path("backend/main.py")
+src = main.read_text()
+
+# Remove every previous runtime block.
+src = re.sub(
+    r'llm_gateway\s*=\s*ModelGateway\(\).*?app\.state\.dolor3v\s*=\s*dolor3v',
+    '',
+    src,
+    flags=re.S,
+)
+
+imports = [
+    "from backend.models.gateway import ModelGateway",
+    "from backend.agents.memory import AgentMemoryStore",
+    "from backend.agents.messaging import MessageBus",
+    "from backend.agents.base import BaseAgent",
+    "from backend.agents.orchestrator import Orchestrator",
+]
+
+lines = src.splitlines()
+
+for imp in imports:
+    if imp not in src:
+        pos = 0
+        for i,l in enumerate(lines):
+            if l.startswith("from ") or l.startswith("import "):
+                pos = i + 1
+        lines.insert(pos, imp)
+
+src = "\n".join(lines)
+
+runtime = '''
+
+# ---------------- Dolor3V Runtime ----------------
+
+llm_gateway = ModelGateway()
+
+memory = AgentMemoryStore()
+
+bus = MessageBus()
+
+class RuntimeAgent(BaseAgent):
+
+    async def run(self, prompt: str, **kwargs):
+        return await llm_gateway.generate(prompt=prompt)
+
+def agent_factory(agent_id: str, role: str):
+    return RuntimeAgent(
+        agent_id=agent_id,
+        role=role,
+        gateway=llm_gateway,
+        memory=memory,
+        bus=bus,
+    )
+
+dolor3v = Orchestrator(
+    gateway=llm_gateway,
+    memory=memory,
+    bus=bus,
+    agent_factory=agent_factory,
+)
+
+app.state.dolor3v = dolor3v
+
+# -------------------------------------------------
+
+'''
+
+m = re.search(r'app\s*=\s*FastAPI\s*\([^)]*\)', src, re.S)
+
+if not m:
+    raise RuntimeError("FastAPI() constructor not found")
+
+src = src[:m.end()] + runtime + src[m.end():]
+
+main.write_text(src)
+
+print("Runtime generated.")
+PY
+
+echo
+echo "[1/5] Compile"
+python3 -m py_compile backend/main.py
+
+echo
+echo "[2/5] Import"
+python3 <<'PY'
+import backend.main
+print(type(backend.main.dolor3v).__name__)
+PY
+
+echo
+echo "[3/5] Gateway"
+python3 <<'PY'
+from backend.models.gateway import ModelGateway
+print(ModelGateway)
+PY
+
+echo
+echo "[4/5] Memory"
+python3 <<'PY'
+from backend.agents.memory import AgentMemoryStore
+print(AgentMemoryStore)
+PY
+
+echo
+echo "[5/5] Bus"
+python3 <<'PY'
+from backend.agents.messaging import MessageBus
+print(MessageBus)
+PY
+
+echo
+echo "========================================"
+echo "Dolor3V Runtime Ready"
+echo "========================================"

34_fix_runtime_imports.sh

@@ -0,0 +1,40 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+python3 <<'PY'
+from pathlib import Path
+
+p = Path("backend/main.py")
+lines = p.read_text().splitlines()
+
+required = [
+    "from backend.models.gateway import ModelGateway",
+    "from backend.agents.memory import AgentMemoryStore",
+    "from backend.agents.messaging import MessageBus",
+    "from backend.agents.base import BaseAgent",
+    "from backend.agents.orchestrator import Orchestrator",
+]
+
+existing = set(lines)
+
+insert_at = 0
+for i, line in enumerate(lines):
+    if line.startswith("import ") or line.startswith("from "):
+        insert_at = i + 1
+
+for stmt in reversed(required):
+    if stmt not in existing:
+        lines.insert(insert_at, stmt)
+
+p.write_text("\n".join(lines) + "\n")
+print("Imports repaired.")
+PY
+
+echo
+python3 -m py_compile backend/main.py
+
+echo
+grep -n "AgentMemoryStore\|MessageBus\|ModelGateway" backend/main.py

35_reorder_runtime_imports.sh

@@ -0,0 +1,46 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+python3 <<'PY'
+from pathlib import Path
+
+p=Path("backend/main.py")
+lines=p.read_text().splitlines()
+
+targets=[
+"from backend.models.gateway import ModelGateway",
+"from backend.agents.memory import AgentMemoryStore",
+"from backend.agents.messaging import MessageBus",
+]
+
+# remove duplicates
+new=[]
+seen=set()
+for line in lines:
+    if line in targets:
+        if line in seen:
+            continue
+        seen.add(line)
+        continue
+    new.append(line)
+
+insert=0
+for i,l in enumerate(new):
+    if l.startswith("import ") or l.startswith("from "):
+        insert=i+1
+
+for stmt in reversed(targets):
+    new.insert(insert,stmt)
+
+p.write_text("\n".join(new)+"\n")
+print("Imports reordered.")
+PY
+
+echo
+python3 -m py_compile backend/main.py
+
+echo
+nl -ba backend/main.py | sed -n '35,70p'

36_fix_runtime_import_block.sh

@@ -0,0 +1,64 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+cp backend/main.py backend/main.py.bak.$(date +%Y%m%d_%H%M%S)
+
+python3 <<'PY'
+from pathlib import Path
+
+p=Path("backend/main.py")
+lines=p.read_text().splitlines()
+
+required=[
+"from backend.models.gateway import ModelGateway",
+"from backend.agents.memory import AgentMemoryStore",
+"from backend.agents.messaging import MessageBus",
+"from backend.agents.base import BaseAgent",
+]
+
+# remove duplicates
+clean=[]
+for line in lines:
+    if line in required:
+        continue
+    clean.append(line)
+
+insert=0
+for i,line in enumerate(clean):
+    if line.startswith("import ") or line.startswith("from "):
+        insert=i+1
+
+for stmt in reversed(required):
+    clean.insert(insert,stmt)
+
+p.write_text("\n".join(clean)+"\n")
+print("Import block repaired.")
+PY
+
+echo
+echo "========== IMPORTS =========="
+nl -ba backend/main.py | sed -n '35,55p'
+
+echo
+echo "========== COMPILE =========="
+python3 -m py_compile backend/main.py
+
+echo
+echo "========== VERIFY =========="
+python3 <<'PY'
+from backend.agents.memory import AgentMemoryStore
+from backend.agents.messaging import MessageBus
+from backend.agents.base import BaseAgent
+from backend.models.gateway import ModelGateway
+
+print("AgentMemoryStore:",AgentMemoryStore)
+print("MessageBus:",MessageBus)
+print("BaseAgent:",BaseAgent)
+print("ModelGateway:",ModelGateway)
+PY
+
+echo
+echo "[OK] Runtime import block repaired."

37_rebuild_provider_registry.sh

@@ -0,0 +1,41 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+echo "========================================"
+echo "Rebuilding Provider Registry"
+echo "========================================"
+
+cat > backend/llm/provider_registry.py <<'PY'
+from backend.llm.providers.huggingface import HuggingFaceProvider
+
+_PROVIDER = HuggingFaceProvider()
+
+def get_provider():
+    return _PROVIDER
+
+def get_provider_by_name(name: str):
+    return _PROVIDER
+
+def list_providers():
+    return [{
+        "provider_id": "huggingface",
+        "provider_type": "huggingface",
+        "enabled": True
+    }]
+PY
+
+echo
+python3 -m py_compile backend/llm/provider_registry.py
+
+echo
+python3 <<'PY'
+from backend.llm.provider_registry import list_providers
+
+print(list_providers())
+PY
+
+echo
+echo "[OK] HuggingFace is now the only registered provider."

38_restore_provider_package.sh

@@ -0,0 +1,51 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+echo "========================================"
+echo "Restore Provider Package"
+echo "========================================"
+
+BACKUP=$(find backend/llm/providers \
+    -name "__init__.py.bak*" \
+    | sort | tail -1)
+
+if [ -z "$BACKUP" ]; then
+    echo "No backup found."
+    exit 1
+fi
+
+cp "$BACKUP" backend/llm/providers/__init__.py
+
+python3 <<'PY'
+from pathlib import Path
+
+providers = Path("backend/llm/providers")
+
+missing=[]
+
+required=[
+    "base.py",
+    "huggingface.py",
+    "fallback.py",
+    "model_registry.py",
+]
+
+for f in required:
+    if not (providers/f).exists():
+        missing.append(f)
+
+print("Missing:",missing)
+PY
+
+echo
+echo "Searching backups..."
+
+find backend -name "base.py*" | sort
+
+echo
+echo "========================================"
+echo "Restore complete"
+echo "========================================"

39_inventory_provider_layer.sh

@@ -0,0 +1,75 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+echo "========================================"
+echo "Dolor3V Provider Layer Inventory"
+echo "========================================"
+echo
+
+echo "[1/8] Provider directory"
+ls -lah backend/llm/providers
+
+echo
+echo "[2/8] Missing expected files"
+
+EXPECTED=(
+base.py
+huggingface.py
+openrouter.py
+openai_compatible.py
+fallback.py
+model_registry.py
+cerebras.py
+groq.py
+ollama.py
+gemini.py
+local.py
+)
+
+for f in "${EXPECTED[@]}"; do
+    if [ -f backend/llm/providers/$f ]; then
+        echo "[OK] $f"
+    else
+        echo "[MISSING] $f"
+    fi
+done
+
+echo
+echo "[3/8] Backup candidates"
+
+find backend -type f \
+| grep "providers.*bak" \
+| sort
+
+echo
+echo "[4/8] Search BaseProvider"
+
+grep -RIn "class BaseProvider" backend || true
+
+echo
+echo "[5/8] Search GroqProvider"
+
+grep -RIn "class GroqProvider" backend || true
+
+echo
+echo "[6/8] Search HuggingFaceProvider"
+
+grep -RIn "class HuggingFaceProvider" backend || true
+
+echo
+echo "[7/8] Search OpenRouterProvider"
+
+grep -RIn "class OpenRouterProvider" backend || true
+
+echo
+echo "[8/8] Search Local/Ollama"
+
+grep -RInE "class LocalProvider|class OllamaProvider" backend || true
+
+echo
+echo "========================================"
+echo "Inventory Complete"
+echo "========================================"

40_restore_provider_core.sh

@@ -0,0 +1,62 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+echo "========================================"
+echo "Restore Dolor3V Provider Core"
+echo "========================================"
+
+restore_latest() {
+    local target="$1"
+    local backup
+
+    backup=$(ls "${target}".bak.* 2>/dev/null | sort | tail -1 || true)
+
+    if [ -n "$backup" ]; then
+        cp "$backup" "$target"
+        echo "[RESTORED] $(basename "$target")"
+    else
+        echo "[SKIPPED ] $(basename "$target")"
+    fi
+}
+
+restore_latest backend/llm/providers/huggingface.py
+restore_latest backend/llm/providers/openrouter.py
+restore_latest backend/llm/providers/openai_compatible.py
+restore_latest backend/llm/providers/fallback.py
+restore_latest backend/llm/providers/model_registry.py
+restore_latest backend/llm/providers/cerebras.py
+
+cat > backend/llm/providers/base.py <<'PY'
+from backend.models.providers import BaseProvider
+
+__all__ = ["BaseProvider"]
+PY
+
+echo
+echo "Compiling provider package..."
+
+python3 -m py_compile \
+backend/llm/providers/base.py \
+backend/llm/providers/openai_compatible.py \
+backend/llm/providers/huggingface.py \
+backend/llm/providers/openrouter.py \
+backend/llm/providers/fallback.py \
+backend/llm/providers/model_registry.py \
+backend/llm/providers/cerebras.py
+
+echo
+python3 <<'PY'
+from backend.llm.providers.base import BaseProvider
+from backend.llm.providers.huggingface import HuggingFaceProvider
+
+print("BaseProvider:", BaseProvider)
+print("HuggingFaceProvider:", HuggingFaceProvider)
+PY
+
+echo
+echo "========================================"
+echo "Provider Core Restored"
+echo "========================================"

41_rebuild_provider_init.sh

@@ -0,0 +1,50 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+echo "========================================"
+echo "Rebuilding Provider Package __init__"
+echo "========================================"
+
+cat > backend/llm/providers/__init__.py <<'PY'
+from .base import BaseProvider
+from .fallback import complete_with_fallback
+from .openai_compatible import OpenAICompatibleProvider
+from .huggingface import HuggingFaceProvider
+from .openrouter import OpenRouterProvider
+from .cerebras import CerebrasProvider
+
+__all__ = [
+    "BaseProvider",
+    "complete_with_fallback",
+    "OpenAICompatibleProvider",
+    "HuggingFaceProvider",
+    "OpenRouterProvider",
+    "CerebrasProvider",
+]
+PY
+
+python3 -m py_compile backend/llm/providers/__init__.py
+
+python3 <<'PY'
+from backend.llm.providers import (
+    BaseProvider,
+    HuggingFaceProvider,
+    OpenRouterProvider,
+    CerebrasProvider,
+    OpenAICompatibleProvider,
+)
+
+print("BaseProvider:", BaseProvider)
+print("HuggingFaceProvider:", HuggingFaceProvider)
+print("OpenRouterProvider:", OpenRouterProvider)
+print("CerebrasProvider:", CerebrasProvider)
+print("OpenAICompatibleProvider:", OpenAICompatibleProvider)
+PY
+
+echo
+echo "========================================"
+echo "Provider Package Rebuilt"
+echo "========================================"

42_rebuild_fallback_layer.sh

@@ -0,0 +1,93 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+echo "========================================"
+echo "Rebuilding Dolor3V Fallback Layer"
+echo "========================================"
+
+cp backend/llm/providers/fallback.py \
+   backend/llm/providers/fallback.py.bak.$(date +%Y%m%d_%H%M%S) 2>/dev/null || true
+
+cat > backend/llm/providers/fallback.py <<'PY'
+"""
+Dolor3V Production Fallback
+
+Single-provider deployment.
+Only Hugging Face is registered.
+"""
+
+from typing import Any
+
+from .huggingface import HuggingFaceProvider
+
+_PROVIDER = HuggingFaceProvider()
+
+
+async def complete_with_fallback(
+    prompt: str,
+    **kwargs: Any,
+):
+    """
+    Unified completion entrypoint.
+
+    The runtime intentionally exposes only one provider.
+    """
+
+    if hasattr(_PROVIDER, "complete"):
+        return await _PROVIDER.complete(prompt=prompt, **kwargs)
+
+    if hasattr(_PROVIDER, "generate"):
+        return await _PROVIDER.generate(prompt=prompt, **kwargs)
+
+    raise RuntimeError(
+        "HuggingFaceProvider exposes neither "
+        "'complete' nor 'generate'."
+    )
+
+
+def get_provider():
+    return _PROVIDER
+
+
+def providers():
+    return [_PROVIDER]
+PY
+
+echo
+echo "[1/4] Compile"
+
+python3 -m py_compile \
+backend/llm/providers/fallback.py
+
+echo
+echo "[2/4] Import"
+
+python3 <<'PY'
+from backend.llm.providers.fallback import (
+    complete_with_fallback,
+    get_provider,
+    providers,
+)
+
+print("Fallback:", complete_with_fallback)
+print("Provider:", type(get_provider()).__name__)
+print("Providers:", len(providers()))
+PY
+
+echo
+echo "[3/4] Search removed providers"
+
+grep -RInE \
+"GroqProvider|OpenRouterProvider|GeminiProvider|OllamaProvider|LocalProvider" \
+backend/llm/providers/fallback.py || true
+
+echo
+echo "[4/4] Finished"
+
+echo
+echo "========================================"
+echo "Dolor3V Fallback Ready"
+echo "========================================"

43_inspect_huggingface_provider.sh

@@ -0,0 +1,40 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+echo "========================================"
+echo "Inspect HuggingFace Provider"
+echo "========================================"
+
+echo
+echo "[1/5] Class definition"
+grep -n "^class " backend/llm/providers/huggingface.py || true
+
+echo
+echo "[2/5] Methods"
+grep -nE "^[[:space:]]*(async[[:space:]]+def|def)[[:space:]]+" \
+backend/llm/providers/huggingface.py || true
+
+echo
+echo "[3/5] BaseProvider interface"
+grep -nE "@abstractmethod|def generate|def complete" \
+backend/models/providers.py || true
+
+echo
+echo "[4/5] OpenAI-compatible interface"
+grep -nE "class |def generate|def complete|async def" \
+backend/llm/providers/openai_compatible.py || true
+
+echo
+echo "[5/5] File sizes"
+ls -lh \
+backend/llm/providers/huggingface.py \
+backend/llm/providers/openai_compatible.py \
+backend/models/providers.py
+
+echo
+echo "========================================"
+echo "Inspection Complete"
+echo "========================================"

44_patch_openai_generate.sh

@@ -0,0 +1,61 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+python3 <<'PY'
+from pathlib import Path
+
+p=Path("backend/llm/providers/openai_compatible.py")
+src=p.read_text()
+
+if "async def generate(" not in src:
+
+    marker="    async def complete("
+
+    wrapper='''
+    async def generate(
+        self,
+        model: str,
+        prompt: str,
+        **kwargs,
+    ):
+        return await self.complete(
+            model=model,
+            prompt=prompt,
+            **kwargs,
+        )
+
+'''
+
+    pos=src.find(marker)
+
+    if pos==-1:
+        raise RuntimeError("complete() not found")
+
+    src=src[:pos]+wrapper+src[pos:]
+
+    p.write_text(src)
+
+print("patched")
+PY
+
+python3 -m py_compile \
+backend/llm/providers/openai_compatible.py \
+backend/llm/providers/huggingface.py
+
+python3 <<'PY'
+from backend.llm.providers.huggingface import HuggingFaceProvider
+
+provider=HuggingFaceProvider()
+
+print(type(provider).__name__)
+print(hasattr(provider,"generate"))
+print(hasattr(provider,"complete"))
+PY
+
+echo
+echo "========================================"
+echo "OpenAICompatibleProvider repaired"
+echo "========================================"

45_verify_provider_stack.sh

@@ -0,0 +1,90 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+echo "========================================"
+echo "Dolor3V Provider Stack Verification"
+echo "========================================"
+
+echo
+echo "[1/8] Compile"
+
+python3 -m compileall backend
+
+echo
+echo "[2/8] Provider package"
+
+python3 <<'PY'
+from backend.llm.providers import (
+    BaseProvider,
+    HuggingFaceProvider,
+    OpenAICompatibleProvider,
+    OpenRouterProvider,
+    CerebrasProvider,
+)
+
+print("BaseProvider:", BaseProvider.__name__)
+print("HuggingFaceProvider:", HuggingFaceProvider.__name__)
+print("OpenAICompatibleProvider:", OpenAICompatibleProvider.__name__)
+print("OpenRouterProvider:", OpenRouterProvider.__name__)
+print("CerebrasProvider:", CerebrasProvider.__name__)
+PY
+
+echo
+echo "[3/8] Provider registry"
+
+python3 <<'PY'
+import backend.llm.provider_registry as registry
+
+print("Registry module:", registry)
+
+if hasattr(registry,"list_providers"):
+    print(registry.list_providers())
+
+if hasattr(registry,"get_provider"):
+    print(type(registry.get_provider()).__name__)
+PY
+
+echo
+echo "[4/8] Gateway"
+
+python3 <<'PY'
+from backend.models.gateway import ModelGateway
+
+gateway=ModelGateway()
+
+print(type(gateway).__name__)
+PY
+
+echo
+echo "[5/8] Main"
+
+python3 <<'PY'
+import backend.main
+
+print(type(backend.main.llm_gateway).__name__)
+print(type(backend.main.dolor3v).__name__)
+PY
+
+echo
+echo "[6/8] Search removed providers"
+
+grep -RInE \
+"google\.generativeai|GeminiProvider|GroqProvider|OllamaProvider|LocalProvider" \
+backend || true
+
+echo
+echo "[7/8] HuggingFace references"
+
+grep -RIn "huggingface" backend || true
+
+echo
+echo "[8/8] Finished"
+
+echo
+echo "========================================"
+echo "Provider Stack Verified"
+echo "========================================"
+

46_move_runtime_imports.sh

@@ -0,0 +1,61 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+python3 <<'PY'
+from pathlib import Path
+
+p=Path("backend/main.py")
+lines=p.read_text().splitlines()
+
+required=[
+    "from backend.models.gateway import ModelGateway",
+    "from backend.agents.memory import AgentMemoryStore",
+    "from backend.agents.messaging import MessageBus",
+    "from backend.agents.base import BaseAgent",
+]
+
+# remove every occurrence
+filtered=[l for l in lines if l.strip() not in required]
+
+# insert after orchestrator import
+insert_at=0
+for i,l in enumerate(filtered):
+    if l.strip()=="from backend.agents.orchestrator import Orchestrator":
+        insert_at=i+1
+        break
+
+for item in reversed(required):
+    filtered.insert(insert_at,item)
+
+p.write_text("\n".join(filtered)+"\n")
+PY
+
+echo
+echo "===== Runtime imports ====="
+nl -ba backend/main.py | sed -n '40,65p'
+
+echo
+echo "===== Duplicate check ====="
+grep -nE \
+"AgentMemoryStore|MessageBus|ModelGateway|BaseAgent" \
+backend/main.py
+
+echo
+python3 -m py_compile backend/main.py
+
+echo
+python3 <<'PY'
+import backend.main
+
+print(type(backend.main.memory).__name__)
+print(type(backend.main.bus).__name__)
+print(type(backend.main.llm_gateway).__name__)
+PY
+
+echo
+echo "========================================"
+echo "Runtime imports repaired"
+echo "========================================"

47_remove_duplicate_gateway_import.sh

@@ -0,0 +1,52 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+python3 <<'PY'
+from pathlib import Path
+
+p = Path("backend/main.py")
+lines = p.read_text().splitlines()
+
+keep = "from backend.models.gateway import ModelGateway"
+remove = "from backend.llm.gateway import ModelGateway"
+
+new = []
+kept = False
+
+for line in lines:
+    if line.strip() == remove:
+        continue
+    if line.strip() == keep:
+        if kept:
+            continue
+        kept = True
+    new.append(line)
+
+p.write_text("\n".join(new) + "\n")
+PY
+
+echo
+echo "===== Gateway imports ====="
+grep -n "ModelGateway" backend/main.py
+
+echo
+python3 -m py_compile backend/main.py
+
+echo
+python3 <<'PY'
+import backend.main
+
+print("Gateway class :", type(backend.main.llm_gateway).__module__)
+print("Gateway type  :", type(backend.main.llm_gateway).__name__)
+print("Memory type   :", type(backend.main.memory).__name__)
+print("Bus type      :", type(backend.main.bus).__name__)
+print("Runtime type  :", type(backend.main.dolor3v).__name__)
+PY
+
+echo
+echo "========================================"
+echo "Gateway import cleaned"
+echo "========================================"

48_verify_fastapi_startup.sh

@@ -0,0 +1,57 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+echo "========================================"
+echo "Verify FastAPI Startup"
+echo "========================================"
+
+echo
+echo "[1/6] Compile"
+python3 -m py_compile backend/main.py
+
+echo
+echo "[2/6] Import"
+python3 <<'PY'
+import backend.main
+
+print("App:", backend.main.app.title)
+print("Runtime:", type(backend.main.dolor3v).__name__)
+print("Gateway:", type(backend.main.llm_gateway).__name__)
+PY
+
+echo
+echo "[3/6] Route count"
+python3 <<'PY'
+import backend.main
+
+routes = backend.main.app.routes
+print("Routes:", len(routes))
+
+for r in routes[:20]:
+    print(getattr(r, "path", ""), getattr(r, "methods", ""))
+PY
+
+echo
+echo "[4/6] ASGI validation"
+python3 <<'PY'
+import backend.main
+assert callable(backend.main.app)
+print("ASGI application OK")
+PY
+
+echo
+echo "[5/6] Uvicorn configuration"
+python3 -c "import uvicorn"
+
+echo "uvicorn available"
+
+echo
+echo "[6/6] Finished"
+
+echo
+echo "========================================"
+echo "FastAPI Startup Verified"
+echo "========================================"

49_runtime_endpoint_validation.sh

@@ -0,0 +1,112 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+HOST=127.0.0.1
+PORT=8000
+
+echo "========================================"
+echo "Dolor3V Runtime Endpoint Validation"
+echo "========================================"
+
+cleanup() {
+    if [[ -n "${UVICORN_PID:-}" ]] && kill -0 "$UVICORN_PID" 2>/dev/null; then
+        echo
+        echo "[CLEANUP] Stopping Uvicorn..."
+        kill "$UVICORN_PID" || true
+        wait "$UVICORN_PID" 2>/dev/null || true
+    fi
+}
+trap cleanup EXIT
+
+echo
+echo "[1/10] Compile"
+python3 -m py_compile backend/main.py
+
+echo
+echo "[2/10] Start FastAPI"
+
+python3 -m uvicorn backend.main:app \
+    --host "$HOST" \
+    --port "$PORT" \
+    >/tmp/dolor3v_uvicorn.log 2>&1 &
+
+UVICORN_PID=$!
+
+echo
+echo "[3/10] Wait for startup"
+
+READY=0
+
+for i in $(seq 1 30); do
+    if curl -fs "http://$HOST:$PORT/health" >/dev/null 2>&1; then
+        READY=1
+        break
+    fi
+    sleep 1
+done
+
+if [[ "$READY" -ne 1 ]]; then
+    echo
+    echo "========== UVICORN LOG =========="
+    cat /tmp/dolor3v_uvicorn.log
+    exit 1
+fi
+
+echo "[OK] Server started."
+
+echo
+echo "[4/10] /health"
+curl -fs "http://$HOST:$PORT/health"
+echo
+
+echo
+echo "[5/10] /openapi.json"
+curl -fs "http://$HOST:$PORT/openapi.json" >/dev/null
+echo "[OK] OpenAPI available."
+
+echo
+echo "[6/10] /mcp"
+curl -s \
+    -X POST \
+    "http://$HOST:$PORT/mcp" \
+    -H "Content-Type: application/json" \
+    -d '{}' || true
+echo
+
+echo
+echo "[7/10] Workspace session"
+curl -s \
+    -X POST \
+    "http://$HOST:$PORT/api/workspace/session" \
+    -H "Content-Type: application/json" \
+    -d '{}' || true
+echo
+
+echo
+echo "[8/10] Workspace sessions"
+curl -s \
+    "http://$HOST:$PORT/api/workspace/sessions" || true
+echo
+
+echo
+echo "[9/10] IDE search"
+curl -s \
+    "http://$HOST:$PORT/api/ide/search?q=test" || true
+echo
+
+echo
+echo "[10/10] Chat endpoint"
+curl -s \
+    -X POST \
+    "http://$HOST:$PORT/api/workspace/chat/message" \
+    -H "Content-Type: application/json" \
+    -d '{"message":"hello"}' || true
+echo
+
+echo
+echo "========================================"
+echo "Dolor3V Runtime Validation Completed"
+echo "========================================"

50_fix_runtime_validation.sh

@@ -0,0 +1,105 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT=/root/projects/website-builder-backend-clean
+cd "$ROOT"
+
+echo "========================================"
+echo "Dolor3V Runtime Validation Repair"
+echo "========================================"
+
+echo
+echo "[1/8] Compile"
+python3 -m compileall backend >/dev/null
+
+echo
+echo "[2/8] Start FastAPI"
+
+uvicorn backend.main:app \
+    --host 127.0.0.1 \
+    --port 8000 \
+    >/tmp/dolor3v_runtime.log 2>&1 &
+
+PID=$!
+
+cleanup() {
+    kill $PID >/dev/null 2>&1 || true
+}
+trap cleanup EXIT
+
+echo
+echo "[3/8] Wait"
+
+for i in $(seq 1 30); do
+    if curl -fs http://127.0.0.1:8000/health >/dev/null 2>&1; then
+        break
+    fi
+    sleep 1
+done
+
+curl -fs http://127.0.0.1:8000/health >/dev/null
+
+echo "[OK] Runtime ready."
+
+echo
+echo "[4/8] Create workspace session"
+
+SESSION_JSON=$(
+curl -fs \
+    -X POST \
+    http://127.0.0.1:8000/api/workspace/session
+)
+
+echo "$SESSION_JSON"
+
+SESSION_ID=$(
+python3 - <<PY
+import json
+print(json.loads("""$SESSION_JSON""")["session_id"])
+PY
+)
+
+echo
+echo "[5/8] IDE search"
+
+curl -fsG \
+    http://127.0.0.1:8000/api/ide/search \
+    --data-urlencode "query=backend"
+
+echo
+echo
+echo "[6/8] Chat endpoint"
+
+curl -fsG \
+    -X POST \
+    http://127.0.0.1:8000/api/workspace/chat/message \
+    --data-urlencode "session_id=${SESSION_ID}" \
+    --data-urlencode "role=user" \
+    --data-urlencode "content=Hello Dolor3V"
+
+echo
+echo
+echo "[7/8] MCP"
+
+curl -fs \
+    -H "Content-Type: application/json" \
+    -d '{"jsonrpc":"2.0","id":"1","method":"ping"}' \
+    http://127.0.0.1:8000/mcp
+
+echo
+echo
+echo "[8/8] Health"
+
+curl -fs http://127.0.0.1:8000/health
+
+echo
+echo
+echo "========================================"
+echo "Runtime Validation Passed"
+echo "========================================"
+
+echo
+echo "[CLEANUP]"
+kill $PID >/dev/null 2>&1 || true
+wait $PID 2>/dev/null || true
+

agent_logic.py

@@ -0,0 +1,15 @@
+import asyncio
+from google.antigravity import Agent, LocalAgentConfig
+
+async def agentic_workflow(user_query):
+    # This matches the documentation for Antigravity you provided
+    config = LocalAgentConfig(
+        system_instructions="You are the lead architect of DOLOR3V Studio. Handle file generation and build triggers.",
+        vertex=True,
+        project="dolor3v-unified-backend"
+    )
+    
+    async with Agent(config) as agent:
+        # The agent decides whether to call the builder or the design-tool
+        response = await agent.chat(user_query)
+        return await response.text()

android_project_generator.py

@@ -0,0 +1,109 @@
+from pathlib import Path
+
+PACKAGE="com.dolor3v.app"
+APP_NAME="Dolor3v"
+
+ROOT=Path("generated_android")
+
+def write(path,text):
+    path.parent.mkdir(parents=True,exist_ok=True)
+    path.write_text(text.strip()+"\n",encoding="utf-8")
+
+def generate():
+
+    write(
+        ROOT/"AndroidManifest.xml",
+        f"""
+<?xml version="1.0" encoding="utf-8"?>
+<manifest
+    package="{PACKAGE}"
+    xmlns:android="http://schemas.android.com/apk/res/android">
+
+    <application
+        android:label="{APP_NAME}"
+        android:allowBackup="true"
+        android:supportsRtl="true"
+        android:theme="@style/Theme.App">
+
+        <activity
+            android:name=".MainActivity"
+            android:exported="true">
+
+            <intent-filter>
+                <action android:name="android.intent.action.MAIN"/>
+                <category android:name="android.intent.category.LAUNCHER"/>
+            </intent-filter>
+
+        </activity>
+
+    </application>
+
+</manifest>
+"""
+    )
+
+    write(
+        ROOT/"res/values/strings.xml",
+        """
+<?xml version="1.0" encoding="utf-8"?>
+<resources>
+<string name="app_name">Dolor3v</string>
+</resources>
+"""
+    )
+
+    write(
+        ROOT/"res/values/colors.xml",
+        """
+<?xml version="1.0" encoding="utf-8"?>
+<resources>
+<color name="black">#000000</color>
+<color name="white">#FFFFFF</color>
+</resources>
+"""
+    )
+
+    write(
+        ROOT/"res/values/themes.xml",
+        """
+<?xml version="1.0" encoding="utf-8"?>
+<resources>
+
+<style
+    name="Theme.App"
+    parent="android:Theme.Material.Light.NoActionBar"/>
+
+</resources>
+"""
+    )
+
+    java_path=ROOT/"src/com/dolor3v/app/MainActivity.java"
+
+    write(
+        java_path,
+        f"""
+package {PACKAGE};
+
+import android.app.Activity;
+import android.os.Bundle;
+import android.widget.TextView;
+
+public class MainActivity extends Activity {{
+
+    @Override
+    protected void onCreate(Bundle state) {{
+        super.onCreate(state);
+
+        TextView tv=new TextView(this);
+        tv.setText("Dolor3v APK Builder");
+        setContentView(tv);
+    }}
+
+}}
+"""
+    )
+
+    print(ROOT.resolve())
+
+if __name__=="__main__":
+    generate()

apk_workflow.py

@@ -0,0 +1,108 @@
+from __future__ import annotations
+
+import os
+import subprocess
+from pathlib import Path
+
+
+ANDROID_HOME = os.environ.get("ANDROID_HOME", "")
+BUILD_TOOLS = os.environ.get("ANDROID_BUILD_TOOLS", "35.0.0")
+JAVA_HOME = os.environ.get("JAVA_HOME", "")
+
+
+class APKWorkflow:
+
+    def __init__(self, project: str):
+        self.project = Path(project).resolve()
+
+    def run(self):
+        return {
+            "validate": self.validate(),
+            "compile_resources": self.compile_resources(),
+            "compile_java": self.compile_java(),
+            "dex": self.dex(),
+            "package": self.package(),
+            "zipalign": self.zipalign(),
+            "sign": self.sign()
+        }
+
+    def validate(self):
+        manifest = self.project / "AndroidManifest.xml"
+
+        if not manifest.exists():
+            return {
+                "ok": False,
+                "error": "AndroidManifest.xml missing"
+            }
+
+        return {"ok": True}
+
+    def compile_resources(self):
+
+        aapt2 = Path(ANDROID_HOME) / "build-tools" / BUILD_TOOLS / "aapt2"
+
+        if not aapt2.exists():
+            return {
+                "ok": False,
+                "error": "aapt2 missing"
+            }
+
+        return {"ok": True}
+
+    def compile_java(self):
+
+        javac = "javac"
+
+        try:
+            subprocess.run(
+                [javac, "-version"],
+                check=True,
+                capture_output=True
+            )
+            return {"ok": True}
+        except Exception as e:
+            return {
+                "ok": False,
+                "error": str(e)
+            }
+
+    def dex(self):
+
+        d8 = Path(ANDROID_HOME) / "build-tools" / BUILD_TOOLS / "d8"
+
+        return {
+            "ok": d8.exists()
+        }
+
+    def package(self):
+
+        aapt2 = Path(ANDROID_HOME) / "build-tools" / BUILD_TOOLS / "aapt2"
+
+        return {
+            "ok": aapt2.exists()
+        }
+
+    def zipalign(self):
+
+        exe = Path(ANDROID_HOME) / "build-tools" / BUILD_TOOLS / "zipalign"
+
+        return {
+            "ok": exe.exists()
+        }
+
+    def sign(self):
+
+        exe = Path(ANDROID_HOME) / "build-tools" / BUILD_TOOLS / "apksigner"
+
+        return {
+            "ok": exe.exists()
+        }
+
+
+if __name__ == "__main__":
+
+    import json
+
+    wf = APKWorkflow("android_project")
+
+    print(json.dumps(wf.run(), indent=2))

app_drive_upload.py

@@ -0,0 +1,82 @@
+import io
+import json
+import os
+from pathlib import Path
+
+from google.oauth2 import service_account
+from googleapiclient.discovery import build
+from googleapiclient.http import MediaIoBaseUpload
+
+
+SCOPES = [
+    "https://www.googleapis.com/auth/drive"
+]
+
+
+class DriveUploader:
+
+    def __init__(self):
+
+        service_json = os.environ["GDRIVE_SERVICE_ACCOUNT_JSON"]
+        folder_id = os.environ["GDRIVE_FOLDER_ID"]
+
+        self.folder_id = folder_id
+
+        credentials = service_account.Credentials.from_service_account_info(
+            json.loads(service_json),
+            scopes=SCOPES,
+        )
+
+        self.service = build(
+            "drive",
+            "v3",
+            credentials=credentials,
+            cache_discovery=False,
+        )
+
+    def upload(self, artifact: Path):
+
+        with artifact.open("rb") as fp:
+
+            media = MediaIoBaseUpload(
+                io.BytesIO(fp.read()),
+                mimetype="application/octet-stream",
+                resumable=False,
+            )
+
+            metadata = {
+                "name": artifact.name,
+                "parents": [
+                    self.folder_id
+                ],
+            }
+
+            created = (
+                self.service.files()
+                .create(
+                    body=metadata,
+                    media_body=media,
+                    fields="id,name,webViewLink,webContentLink",
+                )
+                .execute()
+            )
+
+        self.service.permissions().create(
+            fileId=created["id"],
+            body={
+                "type": "anyone",
+                "role": "reader",
+            },
+        ).execute()
+
+        return {
+            "id": created["id"],
+            "name": created["name"],
+            "download_url": (
+                f"https://drive.google.com/uc?export=download&id={created['id']}"
+            ),
+            "view_url": created.get("webViewLink"),
+        }
+
+
+drive_uploader = DriveUploader()

backend.log

@@ -0,0 +1,24 @@
+INFO:     Started server process [17813]
+INFO:     Waiting for application startup.
+ERROR:dolor3v-unified-backend:Failed to initialize Postgres pool. Falling back to memory: [Errno 111] Connection refused
+INFO:     Application startup complete.
+INFO:     Uvicorn running on http://0.0.0.0:8000 (Press CTRL+C to quit)
+INFO:     127.0.0.1:55224 - "GET /health HTTP/1.1" 200 OK
+INFO:     127.0.0.1:55228 - "GET /health HTTP/1.1" 200 OK
+INFO:     127.0.0.1:55238 - "GET /health HTTP/1.1" 200 OK
+INFO:     127.0.0.1:55252 - "GET /openapi.json HTTP/1.1" 200 OK
+INFO:     127.0.0.1:55262 - "GET /api/mcp HTTP/1.1" 200 OK
+INFO:     127.0.0.1:57966 - "GET /api/mcp/registry HTTP/1.1" 200 OK
+INFO:     127.0.0.1:57974 - "GET /api/mcp/runtime HTTP/1.1" 200 OK
+INFO:     127.0.0.1:57986 - "GET /api/discovery/servers HTTP/1.1" 200 OK
+INFO:     127.0.0.1:57988 - "GET /api/health HTTP/1.1" 200 OK
+INFO:httpx:HTTP Request: POST https://api.groq.com/openai/v1/chat/completions "HTTP/1.1 401 Unauthorized"
+WARNING:dolor3v-unified-backend:Provider groq failed: Groq 401: {"error":{"message":"Invalid API Key","type":"invalid_request_error","code":"invalid_api_key"}}
+
+INFO:httpx:HTTP Request: POST https://api.cerebras.ai/v1/chat/completions "HTTP/1.1 200 OK"
+INFO:     127.0.0.1:57996 - "POST /v1/chat/completions HTTP/1.1" 200 OK
+INFO:httpx:HTTP Request: POST https://api.cerebras.ai/v1/chat/completions "HTTP/1.1 200 OK"
+INFO:     127.0.0.1:42324 - "POST /api/builder/generate/component?name=OrderCard&description=Order%20Card&framework=react HTTP/1.1" 200 OK
+INFO:httpx:HTTP Request: POST https://api.cerebras.ai/v1/chat/completions "HTTP/1.1 200 OK"
+INFO:     127.0.0.1:48874 - "POST /api/builder/generate/api?endpoint_path=/orders&method=POST&description=Create%20Orders HTTP/1.1" 200 OK
+INFO:     127.0.0.1:48876 - "POST /api/builder/generate/project?prompt=Enterprise%20CRM&template=fastapi-react HTTP/1.1" 200 OK

backend.pid

@@ -0,0 +1 @@
+30838

builder_routes.py

@@ -0,0 +1,40 @@
+"""
+Production Builder Routes
+
+Wires the real AIBuilderService (backend/builder_api/service.py)
+into a mountable APIRouter. Component/API/Schema generation now
+call a real LLM via backend.models.gateway.model_gateway.
+"""
+
+from fastapi import APIRouter, Body
+
+from backend.builder_api.service import AIBuilderService
+
+router = APIRouter(prefix="/api/builder", tags=["Builder"])
+
+builder_service = AIBuilderService()
+
+
+@router.post("/generate/project")
+def generate_project_endpoint(prompt: str, template: str = "fastapi-react"):
+    return builder_service.generate_project(prompt, template)
+
+
+@router.post("/generate/component")
+async def generate_component_endpoint(name: str, description: str, framework: str = "react"):
+    return await builder_service.generate_component(name, description, framework)
+
+
+@router.post("/generate/api")
+async def generate_api_endpoint(endpoint_path: str, method: str = "GET", description: str = ""):
+    return await builder_service.generate_api(endpoint_path, method, description)
+
+
+@router.post("/generate/schema")
+async def generate_schema_endpoint(table_name: str, fields: list = Body(...)):
+    return await builder_service.generate_schema(table_name, fields)
+
+
+@router.post("/generate/pipeline")
+def generate_pipeline_endpoint(target: str = "docker"):
+    return builder_service.generate_pipeline(target)

bundle_parser.py

@@ -0,0 +1,143 @@
+"""
+bundle_parser.py
+
+Parses AI-generated multi-file bundles that use `// File: <path>` markers
+to separate individual files within a single LLM completion.
+Stdlib-only — no third-party dependencies.
+"""
+
+from __future__ import annotations
+
+import re
+import logging
+from dataclasses import dataclass, field
+from pathlib import PurePosixPath
+from typing import List, Optional, Tuple, Dict
+
+logger = logging.getLogger("bundle_parser")
+
+
+class BundleParseError(Exception):
+    """Raised when a bundle contains no recognizable file markers at all."""
+
+
+@dataclass
+class ParsedFile:
+    path: str
+    content: str
+    language: Optional[str] = None
+    warnings: List[str] = field(default_factory=list)
+
+
+@dataclass
+class ParseResult:
+    files: List[ParsedFile]
+    raw_marker_count: int
+    skipped: List[str] = field(default_factory=list)
+
+    @property
+    def ok(self) -> bool:
+        return len(self.files) > 0
+
+
+_FILE_MARKER_RE = re.compile(
+    r'''^[ \t]*(?://|\#|<!--)\s*File:\s*(?P<path>[^\n*]+?)\s*(?:-->)?\s*$''',
+    re.IGNORECASE | re.MULTILINE,
+)
+
+_FENCE_OPEN_RE = re.compile(r'^[ \t]*```[ \t]*([A-Za-z0-9_+-]*)[ \t]*$', re.MULTILINE)
+_FENCE_CLOSE_RE = re.compile(r'^[ \t]*```[ \t]*$')
+
+
+def _sanitize_path(raw_path: str) -> Optional[str]:
+    if not raw_path:
+        return None
+    path = raw_path.strip().strip('`').strip('"').strip("'")
+    path = path.replace('\\', '/')
+    while path.startswith('./'):
+        path = path[2:]
+    if not path or path.isspace():
+        return None
+    p = PurePosixPath(path)
+    if p.is_absolute():
+        return None
+    if '..' in p.parts:
+        return None
+    cleaned_parts = [part for part in p.parts if part not in ('', '.')]
+    if not cleaned_parts:
+        return None
+    return '/'.join(cleaned_parts)
+
+
+def _strip_fence(block: str) -> Tuple[str, Optional[str]]:
+    lines = block.split('\n')
+    start_idx = None
+    lang = None
+    for i, line in enumerate(lines):
+        m = _FENCE_OPEN_RE.match(line)
+        if m:
+            start_idx = i
+            lang = m.group(1) or None
+            break
+        if line.strip():
+            break
+    if start_idx is None:
+        return block.strip('\n'), None
+    end_idx = None
+    for j in range(start_idx + 1, len(lines)):
+        if _FENCE_CLOSE_RE.match(lines[j]):
+            end_idx = j
+            break
+    if end_idx is None:
+        content = '\n'.join(lines[start_idx + 1:])
+        return content.strip('\n'), lang
+    content = '\n'.join(lines[start_idx + 1:end_idx])
+    return content.strip('\n'), lang
+
+
+def parse_bundle(raw_text: str) -> ParseResult:
+    if not raw_text or not raw_text.strip():
+        raise BundleParseError("empty bundle: no text to parse")
+    markers = list(_FILE_MARKER_RE.finditer(raw_text))
+    if not markers:
+        raise BundleParseError("no '// File: <path>' markers found in bundle")
+
+    files: List[ParsedFile] = []
+    skipped: List[str] = []
+    seen_paths: Dict[str, int] = {}
+
+    for idx, match in enumerate(markers):
+        raw_path = match.group('path')
+        block_start = match.end()
+        block_end = markers[idx + 1].start() if idx + 1 < len(markers) else len(raw_text)
+        raw_block = raw_text[block_start:block_end]
+
+        safe_path = _sanitize_path(raw_path)
+        if safe_path is None:
+            skipped.append(raw_path.strip() if raw_path else '(empty path)')
+            logger.warning("bundle_parser: skipping unsafe/empty path %r", raw_path)
+            continue
+
+        content, lang = _strip_fence(raw_block)
+        warnings: List[str] = []
+        if not content.strip():
+            warnings.append("file body is empty after stripping markers/fences")
+        if content and not content.endswith('\n'):
+            content += '\n'
+        if safe_path in seen_paths:
+            warnings.append(f"duplicate path, overwriting earlier block #{seen_paths[safe_path]}")
+            files = [f for f in files if f.path != safe_path]
+        seen_paths[safe_path] = idx
+        files.append(ParsedFile(path=safe_path, content=content, language=lang, warnings=warnings))
+
+    return ParseResult(files=files, raw_marker_count=len(markers), skipped=skipped)
+
+
+def summarize(result: ParseResult) -> str:
+    lines = [f"Parsed {len(result.files)} file(s) from {result.raw_marker_count} marker(s)."]
+    for f in result.files:
+        tag = f" [{', '.join(f.warnings)}]" if f.warnings else ""
+        lines.append(f"  - {f.path} ({len(f.content)} bytes){tag}")
+    if result.skipped:
+        lines.append(f"Skipped {len(result.skipped)} unsafe/empty path(s): {result.skipped}")
+    return '\n'.join(lines)

capability_scanner.py

@@ -0,0 +1,54 @@
+import asyncio
+import json
+import httpx
+
+from remote_mcp_registry import list_servers
+
+INIT_REQUEST = {
+    "jsonrpc": "2.0",
+    "id": 1,
+    "method": "initialize",
+    "params": {
+        "protocolVersion": "2025-03-26",
+        "capabilities": {},
+        "clientInfo": {
+            "name": "dolor3v-mcp-core",
+            "version": "1.0.0"
+        }
+    }
+}
+
+async def scan():
+    results=[]
+
+    async with httpx.AsyncClient(timeout=20, follow_redirects=True) as client:
+        for server in list_servers():
+            item={
+                "id":server["id"],
+                "endpoint":server["endpoint"]
+            }
+
+            try:
+                r=await client.post(
+                    server["endpoint"],
+                    json=INIT_REQUEST,
+                    headers={"Content-Type":"application/json"}
+                )
+
+                item["http_status"]=r.status_code
+
+                try:
+                    item["response"]=r.json()
+                except Exception:
+                    item["response"]=r.text[:1000]
+
+            except Exception as e:
+                item["error"]=type(e).__name__
+                item["message"]=str(e)
+
+            results.append(item)
+
+    print(json.dumps(results,indent=2))
+
+if __name__=="__main__":
+    asyncio.run(scan())

check_env.py

@@ -0,0 +1,7 @@
+import os
+
+print("DATABASE_URL =", os.getenv("DATABASE_URL"))
+print("POSTGRES_SERVER =", os.getenv("POSTGRES_SERVER"))
+print("POSTGRES_PORT =", os.getenv("POSTGRES_PORT"))
+print("POSTGRES_USER =", os.getenv("POSTGRES_USER"))
+print("POSTGRES_DB =", os.getenv("POSTGRES_DB"))

compiler.py

@@ -0,0 +1,69 @@
+import asyncio
+import shutil
+import subprocess
+from pathlib import Path
+
+ANDROID_HOME = Path("/opt/android-sdk")
+GRADLE = shutil.which("gradle") or shutil.which("./gradlew")
+
+
+async def run(cmd, cwd=None):
+    process = await asyncio.create_subprocess_exec(
+        *cmd,
+        cwd=cwd,
+        stdout=asyncio.subprocess.PIPE,
+        stderr=asyncio.subprocess.STDOUT,
+    )
+
+    output = []
+
+    while True:
+        line = await process.stdout.readline()
+        if not line:
+            break
+        output.append(line.decode())
+
+    code = await process.wait()
+
+    return code, "".join(output)
+
+
+async def compile_android(project_dir: str):
+
+    project = Path(project_dir)
+
+    gradlew = project / "gradlew"
+
+    if gradlew.exists():
+        gradle = "./gradlew"
+    else:
+        gradle = GRADLE
+
+    if gradle is None:
+        raise RuntimeError("Gradle not installed")
+
+    code, log = await run(
+        [gradle, "assembleRelease"],
+        cwd=str(project)
+    )
+
+    if code != 0:
+        raise RuntimeError(log)
+
+    apk = next(
+        project.glob("**/outputs/apk/release/*.apk"),
+        None
+    )
+
+    aab = next(
+        project.glob("**/outputs/bundle/release/*.aab"),
+        None
+    )
+
+    if apk:
+        return str(apk)
+
+    if aab:
+        return str(aab)
+
+    raise RuntimeError("No APK or AAB generated")

db_patch.py

@@ -0,0 +1,105 @@
+import os
+import ssl
+import asyncpg
+from typing import Optional
+
+DATABASE_URL = os.environ.get("DATABASE_URL", "").strip()
+
+POSTGRES_SERVER = os.environ.get("POSTGRES_SERVER", "").strip()
+POSTGRES_PORT = int(os.environ.get("POSTGRES_PORT", "5432"))
+POSTGRES_USER = os.environ.get("POSTGRES_USER", "").strip()
+POSTGRES_PASSWORD = os.environ.get("POSTGRES_PASSWORD", "").strip()
+POSTGRES_DB = os.environ.get("POSTGRES_DB", "").strip()
+
+db_pool: Optional[asyncpg.Pool] = None
+
+
+async def init_db_pool() -> asyncpg.Pool:
+    """
+    Production database initialization.
+
+    Priority:
+        1. DATABASE_URL
+        2. POSTGRES_* variables
+    """
+
+    ssl_ctx = ssl.create_default_context()
+    ssl_ctx.check_hostname = False
+    ssl_ctx.verify_mode = ssl.CERT_NONE
+
+    if DATABASE_URL:
+        logger.info("Initializing PostgreSQL using DATABASE_URL")
+
+        pool = await asyncpg.create_pool(
+            dsn=DATABASE_URL,
+            ssl=ssl_ctx,
+            min_size=1,
+            max_size=5,
+            timeout=30,
+            command_timeout=60,
+            statement_cache_size=0,
+        )
+
+    else:
+        logger.info("Initializing PostgreSQL using POSTGRES_* variables")
+
+        pool = await asyncpg.create_pool(
+            host=POSTGRES_SERVER,
+            port=POSTGRES_PORT,
+            user=POSTGRES_USER,
+            password=POSTGRES_PASSWORD,
+            database=POSTGRES_DB,
+            ssl=ssl_ctx,
+            min_size=1,
+            max_size=5,
+            timeout=30,
+            command_timeout=60,
+            statement_cache_size=0,
+        )
+
+    async with pool.acquire() as conn:
+
+        await conn.execute("""
+        CREATE TABLE IF NOT EXISTS dolor3v_projects (
+            page_id TEXT PRIMARY KEY,
+            data JSONB NOT NULL,
+            created_at TIMESTAMPTZ DEFAULT now(),
+            updated_at TIMESTAMPTZ DEFAULT now()
+        )
+        """)
+
+        await conn.execute("""
+        CREATE TABLE IF NOT EXISTS dolor3v_assets (
+            id SERIAL PRIMARY KEY,
+            name TEXT NOT NULL,
+            url TEXT NOT NULL,
+            type TEXT NOT NULL,
+            created_at TIMESTAMPTZ DEFAULT now()
+        )
+        """)
+
+        await conn.execute("""
+        CREATE TABLE IF NOT EXISTS dolor3v_versions (
+            id SERIAL PRIMARY KEY,
+            project_id TEXT NOT NULL,
+            name TEXT NOT NULL,
+            data JSONB NOT NULL,
+            created_at TIMESTAMPTZ DEFAULT now()
+        )
+        """)
+
+        await conn.execute("""
+        CREATE TABLE IF NOT EXISTS dolor3v_builds (
+            id TEXT PRIMARY KEY,
+            project_id TEXT NOT NULL,
+            platform TEXT NOT NULL,
+            status TEXT NOT NULL,
+            logs TEXT NOT NULL,
+            download_url TEXT,
+            created_at TIMESTAMPTZ DEFAULT now()
+        )
+        """)
+
+    logger.info("Database pool initialized successfully.")
+
+    return pool