marsalva
/
cobros-hs
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Actualizar robot_cobros.js

This commit is contained in:
marsalva 2025-12-28 20:07:10 +00:00
parent 140a7da912
commit e90bc209c0
1 changed files with 61 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

102
robot_cobros.js
View File

@ -1,69 +1,89 @@
const express = require('express'); const express = require('express');
const cors = require('cors');
const { chromium } = require('playwright'); const { chromium } = require('playwright');
const admin = require('firebase-admin'); const admin = require('firebase-admin');
const cors = require('cors');
// --- CONFIGURACIÓN FIREBASE --- // --- FIREBASE ---
try { try {
if (process.env.FIREBASE_PRIVATE_KEY) { if (process.env.FIREBASE_PRIVATE_KEY) {
if (!admin.apps.length) { if (!admin.apps.length) {
admin.initializeApp({ admin.initializeApp({
credential: admin.credential.cert({ credential: admin.credential.cert({
projectId: process.env.FIREBASE_PROJECT_ID, projectId: process.env.FIREBASE_PROJECT_ID,
clientEmail: process.env.FIREBASE_CLIENT_EMAIL, clientEmail: process.env.FIREBASE_CLIENT_EMAIL,
privateKey: process.env.FIREBASE_PRIVATE_KEY.replace(/\\n/g, '\n'), privateKey: process.env.FIREBASE_PRIVATE_KEY.replace(/\\n/g, '\n'),
}), }),
}); });
}
console.log("✅ Firebase inicializado.");
} }
} 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 db = admin.apps.length ? admin.firestore() : null;
const COLLECTION_NAME = "homeserve_pendientes"; const COLLECTION_NAME = "homeserve_pendientes";
const app = express(); const app = express();
// --- 🛡️ CORRECCIÓN CORS DEFINITIVA 🛡️ --- // --- CORS (robusto) ---
app.use(cors({ app.use(cors({
origin: '*', // Permitir todo origin: '*',
methods: ['GET', 'POST', 'OPTIONS'], // Permitir estos métodos methods: ['GET', 'POST', 'OPTIONS'],
allowedHeaders: ['Content-Type', 'Authorization'] // Permitir estas cabeceras allowedHeaders: ['Content-Type', 'Authorization'],
})); }));
// Forzar respuesta OK a las peticiones OPTIONS (Preflight) // IMPORTANTÍSIMO: responder preflight
app.options('*', cors()); 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()); app.use(express.json());
// RUTA DE TEST // TEST
app.get('/', (req, res) => { 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) => { app.post('/api/robot-cobros', async (req, res) => {
console.log("🔔 Petición POST recibida correctamente."); console.log("🔔 POST /api/robot-cobros recibido.");
res.json({ success: true, message: "Orden recibida. Iniciando..." });
// Respuesta inmediata para que el navegador no espere
// Ejecutar en segundo plano res.status(200).json({ success: true, message: "Orden recibida. Iniciando..." });
runRobotLogic().catch(err => console.error("❌ Error en lógica robot:", err));
// Ejecutar en segundo plano
try {
await runRobotLogic();
} catch (err) {
console.error("❌ Error robot:", err?.message || err);
}
}); });
async function runRobotLogic() { async function runRobotLogic() {
console.log("🚀 Lanzando navegador (Simulación)..."); console.log("🚀 runRobotLogic() arrancando...");
let browser = null;
try { // Si aquí tu lógica usa Firebase, asegúrate:
// AQUÍ VA TU LÓGICA DE PLAYWRIGHT (Puedes pegar la que tenías antes si quieres la real) // if (!db) throw new Error("Firebase no inicializado (faltan env vars)");
// De momento dejamos esto para probar la conexión
await new Promise(resolve => setTimeout(resolve, 2000)); // Ejemplo mínimo
console.log("✅ Proceso simulado terminado."); // const browser = await chromium.launch({ headless: true });
} catch (e) { // ...
console.error(e); // 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, () => { app.listen(PORT, () => {
console.log(`🚀 Servidor escuchando en puerto ${PORT}`); console.log(`🚀 Servidor escuchando en puerto ${PORT}`);
}); });