Lead Enrichment

import { readFile, writeFile } from "node:fs/promises";
const KEY = process.env.GTM_TOOLS_API_KEY!;
interface Lead {
  name: string;
  company_domain: string;
  lead_id?: string;
}
interface EnrichedLead extends Lead {
  linkedin_profile_url?: string;
  email?: string;
  email_status?: string;
  email_reason?: string;
}
async function call<T>(tool: string, body: unknown): Promise<T | null> {
  const res = await fetch(`https://api.gtm-tools.sh/api/v0/${tool}`, {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify(body),
  });
  if (!res.ok) {
    console.error(`${tool} ${res.status}: ${await res.text()}`);
    return null;
  }
  return res.json();
}
async function enrich(lead: Lead): Promise<EnrichedLead> {
  const [profile, email] = await Promise.all([
    call<{ url?: string }>("get_linkedin_profile_url", {
      name: lead.name,
      domain: lead.company_domain,
    }),
    call<{ email?: string; status?: string; reason?: string }>("get_email", {
      name: lead.name,
      domain: lead.company_domain,
      input_parameters: { lead_id: lead.lead_id },
    }),
  ]);
  return {
    ...lead,
    linkedin_profile_url: profile?.url,
    email: email?.email,
    email_status: email?.status,
    email_reason: email?.reason,
  };
}
async function batch(leads: Lead[], concurrency = 5): Promise<EnrichedLead[]> {
  const out: EnrichedLead[] = [];
  for (let i = 0; i < leads.length; i += concurrency) {
    const slice = leads.slice(i, i + concurrency);
    const enriched = await Promise.all(slice.map(enrich));
    out.push(...enriched);
    console.log(`enriched ${out.length}/${leads.length}`);
  }
  return out;
}
const leads: Lead[] = [
  { lead_id: "1", name: "Justin Mares", company_domain: "kettleandfire.com" },
  { lead_id: "2", name: "Sara Blakely", company_domain: "spanx.com" },
  { lead_id: "3", name: "Brian Chesky", company_domain: "airbnb.com" },
];
const enriched = await batch(leads);
await writeFile("./out.json", JSON.stringify(enriched, null, 2));