Verifica delle email per l'igiene dei dati del CRM

// Non c'è ancora un SDK: il wrapper di 12 righe di /docs/quickstart.
import { verifyEmail } from "@/lib/mailbeam";
import { HubSpotClient } from "@hubspot/api-client";
import { subDays } from "date-fns";

const hubspot = new HubSpotClient({ accessToken: process.env.HUBSPOT_TOKEN! });

async function rehygieneContacts() {
  // Recupera i contatti non verificati negli ultimi 90 giorni
  const contacts = await hubspot.crm.contacts.searchApi.doSearch({
    filterGroups: [{
      filters: [{
        propertyName: "email_verified_at",
        operator: "LT",
        value: String(subDays(new Date(), 90).getTime()),
      }],
    }],
    properties: ["email", "email_verified_at"],
    limit: 5000,
  });

  const emails = contacts.results.map((c) => c.properties.email!);
  console.log(`Riverifica di ${emails.length} contatti...`);

  const job = await mb.batch.create({ emails });
  const results = await job.wait();

  for (const result of results) {
    const props: Record<string, string> = {
      mailbeam_score:    String(result.score),
      mailbeam_status:   result.status,
      email_verified_at: new Date().toISOString(),
    };

    if (result.status === "undeliverable") {
      props.hs_email_optout = "true"; // Escludi dalle campagne
    }

    await hubspot.crm.contacts.basicApi.update(result.email, { properties: props });
  }

  console.log("Pulizia del CRM completata.");
}

// Da eseguire ogni notte via cron
rehygieneContacts().catch(console.error);