Email List Cleaning for Cold Outreach

import Mailbeam from "@mailbeam/sdk";
import { readCsv, writeCsv } from "./csv";

const mb = new Mailbeam({ apiKey: process.env.MAILBEAM_KEY! });

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

  console.log(`Submitting ${emails.length} addresses for verification...`);

  // Submit batch job
  const job = await mb.batch.create({
    emails,
    webhookUrl: "https://yourapp.com/webhooks/batch-complete",
  });

  console.log(`Job ${job.id} queued. Waiting for results...`);

  // Poll for completion (or use webhook in production)
  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(`Results:
  ✓ Deliverable: ${deliverable.length}
  ⚠ Risky:       ${risky.length}
  ✗ Removed:     ${invalid.length}`);
}

cleanList(process.argv[2]);