[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_107":108,"_109":110},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22},"handle","amir5","name","dogsspot_puppy_path","path","SOURCE-BUNDLE.part3.txt","project",{"_23":45,"_11":12,"_34":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":33,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":42},"file",{"_23":24,"_11":14,"_25":26,"_27":-5,"_28":29,"_30":31,"_32":33,"_34":35,"_36":37,"_38":17,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/amir5/dogsspot_puppy_path/code/SOURCE-BUNDLE.part3.txt","extension","txt","id","70cdcc27-0c7c-49fb-9da1-e52bd64f0f2d","fileId","1786f918-9081-11f1-93f3-1607ee4eb77e","parentId","branchId","551774fb-a850-4c9d-94a1-d3509ddcf1b0","branchVersion",1199,"latest",true,"createdAt",["D",1786982930501],"version",58,"fileType","content","THE DOGS SPOT — SOURCE BUNDLE (part 3 of 47)\n\nEVERY source file in this project, engine/ included. Restoring these parts and nothing else gives\nyou a tree that builds, typechecks and runs its own test suite with no network and no val.\n\nengine/ is here as of 14 Aug 2026. It used to be left out because val 1bfa6e81-74e1-4c6c-ab32-118304a4ffff\nholds it, which was true of every engine file except engine/watch.ts: a module the val does not run,\nso it was never deployed, so it lived in one container and nothing else. A reclaim destroyed it.\nscripts/deploy.mjs --check still compares engine/ against the val file by file; that is a second\ncheck on the same files now, not the only copy of them.\n\nRESTORE (needs only node, from an empty folder). Save each part, then run this ON EACH ONE:\n\n node -e 'const fs=require(\"fs\"),p=require(\"path\");const b=fs.readFileSync(process.argv[1],\"utf8\");\n for(const s of b.split(\"\\n=====FILE \").slice(1)){const i=s.indexOf(\" =====\\n\");\n const f=s.slice(0,i),c=s.slice(i+7);fs.mkdirSync(p.dirname(f),{recursive:true});\n fs.writeFileSync(f,c.replace(/\\n$/,\"\"))}' PART.txt\n\nA record named #1, #2, ... is one FILE cut into pieces: concatenate them in order, then\nstrip one trailing newline from the last. scripts/restore.mjs does this for you.\n\nEach part is complete in itself: whole files only, no reassembly, any order.\n\nThen: node scripts/build.mjs (engine/ came out of these parts; nothing to fetch first)\n node scripts/typecheck.mjs\n node tests/run-all.mjs\n node scripts/deploy.mjs --check (pulls nothing, proves the val matches what you restored)\n node tests/negative-controls.mjs (proves the suite above can actually fail)\n\nIN THIS PART (4 of 129 files)\n engine/boarding-messages.ts 6473 bytes c088e150b8e5\n engine/cadence.ts 8777 bytes ec06a1830de8\n engine/consent.ts 4489 bytes b9ba53af6140\n engine/cpl.ts 7927 bytes 81d16e3283c2\n\n================================================================================================\n=====FILE engine/boarding-messages.ts =====\n// BOARDING INQUIRY, NOT YET BOOKED — recovered and repaired 17 Aug 2026.\n//\n// Source: the 31 Jul draft recovered from Amir's Downloads folder. This module deliberately stays\n// dry-run only. Prices are limited to the approved boarding-rate set enforced by paths.ts; the copy\n// does not claim availability, invent urgency, diagnose a dog, or turn a complimentary bath into a\n// grooming service. Every direct route points to The Dogs Spot's own boarding form.\n\nimport { PHONE_DISPLAY } from \"./puppy-messages.ts\";\nimport type { Step } from \"./paths.ts\";\n\nconst BOARDING_FORM = \"https://thedogsspotga.com/boarding-booking-form\";\n\nexport const BOARDING_STEPS: Step[] = [\n {\n id: \"main-1\", channel: \"sms\", offsetHours: 0,\n bodyTemplate:\n \"Hi {{FIRST_NAME}}, The Dogs Spot here. We got your boarding question. Tell us your dates and anything {{DOG_NAME}} needs us to know, and a real person will check availability. Reply STOP to opt out.\",\n },\n {\n id: \"main-2\", channel: \"email\", offsetHours: 24,\n subject: \"What a boarding day looks like here\",\n previewText: \"Routine, rest and what our team watches for.\",\n bodyTemplate: `Hi {{FIRST_NAME}},\n\nBefore rates and dates, the useful question is what a stay actually looks like for {{DOG_NAME}}.\n\nBoarding days have a routine: time outside, rest in the dog's own space and supervised time with our team. We watch eating, energy and how each dog is settling in, especially at the start of a first stay. If something does not look right, we contact you rather than guessing.\n\nIf {{DOG_NAME}} has never boarded before, has medication, needs a quieter setup or has a difficult history around other dogs, reply and tell us. That information helps us decide whether we are the right fit and plan responsibly.\n\nThe Dogs Spot`,\n },\n {\n id: \"main-3\", channel: \"sms\", offsetHours: 72,\n bodyTemplate:\n \"A first stay can feel like a big step. Routine helps most dogs settle, and the details matter. Reply with {{DOG_NAME}}'s dates, medication or special needs and we will tell you honestly what is possible. Reply STOP to opt out.\",\n },\n {\n id: \"main-4\", channel: \"email\", offsetHours: 120,\n subject: \"Boarding rates and the next step\",\n previewText: \"The current day rates in one place.\",\n bodyTemplate: `Hi {{FIRST_NAME}},\n\nHere are the current boarding day rates:\n\n- Regular boarding: $35/day\n- Special-needs boarding: $45/day\n- Training refresher for eligible graduates: $35/day\n\nSome eligible training graduates have a $30/day regular rate or $40/day special-needs rate. We confirm eligibility and the exact stay total before anything is booked.\n\nDrop-off and pick-up are by appointment. To request dates for {{DOG_NAME}}, use ${BOARDING_FORM} or reply here and our team will help.\n\nThe Dogs Spot`,\n },\n {\n id: \"main-5\", channel: \"sms\", offsetHours: 168,\n bodyTemplate:\n `Drop-off and pick-up are by appointment so our team is ready for {{DOG_NAME}}. Request your dates here: ${BOARDING_FORM}, or reply and we will help. Availability is confirmed by our team. Reply STOP to opt out.`,\n },\n {\n id: \"main-6\", channel: \"sms\", offsetHours: 240,\n bodyTemplate:\n \"One useful detail: boarding guests normally get a complimentary bath before pick-up, so they come home clean. If you want us to check dates for {{DOG_NAME}}, reply here. Reply STOP to opt out.\",\n },\n {\n id: \"main-7\", channel: \"email\", offsetHours: 312,\n subject: \"What to prepare for a first stay\",\n previewText: \"Food, records and the details that help a dog settle.\",\n bodyTemplate: `Hi {{FIRST_NAME}},\n\nFor a first stay, bring {{DOG_NAME}}'s own food in a labelled container and make sure current vaccination records are available before drop-off. Tell us about medication, feeding instructions, handling needs and anything that tends to make your dog worried.\n\nBecause drop-off and pick-up are by appointment, our team knows when to expect you and can plan the handoff instead of rushing it.\n\nIf you are unsure whether something matters, reply and tell us. We would rather know than guess.\n\nThe Dogs Spot`,\n },\n {\n id: \"main-8\", channel: \"sms\", offsetHours: 384,\n bodyTemplate:\n `If you have a trip coming up, send the dates before the last minute so we can check real availability. Request here: ${BOARDING_FORM}, or reply with the dates. Nothing is confirmed until our team says it is. Reply STOP to opt out.`,\n },\n {\n id: \"main-9\", channel: \"email\", offsetHours: 456,\n subject: \"If your dog is older, anxious or needs extra care\",\n previewText: \"The details we want before we confirm a stay.\",\n bodyTemplate: `Hi {{FIRST_NAME}},\n\nBeing older, anxious or new to boarding does not automatically rule {{DOG_NAME}} out. It does mean we need the full picture before confirming a stay.\n\nReply with medication, mobility limits, bite history, separation concerns, feeding needs and how your dog responds around unfamiliar people or dogs. We will tell you plainly whether our setup is suitable and what would be required.\n\nThis is not a promise that every dog can be accommodated. It is a promise that the decision will be based on the dog in front of us, not a generic checklist.\n\nThe Dogs Spot`,\n },\n {\n id: \"main-10\", channel: \"sms\", offsetHours: 552,\n bodyTemplate:\n `Still considering boarding for {{DOG_NAME}}? Reply with your dates and the one thing you are most concerned about. A real person will read it and give you a straight answer. Reply STOP to opt out.`,\n },\n {\n id: \"main-11\", channel: \"email\", offsetHours: 648,\n subject: \"Boarding rates and request link, one more time\",\n previewText: \"Everything needed to request a stay.\",\n bodyTemplate: `Hi {{FIRST_NAME}},\n\nOne last recap in case the earlier note was buried:\n\n- Regular boarding: $35/day\n- Special-needs boarding: $45/day\n- Training refresher for eligible graduates: $35/day\n- Eligible graduate rates, when confirmed: $30/day regular or $40/day special needs\n\nDrop-off and pick-up are by appointment, and availability must be confirmed by our team. Request dates for {{DOG_NAME}} here: ${BOARDING_FORM}.\n\nYou can also call or text ${PHONE_DISPLAY} if that is easier.\n\nThe Dogs Spot`,\n },\n {\n id: \"main-12\", channel: \"sms\", offsetHours: 720,\n bodyTemplate:\n `Last boarding note from us for now. If you still need dates for {{DOG_NAME}}, request them at ${BOARDING_FORM} or reply here. If plans changed, no problem. Reply STOP to opt out.`,\n },\n];\n\n\n=====FILE engine/cadence.ts =====\n// HOW OFTEN DOES IT ACTUALLY RUN. v1.0, 4 Aug 2026.\n//\n// WHY THIS FILE EXISTS: the dashboard told Kim \"the follow-up system runs every 15 minutes\"\n// because a human typed that sentence, not because anything had measured it. A stranger reading\n// the page cold caught it in one pass: the same health row said \"last checked itself 26 minutes\n// ago\" and \"it runs every 15 minutes\", with a green tick beside both. The claim and the evidence\n// were contradicting each other on screen and the claim was winning.\n//\n// The scheduler's interval is not readable through any API (four candidate routes probed on\n// 4 Aug, all 404), so the only honest source of truth is the footprints each system leaves. The\n// engine now records the timestamp of every run; these functions read the gaps between them.\n// Nobody gets to type the cadence any more, which means nobody can get it wrong.\n\n/** Median minutes between consecutive runs, or null when the evidence is too thin to claim one. */\nexport function observedCadenceMin(history: unknown): number | null {\n const ts = (Array.isArray(history) ? history : [])\n .map((x) => Date.parse(String(x))).filter((n) => Number.isFinite(n)).sort((a, b) => a - b);\n if (ts.length < 3) return null;\n const gaps: number[] = [];\n for (let i = 1; i < ts.length; i++) {\n const g = (ts[i] - ts[i - 1]) / 60000;\n // A same-minute duplicate is a double write, not an interval. A multi-day hole is a deploy or\n // an outage, not an interval. Reading either as \"the rhythm\" would let one bad night convince\n // the page that a 15-minute system normally runs daily, and then nothing would ever look late.\n if (g >= 1 && g <= 24 * 60) gaps.push(g);\n }\n if (gaps.length < 2) return null;\n gaps.sort((a, b) => a - b);\n const mid = Math.floor(gaps.length / 2);\n return Math.round(gaps.length % 2 ? gaps[mid] : (gaps[mid - 1] + gaps[mid]) / 2);\n}\n\n/**\n * Late relative to the rhythm the system actually keeps, not to a number somebody hoped for.\n *\n * THREE states, not two, and the middle one is the point. A single missed turn on a system that\n * batches daily messages is not a business problem, so raising an alarm for it would train the\n * reader to ignore alarms, and the day one matters nobody looks. But printing a plain green tick\n * beside a visibly overdue timestamp is what the stranger test caught and refused to accept: the\n * reader could see the gap, and the page was pretending not to. So an overdue-but-not-alarming\n * system gets its own word. The reader is told it is behind, and told that being behind here is\n * ordinary. Nothing is hidden and nothing is dramatised.\n *\n * ok within half a cycle of schedule\n * due past due, one missed turn or so. Says so out loud. Not a fault, not a green tick either.\n * late two and a half cycles behind, floor 30 minutes. This one reaches the headline verdict.\n *\n * With no measured rhythm the thresholds are a flat 60 and 90 minutes, so \"we have not measured\n * it yet\" cannot quietly become infinite patience for a system that has genuinely stopped.\n */\nexport function lateness(ageMin: number | null, cadenceMin: number | null): {\n state: \"ok\" | \"due\" | \"late\" | \"unknown\"; dueAt: number | null; lateAt: number | null;\n} {\n if (ageMin == null) return { state: \"unknown\", dueAt: null, lateAt: null };\n const dueAt = cadenceMin ? cadenceMin * 1.5 : 60;\n const lateAt = cadenceMin ? Math.max(cadenceMin * 2.5, 30) : 90;\n const state = ageMin > lateAt ? \"late\" : ageMin > dueAt ? \"due\" : \"ok\";\n return { state, dueAt, lateAt };\n}\n/** Does this state deserve a tick? Only a system on schedule does. */\nexport const isHealthy = (s: ReturnType[\"state\"]) => s === \"ok\";\n\n/**\n * Append this run's stamp to the trail a system leaves behind, given whatever the previous blob\n * held. Lives here rather than in the engine because main.ts sits against a hard 80,000-character\n * ceiling on the platform, and because the writer and the reader of this trail should agree on its\n * shape by sharing one definition instead of two that drift.\n *\n * Seeds from a pre-history state's own `ts` so the very next run already yields one real gap\n * rather than starting the evidence from nothing. Never appends a duplicate of the last stamp.\n */\nexport const RUN_HISTORY_MAX = 40;\nexport function appendRunStamp(prev: any, ts: string): string[] {\n let h: string[] = Array.isArray(prev?.history) ? prev.history.filter((x: unknown) => typeof x === \"string\") : [];\n if (!h.length && typeof prev?.ts === \"string\") h = [prev.ts];\n if (h[h.length - 1] !== ts) h.push(ts);\n return h.slice(-RUN_HISTORY_MAX);\n}\n\n/**\n * One sentence for the reader, combining the verdict and the yardstick it was measured against.\n *\n * The previous version printed those two separately and produced a flat contradiction that a\n * reader caught at once: \"Its next look is a little overdue\" immediately followed by \"There is not\n * enough history yet to say how often it normally runs.\" You cannot call a thing late and in the\n * same breath say you do not know when it was due. Both sentences were individually true, because\n * an unmeasured system still falls back to a flat one-hour expectation, but nothing on the page\n * said so. Now the yardstick is never separated from the judgement that used it.\n */\nexport function lateSentence(l: ReturnType, cadenceMin: number | null): string {\n const rhythm = cadenceMin == null\n ? \"We have not watched it long enough to know its usual rhythm, so for now we expect it at least once an hour\"\n : `Left to itself it runs about every ${cadenceMin} minute${cadenceMin === 1 ? \"\" : \"s\"}`;\n if (l.state === \"unknown\") return `${rhythm}, and there is no check-in on record to compare against.`;\n if (l.state === \"late\") return `${rhythm}, and it is well past that. If it is still behind in an hour, tell Amir.`;\n if (l.state === \"due\") return `${rhythm}, and it is a little past that now. One late turn is ordinary; several in a row is not.`;\n return `${rhythm}, and it is on time.`;\n}\n/**\n * The sentence for a system that is supposed to run on a schedule and, as far as anything can\n * tell, is not. Kept separate from lateSentence because \"it is a bit late\" and \"it has never\n * started on its own\" are different facts and must not share a phrasing.\n *\n * WHY THIS EXISTS. The watchdog reported a rhythm of \"about every 95 minutes\". That number was\n * computed from its run stamps, honestly, and it was still wrong: nearly every stamp was a human\n * pressing the check-now button. The page was describing my own button presses back to Kim as the\n * watchdog's schedule.\n *\n * IT MUST NOT GUESS WHY.\n * [was: \"Nothing has started it on its own, which means its timer is not firing.\" First half an\n * observation, second half a conclusion, and the conclusion was wrong. I opened the schedule on\n * 5 August and found it set to once every 24 hours, deliberately, a week earlier. The timer was\n * firing perfectly. It was just slower than the window I had been watching, and everything else\n * in the history was a person. I had already written \"the timer has never fired\" into a message\n * and onto Kim's page before I looked. An empty record of scheduled runs means exactly that:\n * report the gap, and let somebody open the settings.]\n *\n * `sinceIso` is when the system started telling scheduled runs apart from manual ones. Saying so\n * matters: an empty record since this morning is not the same claim as \"it has never run\".\n */\nexport function neverRanItselfSentence(sinceIso: string | null, manualCount: number): string {\n const since = sinceIso\n ? `Since ${new Date(sinceIso).toLocaleDateString(\"en-US\", { month: \"long\", day: \"numeric\" })} this system has recorded which of its checks were scheduled and which were started by hand.`\n : \"This system now records which of its checks were scheduled and which were started by hand.\";\n const manual = manualCount > 1\n ? ` ${manualCount} checks have run since then, every one started by hand.`\n : manualCount === 1\n ? \" One check has run since then, and it was started by hand.\"\n : \" Nothing has run since then either way.\";\n return `${since}${manual} Nothing on a schedule has been recorded in that time. Everything it checks is still being checked, because Amir has been running it by hand, but we cannot yet show you it keeping its own time. Nothing else on this page is affected either way.`;\n}\n\n/** Kept for callers that only want the yardstick. */\nexport function cadenceSentence(cadenceMin: number | null): string {\n return cadenceMin == null\n ? \"There is not enough history yet to say how often it normally runs.\"\n : `Left to itself it runs about every ${cadenceMin} minute${cadenceMin === 1 ? \"\" : \"s\"}.`;\n}\n\n\n=====FILE engine/consent.ts =====\n// PER-CHANNEL CONSENT. Extracted from main.ts on 10 Aug 2026, for two reasons: that file is at its\n// 80,000 character ceiling, and the function that decides whether a real human gets messaged should\n// be a file you can find, not twenty lines buried in the middle of the engine.\n//\n// Full evidence in NOTES-v1.4.md R28 and R31. The short version, and it is the important one:\n// GoHighLevel names dndSettings after the DO NOT DISTURB switch, not after the person.\n//\n// active the DND is ON -> BLOCK. 55 live contacts carry SMS active with\n// TWILIO_ERROR_CODE 30006, dnd:false, so nothing else\n// would have caught them.\n// permanent the recipient sent STOP -> BLOCK. 25 live contacts.\n// inactive the DND is OFF -> SEND. Kristina Gant, the only contact tagged for this\n// sequence, is inactive on every channel.\n// absent/\"\" no per-channel record -> SEND.\n//\n// Until 10 Aug this read `status !== \"active\"` as blocked, which is exactly backwards, and it\n// survived 394 assertions because the only test that touched it grepped the source text for the\n// word \"active\" instead of calling the function.\n//\n// The predicate ALLOW-LISTS the two states that mean go, so a state GoHighLevel invents tomorrow\n// fails CLOSED. `status` is consent; `message` is a delivery diagnostic and is never read as consent.\n\nexport type NurtureChannel = \"email\" | \"sms\";\n\n/** Find every spelling of a channel key. GHL normally returns `SMS`, `RCS` and `Email`, but a\n * lower-cased fixture or proxy response must not turn a block into permission. If duplicate keys\n * disagree, `some(blocked)` below chooses the safe result. */\nfunction channelEntries(ds: unknown, key: string): unknown[] {\n if (!ds || typeof ds !== \"object\" || Array.isArray(ds)) return [];\n return Object.entries(ds as Record)\n .filter(([k]) => k.toLowerCase() === key.toLowerCase())\n .map(([, value]) => value);\n}\n\nfunction entryBlocked(entry: unknown): boolean {\n if (!entry || typeof entry !== \"object\" || Array.isArray(entry)) return true;\n const status = String((entry as any).status ?? \"\").trim().toLowerCase();\n return status !== \"\" && status !== \"inactive\";\n}\n\nexport function readChannelConsent(contact: any): { email: boolean; sms: boolean } {\n const ds = contact?.dndSettings;\n const malformed = ds != null && (typeof ds !== \"object\" || Array.isArray(ds));\n const blocked = (key: string): boolean => malformed || channelEntries(ds, key).some(entryBlocked);\n return {\n // SMS and RCS are both text to the recipient, so either one off means we do not text them.\n sms: blocked(\"SMS\") || blocked(\"RCS\"),\n email: blocked(\"Email\"),\n };\n}\n\n/** One reason string for the planner and release tools. The top-level switch is absolute; a\n * per-channel switch only blocks that channel. Unknown per-channel statuses fail closed inside\n * `readChannelConsent`, while a genuinely absent setting keeps GHL's observed \"not blocked\"\n * meaning. */\nexport function channelBlockReason(contact: any, channel: NurtureChannel): string | null {\n if (!contact || typeof contact !== \"object\" || !Object.prototype.hasOwnProperty.call(contact, \"dnd\")) {\n return \"blanket Do Not Disturb status is unavailable\";\n }\n if (contact?.dnd === true) return \"blanket Do Not Disturb is on\";\n if (contact.dnd !== false) return \"blanket Do Not Disturb status is unreadable\";\n if (!Object.prototype.hasOwnProperty.call(contact, \"dndSettings\") ||\n !contact.dndSettings || typeof contact.dndSettings !== \"object\" || Array.isArray(contact.dndSettings)) {\n return \"per-channel consent snapshot is unavailable\";\n }\n return readChannelConsent(contact)[channel] ? `opted out of ${channel}` : null;\n}\n\n/** Was this object actually hydrated with the two consent surfaces? Opportunity-embedded contacts\n * often carry an address while omitting `dndSettings`; an aged-list release must not treat that\n * partial projection as consent evidence. */\nexport function hasConsentSnapshot(contact: any): boolean {\n return !!contact && typeof contact === \"object\" &&\n Object.prototype.hasOwnProperty.call(contact, \"dnd\") &&\n typeof contact.dnd === \"boolean\" &&\n Object.prototype.hasOwnProperty.call(contact, \"dndSettings\") &&\n !!contact.dndSettings && typeof contact.dndSettings === \"object\" && !Array.isArray(contact.dndSettings);\n}\n\n\n=====FILE engine/cpl.ts =====\n// 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\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",0,"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,"_106":102},"org",{"_9":10,"_99":100,"_101":102,"_55":56,"_103":104,"_105":42},"branch",{"_36":89,"_11":90,"_23":29,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":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",{"_82":-5,"_140":141,"_142":143,"_144":145,"_146":42,"_147":42,"_148":42,"_149":33,"_150":-5,"_151":-7,"_152":-7,"_153":63,"_154":42,"_155":42,"_156":-5,"_157":42,"_158":42,"_159":42,"_160":-5},"ENV",{"_111":112,"_113":114,"_115":90,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139},"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"]