[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_244":245,"_246":247},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_93":-7,"_94":95,"_29":-7,"_96":-5,"_15":97,"_98":99,"_100":101,"_102":103,"_104":105,"_106":-5,"_107":-5,"_108":-5,"_109":38,"_110":111,"_112":50,"_113":-5,"_114":-5,"_115":116},"routes/_app.x.$handle.$name.branches",{"_11":12,"_13":14,"_15":16,"_17":18},"handle","tollakurhansen","name","weather-logger","project",{"_20":28,"_13":14,"_22":36,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":50,"_51":-5,"_52":-5,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":-5,"_64":65,"_66":65,"_67":68,"_69":68,"_70":68,"_71":65,"_72":65,"_73":74,"_75":76,"_77":78,"_79":38},"branches",[19],{"_20":21,"_22":23,"_24":25,"_13":26,"_27":28,"_29":30,"_31":-5,"_32":-5,"_33":34,"_35":-5},"id","2542b9b0-76b4-4575-963f-bb75e9e9bdf5","createdAt",["D",1787559428678],"updatedAt",["D",1789297918250],"main","projectId","b6406ee1-e1d7-40a6-bb87-c6d16cec69d3","version",70,"forkedBranchId","forkedBranchVersion","lockfileKey","1789297918469-esm.town_v_tollakurhansen_weather-logger@70-main","deletedAt",["D",1787559428678],"legacyEnvVars",false,"privacy","public","httpPrivacy","description","Logs weather station data to SQLite every 30 min","imageUrl","userId","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",{"_11":12,"_92":88},"org",{"_11":12,"_85":86,"_87":88,"_45":46,"_89":90,"_91":38},"branch",{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_80":-5,"_81":-5,"_82":-5,"_83":14,"_84":12},"isOwned","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Tollakur Hansen","avatar","https://lh3.googleusercontent.com/a/ACg8ocIkcv4dcqpZnSluPFgO40QnqyMc2wlVkOeC6qAjg0Xe5zOOkP0q=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","path","","adoptOrgId",{"_20":28,"_13":14,"_22":239,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":50,"_51":-5,"_52":-5,"_53":54,"_55":56,"_57":58,"_59":60,"_61":240,"_63":-5,"_64":65,"_66":65,"_67":68,"_69":68,"_70":68,"_71":65,"_72":65,"_73":241,"_75":242,"_77":243,"_79":38},"tree",[206,207,208,209,210,211,212,213],"files",[206,207,208,209,210,211,212,213],"counts",{"_197":54,"_17":172,"_198":54,"_199":200,"_201":202},"contents",[117,118,119,120,121,122,123,124],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_20":189,"_13":190,"_127":191,"_128":-5,"_129":21,"_130":192,"_132":50,"_22":193,"_29":194,"_135":156,"_137":195,"_139":38,"_140":-5,"_94":196},{"_20":182,"_13":183,"_127":184,"_128":-5,"_129":21,"_130":30,"_132":50,"_22":185,"_29":186,"_135":148,"_137":187,"_139":38,"_140":-5,"_94":188},{"_20":175,"_13":176,"_127":177,"_128":-5,"_129":21,"_130":178,"_132":50,"_22":179,"_29":172,"_135":156,"_137":180,"_139":38,"_140":-5,"_94":181},{"_20":167,"_13":168,"_127":169,"_128":-5,"_129":21,"_130":170,"_132":50,"_22":171,"_29":172,"_135":156,"_137":173,"_139":38,"_140":-5,"_94":174},{"_20":159,"_13":160,"_127":161,"_128":-5,"_129":21,"_130":162,"_132":50,"_22":163,"_29":164,"_135":148,"_137":165,"_139":38,"_140":-5,"_94":166},{"_20":151,"_13":152,"_127":153,"_128":-5,"_129":21,"_130":154,"_132":50,"_22":155,"_29":54,"_135":156,"_137":157,"_139":38,"_140":-5,"_94":158},{"_20":142,"_13":143,"_127":144,"_128":-5,"_129":21,"_130":145,"_132":50,"_22":146,"_29":147,"_135":148,"_137":149,"_139":38,"_140":-5,"_94":150},{"_20":125,"_13":126,"_127":48,"_128":-5,"_129":21,"_130":131,"_132":50,"_22":133,"_29":134,"_135":136,"_137":138,"_139":38,"_140":-5,"_94":141},"af3dca10-e92c-4b63-b9e8-3be2ab67f0c0","weather.csv.ts","fileId","parentId","branchId","branchVersion",10,"latest",["D",1787560973168],3,"fileType","http","content","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","deleted","label",[126],"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",[143],"9ca02f29-4b97-4d7b-bd2b-4ba459d225c9","weather-cron.pre-empty-status-20260911.ts","ec0ab3c2-ae19-11f1-a413-1607ee4eb77e",32,["D",1789156178257],"script","// 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",[152],"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",[160],"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",[168],"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",[176],"74510b6d-26ed-4774-82b9-a3480c34bf52","house-forecast.ts","fc85d3ae-aee5-11f1-93fc-1607ee4eb77e",["D",1789297918250],8,"// 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\nfunction parseDmiCoverage(cov: any, status: number, run: string | null): { rec: RecordShape | null; status: number; why?: string } {\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, why: \"empty-time-axis\" };\n const base = times[0];\n const picked = chooseByTimes(times, (i) => i, base);\n if (!picked) return { rec: null, 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, 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,\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, rec } : { status, rec: null, why: \"incomplete-required-fields\" };\n}\n\nfunction dmiPositionUrl(instanceId?: string): string {\n const base = instanceId\n ? DMI.replace(/\\/position$/, `/instances/${encodeURIComponent(instanceId)}/position`)\n : DMI;\n const u = new URL(base);\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 return u.toString();\n}\n\nasync function fromDmi(): Promise<{ rec: RecordShape | null; status: number; why?: string }> {\n const latest = await fetchJson(dmiPositionUrl());\n if (latest.ok) {\n const parsed = parseDmiCoverage(latest.json, latest.status, null);\n if (parsed.rec) return parsed;\n }\n\n const latestFailure = latest.ok ? \"latest-unusable\" : latest.error;\n const instancesUrl = DMI.replace(/\\/position$/, \"/instances\");\n const instances = await fetchJson(instancesUrl);\n if (!instances.ok) {\n return { rec: null, status: latest.ok ? latest.status : latest.status, why: `${latestFailure};instances=${instances.error}` };\n }\n\n const ids = Array.isArray(instances.json?.instances)\n ? instances.json.instances.map((x: any) => x?.id).filter((x: unknown): x is string => typeof x === \"string\")\n : [];\n if (!ids.length) return { rec: null, status: latest.ok ? latest.status : latest.status, why: `${latestFailure};instances=empty` };\n\n for (const id of ids.slice(0, 3)) {\n const r = await fetchJson(dmiPositionUrl(id));\n if (!r.ok) continue;\n const parsed = parseDmiCoverage(r.json, r.status, id);\n if (parsed.rec) return { ...parsed, why: `instance-fallback:${id};latest=${latestFailure}` };\n }\n\n return { rec: null, status: latest.ok ? latest.status : latest.status, why: `${latestFailure};instance-fallback-failed` };\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",[183],"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",[190],"pulls","forks","envVars",{"_203":54,"_205":54},"connections",{"_203":54,"_204":54},"count","unfilledCount","emptyCount",{"_20":189,"_13":190,"_127":191,"_128":-5,"_129":21,"_130":192,"_132":50,"_22":236,"_29":194,"_135":156,"_137":195,"_139":38,"_140":-5,"_215":237,"_94":238},{"_20":182,"_13":183,"_127":184,"_128":-5,"_129":21,"_130":30,"_132":50,"_22":233,"_29":186,"_135":148,"_137":187,"_139":38,"_140":-5,"_215":234,"_94":235},{"_20":175,"_13":176,"_127":177,"_128":-5,"_129":21,"_130":178,"_132":50,"_22":230,"_29":172,"_135":156,"_137":180,"_139":38,"_140":-5,"_215":231,"_94":232},{"_20":167,"_13":168,"_127":169,"_128":-5,"_129":21,"_130":170,"_132":50,"_22":227,"_29":172,"_135":156,"_137":173,"_139":38,"_140":-5,"_215":228,"_94":229},{"_20":159,"_13":160,"_127":161,"_128":-5,"_129":21,"_130":162,"_132":50,"_22":224,"_29":164,"_135":148,"_137":165,"_139":38,"_140":-5,"_215":225,"_94":226},{"_20":151,"_13":152,"_127":153,"_128":-5,"_129":21,"_130":154,"_132":50,"_22":221,"_29":54,"_135":156,"_137":157,"_139":38,"_140":-5,"_215":222,"_94":223},{"_20":142,"_13":143,"_127":144,"_128":-5,"_129":21,"_130":145,"_132":50,"_22":218,"_29":147,"_135":148,"_137":149,"_139":38,"_140":-5,"_215":219,"_94":220},{"_20":125,"_13":126,"_127":48,"_128":-5,"_129":21,"_130":131,"_132":50,"_22":214,"_29":134,"_135":136,"_137":138,"_139":38,"_140":-5,"_215":216,"_94":217},["D",1787560973168],"children",[],[126],["D",1789156187200],[],[143],["D",1789156178257],[],[152],["D",1789111224129],[],[160],["D",1789145078105],[],[168],["D",1789145078598],[],[176],["D",1789297918250],[],[183],["D",1789243546234],[],[190],["D",1787559428678],["D",1789475460618],{"_11":12,"_92":88},{"_11":12,"_85":86,"_87":88,"_45":46,"_89":90,"_91":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_80":-5,"_81":-5,"_82":-5,"_83":14,"_84":12},"ctx",{"_73":-5,"_114":277,"_278":279,"_280":281,"_282":38,"_283":38,"_284":38,"_285":50,"_286":-5,"_287":-7,"_288":-7,"_289":54,"_290":38,"_291":38,"_292":-5,"_293":38,"_294":38,"_295":38,"_296":-5},"ENV",{"_248":249,"_250":251,"_252":26,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Branches1

Branches
1