[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_256":257,"_258":259},"routes/_app.x.$handle.$name",{"_99":98,"_31":44,"_107":89,"_26":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":24,"_122":123,"_124":58,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_31":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":24},"version",24,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","lib/time-value.test.ts","latestPath","fileId","7a0ab3ea-82d5-11f1-93fa-1607ee4eb77e","name","time-value.test.ts","fileType","script","content","import { timeValue, BUSINESS_HOURS_START_HOUR, BUSINESS_HOURS_END_HOUR } from \"./time-value.ts\";\n\nfunction assertEqual(actual: unknown, expected: unknown, label: string): void {\n\tconst a = JSON.stringify(actual);\n\tconst e = JSON.stringify(expected);\n\tif (a !== e) {\n\t\tthrow new Error(`FAIL: ${label}\\n expected: ${e}\\n actual: ${a}`);\n\t}\n\tconsole.log(`PASS: ${label} → ${a}`);\n}\n\n// Constants\nassertEqual(BUSINESS_HOURS_START_HOUR, 7, \"start hour is 7\");\nassertEqual(BUSINESS_HOURS_END_HOUR, 23, \"end hour is 23\");\n\n// 07:00 Berlin (summer, UTC+2) → x = 0\n// 2026-07-18T05:00:00.000Z is 07:00 CEST\nassertEqual(timeValue(\"2026-07-18T05:00:00.000Z\"), 0, \"07:00 CEST maps to 0\");\n\n// 07:00 Berlin (winter, UTC+1) → x = 0\n// 2026-01-15T06:00:00.000Z is 07:00 CET\nassertEqual(timeValue(\"2026-01-15T06:00:00.000Z\"), 0, \"07:00 CET maps to 0\");\n\n// 15:00 Berlin (summer) → x = 100 (midpoint of 7–23h window)\n// 2026-07-18T13:00:00.000Z is 15:00 CEST\nassertEqual(timeValue(\"2026-07-18T13:00:00.000Z\"), 100, \"15:00 CEST maps to 100\");\n\n// 23:00 Berlin (summer) → x = 200\n// 2026-07-18T21:00:00.000Z is 23:00 CEST\nassertEqual(timeValue(\"2026-07-18T21:00:00.000Z\"), 200, \"23:00 CEST maps to 200\");\n\n// 22:59 Berlin (summer) → x ≈ 199 (just before the end)\n// 2026-07-18T20:59:00.000Z is 22:59 CEST\nassertEqual(timeValue(\"2026-07-18T20:59:00.000Z\"), 199, \"22:59 CEST maps to 199\");\n\n// Overnight point (03:00 Berlin) is clamped to x = 0 (left edge)\n// 2026-07-18T01:00:00.000Z is 03:00 CEST\nassertEqual(timeValue(\"2026-07-18T01:00:00.000Z\"), 0, \"03:00 CEST clamps to 0\");\n\n// Midnight Berlin → clamped to 0\n// 2026-07-17T22:00:00.000Z is 00:00 CEST on 2026-07-18\nassertEqual(timeValue(\"2026-07-17T22:00:00.000Z\"), 0, \"00:00 CEST clamps to 0\");\n\nconsole.log(\"\\nAll tests passed.\");\n","createdAt",["D",1784398881206],"branchVersion","branchId","97a9ba24-d203-4a34-a697-e13cd7bccf7e","id","d8bfb0f0-1676-42ac-a1a4-4ef765725e9b","muenchen-plantscht-v2",["D",1784311508215],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Munich water temps & pool capacity: backend, DB, crons","imageUrl","a57118a1-fd01-4461-99a5-f9521a5efd88","pinnedFileId","0bb3022e-820a-11f1-8221-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","ec9fe592-5d96-4ef4-9e64-c821b2a08c4a","tursoName","d8bfb0f0167642aca1a44ef765725e9b","tursoHostname","d8bfb0f0167642aca1a44ef765725e9b-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789559472742],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_106":102},"org",{"_99":98,"_100":-5,"_101":102,"_18":54,"_103":104,"_105":24},"branch",{"_13":88,"_31":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"isOwned",49,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","fgeierst","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJrNmY5SkJXSVo3QmpSejQxUmJiOFNKSlRuQiJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_31":44,"_37":251,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":252,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":253,"_83":254,"_85":255,"_87":24},"tree",[179,181,183,185,189],"files",[179,180,181,182,183,184,185,186,187,188,189],"counts",{"_169":62,"_170":137,"_171":62,"_172":173,"_174":175},"contents",[129,130,131,132,133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":163,"_31":164,"_29":165,"_136":-5,"_40":41,"_39":166,"_138":58,"_37":167,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_26":168},{"_42":157,"_31":158,"_29":159,"_136":-5,"_40":41,"_39":160,"_138":58,"_37":161,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_26":162},{"_42":151,"_31":152,"_29":153,"_136":-5,"_40":41,"_39":154,"_138":58,"_37":155,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_26":156},{"_42":144,"_31":145,"_29":146,"_136":-5,"_40":41,"_39":147,"_138":58,"_37":148,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_26":150},{"_42":134,"_31":135,"_29":56,"_136":-5,"_40":41,"_39":137,"_138":58,"_37":139,"_13":62,"_33":140,"_35":141,"_23":24,"_142":-5,"_26":143},"4e46ea67-aee0-40a8-9624-92b6f726de3f","main.ts","parentId",1,"latest",["D",1784311508261],"http","export default async function (req: Request): Promise {\n return Response.json({ ok: true, service: \"muenchen-plantscht-v2\" });\n}\n","label",[135],"b6b73857-61aa-45b6-8e94-b812c6db2676","lib","611051dd-f6b0-4259-b11a-ebf7ac5e3ea0",15,["D",1784312705542],"directory",[145],"976a6e28-b4f0-46ab-825c-6a3aaea2870a","db","caca4203-217f-44e5-9a2c-341ad96c7be7",2,["D",1784311938655],[152],"7eb4bc66-14c6-4aa3-a9b9-5469b6fab177","cron","d0f4549d-bbf6-4e80-b297-f7fc8a3e7f9c",16,["D",1784312720344],[158],"5ed2bc11-5bb2-4e1a-9f83-852a4c175573","api","5dee9817-c87b-4937-82db-c075261bbdf5",20,["D",1784313509669],[164],"pulls","branches","forks","envVars",{"_176":62,"_178":62},"connections",{"_176":62,"_177":62},"count","unfilledCount","emptyCount",{"_42":163,"_31":164,"_29":165,"_136":-5,"_40":41,"_39":166,"_138":58,"_37":248,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_191":249,"_26":250},{"_42":239,"_31":240,"_29":241,"_136":165,"_40":41,"_39":242,"_138":24,"_37":243,"_13":154,"_33":140,"_35":244,"_23":24,"_142":245,"_191":246,"_26":247},{"_42":157,"_31":158,"_29":159,"_136":-5,"_40":41,"_39":160,"_138":58,"_37":236,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_191":237,"_26":238},{"_42":228,"_31":229,"_29":230,"_136":159,"_40":41,"_39":160,"_138":58,"_37":231,"_13":62,"_33":232,"_35":233,"_23":24,"_142":-5,"_191":234,"_26":235},{"_42":151,"_31":152,"_29":153,"_136":-5,"_40":41,"_39":154,"_138":58,"_37":225,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_191":226,"_26":227},{"_42":216,"_31":217,"_29":218,"_136":153,"_40":41,"_39":219,"_138":24,"_37":220,"_13":221,"_33":34,"_35":222,"_23":24,"_142":-5,"_191":223,"_26":224},{"_42":144,"_31":145,"_29":146,"_136":-5,"_40":41,"_39":147,"_138":58,"_37":213,"_13":62,"_33":149,"_35":-5,"_23":24,"_142":-5,"_191":214,"_26":215},{"_42":206,"_31":207,"_29":208,"_136":146,"_40":41,"_39":147,"_138":58,"_37":209,"_13":62,"_33":34,"_35":210,"_23":24,"_142":-5,"_191":211,"_26":212},{"_42":202,"_31":32,"_29":30,"_136":146,"_40":41,"_39":14,"_138":24,"_37":203,"_13":62,"_33":34,"_35":36,"_23":24,"_142":-5,"_191":204,"_26":205},{"_42":194,"_31":195,"_29":196,"_136":146,"_40":41,"_39":197,"_138":58,"_37":198,"_13":62,"_33":34,"_35":199,"_23":24,"_142":-5,"_191":200,"_26":201},{"_42":134,"_31":135,"_29":56,"_136":-5,"_40":41,"_39":137,"_138":58,"_37":190,"_13":62,"_33":140,"_35":141,"_23":24,"_142":-5,"_191":192,"_26":193},["D",1784311508261],"children",[],[135],"35e4deb0-4c22-414a-b2d6-41e5f4f674a1","time-value.ts","788dc908-82d5-11f1-9d51-1607ee4eb77e",23,["D",1784398878706],"/**\n * Business-hours window in Berlin local time. Matches the cron guard in\n * lib/business-hours.ts (isGermanBusinessHours: hours >= 7 && hours < 23).\n */\nexport const BUSINESS_HOURS_START_HOUR = 7;\nexport const BUSINESS_HOURS_END_HOUR = 23;\n\nconst SECONDS_PER_HOUR = 3600;\nconst CANVAS_WIDTH = 200;\n\nconst windowStartSeconds =\n\tBUSINESS_HOURS_START_HOUR * SECONDS_PER_HOUR; // 25200\nconst windowEndSeconds =\n\tBUSINESS_HOURS_END_HOUR * SECONDS_PER_HOUR; // 82800\nconst windowDurationSeconds = windowEndSeconds - windowStartSeconds; // 57600\n\n/**\n * Map an ISO timestamp to an x-coordinate in [0, CANVAS_WIDTH] (0–200),\n * where 07:00 Europe/Berlin → 0 and 23:00 Europe/Berlin → 200.\n *\n * Timestamps outside the business-hours window are clamped to the nearest\n * edge so a stray overnight point never produces a negative or >200 x.\n *\n * The Berlin timezone is resolved from the timestamp itself via\n * toLocaleTimeString(\"de-DE\", { timeZone: \"Europe/Berlin\" }), so DST is\n * handled correctly — no fixed UTC offset assumption.\n */\nexport function timeValue(iso: string): number {\n\tconst time = new Date(iso).toLocaleTimeString(\"de-DE\", {\n\t\ttimeZone: \"Europe/Berlin\",\n\t});\n\tconst [hours, minutes] = time.split(\":\");\n\tconst totalSeconds =\n\t\tparseInt(hours) * SECONDS_PER_HOUR + parseInt(minutes) * 60;\n\tconst clamped = Math.max(windowStartSeconds, Math.min(windowEndSeconds, totalSeconds));\n\treturn Math.round(((clamped - windowStartSeconds) / windowDurationSeconds) * CANVAS_WIDTH);\n}\n",[],[145,195],"c4d05464-13a9-42e5-9ad3-3325d6e41bac",["D",1784398881206],[],[145,32],"63212832-fac2-415b-9ff5-cddef63210d0","business-hours.ts","d556390a-820c-11f1-8a02-1607ee4eb77e",["D",1784312705542],"/**\n * Munich / German business-hours guard, ported from v1 cron/german-business-hours.js.\n * Returns true between 07:00 and 23:00 Europe/Berlin time. Used to skip pool\n * occupancy logging overnight when the baths are closed.\n */\nexport function isGermanBusinessHours(now: Date = new Date()): boolean {\n const germanTime = now.toLocaleString(\"en-US\", { timeZone: \"Europe/Berlin\" });\n const hours = new Date(germanTime).getHours();\n return hours >= 7 && hours < 23;\n}\n",[],[145,207],["D",1784312705542],[186,187,188],[145],"8de71868-2950-41b8-b1a2-d29717b894a6","schema.ts","0c3d430c-820b-11f1-b505-1607ee4eb77e",14,["D",1784312692268],3,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n/**\n * Create all tables + indexes. Idempotent: safe to run on every deploy.\n * All timestamps are ISO-8601 UTC strings, e.g. \"2024-06-01T18:00:00Z\".\n */\nexport async function migrate() {\n await sqlite.batch([\n // --- Water temperatures (lakes, rivers, feringasee) ---\n `CREATE TABLE IF NOT EXISTS water_temperatures (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n category_id INTEGER NOT NULL, -- 0 = lakes, 1 = rivers\n measurement_site TEXT NOT NULL,\n body_of_water TEXT NOT NULL,\n measured_at TEXT NOT NULL, -- ISO-8601 UTC\n water_temperature REAL NOT NULL,\n updated_at TEXT NOT NULL -- ISO-8601 UTC\n )`,\n // Upsert key: one reading per site+body+time.\n `CREATE UNIQUE INDEX IF NOT EXISTS idx_water_temperatures_unique\n ON water_temperatures (category_id, measurement_site, body_of_water, measured_at)`,\n // Read path: latest readings per body of water within a category.\n `CREATE INDEX IF NOT EXISTS idx_water_temperatures_read\n ON water_temperatures (category_id, body_of_water, measured_at)`,\n\n // --- Bodies of water catalog (presentation metadata for the UI) ---\n // Auto-populated by the water-temperature scraper (INSERT OR IGNORE by\n // category_id + name). `geopath` is curated by hand afterwards.\n `CREATE TABLE IF NOT EXISTS bodies_of_water (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n category_id INTEGER NOT NULL, -- 0 = lakes, 1 = rivers\n name TEXT NOT NULL, -- matches water_temperatures.body_of_water\n slug TEXT NOT NULL, -- generated from name\n geopath TEXT, -- optional frontend asset, e.g. \"isar.svg\"\n created_at TEXT NOT NULL -- ISO-8601 UTC\n )`,\n `CREATE UNIQUE INDEX IF NOT EXISTS idx_bodies_of_water_unique\n ON bodies_of_water (category_id, name)`,\n `CREATE INDEX IF NOT EXISTS idx_bodies_of_water_slug\n ON bodies_of_water (category_id, slug)`,\n\n // --- Bath areas catalog (SWM pool occupancy) ---\n // Roster comes from the SWM visitorCount feed itself (locations -> areas),\n // so this is auto-populated by the pools cron, not hand-seeded. Each area\n // (Hallenbad / Freibad / Sauna / ...) belongs to a location.\n `CREATE TABLE IF NOT EXISTS bath_areas (\n area_id INTEGER PRIMARY KEY, -- SWM area_id\n area_name TEXT NOT NULL,\n location_id INTEGER NOT NULL, -- SWM location_id\n location_name TEXT NOT NULL,\n active INTEGER NOT NULL DEFAULT 1, -- hide areas without deleting history\n updated_at TEXT NOT NULL -- ISO-8601 UTC\n )`,\n `CREATE INDEX IF NOT EXISTS idx_bath_areas_location\n ON bath_areas (location_id)`,\n\n // --- Pool occupancy history (area-level time series) ---\n `CREATE TABLE IF NOT EXISTS occupancy_log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n area_id INTEGER NOT NULL, -- -> bath_areas.area_id\n customer_amount INTEGER NOT NULL, -- current occupancy\n customer_amount_max INTEGER NOT NULL, -- capacity\n recorded_at TEXT NOT NULL -- ISO-8601 UTC\n )`,\n `CREATE INDEX IF NOT EXISTS idx_occupancy_log_read\n ON occupancy_log (area_id, recorded_at)`,\n ]);\n}\n\n/**\n * Slugify a body-of-water name. Ported verbatim from v1 src/lib/slugify.js so\n * generated slugs match the frontend's expectations (ä→ae, ö→oe, ü→ue, spaces→-).\n */\nexport function slugify(text: string): string {\n const replacements: Record = { \"ä\": \"ae\", \"ö\": \"oe\", \"ü\": \"ue\" };\n text = text.toLowerCase();\n for (const [umlaut, replacement] of Object.entries(replacements)) {\n text = text.split(umlaut).join(replacement);\n }\n return text.replace(/\\s+/g, \"-\");\n}\n\n/**\n * Register any newly-seen bodies of water in the catalog. Called by the water\n * scraper with the (category_id, name) pairs it just observed. INSERT OR IGNORE\n * keeps existing rows (and their curated `geopath`) untouched.\n */\nexport async function upsertBodiesOfWater(\n bodies: { category_id: number; name: string }[],\n): Promise {\n if (bodies.length === 0) return;\n // De-dupe within this batch so we don't issue redundant inserts.\n const seen = new Set();\n const unique = bodies.filter((b) => {\n const key = `${b.category_id}\\u0000${b.name}`;\n if (seen.has(key)) return false;\n seen.add(key);\n return true;\n });\n const now = new Date().toISOString();\n await sqlite.batch(\n unique.map((b) => ({\n sql: `INSERT OR IGNORE INTO bodies_of_water (category_id, name, slug, created_at)\n VALUES (?, ?, ?, ?)`,\n args: [b.category_id, b.name, slugify(b.name), now],\n })),\n );\n}\n\n/**\n * Keep the bath_areas roster in sync with the SWM feed. Upserts area/location\n * names by area_id (so renames propagate) without touching the `active` flag\n * once a row exists — you can deactivate areas by hand and it will stick.\n */\nexport async function upsertBathAreas(\n areas: { area_id: number; area_name: string; location_id: number; location_name: string }[],\n): Promise {\n if (areas.length === 0) return;\n const now = new Date().toISOString();\n await sqlite.batch(\n areas.map((a) => ({\n sql: `INSERT INTO bath_areas (area_id, area_name, location_id, location_name, active, updated_at)\n VALUES (?, ?, ?, ?, 1, ?)\n ON CONFLICT(area_id) DO UPDATE SET\n area_name = excluded.area_name,\n location_id = excluded.location_id,\n location_name = excluded.location_name,\n updated_at = excluded.updated_at`,\n args: [a.area_id, a.area_name, a.location_id, a.location_name, now],\n })),\n );\n}\n",[],[152,217],["D",1784311938655],[184],[152],"6d8aef11-7bc2-48fe-bff3-d7c9f3c1dfa3","pools-capacity.ts","de2a3e3c-820c-11f1-aaf3-1607ee4eb77e",["D",1784312720344],"interval","import { fetch as stdFetch } from \"https://esm.town/v/std/fetch\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { migrate, upsertBathAreas } from \"../db/schema.ts\";\nimport { isGermanBusinessHours } from \"../lib/business-hours.ts\";\n\nconst VISITOR_COUNT_URL = \"https://www.swm.de/.rest/bath/visitorCount\";\n\ninterface SwmArea {\n area_id: number;\n area_name: string;\n customer_amount: number;\n customer_amount_max: number;\n}\ninterface SwmLocation {\n location_id: number;\n location_name: string;\n area_list: SwmArea[];\n}\ninterface SwmResponse {\n return_code: string;\n data: SwmLocation[];\n}\n\n/**\n * Fetch the full SWM bath occupancy feed. A single request (no query params)\n * returns every location with its nested areas and live counts.\n */\nasync function fetchVisitorCounts(): Promise {\n const res = await stdFetch(VISITOR_COUNT_URL, {\n headers: { accept: \"*/*\", \"user-agent\": \"Mozilla/5.0\" },\n });\n if (!res.ok) throw new Error(`SWM visitorCount HTTP ${res.status}`);\n const json = (await res.json()) as SwmResponse;\n if (json.return_code !== \"success\" || !Array.isArray(json.data)) {\n throw new Error(`SWM visitorCount unexpected response: ${JSON.stringify(json).slice(0, 200)}`);\n }\n return json.data;\n}\n\n/**\n * One cron pass: fetch the feed, sync the area roster, and log area-level\n * occupancy. Skips logging outside Munich business hours (baths closed), but\n * still refreshes the roster so new areas are discovered even overnight.\n */\nexport async function recordOccupancy(now: Date = new Date()): Promise<{\n skipped: boolean;\n areas: number;\n rows: number;\n}> {\n await migrate();\n\n const locations = await fetchVisitorCounts();\n\n // Flatten locations -> areas, carrying the parent location metadata.\n const flat = locations.flatMap((loc) =>\n loc.area_list.map((a) => ({\n area_id: a.area_id,\n area_name: a.area_name,\n location_id: loc.location_id,\n location_name: loc.location_name,\n customer_amount: a.customer_amount,\n customer_amount_max: a.customer_amount_max,\n }))\n );\n\n // Keep the roster fresh regardless of the hour.\n await upsertBathAreas(flat);\n\n if (!isGermanBusinessHours(now)) {\n return { skipped: true, areas: flat.length, rows: 0 };\n }\n\n const recorded_at = now.toISOString();\n await sqlite.batch(\n flat.map((a) => ({\n sql: `INSERT INTO occupancy_log (area_id, customer_amount, customer_amount_max, recorded_at)\n VALUES (?, ?, ?, ?)`,\n args: [a.area_id, a.customer_amount, a.customer_amount_max, recorded_at],\n })),\n );\n\n return { skipped: false, areas: flat.length, rows: flat.length };\n}\n\nexport default async function (interval: Interval) {\n const result = await recordOccupancy();\n console.log(\n result.skipped\n ? `Outside business hours — refreshed ${result.areas} areas, logged 0 rows.`\n : `Logged ${result.rows} occupancy rows across ${result.areas} areas.`,\n );\n}\n",[],[158,229],["D",1784312720344],[182],[158],"11df49c5-6fb2-46ea-8790-4169c6c7a7d1","pools.ts","b4a36988-820e-11f1-b7fc-1607ee4eb77e",22,["D",1784313551941],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { line, curveNatural } from \"https://esm.sh/d3-shape@3\";\n\n/**\n * GET /?date=YYYY-MM-DD (date optional, defaults to today in Europe/Berlin)\n *\n * Returns pool occupancy for a single day, grouped location -> areas. Each area\n * carries its intraday series, a `latest` snapshot, and a precomputed d3 SVG\n * path (y = % free) so a dumb client/widget can render it directly.\n *\n * Public + CORS-friendly (Val Town adds Access-Control-Allow-Origin: * by\n * default as long as we don't set CORS headers ourselves).\n */\n\ninterface Row {\n area_id: number;\n area_name: string;\n location_id: number;\n location_name: string;\n customer_amount: number;\n customer_amount_max: number;\n recorded_at: string;\n}\n\n/** % free, v1's metric: 100 - occupancy%. Clamped to [0,100]. */\nfunction capacityFreePct(count: number, max: number): number {\n if (!max || max <= 0) return 0;\n const pct = 100 - Math.round((count / max) * 100);\n return Math.max(0, Math.min(100, pct));\n}\n\n/**\n * Map an ISO timestamp to v1's 0..200 time-of-day scale (Berlin local time),\n * used as the x coordinate of the d3 path.\n */\nfunction timeValue(iso: string): number {\n const time = new Date(iso).toLocaleTimeString(\"de-DE\", { timeZone: \"Europe/Berlin\" });\n const [hours, minutes] = time.split(\":\");\n const totalSeconds = parseInt(hours) * 3600 + parseInt(minutes) * 60;\n return Math.round((totalSeconds / (24 * 60 * 60)) * 200);\n}\n\n/** Today's date (YYYY-MM-DD) in Europe/Berlin. */\nfunction todayBerlin(): string {\n // en-CA gives YYYY-MM-DD\n return new Date().toLocaleDateString(\"en-CA\", { timeZone: \"Europe/Berlin\" });\n}\n\nfunction isValidDate(s: string): boolean {\n return /^\\d{4}-\\d{2}-\\d{2}$/.test(s);\n}\n\n/**\n * Given a Berlin calendar day (YYYY-MM-DD), return the UTC instant bounds\n * [startUtc, endUtc) that cover it. DST-correct: derives Berlin's offset for\n * that specific date instead of assuming a fixed +1/+2.\n */\nfunction berlinDayUtcBounds(date: string): { start: string; end: string } {\n // Offset (minutes) that Berlin is ahead of UTC at a given instant.\n const berlinOffsetMinutes = (at: Date): number => {\n // Format the same instant as Berlin wall-clock, parse back as if UTC,\n // and diff — yields the zone offset for that instant (handles DST).\n const s = at.toLocaleString(\"en-US\", {\n timeZone: \"Europe/Berlin\",\n hour12: false,\n year: \"numeric\",\n month: \"2-digit\",\n day: \"2-digit\",\n hour: \"2-digit\",\n minute: \"2-digit\",\n second: \"2-digit\",\n });\n // s like \"07/17/2026, 20:38:04\"\n const [d, t] = s.split(\", \");\n const [mo, da, yr] = d.split(\"/\").map(Number);\n const [h, mi, se] = t.split(\":\").map(Number);\n const asUtc = Date.UTC(yr, mo - 1, da, h, mi, se);\n return Math.round((asUtc - at.getTime()) / 60000);\n };\n\n // Berlin local midnight of `date`, expressed as a first-guess UTC instant,\n // then corrected by that instant's actual offset.\n const [y, m, d] = date.split(\"-\").map(Number);\n const guess = Date.UTC(y, m - 1, d, 0, 0, 0);\n const offset = berlinOffsetMinutes(new Date(guess));\n const startUtc = guess - offset * 60000;\n const endUtc = startUtc + 24 * 60 * 60 * 1000;\n return { start: new Date(startUtc).toISOString(), end: new Date(endUtc).toISOString() };\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const dateParam = url.searchParams.get(\"date\");\n const date = dateParam && isValidDate(dateParam) ? dateParam : todayBerlin();\n\n // Select the day's rows for active areas. `recorded_at` is stored UTC; the\n // \"day\" is a Berlin calendar day, so filter by that day's UTC bounds\n // (DST-correct, no fixed offset).\n const { start, end } = berlinDayUtcBounds(date);\n const { rows } = (await sqlite.execute({\n sql: `\n SELECT o.area_id, b.area_name, b.location_id, b.location_name,\n o.customer_amount, o.customer_amount_max, o.recorded_at\n FROM occupancy_log o\n JOIN bath_areas b ON b.area_id = o.area_id\n WHERE b.active = 1\n AND o.recorded_at >= ?\n AND o.recorded_at < ?\n ORDER BY b.location_name, b.area_name, o.recorded_at ASC\n `,\n args: [start, end],\n })) as unknown as { rows: Row[] };\n\n // Group location -> area -> series.\n const locMap = new Map;\n }>();\n\n for (const r of rows) {\n let loc = locMap.get(r.location_id);\n if (!loc) {\n loc = { location_id: r.location_id, location_name: r.location_name, areas: new Map() };\n locMap.set(r.location_id, loc);\n }\n let area = loc.areas.get(r.area_id);\n if (!area) {\n area = { area_id: r.area_id, area_name: r.area_name, data: [] };\n loc.areas.set(r.area_id, area);\n }\n area.data.push({\n recorded_at: r.recorded_at,\n customer_amount: r.customer_amount,\n customer_amount_max: r.customer_amount_max,\n capacity_free_pct: capacityFreePct(r.customer_amount, r.customer_amount_max),\n });\n }\n\n const pathGen = line<[number, number]>()\n .x((d) => d[0])\n .y((d) => d[1])\n .curve(curveNatural);\n\n const locations = [...locMap.values()]\n .map((loc) => ({\n location_id: loc.location_id,\n location_name: loc.location_name,\n areas: [...loc.areas.values()].map((a) => {\n const points: [number, number][] = a.data.map((d) => [\n timeValue(d.recorded_at),\n d.capacity_free_pct,\n ]);\n const last = a.data[a.data.length - 1];\n return {\n area_id: a.area_id,\n area_name: a.area_name,\n latest: last\n ? {\n recorded_at: last.recorded_at,\n customer_amount: last.customer_amount,\n customer_amount_max: last.customer_amount_max,\n capacity_free_pct: last.capacity_free_pct,\n }\n : null,\n data: a.data,\n path: pathGen(points) ?? \"\",\n };\n }),\n }))\n .sort((a, b) => a.location_name.localeCompare(b.location_name, \"de\"));\n\n return Response.json(\n { date, locations },\n { headers: { \"Cache-Control\": \"public, max-age=600\" } },\n );\n}\n","muenchen-plantscht-pools",[],[164,240],["D",1784313509669],[180],[164],["D",1784311508215],["D",1789559472742],{"_99":98,"_106":102},{"_99":98,"_100":-5,"_101":102,"_18":54,"_103":104,"_105":24},{"_13":88,"_31":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"ctx",{"_81":-5,"_126":289,"_290":291,"_292":293,"_294":24,"_295":24,"_296":24,"_297":58,"_298":-5,"_299":-7,"_300":-7,"_301":62,"_302":24,"_303":24,"_304":-5,"_305":24,"_306":24,"_307":24,"_308":-5},"ENV",{"_260":261,"_262":263,"_264":89,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276,"_277":278,"_279":280,"_281":282,"_283":284,"_285":286,"_287":288},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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 · v24