Title	x

\", 1, \"x\"),\n ScrapeError,\n \"missing History section throws ScrapeError instead of silently returning []\",\n );\n\n // Structural breakage: History table exists but a row has the wrong cell count.\n assertThrows(\n () =>\n parsePatchHtml(\n `\n

Title

History

\n \n \n

When	Who	What
only-one-cell

`,\n 1,\n \"x\",\n ),\n ScrapeError,\n \"malformed history row (wrong cell count) throws ScrapeError\",\n );\n\n console.log(\"\\nAll tests passed.\");\n}\n\nawait main();\n",[18,83],"f24d1ff3-7537-4057-be70-98dc294402bc",["D",1788428721794],[18,67],"pulls","branches",1,"forks","envVars",{"_197":26,"_199":26},"connections",{"_197":26,"_198":26},"count","unfilledCount","emptyCount",{"_35":168,"_13":18,"_65":96,"_45":-5,"_37":38,"_169":42,"_170":24,"_39":277,"_41":26,"_68":69,"_172":-5,"_70":30,"_173":-5,"_218":278,"_17":279},{"_35":186,"_13":67,"_65":66,"_45":96,"_37":38,"_169":42,"_170":24,"_39":274,"_41":26,"_68":69,"_172":-5,"_70":30,"_173":-5,"_218":275,"_17":276},{"_35":267,"_13":268,"_65":269,"_45":66,"_37":38,"_169":42,"_170":24,"_39":270,"_41":26,"_68":21,"_172":271,"_70":30,"_173":-5,"_218":272,"_17":273},{"_35":182,"_13":83,"_65":82,"_45":96,"_37":38,"_169":76,"_170":24,"_39":264,"_41":26,"_68":84,"_172":184,"_70":30,"_173":-5,"_218":265,"_17":266},{"_35":178,"_13":95,"_65":94,"_45":96,"_37":38,"_169":87,"_170":24,"_39":261,"_41":26,"_68":84,"_172":180,"_70":30,"_173":-5,"_218":262,"_17":263},{"_35":254,"_13":255,"_65":256,"_45":-5,"_37":38,"_169":133,"_170":24,"_39":257,"_41":225,"_68":21,"_172":258,"_70":30,"_173":-5,"_218":259,"_17":260},{"_35":246,"_13":247,"_65":248,"_45":-5,"_37":38,"_169":249,"_170":24,"_39":250,"_41":191,"_68":84,"_172":251,"_70":30,"_173":-5,"_218":252,"_17":253},{"_35":238,"_13":239,"_65":240,"_45":-5,"_37":38,"_169":241,"_170":24,"_39":242,"_41":216,"_68":84,"_172":243,"_70":30,"_173":-5,"_218":244,"_17":245},{"_35":230,"_13":231,"_65":232,"_45":-5,"_37":38,"_169":233,"_170":24,"_39":234,"_41":26,"_68":84,"_172":235,"_70":30,"_173":-5,"_218":236,"_17":237},{"_35":221,"_13":222,"_65":109,"_45":-5,"_37":38,"_169":223,"_170":24,"_39":224,"_41":225,"_68":226,"_172":227,"_70":30,"_173":14,"_218":228,"_17":229},{"_35":211,"_13":212,"_65":213,"_45":-5,"_37":38,"_169":214,"_170":24,"_39":215,"_41":216,"_68":84,"_172":217,"_70":30,"_173":-5,"_218":219,"_17":220},"5651939a-71c1-48d7-9047-f413160d7592","rss.ts","7bbbb75a-a6c7-11f1-b9c8-1607ee4eb77e",40,["D",1788432886436],7,"import type { PatchInfo } from \"./commitfest.ts\";\nimport { FEED_TTL_MINUTES } from \"./config.ts\";\n\n/** Convert \"YYYY-MM-DD HH:MM:SS\" (naive GMT, per pgcommitfest settings) to an\n * RFC-822 RSS pubDate. */\nfunction toRfc822(dateStr: string): string {\n const m = dateStr.match(\n /^(\\d{4})-(\\d{2})-(\\d{2})\\s+(\\d{2}):(\\d{2}):(\\d{2})/,\n );\n if (!m) return \"\";\n const [_, y, mo, d, h, mi, s] = m;\n const date = new Date(\n Date.UTC(\n Number(y), Number(mo) - 1, Number(d), Number(h), Number(mi), Number(s),\n ),\n );\n return date.toUTCString(); // \"Tue, 10 Jul 2026 07:04:17 GMT\"\n}\n\nfunction xmlEscape(s: string): string {\n return s\n .replace(/&/g, \"&\")\n .replace(//g, \">\")\n .replace(/\"/g, \""\");\n}\n\n/** Small deterministic hash so guids are stable regardless of where an entry\n * sits in the list (history is newest-first, so positional indexes shift\n * whenever a new entry lands, and readers would re-emit the whole feed). */\nexport function stableHash(s: string): string {\n let h = 5381;\n for (let i = 0; i < s.length; i++) {\n h = ((h << 5) + h + s.charCodeAt(i)) >>> 0;\n }\n return h.toString(36);\n}\n\nexport function buildRss(patch: PatchInfo, feedUrl: string): string {\n const title = patch.title\n ? `Commitfest patch #${patch.id}: ${patch.title}`\n : `Commitfest patch #${patch.id}`;\n\n const items = patch.history.map((h) => {\n const pubDate = toRfc822(h.date);\n const titleLine = `${h.who}: ${h.what}`;\n const guid = `${patch.id}-${stableHash(`${h.date}|${h.who}|${h.what}`)}`;\n return `\n ${xmlEscape(titleLine)}\n ${patch.url}\n ${guid}\n ${pubDate ? `${pubDate}` : \"\"}\n ${xmlEscape(h.what)}\n`;\n }).join(\"\\n\");\n\n return `\n\n\n ${xmlEscape(title)}\n ${patch.url}\n \n ${xmlEscape(title)} — history feed\n en\n cf-rss (https://val.town/mootari/cf-rss)\n ${FEED_TTL_MINUTES}\n ${new Date().toUTCString()}\n ${patch.history.length > 0\n ? `${toRfc822(patch.history[0].date)}`\n : \"\"}\n${items}\n\n\n`;\n}\n","children",[],[212],"ff563ab9-347a-4bad-94a3-75bddd4b1f41","main.ts",45,["D",1788467591016],11,"http","import { Hono, type Context } from \"npm:hono@4.13.5\";\nimport { AppError } from \"./commitfest.ts\";\nimport { fetchPatchCached } from \"./cache.ts\";\nimport { buildRss, stableHash } from \"./rss.ts\";\n\n// strict:false so /patch/6982/ (commitfest's own canonical URL form) works\nconst app = new Hono({ strict: false });\napp.onError((err, c) => {\n if (err instanceof AppError) {\n return c.json({ error: err.message }, err.status);\n }\n console.error(err);\n return c.json({ error: \"internal error\" }, 500);\n});\n\napp.get(\"/\", (c) => {\n return c.html(`\n\nCommitfest patch history RSS\n\n

