[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_248":249,"_250":251},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":59,"_127":-5,"_128":-5,"_129":130},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",59,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","house-forecast.ts","latestPath","fileId","fc85d3ae-aee5-11f1-93fc-1607ee4eb77e","name","fileType","script","content","// 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\", \"GeoJSON\");\n const r = await fetchJson(u.toString());\n if (!r.ok) return { rec: null, status: r.status, why: r.error };\n const features = Array.isArray(r.json?.features) ? r.json.features : [];\n const rows = features\n .map((f: any) => ({ time: String(f?.properties?.step ?? \"\"), p: f?.properties ?? {}, c: f?.geometry?.coordinates }))\n .filter((x: any) => Number.isFinite(Date.parse(x.time)))\n .sort((a: any, b: any) => Date.parse(a.time) - Date.parse(b.time));\n if (!rows.length) return { rec: null, status: r.status, why: \"empty\" };\n const base = rows[0].time;\n const picked = chooseByTimes(rows.map((x: any) => x.time), (i) => rows[i], base);\n if (!picked) return { rec: null, status: r.status, why: \"missing-leads\" };\n const c = Array.isArray(rows[0].c) && rows[0].c.length >= 2 ? [Number(rows[0].c[1]), Number(rows[0].c[0])] as [number, number] : [LAT, LON];\n return {\n status: r.status,\n rec: {\n src: \"dmi\",\n run: base,\n v: base,\n c,\n w: picked.vals.map((x: any) => round(x.p[\"wind-speed-10m\"], 2)),\n g: picked.vals.map((x: any) => round(x.p[\"gust-wind-speed-10m\"], 2)),\n d: picked.vals.map((x: any) => round(x.p[\"wind-dir-10m\"], 1)),\n p: picked.vals.map((x: any) => {\n const v = round(x.p[\"pressure-sealevel\"], 0);\n return v === null ? null : round(v / 100, 1);\n }),\n },\n };\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 return {\n status: r.status,\n rec: {\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 };\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\nasync function run() {\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\nawait run();\n","// 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\", \"GeoJSON\");\n const r = await fetchJson(u.toString());\n if (!r.ok) return { rec: null, status: r.status, why: r.error };\n const features = Array.isArray(r.json?.features) ? r.json.features : [];\n const rows = features\n .map((f: any) => ({ time: String(f?.properties?.step ?? \"\"), p: f?.properties ?? {}, c: f?.geometry?.coordinates }))\n .filter((x: any) => Number.isFinite(Date.parse(x.time)))\n .sort((a: any, b: any) => Date.parse(a.time) - Date.parse(b.time));\n if (!rows.length) return { rec: null, status: r.status, why: \"empty\" };\n const base = rows[0].time;\n const picked = chooseByTimes(rows.map((x: any) => x.time), (i) => rows[i], base);\n if (!picked) return { rec: null, status: r.status, why: \"missing-leads\" };\n const c = Array.isArray(rows[0].c) && rows[0].c.length >= 2 ? [Number(rows[0].c[1]), Number(rows[0].c[0])] as [number, number] : [LAT, LON];\n return {\n status: r.status,\n rec: {\n src: \"dmi\",\n run: base,\n v: base,\n c,\n w: picked.vals.map((x: any) => round(x.p[\"wind-speed-10m\"], 2)),\n g: picked.vals.map((x: any) => round(x.p[\"gust-wind-speed-10m\"], 2)),\n d: picked.vals.map((x: any) => round(x.p[\"wind-dir-10m\"], 1)),\n p: picked.vals.map((x: any) => {\n const v = round(x.p[\"pressure-sealevel\"], 0);\n return v === null ? null : round(v / 100, 1);\n }),\n },\n };\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\nasync function run() {\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\nawait run();\n","createdAt",["D",1789243879900],"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",1789562426294],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",70,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","tollakurhansen","handle","displayName","Tollakur Hansen","avatar","https://lh3.googleusercontent.com/a/ACg8ocIkcv4dcqpZnSluPFgO40QnqyMc2wlVkOeC6qAjg0Xe5zOOkP0q=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":243,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":244,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":245,"_84":246,"_86":247,"_88":25},"tree",[210,211,212,213,214,215,216,217],"files",[210,211,212,213,214,215,216,217],"counts",{"_200":63,"_201":179,"_202":63,"_203":204,"_205":206},"contents",[131,132,133,134,135,136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":192,"_32":193,"_30":194,"_141":-5,"_41":42,"_40":195,"_143":59,"_38":196,"_13":197,"_33":34,"_35":198,"_24":25,"_148":-5,"_27":199},{"_43":189,"_32":28,"_30":31,"_141":-5,"_41":42,"_40":14,"_143":25,"_38":190,"_13":145,"_33":34,"_35":37,"_24":25,"_148":-5,"_27":191},{"_43":182,"_32":183,"_30":184,"_141":-5,"_41":42,"_40":185,"_143":59,"_38":186,"_13":179,"_33":34,"_35":187,"_24":25,"_148":-5,"_27":188},{"_43":174,"_32":175,"_30":176,"_141":-5,"_41":42,"_40":177,"_143":59,"_38":178,"_13":179,"_33":34,"_35":180,"_24":25,"_148":-5,"_27":181},{"_43":166,"_32":167,"_30":168,"_141":-5,"_41":42,"_40":169,"_143":59,"_38":170,"_13":171,"_33":156,"_35":172,"_24":25,"_148":-5,"_27":173},{"_43":159,"_32":160,"_30":161,"_141":-5,"_41":42,"_40":162,"_143":59,"_38":163,"_13":63,"_33":34,"_35":164,"_24":25,"_148":-5,"_27":165},{"_43":150,"_32":151,"_30":152,"_141":-5,"_41":42,"_40":153,"_143":59,"_38":154,"_13":155,"_33":156,"_35":157,"_24":25,"_148":-5,"_27":158},{"_43":139,"_32":140,"_30":57,"_141":-5,"_41":42,"_40":142,"_143":59,"_38":144,"_13":145,"_33":146,"_35":147,"_24":25,"_148":-5,"_27":149},"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",[140],"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",[151],"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",[160],"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",[167],"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",[175],"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",[183],"9a1ecc5e-dd9e-4024-a180-b57ecfb06c4a",["D",1789243879900],[28],"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",[193],"pulls","branches","forks","envVars",{"_207":63,"_209":63},"connections",{"_207":63,"_208":63},"count","unfilledCount","emptyCount",{"_43":192,"_32":193,"_30":194,"_141":-5,"_41":42,"_40":195,"_143":59,"_38":240,"_13":197,"_33":34,"_35":198,"_24":25,"_148":-5,"_219":241,"_27":242},{"_43":189,"_32":28,"_30":31,"_141":-5,"_41":42,"_40":14,"_143":25,"_38":237,"_13":145,"_33":34,"_35":37,"_24":25,"_148":-5,"_219":238,"_27":239},{"_43":182,"_32":183,"_30":184,"_141":-5,"_41":42,"_40":185,"_143":59,"_38":234,"_13":179,"_33":34,"_35":187,"_24":25,"_148":-5,"_219":235,"_27":236},{"_43":174,"_32":175,"_30":176,"_141":-5,"_41":42,"_40":177,"_143":59,"_38":231,"_13":179,"_33":34,"_35":180,"_24":25,"_148":-5,"_219":232,"_27":233},{"_43":166,"_32":167,"_30":168,"_141":-5,"_41":42,"_40":169,"_143":59,"_38":228,"_13":171,"_33":156,"_35":172,"_24":25,"_148":-5,"_219":229,"_27":230},{"_43":159,"_32":160,"_30":161,"_141":-5,"_41":42,"_40":162,"_143":59,"_38":225,"_13":63,"_33":34,"_35":164,"_24":25,"_148":-5,"_219":226,"_27":227},{"_43":150,"_32":151,"_30":152,"_141":-5,"_41":42,"_40":153,"_143":59,"_38":222,"_13":155,"_33":156,"_35":157,"_24":25,"_148":-5,"_219":223,"_27":224},{"_43":139,"_32":140,"_30":57,"_141":-5,"_41":42,"_40":142,"_143":59,"_38":218,"_13":145,"_33":146,"_35":147,"_24":25,"_148":-5,"_219":220,"_27":221},["D",1787560973168],"children",[],[140],["D",1789156187200],[],[151],["D",1789156178257],[],[160],["D",1789111224129],[],[167],["D",1789145078105],[],[175],["D",1789145078598],[],[183],["D",1789243879900],[],[28],["D",1789243546234],[],[193],["D",1787559428678],["D",1789562426294],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_128":281,"_282":283,"_284":285,"_286":25,"_287":25,"_288":25,"_289":59,"_290":-5,"_291":-7,"_292":-7,"_293":63,"_294":25,"_295":25,"_296":-5,"_297":25,"_298":25,"_299":25,"_300":-5},"ENV",{"_252":253,"_254":255,"_256":90,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276,"_277":278,"_279":280},"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 · v59