No data yet - wait for the next cron run

\", { headers: { \"content-type\": \"text/html\" } });\n }\n\n if (latest.error) {\n const dbg = (latest.debug || []).join(\"
\");\n return new Response(\"

Data source problem

\" + dbg + \"

\", { headers: { \"content-type\": \"text/html\" } });\n }\n\n const wave = latest.wave;\n const wind = latest.wind;\n const spots = latest.spots || [];\n const go = latest.go;\n const sc = go ? \"#00d4aa\" : \"#ff6450\";\n const checked = new Date(latest.checkedAt).toLocaleString(\"en-NZ\", { timeZone: \"Pacific/Auckland\" });\n const windGood = wind.knots <= 5 || (wind.deg >= 202.5 && wind.deg <= 247.5 && wind.knots < 30);\n\n let rows = \"\";\n for (const s of spots) {\n const spotGo = s.predicted >= 1.2 && windGood;\n const c = spotGo ? \"#00d4aa\" : \"#ff6450\";\n rows += \"\" + s.name + \"\"\n + \"\" + s.predicted.toFixed(2) + \"m\"\n + \"\" + s.offshore.toFixed(2) + \"m x \" + s.factor.toFixed(2) + \"\"\n + \"\" + (spotGo ? \"GO\" : \"-\") + \"\";\n }\n\n let buoyLine = wave.source + \": \" + wave.height.toFixed(2) + \"m
\";\n if (wave.all && wave.all.length > 0) {\n buoyLine = \"\";\n for (const r of wave.all) {\n buoyLine += r.name + \" \" + r.height.toFixed(2) + \"m @ \" + r.time + \"
\";\n }\n }\n\n let options = \"\";\n for (const id in SPOT_NAMES) {\n options += \"\";\n }\n\n const dbgLine = (latest.debug || []).join(\"
\");\n\n const html = \"\"\n + \"\"\n + \"Surf - The Mount\"\n + \"

\"\n + \"

MOUNT MAUNGANUI COAST

\"\n + \"

\" + (go ? \"GO SURF\" : \"NOT YET\") + \"

\"\n + (saved ? \"

Observation saved - predictions updated

\" : \"\")\n + \"

Predicted by spot (NW to SE)

\"\n + \"\"\n + rows + \"

SPOT

PRED

OFFSHORE x FACTOR

\"\n + \"

Raw data

\"\n + \"Waves (\" + (wave.real ? \"REAL BUOY\" : \"MODEL\") + \"):
\" + buoyLine\n + \"Wind: \" + wind.knots.toFixed(1) + \"kn \" + latest.dir + \" \" + wind.deg.toFixed(0) + \"deg, gust \" + wind.gust.toFixed(1) + \"kn \" + (windGood ? \"(OK)\" : \"(no)\") + \"
\"\n + \"Rules: spot 1.2m+ AND (wind 5kn- OR SW under 30kn)
\"\n + \"last check \" + checked\n + (dbgLine ? \"

Diagnostics:
\" + dbgLine : \"\")\n + \"

\"\n + \"

Train it - what did you actually see?

\"\n + \"\"\n + \"

\" + log.length + \" observations logged

\"\n + \"

