[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_194":195,"_196":197},"routes/_app.x.$handle.$name",{"_97":96,"_32":45,"_106":87,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":59,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",56,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","039adfee-8633-11f1-a89e-1607ee4eb77e","name","fileType","http","content","/**\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\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\", \"Link to Workouts\"]);\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[\"Link to Workouts\"] || []).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: { \"Link to Workouts\": [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 // 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 const typeById = new Map();\n let teamTypeId: string | null = null;\n let youthTypeId: string | null = null;\n for (const t of rawTypes) {\n const id = String(t.appointmentTypeID);\n typeById.set(id, t);\n if (/youth/i.test(t.name || \"\")) youthTypeId = id;\n else if (/team/i.test(t.name || \"\")) teamTypeId = id;\n }\n report.appointmentTypes = rawTypes.map((t: any) => ({\n id: t.appointmentTypeID, name: t.name, duration: t.duration, isGroup: t.isGroupAppointment,\n }));\n\n // Locations — in-person appointment types require a locationID\n const locResp = await callTrainerizeAPI(\"/location/getList\", {});\n const locations = locResp.locations || (Array.isArray(locResp) ? locResp : []);\n report.locations = locations.map((l: any) => ({ id: l.id ?? l.locationID, name: l.name ?? l.locationName }));\n const defaultLocationId = locations[0]?.id ?? locations[0]?.locationID ?? null;\n\n // Classes flagged to push and not yet in Trainerize\n const classes = await fetchAllRecords(\n CLASSES_TABLE,\n [\"Date\", \"Time\", \"Coach\", \"Session Notes\", \"Trainerize Class Type ID\", \"Program (from Link to Workouts)\"],\n \"AND({Push to Trainerize}=1, {Trainerize Appointment ID}='')\",\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 const program = ((f[\"Program (from Link to Workouts)\"] || [])[0] || \"Team\");\n const typeId = f[\"Trainerize Class Type ID\"] || (/youth/i.test(program) ? youthTypeId : teamTypeId);\n const dur = typeId && typeById.get(String(typeId)) ? typeById.get(String(typeId)).duration : 45;\n\n if (!coach || !time || !f[\"Date\"] || !typeId) {\n const missing = [!coach && \"coach\", !time && \"time\", !f[\"Date\"] && \"date\", !typeId && \"class type\"]\n .filter(Boolean).join(\", \");\n report.skipped.push({ classId: c.id, 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 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 }\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","/**\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\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\", \"Link to Workouts\"]);\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[\"Link to Workouts\"] || []).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: { \"Link to Workouts\": [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 // 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 const typeById = new Map();\n let teamTypeId: string | null = null;\n let youthTypeId: string | null = null;\n for (const t of rawTypes) {\n const id = String(t.appointmentTypeID);\n typeById.set(id, t);\n if (/youth/i.test(t.name || \"\")) youthTypeId = id;\n else if (/team/i.test(t.name || \"\")) teamTypeId = id;\n }\n report.appointmentTypes = rawTypes.map((t: any) => ({\n id: t.appointmentTypeID, name: t.name, duration: t.duration, isGroup: t.isGroupAppointment,\n }));\n\n // Location — /location/getList is not permitted for this token, so derive the\n // gym's locationID from an existing appointment (in-person types require it).\n let defaultLocationId: number | null = null;\n const anyTrainer = [...staffMap.values()][0];\n if (anyTrainer) {\n const now = new Date();\n const in30 = new Date(now.getTime() + 30 * 864e5);\n const probe = await callTrainerizeAPI(\"/appointment/getList\", {\n userID: parseInt(anyTrainer.tzId),\n startDate: formatUTC(now),\n endDate: formatUTC(in30),\n });\n for (const a of (probe.appointments || [])) {\n if (a.locationID) { defaultLocationId = a.locationID; break; }\n }\n }\n report.locationID = defaultLocationId;\n\n // Classes flagged to push and not yet in Trainerize\n const classes = await fetchAllRecords(\n CLASSES_TABLE,\n [\"Date\", \"Time\", \"Coach\", \"Session Notes\", \"Trainerize Class Type ID\", \"Program (from Link to Workouts)\"],\n \"AND({Push to Trainerize}=1, {Trainerize Appointment ID}='')\",\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 const program = ((f[\"Program (from Link to Workouts)\"] || [])[0] || \"Team\");\n const typeId = f[\"Trainerize Class Type ID\"] || (/youth/i.test(program) ? youthTypeId : teamTypeId);\n const dur = typeId && typeById.get(String(typeId)) ? typeById.get(String(typeId)).duration : 45;\n\n if (!coach || !time || !f[\"Date\"] || !typeId) {\n const missing = [!coach && \"coach\", !time && \"time\", !f[\"Date\"] && \"date\", !typeId && \"class type\"]\n .filter(Boolean).join(\", \");\n report.skipped.push({ classId: c.id, 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 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 }\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","createdAt",["D",1784782186937],"branchVersion","branchId","e345228c-6abb-433a-a5c4-d19b6d13772c","id","16b4dfda-c5a8-47e2-b75b-3ba596fe8aec","trainerize_airtable_sync",["D",1784768908681],"deletedAt","legacyEnvVars","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",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f56a8-2712-750d-8a46-0901b512a677","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_105":101},"org",{"_97":96,"_98":99,"_100":101,"_18":55,"_102":103,"_104":25},"branch",{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"isOwned",113,"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",{"_43":44,"_32":45,"_38":190,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":191,"_81":192,"_83":193,"_85":25},"tree",[173,174,175,176],"files",[173,174,175,176],"counts",{"_161":63,"_162":163,"_164":63,"_165":166,"_167":168},"contents",[128,129,130,131],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":153,"_32":154,"_30":155,"_133":-5,"_41":42,"_40":156,"_134":25,"_38":157,"_13":63,"_33":158,"_35":159,"_24":25,"_137":-5,"_27":160},{"_43":145,"_32":146,"_30":147,"_133":-5,"_41":42,"_40":148,"_134":59,"_38":149,"_13":150,"_33":34,"_35":151,"_24":25,"_137":-5,"_27":152},{"_43":139,"_32":140,"_30":57,"_133":-5,"_41":42,"_40":141,"_134":59,"_38":142,"_13":63,"_33":34,"_35":143,"_24":25,"_137":-5,"_27":144},{"_43":132,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_134":25,"_38":135,"_13":136,"_33":34,"_35":37,"_24":25,"_137":-5,"_27":138},"f7dcc6d4-90ac-452d-8690-4dc9afa1e674","parentId","latest",["D",1784782186937],50,"label",[28],"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",[140],"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",[146],"683d7962-db72-4edf-8955-a9ad9e335a5f","cron.ts","b5012632-8640-11f1-bcfe-1607ee4eb77e",44,["D",1784774789776],"interval","/**\n * Scheduled runner for the Trainerize ↔ Airtable sync.\n * Runs every 15 minutes and calls the sync logic in main.ts.\n */\nimport { syncTrainerizeToAirtable } from \"./main.ts\";\n\nexport default async function () {\n console.log(`[${new Date().toISOString()}] Scheduled sync starting...`);\n const result = await syncTrainerizeToAirtable();\n console.log(\n result.success\n ? `Sync OK — ${result.logs?.[result.logs.length - 2] ?? \"\"}, ${result.logs?.[result.logs.length - 1] ?? \"\"}`\n : `Sync FAILED — ${result.error}`,\n );\n return result;\n}\n",[154],"pulls","branches",1,"forks","envVars",{"_169":171,"_172":63},"connections",{"_169":63,"_170":63},"count","unfilledCount",9,"emptyCount",{"_43":153,"_32":154,"_30":155,"_133":-5,"_41":42,"_40":156,"_134":25,"_38":187,"_13":63,"_33":158,"_35":159,"_24":25,"_137":-5,"_178":188,"_27":189},{"_43":145,"_32":146,"_30":147,"_133":-5,"_41":42,"_40":148,"_134":59,"_38":184,"_13":150,"_33":34,"_35":151,"_24":25,"_137":-5,"_178":185,"_27":186},{"_43":139,"_32":140,"_30":57,"_133":-5,"_41":42,"_40":141,"_134":59,"_38":181,"_13":63,"_33":34,"_35":143,"_24":25,"_137":-5,"_178":182,"_27":183},{"_43":132,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_134":25,"_38":177,"_13":136,"_33":34,"_35":37,"_24":25,"_137":-5,"_178":179,"_27":180},["D",1784782186937],"children",[],[28],["D",1784771565741],[],[140],["D",1784771792714],[],[146],["D",1784774789776],[],[154],["D",1784768908681],{"_97":96,"_105":101},{"_97":96,"_98":99,"_100":101,"_18":55,"_102":103,"_104":25},{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_79":-5,"_125":227,"_228":229,"_230":231,"_232":25,"_233":25,"_234":25,"_235":59,"_236":-5,"_237":-7,"_238":-7,"_239":63,"_240":25,"_241":25,"_242":-5,"_243":25,"_244":25,"_245":25,"_246":-5},"ENV",{"_198":199,"_200":201,"_202":87,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226},"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 · v56