[{"_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.part35.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.part35.txt","extension","txt","id","707695de-a658-46e4-88eb-d1bdeac9aa10","fileId","8a7ac07e-97ea-11f1-a03f-1607ee4eb77e","parentId","branchId","551774fb-a850-4c9d-94a1-d3509ddcf1b0","branchVersion",1205,"latest",true,"createdAt",["D",1786982936896],"version",6,"fileType","content","THE DOGS SPOT — SOURCE BUNDLE (part 35 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 (1 of 129 files)\n\n\n================================================================================================\n=====FILE scripts/counter-sales-correction.mjs#1 =====\n#!/usr/bin/env node\n// THE COUNTER SALES CORRECTION PACK. Generator, 12 Aug 2026.\n//\n// WHY THIS EXISTS. The client has, in writing, \"33 counter sales worth $22,651.99 are recorded but\n// not linked to a customer, four with a partial trail worth $2,829.99 and 29 worth $19,822.00 that\n// arrived with no name, email or phone attached at all\". That is the THIRD wrong version of this\n// one number (42 / $33,535.99, then 29 / $19,822.00, then 33 / $22,651.99). The true figure is\n// 4 payments worth $1,969.99. LESSONS.md #14 has the cause: the grouping KEY, not the rule.\n//\n// WHAT IT WRITES (all to /mnt/user-data/outputs, override with CORRECTION_OUT_DIR):\n// counter-sales-not-linked.csv the four, each verified against Square itself\n// counter-sales-CORRECTION.md one page for the owner, leading with the corrected figure\n// writeback-dry-run.csv the real remaining work: money on a named customer, not on a booking\n//\n// NOTHING HERE WRITES TO A LIVE SYSTEM. Every call is a GET except POST /contacts/search, which is\n// GoHighLevel's read route for contacts and mutates nothing. There is no PUT, PATCH or DELETE in\n// this file, and no code path that sets an opportunity value. File 3 describes a write; it is not\n// one. Same posture as engine/money-match.ts and scripts/client-files-rebuild.mjs, and for the\n// same reason: another application also writes opportunities in this location, so until its owner\n// confirms whether it owns monetaryValue, two systems would own one field and one would win at\n// random.\n//\n// THE RULES IT ENFORCES, each one already paid for:\n// - THE RULE IS IMPORTED, NEVER RETYPED (LESSONS #14). paymentUniverse() and\n// squarePaymentIdsInRow() come from scripts/exception-report-lib.mjs, the tested parser. A\n// fourth hand written copy of \"which payments are unlinked\" is how the first three went wrong.\n// - AND THEN CHECKED BY A METHOD THAT SHARES NO CODE WITH IT. independentUnmatched() below\n// re-derives the same set by SET SUBTRACTION with a shape based id parser, and the run dies if\n// the two disagree. Two readings that share a helper share its bugs.\n// - A SUBSET NEVER SHIPS WITHOUT ITS PARENT (LESSONS #8). Every population is printed as \"n of N\"\n// and the remainder is proved to add back, in rows and in cents, or the run dies.\n// - NEVER TRUST A FLAG TO ANSWER A QUESTION IT WAS NOT ASKED (engine/facts.ts squareSentence).\n// hadEmail/hadPhone/hadCustomerId describe the WEBHOOK PAYLOAD, not what Square holds. Live,\n// they are backwards for two of the four. Every buyer detail in file 1 comes from Square's own\n// record through ?lookup=, and the disagreement is printed rather than smoothed over.\n// - NO DASHES AS PUNCTUATION, AND NEVER THE WORD \"DAYCARE\", in anything the client reads.\n// Checked mechanically at the end, same as scripts/exception-report.mjs.\n// - SENTENCES ARE GENERATED FROM VALUES. Every figure in the markdown is interpolated from a\n// computed variable. No number is typed beside prose anywhere in this file.\n//\n// USAGE\n// source /home/claude/.ghlenv && node scripts/counter-sales-correction.mjs\n// ENV\n// GHL_TOKEN, BRIDGE_ADMIN required\n// CORRECTION_OUT_DIR default /mnt/user-data/outputs\n// CORRECTION_CACHE_DIR if set, raw API responses are cached here and reused on re-run\n\nimport { writeFileSync, mkdirSync, existsSync, readFileSync } from \"node:fs\";\nimport { join, dirname, resolve } from \"node:path\";\nimport { fileURLToPath } from \"node:url\";\n\nconst HERE = dirname(fileURLToPath(import.meta.url));\nconst ROOT = resolve(HERE, \"..\");\nconst { paymentUniverse, journalAmount, cents } = await import(join(ROOT, \"scripts\", \"exception-report-lib.mjs\"));\n\nconst shout = (m) => console.error(`\\n!!!! ${m} !!!!\\n`);\nconst die = (m) => { shout(m); process.exit(1); };\n\nconst LOCATION = \"BQHJ19uohldYe3eqA0bl\";\nconst GHL = \"https://services.leadconnectorhq.com\";\nconst BRIDGE = \"https://amir5--41ace24c7e2111f18c9d1607ee4eb77e.web.val.run\";\nconst UA = \"curl/8.5.0\"; // the API 403s without this exact User-Agent. Not optional, not cosmetic.\nconst TOKEN = process.env.GHL_TOKEN;\nconst ADMIN = process.env.BRIDGE_ADMIN;\nif (!TOKEN) die(\"GHL_TOKEN is not set. `source /home/claude/.ghlenv` first.\");\nif (!ADMIN) die(\"BRIDGE_ADMIN is not set. `source /home/claude/.ghlenv` first.\");\n\n// THE TWO STAGES A PAYMENT MAY EVER BE WRITTEN TO. Asserted equal to engine/money-match.ts's own\n// list below: the scope lives in both places on purpose, and an unscoped write puts money on a\n// Survey Requested card (proven live, $4,020 of $4,685 landed off the booking board).\nconst VALUABLE_STAGES = [\"fd821b4e-bbe6-44de-b754-fa80e4823616\", \"ae173310-f8b1-4399-acb7-ef1fc03d3697\"];\n// USE HER NAMES FOR HER THINGS. This map is filled from the client's own pipeline definition at\n// run time and is deliberately EMPTY here. A typed copy of a board name drifts silently: this file\n// carried \"Won and Paid\" for weeks and the board in her CRM is called \"Won - Paid\". A client\n// reading a board name that does not exist on her screen cannot check anything we tell her.\nconst STAGE_NAME = {};\nconst IN_SCOPE = new Set(VALUABLE_STAGES);\n{\n const src = readFileSync(join(ROOT, \"engine\", \"money-match.ts\"), \"utf8\");\n for (const s of VALUABLE_STAGES) {\n if (!src.includes(s)) die(`stage ${s} is not in engine/money-match.ts VALUABLE_STAGES. The two scope lists have drifted; fix that before planning a write.`);\n }\n}\n\nconst CACHE = process.env.CORRECTION_CACHE_DIR || \"\";\nif (CACHE) mkdirSync(CACHE, { recursive: true });\nconst cacheGet = (k) => (CACHE && existsSync(join(CACHE, k)) ? JSON.parse(readFileSync(join(CACHE, k), \"utf8\")) : null);\nconst cachePut = (k, v) => { if (CACHE) writeFileSync(join(CACHE, k), JSON.stringify(v)); return v; };\nconst sleep = (ms) => new Promise((r) => setTimeout(r, ms));\n\n// THE QUERY LOG. Every figure has to be traceable to the call that produced it and the row count\n// that came back, so every fetch appends here and the whole log prints at the end.\nconst QUERIES = [];\nconst logQuery = (what, url, rows) => { QUERIES.push({ what, url, rows }); return rows; };\n\nasync function jsonFetch(url, opts = {}, tries = 6) {\n let last = null;\n for (let t = 0; t < tries; t++) {\n try {\n const res = await fetch(url, { ...opts, headers: { \"User-Agent\": UA, Accept: \"application/json\", ...(opts.headers ?? {}) } });\n const text = await res.text();\n if (!res.ok) { last = `HTTP ${res.status}: ${text.slice(0, 200)}`; await sleep(1200 * (t + 1)); continue; }\n return JSON.parse(text);\n } catch (e) { last = e.message; await sleep(1200 * (t + 1)); }\n }\n die(`fetch failed after ${tries} tries: ${url.replace(/admin=[^&]+/, \"admin=\")}\\n last error: ${last}`);\n}\nconst ghlHeaders = { Authorization: `Bearer ${TOKEN}`, Version: \"2021-07-28\" };\n\n// -------------------------------------------------------------------------------------------\n// FETCHES. An empty page is retried, never believed, and the stop condition is the STATED TOTAL\n// as it stood at the FIRST page (LESSONS #15: a walk once stopped at 900 of 5,708 and reported\n// 900 as the whole CRM). Zero rows anywhere is a hard failure, never an empty success.\n// -------------------------------------------------------------------------------------------\nasync function fetchAllContacts() {\n const hit = cacheGet(\"contacts.json\"); if (hit) return logQuery(\"contacts\", \"POST /contacts/search {locationId, pageLimit:100, searchAfter}\", hit.length), hit;\n const all = []; const seen = new Set(); let searchAfter = null; let stated = null; let target = null; let empties = 0;\n while (true) {\n const body = { locationId: LOCATION, pageLimit: 100, ...(searchAfter ? { searchAfter } : {}) };\n const d = await jsonFetch(`${GHL}/contacts/search`, { method: \"POST\", headers: { ...ghlHeaders, \"Content-Type\": \"application/json\" }, body: JSON.stringify(body) });\n const page = d?.contacts ?? [];\n stated = d?.total ?? stated;\n if (target === null && stated != null) target = stated;\n if (page.length === 0) { if (++empties >= 3) break; await sleep(2500); continue; }\n empties = 0;\n for (const c of page) if (!seen.has(c.id)) { seen.add(c.id); all.push(c); }\n searchAfter = page[page.length - 1]?.searchAfter;\n if (target != null && all.length >= target) break;\n if (!searchAfter) break;\n }\n if (all.length === 0) die(\"contacts came back with ZERO rows. That is a broken read, not an empty CRM.\");\n if (target != null && all.length < target) die(`contact pagination is short: collected ${all.length}, the CRM held ${target} when this read began.`);\n if (stated != null && stated > all.length) console.log(` note: contacts grew from ${target} to ${stated} during the read; the ${all.length} read is the snapshot these files describe.`);\n logQuery(\"contacts\", \"POST /contacts/search {locationId, pageLimit:100, searchAfter}\", all.length);\n return cachePut(\"contacts.json\", all);\n}\n\nasync function fetchAllOpportunities() {\n const hit = cacheGet(\"opportunities.json\"); if (hit) return logQuery(\"opportunities\", `GET /opportunities/search?location_id=${LOCATION}&limit=100 (+nextPageUrl)`, hit.length), hit;\n const all = []; const seen = new Set(); let empties = 0; let stated = null; let target = null;\n let url = `${GHL}/opportunities/search?location_id=${LOCATION}&limit=100`;\n while (url) {\n const d = await jsonFetch(url, { headers: ghlHeaders });\n const page = d?.opportunities ?? []; const meta = d?.meta ?? {};\n stated = meta.total ?? stated;\n if (target === null && stated != null) target = stated;\n if (page.length === 0) { if (++empties >= 3) break; await sleep(2500); continue; }\n empties = 0;\n for (const o of page) if (!seen.has(o.id)) { seen.add(o.id); all.push(o); }\n if (target != null && all.length >= target) break;\n url = meta.nextPageUrl;\n }\n if (all.length === 0) die(\"opportunities came back with ZERO rows.\");\n if (target != null && all.length < target) die(`opportunity pagination is short: collected ${all.length}, the CRM held ${target} when this read began.`);\n if (stated != null && stated > all.length) console.log(` note: opportunities grew from ${target} to ${stated} during the read; the ${all.length} read is the snapshot these files describe.`);\n logQuery(\"opportunities\", `GET /opportunities/search?location_id=${LOCATION}&limit=100 (+nextPageUrl)`, all.length);\n return cachePut(\"opportunities.json\", all);\n}\n\n// INVOICES. `offset` is mandatory on this route or it 422s, and a page that comes back exactly\n// full is never the last page however tempting. Moved here from scripts/client-files-rebuild.mjs\n// so that one run produces the whole client pack: two generators writing files about the same\n// business on the same day is how a client ends up holding two documents that disagree.\nasync function fetchAllInvoices() {\n const hit = cacheGet(\"invoices.json\"); if (hit) return logQuery(\"invoices\", `GET /invoices/?altId=${LOCATION}&altType=location&limit=100&offset=<0..>`, hit.length), hit;\n const LIMIT = 100; const all = []; let stated = null;\n for (let offset = 0; offset < 5000; offset += LIMIT) {\n const d = await jsonFetch(`${GHL}/invoices/?altId=${LOCATION}&altType=location&limit=${LIMIT}&offset=${offset}`, { headers: ghlHeaders });\n const page = d?.invoices ?? [];\n stated = d?.total ?? stated;\n all.push(...page);\n if (page.length < LIMIT) break;\n }\n if (all.length === 0) die(\"invoices came back with ZERO rows. That is a broken read, not an empty business.\");\n if (stated != null && all.length !== stated) die(`invoice pagination is short: collected ${all.length}, the API says total ${stated}.`);\n logQuery(\"invoices\", `GET /invoices/?altId=${LOCATION}&altType=location&limit=100&offset=<0..>`, all.length);\n return cachePut(\"invoices.json\", all);\n}\n\n// THE CRM'S OWN PAYMENT RECORDS. Used only to answer \"has this invoice been settled another way\",\n// never as the Square population. This route rejects locationId and wants altId/altType.\nasync function fetchAllTransactions() {\n const hit = cacheGet(\"transactions.json\"); if (hit) return logQuery(\"payment transactions\", `GET /payments/transactions?altId=${LOCATION}&altType=location&limit=100&offset=<0..>`, hit.length), hit;\n const LIMIT = 100; const all = []; let stated = null;\n for (let offset = 0; offset < 20000; offset += LIMIT) {\n const d = await jsonFetch(`${GHL}/payments/transactions?altId=${LOCATION}&altType=location&limit=${LIMIT}&offset=${offset}`, { headers: ghlHeaders });\n const page = d?.data ?? d?.transactions ?? [];\n stated = d?.totalCount ?? d?.total ?? stated;\n all.push(...page);\n if (page.length < LIMIT) break;\n }\n if (all.length === 0) die(\"payment transactions came back with ZERO rows. That is a broken read, not an empty business.\");\n logQuery(\"payment transactions\", `GET /payments/transactions?altId=${LOCATION}&altType=location&limit=100&offset=<0..>`, all.length);\n return cachePut(\"transactions.json\", all);\n}\n\n// THE PRICE LIST, BOTH SIDES OF IT. Her CRM's products and prices, and Square's own catalogue, so\n// the claim \"set up at the exact Square price\" is checked against Square rather than asserted.\nasync function fetchCrmProducts() {\n const hit = cacheGet(\"products.json\"); if (hit) return logQuery(\"products\", `GET /products/?locationId=${LOCATION}&limit=100`, hit.length), hit;\n const d = await jsonFetch(`${GHL}/products/?locationId=${LOCATION}&limit=100`, { headers: ghlHeaders });\n const all = d?.products ?? [];\n if (all.length === 0) die(\"products came back with ZERO rows.\");\n logQuery(\"products\", `GET /products/?locationId=${LOCATION}&limit=100`, all.length);\n return cachePut(\"products.json\", all);\n}\nasync function fetchCrmPrices(productIds) {\n const hit = cacheGet(\"prices.json\"); if (hit) return logQuery(\"product prices\", `GET /products//price?locationId=${LOCATION}`, Object.keys(hit).length), hit;\n const out = {};\n for (const id of productIds) {\n const d = await jsonFetch(`${GHL}/products/${id}/price?locationId=${LOCATION}&limit=100`, { headers: ghlHeaders });\n out[id] = (d?.prices ?? []).map((p) => ({ id: p._id, name: p.name, amount: Number(p.amount) || 0, currency: p.currency }));\n }\n logQuery(\"product prices\", `GET /products//price?locationId=${LOCATION}`, Object.keys(out).length);\n return cachePut(\"prices.json\", out);\n}\nasync function fetchSquareCatalog() {\n const hit = cacheGet(\"catalog.json\"); if (hit) return logQuery(\"square catalogue\", \"GET ?catalog=1&admin=\", (hit.items ?? []).length), hit;\n const d = await jsonFetch(`${BRIDGE}?catalog=1&admin=${encodeURIComponent(ADMIN)}`);\n if (!Array.isArray(d?.items) || d.items.length === 0) die(\"the Square catalogue came back empty.\");\n logQuery(\"square catalogue\", \"GET ?catalog=1&admin=\", d.items.length);\n return cachePut(\"catalog.json\", d);\n}\n\n// HER BOARD NAMES, READ FROM HER CRM. Never typed into this file. See STAGE_NAME above.\nasync function fetchPipelines() {\n const hit = cacheGet(\"pipelines.json\"); if (hit) return logQuery(\"pipelines\", `GET /opportunities/pipelines?locationId=${LOCATION}`, hit.length), hit;\n const d = await jsonFetch(`${GHL}/opportunities/pipelines?locationId=${LOCATION}`, { headers: ghlHeaders });\n const all = d?.pipelines ?? [];\n if (all.length === 0) die(\"pipelines came back with ZERO rows, so this run cannot know what the client calls her own boards.\");\n logQuery(\"pipelines\", `GET /opportunities/pipelines?locationId=${LOCATION}`, all.length);\n return cachePut(\"pipelines.json\", all);\n}\n\nasync function fetchJournal() {\n const hit = cacheGet(\"journal.json\"); if (hit) return logQuery(\"bridge journal\", \"GET ?dump=1&admin=\", hit.length), hit;\n const j = await jsonFetch(`${BRIDGE}?dump=1&admin=${encodeURIComponent(ADMIN)}`);\n if (!Array.isArray(j)) die(`journal did not come back as an array (got ${typeof j}).`);\n if (j.length === 0) die(\"journal came back with ZERO rows. That is a failure, not an empty week.\");\n logQuery(\"bridge journal\", \"GET ?dump=1&admin=\", j.length);\n return cachePut(\"journal.json\", j);\n}\n\nasync function fetchSquare(ids) {\n const hit = cacheGet(\"square.json\"); if (hit) return logQuery(\"square lookup\", \"GET ?lookup=&admin=\", hit.length), hit;\n const out = []; const CHUNK = 45; // the bridge caps at 90; 45 keeps the URL comfortably short\n for (let i = 0; i < ids.length; i += CHUNK) {\n const d = await jsonFetch(`${BRIDGE}?lookup=${ids.slice(i, i + CHUNK).map(encodeURIComponent).join(\",\")}&admin=${encodeURIComponent(ADMIN)}`);\n out.push(...(d?.results ?? []));\n }\n if (out.length !== ids.length) die(`Square lookup returned ${out.length} of ${ids.length} requested payments. Every figure below depends on Square's own record, so a partial answer is not usable.`);\n logQuery(\"square lookup\", \"GET ?lookup=&admin=\", out.length);\n return cachePut(\"square.json\", out);\n}\n\n// -------------------------------------------------------------------------------------------\n// THE INDEPENDENT SECOND READING. Shares no code with paymentUniverse().\n//\n// paymentUniverse() groups a payment's rows by id and applies a guard per group. This does the\n// opposite: it builds two SETS and subtracts one from the other, and it finds ids by SHAPE and by\n// the grammatical slot they sit in rather than by a greedy \\S+ capture. If the two ever disagree\n// the run stops, because a number that only one method can produce is exactly what put three\n// wrong figures in the client's inbox.\n// -------------------------------------------------------------------------------------------\nconst SQUARE_PAYMENT_ID = /^[A-Za-z0-9]{29}$/; // refund ids are 73 chars with an underscore,\nconst SELF_TEST = /^(TESTPAY|captest|TESTREF)[-_]/i; // opportunity ids 20, invoice ids 28\nfunction independentIdsOnRow(r) {\n const found = new Set();\n for (const m of String(r?.note ?? \"\").matchAll(/\\bpayment\\s+([A-Za-z0-9]+)/g)) found.add(m[1]);\n if (typeof r?.id === \"string\" && r.id) found.add(r.id);\n const out = new Set();\n for (const t of found) if (SQUARE_PAYMENT_ID.test(t) && !SELF_TEST.test(t)) out.add(t);\n return out;\n}\nfunction independentUnmatched(journal) {\n const all = new Set(), onAContactRow = new Set();\n for (const r of journal) {\n const ids = independentIdsOnRow(r);\n for (const id of ids) all.add(id);\n if (typeof r?.contactId === \"string\" && r.contactId.trim().length > 4) for (const id of ids) onAContactRow.add(id);\n }\n return { all, linked: onAContactRow, unmatched: new Set([...all].filter((id) => !onAContactRow.has(id))) };\n}\n\n// -------------------------------------------------------------------------------------------\n// NORMALISERS. One definition each, so \"same phone\" cannot mean two different things.\n// -------------------------------------------------------------------------------------------\nconst normPhone = (p) => { const d = String(p ?? \"\").replace(/\\D/g, \"\"); const t = d.length === 11 && d.startsWith(\"1\") ? d.slice(1) : d; return t.length === 10 ? t : null; };\nconst normEmail = (e) => { const s = String(e ?? \"\").trim().toLowerCase(); return s || null; };\nconst normName = (n) => String(n ?? \"\").toLowerCase().replace(/[^a-z ]/g, \"\").replace(/\\s+/g, \" \").trim() || null;\nconst money = (n) => `$${Number(n).toLocaleString(\"en-US\", { minimumFractionDigits: 2, maximumFractionDigits: 2 })}`;\nconst plural = (n, one, many) => (n === 1 ? one : many);\nconst csvField = (v) => { const s = v === null || v === undefined ? \"\" : String(v); return /[\",\\n]/.test(s) ? `\"${s.replace(/\"/g, '\"\"')}\"` : s; };\n// THE HEADER ROW GOES THROUGH THE SAME ESCAPING AS EVERY OTHER ROW. It did not, and the moment a\n// column was given a name a person could read (\"Square receipt link, open this to see the sale\")\n// the comma inside it split the header into two columns and every spreadsheet mis-shaped the file.\nconst toCsv = (headers, records) => [headers.map(csvField).join(\",\"), ...records.map((r) => headers.map((h) => csvField(r[h])).join(\",\"))].join(\"\\n\") + \"\\n\";\nconst fmtDate = (iso) => {\n const d = new Date(iso); if (Number.isNaN(d.getTime())) return \"date unknown\";\n const M = [\"January\", \"February\", \"March\", \"April\", \"May\", \"June\", \"July\", \"August\", \"September\", \"October\", \"November\", \"December\"];\n return `${d.getUTCDate()} ${M[d.getUTCMonth()]} ${d.getUTCFullYear()}`;\n};\n// Dates inside a spreadsheet column stay in year, month, day order so a sort on the column works\n// and no reader has to guess whether 07/08 is July or August. Dates in prose are spelled out.\nconst isoDay = (iso) => String(iso ?? \"\").slice(0, 10);\n// Names as a person writes them. The CRM stores \"kylie smalley\" and Square stores \"AMERICAN_EXPRESS\";\n// neither is how the owner would write it down, and a client file is not the place to show either.\nconst titleCase = (s) => String(s ?? \"\").trim().replace(/\\b([a-z])/g, (m0) => m0.toUpperCase());\n// A person's name as her CRM spells it. The lowercased contactName field loses the capital in\n// \"McIntosh\"; the first and last name fields keep it, so those are preferred and contactName is\n// only a fallback. Never invent a capital the CRM does not hold.\nconst personName = (c) => {\n const parts = [c?.firstName, c?.lastName].map((x) => String(x ?? \"\").trim()).filter(Boolean);\n return parts.length ? parts.join(\" \") : titleCase(c?.contactName ?? \"\");\n};\nconst CARD_NAME = (brand) => {\n const b = String(brand ?? \"\").trim().toUpperCase();\n if (!b) return \"Card type not recorded\";\n const known = { VISA: \"Visa\", MASTERCARD: \"Mastercard\", AMERICAN_EXPRESS: \"American Express\", DISCOVER: \"Discover\", DISCOVER_DINERS: \"Discover Diners\", JCB: \"JCB\", CHINA_UNIONPAY: \"China UnionPay\", SQUARE_GIFT_CARD: \"Square gift card\" };\n return known[b] ?? titleCase(b.replace(/_/g, \" \").toLowerCase());\n};\n\n// THE FILE NAMES LIVE HERE ONCE. Every cross reference in every page below is interpolated from\n// these, so a rename can never leave one page pointing at a file that no longer exists. The old\n// names (writeback-dry-run.csv, counter-sales-not-linked.csv, counter-sales-CORRECTION.md) were\n// ours, not hers: she cannot search for a word she has never used.\nconst F_COUNTER_CSV = \"Counter-sales-with-no-customer.csv\";\nconst F_COUNTER_MD = \"Counter-sales-with-no-customer.md\";\nconst F_WRITE_CSV = \"Money-to-put-on-bookings.csv\";\nconst F_WRITE_MD = \"Money-to-put-on-bookings.md\";\nconst F_LEFT_CSV = \"Payments-left-alone-and-why.csv\";\nconst F_INVOICES_CSV = \"Unpaid-invoices.csv\";\nconst F_INVOICES_MD = \"Unpaid-invoices.md\";\nconst F_PRICES_CSV = \"Payment-links-and-prices.csv\";\n\n// ===========================================================================================\n// MAIN\n// ===========================================================================================\nconst RUN_AT = new Date();\n// \"Today\" is true for one day and quietly wrong every day after, and these files are kept. Every\n// sentence that wants to say \"right now\" names the date instead.\nconst AS_AT = fmtDate(RUN_AT.toISOString());\nconsole.log(`Reading live. Location ${LOCATION}. As of ${RUN_AT.toISOString()}.\\n`);\n\nconst [contacts, opportunities, journal, pipelines, invoices, transactions, crmProducts, squareCatalog] = await Promise.all([\n fetchAllContacts(), fetchAllOpportunities(), fetchJournal(), fetchPipelines(), fetchAllInvoices(), fetchAllTransactions(),\n fetchCrmProducts(), fetchSquareCatalog(),\n]);\nconst universe = paymentUniverse(journal);\nconst square = await fetchSquare([...universe.payments.keys()].sort());\nconst sqById = new Map(square.map((s) => [s.id, s]));\n\n// HER NAMES, FILLED IN FROM HER OWN CRM. A stage this run cannot name is a stage this run has no\n// business writing about, so a missing name stops the run rather than falling back to a guess.\nfor (const p of pipelines) for (const s of p?.stages ?? []) if (IN_SCOPE.has(s?.id)) STAGE_NAME[s.id] = String(s?.name ?? \"\").trim();\nfor (const s of VALUABLE_STAGES) if (!STAGE_NAME[s]) die(`stage ${s} is in the write scope and no pipeline in this CRM names it. Nothing written.`);\nconst BOARDS = VALUABLE_STAGES.map((s) => STAGE_NAME[s]);\nconst BOARDS_PHRASE = `${BOARDS.slice(0, -1).join(\", \")} or ${BOARDS[BOARDS.length - 1]}`;\nconsole.log(`Her board names, read from her own pipelines: ${BOARDS.map((b) => `\"${b}\"`).join(\" and \")}.`);\n\n// -------------------------------------------------------------------------------------------\n// GATE 1. The two independent readings must agree, exactly, before anything is computed from\n// either. This is the check that would have caught all three previous wrong numbers.\n// -------------------------------------------------------------------------------------------\nconst indep = independentUnmatched(journal);\n{\n const p = [];\n const a = [...indep.unmatched].sort(), b = [...universe.unlinked].sort();\n if (a.length !== b.length || a.some((x, i) => x !== b[i])) {\n p.push(`unmatched sets differ. set subtraction: ${a.length} (${a.join(\", \")}). paymentUniverse(): ${b.length} (${b.join(\", \")})`);\n }\n const u = [...indep.all].sort(), v = [...universe.payments.keys()].sort();\n if (u.length !== v.length || u.some((x, i) => x !== v[i])) {\n p.push(`populations differ. set subtraction sees ${u.length} payment ids, paymentUniverse() sees ${v.length}. only in one: ${[...u.filter((x) => !v.includes(x)), ...v.filter((x) => !u.includes(x))].join(\", \")}`);\n }\n if (p.length) { shout(\"THE TWO INDEPENDENT READINGS DISAGREE. This is the most important thing in this run. Nothing written.\"); p.forEach((x) => console.error(\" - \" + x)); process.exit(1); }\n console.log(`Independent check PASSED: set subtraction and paymentUniverse() name the same ${universe.payments.size} payments and the same ${universe.unlinked.length} unlinked, id for id.`);\n}\n\n// -------------------------------------------------------------------------------------------\n// THE AMOUNT. Square is the authority on what a card was charged; the journal is a log of\n// attempts and does not always carry an amount at all (PAY-DUP rows have no amount field). Where\n// both speak they must agree, or the total depends on which system you asked, and that is fatal.\n// -------------------------------------------------------------------------------------------\nconst amountOf = (id) => { const s = Number(sqById.get(id)?.amount); return Number.isFinite(s) ? s : journalAmount(universe.payments.get(id)); };\nconst amountSilentInJournal = [];\n{\n const p = [];\n for (const [id, rows] of universe.payments) {\n const j = journalAmount(rows), s = Number(sqById.get(id)?.amount ?? NaN);\n if (!Number.isFinite(s)) { p.push(`payment ${id}: Square returned no amount`); continue; }\n if (j === 0) { amountSilentInJournal.push({ id, square: s }); continue; } // journal never logged one\n if (cents(j) !== cents(s)) p.push(`payment ${id}: the journal says ${money(j)} and Square says ${money(s)}`);\n }\n if (p.length) { shout(\"THE JOURNAL AND SQUARE DISAGREE ON AN AMOUNT. Nothing written.\"); p.forEach((x) => console.error(\" - \" + x)); process.exit(1); }\n}\n\n// -------------------------------------------------------------------------------------------\n// REFUNDS. A refund id lives in its own namespace and is shaped \"_\", so the\n// payment a refund belongs to is recoverable. A payment with a refund against it must never have\n// its full amount proposed onto a booking.\n// -------------------------------------------------------------------------------------------\nconst refundedPayments = new Map();\nfor (const r of journal) {\n if (!/^REFUND/.test(String(r?.kind ?? \"\"))) continue;\n const tok = (String(r?.note ?? \"\").match(/refund\\s+(\\S+)/) ?? [])[1] ?? r?.id ?? \"\";\n const paymentId = String(tok).split(\"_\")[0];\n if (!universe.payments.has(paymentId)) continue;\n const g = refundedPayments.get(paymentId) ?? { paymentId, kinds: new Set(), amount: 0 };\n g.kinds.add(r.kind); g.amount = Math.max(g.amount, Number(r.amount) || 0);\n refundedPayments.set(paymentId, g);\n}\n\n// -------------------------------------------------------------------------------------------\n// THE PARENT TOTAL, and the split that must add back to it.\n// -------------------------------------------------------------------------------------------\nconst allIds = [...universe.payments.keys()];\nconst linkedIds = [...universe.linked].sort((a, b) => String(sqById.get(a)?.created_at ?? \"\").localeCompare(String(sqById.get(b)?.created_at ?? \"\")));\nconst unlinkedIds = [...universe.unlinked].sort((a, b) => String(sqById.get(a)?.created_at ?? \"\").localeCompare(String(sqById.get(b)?.created_at ?? \"\")));\nconst universeTotal = allIds.reduce((a, id) => a + amountOf(id), 0);\nconst linkedTotal = linkedIds.reduce((a, id) => a + amountOf(id), 0);\nconst unlinkedTotal = unlinkedIds.reduce((a, id) => a + amountOf(id), 0);\n{\n const p = [];\n if (linkedIds.length + unlinkedIds.length !== allIds.length) p.push(`linked ${linkedIds.length} + unlinked ${unlinkedIds.length} does not equal ${allIds.length} seen`);\n if (cents(linkedTotal + unlinkedTotal) !== cents(universeTotal)) p.push(`linked ${money(linkedTotal)} + unlinked ${money(unlinkedTotal)} does not equal ${money(universeTotal)}`);\n if (p.length) { shout(\"POPULATION RECONCILIATION FAILED. Nothing written.\"); p.forEach((x) => console.error(\" - \" + x)); process.exit(1); }\n}\n\n// -------------------------------------------------------------------------------------------\n// THE HISTORY OF THE NUMBER, re-derived rather than remembered, so the correction page can show\n// its own arithmetic. Three figures have been in writing; each one is reproduced here from the\n// live journal by running the rule as it stood at the time.\n// -------------------------------------------------------------------------------------------\nconst MATCHED_KINDS = new Set([\"REVENUE-ON-CLIENT-OPP\", \"PAYMENT\", \"CAPI-PURCHASE\", \"INVOICE-LINKED\"]);\nconst history = (() => {\n const byGreedyNoteKey = new Map();\n for (const r of journal) { const m = /payment\\s+(\\S+)/.exec(String(r?.note ?? \"\")); if (m) (byGreedyNoteKey.get(m[1]) ?? byGreedyNoteKey.set(m[1], []).get(m[1])).push(r); }\n const amt = (rs) => rs.map((r) => Number(r?.amount) || 0).find((a) => a > 0) ?? 0;\n const isMatched = (rs) => rs.some((r) => MATCHED_KINDS.has(r?.kind) || (typeof r?.contactId === \"string\" && r.contactId.length > 4));\n const failed = [...byGreedyNoteKey].filter(([, rs]) => rs.some((r) => r?.kind === \"NO-MATCH\"));\n const everFailed = failed.map(([id, rs]) => ({ id, amount: amt(rs) }));\n const thirdFigure = failed.filter(([, rs]) => !isMatched(rs)).map(([id, rs]) => ({ id, amount: amt(rs), trail: rs.some((r) => r?.hadEmail === true || r?.hadPhone === true || r?.hadCustomerId === true) }));\n const matchedLater = everFailed.filter((x) => !thirdFigure.some((y) => y.id === x.id));\n const semicolonBug = thirdFigure.filter((x) => !universe.unlinked.includes(x.id));\n const sum = (xs) => xs.reduce((a, x) => a + x.amount, 0);\n return {\n everFailed, everFailedTotal: sum(everFailed),\n matchedLater, matchedLaterTotal: sum(matchedLater),\n thirdFigure, thirdFigureTotal: sum(thirdFigure),\n thirdWithTrail: thirdFigure.filter((x) => x.trail), thirdWithTrailTotal: sum(thirdFigure.filter((x) => x.trail)),\n thirdNoTrail: thirdFigure.filter((x) => !x.trail), thirdNoTrailTotal: sum(thirdFigure.filter((x) => !x.trail)),\n semicolonBug, semicolonBugTotal: sum(semicolonBug),\n };\n})();\n{\n const p = [];\n if (history.matchedLater.length + history.thirdFigure.length !== history.everFailed.length) p.push(\"matched later plus still unmatched does not equal every payment that ever failed\");\n if (cents(history.matchedLaterTotal + history.thirdFigureTotal) !== cents(history.everFailedTotal)) p.push(\"the history dollars do not add back\");\n if (history.semicolonBug.length + unlinkedIds.length !== history.thirdFigure.length) p.push(\"the semicolon group plus the true unlinked does not equal the figure the client holds\");\n if (cents(history.semicolonBugTotal + unlinkedTotal) !== cents(history.thirdFigureTotal)) p.push(\"the semicolon dollars plus the true unlinked dollars do not equal the figure the client holds\");\n if (p.length) { shout(\"THE HISTORY OF THE NUMBER DOES NOT RECONCILE. Nothing written.\"); p.forEach((x) => console.error(\" - \" + x)); process.exit(1); }\n}\n\n// -------------------------------------------------------------------------------------------\n// CRM CANDIDATE MATCHING, for the four. Two tiers, and the tier is always stated.\n// PROOF an exact phone, email or full name hit, and exactly one contact answers to it.\n// PROBABLE the surname matches exactly and the first initial matches, on a different number.\n// Offered as a question, never as an answer. A merge is a decision about a person's\n// records and it belongs to the owner, not to this script.\n// Two candidates is not a better guess than one, it is a question, and this says so.\n// -------------------------------------------------------------------------------------------\nconst byPhone = new Map(), byEmail = new Map(), byName = new Map(), bySurname = new Map();\nconst push = (m, k, v) => { if (k) (m.get(k) ?? m.set(k, []).get(k)).push(v); };\nfor (const c of contacts) {\n push(byPhone, normPhone(c.phone), c);\n push(byEmail, normEmail(c.email), c);\n push(byName, normName(c.contactName || [c.firstName, c.lastName].filter(Boolean).join(\" \")), c);\n push(bySurname, normName(c.lastName), c);\n for (const ap of c.additionalPhones ?? []) push(byPhone, normPhone(typeof ap === \"string\" ? ap : ap?.phone), c);\n for (const ae of c.additionalEmails ?? []) push(byEmail, normEmail(typeof ae === \"string\" ? ae : ae?.email), c);\n}\nconst contactById = new Map(contacts.map((c) => [c.id, c]));\n\nfunction findCandidate(sq) {\n const c = sq?.square_customer ?? {};\n const given = String(c.given_name ?? \"\").trim(), family = String(c.family_name ?? \"\").trim();\n const full = [given, family].filter(Boolean).join(\" \") || String(sq?.cardholder_name ?? \"\").trim();\n const ph = normPhone(c.phone_number), em = normEmail(c.email_address), nm = normName(full);\n const hits = new Map(); const ev = [];\n const add = (list, label) => { if (list?.length) { ev.push(label); for (const x of list) hits.set(x.id, x); } };\n add(ph && byPhone.get(ph), `exact phone match on ${c.phone_number}`);\n add(em && byEmail.get(em), `exact email match on ${c.email_address}`);\n add(nm && byName.get(nm), `exact name match on \"${full}\"`);\n const proof = [...hits.values()];\n if (proof.length === 1) return { tier: \"proof\", contact: proof[0], evidence: ev.join(\"; \"), candidates: proof };\n if (proof.length > 1) return { tier: \"several\", contact: null, evidence: `${proof.length} contacts answer to this buyer (${ev.join(\"; \")}), so a person picks`, candidates: proof };\n // PROBABLE tier\n const sur = normName(family);\n const near = sur ? (bySurname.get(sur) ?? []).filter((x) => normName(x.firstName)?.[0] === normName(given)?.[0]) : [];\n if (near.length === 1) {\n const x = near[0];\n const bits = [`surname \"${family}\" matches exactly`, `first name is \"${x.firstName}\" in the CRM and \"${given}\" in Square`];\n if (ph && normPhone(x.phone) && ph !== normPhone(x.phone)) bits.push(`the phone numbers are different, ${c.phone_number} in Square and ${x.phone} in the CRM`);\n return { tier: \"probable\", contact: x, evidence: bits.join(\"; \"), candidates: near };\n }\n if (near.length > 1) return { tier: \"several\", contact: null, evidence: `${near.length} contacts share this surname and first initial, so a person picks`, candidates: near };\n return { tier: \"none\", contact: null, evidence: \"Square holds no name, no email and no phone for this sale, so there is nothing to match a customer on\", candidates: [] };\n}\n\n// -------------------------------------------------------------------------------------------\n// SPLIT TENDER. One sale settled on two cards is two payments against ONE Square order, and each\n// payment's line items describe the WHOLE order, not that card's share. Printing a line item\n// total of $1,795.00 beside a card that was charged $795.00 is exactly the kind of number beside\n// a sentence that this project keeps being burned by, so the relationship is stated instead.\n// -------------------------------------------------------------------------------------------\nconst paymentsByOrder = new Map();\nfor (const id of allIds) {\n const oid = sqById.get(id)?.order_id;\n if (oid) (paymentsByOrder.get(oid) ?? paymentsByOrder.set(oid, []).get(oid)).push(id);\n}\nconst orderTotal = (s) => (s?.line_items ?? []).reduce((a, li) => a + (Number(li?.total) || 0), 0);\n\n// -------------------------------------------------------------------------------------------\n// FILE 3, COMPUTED FIRST because file 1 needs to be able to say which booking a confirmed match\n// would land on, and whether that booking is already due to receive money in this same plan.\n//\n// Scope: the payments that DID reach a named customer. Those are the real remaining work, and\n// they are a different population from file 1's four, which is why the two files never share a\n// row and their counts add back to the parent total rather than overlapping.\n//\n// Kim's rule, agreed in writing 9 Aug: one open booking, assign it; more than one, a person\n// chooses. Scoped to the two stage IDS, summed per booking, never overwriting a non zero value.\n// -------------------------------------------------------------------------------------------\nconst oppsByContact = new Map();\nfor (const o of opportunities) {\n if (!IN_SCOPE.has(o.pipelineStageId) || !o.contactId) continue;\n (oppsByContact.get(o.contactId) ?? oppsByContact.set(o.contactId, []).get(o.contactId)).push(o);\n}\n\nconst leftAlone = [];\nconst plan = new Map();\nfor (const id of linkedIds) {\n const rows = universe.payments.get(id) ?? [];\n const s = sqById.get(id) ?? {};\n const sc = s.square_customer ?? {};\n const buyer = [sc.given_name, sc.family_name].map((x) => String(x ?? \"\").trim()).filter(Boolean).join(\" \") || String(s.cardholder_name ?? \"\").trim() || \"(Square holds no name)\";\n // EVERY REASON BELOW IS WRITTEN FOR THE OWNER, not for us. No record ids, no log vocabulary:\n // she has to be able to act on the sentence without asking anybody what a word in it means.\n const item = { id, amount: amountOf(id), date: String(s.created_at ?? \"\").slice(0, 10), buyer, receipt: s.receipt_url ?? \"\" };\n const reject = (why) => leftAlone.push({ ...item, why });\n\n const contactIds = [...new Set(rows.filter((r) => typeof r?.contactId === \"string\" && r.contactId.length > 4).map((r) => r.contactId))];\n if (contactIds.length !== 1) { reject(contactIds.length === 0 ? \"the Square connection never recorded a customer for this payment\" : `the Square connection recorded ${contactIds.length} different customers against this one payment, so a person picks`); continue; }\n const contact = contactById.get(contactIds[0]);\n if (!contact) { reject(\"the customer record this payment was filed against is no longer in your CRM\"); continue; }\n if (refundedPayments.has(id)) { reject(\"this payment was refunded, so its full amount must not be added to a booking\"); continue; }\n\n const inScope = oppsByContact.get(contact.id) ?? [];\n if (!inScope.length) { reject(`the customer is named and has no booking on the ${BOARDS_PHRASE} board to put the money on`); continue; }\n const open = inScope.filter((o) => Number(o.monetaryValue || 0) === 0);\n const valued = inScope.filter((o) => Number(o.monetaryValue || 0) > 0);\n if (!open.length) { reject(`every booking for this customer already carries a figure (${valued.map((o) => money(o.monetaryValue)).join(\", \")}), and nothing here overwrites a figure another system may own`); continue; }\n if (open.length !== 1) { reject(`${open.length} bookings for this customer show no dollars, so a person picks which one`); continue; }\n\n const o = open[0];\n const g = plan.get(o.id) ?? { opp: o, contact, items: [] };\n g.items.push(item); plan.set(o.id, g);\n}\n\n// -------------------------------------------------------------------------------------------\n// FILE 1. THE FOUR. Every buyer detail comes from Square's own record, not from the journal's\n// flags, and where the two disagree the disagreement is a column of its own.\n// -------------------------------------------------------------------------------------------\nconst flagDisagreements = [];\nconst fourRows = unlinkedIds.map((id) => {\n const s = sqById.get(id) ?? {};\n const c = s.square_customer ?? {};\n const rows = universe.payments.get(id) ?? [];\n const name = [c.given_name, c.family_name].map((x) => String(x ?? \"\").trim()).filter(Boolean).join(\" \").replace(/\\s+/g, \" \") || String(s.cardholder_name ?? \"\").trim();\n const m = findCandidate(s);\n\n // THE FLAGS versus SQUARE. hadEmail/hadPhone/hadCustomerId describe the webhook payload the\n // bridge received. Square is the record of what Square holds. Where they differ, say so.\n const flagSaysTrail = rows.some((r) => r?.hadEmail === true || r?.hadPhone === true || r?.hadCustomerId === true);\n const squareHasSomething = Boolean(name || c.email_address || c.phone_number);\n let flagVerdict = \"the journal flag and Square agree\";\n if (flagSaysTrail && !squareHasSomething) { flagVerdict = \"the journal flag said there was something to go on and Square holds no name, no email and no phone\"; flagDisagreements.push({ id, direction: \"flag too generous\" }); }\n if (!flagSaysTrail && squareHasSomething) { flagVerdict = \"the journal flag said there was nothing to go on and Square holds a name and a phone number\"; flagDisagreements.push({ id, direction: \"flag too harsh\" }); }\n\n // WHERE IT WOULD GO IF THE MATCH IS CONFIRMED. Same rule and same two stages as file 3, so the\n // two files cannot recommend different things about one customer.\n let landsOn = \"\", landsOnId = \"\", landsOnCurrent = \"\", landsOnAlreadyDue = \"\";\n if (m.contact) {\n const inScope = oppsByContact.get(m.contact.id) ?? [];\n const open = inScope.filter((o) => Number(o.monetaryValue || 0) === 0);\n if (open.length === 1) {\n const o = open[0];\n landsOnId = o.id;\n landsOnCurrent = Number(o.monetaryValue || 0).toFixed(2);\n const due = plan.get(o.id);\n landsOnAlreadyDue = due ? due.items.reduce((a, x) => a + x.amount, 0).toFixed(2) : \"0.00\";\n landsOn = `${o.name ?? \"(booking not named)\"} on the ${STAGE_NAME[o.pipelineStageId]} board, which shows ${money(o.monetaryValue || 0)} as at ${AS_AT}` + (due ? ` and is already due to receive ${money(Number(landsOnAlreadyDue))} in ${F_WRITE_CSV}` : \"\");\n } else if (inScope.length === 0) {\n landsOn = `this customer has no booking on the ${BOARDS_PHRASE} board, so there is nowhere to put it yet`;\n } else {\n landsOn = `${open.length} bookings for this customer show no dollars, so a person picks which one`;\n }\n }\n\n // SPLIT TENDER. Another payment against the same Square order means one sale on two cards. The\n // other card is named by ITS AMOUNT, not by its reference number: she can see two amounts on one\n // receipt, and a reference number tells her nothing she can use.\n const siblings = (paymentsByOrder.get(s.order_id) ?? []).filter((x) => x !== id);\n const whole = orderTotal(s);\n const splitNote = siblings.length\n ? `Yes. This was one sale of ${money(whole)} paid on ${siblings.length + 1} cards. This card paid ${money(amountOf(id))} and the other ${plural(siblings.length, \"card paid\", \"cards paid\")} ${siblings.map((x) => money(amountOf(x))).join(\" and \")}.`\n : \"No, one card, one sale.\";\n\n const refund = refundedPayments.get(id);\n const bought = (s.line_items ?? []).map((li) => (li?.name ? `${li.name} x${li?.quantity ?? \"1\"}` : \"The receipt does not name what was bought\")).join(\"; \")\n || \"The receipt does not name what was bought\";\n // KEYS THAT START WITH AN UNDERSCORE NEVER REACH THE CLIENT. They exist so the checks below and\n // the note beside this file can be built from the same row, without a reference number, a record\n // id or a status code ever appearing in a column she reads.\n return {\n \"Date of sale\": isoDay(s.created_at),\n \"Amount (US dollars)\": amountOf(id).toFixed(2),\n \"Name Square holds\": name || \"No name in Square\",\n \"Phone Square holds\": c.phone_number || \"No phone in Square\",\n \"What was bought\": bought,\n \"Card\": CARD_NAME(s.card_brand),\n \"Last four digits\": s.last_4 ?? \"\",\n \"One sale on two cards\": splitNote,\n \"Best match in your customer list\": m.contact ? personName(m.contact) : \"No match found\",\n \"How sure I am\": m.tier === \"proof\" ? \"Certain\" : m.tier === \"probable\" ? \"Likely, please confirm\" : m.tier === \"several\" ? \"More than one person could be this, please pick\" : \"No match found\",\n \"Why I think that\": m.evidence,\n \"Where the money would go if you confirm it\": landsOn || \"Nowhere yet, there is no one to attach it to\",\n \"Square receipt link, open this to see the sale\": s.receipt_url ?? \"\",\n _id: id,\n _date: isoDay(s.created_at),\n _createdAt: s.created_at ?? \"\",\n _amount: amountOf(id),\n _buyer: name || \"No name in Square\",\n _phone: c.phone_number ?? \"\",\n _bought: bought,\n _match: m.contact ? personName(m.contact) : \"\",\n _tier: m.tier,\n _orderId: s.order_id ?? \"\",\n _wholeSale: whole,\n _status: s.status ?? \"\",\n _flagVerdict: flagVerdict,\n _refunded: Boolean(refund),\n };\n});\n{\n const p = [];\n if (fourRows.length !== unlinkedIds.length) p.push(\"the file has a different row count from the unlinked set\");\n const t = fourRows.reduce((a, r) => a + r._amount, 0);\n if (cents(t) !== cents(unlinkedTotal)) p.push(`the file sums to ${money(t)} and the unlinked set is ${money(unlinkedTotal)}`);\n if (fourRows.some((r) => r._status !== \"COMPLETED\")) p.push(\"a payment in this file is not COMPLETED in Square, so it may not be counted as money collected\");\n // THE ORDER A FILE CLAIMS IS THE SOURCE'S ORDER, NEVER OURS. This list says \"oldest first\", and\n // oldest means the moment Square took the card, not the moment our own log noticed it. Two\n // payments 15 seconds apart on 27 July were once printed in the wrong order for exactly that\n // reason, in a file that told the reader it was in the order the payments arrived.\n for (let i = 1; i < fourRows.length; i++) {\n if (String(fourRows[i - 1]._createdAt) > String(fourRows[i]._createdAt)) p.push(\"this file claims oldest first and is not in Square's own time order\");\n }\n if (p.length) { shout(\"FILE 1 RECONCILIATION FAILED. Nothing written.\"); p.forEach((x) => console.error(\" - \" + x)); process.exit(1); }\n}\n\n// -------------------------------------------------------------------------------------------\n// FILE 3, RENDERED. The plan itself was computed above, before file 1, so that file 1 can name\n// the booking a confirmed match would land on.\n// -------------------------------------------------------------------------------------------\nconst writeRows = [...plan.values()].map((g) => {\n const cur = Number(g.opp.monetaryValue || 0);\n const items = [...g.items].sort((a, b) => String(a.date).localeCompare(String(b.date)));\n const delta = items.reduce((a, x) => a + x.amount, 0);\n return {\n \"Customer\": personName(g.contact),\n \"Booking\": g.opp.name ?? \"\",\n \"Board it sits on\": STAGE_NAME[g.opp.pipelineStageId],\n \"Amount showing on it now (US dollars)\": cur.toFixed(2),\n \"Amount to add (US dollars)\": delta.toFixed(2),\n \"Amount it would show afterwards (US dollars)\": (cur + delta).toFixed(2),\n \"How many payments make that up\": items.length,\n \"When those payments were taken\": items.map((x) => x.date).join(\"; \"),\n \"What each one was (US dollars)\": items.map((x) => x.amount.toFixed(2)).join(\"; \"),\n \"How I know\": `Square took ${plural(items.length, \"this payment\", \"these payments\")} from ${personName(g.contact)} and your CRM filed ${plural(items.length, \"it\", \"them\")} against that customer's record, but no dollars were ever put on the booking itself.`,\n \"Would this write over a figure already there\": cur > 0 ? \"YES, DO NOT RUN THIS ROW\" : \"No, the box is empty\",\n _increase: delta,\n _current: cur,\n _count: items.length,\n _stage: g.opp.pipelineStageId,\n _paymentIds: items.map((x) => x.id),\n _booking: g.opp.name ?? \"\",\n };\n}).sort((a, b) => b._increase - a._increase || String(a[\"Customer\"]).localeCompare(String(b[\"Customer\"])));\n\nconst writtenPayments = writeRows.reduce((a, r) => a + r._count, 0);\nconst writtenTotal = writeRows.reduce((a, r) => a + r._increase, 0);\nconst leftAloneTotal = leftAlone.reduce((a, r) => a + r.amount, 0);\n{\n const p = [];\n if (writtenPayments + leftAlone.length !== linkedIds.length) p.push(`${writtenPayments} written + ${leftAlone.length} left alone does not equal the ${linkedIds.length} payments that reached a customer`);\n if (cents(writtenTotal + leftAloneTotal) !== cents(linkedTotal)) p.push(`written ${money(writtenTotal)} + left alone ${money(leftAloneTotal)} does not equal ${money(linkedTotal)}`);\n if (writeRows.some((r) => r._current > 0)) p.push(\"a planned write would overwrite a non zero value\");\n if (writeRows.some((r) => !IN_SCOPE.has(r._stage))) p.push(\"a planned write is outside the two allowed stages\");\n if (new Set(writeRows.flatMap((r) => r._paymentIds)).size !== writtenPayments) p.push(\"a payment appears on more than one booking\");\n if (writeRows.some((r) => r._paymentIds.some((x) => refundedPayments.has(x)))) p.push(\"a refunded payment is in the write plan\");\n // NO ID COLUMN MEANS THE NAME HAS TO BE ENOUGH. If two bookings in this plan share a name and a\n // board, a reader cannot tell which row is which, and the file has to grow a column rather than\n // ship ambiguous. Checked rather than assumed.\n {\n const keys = writeRows.map((r) => `${r._booking}\\u0000${r[\"Board it sits on\"]}`);\n if (new Set(keys).size !== keys.length) p.push(\"two bookings in this plan share a name and a board, so a reader cannot tell the rows apart without an identifier\");\n }\n // The same rule as the counter sales list: where the file states an order it is the source's own\n // order. These payment dates come from Square's record of when the card was taken.\n for (const r of writeRows) {\n const d = r[\"When those payments were taken\"].split(\"; \");\n for (let i = 1; i < d.length; i++) if (d[i - 1] > d[i]) p.push(`the payments on ${r[\"Customer\"]}'s row are not in the order Square took them`);\n }\n if (writeRows.some((r) => r._paymentIds.some((x) => unlinkedIds.includes(x)))) p.push(\"an unlinked payment leaked into the write plan\");\n if (p.length) { shout(\"WRITE-BACK RECONCILIATION FAILED. Nothing written.\"); p.forEach((x) => console.error(\" - \" + x)); process.exit(1); }\n}\n\n// WHAT THE FIELD BEING WRITTEN ACTUALLY HOLDS TODAY. Checked, never assumed, because \"sum the\n// payment onto monetaryValue\" is only obviously right if that field already holds payments.\nconst valueShape = new Map();\nfor (const o of opportunities) { const v = Number(o.monetaryValue || 0); if (v > 0) valueShape.set(v, (valueShape.get(v) ?? 0) + 1); }\nconst distinctValues = [...valueShape.entries()].sort((a, b) => b[1] - a[1]);\nconst cardsWithValue = distinctValues.reduce((a, [, n]) => a + n, 0);\nconst looksLikeAPriceList = distinctValues.length > 0 && distinctValues.length <= 5;\nconst priceListNotice = looksLikeAPriceList\n ? `READ THIS BEFORE ANY OF IT IS RUN. ${cardsWithValue} of your ${opportunities.length.toLocaleString(\"en-US\")} cards carried a figure in the value column when I read them on ${AS_AT}, and between them they use only ${distinctValues.length} different ${plural(distinctValues.length, \"figure\", \"figures\")}, ${distinctValues.map(([v]) => money(v)).join(\", \")}. That is the shape of a price list, not of money taken. If that column holds the price of the program, then an empty card means no price was set rather than nobody has paid, and adding a counter sale to it makes the column mean two different things on different rows. Deciding what that column is for is your call and not this file's, so nothing here has been run.`\n : \"\";\n\n// ===========================================================================================\n// THE UNPAID INVOICES. A different population from everything above and it is labelled as one.\n// An unpaid invoice is money asked for that has not arrived; a counter sale with no customer is\n// money that HAS arrived and is not filed against anybody. Those two lists were once sent as if\n// they were the same list, so from here on each one says what it is not.\n// ===========================================================================================\n// Settled is enumerated as a positive list rather than assumed to be the single word \"paid\". An\n// unknown status counted as unresolved would invent a debt and counted as settled would hide one,\n// so an unknown status stops the run.\nconst SETTLED = new Set([\"paid\", \"void\", \"voided\", \"cancelled\", \"canceled\", \"written_off\", \"partially_paid\"]);\nconst UNRESOLVED = new Set([\"draft\", \"sent\", \"overdue\", \"viewed\", \"partially_paid_unsettled\"]);\n{\n const unknown = [...new Set(invoices.map((i) => i.status))].filter((s) => !SETTLED.has(s) && !UNRESOLVED.has(s));\n if (unknown.length) die(`invoice status(es) this report has no rule for: ${unknown.join(\", \")}. Classify them before shipping a number.`);\n}\nconst invTotal = (i) => Number(i.total ?? i.invoiceTotal ?? 0) || 0;\nconst invDue = (i) => Number(i.amountDue ?? 0) || 0;\nconst parentInvoiceTotal = invoices.reduce((a, i) => a + invTotal(i), 0);\nconst unresolvedInvoices = invoices.filter((i) => !SETTLED.has(i.status)).sort((a, b) => String(a.createdAt).localeCompare(String(b.createdAt)));\nconst settledInvoices = invoices.filter((i) => SETTLED.has(i.status));\nconst unresolvedTotal = unresolvedInvoices.reduce((a, i) => a + invTotal(i), 0);\nconst settledTotal = settledInvoices.reduce((a, i) => a + invTotal(i), 0);\n{\n const p = [];\n if (unresolvedInvoices.length + settledInvoices.length !== invoices.length) p.push(\"unresolved plus settled does not equal all invoices\");\n if (cents(unresolvedTotal + settledTotal) !== cents(parentInvoiceTotal)) p.push(`unresolved ${money(unresolvedTotal)} plus settled ${money(settledTotal)} does not equal ${money(parentInvoiceTotal)}`);\n if (p.length) { shout(\"INVOICE RECONCILIATION FAILED. Nothing written.\"); p.forEach((x) => console.error(\" - \" + x)); process.exit(1); }\n}\n\n// THE NAME COMES FROM THE CUSTOMER RECORD, NOT FROM WHATEVER THE INVOICE HAPPENED TO STORE. One\n// invoice in this list showed a customer called \"(410) 804-1833\", because that is what somebody\n// typed at the counter. Her CRM knows that person perfectly well. A phone number where a name\n// should be is not a data problem she has to solve, it is one we have to stop printing.\nconst PLACEHOLDER_EMAIL = /^auto\\.generated@pos\\.payment$/i;\nconst NAMELESS = new Set([\"unknown\", \"\", \"no name\", \"customer\", \"your dog\"]);\nconst looksLikeAPhoneNumber = (s) => /^[\\s()+\\-.\\d]{7,}$/.test(String(s ?? \"\").trim());\nconst sharedCounterContactIds = new Set(\n contacts.filter((c) => PLACEHOLDER_EMAIL.test(String(c.email ?? \"\")) || NAMELESS.has(String(c.contactName ?? \"\").trim().toLowerCase()))\n .map((c) => c.id),\n);\nfunction resolveCustomer(i) {\n const cd = i.contactDetails ?? {};\n const stored = String(cd.name ?? \"\").trim();\n const c = contactById.get(cd.id);\n const notes = [];\n let name = \"\";\n if (c && sharedCounterContactIds.has(c.id)) {\n name = \"No customer name on file\";\n notes.push(\"this one was rung up against the shared counter record your card reader uses, so there is no person on it to chase\");\n } else if (c) {\n name = personName(c);\n if (stored && normName(stored) && normName(stored) !== normName(name) && !looksLikeAPhoneNumber(stored)) {\n notes.push(`the invoice was typed up under the name ${stored} and the customer record now reads ${name}`);\n }\n } else if (stored && !looksLikeAPhoneNumber(stored) && !NAMELESS.has(stored.toLowerCase())) {\n name = titleCase(stored);\n notes.push(\"the customer record this was raised against has since been deleted from your CRM, so the email and phone on the invoice are all there is to go on\");\n } else {\n name = \"No customer name on file\";\n notes.push(\"the customer record this was raised against has since been deleted from your CRM\");\n }\n return { name, notes };\n}\n\n// SQUARE CANNOT SPEAK ABOUT WHAT IT NEVER SAW. Its record here begins the day the connection was\n// switched on, so for anything raised before that it is silent rather than negative. Saying \"no\n// Square payment found\" about a December invoice would be a date boundary passed off as a finding.\nconst squareCoverageStart = square.map((s) => s.created_at).filter(Boolean).sort()[0] ?? journal.map((r) => r?.ts).filter(Boolean).sort()[0];\nconst squareByKey = new Map();\nfor (const s of square) {\n const c = s.square_customer ?? {};\n for (const k of [normPhone(c.phone_number), normEmail(c.email_address), normName([c.given_name, c.family_name].filter(Boolean).join(\" \"))]) {\n if (k) (squareByKey.get(k) ?? squareByKey.set(k, []).get(k)).push(s);\n }\n}\nconst invoiceById = new Map(invoices.map((i) => [i._id, i]));\nconst SOURCE_NAME = { mobile_pos: \"Rung up at the counter\", payments_subscription: \"A subscription in your CRM\", manual: \"Entered by hand\" };\n\n// REAL MONEY OR A TEST ROW. This cut is a judgement and the file says so in the page beside it.\n// The rule is two lines long on purpose, so she can disagree with it row by row: anything under\n// five dollars is somebody testing a card reader rather than a sale, and anything raised against\n// a record with the word \"test\" in its name is somebody testing the software. Everything else is\n// treated as real money even where it is awkward, because deciding otherwise on a customer's\n// behalf is how a real unpaid invoice quietly disappears off a list.\nconst TEST_MONEY_CEILING = 5;\nconst invoiceRows = unresolvedInvoices.map((i) => {\n const cd = i.contactDetails ?? {};\n const amt = invTotal(i);\n const { name, notes } = resolveCustomer(i);\n const storedName = String(cd.name ?? \"\").trim();\n const namedAsATest = /\\btest\\b/i.test(storedName) || /\\btest\\b/i.test(name);\n const tooSmallToBeASale = amt < TEST_MONEY_CEILING;\n const isTest = namedAsATest || tooSmallToBeASale;\n\n const inSquareWindow = i.createdAt && squareCoverageStart && i.createdAt >= squareCoverageStart;\n const keys = [normPhone(cd.phoneNo), normEmail(cd.email), normName(cd.name)].filter(Boolean);\n const sqHits = [...new Set(keys.flatMap((k) => squareByKey.get(k) ?? []))].filter((s) => cents(s.amount) === cents(amt));\n const txHits = sharedCounterContactIds.has(cd.id) ? [] : transactions.filter((t) =>\n t.status === \"succeeded\" && cents(Number(t.amount) || 0) === cents(amt) && t.contactId && t.contactId === cd.id);\n\n let paid = \"No sign of it either way\";\n let evidence = \"\";\n let alreadyPaid = false;\n if (sqHits.length) {\n const s = sqHits[0];\n paid = \"Yes, in Square\";\n evidence = `Square took ${money(s.amount)} from this customer on ${fmtDate(s.created_at)}, and the receipt is at ${s.receipt_url}`;\n alreadyPaid = true;\n } else if (txHits.length) {\n const t = txHits[0];\n const sib = invoiceById.get(t.entitySourceId) ?? invoiceById.get(t.entityId);\n paid = \"Yes, in your CRM\";\n evidence = sib\n ? `the same customer paid ${money(t.amount)} on ${fmtDate(t.createdAt)} against invoice ${sib.invoiceNumber}, which is a duplicate of this one raised the same day and is marked paid`\n : `your CRM recorded a payment of ${money(t.amount)} from this customer on ${fmtDate(t.createdAt)}`;\n alreadyPaid = true;\n } else if (!inSquareWindow) {\n paid = \"Square cannot say\";\n evidence = `this was raised before the Square connection started recording on ${fmtDate(squareCoverageStart)}, so Square can neither confirm nor rule out\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"]