[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_211":212,"_213":214},"routes/_app.x.$handle.$name",{"_95":94,"_32":44,"_104":85,"_27":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":48,"_119":120,"_121":25,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":48},"version",113,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",true,"deletedHere","path","_check.ts","latestPath","fileId","e2bbd9ba-a56b-11f1-9ad3-1607ee4eb77e","name","fileType","script","content","import { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nconst t = await readFile(\"/main.ts\", import.meta.url);\nconst push = t.slice(t.indexOf(\"export async function pushClasses\"));\n// Both Classes queries must carry the past-date guard.\nconst queries = [...push.matchAll(/`AND\$\\{Push to Trainerize\\}[^`]*`/g)].map(m => m[0]);\nconsole.log(`Classes queries in pushClasses: ${queries.length}`);\nfor (const q of queries) {\n const guarded = /NOT\\(IS_BEFORE\\(\\{Date\\}, '\\$\\{todayLocal\\}'\$\\)/.test(q);\n const label = /Trainerize Appointment ID\\}=''/.test(q) ? \"eligibility (what gets pushed)\" : \"self-heal (what gets repaired)\";\n console.log(` ${guarded ? \"GUARDED\" : \"UNGUARDED\"} ${label}`);\n}\n// todayLocal must be declared before the first use.\nconst decl = push.indexOf(\"const todayLocal\");\nconsole.log(\"\\ntodayLocal declared before both queries:\", decl > -1 && decl < push.indexOf(queries[0]) ? \"yes\" : \"NO\");\n","createdAt",["D",1788201859657],"branchVersion","branchId","e345228c-6abb-433a-a5c4-d19b6d13772c","id","16b4dfda-c5a8-47e2-b75b-3ba596fe8aec","trainerize_airtable_sync",["D",1784768908681],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","Trainerize bookings to airtable attendance records via polling.","imageUrl","44ce8aa9-1ed9-4504-91ee-c68325632994","pinnedFileId","3352f450-8639-11f1-b72c-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f56a8-2712-750d-8a46-0901b512a677","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":48},"branch",{"_13":14,"_32":85,"_42":41,"_86":43,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":44,"_93":94},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","ascendfitness","handle","displayName","Jesse Walker","avatar","https://lh3.googleusercontent.com/a/ACg8ocJfsYea3m83vsjChcIBvF2gnICQEl7Z7-I3gHouqBctmyoQyWve=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_32":44,"_37":207,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":208,"_80":209,"_82":210,"_84":48},"tree",[186,187,188,189,190],"files",[186,187,188,189,190],"counts",{"_174":62,"_175":176,"_177":62,"_178":179,"_180":181},"contents",[126,127,128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":166,"_32":167,"_30":168,"_134":-5,"_40":41,"_39":169,"_136":25,"_37":170,"_13":171,"_33":139,"_35":172,"_24":48,"_141":-5,"_27":173},{"_42":157,"_32":158,"_30":159,"_134":-5,"_40":41,"_39":160,"_136":25,"_37":161,"_13":162,"_33":163,"_35":164,"_24":48,"_141":-5,"_27":165},{"_42":149,"_32":150,"_30":151,"_134":-5,"_40":41,"_39":152,"_136":25,"_37":153,"_13":154,"_33":139,"_35":155,"_24":48,"_141":-5,"_27":156},{"_42":143,"_32":144,"_30":57,"_134":-5,"_40":41,"_39":145,"_136":25,"_37":146,"_13":62,"_33":139,"_35":147,"_24":48,"_141":-5,"_27":148},{"_42":131,"_32":132,"_30":133,"_134":-5,"_40":41,"_39":135,"_136":25,"_37":137,"_13":138,"_33":139,"_35":140,"_24":48,"_141":-5,"_27":142},"d356f2ff-6012-4101-a413-3ddb027f0170","main.ts","039adfee-8633-11f1-a89e-1607ee4eb77e","parentId",110,"latest",["D",1788201806543],66,"http","/**\n * Trainerize ↔ Airtable Booking Sync (Val Town) — HTTP val\n *\n * Routes:\n * / → run the sync\n * /sync → run the sync\n * /populate → auto-fill Roster \"Trainerize User ID\" by name match\n * /ids → list all Trainerize trainer + client IDs\n *\n * Scheduling lives in the separate interval file: cron.ts\n *\n * Env secrets: TZ_GROUP_ID, TZ_API_TOKEN, TZ_BASE_URL (optional), AT_PAT, AT_BASE_ID\n */\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\n// Airtable IDs\nconst STAFF_TABLE = \"tblBfxQjKCie5ch5U\";\nconst CLASSES_TABLE = \"tblmj5ezsqdd6bm4S\";\nconst ROSTER_TABLE = \"tbl9fSFXxA6NXGCZ8\";\nconst ATTENDANCE_TABLE = \"tblEGksWB6sBy5bAB\";\nconst BLOCKS_TABLE = \"tblSnFCbPQFpLI15a\";\nconst WORKOUTS_TABLE = \"tblejHe7t8gOEeuCO\";\n\n// Classes→Workouts link field. Renamed in Airtable from \"Link to Workouts\" to \"Workout\";\n// the kiosk and the Schedule Builder were updated at the time but this val was not, so\n// every sync run 422'd with UNKNOWN_FIELD_NAME and no Trainerize bookings reached Airtable.\n// Kept as a constant so the next rename is a one-line change.\nconst WORKOUT_LINK_FIELD = \"Workout\";\nconst CLASS_TYPES_TABLE = \"tblgB5KsbYEMfGv13\";\n\n// Trainerize rejects in-person appointments without a location (406). The API token has no\n// privilege for /location/getList, and the old code guessed the ID by probing the FIRST\n// staff row's next 30 days — which silently yielded null whenever that coach had no\n// upcoming appointment, breaking every push. The gym's real ID is 624401 (confirmed on 94\n// of 96 appointments across both coaches); override with TZ_LOCATION_ID if it ever changes.\nconst DEFAULT_LOCATION_ID = 624401;\n\nconst TZ_GROUP_ID = Deno.env.get(\"TZ_GROUP_ID\")!;\nconst TZ_API_TOKEN = Deno.env.get(\"TZ_API_TOKEN\")!;\nconst TZ_BASE_URL = Deno.env.get(\"TZ_BASE_URL\") ?? \"https://api.trainerize.com/v03\";\nconst AT_PAT = Deno.env.get(\"AT_PAT\")!;\nconst AT_BASE_ID = Deno.env.get(\"AT_BASE_ID\")!;\n\n// ── HTTP router ──────────────────────────────────────────────────────────────\nexport default async function (req: Request) {\n const url = new URL(req.url);\n if (url.pathname.endsWith(\"/ids\")) return getTrainerizeIDs(req);\n if (url.pathname.endsWith(\"/populate\")) return populateRosterIDs(req);\n if (url.pathname.endsWith(\"/pushClass\")) return pushClasses(req);\n const result = await syncTrainerizeToAirtable();\n return Response.json(result);\n}\n\n// ── Helpers ──────────────────────────────────────────────────────────────────\nfunction getTrainerizeAuth() {\n return `Basic ${btoa(`${TZ_GROUP_ID}:${TZ_API_TOKEN}`)}`;\n}\n\nasync function callTrainerizeAPI(endpoint: string, body?: object) {\n const response = await fetch(`${TZ_BASE_URL}${endpoint}`, {\n method: \"POST\",\n headers: { \"Authorization\": getTrainerizeAuth(), \"Content-Type\": \"application/json\" },\n body: body ? JSON.stringify(body) : undefined,\n });\n if (!response.ok) {\n const detail = await response.text();\n throw new Error(`Trainerize API error: ${response.status} on ${endpoint}: ${detail}`);\n }\n return response.json();\n}\n\nasync function callAirtableAPI(path: string, method: string = \"GET\", body?: object) {\n const response = await fetch(`https://api.airtable.com/v0/${path}`, {\n method,\n headers: { \"Authorization\": `Bearer ${AT_PAT}`, \"Content-Type\": \"application/json\" },\n body: body ? JSON.stringify(body) : undefined,\n });\n if (!response.ok) {\n const error = await response.text();\n throw new Error(`Airtable API error: ${response.status} on ${path}: ${error}`);\n }\n return response.json();\n}\n\n// Airtable wants repeated fields as fields[]=\nfunction fieldsParam(fields: string[], extra?: Record): string {\n const params = new URLSearchParams();\n for (const f of fields) params.append(\"fields[]\", f);\n if (extra) for (const [k, v] of Object.entries(extra)) params.append(k, v);\n return params.toString();\n}\n\n// Paginated read — Airtable returns max 100 records/page. Attendance now has\n// thousands of rows, so every lookup MUST paginate or it silently sees only 100.\nasync function fetchAllRecords(tableId: string, fields: string[], filterFormula?: string) {\n let records: any[] = [];\n let offset: string | undefined;\n do {\n const extra: Record = { pageSize: \"100\" };\n if (offset) extra.offset = offset;\n if (filterFormula) extra.filterByFormula = filterFormula;\n const resp = await callAirtableAPI(`${AT_BASE_ID}/${tableId}?${fieldsParam(fields, extra)}`);\n records = records.concat(resp.records);\n offset = resp.offset;\n } while (offset);\n return records;\n}\n\nfunction formatUTC(date: Date) {\n const pad = (n: number) => String(n).padStart(2, \"0\");\n return `${date.getUTCFullYear()}-${pad(date.getUTCMonth() + 1)}-${pad(date.getUTCDate())} ${pad(date.getUTCHours())}:${pad(date.getUTCMinutes())}:${pad(date.getUTCSeconds())}`;\n}\n\nfunction matchTimeSlot(tzTime: string): string | null {\n const match = tzTime?.match(/(\\d{2}):(\\d{2})/);\n if (!match) return null;\n const key = `${match[1]}:${match[2]}`;\n const timeMap: Record = {\n \"06:00\": \"6:00 AM\",\n \"07:00\": \"7:00 AM\",\n \"08:30\": \"8:30 AM\",\n \"10:00\": \"10:00 AM\",\n \"10:45\": \"10:45 AM\",\n \"17:15\": \"5:15 PM\",\n \"17:45\": \"5:45 PM\",\n \"18:15\": \"6:15 PM\",\n \"18:20\": \"6:20 PM\",\n };\n return timeMap[key] || null;\n}\n\nfunction normalizeName(first: string, last: string): string {\n return `${first || \"\"} ${last || \"\"}`\n .toLowerCase()\n .replace(/['’‘`]/g, \"\") // Trainerize can't store apostrophes; strip so names still match\n .replace(/\\s+/g, \" \")\n .trim();\n}\n\nconst DOW = [\"Sun\", \"Mon\", \"Tues\", \"Wed\", \"Thur\", \"Fri\", \"Sat\"];\n\n// Fetch clients across ALL trainers (getClientList is scoped to one trainer), deduped by id.\nasync function fetchAllTrainerizeClients() {\n const auth = getTrainerizeAuth();\n const tResp = await fetch(`${TZ_BASE_URL}/user/getTrainerList`, {\n method: \"POST\",\n headers: { \"Authorization\": auth, \"Content-Type\": \"application/json\" },\n body: \"{}\",\n });\n const tData = await tResp.json();\n const trainerList = Array.isArray(tData) ? tData : (tData.users || []);\n const byId = new Map();\n for (const t of trainerList) {\n const cResp = await fetch(`${TZ_BASE_URL}/user/getClientList`, {\n method: \"POST\",\n headers: { \"Authorization\": auth, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ userID: t.id, view: \"allActive\", count: 500 }),\n });\n const cData = await cResp.json();\n for (const c of (cData.users || [])) byId.set(String(c.id), c);\n }\n return [...byId.values()];\n}\n\n// ── Main sync ────────────────────────────────────────────────────────────────\nexport async function syncTrainerizeToAirtable() {\n const startTime = new Date();\n const logs: string[] = [];\n\n try {\n logs.push(`[${new Date().toISOString()}] Starting sync...`);\n\n // Active trainers\n const staffResp = await callAirtableAPI(\n `${AT_BASE_ID}/${STAFF_TABLE}?${fieldsParam([\"Name\", \"Trainerize Trainer ID\", \"Active\"])}`,\n );\n const trainers = staffResp.records\n .filter((r: any) => r.fields[\"Active\"] === true && r.fields[\"Trainerize Trainer ID\"])\n .map((r: any) => ({ id: r.id, name: r.fields[\"Name\"], tzID: r.fields[\"Trainerize Trainer ID\"] }));\n logs.push(`Found ${trainers.length} active trainers`);\n\n // Roster (match attendees by Trainerize User ID)\n const rosterRecords = await fetchAllRecords(ROSTER_TABLE, [\"Trainerize User ID\"]);\n const rosterLookup = new Map(\n rosterRecords\n .filter((r: any) => r.fields[\"Trainerize User ID\"])\n .map((r: any) => [String(r.fields[\"Trainerize User ID\"]), r.id]),\n );\n\n // Existing classes (know which already have a workout linked)\n const classesRecords = await fetchAllRecords(CLASSES_TABLE, [\"Trainerize Appointment ID\", WORKOUT_LINK_FIELD]);\n const classesLookup = new Map(\n classesRecords\n .filter((r: any) => r.fields[\"Trainerize Appointment ID\"])\n .map((r: any) => [\n String(r.fields[\"Trainerize Appointment ID\"]),\n { id: r.id, linked: (r.fields[WORKOUT_LINK_FIELD] || []).length > 0 },\n ]),\n );\n\n // Existing attendance keys — filter server-side to only keyed (going-forward)\n // records so historic ZP rows don't crowd out the dedup lookup.\n const attendRecords = await fetchAllRecords(\n ATTENDANCE_TABLE,\n [\"Trainerize Attendee Key\"],\n \"NOT({Trainerize Attendee Key} = '')\",\n );\n const attendanceLookup = new Map(\n attendRecords\n .filter((r: any) => r.fields[\"Trainerize Attendee Key\"])\n .map((r: any) => [r.fields[\"Trainerize Attendee Key\"], r.id]),\n );\n\n // Blocks + workouts index for auto-assigning class → workout (block × day × program)\n const blocksResp = await callAirtableAPI(\n `${AT_BASE_ID}/${BLOCKS_TABLE}?${fieldsParam([\"Start Date\", \"End Date\"])}`,\n );\n const blocks = blocksResp.records\n .map((r: any) => ({ id: r.id, start: r.fields[\"Start Date\"], end: r.fields[\"End Date\"] }))\n .filter((b: any) => b.start && b.end);\n\n const woResp = await callAirtableAPI(\n `${AT_BASE_ID}/${WORKOUTS_TABLE}?${fieldsParam([\"Block\", \"Day\", \"Program\"])}`,\n );\n const workoutMap = new Map();\n for (const r of woResp.records) {\n const blockId = (r.fields[\"Block\"] || [])[0];\n const day = r.fields[\"Day\"];\n const program = r.fields[\"Program\"];\n if (blockId && day && program) workoutMap.set(`${blockId}|${day}|${program}`, r.id);\n }\n\n let classesCreated = 0;\n let attendanceCreated = 0;\n let workoutsLinked = 0;\n\n const today = new Date();\n today.setUTCHours(0, 0, 0, 0);\n const thirtyDaysOut = new Date(today);\n thirtyDaysOut.setUTCDate(thirtyDaysOut.getUTCDate() + 30);\n\n for (const trainer of trainers) {\n logs.push(`Polling ${trainer.name}...`);\n const aptResp = await callTrainerizeAPI(\"/appointment/getList\", {\n userID: parseInt(trainer.tzID),\n startDate: formatUTC(today),\n endDate: formatUTC(thirtyDaysOut),\n });\n const groupApts = (aptResp.appointments || []).filter(\n (a: any) => a.appointmentType?.isGroupAppointment === true,\n );\n logs.push(` Found ${groupApts.length} group classes`);\n\n for (const apt of groupApts) {\n const tzClassID = String(apt.id);\n // startDateTime = local wall-clock time (matches gym schedule); startDate is UTC.\n const classDate = apt.startDateTime?.split(\" \")[0];\n const timeSlot = matchTimeSlot(apt.startDateTime);\n if (!classDate || !timeSlot) {\n logs.push(` Skipping class ${tzClassID}: no matching time slot for \"${apt.startDateTime}\"`);\n continue;\n }\n\n let classRecord = classesLookup.get(tzClassID);\n if (!classRecord) {\n const createResp = await callAirtableAPI(`${AT_BASE_ID}/${CLASSES_TABLE}`, \"POST\", {\n typecast: true, // auto-create Time options for new slots (e.g. 8:30 AM, 6:15 PM)\n records: [{\n fields: {\n Date: classDate,\n Time: timeSlot,\n \"Trainerize Appointment ID\": tzClassID,\n \"Trainerize Class Type ID\": String(apt.appointmentType.appointmentTypeID),\n Coach: [trainer.id],\n \"Session Notes\": apt.notes || \"\",\n },\n }],\n });\n classRecord = { id: createResp.records[0].id, linked: false };\n classesLookup.set(tzClassID, classRecord);\n classesCreated++;\n logs.push(` Created class: ${trainer.name} on ${classDate} at ${timeSlot}`);\n }\n\n // Auto-assign workout by block × day-of-week × program (if not already linked)\n if (!classRecord.linked) {\n const dow = DOW[new Date(classDate + \"T00:00:00Z\").getUTCDay()];\n const program = /youth/i.test(apt.appointmentType?.name || \"\") ? \"Youth\" : \"Team\";\n const block = blocks.find((b: any) => b.start <= classDate && classDate <= b.end);\n if (!block) {\n logs.push(` No block covers ${classDate}; workout left unlinked`);\n } else {\n const workoutId = workoutMap.get(`${block.id}|${dow}|${program}`);\n if (workoutId) {\n await callAirtableAPI(`${AT_BASE_ID}/${CLASSES_TABLE}`, \"PATCH\", {\n records: [{ id: classRecord.id, fields: { [WORKOUT_LINK_FIELD]: [workoutId] } }],\n });\n classRecord.linked = true;\n workoutsLinked++;\n } else {\n logs.push(` No workout for ${dow}/${program} in block; left unlinked`);\n }\n }\n }\n\n // Attendance\n for (const attendee of apt.attendents || []) {\n if (attendee.type !== \"client\") continue;\n const rosterID = rosterLookup.get(String(attendee.id));\n if (!rosterID) {\n logs.push(` Warning: Client ${attendee.firstName} ${attendee.lastName} (${attendee.id}) not in Roster`);\n continue;\n }\n const tzAttendeeKey = `${tzClassID}_${attendee.id}`;\n if (!attendanceLookup.has(tzAttendeeKey)) {\n const createResp = await callAirtableAPI(`${AT_BASE_ID}/${ATTENDANCE_TABLE}`, \"POST\", {\n records: [{\n fields: {\n Class: [classRecord.id],\n Client: [rosterID],\n \"Attendance Type\": \"Reserved\",\n \"Source\": \"Trainerize-Kiosk\",\n \"Trainerize Attendee Key\": tzAttendeeKey,\n },\n }],\n });\n attendanceLookup.set(tzAttendeeKey, createResp.records[0].id);\n attendanceCreated++;\n logs.push(` New booking: ${attendee.firstName} ${attendee.lastName}`);\n }\n }\n }\n }\n\n const duration = Math.round((Date.now() - startTime.getTime()) / 1000);\n logs.push(`✓ Sync complete (${duration}s)`);\n logs.push(` Classes created: ${classesCreated}`);\n logs.push(` Workouts linked: ${workoutsLinked}`);\n logs.push(` Attendance created: ${attendanceCreated}`);\n\n await blob.set(\"sync_logs\", JSON.stringify(logs, null, 2));\n return { success: true, logs };\n } catch (error) {\n const errorMsg = error instanceof Error ? error.message : String(error);\n logs.push(`✗ Sync failed: ${errorMsg}`);\n await blob.set(\"sync_logs\", JSON.stringify(logs, null, 2));\n return { success: false, logs, error: errorMsg };\n }\n}\n\n// ── Push: Airtable class → Trainerize appointment ───────────────────────────\nconst GYM_TZ = \"America/New_York\";\n\nfunction tzOffsetMinutes(utcMs: number, tz: string): number {\n const dtf = new Intl.DateTimeFormat(\"en-US\", {\n timeZone: tz, hour12: false,\n year: \"numeric\", month: \"2-digit\", day: \"2-digit\",\n hour: \"2-digit\", minute: \"2-digit\", second: \"2-digit\",\n });\n const m: any = {};\n for (const p of dtf.formatToParts(new Date(utcMs))) m[p.type] = p.value;\n const asIfUTC = Date.UTC(+m.year, +m.month - 1, +m.day, +m.hour, +m.minute, +m.second);\n return (asIfUTC - utcMs) / 60000;\n}\n\n// Convert a gym-local wall-clock time to the true UTC instant (DST-aware).\nfunction localToUTC(y: number, mo: number, d: number, h: number, mi: number): Date {\n const naive = Date.UTC(y, mo - 1, d, h, mi);\n let utc = naive - tzOffsetMinutes(naive, GYM_TZ) * 60000;\n const off2 = tzOffsetMinutes(utc, GYM_TZ);\n utc = naive - off2 * 60000; // re-resolve once for DST-boundary safety\n return new Date(utc);\n}\n\n// Parse an Airtable Time option like \"6:20 PM\" into 24h parts.\nfunction parseTimeSlot(t: string): { h: number; m: number } | null {\n const mt = t?.match(/(\\d{1,2}):(\\d{2})\\s*(AM|PM)/i);\n if (!mt) return null;\n let h = parseInt(mt[1]);\n const m = parseInt(mt[2]);\n const ap = mt[3].toUpperCase();\n if (ap === \"PM\" && h !== 12) h += 12;\n if (ap === \"AM\" && h === 12) h = 0;\n return { h, m };\n}\n\n/**\n * Push Airtable classes (flagged \"Push to Trainerize\", not yet pushed) into Trainerize.\n * Defaults to DRY RUN — returns the computed payloads without writing. Add ?commit=1 to push.\n */\nexport async function pushClasses(req: Request) {\n const url = new URL(req.url);\n const commit = url.searchParams.get(\"commit\") === \"1\";\n const report: any = { dryRun: !commit, appointmentTypes: [], pushed: 0, skipped: [], results: [] };\n\n try {\n // Staff record id -> Trainerize trainer id\n const staff = await fetchAllRecords(STAFF_TABLE, [\"Name\", \"Trainerize Trainer ID\"]);\n const staffMap = new Map();\n for (const s of staff) {\n if (s.fields[\"Trainerize Trainer ID\"]) {\n staffMap.set(s.id, { tzId: String(s.fields[\"Trainerize Trainer ID\"]), name: s.fields[\"Name\"] });\n }\n }\n\n // ── Class Types table ────────────────────────────────────────────────────────\n // The Schedule Builder's Class Types table is the source of truth for which types\n // exist, which Trainerize appointment type they map to, and — critically — whether\n // they publish at all. This replaces the old regex name-matching (/youth/, /team/…),\n // which silently produced a null type ID for anything it didn't recognise.\n const classTypeRecs = await fetchAllRecords(CLASS_TYPES_TABLE, [\n \"Name\",\n \"Key\",\n \"Show in Trainerize\",\n \"Trainerize Class Type ID\",\n ]);\n const norm = (s: unknown) => String(s ?? \"\").toLowerCase().replace(/[^a-z0-9]/g, \"\");\n const classTypes = classTypeRecs.map((r: any) => ({\n name: String(r.fields[\"Name\"] || \"\"),\n key: norm(r.fields[\"Key\"] || r.fields[\"Name\"]),\n show: r.fields[\"Show in Trainerize\"] === true,\n tzId: r.fields[\"Trainerize Class Type ID\"] ? String(r.fields[\"Trainerize Class Type ID\"]) : null,\n })).filter((t: any) => t.name);\n const lookupClassType = (v: unknown) => {\n const want = norm(v);\n return classTypes.find((t: any) => t.key === want) ||\n classTypes.find((t: any) => norm(t.name) === want) || null;\n };\n report.classTypes = classTypes;\n\n // Appointment types (id -> duration; program -> id)\n const typesResp = await callTrainerizeAPI(\"/appointment/getAppointmentTypeList\", {});\n const rawTypes = typesResp.appointmentTypes || typesResp.types ||\n (Array.isArray(typesResp) ? typesResp : []);\n // Indexed only for its duration default now — the name matching that used to live here\n // has moved to the Class Types table, which maps each type to its ID explicitly.\n const typeById = new Map();\n for (const t of rawTypes) typeById.set(String(t.appointmentTypeID), t);\n // Last-resort default for a class whose type isn't in the Class Types table. The\n // Trainerize API returns a stale duplicate \"Team Training\" (8136329) alongside the live\n // one, so this is pinned rather than discovered by name.\n const teamTypeId = \"11197128\";\n report.appointmentTypes = rawTypes.map((t: any) => ({\n id: t.appointmentTypeID, name: t.name, duration: t.duration, isGroup: t.isGroupAppointment,\n }));\n\n // Location — required by Trainerize for in-person appointments, and /location/getList\n // is 403 for this token. Prefer the configured value; only fall back to probing, and\n // when we do, sweep EVERY trainer across a wide window instead of one coach's next 30\n // days (that narrow probe returned null and 406'd every push).\n const envLocation = parseInt(Deno.env.get(\"TZ_LOCATION_ID\") || \"\");\n let defaultLocationId: number | null = Number.isFinite(envLocation) ? envLocation : DEFAULT_LOCATION_ID;\n if (!defaultLocationId) {\n const now = new Date();\n const from = new Date(now.getTime() - 60 * 864e5);\n const to = new Date(now.getTime() + 60 * 864e5);\n for (const t of staffMap.values()) {\n const probe = await callTrainerizeAPI(\"/appointment/getList\", {\n userID: parseInt(t.tzId),\n startDate: formatUTC(from),\n endDate: formatUTC(to),\n });\n for (const a of (probe.appointments || [])) {\n if (a.locationID) { defaultLocationId = a.locationID; break; }\n }\n if (defaultLocationId) break;\n }\n }\n report.locationID = defaultLocationId;\n\n // ── Self-heal orphaned appointment IDs ──────────────────────────────────────────\n // An appointment deleted inside Trainerize does not propagate back to Airtable, so the\n // class keeps an ID pointing at nothing. Because the push filter treats \"has an ID\" as\n // \"already pushed\", such a class is excluded forever and silently never republishes —\n // ticking the checkbox does nothing, which is exactly how nine Aug 3/5/7 classes went\n // missing. Verify the ID on any future class still flagged to push and clear it if\n // Trainerize 404s, so the class becomes eligible again in this same run.\n // Scoped to future dates on purpose: we must never recreate a past class.\n const todayLocal = new Intl.DateTimeFormat(\"en-CA\", { timeZone: GYM_TZ }).format(new Date());\n const maybeStale = await fetchAllRecords(\n CLASSES_TABLE,\n [\"Date\", \"Time\", \"Trainerize Appointment ID\"],\n `AND({Push to Trainerize}=1, NOT({Trainerize Appointment ID}=''), NOT(IS_BEFORE({Date}, '${todayLocal}')))`,\n );\n report.repaired = [];\n for (const s of maybeStale) {\n const apptId = String(s.fields[\"Trainerize Appointment ID\"]);\n const probe = await fetch(`${TZ_BASE_URL}/appointment/get`, {\n method: \"POST\",\n headers: { \"Authorization\": getTrainerizeAuth(), \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ id: parseInt(apptId) }),\n });\n const gone = probe.status === 404;\n await probe.body?.cancel();\n if (!gone) continue;\n if (commit) {\n await callAirtableAPI(`${AT_BASE_ID}/${CLASSES_TABLE}`, \"PATCH\", {\n records: [{ id: s.id, fields: { \"Trainerize Appointment ID\": \"\" } }],\n });\n }\n report.repaired.push({ classId: s.id, local: `${s.fields[\"Date\"]} ${s.fields[\"Time\"]}`, deadId: apptId });\n }\n\n // Classes flagged to push and not yet in Trainerize.\n // The date guard is load-bearing: publishing a class that already happened creates a\n // phantom appointment nobody can attend. Backfilling attendance means old Class rows\n // get touched, and any of them still carrying a ticked Push to Trainerize would\n // otherwise be picked up here and published weeks late.\n const classes = await fetchAllRecords(\n CLASSES_TABLE,\n [\"Date\", \"Time\", \"Coach\", \"Session Notes\", \"Trainerize Class Type ID\", \"Type\", \"Duration\", \"Program (from Link to Workouts)\"],\n `AND({Push to Trainerize}=1, {Trainerize Appointment ID}='', NOT(IS_BEFORE({Date}, '${todayLocal}')))`,\n );\n\n for (const c of classes) {\n const f = c.fields;\n const coach = (f[\"Coach\"] || [])[0] ? staffMap.get((f[\"Coach\"] || [])[0]) : null;\n const time = parseTimeSlot(f[\"Time\"]);\n // Prefer the explicit Type field (set by the Schedule Builder); fall back to the workout-derived program.\n const typeName = f[\"Type\"] || (f[\"Program (from Link to Workouts)\"] || [])[0] || \"Team\";\n const ct = lookupClassType(typeName);\n // A type marked \"Show in Trainerize\" = false never publishes, no matter what the\n // class's own Push to Trainerize checkbox says. This is the hard gate: it means a\n // class can't leak into Trainerize by someone ticking the box in Airtable by hand.\n if (ct && !ct.show) {\n report.skipped.push({\n classId: c.id,\n local: `${f[\"Date\"]} ${f[\"Time\"]}`,\n reason: `class type \"${ct.name}\" is not shown in Trainerize`,\n });\n // Un-queue it so it stops being re-examined on every run.\n if (commit) {\n await callAirtableAPI(`${AT_BASE_ID}/${CLASSES_TABLE}`, \"PATCH\", {\n records: [{ id: c.id, fields: { \"Push to Trainerize\": false } }],\n });\n }\n continue;\n }\n // Type ID: the class's own override wins, then the Class Types row, then the\n // pinned Team default for anything unrecognised.\n const typeId = f[\"Trainerize Class Type ID\"] || (ct && ct.tzId) || teamTypeId;\n // Use the class's own Duration when set, else the appointment type's default.\n const dur = f[\"Duration\"] || (typeId && typeById.get(String(typeId)) ? typeById.get(String(typeId)).duration : 45);\n\n // A null location would 406 at Trainerize, so treat it as a missing field and say so\n // rather than firing a request we know will be rejected.\n if (!coach || !time || !f[\"Date\"] || !typeId || !defaultLocationId) {\n const missing = [\n !coach && \"coach (or their Trainerize Trainer ID)\",\n !time && \"time\",\n !f[\"Date\"] && \"date\",\n !typeId && \"class type\",\n !defaultLocationId && \"location\",\n ].filter(Boolean).join(\", \");\n report.skipped.push({ classId: c.id, local: `${f[\"Date\"]} ${f[\"Time\"]}`, reason: `missing ${missing}` });\n continue;\n }\n\n const [y, mo, d] = f[\"Date\"].split(\"-\").map((x: string) => parseInt(x));\n const startUTC = localToUTC(y, mo, d, time.h, time.m);\n const endUTC = new Date(startUTC.getTime() + dur * 60000);\n const payload = {\n userID: parseInt(coach.tzId),\n startDate: formatUTC(startUTC),\n endDate: formatUTC(endUTC),\n appointmentTypeID: parseInt(String(typeId)),\n locationID: defaultLocationId,\n notes: f[\"Session Notes\"] || \"\",\n };\n const row: any = { classId: c.id, coach: coach.name, local: `${f[\"Date\"]} ${f[\"Time\"]}`, payload };\n\n if (commit) {\n // Isolate each class: one rejection used to throw out of the whole loop and abort\n // the batch, so a single bad record blocked every other class from being pushed.\n try {\n const resp = await callTrainerizeAPI(\"/appointment/add\", payload);\n const apptId = String(resp.id);\n await callAirtableAPI(`${AT_BASE_ID}/${CLASSES_TABLE}`, \"PATCH\", {\n records: [{ id: c.id, fields: { \"Trainerize Appointment ID\": apptId, \"Push to Trainerize\": false } }],\n });\n report.pushed++;\n row.trainerizeId = apptId;\n } catch (err) {\n row.error = err instanceof Error ? err.message : String(err);\n report.failed = (report.failed ?? 0) + 1;\n }\n }\n report.results.push(row);\n }\n\n return Response.json({ success: true, ...report });\n } catch (error) {\n return Response.json({ success: false, error: error instanceof Error ? error.message : String(error), ...report });\n }\n}\n\n// ── Utility: list Trainerize IDs ─────────────────────────────────────────────\nexport async function getTrainerizeIDs(_req: Request) {\n try {\n const auth = getTrainerizeAuth();\n const trainersResp = await fetch(`${TZ_BASE_URL}/user/getTrainerList`, {\n method: \"POST\",\n headers: { \"Authorization\": auth, \"Content-Type\": \"application/json\" },\n body: \"{}\",\n });\n const trainers = await trainersResp.json();\n const clients = await fetchAllTrainerizeClients();\n return Response.json({\n trainers: (Array.isArray(trainers) ? trainers : trainers.users || []).map((t: any) => ({\n id: t.id,\n name: `${t.firstName} ${t.lastName}`,\n })),\n clients: clients.map((c: any) => ({ id: c.id, name: `${c.firstName} ${c.lastName}` })),\n });\n } catch (error) {\n return Response.json({ error: error instanceof Error ? error.message : String(error) });\n }\n}\n\n// ── Utility: auto-populate Roster Trainerize User IDs by name ────────────────\nexport async function populateRosterIDs(_req: Request) {\n const report = {\n matched: 0,\n updated: 0,\n alreadySet: 0,\n unmatchedTrainerize: [] as string[],\n unmatchedRoster: [] as string[],\n };\n try {\n const allClients = await fetchAllTrainerizeClients();\n const tzClients = allClients.map((c: any) => ({\n id: String(c.id),\n key: normalizeName(c.firstName, c.lastName),\n name: `${c.firstName} ${c.lastName}`,\n }));\n\n let rosterRecords: any[] = [];\n let offset: string | undefined;\n do {\n const qs = fieldsParam(\n [\"First Name\", \"Last Name\", \"Name\", \"Trainerize User ID\"],\n offset ? { offset } : undefined,\n );\n const resp = await callAirtableAPI(`${AT_BASE_ID}/${ROSTER_TABLE}?${qs}`);\n rosterRecords = rosterRecords.concat(resp.records);\n offset = resp.offset;\n } while (offset);\n\n const tzByName = new Map(tzClients.map((c: any) => [c.key, c]));\n const updates: any[] = [];\n const matchedTzKeys = new Set();\n\n for (const rec of rosterRecords) {\n const f = rec.fields;\n let key = normalizeName(f[\"First Name\"], f[\"Last Name\"]);\n if (!key) key = (f[\"Name\"] || \"\").toLowerCase().replace(/['’‘`]/g, \"\").replace(/\\s+/g, \" \").trim();\n const tzMatch = tzByName.get(key);\n if (!tzMatch) {\n report.unmatchedRoster.push(f[\"Name\"] || key || rec.id);\n continue;\n }\n report.matched++;\n matchedTzKeys.add(key);\n if (String(f[\"Trainerize User ID\"]) === tzMatch.id) {\n report.alreadySet++;\n continue;\n }\n updates.push({ id: rec.id, fields: { \"Trainerize User ID\": tzMatch.id } });\n }\n\n for (const c of tzClients) {\n if (!matchedTzKeys.has(c.key)) report.unmatchedTrainerize.push(c.name);\n }\n\n for (let i = 0; i < updates.length; i += 10) {\n const batch = updates.slice(i, i + 10);\n await callAirtableAPI(`${AT_BASE_ID}/${ROSTER_TABLE}`, \"PATCH\", { records: batch });\n report.updated += batch.length;\n }\n\n return Response.json({ success: true, ...report });\n } catch (error) {\n return Response.json({\n success: false,\n error: error instanceof Error ? error.message : String(error),\n ...report,\n });\n }\n}\n","label",[132],"aee3fba3-6fd0-4b4f-8acc-bbbec1e3d8e8","logs.ts",20,["D",1784771565741],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nexport default async function () {\n const logs = await blob.get(\"sync_logs\");\n return Response.json({ logs });\n}\n",[144],"f6216639-113f-4bbc-a2e5-d72fe41f7ef0","debug_schema.ts","b3817192-8639-11f1-a152-1607ee4eb77e",24,["D",1784771792714],2,"const AT_PAT = Deno.env.get(\"AT_PAT\")!;\nconst AT_BASE_ID = Deno.env.get(\"AT_BASE_ID\")!;\n\nconst TABLES = [\n { name: \"Staff\", id: \"tblBfxQjKCie5ch5U\" },\n { name: \"Classes\", id: \"tblmj5ezsqdd6bm4S\" },\n { name: \"Roster\", id: \"tbl9fSFXxA6NXGCZ8\" },\n { name: \"Attendance\", id: \"tblEGksWB6sBy5bAB\" },\n];\n\nexport default async function () {\n const results: any = {};\n for (const t of TABLES) {\n const resp = await fetch(\n `https://api.airtable.com/v0/${AT_BASE_ID}/${t.id}?maxRecords=3`,\n { headers: { \"Authorization\": `Bearer ${AT_PAT}` } },\n );\n const data = await resp.json();\n if (!resp.ok) {\n results[t.name] = { error: data };\n } else {\n results[t.name] = {\n fieldNames: Object.keys(data.records?.[0]?.fields || {}),\n sampleRecords: data.records,\n };\n }\n }\n return Response.json(results);\n}\n",[150],"2f778350-de0f-4a63-b6b1-0d602199db91","cron.ts","b5012632-8640-11f1-bcfe-1607ee4eb77e",102,["D",1785765484323],3,"interval","/**\n * Scheduled runner — every 15 minutes.\n * 1) Pull Trainerize bookings → Airtable (inbound sync + workout auto-assign)\n * 2) Push Airtable classes flagged \"Push to Trainerize\" → Trainerize (outbound)\n */\nimport { pushClasses, syncTrainerizeToAirtable } from \"./main.ts\";\n\nexport default async function () {\n const ts = new Date().toISOString();\n\n const sync = await syncTrainerizeToAirtable();\n console.log(`[${ts}] sync:`, sync.success ? (sync.logs?.slice(-3) ?? []) : `FAILED — ${sync.error}`);\n\n const pushResp = await pushClasses(new Request(\"https://cron.local/pushClass?commit=1\"));\n const push = await pushResp.json();\n // Per-class failures no longer abort the batch, so success:true can still hide problems —\n // log the failed and skipped counts (and their reasons) rather than just the pushed count.\n if (!push.success) {\n console.log(`[${ts}] push: FAILED — ${push.error}`);\n } else {\n console.log(`[${ts}] push: pushed ${push.pushed}, repaired ${push.repaired?.length ?? 0}, failed ${push.failed ?? 0}, skipped ${push.skipped?.length ?? 0} (location ${push.locationID})`);\n for (const r of (push.repaired ?? [])) console.log(` cleared dead appointment ${r.deadId} on ${r.local} — will republish`);\n for (const r of (push.results ?? [])) if (r.error) console.log(` push error ${r.local}: ${r.error}`);\n for (const s of (push.skipped ?? [])) console.log(` skipped ${s.local}: ${s.reason}`);\n }\n\n return { syncOk: sync.success, pushed: push.pushed ?? 0 };\n}\n",[158],"22746dc6-a8a2-4f6b-9ec8-61721c6f72ce","builder_api.ts","3a6524f4-8691-11f1-bc1d-1607ee4eb77e",78,["D",1784913690952],16,"/**\n * Schedule Builder API (Val Town) — HTTP val\n *\n * Front door for the Ascend Schedule Builder HTML tool. Reads reference data\n * and writes Classes / Attendance into the \"Team Training\" Airtable base.\n * Trainerize propagation is handled by the existing sync in main.ts:\n * - createClass sets \"Push to Trainerize\" so /pushClass adds the appointment\n * - addParticipants writes \"Reserved\" Attendance; the Trainerize booking\n * follows once the class has a Trainerize Appointment ID (future step).\n *\n * Routes (all CORS-enabled):\n * GET / → health + route list\n * GET /blocks → [{id,num,name,theme,start,end}]\n * GET /staff → active coaches [{id,name}]\n * GET /clients?q= → roster search [{id,name,status}] (max 30)\n * GET /classes?from=&to= → classes in date range [{id,date,time,coachId,capacity,program,workoutId}]\n * POST /createClass → body {classes:[{date,time,coachRecId,program,capacity,notes?}], pushToTrainerize?, dryRun?}\n * POST /addParticipants → body {classRecordIds:[], clientRecordIds:[], dryRun?}\n *\n * Reuses env secrets from this val: AT_PAT, AT_BASE_ID.\n */\n\nimport { serveFile } from \"https://esm.town/v/std/utils/index.ts\";\n\nconst AT_PAT = Deno.env.get(\"AT_PAT\")!;\nconst AT_BASE_ID = Deno.env.get(\"AT_BASE_ID\")!;\n// Serve a static HTML page stored in this val (behind Basic Auth).\nasync function servePage(name: string) {\n return await serveFile(`/${name}`, import.meta.url);\n}\n\n// Airtable table IDs (Team Training base)\nconst STAFF_TABLE = \"tblBfxQjKCie5ch5U\";\nconst CLASSES_TABLE = \"tblmj5ezsqdd6bm4S\";\nconst ROSTER_TABLE = \"tbl9fSFXxA6NXGCZ8\";\nconst ATTENDANCE_TABLE = \"tblEGksWB6sBy5bAB\";\nconst BLOCKS_TABLE = \"tblSnFCbPQFpLI15a\";\nconst WORKOUTS_TABLE = \"tblejHe7t8gOEeuCO\";\n\nconst DOW = [\"Sun\", \"Mon\", \"Tues\", \"Wed\", \"Thur\", \"Fri\", \"Sat\"];\n// Builder program key → Airtable Workouts.Program value (null = no workout link, e.g. Open Gym)\nconst PROGRAM_MAP: Record = {\n team: \"Team\",\n youth: \"Youth\",\n opengym: null,\n internal: null,\n};\n// Written directly to the Classes \"Type\" field so the program is correct immediately\n// (the \"Program (from Link to Workouts)\" lookup lags right after a record is created).\nconst TYPE_LABEL: Record = {\n team: \"Team\",\n youth: \"Youth\",\n opengym: \"Open Gym\",\n internal: \"Internal\",\n};\n\n// ── CORS + JSON helpers ──────────────────────────────────────────────────────\nconst CORS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n};\n\n// ── HTTP Basic Auth (gates everything — the browser prompts for user/pass on navigation,\n// nothing renders until valid credentials are entered, and the PAT never leaves the server) ──\nconst BASIC_USER = Deno.env.get(\"BASIC_USER\") || \"\";\nconst BASIC_PASS = Deno.env.get(\"BASIC_PASS\") || \"\";\nfunction checkBasicAuth(req: Request): boolean {\n const h = req.headers.get(\"Authorization\") || \"\";\n if (!h.startsWith(\"Basic \")) return false;\n try {\n const dec = atob(h.slice(6));\n const i = dec.indexOf(\":\");\n const u = dec.slice(0, i), p = dec.slice(i + 1);\n return !!BASIC_USER && u === BASIC_USER && p === BASIC_PASS;\n } catch { return false; }\n}\nfunction authChallenge(): Response {\n return new Response(\"Authentication required\", {\n status: 401,\n headers: { \"WWW-Authenticate\": 'Basic realm=\"Ascend\", charset=\"UTF-8\"' },\n });\n}\n\n// ── Generic authenticated Airtable proxy (used by the kiosk; PAT stays server-side) ──\nasync function handleAt(req: Request) {\n const body = await req.json().catch(() => ({}));\n const op = body.op;\n const auth = { \"Authorization\": `Bearer ${AT_PAT}` };\n const pass = async (r: Response) => new Response(await r.text(), { status: r.status, headers: { \"Content-Type\": \"application/json\", ...CORS } });\n try {\n if (op === \"schema\") {\n return pass(await fetch(`https://api.airtable.com/v0/meta/bases/${AT_BASE_ID}/tables`, { headers: auth }));\n }\n const table = body.table;\n if (!table) return json({ success: false, error: \"table required\" }, 400);\n const enc = encodeURIComponent(table);\n if (op === \"list\") {\n let url = `https://api.airtable.com/v0/${AT_BASE_ID}/${enc}?pageSize=100`;\n if (body.formula) url += `&filterByFormula=${encodeURIComponent(body.formula)}`;\n if (body.sort) url += `&sort[0][field]=${encodeURIComponent(body.sort)}&sort[0][direction]=asc`;\n let all: any[] = [], offset: string | undefined;\n do {\n const r = await fetch(url + (offset ? `&offset=${offset}` : \"\"), { headers: auth });\n if (!r.ok) return json({ success: false, error: `Airtable ${r.status}` }, r.status);\n const d = await r.json();\n all = all.concat(d.records);\n offset = d.offset;\n if (body.max && all.length >= body.max) break;\n } while (offset);\n return json({ records: all });\n }\n if (op === \"update\") {\n return pass(await fetch(`https://api.airtable.com/v0/${AT_BASE_ID}/${enc}/${body.id}`, { method: \"PATCH\", headers: { ...auth, \"Content-Type\": \"application/json\" }, body: JSON.stringify({ fields: body.fields, typecast: true }) }));\n }\n if (op === \"create\") {\n return pass(await fetch(`https://api.airtable.com/v0/${AT_BASE_ID}/${enc}`, { method: \"POST\", headers: { ...auth, \"Content-Type\": \"application/json\" }, body: JSON.stringify({ records: [{ fields: body.fields }], typecast: true }) }));\n }\n if (op === \"delete\") {\n return pass(await fetch(`https://api.airtable.com/v0/${AT_BASE_ID}/${enc}/${body.id}`, { method: \"DELETE\", headers: auth }));\n }\n return json({ success: false, error: \"unknown op\" }, 400);\n } catch (e) {\n return json({ success: false, error: e instanceof Error ? e.message : String(e) }, 500);\n }\n}\nfunction json(data: unknown, status = 200) {\n return new Response(JSON.stringify(data), {\n status,\n headers: { \"Content-Type\": \"application/json\", ...CORS },\n });\n}\n\n// ── Airtable helpers ─────────────────────────────────────────────────────────\nasync function callAirtableAPI(path: string, method = \"GET\", body?: object) {\n const resp = await fetch(`https://api.airtable.com/v0/${path}`, {\n method,\n headers: { \"Authorization\": `Bearer ${AT_PAT}`, \"Content-Type\": \"application/json\" },\n body: body ? JSON.stringify(body) : undefined,\n });\n if (!resp.ok) {\n const err = await resp.text();\n throw new Error(`Airtable ${resp.status} on ${path}: ${err}`);\n }\n return resp.json();\n}\nfunction fieldsParam(fields: string[], extra?: Record): string {\n const p = new URLSearchParams();\n for (const f of fields) p.append(\"fields[]\", f);\n if (extra) for (const [k, v] of Object.entries(extra)) p.append(k, v);\n return p.toString();\n}\nasync function fetchAllRecords(tableId: string, fields: string[], filterFormula?: string) {\n let records: any[] = [];\n let offset: string | undefined;\n do {\n const extra: Record = { pageSize: \"100\" };\n if (offset) extra.offset = offset;\n if (filterFormula) extra.filterByFormula = filterFormula;\n const resp = await callAirtableAPI(`${AT_BASE_ID}/${tableId}?${fieldsParam(fields, extra)}`);\n records = records.concat(resp.records);\n offset = resp.offset;\n } while (offset);\n return records;\n}\n\n// \"Block 6\" / \"Block 11 - Olympics\" → 6 / 11\nfunction blockNum(name: string): number | null {\n const m = (name || \"\").match(/block\\s*(\\d+)/i);\n return m ? parseInt(m[1]) : null;\n}\n// 375 (minutes) → \"6:15 AM\"\nfunction minToTimeSlot(min: number): string {\n const h = Math.floor(min / 60), m = min % 60;\n const ap = h >= 12 ? \"PM\" : \"AM\", hr = (h % 12) || 12;\n return `${hr}:${String(m).padStart(2, \"0\")} ${ap}`;\n}\n\n// Build a block-lookup + workout index (block×day×program → workout id)\nasync function loadWorkoutIndex() {\n const blocksResp = await callAirtableAPI(\n `${AT_BASE_ID}/${BLOCKS_TABLE}?${fieldsParam([\"Name\", \"Start Date\", \"End Date\"])}`,\n );\n const blocks = blocksResp.records\n .map((r: any) => ({ id: r.id, start: r.fields[\"Start Date\"], end: r.fields[\"End Date\"] }))\n .filter((b: any) => b.start && b.end);\n const woResp = await callAirtableAPI(\n `${AT_BASE_ID}/${WORKOUTS_TABLE}?${fieldsParam([\"Block\", \"Day\", \"Program\"])}`,\n );\n const workoutMap = new Map();\n for (const r of woResp.records) {\n const blockId = (r.fields[\"Block\"] || [])[0];\n const day = r.fields[\"Day\"];\n const program = r.fields[\"Program\"];\n if (blockId && day && program) workoutMap.set(`${blockId}|${day}|${program}`, r.id);\n }\n return { blocks, workoutMap };\n}\nfunction findWorkout(date: string, programKey: string, idx: { blocks: any[]; workoutMap: Map }): string | null {\n const atProgram = PROGRAM_MAP[programKey];\n if (!atProgram) return null; // Open Gym / Internal — no workout\n const dow = DOW[new Date(date + \"T00:00:00Z\").getUTCDay()];\n const block = idx.blocks.find((b) => b.start <= date && date <= b.end);\n if (!block) return null;\n return idx.workoutMap.get(`${block.id}|${dow}|${atProgram}`) || null;\n}\n\n// ── Routes ───────────────────────────────────────────────────────────────────\nexport default async function (req: Request) {\n if (req.method === \"OPTIONS\") return new Response(null, { status: 204, headers: CORS });\n // Gate EVERYTHING (including the served HTML pages) behind HTTP Basic Auth.\n if (!checkBasicAuth(req)) return authChallenge();\n const url = new URL(req.url);\n const p = url.pathname;\n try {\n // Served UIs (same origin → the /at, /createClass etc. calls carry the Basic creds automatically)\n if (p === \"/\" || p === \"\" || p.endsWith(\"/kiosk\")) return await servePage(\"kiosk.html\");\n if (p.endsWith(\"/builder\")) return await servePage(\"builder.html\");\n if (p.endsWith(\"/Ascend_logo.png\")) return await servePage(\"Ascend_logo.png\");\n // Data API\n if (p.endsWith(\"/at\")) return await handleAt(req);\n if (p.endsWith(\"/blocks\")) return await getBlocks();\n if (p.endsWith(\"/staff\")) return await getStaff();\n if (p.endsWith(\"/clients\")) return await getClients(url);\n if (p.endsWith(\"/classes\")) return await getClasses(url);\n if (p.endsWith(\"/series\")) return await getSeries(url);\n if (p.endsWith(\"/createClass\")) return await createClass(req);\n if (p.endsWith(\"/updateClass\")) return await updateClass(req);\n if (p.endsWith(\"/deleteClass\")) return await deleteClass(req);\n if (p.endsWith(\"/addParticipants\")) return await addParticipants(req);\n return json({\n ok: true,\n service: \"schedule-builder-api\",\n routes: [\"/blocks\", \"/staff\", \"/clients?q=\", \"/classes?from=&to=\", \"POST /createClass\", \"POST /addParticipants\"],\n });\n } catch (e) {\n return json({ success: false, error: e instanceof Error ? e.message : String(e) }, 500);\n }\n}\n\nasync function getBlocks() {\n const recs = await fetchAllRecords(BLOCKS_TABLE, [\"Name\", \"Theme\", \"Start Date\", \"End Date\"]);\n const blocks = recs\n .filter((r: any) => r.fields[\"Start Date\"] && r.fields[\"End Date\"])\n .map((r: any) => ({\n id: r.id,\n num: blockNum(r.fields[\"Name\"]),\n name: r.fields[\"Name\"],\n theme: r.fields[\"Theme\"] || \"\",\n start: r.fields[\"Start Date\"],\n end: r.fields[\"End Date\"],\n }))\n .sort((a: any, b: any) => (a.start < b.start ? -1 : 1));\n return json({ success: true, blocks });\n}\n\nasync function getStaff() {\n const recs = await fetchAllRecords(STAFF_TABLE, [\"Name\", \"Active\", \"Role\"]);\n const staff = recs\n .filter((r: any) => r.fields[\"Active\"] === true && r.fields[\"Name\"])\n .map((r: any) => ({ id: r.id, name: r.fields[\"Name\"], role: r.fields[\"Role\"] || \"\" }));\n return json({ success: true, staff });\n}\n\nasync function getClients(url: URL) {\n const q = (url.searchParams.get(\"q\") || \"\").trim();\n const recs = await fetchAllRecords(ROSTER_TABLE, [\"Name\", \"Member Status\", \"First Name\", \"Last Name\"]);\n let clients = recs\n .filter((r: any) => r.fields[\"Name\"])\n .map((r: any) => ({ id: r.id, name: r.fields[\"Name\"], status: r.fields[\"Member Status\"] || \"\" }));\n if (q) {\n const ql = q.toLowerCase();\n clients = clients.filter((c: any) => c.name.toLowerCase().includes(ql));\n }\n clients.sort((a: any, b: any) => a.name.localeCompare(b.name));\n return json({ success: true, count: clients.length, clients: clients.slice(0, 30) });\n}\n\nasync function getClasses(url: URL) {\n const from = url.searchParams.get(\"from\");\n const to = url.searchParams.get(\"to\");\n let filter: string | undefined;\n if (from && to) filter = `AND(IS_AFTER({Date}, '${from}'), IS_BEFORE({Date}, '${to}'))`;\n const recs = await fetchAllRecords(\n CLASSES_TABLE,\n CLASS_FIELDS,\n filter,\n );\n const classes = recs.filter((r: any) => r.fields[\"Date\"]).map(mapClass);\n return json({ success: true, count: classes.length, classes });\n}\n\nconst CLASS_FIELDS = [\"Date\", \"Time\", \"Coach\", \"Capacity\", \"Duration\", \"Type\", \"Program (from Link to Workouts)\", \"Link to Workouts\", \"Session Notes\", \"Announcement\", \"Series ID\", \"Push to Trainerize\", \"Trainerize Appointment ID\"];\nfunction mapClass(r: any) {\n return {\n id: r.id,\n date: r.fields[\"Date\"],\n time: r.fields[\"Time\"] || \"\",\n coachId: (r.fields[\"Coach\"] || [])[0] || null,\n capacity: r.fields[\"Capacity\"] ?? null,\n duration: r.fields[\"Duration\"] ?? null,\n // Prefer the explicit Type field; fall back to the workout lookup for legacy records.\n type: r.fields[\"Type\"] || (r.fields[\"Program (from Link to Workouts)\"] || [])[0] || null,\n program: (r.fields[\"Program (from Link to Workouts)\"] || [])[0] || null,\n workoutId: (r.fields[\"Link to Workouts\"] || [])[0] || null,\n notes: r.fields[\"Session Notes\"] || \"\",\n announcement: r.fields[\"Announcement\"] || \"\",\n seriesId: r.fields[\"Series ID\"] || null,\n pushed: !!r.fields[\"Trainerize Appointment ID\"],\n queued: r.fields[\"Push to Trainerize\"] === true,\n };\n}\n\n// All classes belonging to one Series ID (for series edit/delete in the builder).\nasync function getSeries(url: URL) {\n const sid = (url.searchParams.get(\"seriesId\") || \"\").trim();\n if (!sid) return json({ success: false, error: \"seriesId required\" }, 400);\n const safe = sid.replace(/'/g, \"\\\\'\");\n const recs = await fetchAllRecords(CLASSES_TABLE, CLASS_FIELDS, `{Series ID} = '${safe}'`);\n const classes = recs\n .filter((r: any) => r.fields[\"Date\"])\n .map(mapClass)\n .sort((a: any, b: any) => (a.date < b.date ? -1 : a.date > b.date ? 1 : 0));\n return json({ success: true, count: classes.length, seriesId: sid, classes });\n}\n\nasync function createClass(req: Request) {\n const body = await req.json().catch(() => ({}));\n const items: any[] = body.classes || [];\n const dryRun = body.dryRun === true;\n const pushToTrainerize = body.pushToTrainerize !== false; // default true\n if (!items.length) return json({ success: false, error: \"No classes provided\" }, 400);\n\n const idx = await loadWorkoutIndex();\n const results: any[] = [];\n const toCreate: any[] = [];\n\n for (const it of items) {\n const date = it.date;\n const time = it.time || (typeof it.startMin === \"number\" ? minToTimeSlot(it.startMin) : null);\n if (!date || !time) { results.push({ date, error: \"missing date or time\" }); continue; }\n const workoutId = findWorkout(date, it.program || \"team\", idx);\n const fields: any = {\n Date: date,\n Time: time,\n \"Push to Trainerize\": pushToTrainerize,\n };\n fields[\"Type\"] = TYPE_LABEL[it.program || \"team\"] || \"Team\";\n if (it.coachRecId) fields[\"Coach\"] = [it.coachRecId];\n if (it.capacity != null) fields[\"Capacity\"] = Number(it.capacity);\n if (it.duration != null) fields[\"Duration\"] = Number(it.duration);\n if (it.notes) fields[\"Session Notes\"] = it.notes;\n if (it.announcement) fields[\"Announcement\"] = it.announcement;\n if (it.seriesId) fields[\"Series ID\"] = it.seriesId;\n if (workoutId) fields[\"Link to Workouts\"] = [workoutId];\n toCreate.push({ fields });\n results.push({ date, time, program: it.program || \"team\", workoutLinked: !!workoutId });\n }\n\n if (dryRun) return json({ success: true, dryRun: true, wouldCreate: toCreate.length, results });\n\n // Airtable caps at 10 records per create call\n const created: string[] = [];\n for (let i = 0; i < toCreate.length; i += 10) {\n const batch = toCreate.slice(i, i + 10);\n const resp = await callAirtableAPI(`${AT_BASE_ID}/${CLASSES_TABLE}`, \"POST\", {\n typecast: true, // auto-create Time options for new slots\n records: batch,\n });\n for (const r of resp.records) created.push(r.id);\n }\n return json({ success: true, created, count: created.length, results });\n}\n\n// Update one existing class (edit in the panel, or drag to a new date/time).\nasync function updateClass(req: Request) {\n const body = await req.json().catch(() => ({}));\n const id = body.id;\n if (!id) return json({ success: false, error: \"id required\" }, 400);\n const fields: any = {};\n if (body.date) fields[\"Date\"] = body.date;\n if (body.time) fields[\"Time\"] = body.time;\n if (body.program) fields[\"Type\"] = TYPE_LABEL[body.program] || \"Team\";\n if (body.coachRecId) fields[\"Coach\"] = [body.coachRecId];\n if (body.capacity != null) fields[\"Capacity\"] = Number(body.capacity);\n if (body.duration != null) fields[\"Duration\"] = Number(body.duration);\n if (body.announcement != null) fields[\"Announcement\"] = body.announcement;\n if (body.notes != null) fields[\"Session Notes\"] = body.notes;\n if (body.pushToTrainerize != null) fields[\"Push to Trainerize\"] = !!body.pushToTrainerize;\n // Re-link the workout (and thus Block/Week) when the date + program are known.\n if (body.date && body.program) {\n const idx = await loadWorkoutIndex();\n const wid = findWorkout(body.date, body.program, idx);\n fields[\"Link to Workouts\"] = wid ? [wid] : [];\n }\n const resp = await callAirtableAPI(`${AT_BASE_ID}/${CLASSES_TABLE}`, \"PATCH\", {\n typecast: true,\n records: [{ id, fields }],\n });\n return json({ success: true, id: resp.records[0].id });\n}\n\n// Delete one or more classes by record id.\nasync function deleteClass(req: Request) {\n const body = await req.json().catch(() => ({}));\n const ids: string[] = body.ids || (body.id ? [body.id] : []);\n if (!ids.length) return json({ success: false, error: \"ids required\" }, 400);\n let deleted = 0;\n for (let i = 0; i < ids.length; i += 10) {\n const batch = ids.slice(i, i + 10);\n const qs = batch.map((x) => `records[]=${encodeURIComponent(x)}`).join(\"&\");\n const resp = await fetch(`https://api.airtable.com/v0/${AT_BASE_ID}/${CLASSES_TABLE}?${qs}`, {\n method: \"DELETE\",\n headers: { \"Authorization\": `Bearer ${AT_PAT}` },\n });\n if (!resp.ok) { const e = await resp.text(); throw new Error(`Airtable delete ${resp.status}: ${e}`); }\n const j = await resp.json();\n deleted += (j.records || []).length;\n }\n return json({ success: true, deleted });\n}\n\nasync function addParticipants(req: Request) {\n const body = await req.json().catch(() => ({}));\n const classIds: string[] = body.classRecordIds || [];\n const clientIds: string[] = body.clientRecordIds || [];\n const dryRun = body.dryRun === true;\n if (!classIds.length || !clientIds.length) {\n return json({ success: false, error: \"classRecordIds and clientRecordIds are required\" }, 400);\n }\n\n const records: any[] = [];\n for (const classId of classIds) {\n for (const clientId of clientIds) {\n records.push({\n fields: {\n Class: [classId],\n Client: [clientId],\n \"Attendance Type\": \"Reserved\",\n \"Source\": \"Schedule Builder\",\n },\n });\n }\n }\n\n if (dryRun) return json({ success: true, dryRun: true, wouldCreate: records.length });\n\n const created: string[] = [];\n for (let i = 0; i < records.length; i += 10) {\n const batch = records.slice(i, i + 10);\n const resp = await callAirtableAPI(`${AT_BASE_ID}/${ATTENDANCE_TABLE}`, \"POST\", {\n typecast: true, // auto-create the \"Schedule Builder\" Source option\n records: batch,\n });\n for (const r of resp.records) created.push(r.id);\n }\n return json({ success: true, created, count: created.length });\n}\n",[167],"pulls","branches",1,"forks","envVars",{"_182":184,"_185":62},"connections",{"_182":62,"_183":62},"count","unfilledCount",9,"emptyCount",{"_42":166,"_32":167,"_30":168,"_134":-5,"_40":41,"_39":169,"_136":25,"_37":204,"_13":171,"_33":139,"_35":172,"_24":48,"_141":-5,"_192":205,"_27":206},{"_42":157,"_32":158,"_30":159,"_134":-5,"_40":41,"_39":160,"_136":25,"_37":201,"_13":162,"_33":163,"_35":164,"_24":48,"_141":-5,"_192":202,"_27":203},{"_42":149,"_32":150,"_30":151,"_134":-5,"_40":41,"_39":152,"_136":25,"_37":198,"_13":154,"_33":139,"_35":155,"_24":48,"_141":-5,"_192":199,"_27":200},{"_42":143,"_32":144,"_30":57,"_134":-5,"_40":41,"_39":145,"_136":25,"_37":195,"_13":62,"_33":139,"_35":147,"_24":48,"_141":-5,"_192":196,"_27":197},{"_42":131,"_32":132,"_30":133,"_134":-5,"_40":41,"_39":135,"_136":25,"_37":191,"_13":138,"_33":139,"_35":140,"_24":48,"_141":-5,"_192":193,"_27":194},["D",1788201806543],"children",[],[132],["D",1784771565741],[],[144],["D",1784771792714],[],[150],["D",1785765484323],[],[158],["D",1784913690952],[],[167],["D",1784768908681],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":48},{"_13":14,"_32":85,"_42":41,"_86":43,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":44,"_93":94},"ctx",{"_78":-5,"_123":244,"_245":246,"_247":248,"_249":48,"_250":48,"_251":48,"_252":25,"_253":-5,"_254":-7,"_255":-7,"_256":62,"_257":48,"_258":48,"_259":-5,"_260":48,"_261":48,"_262":48,"_263":-5},"ENV",{"_215":216,"_217":218,"_219":85,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235,"_236":237,"_238":239,"_240":241,"_242":243},"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"]

Diff · v113