Commitfest patch history → RSS

Expose the History section of a\n PostgreSQL commitfest patch\n page — which isn't available through the commitfest JSON API — as an RSS feed.

\n \n

Or use the URL directly:

/patch/6982

/patch/<id> — RSS feed for a patch
/patch/<id>.json — same data as JSON (for debugging)

\n \n\n`);\n});\n\n/** Shared handler for both /patch/:file and /:file. The segment is\n * \"\" optionally followed by \".json\" (debug response). */\nconst FILE_RE = /^(\\d+)(\\.json)?$/;\n\nasync function handlePatchRoute(\n c: Context,\n raw: string,\n onInvalid: () => Response,\n) {\n const m = FILE_RE.exec(raw);\n if (!m) return onInvalid();\n const [, id, jsonSuffix] = m;\n\n const patch = await fetchPatchCached(id);\n if (jsonSuffix) return c.json(patch);\n\n // Conditional GET: readers that poll with If-None-Match get an empty 304\n // instead of a full body when the history hasn't changed. The validator\n // hashes only the history content, not the rendered feed (whose\n // lastBuildDate changes every response).\n const etag = `\"h1-${stableHash(JSON.stringify(patch.history))}\"`;\n const ifNoneMatch = c.req.header(\"If-None-Match\");\n const clientMatches = ifNoneMatch\n ?.split(\",\")\n .map((v) => v.trim().replace(/^W\\//, \"\"))\n .includes(etag);\n if (clientMatches) {\n return new Response(null, {\n status: 304,\n headers: { ETag: etag },\n });\n }\n\n return new Response(buildRss(patch, new URL(c.req.url).href), {\n headers: {\n \"Content-Type\": \"application/rss+xml; charset=utf-8\",\n ETag: etag,\n },\n });\n}\n\n// /patch/6982 and /patch/6982.json\napp.get(\"/patch/:file\", (c) =>\n handlePatchRoute(\n c,\n c.req.param(\"file\"),\n () => c.json({ error: \"Patch id must be numeric\" }, 400),\n ));\n\n// Convenience alias: /6982\napp.get(\"/:file\", (c) =>\n handlePatchRoute(c, c.req.param(\"file\"), () => c.redirect(\"/\", 302)));\n\nexport default app.fetch;",[],[222],"6d38a562-1c99-45f0-a42f-cb785207fcb3","config.ts","dea7a5f0-a784-11f1-8119-1607ee4eb77e",34,["D",1788432453810],"// Single place for tunables shared across modules.\nexport const FEED_TTL_MINUTES = 10;",[],[231],"23f3cda5-1b83-411f-b611-48a8e93dd368","commitfest.ts","755ef5f2-a6c7-11f1-8c42-1607ee4eb77e",35,["D",1788432453865],"// Fetch a PostgreSQL commitfest patch page and extract its history table,\n// which the commitfest JSON API does not expose.\n//\n// Verified against pgcommitfest @ 07e2bc68f138b0232668b8d7e08fd830d059206a:\n// - TIME_ZONE = \"GMT\", USE_TZ = False, DATETIME_FORMAT = \"Y-m-d H:i:s\"\n// (pgcommitfest/settings.py) -> history timestamps are naive GMT/UTC.\n// - History table markup: pgcommitfest/commitfest/templates/patch.html\n//\nimport { load } from \"npm:cheerio@1.2.0\";\nimport type { CheerioAPI } from \"npm:cheerio@1.2.0\";\n\nexport interface HistoryEntry {\n date: string;\n who: string;\n what: string;\n}\n\nexport interface PatchInfo {\n id: number;\n title: string;\n url: string;\n history: HistoryEntry[];\n}\n\n/** HTTP statuses this app ever returns. */\nexport type HttpErrorStatus = 400 | 404 | 500 | 502 | 504;\n\nexport class AppError extends Error {\n status: HttpErrorStatus;\n constructor(message: string, status: HttpErrorStatus = 500) {\n super(message);\n this.status = status;\n }\n}\n\n/** Thrown when the page structure no longer matches what we parse for\n * (as opposed to a page that legitimately has zero history rows). */\nexport class ScrapeError extends AppError {\n constructor(message: string) {\n super(`commitfest page structure has changed: ${message}`, 502);\n }\n}\n\nconst UPSTREAM_TIMEOUT_MS = 10_000;\n\nfunction normalizeText(s: string): string {\n return s.replace(/\\s+/g, \" \").trim();\n}\n\n/** Find the `` immediately following the `` whose text is exactly `label`. */\nfunction findLabeledCell($: CheerioAPI, label: string) {\n const th = $(\"th\").filter((_, el) => $(el).text().trim() === label).first();\n if (th.length === 0) return null;\n const td = th.next(\"td\");\n return td.length > 0 ? td : null;\n}\n\nfunction extractTitle($: CheerioAPI): string {\n const td = findLabeledCell($, \"Title\");\n if (!td) throw new ScrapeError('\"Title\" row not found');\n return normalizeText(td.text());\n}\n\nfunction extractHistory($: CheerioAPI): HistoryEntry[] {\n const historyCell = findLabeledCell($, \"History\");\n if (!historyCell) throw new ScrapeError('\"History\" section not found');\n\n const table = historyCell.find(\"table\").first();\n if (table.length === 0) {\n throw new ScrapeError(\"no found inside the History cell\");\n }\n\n const rows = table.find(\"tbody tr\");\n if (rows.length === 0) {\n throw new ScrapeError(\"History table body has no rows at all, not even a header\");\n }\n\n const entries: HistoryEntry[] = [];\n rows.each((_, rowEl) => {\n const cells = $(rowEl).find(\"td\");\n // The header row uses ` cell in [`patch.html`](https://github.com/postgres/pgcommitfest/blob/07e2bc68f138b0232668b8d7e08fd830d059206a/pgcommitfest/commitfest/templates/patch.html). If the page doesn't match the expected structure, a `ScrapeError` (HTTP 502) is returned. Timestamps on commitfest are naive GMT (Django `TIME_ZONE = \"GMT\"`, `USE_TZ = False`).\n\nParsed results are cached in blob storage for 10 minutes (`cache.ts`); concurrent requests for the same patch share one upstream fetch, and a failed refresh falls back to the cached copy.\n\n## Files\n\n- `main.ts` — HTTP routes\n- `commitfest.ts` — upstream fetch + HTML parsing\n- `rss.ts` — RSS generation and ETag\n- `cache.ts` — blob cache\n- `config.ts` — TTL constant\n- `test/` — parser and renderer tests (run with `run_file`)\n",[],[255],["D",1788432792742],[],[18,95],["D",1788428748135],[],[18,83],"95896487-0e97-4bf1-ac54-cb9ff0d56612","patch-6982.html","2e33b734-a77c-11f1-8c7e-1607ee4eb77e",["D",1788428721794],"\n

