EmailChecker + Mautic

// Higienização em lote: Mautic -> EmailChecker -> Mautic
const EC = 'https://app.emailchecker.email/api/v1';
const MAUTIC = 'https://seu-mautic.com';
const ecH = {
  Authorization: `Bearer ${process.env.EC_API_KEY}`,
  'Content-Type': 'application/json',
};
const mauticH = {
  Authorization: `Bearer ${process.env.MAUTIC_TOKEN}`,
  'Content-Type': 'application/json',
};
const sleep = (ms) => new Promise((r) => setTimeout(r, ms));

// 1) pagina os contatos do Mautic
const lista = await fetch(`${MAUTIC}/api/contacts?limit=1000`, { headers: mauticH }).then((r) => r.json());
const contatos = Object.values(lista.contacts); // { id, fields: { all: { email } } }

// 2) envia UM lote (1 a 100.000 emails por chamada)
const criado = await fetch(`${EC}/batch`, {
  method: 'POST',
  headers: ecH,
  body: JSON.stringify({
    emails: contatos.map((c) => c.fields.all.email),
    name: 'mautic-higiene',
  }),
}).then((r) => r.json());

// 3) polling: não há webhook de retorno do EmailChecker
let lote;
do {
  await sleep(30_000);
  lote = await fetch(`${EC}/batch/${criado.data.id}`, { headers: ecH }).then((r) => r.json());
} while (lote.data.status === 'pending' || lote.data.status === 'processing');
if (lote.data.status !== 'completed') throw new Error(`lote ${lote.data.status}`);

// 4) devolve o resultado pro Mautic
const porEmail = new Map(lote.data.emails.map((e) => [e.email, e.result]));
for (const c of contatos) {
  const status = porEmail.get(c.fields.all.email);
  if (!status) continue;
  await fetch(`${MAUTIC}/api/contacts/${c.id}/edit`, {
    method: 'PATCH',
    headers: mauticH,
    body: JSON.stringify({ email_status: status }),
  });
}