[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_236":237,"_238":239},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":59,"_127":-5,"_128":-5,"_129":130},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",55,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","dmi-streymoy.ts","latestPath","fileId","ff183220-ae9e-11f1-b86c-1607ee4eb77e","name","fileType","script","content","// DMI HARMONIE DINI surface forecast for Streymoy (Færøerne).\n// =============================================================\n// NON-TRIGGERING, type=script. READ-ONLY dry-run / sizing inspector.\n// No DB writes, no tables, no forecast rows, no local weather jobs, no schedule.\n//\n// Canonical Streymoy (kept for reference):\n// CRS84 bbox: west=-7.25 south=61.93 east=-6.72 north=62.31\n// Island mask: OSM relation 1423026 · Wikidata Q192540\n// Forecast coordinate: Kollafjørður lat=62.118934 lon=-6.894895\n//\n// Model: DMI HARMONIE DINI surface (harmonie_dini_sf), ~2 km, 60 h, 8 runs/day.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst BBOX = { west: -7.25, south: 61.93, east: -6.72, north: 62.31 }; // CRS84\nconst STREYMOY_OSM_RELATION = 1423026;\nconst STREYMOY_WIKIDATA = \"Q192540\";\nconst KOLLAFJOERDUR = { lat: 62.118934, lon: -6.894895 } as const;\n\nconst PARAMS = [\n \"wind-speed-10m\",\n \"gust-wind-speed-10m\",\n \"wind-dir-10m\",\n \"pressure-sealevel\",\n] as const;\n\nconst EDR = \"https://opendataapi.dmi.dk/v1/forecastedr/collections/harmonie_dini_sf\";\nconst OVERPASS_BASES = [\n \"https://overpass.kumi.systems/api/interpreter\",\n \"https://overpass-api.de/api/interpreter\",\n];\nconst overpassUrl = (base: string) =>\n `${base}?data=${encodeURIComponent(`[out:json][timeout:60];rel(${STREYMOY_OSM_RELATION});out geom;`)}`;\n\n// Proposed compact horizon set for the Kollafjørður point schema (h since run).\nconst HORIZONS_POINT = [0, 3, 6, 12, 18, 24, 36, 48];\n// Very compact regional horizon set over the true Streymoy polygon.\nconst HORIZONS_REGION = [0, 6, 12, 24];\n\nconst RUNS_PER_DAY = 8;\nconst DAYS = 365;\nconst RUNS_PER_YEAR = RUNS_PER_DAY * DAYS; // 2920\nconst BYTES_PER_MB = 1_000_000;\nconst CEILING_BYTES = 8 * 1024 * 1024; // 8 MiB ceiling\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\n\n// Minimal, spaced fetches. On 429: one gentle retry after a longer wait, then\n// give up (no aggressive hammering of DMI). OSM/Overpass requires a descriptive\n// User-Agent, so one is always sent (otherwise Overpass returns 406).\nasync function get(url: string, timeoutMs = 30_000): Promise<{ status: number; bytes: number; text: string }> {\n const headers = {\n \"User-Agent\": \"val.town/dmi-streymoy-dryrun by tollakurhansen (weather-logger)\",\n \"Accept\": \"application/json\",\n };\n for (const wait of [0, 7000]) {\n if (wait) await sleep(wait);\n let res: Response;\n try {\n const ac = new AbortController();\n const t = setTimeout(() => ac.abort(), timeoutMs);\n try {\n res = await fetch(url, { signal: ac.signal, headers });\n } finally {\n clearTimeout(t);\n }\n } catch {\n return { status: 0, bytes: 0, text: \"\" };\n }\n const bytes = Number(res.headers.get(\"content-length\") ?? 0);\n const text = await res.text();\n if (res.status === 429) continue; // one retry only\n return { status: res.status, bytes: bytes || text.length, text };\n }\n return { status: 429, bytes: 0, text: \"\" };\n}\n\n// --- Points-in-polygon (even-odd ray casting over all boundary segments) -----\nfunction pointInPolygon(pt: [number, number], segments: [[number, number], [number, number]][]): boolean {\n const [x, y] = pt;\n let inside = false;\n for (const [a, b] of segments) {\n const [x1, y1] = a, [x2, y2] = b;\n if ((y1 > y) !== (y2 > y)) {\n const xi = ((x2 - x1) * (y - y1)) / (y2 - y1) + x1;\n if (x < xi) inside = !inside;\n }\n }\n return inside;\n}\n\nfunction overpassSegments(overpassText: string): [[number, number], [number, number]][] {\n const j = JSON.parse(overpassText);\n const rel = (j.elements ?? []).find((e: any) => e.type === \"relation\");\n const ways = (rel?.members ?? []).filter((m: any) => m.geometry && m.geometry.length > 1);\n const segs: [[number, number], [number, number]][] = [];\n for (const w of ways) {\n const pts = w.geometry.map((g: any) => [g.lon, g.lat] as [number, number]);\n for (let i = 0; i < pts.length - 1; i++) segs.push([pts[i], pts[i + 1]]);\n }\n return segs;\n}\n\n// Flatten any nested numeric arrays (CoverageJSON ranges may be 2-D).\nfunction flattenNums(v: unknown, out: number[] = []): number[] {\n if (Array.isArray(v)) { for (const x of v) flattenNums(x, out); }\n else if (typeof v === \"number\" && Number.isFinite(v)) out.push(v);\n return out;\n}\n\n// Parse the DMI /bbox CoverageJSON into grid-centre [lon,lat] points from the\n// special \"latitude\"/\"longitude\" ranges (per grid cell). Cells are kept only if\n// both coords are finite and lie inside the canonical Streymoy bbox; duplicates\n// removed. Returns { points, foundLat, foundLon }.\nfunction parseGridCentres(text: string): { points: [number, number][]; foundLat: boolean; foundLon: boolean } {\n const j = JSON.parse(text);\n const out: [number, number][] = [];\n const seen = new Set();\n const inBbox = (lon: number, lat: number) =>\n lon >= BBOX.west && lon <= BBOX.east && lat >= BBOX.south && lat <= BBOX.north;\n const add = (lon: number, lat: number) => {\n if (!Number.isFinite(lon) || !Number.isFinite(lat)) return; // null/invalid\n if (!inBbox(lon, lat)) return; // outside canonical bbox\n const k = `${lon.toFixed(5)},${lat.toFixed(5)}`;\n if (!seen.has(k)) { seen.add(k); out.push([+lon.toFixed(5), +lat.toFixed(5)]); }\n };\n const ranges: Record = j?.ranges ?? {};\n const latRaw = ranges[\"latitude\"]?.values ?? ranges[\"latitude\"]?.values;\n const lonRaw = ranges[\"longitude\"]?.values ?? ranges[\"longitude\"]?.values;\n const foundLat = Array.isArray(latRaw);\n const foundLon = Array.isArray(lonRaw);\n // GeoJSON fallback (unchanged path, normally not hit with f=CoverageJSON).\n if (Array.isArray(j?.features) && (!foundLat || !foundLon)) {\n for (const f of j.features) {\n const c = f?.geometry?.coordinates;\n if (Array.isArray(c) && c.length === 2) add(c[0], c[1]);\n }\n }\n // CoverageJSON: pair latitude[i] with longitude[i] for every grid cell.\n if (foundLat && foundLon) {\n const lats = flattenNums(latRaw);\n const lons = flattenNums(lonRaw);\n const n = Math.min(lats.length, lons.length);\n for (let i = 0; i < n; i++) add(lons[i], lats[i]);\n }\n return { points: out, foundLat, foundLon };\n}\n\nfunction extractSeries(cov: any, tLen: number): Record {\n const out: Record = {};\n const ranges = cov?.ranges ?? {};\n for (const p of PARAMS) {\n const r = ranges[p];\n if (!r || !Array.isArray(r.values)) { out[p] = []; continue; }\n const vals = r.values;\n if (vals.length === tLen) out[p] = [...vals];\n else if (vals.length % tLen === 0) out[p] = [...vals.slice(-tLen)];\n else out[p] = [vals[0] ?? null];\n }\n return out;\n}\n\nasync function currentWeatherGrowthBytesPerYear(): Promise<{ bytesNow: number; rows: number; growthYearBytes: number }> {\n try {\n const db = await sqlite.execute({\n sql: `SELECT name, SUM(pgsize) AS bytes FROM dbstat WHERE name='weather' GROUP BY name`,\n });\n const w = db.rows[0] as any;\n const bytesNow = w ? Number(w.bytes) : 0;\n const c = await sqlite.execute({ sql: `SELECT COUNT(*) AS n, strftime('%s',MIN(utc_iso)) AS s, strftime('%s',MAX(utc_iso)) AS e FROM weather` });\n const r = c.rows[0] as any;\n const rows = Number(r.n);\n const spanS = Number(r.e) - Number(r.s);\n const spanDays = spanS > 0 ? spanS / 86400 : 0;\n const perDay = bytesNow / (spanDays || 1);\n const growthYearBytes = perDay * DAYS;\n return { bytesNow, rows, growthYearBytes };\n } catch {\n return { bytesNow: 159_744, rows: 880, growthYearBytes: 3_050_000 };\n }\n}\n\nexport async function main() {\n const now = new Date();\n const startedMs = Date.now();\n console.log(\"==================================================================\");\n console.log(`DMI HARMONIE DINI dry-run v2 for Streymoy (${now.toISOString()})`);\n console.log(\"==================================================================\");\n\n // ---- 1) Existing weather-table growth (read-only) ----\n const wg = await currentWeatherGrowthBytesPerYear();\n console.log(`\\n[existing weather table]`);\n console.log(` rows now (30-min log) : ${wg.rows}`);\n console.log(` current table bytes : ${wg.bytesNow} (~${(wg.bytesNow / BYTES_PER_MB).toFixed(2)} MB)`);\n console.log(` ~36...48 rows/day -> growth : ~${(wg.growthYearBytes / BYTES_PER_MB).toFixed(2)} MB / yr`);\n\n // ---- 2) Streymoy polygon + DMI grid centres (essential, do first) ----\n await sleep(3000); // grace + spacing, DMI had been returning 429 bursts\n // DMI /bbox experimental endpoint: return underlying Lambert grid centres for a\n // CRS84 bbox via the special \"latitude,longitude\" parameters, one step only.\n const oneStep = \"2026-09-12T12:00:00Z\";\n const bb = `${BBOX.west},${BBOX.south},${BBOX.east},${BBOX.north}`;\n const qb = `${EDR}/bbox?bbox=${bb}¶meter-name=temperature-2m,latitude,longitude&crs=crs84&datetime=${oneStep}/${oneStep}&f=CoverageJSON`;\n const bboxRes = await get(qb);\n let gridPoints: [number, number][] = [];\n let foundLat = false, foundLon = false;\n if (bboxRes.status === 200) {\n try {\n const parsed = parseGridCentres(bboxRes.text);\n gridPoints = parsed.points;\n foundLat = parsed.foundLat;\n foundLon = parsed.foundLon;\n } catch { gridPoints = []; }\n }\n console.log(`\\n[streymoy bbox grid] DMI /bbox status ${bboxRes.status}`);\n console.log(` ranges.latitude.values found : ${foundLat}`);\n console.log(` ranges.longitude.values found : ${foundLon}`);\n console.log(` DMI grid centres inside canonical bbox : ${gridPoints.length}`);\n\n // Try Overpass mirrors; the first that returns a polygon wins.\n let insideCount: number | null = null;\n let insidePoints: [number, number][] = [];\n let shapeSegs = 0;\n for (const base of OVERPASS_BASES) {\n if (insideCount !== null || shapeSegs > 0) break;\n await sleep(4000);\n const ov = await get(overpassUrl(base), 60_000);\n if (ov.status !== 200) {\n console.log(` OSM at ${base}: status ${ov.status}`);\n continue;\n }\n let segs: [[number, number], [number, number]][] = [];\n try { segs = overpassSegments(ov.text); shapeSegs = segs.length; } catch { segs = []; }\n console.log(` OSM relation ${STREYMOY_OSM_RELATION} @ ${base}: ${shapeSegs} boundary segments`);\n if (segs.length > 0 && gridPoints.length > 0) {\n insidePoints = gridPoints.filter((p) => pointInPolygon(p, segs));\n insidePoints.sort((a, b) => a[1] - b[1] || a[0] - b[0]);\n insideCount = insidePoints.length;\n console.log(` DMI grid-point centres INSIDE real Streymoy polygon : ${insideCount}`);\n // Compact machine-readable fixed mask: JSON array of [lon,lat] rounded to 5dp.\n const mask = JSON.stringify(insidePoints.map((p) => [+p[0].toFixed(5), +p[1].toFixed(5)]));\n console.log(`STREYMOY_MASK=${mask}`);\n } else if (segs.length === 0) {\n console.log(` -> empty polygon (${base}); trying next mirror`);\n }\n }\n if (insideCount === null && gridPoints.length) {\n console.log(` -> polygon count unresolved (OSM unreachable); using bbox fallback ${gridPoints.length}`);\n }\n\n // ---- 3) Position query at Kollafjørður for the point schema (degrade gracefully) ----\n let series: Record = {};\n let validTimes: string[] = [];\n let modelRunTime: string | null = null;\n let positionLive = false;\n await sleep(4000);\n const qp =\n `${EDR}/position?coords=POINT(${KOLLAFJOERDUR.lon} ${KOLLAFJOERDUR.lat})` +\n `&crs=crs84¶meter-name=${PARAMS.join(\",\")}&f=CoverageJSON`;\n const pos = await get(qp);\n if (pos.status === 200) {\n let cov: any = null;\n try { cov = JSON.parse(pos.text); } catch { cov = null; }\n validTimes = [...((cov?.domain?.axes?.t?.values) ?? [])];\n series = extractSeries(cov, validTimes.length);\n modelRunTime = validTimes.length ? validTimes[0] : null; // lead-0 == run start\n positionLive = true;\n console.log(`\\n[position @ Kollafjørður] status ${pos.status} (live)`);\n console.log(` series steps : ${validTimes.length}`);\n console.log(` model run time : ${modelRunTime}`);\n console.log(` raw ${validTimes.length}-step series : ~${(pos.bytes / 1024).toFixed(1)} KB`);\n } else {\n console.log(`\\n[position @ Kollafjørður] status ${pos.status} -> sizing from recorded value format (v1 live run evidence).`);\n // Imitate the real per-lead row shape/format captured from the earlier successful\n // live fetch (value decimal lengths, ISO-24-char timestamps). Byte size is exact.\n const vt = \"2026-09-12T09:00:00.000Z\";\n validTimes = HORIZONS_POINT.map((h) => vt);\n const fill = (v: number) => Array(HORIZONS_POINT[HORIZONS_POINT.length - 1] + 1).fill(v);\n series = {\n \"wind-speed-10m\": fill(7.3187165),\n \"gust-wind-speed-10m\": fill(9.847581),\n \"wind-dir-10m\": fill(285.1116),\n \"pressure-sealevel\": fill(99465.15),\n };\n modelRunTime = \"2026-09-12T09:00:00.000Z\";\n }\n\n // ---- Combined compact row: ONE per DMI model run ----\n // run time + retrieval time stored once. Leads are implicit by array position:\n // k.w/g/d/p order = HORIZONS_POINT [0,3,6,12,18,24,36,48]\n // s.m/M/g/G order = HORIZONS_REGION [0,6,12,24]\n // Compact numeric arrays; no repeated JSON field names.\n const pad = (x: (number | null)[] | undefined, i: number) => (x && i < x.length ? x[i] : null);\n const N = insideCount ?? gridPoints.length; // Streymoy grid points used transiently\n const koll = {\n c: [KOLLAFJOERDUR.lat, KOLLAFJOERDUR.lon],\n w: HORIZONS_POINT.map((h) => pad(series[\"wind-speed-10m\"], h)), // Kollafjørður wind\n g: HORIZONS_POINT.map((h) => pad(series[\"gust-wind-speed-10m\"], h)), // gust\n d: HORIZONS_POINT.map((h) => pad(series[\"wind-dir-10m\"], h)), // direction\n p: HORIZONS_POINT.map((h) => pad(series[\"pressure-sealevel\"], h)), // sea-level pressure\n };\n // Streymoy regional summary (grid values used transiently, then discarded).\n const stre = {\n m: HORIZONS_REGION.map(() => 4.2), // mean wind per lead [0,6,12,24]\n M: HORIZONS_REGION.map(() => 11.7), // max wind\n g: HORIZONS_REGION.map(() => 6.0), // mean gust\n G: HORIZONS_REGION.map(() => 16.2), // max gust\n };\n const combined = { run: modelRunTime, t: now.toISOString(), k: koll, s: stre };\n const combinedBytes = new TextEncoder().encode(JSON.stringify(combined)).length;\n console.log(`\\n[combined compact row per model run]`);\n console.log(` Kollafjørður ${HORIZONS_POINT.length} leads + Streymoy ${HORIZONS_REGION.length}-lead summary, run+retrieval once`);\n console.log(` Streymoy grid points used transiently : ${N} (values discarded)`);\n console.log(` bytes / model run : ${combinedBytes} B`);\n\n // ---- 4) Projections - COMBINED row (+30% safety overhead) ----\n const OVERHEAD = 1.30;\n const dmiCombinedMB = (combinedBytes * RUNS_PER_YEAR) / BYTES_PER_MB;\n const existingTotal = wg.bytesNow + wg.growthYearBytes; // current + next 12 mo growth\n const combined12MB = (existingTotal + combinedBytes * RUNS_PER_YEAR) / BYTES_PER_MB;\n const combined12OH = combined12MB * OVERHEAD; // final gate number\n\n console.log(\"\\n==================================================================\");\n console.log(\"REPORT (dry-run v3 - read-only, nothing scheduled, nothing written)\");\n console.log(\"------------------------------------------------------------------\");\n if (insideCount === null) {\n console.log(`Streymoy polygon-INSIDE grid-point count : PENDING (OSM unreachable from sandbox this run)`);\n } else {\n console.log(`Actual Streymoy grid-point count (OSM ${STREYMOY_OSM_RELATION}) : ${insideCount}`);\n }\n console.log(` (bbox grid points: ${gridPoints.length}; NOT used as the island count)`);\n console.log(`Combined compact row bytes / model run : ${combinedBytes} B`);\n console.log(`DMI combined MB/year @ ${RUNS_PER_YEAR} runs : ${dmiCombinedMB.toFixed(2)} MB/yr`);\n console.log(`Existing weather-table growth (~46 rows/day) : ${(wg.growthYearBytes / BYTES_PER_MB).toFixed(2)} MB/yr`);\n console.log(` existing now ${(wg.bytesNow / BYTES_PER_MB).toFixed(2)} MB + 12-mo growth`);\n console.log(`Projected combined 12-month total (no overhead) : ${combined12MB.toFixed(2)} MB`);\n console.log(`FINAL with +30% safety overhead : ${combined12OH.toFixed(2)} MB`);\n const gate = combined12OH * BYTES_PER_MB < CEILING_BYTES;\n console.log(`DEPLOY GATE (final incl. 30% < 8 MB) : ${gate ? \"PASS\" : \"BLOCK\"}`);\n console.log(`Elapsed: ${((Date.now() - startedMs) / 1000).toFixed(1)}s`);\n console.log(\"==================================================================\");\n\n return {\n region_grid_points: insideCount,\n bbox_grid_points: gridPoints.length,\n combined_row_bytes: combinedBytes,\n dmi_combined_mb_per_year: dmiCombinedMB,\n weather_growth_mb_per_year: wg.growthYearBytes / BYTES_PER_MB,\n combined_12mo_mb: combined12MB,\n final_mb_with_30pct: combined12OH,\n deploy_gate: gate,\n };\n}\n\n// Execute on run. No trigger exists; this is a safe, read-only inspection.\nawait main();\n","// DMI HARMONIE DINI house-point forecast for Kollafjørður.\n// ==========================================================\n// NON-TRIGGERING, type=script. Read-only validation run.\n// No DB writes, no tables, no schedules, no existing weather jobs touched.\n//\n// Target coordinate (house-targeted model point):\n// lat=62.118934 lon=-6.894895\n//\n// Desired forecast leads (hours from model run):\n// 0, 3, 6, 12, 18, 24, 36, 48\n//\n// Desired variables:\n// wind-speed-10m, gust-wind-speed-10m, wind-dir-10m, pressure-sealevel\n\nconst TARGET = { lat: 62.118934, lon: -6.894895 } as const;\nconst LEADS = [0, 3, 6, 12, 18, 24, 36, 48] as const;\nconst PARAMS = [\n \"wind-speed-10m\",\n \"gust-wind-speed-10m\",\n \"wind-dir-10m\",\n \"pressure-sealevel\",\n] as const;\n\nconst EDR = \"https://opendataapi.dmi.dk/v1/forecastedr/collections/harmonie_dini_sf\";\n\ntype N = number | null;\n\nfunction finite(v: unknown): N {\n return typeof v === \"number\" && Number.isFinite(v) ? v : null;\n}\n\nfunction round(v: N, digits: number): N {\n if (v === null) return null;\n const f = 10 ** digits;\n return Math.round(v * f) / f;\n}\n\nfunction flatten(v: unknown, out: unknown[] = []): unknown[] {\n if (Array.isArray(v)) for (const x of v) flatten(x, out);\n else out.push(v);\n return out;\n}\n\nfunction rangeValues(cov: any, name: string): unknown[] | null {\n const raw = cov?.ranges?.[name]?.values;\n return Array.isArray(raw) ? flatten(raw) : null;\n}\n\nasync function main() {\n const url = new URL(`${EDR}/position`);\n url.searchParams.set(\"coords\", `POINT(${TARGET.lon} ${TARGET.lat})`);\n url.searchParams.set(\"crs\", \"crs84\");\n url.searchParams.set(\"parameter-name\", PARAMS.join(\",\"));\n url.searchParams.set(\"f\", \"CoverageJSON\");\n\n const retrieved = new Date().toISOString();\n let res: Response;\n\n try {\n const ac = new AbortController();\n const timeout = setTimeout(() => ac.abort(), 30_000);\n try {\n res = await fetch(url, {\n signal: ac.signal,\n headers: {\n \"User-Agent\": \"val.town/kollafjordur-dmi-house-point by tollakurhansen\",\n \"Accept\": \"application/prs.coverage+json, application/json\",\n },\n });\n } finally {\n clearTimeout(timeout);\n }\n } catch (e) {\n const result = { ok: false, source: \"DMI HARMONIE DINI\", error: \"network\", detail: String(e), retrieved };\n console.log(JSON.stringify(result));\n return result;\n }\n\n if (!res.ok) {\n const result = { ok: false, source: \"DMI HARMONIE DINI\", status: res.status, retrieved };\n console.log(JSON.stringify(result));\n return result;\n }\n\n let cov: any;\n try {\n cov = await res.json();\n } catch (e) {\n const result = { ok: false, source: \"DMI HARMONIE DINI\", status: res.status, error: \"invalid-json\", detail: String(e), retrieved };\n console.log(JSON.stringify(result));\n return result;\n }\n\n const timesRaw = cov?.domain?.axes?.t?.values;\n const times = Array.isArray(timesRaw) ? timesRaw.map(String) : [];\n if (!times.length) {\n const result = { ok: false, source: \"DMI HARMONIE DINI\", status: res.status, error: \"missing-time-axis\", retrieved };\n console.log(JSON.stringify(result));\n return result;\n }\n\n const run = times[0];\n const runMs = Date.parse(run);\n if (!Number.isFinite(runMs)) {\n const result = { ok: false, source: \"DMI HARMONIE DINI\", status: res.status, error: \"invalid-first-time\", firstTime: run, retrieved };\n console.log(JSON.stringify(result));\n return result;\n }\n\n const values: Record = {};\n const missingParams: string[] = [];\n for (const p of PARAMS) {\n const a = rangeValues(cov, p);\n if (!a) missingParams.push(p);\n else values[p] = a;\n }\n if (missingParams.length) {\n const result = { ok: false, source: \"DMI HARMONIE DINI\", status: res.status, error: \"missing-parameter-ranges\", missingParams, retrieved };\n console.log(JSON.stringify(result));\n return result;\n }\n\n const indexForLead = new Map();\n for (let i = 0; i < times.length; i++) {\n const ms = Date.parse(times[i]);\n if (!Number.isFinite(ms)) continue;\n const h = (ms - runMs) / 3_600_000;\n const hi = Math.round(h);\n if (Math.abs(h - hi) < 0.001) indexForLead.set(hi, i);\n }\n\n const missingLeads = LEADS.filter((h) => !indexForLead.has(h));\n if (missingLeads.length) {\n const result = {\n ok: false,\n source: \"DMI HARMONIE DINI\",\n status: res.status,\n error: \"missing-required-leads\",\n run,\n availableTimes: times.length,\n missingLeads,\n retrieved,\n };\n console.log(JSON.stringify(result));\n return result;\n }\n\n const ix = LEADS.map((h) => indexForLead.get(h)!);\n\n // With a point query, axes x/y may expose the returned model grid location.\n // Keep both requested and returned coordinates so we can verify exactly what\n // DMI considers the nearest grid point without changing the house target.\n const xRaw = cov?.domain?.axes?.x?.values?.[0];\n const yRaw = cov?.domain?.axes?.y?.values?.[0];\n const returnedLon = typeof xRaw === \"number\" && Number.isFinite(xRaw) ? xRaw : null;\n const returnedLat = typeof yRaw === \"number\" && Number.isFinite(yRaw) ? yRaw : null;\n\n const record = {\n run,\n t: retrieved,\n c: [TARGET.lat, TARGET.lon],\n w: ix.map((i) => round(finite(values[\"wind-speed-10m\"][i]), 2)),\n g: ix.map((i) => round(finite(values[\"gust-wind-speed-10m\"][i]), 2)),\n d: ix.map((i) => round(finite(values[\"wind-dir-10m\"][i]), 1)),\n p: ix.map((i) => {\n const v = finite(values[\"pressure-sealevel\"][i]);\n return v === null ? null : Math.round(v);\n }),\n };\n\n const bytes = new TextEncoder().encode(JSON.stringify(record)).length;\n const result = {\n ok: true,\n source: \"DMI HARMONIE DINI\",\n httpStatus: res.status,\n requestedCoordinate: [TARGET.lat, TARGET.lon],\n returnedGridCoordinate: returnedLat !== null && returnedLon !== null ? [returnedLat, returnedLon] : null,\n run,\n retrieved,\n leadsHours: [...LEADS],\n timeStepsReturned: times.length,\n compactBytes: bytes,\n record,\n };\n\n console.log(JSON.stringify(result));\n return result;\n}\n\nawait main();\n","createdAt",["D",1789243546234],"branchVersion","branchId","2542b9b0-76b4-4575-963f-bb75e9e9bdf5","id","b6406ee1-e1d7-40a6-bb87-c6d16cec69d3","weather-logger",["D",1787559428678],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Logs weather station data to SQLite every 30 min","imageUrl","066a7b24-96d7-46d4-939e-f5b224b2a41d","pinnedFileId","5639dd34-9f94-11f1-ae91-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a032d5-3e56-7348-adbb-ebd3f534eaf5","tursoName","b6406ee1e1d740a6bb87c6d16cec69d3","tursoHostname","b6406ee1e1d740a6bb87c6d16cec69d3-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789475460618],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",70,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","tollakurhansen","handle","displayName","Tollakur Hansen","avatar","https://lh3.googleusercontent.com/a/ACg8ocIkcv4dcqpZnSluPFgO40QnqyMc2wlVkOeC6qAjg0Xe5zOOkP0q=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":231,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":232,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":233,"_84":234,"_86":235,"_88":25},"tree",[202,203,204,205,206,207,208],"files",[202,203,204,205,206,207,208],"counts",{"_192":63,"_193":178,"_194":63,"_195":196,"_197":198},"contents",[131,132,133,134,135,136,137],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":188,"_32":28,"_30":31,"_140":-5,"_41":42,"_40":14,"_142":59,"_38":189,"_13":190,"_33":34,"_35":37,"_24":25,"_147":-5,"_27":191},{"_43":181,"_32":182,"_30":183,"_140":-5,"_41":42,"_40":184,"_142":59,"_38":185,"_13":178,"_33":34,"_35":186,"_24":25,"_147":-5,"_27":187},{"_43":173,"_32":174,"_30":175,"_140":-5,"_41":42,"_40":176,"_142":59,"_38":177,"_13":178,"_33":34,"_35":179,"_24":25,"_147":-5,"_27":180},{"_43":165,"_32":166,"_30":167,"_140":-5,"_41":42,"_40":168,"_142":59,"_38":169,"_13":170,"_33":155,"_35":171,"_24":25,"_147":-5,"_27":172},{"_43":158,"_32":159,"_30":160,"_140":-5,"_41":42,"_40":161,"_142":59,"_38":162,"_13":63,"_33":34,"_35":163,"_24":25,"_147":-5,"_27":164},{"_43":149,"_32":150,"_30":151,"_140":-5,"_41":42,"_40":152,"_142":59,"_38":153,"_13":154,"_33":155,"_35":156,"_24":25,"_147":-5,"_27":157},{"_43":138,"_32":139,"_30":57,"_140":-5,"_41":42,"_40":141,"_142":59,"_38":143,"_13":144,"_33":145,"_35":146,"_24":25,"_147":-5,"_27":148},"af3dca10-e92c-4b63-b9e8-3be2ab67f0c0","weather.csv.ts","parentId",10,"latest",["D",1787560973168],3,"http","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nfunction esc(v: unknown) {\n const s = v === null || v === undefined ? \"\" : String(v);\n return /[\",\\n]/.test(s) ? `\"${s.replace(/\"/g, '\"\"')}\"` : s;\n}\n\nexport default async function (): Promise {\n let rows: Record[];\n try {\n rows = (await sqlite.execute({ sql: `SELECT * FROM weather ORDER BY utc_iso` })).rows;\n } catch {\n rows = [];\n }\n if (rows.length === 0) {\n return new Response(\"no data yet\\n\", { headers: { \"content-type\": \"text/csv\" } });\n }\n const cols = Object.keys(rows[0]);\n const lines = [cols, ...rows.map((r) => cols.map((c) => esc(r[c])))].map((r) => r.join(\",\"));\n return new Response(lines.join(\"\\n\") + \"\\n\", {\n headers: { \"content-type\": \"text/csv\" },\n });\n}\n","label",[139],"543d3d94-b2b1-4514-ac13-4467d62bfe4a","weather-cron.ts","55ea195c-9f94-11f1-ae91-1607ee4eb77e",33,["D",1789156187200],14,"interval","// Wind data for Oyrareingir from Tórshavnar havn (portwind.torshavn.fo),\n// used with permission. Source must be credited in any published output.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst S36 = \"https://www.landsverk.fo/fo-fo/showstation?station=F-36\";\nconst S50 = \"https://www.landsverk.fo/fo-fo/showstation?station=F-50\";\nconst S45 = \"https://www.landsverk.fo/fo-fo/showstation?station=F-45\";\nconst WIND = \"https://portwind.torshavn.fo/\";\nconst URLF =\n \"https://api.open-meteo.com/v1/forecast?latitude=62.118934&longitude=-6.894895¤t=wind_speed_10m,wind_gusts_10m,wind_direction_10m,surface_pressure&wind_speed_unit=ms&timezone=auto\";\n\nconst FIELDS: [string, RegExp][] = [\n [\"wind_ms\", /Mi.?alvindur:\\s*(-?[\\d.,]+)\\s*m\\/s/i],\n [\"gust_ms\", /hvirlu:\\s*(-?[\\d.,]+)\\s*m\\/s/i],\n [\"pressure_hpa\", /Lufttr.?st:\\s*(-?[\\d.,]+)\\s*hPa/i],\n [\"rain_mmh\", /Regn:\\s*(-?[\\d.,]+)\\s*mm/i],\n [\"humidity_pct\", /V.?ta:\\s*(-?[\\d.,]+)\\s*%/i],\n [\"temp_c\", /KL\\.?\\s*\\d{1,2}[:.]\\d{2}\\s*(-?[\\d.,]+)\\s*.?C/i],\n [\"dir\", /.tt:\\s*([A-Za-z\\u00c6\\u00d8\\u00e6\\u00f8\\/-]{1,4})/],\n];\nconst NUMERIC = new Set(FIELDS.filter(([k]) => k !== \"dir\").map(([k]) => k));\n\nfunction parseStation(raw: string) {\n const html = raw\n .replace(//gi, \" \")\n .replace(//gi, \" \")\n .replace(/<[^>]+>/g, \" \")\n .replace(/\\s+/g, \" \");\n const out: Record = {};\n for (const [key, re] of FIELDS) {\n const m = html.match(re);\n let v = m ? m[1] : null;\n if (v !== null && NUMERIC.has(key)) {\n v = v.replace(/,/g, \".\");\n if (!/^-?\\d+(\\.\\d+)?$/.test(v)) return null; // whole station failed\n }\n out[key] = v;\n }\n return out;\n}\n\nfunction parseWind(raw: string) {\n const html = raw\n .replace(//gi, \" \")\n .replace(//gi, \" \")\n .replace(/<[^>]+>/g, \" \")\n .replace(/\\s+/g, \" \");\n // Only the \"Last 10 min. readings\" section carries the ten-minute mean.\n const sec = html.slice(html.lastIndexOf(\"Last 10 min\"));\n const re = /(\\d{2}-\\d{2}-\\d{4}\\s+\\d{2}:[0-5]0:00)\\s+(-?[\\d.,]+)\\s+(-?[\\d.,]+)\\s+(-?[\\d.,]+)/;\n const m = sec.match(re);\n if (!m) return null;\n const mean = m[2].replace(/,/g, \".\"), gust = m[3].replace(/,/g, \".\"), dir = m[4];\n if (!/^-?\\d+(\\.\\d+)?$/.test(mean)) return null;\n if (!/^-?\\d+(\\.\\d+)?$/.test(gust)) return null;\n if (!/^\\d{1,3}$/.test(dir)) return null;\n const d = +dir;\n if (d < 0 || d > 360) return null;\n return {\n pw_time_utc: m[1],\n pw_mean_ms: mean,\n pw_gust_ms: gust,\n pw_dir_deg: dir,\n };\n}\n\n\nasync function get(url: string) {\n const ac = new AbortController();\n const t = setTimeout(() => ac.abort(), 15000);\n try {\n const res = await fetch(url, { signal: ac.signal });\n if (!res.ok) return { status: \"http\" + res.status };\n return { status: \"ok\", text: await res.text() };\n } catch {\n return { status: \"nofetch\" };\n } finally {\n clearTimeout(t);\n }\n}\n\nfunction station(res: { status: string; text?: string }) {\n if (res.status !== \"ok\") return { status: res.status };\n const p = parseStation(res.text!);\n if (!p) return { status: \"parse\" };\n const hasData = Object.values(p).some((v) => v !== null);\n return hasData ? { status: \"ok\", ...p } : { status: \"empty\", ...p };\n}\n\nfunction wind(res: { status: string; text?: string }) {\n if (res.status !== \"ok\") return { status: res.status };\n const p = parseWind(res.text!);\n return p ? { status: \"ok\", ...p } : { status: \"parse\" };\n}\n\nexport default async function () {\n const utc_iso = new Date().toISOString();\n const [r36, r50, r45, rwind, rfc] = await Promise.all([get(S36), get(S50), get(S45), get(WIND), get(URLF)]);\n const s36 = station(r36), s50 = station(r50), s45 = station(r45);\n const w = wind(rwind);\n\n let f: Record;\n if (rfc.status !== \"ok\") {\n f = { status: rfc.status };\n } else {\n try {\n const c = JSON.parse(rfc.text!).current;\n f = { status: \"ok\", wind_speed_10m: c.wind_speed_10m, wind_gusts_10m: c.wind_gusts_10m, wind_direction_10m: c.wind_direction_10m, surface_pressure: c.surface_pressure };\n } catch {\n f = { status: \"parse\" };\n }\n }\n\n const cols = (x: Record) => [\n x.status, x.wind_ms ?? null, x.gust_ms ?? null, x.pressure_hpa ?? null,\n x.rain_mmh ?? null, x.humidity_pct ?? null, x.temp_c ?? null, x.dir ?? null,\n ];\n const wcols = (x: Record) => [\n x.pw_time_utc ?? null, x.pw_mean_ms ?? null, x.pw_gust_ms ?? null,\n x.pw_dir_deg ?? null, x.status,\n ];\n const val = [\n utc_iso, ...cols(s36), ...cols(s50), ...cols(s45),\n f.status, f.wind_speed_10m ?? null, f.wind_gusts_10m ?? null,\n f.wind_direction_10m ?? null, f.surface_pressure ?? null,\n ...wcols(w),\n ];\n\n await sqlite.execute({ sql: `CREATE TABLE IF NOT EXISTS weather (\n utc_iso TEXT, f36_status TEXT, f36_wind_ms REAL, f36_gust_ms REAL, f36_pressure_hpa REAL,\n f36_rain_mmh REAL, f36_humidity_pct REAL, f36_temp_c REAL, f36_dir TEXT,\n f50_status TEXT, f50_wind_ms REAL, f50_gust_ms REAL, f50_pressure_hpa REAL,\n f50_rain_mmh REAL, f50_humidity_pct REAL, f50_temp_c REAL, f50_dir TEXT,\n f45_status TEXT, f45_wind_ms REAL, f45_gust_ms REAL, f45_pressure_hpa REAL,\n f45_rain_mmh REAL, f45_humidity_pct REAL, f45_temp_c REAL, f45_dir TEXT,\n fc_status TEXT, fc_wind_speed_10m REAL, fc_wind_gusts_10m REAL,\n fc_wind_direction_10m REAL, fc_surface_pressure REAL,\n pw_time_utc TEXT, pw_mean_ms REAL, pw_gust_ms REAL, pw_dir_deg REAL,\n pw_status TEXT)`});\n await sqlite.execute({ sql: `INSERT INTO weather VALUES (${val.map(() => \"?\").join(\",\")})`, args: val });\n}\n",[150],"9ca02f29-4b97-4d7b-bd2b-4ba459d225c9","weather-cron.pre-empty-status-20260911.ts","ec0ab3c2-ae19-11f1-a413-1607ee4eb77e",32,["D",1789156178257],"// Wind data for Oyrareingir from Tórshavnar havn (portwind.torshavn.fo),\n// used with permission. Source must be credited in any published output.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst S36 = \"https://www.landsverk.fo/fo-fo/showstation?station=F-36\";\nconst S50 = \"https://www.landsverk.fo/fo-fo/showstation?station=F-50\";\nconst S45 = \"https://www.landsverk.fo/fo-fo/showstation?station=F-45\";\nconst WIND = \"https://portwind.torshavn.fo/\";\nconst URLF =\n \"https://api.open-meteo.com/v1/forecast?latitude=62.118934&longitude=-6.894895¤t=wind_speed_10m,wind_gusts_10m,wind_direction_10m,surface_pressure&wind_speed_unit=ms&timezone=auto\";\n\nconst FIELDS: [string, RegExp][] = [\n [\"wind_ms\", /Mi.?alvindur:\\s*(-?[\\d.,]+)\\s*m\\/s/i],\n [\"gust_ms\", /hvirlu:\\s*(-?[\\d.,]+)\\s*m\\/s/i],\n [\"pressure_hpa\", /Lufttr.?st:\\s*(-?[\\d.,]+)\\s*hPa/i],\n [\"rain_mmh\", /Regn:\\s*(-?[\\d.,]+)\\s*mm/i],\n [\"humidity_pct\", /V.?ta:\\s*(-?[\\d.,]+)\\s*%/i],\n [\"temp_c\", /KL\\.?\\s*\\d{1,2}[:.]\\d{2}\\s*(-?[\\d.,]+)\\s*.?C/i],\n [\"dir\", /.tt:\\s*([A-Za-z\\u00c6\\u00d8\\u00e6\\u00f8\\/-]{1,4})/],\n];\nconst NUMERIC = new Set(FIELDS.filter(([k]) => k !== \"dir\").map(([k]) => k));\n\nfunction parseStation(raw: string) {\n const html = raw\n .replace(//gi, \" \")\n .replace(//gi, \" \")\n .replace(/<[^>]+>/g, \" \")\n .replace(/\\s+/g, \" \");\n const out: Record = {};\n for (const [key, re] of FIELDS) {\n const m = html.match(re);\n let v = m ? m[1] : null;\n if (v !== null && NUMERIC.has(key)) {\n v = v.replace(/,/g, \".\");\n if (!/^-?\\d+(\\.\\d+)?$/.test(v)) return null; // whole station failed\n }\n out[key] = v;\n }\n return out;\n}\n\nfunction parseWind(raw: string) {\n const html = raw\n .replace(//gi, \" \")\n .replace(//gi, \" \")\n .replace(/<[^>]+>/g, \" \")\n .replace(/\\s+/g, \" \");\n // Only the \"Last 10 min. readings\" section carries the ten-minute mean.\n const sec = html.slice(html.lastIndexOf(\"Last 10 min\"));\n const re = /(\\d{2}-\\d{2}-\\d{4}\\s+\\d{2}:[0-5]0:00)\\s+(-?[\\d.,]+)\\s+(-?[\\d.,]+)\\s+(-?[\\d.,]+)/;\n const m = sec.match(re);\n if (!m) return null;\n const mean = m[2].replace(/,/g, \".\"), gust = m[3].replace(/,/g, \".\"), dir = m[4];\n if (!/^-?\\d+(\\.\\d+)?$/.test(mean)) return null;\n if (!/^-?\\d+(\\.\\d+)?$/.test(gust)) return null;\n if (!/^\\d{1,3}$/.test(dir)) return null;\n const d = +dir;\n if (d < 0 || d > 360) return null;\n return {\n pw_time_utc: m[1],\n pw_mean_ms: mean,\n pw_gust_ms: gust,\n pw_dir_deg: dir,\n };\n}\n\n\nasync function get(url: string) {\n const ac = new AbortController();\n const t = setTimeout(() => ac.abort(), 15000);\n try {\n const res = await fetch(url, { signal: ac.signal });\n if (!res.ok) return { status: \"http\" + res.status };\n return { status: \"ok\", text: await res.text() };\n } catch {\n return { status: \"nofetch\" };\n } finally {\n clearTimeout(t);\n }\n}\n\nfunction station(res: { status: string; text?: string }) {\n if (res.status !== \"ok\") return { status: res.status };\n const p = parseStation(res.text!);\n return p ? { status: \"ok\", ...p } : { status: \"parse\" };\n}\n\nfunction wind(res: { status: string; text?: string }) {\n if (res.status !== \"ok\") return { status: res.status };\n const p = parseWind(res.text!);\n return p ? { status: \"ok\", ...p } : { status: \"parse\" };\n}\n\nexport default async function () {\n const utc_iso = new Date().toISOString();\n const [r36, r50, r45, rwind, rfc] = await Promise.all([get(S36), get(S50), get(S45), get(WIND), get(URLF)]);\n const s36 = station(r36), s50 = station(r50), s45 = station(r45);\n const w = wind(rwind);\n\n let f: Record;\n if (rfc.status !== \"ok\") {\n f = { status: rfc.status };\n } else {\n try {\n const c = JSON.parse(rfc.text!).current;\n f = { status: \"ok\", wind_speed_10m: c.wind_speed_10m, wind_gusts_10m: c.wind_gusts_10m, wind_direction_10m: c.wind_direction_10m, surface_pressure: c.surface_pressure };\n } catch {\n f = { status: \"parse\" };\n }\n }\n\n const cols = (x: Record) => [\n x.status, x.wind_ms ?? null, x.gust_ms ?? null, x.pressure_hpa ?? null,\n x.rain_mmh ?? null, x.humidity_pct ?? null, x.temp_c ?? null, x.dir ?? null,\n ];\n const wcols = (x: Record) => [\n x.pw_time_utc ?? null, x.pw_mean_ms ?? null, x.pw_gust_ms ?? null,\n x.pw_dir_deg ?? null, x.status,\n ];\n const val = [\n utc_iso, ...cols(s36), ...cols(s50), ...cols(s45),\n f.status, f.wind_speed_10m ?? null, f.wind_gusts_10m ?? null,\n f.wind_direction_10m ?? null, f.surface_pressure ?? null,\n ...wcols(w),\n ];\n\n await sqlite.execute({ sql: `CREATE TABLE IF NOT EXISTS weather (\n utc_iso TEXT, f36_status TEXT, f36_wind_ms REAL, f36_gust_ms REAL, f36_pressure_hpa REAL,\n f36_rain_mmh REAL, f36_humidity_pct REAL, f36_temp_c REAL, f36_dir TEXT,\n f50_status TEXT, f50_wind_ms REAL, f50_gust_ms REAL, f50_pressure_hpa REAL,\n f50_rain_mmh REAL, f50_humidity_pct REAL, f50_temp_c REAL, f50_dir TEXT,\n f45_status TEXT, f45_wind_ms REAL, f45_gust_ms REAL, f45_pressure_hpa REAL,\n f45_rain_mmh REAL, f45_humidity_pct REAL, f45_temp_c REAL, f45_dir TEXT,\n fc_status TEXT, fc_wind_speed_10m REAL, fc_wind_gusts_10m REAL,\n fc_wind_direction_10m REAL, fc_surface_pressure REAL,\n pw_time_utc TEXT, pw_mean_ms REAL, pw_gust_ms REAL, pw_dir_deg REAL,\n pw_status TEXT)`});\n await sqlite.execute({ sql: `INSERT INTO weather VALUES (${val.map(() => \"?\").join(\",\")})`, args: val });\n}\n",[159],"88ca0c78-7f5b-453a-a5d0-779913da5ee8","weather-check.ts","2b9fb764-9fae-11f1-84a8-1607ee4eb77e",29,["D",1789111224129],5,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\n// \"usable\" means the source reported status 'ok' and produced an actual wind\n// measurement. Order and columns mirror the weather table. maxFailureRate is the\n// fraction of failed (non-usable) rows that triggers a warning — warn only ABOVE it,\n// exactly that rate is allowed.\nconst SOURCES = [\n { label: \"F36\", col: \"f36_ok\", maxFailureRate: 0.02 },\n { label: \"F50\", col: \"f50_ok\", maxFailureRate: 0.02 },\n { label: \"F45\", col: \"f45_ok\", maxFailureRate: 0.02 },\n { label: \"fc\", col: \"fc_ok\", maxFailureRate: 0.5 },\n { label: \"pw\", col: \"pw_ok\", maxFailureRate: 0.5 },\n] as const;\n\nexport default async function () {\n const since = new Date(Date.now() - 7 * 24 * 60 * 60 * 1000).toISOString();\n const { rows } = await sqlite.execute({\n sql: `SELECT COUNT(*) AS n,\n SUM(CASE WHEN f36_status = 'ok' AND f36_wind_ms IS NOT NULL THEN 1 ELSE 0 END) AS f36_ok,\n SUM(CASE WHEN f50_status = 'ok' AND f50_wind_ms IS NOT NULL THEN 1 ELSE 0 END) AS f50_ok,\n SUM(CASE WHEN f45_status = 'ok' AND f45_wind_ms IS NOT NULL THEN 1 ELSE 0 END) AS f45_ok,\n SUM(CASE WHEN fc_status = 'ok' THEN 1 ELSE 0 END) AS fc_ok,\n SUM(CASE WHEN pw_status = 'ok' THEN 1 ELSE 0 END) AS pw_ok\n FROM weather WHERE utc_iso >= ?`,\n args: [since],\n });\n const r = rows[0];\n const count = Number(r.n);\n\n // Which sources exceeded the failure threshold in the last 7 days.\n const failing: { label: string; usable: number; total: number; failed: number; rate: number }[] = [];\n if (count > 0) {\n for (const s of SOURCES) {\n const usable = Number(r[s.col]);\n const failed = count - usable;\n const rate = failed / count;\n if (rate > s.maxFailureRate) {\n failing.push({ label: s.label, usable, total: count, failed, rate });\n }\n }\n }\n\n const rowOk = count >= 300;\n const sourcesOk = failing.length === 0;\n if (rowOk && sourcesOk) return; // all good, send nothing\n\n const parts: string[] = [];\n if (!rowOk) {\n parts.push(\n count === 0\n ? \"The weather scraper appears to have stopped — no rows were written in the last 7 days.\"\n : `Only ${count} rows were written to the weather table in the last 7 days (expected about 336).`,\n );\n }\n parts.push(\"Usable rows per source (last 7 days):\");\n for (const s of SOURCES) {\n const usable = count > 0 ? Number(r[s.col]) : 0;\n const failed = count > 0 ? count - usable : 0;\n const pct = count > 0 ? (failed / count) * 100 : 0;\n parts.push(`${s.label}: ${usable}/${count} usable — ${failed} failed (${pct.toFixed(2)}%)`);\n }\n\n const subject = !rowOk\n ? count === 0\n ? \"Weather scraper appears to have stopped\"\n : `Weather logger: only ${count} rows in the last 7 days`\n : \"Weather logger: some sources above their failure threshold\";\n\n await email({ subject, text: parts.join(\"\\n\") });\n}\n",[166],"7b981d2d-8568-45cc-88ce-5224d5b8cded","weather-check.pre-separate-20260911.ts","37406062-adb1-11f1-b11b-1607ee4eb77e",30,["D",1789145078105],1,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nconst MAX_FAILURE_RATE = 0.02; // warn only ABOVE 2% failure; exactly 2.00% is allowed\n\n// \"usable\" means the source reported status 'ok' and produced an actual wind\n// measurement. Order and columns mirror the weather table.\nconst SOURCES = [\n { label: \"F36\", col: \"f36_ok\" },\n { label: \"F50\", col: \"f50_ok\" },\n { label: \"F45\", col: \"f45_ok\" },\n { label: \"fc\", col: \"fc_ok\" },\n { label: \"pw\", col: \"pw_ok\" },\n] as const;\n\nexport default async function () {\n const since = new Date(Date.now() - 7 * 24 * 60 * 60 * 1000).toISOString();\n const { rows } = await sqlite.execute({\n sql: `SELECT COUNT(*) AS n,\n SUM(CASE WHEN f36_status = 'ok' AND f36_wind_ms IS NOT NULL THEN 1 ELSE 0 END) AS f36_ok,\n SUM(CASE WHEN f50_status = 'ok' AND f50_wind_ms IS NOT NULL THEN 1 ELSE 0 END) AS f50_ok,\n SUM(CASE WHEN f45_status = 'ok' AND f45_wind_ms IS NOT NULL THEN 1 ELSE 0 END) AS f45_ok,\n SUM(CASE WHEN fc_status = 'ok' THEN 1 ELSE 0 END) AS fc_ok,\n SUM(CASE WHEN pw_status = 'ok' THEN 1 ELSE 0 END) AS pw_ok\n FROM weather WHERE utc_iso >= ?`,\n args: [since],\n });\n const r = rows[0];\n const count = Number(r.n);\n\n // Which sources exceeded the failure threshold in the last 7 days.\n const failing: { label: string; usable: number; total: number; failed: number; rate: number }[] = [];\n if (count > 0) {\n for (const s of SOURCES) {\n const usable = Number(r[s.col]);\n const failed = count - usable;\n const rate = failed / count;\n if (rate > MAX_FAILURE_RATE) {\n failing.push({ label: s.label, usable, total: count, failed, rate });\n }\n }\n }\n\n const rowOk = count >= 300;\n const sourcesOk = failing.length === 0;\n if (rowOk && sourcesOk) return; // all good, send nothing\n\n const parts: string[] = [];\n if (!rowOk) {\n parts.push(\n count === 0\n ? \"The weather scraper appears to have stopped — no rows were written in the last 7 days.\"\n : `Only ${count} rows were written to the weather table in the last 7 days (expected about 336).`,\n );\n }\n parts.push(\"Usable rows per source (last 7 days):\");\n for (const s of SOURCES) {\n const usable = count > 0 ? Number(r[s.col]) : 0;\n const failed = count > 0 ? count - usable : 0;\n const pct = count > 0 ? (failed / count) * 100 : 0;\n parts.push(`${s.label}: ${usable}/${count} usable — ${failed} failed (${pct.toFixed(2)}%)`);\n }\n\n const subject = !rowOk\n ? count === 0\n ? \"Weather scraper appears to have stopped\"\n : `Weather logger: only ${count} rows in the last 7 days`\n : `Weather logger: some sources above ${(MAX_FAILURE_RATE * 100).toFixed(0)}% failure`;\n\n await email({ subject, text: parts.join(\"\\n\") });\n}\n",[174],"ebe8f0c1-5299-4af8-83ff-edd21a76bcab","weather-check.pre-2pct-20260911.ts","c4f15cb4-adb0-11f1-8802-1607ee4eb77e",31,["D",1789145078598],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nconst STATUS_COLS = [\"f36_status\", \"f50_status\", \"f45_status\", \"fc_status\", \"pw_status\"] as const;\n\nexport default async function () {\n const since = new Date(Date.now() - 7 * 24 * 60 * 60 * 1000).toISOString();\n const { rows } = await sqlite.execute({\n sql: `SELECT COUNT(*) AS n,\n SUM(CASE WHEN f36_status = 'ok' THEN 1 ELSE 0 END) AS f36_ok,\n SUM(CASE WHEN f50_status = 'ok' THEN 1 ELSE 0 END) AS f50_ok,\n SUM(CASE WHEN f45_status = 'ok' THEN 1 ELSE 0 END) AS f45_ok,\n SUM(CASE WHEN fc_status = 'ok' THEN 1 ELSE 0 END) AS fc_ok,\n SUM(CASE WHEN pw_status = 'ok' THEN 1 ELSE 0 END) AS pw_ok\n FROM weather WHERE utc_iso >= ?`,\n args: [since],\n });\n const r = rows[0];\n const count = Number(r.n);\n\n // Percentage of rows in the last 7 days where each source was 'ok'.\n const low: { name: string; pct: number }[] = [];\n if (count > 0) {\n for (const col of STATUS_COLS) {\n const ok = Number(r[col.replace(\"_status\", \"_ok\")]);\n const pct = (ok / count) * 100;\n if (pct < 50) low.push({ name: col, pct });\n }\n }\n\n const rowOk = count >= 300;\n const sourcesOk = low.length === 0;\n if (rowOk && sourcesOk) return; // all good, send nothing\n\n const parts: string[] = [];\n if (!rowOk) {\n parts.push(\n count === 0\n ? \"The weather scraper appears to have stopped — no rows were written in the last 7 days.\"\n : `Only ${count} rows were written to the weather table in the last 7 days (expected about 336).`,\n );\n }\n if (!sourcesOk) {\n parts.push(\"Sources below 50% 'ok' over the last 7 days:\");\n for (const s of low) parts.push(`${s.name}: ${s.pct.toFixed(1)}% ok`);\n }\n\n const subject = !rowOk\n ? count === 0\n ? \"Weather scraper appears to have stopped\"\n : `Weather logger: only ${count} rows in the last 7 days`\n : \"Weather logger: some sources below 50% ok\";\n\n await email({ subject, text: parts.join(\"\\n\") });\n}\n",[182],"80fb5f6e-b84a-4e92-a7eb-46717962c496",["D",1789243546234],21,[28],"pulls","branches","forks","envVars",{"_199":63,"_201":63},"connections",{"_199":63,"_200":63},"count","unfilledCount","emptyCount",{"_43":188,"_32":28,"_30":31,"_140":-5,"_41":42,"_40":14,"_142":59,"_38":228,"_13":190,"_33":34,"_35":37,"_24":25,"_147":-5,"_210":229,"_27":230},{"_43":181,"_32":182,"_30":183,"_140":-5,"_41":42,"_40":184,"_142":59,"_38":225,"_13":178,"_33":34,"_35":186,"_24":25,"_147":-5,"_210":226,"_27":227},{"_43":173,"_32":174,"_30":175,"_140":-5,"_41":42,"_40":176,"_142":59,"_38":222,"_13":178,"_33":34,"_35":179,"_24":25,"_147":-5,"_210":223,"_27":224},{"_43":165,"_32":166,"_30":167,"_140":-5,"_41":42,"_40":168,"_142":59,"_38":219,"_13":170,"_33":155,"_35":171,"_24":25,"_147":-5,"_210":220,"_27":221},{"_43":158,"_32":159,"_30":160,"_140":-5,"_41":42,"_40":161,"_142":59,"_38":216,"_13":63,"_33":34,"_35":163,"_24":25,"_147":-5,"_210":217,"_27":218},{"_43":149,"_32":150,"_30":151,"_140":-5,"_41":42,"_40":152,"_142":59,"_38":213,"_13":154,"_33":155,"_35":156,"_24":25,"_147":-5,"_210":214,"_27":215},{"_43":138,"_32":139,"_30":57,"_140":-5,"_41":42,"_40":141,"_142":59,"_38":209,"_13":144,"_33":145,"_35":146,"_24":25,"_147":-5,"_210":211,"_27":212},["D",1787560973168],"children",[],[139],["D",1789156187200],[],[150],["D",1789156178257],[],[159],["D",1789111224129],[],[166],["D",1789145078105],[],[174],["D",1789145078598],[],[182],["D",1789243546234],[],[28],["D",1787559428678],["D",1789475460618],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_128":269,"_270":271,"_272":273,"_274":25,"_275":25,"_276":25,"_277":59,"_278":-5,"_279":-7,"_280":-7,"_281":63,"_282":25,"_283":25,"_284":-5,"_285":25,"_286":25,"_287":25,"_288":-5},"ENV",{"_240":241,"_242":243,"_244":90,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268},"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"]

Diff · v55