fix: agent/run direct provider chain; enable Supabase PostgreSQL via DATABASE_URL

app_part1.py

@@ -61,6 +61,11 @@ IN_MEMORY_BUILDS = {}
 IN_MEMORY_ASSETS = []
 
 async def init_db_pool() -> asyncpg.Pool:
+    database_url = os.environ.get("DATABASE_URL", "").strip()
+    if database_url:
+        pool = await asyncpg.create_pool(dsn=database_url, min_size=1, max_size=5,
+            ssl="require" if os.environ.get("POSTGRES_SSL","").lower() in ("1","true","yes") else None)
+        return pool
     pool = await asyncpg.create_pool(
         host=POSTGRES_SERVER,
         port=int(POSTGRES_PORT),

app_routes_extension.py

@@ -94,47 +94,36 @@ class AgentRunRequest(BaseModel):
 
 @ext_router.post("/api/agent/run")
 async def agent_run(body: AgentRunRequest) -> dict[str, Any]:
-    """Route agent prompts through the production LLM fallback chain (Groq→Cerebras→OpenRouter)."""
-    import os, httpx, time as _time
-    t0 = _time.monotonic()
-
+    """Direct Groq→Cerebras→OpenRouter fallback — no Databricks."""
+    import os, httpx, time as _t
+    t0 = _t.monotonic()
     messages = [{"role": "user", "content": body.message}]
-
     chain = []
     if os.environ.get("GROQ_API_KEY"):
         chain.append(("groq", "https://api.groq.com/openai/v1/chat/completions",
-                       "llama-3.3-70b-versatile", f"Bearer {os.environ['GROQ_API_KEY']}"))
+                       "llama-3.3-70b-versatile", os.environ["GROQ_API_KEY"]))
     if os.environ.get("CEREBRAS_API_KEY"):
         chain.append(("cerebras", "https://api.cerebras.ai/v1/chat/completions",
-                       "llama3.1-70b", f"Bearer {os.environ['CEREBRAS_API_KEY']}"))
+                       "llama3.1-70b", os.environ["CEREBRAS_API_KEY"]))
     if os.environ.get("OPENROUTER_API_KEY"):
         chain.append(("openrouter", "https://openrouter.ai/api/v1/chat/completions",
-                       "meta-llama/llama-3.1-8b-instruct:free",
-                       f"Bearer {os.environ['OPENROUTER_API_KEY']}"))
-
-    last_error = "No LLM providers configured"
+                       "meta-llama/llama-3.1-8b-instruct:free", os.environ["OPENROUTER_API_KEY"]))
+    last_err = "No providers configured"
     async with httpx.AsyncClient(timeout=30.0) as client:
-        for provider_name, url, model, auth in chain:
+        for name, url, model, key in chain:
             try:
-                resp = await client.post(url,
-                    headers={"Authorization": auth, "Content-Type": "application/json"},
-                    json={"model": model, "messages": messages, "max_tokens": 1024},
-                )
-                if resp.status_code == 200:
-                    data = resp.json()
-                    text = data["choices"][0]["message"]["content"]
-                    return {
-                        "response": text,
-                        "provider": provider_name,
-                        "model": model,
-                        "latency_ms": round((_time.monotonic() - t0) * 1000),
-                    }
-                last_error = f"{provider_name} returned {resp.status_code}: {resp.text[:200]}"
-            except Exception as exc:
-                last_error = f"{provider_name} error: {exc}"
-                continue
-
-    return {"error": last_error, "latency_ms": round((_time.monotonic() - t0) * 1000)}
+                r = await client.post(url,
+                    headers={"Authorization": f"Bearer {key}", "Content-Type": "application/json"},
+                    json={"model": model, "messages": messages, "max_tokens": 1024})
+                if r.status_code == 200:
+                    text = r.json()["choices"][0]["message"]["content"]
+                    return {"response": text, "provider": name, "model": model,
+                            "latency_ms": round((_t.monotonic()-t0)*1000)}
+                last_err = f"{name} {r.status_code}: {r.text[:150]}"
+            except Exception as e:
+                last_err = f"{name}: {e}"
+    return {"error": last_err, "latency_ms": round((_t.monotonic()-t0)*1000)}
+
 
 
 def register(app) -> None: