import os, random, httpx, uvicorn from fastapi import FastAPI, Request, Response from fastapi.responses import HTMLResponse app = FastAPI() # 🛡️ Pool de 15 Chaves - Carregamento Seguro KEYS = [os.getenv(f"OR_KEY_{i}") for i in range(1, 16)] KEYS = [k.strip() for k in KEYS if k and k.strip()] # 🧠 MAPEAMENTO DE ELITE (Roteamento por Projeto) MODEL_MAP = { "gpt-4o": "qwen/qwen3-coder:free", "vitalis": "google/gemini-2.0-pro-exp-02-05:free", "nexos": "qwen/qwen3-coder:free", "nutrilens": "google/gemini-2.0-flash-lite-preview-02-05:free", "default": "qwen/qwen3-coder:free" } @app.get("/", response_class=HTMLResponse) async def root(): status_color = "#00ff00" if KEYS else "#ff0000" return f"""

🛡️ Escudo Fortune Ativo

{len(KEYS)} chaves operacionais no sistema.

Status: Roteador AI e Ponte Telegram Operacionais.

""" # 1️⃣ ROTA DO CÉREBRO (Modelos de IA) @app.post("/v1/chat/completions") async def proxy(request: Request): if not KEYS: return Response(content='{"error": "Nenhuma chave configurada nos Secrets!"}', status_code=500) try: body = await request.json() msg_content = str(body.get("messages", "")).lower() # 🛰️ Roteador Inteligente de Projetos target = MODEL_MAP["gpt-4o"] if "vitalis" in msg_content: target = MODEL_MAP["vitalis"] elif "nexos" in msg_content: target = MODEL_MAP["nexos"] elif "nutrilens" in msg_content: target = MODEL_MAP["nutrilens"] body["model"] = target selected_key = random.choice(KEYS).strip() headers = { "Authorization": f"Bearer {selected_key}", "X-Title": "Aria_Sovereign_System", "HTTP-Referer": "https://fortune-dev-moz.io", "Content-Type": "application/json" } async with httpx.AsyncClient() as client: resp = await client.post( "https://openrouter.ai/api/v1/chat/completions", json=body, headers=headers, timeout=60.0 ) # 🚨 Modo de Emergência if resp.status_code != 200: print(f"⚠️ Erro {resp.status_code} na chave atual. Tentando emergência...") body["model"] = "openrouter/free" new_key = random.choice(KEYS).strip() headers["Authorization"] = f"Bearer {new_key}" resp = await client.post( "https://openrouter.ai/api/v1/chat/completions", json=body, headers=headers, timeout=60.0 ) return Response(content=resp.content, status_code=resp.status_code) except Exception as e: print(f"🔥 Erro Crítico: {str(e)}") return Response(content=f'{{"error": "{str(e)}"}}', status_code=500) # 2️⃣ ROTA DA BOCA/OUVIDOS (Ponte de Rede para o Telegram) @app.api_route("/bot{token}/{method_name}", methods=["GET", "POST"]) async def telegram_proxy(request: Request, token: str, method_name: str): target_url = f"https://api.telegram.org/bot{token}/{method_name}" try: async with httpx.AsyncClient() as client: if request.method == "POST": body = await request.body() headers = {"Content-Type": request.headers.get("content-type", "application/json")} resp = await client.post(target_url, content=body, headers=headers, timeout=60.0) else: resp = await client.get(target_url, params=request.query_params, timeout=60.0) return Response(content=resp.content, status_code=resp.status_code) except Exception as e: print(f"🔥 Erro na Ponte Telegram: {str(e)}") return Response(content=f'{{"ok": false, "error_code": 500, "description": "Erro no Escudo: {str(e)}"}}', status_code=500) if __name__ == "__main__": uvicorn.run(app, host="0.0.0.0", port=7860)