[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_157":158,"_159":160},"routes/_app.x.$handle.$name",{"_94":93,"_32":44,"_103":84,"_27":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":48,"_118":119,"_120":48,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":56,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":48},"version",15,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",true,"deletedHere","path","cron.tsx","latestPath","fileId","c7c7897e-a2f0-11f1-8fa3-1607ee4eb77e","name","fileType","interval","content","import main from \"./main.tsx\";\n\nexport default async function() {\n console.log(\"Interval cron triggered\");\n await main();\n}\n","createdAt",["D",1788533182627],"branchVersion","branchId","5133b829-7d64-49d1-8064-f2313d1a82b6","id","bf343fb0-e04f-4039-b7d2-c73fe321e231","ymcaRegister",["D",1782143475164],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","imageUrl","61abc3c6-eb36-4fd9-94f8-7322c9946abe","pinnedFileId","e2b37540-6e52-11f1-867f-1607ee4eb77e","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",{"_94":93,"_102":98},"org",{"_94":93,"_95":96,"_97":98,"_18":54,"_99":100,"_101":48},"branch",{"_13":14,"_32":84,"_42":41,"_85":43,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":44,"_92":93},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","wgkluck2","handle","displayName","Gerry Kluck","avatar","https://lh3.googleusercontent.com/a/ACg8ocLshMIWzsvaGnBJgECSn5b1qWPDMbAkJE0ekSVhfd_huGs2OaH6Ig=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_32":44,"_37":153,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":56,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":154,"_79":155,"_81":156,"_83":48},"tree",[148],"files",[148],"counts",{"_136":61,"_137":138,"_139":61,"_140":141,"_142":143},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":126,"_32":127,"_30":56,"_128":-5,"_40":41,"_39":129,"_130":25,"_37":131,"_13":132,"_33":34,"_35":133,"_24":48,"_134":-5,"_27":135},"0cf77d5e-11ca-475f-b419-da0b53fe8b5a","main.tsx","parentId",14,"latest",["D",1788533167216],10,"/**\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","label",[127],"pulls","branches",1,"forks","envVars",{"_144":146,"_147":61},"connections",{"_144":61,"_145":61},"count","unfilledCount",4,"emptyCount",{"_42":126,"_32":127,"_30":56,"_128":-5,"_40":41,"_39":129,"_130":25,"_37":149,"_13":132,"_33":34,"_35":133,"_24":48,"_134":-5,"_150":151,"_27":152},["D",1788533167216],"children",[],[127],["D",1782143475164],{"_94":93,"_102":98},{"_94":93,"_95":96,"_97":98,"_18":54,"_99":100,"_101":48},{"_13":14,"_32":84,"_42":41,"_85":43,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":44,"_92":93},"ctx",{"_77":-5,"_122":190,"_191":192,"_193":194,"_195":48,"_196":48,"_197":48,"_198":25,"_199":-5,"_200":-7,"_201":-7,"_202":61,"_203":48,"_204":48,"_205":-5,"_206":48,"_207":48,"_208":48,"_209":-5},"ENV",{"_161":162,"_163":164,"_165":84,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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 · v15