Enrich leads

const MAGPIE = "https://api.magpie-cloud.com/v1";

// A lead with a name and a company domain, such as from a demo request form.
export async function findEmail(lead) {
  const res = await fetch(`${MAGPIE}/find`, {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.MAGPIE_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      first_name: lead.firstName,
      last_name: lead.lastName,
      domain: lead.domain,
    }),
    signal: AbortSignal.timeout(90_000), // up to 6 checks with a mail server
  });
  if (!res.ok) throw new Error(`Find failed: HTTP ${res.status}`);
  const { status, email } = await res.json();

  if (status === "verified") {
    return { ...lead, email, emailStatus: "verified", checkedAt: new Date().toISOString() };
  }
  // catch_all, risky, not_found or unknown: no email, and the call wasn't charged.
  return { ...lead, email: null, emailStatus: status, checkedAt: new Date().toISOString() };
}

import os
from datetime import datetime, timezone
import requests

MAGPIE = "https://api.magpie-cloud.com/v1"

# A lead with a name and a company domain, such as from a demo request form.
def find_email(lead):
    res = requests.post(
        f"{MAGPIE}/find",
        json={
            "first_name": lead["first_name"],
            "last_name": lead["last_name"],
            "domain": lead["domain"],
        },
        headers={"Authorization": f"Bearer {os.environ['MAGPIE_API_KEY']}"},
        timeout=90,  # up to 6 checks with a mail server
    )
    res.raise_for_status()
    data = res.json()
    checked_at = datetime.now(timezone.utc).isoformat()

    if data["status"] == "verified":
        return {**lead, "email": data["email"], "email_status": "verified", "checked_at": checked_at}
    # catch_all, risky, not_found or unknown: no email, and the call wasn't charged.
    return {**lead, "email": None, "email_status": data["status"], "checked_at": checked_at}