From e90bc209c047060d79ca81a2c6171ff4b8b09b1c Mon Sep 17 00:00:00 2001
From: marsalva <info@marsalva.es>
Date: Sun, 28 Dec 2025 20:07:10 +0000
Subject: [PATCH] Actualizar robot_cobros.js

---
 robot_cobros.js | 102 +++++++++++++++++++++++++++++-------------------
 1 file changed, 61 insertions(+), 41 deletions(-)

diff --git a/robot_cobros.js b/robot_cobros.js
index 52fc909..ceeb40e 100644
--- a/robot_cobros.js
+++ b/robot_cobros.js
@@ -1,69 +1,89 @@
 const express = require('express');
+const cors = require('cors');
 const { chromium } = require('playwright');
 const admin = require('firebase-admin');
-const cors = require('cors');
 
-// --- CONFIGURACIÓN FIREBASE ---
+// --- FIREBASE ---
 try {
-    if (process.env.FIREBASE_PRIVATE_KEY) {
-        if (!admin.apps.length) {
-            admin.initializeApp({
-                credential: admin.credential.cert({
-                    projectId: process.env.FIREBASE_PROJECT_ID,
-                    clientEmail: process.env.FIREBASE_CLIENT_EMAIL,
-                    privateKey: process.env.FIREBASE_PRIVATE_KEY.replace(/\\n/g, '\n'),
-                }),
-            });
-        }
-        console.log("✅ Firebase inicializado.");
+  if (process.env.FIREBASE_PRIVATE_KEY) {
+    if (!admin.apps.length) {
+      admin.initializeApp({
+        credential: admin.credential.cert({
+          projectId: process.env.FIREBASE_PROJECT_ID,
+          clientEmail: process.env.FIREBASE_CLIENT_EMAIL,
+          privateKey: process.env.FIREBASE_PRIVATE_KEY.replace(/\\n/g, '\n'),
+        }),
+      });
     }
-} catch (e) { console.error("❌ Error Firebase:", e.message); }
+    console.log("✅ Firebase inicializado.");
+  } else {
+    console.log("⚠️ FIREBASE_PRIVATE_KEY no está seteada. Firebase OFF.");
+  }
+} catch (e) {
+  console.error("❌ Error Firebase:", e.message);
+}
 
 const db = admin.apps.length ? admin.firestore() : null;
-const COLLECTION_NAME = "homeserve_pendientes"; 
+const COLLECTION_NAME = "homeserve_pendientes";
 
 const app = express();
 
-// --- 🛡️ CORRECCIÓN CORS DEFINITIVA 🛡️ ---
+// --- CORS (robusto) ---
 app.use(cors({
-    origin: '*', // Permitir todo
-    methods: ['GET', 'POST', 'OPTIONS'], // Permitir estos métodos
-    allowedHeaders: ['Content-Type', 'Authorization'] // Permitir estas cabeceras
+  origin: '*',
+  methods: ['GET', 'POST', 'OPTIONS'],
+  allowedHeaders: ['Content-Type', 'Authorization'],
 }));
 
-// Forzar respuesta OK a las peticiones OPTIONS (Preflight)
-app.options('*', cors());
+// IMPORTANTÍSIMO: responder preflight
+app.options('*', (req, res) => {
+  res.header("Access-Control-Allow-Origin", "*");
+  res.header("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept, Authorization");
+  res.header("Access-Control-Allow-Methods", "GET, POST, OPTIONS");
+  return res.sendStatus(204);
+});
 
 app.use(express.json());
 
-// RUTA DE TEST
+// TEST
 app.get('/', (req, res) => {
-    res.send('🤖 El Robot de Cobros está ONLINE y esperando órdenes.');
+  res.status(200).send('🤖 El Robot de Cobros está ONLINE y esperando órdenes.');
 });
 
-// RUTA DEL ROBOT
+app.get('/health', (req, res) => {
+  res.status(200).json({ ok: true, firebase: !!db, ts: new Date().toISOString() });
+});
+
+// ROBOT
 app.post('/api/robot-cobros', async (req, res) => {
-    console.log("🔔 Petición POST recibida correctamente.");
-    res.json({ success: true, message: "Orden recibida. Iniciando..." });
-    
-    // Ejecutar en segundo plano
-    runRobotLogic().catch(err => console.error("❌ Error en lógica robot:", err));
+  console.log("🔔 POST /api/robot-cobros recibido.");
+
+  // Respuesta inmediata para que el navegador no espere
+  res.status(200).json({ success: true, message: "Orden recibida. Iniciando..." });
+
+  // Ejecutar en segundo plano
+  try {
+    await runRobotLogic();
+  } catch (err) {
+    console.error("❌ Error robot:", err?.message || err);
+  }
 });
 
 async function runRobotLogic() {
-    console.log("🚀 Lanzando navegador (Simulación)...");
-    let browser = null;
-    try {
-        // AQUÍ VA TU LÓGICA DE PLAYWRIGHT (Puedes pegar la que tenías antes si quieres la real)
-        // De momento dejamos esto para probar la conexión
-        await new Promise(resolve => setTimeout(resolve, 2000));
-        console.log("✅ Proceso simulado terminado.");
-    } catch (e) {
-        console.error(e);
-    }
+  console.log("🚀 runRobotLogic() arrancando...");
+
+  // Si aquí tu lógica usa Firebase, asegúrate:
+  // if (!db) throw new Error("Firebase no inicializado (faltan env vars)");
+
+  // Ejemplo mínimo
+  // const browser = await chromium.launch({ headless: true });
+  // ...
+  // await browser.close();
+
+  console.log("✅ runRobotLogic() terminado (simulación).");
 }
 
-const PORT = process.env.PORT || 3000;
+const PORT = process.env.PORT || process.env.CAPROVER_PORT || 3000;
 app.listen(PORT, () => {
-    console.log(`🚀 Servidor escuchando en puerto ${PORT}`);
+  console.log(`🚀 Servidor escuchando en puerto ${PORT}`);
 });
\ No newline at end of file