[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_153":154,"_155":156},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_90":-7,"_91":84,"_29":-7,"_92":-5,"_15":93,"_94":95,"_96":97,"_98":99,"_100":101,"_102":-5,"_103":-5,"_104":-5,"_105":38,"_106":107,"_108":109,"_110":-5,"_111":-5,"_112":113},"routes/_app.x.$handle.$name.branches",{"_11":12,"_13":14,"_15":16,"_17":18},"handle","CrossbridgeMarketing","name","attio-to-sendpilot","project",{"_20":28,"_13":14,"_22":36,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":38,"_49":-5,"_50":-5,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":-5,"_62":63,"_64":63,"_65":66,"_67":66,"_68":66,"_69":63,"_70":63,"_71":72,"_73":74,"_75":76,"_77":38},"branches",[19],{"_20":21,"_22":23,"_24":25,"_13":26,"_27":28,"_29":30,"_31":-5,"_32":-5,"_33":34,"_35":-5},"id","6fecce64-4dee-11f1-874d-ee650bb23af1","createdAt",["D",1778582190054],"updatedAt",["D",1779459916709],"main","projectId","6feaf634-4dee-11f1-874d-ee650bb23af1","version",16,"forkedBranchId","forkedBranchVersion","lockfileKey","1779459917200-esm.town_v_CrossbridgeMarketing_attio-to-sendpilot@16-main","deletedAt",["D",1778582190041],"legacyEnvVars",false,"privacy","public","httpPrivacy","description","Automation Attio to Sendpilot","imageUrl","userId","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",{"_11":12,"_89":84},"org",{"_11":12,"_83":84,"_85":84,"_45":46,"_86":87,"_88":38},"branch",{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_78":-5,"_79":-5,"_80":-5,"_81":14,"_82":12},"isOwned","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","path","adoptOrgId",{"_20":28,"_13":14,"_22":148,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":38,"_49":-5,"_50":-5,"_51":52,"_53":54,"_55":56,"_57":58,"_59":149,"_61":-5,"_62":63,"_64":63,"_65":66,"_67":66,"_68":66,"_69":63,"_70":63,"_71":150,"_73":151,"_75":152,"_77":38},"tree",[143],"files",[143],"counts",{"_132":52,"_17":133,"_134":52,"_135":136,"_137":138},"contents",[114],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_20":115,"_13":116,"_117":118,"_119":-5,"_120":21,"_121":30,"_122":109,"_22":123,"_29":124,"_125":126,"_127":128,"_129":38,"_130":-5,"_91":131},"0dca8100-55ea-11f1-b10b-ee650bb23af1","main.ts","fileId","6ff20c3a-4dee-11f1-874d-ee650bb23af1","parentId","branchId","branchVersion","latest",["D",1779459916709],10,"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, 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}","deleted","label",[116],"pulls",1,"forks","envVars",{"_139":141,"_142":52},"connections",{"_139":52,"_140":52},"count","unfilledCount",7,"emptyCount",{"_20":115,"_13":116,"_117":118,"_119":-5,"_120":21,"_121":30,"_122":109,"_22":144,"_29":124,"_125":126,"_127":128,"_129":38,"_130":-5,"_145":146,"_91":147},["D",1779459916709],"children",[],[116],["D",1778582190041],["D",1789503703835],{"_11":12,"_89":84},{"_11":12,"_83":84,"_85":84,"_45":46,"_86":87,"_88":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_78":-5,"_79":-5,"_80":-5,"_81":14,"_82":12},"ctx",{"_71":-5,"_111":186,"_187":188,"_189":190,"_191":38,"_192":38,"_193":38,"_194":109,"_195":-5,"_196":-7,"_197":-7,"_198":52,"_199":38,"_200":38,"_201":-5,"_202":38,"_203":38,"_204":38,"_205":-5},"ENV",{"_157":158,"_159":160,"_161":26,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185},"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"]

Branches1

Branches
1