[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_157":158,"_159":160},"routes/_app.x.$handle.$name",{"_97":96,"_32":45,"_105":87,"_27":99,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":122,"_123":-5,"_124":-5,"_125":126},"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",16,"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)\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 * Leads are only sent to SendPilot when explicitly set to ON.\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 * SETUP_SECRET (required for GET setup helper)\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/**\n * Reads the `automation` Select attribute from Attio values.\n * Returns \"ON\" or \"OFF\" (defaults to \"OFF\" if missing or unset).\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(rawEv: any, recordValues: any): boolean {\n const changes: any[] = rawEv?.changes ?? [];\n if (changes.length > 0) {\n const automationChange = changes.find(\n (c: any) => c?.attribute_slug === \"automation\",\n );\n if (!automationChange) return false;\n const newTitle = automationChange?.new_value?.option?.title ?? \"\";\n return newTitle.toUpperCase() === \"ON\";\n }\n // Fallback: check current value on the record\n return getAutomationStatus(recordValues) === \"ON\";\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. */\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 // 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 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: 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\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\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 rawEvents = Array.isArray(payload?.events) && payload.events.length\n ? payload.events\n : [payload?.data ?? payload];\n\n const events: AttioEvent[] = 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 entryId: ev?.id?.entry_id ?? ev?.entry_id ?? ev?.data?.entry_id ?? \"\",\n attributeId: ev?.id?.attribute_id ?? ev?.attribute_id ?? \"\",\n }));\n\n // Diagnostic log: prints each event (event_type, list_id, record_id) in the val's Logs.\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 // Respond 200 to acknowledge receipt to Attio (prevents retry loops).\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). That's why the\n * existing Outreach flow is NOT affected.\n *\n * ON / OFF FROM ATTIO (per list, via the `sendpilot_automation` column):\n * The column is a STATUS attribute on the list (values \"On\" / \"Off\").\n * It lives on the LIST ENTRY, not on the person record, so it is read\n * with GET /v2/lists/{list}/entries/{entry}.\n *\n * - Added to the list (list-entry.created)\n * column == \"Off\" -> skipped (no-op)\n * column == \"On\" / unset -> lead added to campaign (default ON)\n * - Entry updated (list-entry.updated)\n * column == \"Off\" -> lead set to DONE (sequence stopped)\n * column == \"On\" -> lead added IF not already in campaign\n * column unset / unknown -> skipped (avoids re-adding on edits)\n * - Removed from list (list-entry.deleted)\n * -> lead set to DONE (sequence stopped)\n *\n * DESIGN NOTE — default ON is also the SAFE choice: if the column is\n * empty, missing, or the value can't be read, the val behaves exactly\n * like before (adds on entry). Only an EXPLICIT \"Off\" changes behavior.\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 * IMPORTANT — webhook subscriptions:\n * `list-entry.created` is workspace-wide and already reaches this val.\n * `list-entry.updated` and `list-entry.deleted` must be subscribed once\n * (see the GET setup helper below). That requires the ATTIO_TOKEN to have\n * the \"Webhooks: Read-write\" scope.\n *\n * ENVIRONMENT VARIABLES\n * ATTIO_TOKEN (required)\n * SENDPILOT_API_KEY (required)\n * SETUP_SECRET (required for the GET setup helper)\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 goes OFF.\n// Valid enum for PATCH /v1/leads/{id}/status:\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\n// Slug of the ON/OFF status column in Attio. Same name on every list so the\n// auto-generated slug matches. (Discovered on the Outreach list.)\nconst AUTOMATION_SLUGS = [\"sendpilot_automation\", \"automation\"];\n\ntype AutomationState = \"ON\" | \"OFF\" | \"UNSET\";\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 (used for lead fields). */\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 person ${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 person `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/**\n * Fetches the list ENTRY and reads the ON/OFF status column from it.\n * The column is list-specific, so it lives on the entry, not the record.\n * Tolerant to the value shape (status / option / plain value) and to the\n * response field name (entry_values / values).\n * Returns \"ON\" | \"OFF\" | \"UNSET\". On any error -> \"UNSET\" (safe default).\n */\nasync function getAutomationState(\n token: string,\n listId: string,\n entryId: string,\n): Promise {\n if (!listId || !entryId) return \"UNSET\";\n try {\n const res = await fetch(\n `${ATTIO_API}/lists/${listId}/entries/${entryId}`,\n {\n headers: {\n Authorization: `Bearer ${token}`,\n Accept: \"application/json\",\n },\n },\n );\n if (!res.ok) return \"UNSET\";\n const json = await res.json();\n const data = json?.data ?? {};\n const bag = data.entry_values ?? data.values ?? {};\n\n for (const slug of AUTOMATION_SLUGS) {\n const arr = bag?.[slug];\n const first = Array.isArray(arr) ? arr[0] : arr;\n if (!first) continue;\n const title: string = first?.status?.title ??\n first?.option?.title ??\n first?.value ??\n \"\";\n const t = String(title).trim().toUpperCase();\n if (t === \"ON\") return \"ON\";\n if (t === \"OFF\") return \"OFF\";\n }\n return \"UNSET\";\n } catch {\n return \"UNSET\";\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. */\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 isCreated = ev.eventType === \"list-entry.created\";\n const isUpdated = ev.eventType === \"list-entry.updated\";\n const isDeleted = ev.eventType === \"list-entry.deleted\";\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 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 // --- DELETED: removed from the list -> stop the sequence ---\n if (isDeleted) {\n const leadId = await findLeadId(\n sendpilotKey,\n route.sendpilotCampaignId,\n lead.linkedinUrl,\n );\n if (!leadId) {\n return {\n action: \"OFF (removed)\",\n owner: route.owner,\n skipped: true,\n reason: \"Lead not found in campaign\",\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 (removed)\",\n owner: route.owner,\n ok: r.ok,\n leadId,\n contact: lead,\n sendpilot: r.result,\n };\n }\n\n // For created/updated, read the ON/OFF column from the list entry.\n const state = await getAutomationState(attioToken, ev.listId, ev.entryId);\n console.log(\n `[${ev.eventType}] ${lead.firstName} ${lead.lastName} — automation: ${state}`,\n );\n\n // --- CREATED: add unless explicitly OFF (default ON / non-breaking) ---\n if (isCreated) {\n if (state === \"OFF\") {\n return {\n action: \"skip\",\n owner: route.owner,\n skipped: true,\n reason: \"automation = OFF\",\n contact: lead,\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: act only on an explicit ON/OFF; idempotent (no duplicates) ---\n const existingId = await findLeadId(\n sendpilotKey,\n route.sendpilotCampaignId,\n lead.linkedinUrl,\n );\n\n if (state === \"OFF\") {\n if (!existingId) {\n return {\n action: \"OFF (column)\",\n owner: route.owner,\n skipped: true,\n reason: \"Lead not in campaign\",\n contact: lead,\n };\n }\n const r = await setLeadStatus(\n sendpilotKey,\n existingId,\n OFF_STATUS,\n \"Set to Off in Attio (OFF)\",\n );\n return {\n action: \"OFF (column)\",\n owner: route.owner,\n ok: r.ok,\n leadId: existingId,\n contact: lead,\n sendpilot: r.result,\n };\n }\n\n if (state === \"ON\") {\n if (existingId) {\n return {\n action: \"ON (column)\",\n owner: route.owner,\n skipped: true,\n reason: \"Already in campaign\",\n leadId: existingId,\n contact: lead,\n };\n }\n const r = await addLead(sendpilotKey, route.sendpilotCampaignId, lead);\n return {\n action: \"ON (column)\",\n owner: route.owner,\n ok: r.ok,\n contact: lead,\n sendpilot: r.result,\n };\n }\n\n // state UNSET -> ignore the update (it was some other field).\n return {\n action: \"skip\",\n owner: route.owner,\n skipped: true,\n reason: \"Update not an ON/OFF change\",\n contact: lead,\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-webhooks -> subscribe list-entry.updated + .deleted -> this val\n // /?setup=&action=list-attributes -> show a list's attributes (find the column slug)\n // (add &list= to inspect a different list; defaults to Outreach)\n // /?setup=&action=inspect-entry&list=&entry=\n // -> dump a list entry's raw values (confirm the column shape)\n // Every action requires the secret, so it is safe to leave in place.\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\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-webhooks\") {\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\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: [\n { event_type: \"list-entry.updated\", filter },\n { event_type: \"list-entry.deleted\", filter },\n ],\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 if (action === \"inspect-entry\") {\n const list = url.searchParams.get(\"list\") ?? \"\";\n const entry = url.searchParams.get(\"entry\") ?? \"\";\n if (!list || !entry) {\n return jsonResponse({ error: \"Missing ?list= and/or ?entry=\" }, 400);\n }\n const res = await fetch(`${ATTIO_API}/lists/${list}/entries/${entry}`, {\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-webhooks | list-attributes | inspect-entry)\",\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 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\n // Diagnostic log: prints each event (event_type, list_id, record_id, entry_id) in the val's Logs.\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 return jsonResponse({ received: events.length, results }, 200);\n}","createdAt",["D",1779459916709],"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",{"_97":96,"_104":99},"org",{"_97":96,"_98":99,"_100":99,"_18":55,"_101":102,"_103":25},"branch",{"_13":14,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","CrossbridgeMarketing","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":152,"_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":153,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":154,"_82":155,"_84":156,"_86":25},"tree",[147],"files",[147],"counts",{"_135":61,"_136":137,"_138":61,"_139":140,"_141":142},"contents",[127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":122,"_38":131,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_27":134},"0dca8100-55ea-11f1-b10b-ee650bb23af1","parentId","latest",["D",1779459916709],10,"label",[28],"pulls","branches",1,"forks","envVars",{"_143":145,"_146":61},"connections",{"_143":61,"_144":61},"count","unfilledCount",7,"emptyCount",{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":122,"_38":148,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_149":150,"_27":151},["D",1779459916709],"children",[],[28],["D",1778582190041],["D",1789503703835],{"_97":96,"_104":99},{"_97":96,"_98":99,"_100":99,"_18":55,"_101":102,"_103":25},{"_13":14,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_80":-5,"_124":190,"_191":192,"_193":194,"_195":25,"_196":25,"_197":25,"_198":122,"_199":-5,"_200":-7,"_201":-7,"_202":61,"_203":25,"_204":25,"_205":-5,"_206":25,"_207":25,"_208":25,"_209":-5},"ENV",{"_161":162,"_163":164,"_165":87,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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 · v16