Henry Hub Forward Curve

${s.name}

${s.note}

\n $${money(s.avg)}\n

\n ${signed(s.chg)} vs prior\n

\n `;\n}\n\nfunction curveRow(q: Quote, shade: boolean): string {\n const bg = shade ? \"#F7FAFD\" : \"#FFFFFF\";\n const cell =\n `padding:7px 10px;font-family:Arial,Helvetica,sans-serif;font-size:13px;border-bottom:1px solid #EDF2F7;`;\n const flag = q.error\n ? ` no data`\n : q.stale\n ? ` settle`\n : \"\";\n return `\n \n ${q.n}\n ${q.ticker}\n ${q.label}${flag}\n ${\n q.price === null ? \"—\" : \"$\" + money(q.price)\n }\n ${signed(q.change)}\n ${\n q.pct === null ? \"—\" : signed(q.pct, 2) + \"%\"\n }\n `;\n}\n\nexport function renderReport(\n qs: Quote[],\n strips: Strip[],\n stamp: string,\n sampleNote = \"\",\n): string {\n const th =\n `padding:8px 10px;font-family:Arial,Helvetica,sans-serif;font-size:10px;font-weight:bold;` +\n `letter-spacing:.7px;text-transform:uppercase;color:#FFFFFF;background:${C.blue};`;\n\n // strips laid out two per row\n let tiles = \"\";\n for (let i = 0; i < strips.length; i += 2) {\n tiles += `${stripTile(strips[i])}${\n strips[i + 1]\n ? stripTile(strips[i + 1])\n : ''\n }`;\n }\n\n const priced = qs.filter((q) => q.change !== null && q.price !== null);\n const sorted = [...priced].sort((a, b) =>\n Math.abs(b.change!) - Math.abs(a.change!)\n );\n const movers = sorted.slice(0, 3)\n .map((q) =>\n `${q.label} ${signed(q.change)}`\n )\n .join(\" · \");\n\n const missing = qs.filter((q) => q.price === null);\n const warn = missing.length\n ? `\n ${missing.length} contract${\n missing.length > 1 ? \"s\" : \"\"\n } did not return a price:\n ${missing.map((m) => m.ticker).join(\", \")}\n `\n : \"\";\n\n const sample = sampleNote\n ? `${sampleNote}\n `\n : \"\";\n\n let rows = \"\", shade = false, lastYear = qs[0]?.year;\n for (const q of qs) {\n if (q.year !== lastYear) {\n shade = !shade;\n lastYear = q.year;\n }\n rows += curveRow(q, shade);\n }\n\n return `\n\nHenry Hub Forward Curve\n\n\n\n

