[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_259":260,"_261":262},"routes/_app.x.$handle.$name",{"_98":97,"_32":44,"_107":88,"_27":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":26,"_122":123,"_124":24,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":26,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":24,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":26},"version",64,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":26,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":26},"previous","deleted",true,"deletedHere",false,"path","weathernext-probe.ts","latestPath","fileId","f941a64e-aefb-11f1-a791-1607ee4eb77e","name","fileType","script","content","async function main(){\n const urls=[\n 'https://storage.googleapis.com/storage/v1/b/weathernext3_statistics_spatial/o?maxResults=3&prefix=weathernext_3_0_0_statistics/zarr/',\n 'https://storage.googleapis.com/weathernext3_statistics_spatial/weathernext_3_0_0_statistics/zarr/zarr.json'\n ];\n const out=[];\n for(const u of urls){\n try{\n const r=await fetch(u,{headers:{'User-Agent':'Kollafjordur-weather-logger/1.0'}});\n const text=await r.text();\n out.push({url:u,status:r.status,body:text.slice(0,500)});\n }catch(e){out.push({url:u,status:0,body:String(e)})}\n }\n console.log(JSON.stringify(out));\n return out;\n}\nawait main();","createdAt",["D",1789253266690],"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","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a032d5-3e56-7348-adbb-ebd3f534eaf5","tursoName","b6406ee1e1d740a6bb87c6d16cec69d3","tursoHostname","b6406ee1e1d740a6bb87c6d16cec69d3-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789562426294],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":54,"_103":104,"_105":26},"branch",{"_13":87,"_32":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"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",{"_42":43,"_32":44,"_37":254,"_46":-5,"_47":26,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":24,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":255,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":256,"_82":257,"_84":258,"_86":26},"tree",[217,218,219,220,221,222,223,224,225],"files",[217,218,219,220,221,222,223,224,225],"counts",{"_207":61,"_208":181,"_209":61,"_210":211,"_212":213},"contents",[129,130,131,132,133,134,135,136,137],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":199,"_32":200,"_30":201,"_139":-5,"_40":41,"_39":202,"_140":24,"_37":203,"_13":204,"_33":34,"_35":205,"_23":26,"_142":-5,"_27":206},{"_42":191,"_32":192,"_30":193,"_139":-5,"_40":41,"_39":194,"_140":26,"_37":195,"_13":196,"_33":158,"_35":197,"_23":26,"_142":-5,"_27":198},{"_42":184,"_32":185,"_30":186,"_139":-5,"_40":41,"_39":187,"_140":24,"_37":188,"_13":181,"_33":34,"_35":189,"_23":26,"_142":-5,"_27":190},{"_42":176,"_32":177,"_30":178,"_139":-5,"_40":41,"_39":179,"_140":24,"_37":180,"_13":181,"_33":34,"_35":182,"_23":26,"_142":-5,"_27":183},{"_42":168,"_32":169,"_30":170,"_139":-5,"_40":41,"_39":171,"_140":24,"_37":172,"_13":173,"_33":158,"_35":174,"_23":26,"_142":-5,"_27":175},{"_42":161,"_32":162,"_30":163,"_139":-5,"_40":41,"_39":164,"_140":24,"_37":165,"_13":61,"_33":34,"_35":166,"_23":26,"_142":-5,"_27":167},{"_42":152,"_32":153,"_30":154,"_139":-5,"_40":41,"_39":155,"_140":24,"_37":156,"_13":157,"_33":158,"_35":159,"_23":26,"_142":-5,"_27":160},{"_42":144,"_32":145,"_30":56,"_139":-5,"_40":41,"_39":146,"_140":24,"_37":147,"_13":148,"_33":149,"_35":150,"_23":26,"_142":-5,"_27":151},{"_42":138,"_32":28,"_30":31,"_139":-5,"_40":41,"_39":14,"_140":26,"_37":141,"_13":61,"_33":34,"_35":36,"_23":26,"_142":-5,"_27":143},"1efb673c-8abd-4e65-b7b2-0d92d47f89a4","parentId","latest",["D",1789253266690],"label",[28],"af3dca10-e92c-4b63-b9e8-3be2ab67f0c0","weather.csv.ts",10,["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",[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",[153],"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",[162],"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",[169],"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",[177],"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",[185],"7a58b323-c329-4eac-879c-6f7635fae1b0","house-forecast.ts","fc85d3ae-aee5-11f1-93fc-1607ee4eb77e",63,["D",1789243920071],7,"// House-targeted forecast logger for Kollafjørður.\n// Preferred source: DMI HARMONIE DINI (~2 km).\n// Fallbacks: MET Norway Locationforecast, then Open-Meteo.\n// Designed for one execution every 3 hours.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst LAT = 62.118934;\nconst LON = -6.894895;\nconst LEADS = [0, 3, 6, 12, 18, 24, 36, 48] as const;\nconst DMI = \"https://opendataapi.dmi.dk/v1/forecastedr/collections/harmonie_dini_sf/position\";\nconst MET = \"https://api.met.no/weatherapi/locationforecast/2.0/complete\";\nconst OM = \"https://api.open-meteo.com/v1/forecast\";\nconst UA = \"Kollafjordur-weather-logger/1.0 (Val Town; tollakurhansen)\";\n\ntype RecordShape = {\n src: \"dmi\" | \"met\" | \"om\";\n run: string | null;\n v: string;\n c: [number, number];\n w: (number | null)[];\n g: (number | null)[];\n d: (number | null)[];\n p: (number | null)[]; // hPa\n};\n\ntype FetchResult = { ok: true; status: number; json: any } | { ok: false; status: number; error: string };\n\nfunction round(v: unknown, digits = 1): number | null {\n if (typeof v !== \"number\" || !Number.isFinite(v)) return null;\n const f = 10 ** digits;\n return Math.round(v * f) / f;\n}\n\nfunction floor3hIso(d = new Date()): string {\n const x = new Date(d);\n x.setUTCMinutes(0, 0, 0);\n x.setUTCHours(Math.floor(x.getUTCHours() / 3) * 3);\n return x.toISOString();\n}\n\nasync function fetchJson(url: string, timeoutMs = 25_000): Promise {\n const ac = new AbortController();\n const t = setTimeout(() => ac.abort(), timeoutMs);\n try {\n const r = await fetch(url, {\n signal: ac.signal,\n headers: { \"User-Agent\": UA, \"Accept\": \"application/json\" },\n });\n if (!r.ok) return { ok: false, status: r.status, error: `http${r.status}` };\n try {\n return { ok: true, status: r.status, json: await r.json() };\n } catch {\n return { ok: false, status: r.status, error: \"parse\" };\n }\n } catch (e) {\n return { ok: false, status: 0, error: e instanceof Error ? e.name : \"network\" };\n } finally {\n clearTimeout(t);\n }\n}\n\nfunction chooseByTimes(times: string[], get: (i: number) => T, baseTime?: string): { base: string; vals: T[] } | null {\n if (!times.length) return null;\n const base = baseTime ?? times[0];\n const b = Date.parse(base);\n if (!Number.isFinite(b)) return null;\n const byHour = 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 - b) / 3_600_000;\n const hi = Math.round(h);\n if (Math.abs(h - hi) < 0.001) byHour.set(hi, i);\n }\n if (LEADS.some((h) => !byHour.has(h))) return null;\n return { base, vals: LEADS.map((h) => get(byHour.get(h)!)) };\n}\n\nasync function fromDmi(): Promise<{ rec: RecordShape | null; status: number; why?: string }> {\n const u = new URL(DMI);\n u.searchParams.set(\"coords\", `POINT(${LON} ${LAT})`);\n u.searchParams.set(\"crs\", \"crs84\");\n u.searchParams.set(\"parameter-name\", \"wind-speed-10m,gust-wind-speed-10m,wind-dir-10m,pressure-sealevel\");\n u.searchParams.set(\"f\", \"CoverageJSON\");\n const r = await fetchJson(u.toString());\n if (!r.ok) return { rec: null, status: r.status, why: r.error };\n const cov = r.json;\n const times = Array.isArray(cov?.domain?.axes?.t?.values) ? cov.domain.axes.t.values.map(String) : [];\n if (!times.length) return { rec: null, status: r.status, why: \"empty-time-axis\" };\n const base = times[0];\n const picked = chooseByTimes(times, (i) => i, base);\n if (!picked) return { rec: null, status: r.status, why: \"missing-leads\" };\n const rv = (name: string): unknown[] | null => {\n const raw = cov?.ranges?.[name]?.values;\n return Array.isArray(raw) ? raw.flat(Infinity) : null;\n };\n const wind = rv(\"wind-speed-10m\");\n const gust = rv(\"gust-wind-speed-10m\");\n const dir = rv(\"wind-dir-10m\");\n const pressure = rv(\"pressure-sealevel\");\n if (!wind || !gust || !dir || !pressure) return { rec: null, status: r.status, why: \"missing-ranges\" };\n const x = cov?.domain?.axes?.x?.values?.[0];\n const y = cov?.domain?.axes?.y?.values?.[0];\n const c: [number, number] = typeof y === \"number\" && typeof x === \"number\" ? [y, x] : [LAT, LON];\n const rec: RecordShape = {\n src: \"dmi\",\n run: null,\n v: base,\n c,\n w: picked.vals.map((i: any) => round(wind[i], 2)),\n g: picked.vals.map((i: any) => round(gust[i], 2)),\n d: picked.vals.map((i: any) => round(dir[i], 1)),\n p: picked.vals.map((i: any) => {\n const v = round(pressure[i], 0);\n return v === null ? null : round(v / 100, 1);\n }),\n };\n const complete = [...rec.w, ...rec.g, ...rec.d, ...rec.p].every((v) => v !== null);\n return complete ? { status: r.status, rec } : { status: r.status, rec: null, why: \"incomplete-required-fields\" };\n}\n\nasync function fromMet(): Promise<{ rec: RecordShape | null; status: number; why?: string }> {\n const u = new URL(MET);\n u.searchParams.set(\"lat\", String(LAT));\n u.searchParams.set(\"lon\", String(LON));\n const r = await fetchJson(u.toString());\n if (!r.ok) return { rec: null, status: r.status, why: r.error };\n const ts = Array.isArray(r.json?.properties?.timeseries) ? r.json.properties.timeseries : [];\n if (!ts.length) return { rec: null, status: r.status, why: \"empty\" };\n const times = ts.map((x: any) => String(x?.time ?? \"\"));\n const base = times[0];\n const picked = chooseByTimes(times, (i) => ts[i], base);\n if (!picked) return { rec: null, status: r.status, why: \"missing-leads\" };\n const detail = (x: any) => x?.data?.instant?.details ?? {};\n const rec: RecordShape = {\n src: \"met\",\n run: typeof r.json?.properties?.meta?.updated_at === \"string\" ? r.json.properties.meta.updated_at : null,\n v: base,\n c: [LAT, LON],\n w: picked.vals.map((x: any) => round(detail(x).wind_speed, 2)),\n g: picked.vals.map((x: any) => round(detail(x).wind_speed_of_gust, 2)),\n d: picked.vals.map((x: any) => round(detail(x).wind_from_direction, 1)),\n p: picked.vals.map((x: any) => round(detail(x).air_pressure_at_sea_level, 1)),\n };\n const complete = [...rec.w, ...rec.g, ...rec.d, ...rec.p].every((v) => v !== null);\n return complete ? { status: r.status, rec } : { status: r.status, rec: null, why: \"incomplete-required-fields\" };\n}\n\nasync function fromOpenMeteo(): Promise<{ rec: RecordShape | null; status: number; why?: string }> {\n const u = new URL(OM);\n u.searchParams.set(\"latitude\", String(LAT));\n u.searchParams.set(\"longitude\", String(LON));\n u.searchParams.set(\"hourly\", \"wind_speed_10m,wind_gusts_10m,wind_direction_10m,pressure_msl\");\n u.searchParams.set(\"wind_speed_unit\", \"ms\");\n u.searchParams.set(\"timezone\", \"UTC\");\n u.searchParams.set(\"forecast_days\", \"3\");\n const r = await fetchJson(u.toString());\n if (!r.ok) return { rec: null, status: r.status, why: r.error };\n const h = r.json?.hourly ?? {};\n const times = Array.isArray(h.time) ? h.time.map((x: any) => `${String(x)}:00Z`.replace(\":00:00Z\", \":00:00Z\")) : [];\n if (!times.length) return { rec: null, status: r.status, why: \"empty\" };\n const now = Date.now();\n let start = times.findIndex((t: string) => Date.parse(t) >= now - 3_600_000);\n if (start < 0) start = 0;\n const base = times[start];\n const indices = chooseByTimes(times, (i) => i, base);\n if (!indices) return { rec: null, status: r.status, why: \"missing-leads\" };\n return {\n status: r.status,\n rec: {\n src: \"om\",\n run: null,\n v: base,\n c: [LAT, LON],\n w: indices.vals.map((i: any) => round(h.wind_speed_10m?.[i], 2)),\n g: indices.vals.map((i: any) => round(h.wind_gusts_10m?.[i], 2)),\n d: indices.vals.map((i: any) => round(h.wind_direction_10m?.[i], 1)),\n p: indices.vals.map((i: any) => round(h.pressure_msl?.[i], 1)),\n },\n };\n}\n\nexport default async function () {\n const retrieved = new Date().toISOString();\n const slot = floor3hIso();\n\n const dmi = await fromDmi();\n let chosen = dmi.rec;\n let metStatus: number | null = null;\n let metWhy: string | null = null;\n let omStatus: number | null = null;\n let omWhy: string | null = null;\n\n if (!chosen) {\n const met = await fromMet();\n metStatus = met.status;\n metWhy = met.why ?? null;\n chosen = met.rec;\n }\n if (!chosen) {\n const om = await fromOpenMeteo();\n omStatus = om.status;\n omWhy = om.why ?? null;\n chosen = om.rec;\n }\n\n await sqlite.execute({ sql: `CREATE TABLE IF NOT EXISTS house_forecast (\n slot_utc TEXT PRIMARY KEY,\n retrieved_utc TEXT NOT NULL,\n source TEXT NOT NULL,\n source_run TEXT,\n base_valid TEXT,\n payload TEXT,\n dmi_status INTEGER,\n dmi_note TEXT,\n met_status INTEGER,\n met_note TEXT,\n om_status INTEGER,\n om_note TEXT\n )` });\n\n const source = chosen?.src ?? \"none\";\n const payload = chosen ? JSON.stringify(chosen) : null;\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO house_forecast\n (slot_utc,retrieved_utc,source,source_run,base_valid,payload,dmi_status,dmi_note,met_status,met_note,om_status,om_note)\n VALUES (?,?,?,?,?,?,?,?,?,?,?,?)`,\n args: [\n slot, retrieved, source, chosen?.run ?? null, chosen?.v ?? null, payload,\n dmi.status, dmi.why ?? null, metStatus, metWhy, omStatus, omWhy,\n ],\n });\n\n const result = {\n ok: !!chosen,\n slot,\n source,\n dmi: { status: dmi.status, note: dmi.why ?? null },\n met: { status: metStatus, note: metWhy },\n openMeteo: { status: omStatus, note: omWhy },\n leadsHours: [...LEADS],\n record: chosen,\n };\n console.log(JSON.stringify(result));\n return result;\n}\n\n",[192],"80fb5f6e-b84a-4e92-a7eb-46717962c496","dmi-streymoy.ts","ff183220-ae9e-11f1-b86c-1607ee4eb77e",55,["D",1789243546234],21,"// 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",[200],"pulls","branches","forks","envVars",{"_214":61,"_216":61},"connections",{"_214":61,"_215":61},"count","unfilledCount","emptyCount",{"_42":199,"_32":200,"_30":201,"_139":-5,"_40":41,"_39":202,"_140":24,"_37":251,"_13":204,"_33":34,"_35":205,"_23":26,"_142":-5,"_227":252,"_27":253},{"_42":191,"_32":192,"_30":193,"_139":-5,"_40":41,"_39":194,"_140":26,"_37":248,"_13":196,"_33":158,"_35":197,"_23":26,"_142":-5,"_227":249,"_27":250},{"_42":184,"_32":185,"_30":186,"_139":-5,"_40":41,"_39":187,"_140":24,"_37":245,"_13":181,"_33":34,"_35":189,"_23":26,"_142":-5,"_227":246,"_27":247},{"_42":176,"_32":177,"_30":178,"_139":-5,"_40":41,"_39":179,"_140":24,"_37":242,"_13":181,"_33":34,"_35":182,"_23":26,"_142":-5,"_227":243,"_27":244},{"_42":168,"_32":169,"_30":170,"_139":-5,"_40":41,"_39":171,"_140":24,"_37":239,"_13":173,"_33":158,"_35":174,"_23":26,"_142":-5,"_227":240,"_27":241},{"_42":161,"_32":162,"_30":163,"_139":-5,"_40":41,"_39":164,"_140":24,"_37":236,"_13":61,"_33":34,"_35":166,"_23":26,"_142":-5,"_227":237,"_27":238},{"_42":152,"_32":153,"_30":154,"_139":-5,"_40":41,"_39":155,"_140":24,"_37":233,"_13":157,"_33":158,"_35":159,"_23":26,"_142":-5,"_227":234,"_27":235},{"_42":144,"_32":145,"_30":56,"_139":-5,"_40":41,"_39":146,"_140":24,"_37":230,"_13":148,"_33":149,"_35":150,"_23":26,"_142":-5,"_227":231,"_27":232},{"_42":138,"_32":28,"_30":31,"_139":-5,"_40":41,"_39":14,"_140":26,"_37":226,"_13":61,"_33":34,"_35":36,"_23":26,"_142":-5,"_227":228,"_27":229},["D",1789253266690],"children",[],[28],["D",1787560973168],[],[145],["D",1789156187200],[],[153],["D",1789156178257],[],[162],["D",1789111224129],[],[169],["D",1789145078105],[],[177],["D",1789145078598],[],[185],["D",1789243920071],[],[192],["D",1789243546234],[],[200],["D",1787559428678],["D",1789562426294],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":54,"_103":104,"_105":26},{"_13":87,"_32":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"ctx",{"_80":-5,"_126":292,"_293":294,"_295":296,"_297":26,"_298":26,"_299":26,"_300":24,"_301":-5,"_302":-7,"_303":-7,"_304":61,"_305":26,"_306":26,"_307":-5,"_308":26,"_309":26,"_310":26,"_311":-5},"ENV",{"_263":264,"_265":266,"_267":88,"_268":269,"_270":271,"_272":273,"_274":275,"_276":277,"_278":279,"_280":281,"_282":283,"_284":285,"_286":287,"_288":289,"_290":291},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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 · v64