Update server.js

server.js

@@ -7,71 +7,64 @@ const app = express();
 const PORT = 7860;
 
 // --- CONFIGURACIÓN DE SEGURIDAD Y PRIVACIDAD ---
+// CRÍTICO: Confiar en el proxy es necesario para que req.ip lea la IP real del usuario y no la de Cloudflare/Host
 app.set('trust proxy', 1);
-app.disable('x-powered-by'); // Oculta que estamos usando Express
+app.disable('x-powered-by'); 
 app.use(cors());
 
-// Inyección de cabeceras de seguridad estándar
 app.use((req, res, next) => {
     res.setHeader('X-Content-Type-Options', 'nosniff');
     res.setHeader('X-Frame-Options', 'DENY');
     res.setHeader('X-XSS-Protection', '1; mode=block');
     res.setHeader('Strict-Transport-Security', 'max-age=31536000; includeSubDomains');
-    res.setHeader('Referrer-Policy', 'no-referrer'); // Protege la privacidad del origen
+    res.setHeader('Referrer-Policy', 'no-referrer');
     next();
 });
 
-// Aumentar límite a 50mb para soportar imágenes en Base64 (Visión / Multimodal)
 app.use(express.json({ limit: '50mb' }));
 app.use(express.urlencoded({ limit: '50mb', extended: true }));
 
-// --- FUNCIÓN DE LOGS (Sanitizada) ---
 function logError(providerId, reason) {
     const timestamp = new Date().toISOString();
-    // No guardamos IPs ni prompts de usuarios, solo el estado de nuestros proveedores
     console.error(`[${timestamp}] [ERROR] Proveedor: ${providerId} | Motivo: ${reason}`);
 }
 
-// --- CONFIGURACIÓN DE PROVEEDORES ---
+// --- NUEVOS PROVEEDORES PÚBLICOS (SIN API KEY) ---
+// Se eliminaron los HF Spaces. Se añaden endpoints gratuitos compatibles con OpenAI.
 const PROVIDERS = [
     { 
-        id: "oai", 
-        url: "https://oai.endpoints.kepler.ai.cloud.ovh.net/v1/chat/completions" 
+        id: "pollinations-ai", 
+        url: "https://text.pollinations.ai/openai/v1/chat/completions",
+        modelsUrl: "https://text.pollinations.ai/openai/models"
     },
     { 
-        id: "ventarys-mirror", 
-        url: "https://arliai.com/v1/chat/completions", 
-        proxySecret: "sk-52650650a50f0v10vg150vs0v" 
-    },
-  { 
-        id: "ventarys-mirror-2", 
-        url: "https://Juanoto2012-mirror-2.hf.space/v1/chat/completions", 
-        proxySecret: "sk-52650650a50f0v10vg150vs0v" 
+        id: "kepler-cloud", 
+        url: "https://oai.endpoints.kepler.ai.cloud.ovh.net/v1/chat/completions" 
     }
 ];
 
-const MAX_PER_PROVIDER = 3; 
+// Hemos subido el límite drásticamente. Ahora el proxy no será el cuello de botella.
+// El límite real lo dictarán los proveedores según la IP que les reenviemos.
+const MAX_PER_PROVIDER = 100; 
 const QUEUE_TIMEOUT = 25000; 
-let currentLoad = { "oai": 0, "ventarys-mirror": 0 , "ventarys-mirror-2": 0 };
+let currentLoad = { "pollinations-ai": 0, "kepler-cloud": 0 };
 
-// --- RATE LIMITING (Basado en la IP real del usuario) ---
+// --- RATE LIMITING LOCAL (Protección de tu propio servidor) ---
 const limiter = rateLimit({
     windowMs: 60 * 1000, 
-    max: 25, 
+    max: 50, // Aumentado a 50 peticiones por minuto por IP
     keyGenerator: (req) => req.ip, 
-    message: { error: { message: "Límite de solicitudes alcanzado. Por favor, espera un momento.", code: 429 } },
+    message: { error: { message: "Estás enviando demasiadas peticiones. Espera un momento.", code: 429 } },
     standardHeaders: true,
     legacyHeaders: false,
 });
 
