[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_292":293,"_294":295},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_242":79,"_48":-7,"_243":-5,"_17":244,"_245":246,"_247":248,"_249":250,"_251":252,"_62":-5,"_253":-5,"_254":-5,"_255":24,"_256":257,"_258":118,"_259":-5,"_260":-5,"_261":262},"routes/_app.x.$handle.$name.branch.$branch.history",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-5},"handle","CrossbridgeMarketing","name","attio-to-sendpilot","branchName","main","project",{"_42":192,"_13":14,"_46":193,"_194":-5,"_195":24,"_196":197,"_198":197,"_199":200,"_201":-5,"_25":77,"_202":-5,"_203":24,"_204":-5,"_205":-5,"_206":20,"_50":51,"_207":208,"_209":210,"_211":212,"_213":-5,"_214":215,"_216":215,"_217":218,"_219":218,"_220":218,"_221":215,"_222":215,"_60":223,"_224":225,"_226":227,"_228":24},"page",0,"history",[26,27,28,29,30,31,32,33,34,35,36,37,38,39,40,41],"hasNext",false,"userId",{"_42":185,"_44":45,"_46":186,"_48":187,"_50":51,"_52":178,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":188,"_62":189,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":190},{"_42":178,"_44":45,"_46":179,"_48":180,"_50":51,"_52":171,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":181,"_62":182,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":183},{"_42":171,"_44":45,"_46":172,"_48":173,"_50":51,"_52":164,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":174,"_62":175,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":176},{"_42":164,"_44":45,"_46":165,"_48":166,"_50":51,"_52":157,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":167,"_62":168,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":169},{"_42":157,"_44":45,"_46":158,"_48":159,"_50":51,"_52":150,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":160,"_62":161,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":162},{"_42":150,"_44":45,"_46":151,"_48":152,"_50":51,"_52":143,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":153,"_62":154,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":155},{"_42":143,"_44":45,"_46":144,"_48":145,"_50":51,"_52":136,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":146,"_62":147,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":148},{"_42":136,"_44":45,"_46":137,"_48":138,"_50":51,"_52":128,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":139,"_62":140,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":141},{"_42":128,"_44":45,"_46":129,"_48":130,"_50":51,"_52":119,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":131,"_62":132,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":133},{"_42":119,"_44":45,"_46":120,"_48":121,"_50":51,"_52":111,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":122,"_62":123,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":124},{"_42":111,"_44":45,"_46":112,"_48":113,"_50":51,"_52":102,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":114,"_62":115,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":116},{"_42":102,"_44":45,"_46":103,"_48":104,"_50":51,"_52":95,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":105,"_62":106,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":107},{"_42":95,"_44":45,"_46":96,"_48":97,"_50":51,"_52":87,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":98,"_62":99,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":100},{"_42":87,"_44":45,"_46":88,"_48":89,"_50":51,"_52":80,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":90,"_62":91,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":92},{"_42":80,"_44":45,"_46":81,"_48":82,"_50":51,"_52":43,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":83,"_62":84,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":85},{"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69},"id","6ffa2636-4dee-11f1-874d-ee650bb23af1","branchId","6fecce64-4dee-11f1-874d-ee650bb23af1","createdAt",["D",1778582190075],"version",1,"orgId","019e0860-38fe-73fe-b84e-4ba78520350c","parentId","incomingCommitId","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","clientLabel","user",{"_42":77,"_50":51,"_11":12,"_78":79},"file",{"_71":72,"_13":73,"_74":75,"_76":24},"pull","merge","revert","multiple","commits",[70],{"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5},"fileId","6ff20c3a-4dee-11f1-874d-ee650bb23af1","main.ts","fileType","script","deleted","1c9c43a8-9f0c-4174-9674-23ebdf84710f","avatar","","a78ea3ec-4dee-11f1-8505-ee650bb23af1",["D",1778582283367],2,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":75,"_76":24},[86],{"_42":80,"_44":45,"_46":81,"_48":82,"_50":51,"_52":43,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":83,"_62":84,"_64":-5,"_65":-5,"_66":-5},"237c7f1e-4df0-11f1-aa4e-ee650bb23af1",["D",1778582920778],3,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[93],{"_42":87,"_44":45,"_46":88,"_48":89,"_50":51,"_52":80,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":90,"_62":91,"_64":-5,"_65":-5,"_66":-5},"http","817eedb6-4df2-11f1-9aef-ee650bb23af1",["D",1778583937484],4,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[101],{"_42":95,"_44":45,"_46":96,"_48":97,"_50":51,"_52":87,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":98,"_62":99,"_64":-5,"_65":-5,"_66":-5},"b0dd33ce-5423-11f1-b225-ee650bb23af1",["D",1779264769286],5,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":109,"_13":110,"_74":75,"_76":24},[108],{"_42":102,"_44":45,"_46":103,"_48":104,"_50":51,"_52":95,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":105,"_62":106,"_64":-5,"_65":-5,"_66":-5},"b0db462c-5423-11f1-b225-ee650bb23af1","new-file-6594.ts","c8de3b3a-5423-11f1-9f86-ee650bb23af1",["D",1779264809550],6,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":109,"_13":110,"_74":75,"_76":118},[117],{"_42":111,"_44":45,"_46":112,"_48":113,"_50":51,"_52":102,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":114,"_62":115,"_64":-5,"_65":-5,"_66":-5},true,"c9f5a864-5423-11f1-9ee3-ee650bb23af1",["D",1779264811361],7,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":126,"_13":127,"_74":75,"_76":24},[125],{"_42":119,"_44":45,"_46":120,"_48":121,"_50":51,"_52":111,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":122,"_62":123,"_64":-5,"_65":-5,"_66":-5},"c9f0a6ac-5423-11f1-9ee3-ee650bb23af1","new-file-335.ts","cd124980-5423-11f1-a25e-ee650bb23af1",["D",1779264816587],8,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":126,"_13":135,"_74":75,"_76":24},[134],{"_42":128,"_44":45,"_46":129,"_48":130,"_50":51,"_52":119,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":131,"_62":132,"_64":-5,"_65":-5,"_66":-5},"SanFranciscoLeads.ts","0df30dae-5424-11f1-b764-ee650bb23af1",["D",1779264925450],9,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":126,"_13":135,"_74":75,"_76":118},[142],{"_42":136,"_44":45,"_46":137,"_48":138,"_50":51,"_52":128,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":139,"_62":140,"_64":-5,"_65":-5,"_66":-5},"1686eb7a-5424-11f1-9694-ee650bb23af1",["D",1779264939844],10,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[149],{"_42":143,"_44":45,"_46":144,"_48":145,"_50":51,"_52":136,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":146,"_62":147,"_64":-5,"_65":-5,"_66":-5},"1c2aea0e-549c-11f1-957f-ee650bb23af1",["D",1779316488901],11,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[156],{"_42":150,"_44":45,"_46":151,"_48":152,"_50":51,"_52":143,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":153,"_62":154,"_64":-5,"_65":-5,"_66":-5},"1be76f2a-549e-11f1-b14d-ee650bb23af1",["D",1779317347453],12,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[163],{"_42":157,"_44":45,"_46":158,"_48":159,"_50":51,"_52":150,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":160,"_62":161,"_64":-5,"_65":-5,"_66":-5},"8b9f484e-5528-11f1-8483-ee650bb23af1",["D",1779376805445],13,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[170],{"_42":164,"_44":45,"_46":165,"_48":166,"_50":51,"_52":157,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":167,"_62":168,"_64":-5,"_65":-5,"_66":-5},"b27c097c-552b-11f1-a132-ee650bb23af1",["D",1779378159129],14,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[177],{"_42":171,"_44":45,"_46":172,"_48":173,"_50":51,"_52":164,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":174,"_62":175,"_64":-5,"_65":-5,"_66":-5},"74dd3a0c-5538-11f1-9de1-ee650bb23af1",["D",1779383639202],15,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[184],{"_42":178,"_44":45,"_46":179,"_48":180,"_50":51,"_52":171,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":181,"_62":182,"_64":-5,"_65":-5,"_66":-5},"0dcdb28a-55ea-11f1-b10b-ee650bb23af1",["D",1779459916709],16,{"_42":77,"_50":51,"_11":12,"_78":79},{"_71":72,"_13":73,"_74":94,"_76":24},[191],{"_42":185,"_44":45,"_46":186,"_48":187,"_50":51,"_52":178,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":188,"_62":189,"_64":-5,"_65":-5,"_66":-5},"6feaf634-4dee-11f1-874d-ee650bb23af1",["D",1778582190041],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Automation Attio to Sendpilot","imageUrl","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","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",{"_11":12,"_241":79},"org",{"_11":12,"_237":79,"_78":79,"_25":77,"_238":239,"_240":24},"branch",{"_48":187,"_13":16,"_42":45,"_229":192,"_230":-5,"_231":-5,"_232":-5,"_233":-5,"_234":-5,"_235":14,"_236":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","tier","free","canRestrictVals","profileImageUrl","path","adoptOrgId",{"_42":192,"_13":14,"_46":287,"_194":-5,"_195":24,"_196":197,"_198":197,"_199":200,"_201":-5,"_25":77,"_202":-5,"_203":24,"_204":-5,"_205":-5,"_206":20,"_50":51,"_207":208,"_209":210,"_211":288,"_213":-5,"_214":215,"_216":215,"_217":218,"_219":218,"_220":218,"_221":215,"_222":215,"_60":289,"_224":290,"_226":291,"_228":24},"tree",[282],"files",[282],"counts",{"_272":20,"_273":49,"_274":20,"_275":276,"_277":278},"contents",[263],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":264,"_13":73,"_71":72,"_52":-5,"_44":45,"_265":187,"_266":118,"_46":267,"_48":145,"_74":94,"_268":269,"_76":24,"_270":-5,"_242":271},"0dca8100-55ea-11f1-b10b-ee650bb23af1","branchVersion","latest",["D",1779459916709],"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}","label",[73],"pulls","branches","forks","envVars",{"_279":121,"_281":20},"connections",{"_279":20,"_280":20},"count","unfilledCount","emptyCount",{"_42":264,"_13":73,"_71":72,"_52":-5,"_44":45,"_265":187,"_266":118,"_46":283,"_48":145,"_74":94,"_268":269,"_76":24,"_270":-5,"_284":285,"_242":286},["D",1779459916709],"children",[],[73],["D",1778582190041],["D",1789503703835],{"_11":12,"_241":79},{"_11":12,"_237":79,"_78":79,"_25":77,"_238":239,"_240":24},{"_48":187,"_13":16,"_42":45,"_229":192,"_230":-5,"_231":-5,"_232":-5,"_233":-5,"_234":-5,"_235":14,"_236":12},"ctx",{"_60":-5,"_260":325,"_326":327,"_328":329,"_330":24,"_331":24,"_332":24,"_333":118,"_334":-5,"_335":-7,"_336":-7,"_337":20,"_338":24,"_339":24,"_340":-5,"_341":24,"_342":24,"_343":24,"_344":-5},"ENV",{"_296":297,"_298":299,"_300":16,"_301":302,"_303":304,"_305":306,"_307":308,"_309":310,"_311":312,"_313":314,"_315":316,"_317":318,"_319":320,"_321":322,"_323":324},"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"]

History