[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_186":187,"_188":189},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_103":85,"_27":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":58,"_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":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",12,"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","main.ts","latestPath","fileId","435e5bde-84d4-11f1-9615-1607ee4eb77e","name","fileType","http","content","// Aggregates comments on a blog post from external sources into one normalized feed.\n// Each supported source is a query param naming a post on that platform:\n// GET /?bsky=https://bsky.app/profile/HANDLE/post/RKEY (or an at:// URI)\n// GET /purge?bsky=... drop the cache entry for that source set\n// GET /purge drop all cache entries\n// Future sources (hn=..., lobsters=..., masto=...) plug into SOURCES below.\n//\n// Responses are cached in blob storage for TTL_MS. Stale entries are served\n// immediately while a refresh runs in the background (a lock blob keeps\n// concurrent requests from all refreshing; locks expire after LOCK_MS so a\n// refresh that died gets retried by a later request).\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport type { SourceResult } from \"./types.ts\";\nimport { fetchBsky } from \"./sources/bsky.ts\";\n\nconst SOURCES: Record Promise> = {\n bsky: fetchBsky,\n};\n\nconst TTL_MS = 5 * 60 * 1000;\nconst LOCK_MS = 2 * 60 * 1000;\nconst CACHE_PREFIX = \"cache:\";\nconst LOCK_PREFIX = \"cache-lock:\";\n\ninterface Requested {\n type: string;\n ref: string;\n}\n\nfunction parseSources(params: URLSearchParams): Requested[] {\n return Object.keys(SOURCES)\n .map((type) => ({ type, ref: params.get(type) }))\n .filter((s): s is Requested => !!s.ref);\n}\n\n// Stable identifier for a source set; SOURCES key order is fixed so this is canonical.\nfunction sourcesKey(requested: Requested[]): string {\n return requested.map((s) => `${s.type}=${s.ref}`).join(\"&\");\n}\n\nasync function buildFeed(requested: Requested[]) {\n const results = await Promise.all(\n requested.map(async ({ type, ref }): Promise => {\n try {\n return await SOURCES[type](ref);\n } catch (e) {\n return {\n type,\n url: ref,\n replyUrl: ref,\n count: 0,\n comments: [],\n error: String(e?.message ?? e),\n };\n }\n }),\n );\n const comments = results.flatMap((r) => r.comments);\n return {\n count: comments.length,\n sources: results.map(({ comments: _, ...meta }) => meta),\n comments,\n };\n}\n\nasync function refresh(requested: Requested[], key: string) {\n const feed = await buildFeed(requested);\n const fetchedAt = Date.now();\n // Don't overwrite a good cache entry with an all-sources-failed result.\n const allFailed = feed.sources.length > 0 && feed.sources.every((s) => s.error);\n if (!allFailed) {\n await blob.setJSON(CACHE_PREFIX + key, { fetchedAt, feed });\n }\n return { feed, fetchedAt };\n}\n\nasync function purge(requested: Requested[]): Promise {\n let keys: string[];\n if (requested.length > 0) {\n const key = sourcesKey(requested);\n keys = [CACHE_PREFIX + key, LOCK_PREFIX + key];\n } else {\n keys = (await Promise.all([blob.list(CACHE_PREFIX), blob.list(LOCK_PREFIX)]))\n .flat()\n .map((e) => e.key);\n }\n await Promise.all(keys.map((k) => blob.delete(k).catch(() => {})));\n return Response.json({ purged: keys.filter((k) => k.startsWith(CACHE_PREFIX)) });\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const requested = parseSources(url.searchParams);\n if (url.pathname === \"/purge\") return purge(requested);\n if (requested.length === 0) {\n return Response.json(\n { error: `no sources given; supported: ${Object.keys(SOURCES).join(\", \")}` },\n { status: 400 },\n );\n }\n\n const key = sourcesKey(requested);\n const cached = await blob.getJSON(CACHE_PREFIX + key);\n const headers = { \"Cache-Control\": \"public, max-age=300\" };\n\n if (cached && Date.now() - cached.fetchedAt < TTL_MS) {\n return Response.json({ ...cached.feed, fetchedAt: cached.fetchedAt }, { headers });\n }\n\n if (cached) {\n // Stale: serve it now, refresh in the background unless one is already running.\n const lockKey = LOCK_PREFIX + key;\n const lock = await blob.getJSON(lockKey);\n if (!lock || Date.now() - lock.at > LOCK_MS) {\n await blob.setJSON(lockKey, { at: Date.now() });\n refresh(requested, key)\n .catch((e) => console.error(\"background refresh failed:\", e))\n .finally(() => blob.delete(lockKey).catch(() => {}));\n }\n return Response.json({ ...cached.feed, fetchedAt: cached.fetchedAt, stale: true }, { headers });\n }\n\n const { feed, fetchedAt } = await refresh(requested, key);\n return Response.json({ ...feed, fetchedAt }, { headers });\n}\n","// Aggregates comments on a blog post from external sources into one normalized feed.\n// Each supported source is a query param naming a post on that platform:\n// GET /?bsky=https://bsky.app/profile/HANDLE/post/RKEY (or an at:// URI)\n// GET /purge?bsky=... drop the cache entry for that source set\n// GET /purge drop all cache entries\n// Future sources (hn=..., lobsters=..., masto=...) plug into SOURCES below.\n//\n// Responses are cached in blob storage for TTL_MS. Stale entries are served\n// immediately while a refresh runs in the background (a lock blob keeps\n// concurrent requests from all refreshing; locks expire after LOCK_MS so a\n// refresh that died gets retried by a later request).\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport type { SourceResult } from \"./types.ts\";\nimport { fetchBsky } from \"./sources/bsky.ts\";\n\nconst SOURCES: Record Promise> = {\n bsky: fetchBsky,\n};\n\nconst TTL_MS = 0.5 * 60 * 1000;\nconst LOCK_MS = 2 * 60 * 1000;\nconst CACHE_PREFIX = \"cache:\";\nconst LOCK_PREFIX = \"cache-lock:\";\n\ninterface Requested {\n type: string;\n ref: string;\n}\n\nfunction parseSources(params: URLSearchParams): Requested[] {\n return Object.keys(SOURCES)\n .map((type) => ({ type, ref: params.get(type) }))\n .filter((s): s is Requested => !!s.ref);\n}\n\n// Stable identifier for a source set; SOURCES key order is fixed so this is canonical.\nfunction sourcesKey(requested: Requested[]): string {\n return requested.map((s) => `${s.type}=${s.ref}`).join(\"&\");\n}\n\nasync function buildFeed(requested: Requested[]) {\n const results = await Promise.all(\n requested.map(async ({ type, ref }): Promise => {\n try {\n return await SOURCES[type](ref);\n } catch (e) {\n return {\n type,\n url: ref,\n replyUrl: ref,\n count: 0,\n comments: [],\n error: String(e?.message ?? e),\n };\n }\n }),\n );\n const comments = results.flatMap((r) => r.comments);\n return {\n count: comments.length,\n sources: results.map(({ comments: _, ...meta }) => meta),\n comments,\n };\n}\n\nasync function refresh(requested: Requested[], key: string) {\n const feed = await buildFeed(requested);\n const fetchedAt = Date.now();\n // Don't overwrite a good cache entry with an all-sources-failed result.\n const allFailed = feed.sources.length > 0 &&\n feed.sources.every((s) => s.error);\n if (!allFailed) {\n await blob.setJSON(CACHE_PREFIX + key, { fetchedAt, feed });\n }\n return { feed, fetchedAt };\n}\n\nasync function purge(requested: Requested[]): Promise {\n let keys: string[];\n if (requested.length > 0) {\n const key = sourcesKey(requested);\n keys = [CACHE_PREFIX + key, LOCK_PREFIX + key];\n } else {\n keys =\n (await Promise.all([blob.list(CACHE_PREFIX), blob.list(LOCK_PREFIX)]))\n .flat()\n .map((e) => e.key);\n }\n await Promise.all(keys.map((k) => blob.delete(k).catch(() => {})));\n return Response.json({\n purged: keys.filter((k) => k.startsWith(CACHE_PREFIX)),\n });\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const requested = parseSources(url.searchParams);\n if (url.pathname === \"/purge\") return purge(requested);\n if (requested.length === 0) {\n return Response.json(\n {\n error: `no sources given; supported: ${\n Object.keys(SOURCES).join(\", \")\n }`,\n },\n { status: 400 },\n );\n }\n\n const key = sourcesKey(requested);\n const cached = await blob.getJSON(CACHE_PREFIX + key);\n const headers = { \"Cache-Control\": \"public, max-age=300\" };\n\n if (cached && Date.now() - cached.fetchedAt < TTL_MS) {\n return Response.json({ ...cached.feed, fetchedAt: cached.fetchedAt }, {\n headers,\n });\n }\n\n if (cached) {\n // Stale: serve it now, refresh in the background unless one is already running.\n const lockKey = LOCK_PREFIX + key;\n const lock = await blob.getJSON(lockKey);\n if (!lock || Date.now() - lock.at > LOCK_MS) {\n await blob.setJSON(lockKey, { at: Date.now() });\n refresh(requested, key)\n .catch((e) => console.error(\"background refresh failed:\", e))\n .finally(() => blob.delete(lockKey).catch(() => {}));\n }\n return Response.json({\n ...cached.feed,\n fetchedAt: cached.fetchedAt,\n stale: true,\n }, { headers });\n }\n\n const { feed, fetchedAt } = await refresh(requested, key);\n return Response.json({ ...feed, fetchedAt }, { headers });\n}","createdAt",["D",1786494622093],"branchVersion","branchId","ab7b3a08-e8a3-4643-88aa-8c40c87d328b","id","1f6b5558-40a5-4113-b905-18cfb17e7a03","bsky-comments",["D",1784618262313],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Fetch Bluesky replies for a post, for blog comment sections","imageUrl","97177c5c-af07-4798-9b86-b4d21d19bfb0","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","af738af5-7598-4605-b00a-14b530088d70","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_102":98},"org",{"_95":94,"_96":-5,"_97":98,"_18":55,"_99":100,"_101":25},"branch",{"_13":14,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","i","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJObXdRZmo4VzFuQnRuRHRNUk5YUjJQTzdxVCJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":182,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":183,"_80":184,"_82":185,"_84":25},"tree",[161,163,164],"files",[161,162,163,164],"counts",{"_151":62,"_152":135,"_153":62,"_154":155,"_156":157},"contents",[125,126,127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":144,"_32":145,"_30":146,"_131":-5,"_41":42,"_40":147,"_133":58,"_38":148,"_13":62,"_33":149,"_35":-5,"_24":25,"_138":-5,"_27":150},{"_43":140,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_133":58,"_38":141,"_13":142,"_33":34,"_35":37,"_24":25,"_138":-5,"_27":143},{"_43":128,"_32":129,"_30":130,"_131":-5,"_41":42,"_40":132,"_133":58,"_38":134,"_13":135,"_33":136,"_35":137,"_24":25,"_138":-5,"_27":139},"cf981415-9d84-44a8-bd82-176a2c97419e","types.ts","6eb23e3e-84d6-11f1-9cbc-1607ee4eb77e","parentId",6,"latest",["D",1784619599310],1,"script","// Shared types for comment sources. A \"source\" is one place a post was shared\n// (Bluesky today; HN, Lobsters, Mastodon, etc. later) whose replies we surface\n// as blog comments in a single normalized shape.\n\nexport interface CommentAuthor {\n name: string;\n handle?: string;\n url?: string;\n avatar?: string;\n}\n\nexport interface Comment {\n source: string; // which source this came from, e.g. \"bsky\"\n id: string; // stable id within the source\n url: string; // permalink to the comment\n depth: number; // 0 = direct reply to the shared post\n author: CommentAuthor;\n text: string; // plain text — clients must escape before inserting as HTML\n createdAt: string; // ISO 8601\n likeCount?: number;\n isAuthor?: boolean; // comment is by the blog author\n\n}\n\nexport interface SourceResult {\n type: string;\n url: string; // link to the shared post\n replyUrl: string; // where a reader should go to add a comment\n count: number;\n comments: Comment[];\n likeCount?: number;\n repostCount?: number;\n error?: string; // set instead of comments when the source failed\n}\n","label",[129],"f37b8b26-cf7b-47b4-b38d-f2b4665b7330",["D",1786494622093],7,[28],"c3774c06-fd70-4e4f-8779-4f6bfb5da5ce","sources","79fdcfce-5f2a-4697-bbdd-cb8f408619ff",4,["D",1784619194245],"directory",[145],"pulls","branches","forks","envVars",{"_158":62,"_160":62},"connections",{"_158":62,"_159":62},"count","unfilledCount","emptyCount",{"_43":144,"_32":145,"_30":146,"_131":-5,"_41":42,"_40":147,"_133":58,"_38":179,"_13":62,"_33":149,"_35":-5,"_24":25,"_138":-5,"_166":180,"_27":181},{"_43":172,"_32":173,"_30":174,"_131":146,"_41":42,"_40":142,"_133":58,"_38":175,"_13":135,"_33":136,"_35":176,"_24":25,"_138":-5,"_166":177,"_27":178},{"_43":140,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_133":58,"_38":169,"_13":142,"_33":34,"_35":37,"_24":25,"_138":-5,"_166":170,"_27":171},{"_43":128,"_32":129,"_30":130,"_131":-5,"_41":42,"_40":132,"_133":58,"_38":165,"_13":135,"_33":136,"_35":137,"_24":25,"_138":-5,"_166":167,"_27":168},["D",1784619599310],"children",[],[129],["D",1786494622093],[],[28],"b8f4c4a0-129d-42f9-a77b-cf8feff7ca49","bsky.ts","6ed64252-84d6-11f1-bf8a-1607ee4eb77e",["D",1784619599698],"// Bluesky comment source: fetches the reply thread for a post via the public AppView API.\nimport type { Comment, SourceResult } from \"../types.ts\";\n\nconst APPVIEW = \"https://public.api.bsky.app\";\n\n// The blog author's account (@iter.ca); their comments get isAuthor: true.\nconst AUTHOR_DID = \"did:plc:n3csajkwabhchilmzmrsnvlc\";\n\nfunction parsePostRef(post: string): { repo: string; rkey: string } | null {\n // at://did:plc:xyz/app.bsky.feed.post/rkey\n let m = post.match(/^at:\\/\\/([^/]+)\\/app\\.bsky\\.feed\\.post\\/([^/?#]+)$/);\n if (m) return { repo: m[1], rkey: m[2] };\n // https://bsky.app/profile/handle-or-did/post/rkey\n try {\n const u = new URL(post);\n if (u.hostname === \"bsky.app\" || u.hostname === \"staging.bsky.app\") {\n m = u.pathname.match(/^\\/profile\\/([^/]+)\\/post\\/([^/?#]+)\\/?$/);\n if (m) return { repo: decodeURIComponent(m[1]), rkey: m[2] };\n }\n } catch {}\n return null;\n}\n\nasync function resolveDid(repo: string): Promise {\n if (repo.startsWith(\"did:\")) return repo;\n const res = await fetch(\n `${APPVIEW}/xrpc/com.atproto.identity.resolveHandle?handle=${encodeURIComponent(repo)}`,\n );\n if (!res.ok) throw new Error(`could not resolve handle ${repo}`);\n const { did } = await res.json();\n return did;\n}\n\nfunction flatten(node: any, depth: number, out: Comment[]) {\n const replies = (node?.replies ?? [])\n .filter((r: any) => r?.post)\n .sort((a: any, b: any) =>\n (a.post?.record?.createdAt ?? \"\").localeCompare(b.post?.record?.createdAt ?? \"\")\n );\n for (const r of replies) {\n const p = r.post;\n const rkey = p.uri.split(\"/\").pop();\n out.push({\n source: \"bsky\",\n id: p.uri,\n url: `https://bsky.app/profile/${p.author.handle}/post/${rkey}`,\n depth,\n author: {\n name: p.author.displayName || p.author.handle,\n handle: p.author.handle,\n url: `https://bsky.app/profile/${p.author.handle}`,\n avatar: p.author.avatar,\n },\n text: p.record?.text ?? \"\",\n createdAt: p.record?.createdAt ?? p.indexedAt,\n likeCount: p.likeCount ?? 0,\n isAuthor: p.author.did === AUTHOR_DID || undefined,\n });\n flatten(r, depth + 1, out);\n }\n}\n\nexport async function fetchBsky(ref: string): Promise {\n const parsed = parsePostRef(ref);\n if (!parsed) throw new Error(\"unrecognized Bluesky post reference\");\n const did = await resolveDid(parsed.repo);\n const uri = `at://${did}/app.bsky.feed.post/${parsed.rkey}`;\n const res = await fetch(\n `${APPVIEW}/xrpc/app.bsky.feed.getPostThread?depth=10&uri=${encodeURIComponent(uri)}`,\n );\n if (!res.ok) throw new Error(`appview error: ${res.status}`);\n const { thread } = await res.json();\n if (!thread?.post) throw new Error(\"post not found or blocked\");\n const comments: Comment[] = [];\n flatten(thread, 0, comments);\n return {\n type: \"bsky\",\n url: `https://bsky.app/profile/${thread.post.author.handle}/post/${parsed.rkey}`,\n replyUrl: `https://bsky.app/profile/${thread.post.author.handle}/post/${parsed.rkey}`,\n likeCount: thread.post.likeCount ?? 0,\n repostCount: thread.post.repostCount ?? 0,\n count: comments.length,\n comments,\n };\n}\n",[],[145,173],["D",1784619194245],[162],[145],["D",1784618262313],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":55,"_99":100,"_101":25},{"_13":14,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_78":-5,"_122":219,"_220":221,"_222":223,"_224":25,"_225":25,"_226":25,"_227":58,"_228":-5,"_229":-7,"_230":-7,"_231":62,"_232":25,"_233":25,"_234":-5,"_235":25,"_236":25,"_237":25,"_238":-5},"ENV",{"_190":191,"_192":193,"_194":85,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218},"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 · v12