[{"_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":-5},"handle","amir5","name","dogsspot_puppy_path","path","payments-source.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/payments-source.ts","extension","id","07010f2c-1685-4e77-9e01-02926171f76c","fileId","e209084c-94ec-11f1-9ce5-1607ee4eb77e","parentId","branchId","551774fb-a850-4c9d-94a1-d3509ddcf1b0","branchVersion",1159,"latest",true,"createdAt",["D",1786979130738],"version",1,"fileType","script","content","// SQUARE MONEY AS THE CRM RECORDS IT. Read-only, paged, duplicate-safe.\n// The payments endpoint rejects locationId and requires altId + altType=location.\n\nimport type { Payment } from \"./money-match.ts\";\n\nconst LOC = \"BQHJ19uohldYe3eqA0bl\";\nconst GHL = \"https://services.leadconnectorhq.com\";\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\nexport const PAYMENT_PAGE_SIZE = 100;\nexport const PAYMENT_PAGE_CAP = 60;\nexport const MIN_REAL_PAYMENT = 1;\n\n// Proven live 10 Aug 2026 across all 233 transactions. Unknown types remain in the result and are\n// reported, because a new payment route must not disappear merely because the allow-list is old.\nexport const ACCEPTED_SOURCE_TYPES: readonly string[] = Object.freeze([\n \"calendar\", \"invoice\", \"funnel\", \"payment_link\", \"manual\",\n]);\nconst ACCEPTED = new Set(ACCEPTED_SOURCE_TYPES);\nconst BAD_TEXT = /[\\u0000-\\u001f\\u007f\\u202a-\\u202e\\u2066-\\u2069\\u200e\\u200f\\u061c]/;\n\nexport const isRealMoney = (p: { amount: number }) =>\n Number.isFinite(p?.amount) && p.amount >= MIN_REAL_PAYMENT;\n\nconst nullableText = (v: unknown, label: string, max: number): string | null => {\n if (v == null) return null;\n if (typeof v !== \"string\") throw new Error(`payment row has an invalid ${label}`);\n const text = v.trim();\n if (!text) return null;\n if (text.length > max || BAD_TEXT.test(text)) throw new Error(`payment row has an invalid ${label}`);\n return text;\n};\n\nconst sourceAmount = (v: unknown): number => {\n if (typeof v !== \"number\") throw new Error(\"payment row has an invalid amount\");\n const amount = v;\n if (!Number.isFinite(amount) || amount < 0 || amount > 1_000_000_000) throw new Error(\"payment row has an invalid amount\");\n return amount;\n};\n\n/** Validate and normalize one source record. Invalid money is an error, not a quiet $0 drop. */\nexport function toPayment(t: any): Payment {\n if (!t || typeof t !== \"object\" || Array.isArray(t)) throw new Error(\"payment row is not an object\");\n const id = nullableText(t._id, \"id\", 160);\n if (!id) throw new Error(\"payment row has no stable id\");\n const amount = sourceAmount(t.amount);\n if (typeof t.status !== \"string\") throw new Error(`payment ${id} has an invalid status`);\n const status = t.status.trim().toLowerCase();\n const atRaw = nullableText(t.createdAt, \"createdAt\", 80);\n if (!status || status.length > 80 || BAD_TEXT.test(status)) throw new Error(`payment ${id} has an invalid status`);\n if (atRaw != null && !Number.isFinite(Date.parse(atRaw))) throw new Error(`payment ${id} has an invalid createdAt`);\n return {\n id,\n amount,\n status,\n contactId: nullableText(t.contactId, \"contactId\", 160),\n contactName: nullableText(t.contactName, \"contactName\", 240),\n at: atRaw,\n };\n}\n\nexport type Accepted = {\n payments: Payment[];\n unknownTypes: string[];\n dropped: { zeroOrTest: number; notSucceeded: number; duplicate: number };\n};\n\n/**\n * Keep only completed, real money. Exact duplicate ids collapse; conflicting duplicate ids throw.\n * Every source row lands in payments or exactly one dropped counter.\n */\nexport function acceptPayments(rows: any[]): Accepted {\n if (!Array.isArray(rows)) throw new Error(\"payment rows are not an array\");\n const unknown = new Set();\n const kept: Payment[] = [];\n const seen = new Map();\n let zeroOrTest = 0, notSucceeded = 0, duplicate = 0;\n for (const t of rows) {\n const p = toPayment(t);\n const sourceType = nullableText(t?.entitySourceType, \"entitySourceType\", 80) ?? \"\";\n if (!ACCEPTED.has(sourceType)) unknown.add(sourceType);\n const signature = JSON.stringify({ p, sourceType });\n const prior = seen.get(p.id);\n if (prior !== undefined) {\n if (prior !== signature) throw new Error(`conflicting duplicate payment id: ${p.id}`);\n duplicate++;\n continue;\n }\n seen.set(p.id, signature);\n if (p.status !== \"succeeded\") { notSucceeded++; continue; }\n if (!isRealMoney(p)) { zeroOrTest++; continue; }\n kept.push(p);\n }\n return {\n payments: kept,\n unknownTypes: [...unknown].sort(),\n dropped: { zeroOrTest, notSucceeded, duplicate },\n };\n}\n\nexport type PaymentGetter = (url: string) => Promise;\nexport type PaymentSource = Accepted & {\n source: {\n endpoint: \"GoHighLevel /payments/transactions\";\n fetchedAt: string;\n totalCount: number;\n fetched: number;\n pages: number;\n complete: true;\n };\n};\n\n/** Injected getter keeps paging behavior testable without touching a live account. */\nexport async function fetchPayments(\n get: PaymentGetter,\n opts: { locationId?: string; pageSize?: number; pageCap?: number; now?: number } = {},\n): Promise {\n const locationId = opts.locationId ?? LOC;\n const pageSize = opts.pageSize ?? PAYMENT_PAGE_SIZE;\n const pageCap = opts.pageCap ?? PAYMENT_PAGE_CAP;\n const now = opts.now ?? Date.now();\n if (!locationId || !Number.isInteger(pageSize) || pageSize < 1 || pageSize > PAYMENT_PAGE_SIZE ||\n !Number.isInteger(pageCap) || pageCap < 1 || pageCap > 100 || !Number.isFinite(now)) {\n throw new Error(\"invalid payment source options\");\n }\n\n const rows: any[] = [];\n let totalCount: number | null = null;\n let pages = 0;\n for (let offset = 0; pages < pageCap; offset += pageSize) {\n const q = new URLSearchParams({\n altId: locationId,\n altType: \"location\",\n limit: String(pageSize),\n offset: String(offset),\n });\n const body = await get(`${GHL}/payments/transactions?${q}`) as any;\n if (!body || !Array.isArray(body.data)) throw new Error(`payment page ${pages + 1} has no data array`);\n const reported = Number(body.totalCount);\n if (!Number.isInteger(reported) || reported < 0) throw new Error(`payment page ${pages + 1} has no valid totalCount`);\n if (totalCount === null) totalCount = reported;\n else if (reported !== totalCount) throw new Error(`payment totalCount changed during paging: ${totalCount} to ${reported}`);\n if (body.data.length > pageSize) throw new Error(`payment page ${pages + 1} exceeds its requested limit`);\n rows.push(...body.data);\n pages++;\n if (rows.length >= totalCount) break;\n if (body.data.length < pageSize) throw new Error(`payment source stopped at ${rows.length} of ${totalCount}`);\n }\n\n if (totalCount === null) throw new Error(\"payment source returned no pages\");\n if (rows.length !== totalCount) throw new Error(`payment source read ${rows.length} of ${totalCount} before its page cap`);\n for (const row of rows) {\n const payment = toPayment(row);\n if (payment.at && Date.parse(payment.at) > now + 5 * 60_000) {\n throw new Error(`payment ${payment.id} has a future createdAt`);\n }\n }\n const accepted = acceptPayments(rows);\n if (accepted.dropped.duplicate > 0) {\n throw new Error(`payment pagination repeated ${accepted.dropped.duplicate} transaction(s); completeness cannot be proven`);\n }\n return {\n ...accepted,\n source: {\n endpoint: \"GoHighLevel /payments/transactions\",\n fetchedAt: new Date(now).toISOString(),\n totalCount,\n fetched: rows.length,\n pages,\n complete: true,\n },\n };\n}\n\n/** Production GET transport. It cannot issue a mutating request. */\nexport function ghlPaymentGetter(token: string): PaymentGetter {\n if (!token) throw new Error(\"GHL_TOKEN is required\");\n return async (url: string) => {\n const target = new URL(url, GHL);\n if (target.origin !== GHL || target.pathname !== \"/payments/transactions\") {\n throw new Error(\"refusing a payment URL outside the documented CRM endpoint\");\n }\n const r = await fetch(target.toString(), {\n method: \"GET\",\n headers: { Authorization: `Bearer ${token}`, Version: \"2021-07-28\", \"User-Agent\": UA, Accept: \"application/json\" },\n signal: AbortSignal.timeout(20_000),\n });\n if (!r.ok) throw new Error(`payments source returned ${r.status}`);\n return r.json();\n };\n}\n\nexport const fetchPaymentsFromGhl = (token: string, opts: Parameters[1] = {}) =>\n fetchPayments(ghlPaymentGetter(token), opts);\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",{"_35":89,"_11":90,"_22":28,"_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":32,"_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"]