const { chromium } = require('playwright');
const admin = require('firebase-admin');

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'),
    }),
  });
}

const db = admin.firestore();
const COLLECTION_PENDIENTES = "multiasistencia_pendientes";

async function runMultiasistencia() {
  console.log(`\n🕒 [${new Date().toLocaleTimeString()}] Iniciando ciclo...`);
  
  // 1. Guardamos la hora de inicio para comparar después
  const startRunTime = new Date();

  let user, pass;
  try {
    const credSnap = await db.collection("providerCredentials").doc("multiasistencia").get();
    if (!credSnap.exists) return console.error("❌ No hay credenciales.");
    user = credSnap.data().user;
    pass = credSnap.data().pass;
  } catch (e) {
    return console.error("❌ Error Firestore:", e.message);
  }

  const browser = await chromium.launch({
    headless: true,
    args: ['--no-sandbox', '--disable-setuid-sandbox'],
  });

  const context = await browser.newContext({
    userAgent:
      'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36',
  });

  const page = await context.newPage();

  try {
    console.log("🌍 Entrando a la web...");
    await page.goto('https://web.multiasistencia.com/w3multi/acceso.php', { waitUntil: 'networkidle', timeout: 60000 });

    const userFilled = await page.evaluate((u) => {
      const el = document.querySelector('input[name="usuario"]') || document.querySelector('input[type="text"]');
      if (el) {
        el.value = u;
        el.dispatchEvent(new Event('input', { bubbles: true }));
        return true;
      }
      return false;
    }, user);

    if (!userFilled) await page.fill('input[name="usuario"]', user);
    await page.fill('input[type="password"]', pass);
    await page.click('input[type="submit"]');
    await page.waitForTimeout(4000);

    console.log("🔄 Cargando listado...");
    for (let i = 1; i <= 3; i++) {
      await page.goto('https://web.multiasistencia.com/w3multi/frepasos_new.php?refresh=1', { waitUntil: 'domcontentloaded' });
      await page.waitForTimeout(2000);
    }

    let tieneSiguiente = true;
    let paginaActual = 1;

    while (tieneSiguiente && paginaActual <= 3) {
      console.log(`📄 Página ${paginaActual}...`);
      
      const expedientes = await page.evaluate(() => {
        const links = Array.from(document.querySelectorAll('a[href*="reparacion="]'));
        return Array.from(new Set(links.map(a => a.href.match(/reparacion=(\d+)/)?.[1]).filter(Boolean)));
      });

      if (expedientes.length === 0) {
        for (const frame of page.frames()) {
          const frameLinks = await frame.evaluate(() => {
            const links = Array.from(document.querySelectorAll('a[href*="reparacion="]'));
            return Array.from(new Set(links.map(a => a.href.match(/reparacion=(\d+)/)?.[1]).filter(Boolean)));
          });
          if (frameLinks.length > 0) expedientes.push(...frameLinks);
        }
      }

      console.log(`🔍 Encontrados ${expedientes.length} expedientes.`);

      for (const ref of expedientes) {
        const detalleUrl = `https://web.multiasistencia.com/w3multi/repasos1.php?reparacion=${ref}`;
        try {
          await page.goto(detalleUrl, { waitUntil: 'domcontentloaded' });
          await page.waitForTimeout(1500);

          let foundData = false;
          for (const frame of page.frames()) {
            try {
              const scrapData = await frame.evaluate(() => {
                const clean = (text) => text ? text.replace(/\s+/g, ' ').trim() : "";
                const bodyText = document.body?.innerText || "";
                
                if (!bodyText.includes("Nombre Cliente") && !bodyText.includes("Asegurado")) return null;

                const findRowValue = (labels) => {
                  const rows = Array.from(document.querySelectorAll('tr'));
                  for (const tr of rows) {
                    const tds = Array.from(tr.querySelectorAll('td'));
                    if (tds.length >= 2) {
                      const key = clean(tds[0].innerText).toUpperCase();
                      if (labels.some(l => key === l.toUpperCase())) {
                        const val = clean(tds[1].innerText);
                        if (val) return val;
                      }
                    }
                  }
                  return "";
                };

                const allCells = Array.from(document.querySelectorAll('td, th'));
                const getVertical = (keywords) => {
                  const header = allCells.find(el => keywords.some(k => (el.innerText || "").trim().toUpperCase() === k.toUpperCase()));
                  if (!header) return null;
                  const cellIndex = header.cellIndex;
                  const row = header.parentElement;
                  const tbody = row.parentElement;
                  let nextRow = row.nextElementSibling;
                  if (!nextRow && tbody.tagName === 'THEAD') {
                    const table = header.closest('table');
                    const realBody = table ? table.querySelector('tbody') : null;
                    if (realBody && realBody.rows && realBody.rows[0]) nextRow = realBody.rows[0];
                  }
                  if (nextRow && nextRow.cells && nextRow.cells[cellIndex]) {
                    return clean(nextRow.cells[cellIndex].innerText);
                  }
                  return null;
                };

                const getHorizontal = (keywords) => {
                  const header = allCells.find(el => keywords.some(k => (el.innerText || "").toUpperCase().includes(k.toUpperCase())));
                  if (header && header.nextElementSibling) {
                    return clean(header.nextElementSibling.innerText);
                  }
                  return null;
                };

                const getDescription = () => {
                  let text =
                    findRowValue(["Descripción de la Reparación"]) ||
                    getHorizontal(["Descripción de la Reparación", "Descripción", "Daños"]) ||
                    "";
                  text = clean(text);
                  const idxDate = text.search(/\b\d{2}\/\d{2}\/\d{4}\b/);
                  if (idxDate !== -1) {
                    text = text.substring(0, idxDate).trim();
                  }
                  return text;
                };

                const getStatus = () => {
                  const st = findRowValue(["Estado", "Situación"]);
                  if (st) return st;
                  return getHorizontal(["Estado", "Situación"]) || "PENDIENTE";
                };

                const getDate = () => {
                  let dt = getHorizontal(["Fecha/Hora Apertura", "Fecha Apertura"]);
                  if (dt) dt = dt.replace('/', '').replace(/\s+/g, ' ').trim();
                  return dt || "";
                };

                const getPhone = () => {
                  let rawText = "";
                  const titleDiv = Array.from(document.querySelectorAll('div.subtitulo'))
                    .find(d => (d.innerText || "").includes("Teléfono del Cliente"));
                  if (titleDiv) {
                    const table = titleDiv.closest('table') || titleDiv.parentElement.querySelector('table');
                    if (table) rawText = table.innerText || "";
                  }
                  if (!rawText) rawText = bodyText;
                  const match = rawText.match(/[6789]\d{8}/);
                  return match ? match[0] : "Sin teléfono";
                };

                const getCompany = () => {
                  let text = getHorizontal(["Procedencia", "Compañía"]);
                  if (!text) {
                    const regex = /Procedencia\s*[:\-]?\s*([^\n]+)/i;
                    const match = bodyText.match(regex);
                    if (match) text = match[1];
                  }
                  if (!text) return "MULTI - MULTIASISTENCIA";
                  return `MULTI - ${clean(text)}`;
                };

                const rawAddress = getVertical(["Dirección", "Domicilio"]);
                const rawZip = getVertical(["Distrito Postal", "C.P", "Distrito"]);
                let fullAddress = rawAddress || "Sin dirección";
                if (rawZip) fullAddress = `${fullAddress} ${rawZip}`;

                return {
                  clientName: getVertical(["Nombre Cliente", "Asegurado"]),
                  address: fullAddress,
                  company: getCompany(),
                  phone: getPhone(),
                  description: getDescription(),
                  multiStatus: getStatus(),
                  dateString: getDate(),
                  serviceNumber: "",
                  hasContent: true
                };
              });

              if (scrapData && scrapData.clientName) {
                scrapData.serviceNumber = ref;
                console.log(`✅ EXITO ${ref}: ${scrapData.clientName} | Estado: ${scrapData.multiStatus}`);
                
                await db.collection(COLLECTION_PENDIENTES).doc(ref).set({
                  ...scrapData,
                  status: "pendiente_validacion",
                  updatedAt: admin.firestore.FieldValue.serverTimestamp(),
                  // 2. AÑADIMOS "VISTO POR ÚLTIMA VEZ"
                  lastSeenAt: admin.firestore.FieldValue.serverTimestamp()
                }, { merge: true });
                
                foundData = true;
                break;
              }
            } catch (e) { /* ignore frame errors */ }
          }

          if (!foundData) {
            console.log(`⚠️ ALERTA: No se pudo leer ${ref}`);
            await db.collection(COLLECTION_PENDIENTES).doc(ref).set({
              serviceNumber: ref,
              status: "error_formato",
              clientName: "ERROR - REVISAR MANUAL",
              updatedAt: admin.firestore.FieldValue.serverTimestamp(),
              // También lo marcamos aquí para que no se "borre" si da error de lectura pero sigue existiendo
              lastSeenAt: admin.firestore.FieldValue.serverTimestamp()
            }, { merge: true });
          }

        } catch (errDetail) {
          console.error(`❌ Error en ${ref}:`, errDetail.message);
        }
      }

      if (paginaActual >= 3) break;

      const siguientePaginaNum = paginaActual + 1;
      console.log(`➡️ Pasando a pág ${siguientePaginaNum}...`);
      await page.goto(
        `https://web.multiasistencia.com/w3multi/frepasos_new.php?refresh=1&paginasiguiente=${siguientePaginaNum}`,
        { waitUntil: 'domcontentloaded' }
      );

      const hayResultados = await page.evaluate(() => document.querySelectorAll('a[href*="reparacion="]').length > 0);
      if (hayResultados) {
        paginaActual++;
        await page.waitForTimeout(2000);
      } else {
        tieneSiguiente = false;
      }
    }

    // 3. LIMPIEZA FINAL (Solo afecta a los que tengan 'lastSeenAt' antiguo)
    console.log("🧹 Verificando servicios que han desaparecido de la web...");
    
    // Esta consulta busca documentos que tengan el campo lastSeenAt Y sea viejo.
    // Los documentos antiguos sin ese campo serán ignorados.
    const snapshotViejos = await db.collection(COLLECTION_PENDIENTES)
      .where('lastSeenAt', '<', startRunTime)
      .get();

    if (!snapshotViejos.empty) {
      console.log(`🗑️ Se han detectado ${snapshotViejos.size} servicios rastreados que ya no están.`);
      const batch = db.batch();
      
      snapshotViejos.docs.forEach(doc => {
        // Opcional: Verificar que no esté ya cerrado para no escribir de más
        if (doc.data().status !== "cerrado_multiasistencia") {
            batch.update(doc.ref, {
              status: "cerrado_multiasistencia",
              closedAt: admin.firestore.FieldValue.serverTimestamp()
            });
        }
      });
      
      await batch.commit();
      console.log("✅ Limpieza completada.");
    }

  } catch (e) {
    console.error("❌ Error General:", e.message);
  } finally {
    await browser.close();
  }
}

async function start() {
  while (true) {
    await runMultiasistencia();
    console.log("💤 Durmiendo 15 minutos...");
    await new Promise(r => setTimeout(r, 10 * 60 * 1000));
  }
}

start();