\";\n\n return new Response(html, { headers: { \"content-type\": \"text/html\" } });\n}","deleted","label",[116],"71985dcd-01a8-4fba-beca-d1f20ecc4a5d","main.ts","83e906b2-7fd5-11f1-b365-1607ee4eb77e",5,["D",1784072240787],4,"interval","// SURF ALERT — Mount Maunganui coast (Cron — every 15 min)\nconst NTFY_TOPIC = Deno.env.get(\"NTFY_TOPIC\") ?? \"\";\nconst QUIET_START = 20.5, QUIET_END = 5.5;\nconst BASE =\n \"https://monitoring.boprc.govt.nz/MonitoredSites/cgi-bin/hydwebserver.cgi\";\nconst KNOWN_BUOYS: Record = { \"Pukehina\": 241 };\nconst BUOY_POS: Record = {\n Bowentown: { lng: 175.99 },\n Pukehina: { lng: 176.53 },\n};\nconst SPOTS = [\n { id: \"main\", name: \"Main Beach\", lng: 176.178 },\n { id: \"tay\", name: \"Tay St\", lng: 176.195 },\n { id: \"hart\", name: \"Hart St\", lng: 176.202 },\n { id: \"surfrd\", name: \"Omanu / Surf Rd\", lng: 176.211 },\n { id: \"arataki\", name: \"Arataki / Yale St\", lng: 176.227 },\n { id: \"pony\", name: \"Pony Club / Papamoa Dom\", lng: 176.253 },\n];\n\nfunction isSW(deg: number) {\n return deg >= 202.5 && deg <= 247.5;\n}\n\nfunction dirLabel(deg: number) {\n const d = [\n \"N\",\n \"NNE\",\n \"NE\",\n \"ENE\",\n \"E\",\n \"ESE\",\n \"SE\",\n \"SSE\",\n \"S\",\n \"SSW\",\n \"SW\",\n \"WSW\",\n \"W\",\n \"WNW\",\n \"NW\",\n \"NNW\",\n ];\n return d[Math.round(deg / 22.5) % 16];\n}\n\nfunction fetchT(url: string, ms = 10000) {\n return fetch(url, {\n headers: {\n \"User-Agent\": \"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7)\",\n },\n signal: AbortSignal.timeout(ms),\n });\n}\n\nasync function discoverBuoys(blob: any) {\n const cached = await blob.getJSON(\"surf-buoy-ids\").catch(() => null);\n if (cached) return cached;\n const ids: Record = { ...KNOWN_BUOYS };\n try {\n const html = await (await fetchT(BASE + \"/sites\")).text();\n const m = html.match(/details\\?site=(\\d+)[^>]*>[^<]*Bowentown/i) ||\n html.match(/site=(\\d+)[^<]{0,120}Bowentown/i);\n if (m) ids[\"Bowentown\"] = parseInt(m[1]);\n } catch {}\n await blob.setJSON(\"surf-buoy-ids\", ids);\n return ids;\n}\n\nasync function readBuoy(name: string, site: number) {\n try {\n const html = await (await fetchT(BASE + \"/sites/details?site=\" + site))\n .text();\n const m = html.match(\n /Sig\\.?\\s*Wave\\s*Height[\\s\\S]{0,120}?([\\d.]+)\\s*metres[\\s\\S]{0,40}?(\\d{2}-\\w{3}-\\d{4}\\s\\d{2}:\\d{2})/i,\n );\n if (!m) return null;\n const height = parseFloat(m[1]);\n const ts = new Date(m[2] + \" GMT+1200\");\n if ((Date.now() - ts.getTime()) / 3.6e6 > 2 || isNaN(height)) return null;\n return { name: name, height: height, time: m[2] };\n } catch {\n return null;\n }\n}\n\nexport default async function cron() {\n const { blob } = await import(\"https://esm.town/v/std/blob\");\n const ids = await discoverBuoys(blob);\n const entries = Object.entries(ids) as [string, number][];\n const results = await Promise.all(entries.map(function (e) {\n return readBuoy(e[0], e[1]);\n }));\n const readings = results.filter(Boolean) as any[];\n\n let wave: any;\n if (readings.length > 0) {\n let best = readings[0];\n for (const r of readings) if (r.height > best.height) best = r;\n wave = {\n height: best.height,\n source: best.name + \" buoy\",\n time: best.time,\n real: true,\n all: readings,\n };\n } else {\n const r = await fetchT(\n \"https://marine-api.open-meteo.com/v1/marine?latitude=-37.6333&longitude=176.1833¤t=wave_height&timezone=Pacific/Auckland\",\n );\n const j = await r.json();\n wave = {\n height: j.current.wave_height,\n source: \"Open-Meteo MODEL (buoys down)\",\n time: j.current.time,\n real: false,\n all: [],\n };\n }\n\n const wr = await fetchT(\n \"https://api.open-meteo.com/v1/forecast?latitude=-37.6333&longitude=176.1833¤t=wind_speed_10m,wind_direction_10m,wind_gusts_10m&wind_speed_unit=kn&timezone=Pacific/Auckland\",\n );\n const wj = await wr.json();\n const wind = {\n knots: wj.current.wind_speed_10m,\n deg: wj.current.wind_direction_10m,\n gust: wj.current.wind_gusts_10m,\n };\n\n const rawFactors = await blob.getJSON(\"surf-spot-factors\").catch(function () {\n return null;\n });\n const factors: Record = rawFactors ? rawFactors : {};\n\n let bowen: number | null = null;\n let puke: number | null = null;\n for (const r of wave.all) {\n if (r.name === \"Bowentown\") bowen = r.height;\n if (r.name === \"Pukehina\") puke = r.height;\n }\n\n const spots = SPOTS.map(function (s) {\n let offshore: number;\n if (bowen !== null && puke !== null) {\n const t = (s.lng - BUOY_POS.Bowentown.lng) /\n (BUOY_POS.Pukehina.lng - BUOY_POS.Bowentown.lng);\n offshore = bowen * (1 - t) + puke * t;\n } else if (bowen !== null) {\n offshore = bowen;\n } else if (puke !== null) {\n offshore = puke;\n } else {\n offshore = wave.height;\n }\n const factor = factors[s.id] !== undefined ? factors[s.id] : 1.0;\n return {\n id: s.id,\n name: s.name,\n lng: s.lng,\n offshore: Math.round(offshore * 100) / 100,\n predicted: Math.round(offshore * factor * 100) / 100,\n factor: Math.round(factor * 100) / 100,\n };\n });\n\n const windGood = wind.knots <= 5 || (isSW(wind.deg) && wind.knots < 30);\n const goSpots = spots.filter(function (s) {\n return s.predicted >= 1.2;\n });\n const go = windGood && goSpots.length > 0;\n\n await blob.setJSON(\"surf-latest\", {\n checkedAt: new Date().toISOString(),\n wave: wave,\n wind: wind,\n spots: spots,\n go: go,\n dir: dirLabel(wind.deg),\n });\n\n const nz = new Date().toLocaleString(\"en-NZ\", {\n timeZone: \"Pacific/Auckland\",\n hour: \"numeric\",\n minute: \"numeric\",\n hour12: false,\n });\n const parts = nz.split(\":\");\n const hourDec = Number(parts[0]) + Number(parts[1]) / 60;\n const quiet = hourDec >= QUIET_START || hourDec < QUIET_END;\n\n const prev = await blob.getJSON(\"surf-state\").catch(function () {\n return null;\n });\n const lastNotified = prev && prev.lastNotified ? prev.lastNotified : 0;\n const wasGo = prev && prev.go ? true : false;\n const hoursSince = (Date.now() - lastNotified) / 3.6e6;\n\n if (go && !quiet && (!wasGo || hoursSince >= 2)) {\n let bestSpot = goSpots[0];\n for (const s of goSpots) if (s.predicted > bestSpot.predicted) bestSpot = s;\n let buoyLine = wave.height.toFixed(2) + \"m \" + wave.source;\n if (wave.all.length > 1) {\n buoyLine = wave.all.map(function (r: any) {\n return r.name + \" \" + r.height.toFixed(2) + \"m\";\n }).join(\" / \");\n }\n const spotLine = goSpots.map(function (s) {\n return s.name + \" \" + s.predicted + \"m\";\n }).join(\" / \");\n await fetch(\"https://ntfy.sh/\" + NTFY_TOPIC, {\n method: \"POST\",\n headers: {\n Title: \"GO SURF - best: \" + bestSpot.name + \" ~\" + bestSpot.predicted +\n \"m\",\n Priority: \"high\",\n Tags: \"ocean\",\n },\n body: spotLine + \" | Buoys: \" + buoyLine + \" | Wind \" +\n wind.knots.toFixed(1) + \"kn \" + dirLabel(wind.deg) +\n (wave.real ? \"\" : \" (model)\"),\n });\n await blob.setJSON(\"surf-state\", { go: go, lastNotified: Date.now() });\n } else {\n await blob.setJSON(\"surf-state\", { go: go, lastNotified: lastNotified });\n }\n\n return {\n go: go,\n real: wave.real,\n source: wave.source,\n buoys: wave.all,\n wind: wind,\n spots: spots,\n };\n}",[132],"pulls",1,"forks","envVars",{"_147":141,"_149":54},"connections",{"_147":54,"_148":54},"count","unfilledCount","emptyCount",{"_20":131,"_13":132,"_117":133,"_118":-5,"_119":21,"_120":134,"_121":50,"_22":156,"_29":136,"_124":137,"_126":138,"_128":38,"_129":-5,"_153":157,"_91":158},{"_20":115,"_13":116,"_117":48,"_118":-5,"_119":21,"_120":30,"_121":50,"_22":152,"_29":123,"_124":125,"_126":127,"_128":38,"_129":-5,"_153":154,"_91":155},["D",1784076260808],"children",[],[116],["D",1784072240787],[],[132],["D",1784069044282],{"_11":12,"_89":85},{"_11":12,"_82":83,"_84":85,"_45":46,"_86":87,"_88":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_77":-5,"_78":-5,"_79":-5,"_80":14,"_81":12},"ctx",{"_70":-5,"_110":196,"_197":198,"_199":200,"_201":38,"_202":38,"_203":38,"_204":50,"_205":-5,"_206":-7,"_207":-7,"_208":54,"_209":38,"_210":38,"_211":-5,"_212":38,"_213":38,"_214":38,"_215":-5},"ENV",{"_167":168,"_169":170,"_171":26,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195},"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