[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_155":156,"_157":158},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_91":-7,"_92":93,"_29":-7,"_94":-5,"_15":95,"_96":97,"_98":99,"_100":101,"_102":103,"_104":-5,"_105":-5,"_106":-5,"_107":38,"_108":109,"_110":111,"_112":-5,"_113":-5,"_114":115},"routes/_app.x.$handle.$name.branches",{"_11":12,"_13":14,"_15":16,"_17":18},"handle","ascendfitness","name","zenplanner-people-to-airtable","project",{"_20":28,"_13":14,"_22":36,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":38,"_49":-5,"_50":-5,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":-5,"_62":63,"_64":63,"_65":66,"_67":66,"_68":66,"_69":63,"_70":63,"_71":72,"_73":74,"_75":76,"_77":38},"branches",[19],{"_20":21,"_22":23,"_24":25,"_13":26,"_27":28,"_29":30,"_31":-5,"_32":-5,"_33":34,"_35":-5},"id","51ee2596-80d2-4364-8d07-88988219b4aa","createdAt",["D",1783865378698],"updatedAt",["D",1785086117359],"main","projectId","53110344-d8a1-4352-b73d-187def954d64","version",20,"forkedBranchId","forkedBranchVersion","lockfileKey","1785086117808-esm.town_v_ascendfitness_zenplanner-people-to-airtable@20-main","deletedAt",["D",1783865378694],"legacyEnvVars",false,"privacy","public","httpPrivacy","description","webhooks sync from zp to airtable","imageUrl","userId","44ce8aa9-1ed9-4504-91ee-c68325632994","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f56a8-2712-750d-8a46-0901b512a677","tursoName","53110344d8a14352b73d187def954d64","tursoHostname","53110344d8a14352b73d187def954d64-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789472446807],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_90":86},"org",{"_11":12,"_83":84,"_85":86,"_45":46,"_87":88,"_89":38},"branch",{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_78":-5,"_79":-5,"_80":-5,"_81":14,"_82":12},"isOwned","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Jesse Walker","avatar","https://lh3.googleusercontent.com/a/ACg8ocJfsYea3m83vsjChcIBvF2gnICQEl7Z7-I3gHouqBctmyoQyWve=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","path","","adoptOrgId",{"_20":28,"_13":14,"_22":150,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":38,"_49":-5,"_50":-5,"_51":52,"_53":54,"_55":56,"_57":58,"_59":151,"_61":-5,"_62":63,"_64":63,"_65":66,"_67":66,"_68":66,"_69":63,"_70":63,"_71":152,"_73":153,"_75":154,"_77":38},"tree",[145],"files",[145],"counts",{"_134":52,"_17":135,"_136":52,"_137":138,"_139":140},"contents",[116],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_20":117,"_13":118,"_119":120,"_121":-5,"_122":21,"_123":30,"_124":111,"_22":125,"_29":126,"_127":128,"_129":130,"_131":38,"_132":-5,"_92":133},"a8504f00-5dbe-484d-91e4-d4c060e948b6","main.ts","fileId","51c28be4-7dfb-11f1-89b1-1607ee4eb77e","parentId","branchId","branchVersion","latest",["D",1785086117359],19,"fileType","http","content","// ZenPlanner \"people\" webhook -> Airtable (Roster + Event Records)\n// v3 — 2026-07-26. Built against the real base schema and a real ZP payload.\n//\n// ZP posts application/x-www-form-urlencoded on every person change, several\n// times simultaneously. We log the raw body, dedupe, then sync via the Airtable\n// REST API (bypassing Airtable Automations so it doesn't burn runs).\n//\n// ============================================================================\n// BEHAVIOUR\n// ============================================================================\n// Match: {ZenPlanner ID} = personId -> else exact {Name}.\n// Name matching 2+ Roster records -> AMBIGUOUS: skip & log.\n//\n// ZP status -> Roster {Member Status}:\n// STUDENT -> Active (creates a Roster record if there's no match)\n// PROSPECT -> status left untouched; NEVER creates a record\n// (missing) -> status left untouched (partial payload guard)\n// anything else (ALUMNI, NON-MEMBER, …) -> Alumni; update-only, never creates\n// \"Hold\" in Airtable is never overwritten by a STUDENT webhook — a member you\n// put on hold stays on hold. Hold -> Alumni still counts as a cancellation.\n//\n// Contact fields: written when ZP has a value that differs from Airtable.\n// An empty ZP value never blanks an Airtable value.\n//\n// Event Records:\n// Roster record CREATED -> {Event Type} \"Sign Up\", {Sign Up Date}\n// {Member Status} -> Alumni -> {Event Type} \"Cancel\", {Cancel Date}\n// Cancel fires only on a genuine transition, so repeat webhooks and later\n// unrelated edits can't write duplicate cancels.\n// Roster {Sign Up Date} / {Cancel Date} are lookups through {Event Records} —\n// they are read-only and populate themselves from the linked event.\n//\n// Env vars: AIRTABLE_TOKEN (required), AIRTABLE_BASE_ID, DRY_RUN.\n// Table IDs are hardcoded below (they aren't secrets) but env vars override.\n// GET this endpoint in a browser for a config dump — no secrets shown.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// ============================================================================\n// CONFIG\n// ============================================================================\nconst BASE_ID = Deno.env.get(\"AIRTABLE_BASE_ID\") || \"appAUyXe4LgupwX0f\";\nconst ROSTER_TABLE = Deno.env.get(\"AIRTABLE_TABLE_ID\") || \"tbl9fSFXxA6NXGCZ8\";\nconst EVENTS_TABLE = Deno.env.get(\"EVENT_TABLE_ID\") || \"tblXximw4Vrq8GaYk\";\n\n// --- Roster fields (verified against the base 2026-07-26) ---\nconst R_NAME = \"Name\"; // primary, multilineText\nconst R_FIRST = \"First Name\";\nconst R_LAST = \"Last Name\";\nconst R_ZP_ID = \"ZenPlanner ID\";\nconst R_STATUS = \"Member Status\"; // singleSelect: Active | Hold | Alumni\nconst R_EVENTS = \"Event Records\"; // link -> Event Records, used to spot pre-existing events\nconst STATUS_ACTIVE = \"Active\";\nconst STATUS_HOLD = \"Hold\";\nconst STATUS_ALUMNI = \"Alumni\";\n\n// --- Event Records fields ---\nconst E_TYPE = \"Event Type\"; // singleSelect: Sign Up | Hold | Cancel\nconst E_MEMBER = \"Member\"; // link -> Roster\nconst E_SIGNUP_DATE = \"Sign Up Date\";\nconst E_CANCEL_DATE = \"Cancel Date\";\nconst EVENT_SIGNUP = \"Sign Up\";\nconst EVENT_CANCEL = \"Cancel\";\n\n// --- ZP status values ---\nconst ZP_ACTIVE = [\"STUDENT\"];\nconst ZP_PROSPECT = [\"PROSPECT\"];\n// A blank status is indistinguishable from a truncated payload, and acting on\n// it would cancel a real member. Left false until blank-status deliveries show\n// up in the logs. Flip to true to treat blank as Alumni.\nconst BLANK_STATUS_MEANS_ALUMNI = false;\n\n// --- Select-field value maps -------------------------------------------------\n// We write selects with typecast:false, so an unmapped value is SKIPPED and\n// logged rather than silently creating a junk choice in your base.\nconst GENDER_MAP: Record = { male: \"Male\", female: \"Female\" };\n\n// ZP personGroups is free text (\"Team Strength\"); Roster {Format} is a select.\nfunction mapFormat(raw: string): string {\n for (const part of raw.split(/[,;|]/)) {\n const s = part.trim().toLowerCase();\n if (!s) continue;\n if (s.includes(\"youth\")) return \"Youth\";\n if (s.includes(\"team\")) return \"Team\";\n if (s.includes(\"1-1\") || s.includes(\"personal\") || s.includes(\"one on one\")) return \"1-1\";\n }\n return \"\";\n}\n\n// --- Contact field mapping ---------------------------------------------------\n// zp: payload key(s), tried in order; first non-empty wins (case-insensitive)\n// at: Airtable field name\n// compare: text | phone | date | select — how \"has it changed?\" is decided\n// policy: zp-wins (overwrite on mismatch) | fill-blank (only write if AT empty)\ntype Compare = \"text\" | \"phone\" | \"date\" | \"select\";\ntype Policy = \"zp-wins\" | \"fill-blank\";\nconst FIELD_MAP: Array<{\n zp: string[];\n at: string;\n compare: Compare;\n policy: Policy;\n transform?: (v: string) => string;\n}> = [\n { zp: [\"primaryEmail\", \"email\"], at: \"Email\", compare: \"text\", policy: \"zp-wins\" },\n { zp: [\"phoneNumber\", \"phone\"], at: \"Phone\", compare: \"phone\", policy: \"zp-wins\" },\n { zp: [\"birthDate\"], at: \"Birth Date\", compare: \"date\", policy: \"zp-wins\" },\n {\n zp: [\"gender\"],\n at: \"Gender\",\n compare: \"select\",\n policy: \"zp-wins\",\n transform: (v) => GENDER_MAP[v.toLowerCase()] ?? \"\",\n },\n // personGroups -> Format is an inference, not a fact, so it only fills blanks\n // and never overwrites a Format you set deliberately in Airtable.\n {\n zp: [\"personGroups\"],\n at: \"Format\",\n compare: \"select\",\n policy: \"fill-blank\",\n transform: mapFormat,\n },\n];\n\n// ============================================================================\n\nconst DEDUPE_TABLE = \"zp_relay_processed_events\";\nawait sqlite.execute(\n `CREATE TABLE IF NOT EXISTS ${DEDUPE_TABLE} (\n person_id TEXT NOT NULL,\n version TEXT NOT NULL,\n processed_at TEXT NOT NULL DEFAULT (datetime('now')),\n PRIMARY KEY (person_id, version)\n )`,\n);\n\nexport default async function (req: Request): Promise {\n if (req.method === \"GET\") return configCheck();\n if (req.method !== \"POST\") return new Response(\"Method not allowed\", { status: 405 });\n\n // Read + log the raw body BEFORE parsing — ZP posts form-encoded, so parsing\n // straight to JSON would throw and 400 before anything got logged.\n const rawBody = await req.text();\n const contentType = req.headers.get(\"content-type\") ?? \"\";\n const dryRun = Deno.env.get(\"DRY_RUN\") === \"true\";\n\n console.log(`[dryRun=${dryRun}] ${req.method} content-type=\"${contentType}\" rawBody:`, rawBody);\n\n const payload = parseBody(rawBody, contentType);\n if (!payload) {\n console.log(\"Could not parse body into a payload — see rawBody above.\");\n return new Response(\"Bad body\", { status: 400 });\n }\n\n const personId = get(payload, \"personId\");\n const first = get(payload, \"firstName\");\n const last = get(payload, \"lastName\");\n const name = [first, last].filter(Boolean).join(\" \").trim();\n const rawStatus = get(payload, \"status\");\n const statusPresent = hasKey(payload, \"status\");\n const intent = mapStatus(rawStatus, statusPresent);\n\n // ZP sends ColdFusion timestamps: {ts '2026-07-25 01:14:22'}. Dates are taken\n // literally (no UTC conversion) — these are gym-local and the fields are\n // date-only, so shifting them through a timezone would move them a day.\n const changedOn = toISODate(get(payload, \"lastUpdated\")) ||\n toISODate(get(payload, \"timestamp\")) || today();\n const signupDate = toISODate(get(payload, \"signupDate\")) || changedOn;\n const cancelDate = toISODate(get(payload, \"membershipDropDate\")) || changedOn;\n\n console.log(\n `Parsed: personId=\"${personId}\" name=\"${name}\" status=\"${rawStatus}\" ` +\n `(present=${statusPresent}) -> intent=${intent} changedOn=${changedOn} ` +\n `signupDate=${signupDate} cancelDate=${cancelDate}`,\n );\n\n if (!personId) {\n console.log(\"No personId in payload — cannot sync. Ignoring.\");\n return new Response(\"No personId\", { status: 200 });\n }\n\n // Dedupe ZP's repeated/simultaneous deliveries. INSERT OR IGNORE is atomic,\n // so two concurrent deliveries can't both create the same record.\n const version = get(payload, \"lastUpdated\") || get(payload, \"timestamp\") || rawBody;\n if (!dryRun && !(await claimEvent(personId, version))) {\n console.log(`Duplicate delivery (personId=\"${personId}\" version=\"${version}\") — skipping.`);\n return new Response(\"Duplicate\", { status: 200 });\n }\n\n try {\n await sync({ personId, name, first, last, intent, signupDate, cancelDate, payload, dryRun });\n } catch (err) {\n // Release the claim so a genuine retry can re-process this change.\n if (!dryRun) await releaseEvent(personId, version).catch(() => {});\n console.error(\"Sync failed:\", err instanceof Error ? err.message : String(err));\n return new Response(\"Sync error\", { status: 500 });\n }\n\n return new Response(\"OK\", { status: 200 });\n}\n\n// ============================================================================\n// Core sync\n// ============================================================================\ntype Intent = \"active\" | \"prospect\" | \"alumni\" | \"unknown\";\n\nfunction mapStatus(raw: string, present: boolean): Intent {\n if (!present) return \"unknown\"; // key absent -> partial payload, don't touch status\n const s = raw.toUpperCase();\n if (ZP_ACTIVE.includes(s)) return \"active\";\n if (ZP_PROSPECT.includes(s)) return \"prospect\";\n if (!s) return BLANK_STATUS_MEANS_ALUMNI ? \"alumni\" : \"unknown\";\n return \"alumni\";\n}\n\nasync function sync(o: {\n personId: string;\n name: string;\n first: string;\n last: string;\n intent: Intent;\n signupDate: string;\n cancelDate: string;\n payload: Record;\n dryRun: boolean;\n}) {\n const { personId, name, first, last, intent, signupDate, cancelDate, payload, dryRun } = o;\n const at = airtable();\n if (!at) return;\n\n // --- 1) Find the Roster record: stable ZP ID first, then exact name --------\n let match = await at.roster.findOne(R_ZP_ID, personId);\n let matchedBy = match ? \"ZenPlanner ID\" : \"\";\n\n if (!match) {\n if (!name) {\n console.log(\"No ZenPlanner ID match and no name — cannot match. Ignoring.\");\n return;\n }\n const byName = await at.roster.find(R_NAME, name, 3);\n if (byName.length > 1) {\n console.log(\n `AMBIGUOUS: ${byName.length} Roster records named \"${name}\" ` +\n `(${byName.map((r) => r.id).join(\", \")}). Skipping — resolve manually.`,\n );\n return;\n }\n match = byName[0] ?? null;\n matchedBy = match ? \"Name\" : \"\";\n }\n\n // --- 2) No Roster record: only an active member earns one -----------------\n if (!match) {\n if (intent !== \"active\") {\n console.log(`No Roster match and intent=\"${intent}\" (\"${name}\") — not creating. Ignoring.`);\n return;\n }\n const fields: Record = {\n [R_NAME]: name,\n [R_FIRST]: first,\n [R_LAST]: last,\n [R_ZP_ID]: personId,\n [R_STATUS]: STATUS_ACTIVE,\n ...contactFields(payload, {}),\n };\n console.log(`${tag(dryRun, \"CREATE\")} Roster -> ${JSON.stringify(fields)}`);\n console.log(`${tag(dryRun, \"CREATE\")} Event Record \"${EVENT_SIGNUP}\" ${signupDate}`);\n if (dryRun) return;\n\n const created = await at.roster.create(fields);\n // Sign Up fires only on genuine creation, so the ID-backfill pass over your\n // existing members can't invent sign-up events for people who joined years ago.\n await at.events.create({\n [E_TYPE]: EVENT_SIGNUP,\n [E_MEMBER]: [created.id],\n [E_SIGNUP_DATE]: signupDate,\n });\n return;\n }\n\n // --- 3) Matched: build a minimal patch ------------------------------------\n const cur = match.fields ?? {};\n const curStatus = str(cur[R_STATUS]);\n const fields: Record = {};\n\n if (name && !sameText(name, str(cur[R_NAME]))) fields[R_NAME] = name;\n if (first && !sameText(first, str(cur[R_FIRST]))) fields[R_FIRST] = first;\n if (last && !sameText(last, str(cur[R_LAST]))) fields[R_LAST] = last;\n if (personId !== str(cur[R_ZP_ID])) fields[R_ZP_ID] = personId; // backfill the ID\n Object.assign(fields, contactFields(payload, cur));\n\n let cancelled = false;\n let writeCancelEvent = false;\n if (intent === \"active\") {\n if (curStatus === STATUS_HOLD) {\n console.log(`Roster ${match.id} is on Hold — leaving status alone.`);\n } else if (curStatus !== STATUS_ACTIVE) {\n fields[R_STATUS] = STATUS_ACTIVE;\n }\n } else if (intent === \"alumni\") {\n cancelled = curStatus !== STATUS_ALUMNI; // only a real move INTO Alumni is a cancel\n if (cancelled) {\n fields[R_STATUS] = STATUS_ALUMNI;\n // The status transition alone isn't enough: a member may already have a\n // Cancel event entered by hand or carried over in an import, in which case\n // writing another one would double-count them. Check the linked events.\n const linked = Array.isArray(cur[R_EVENTS]) ? cur[R_EVENTS] as string[] : [];\n const dupe = await hasEvent(at, linked, EVENT_CANCEL);\n writeCancelEvent = !dupe;\n if (dupe) {\n console.log(\n `Roster ${match.id} already has a \"${EVENT_CANCEL}\" event — ` +\n `setting status to ${STATUS_ALUMNI} but not writing a second event.`,\n );\n }\n }\n } else {\n console.log(`intent=\"${intent}\" — syncing contact fields only, {Member Status} untouched.`);\n }\n\n if (!Object.keys(fields).length && !cancelled) {\n console.log(`Roster ${match.id} already in sync (matched by ${matchedBy}) — nothing to do.`);\n return;\n }\n\n console.log(\n `${tag(dryRun, \"UPDATE\")} Roster ${match.id} (matched by ${matchedBy}, name=\"${name}\") ` +\n `-> ${JSON.stringify(fields)}`,\n );\n if (writeCancelEvent) {\n console.log(\n `${tag(dryRun, \"CREATE\")} Event Record \"${EVENT_CANCEL}\" ` +\n `(was \"${curStatus || \"(blank)\"}\") Cancel Date=${cancelDate}`,\n );\n }\n if (dryRun) return;\n\n if (Object.keys(fields).length) await at.roster.update(match.id, fields);\n if (writeCancelEvent) {\n await at.events.create({\n [E_TYPE]: EVENT_CANCEL,\n [E_MEMBER]: [match.id],\n [E_CANCEL_DATE]: cancelDate,\n });\n }\n}\n\n// Does this member already have an event of this type? Guards against\n// double-counting people whose Sign Up / Cancel was entered by hand or imported\n// before the relay ever saw them.\nasync function hasEvent(\n at: NonNullable>,\n linkedEventIds: string[],\n type: string,\n): Promise {\n if (!linkedEventIds.length) return false;\n // Cap the id list so the formula can't blow past Airtable's URL length limit.\n const ors = linkedEventIds.slice(0, 40).map((id) => `RECORD_ID()=\"${esc(id)}\"`).join(\",\");\n const found = await at.events.findByFormula(`AND({${E_TYPE}}=\"${type}\",OR(${ors}))`, 1);\n return found.length > 0;\n}\n\n// Only the contact fields ZP actually has AND that differ from Airtable.\n// An empty ZP value never blanks an existing Airtable value.\nfunction contactFields(\n payload: Record,\n cur: Record,\n): Record {\n const out: Record = {};\n for (const m of FIELD_MAP) {\n let incoming = \"\";\n for (const key of m.zp) {\n const v = get(payload, key);\n if (v) {\n incoming = v;\n break;\n }\n }\n if (!incoming) continue;\n\n if (m.transform) {\n const mapped = m.transform(incoming);\n if (!mapped) {\n console.log(`{${m.at}}: no mapping for ZP value \"${incoming}\" — skipping field.`);\n continue;\n }\n incoming = mapped;\n }\n if (m.compare === \"date\") {\n const iso = toISODate(incoming);\n if (!iso) {\n console.log(`{${m.at}}: could not parse \"${incoming}\" as a date — skipping field.`);\n continue;\n }\n incoming = iso;\n }\n\n const existing = str(cur[m.at]);\n if (norm(incoming, m.compare) === norm(existing, m.compare)) continue;\n if (existing && m.policy === \"fill-blank\") {\n console.log(`{${m.at}}: ZP \"${incoming}\" != Airtable \"${existing}\" — fill-blank, keeping AT.`);\n continue;\n }\n if (existing) console.log(`{${m.at}}: ZP \"${incoming}\" != Airtable \"${existing}\" — ZP wins.`);\n out[m.at] = incoming;\n }\n return out;\n}\n\n// ============================================================================\n// Parsing helpers\n// ============================================================================\nfunction parseBody(rawBody: string, contentType: string): Record | null {\n const asJson = () => {\n try {\n const v = JSON.parse(rawBody);\n return v && typeof v === \"object\" ? v as Record : null;\n } catch {\n return null;\n }\n };\n const asForm = () => {\n const obj = Object.fromEntries(new URLSearchParams(rawBody));\n return Object.keys(obj).length ? obj as Record : null;\n };\n if (contentType.includes(\"application/json\")) return asJson() ?? asForm();\n if (contentType.includes(\"application/x-www-form-urlencoded\")) return asForm() ?? asJson();\n return asJson() ?? asForm();\n}\n\n// Case-insensitive key lookup — the field-mapping sheet says \"Status\", the live\n// payload sends \"status\". Tolerate either.\nfunction get(p: Record, key: string): string {\n if (key in p) return str(p[key]);\n const lower = key.toLowerCase();\n for (const k of Object.keys(p)) if (k.toLowerCase() === lower) return str(p[k]);\n return \"\";\n}\n\nfunction hasKey(p: Record, key: string): boolean {\n const lower = key.toLowerCase();\n return Object.keys(p).some((k) => k.toLowerCase() === lower);\n}\n\nfunction str(v: unknown): string {\n return v == null ? \"\" : String(v).trim();\n}\n\nfunction sameText(a: string, b: string): boolean {\n return a.trim().toLowerCase() === b.trim().toLowerCase();\n}\n\nfunction norm(v: string, mode: Compare): string {\n if (mode === \"phone\") return v.replace(/\\D/g, \"\"); // \"(555) 123-4567\" == \"555-123-4567\"\n if (mode === \"date\") return toISODate(v) || v.trim();\n return v.trim().toLowerCase();\n}\n\nfunction today(): string {\n return new Date().toISOString().slice(0, 10);\n}\n\n// Handles ColdFusion {ts '2025-12-05 00:00:00'}, ISO \"1974-04-21T12:00\",\n// plain YYYY-MM-DD, and US M/D/YYYY. Reads the calendar date literally rather\n// than converting through UTC, which would shift date-only fields by a day.\nfunction toISODate(v: string): string {\n const s = v.trim();\n if (!s) return \"\";\n const cf = s.match(/\\{ts\\s*'(\\d{4})-(\\d{2})-(\\d{2})/);\n if (cf) return `${cf[1]}-${cf[2]}-${cf[3]}`;\n const lead = s.match(/^(\\d{4})-(\\d{2})-(\\d{2})/);\n if (lead) return `${lead[1]}-${lead[2]}-${lead[3]}`;\n const us = s.match(/^(\\d{1,2})[/-](\\d{1,2})[/-](\\d{4})/);\n if (us) return `${us[3]}-${us[1].padStart(2, \"0\")}-${us[2].padStart(2, \"0\")}`;\n const t = Date.parse(s);\n return Number.isNaN(t) ? \"\" : new Date(t).toISOString().slice(0, 10);\n}\n\nfunction tag(dryRun: boolean, verb: string): string {\n return dryRun ? `[DRY_RUN] would ${verb}` : verb;\n}\n\n// ============================================================================\n// Idempotency\n// ============================================================================\nasync function claimEvent(personId: string, version: string): Promise {\n const res = await sqlite.execute({\n sql: `INSERT OR IGNORE INTO ${DEDUPE_TABLE} (person_id, version) VALUES (?, ?)`,\n args: [personId, version],\n });\n if (Math.random() < 0.02) {\n await sqlite\n .execute(`DELETE FROM ${DEDUPE_TABLE} WHERE processed_at < datetime('now', '-30 days')`)\n .catch(() => {});\n }\n return (res.rowsAffected ?? 0) > 0;\n}\n\nasync function releaseEvent(personId: string, version: string): Promise {\n await sqlite.execute({\n sql: `DELETE FROM ${DEDUPE_TABLE} WHERE person_id = ? AND version = ?`,\n args: [personId, version],\n });\n}\n\n// ============================================================================\n// Airtable REST\n// ============================================================================\ntype AirtableRecord = { id: string; fields: Record };\n\nfunction airtable() {\n const token = Deno.env.get(\"AIRTABLE_TOKEN\");\n if (!token) {\n console.error(\"Missing AIRTABLE_TOKEN\");\n return null;\n }\n return {\n roster: table(token, ROSTER_TABLE, \"Roster\"),\n events: table(token, EVENTS_TABLE, \"Event Records\"),\n };\n}\n\nfunction table(token: string, tableId: string, label: string) {\n const url = `https://api.airtable.com/v0/${BASE_ID}/${encodeURIComponent(tableId)}`;\n const read = { Authorization: `Bearer ${token}` };\n const write = { Authorization: `Bearer ${token}`, \"Content-Type\": \"application/json\" };\n\n async function findByFormula(formula: string, maxRecords = 1): Promise {\n const resp = await fetch(\n `${url}?filterByFormula=${encodeURIComponent(formula)}&maxRecords=${maxRecords}`,\n { headers: read },\n );\n if (!resp.ok) throw new Error(`${label} find failed ${resp.status}: ${await resp.text()}`);\n const data = await resp.json();\n return (data.records ?? []) as AirtableRecord[];\n }\n\n async function find(field: string, value: string, maxRecords = 1): Promise {\n return await findByFormula(`{${field}} = \"${esc(value)}\"`, maxRecords);\n }\n\n async function findOne(field: string, value: string): Promise {\n return (await find(field, value, 1))[0] ?? null;\n }\n\n // typecast is deliberately OFF. With it on, a single-select would silently\n // gain a new choice (\"Team Strength\", \"female\") whenever ZP sent something\n // unexpected. Select values are pre-mapped above; anything unmapped is\n // skipped, so a bad value errors loudly instead of polluting the base.\n async function create(fields: Record): Promise {\n const resp = await fetch(url, {\n method: \"POST\",\n headers: write,\n body: JSON.stringify({ fields, typecast: false }),\n });\n if (!resp.ok) throw new Error(`${label} create failed ${resp.status}: ${await resp.text()}`);\n const data = await resp.json();\n console.log(`Created ${label} record`, data.id);\n return data as AirtableRecord;\n }\n\n async function update(id: string, fields: Record): Promise {\n const resp = await fetch(`${url}/${id}`, {\n method: \"PATCH\",\n headers: write,\n body: JSON.stringify({ fields, typecast: false }),\n });\n if (!resp.ok) throw new Error(`${label} update failed ${resp.status}: ${await resp.text()}`);\n console.log(`Updated ${label} record`, id);\n return await resp.json() as AirtableRecord;\n }\n\n return { find, findByFormula, findOne, create, update };\n}\n\n// Escape for an Airtable formula string literal. Backslash first.\nfunction esc(v: string): string {\n return v.replace(/\\\\/g, \"\\\\\\\\\").replace(/\"/g, '\\\\\"');\n}\n\n// ============================================================================\n// GET / — config dump, no secrets\n// ============================================================================\nfunction configCheck(): Response {\n return new Response(\n JSON.stringify(\n {\n version: \"v3 2026-07-26\",\n dryRun: Deno.env.get(\"DRY_RUN\") === \"true\",\n tokenSet: Boolean(Deno.env.get(\"AIRTABLE_TOKEN\")),\n baseId: BASE_ID,\n rosterTable: ROSTER_TABLE,\n eventsTable: EVENTS_TABLE,\n rosterFields: [R_NAME, R_FIRST, R_LAST, R_ZP_ID, R_STATUS],\n eventFields: [E_TYPE, E_MEMBER, E_SIGNUP_DATE, E_CANCEL_DATE],\n statusMap: {\n active: ZP_ACTIVE,\n prospect: ZP_PROSPECT,\n else: STATUS_ALUMNI,\n BLANK_STATUS_MEANS_ALUMNI,\n holdIsPreserved: true,\n },\n contactFields: FIELD_MAP.map((m) => `${m.zp.join(\"|\")} -> {${m.at}} (${m.policy})`),\n },\n null,\n 2,\n ),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n}\n","deleted","label",[118],"pulls",1,"forks","envVars",{"_141":143,"_144":52},"connections",{"_141":52,"_142":52},"count","unfilledCount",5,"emptyCount",{"_20":117,"_13":118,"_119":120,"_121":-5,"_122":21,"_123":30,"_124":111,"_22":146,"_29":126,"_127":128,"_129":130,"_131":38,"_132":-5,"_147":148,"_92":149},["D",1785086117359],"children",[],[118],["D",1783865378694],["D",1789472446807],{"_11":12,"_90":86},{"_11":12,"_83":84,"_85":86,"_45":46,"_87":88,"_89":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_78":-5,"_79":-5,"_80":-5,"_81":14,"_82":12},"ctx",{"_71":-5,"_113":188,"_189":190,"_191":192,"_193":38,"_194":38,"_195":38,"_196":111,"_197":-5,"_198":-7,"_199":-7,"_200":52,"_201":38,"_202":38,"_203":-5,"_204":38,"_205":38,"_206":38,"_207":-5},"ENV",{"_159":160,"_161":162,"_163":26,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187},"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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Branches1

Branches
1