EmailChecker + Brevo (ex-Sendinblue)

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

// 1) exporta a lista paginando de 500 em 500
const emails = [];
for (let offset = 0; ; offset += 500) {
  const url = `https://api.brevo.com/v3/contacts?listIds=42&limit=500&offset=${offset}`;
  const pagina = await fetch(url, { headers: brevoH }).then((r) => r.json());
  if (!pagina.contacts || pagina.contacts.length === 0) break;
  emails.push(...pagina.contacts.map((c) => c.email));
}

// 2) envia o lote
const criado = await fetch(`${EC}/batch`, {
  method: 'POST',
  headers: ecH,
  body: JSON.stringify({ emails, name: 'brevo-lista-42' }),
}).then((r) => r.json());

// 3) polling até completed (a plataforma não chama de volta)
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) atributo pra segmentar + blocklist pros inválidos
for (const e of lote.data.emails) {
  await fetch(`https://api.brevo.com/v3/contacts/${encodeURIComponent(e.email)}`, {
    method: 'PUT',
    headers: brevoH,
    body: JSON.stringify({
      attributes: { EMAIL_QUALITY: e.result },
      emailBlacklisted: e.result === 'undeliverable',
    }),
  });
}