[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_158":159,"_160":161},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_106":88,"_27":100,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":123,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",12,"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 — Orquestador Attio -> SendPilot (Val Town)\n * =======================================================\n * Un solo val, \"config por lista\". Cada lista de Attio se mapea a una\n * campaña de SendPilot y a un dueño. Agregar una persona = agregar UNA\n * entrada a CONFIG + sus 2 variables de entorno. No se duplica código.\n *\n * RUTEO (anti-colisión):\n * El val identifica el `list_id` del evento y busca su ruta en CONFIG.\n * Si la lista no está configurada, se ignora (no hace nada). Por eso el\n * flujo de Outreach que ya funciona NO se ve afectado.\n *\n * ON / OFF DESDE ATTIO (por lista):\n * - Entrar a la lista (list-entry.created) = ON -> alta del lead en la campaña\n * - Salir de la lista (list-entry.deleted) = OFF -> el lead se marca como DONE\n * (se detiene la secuencia)\n *\n * MASTER SWITCH POR CAMPAÑA (opcional):\n * La variable _ENABLED = \"false\" desactiva una ruta completa\n * sin borrar nada (útil para pausar una campaña entera).\n *\n * VARIABLES DE ENTORNO\n * ATTIO_TOKEN (requerida)\n * SENDPILOT_API_KEY (requerida)\n * --- Ruta existente: Outreach ---\n * SENDPILOT_OUTREACH_LIST_ID (lista de Attio que dispara el flujo)\n * SENDPILOT_CAMPAIGN_ID (campaña de SendPilot destino)\n * OUTREACH_ENABLED (opcional; \"false\" para pausar)\n * --- Ruta nueva: Claudia ---\n * CLAU_ATTIO_LIST_ID (lista de Attio de Claudia)\n * CLAU_SENDPILOT_CAMPAIGN_ID (campaña de SendPilot de Claudia)\n * CLAU_ENABLED (opcional; \"false\" para pausar)\n *\n * Para agregar a una 3ª persona: copia el bloque de Claudia en buildConfig(),\n * cambia el prefijo (p. ej. \"JUAN_\") y crea sus 2 variables. Nada más.\n */\n \nconst ATTIO_API = \"https://api.attio.com/v2\";\nconst SENDPILOT_API = \"https://api.sendpilot.ai/v1\";\n \n// Estado de SendPilot al que se manda un lead cuando sale de la lista (OFF).\n// Enum válido del endpoint PATCH /v1/leads/{id}/status:\n// PENDING | CONNECTION_SENT | CONNECTION_ACCEPTED | MESSAGE_SENT | REPLY_RECEIVED | DONE\n// \"DONE\" detiene la secuencia. Si prefieres otro criterio, cámbialo aquí.\nconst OFF_STATUS = \"DONE\";\n \ninterface CampaignRoute {\n owner: string;\n attioListId: string;\n sendpilotCampaignId: string;\n enabled: boolean;\n}\n \ninterface AttioEvent {\n eventType: string;\n listId: string;\n recordId: string;\n}\n \ninterface Lead {\n linkedinUrl: string;\n firstName: string;\n lastName: string;\n title: string;\n email: string;\n}\n \n/** Construye el mapa de rutas a partir de variables de entorno. */\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 (existente)\",\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: \"Claudia\",\n attioListId: Deno.env.get(\"CLAU_ATTIO_LIST_ID\") ?? \"\",\n sendpilotCampaignId: Deno.env.get(\"CLAU_SENDPILOT_CAMPAIGN_ID\") ?? \"\",\n enabled: flag(\"CLAU_ENABLED\"),\n },\n ];\n \n // Solo rutas completamente configuradas (lista + campaña).\n return routes.filter((r) => r.attioListId && r.sendpilotCampaignId);\n}\n \n/** Normaliza el payload de Attio a una lista de eventos manejables. */\nfunction parseEvents(payload: any): AttioEvent[] {\n const raw = Array.isArray(payload?.events) && payload.events.length\n ? payload.events\n : [payload?.data ?? payload];\n \n return raw.map((ev: any) => ({\n eventType: ev?.event_type ?? ev?.type ?? \"\",\n listId: ev?.id?.list_id ?? ev?.list_id ?? ev?.data?.list_id ??\n payload?.list_id ?? \"\",\n recordId: ev?.parent_record_id ?? ev?.id?.parent_record_id ??\n ev?.data?.parent_record_id ?? ev?.record_id ??\n payload?.parent_record_id ?? payload?.record_id ?? \"\",\n }));\n}\n \n/** Trae el registro completo de la persona desde Attio. */\nasync function getAttioPerson(token: string, recordId: string): Promise {\n const res = await fetch(\n `${ATTIO_API}/objects/people/records/${recordId}`,\n { headers: { Authorization: `Bearer ${token}`, Accept: \"application/json\" } },\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/** Extrae los campos del lead desde los `values` de Attio. */\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/** Normaliza una URL de LinkedIn para comparar de forma robusta. */\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: da de alta el lead en la campaña de SendPilot. */\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 { ok: res.ok, status: res.status, result: await res.json().catch(() => ({})) };\n}\n \n/** Busca el lead en una campaña por LinkedIn URL y devuelve su ID de SendPilot. */\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++) { // tope de seguridad\n const res = await fetch(\n `${SENDPILOT_API}/leads?campaignId=${encodeURIComponent(campaignId)}&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) => normalizeLinkedIn(l?.linkedinUrl) === target);\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: actualiza el estado del lead (detiene la secuencia). */\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 { ok: res.ok, status: res.status, result: await res.json().catch(() => ({})) };\n}\n \n/** Procesa un único evento de Attio según su ruta y tipo (ON/OFF). */\nasync function handleEvent(\n ev: AttioEvent,\n config: CampaignRoute[],\n attioToken: string,\n sendpilotKey: string,\n) {\n if (!ev.listId) {\n return { skipped: true, reason: \"Evento sin list_id\" };\n }\n \n const route = config.find((r) => r.attioListId === ev.listId);\n if (!route) {\n // Lista no configurada -> se ignora. Esto protege al flujo existente.\n return { skipped: true, reason: \"Lista no configurada (ignorada)\", listId: ev.listId };\n }\n if (!route.enabled) {\n return { skipped: true, reason: \"Campaña desactivada (ENABLED=false)\", owner: route.owner };\n }\n if (!ev.recordId) {\n return { skipped: true, reason: \"Evento sin parent_record_id\", owner: route.owner };\n }\n \n const isOn = ev.eventType === \"list-entry.created\";\n const isOff = ev.eventType === \"list-entry.deleted\";\n if (!isOn && !isOff) {\n return { skipped: true, reason: `event_type no manejado: ${ev.eventType}`, owner: route.owner };\n }\n \n const lead = extractLead(await getAttioPerson(attioToken, ev.recordId));\n if (!lead.linkedinUrl) {\n return {\n skipped: true,\n reason: \"Contacto sin LinkedIn URL\",\n owner: route.owner,\n contact: { firstName: lead.firstName, lastName: lead.lastName },\n };\n }\n \n // --- ON: alta en campaña ---\n if (isOn) {\n const r = await addLead(sendpilotKey, route.sendpilotCampaignId, lead);\n return { action: \"ON\", owner: route.owner, ok: r.ok, contact: lead, sendpilot: r.result };\n }\n \n // --- OFF: buscar lead y detener secuencia ---\n const leadId = await findLeadId(sendpilotKey, route.sendpilotCampaignId, lead.linkedinUrl);\n if (!leadId) {\n return {\n action: \"OFF\",\n owner: route.owner,\n skipped: true,\n reason: \"Lead no encontrado en la campaña (quizá ya no estaba)\",\n contact: lead,\n };\n }\n const r = await setLeadStatus(sendpilotKey, leadId, OFF_STATUS, \"Quitado de la lista en Attio (OFF)\");\n return { action: \"OFF\", owner: route.owner, ok: r.ok, leadId, contact: lead, sendpilot: r.result };\n}\n \nfunction jsonResponse(body: unknown, status: number): Response {\n return new Response(JSON.stringify(body), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n \nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") {\n return jsonResponse({ error: \"Method not allowed\" }, 405);\n }\n \n const ATTIO_TOKEN = Deno.env.get(\"ATTIO_TOKEN\");\n const SENDPILOT_API_KEY = Deno.env.get(\"SENDPILOT_API_KEY\");\n if (!ATTIO_TOKEN || !SENDPILOT_API_KEY) {\n return jsonResponse(\n { error: \"Faltan variables: ATTIO_TOKEN y/o SENDPILOT_API_KEY\" },\n 500,\n );\n }\n \n const config = buildConfig();\n if (config.length === 0) {\n return jsonResponse({ error: \"No hay rutas configuradas (revisa las variables de lista/campaña)\" }, 500);\n }\n \n let payload: any;\n try {\n payload = await req.json();\n } catch {\n return jsonResponse({ error: \"Body JSON inválido\" }, 400);\n }\n \n const events = parseEvents(payload);\n // Log de diagnóstico: imprime cada evento (event_type, list_id, record_id) en los Logs del val.\n // Útil para descubrir el list_id de una lista nueva (p. ej. la de Claudia).\n console.log(\"ATTIO EVENT(S) recibidos:\", JSON.stringify(events));\n \n const results: any[] = [];\n for (const ev of events) {\n try {\n results.push(await handleEvent(ev, config, ATTIO_TOKEN, SENDPILOT_API_KEY));\n } catch (err) {\n results.push({ ok: false, error: String(err), event: ev });\n }\n }\n \n // Respondemos 200 para confirmar recepción a Attio (evita reintentos en\n // bucle). El detalle de cada evento va en `results`.\n return jsonResponse({ received: events.length, results }, 200);\n}","/**\n * Crossbridge — Attio -> SendPilot Orchestrator (Val Town)\n * ========================================================\n * A single val, \"config per list\". Each Attio list maps to a SendPilot\n * campaign and an owner. Adding a campaign = add ONE entry to CONFIG +\n * its 2 environment variables. No code duplication.\n *\n * ROUTING (anti-collision):\n * The val reads the event's `list_id` and looks up its route in CONFIG.\n * If the list isn't configured, it is ignored (no-op). That's why the\n * existing Outreach flow is NOT affected.\n *\n * ON / OFF FROM ATTIO (per list):\n * - Added to the list (list-entry.created) = ON -> add the lead to the campaign\n * - Removed from list (list-entry.deleted) = OFF -> the lead is set to DONE\n * (its sequence is stopped)\n *\n * PER-CAMPAIGN MASTER SWITCH (optional):\n * The variable _ENABLED = \"false\" disables a whole route without\n * deleting anything (handy to pause an entire campaign).\n *\n * ENVIRONMENT VARIABLES\n * ATTIO_TOKEN (required)\n * SENDPILOT_API_KEY (required)\n * --- Existing route: Outreach ---\n * SENDPILOT_OUTREACH_LIST_ID (Attio list that triggers the flow)\n * SENDPILOT_CAMPAIGN_ID (destination SendPilot campaign)\n * OUTREACH_ENABLED (optional; \"false\" to pause)\n * --- New route: San Francisco (Claudia's campaign) ---\n * SANFRANCISCO_ATTIO_LIST_ID (Attio list that triggers this campaign)\n * SENDPILOT_SANFRANCISCO_CAMPAIGN_ID (destination SendPilot campaign)\n * SANFRANCISCO_ENABLED (optional; \"false\" to pause)\n *\n * To add another campaign: copy the San Francisco block in buildConfig(),\n * change the prefix (e.g. \"NEWYORK_\") and create its 2 variables. That's it.\n */\n\nconst ATTIO_API = \"https://api.attio.com/v2\";\nconst SENDPILOT_API = \"https://api.sendpilot.ai/v1\";\n\n// SendPilot status a lead is set to when it leaves the list (OFF).\n// Valid enum for the PATCH /v1/leads/{id}/status endpoint:\n// PENDING | CONNECTION_SENT | CONNECTION_ACCEPTED | MESSAGE_SENT | REPLY_RECEIVED | DONE\n// \"DONE\" stops the sequence. Change it here if you prefer a different criterion.\nconst OFF_STATUS = \"DONE\";\n\ninterface CampaignRoute {\n owner: string;\n attioListId: string;\n sendpilotCampaignId: string;\n enabled: boolean;\n}\n\ninterface AttioEvent {\n eventType: string;\n listId: string;\n recordId: string;\n}\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 }));\n}\n\n/** Fetches the full person record from Attio. */\nasync function getAttioPerson(token: string, recordId: string): Promise {\n const res = await fetch(\n `${ATTIO_API}/objects/people/records/${recordId}`,\n {\n headers: { Authorization: `Bearer ${token}`, Accept: \"application/json\" },\n },\n );\n if (!res.ok) {\n throw new Error(`Attio ${res.status}: ${await res.text()}`);\n }\n const json = await res.json();\n return json?.data?.values ?? {};\n}\n\n/** Extracts the lead fields from the Attio `values`. */\nfunction extractLead(values: any): Lead {\n return {\n linkedinUrl: values?.linkedin?.[0]?.value ?? \"\",\n firstName: values?.name?.[0]?.first_name ?? \"\",\n lastName: values?.name?.[0]?.last_name ?? \"\",\n title: values?.job_title?.[0]?.value ?? \"\",\n email: values?.email_addresses?.[0]?.email_address ?? \"\",\n };\n}\n\n/** Normalizes a LinkedIn URL for robust comparison. */\nfunction normalizeLinkedIn(url: string): string {\n return (url ?? \"\")\n .trim()\n .toLowerCase()\n .replace(/^https?:\\/\\//, \"\")\n .replace(/^www\\./, \"\")\n .split(\"?\")[0]\n .split(\"#\")[0]\n .replace(/\\/+$/, \"\");\n}\n\n/** ON: adds the lead to the SendPilot campaign. */\nasync function addLead(apiKey: string, campaignId: string, lead: Lead) {\n const leadBody: any = {\n linkedinUrl: lead.linkedinUrl,\n firstName: lead.firstName,\n lastName: lead.lastName,\n title: lead.title,\n };\n if (lead.email) leadBody.email = lead.email;\n\n const res = await fetch(`${SENDPILOT_API}/leads`, {\n method: \"POST\",\n headers: { \"X-API-Key\": apiKey, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ campaignId, leads: [leadBody] }),\n });\n return {\n ok: res.ok,\n status: res.status,\n result: await res.json().catch(() => ({})),\n };\n}\n\n/** Finds the lead in a campaign by LinkedIn URL and returns its SendPilot ID. */\nasync function findLeadId(\n apiKey: string,\n campaignId: string,\n linkedinUrl: string,\n): Promise {\n const target = normalizeLinkedIn(linkedinUrl);\n const limit = 100;\n\n for (let page = 1; page <= 50; page++) { // safety cap\n const res = await fetch(\n `${SENDPILOT_API}/leads?campaignId=${\n encodeURIComponent(campaignId)\n }&page=${page}&limit=${limit}`,\n { headers: { \"X-API-Key\": apiKey, Accept: \"application/json\" } },\n );\n if (!res.ok) break;\n\n const data = await res.json();\n const leads: any[] = data?.leads ?? [];\n const match = leads.find((l) =>\n normalizeLinkedIn(l?.linkedinUrl) === target\n );\n if (match?.id) return match.id;\n\n const totalPages = data?.pagination?.totalPages ?? 1;\n if (leads.length === 0 || page >= totalPages) break;\n }\n return null;\n}\n\n/** OFF: updates the lead status (stops its sequence). */\nasync function setLeadStatus(\n apiKey: string,\n leadId: string,\n status: string,\n note: string,\n) {\n const res = await fetch(`${SENDPILOT_API}/leads/${leadId}/status`, {\n method: \"PATCH\",\n headers: { \"X-API-Key\": apiKey, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ status, note }),\n });\n return {\n ok: res.ok,\n status: res.status,\n result: await res.json().catch(() => ({})),\n };\n}\n\n/** Processes a single Attio event based on its route and type (ON/OFF). */\nasync function handleEvent(\n ev: AttioEvent,\n config: CampaignRoute[],\n attioToken: string,\n sendpilotKey: string,\n) {\n if (!ev.listId) {\n return { skipped: true, reason: \"Event has no list_id\" };\n }\n\n const route = config.find((r) => r.attioListId === ev.listId);\n if (!route) {\n // Unconfigured list -> ignored. This protects the existing flow.\n return {\n skipped: true,\n reason: \"List not configured (ignored)\",\n listId: ev.listId,\n };\n }\n if (!route.enabled) {\n return {\n skipped: true,\n reason: \"Campaign disabled (ENABLED=false)\",\n owner: route.owner,\n };\n }\n if (!ev.recordId) {\n return {\n skipped: true,\n reason: \"Event has no parent_record_id\",\n owner: route.owner,\n };\n }\n\n const isOn = ev.eventType === \"list-entry.created\";\n const isOff = ev.eventType === \"list-entry.deleted\";\n if (!isOn && !isOff) {\n return {\n skipped: true,\n reason: `Unhandled event_type: ${ev.eventType}`,\n owner: route.owner,\n };\n }\n\n const lead = extractLead(await getAttioPerson(attioToken, ev.recordId));\n if (!lead.linkedinUrl) {\n return {\n skipped: true,\n reason: \"Contact has no LinkedIn URL\",\n owner: route.owner,\n contact: { firstName: lead.firstName, lastName: lead.lastName },\n };\n }\n\n // --- ON: add to campaign ---\n if (isOn) {\n const r = await addLead(sendpilotKey, route.sendpilotCampaignId, lead);\n return {\n action: \"ON\",\n owner: route.owner,\n ok: r.ok,\n contact: lead,\n sendpilot: r.result,\n };\n }\n\n // --- OFF: find the lead and stop its sequence ---\n const leadId = await findLeadId(\n sendpilotKey,\n route.sendpilotCampaignId,\n lead.linkedinUrl,\n );\n if (!leadId) {\n return {\n action: \"OFF\",\n owner: route.owner,\n skipped: true,\n reason: \"Lead not found in campaign (may already be gone)\",\n contact: lead,\n };\n }\n const r = await setLeadStatus(\n sendpilotKey,\n leadId,\n OFF_STATUS,\n \"Removed from Attio list (OFF)\",\n );\n return {\n action: \"OFF\",\n owner: route.owner,\n ok: r.ok,\n leadId,\n contact: lead,\n sendpilot: r.result,\n };\n}\n\nfunction jsonResponse(body: unknown, status: number): Response {\n return new Response(JSON.stringify(body), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") {\n return jsonResponse({ error: \"Method not allowed\" }, 405);\n }\n\n const ATTIO_TOKEN = Deno.env.get(\"ATTIO_TOKEN\");\n const SENDPILOT_API_KEY = Deno.env.get(\"SENDPILOT_API_KEY\");\n if (!ATTIO_TOKEN || !SENDPILOT_API_KEY) {\n return jsonResponse(\n { error: \"Missing env vars: ATTIO_TOKEN and/or SENDPILOT_API_KEY\" },\n 500,\n );\n }\n\n const config = buildConfig();\n if (config.length === 0) {\n return jsonResponse({\n error: \"No routes configured (check list/campaign env vars)\",\n }, 500);\n }\n\n let payload: any;\n try {\n payload = await req.json();\n } catch {\n return jsonResponse({ error: \"Invalid JSON body\" }, 400);\n }\n\n const events = parseEvents(payload);\n // Diagnostic log: prints each event (event_type, list_id, record_id) in the val's Logs.\n // Useful to discover the list_id of a new list (e.g. San Francisco / Claudia).\n console.log(\"ATTIO EVENT(S) received:\", JSON.stringify(events));\n\n const results: any[] = [];\n for (const ev of events) {\n try {\n results.push(\n await handleEvent(ev, config, ATTIO_TOKEN, SENDPILOT_API_KEY),\n );\n } catch (err) {\n results.push({ ok: false, error: String(err), event: ev });\n }\n }\n\n // Respond 200 to acknowledge receipt to Attio (prevents retry loops).\n // Per-event detail is in `results`.\n return jsonResponse({ received: events.length, results }, 200);\n}","createdAt",["D",1779317347453],"branchVersion","branchId","6fecce64-4dee-11f1-874d-ee650bb23af1","id","6feaf634-4dee-11f1-874d-ee650bb23af1","attio-to-sendpilot",["D",1778582190041],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Automation Attio to Sendpilot","imageUrl","1c9c43a8-9f0c-4174-9674-23ebdf84710f","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e0860-38fe-73fe-b84e-4ba78520350c","tursoName","6feaf6344dee11f1874dee650bb23af1","tursoHostname","6feaf6344dee11f1874dee650bb23af1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789503703835],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":100},"org",{"_98":97,"_99":100,"_101":100,"_18":55,"_102":103,"_104":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",16,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","CrossbridgeMarketing","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":153,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":154,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":155,"_82":156,"_84":157,"_86":25},"tree",[148],"files",[148],"counts",{"_136":61,"_137":138,"_139":61,"_140":141,"_142":143},"contents",[128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":25,"_38":132,"_13":133,"_33":34,"_35":37,"_24":25,"_134":-5,"_27":135},"1be52b8e-549e-11f1-b14d-ee650bb23af1","parentId","latest",["D",1779317347453],6,"label",[28],"pulls","branches",1,"forks","envVars",{"_144":146,"_147":61},"connections",{"_144":61,"_145":61},"count","unfilledCount",7,"emptyCount",{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":25,"_38":149,"_13":133,"_33":34,"_35":37,"_24":25,"_134":-5,"_150":151,"_27":152},["D",1779317347453],"children",[],[28],["D",1778582190041],["D",1789503703835],{"_98":97,"_105":100},{"_98":97,"_99":100,"_101":100,"_18":55,"_102":103,"_104":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_125":191,"_192":193,"_194":195,"_196":25,"_197":25,"_198":25,"_199":123,"_200":-5,"_201":-7,"_202":-7,"_203":61,"_204":25,"_205":25,"_206":-5,"_207":25,"_208":25,"_209":25,"_210":-5},"ENV",{"_162":163,"_164":165,"_166":88,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","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 · v12