{children}

\n \n \n );\n}\n\n/**\n * Render through `c.html` rather than `new Response(...)`. Returning a bare\n * Response from a handler discards the headers Hono has staged on the context\n * — which silently dropped the Set-Cookie from the auth middleware.\n */\nfunction page(c: Context, node: React.ReactElement, status = 200): Response {\n return c.html(`${renderToStaticMarkup(node)}`, status as 200);\n}\n\n/** Back to the dashboard, keeping the token and an optional flash message. */\nfunction backToDashboard(c: Context, msg?: string): Response {\n const qs = new URLSearchParams({ t: c.get(\"token\") ?? \"\" });\n if (msg) qs.set(\"msg\", msg);\n return c.redirect(`/?${qs}`, 302);\n}\n\n/** Every form posts the token back; nothing here relies on the cookie. */\nfunction TokenField({ token }: { token: string }) {\n return ;\n}\n\nconst STATE_STYLE: Record = {\n open: \"bg-emerald-100 text-emerald-800\",\n full: \"bg-amber-100 text-amber-800\",\n missing: \"bg-slate-200 text-slate-600\",\n};\n\nfunction WatchRow({ w, token }: { w: Watch; token: string }) {\n const on = w.active === 1;\n return (\n \n

{w.label || w.match || \"any class\"}

\n {w.date}\n {w.time ? ` · ${w.time}` : \" · any time\"}\n {w.min_spots > 1 ? ` · needs ${w.min_spots} spots` : \"\"}\n {w.once === 1 ? \" · one-shot\" : \" · standing\"}\n

\n {w.last_state\n ? (\n \n {w.last_state}\n \n )\n : not checked yet}\n {w.last_checked_at ? ` at ${w.last_checked_at}` : \"\"}\n {w.notified_at ? ` · notified ${w.notified_at}` : \"\"}\n

\n \n );\n}\n\nfunction DayBrowser(\n { date, events, token }: { date: string; events: GymEvent[] | null; token: string },\n) {\n return (\n

Browse a day

\n \n \n \n \n\n {events == null ?

Pick a date to see its classes.

: (\n events.length === 0\n ?

No classes published for {date} yet.

\n : (\n

\n {time}\n {name}\n \n {ev.full ? \"full\" : `${ev.vacancy} left`}\n \n

\n )\n )}\n

\n );\n}\n\nfunction Dashboard(\n { watches, date, events, msg, token }: {\n watches: Watch[];\n date: string;\n events: GymEvent[] | null;\n msg: string;\n token: string;\n },\n) {\n const active = watches.filter((w) => w.active === 1);\n const inactive = watches.filter((w) => w.active !== 1);\n return (\n \n

Gym watch

\n CrossFit Black Ships Yoyogi · checks every 15 min · pushes to ntfy topic{\" \"}\n {ntfyTopic()}\n

\n\n {msg\n ?

{msg}

\n : null}\n\n

Active ({active.length})

\n {active.length === 0\n ?

Nothing being watched. The checker idles.

\n :

)}

}\n

\n\n \n\n

Add manually

\n\n {inactive.length > 0\n ? (\n

Stopped ({inactive.length})

)}

\n )\n : null}\n\n \n \n );\n}\n\n// -------------------------------------------------------------------- auth\n\napp.use(\"*\", async (c, next) => {\n if (c.req.path === \"/source\") return next();\n\n const expected = Deno.env.get(\"GYM_UI_TOKEN\");\n if (!expected) {\n return page(\n c,\n \n

Not configured

\n Set the GYM_UI_TOKEN{\" \"}\n environment variable on this val, then reload with{\" \"}\n ?t=<token>.\n

\n ,\n 503,\n );\n }\n\n // Parse the body here and stash it: the request body is a one-shot stream,\n // so the routes read the stashed copy instead of parsing a second time.\n let body: Record = {};\n if (c.req.method === \"POST\") {\n body = await c.req.parseBody();\n c.set(\"body\", body);\n }\n\n const fromQuery = new URL(c.req.url).searchParams.get(\"t\") ?? \"\";\n const fromBody = typeof body.t === \"string\" ? body.t : \"\";\n const fromCookie = getCookie(c, COOKIE) ?? \"\";\n const supplied = fromQuery || fromBody || fromCookie;\n\n if (supplied !== expected) {\n return c.text(\"Not found\", 404);\n }\n\n c.set(\"token\", expected);\n setCookie(c, COOKIE, expected, {\n path: \"/\",\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n maxAge: 60 * 60 * 24 * 365,\n });\n return next();\n});\n\n// ------------------------------------------------------------------ routes\n\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\napp.get(\"/\", async (c) => {\n await ensureSchema();\n const token = c.get(\"token\");\n const url = new URL(c.req.url);\n const date = url.searchParams.get(\"d\") ?? \"\";\n const msg = url.searchParams.get(\"msg\") ?? \"\";\n\n let events: GymEvent[] | null = null;\n let loadError = \"\";\n if (/^\\d{4}-\\d{2}-\\d{2}$/.test(date)) {\n try {\n events = await fetchDay(date);\n } catch (err) {\n events = [];\n loadError = `Could not load ${date}: ${err instanceof Error ? err.message : String(err)}`;\n }\n }\n\n return page(\n c,\n ,\n );\n});\n\napp.get(\"/api/watches\", async (c) => {\n await ensureSchema();\n return c.json({ topic: ntfyTopic(), watches: await listWatches() });\n});\n\napp.post(\"/add\", async (c) => {\n await ensureSchema();\n const body = c.get(\"body\");\n const date = String(body.date ?? \"\").trim();\n const time = String(body.time ?? \"\").trim();\n const match = String(body.match ?? \"\").trim();\n const label = String(body.label ?? \"\").trim() || match;\n const minSpots = Number(body.min_spots ?? 1);\n const once = String(body.standing ?? \"\") !== \"1\";\n\n try {\n await addWatch({ date, time: time || null, match, label, minSpots, once });\n } catch (err) {\n const reason = err instanceof Error ? err.message : String(err);\n return backToDashboard(c, `Could not add watch: ${reason}`);\n }\n const what = `${label || \"any class\"} on ${date}${time ? ` at ${time}` : \"\"}`;\n return backToDashboard(c, `Watching ${what}.`);\n});\n\napp.post(\"/toggle\", async (c) => {\n await ensureSchema();\n const body = c.get(\"body\");\n const on = String(body.active) === \"1\";\n await setActive(Number(body.id), on);\n return backToDashboard(c, on ? \"Watch started.\" : \"Watch stopped.\");\n});\n\napp.post(\"/delete\", async (c) => {\n await ensureSchema();\n await deleteWatch(Number(c.get(\"body\").id));\n return backToDashboard(c, \"Watch deleted.\");\n});\n\napp.post(\"/check\", async (c) => {\n const result = await runCheck();\n const parts = [\n `Checked ${result.activeWatches} watch(es) at ${result.ranAt}.`,\n result.notified > 0 ? `Sent ${result.notified} notification(s).` : \"\",\n ...result.lines.map((l) => `${l.label}: ${l.state}`),\n ...result.errors.map((e) => `Error: ${e}`),\n ].filter(Boolean);\n return backToDashboard(c, parts.join(\" \"));\n});\n\nexport default app.fetch;\n",[141],"c438ad7c-b88e-421d-b778-eaaa825f9706","gym.ts","dfb7045c-87f1-11f1-a052-1607ee4eb77e",2,["D",1784960833525],"// Client for the CrossFit Black Ships Yoyogi booking calendar.\n//\n// The public site (blackships.stores.jp, formerly coubic.com) is a Next.js app\n// behind Cloudflare; the calendar itself is client-rendered, so scraping the\n// HTML gets you an empty shell. The grid is populated from this JSON endpoint,\n// which needs no auth and no browser:\n//\n// GET /reserve/api/v2/merchants//booking_events\n// ?renderer=fullcalendar&start=&end=\n//\n// `start`/`end` are inclusive/exclusive instants; sending them with a +09:00\n// offset keeps day boundaries on Japan time. Times come back as local (JST)\n// \"YYYY-MM-DD HH:MM\" strings, already zero-padded — which is why plain string\n// comparison is safe for both matching and past-event filtering below.\n\nexport const MERCHANT = \"crossfityoyogi\";\nexport const SITE = \"https://blackships.stores.jp\";\nexport const CALENDAR_URL = `${SITE}/reserve/${MERCHANT}/services#pageContent`;\n\nconst API = `${SITE}/reserve/api/v2/merchants/${MERCHANT}/booking_events`;\n\nexport type GymEvent = {\n title: string;\n vacancy: number;\n capacity: number;\n full: boolean;\n waitingList: boolean;\n /** JST local time, \"YYYY-MM-DD HH:MM\". */\n start: string;\n end: string;\n /** Site-relative deep link straight to the booking slot. */\n url: string;\n};\n\n/** Absolute, tappable booking link for an event. */\nexport function bookingUrl(ev: GymEvent): string {\n return ev.url?.startsWith(\"http\") ? ev.url : `${SITE}${ev.url ?? \"\"}`;\n}\n\n/** \"YYYY-MM-DD\" for the given instant in Japan time. */\nexport function jstDate(at: Date = new Date()): string {\n return at.toLocaleDateString(\"en-CA\", { timeZone: \"Asia/Tokyo\" });\n}\n\n/** \"YYYY-MM-DD HH:MM\" for the given instant in Japan time. */\nexport function jstStamp(at: Date = new Date()): string {\n const parts = new Intl.DateTimeFormat(\"en-CA\", {\n timeZone: \"Asia/Tokyo\",\n year: \"numeric\",\n month: \"2-digit\",\n day: \"2-digit\",\n hour: \"2-digit\",\n minute: \"2-digit\",\n hourCycle: \"h23\",\n }).formatToParts(at);\n const get = (type: string) => parts.find((p) => p.type === type)?.value ?? \"00\";\n return `${get(\"year\")}-${get(\"month\")}-${get(\"day\")} ${get(\"hour\")}:${get(\"minute\")}`;\n}\n\n/** Shift a plain \"YYYY-MM-DD\" by whole days without tripping over timezones. */\nexport function addDays(date: string, days: number): string {\n const ms = Date.parse(`${date}T00:00:00Z`) + days * 86_400_000;\n return new Date(ms).toISOString().slice(0, 10);\n}\n\n/** Accepts \"9:15\" or \"09:15\"; returns \"09:15\". Empty input stays empty. */\nexport function padTime(time: string): string {\n const m = time.trim().match(/^(\\d{1,2}):(\\d{2})$/);\n return m ? `${m[1].padStart(2, \"0\")}:${m[2]}` : time.trim();\n}\n\n/** Class names carry a 【※予約制】-style suffix; strip it for display/matching. */\nexport function shortTitle(title: string): string {\n return title.split(/[【\\[]/)[0].replace(/\\s+/g, \" \").trim() || title.trim();\n}\n\nfunction normalize(s: string): string {\n return s.toLowerCase().replace(/\\s+/g, \" \").trim();\n}\n\n/**\n * Fetch every published class from `startDate` up to (not including) `endDate`,\n * both plain \"YYYY-MM-DD\" in Japan time. Dates the gym hasn't published yet\n * simply come back empty rather than erroring.\n */\nexport async function fetchEvents(startDate: string, endDate: string): Promise {\n const qs = new URLSearchParams({\n renderer: \"fullcalendar\",\n start: `${startDate}T00:00:00+09:00`,\n end: `${endDate}T00:00:00+09:00`,\n });\n const res = await fetch(`${API}?${qs}`, {\n headers: {\n Accept: \"application/json\",\n \"Accept-Language\": \"ja,en;q=0.9\",\n // The bare Deno UA gets challenged by Cloudflare on some paths.\n \"User-Agent\":\n \"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 \" +\n \"(KHTML, like Gecko) Chrome/131.0.0.0 Safari/537.36\",\n },\n });\n if (!res.ok) {\n throw new Error(`booking_events ${res.status} for ${startDate}..${endDate}`);\n }\n const body = await res.json();\n if (!Array.isArray(body)) throw new Error(\"booking_events did not return an array\");\n return body as GymEvent[];\n}\n\n/** All classes on a single JST date, in start order. */\nexport async function fetchDay(date: string): Promise {\n const events = await fetchEvents(date, addDays(date, 1));\n return events\n .filter((ev) => ev.start?.startsWith(date))\n .sort((a, b) => a.start.localeCompare(b.start));\n}\n\nexport type WatchCriteria = {\n date: string;\n /** \"HH:MM\" pins an exact class; empty matches any time that day. */\n time?: string | null;\n /** Case-insensitive substring of the class title; empty matches any class. */\n match?: string | null;\n};\n\n/** Classes on `criteria.date` matching the watch, regardless of availability. */\nexport function matchEvents(events: GymEvent[], criteria: WatchCriteria): GymEvent[] {\n const wantTime = criteria.time ? padTime(criteria.time) : \"\";\n const wantMatch = normalize(criteria.match ?? \"\");\n return events.filter((ev) => {\n const [date, time] = (ev.start ?? \"\").split(\" \");\n if (date !== criteria.date) return false;\n if (wantTime && time !== wantTime) return false;\n if (wantMatch && !normalize(ev.title ?? \"\").includes(wantMatch)) return false;\n return true;\n });\n}\n\n/**\n * Of the matched classes, the ones actually bookable right now: not full,\n * enough open spots, and not already under way (a spot freeing up ten minutes\n * into the class is not something to wake someone for).\n */\nexport function openEvents(events: GymEvent[], minSpots: number, now = jstStamp()): GymEvent[] {\n return events.filter(\n (ev) => !ev.full && (ev.vacancy ?? 0) >= Math.max(1, minSpots) && ev.start > now,\n );\n}\n",[148],"06a8dd9f-9c4f-4a2c-91c9-d39594268110","checker.ts","10b6b696-87f3-11f1-b842-1607ee4eb77e",5,["D",1784961345232],"interval","// Cron entrypoint: every 15 minutes (Val.town free-tier minimum), check every\n// active watch and push to ntfy when a full class opens up.\n//\n// Schedule: */15 * * * * (cron runs in UTC; a fixed interval is unaffected)\n// Everything interesting lives in check.ts so the control UI can run the same\n// pass on demand.\n\nimport { runCheck } from \"./check.ts\";\n\nexport default async function () {\n const result = await runCheck();\n\n if (result.activeWatches === 0) {\n console.log(\"no active watches — nothing to do\");\n return;\n }\n\n for (const line of result.lines) {\n console.log(\n `${line.notified ? \"NOTIFIED\" : line.state.toUpperCase().padEnd(8)} ${line.label} :: ${\n line.detail.replace(/\\n/g, \" | \")\n }`,\n );\n }\n console.log(\n `checked ${result.activeWatches} watch(es), notified ${result.notified}, expired ${result.expired}`,\n );\n\n // Surface fetch/push failures as a failed run so they show up in val logs.\n if (result.errors.length > 0) {\n throw new Error(result.errors.join(\"; \"));\n }\n}\n",[155],"e08fe630-c28b-4b1a-8cc6-1027237de7c6","check.ts","0ad06128-87f3-11f1-a071-1607ee4eb77e",4,["D",1784961335331],"// The actual availability check. Shared by the cron handler (checker.ts) and\n// the \"check now\" button in the control UI (main.tsx).\n\nimport {\n bookingUrl,\n CALENDAR_URL,\n fetchDay,\n type GymEvent,\n jstDate,\n jstStamp,\n matchEvents,\n openEvents,\n shortTitle,\n} from \"./gym.ts\";\nimport {\n ensureSchema,\n expirePastWatches,\n listActiveWatches,\n recordCheck,\n recordNotified,\n type Watch,\n} from \"./store.ts\";\n\n/** Unguessable topic = the only auth ntfy has. Rotate by changing this. */\nconst DEFAULT_NTFY_TOPIC = \"paul-gym-watch-4c19e2\";\n\nexport function ntfyTopic(): string {\n return Deno.env.get(\"GYM_NTFY_TOPIC\") || DEFAULT_NTFY_TOPIC;\n}\n\nexport type CheckLine = {\n watchId: number;\n label: string;\n when: string;\n state: \"open\" | \"full\" | \"missing\";\n notified: boolean;\n detail: string;\n};\n\nexport type CheckResult = {\n ranAt: string;\n activeWatches: number;\n expired: number;\n notified: number;\n lines: CheckLine[];\n errors: string[];\n};\n\nfunction describe(w: Watch): string {\n const time = w.time ? ` ${w.time}` : \"\";\n return `${w.label || w.match || \"any class\"} — ${w.date}${time}`;\n}\n\nasync function push(title: string, body: string, click: string): Promise {\n const res = await fetch(`https://ntfy.sh/${ntfyTopic()}`, {\n method: \"POST\",\n headers: {\n Title: title,\n Click: click,\n Priority: \"high\",\n Tags: \"weight_lifter\",\n },\n body,\n });\n if (!res.ok) throw new Error(`ntfy ${res.status}: ${await res.text()}`);\n}\n\nfunction summarise(events: GymEvent[]): string {\n return events\n .map((ev) => {\n const time = ev.start.split(\" \")[1] ?? ev.start;\n const spots = ev.vacancy === 1 ? \"1 spot\" : `${ev.vacancy} spots`;\n return `${time} ${shortTitle(ev.title)} — ${spots} of ${ev.capacity}`;\n })\n .join(\"\\n\");\n}\n\nexport async function runCheck(): Promise {\n await ensureSchema();\n\n const ranAt = jstStamp();\n const today = jstDate();\n const expired = await expirePastWatches(today);\n const watches = await listActiveWatches();\n\n const result: CheckResult = {\n ranAt,\n activeWatches: watches.length,\n expired,\n notified: 0,\n lines: [],\n errors: [],\n };\n if (watches.length === 0) return result;\n\n // One request per distinct date, not per watch — several watches usually\n // share a day.\n const dates = [...new Set(watches.map((w) => w.date))];\n const byDate = new Map();\n await Promise.all(\n dates.map(async (date) => {\n try {\n byDate.set(date, await fetchDay(date));\n } catch (err) {\n result.errors.push(`${date}: ${err instanceof Error ? err.message : String(err)}`);\n }\n }),\n );\n\n for (const w of watches) {\n const events = byDate.get(w.date);\n if (!events) continue; // fetch failed; already recorded in errors\n\n const matched = matchEvents(events, w);\n const open = openEvents(matched, w.min_spots, ranAt);\n const state: CheckLine[\"state\"] = open.length > 0\n ? \"open\"\n : matched.length > 0\n ? \"full\"\n : \"missing\";\n\n const detail = matched.length === 0\n ? \"no matching class published\"\n : summarise(matched);\n\n if (state === \"open\" && w.armed === 1) {\n const first = open[0];\n try {\n await push(\n `Spot open: ${w.label || shortTitle(first.title)}`,\n `${w.date}\\n${summarise(open)}\\n\\nTap to book.`,\n bookingUrl(first) || CALENDAR_URL,\n );\n await recordNotified(w.id, w.once === 1, ranAt);\n result.notified++;\n result.lines.push({\n watchId: w.id,\n label: describe(w),\n when: ranAt,\n state,\n notified: true,\n detail: summarise(open),\n });\n continue;\n } catch (err) {\n // Leave the watch armed so the next run retries the push.\n result.errors.push(\n `watch ${w.id} notify failed: ${err instanceof Error ? err.message : String(err)}`,\n );\n }\n }\n\n await recordCheck(w.id, state, ranAt);\n result.lines.push({\n watchId: w.id,\n label: describe(w),\n when: ranAt,\n state,\n notified: false,\n detail,\n });\n }\n\n return result;\n}\n",[163],"5f073c8b-0d77-4958-8b92-a8ef397c22e7","README.md","2b8956ce-87f1-11f1-9fc0-1607ee4eb77e",["D",1784960531236],"# gym-watch\n\nSource of truth: https://github.com/paul-brenner/toys `vals/gym-watch/`\n",[170],"pulls","forks","envVars",{"_181":143,"_183":54},"connections",{"_181":54,"_182":54},"count","unfilledCount","emptyCount",{"_20":169,"_13":170,"_125":171,"_127":-5,"_128":21,"_129":143,"_131":50,"_22":206,"_29":54,"_133":106,"_135":173,"_137":38,"_138":-5,"_191":207,"_94":208},{"_20":162,"_13":163,"_125":164,"_127":-5,"_128":21,"_129":165,"_131":50,"_22":203,"_29":54,"_133":134,"_135":167,"_137":38,"_138":-5,"_191":204,"_94":205},{"_20":154,"_13":155,"_125":156,"_127":-5,"_128":21,"_129":157,"_131":50,"_22":200,"_29":54,"_133":159,"_135":160,"_137":38,"_138":-5,"_191":201,"_94":202},{"_20":147,"_13":148,"_125":149,"_127":-5,"_128":21,"_129":150,"_131":50,"_22":197,"_29":54,"_133":134,"_135":152,"_137":38,"_138":-5,"_191":198,"_94":199},{"_20":140,"_13":141,"_125":48,"_127":-5,"_128":21,"_129":30,"_131":50,"_22":194,"_29":143,"_133":144,"_135":145,"_137":38,"_138":-5,"_191":195,"_94":196},{"_20":123,"_13":124,"_125":126,"_127":-5,"_128":21,"_129":130,"_131":50,"_22":190,"_29":54,"_133":134,"_135":136,"_137":38,"_138":-5,"_191":192,"_94":193},["D",1784961138871],"children",[],[124],["D",1785021751786],[],[141],["D",1784960833525],[],[148],["D",1784961345232],[],[155],["D",1784961335331],[],[163],["D",1784960531236],[],[170],["D",1784960531219],["D",1789476648181],{"_11":12,"_92":88},{"_11":12,"_85":86,"_87":88,"_45":46,"_89":90,"_91":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_80":-5,"_81":-5,"_82":-5,"_83":14,"_84":12},"ctx",{"_73":-5,"_114":247,"_248":249,"_250":251,"_252":38,"_253":38,"_254":38,"_255":50,"_256":-5,"_257":-7,"_258":-7,"_259":54,"_260":38,"_261":38,"_262":-5,"_263":38,"_264":38,"_265":38,"_266":-5},"ENV",{"_218":219,"_220":221,"_222":26,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246},"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"]

Branches1

Branches
1