Auto-Enrich Leads in Your CRM

import express from "express";
import ContextDev from "context.dev";

const app = express();
app.use(express.json());
const client = new ContextDev({ apiKey: process.env.CONTEXT_DEV_API_KEY });

// One endpoint for every CRM. Point each CRM's webhook at /webhooks/<crm>.
app.post("/webhooks/:crm", async (req, res) => {
  res.sendStatus(200); // ack fast; CRMs retry slow endpoints

  const { email, recordId } = extractLead(req.params.crm, req.body);
  if (!email) return;

  const fields = await enrichLead(email);
  if (fields) await writeBack(req.params.crm, recordId, fields);
});

// Call the Brand API and map the response to the fields you store.
async function enrichLead(email: string) {
  try {
    const { brand } = await client.brand.retrieveByEmail({ email, timeoutMS: 8000 });
    return {
      companyName: brand.title,
      description: brand.description,
      phone: brand.phone,
      website: brand.domain,
      logo: brand.logos?.find((l) => l.mode === "light")?.url ?? brand.logos?.[0]?.url ?? null,
      industry: brand.industries?.eic?.[0]?.industry ?? null,
      linkedin: brand.socials?.find((s) => s.type === "linkedin")?.url ?? null,
    };
  } catch {
    return null; // 422 free email, 400 no brand, 408 timeout: keep the rep's input
  }
}

// CRM-specific: read the email + record id from each payload shape.
function extractLead(crm: string, body: any): { email?: string; recordId?: string } {
  switch (crm) {
    case "hubspot":    return { email: body[0]?.propertyValue, recordId: body[0]?.objectId };
    case "salesforce": return { email: body.Lead?.Email, recordId: body.Lead?.Id };
    case "zoho":       return { email: body.email, recordId: body.id };
    case "pipedrive":  return { email: body.data?.email?.[0]?.value, recordId: body.data?.id };
    case "monday":     return { email: body.event?.columnValues?.email?.email, recordId: body.event?.pulseId };
    default:           return {};
  }
}

// CRM-specific: write the mapped fields back, filling blanks only.
async function writeBack(crm: string, recordId: string | undefined, fields: object) {
  // HubSpot CRM API, Salesforce sObject update, Zoho Records API,
  // Pipedrive Persons, monday change_multiple_column_values.
}

app.listen(3000);

// After enrichLead() returns: pull a custom datapoint and attach it to the write-back.
const { data } = await client.web.extract({
  url: `https://${fields.website}`,
  schema: {
    type: "object",
    properties: {
      pricing_model: {
        type: "string",
        description: "How the product is priced: per-seat, usage-based, or flat-rate.",
      },
    },
    required: ["pricing_model"],
    additionalProperties: false,
  },
});

fields.pricingModel = data.pricing_model ?? null;

// Fire and forget at the top of the handler, before other work.
client.utility.prefetchByEmail({ email }).catch(() => {});
// ... later, when you need the data:
const data = await enrichLead(email);