Clean fix: no auth, just proxy

app.py

@@ -9,15 +9,11 @@ from fastapi.responses import JSONResponse, StreamingResponse, Response
 
 app = FastAPI()
 
-# ─────────────────────────────
 # CONFIG
-# ─────────────────────────────
 MASTER_API_KEY = os.getenv("MASTER_API_KEY", "changeme")
 BASE_URL = os.getenv("BASE_URL", "https://ollama.com")
 
-# ─────────────────────────────
 # LOAD KEYS
-# ─────────────────────────────
 def load_keys(prefix="OLLAMA_KEY_"):
     keys = []
     for k, v in os.environ.items():
@@ -26,41 +22,19 @@ def load_keys(prefix="OLLAMA_KEY_"):
     return keys
 
 API_KEYS = load_keys()
-print(f"[INIT] KEYS_LOADED: {len(API_KEYS)}, keys={[(k[:6]+chr(42)*4) if len(k)>10 else k for k in API_KEYS]}")
-
-# ─────────────────────────────
-# STATE
-# ─────────────────────────────
-key_status: Dict[str, Dict] = {
-    k: {"fail": 0, "cooldown": 0, "status": "active"}
-    for k in API_KEYS
-}
-
-# ─────────────────────────────
-# AUTH - Accept valid backend key OR master key
-# ─────────────────────────────
+print(f"[INIT] Keys: {len(API_KEYS)}")
+
+key_status = {k: {"fail": 0, "cooldown": 0, "status": "active"} for k in API_KEYS}
+
+# AUTH - ACCEPT ALL
 def auth(req: Request):
-    auth_header = req.headers.get("Authorization", "").replace("Bearer ", "")
-    # DEBUG - show what's happening
-    print(f"[AUTH] client={auth_header[:10]}, master={MASTER_API_KEY[:10]}, keys_count={len(API_KEYS)}")
-    # Accept any key for testing
-    print(f"[AUTH] ALLOWING ALL")
     return
 
-# ─────────────────────────────
-# KEY PICKER
-# ─────────────────────────────
 def pick_key():
     now = time.time()
-    valid = [
-        k for k, v in key_status.items()
-        if v["status"] != "dead" and v["cooldown"] < now
-    ]
+    valid = [k for k, v in key_status.items() if v["status"] != "dead" and v["cooldown"] < now]
     return random.choice(valid) if valid else None
 
-# ─────────────────────────────
-# STATUS HANDLER
-# ─────────────────────────────
 def mark_limit(k):
     key_status[k]["cooldown"] = time.time() + 60
     key_status[k]["status"] = "limited"
@@ -72,9 +46,6 @@ def mark_ok(k):
     key_status[k]["fail"] = 0
     key_status[k]["status"] = "active"
 
-# ─────────────────────────────
-# UNIVERSAL OPENAI PROXY (/v1/*)
-# ─────────────────────────────
 @app.api_route("/v1/{path:path}", methods=["GET", "POST", "PUT", "DELETE"])
 async def proxy(req: Request, path: str):
     auth(req)
@@ -92,11 +63,10 @@ async def proxy(req: Request, path: str):
             return JSONResponse({"error": "all keys failed"}, status_code=503)
 
         headers["Authorization"] = f"Bearer {key}"
-        print(f"[PROXY] trying key={key[:15]}... -> {BASE_URL}")
+        print(f"[PROXY] key={key[:6]}.. url={target_url}")
 
         try:
             async with httpx.AsyncClient(timeout=60) as client:
-                # Validate request first
                 test = await client.request(
                     method=req.method,
                     url=target_url,
@@ -113,17 +83,11 @@ async def proxy(req: Request, path: str):
                         if key_status[key]["fail"] >= 3:
                             mark_dead(key)
                         continue
-                    
                     mark_ok(key)
-                    return Response(
-                        content=test.content,
-                        status_code=test.status_code,
-                        headers=dict(test.headers)
-                    )
+                    return Response(content=test.content, status_code=test.status_code, headers=dict(test.headers))
 
                 mark_ok(key)
 
-                # Stream response
                 stream = await client.stream(
                     method=req.method,
                     url=target_url,
@@ -138,29 +102,14 @@ async def proxy(req: Request, path: str):
                 )
 
         except Exception as e:
-            import traceback
             key_status[key]["fail"] += 1
             if key_status[key]["fail"] >= 3:
                 mark_dead(key)
-            print(f"[ERROR] key={key[:15]} -> {type(e).__name__}: {e}")
-            print(f"[TRACE] {traceback.format_exc()}")
+            print(f"[ERROR] {type(e).__name__}: {e}")
             continue
 
-    return JSONResponse(
-        {"error": "all keys failed", "hint": "check keys / model access / BASE_URL"},
-        status_code=500
-    )
+    return JSONResponse({"error": "all keys failed"}, status_code=500)
 
-# ─────────────────────────────
-# HEALTH CHECK
-# ─────────────────────────────
 @app.get("/")
 def root():
-    active = sum(1 for v in key_status.values() if v["status"] == "active")
-    return {
-        "status": "ok",
-        "mode": "openai-proxy-fixed",
-        "keys": len(API_KEYS),
-        "active": active
-    }
-# Debug build
+    return {"status": "ok", "keys": len(API_KEYS)}