-// --- AYUDANTES PARA FILTRAR MODELOS ---
 const IMAGE_KEYWORDS = ["flux", "dall", "midjourney", "sdxl", "stable-diffusion", "image", "vision"];
-const AUDIO_KEYWORDS = ["suno", "udio", "music", "audio", "song", "voice", "tts", "whisper",];
+const AUDIO_KEYWORDS = ["suno", "udio", "music", "audio", "song", "voice", "tts", "whisper"];
 
 function isImageModel(model) {
     if (!model) return false;
     if (model.type === 'image' || model.supports_images === true) return true;
-    
     const id = (model.id || model.name || "").toLowerCase();
     return IMAGE_KEYWORDS.some(kw => id.includes(kw));
 }
@@ -87,9 +80,6 @@ async function fetchAllModels() {
         const modelsUrl = provider.modelsUrl || provider.url.replace("/chat/completions", "/models");
         const fetchHeaders = { "Content-Type": "application/json" };
         
-        if (provider.apiKey) fetchHeaders["Authorization"] = `Bearer ${provider.apiKey}`;
-        if (provider.proxySecret) fetchHeaders["X-Proxy-Secret"] = provider.proxySecret;
-        
         try {
             const resp = await fetch(modelsUrl, { method: "GET", headers: fetchHeaders });
             if (!resp.ok) return [];
@@ -102,17 +92,7 @@ async function fetchAllModels() {
             
             if (modelsArray.length > 0) {
                 return modelsArray
-                    // 1. Filtrar modelos de audio/música
                     .filter(model => !isAudioModel(model))
-                    // 2. CRÍTICO: Permitir estrictamente modelos con precio 0 (si la API reporta el precio)
-                    .filter(model => {
-                        if (model.pricepermilliontokens !== undefined && model.pricepermilliontokens !== null) {
-                            return model.pricepermilliontokens === 0;
-                        }
-                        // Si el proveedor (ej. llm7) no envía el campo de precio, lo asumimos como válido
-                        return true;
-                    })
-                    // 3. Procesar y formatear campos
                     .map(model => ({
                         ...model,
                         id: model.id || model.name,
@@ -130,10 +110,18 @@ async function fetchAllModels() {
     results.forEach(result => {
         if (result.status === "fulfilled") allModels = allModels.concat(result.value);
     });
+    
+    // Fallback: Si los proveedores gratuitos fallan al devolver la lista, inyectamos modelos estándar
+    if (allModels.length === 0) {
+        allModels = [
+            { id: "gpt-4o", object: "model", type: "text", owned_by: "pollinations-ai" },
+            { id: "claude-3-5-sonnet", object: "model", type: "text", owned_by: "pollinations-ai" }
+        ];
+    }
+    
     return allModels;
 }
 
-// --- RUTAS INFORMATIVAS ---
 app.get('/health', (req, res) => {
     res.json({ 
         status: "online", 
@@ -143,11 +131,9 @@ app.get('/health', (req, res) => {
     });
 });
 
-// Endpoint para modelos de TEXTO
 app.get('/v1/models', async (req, res) => {
     try {
         const allModels = await fetchAllModels();
-        
         const textModels = allModels
             .filter(m => !isImageModel(m) && m.supports_chat !== false)
             .map(m => {
@@ -162,11 +148,9 @@ app.get('/v1/models', async (req, res) => {
     }
 });
 
-// Endpoint para modelos de IMAGEN
 app.get('/v1/images/models', async (req, res) => {
     try {
         const allModels = await fetchAllModels();
-        
         let imageModels = allModels
             .filter(m => isImageModel(m))
             .map(m => {
@@ -192,17 +176,21 @@ app.get('/v1/images/models', async (req, res) => {
     }
 });
 
-// --- RUTA PRINCIPAL DE GENERACIÓN ---
 app.post(['/v1/chat/completions', '/v1/images/generations'], limiter, async (req, res) => {
     const isImage = req.path === '/v1/images/generations';
-    
     let availableProviders = isImage ? PROVIDERS.filter(p => p.imageUrl) : [...PROVIDERS];
+    
+    // Respaldo por si ningún proveedor declara explícitamente soportar imágenes
+    if (isImage && availableProviders.length === 0) availableProviders = [...PROVIDERS];
+    
     const startTime = Date.now();
     let responseSent = false;
     
+    // Capturamos la IP real del usuario
+    const clientIp = req.ip || req.headers['x-forwarded-for'] || req.connection.remoteAddress;
+    
     while (availableProviders.length > 0 && Date.now() - startTime < QUEUE_TIMEOUT) {
         let selectedProvider = null;
-        
         let shuffled = [...availableProviders].sort(() => Math.random() - 0.5);
         
         for (let provider of shuffled) {
@@ -227,28 +215,29 @@ app.post(['/v1/chat/completions', '/v1/images/generations'], limiter, async (req
         };
         
         try {
-            let targetUrl = isImage ? selectedProvider.imageUrl : selectedProvider.url;
-            let reqMethod = "POST";
-            let reqBody = JSON.stringify(req.body);
-            const fetchHeaders = { "Content-Type": "application/json" };
+            let targetUrl = isImage && selectedProvider.imageUrl ? selectedProvider.imageUrl : selectedProvider.url;
             
-            if (selectedProvider.apiKey) fetchHeaders["Authorization"] = `Bearer ${selectedProvider.apiKey}`;
-            if (selectedProvider.proxySecret) fetchHeaders["X-Proxy-Secret"] = selectedProvider.proxySecret;
+            // Reenviar la IP del usuario en las cabeceras para aislar los rate limits
+            const fetchHeaders = { 
+                "Content-Type": "application/json",
+                "X-Forwarded-For": clientIp,
+                "X-Real-IP": clientIp,
+                "True-Client-IP": clientIp
+            };
             
             const response = await fetch(targetUrl, {
-                method: reqMethod,
+                method: "POST",
                 headers: fetchHeaders,
-                body: reqBody
+                body: JSON.stringify(req.body)
             });
             
             if (!response.ok) {
-                logError(selectedProvider.id, `Fallo con código HTTP ${response.status}`);
+                logError(selectedProvider.id, `Fallo HTTP ${response.status} (Posible Rate Limit a la IP ${clientIp})`);
                 releaseSlot();
                 availableProviders = availableProviders.filter(p => p.id !== selectedProvider.id);
                 continue; 
             }
             
-            // Sanitización: Evitar devolver cookies o cabeceras de servidor del proveedor original
             const responseHeaders = new Headers(response.headers);
             responseHeaders.delete('set-cookie');
             responseHeaders.delete('server');
@@ -260,11 +249,8 @@ app.post(['/v1/chat/completions', '/v1/images/generations'], limiter, async (req
                 
                 if (contentType.includes("application/json")) {
                     const jsonResp = await response.json();
-                    
                     let dataArray = jsonResp.data;
-                    if (!dataArray && jsonResp.url) {
-                        dataArray = [{ url: jsonResp.url }];
-                    }
+                    if (!dataArray && jsonResp.url) dataArray = [{ url: jsonResp.url }];
                     
                     if (dataArray && Array.isArray(dataArray)) {
                         for (let item of dataArray) {
@@ -343,11 +329,11 @@ app.post(['/v1/chat/completions', '/v1/images/generations'], limiter, async (req
     }
     
     if (!responseSent) {
-        logError("ProxyMain", "Todos los proveedores fallaron o se agotó el tiempo de espera.");
-        return res.status(503).json({ error: { message: "El servicio no está disponible temporalmente. Inténtalo de nuevo.", code: 503 } });
+        logError("ProxyMain", "Todos los proveedores fallaron.");
+        return res.status(503).json({ error: { message: "El servicio no está disponible temporalmente.", code: 503 } });
     }
 });
 
 app.listen(PORT, '0.0.0.0', () => {
-    console.log(`🚀 API Proxy (Node.js) corriendo seguro en el puerto ${PORT}`);
+    console.log(`🚀 API Proxy corriendo seguro en el puerto ${PORT}`);
 });