cells, not	, so it naturally yields 0\n //	s here and is skipped without needing special-casing.\n if (cells.length === 0) return;\n if (cells.length !== 3) {\n throw new ScrapeError(\n `expected 3	cells per history row, found ${cells.length}`,\n );\n }\n entries.push({\n date: normalizeText($(cells[0]).text()),\n who: normalizeText($(cells[1]).text()),\n what: normalizeText($(cells[2]).text()),\n });\n });\n return entries;\n}\n\n/** Pure parsing step, exported separately so it can be unit-tested against\n * an HTML fixture without hitting the network (see test/commitfest.test.ts). /\nexport function parsePatchHtml(html: string, id: number \| string, url: string): PatchInfo {\n const $ = load(html);\n return {\n id: Number(id),\n title: extractTitle($),\n url,\n history: extractHistory($),\n };\n}\n\nexport async function fetchPatch(id: number \| string): Promise {\n const url = `https://commitfest.postgresql.org/patch/${id}/`;\n let res: Response;\n try {\n res = await fetch(url, {\n headers: { \"User-Agent\": \"cf-rss (+https://val.town/mootari/cf-rss)\" },\n redirect: \"follow\",\n signal: AbortSignal.timeout(UPSTREAM_TIMEOUT_MS),\n });\n } catch (err) {\n if (err instanceof DOMException && err.name === \"TimeoutError\") {\n throw new AppError(`commitfest did not respond within ${UPSTREAM_TIMEOUT_MS}ms`, 504);\n }\n throw new AppError(`failed to reach commitfest: ${(err as Error).message}`, 502);\n }\n if (res.status === 404) {\n throw new AppError(`Patch ${id} not found`, 404);\n }\n if (!res.ok) {\n throw new AppError(`commitfest returned HTTP ${res.status}`, 502);\n }\n const html = await res.text();\n return parsePatchHtml(html, id, url);\n}\n",[],[239],"936a84f4-b0eb-475a-8c7a-74daf42384da","cache.ts","20abce08-a77c-11f1-bdfe-1607ee4eb77e",36,["D",1788432638904],"// Short-lived cache so repeated RSS-reader polls for the same patch don't\n// re-fetch and re-parse commitfest.postgresql.org on every request.\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { fetchPatch, type PatchInfo } from \"./commitfest.ts\";\nimport { FEED_TTL_MINUTES } from \"./config.ts\";\n\nconst CACHE_TTL_MS = FEED_TTL_MINUTES 60_000;\n\ninterface CacheEntry {\n fetchedAt: number;\n patch: PatchInfo;\n}\n\nfunction cacheKey(id: string): string {\n return `patch-cache/${id}.json`;\n}\n\n// In-flight de-duplication (\"single flight\"): when two requests for the same\n// uncached patch arrive together, only the first hits upstream; the second\n// awaits the first's promise. The map entry is removed when the request\n// settles (success or failure), so a failed fetch never wedges the map.\nconst inFlight = new Map>();\n\nexport async function fetchPatchCached(id: string): Promise {\n const key = cacheKey(id);\n\n const cached = await blob.getJSON(key) as CacheEntry \| null;\n if (cached && Date.now() - cached.fetchedAt < CACHE_TTL_MS) {\n return cached.patch;\n }\n\n const pending = inFlight.get(id);\n if (pending) return pending;\n\n const p = (async () => {\n try {\n const patch = await fetchPatch(id);\n await blob.setJSON(key, { fetchedAt: Date.now(), patch } satisfies CacheEntry);\n return patch;\n } catch (err) {\n // If upstream is down/broken but we have a (stale) cached copy, prefer\n // serving stale data over a hard failure - better for RSS readers than\n // an error every poll during a transient outage.\n if (cached) return cached.patch;\n throw err;\n } finally {\n inFlight.delete(id);\n }\n })();\n inFlight.set(id, p);\n return p;\n}\n",[],[247],"7a605bf2-06ee-4af4-8a76-a1773732fe35","README.md","90ed6d1c-a6c7-11f1-94a3-1607ee4eb77e",["D",1788685452714],"# cf-rss\n\n_This app was generated by Townie._\n\nServes the History section of a [PostgreSQL commitfest](https://commitfest.postgresql.org/) patch page as an RSS feed. The commitfest JSON API ([`apiv1.py`](https://github.com/postgres/pgcommitfest/blob/07e2bc68f138b0232668b8d7e08fd830d059206a/pgcommitfest/commitfest/apiv1.py)) doesn't expose history, so the patch page's HTML is fetched and parsed instead.\n\n## Routes\n\n- `GET /patch/` — RSS feed\n- `GET /patch/.json` — parsed history as JSON\n- `GET /` — alias for the RSS feed\n- `GET /` — form for looking up a patch\n\nTrailing slashes are accepted. Example: [feed for patch 6982](url:main.ts/patch/6982).\n\n## Feed format\n\nEach history row becomes an item with title `\"who: what\"`, description `what`, and the row's timestamp as `pubDate`. Item guids are hashes of the row contents, so they don't change when new rows are added. Responses carry an `ETag` (hash of the history) and answer `If-None-Match` with a 304 when nothing changed.\n\n## Implementation\n\nThe parser (`commitfest.ts`) uses cheerio to locate the table following the `	History

