Verifica delle email per le campagne di riattivazione degli utenti

const auth = { Authorization: `Bearer ${process.env.MAILBEAM_KEY}` };

async function verifyList(emails: string[]) {
  const job = await fetch("https://api.mailbeam.dev/v1/verify/batch", {
    method: "POST",
    headers: { ...auth, "Content-Type": "application/json" },
    body: JSON.stringify({ emails }),
  }).then((r) => r.json());

  // Aspetta il webhook batch.completed, o interroga /v1/jobs/:id finché non finisce.
  const { results } = await fetch(
    `https://api.mailbeam.dev/v1/jobs/${job.job_id}/results?format=json`,
    { headers: auth }
  ).then((r) => r.json());

  return results; // [{ index, email, status, score, reason }]
}

interface User { id: string; email: string; lastActiveAt: Date }

async function preflightReengagement(users: User[]) {
  const results = await verifyList(users.map((u) => u.email));

  const segments = { send: [] as User[], suppress: [] as User[] };

  users.forEach((user, i) => {
    const r = results[i];
    if (r.status !== "deliverable" || r.score < 40) {
      segments.suppress.push(user);
    } else {
      segments.send.push(user);
    }
  });

  console.log(
    `Pronti all'invio: ${segments.send.length} | Soppressi: ${segments.suppress.length}`
  );

  return segments;
}