[{"_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",45,"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)\n *\n * HTTP val with routing:\n * / → runs the sync\n * /sync → runs the sync\n * /populate → auto-fills Roster \"Trainerize User ID\" by name match\n * /ids → lists all Trainerize trainer + client IDs\n *\n * Scheduling is handled by the separate interval file: cron.ts\n *\n * Environment secrets needed:\n * - TZ_GROUP_ID: \"622051\"\n * - TZ_API_TOKEN: \"lSe9eneUhEafXadUkgyTeA\"\n * - TZ_BASE_URL: \"https://api.trainerize.com/v03\" (optional, defaults below)\n * - AT_PAT: Airtable Personal Access Token (https://airtable.com/create/tokens)\n * - AT_BASE_ID: \"appAUyXe4LgupwX0f\"\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\";\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\n if (url.pathname.endsWith(\"/ids\")) {\n return getTrainerizeIDs(req);\n }\n if (url.pathname.endsWith(\"/populate\")) {\n return populateRosterIDs(req);\n }\n\n // default + /sync: run the sync\n console.log(`[${new Date().toISOString()}] Running sync (HTTP)...`);\n const result = await syncTrainerizeToAirtable();\n return Response.json(result);\n}\n\n// ── Helpers ──────────────────────────────────────────────────────────────────\nfunction getTrainerizeAuth() {\n const creds = `${TZ_GROUP_ID}:${TZ_API_TOKEN}`;\n return `Basic ${btoa(creds)}`;\n}\n\nasync function callTrainerizeAPI(endpoint: string, body?: object) {\n const response = await fetch(`${TZ_BASE_URL}${endpoint}`, {\n method: \"POST\",\n headers: {\n \"Authorization\": getTrainerizeAuth(),\n \"Content-Type\": \"application/json\",\n },\n body: body ? JSON.stringify(body) : undefined,\n });\n\n if (!response.ok) {\n throw new Error(`Trainerize API error: ${response.status} on ${endpoint}`);\n }\n\n return response.json();\n}\n\nasync function callAirtableAPI(\n path: string,\n method: string = \"GET\",\n body?: object,\n) {\n const response = await fetch(`https://api.airtable.com/v0/${path}`, {\n method,\n headers: {\n \"Authorization\": `Bearer ${AT_PAT}`,\n \"Content-Type\": \"application/json\",\n },\n body: body ? JSON.stringify(body) : undefined,\n });\n\n if (!response.ok) {\n const error = await response.text();\n throw new Error(\n `Airtable API error: ${response.status} on ${path}: ${error}`,\n );\n }\n\n return response.json();\n}\n\n// Airtable wants repeated fields as fields[]=; build that safely\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\nfunction formatUTC(date: Date) {\n const pad = (n: number) => String(n).padStart(2, \"0\");\n return `${date.getUTCFullYear()}-${pad(date.getUTCMonth() + 1)}-${\n pad(date.getUTCDate())\n } ${pad(date.getUTCHours())}:${pad(date.getUTCMinutes())}:${\n pad(date.getUTCSeconds())\n }`;\n}\n\nfunction matchTimeSlot(tzTime: string): string | null {\n const match = tzTime.match(/(\\d{2}):(\\d{2})/);\n if (!match) return null;\n\n const hour = parseInt(match[1]);\n const min = parseInt(match[2]);\n const key = `${String(hour).padStart(2, \"0\")}:${String(min).padStart(2, \"0\")}`;\n\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\n return timeMap[key] || null;\n}\n\nfunction normalizeName(first: string, last: string): string {\n return `${first || \"\"} ${last || \"\"}`.trim().toLowerCase().replace(/\\s+/g, \" \");\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 // Fetch active trainers\n const staffResp = await callAirtableAPI(\n `${AT_BASE_ID}/${STAFF_TABLE}?${fieldsParam([\"Name\", \"Trainerize Trainer ID\", \"Active\"])}`,\n );\n\n const trainers = staffResp.records\n .filter(\n (r: any) =>\n r.fields[\"Active\"] === true && r.fields[\"Trainerize Trainer ID\"],\n )\n .map((r: any) => ({\n id: r.id,\n name: r.fields[\"Name\"],\n tzID: r.fields[\"Trainerize Trainer ID\"],\n }));\n\n logs.push(`Found ${trainers.length} active trainers`);\n\n // Fetch roster for matching (by Trainerize User ID)\n const rosterResp = await callAirtableAPI(\n `${AT_BASE_ID}/${ROSTER_TABLE}?${fieldsParam([\"Name\", \"Trainerize User ID\"])}`,\n );\n\n const rosterLookup = new Map(\n rosterResp.records\n .filter((r: any) => r.fields[\"Trainerize User ID\"])\n .map((r: any) => [String(r.fields[\"Trainerize User ID\"]), r.id]),\n );\n\n // Fetch existing classes\n const classesResp = await callAirtableAPI(\n `${AT_BASE_ID}/${CLASSES_TABLE}?${fieldsParam([\"Trainerize Appointment ID\"])}`,\n );\n\n const classesLookup = new Map(\n classesResp.records\n .filter((r: any) => r.fields[\"Trainerize Appointment ID\"])\n .map((r: any) => [String(r.fields[\"Trainerize Appointment ID\"]), { id: r.id }]),\n );\n\n // Fetch existing attendance\n const attendResp = await callAirtableAPI(\n `${AT_BASE_ID}/${ATTENDANCE_TABLE}?${fieldsParam([\"Trainerize Attendee Key\"])}`,\n );\n\n const attendanceLookup = new Map(\n attendResp.records\n .filter((r: any) => r.fields[\"Trainerize Attendee Key\"])\n .map((r: any) => [r.fields[\"Trainerize Attendee Key\"], r.id]),\n );\n\n // Poll appointments for each trainer\n let classesCreated = 0;\n let attendanceCreated = 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\n const aptResp = await callTrainerizeAPI(\"/appointment/getList\", {\n userID: parseInt(trainer.tzID),\n startDate: formatUTC(today),\n endDate: formatUTC(thirtyDaysOut),\n });\n\n const groupApts = (aptResp.appointments || []).filter(\n (a: any) => a.appointmentType?.isGroupAppointment === true,\n );\n\n logs.push(` Found ${groupApts.length} group classes`);\n\n for (const apt of groupApts) {\n const tzClassID = String(apt.id);\n // Use startDateTime = local wall-clock time (matches the gym's schedule).\n // startDate is UTC and would shift the slot by the timezone offset.\n const classDate = apt.startDateTime?.split(\" \")[0];\n const timeSlot = matchTimeSlot(apt.startDateTime);\n\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\n if (!classRecord) {\n const createResp = await callAirtableAPI(\n `${AT_BASE_ID}/${CLASSES_TABLE}`,\n \"POST\",\n {\n typecast: true, // auto-create Time options for new slots (e.g. 8:30 AM, 6:15 PM)\n records: [\n {\n fields: {\n Date: classDate,\n Time: timeSlot,\n \"Trainerize Appointment ID\": tzClassID,\n \"Trainerize Class Type ID\": String(\n apt.appointmentType.appointmentTypeID,\n ),\n Coach: [trainer.id],\n \"Session Notes\": apt.notes || \"\",\n },\n },\n ],\n },\n );\n\n classRecord = { id: createResp.records[0].id };\n classesLookup.set(tzClassID, classRecord);\n classesCreated++;\n logs.push(\n ` Created class: ${trainer.name} on ${classDate} at ${timeSlot}`,\n );\n }\n\n // Sync attendance\n for (const attendee of apt.attendents || []) {\n if (attendee.type !== \"client\") continue;\n\n const rosterID = rosterLookup.get(String(attendee.id));\n if (!rosterID) {\n logs.push(\n ` Warning: Client ${attendee.firstName} ${attendee.lastName} (${attendee.id}) not in Roster`,\n );\n continue;\n }\n\n const tzAttendeeKey = `${tzClassID}_${attendee.id}`;\n\n if (!attendanceLookup.has(tzAttendeeKey)) {\n const createResp = await callAirtableAPI(\n `${AT_BASE_ID}/${ATTENDANCE_TABLE}`,\n \"POST\",\n {\n records: [\n {\n fields: {\n Class: [classRecord.id],\n Client: [rosterID],\n \"Attendance Type\": \"Reserved\",\n \"Trainerize Attendee Key\": tzAttendeeKey,\n },\n },\n ],\n },\n );\n\n attendanceLookup.set(tzAttendeeKey, createResp.records[0].id);\n attendanceCreated++;\n logs.push(\n ` New booking: ${attendee.firstName} ${attendee.lastName}`,\n );\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(` 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// Fetch clients across ALL trainers (getClientList is scoped to one trainer),\n// deduped by client id.\nasync function fetchAllTrainerizeClients() {\n const auth = getTrainerizeAuth();\n\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\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// ── Utility: list Trainerize IDs ─────────────────────────────────────────────\nexport async function getTrainerizeIDs(_req: Request) {\n try {\n const auth = getTrainerizeAuth();\n\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\n const clients = await fetchAllTrainerizeClients();\n\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) => ({\n id: c.id,\n name: `${c.firstName} ${c.lastName}`,\n })),\n });\n } catch (error) {\n return Response.json({\n error: error instanceof Error ? error.message : String(error),\n });\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\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 // Fetch all Roster records (paginate)\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\"] || \"\").trim().toLowerCase().replace(/\\s+/g, \" \");\n\n const tzMatch = tzByName.get(key);\n if (!tzMatch) {\n report.unmatchedRoster.push(f[\"Name\"] || key || rec.id);\n continue;\n }\n\n report.matched++;\n matchedTzKeys.add(key);\n\n if (String(f[\"Trainerize User ID\"]) === tzMatch.id) {\n report.alreadySet++;\n continue;\n }\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 // Write updates in batches of 10\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)\n *\n * HTTP val with routing:\n * / → runs the sync\n * /sync → runs the sync\n * /populate → auto-fills Roster \"Trainerize User ID\" by name match\n * /ids → lists all Trainerize trainer + client IDs\n *\n * Scheduling is handled by the separate interval file: cron.ts\n *\n * Environment secrets needed:\n * - TZ_GROUP_ID: \"622051\"\n * - TZ_API_TOKEN: \"lSe9eneUhEafXadUkgyTeA\"\n * - TZ_BASE_URL: \"https://api.trainerize.com/v03\" (optional, defaults below)\n * - AT_PAT: Airtable Personal Access Token (https://airtable.com/create/tokens)\n * - AT_BASE_ID: \"appAUyXe4LgupwX0f\"\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\";\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\n if (url.pathname.endsWith(\"/ids\")) {\n return getTrainerizeIDs(req);\n }\n if (url.pathname.endsWith(\"/populate\")) {\n return populateRosterIDs(req);\n }\n\n // default + /sync: run the sync\n console.log(`[${new Date().toISOString()}] Running sync (HTTP)...`);\n const result = await syncTrainerizeToAirtable();\n return Response.json(result);\n}\n\n// ── Helpers ──────────────────────────────────────────────────────────────────\nfunction getTrainerizeAuth() {\n const creds = `${TZ_GROUP_ID}:${TZ_API_TOKEN}`;\n return `Basic ${btoa(creds)}`;\n}\n\nasync function callTrainerizeAPI(endpoint: string, body?: object) {\n const response = await fetch(`${TZ_BASE_URL}${endpoint}`, {\n method: \"POST\",\n headers: {\n \"Authorization\": getTrainerizeAuth(),\n \"Content-Type\": \"application/json\",\n },\n body: body ? JSON.stringify(body) : undefined,\n });\n\n if (!response.ok) {\n throw new Error(`Trainerize API error: ${response.status} on ${endpoint}`);\n }\n\n return response.json();\n}\n\nasync function callAirtableAPI(\n path: string,\n method: string = \"GET\",\n body?: object,\n) {\n const response = await fetch(`https://api.airtable.com/v0/${path}`, {\n method,\n headers: {\n \"Authorization\": `Bearer ${AT_PAT}`,\n \"Content-Type\": \"application/json\",\n },\n body: body ? JSON.stringify(body) : undefined,\n });\n\n if (!response.ok) {\n const error = await response.text();\n throw new Error(\n `Airtable API error: ${response.status} on ${path}: ${error}`,\n );\n }\n\n return response.json();\n}\n\n// Airtable wants repeated fields as fields[]=; build that safely\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\nfunction formatUTC(date: Date) {\n const pad = (n: number) => String(n).padStart(2, \"0\");\n return `${date.getUTCFullYear()}-${pad(date.getUTCMonth() + 1)}-${\n pad(date.getUTCDate())\n } ${pad(date.getUTCHours())}:${pad(date.getUTCMinutes())}:${\n pad(date.getUTCSeconds())\n }`;\n}\n\nfunction matchTimeSlot(tzTime: string): string | null {\n const match = tzTime.match(/(\\d{2}):(\\d{2})/);\n if (!match) return null;\n\n const hour = parseInt(match[1]);\n const min = parseInt(match[2]);\n const key = `${String(hour).padStart(2, \"0\")}:${String(min).padStart(2, \"0\")}`;\n\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\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\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 // Fetch active trainers\n const staffResp = await callAirtableAPI(\n `${AT_BASE_ID}/${STAFF_TABLE}?${fieldsParam([\"Name\", \"Trainerize Trainer ID\", \"Active\"])}`,\n );\n\n const trainers = staffResp.records\n .filter(\n (r: any) =>\n r.fields[\"Active\"] === true && r.fields[\"Trainerize Trainer ID\"],\n )\n .map((r: any) => ({\n id: r.id,\n name: r.fields[\"Name\"],\n tzID: r.fields[\"Trainerize Trainer ID\"],\n }));\n\n logs.push(`Found ${trainers.length} active trainers`);\n\n // Fetch roster for matching (by Trainerize User ID)\n const rosterResp = await callAirtableAPI(\n `${AT_BASE_ID}/${ROSTER_TABLE}?${fieldsParam([\"Name\", \"Trainerize User ID\"])}`,\n );\n\n const rosterLookup = new Map(\n rosterResp.records\n .filter((r: any) => r.fields[\"Trainerize User ID\"])\n .map((r: any) => [String(r.fields[\"Trainerize User ID\"]), r.id]),\n );\n\n // Fetch existing classes\n const classesResp = await callAirtableAPI(\n `${AT_BASE_ID}/${CLASSES_TABLE}?${fieldsParam([\"Trainerize Appointment ID\"])}`,\n );\n\n const classesLookup = new Map(\n classesResp.records\n .filter((r: any) => r.fields[\"Trainerize Appointment ID\"])\n .map((r: any) => [String(r.fields[\"Trainerize Appointment ID\"]), { id: r.id }]),\n );\n\n // Fetch existing attendance\n const attendResp = await callAirtableAPI(\n `${AT_BASE_ID}/${ATTENDANCE_TABLE}?${fieldsParam([\"Trainerize Attendee Key\"])}`,\n );\n\n const attendanceLookup = new Map(\n attendResp.records\n .filter((r: any) => r.fields[\"Trainerize Attendee Key\"])\n .map((r: any) => [r.fields[\"Trainerize Attendee Key\"], r.id]),\n );\n\n // Poll appointments for each trainer\n let classesCreated = 0;\n let attendanceCreated = 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\n const aptResp = await callTrainerizeAPI(\"/appointment/getList\", {\n userID: parseInt(trainer.tzID),\n startDate: formatUTC(today),\n endDate: formatUTC(thirtyDaysOut),\n });\n\n const groupApts = (aptResp.appointments || []).filter(\n (a: any) => a.appointmentType?.isGroupAppointment === true,\n );\n\n logs.push(` Found ${groupApts.length} group classes`);\n\n for (const apt of groupApts) {\n const tzClassID = String(apt.id);\n // Use startDateTime = local wall-clock time (matches the gym's schedule).\n // startDate is UTC and would shift the slot by the timezone offset.\n const classDate = apt.startDateTime?.split(\" \")[0];\n const timeSlot = matchTimeSlot(apt.startDateTime);\n\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\n if (!classRecord) {\n const createResp = await callAirtableAPI(\n `${AT_BASE_ID}/${CLASSES_TABLE}`,\n \"POST\",\n {\n typecast: true, // auto-create Time options for new slots (e.g. 8:30 AM, 6:15 PM)\n records: [\n {\n fields: {\n Date: classDate,\n Time: timeSlot,\n \"Trainerize Appointment ID\": tzClassID,\n \"Trainerize Class Type ID\": String(\n apt.appointmentType.appointmentTypeID,\n ),\n Coach: [trainer.id],\n \"Session Notes\": apt.notes || \"\",\n },\n },\n ],\n },\n );\n\n classRecord = { id: createResp.records[0].id };\n classesLookup.set(tzClassID, classRecord);\n classesCreated++;\n logs.push(\n ` Created class: ${trainer.name} on ${classDate} at ${timeSlot}`,\n );\n }\n\n // Sync attendance\n for (const attendee of apt.attendents || []) {\n if (attendee.type !== \"client\") continue;\n\n const rosterID = rosterLookup.get(String(attendee.id));\n if (!rosterID) {\n logs.push(\n ` Warning: Client ${attendee.firstName} ${attendee.lastName} (${attendee.id}) not in Roster`,\n );\n continue;\n }\n\n const tzAttendeeKey = `${tzClassID}_${attendee.id}`;\n\n if (!attendanceLookup.has(tzAttendeeKey)) {\n const createResp = await callAirtableAPI(\n `${AT_BASE_ID}/${ATTENDANCE_TABLE}`,\n \"POST\",\n {\n records: [\n {\n fields: {\n Class: [classRecord.id],\n Client: [rosterID],\n \"Attendance Type\": \"Reserved\",\n \"Trainerize Attendee Key\": tzAttendeeKey,\n },\n },\n ],\n },\n );\n\n attendanceLookup.set(tzAttendeeKey, createResp.records[0].id);\n attendanceCreated++;\n logs.push(\n ` New booking: ${attendee.firstName} ${attendee.lastName}`,\n );\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(` 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// Fetch clients across ALL trainers (getClientList is scoped to one trainer),\n// deduped by client id.\nasync function fetchAllTrainerizeClients() {\n const auth = getTrainerizeAuth();\n\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\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// ── Utility: list Trainerize IDs ─────────────────────────────────────────────\nexport async function getTrainerizeIDs(_req: Request) {\n try {\n const auth = getTrainerizeAuth();\n\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\n const clients = await fetchAllTrainerizeClients();\n\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) => ({\n id: c.id,\n name: `${c.firstName} ${c.lastName}`,\n })),\n });\n } catch (error) {\n return Response.json({\n error: error instanceof Error ? error.message : String(error),\n });\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\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 // Fetch all Roster records (paginate)\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\"] || \"\").trim().toLowerCase().replace(/\\s+/g, \" \");\n\n const tzMatch = tzByName.get(key);\n if (!tzMatch) {\n report.unmatchedRoster.push(f[\"Name\"] || key || rec.id);\n continue;\n }\n\n report.matched++;\n matchedTzKeys.add(key);\n\n if (String(f[\"Trainerize User ID\"]) === tzMatch.id) {\n report.alreadySet++;\n continue;\n }\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 // Write updates in batches of 10\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",1784776639408],"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},"5615bba5-ae14-44b7-8793-f821fa04b82c","parentId","latest",["D",1784776639408],39,"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",1784776639408],"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","fdb67791413f4386b4dbf18f354029a617f6160f","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 · v45