\n \n \n \n \n \n \n \n \n

6982

Title

Proposal: INSERT ... BY NAME

History

\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n

When	Who	What
2026-07-10 07:04:17	Jim Jones (jimus)	Added jimus as reviewer
2026-07-08 07:09:29	solai v (solaiv)	Added solaiv as reviewer
2026-07-03 14:24:57	Ayush Tiwari (aytiwari)	Attached mail thread CAJTYsWVDs7vkEN-eD1NAnZ7XqcfpXu3tP1wMGzJQ12G6eo1oRw@mail.gmail.com
2026-07-03 14:24:57	Ayush Tiwari (aytiwari)	Created patch record

\n",[],[18,67,268],["D",1788428721794],[202],[18,67],["D",1788428721794],[201,203,204],[18],["D",1788351095345],{"_11":12,"_146":73},{"_11":12,"_142":-5,"_72":73,"_31":71,"_143":144,"_145":30},{"_41":133,"_13":16,"_35":38,"_134":98,"_135":-5,"_136":-5,"_137":-5,"_138":-5,"_139":-5,"_140":14,"_141":12},"ctx",{"_55":-5,"_165":317,"_318":319,"_320":321,"_322":30,"_323":30,"_324":30,"_325":24,"_326":-5,"_327":-7,"_328":-7,"_329":26,"_330":30,"_331":30,"_332":-5,"_333":30,"_334":30,"_335":30,"_336":-5},"ENV",{"_288":289,"_290":291,"_292":16,"_293":294,"_295":296,"_297":298,"_299":300,"_301":302,"_303":304,"_305":306,"_307":308,"_309":310,"_311":312,"_313":314,"_315":316},"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"]

History · test