[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_179":180,"_181":182},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_102":84,"_27":103,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":120,"_121":-5,"_122":-5,"_123":124},"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":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",27,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":37,"_35":36,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","511dd6be-e1ff-11f0-a5d0-42dde27851f2","name","fileType","script","content","import { DateTime } from \"https://esm.sh/luxon@3.5.0\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst USER_AGENT = \"rh-temp-forecast (you@example.com)\"; // put real contact\n\n// Robinhood settlement site: CLI location \"SFO\"\nconst SITES: Record<\n string,\n { cliLocation: string; stationId: string; lat: number; lon: number }\n> = {\n SFO: {\n cliLocation: \"SFO\",\n stationId: \"KSFO\",\n lat: 37.6188056,\n lon: -122.3754167,\n },\n};\n\n// Try a couple independent models. Open-Meteo availability varies; failures are handled.\nconst OPEN_METEO_MODELS = [\"hrrr\", \"gfs_global\"];\n\nfunction clamp(x: number, a: number, b: number) {\n return Math.max(a, Math.min(b, x));\n}\nfunction mean(xs: number[]) {\n return xs.reduce((a, b) => a + b, 0) / Math.max(1, xs.length);\n}\nfunction stddev(xs: number[]) {\n if (xs.length < 2) return NaN;\n const m = mean(xs);\n const v = xs.reduce((acc, x) => acc + (x - m) ** 2, 0) / (xs.length - 1);\n return Math.sqrt(v);\n}\n\n// Normal CDF approximation (sufficient for pricing)\nfunction normCdf(z: number) {\n const t = 1 / (1 + 0.2316419 * Math.abs(z));\n const d = 0.3989423 * Math.exp(-z * z / 2);\n let p = d * t *\n (0.3193815 +\n t * (-0.3565638 +\n t * (1.781478 +\n t * (-1.821256 +\n t * 1.330274))));\n if (z > 0) p = 1 - p;\n return p;\n}\n\ntype SqlResult = {\n columns: string[];\n rows: any[][];\n rowsAffected: number;\n lastInsertRowid: any;\n};\n\nfunction rowsToObjects(res: SqlResult): T[] {\n return (res.rows ?? []).map((row) =>\n Object.fromEntries(row.map((v, i) => [res.columns[i], v])) as T\n );\n}\n\nasync function initDb() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS predictions (\n site TEXT NOT NULL,\n dateLocal TEXT NOT NULL,\n tz TEXT NOT NULL,\n issuedAtUTC TEXT NOT NULL,\n meanHigh REAL NOT NULL,\n sigma REAL NOT NULL,\n componentsJson TEXT,\n PRIMARY KEY (site, dateLocal)\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS settlements (\n site TEXT NOT NULL,\n dateLocal TEXT NOT NULL,\n settledHigh INTEGER NOT NULL,\n forecastMean REAL NOT NULL,\n error REAL NOT NULL,\n productId TEXT,\n issuanceDateLocal TEXT,\n settledAtUTC TEXT NOT NULL,\n PRIMARY KEY (site, dateLocal)\n )\n `);\n\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_settlements_site_date\n ON settlements(site, dateLocal)\n `);\n}\n\nasync function dbSavePrediction(row: {\n site: string;\n dateLocal: string;\n tz: string;\n issuedAtUTC: string;\n meanHigh: number;\n sigma: number;\n components: any;\n}) {\n await sqlite.execute({\n sql: `\n INSERT INTO predictions(site, dateLocal, tz, issuedAtUTC, meanHigh, sigma, componentsJson)\n VALUES (?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(site, dateLocal) DO UPDATE SET\n tz=excluded.tz,\n issuedAtUTC=excluded.issuedAtUTC,\n meanHigh=excluded.meanHigh,\n sigma=excluded.sigma,\n componentsJson=excluded.componentsJson\n `,\n args: [\n row.site,\n row.dateLocal,\n row.tz,\n row.issuedAtUTC,\n row.meanHigh,\n row.sigma,\n JSON.stringify(row.components ?? null),\n ],\n });\n}\n\nasync function dbGetRecentErrors(site: string, limit = 60): Promise {\n const res = await sqlite.execute({\n sql: `\n SELECT error\n FROM settlements\n WHERE site = ?\n ORDER BY dateLocal DESC\n LIMIT ?\n `,\n args: [site, limit],\n });\n const objs = rowsToObjects<{ error: any }>(res as any);\n return objs.map((o) => Number(o.error)).filter((x) => Number.isFinite(x));\n}\n\nfunction calibratedParams(errors: number[]) {\n // Conservative prior until you have real settlement history\n const priorSigma = 3.5; // °F\n const minSigma = 2.0;\n\n if (errors.length < 5) {\n return { muErr: 0, sigma: priorSigma, n: errors.length };\n }\n const mu = mean(errors);\n const sd = stddev(errors);\n\n // mild shrinkage + prevent overconfidence\n const muErr = mu * 0.7;\n const sigmaRaw = Number.isFinite(sd) ? sd : priorSigma;\n const sigma = clamp(\n Math.sqrt(sigmaRaw * sigmaRaw + priorSigma * priorSigma * 0.2),\n minSigma,\n 8,\n );\n\n return { muErr, sigma, n: errors.length };\n}\n\nasync function fetchJson(url: string, accept = \"application/geo+json\") {\n const r = await fetch(url, {\n headers: { \"User-Agent\": USER_AGENT, \"Accept\": accept },\n });\n if (!r.ok) throw new Error(`Fetch failed ${r.status} for ${url}`);\n return r.json();\n}\n\nasync function getNwsHourly(lat: number, lon: number) {\n const points = await fetchJson(\n `https://api.weather.gov/points/${lat},${lon}`,\n );\n const tz = points.properties.timeZone as string;\n const hourlyUrl = points.properties.forecastHourly as string;\n\n const hourly = await fetchJson(hourlyUrl);\n const periods = hourly.properties.periods as Array<\n { startTime: string; temperature: number; temperatureUnit: string }\n >;\n\n return {\n tz,\n hours: periods.map((p) => ({\n t: DateTime.fromISO(p.startTime),\n tempF: p.temperatureUnit === \"F\"\n ? p.temperature\n : (p.temperature * 9) / 5 + 32,\n })),\n };\n}\n\nasync function getLatestNwsObservation(stationId: string) {\n const j = await fetchJson(\n `https://api.weather.gov/stations/${stationId}/observations/latest`,\n );\n const ts = j.properties.timestamp as string;\n const tempC = j.properties.temperature?.value;\n if (!ts || tempC === null || tempC === undefined) return null;\n return {\n obsTimeUTC: DateTime.fromISO(ts).toUTC(),\n tempF: (tempC * 9) / 5 + 32,\n };\n}\n\nfunction highForLocalDate(\n hours: Array<{ t: DateTime; tempF: number }>,\n tz: string,\n localISODate: string,\n) {\n const todays = hours\n .map((h) => ({ ...h, local: h.t.setZone(tz) }))\n .filter((h) => h.local.toISODate() === localISODate);\n if (!todays.length) return null;\n return Math.max(...todays.map((h) => h.tempF));\n}\n\nfunction nearestForecastTemp(\n hours: Array<{ t: DateTime; tempF: number }>,\n whenUTC: DateTime,\n) {\n let best = hours[0];\n let bestAbs = Infinity;\n for (const h of hours) {\n const d = Math.abs(h.t.toUTC().diff(whenUTC).as(\"minutes\"));\n if (d < bestAbs) {\n bestAbs = d;\n best = h;\n }\n }\n return best.tempF;\n}\n\nfunction adjustedHighForToday(\n hours: Array<{ t: DateTime; tempF: number }>,\n tz: string,\n todayISO: string,\n obsUTC: DateTime,\n biasF: number,\n tauHours = 6,\n) {\n const obs = obsUTC.toUTC();\n const todays = hours\n .map((h) => ({ ...h, local: h.t.setZone(tz) }))\n .filter((h) => h.local.toISODate() === todayISO);\n\n let maxAdj = -Infinity;\n for (const h of todays) {\n const leadHours = Math.max(0, h.t.toUTC().diff(obs).as(\"hours\"));\n const w = Math.exp(-leadHours / tauHours);\n const tadj = h.tempF + biasF * w;\n if (tadj > maxAdj) maxAdj = tadj;\n }\n return maxAdj;\n}\n\nasync function getOpenMeteoHourly(\n lat: number,\n lon: number,\n tz: string,\n model: string,\n) {\n const url = new URL(\"https://api.open-meteo.com/v1/forecast\");\n url.searchParams.set(\"latitude\", String(lat));\n url.searchParams.set(\"longitude\", String(lon));\n url.searchParams.set(\"hourly\", \"temperature_2m\");\n url.searchParams.set(\"temperature_unit\", \"fahrenheit\");\n url.searchParams.set(\"timezone\", tz);\n url.searchParams.set(\"forecast_days\", \"2\");\n url.searchParams.set(\"models\", model);\n\n const r = await fetch(url.toString(), {\n headers: { \"User-Agent\": USER_AGENT },\n });\n if (!r.ok) {\n throw new Error(`Open-Meteo failed ${r.status} for model=${model}`);\n }\n const j = await r.json();\n\n const times: string[] = j.hourly?.time ?? [];\n const temps: number[] = j.hourly?.temperature_2m ?? [];\n return times.map((t, i) => ({\n t: DateTime.fromISO(t, { zone: tz }),\n tempF: temps[i],\n }));\n}\n\nasync function modelHighsForToday(\n lat: number,\n lon: number,\n tz: string,\n todayISO: string,\n) {\n const highs: Record = {};\n for (const model of OPEN_METEO_MODELS) {\n try {\n const hrs = await getOpenMeteoHourly(lat, lon, tz, model);\n const todays = hrs.filter((h) => h.t.toISODate() === todayISO);\n if (todays.length) highs[model] = Math.max(...todays.map((h) => h.tempF));\n } catch {\n // model not available / failed; ignore\n }\n }\n return highs;\n}\n\nexport default async function (req: Request): Promise {\n try {\n await initDb();\n\n const url = new URL(req.url);\n const site = (url.searchParams.get(\"site\") || \"SFO\").toUpperCase();\n const strike = Number(url.searchParams.get(\"strike\") ?? \"0\");\n\n const cfg = SITES[site];\n if (!cfg) {\n return new Response(\n JSON.stringify({ error: `Unknown site ${site}` }, null, 2),\n { status: 400 },\n );\n }\n\n // Forecast basis: NWS hourly (already strong)\n const { tz, hours } = await getNwsHourly(cfg.lat, cfg.lon);\n const todayISO = DateTime.now().setZone(tz).toISODate()!;\n\n const nwsHigh = highForLocalDate(hours, tz, todayISO);\n if (nwsHigh === null) throw new Error(\"No NWS hourly data for today.\");\n\n // Observation correction: NWS latest station obs\n const obs = await getLatestNwsObservation(cfg.stationId);\n let bias = 0;\n let nwsAdjHigh = nwsHigh;\n if (obs) {\n const tNwsNow = nearestForecastTemp(hours, obs.obsTimeUTC);\n bias = obs.tempF - tNwsNow;\n nwsAdjHigh = adjustedHighForToday(\n hours,\n tz,\n todayISO,\n obs.obsTimeUTC,\n bias,\n 6,\n );\n }\n\n // Independent model signal(s) via Open-Meteo\n const modelHighs = await modelHighsForToday(cfg.lat, cfg.lon, tz, todayISO);\n const modelVals = Object.values(modelHighs).filter((x) =>\n Number.isFinite(x)\n );\n const modelMedian = modelVals.length\n ? modelVals.slice().sort((a, b) =>\n a - b\n )[Math.floor(modelVals.length / 2)]\n : null;\n\n // Blend\n const blended = modelMedian === null\n ? nwsAdjHigh\n : (0.65 * nwsAdjHigh + 0.35 * modelMedian);\n\n // Calibration against settlement: use recent settlement errors for this site\n const errors = await dbGetRecentErrors(site, 60);\n const { muErr, sigma, n } = calibratedParams(errors);\n\n // Mean prediction for settlement high (after bias correction learned from history)\n const meanHigh = blended + muErr;\n\n // Probability for Robinhood “High > strike”\n // Continuity correction: treat integer high; P(H > X) ~ 1 - Φ((X+0.5 - μ)/σ)\n const z = ((strike + 0.5) - meanHigh) / sigma;\n const pYes = 1 - normCdf(z);\n\n // Save today’s prediction (so the scheduled settler can score it tomorrow)\n await dbSavePrediction({\n site,\n dateLocal: todayISO,\n tz,\n issuedAtUTC: DateTime.utc().toISO()!,\n meanHigh,\n sigma,\n components: {\n nwsHigh,\n nwsAdjHigh,\n obsBiasF: bias,\n modelHighs,\n modelMedian,\n blended,\n calibN: n,\n muErr,\n },\n });\n\n const out = {\n site,\n dateLocal: todayISO,\n timeZone: tz,\n\n meanHighF: Math.round(meanHigh * 10) / 10,\n sigmaF: Math.round(sigma * 10) / 10,\n calibN: n,\n\n strikeF: strike,\n pHighGreaterThanStrike: Math.round(pYes * 10000) / 10000,\n fairPrice: Math.round(pYes * 10000) / 10000,\n\n debug: {\n nwsHighF: Math.round(nwsHigh * 10) / 10,\n nwsAdjHighF: Math.round(nwsAdjHigh * 10) / 10,\n obsBiasF: Math.round(bias * 10) / 10,\n modelHighs,\n },\n };\n\n return new Response(JSON.stringify(out, null, 2), {\n headers: { \"content-type\": \"application/json\" },\n });\n } catch (e: any) {\n return new Response(\n JSON.stringify({ error: String(e?.message ?? e) }, null, 2),\n {\n status: 500,\n headers: { \"content-type\": \"application/json\" },\n },\n );\n }\n}","http","createdAt",["D",1766714730627],"branchVersion","branchId","0990179a-e1f4-11f0-8dec-42dde27851f2","id","098fe1ee-e1f4-11f0-8dec-42dde27851f2","get-high-temp",["D",1766709869715],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","019aeb5a-8601-72dc-933c-5116c9b9ad52","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019aeb5a-8601-72dc-933c-5699b88cb012","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_101":97},"org",{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},"branch",{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned",40,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","jvt012","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzM2T2tsUkc5c3FHYlNtOG1TamQxZ0pSZzdWWiJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":175,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":176,"_78":177,"_80":178,"_82":25},"tree",[162,163,164],"files",[162,163,164],"counts",{"_151":60,"_152":153,"_154":60,"_155":156,"_157":158},"contents",[125,126,127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":143,"_32":144,"_30":145,"_129":-5,"_41":42,"_40":146,"_130":25,"_38":147,"_13":148,"_33":34,"_35":149,"_24":25,"_133":-5,"_27":150},{"_43":135,"_32":136,"_30":137,"_129":-5,"_41":42,"_40":138,"_130":120,"_38":139,"_13":140,"_33":37,"_35":141,"_24":25,"_133":-5,"_27":142},{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":25,"_38":131,"_13":132,"_33":37,"_35":36,"_24":25,"_133":-5,"_27":134},"5ae51748-e1ff-11f0-9dd6-42dde27851f2","parentId","latest",["D",1766714730627],3,"label",[28],"4e1c47f2-e1ff-11f0-95b2-42dde27851f2","initial-works.ts","09916244-e1f4-11f0-8dec-42dde27851f2",23,["D",1766714709178],7,"import { DateTime } from \"https://esm.sh/luxon@3.5.0\";\n\nconst USER_AGENT = \"airport-high-forecast (jwa012@ciceroisback.com)\"; // required by NWS\n\n// Keep this list to ~10 airports. Hardcode lat/lon for simplicity & reliability.\nconst AIRPORTS: Record<\n string,\n { icao: string; iata?: string; lat: number; lon: number }\n> = {\n KLAX: { icao: \"KLAX\", iata: \"LAX\", lat: 33.9425, lon: -118.4081 },\n KHOU: { icao: \"KHOU\", iata: \"HOU\", lat: 29.6454, lon: -95.2789 },\n KSEA: { icao: \"KSEA\", iata: \"SEA\", lat: 47.4472, lon: -122.31361 },\n KMIA: { icao: \"KMIA\", iata: \"MIA\", lat: 25.79, lon: -80.32 },\n KMDW: { icao: \"KMDW\", iata: \"MDW\", lat: 41.78, lon: -87.65 },\n KAUS: { icao: \"KAUS\", iata: \"AUS\", lat: 30.18, lon: -97.68 },\n KDEN: { icao: \"KDEN\", iata: \"DEN\", lat: 39.85, lon: -104.66 },\n KSFO: { icao: \"KSFO\", iata: \"SFO\", lat: 37.61961, lon: -122.36558 },\n KDFW: { icao: \"KDFW\", iata: \"DFW\", lat: 32.9, lon: -97.02 },\n};\n\nfunction resolveStation(params: URLSearchParams) {\n const icaoParam = (params.get(\"icao\") || \"\").toUpperCase();\n const iataParam = (params.get(\"iata\") || \"\").toUpperCase();\n\n if (icaoParam && AIRPORTS[icaoParam]) return AIRPORTS[icaoParam];\n\n if (iataParam) {\n const match = Object.values(AIRPORTS).find((a) => a.iata === iataParam);\n if (match) return match;\n }\n return null;\n}\n\nasync function fetchJson(url: string) {\n const r = await fetch(url, {\n headers: { \"User-Agent\": USER_AGENT, \"Accept\": \"application/geo+json\" },\n });\n if (!r.ok) throw new Error(`Fetch failed ${r.status} for ${url}`);\n return r.json();\n}\n\nasync function getNwsHourly(lat: number, lon: number) {\n const points = await fetchJson(\n `https://api.weather.gov/points/${lat},${lon}`,\n );\n const tz = points.properties.timeZone as string;\n const hourlyUrl = points.properties.forecastHourly as string;\n\n const hourly = await fetchJson(hourlyUrl);\n const periods = hourly.properties.periods as Array<\n { startTime: string; temperature: number; temperatureUnit: string }\n >;\n\n // NWS hourly startTime is ISO with offset; Luxon will parse correctly.\n return {\n tz,\n hours: periods.map((p) => ({\n t: DateTime.fromISO(p.startTime),\n tempF: p.temperatureUnit === \"F\"\n ? p.temperature\n : (p.temperature * 9) / 5 + 32,\n })),\n };\n}\n\n// function parseAddsCsv(text: string): Array> {\n// // ADDS returns comment lines starting with #, then a header row.\n// const lines = text.split(\"\\n\").map((l) => l.trim()).filter((l) =>\n// l && !l.startsWith(\"#\")\n// );\n// if (lines.length < 2) return [];\n// const header = lines[0].split(\",\").map((s) => s.trim());\n// return lines.slice(1).map((line) => {\n// const cols = line.split(\",\");\n// const row: Record = {};\n// for (let i = 0; i < header.length; i++) {\n// row[header[i]] = (cols[i] ?? \"\").trim();\n// }\n// return row;\n// });\n// }\n\nasync function getLatestNwsObservation(stationId: string) {\n const url =\n `https://api.weather.gov/stations/${stationId}/observations/latest`;\n\n const r = await fetch(url, {\n headers: {\n \"User-Agent\": USER_AGENT,\n \"Accept\": \"application/geo+json\",\n },\n });\n if (!r.ok) {\n throw new Error(`NWS obs fetch failed ${r.status} for ${stationId}`);\n }\n const j = await r.json();\n\n const ts = j.properties.timestamp as string; // ISO time\n const tempC = j.properties.temperature?.value; // degC, may be null\n\n if (!ts || tempC === null || tempC === undefined) return null;\n\n return {\n obsTime: DateTime.fromISO(ts).toUTC(),\n tempF: (tempC * 9) / 5 + 32,\n raw: j.properties,\n };\n}\n\nfunction todayHighForLocalDate(\n hours: Array<{ t: DateTime; tempF: number }>,\n tz: string,\n localDateISO: string,\n) {\n const todays = hours\n .map((h) => ({ ...h, local: h.t.setZone(tz) }))\n .filter((h) => h.local.toISODate() === localDateISO);\n\n if (!todays.length) return null;\n\n let max = -Infinity;\n let maxTime: DateTime | null = null;\n for (const h of todays) {\n if (h.tempF > max) {\n max = h.tempF;\n maxTime = h.local;\n }\n }\n return { highF: max, atLocal: maxTime! };\n}\n\nfunction nearestForecastTemp(\n hours: Array<{ t: DateTime; tempF: number }>,\n whenUTC: DateTime,\n) {\n let best = hours[0];\n let bestAbs = Infinity;\n for (const h of hours) {\n const d = Math.abs(h.t.toUTC().diff(whenUTC).as(\"minutes\"));\n if (d < bestAbs) {\n bestAbs = d;\n best = h;\n }\n }\n return best.tempF;\n}\n\nfunction adjustedHigh(\n hours: Array<{ t: DateTime; tempF: number }>,\n tz: string,\n localDateISO: string,\n obsUTC: DateTime,\n biasF: number,\n tauHours = 6,\n) {\n const obs = obsUTC.toUTC();\n const todays = hours\n .map((h) => ({ ...h, local: h.t.setZone(tz) }))\n .filter((h) => h.local.toISODate() === localDateISO);\n\n let maxAdj = -Infinity;\n for (const h of todays) {\n const leadHours = Math.max(0, h.t.toUTC().diff(obs).as(\"hours\"));\n const weight = Math.exp(-leadHours / tauHours);\n const tadj = h.tempF + biasF * weight;\n if (tadj > maxAdj) maxAdj = tadj;\n }\n return maxAdj;\n}\n\nfunction clamp(x: number, a: number, b: number) {\n return Math.max(a, Math.min(b, x));\n}\n\nexport default async function (req: Request): Promise {\n try {\n const url = new URL(req.url);\n const airport = resolveStation(url.searchParams);\n if (!airport) {\n return new Response(\n JSON.stringify(\n {\n error: \"Pass eg ?icao=KLAX or ?iata=LAX.\",\n },\n null,\n 2,\n ),\n {\n status: 400,\n headers: { \"content-type\": \"application/json\" },\n },\n );\n }\n\n const { tz, hours } = await getNwsHourly(airport.lat, airport.lon);\n const nowLocal = DateTime.now().setZone(tz);\n const todayISO = nowLocal.toISODate()!;\n\n const base = todayHighForLocalDate(hours, tz, todayISO);\n if (!base) throw new Error(\"No NWS hourly data for today.\");\n\n const metar = await getLatestNwsObservation(airport.icao);\n\n let highAdj = base.highF;\n let bias = 0;\n\n if (metar) {\n const tNwsNow = nearestForecastTemp(hours, metar.obsTime);\n bias = metar.tempF - tNwsNow;\n highAdj = adjustedHigh(hours, tz, todayISO, metar.obsTime, bias, 6);\n }\n\n const range = clamp(\n 2 + 0.6 * Math.abs(highAdj - base.highF) + 0.3 * Math.abs(bias),\n 2,\n 8,\n );\n\n const out = {\n station: airport.icao,\n iata: airport.iata ?? null,\n dateLocal: todayISO,\n timeZone: tz,\n\n forecastHighF: Math.round(highAdj),\n confidencePlusMinusF: Math.round(range),\n\n debug: {\n nwsHighF: Math.round(base.highF),\n nwsHighTimeLocal: base.atLocal.toISO(),\n metarUsed: Boolean(metar),\n biasF: Math.round(bias * 10) / 10,\n metarObsTimeUTC: metar?.obsTime.toISO() ?? null,\n metarTempF: metar ? Math.round(metar.tempF * 10) / 10 : null,\n },\n };\n\n return new Response(JSON.stringify(out, null, 2), {\n headers: { \"content-type\": \"application/json\" },\n });\n } catch (e: any) {\n return new Response(\n JSON.stringify({ error: String(e?.message ?? e) }, null, 2),\n {\n status: 500,\n headers: { \"content-type\": \"application/json\" },\n },\n );\n }\n}",[136],"e34fbeee-e1fa-11f0-bc63-42dde27851f2","daily-record-cli.ts","de92e124-e1fa-11f0-9c5f-42dde27851f2",15,["D",1766712812014],2,"import { DateTime } from \"https://esm.sh/luxon@3.5.0\";\nimport { kv } from \"https://esm.town/v/std/kv\";\n\nconst USER_AGENT = \"your-valtown-hightemp (you@example.com)\";\n\nconst SITES = [\"SFO\"]; // add more later\n\nasync function fetchJson(url: string) {\n const r = await fetch(url, {\n headers: { \"User-Agent\": USER_AGENT, \"Accept\": \"application/geo+json\" },\n });\n if (!r.ok) throw new Error(`Fetch failed ${r.status} for ${url}`);\n return r.json();\n}\n\nasync function fetchText(url: string) {\n const r = await fetch(url, {\n headers: { \"User-Agent\": USER_AGENT, \"Accept\": \"text/plain\" },\n });\n if (!r.ok) throw new Error(`Fetch failed ${r.status} for ${url}`);\n return r.text();\n}\n\n// Attempt to parse CLI text for:\n// - DATE (the product date, usually “DATE: MM/DD/YYYY”)\n// - YESTERDAY MAXIMUM value\nfunction parseCliYesterdayHigh(\n cliText: string,\n): { productDate?: string; maxF?: number } {\n const t = cliText.replace(/\\r/g, \"\");\n\n const dateMatch = t.match(/DATE:\\s*(\\d{2}\\/\\d{2}\\/\\d{4})/);\n const productDate = dateMatch?.[1];\n\n // Look for the YESTERDAY section then MAXIMUM\n // This is intentionally tolerant; CLI format varies slightly by WFO.\n const yesterdayIdx = t.search(/\\bYESTERDAY\\b/i);\n const slice = yesterdayIdx >= 0\n ? t.slice(yesterdayIdx, yesterdayIdx + 800)\n : t;\n\n const maxMatch = slice.match(/\\bMAXIMUM\\b\\s+(-?\\d{1,3})\\b/);\n const maxF = maxMatch ? Number(maxMatch[1]) : undefined;\n\n return { productDate, maxF };\n}\n\n// Find settlement high for a local date using NWS Products API (CLI type).\n// We search recent products and match by “product DATE minus 1 day”.\nasync function getSettlementHighForDate(\n cliLocation: string,\n targetLocalISO: string,\n) {\n const listUrl =\n `https://api.weather.gov/products/types/CLI/locations/${cliLocation}?limit=20`;\n const listing = await fetchJson(listUrl);\n const items: Array<{ id: string }> = listing[\"@graph\"] ?? [];\n\n for (const it of items) {\n const prod = await fetchJson(`https://api.weather.gov/products/${it.id}`);\n const text: string = prod?.productText;\n if (!text) continue;\n\n const parsed = parseCliYesterdayHigh(text);\n if (!parsed.productDate || parsed.maxF === undefined) continue;\n\n // CLI “DATE” is the issuance day; it reports “YESTERDAY” as the prior day.\n const issuance = DateTime.fromFormat(parsed.productDate, \"MM/dd/yyyy\", {\n zone: \"America/Los_Angeles\",\n });\n const yesterday = issuance.minus({ days: 1 }).toISODate();\n\n if (yesterday === targetLocalISO) {\n return {\n maxF: parsed.maxF,\n productId: it.id,\n issuanceDate: issuance.toISODate(),\n };\n }\n }\n return null;\n}\n\nasync function getCalib(site: string) {\n const obj = (await kv.get(`calib:${site}`)) as any;\n return { errors: (obj?.errors ?? []) as number[] };\n}\n\nasync function putCalib(site: string, errors: number[]) {\n await kv.set(`calib:${site}`, {\n errors: errors.slice(-60),\n updatedAtUTC: DateTime.utc().toISO(),\n });\n}\n\nexport default async function settleAndCalibrate() {\n // settle “yesterday” in the settlement timezone.\n const target = DateTime.now().setZone(\"America/Los_Angeles\").minus({\n days: 1,\n }).toISODate()!;\n\n for (const site of SITES) {\n const predKey = `pred:${site}:${target}`;\n const pred = (await kv.get(predKey)) as any;\n if (!pred) continue; // no prediction stored for that day\n\n // already settled?\n const settledKey = `settled:${site}:${target}`;\n if (await kv.get(settledKey)) continue;\n\n const settlement = await getSettlementHighForDate(site, target);\n if (!settlement) continue; // CLI not posted/found yet\n\n const settledHigh = settlement.maxF;\n const forecastMean = Number(pred.meanHigh);\n\n const error = settledHigh - forecastMean; // positive means we under-forecast\n\n const { errors } = await getCalib(site);\n errors.push(error);\n await putCalib(site, errors);\n\n await kv.set(settledKey, {\n site,\n dateLocal: target,\n settledHighF: settledHigh,\n forecastMeanF: forecastMean,\n errorF: error,\n productId: settlement.productId,\n issuanceDateLocal: settlement.issuanceDate,\n settledAtUTC: DateTime.utc().toISO(),\n });\n }\n\n return { ok: true, targetDate: target };\n}",[144],"pulls","branches",1,"forks","envVars",{"_159":60,"_161":60},"connections",{"_159":60,"_160":60},"count","unfilledCount","emptyCount",{"_43":143,"_32":144,"_30":145,"_129":-5,"_41":42,"_40":146,"_130":25,"_38":172,"_13":148,"_33":34,"_35":149,"_24":25,"_133":-5,"_166":173,"_27":174},{"_43":135,"_32":136,"_30":137,"_129":-5,"_41":42,"_40":138,"_130":120,"_38":169,"_13":140,"_33":37,"_35":141,"_24":25,"_133":-5,"_166":170,"_27":171},{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":25,"_38":165,"_13":132,"_33":37,"_35":36,"_24":25,"_133":-5,"_166":167,"_27":168},["D",1766714730627],"children",[],[28],["D",1766714709178],[],[136],["D",1766712812014],[],[144],["D",1766709869715],{"_94":93,"_101":97},{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_76":-5,"_122":212,"_213":214,"_215":216,"_217":25,"_218":25,"_219":25,"_220":120,"_221":-5,"_222":-7,"_223":-7,"_224":60,"_225":25,"_226":25,"_227":-5,"_228":25,"_229":25,"_230":25,"_231":-5},"ENV",{"_183":184,"_185":186,"_187":84,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v27