Email Verification for CRM Data Hygiene

import Mailbeam from "@mailbeam/sdk";
import { HubSpotClient } from "@hubspot/api-client";
import { subDays } from "date-fns";

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

async function rehygieneContacts() {
  // Fetch contacts not verified in the last 90 days
  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(`Re-verifying ${emails.length} contacts...`);

  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"; // Suppress from campaigns
    }

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

  console.log("CRM re-hygiene complete.");
}

// Run nightly via cron
rehygieneContacts().catch(console.error);