Pulizia delle liste email per il prospecting a freddo

// Non c'è ancora un SDK: il wrapper di 12 righe di /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(`Invio di ${emails.length} indirizzi da verificare...`);

  // Crea il lavoro in blocco. Registra l'endpoint del webhook una volta
  // nella dashboard, non a ogni richiesta.
  const job = await mb.batch.create({ emails });

  console.log(`Lavoro ${job.id} in coda. In attesa dei risultati...`);

  // Interroga finché non finisce (o usa il webhook in produzione)
  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(`Risultati:
  ✓ Recapitabili:  ${deliverable.length}
  ⚠ Rischiosi:     ${risky.length}
  ✗ Eliminati:     ${invalid.length}`);
}

cleanList(process.argv[2]);