[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_155":156,"_157":158},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_117":-5,"_20":118,"_22":119,"_120":121,"_122":123,"_25":124,"_24":-5,"_125":-5,"_126":-5,"_127":53,"_128":129,"_130":53,"_131":-5,"_132":-5,"_133":134},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","wgkluck2","name","ymcaRegister","branchName","main","version","path","","project",{"_33":61,"_13":14,"_45":62,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":-5,"_69":-5,"_70":71,"_72":37,"_73":44,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":94,"_95":96,"_97":98,"_99":53},"tree",[56],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":55},"id","0cf77d5e-11ca-475f-b419-da0b53fe8b5a","main.tsx","fileId","e2b37540-6e52-11f1-867f-1607ee4eb77e","parentId","branchId","5133b829-7d64-49d1-8064-f2313d1a82b6","branchVersion",14,"latest",true,"createdAt",["D",1788533167216],10,"fileType","interval","content","/**\n * YMCA Auto-Registration — Val.town Cron Val\n *\n * Runs every 15 minutes. When a registration window opens (50 hours before\n * class), logs in to uPace and registers Mary for Group Water Fitness.\n *\n * Runs on Val.town infrastructure (non-Cloudflare IPs) to avoid uPace WAF blocks.\n *\n * Required Val.town secrets (Settings → Environment Variables):\n * DAXKO_USERNAME — Mary's uPace email\n * DAXKO_PASSWORD — Mary's uPace password\n * APPS_SCRIPT_URL — Google Apps Script webhook URL\n * APPS_SCRIPT_TOKEN — Shared auth token for Apps Script\n */\n\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst API = \"https://upace.app/api\";\nconst ORG_ID = \"65\";\n\nconst UPACE_HEADERS = {\n \"User-Agent\": \"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Safari/537.36\",\n \"Accept\": \"application/json, text/plain, */*\",\n \"Accept-Language\": \"en-US,en;q=0.9\",\n \"Referer\": \"https://upace.app/\",\n \"Origin\": \"https://upace.app\",\n};\n\n// Registration window: opens exactly 50 hours before class start\nconst WINDOW_HOURS = 50;\n\n// Class definitions — (weekday: JS day 0=Sun, 1=Mon, ...)\nconst CLASSES = [\n { classId: 88628, slotId: 28457186, weekday: 2, time: \"08:00\", label: \"Tuesday 8:00am\", tz: \"America/Denver\" },\n { classId: 75002, slotId: 28372902, weekday: 4, time: \"09:15\", label: \"Thursday 9:15am\", tz: \"America/Denver\" },\n { classId: 112509, slotId: 28795904, weekday: 6, time: \"11:15\", label: \"Saturday 11:15am\", tz: \"America/Denver\" },\n];\n\n// ---- helpers ----------------------------------------------------------------\n\nfunction log(msg: string) {\n console.log(`[${new Date().toISOString()}] ${msg}`);\n}\n\nfunction blobKey(classId: number, date: string) {\n return `ymca_state_${classId}_${date}`;\n}\n\n/** Return the date string (YYYY-MM-DD) for the next occurrence of a given\n * JS weekday at the specified local time, relative to now. */\nfunction nextOccurrence(weekday: number, localTime: string, tz: string): { date: string; utcDateTime: Date } {\n const now = new Date();\n\n const localNow = new Date(now.toLocaleString(\"en-US\", { timeZone: tz }));\n const localDay = localNow.getDay();\n const [h, m] = localTime.split(\":\").map(Number);\n\n let daysAhead = weekday - localDay;\n if (daysAhead < 0) daysAhead += 7;\n\n if (daysAhead === 0) {\n const classTime = new Date(localNow);\n classTime.setHours(h, m, 0, 0);\n if (localNow >= classTime) daysAhead = 7;\n }\n\n const classLocal = new Date(localNow);\n classLocal.setDate(classLocal.getDate() + daysAhead);\n classLocal.setHours(h, m, 0, 0);\n\n const datePart = classLocal.toLocaleDateString(\"en-CA\", { timeZone: tz }); // \"YYYY-MM-DD\"\n const classUtc = toUtc(datePart, localTime, tz);\n\n return { date: datePart, utcDateTime: classUtc };\n}\n\n/** Convert a local date+time in a named timezone to a UTC Date */\nfunction toUtc(datePart: string, localTime: string, tz: string): Date {\n const [h, m] = localTime.split(\":\").map(Number);\n // Use Intl to find the UTC instant corresponding to this local time\n const candidate = new Date(`${datePart}T${String(h).padStart(2,\"0\")}:${String(m).padStart(2,\"0\")}:00Z`);\n // Adjust for timezone offset\n const local = new Date(candidate.toLocaleString(\"en-US\", { timeZone: tz }));\n const utc = new Date(candidate.toLocaleString(\"en-US\", { timeZone: \"UTC\" }));\n const offsetMs = utc.getTime() - local.getTime();\n return new Date(candidate.getTime() + offsetMs);\n}\n\n// ---- uPace API --------------------------------------------------------------\n\nasync function login(): Promise {\n const username = Deno.env.get(\"DAXKO_USERNAME\");\n const password = Deno.env.get(\"DAXKO_PASSWORD\");\n if (!username || !password) throw new Error(\"Missing DAXKO_USERNAME or DAXKO_PASSWORD env vars\");\n\n for (let attempt = 1; attempt <= 3; attempt++) {\n const resp = await fetch(`${API}/auth/login/legacy`, {\n method: \"POST\",\n headers: { ...UPACE_HEADERS, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ email: username, password, orgId: ORG_ID }),\n });\n const body = await resp.text();\n if (resp.status === 401) throw Object.assign(new Error(`Auth failed: ${body.slice(0,200)}`), { permanent: true });\n if (!resp.ok) {\n if (attempt < 3) { await sleep(3000 * attempt); continue; }\n throw new Error(`Login HTTP ${resp.status}: ${body.slice(0,200)}`);\n }\n const data = JSON.parse(body);\n if (!data.success) throw Object.assign(new Error(`Login rejected: ${data.message}`), { permanent: true });\n log(`Logged in as ${data.email ?? username}`);\n return data.token;\n }\n throw new Error(\"Login failed after 3 attempts\");\n}\n\nasync function getReservations(token: string): Promise {\n const now = new Date().toISOString().split(\"T\")[0];\n const future = new Date(Date.now() + 14 * 86400000).toISOString().split(\"T\")[0];\n const resp = await fetch(`${API}/reservations/mine?start_time=${now}&end_time=${future}&orgId=${ORG_ID}`, {\n headers: { ...UPACE_HEADERS, Authorization: `Bearer ${token}` },\n });\n if (!resp.ok) throw new Error(`Reservations HTTP ${resp.status}`);\n const data = await resp.json();\n return data?.data?.reservations ?? [];\n}\n\nfunction isReserved(reservations: any[], classId: number, date: string): boolean {\n return reservations.some(r => r.class_id === classId && r.active === 1 && r.start_time?.startsWith(date));\n}\n\nasync function reserve(token: string, cls: typeof CLASSES[0], date: string): Promise {\n const resp = await fetch(`${API}/reserve`, {\n method: \"POST\",\n headers: { ...UPACE_HEADERS, \"Content-Type\": \"application/json\", Authorization: `Bearer ${token}` },\n body: JSON.stringify({ class_id: cls.classId, slot_id: cls.slotId, date, type: \"class\" }),\n });\n const body = await resp.text();\n if (resp.status === 401) throw Object.assign(new Error(`Auth expired`), { permanent: true });\n if (!resp.ok) {\n // Return the body as a result object so callers can classify the failure\n try { return JSON.parse(body); } catch { return { success: false, message: `HTTP ${resp.status}: ${body.slice(0,200)}` }; }\n }\n return JSON.parse(body);\n}\n\n// ---- notifications ----------------------------------------------------------\n\nasync function notifyCalendar(cls: typeof CLASSES[0], date: string) {\n const appsScriptUrl = Deno.env.get(\"APPS_SCRIPT_URL\");\n const appsScriptToken = Deno.env.get(\"APPS_SCRIPT_TOKEN\");\n if (!appsScriptUrl || !appsScriptToken) { log(\"No APPS_SCRIPT_URL/TOKEN — skipping notification\"); return; }\n\n const [h, m] = cls.time.split(\":\").map(Number);\n const start = `${date}T${String(h).padStart(2,\"0\")}:${String(m).padStart(2,\"0\")}:00`;\n const end = `${date}T${String(h+1).padStart(2,\"0\")}:${String(m).padStart(2,\"0\")}:00`;\n\n const resp = await fetch(appsScriptUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n token: appsScriptToken,\n action: \"calendar\",\n title: `Group Water Fitness — ${cls.label}`,\n start, end,\n location: \"Boulder YMCA, 2850 Mapleton Ave, Boulder, CO\",\n description: \"Auto-registered by YMCA Bot (Val.town)\",\n }),\n });\n log(`Calendar notification: HTTP ${resp.status}`);\n}\n\nasync function notifyAlert(subject: string, body: string) {\n const appsScriptUrl = Deno.env.get(\"APPS_SCRIPT_URL\");\n const appsScriptToken = Deno.env.get(\"APPS_SCRIPT_TOKEN\");\n if (!appsScriptUrl || !appsScriptToken) return;\n\n await fetch(appsScriptUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ token: appsScriptToken, action: \"alert\", subject, body }),\n });\n}\n\n// ---- core registration logic ------------------------------------------------\n\nasync function tryRegister(cls: typeof CLASSES[0], date: string, preAuthToken?: string) {\n const key = blobKey(cls.classId, date);\n\n // Idempotency: already handled this class+date?\n const existing = await blob.getJSON(key) as any;\n if (existing?.state === \"success\" || existing?.state === \"waitlisted\") {\n log(`${cls.label} on ${date}: already ${existing.state} — skipping`);\n return;\n }\n\n log(`${cls.label} on ${date}: window open, attempting registration...`);\n\n try {\n const token = preAuthToken ?? await login();\n\n // Check if already registered via API (already done pre-sleep when preAuthToken is set)\n if (!preAuthToken) {\n const reservations = await getReservations(token);\n if (isReserved(reservations, cls.classId, date)) {\n log(` Already registered (API confirmed)`);\n await blob.setJSON(key, { state: \"success\", timestamp: new Date().toISOString(), source: \"already_registered\" });\n return;\n }\n }\n\n // Reserve\n const result = await reserve(token, cls, date);\n log(` Reserve response: ${JSON.stringify(result).slice(0, 300)}`);\n\n // Verify via API (always trust API, not reserve response)\n const fresh = await getReservations(token);\n const confirmed = isReserved(fresh, cls.classId, date);\n\n if (confirmed) {\n log(` SUCCESS: ${cls.label} on ${date} confirmed`);\n await blob.setJSON(key, { state: \"success\", timestamp: new Date().toISOString() });\n await notifyCalendar(cls, date);\n return;\n }\n\n // Not confirmed — check if waitlisted\n const isWaitlist = result?.message?.toLowerCase().includes(\"waitlist\") || result?.success === false && result?.message?.toLowerCase().includes(\"waitlist\");\n if (isWaitlist) {\n log(` WAITLISTED: ${result.message}`);\n await blob.setJSON(key, { state: \"waitlisted\", timestamp: new Date().toISOString(), message: result.message });\n await notifyAlert(\n `YMCA: Waitlisted for ${cls.label} on ${date}`,\n `Class was full. You're on the waitlist. YMCA will move you in if a spot opens.\\n\\nAPI response: ${result.message}`\n );\n return;\n }\n\n // Generic failure — store for retry on next 15-min cron run\n const msg = result?.message || \"unknown error\";\n log(` FAILED: ${msg} — will retry on next cron run`);\n await blob.setJSON(key, { state: \"failed\", timestamp: new Date().toISOString(), message: msg, attempts: (existing?.attempts ?? 0) + 1 });\n\n // Alert only after 2 failures (first is normal transient noise)\n if ((existing?.attempts ?? 0) >= 1) {\n await notifyAlert(\n `YMCA: Registration failed for ${cls.label} on ${date}`,\n `Attempt ${(existing?.attempts ?? 0) + 2} failed: ${msg}\\n\\nWill keep retrying every 15 minutes until class date.`\n );\n }\n } catch (e: any) {\n const msg: string = e.message ?? String(e);\n log(` ERROR: ${msg}`);\n // \"already on waitlist\" from a prior run — treat as waitlisted, stop retrying\n if (msg.toLowerCase().includes(\"waitlist\")) {\n await blob.setJSON(key, { state: \"waitlisted\", timestamp: new Date().toISOString(), message: msg });\n return;\n }\n await blob.setJSON(key, {\n state: \"error\",\n timestamp: new Date().toISOString(),\n message: msg,\n attempts: (existing?.attempts ?? 0) + 1,\n });\n if ((existing?.attempts ?? 0) >= 1) {\n await notifyAlert(\n `YMCA: System error for ${cls.label} on ${date}`,\n `Error: ${msg}\\n\\nWill retry on next cron run.`\n );\n }\n }\n}\n\nfunction sleep(ms: number) {\n return new Promise(r => setTimeout(r, ms));\n}\n\n// ---- main entry point -------------------------------------------------------\n\nexport default async function main(req?: Request): Promise {\n const now = new Date();\n log(`Trigger fired. Checking ${CLASSES.length} classes...`);\n\n for (const cls of CLASSES) {\n const { date, utcDateTime } = nextOccurrence(cls.weekday, cls.time, cls.tz);\n const windowOpenUtc = new Date(utcDateTime.getTime() - WINDOW_HOURS * 3600000);\n\n const msSinceOpen = now.getTime() - windowOpenUtc.getTime();\n const minutesSinceOpen = msSinceOpen / 60000;\n\n log(`${cls.label}: next=${date}, window_open=${windowOpenUtc.toISOString()}, minutes_since_open=${minutesSinceOpen.toFixed(1)}`);\n\n if (msSinceOpen < 0) {\n const msUntilOpen = -msSinceOpen;\n if (msUntilOpen <= 180000) {\n const key = blobKey(cls.classId, date);\n const existing = await blob.getJSON(key) as any;\n if (existing?.state === \"success\" || existing?.state === \"waitlisted\") {\n log(` ${cls.label} on ${date}: already ${existing.state} — skipping`);\n continue;\n }\n\n log(` Window opens in ${(msUntilOpen / 1000).toFixed(1)}s — pre-authenticating before precise sleep...`);\n\n // Login + \"already registered\" check happen now, so reserve() is the\n // only network call left to fire at the actual opening instant below.\n let preAuthToken: string | undefined;\n try {\n const token = await login();\n const reservations = await getReservations(token);\n if (isReserved(reservations, cls.classId, date)) {\n log(` Already registered (API confirmed) — no need to wait`);\n await blob.setJSON(key, { state: \"success\", timestamp: new Date().toISOString(), source: \"already_registered\" });\n continue;\n }\n preAuthToken = token;\n } catch (e: any) {\n log(` Pre-auth failed (${e.message ?? e}) — will log in again at reserve time`);\n }\n\n const sleepMs = windowOpenUtc.getTime() + 200 - Date.now();\n if (sleepMs > 0) {\n log(` Sleeping ${(sleepMs / 1000).toFixed(1)}s until exact window open...`);\n await sleep(sleepMs);\n }\n await tryRegister(cls, date, preAuthToken);\n continue;\n }\n log(` Window not yet open (opens in ${(msUntilOpen / 60000).toFixed(1)} min)`);\n continue;\n }\n\n if (minutesSinceOpen > 60) {\n // Window opened more than 60 minutes ago — check if we have a pending state to retry\n const key = blobKey(cls.classId, date);\n const existing = await blob.getJSON(key) as any;\n if (!existing || existing.state === \"failed\" || existing.state === \"error\") {\n // Retry failed/errored registrations until class date\n const classDate = new Date(date + \"T12:00:00Z\");\n if (now < classDate) {\n log(` Retrying failed registration (state: ${existing?.state ?? \"none\"})`);\n await tryRegister(cls, date);\n }\n }\n continue;\n }\n\n // Window opened within the last 60 minutes — this is the primary registration attempt\n await tryRegister(cls, date);\n }\n\n log(\"Done.\");\n return new Response(JSON.stringify({ success: true, timestamp: new Date().toISOString() }), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n}\n","deleted",false,"label",[35],{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":59,"_18":60},["D",1788533167216],"children",[],[35],"bf343fb0-e04f-4039-b7d2-c73fe321e231",["D",1782143475164],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","61abc3c6-eb36-4fd9-94f8-7322c9946abe","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019eeffc-40ba-77c4-a393-8c5d227e0611","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_116":112},"org",{"_11":12,"_109":110,"_111":112,"_70":71,"_113":114,"_115":53},"branch",{"_17":100,"_13":16,"_33":40,"_101":61,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":14,"_108":12},"isOwned",15,"projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Gerry Kluck","avatar","https://lh3.googleusercontent.com/a/ACg8ocLshMIWzsvaGnBJgECSn5b1qWPDMbAkJE0ekSVhfd_huGs2OaH6Ig=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":61,"_13":14,"_45":151,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":-5,"_69":-5,"_70":71,"_72":37,"_73":44,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":152,"_95":153,"_97":154,"_99":53},[148],"files",[148],"counts",{"_137":77,"_138":139,"_140":77,"_31":141,"_142":143},[135],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":136},[35],"pulls","branches",1,"forks",{"_144":146,"_147":77},"connections",{"_144":77,"_145":77},"count","unfilledCount",4,"emptyCount",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":149,"_18":150},[],[35],["D",1782143475164],{"_11":12,"_116":112},{"_11":12,"_109":110,"_111":112,"_70":71,"_113":114,"_115":53},{"_17":100,"_13":16,"_33":40,"_101":61,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":14,"_108":12},"ctx",{"_93":-5,"_132":188,"_189":190,"_191":192,"_193":53,"_194":53,"_195":53,"_196":44,"_197":-5,"_198":-7,"_199":-7,"_200":77,"_201":53,"_202":53,"_203":-5,"_204":53,"_205":53,"_206":53,"_207":-5},"ENV",{"_159":160,"_161":162,"_163":16,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Code