diff --git a/worker-homeserve.js b/worker-homeserve.js index 416334e..f8538aa 100644 --- a/worker-homeserve.js +++ b/worker-homeserve.js @@ -1,4 +1,4 @@ -// worker-homeserve.js (Versión Definitiva PostgreSQL - MULTI-EMPRESA SAAS) +// worker-homeserve.js (Versión SaaS Ultra-Eficaz con Logs Reforzados) import { chromium } from 'playwright'; import pg from 'pg'; @@ -10,241 +10,193 @@ const CONFIG = { LOGIN_URL: 'https://www.clientes.homeserve.es/cgi-bin/fccgi.exe?w3exec=PROF_PASS', BASE_CGI: 'https://www.clientes.homeserve.es/cgi-bin/fccgi.exe', NAV_TIMEOUT: 60000, - POLL_INTERVAL_MS: 5000 // Cada 5 segundos mira si hay trabajo en la pizarra + POLL_INTERVAL_MS: 5000 }; -if (!CONFIG.DATABASE_URL) { - console.error("❌ ERROR FATAL: Falta la variable de entorno DATABASE_URL"); - process.exit(1); -} - -// Conexión a la Base de Datos const pool = new Pool({ connectionString: CONFIG.DATABASE_URL, ssl: false }); -// --- UTILS --- -const sleep = (ms) => new Promise((r) => setTimeout(r, ms)); - +// --- HELPERS --- function checkWeekend(dateStr) { if (!dateStr) return; const parts = dateStr.split('/'); if (parts.length !== 3) return; - const day = parseInt(parts[0], 10); - const month = parseInt(parts[1], 10) - 1; - const year = parseInt(parts[2], 10); - const d = new Date(year, month, day); - const dayOfWeek = d.getDay(); - if (dayOfWeek === 0 || dayOfWeek === 6) { - throw new Error(`⛔ ERROR: La fecha ${dateStr} es fin de semana (Sáb/Dom). No permitido por HomeServe.`); + const d = new Date(parseInt(parts[2]), parseInt(parts[1]) - 1, parseInt(parts[0])); + if (d.getDay() === 0 || d.getDay() === 6) { + throw new Error(`⛔ ERROR: La fecha ${dateStr} es fin de semana.`); } } -// --- DESENCRIPTAR CREDENCIALES (MULTI-EMPRESA) --- async function getHomeServeCreds(ownerId) { const q = await pool.query( "SELECT username, password_hash FROM provider_credentials WHERE provider = 'homeserve' AND status = 'active' AND owner_id = $1 LIMIT 1", [ownerId] ); - - if (q.rowCount === 0) { - throw new Error(`No hay credenciales activas de HomeServe para la empresa/dueño ID: ${ownerId}.`); - } - - const user = q.rows[0].username; - // Convierte el Base64 a texto normal - const pass = Buffer.from(q.rows[0].password_hash, 'base64').toString('utf-8'); - - return { user, pass }; -} - -// --- PLAYWRIGHT HELPERS --- -async function withBrowser(fn) { - const browser = await chromium.launch({ headless: true, args: ['--no-sandbox', '--disable-setuid-sandbox'] }); - const context = await browser.newContext(); - const page = await context.newPage(); - try { return await fn(page); } finally { await browser.close().catch(() => {}); } + if (q.rowCount === 0) throw new Error(`Sin credenciales para empresa ID: ${ownerId}`); + return { + user: q.rows[0].username, + pass: Buffer.from(q.rows[0].password_hash, 'base64').toString('utf-8') + }; } async function findLocatorInFrames(page, selector) { - for (const fr of page.frames()) { - const loc = fr.locator(selector); - try { if (await loc.count()) return { frame: fr, locator: loc }; } catch (_) {} - } - return null; + // Primero buscamos en la página principal + const mainLoc = page.locator(selector); + if (await mainLoc.count() > 0) return mainLoc.first(); + + // Si no está, buscamos dentro de cada frame (HomeServe usa muchos frames) + for (const frame of page.frames()) { + const frameLoc = frame.locator(selector); + try { + if (await frameLoc.count() > 0) return frameLoc.first(); + } catch (e) {} + } + return null; } -async function clickFirstThatExists(page, selectors) { - for (const sel of selectors) { - const hit = await findLocatorInFrames(page, sel); - if (hit) { await hit.locator.first().click(); return sel; } - } - return null; -} - -async function fillFirstThatExists(page, selectors, value) { - for (const sel of selectors) { - const hit = await findLocatorInFrames(page, sel); - if (hit) { await hit.locator.first().fill(String(value)); return sel; } - } - return null; -} - -// --- INYECCIÓN EN HOMESERVE --- +// --- PROCESO PRINCIPAL --- async function loginAndProcess(page, creds, jobData) { - console.log(`>>> 1. Login en HomeServe con usuario: ${creds.user}`); - - if (jobData.appointment_date) checkWeekend(jobData.appointment_date); - - if (!jobData.observation || jobData.observation.trim().length === 0) { - throw new Error('⛔ ERROR: El campo Observaciones es obligatorio para HomeServe.'); - } + console.log(` [1] Intentando Login (${creds.user})...`); + + if (jobData.appointment_date) checkWeekend(jobData.appointment_date); + + // Manejo de diálogos (Alertas de la web que bloquean el proceso) + page.on('dialog', async dialog => { + console.log(` [DIALOG] Mensaje detectado: ${dialog.message()}`); + await dialog.accept(); + }); - await page.goto(CONFIG.LOGIN_URL, { waitUntil: 'domcontentloaded', timeout: CONFIG.NAV_TIMEOUT }); - await page.waitForTimeout(1000); + await page.goto(CONFIG.LOGIN_URL, { waitUntil: 'networkidle', timeout: CONFIG.NAV_TIMEOUT }); + + const userInp = await findLocatorInFrames(page, 'input[name="w3user"]'); + const passInp = await findLocatorInFrames(page, 'input[name="w3clau"]'); + + if (!userInp || !passInp) throw new Error("No se cargó el formulario de login."); - await fillFirstThatExists(page, ['input[name="w3user"]', 'input[type="text"]'], creds.user); - await fillFirstThatExists(page, ['input[name="w3clau"]', 'input[type="password"]'], creds.pass); - - await page.keyboard.press('Enter'); - await page.waitForTimeout(3000); + await userInp.fill(creds.user); + await passInp.fill(creds.pass); + await page.keyboard.press('Enter'); + + await page.waitForTimeout(3000); - const loginFail = await findLocatorInFrames(page, 'input[type="password"]'); - if (loginFail) throw new Error(`Login fallido en HomeServe para el usuario ${creds.user}. Revise las credenciales.`); + // Verificar si seguimos en login + if (await page.locator('input[type="password"]').count() > 0) { + throw new Error("Credenciales rechazadas por HomeServe."); + } - console.log(`>>> 2. Login OK. Navegando al expediente ${jobData.service_number}...`); + console.log(` [2] Login OK. Buscando expediente: ${jobData.service_number}...`); + const serviceUrl = `${CONFIG.BASE_CGI}?w3exec=ver_servicioencurso&Servicio=${jobData.service_number}&Pag=1`; + await page.goto(serviceUrl, { waitUntil: 'domcontentloaded' }); - const serviceUrl = `${CONFIG.BASE_CGI}?w3exec=ver_servicioencurso&Servicio=${jobData.service_number}&Pag=1`; - await page.goto(serviceUrl, { waitUntil: 'domcontentloaded', timeout: CONFIG.NAV_TIMEOUT }); - await page.waitForTimeout(1500); + const repasBtn = await findLocatorInFrames(page, 'input[name="repaso"]'); + if (!repasBtn) throw new Error("No se encuentra el siniestro o no permite 'repaso'."); + await repasBtn.click(); - const changeBtn = await clickFirstThatExists(page, ['input[name="repaso"]']); - if (!changeBtn) { - throw new Error(`No veo el botón 'repaso'. ¿El siniestro ${jobData.service_number} existe y está abierto?`); - } + console.log(' [3] Rellenando formulario de cambio de estado...'); + await page.waitForTimeout(2000); - console.log('>>> 3. Accediendo al formulario. Rellenando datos...'); - await page.waitForLoadState('domcontentloaded'); - await page.waitForTimeout(1000); + // Selección de Estado + const targetCode = jobData.new_status; + const statusOk = await page.evaluate((code) => { + const sel = document.querySelector('select[name="ESTADO"]'); + if (!sel) return false; + // Buscamos por valor (código 307, 348...) o por texto parcial + for (let opt of sel.options) { + if (opt.value == code || opt.text.includes(code)) { + sel.value = opt.value; + sel.dispatchEvent(new Event('change', { bubbles: true })); + return true; + } + } + return false; + }, targetCode); - // 🔴 MAGIA: DICCIONARIO TRADUCTOR DE ESTADOS - const HOMESERVE_MAP = { - 'CITADO': '307', - 'ESPERA': '303', - 'TERMINADO': '345', - 'ANULADO': '352' - }; + if (!statusOk) throw new Error(`Estado '${targetCode}' no disponible en la web.`); - let targetCode = jobData.new_status.toUpperCase(); - if (HOMESERVE_MAP[targetCode]) { - targetCode = HOMESERVE_MAP[targetCode]; - } + // Fecha Siguiente Acción + if (jobData.appointment_date) { + const dateInp = await findLocatorInFrames(page, 'input[name="FECSIG"]'); + if (dateInp) await dateInp.fill(jobData.appointment_date); + } - const statusOk = await page.evaluate((code) => { - const select = document.querySelector('select[name="ESTADO"]'); - if (!select) return false; - for (const opt of select.options) { - if (opt.value == code || opt.text.toUpperCase().includes(code.toUpperCase())) { - select.value = opt.value; - return true; - } - } - return false; - }, targetCode); + // Observaciones + const obsInp = await findLocatorInFrames(page, 'textarea[name="Observaciones"]'); + if (!obsInp) throw new Error("Campo observaciones no encontrado."); + await obsInp.fill(jobData.observation); - if (!statusOk) throw new Error(`No encontré el estado '${jobData.new_status}' (Buscando código interno: ${targetCode}) en el desplegable de HomeServe.`); + // Informar Cliente + if (jobData.inform_client) { + const check = await findLocatorInFrames(page, 'input[name="INFORMO"]'); + if (check && !(await check.isChecked())) await check.check(); + } - if (jobData.appointment_date) { - const dateFilled = await fillFirstThatExists(page, ['input[name="FECSIG"]'], jobData.appointment_date); - if (!dateFilled) console.warn('⚠️ No encontré el recuadro para la fecha.'); - } + console.log(' [4] Ejecutando CLIC DE GUARDADO FINAL...'); + const btnGuardar = await findLocatorInFrames(page, 'input[name="BTNCAMBIAESTADO"]'); + if (!btnGuardar) throw new Error("Botón GUARDAR no encontrado."); - const obsFilled = await fillFirstThatExists(page, ['textarea[name="Observaciones"]'], jobData.observation); - if (!obsFilled) throw new Error('No encontré el recuadro de Observaciones en la web de HomeServe.'); + // Clic con reintento y espera de red + await Promise.all([ + page.waitForLoadState('networkidle').catch(() => {}), + btnGuardar.click() + ]); - if (jobData.inform_client) { - const informCheck = await findLocatorInFrames(page, 'input[name="INFORMO"]'); - if (informCheck && !(await informCheck.locator.first().isChecked())) { - await informCheck.locator.first().check(); - } - } + // Verificación de éxito + await page.waitForTimeout(3000); + const feedback = await page.evaluate(() => { + // Buscamos textos rojos o negritas que indiquen el resultado + const el = document.querySelector('font[color="#FF0000"], .Estilo4, b, .mensaje'); + return el ? el.innerText : ""; + }); - console.log('>>> 4. Guardando cambios en HomeServe...'); - - const saveBtnLocator = page.locator('input[name="BTNCAMBIAESTADO"]'); - - if (await saveBtnLocator.count() === 0) { - throw new Error('No encuentro el botón para guardar los cambios en HomeServe.'); - } + console.log(` [RESULTADO] Web dice: "${feedback.trim() || 'Sin mensaje visible'}"`); + + const esExito = feedback.toUpperCase().includes('EXITO') || + feedback.toUpperCase().includes('ÉXITO') || + feedback.toUpperCase().includes('MODIFICADO') || + feedback.toUpperCase().includes('ACTUALIZADO'); - // Esperamos a que la página navegue DESPUÉS de hacer clic (El Clic Seguro) - await Promise.all([ - page.waitForNavigation({ waitUntil: 'domcontentloaded', timeout: CONFIG.NAV_TIMEOUT }), - saveBtnLocator.first().click() - ]); + if (!esExito && feedback.length > 0) { + throw new Error(`HomeServe denegó el cambio: ${feedback}`); + } - // 🔴 LECTURA INTELIGENTE DEL RESULTADO (Evita los falsos errores rojos) - const alertText = await page.locator('font[color="#FF0000"], .Estilo4').first().textContent().catch(() => null); - if (alertText && alertText.trim().length > 0) { - const textUpper = alertText.toUpperCase(); - if (!textUpper.includes('EXITO') && !textUpper.includes('ÉXITO')) { - throw new Error(`HomeServe devolvió un error: ${alertText.trim()}`); - } else { - console.log(`>>> Confirmación positiva de HomeServe: ${alertText.trim()}`); - } - } - - await page.waitForTimeout(2000); - return { success: true }; + return { success: true }; } -// --- EL CEREBRO: LECTURA DE LA COLA EN POSTGRESQL --- +// --- BUCLE DE COLA --- async function pollQueue() { try { const res = await pool.query(` - UPDATE robot_queue - SET status = 'RUNNING', updated_at = NOW() - WHERE id = ( - SELECT id FROM robot_queue - WHERE status = 'PENDING' AND provider = 'homeserve' - ORDER BY created_at ASC - FOR UPDATE SKIP LOCKED - LIMIT 1 - ) + UPDATE robot_queue SET status = 'RUNNING', updated_at = NOW() + WHERE id = (SELECT id FROM robot_queue WHERE status = 'PENDING' AND provider = 'homeserve' ORDER BY created_at ASC FOR UPDATE SKIP LOCKED LIMIT 1) RETURNING *; `); if (res.rowCount > 0) { const job = res.rows[0]; - console.log(`\n========================================`); - console.log(`🤖 TRABAJO #${job.id} | Empresa ID: ${job.owner_id}`); - console.log(`📋 Siniestro: ${job.service_number} -> Cambiar a: ${job.new_status}`); - console.log(`========================================`); + console.log(`\n🚀 TRABAJO #${job.id} | Exp: ${job.service_number} | Accion: ${job.new_status}`); + + const browser = await chromium.launch({ headless: true, args: ['--no-sandbox'] }); + const page = await browser.newPage(); try { const creds = await getHomeServeCreds(job.owner_id); - - await withBrowser(async (page) => { - await loginAndProcess(page, creds, job); - }); - + await loginAndProcess(page, creds, job); await pool.query("UPDATE robot_queue SET status = 'DONE', updated_at = NOW() WHERE id = $1", [job.id]); - console.log(`✅ TRABAJO #${job.id} COMPLETADO CON ÉXITO.\n`); - + console.log(`✅ COMPLETADO #${job.id}`); } catch (err) { - console.error(`❌ ERROR EN TRABAJO #${job.id}:`, err.message); + console.error(`❌ ERROR #${job.id}:`, err.message); await pool.query("UPDATE robot_queue SET status = 'FAILED', error_msg = $1, updated_at = NOW() WHERE id = $2", [err.message, job.id]); + } finally { + await browser.close(); + setTimeout(pollQueue, 1000); } - - setTimeout(pollQueue, 1000); } else { setTimeout(pollQueue, CONFIG.POLL_INTERVAL_MS); } } catch (e) { - console.error("Error crítico en el bucle del robot:", e.message); + console.error("Error en bucle:", e.message); setTimeout(pollQueue, CONFIG.POLL_INTERVAL_MS); } } -// --- INICIO --- -console.log("🚀 Robot HomeServe (Multi-Empresa SaaS) Iniciado."); -console.log("📡 Conectado a PostgreSQL. Esperando peticiones en la cola..."); +console.log("📡 Robot HomeServe SaaS Online..."); pollQueue(); \ No newline at end of file