Limpieza de listas de email para prospección en frío

// Todavía no hay SDK: el wrapper de 12 líneas de /docs/quickstart.
import { verifyEmail } from "@/lib/mailbeam";
import { readCsv, writeCsv } from "./csv";


async function cleanList(inputFile: string) {
  const contacts = await readCsv(inputFile);
  const emails = contacts.map((c) => c.email);

  console.log(`Enviando ${emails.length} direcciones a verificar...`);

  // Crea el trabajo por lotes. Registra el endpoint del webhook una vez
  // en el panel, no en cada petición.
  const job = await mb.batch.create({ emails });

  console.log(`Trabajo ${job.id} en cola. Esperando resultados...`);

  // Consulta hasta que termine (o usa el webhook en producción)
  const results = await job.wait();

  const deliverable = results.filter((r) => r.status === "deliverable");
  const risky      = results.filter((r) => r.status === "risky");
  const invalid    = results.filter((r) =>
    r.status === "undeliverable" || r.status === "unknown"
  );

  await writeCsv("clean-list.csv",   deliverable);
  await writeCsv("risky-list.csv",   risky);
  await writeCsv("removed-list.csv", invalid);

  console.log(`Resultados:
  ✓ Entregables:   ${deliverable.length}
  ⚠ Arriesgadas:   ${risky.length}
  ✗ Eliminadas:    ${invalid.length}`);
}

cleanList(process.argv[2]);