\n \n\n \n\n \n\n ${\n movers\n ? ``\n : \"\"\n }\n\n \n\n \n\n

Henry Hub Forward Curve

NYMEX Natural Gas (NG) · 48-month strip · ${stamp}

\n ${sample}${warn}

\n ${tiles}

\n Biggest moves
\n ${movers}\n

\n \n \n \n \n \n \n \n \n \n ${rows}\n

#	Ticker	Contract	Last	Chg	%

\n Prices in $/MMBtu. Change is versus the prior session's close. Contracts marked\n settle did not trade in the latest session and show the last settlement.\n The 48-month window rolls forward automatically as each prompt month expires.
\n Source: Yahoo Finance delayed NYMEX data. Automated daily report — Sunlight Energy Group.\n

\n`;\n}\n\n// ------------------------------------------------- history + excel workbook\n\nexport interface Snapshot {\n date: string;\n quotes: Quote[];\n strips: Strip[];\n}\n\n/** Monday of the week containing an ISO (YYYY-MM-DD) date, as ISO. */\nfunction weekStart(iso: string): string {\n const [y, m, d] = iso.split(\"-\").map(Number);\n const dt = new Date(Date.UTC(y, m - 1, d));\n const mondayOffset = (dt.getUTCDay() + 6) % 7; // Mon=0 ... Sun=6\n dt.setUTCDate(dt.getUTCDate() - mondayOffset);\n return dt.toISOString().slice(0, 10);\n}\n\nconst isoOf = (t: { y: number; m: number; d: number }) =>\n `${t.y}-${String(t.m).padStart(2, \"0\")}-${String(t.d).padStart(2, \"0\")}`;\n\n/** \"Mon 08/18\" — the per-day column header inside a week tab. */\nfunction dayLabel(iso: string): string {\n const [y, m, d] = iso.split(\"-\").map(Number);\n const wd =\n [\n \"Sun\",\n \"Mon\",\n \"Tue\",\n \"Wed\",\n \"Thu\",\n \"Fri\",\n \"Sat\",\n ][new Date(Date.UTC(y, m - 1, d)).getUTCDay()];\n return `${wd} ${String(m).padStart(2, \"0\")}/${String(d).padStart(2, \"0\")}`;\n}\n\n/** Excel tab name: \"Aug 17 2026\" for the week beginning that Monday. */\nfunction sheetName(weekIso: string): string {\n const [y, m, d] = weekIso.split(\"-\").map(Number);\n return `${MONTH_ABBR[m - 1]} ${d} ${y}`.slice(0, 31);\n}\n\n/**\n * History is stored one blob PER WEEK, not per day.\n *\n * Val Town's free plan caps a run at 60 seconds. Day-keyed storage meant the\n * number of blob reads grew with history — 13 weeks would be 65 round trips\n * every morning, on top of 48 Yahoo lookups, against that same 60s budget.\n * Week-keyed storage fixes the read count at HISTORY_WEEKS (13) no matter how\n * many years this runs, so the job's cost stops growing.\n */\ninterface WeekBlob {\n week: string;\n days: Record;\n}\n\nconst weekKey = (iso: string) => `${BLOB_PREFIX}wk-${weekStart(iso)}`;\n\n/** Merge today's curve into its week's blob. Never throws — history is a bonus. */\nasync function saveSnapshot(snap: Snapshot): Promise {\n try {\n const key = weekKey(snap.date);\n let wk: WeekBlob;\n try {\n wk = await blob.getJSON(key) as WeekBlob;\n if (!wk?.days) throw new Error(\"empty\");\n } catch {\n wk = { week: weekStart(snap.date), days: {} };\n }\n wk.days[snap.date] = { quotes: snap.quotes, strips: snap.strips };\n await blob.setJSON(key, wk);\n } catch (e) {\n console.error(\"snapshot save failed:\", e);\n }\n}\n\n/** Load the most recent HISTORY_WEEKS weeks — a fixed number of reads. */\nasync function loadHistory(todayIso: string): Promise {\n try {\n const keys: string[] = [];\n const cursor = new Date(`${weekStart(todayIso)}T00:00:00Z`);\n for (let i = 0; i < HISTORY_WEEKS; i++) {\n keys.push(`${BLOB_PREFIX}wk-${cursor.toISOString().slice(0, 10)}`);\n cursor.setUTCDate(cursor.getUTCDate() - 7);\n }\n\n const blobs = await Promise.all(\n keys.map((k) =>\n blob.getJSON(k).catch(() => null) as Promise\n ),\n );\n\n const out: Snapshot[] = [];\n for (const wk of blobs) {\n if (!wk?.days) continue;\n for (const [date, v] of Object.entries(wk.days)) {\n if (Array.isArray(v?.quotes)) {\n out.push({ date, quotes: v.quotes, strips: v.strips ?? [] });\n }\n }\n }\n return out.sort((a, b) => a.date.localeCompare(b.date));\n } catch (e) {\n console.error(\"history load failed:\", e);\n return [];\n }\n}\n\n/** One week tab: contracts down the side, each session across the top. */\nfunction weekSheet(\n weekIso: string,\n days: Snapshot[],\n): (string | number | null)[][] {\n const cols = days.map((d) => d.date);\n const newest = days.at(-1)!;\n\n // Row order follows the newest session; anything that rolled off mid-week is\n // appended after it so no day's data silently disappears from the file.\n const order: string[] = newest.quotes.map((q) => q.ticker);\n const seen = new Set(order);\n for (const d of days) {\n for (const q of d.quotes) {\n if (!seen.has(q.ticker)) {\n seen.add(q.ticker);\n order.push(q.ticker);\n }\n }\n }\n\n const meta = new Map();\n for (const d of days) {\n for (const q of d.quotes) if (!meta.has(q.ticker)) meta.set(q.ticker, q);\n }\n\n const priceOn = (date: string, ticker: string): number | null => {\n const day = days.find((d) => d.date === date);\n const q = day?.quotes.find((x) => x.ticker === ticker);\n return q?.price ?? null;\n };\n\n const [wy, wm, wd] = weekIso.split(\"-\").map(Number);\n const rows: (string | number | null)[][] = [\n [`Henry Hub Forward Curve — week of ${MONTH_NAMES[wm - 1]} ${wd}, ${wy}`],\n [\"NYMEX Natural Gas (NG). Settlement prices in $/MMBtu.\"],\n [],\n [\"Ticker\", \"Contract Month\", \"Year\", ...cols.map(dayLabel), \"Wk Chg\"],\n ];\n\n for (const ticker of order) {\n const q = meta.get(ticker)!;\n const series = cols.map((c) => priceOn(c, ticker));\n const present = series.filter((v): v is number => v !== null);\n const wkChg = present.length >= 2\n ? +(present.at(-1)! - present[0]).toFixed(3)\n : null;\n rows.push([ticker, q.monthName, q.year, ...series, wkChg]);\n }\n\n rows.push([]);\n rows.push([\"Summary strips\", ...Array(2 + cols.length).fill(\"\"), \"\"]);\n rows.push([\"Strip\", \"Range\", \"\", ...cols.map(dayLabel), \"Wk Chg\"]);\n\n const stripNames: string[] = [];\n for (const d of days) {\n for (const s of d.strips) {\n if (!stripNames.includes(s.name)) stripNames.push(s.name);\n }\n }\n for (const name of stripNames) {\n const note = days.map((d) =>\n d.strips.find((s) => s.name === name)?.note\n ).find(Boolean) ?? \"\";\n const series = cols.map((c) => {\n const day = days.find((d) =>\n d.date === c\n );\n const v = day?.strips.find((s) => s.name === name)?.avg;\n return v === undefined || v === null ? null : +v.toFixed(3);\n });\n const present = series.filter((v): v is number => v !== null);\n const wkChg = present.length >= 2\n ? +(present.at(-1)! - present[0]).toFixed(3)\n : null;\n rows.push([name, note, \"\", ...series, wkChg]);\n }\n return rows;\n}\n\n/**\n * Build the workbook, newest week as the first tab.\n *\n * Tabs are appended in reverse chronological order, so this morning's week is\n * always the one Excel opens on and older weeks trail off to the right.\n * Returns base64 ready for the mail attachment, or null if anything went wrong\n * (the report still sends without the file rather than not sending at all).\n */\nfunction buildWorkbook(snaps: Snapshot[]): string | null {\n try {\n if (snaps.length === 0) return null;\n\n const byWeek = new Map();\n for (const s of snaps) {\n const w = weekStart(s.date);\n (byWeek.get(w) ?? byWeek.set(w, []).get(w)!).push(s);\n }\n\n const weeks = [...byWeek.keys()].sort().reverse(); // newest first\n const wb = XLSX.utils.book_new();\n\n for (const w of weeks) {\n const days = byWeek.get(w)!.sort((a, b) => a.date.localeCompare(b.date));\n const aoa = weekSheet(w, days);\n const ws = XLSX.utils.aoa_to_sheet(aoa);\n\n ws[\"!cols\"] = [\n { wch: 11 },\n { wch: 15 },\n { wch: 7 },\n ...days.map(() => ({ wch: 11 })),\n { wch: 9 },\n ];\n\n // Three decimals on every numeric price cell.\n for (const ref of Object.keys(ws)) {\n if (ref.startsWith(\"!\")) continue;\n const cell = ws[ref];\n if (cell?.t === \"n\" && !/^C\\d+$/.test(ref)) cell.z = \"0.000\"; // column C is Year\n }\n\n XLSX.utils.book_append_sheet(wb, ws, sheetName(w));\n }\n\n return XLSX.write(wb, { type: \"base64\", bookType: \"xlsx\" });\n } catch (e) {\n console.error(\"workbook build failed:\", e);\n return null;\n }\n}\n\n/** Plain-text fallback for clients that will not render HTML. */\nfunction renderText(qs: Quote[], strips: Strip[], stamp: string): string {\n const lines = [\n `HENRY HUB FORWARD CURVE — ${stamp}`,\n `NYMEX Natural Gas (NG), $/MMBtu, 48-month strip`,\n \"\",\n \"SUMMARY\",\n ...strips.map((s) =>\n ` ${s.name.padEnd(18)} $${money(s.avg)} (${signed(s.chg)}) ${s.note}`\n ),\n \"\",\n \"FULL CURVE\",\n ` ${\"#\".padStart(3)} ${\"TICKER\".padEnd(9)} ${\"CONTRACT\".padEnd(16)} ${\n \"LAST\".padStart(8)\n } ${\"CHG\".padStart(8)} ${\"%\".padStart(8)}`,\n ...qs.map((q) =>\n ` ${String(q.n).padStart(3)} ${q.ticker.padEnd(9)} ${\n (q.monthName + \" \" + q.year).padEnd(16)\n }` +\n ` ${money(q.price).padStart(8)} ${signed(q.change).padStart(8)}` +\n ` ${(q.pct === null ? \"—\" : signed(q.pct, 2) + \"%\").padStart(8)}`\n ),\n \"\",\n \"Source: Yahoo Finance delayed NYMEX data. Automated report — Sunlight Energy Group.\",\n ];\n return lines.join(\"\\n\");\n}\n\n// ------------------------------------------------------------------ handler\n\nexport default async function () {\n const t = easternNow();\n\n // The cron fires at both 12:30 and 13:30 UTC so that one of them is always\n // 8:30 AM Eastern. This guard discards the other, and skips weekends.\n if (!isReportTime(t)) return;\n\n const stamp = `${MONTH_NAMES[t.m - 1]} ${t.d}, ${t.y}`;\n\n try {\n const t0 = Date.now();\n const contracts = buildCurve();\n const quotes = await fetchCurve(contracts);\n const strips = buildStrips(quotes);\n console.log(`quotes fetched in ${((Date.now() - t0) / 1000).toFixed(1)}s`);\n\n const failed = quotes.filter((q) => q.price === null).length;\n const subject = failed > 6\n ? `⚠ Henry Hub Curve — ${stamp} (${failed} contracts missing)`\n : `Henry Hub Forward Curve — ${stamp} · Prompt $${\n money(quotes[0].price)\n }`;\n\n // Record today, then rebuild the rolling workbook from stored history.\n const today = isoOf(t);\n await saveSnapshot({ date: today, quotes, strips });\n const history = await loadHistory(today);\n if (!history.some((h) => h.date === today)) {\n history.push({ date: today, quotes, strips }); // blob lagged; use in-memory\n }\n const workbook = buildWorkbook(history);\n console.log(\n `total ${\n ((Date.now() - t0) / 1000).toFixed(1)\n }s · ${history.length} sessions of history · ` +\n `workbook ${\n workbook\n ? Math.round(workbook.length * 0.75 / 1024) + \" KB\"\n : \"FAILED\"\n }`,\n );\n\n await email({\n subject,\n html: renderReport(quotes, strips, stamp),\n text: renderText(quotes, strips, stamp),\n ...(RECIPIENTS.length ? { to: RECIPIENTS } : {}),\n ...(workbook\n ? {\n attachments: [{\n content: workbook,\n filename: `HenryHub_Curve_${today}.xlsx`,\n type:\n \"application/vnd.openxmlformats-officedocument.spreadsheetml.sheet\",\n disposition: \"attachment\",\n }],\n }\n : {}),\n });\n } catch (err) {\n await email({\n subject: `⚠ Henry Hub Curve report FAILED — ${stamp}`,\n text: `The daily gas curve report could not be generated.\\n\\n` +\n `${err instanceof Error ? err.stack ?? err.message : String(err)}\\n\\n` +\n `No prices were sent. The job will try again tomorrow at 8:30 AM ET.`,\n });\n }\n}\n\n// Exported so the pieces can be unit-tested or reused elsewhere.\nexport {\n buildCurve,\n buildStrips,\n buildWorkbook,\n easternNow,\n fetchCurve,\n isReportTime,\n lastTradeDate,\n promptMonth,\n renderText,\n sheetName,\n weekSheet,\n weekStart,\n};","deleted","label",[113],"pulls",1,"forks","envVars",{"_137":52,"_139":52},"connections",{"_137":52,"_138":52},"count","unfilledCount","emptyCount",{"_20":112,"_13":113,"_114":115,"_116":-5,"_117":21,"_118":30,"_119":120,"_22":141,"_29":122,"_123":124,"_125":126,"_127":38,"_128":-5,"_142":143,"_89":144},["D",1787348148080],"children",[],[113],["D",1787343743683],{"_11":12,"_87":83},{"_11":12,"_80":81,"_82":83,"_45":46,"_84":85,"_86":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_75":-5,"_76":-5,"_77":-5,"_78":14,"_79":12},"ctx",{"_68":-5,"_108":182,"_183":184,"_185":186,"_187":38,"_188":38,"_189":38,"_190":120,"_191":-5,"_192":-7,"_193":-7,"_194":52,"_195":38,"_196":38,"_197":-5,"_198":38,"_199":38,"_200":38,"_201":-5},"ENV",{"_153":154,"_155":156,"_157":26,"_158":159,"_160":161,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181},"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