274 lines
11 KiB
JavaScript
274 lines
11 KiB
JavaScript
// worker-homeserve.js (Versión Final - Selectores Exactos + Validación Fecha)
|
|
'use strict';
|
|
|
|
const { chromium } = require('playwright');
|
|
const admin = require('firebase-admin');
|
|
|
|
// --- CONFIGURACIÓN ---
|
|
const CONFIG = {
|
|
QUEUE_COLLECTION: process.env.QUEUE_COLLECTION || 'homeserve_cambios_estado',
|
|
RESULT_COLLECTION: process.env.RESULT_COLLECTION || 'homeserve_cambios_estado_log',
|
|
HS_CRED_DOC_PATH: process.env.HS_CRED_DOC_PATH || 'providerCredentials/homeserve',
|
|
|
|
// URL de Login (la que me confirmaste que funciona)
|
|
LOGIN_URL: 'https://www.clientes.homeserve.es/cgi-bin/fccgi.exe?w3exec=PROF_PASS',
|
|
// Base para construir la URL del servicio
|
|
BASE_CGI: 'https://www.clientes.homeserve.es/cgi-bin/fccgi.exe',
|
|
|
|
NAV_TIMEOUT: 60000,
|
|
RESCAN_SECONDS: 60
|
|
};
|
|
|
|
// --- UTILS ---
|
|
const sleep = (ms) => new Promise((r) => setTimeout(r, ms));
|
|
function toServerTimestamp() { return admin.firestore.FieldValue.serverTimestamp(); }
|
|
function mustEnv(name) {
|
|
const v = process.env[name];
|
|
if (!v) throw new Error(`Falta variable: ${name}`);
|
|
return v;
|
|
}
|
|
|
|
// --- VALIDACIÓN DE FECHA (NO SÁBADOS NI DOMINGOS) ---
|
|
function checkWeekend(dateStr) {
|
|
if (!dateStr) return; // Si no hay fecha, no validamos
|
|
|
|
// Formato esperado: DD/MM/AAAA
|
|
const parts = dateStr.split('/');
|
|
if (parts.length !== 3) return; // Formato inválido, dejamos que la web se queje
|
|
|
|
const day = parseInt(parts[0], 10);
|
|
const month = parseInt(parts[1], 10) - 1; // Meses en JS son 0-11
|
|
const year = parseInt(parts[2], 10);
|
|
|
|
const d = new Date(year, month, day);
|
|
const dayOfWeek = d.getDay(); // 0 = Domingo, 6 = Sábado
|
|
|
|
if (dayOfWeek === 0 || dayOfWeek === 6) {
|
|
throw new Error(`⛔ ERROR DE NEGOCIO: La fecha ${dateStr} es fin de semana (Sáb/Dom). No permitido.`);
|
|
}
|
|
}
|
|
|
|
// --- FIREBASE ---
|
|
function initFirebase() {
|
|
if (!process.env.FIREBASE_PRIVATE_KEY) throw new Error('Missing FIREBASE_PRIVATE_KEY');
|
|
if (!admin.apps.length) {
|
|
admin.initializeApp({
|
|
credential: admin.credential.cert({
|
|
projectId: mustEnv('FIREBASE_PROJECT_ID'),
|
|
clientEmail: mustEnv('FIREBASE_CLIENT_EMAIL'),
|
|
privateKey: mustEnv('FIREBASE_PRIVATE_KEY').replace(/\\n/g, '\n'),
|
|
}),
|
|
});
|
|
}
|
|
return admin.firestore();
|
|
}
|
|
|
|
// --- CREDS ---
|
|
async function getHomeServeCreds(db) {
|
|
// Intentar ENV primero
|
|
if (process.env.HOMESERVE_USER && process.env.HOMESERVE_PASS) {
|
|
return { user: process.env.HOMESERVE_USER, pass: process.env.HOMESERVE_PASS };
|
|
}
|
|
// Intentar Firestore
|
|
const path = CONFIG.HS_CRED_DOC_PATH;
|
|
const parts = path.split('/');
|
|
if (parts.length === 2) {
|
|
const snap = await db.collection(parts[0]).doc(parts[1]).get();
|
|
if (snap.exists) {
|
|
const d = snap.data();
|
|
const user = d.user || d.username || d.usuario;
|
|
const pass = d.pass || d.password || d.clave;
|
|
if (user && pass) return { user, pass };
|
|
}
|
|
}
|
|
throw new Error('Sin credenciales disponibles.');
|
|
}
|
|
|
|
// --- 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(() => {}); }
|
|
}
|
|
|
|
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;
|
|
}
|
|
|
|
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;
|
|
}
|
|
|
|
// --- DIAGNÓSTICO ---
|
|
async function getDebugInfo(page) {
|
|
try {
|
|
const title = await page.title();
|
|
const url = page.url();
|
|
const bodyText = await page.evaluate(() => document.body.innerText.substring(0, 300).replace(/\n/g, ' '));
|
|
return `URL: ${url} | Titulo: ${title} | Texto: ${bodyText}...`;
|
|
} catch (e) { return "Error debug info"; }
|
|
}
|
|
|
|
// --- LÓGICA PRINCIPAL (TU FLUJO ACTUALIZADO) ---
|
|
async function loginAndProcess(page, creds, jobData) {
|
|
console.log('>>> 1. Login...');
|
|
|
|
// 1. VALIDAR FECHA ANTES DE NAVEGAR
|
|
if (jobData.dateString) {
|
|
checkWeekend(jobData.dateString);
|
|
}
|
|
// VALIDAR OBSERVACIONES (Son obligatorias según tu indicación)
|
|
if (!jobData.observation || jobData.observation.trim().length === 0) {
|
|
throw new Error('⛔ ERROR: El campo Observaciones es obligatorio.');
|
|
}
|
|
|
|
// 2. LOGIN
|
|
await page.goto(CONFIG.LOGIN_URL, { waitUntil: 'domcontentloaded', timeout: CONFIG.NAV_TIMEOUT });
|
|
await page.waitForTimeout(1000); // Estabilidad
|
|
|
|
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); // Esperar redirección de login
|
|
|
|
// Chequeo rápido de fallo login
|
|
const loginFail = await findLocatorInFrames(page, 'input[type="password"]');
|
|
if (loginFail) throw new Error('Login fallido (sigo viendo el password). Revise credenciales.');
|
|
|
|
console.log(`>>> 2. Login OK. Yendo al servicio ${jobData.serviceNumber}...`);
|
|
|
|
// 3. CONSTRUIR URL DEL SERVICIO (TU ENLACE EXACTO)
|
|
// https://www.clientes.homeserve.es/cgi-bin/fccgi.exe?w3exec=ver_servicioencurso&Servicio=XXXX&Pag=1
|
|
const serviceUrl = `${CONFIG.BASE_CGI}?w3exec=ver_servicioencurso&Servicio=${jobData.serviceNumber}&Pag=1`;
|
|
|
|
await page.goto(serviceUrl, { waitUntil: 'domcontentloaded', timeout: CONFIG.NAV_TIMEOUT });
|
|
await page.waitForTimeout(1500);
|
|
|
|
// 4. BUSCAR BOTÓN "REPASO" (TU SELECTOR EXACTO)
|
|
// <input type="IMAGE" name="repaso" ...>
|
|
const changeBtn = await clickFirstThatExists(page, ['input[name="repaso"]']);
|
|
|
|
if (!changeBtn) {
|
|
const debug = await getDebugInfo(page);
|
|
throw new Error(`No veo el botón 'repaso'. ¿Servicio ${jobData.serviceNumber} existe/abierto? DEBUG: ${debug}`);
|
|
}
|
|
|
|
console.log('>>> 3. Botón repaso clickado. Rellenando formulario...');
|
|
|
|
// 5. RELLENAR FORMULARIO
|
|
await page.waitForLoadState('domcontentloaded');
|
|
await page.waitForTimeout(1000);
|
|
|
|
// A) SELECCIONAR ESTADO
|
|
// Buscamos un <select> genérico o por nombre si lo tuviéramos, pero Playwright suele manejar bien buscar la opción dentro del form
|
|
const statusOk = await page.evaluate((code) => {
|
|
const selects = document.querySelectorAll('select');
|
|
for (const s of selects) {
|
|
// Buscamos la opción por valor o texto
|
|
for (const opt of s.options) {
|
|
if (opt.value == code || opt.text.includes(code)) {
|
|
s.value = opt.value;
|
|
return true;
|
|
}
|
|
}
|
|
}
|
|
return false;
|
|
}, jobData.newStatusValue);
|
|
|
|
if (!statusOk) throw new Error(`No encontré el estado '${jobData.newStatusValue}' en ningún desplegable.`);
|
|
|
|
// B) FECHA (TU SELECTOR EXACTO: name="FECSIG")
|
|
if (jobData.dateString) {
|
|
// <input type="TEXT" name="FECSIG" size="10">
|
|
const dateFilled = await fillFirstThatExists(page, ['input[name="FECSIG"]'], jobData.dateString);
|
|
if (!dateFilled) console.warn('⚠️ No encontré el input FECSIG, pero tenía fecha para poner.');
|
|
}
|
|
|
|
// C) OBSERVACIONES (TU SELECTOR EXACTO: name="Observaciones")
|
|
// <textarea name="Observaciones">
|
|
const obsFilled = await fillFirstThatExists(page, ['textarea[name="Observaciones"]'], jobData.observation);
|
|
if (!obsFilled) throw new Error('No encontré el textarea de Observaciones.');
|
|
|
|
// D) CHECKBOX "INFORMAR CLIENTE" (Opcional, si existe en esta pantalla)
|
|
if (jobData.informoCliente) {
|
|
const labels = ['informado al cliente', 'informado al Cliente'];
|
|
for (const txt of labels) {
|
|
const hit = await findLocatorInFrames(page, `label:has-text("${txt}") >> input[type="checkbox"]`);
|
|
if (hit && !(await hit.locator.first().isChecked())) await hit.locator.first().check();
|
|
}
|
|
}
|
|
|
|
// 6. GUARDAR
|
|
const saveBtn = await clickFirstThatExists(page, ['input[type="submit"]', 'input[value="Guardar"]', 'button:has-text("Guardar")']);
|
|
if (!saveBtn) throw new Error('No encuentro botón para guardar los cambios.');
|
|
|
|
await page.waitForTimeout(3000); // Esperar confirmación
|
|
return { success: true };
|
|
}
|
|
|
|
// --- WORKER LOOP (Igual que antes) ---
|
|
async function claimJobById(db, jobId) {
|
|
const ref = db.collection(CONFIG.QUEUE_COLLECTION).doc(jobId);
|
|
return await db.runTransaction(async (tx) => {
|
|
const snap = await tx.get(ref);
|
|
if (!snap.exists || snap.data().status !== 'PENDING') return null;
|
|
tx.set(ref, { status: 'RUNNING', claimedAt: toServerTimestamp() }, { merge: true });
|
|
return { id: jobId, ...snap.data() };
|
|
});
|
|
}
|
|
async function markJobDone(db, jobId, result) {
|
|
await db.collection(CONFIG.QUEUE_COLLECTION).doc(jobId).set({ status: 'DONE', result }, { merge: true });
|
|
await db.collection(CONFIG.RESULT_COLLECTION).add({ jobId, ok: true, ...result, createdAt: toServerTimestamp() });
|
|
}
|
|
async function markJobFailed(db, jobId, err) {
|
|
const errData = { message: String(err?.message || err) };
|
|
await db.collection(CONFIG.QUEUE_COLLECTION).doc(jobId).set({ status: 'FAILED', error: errData }, { merge: true });
|
|
await db.collection(CONFIG.RESULT_COLLECTION).add({ jobId, ok: false, error: errData, createdAt: toServerTimestamp() });
|
|
}
|
|
async function processJob(db, job) {
|
|
console.log(`>>> Job: ${job.id}`);
|
|
try {
|
|
const creds = await getHomeServeCreds(db);
|
|
await withBrowser(async (page) => {
|
|
const res = await loginAndProcess(page, creds, {
|
|
serviceNumber: job.parteId || job.serviceNumber,
|
|
newStatusValue: job.nuevoEstado || job.newStatusValue,
|
|
dateString: job.fecha || '',
|
|
observation: job.nota || '', // Ahora es obligatorio, el script fallará si viene vacío
|
|
informoCliente: job.informoCliente || false
|
|
});
|
|
await markJobDone(db, job.id, res);
|
|
console.log(`✅ OK: ${job.id}`);
|
|
});
|
|
} catch (err) {
|
|
console.error(`❌ Error: ${err.message}`);
|
|
await markJobFailed(db, job.id, err);
|
|
}
|
|
}
|
|
function startWorker(db) {
|
|
const queue = [];
|
|
const run = async () => { while(queue.length) { await processJob(db, await claimJobById(db, queue.shift())); } };
|
|
db.collection(CONFIG.QUEUE_COLLECTION).where('status', '==', 'PENDING').onSnapshot(s => {
|
|
s.docChanges().forEach(c => { if(c.type==='added') { queue.push(c.doc.id); run(); } });
|
|
});
|
|
console.log('🚀 Worker HomeServe Final Listo.');
|
|
}
|
|
startWorker(initFirebase()); |