[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_158":159,"_160":161},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_106":88,"_27":100,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":123,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",14,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","6ff20c3a-4dee-11f1-874d-ee650bb23af1","name","fileType","http","content","/**\n * Crossbridge — Attio -> SendPilot Orchestrator (Val Town)\n * ========================================================\n * A single val, \"config per list\". Each Attio list maps to a SendPilot\n * campaign and an owner. Adding a campaign = add ONE entry to CONFIG +\n * its 2 environment variables. No code duplication.\n *\n * ROUTING (anti-collision):\n * The val reads the event's `list_id` and looks up its route in CONFIG.\n * If the list isn't configured, it is ignored (no-op). That's why the\n * existing Outreach flow is NOT affected.\n *\n * ON / OFF FROM ATTIO (per list):\n * - Added to the list (list-entry.created) = ON -> add the lead to the campaign\n * - Removed from list (list-entry.deleted) = OFF -> the lead is set to DONE\n * (its sequence is stopped)\n *\n * PER-CAMPAIGN MASTER SWITCH (optional):\n * The variable _ENABLED = \"false\" disables a whole route without\n * deleting anything (handy to pause an entire campaign).\n *\n * ENVIRONMENT VARIABLES\n * ATTIO_TOKEN (required)\n * SENDPILOT_API_KEY (required)\n * --- Existing route: Outreach ---\n * SENDPILOT_OUTREACH_LIST_ID (Attio list that triggers the flow)\n * SENDPILOT_CAMPAIGN_ID (destination SendPilot campaign)\n * OUTREACH_ENABLED (optional; \"false\" to pause)\n * --- New route: San Francisco (Claudia's campaign) ---\n * SANFRANCISCO_ATTIO_LIST_ID (Attio list that triggers this campaign)\n * SENDPILOT_SANFRANCISCO_CAMPAIGN_ID (destination SendPilot campaign)\n * SANFRANCISCO_ENABLED (optional; \"false\" to pause)\n *\n * To add another campaign: copy the San Francisco block in buildConfig(),\n * change the prefix (e.g. \"NEWYORK_\") and create its 2 variables. That's it.\n */\n\nconst ATTIO_API = \"https://api.attio.com/v2\";\nconst SENDPILOT_API = \"https://api.sendpilot.ai/v1\";\n\n// SendPilot status a lead is set to when it leaves the list (OFF).\n// Valid enum for the PATCH /v1/leads/{id}/status endpoint:\n// PENDING | CONNECTION_SENT | CONNECTION_ACCEPTED | MESSAGE_SENT | REPLY_RECEIVED | DONE\n// \"DONE\" stops the sequence. Change it here if you prefer a different criterion.\nconst OFF_STATUS = \"DONE\";\n\ninterface CampaignRoute {\n owner: string;\n attioListId: string;\n sendpilotCampaignId: string;\n enabled: boolean;\n}\n\ninterface AttioEvent {\n eventType: string;\n listId: string;\n recordId: string;\n entryId: string;\n attributeId: string;\n}\n\ninterface Lead {\n linkedinUrl: string;\n firstName: string;\n lastName: string;\n title: string;\n email: string;\n}\n\n/** Builds the route map from environment variables. */\nfunction buildConfig(): CampaignRoute[] {\n const flag = (name: string) =>\n (Deno.env.get(name) ?? \"true\").toLowerCase() !== \"false\";\n\n const routes: CampaignRoute[] = [\n {\n owner: \"Outreach (existing)\",\n attioListId: Deno.env.get(\"SENDPILOT_OUTREACH_LIST_ID\") ?? \"\",\n sendpilotCampaignId: Deno.env.get(\"SENDPILOT_CAMPAIGN_ID\") ?? \"\",\n enabled: flag(\"OUTREACH_ENABLED\"),\n },\n {\n owner: \"San Francisco (Claudia)\",\n attioListId: Deno.env.get(\"SANFRANCISCO_ATTIO_LIST_ID\") ?? \"\",\n sendpilotCampaignId: Deno.env.get(\"SENDPILOT_SANFRANCISCO_CAMPAIGN_ID\") ??\n \"\",\n enabled: flag(\"SANFRANCISCO_ENABLED\"),\n },\n ];\n\n // Only fully-configured routes (list + campaign).\n return routes.filter((r) => r.attioListId && r.sendpilotCampaignId);\n}\n\n/** Normalizes the Attio payload into a list of manageable events. */\nfunction parseEvents(payload: any): AttioEvent[] {\n const raw = Array.isArray(payload?.events) && payload.events.length\n ? payload.events\n : [payload?.data ?? payload];\n\n return raw.map((ev: any) => ({\n eventType: ev?.event_type ?? ev?.type ?? \"\",\n listId: ev?.id?.list_id ?? ev?.list_id ?? ev?.data?.list_id ??\n payload?.list_id ?? \"\",\n recordId: ev?.parent_record_id ?? ev?.id?.parent_record_id ??\n ev?.data?.parent_record_id ?? ev?.record_id ??\n payload?.parent_record_id ?? payload?.record_id ?? \"\",\n entryId: ev?.id?.entry_id ?? ev?.entry_id ?? ev?.data?.entry_id ?? \"\",\n attributeId: ev?.id?.attribute_id ?? ev?.attribute_id ?? \"\",\n }));\n}\n\n/** Fetches the full person record from Attio. */\nasync function getAttioPerson(token: string, recordId: string): Promise {\n const res = await fetch(\n `${ATTIO_API}/objects/people/records/${recordId}`,\n {\n headers: { Authorization: `Bearer ${token}`, Accept: \"application/json\" },\n },\n );\n if (!res.ok) {\n throw new Error(`Attio ${res.status}: ${await res.text()}`);\n }\n const json = await res.json();\n return json?.data?.values ?? {};\n}\n\n/** Extracts the lead fields from the Attio `values`. */\nfunction extractLead(values: any): Lead {\n return {\n linkedinUrl: values?.linkedin?.[0]?.value ?? \"\",\n firstName: values?.name?.[0]?.first_name ?? \"\",\n lastName: values?.name?.[0]?.last_name ?? \"\",\n title: values?.job_title?.[0]?.value ?? \"\",\n email: values?.email_addresses?.[0]?.email_address ?? \"\",\n };\n}\n\n/** Normalizes a LinkedIn URL for robust comparison. */\nfunction normalizeLinkedIn(url: string): string {\n return (url ?? \"\")\n .trim()\n .toLowerCase()\n .replace(/^https?:\\/\\//, \"\")\n .replace(/^www\\./, \"\")\n .split(\"?\")[0]\n .split(\"#\")[0]\n .replace(/\\/+$/, \"\");\n}\n\n/** ON: adds the lead to the SendPilot campaign. */\nasync function addLead(apiKey: string, campaignId: string, lead: Lead) {\n const leadBody: any = {\n linkedinUrl: lead.linkedinUrl,\n firstName: lead.firstName,\n lastName: lead.lastName,\n title: lead.title,\n };\n if (lead.email) leadBody.email = lead.email;\n\n const res = await fetch(`${SENDPILOT_API}/leads`, {\n method: \"POST\",\n headers: { \"X-API-Key\": apiKey, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ campaignId, leads: [leadBody] }),\n });\n return {\n ok: res.ok,\n status: res.status,\n result: await res.json().catch(() => ({})),\n };\n}\n\n/** Finds the lead in a campaign by LinkedIn URL and returns its SendPilot ID. */\nasync function findLeadId(\n apiKey: string,\n campaignId: string,\n linkedinUrl: string,\n): Promise {\n const target = normalizeLinkedIn(linkedinUrl);\n const limit = 100;\n\n for (let page = 1; page <= 50; page++) { // safety cap\n const res = await fetch(\n `${SENDPILOT_API}/leads?campaignId=${\n encodeURIComponent(campaignId)\n }&page=${page}&limit=${limit}`,\n { headers: { \"X-API-Key\": apiKey, Accept: \"application/json\" } },\n );\n if (!res.ok) break;\n\n const data = await res.json();\n const leads: any[] = data?.leads ?? [];\n const match = leads.find((l) =>\n normalizeLinkedIn(l?.linkedinUrl) === target\n );\n if (match?.id) return match.id;\n\n const totalPages = data?.pagination?.totalPages ?? 1;\n if (leads.length === 0 || page >= totalPages) break;\n }\n return null;\n}\n\n/** OFF: updates the lead status (stops its sequence). */\nasync function setLeadStatus(\n apiKey: string,\n leadId: string,\n status: string,\n note: string,\n) {\n const res = await fetch(`${SENDPILOT_API}/leads/${leadId}/status`, {\n method: \"PATCH\",\n headers: { \"X-API-Key\": apiKey, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ status, note }),\n });\n return {\n ok: res.ok,\n status: res.status,\n result: await res.json().catch(() => ({})),\n };\n}\n\n/** Processes a single Attio event based on its route and type (ON/OFF). */\nasync function handleEvent(\n ev: AttioEvent,\n config: CampaignRoute[],\n attioToken: string,\n sendpilotKey: string,\n) {\n if (!ev.listId) {\n return { skipped: true, reason: \"Event has no list_id\" };\n }\n\n const route = config.find((r) => r.attioListId === ev.listId);\n if (!route) {\n // Unconfigured list -> ignored. This protects the existing flow.\n return {\n skipped: true,\n reason: \"List not configured (ignored)\",\n listId: ev.listId,\n };\n }\n if (!route.enabled) {\n return {\n skipped: true,\n reason: \"Campaign disabled (ENABLED=false)\",\n owner: route.owner,\n };\n }\n if (!ev.recordId) {\n return {\n skipped: true,\n reason: \"Event has no parent_record_id\",\n owner: route.owner,\n };\n }\n\n const isOn = ev.eventType === \"list-entry.created\";\n const isOff = ev.eventType === \"list-entry.deleted\";\n if (!isOn && !isOff) {\n return {\n skipped: true,\n reason: `Unhandled event_type: ${ev.eventType}`,\n owner: route.owner,\n };\n }\n\n const lead = extractLead(await getAttioPerson(attioToken, ev.recordId));\n if (!lead.linkedinUrl) {\n return {\n skipped: true,\n reason: \"Contact has no LinkedIn URL\",\n owner: route.owner,\n contact: { firstName: lead.firstName, lastName: lead.lastName },\n };\n }\n\n // --- ON: add to campaign ---\n if (isOn) {\n const r = await addLead(sendpilotKey, route.sendpilotCampaignId, lead);\n return {\n action: \"ON\",\n owner: route.owner,\n ok: r.ok,\n contact: lead,\n sendpilot: r.result,\n };\n }\n\n // --- OFF: find the lead and stop its sequence ---\n const leadId = await findLeadId(\n sendpilotKey,\n route.sendpilotCampaignId,\n lead.linkedinUrl,\n );\n if (!leadId) {\n return {\n action: \"OFF\",\n owner: route.owner,\n skipped: true,\n reason: \"Lead not found in campaign (may already be gone)\",\n contact: lead,\n };\n }\n const r = await setLeadStatus(\n sendpilotKey,\n leadId,\n OFF_STATUS,\n \"Removed from Attio list (OFF)\",\n );\n return {\n action: \"OFF\",\n owner: route.owner,\n ok: r.ok,\n leadId,\n contact: lead,\n sendpilot: r.result,\n };\n}\n\nfunction jsonResponse(body: unknown, status: number): Response {\n return new Response(JSON.stringify(body), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n // ------------------------------------------------------------------\n // ONE-TIME SETUP HELPER (GET, protected by the SETUP_SECRET env var).\n // Open these in your browser, replacing with your SETUP_SECRET:\n // /?setup=&action=list-webhooks -> show current Attio webhooks\n // /?setup=&action=create-updated-webhook -> create a list-entry.updated webhook -> this val\n // /?setup=&action=list-attributes -> show the Outreach list's attributes\n // (add &list= to inspect a different list)\n // Safe to leave in place: every action requires the secret.\n // ------------------------------------------------------------------\n if (req.method === \"GET\") {\n const setup = url.searchParams.get(\"setup\");\n const SETUP_SECRET = Deno.env.get(\"SETUP_SECRET\");\n const token = Deno.env.get(\"ATTIO_TOKEN\");\n if (!setup || !SETUP_SECRET || setup !== SETUP_SECRET) {\n return jsonResponse({ error: \"Method not allowed\" }, 405);\n }\n if (!token) return jsonResponse({ error: \"Missing ATTIO_TOKEN\" }, 500);\n\n const action = url.searchParams.get(\"action\");\n const authHeaders = { Authorization: `Bearer ${token}` };\n\n if (action === \"list-webhooks\") {\n const res = await fetch(`${ATTIO_API}/webhooks`, {\n headers: { ...authHeaders, Accept: \"application/json\" },\n });\n return jsonResponse({\n ok: res.ok,\n status: res.status,\n result: await res.json().catch(() => ({})),\n }, res.ok ? 200 : 500);\n }\n\n if (action === \"create-updated-webhook\") {\n const listIds = buildConfig().map((r) => r.attioListId).filter(Boolean);\n const filter = listIds.length\n ? {\n $or: listIds.map((id) => ({\n field: \"id.list_id\",\n operator: \"equals\",\n value: id,\n })),\n }\n : null;\n const res = await fetch(`${ATTIO_API}/webhooks`, {\n method: \"POST\",\n headers: { ...authHeaders, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n data: {\n target_url: `${url.origin}/`,\n subscriptions: [{ event_type: \"list-entry.updated\", filter }],\n },\n }),\n });\n return jsonResponse({\n ok: res.ok,\n status: res.status,\n result: await res.json().catch(() => ({})),\n }, res.ok ? 200 : 500);\n }\n\n if (action === \"list-attributes\") {\n const list = url.searchParams.get(\"list\") ??\n Deno.env.get(\"SENDPILOT_OUTREACH_LIST_ID\") ?? \"\";\n if (!list) {\n return jsonResponse({\n error: \"Missing ?list= and no SENDPILOT_OUTREACH_LIST_ID set\",\n }, 400);\n }\n const res = await fetch(`${ATTIO_API}/lists/${list}/attributes`, {\n headers: { ...authHeaders, Accept: \"application/json\" },\n });\n return jsonResponse({\n ok: res.ok,\n status: res.status,\n result: await res.json().catch(() => ({})),\n }, res.ok ? 200 : 500);\n }\n\n return jsonResponse({\n error:\n \"Unknown action (use list-webhooks | create-updated-webhook | list-attributes)\",\n }, 400);\n }\n\n if (req.method !== \"POST\") {\n return jsonResponse({ error: \"Method not allowed\" }, 405);\n }\n\n const ATTIO_TOKEN = Deno.env.get(\"ATTIO_TOKEN\");\n const SENDPILOT_API_KEY = Deno.env.get(\"SENDPILOT_API_KEY\");\n if (!ATTIO_TOKEN || !SENDPILOT_API_KEY) {\n return jsonResponse(\n { error: \"Missing env vars: ATTIO_TOKEN and/or SENDPILOT_API_KEY\" },\n 500,\n );\n }\n\n const config = buildConfig();\n if (config.length === 0) {\n return jsonResponse({\n error: \"No routes configured (check list/campaign env vars)\",\n }, 500);\n }\n\n let payload: any;\n try {\n payload = await req.json();\n } catch {\n return jsonResponse({ error: \"Invalid JSON body\" }, 400);\n }\n\n const events = parseEvents(payload);\n // Diagnostic log: prints each event (event_type, list_id, record_id) in the val's Logs.\n // Useful to discover the list_id of a new list (e.g. San Francisco / Claudia).\n console.log(\"ATTIO EVENT(S) received:\", JSON.stringify(events));\n\n const results: any[] = [];\n for (const ev of events) {\n try {\n results.push(\n await handleEvent(ev, config, ATTIO_TOKEN, SENDPILOT_API_KEY),\n );\n } catch (err) {\n results.push({ ok: false, error: String(err), event: ev });\n }\n }\n\n // Respond 200 to acknowledge receipt to Attio (prevents retry loops).\n // Per-event detail is in `results`.\n return jsonResponse({ received: events.length, results }, 200);\n}","/**\n * Crossbridge — Attio -> SendPilot Orchestrator (Val Town)\n * ========================================================\n * A single val, \"config per list\". Each Attio list maps to a SendPilot\n * campaign and an owner. Adding a campaign = add ONE entry to CONFIG +\n * its 2 environment variables. No code duplication.\n *\n * ROUTING (anti-collision):\n * The val reads the event's `list_id` and looks up its route in CONFIG.\n * If the list isn't configured, it is ignored (no-op).\n *\n * ON / OFF FROM ATTIO (per list):\n * - Added to the list (list-entry.created)\n * → automation = ON → lead added to campaign\n * → automation = OFF → skipped (no-op)\n * - Attribute updated (list-entry.updated)\n * → automation changed to ON → lead added to campaign\n * → any other change → skipped (no-op)\n * - Removed from list (list-entry.deleted)\n * → lead is set to DONE (sequence stopped)\n *\n * AUTOMATION ATTRIBUTE:\n * Select attribute with slug `automation`, options ON / OFF (default OFF).\n *\n * PER-CAMPAIGN MASTER SWITCH (optional):\n * _ENABLED = \"false\" pauses a whole route without deleting anything.\n *\n * ENVIRONMENT VARIABLES\n * ATTIO_TOKEN (required)\n * SENDPILOT_API_KEY (required)\n * --- Existing route: Outreach ---\n * SENDPILOT_OUTREACH_LIST_ID\n * SENDPILOT_CAMPAIGN_ID\n * OUTREACH_ENABLED (optional; \"false\" to pause)\n * --- Route: San Francisco (Claudia) ---\n * SANFRANCISCO_ATTIO_LIST_ID\n * SENDPILOT_SANFRANCISCO_CAMPAIGN_ID\n * SANFRANCISCO_ENABLED (optional; \"false\" to pause)\n *\n * To add another campaign: copy a block in buildConfig(), change the prefix,\n * create its 2 env vars. That's it.\n */\n\nconst ATTIO_API = \"https://api.attio.com/v2\";\nconst SENDPILOT_API = \"https://api.sendpilot.ai/v1\";\n\nconst OFF_STATUS = \"DONE\";\n\ninterface CampaignRoute {\n owner: string;\n attioListId: string;\n sendpilotCampaignId: string;\n enabled: boolean;\n}\n\ninterface AttioEvent {\n eventType: string;\n listId: string;\n recordId: string;\n}\n\ninterface Lead {\n linkedinUrl: string;\n firstName: string;\n lastName: string;\n title: string;\n email: string;\n}\n\nfunction buildConfig(): CampaignRoute[] {\n const flag = (name: string) =>\n (Deno.env.get(name) ?? \"true\").toLowerCase() !== \"false\";\n\n const routes: CampaignRoute[] = [\n {\n owner: \"Outreach (existing)\",\n attioListId: Deno.env.get(\"SENDPILOT_OUTREACH_LIST_ID\") ?? \"\",\n sendpilotCampaignId: Deno.env.get(\"SENDPILOT_CAMPAIGN_ID\") ?? \"\",\n enabled: flag(\"OUTREACH_ENABLED\"),\n },\n {\n owner: \"San Francisco (Claudia)\",\n attioListId: Deno.env.get(\"SANFRANCISCO_ATTIO_LIST_ID\") ?? \"\",\n sendpilotCampaignId: Deno.env.get(\"SENDPILOT_SANFRANCISCO_CAMPAIGN_ID\") ??\n \"\",\n enabled: flag(\"SANFRANCISCO_ENABLED\"),\n },\n ];\n\n return routes.filter((r) => r.attioListId && r.sendpilotCampaignId);\n}\n\nfunction parseEvents(payload: any): AttioEvent[] {\n const raw = Array.isArray(payload?.events) && payload.events.length\n ? payload.events\n : [payload?.data ?? payload];\n\n return raw.map((ev: any) => ({\n eventType: ev?.event_type ?? ev?.type ?? \"\",\n listId: ev?.id?.list_id ?? ev?.list_id ?? ev?.data?.list_id ??\n payload?.list_id ?? \"\",\n recordId: ev?.parent_record_id ?? ev?.id?.parent_record_id ??\n ev?.data?.parent_record_id ?? ev?.record_id ??\n payload?.parent_record_id ?? payload?.record_id ?? \"\",\n }));\n}\n\nasync function getAttioPerson(token: string, recordId: string): Promise {\n const res = await fetch(\n `${ATTIO_API}/objects/people/records/${recordId}`,\n {\n headers: { Authorization: `Bearer ${token}`, Accept: \"application/json\" },\n },\n );\n if (!res.ok) {\n throw new Error(`Attio ${res.status}: ${await res.text()}`);\n }\n const json = await res.json();\n return json?.data?.values ?? {};\n}\n\nfunction extractLead(values: any): Lead {\n return {\n linkedinUrl: values?.linkedin?.[0]?.value ?? \"\",\n firstName: values?.name?.[0]?.first_name ?? \"\",\n lastName: values?.name?.[0]?.last_name ?? \"\",\n title: values?.job_title?.[0]?.value ?? \"\",\n email: values?.email_addresses?.[0]?.email_address ?? \"\",\n };\n}\n\n/**\n * Reads the `automation` Select attribute.\n * Returns \"ON\" or \"OFF\" (defaults to \"OFF\" if missing).\n */\nfunction getAutomationStatus(values: any): \"ON\" | \"OFF\" {\n const title = values?.automation?.[0]?.option?.title ?? \"OFF\";\n return title.toUpperCase() === \"ON\" ? \"ON\" : \"OFF\";\n}\n\n/**\n * For list-entry.updated events, checks whether the `automation`\n * attribute was the one that changed AND its new value is \"ON\".\n *\n * Attio sends changed attributes in ev.changes (array of { attribute_slug, new_value }).\n * Falls back to reading the full record values if changes aren't present.\n */\nfunction automationJustTurnedOn(ev: any, recordValues: any): boolean {\n // If Attio provides a changes array, use it for precision\n const changes: any[] = ev?.changes ?? [];\n if (changes.length > 0) {\n const automationChange = changes.find(\n (c: any) => c?.attribute_slug === \"automation\",\n );\n if (!automationChange) return false; // automation wasn't the changed attribute\n const newTitle = automationChange?.new_value?.option?.title ?? \"\";\n return newTitle.toUpperCase() === \"ON\";\n }\n\n // Fallback: just check the current value on the record\n return getAutomationStatus(recordValues) === \"ON\";\n}\n\nfunction normalizeLinkedIn(url: string): string {\n return (url ?? \"\")\n .trim()\n .toLowerCase()\n .replace(/^https?:\\/\\//, \"\")\n .replace(/^www\\./, \"\")\n .split(\"?\")[0]\n .split(\"#\")[0]\n .replace(/\\/+$/, \"\");\n}\n\nasync function addLead(apiKey: string, campaignId: string, lead: Lead) {\n const leadBody: any = {\n linkedinUrl: lead.linkedinUrl,\n firstName: lead.firstName,\n lastName: lead.lastName,\n title: lead.title,\n };\n if (lead.email) leadBody.email = lead.email;\n\n const res = await fetch(`${SENDPILOT_API}/leads`, {\n method: \"POST\",\n headers: { \"X-API-Key\": apiKey, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ campaignId, leads: [leadBody] }),\n });\n return {\n ok: res.ok,\n status: res.status,\n result: await res.json().catch(() => ({})),\n };\n}\n\nasync function findLeadId(\n apiKey: string,\n campaignId: string,\n linkedinUrl: string,\n): Promise {\n const target = normalizeLinkedIn(linkedinUrl);\n const limit = 100;\n\n for (let page = 1; page <= 50; page++) {\n const res = await fetch(\n `${SENDPILOT_API}/leads?campaignId=${\n encodeURIComponent(campaignId)\n }&page=${page}&limit=${limit}`,\n { headers: { \"X-API-Key\": apiKey, Accept: \"application/json\" } },\n );\n if (!res.ok) break;\n\n const data = await res.json();\n const leads: any[] = data?.leads ?? [];\n const match = leads.find((l) =>\n normalizeLinkedIn(l?.linkedinUrl) === target\n );\n if (match?.id) return match.id;\n\n const totalPages = data?.pagination?.totalPages ?? 1;\n if (leads.length === 0 || page >= totalPages) break;\n }\n return null;\n}\n\nasync function setLeadStatus(\n apiKey: string,\n leadId: string,\n status: string,\n note: string,\n) {\n const res = await fetch(`${SENDPILOT_API}/leads/${leadId}/status`, {\n method: \"PATCH\",\n headers: { \"X-API-Key\": apiKey, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ status, note }),\n });\n return {\n ok: res.ok,\n status: res.status,\n result: await res.json().catch(() => ({})),\n };\n}\n\nasync function handleEvent(\n ev: AttioEvent,\n rawEv: any,\n config: CampaignRoute[],\n attioToken: string,\n sendpilotKey: string,\n) {\n if (!ev.listId) {\n return { skipped: true, reason: \"Event has no list_id\" };\n }\n\n const route = config.find((r) => r.attioListId === ev.listId);\n if (!route) {\n return {\n skipped: true,\n reason: \"List not configured (ignored)\",\n listId: ev.listId,\n };\n }\n if (!route.enabled) {\n return {\n skipped: true,\n reason: \"Campaign disabled (ENABLED=false)\",\n owner: route.owner,\n };\n }\n if (!ev.recordId) {\n return {\n skipped: true,\n reason: \"Event has no parent_record_id\",\n owner: route.owner,\n };\n }\n\n const isCreated = ev.eventType === \"list-entry.created\";\n const isUpdated = ev.eventType === \"list-entry.updated\";\n const isDeleted = ev.eventType === \"list-entry.deleted\";\n\n if (!isCreated && !isUpdated && !isDeleted) {\n return {\n skipped: true,\n reason: `Unhandled event_type: ${ev.eventType}`,\n owner: route.owner,\n };\n }\n\n const values = await getAttioPerson(attioToken, ev.recordId);\n const lead = extractLead(values);\n\n if (!lead.linkedinUrl) {\n return {\n skipped: true,\n reason: \"Contact has no LinkedIn URL\",\n owner: route.owner,\n contact: { firstName: lead.firstName, lastName: lead.lastName },\n };\n }\n\n // --- CREATED: check automation before adding ---\n if (isCreated) {\n const automationStatus = getAutomationStatus(values);\n console.log(\n `[created] ${lead.firstName} ${lead.lastName} — automation: ${automationStatus}`,\n );\n\n if (automationStatus !== \"ON\") {\n return {\n skipped: true,\n reason: `automation = ${automationStatus} — lead not sent to SendPilot`,\n owner: route.owner,\n contact: { firstName: lead.firstName, lastName: lead.lastName },\n };\n }\n\n const r = await addLead(sendpilotKey, route.sendpilotCampaignId, lead);\n return {\n action: \"ON\",\n owner: route.owner,\n ok: r.ok,\n contact: lead,\n sendpilot: r.result,\n };\n }\n\n // --- UPDATED: only act if automation just turned ON ---\n if (isUpdated) {\n const turnedOn = automationJustTurnedOn(rawEv, values);\n console.log(\n `[updated] ${lead.firstName} ${lead.lastName} — automationJustTurnedOn: ${turnedOn}`,\n );\n\n if (!turnedOn) {\n return {\n skipped: true,\n reason: \"Update did not change automation to ON\",\n owner: route.owner,\n contact: { firstName: lead.firstName, lastName: lead.lastName },\n };\n }\n\n const r = await addLead(sendpilotKey, route.sendpilotCampaignId, lead);\n return {\n action: \"ON (via update)\",\n owner: route.owner,\n ok: r.ok,\n contact: lead,\n sendpilot: r.result,\n };\n }\n\n // --- DELETED: stop the sequence in SendPilot ---\n const leadId = await findLeadId(\n sendpilotKey,\n route.sendpilotCampaignId,\n lead.linkedinUrl,\n );\n if (!leadId) {\n return {\n action: \"OFF\",\n owner: route.owner,\n skipped: true,\n reason: \"Lead not found in campaign (may already be gone)\",\n contact: lead,\n };\n }\n const r = await setLeadStatus(\n sendpilotKey,\n leadId,\n OFF_STATUS,\n \"Removed from Attio list (OFF)\",\n );\n return {\n action: \"OFF\",\n owner: route.owner,\n ok: r.ok,\n leadId,\n contact: lead,\n sendpilot: r.result,\n };\n}\n\nfunction jsonResponse(body: unknown, status: number): Response {\n return new Response(JSON.stringify(body), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") {\n return jsonResponse({ error: \"Method not allowed\" }, 405);\n }\n\n const ATTIO_TOKEN = Deno.env.get(\"ATTIO_TOKEN\");\n const SENDPILOT_API_KEY = Deno.env.get(\"SENDPILOT_API_KEY\");\n if (!ATTIO_TOKEN || !SENDPILOT_API_KEY) {\n return jsonResponse({\n error: \"Missing env vars: ATTIO_TOKEN and/or SENDPILOT_API_KEY\",\n }, 500);\n }\n\n const config = buildConfig();\n if (config.length === 0) {\n return jsonResponse({\n error: \"No routes configured (check list/campaign env vars)\",\n }, 500);\n }\n\n let payload: any;\n try {\n payload = await req.json();\n } catch {\n return jsonResponse({ error: \"Invalid JSON body\" }, 400);\n }\n\n const rawEvents = Array.isArray(payload?.events) && payload.events.length\n ? payload.events\n : [payload?.data ?? payload];\n\n const events = rawEvents.map((ev: any) => ({\n eventType: ev?.event_type ?? ev?.type ?? \"\",\n listId: ev?.id?.list_id ?? ev?.list_id ?? ev?.data?.list_id ??\n payload?.list_id ?? \"\",\n recordId: ev?.parent_record_id ?? ev?.id?.parent_record_id ??\n ev?.data?.parent_record_id ?? ev?.record_id ??\n payload?.parent_record_id ?? payload?.record_id ?? \"\",\n }));\n\n console.log(\"ATTIO EVENT(S) received:\", JSON.stringify(events));\n\n const results: any[] = [];\n for (let i = 0; i < events.length; i++) {\n try {\n results.push(\n await handleEvent(\n events[i],\n rawEvents[i],\n config,\n ATTIO_TOKEN,\n SENDPILOT_API_KEY,\n ),\n );\n } catch (err) {\n results.push({ ok: false, error: String(err), event: events[i] });\n }\n }\n\n return jsonResponse({ received: events.length, results }, 200);\n}","createdAt",["D",1779378159129],"branchVersion","branchId","6fecce64-4dee-11f1-874d-ee650bb23af1","id","6feaf634-4dee-11f1-874d-ee650bb23af1","attio-to-sendpilot",["D",1778582190041],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Automation Attio to Sendpilot","imageUrl","1c9c43a8-9f0c-4174-9674-23ebdf84710f","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e0860-38fe-73fe-b84e-4ba78520350c","tursoName","6feaf6344dee11f1874dee650bb23af1","tursoHostname","6feaf6344dee11f1874dee650bb23af1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789503703835],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":100},"org",{"_98":97,"_99":100,"_101":100,"_18":55,"_102":103,"_104":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",16,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","CrossbridgeMarketing","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":153,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":154,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":155,"_82":156,"_84":157,"_86":25},"tree",[148],"files",[148],"counts",{"_136":61,"_137":138,"_139":61,"_140":141,"_142":143},"contents",[128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":25,"_38":132,"_13":133,"_33":34,"_35":37,"_24":25,"_134":-5,"_27":135},"b27942d2-552b-11f1-a132-ee650bb23af1","parentId","latest",["D",1779378159129],8,"label",[28],"pulls","branches",1,"forks","envVars",{"_144":146,"_147":61},"connections",{"_144":61,"_145":61},"count","unfilledCount",7,"emptyCount",{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":25,"_38":149,"_13":133,"_33":34,"_35":37,"_24":25,"_134":-5,"_150":151,"_27":152},["D",1779378159129],"children",[],[28],["D",1778582190041],["D",1789503703835],{"_98":97,"_105":100},{"_98":97,"_99":100,"_101":100,"_18":55,"_102":103,"_104":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_125":191,"_192":193,"_194":195,"_196":25,"_197":25,"_198":25,"_199":123,"_200":-5,"_201":-7,"_202":-7,"_203":61,"_204":25,"_205":25,"_206":-5,"_207":25,"_208":25,"_209":25,"_210":-5},"ENV",{"_162":163,"_164":165,"_166":88,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v14