[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_241":242,"_243":244},"routes/_app.x.$handle.$name",{"_106":105,"_38":51,"_115":96,"_33":116,"_13":14,"_117":-5,"_11":118,"_119":120,"_121":122,"_123":124,"_125":126,"_26":-5,"_127":-5,"_128":-5,"_129":31,"_130":131,"_132":65,"_133":-5,"_134":-5,"_135":136},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":77,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":89,"_90":91,"_92":93,"_94":31},"version",35,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","7e5e2cb0-bcc5-4109-801d-dad06e2bbd10","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"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. This is a READ-ONLY dry-run inspector.\n//\n// It makes no DB writes, creates no tables, inserts no forecast rows, calls no\n// local weather jobs, and schedules nothing. It only queries the public DMI\n// Forecast Data EDR API anonymously and logs a storage feasibility report.\n//\n// Canonical Streymoy area (kept for future reference):\n// CRS84 bbox: west=-7.25 south=61.93 east=-6.72 north=62.31\n// Island mask (OSM): relation 1423026\n// Island mask (WD): 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 range,\n// deterministic runs at 00/03/06/09/12/15/18/21 UTC -> 8 runs/day.\n//\n// Collected variables (only the useful surface set):\n// wind-speed-10m -> 10 m wind speed (m/s)\n// gust-wind-speed-10m -> 10 m gust (m/s)\n// wind-dir-10m -> wind direction (deg true)\n// pressure-sealevel-> sea-level pressure (Pa)\n// plus model run time, retrieval time, and forecast lead/valid times.\n\n// --- Canonical constants -----------------------------------------------------\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\";\n\n// Current size of the existing project-scoped SQLite DB (weather table, 880 rows),\n// measured via `dbstat` at dry-run time. Read-only reference value.\nconst CURRENT_DB_BYTES = 163_840; // 0.16 MB\n\nconst RUNS_PER_DAY = 8; // 00z..21z every 3 h\nconst DAYS = 365;\nconst RUNS_PER_YEAR = RUNS_PER_DAY * DAYS; // 2920\nconst SAFETY_CEILING_BYTES = 8 * 1024 * 1024; // 8 MiB ceiling\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\n\n// Fetch with 429-friendly retry/backoff. Returns { status, bytes, text }.\nasync function get(url: string, tries = 4): Promise<{ status: number; bytes: number; text: string }> {\n for (let i = 1; i <= tries; i++) {\n let res: Response;\n try {\n res = await fetch(url);\n } catch {\n return { status: 0, bytes: 0, text: \"\" }; // network/connect failed\n }\n const bytes = Number(res.headers.get(\"content-length\") ?? 0);\n const text = await res.text();\n if (res.status === 429) {\n const wait = 1000 * i + Math.random() * 1000; // backing off after being rate-limited\n console.log(`[dmi] 429 rate-limited on attempt ${i}/${tries}; waiting ${wait}ms`);\n await sleep(wait);\n continue;\n }\n return { status: res.status, bytes: bytes || text.length, text };\n }\n return { status: 429, bytes: 0, text: \"\" };\n}\n\nfunction extractSeries(cov: any, tLen: number): Record {\n // CoverageJSON `ranges[param].values` is the forecast array over the t axis.\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)) {\n out[p] = [];\n continue;\n }\n const vals = r.values;\n // Handle flattened multi-dim shapes conservatively: if shape != [...,tLen],\n // take the trailing tLen values as the time series.\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]; // unknown shape -> whole-array hmm, fall back to first\n }\n return out;\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 inspection for Streymoy (${now.toISOString()})`);\n console.log(\"============================================================\");\n\n // 1) Available model run instances (cadence check).\n const inst = await get(`${EDR}/instances`);\n let runTimes: string[] = [];\n let latestRun: string | null = null;\n if (inst.status === 200) {\n try {\n runTimes = (JSON.parse(inst.text).features ?? []).map((f: any) => f.id);\n } catch {\n runTimes = [];\n }\n runTimes.sort();\n latestRun = runTimes[runTimes.length - 1] ?? null;\n console.log(`DMI API reachable : YES (status 200, few hundred bytes)`);\n console.log(`Available run instances (last 24h): ${runTimes.length}`);\n if (runTimes.length > 0) {\n console.log(` sample: ${runTimes.slice(0, 3).join(\", \")} ...`);\n console.log(` latest: ${latestRun}`);\n }\n } else {\n console.log(`DMI API reachable : NO (status ${inst.status})`);\n console.log(\"STOP: cannot verify live DMI data -> uncertain, unsafe to proceed.\");\n return;\n }\n\n // 2) Position (single nearest grid point to Kollafjørður), full 60 h forecast,\n // all 4 wanted parameters. This mimics what one scheduled run would fetch.\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 let series: Record = {};\n let steps = 0;\n let modelRunTime: string | null = null;\n let validTimes: string[] = [];\n if (pos.status === 200) {\n let cov: any = null;\n try {\n cov = JSON.parse(pos.text);\n } catch {\n cov = null;\n }\n const tAxis = cov?.domain?.axes?.t?.values ?? [];\n validTimes = [...tAxis];\n steps = validTimes.length;\n series = extractSeries(cov, steps);\n modelRunTime = latestRun;\n console.log(`\\nPosition query (Kollafjørður) : status 200`);\n console.log(`Forecast series steps : ${steps} (t-axis)`);\n console.log(`Series valid times : ${validTimes[0]} .. ${validTimes[steps - 1]}`);\n } else {\n console.log(`\\nPosition query : status ${pos.status} -> cannot extract series. STOP.`);\n return;\n }\n\n const foundParams = PARAMS.filter((p) => Array.isArray(series[p]) && series[p].some((v) => v != null));\n const sample = foundParams.length\n ? Object.fromEntries(foundParams.map((p) => [p, series[p][0]]))\n : null;\n console.log(`Param names actually populated: ${foundParams.join(\", \") || \"NONE\"}`);\n if (sample) console.log(`Sample values (step 0/analysis): ${JSON.stringify(sample)}`);\n console.log(`Model/run time (latest instance): ${modelRunTime}`);\n console.log(`Retrieval time : ${now.toISOString()}`);\n\n // 3) Count Streymoy grid points inside the CRS84 bbox (single step, GeoJSON).\n // DINI area queries are only native-crs for CoverageJSON, but GeoJSON\n // output supports crs84 (per DMI docs); count returned features.\n await sleep(1500); // be polite to the rate limit after the position call\n const oneStep = validTimes[validTimes.length - 1]; // a valid step the run covers\n const qc =\n `${EDR}/cube?bbox=${BBOX.west},${BBOX.south},${BBOX.east},${BBOX.north}` +\n `&crs=crs84&f=GeoJSON¶meter-name=wind-speed-10m&datetime=${oneStep}/${oneStep}`;\n const cube = await get(qc);\n let gridPoints: number | null = null;\n if (cube.status === 200) {\n try {\n const gj = JSON.parse(cube.text);\n const feats = gj?.features ?? [];\n if (Array.isArray(feats)) gridPoints = feats.length;\n // GeoJSON cube may also come back as a gridded object with range values length.\n else if (gj?.ranges && gj.ranges[\"wind-speed-10m\"]?.values) {\n gridPoints = gj.ranges[\"wind-speed-10m\"].values.length;\n }\n } catch {\n gridPoints = null;\n }\n }\n console.log(`\\nCube query (Streymoy bbox, 1 step) : status ${cube.status}`);\n console.log(`Streymoy grid points in bbox : ${gridPoints ?? \"unresolved\"}`);\n if ((cube.status !== 200) && gridPoints === null) {\n console.log(\"NOTE: grid-point count unresolved (rate limit or unsupported crs) -> see analytic estimate in report.\");\n }\n\n // 4) Storage estimates.\n const rawBytesRun = pos.bytes;\n\n // Schema A - pack the FULL forecast series (all steps) as one row per model run.\n const packedFull = {\n run: modelRunTime,\n retrieval: now.toISOString(),\n t: validTimes,\n wind: series[\"wind-speed-10m\"] ?? [],\n gust: series[\"gust-wind-speed-10m\"] ?? [],\n dir: series[\"wind-dir-10m\"] ?? [],\n pres: series[\"pressure-sealevel\"] ?? [],\n };\n const fullBytes = new TextEncoder().encode(JSON.stringify(packedFull)).length;\n\n // Schema B - compact per-run summary: analysis (lead 0) + one near/now step.\n const pad = (x: (number | null)[] | undefined) => (x ? (x[0] ?? null) : null);\n const packedSingle = {\n run: modelRunTime,\n retrieval: now.toISOString(),\n valid: validTimes[0] ?? null,\n wind: pad(series[\"wind-speed-10m\"]),\n gust: pad(series[\"gust-wind-speed-10m\"]),\n dir: pad(series[\"wind-dir-10m\"]),\n pres: pad(series[\"pressure-sealevel\"]),\n };\n const singleBytes = new TextEncoder().encode(JSON.stringify(packedSingle)).length;\n\n const yrFullMB = (fullBytes * RUNS_PER_YEAR) / 1e6;\n const yrSingleMB = (singleBytes * RUNS_PER_YEAR) / 1e6;\n const totalFullMB = (fullBytes * RUNS_PER_YEAR + CURRENT_DB_BYTES) / 1e6;\n const totalSingleMB = (singleBytes * RUNS_PER_YEAR + CURRENT_DB_BYTES) / 1e6;\n\n // Analytic line-based estimate of Streymoy grid points (~2 km grid), for sanity.\n const latMean = ((BBOX.north + BBOX.south) / 2) * (Math.PI / 180);\n const degLonKm = 111.32 * Math.cos(latMean);\n const widthKm = (BBOX.east - BBOX.west) * degLonKm;\n const heightKm = (BBOX.north - BBOX.south) * 111.19;\n const gridKm = 2; // DINI ~2 km grid\n const analyticPtsX = Math.floor(widthKm / gridKm) + 1;\n const analyticPtsY = Math.floor(heightKm / gridKm) + 1;\n const analyticPts = analyticPtsX * analyticPtsY;\n\n console.log(\"\\n============================================================\");\n console.log(\"REPORT (dry-run, read-only - nothing written, nothing scheduled)\");\n console.log(\"------------------------------------------------------------\");\n console.log(`DMI HARMONIE DINI API works : YES (anonymous, EDR JSON)`);\n console.log(`Streymoy grid points (bbox) : ${gridPoints ?? `~${analyticPts} analytic (${analyticPtsX}x${analyticPtsY} @ ~2km)`}`);\n console.log(`Exact parameters found : ${foundParams.join(\", \")}`);\n console.log(`Raw HTTP response size / run : ~${(rawBytesRun / 1024).toFixed(1)} KB`);\n console.log(` (steps in series: ${steps})`);\n console.log(`Compact bytes / model run:`);\n console.log(` Schema A full-series row : ${fullBytes} B`);\n console.log(` Schema B single summary row : ${singleBytes} B`);\n console.log(`Projected storage @ ${RUNS_PER_DAY} runs/day x ${DAYS}d (=${RUNS_PER_YEAR} runs/yr):`);\n console.log(` Schema A: ${yrFullMB.toFixed(2)} MB/yr`);\n console.log(` Schema B: ${yrSingleMB.toFixed(2)} MB/yr`);\n console.log(`Current SQLite DB size : ${(CURRENT_DB_BYTES / 1024 / 1024).toFixed(2)} MB (${CURRENT_DB_BYTES} B)`);\n console.log(`Projected total 12-mo (A = series) : ${totalFullMB.toFixed(2)} MB`);\n console.log(`Projected total 12-mo (B = summary) : ${totalSingleMB.toFixed(2)} MB`);\n const belowA = totalFullMB * 1e6 < SAFETY_CEILING_BYTES;\n const belowB = totalSingleMB * 1e6 < SAFETY_CEILING_BYTES;\n console.log(`Safety ceiling 8 MB : ${belowA && belowB ? \"SAFE (both schemas well below)\" : belowB ? \"SAFE via summary schema only\" : \"NOT SAFE\"}`);\n console.log(`Elapsed : ${((Date.now() - startedMs) / 1000).toFixed(1)}s`);\n console.log(\"============================================================\");\n\n return {\n api_ok: true,\n grid_points: gridPoints,\n analytic_grid_points: analyticPts,\n params: foundParams,\n raw_bytes_per_run: rawBytesRun,\n steps,\n schema_a_bytes: fullBytes,\n schema_b_bytes: singleBytes,\n mb_per_year_a: yrFullMB,\n mb_per_year_b: yrSingleMB,\n current_db_mb: CURRENT_DB_BYTES / 1e6,\n total_mb_a: totalFullMB,\n total_mb_b: totalSingleMB,\n below_8mb: belowA && belowB,\n };\n}\n\n// Run when executed directly (run_file / script eval). No trigger, no writes.\nif (import.meta.main) {\n await main();\n}\n","// DMI HARMONIE DINI surface forecast for Streymoy (Færøerne).\n// =============================================================\n// NON-TRIGGERING, type=script. This is a READ-ONLY dry-run inspector.\n//\n// It makes no DB writes, creates no tables, inserts no forecast rows, calls no\n// local weather jobs, and schedules nothing. It only queries the public DMI\n// Forecast Data EDR API anonymously and logs a storage feasibility report.\n//\n// Canonical Streymoy area (kept for future reference):\n// CRS84 bbox: west=-7.25 south=61.93 east=-6.72 north=62.31\n// Island mask (OSM): relation 1423026\n// Island mask (WD): 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 range,\n// deterministic runs at 00/03/06/09/12/15/18/21 UTC -> 8 runs/day.\n//\n// Collected variables (only the useful surface set):\n// wind-speed-10m -> 10 m wind speed (m/s)\n// gust-wind-speed-10m -> 10 m gust (m/s)\n// wind-dir-10m -> wind direction (deg true)\n// pressure-sealevel-> sea-level pressure (Pa)\n// plus model run time, retrieval time, and forecast lead/valid times.\n\n// --- Canonical constants -----------------------------------------------------\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\";\n\n// Current size of the existing project-scoped SQLite DB (weather table, 880 rows),\n// measured via `dbstat` at dry-run time. Read-only reference value.\nconst CURRENT_DB_BYTES = 163_840; // 0.16 MB\n\nconst RUNS_PER_DAY = 8; // 00z..21z every 3 h\nconst DAYS = 365;\nconst RUNS_PER_YEAR = RUNS_PER_DAY * DAYS; // 2920\nconst SAFETY_CEILING_BYTES = 8 * 1024 * 1024; // 8 MiB ceiling\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\n\n// Fetch with 429-friendly retry/backoff. Returns { status, bytes, text }.\nasync function get(url: string, tries = 4): Promise<{ status: number; bytes: number; text: string }> {\n for (let i = 1; i <= tries; i++) {\n let res: Response;\n try {\n res = await fetch(url);\n } catch {\n return { status: 0, bytes: 0, text: \"\" }; // network/connect failed\n }\n const bytes = Number(res.headers.get(\"content-length\") ?? 0);\n const text = await res.text();\n if (res.status === 429) {\n const wait = 1000 * i + Math.random() * 1000; // backing off after being rate-limited\n console.log(`[dmi] 429 rate-limited on attempt ${i}/${tries}; waiting ${wait}ms`);\n await sleep(wait);\n continue;\n }\n return { status: res.status, bytes: bytes || text.length, text };\n }\n return { status: 429, bytes: 0, text: \"\" };\n}\n\nfunction extractSeries(cov: any, tLen: number): Record {\n // CoverageJSON `ranges[param].values` is the forecast array over the t axis.\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)) {\n out[p] = [];\n continue;\n }\n const vals = r.values;\n // Handle flattened multi-dim shapes conservatively: if shape != [...,tLen],\n // take the trailing tLen values as the time series.\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]; // unknown shape -> whole-array hmm, fall back to first\n }\n return out;\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 inspection for Streymoy (${now.toISOString()})`);\n console.log(\"============================================================\");\n\n // 1) Available model run instances (cadence check).\n const inst = await get(`${EDR}/instances`);\n let runTimes: string[] = [];\n let latestRun: string | null = null;\n if (inst.status === 200) {\n try {\n runTimes = (JSON.parse(inst.text).features ?? []).map((f: any) => f.id);\n } catch {\n runTimes = [];\n }\n runTimes.sort();\n latestRun = runTimes[runTimes.length - 1] ?? null;\n console.log(`DMI API reachable : YES (status 200, few hundred bytes)`);\n console.log(`Available run instances (last 24h): ${runTimes.length}`);\n if (runTimes.length > 0) {\n console.log(` sample: ${runTimes.slice(0, 3).join(\", \")} ...`);\n console.log(` latest: ${latestRun}`);\n }\n } else {\n console.log(`DMI API reachable : NO (status ${inst.status})`);\n console.log(\"STOP: cannot verify live DMI data -> uncertain, unsafe to proceed.\");\n return;\n }\n\n // 2) Position (single nearest grid point to Kollafjørður), full 60 h forecast,\n // all 4 wanted parameters. This mimics what one scheduled run would fetch.\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 let series: Record = {};\n let steps = 0;\n let modelRunTime: string | null = null;\n let validTimes: string[] = [];\n if (pos.status === 200) {\n let cov: any = null;\n try {\n cov = JSON.parse(pos.text);\n } catch {\n cov = null;\n }\n const tAxis = cov?.domain?.axes?.t?.values ?? [];\n validTimes = [...tAxis];\n steps = validTimes.length;\n series = extractSeries(cov, steps);\n modelRunTime = latestRun;\n console.log(`\\nPosition query (Kollafjørður) : status 200`);\n console.log(`Forecast series steps : ${steps} (t-axis)`);\n console.log(`Series valid times : ${validTimes[0]} .. ${validTimes[steps - 1]}`);\n } else {\n console.log(`\\nPosition query : status ${pos.status} -> cannot extract series. STOP.`);\n return;\n }\n\n const foundParams = PARAMS.filter((p) => Array.isArray(series[p]) && series[p].some((v) => v != null));\n const sample = foundParams.length\n ? Object.fromEntries(foundParams.map((p) => [p, series[p][0]]))\n : null;\n console.log(`Param names actually populated: ${foundParams.join(\", \") || \"NONE\"}`);\n if (sample) console.log(`Sample values (step 0/analysis): ${JSON.stringify(sample)}`);\n console.log(`Model/run time (latest instance): ${modelRunTime}`);\n console.log(`Retrieval time : ${now.toISOString()}`);\n\n // 3) Count Streymoy grid points inside the CRS84 bbox (single step, GeoJSON).\n // DINI area queries are only native-crs for CoverageJSON, but GeoJSON\n // output supports crs84 (per DMI docs); count returned features.\n await sleep(1500); // be polite to the rate limit after the position call\n const oneStep = validTimes[validTimes.length - 1]; // a valid step the run covers\n const qc =\n `${EDR}/cube?bbox=${BBOX.west},${BBOX.south},${BBOX.east},${BBOX.north}` +\n `&crs=crs84&f=GeoJSON¶meter-name=wind-speed-10m&datetime=${oneStep}/${oneStep}`;\n const cube = await get(qc);\n let gridPoints: number | null = null;\n if (cube.status === 200) {\n try {\n const gj = JSON.parse(cube.text);\n const feats = gj?.features ?? [];\n if (Array.isArray(feats)) gridPoints = feats.length;\n // GeoJSON cube may also come back as a gridded object with range values length.\n else if (gj?.ranges && gj.ranges[\"wind-speed-10m\"]?.values) {\n gridPoints = gj.ranges[\"wind-speed-10m\"].values.length;\n }\n } catch {\n gridPoints = null;\n }\n }\n console.log(`\\nCube query (Streymoy bbox, 1 step) : status ${cube.status}`);\n console.log(`Streymoy grid points in bbox : ${gridPoints ?? \"unresolved\"}`);\n if ((cube.status !== 200) && gridPoints === null) {\n console.log(\"NOTE: grid-point count unresolved (rate limit or unsupported crs) -> see analytic estimate in report.\");\n }\n\n // 4) Storage estimates.\n const rawBytesRun = pos.bytes;\n\n // Schema A - pack the FULL forecast series (all steps) as one row per model run.\n const packedFull = {\n run: modelRunTime,\n retrieval: now.toISOString(),\n t: validTimes,\n wind: series[\"wind-speed-10m\"] ?? [],\n gust: series[\"gust-wind-speed-10m\"] ?? [],\n dir: series[\"wind-dir-10m\"] ?? [],\n pres: series[\"pressure-sealevel\"] ?? [],\n };\n const fullBytes = new TextEncoder().encode(JSON.stringify(packedFull)).length;\n\n // Schema B - compact per-run summary: analysis (lead 0) + one near/now step.\n const pad = (x: (number | null)[] | undefined) => (x ? (x[0] ?? null) : null);\n const packedSingle = {\n run: modelRunTime,\n retrieval: now.toISOString(),\n valid: validTimes[0] ?? null,\n wind: pad(series[\"wind-speed-10m\"]),\n gust: pad(series[\"gust-wind-speed-10m\"]),\n dir: pad(series[\"wind-dir-10m\"]),\n pres: pad(series[\"pressure-sealevel\"]),\n };\n const singleBytes = new TextEncoder().encode(JSON.stringify(packedSingle)).length;\n\n const yrFullMB = (fullBytes * RUNS_PER_YEAR) / 1e6;\n const yrSingleMB = (singleBytes * RUNS_PER_YEAR) / 1e6;\n const totalFullMB = (fullBytes * RUNS_PER_YEAR + CURRENT_DB_BYTES) / 1e6;\n const totalSingleMB = (singleBytes * RUNS_PER_YEAR + CURRENT_DB_BYTES) / 1e6;\n\n // Analytic line-based estimate of Streymoy grid points (~2 km grid), for sanity.\n const latMean = ((BBOX.north + BBOX.south) / 2) * (Math.PI / 180);\n const degLonKm = 111.32 * Math.cos(latMean);\n const widthKm = (BBOX.east - BBOX.west) * degLonKm;\n const heightKm = (BBOX.north - BBOX.south) * 111.19;\n const gridKm = 2; // DINI ~2 km grid\n const analyticPtsX = Math.floor(widthKm / gridKm) + 1;\n const analyticPtsY = Math.floor(heightKm / gridKm) + 1;\n const analyticPts = analyticPtsX * analyticPtsY;\n\n console.log(\"\\n============================================================\");\n console.log(\"REPORT (dry-run, read-only - nothing written, nothing scheduled)\");\n console.log(\"------------------------------------------------------------\");\n console.log(`DMI HARMONIE DINI API works : YES (anonymous, EDR JSON)`);\n console.log(`Streymoy grid points (bbox) : ${gridPoints ?? `~${analyticPts} analytic (${analyticPtsX}x${analyticPtsY} @ ~2km)`}`);\n console.log(`Exact parameters found : ${foundParams.join(\", \")}`);\n console.log(`Raw HTTP response size / run : ~${(rawBytesRun / 1024).toFixed(1)} KB`);\n console.log(` (steps in series: ${steps})`);\n console.log(`Compact bytes / model run:`);\n console.log(` Schema A full-series row : ${fullBytes} B`);\n console.log(` Schema B single summary row : ${singleBytes} B`);\n console.log(`Projected storage @ ${RUNS_PER_DAY} runs/day x ${DAYS}d (=${RUNS_PER_YEAR} runs/yr):`);\n console.log(` Schema A: ${yrFullMB.toFixed(2)} MB/yr`);\n console.log(` Schema B: ${yrSingleMB.toFixed(2)} MB/yr`);\n console.log(`Current SQLite DB size : ${(CURRENT_DB_BYTES / 1024 / 1024).toFixed(2)} MB (${CURRENT_DB_BYTES} B)`);\n console.log(`Projected total 12-mo (A = series) : ${totalFullMB.toFixed(2)} MB`);\n console.log(`Projected total 12-mo (B = summary) : ${totalSingleMB.toFixed(2)} MB`);\n const belowA = totalFullMB * 1e6 < SAFETY_CEILING_BYTES;\n const belowB = totalSingleMB * 1e6 < SAFETY_CEILING_BYTES;\n console.log(`Safety ceiling 8 MB : ${belowA && belowB ? \"SAFE (both schemas well below)\" : belowB ? \"SAFE via summary schema only\" : \"NOT SAFE\"}`);\n console.log(`Elapsed : ${((Date.now() - startedMs) / 1000).toFixed(1)}s`);\n console.log(\"============================================================\");\n\n return {\n api_ok: true,\n grid_points: gridPoints,\n analytic_grid_points: analyticPts,\n params: foundParams,\n raw_bytes_per_run: rawBytesRun,\n steps,\n schema_a_bytes: fullBytes,\n schema_b_bytes: singleBytes,\n mb_per_year_a: yrFullMB,\n mb_per_year_b: yrSingleMB,\n current_db_mb: CURRENT_DB_BYTES / 1e6,\n total_mb_a: totalFullMB,\n total_mb_b: totalSingleMB,\n below_8mb: belowA && belowB,\n };\n}\n\n// Run when this script is executed. No trigger exists; running it performs only\n// the read-only inspection. Safe to re-run at any time.\nawait main();\n","createdAt",["D",1789213348142],"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",{"_106":105,"_114":110},"org",{"_106":105,"_107":108,"_109":110,"_19":61,"_111":112,"_113":31},"branch",{"_13":95,"_38":96,"_49":48,"_97":50,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":51,"_104":105},"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",{"_49":50,"_38":51,"_44":236,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":237,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":238,"_90":239,"_92":240,"_94":31},"tree",[207,208,209,210,211,212,213],"files",[207,208,209,210,211,212,213],"counts",{"_197":69,"_198":184,"_199":69,"_200":201,"_202":203},"contents",[137,138,139,140,141,142,143],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":194,"_38":34,"_36":37,"_146":-5,"_47":48,"_46":14,"_148":31,"_44":195,"_13":184,"_39":40,"_41":43,"_30":31,"_153":-5,"_33":196},{"_49":187,"_38":188,"_36":189,"_146":-5,"_47":48,"_46":190,"_148":65,"_44":191,"_13":184,"_39":40,"_41":192,"_30":31,"_153":-5,"_33":193},{"_49":179,"_38":180,"_36":181,"_146":-5,"_47":48,"_46":182,"_148":65,"_44":183,"_13":184,"_39":40,"_41":185,"_30":31,"_153":-5,"_33":186},{"_49":171,"_38":172,"_36":173,"_146":-5,"_47":48,"_46":174,"_148":65,"_44":175,"_13":176,"_39":161,"_41":177,"_30":31,"_153":-5,"_33":178},{"_49":164,"_38":165,"_36":166,"_146":-5,"_47":48,"_46":167,"_148":65,"_44":168,"_13":69,"_39":40,"_41":169,"_30":31,"_153":-5,"_33":170},{"_49":155,"_38":156,"_36":157,"_146":-5,"_47":48,"_46":158,"_148":65,"_44":159,"_13":160,"_39":161,"_41":162,"_30":31,"_153":-5,"_33":163},{"_49":144,"_38":145,"_36":63,"_146":-5,"_47":48,"_46":147,"_148":65,"_44":149,"_13":150,"_39":151,"_41":152,"_30":31,"_153":-5,"_33":154},"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",[145],"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",[156],"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",[165],"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",[172],"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",[180],"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",[188],"bbff8f34-aa7a-4e20-9764-1ba17a9d3e2b",["D",1789213348142],[34],"pulls","branches","forks","envVars",{"_204":69,"_206":69},"connections",{"_204":69,"_205":69},"count","unfilledCount","emptyCount",{"_49":194,"_38":34,"_36":37,"_146":-5,"_47":48,"_46":14,"_148":31,"_44":233,"_13":184,"_39":40,"_41":43,"_30":31,"_153":-5,"_215":234,"_33":235},{"_49":187,"_38":188,"_36":189,"_146":-5,"_47":48,"_46":190,"_148":65,"_44":230,"_13":184,"_39":40,"_41":192,"_30":31,"_153":-5,"_215":231,"_33":232},{"_49":179,"_38":180,"_36":181,"_146":-5,"_47":48,"_46":182,"_148":65,"_44":227,"_13":184,"_39":40,"_41":185,"_30":31,"_153":-5,"_215":228,"_33":229},{"_49":171,"_38":172,"_36":173,"_146":-5,"_47":48,"_46":174,"_148":65,"_44":224,"_13":176,"_39":161,"_41":177,"_30":31,"_153":-5,"_215":225,"_33":226},{"_49":164,"_38":165,"_36":166,"_146":-5,"_47":48,"_46":167,"_148":65,"_44":221,"_13":69,"_39":40,"_41":169,"_30":31,"_153":-5,"_215":222,"_33":223},{"_49":155,"_38":156,"_36":157,"_146":-5,"_47":48,"_46":158,"_148":65,"_44":218,"_13":160,"_39":161,"_41":162,"_30":31,"_153":-5,"_215":219,"_33":220},{"_49":144,"_38":145,"_36":63,"_146":-5,"_47":48,"_46":147,"_148":65,"_44":214,"_13":150,"_39":151,"_41":152,"_30":31,"_153":-5,"_215":216,"_33":217},["D",1787560973168],"children",[],[145],["D",1789156187200],[],[156],["D",1789156178257],[],[165],["D",1789111224129],[],[172],["D",1789145078105],[],[180],["D",1789145078598],[],[188],["D",1789213348142],[],[34],["D",1787559428678],["D",1789475460618],{"_106":105,"_114":110},{"_106":105,"_107":108,"_109":110,"_19":61,"_111":112,"_113":31},{"_13":95,"_38":96,"_49":48,"_97":50,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":51,"_104":105},"ctx",{"_88":-5,"_134":274,"_275":276,"_277":278,"_279":31,"_280":31,"_281":31,"_282":65,"_283":-5,"_284":-7,"_285":-7,"_286":69,"_287":31,"_288":31,"_289":-5,"_290":31,"_291":31,"_292":31,"_293":-5},"ENV",{"_245":246,"_247":248,"_249":96,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263,"_264":265,"_266":267,"_268":269,"_270":271,"_272":273},"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 · v35