[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","amir5","name","dogsspot_puppy_path","path","cpl.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":36,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/amir5/dogsspot_puppy_path/code/cpl.ts","extension","id","b45f58b5-564d-491b-a9ac-642ffdfcff88","fileId","e52967e0-941c-11f1-8def-1607ee4eb77e","parentId","branchId","551774fb-a850-4c9d-94a1-d3509ddcf1b0","branchVersion",473,"latest",true,"createdAt",["D",1786298724982],"version",0,"fileType","script","content","// COST PER LEAD, v1.0, 9 Aug 2026. GHL leads grouped by attributionSource.adId, joined to Meta\n// spend into per-campaign cost per lead. The val orchestrator wires these together and fetches\n// Meta itself; nothing here runs unattended, writes anything, or is a route.\n// WHY attributionSource, not attributions[] (report.ts/dashboard.ts's field): proven live 9 Aug —\n// GET /contacts/ (contactsSince, report.ts:70-92) has attributions[]/utmAdId, no attributionSource;\n// POST /contacts/search has attributionSource.adId directly; both agree on the total, 175 contacts\n// for 31 Jul-6 Aug. Window filter is report-logic.ts's inWindow (report-logic.ts:38-41): same rule\n// as \"New inquiries\".\ndeclare const Deno: { env: { get(k: string): string | undefined } };\nif (typeof (globalThis as any).Deno === \"undefined\") {\n (globalThis as any).Deno = { env: { get: (k: string) => (globalThis as any).process?.env?.[k] } };\n}\nimport { inWindow, money, type Window } from \"./report-logic.ts\";\nexport type { Window };\n\nexport const LOC = \"BQHJ19uohldYe3eqA0bl\";\nconst GHL = \"https://services.leadconnectorhq.com\";\n\n// ---- 1. GHL PULL, GROUPED BY AD ----\n\nexport type AdCount = { adId: string | null; n: number };\n// Network as an argument, shape of deposits.ts's io.get (deposits.ts:212): tests use a fixture.\nexport type GhlIo = { post: (path: string, version: string, body: unknown) => Promise };\n\nexport async function pullAdCounts(io: GhlIo, w: Window, errorsOut: string[]): Promise {\n const counts = new Map();\n let searchAfter: any;\n let reachedFloor = false;\n for (let page = 0; page < 40; page++) {\n const body: Record = { locationId: LOC, pageLimit: 100 };\n if (searchAfter) body.searchAfter = searchAfter;\n const d = await io.post(\"/contacts/search\", \"2021-07-28\", body);\n const cs = d?.contacts ?? [];\n if (!cs.length) break;\n for (const c of cs) {\n if (!inWindow(c.dateAdded, w)) continue;\n const adId = c?.attributionSource?.adId || null;\n const k = adId ?? \"\";\n counts.set(k, (counts.get(k) ?? 0) + 1);\n }\n const oldest = Date.parse(cs[cs.length - 1]?.dateAdded ?? \"\");\n searchAfter = cs[cs.length - 1]?.searchAfter;\n if (Number.isFinite(oldest) && oldest < w.startMs) { reachedFloor = true; break; }\n if (!searchAfter) { reachedFloor = true; break; }\n }\n // contactsSince's reachedFloor warning (report.ts:90): never silently read as \"no leads\".\n if (!reachedFloor) errorsOut.push(\"Contact pull hit the page cap before covering the window; ad counts may undercount\");\n return [...counts.entries()]\n .map(([k, n]) => ({ adId: k === \"\" ? null : k, n }))\n .sort((a, b) => b.n - a.n || String(a.adId).localeCompare(String(b.adId)));\n}\n\n// A ready io for real use (token resolution stays with the caller).\nexport function liveGhlIo(token: string): GhlIo {\n return {\n post: async (path, version, body) => {\n const r = await fetch(`${GHL}${path}`, {\n method: \"POST\",\n headers: { Authorization: `Bearer ${token}`, Version: version, \"User-Agent\": \"curl/8.5.0\", \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n signal: AbortSignal.timeout(25_000),\n });\n if (!r.ok) throw new Error(`GHL ${path} -> HTTP ${r.status}`);\n return r.json();\n },\n };\n}\n\n// ---- 2. JOIN TO PER-CAMPAIGN COST PER LEAD, pure, no network ----\n\nexport type AdSpend = { campaign: string; spend: number };\nexport type CampaignCPL = {\n campaign: string; leads: number; spend: number; spendStr: string;\n cpl: number | null; cplStr: string;\n formula: string; // spend / leads with real numbers in it (report-logic.ts:52's formula)\n};\n// noAdId: leads with no ad attribution at all. noSpendData: leads on a real adId Meta had no spend row for.\nexport type CPLResult = { campaigns: CampaignCPL[]; noAdId: number; noSpendData: number };\n\nexport function joinCostPerLead(counts: AdCount[], adSpend: Record): CPLResult {\n const byCampaign = new Map();\n const row = (name: string) => byCampaign.get(name) ?? { spend: 0, leads: 0 };\n for (const s of Object.values(adSpend)) {\n const r = row(s.campaign); r.spend += Number(s.spend) || 0; byCampaign.set(s.campaign, r);\n }\n let noAdId = 0, noSpendData = 0;\n for (const { adId, n } of counts) {\n if (!adId) { noAdId += n; continue; }\n const s = adSpend[adId];\n if (!s) { noSpendData += n; continue; }\n const r = row(s.campaign); r.leads += n; byCampaign.set(s.campaign, r);\n }\n const campaigns = [...byCampaign.entries()].map(([campaign, { spend, leads }]) => {\n const cpl = leads > 0 ? spend / leads : null;\n const spendStr = money(spend), cplStr = cpl === null ? \"n/a\" : money(cpl);\n const formula = `${spendStr} / ${leads} lead${leads === 1 ? \"\" : \"s\"} = ${cplStr}`;\n return { campaign, leads, spend, spendStr, cpl, cplStr, formula };\n }).sort((a, b) => b.spend - a.spend || a.campaign.localeCompare(b.campaign));\n return { campaigns, noAdId, noSpendData };\n}\n\n// ---- 3. META AD SPEND, defensive: every failure is a value, never a throw ----\n// A hiccup reads as \"spend not available now\", never crashes the unattended run. Same ET-day\n// slicing + unencoded time_range as report.ts's metaSpend (report.ts:135-141) — matched, not\n// \"improved\": the one Meta call run live so far.\n\nexport type MetaAdRow = { adId: string; adName: string; campaign: string; spend: number };\nexport type MetaResult = { ok: true; rows: MetaAdRow[]; truncated?: string } | { ok: false; why: string };\n\n// Mirrors report.ts:29-34, copied not imported: report.ts is an HTTP entry point, no exports.\nexport function etOffsetMin(atMs: number): number {\n const fmt = new Intl.DateTimeFormat(\"en-US\", { timeZone: \"America/New_York\", timeZoneName: \"shortOffset\" });\n const part = fmt.formatToParts(new Date(atMs)).find((p) => p.type === \"timeZoneName\")?.value ?? \"GMT-4\";\n const m = part.match(/GMT([+-]\\d+)/);\n return m ? Number(m[1]) * 60 : -240;\n}\n\nexport async function fetchMetaAdSpend(w: { startMs: number; endMs: number }, tzOffsetMin: number): Promise {\n const tok = Deno.env.get(\"META_TOKEN\"), act = Deno.env.get(\"META_AD_ACCOUNT\");\n if (!tok) return { ok: false, why: \"META_TOKEN is not set\" };\n if (!act) return { ok: false, why: \"META_AD_ACCOUNT is not set\" };\n const day = (ms: number) => new Date(ms + tzOffsetMin * 60_000).toISOString().slice(0, 10);\n const since = day(w.startMs), until = day(w.endMs - 86_400_000);\n // level=ad, one row per ad; limit=500 covers this account (17 ads seen in one live week).\n const url = `https://graph.facebook.com/v21.0/${act}/insights?level=ad&fields=ad_id,ad_name,campaign_name,spend&time_range={\"since\":\"${since}\",\"until\":\"${until}\"}&limit=500`;\n let r: Response;\n try { r = await fetch(url, { headers: { Authorization: `Bearer ${tok}` }, signal: AbortSignal.timeout(20_000) }); }\n catch (e) { return { ok: false, why: `Meta API unreachable: ${String(e).slice(0, 150)}` }; }\n let body: any;\n try { body = await r.json(); } catch { return { ok: false, why: `Meta insights returned unparseable JSON (HTTP ${r.status})` }; }\n if (!r.ok) return { ok: false, why: `Meta insights error: ${String(body?.error?.message ?? `HTTP ${r.status}`).slice(0, 200)}` };\n const rows: MetaAdRow[] = (body?.data ?? []).map((d: any) => ({\n adId: String(d.ad_id ?? \"\"), adName: String(d.ad_name ?? \"\"), campaign: String(d.campaign_name ?? \"\"), spend: Number(d.spend) || 0,\n }));\n const truncated = typeof body?.paging?.next === \"string\" ? \"more ads exist past this page; spend is partial\" : undefined;\n return { ok: true, rows, truncated };\n}\n\nexport function toAdSpendMap(rows: MetaAdRow[]): Record {\n const m: Record = {};\n for (const r of rows) if (r.adId) m[r.adId] = { campaign: r.campaign, spend: (m[r.adId]?.spend ?? 0) + r.spend };\n return m;\n}\n","deleted",false,"label",[14],"1bfa6e81-74e1-4c6c-ab32-118304a4ffff",["D",1785429259053],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Puppy path nurture engine v1.2 — The Dogs Spot","imageUrl","userId","d26e64e6-cd39-4be1-b5b4-1de11cc555f8","pinnedFileId","ad633fec-8e73-11f1-b800-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","019f56fd-bd59-724f-8163-80ffcf8235dd","tursoName","1bfa6e8174e14c6cab32118304a4ffff","tursoHostname","1bfa6e8174e14c6cab32118304a4ffff-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789519842404],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":101},"org",{"_9":10,"_98":99,"_100":101,"_55":56,"_102":103,"_104":42},"branch",{"_35":88,"_11":89,"_22":28,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned",1233,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Amir","avatar","https://lh3.googleusercontent.com/a/ACg8ocILk3bwhcvrzozUWm7gxlKoBm7ZGtsgIkesW3ysOOsJ1rSQuA=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":36,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":89,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]