[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_146":147,"_148":149},"routes/_app.x.$handle.$name",{"_16":17,"_20":21,"_84":66,"_85":86,"_64":-7,"_87":-5,"_13":88,"_89":90,"_11":91,"_92":93,"_94":95,"_96":-5,"_97":-5,"_98":-5,"_99":26,"_100":101,"_102":26,"_103":-5,"_104":-5,"_105":106},"routes/_app.x.$handle.$name.search.$(branch)",{"_11":12,"_13":14,"_15":-5,"_16":17},"files",[],"project",{"_18":19,"_20":21,"_22":23,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":-5,"_31":-5,"_32":33,"_34":35,"_36":37,"_38":-5,"_39":-5,"_40":41,"_42":43,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":49,"_50":49,"_51":52,"_53":52,"_54":52,"_55":49,"_56":49,"_57":58,"_59":60,"_61":62,"_63":26},"query","handle","wgkluck2","id","bf343fb0-e04f-4039-b7d2-c73fe321e231","name","ymcaRegister","createdAt",["D",1782143475164],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","imageUrl","userId","61abc3c6-eb36-4fd9-94f8-7322c9946abe","pinnedFileId","e2b37540-6e52-11f1-867f-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019eeffc-40ba-77c4-a393-8c5d227e0611","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_16":17,"_83":79},"org",{"_16":17,"_76":77,"_78":79,"_32":33,"_80":81,"_82":26},"branch",{"_64":65,"_20":66,"_18":67,"_68":19,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":-5,"_74":21,"_75":17},"isOwned","version",15,"main","5133b829-7d64-49d1-8064-f2313d1a82b6","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","branchName","path","","adoptOrgId",{"_18":19,"_20":21,"_22":142,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":-5,"_31":-5,"_32":33,"_34":35,"_36":37,"_38":-5,"_39":-5,"_40":41,"_42":43,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":49,"_50":49,"_51":52,"_53":52,"_54":52,"_55":49,"_56":49,"_57":143,"_59":144,"_61":145,"_63":26},"tree",[137],[137],"counts",{"_125":41,"_126":127,"_128":41,"_129":130,"_131":132},"contents",[107],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_18":108,"_20":109,"_110":35,"_111":-5,"_112":67,"_113":114,"_115":37,"_22":116,"_64":117,"_118":119,"_120":121,"_122":26,"_123":-5,"_85":124},"0cf77d5e-11ca-475f-b419-da0b53fe8b5a","main.tsx","fileId","parentId","branchId","branchVersion",14,"latest",["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","label",[109],"pulls","branches",1,"forks","envVars",{"_133":135,"_136":41},"connections",{"_133":41,"_134":41},"count","unfilledCount",4,"emptyCount",{"_18":108,"_20":109,"_110":35,"_111":-5,"_112":67,"_113":114,"_115":37,"_22":138,"_64":117,"_118":119,"_120":121,"_122":26,"_123":-5,"_139":140,"_85":141},["D",1788533167216],"children",[],[109],["D",1782143475164],{"_16":17,"_83":79},{"_16":17,"_76":77,"_78":79,"_32":33,"_80":81,"_82":26},{"_64":65,"_20":66,"_18":67,"_68":19,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":-5,"_74":21,"_75":17},"ctx",{"_57":-5,"_104":179,"_180":181,"_182":183,"_184":26,"_185":26,"_186":26,"_187":37,"_188":-5,"_189":-7,"_190":-7,"_191":41,"_192":26,"_193":26,"_194":-5,"_195":26,"_196":26,"_197":26,"_198":-5},"ENV",{"_150":151,"_152":153,"_154":66,"_155":156,"_157":158,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178},"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"]

Search