Where your leads come from, and what goes back

[{"_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","tracking.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":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",{"_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/tracking.ts","extension","id","613f52a6-70ce-4a44-801a-1b6b81cbe517","fileId","e66f0424-98cd-11f1-9ee4-1607ee4eb77e","parentId","branchId","551774fb-a850-4c9d-94a1-d3509ddcf1b0","branchVersion",1233,"latest",true,"createdAt",["D",1787226722997],"version",5,"fileType","http","content","// ONE PAGE FOR ALL THREE CHANNELS, IN AND OUT. v1.0, 15 Aug 2026.\n//\n// WHAT KIM ACTUALLY ASKED FOR, three times, in three different sets of words:\n//\n// \"how do we verify that Facebook is actually receiving and using the information we're sending\n// back from the CRM... I want to be able to see what information is going the other direction —\n// from GHL back to Facebook — and know that it's working correctly\" [12 Aug]\n// \"getting Google onto the same person-in-the-CRM attribution footing as Facebook is on the list.\n// Can you give me a timeline for when you expect to have that piece in place?\" [12 Aug]\n// \"some kind of early-warning system so a five-month gap like this can't quietly happen again\"\n// [12 Aug]\n//\n// Three questions, one shape: FOR EACH CHANNEL, IS DATA MOVING IN BOTH DIRECTIONS, AND WHEN DID IT\n// LAST MOVE? Every piece already existed on separate pages and in separate blobs. Nothing joined\n// them, so answering her needed four URLs and a person who knew which four.\n//\n// THE RULE THIS PAGE IS BUILT ON, and it is the same rule as the early-warning monitor: a channel\n// this page CANNOT read is shown as unreadable, never as healthy. The five-month Square gap\n// happened because a silence looked like a calm. Blank is not green here; blank is grey and says\n// so.\n//\n// WHAT IT CAN AND CANNOT SEE, stated once here so the page never has to imply otherwise:\n// * INBOUND, all three channels: read directly from the CRM. A partial or capped walk is unknown.\n// * OUTBOUND to Google: feed supply and scheduled fetches are readable from the build log. The\n// initial upload has a manual receipt; later automatic imports need their own Upload History\n// receipt before this page may call the whole path healthy.\n// * OUTBOUND to Facebook: readable from the bridge's PII-free Meta Graph API response journal.\n// An events_received receipt proves Meta accepted the server event; it does not prove Meta\n// later used that event for attribution or optimisation, and the page says so explicitly.\n// * SQUARE: readable through the CRM's payment records, which is the direction that broke in\n// February and the direction that matters.\n//\n// READ ONLY. GET against GoHighLevel, plus two blobs written by other files. No write path exists.\n\nimport { cacheIntegrity, diagnoseSupply, feedState, SCHEDULE_STALL_DAYS, type Cache as FeedCache } from \"./gads-feed.ts\";\nimport { GOOGLE_ADS_BLOB, snapshotFreshness, type GoogleAdsSnapshot } from \"./google-ads-ingest.ts\";\nimport {\n WATCH_BLOB,\n validateWatchBlob,\n validatedWatchFindingSummary,\n type WatchBlob,\n} from \"./watch-cron.ts\";\nimport { watchViewData } from \"./watch-view.ts\";\n\nconst LOC = \"BQHJ19uohldYe3eqA0bl\";\nconst GHL = \"https://services.leadconnectorhq.com\";\nconst CONTACT_PATH = \"/contacts/\";\nconst CONTACT_PAGE_SIZE = \"100\";\nconst CONTACT_QUERY_KEYS = new Set([\"locationId\", \"limit\", \"startAfter\", \"startAfterId\"]);\nconst BRIDGE = \"https://amir5--41ace24c7e2111f18c9d1607ee4eb77e.web.val.run\";\nconst UA =\n \"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/126.0 Safari/537.36\";\n\n/** How far back \"recent\" reaches. Long enough that a quiet week is not an alarm, short enough that\n * a month-long outage cannot hide inside it. */\nconst WINDOW_DAYS = 30;\n/** Contact pages to walk. 100 per page; 20 pages covers well beyond the requested 30 days at the\n * observed volume while retaining a hard safety bound for a human-facing page. */\nconst PAGES = 20;\n/** A channel that has sent nothing for this long is not quiet, it has stopped. */\nconst SILENT_DAYS = 7;\nconst FUTURE_TOLERANCE_MS = 5 * 60_000;\n// The bridge retains only its newest 1,500 journal rows. At that exact capacity, this page cannot\n// prove older Meta receipts are still represented and must mark the evidence truncated.\nconst META_JOURNAL_CAP = 1_500;\n// Immutable first-run receipt observed directly in Google Ads Uploads after the secured recurring\n// schedule was created. It proves the file format and conversion actions were accepted once; it is\n// never presented as proof that a later automatic run succeeded.\nconst INITIAL_GOOGLE_UPLOAD_RECEIPT = {\n at: \"2026-08-17T15:30:46.000Z\", successful: 13, failed: 0, source: \"Google Ads Uploads UI\",\n} as const;\n// No later Upload History receipt is available to this local page yet. A configured/fresh fetch is\n// not proof that Google accepted the resulting import, so this keeps overall health non-green.\nconst GOOGLE_AUTOMATIC_IMPORT_PROOF = \"initial-only\" as const;\n\nconst GOOD = \"#0ca30c\", WARN = \"#fab219\", CRIT = \"#d03b3b\", GREY = \"#898781\";\n\nasync function sha256Hex(s: string): Promise {\n const b = await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(s));\n return [...new Uint8Array(b)].map((x) => x.toString(16).padStart(2, \"0\")).join(\"\");\n}\nconst constantTimeEqual = (a: string, b: string): boolean => {\n let difference = a.length ^ b.length;\n for (let i = 0; i < Math.min(a.length, b.length); i++) difference |= a.charCodeAt(i) ^ b.charCodeAt(i);\n return difference === 0;\n};\nasync function isAdmin(k: string): Promise {\n const expected = (Deno.env.get(\"NURTURE_ADMIN_KEY_SHA256\") ?? \"\").trim().toLowerCase();\n return !!k && /^[0-9a-f]{64}$/.test(expected) && constantTimeEqual(await sha256Hex(k), expected);\n}\nexport async function viewerKeyForToken(tok: string): Promise {\n return \"tds_view_\" + (await sha256Hex(tok + \":view\")).slice(0, 32);\n}\nasync function isViewer(k: string): Promise {\n const tok = await ghlToken();\n return !!tok && !!k && constantTimeEqual(k, await viewerKeyForToken(tok));\n}\nasync function ghlToken(): Promise {\n return (Deno.env.get(\"GHL_TOKEN\") ?? \"\").trim();\n}\n\nconst esc = (s: unknown) =>\n String(s ?? \"\").replace(/[&<>\"']/g, (c) => ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\", '\"': \""\", \"'\": \"'\" }[c] as string));\n\nexport type Channel = {\n name: string;\n /** Leads arriving FROM the channel INTO the CRM. */\n inbound: { n: number | null; withId: number | null; lastAt: number | null; note: string };\n /** Outcomes going back OUT to the channel. null when this page cannot see it. */\n outbound: { state: string; detail: string; lastAt: number | null } | null;\n verdict: { colour: string; word: string; line: string };\n};\n\nexport type TimestampFreshness = {\n state: \"fresh\" | \"stale\" | \"future\" | \"missing\" | \"invalid\";\n at: number | null;\n ageMs: number | null;\n};\n\nexport type MetaReceipt = {\n state: \"fresh\" | \"stale\" | \"missing\" | \"invalid\" | \"truncated\";\n accepted: number;\n failed: number;\n lastAcceptedAt: number | null;\n complete: boolean;\n truncated: boolean;\n reason: string;\n};\n\nexport type WatchdogCardAssessment = {\n /** The receipt after the canonical watch-view contract has proved a successful report exists. */\n receipt: WatchBlob | null;\n /** Canonical receipt state from watch-view, before business findings are applied. */\n receiptState: SquareReceiptState;\n /** Client-card state. An urgent finding or high-water regression is an alert, never healthy. */\n state: SquareCardState;\n validSuccessfulReport: boolean;\n working: boolean;\n blind: number;\n urgent: number;\n regression: boolean;\n coverageComplete: boolean;\n truncated: boolean;\n unknownEvidence: boolean;\n monitorDisagreement: boolean;\n transactions: number | null;\n builtAt: number | null;\n dollars: number | null;\n problem: string;\n verdict: Channel[\"verdict\"] & { word: \"Working\" | \"Needs a look\" | \"Cannot tell\" };\n};\n\nexport type TrackingHealthStatus = \"ok\" | \"warning\" | \"failed\";\nexport type TrackingHealthIssue = {\n code: string;\n severity: Exclude;\n message: string;\n};\n\ntype SquareReceiptState =\n | \"never-run\"\n | \"not-yet-successful\"\n | \"healthy\"\n | \"degraded\"\n | \"urgent\"\n | \"failed\"\n | \"stale\"\n | \"invalid\"\n | \"unreadable\";\ntype SquareCardState = SquareReceiptState | \"alert\";\nconst SQUARE_RECEIPT_STATES: ReadonlySet = new Set([\n \"never-run\",\n \"not-yet-successful\",\n \"healthy\",\n \"degraded\",\n \"urgent\",\n \"failed\",\n \"stale\",\n \"invalid\",\n \"unreadable\",\n]);\nconst isSquareReceiptState = (value: unknown): value is SquareReceiptState =>\n typeof value === \"string\" && SQUARE_RECEIPT_STATES.has(value);\n\n/** Every fact required before the page or its JSON may claim an all clear. */\nexport type TrackingHealthEvidence = {\n errors: string[];\n contacts: { complete: boolean; truncated: boolean };\n google: {\n sourcesReadable: boolean;\n adsFreshness: TimestampFreshness[\"state\"];\n supplyHealthy: boolean;\n supplyProven: boolean;\n supplyTruncated: boolean | null;\n supplyFreshness: TimestampFreshness[\"state\"];\n feedState: \"ok\" | \"quiet\" | \"ALARM\";\n schedule: \"healthy\" | \"stalled\" | \"not scheduled\" | \"unknown\";\n inbound: { n: number; withId: number; lastAt: number | null };\n importProof: \"fresh\" | \"stale\" | \"failed\" | \"initial-only\" | \"missing\" | \"unknown\";\n };\n meta: {\n receiptState: MetaReceipt[\"state\"];\n failed: number;\n complete: boolean;\n truncated: boolean;\n inbound: { n: number; withId: number; lastAt: number | null };\n };\n square: {\n receiptState: SquareReceiptState;\n validSuccessfulReport: boolean;\n working: boolean;\n state: SquareCardState;\n verdictWord: \"Working\" | \"Needs a look\" | \"Cannot tell\";\n urgent: number;\n regression: boolean;\n blind: number;\n truncated: boolean;\n unknownEvidence: boolean;\n monitorDisagreement: boolean;\n };\n};\n\nexport type TrackingHealthAssessment = {\n ok: boolean;\n status: TrackingHealthStatus;\n summary: string;\n issues: TrackingHealthIssue[];\n};\n\nconst TRACKING_FRESHNESS_STATES = new Set([\"fresh\", \"stale\", \"future\", \"missing\", \"invalid\"]);\nconst TRACKING_FEED_STATES = new Set([\"ok\", \"quiet\", \"ALARM\"]);\nconst TRACKING_SCHEDULE_STATES = new Set([\"healthy\", \"stalled\", \"not scheduled\", \"unknown\"]);\nconst TRACKING_IMPORT_STATES = new Set([\"fresh\", \"stale\", \"failed\", \"initial-only\", \"missing\", \"unknown\"]);\nconst TRACKING_META_STATES = new Set([\"fresh\", \"stale\", \"missing\", \"invalid\", \"truncated\"]);\nconst TRACKING_SQUARE_RECEIPT_STATES = new Set([\n \"never-run\", \"not-yet-successful\", \"healthy\", \"degraded\", \"urgent\", \"failed\", \"stale\", \"invalid\", \"unreadable\",\n]);\nconst TRACKING_SQUARE_CARD_STATES = new Set([...TRACKING_SQUARE_RECEIPT_STATES, \"alert\"]);\nconst TRACKING_VERDICT_WORDS = new Set([\"Working\", \"Needs a look\", \"Cannot tell\"]);\n\nconst normalTrackingDescriptor = (descriptor: PropertyDescriptor | undefined): boolean =>\n descriptor !== undefined && Object.prototype.hasOwnProperty.call(descriptor, \"value\") &&\n descriptor.enumerable === true && descriptor.writable === true && descriptor.configurable === true;\n\n/** Detach runtime evidence without invoking any property getter or trusting an inherited value. */\nfunction detachedTrackingData(value: unknown, path = \"evidence\", active: Set

${esc(ch.name)}

Where your leads come from, and what goes back

Overall status

What this page deliberately does not claim