[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_188":189,"_190":191},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_104":86,"_27":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":58,"_122":-5,"_123":-5,"_124":125},"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",8,"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// Future sources (hn=..., lobsters=..., masto=...) plug into SOURCES below.\nimport type { SourceResult } from \"./types.ts\";\nimport { fetchBsky } from \"./sources/bsky.ts\";\n\nconst SOURCES: Record Promise> = {\n bsky: fetchBsky,\n};\n\nexport default async function (req: Request): Promise {\n const params = new URL(req.url).searchParams;\n const requested = Object.keys(SOURCES)\n .map((type) => ({ type, ref: params.get(type) }))\n .filter((s): s is { type: string; ref: string } => !!s.ref);\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 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 Response.json(\n {\n count: comments.length,\n sources: results.map(({ comments: _, ...meta }) => meta),\n comments,\n },\n { headers: { \"Cache-Control\": \"public, max-age=300\" } },\n );\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 = 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 // 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: Date.now(), feed });\n }\n return feed;\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 fetchedAt = Date.now();\n const feed = await refresh(requested, key);\n return Response.json({ ...feed, fetchedAt }, { headers });\n}\n","createdAt",["D",1784619761802],"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",{"_96":95,"_103":99},"org",{"_96":95,"_97":-5,"_98":99,"_18":55,"_100":101,"_102":25},"branch",{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"isOwned",12,"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":184,"_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":185,"_80":186,"_82":187,"_84":25},"tree",[162,164,165],"files",[162,163,164,165],"counts",{"_152":62,"_153":136,"_154":62,"_155":156,"_157":158},"contents",[126,127,128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":145,"_32":146,"_30":147,"_132":-5,"_41":42,"_40":148,"_134":58,"_38":149,"_13":62,"_33":150,"_35":-5,"_24":25,"_139":-5,"_27":151},{"_43":141,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_134":25,"_38":142,"_13":143,"_33":34,"_35":37,"_24":25,"_139":-5,"_27":144},{"_43":129,"_32":130,"_30":131,"_132":-5,"_41":42,"_40":133,"_134":58,"_38":135,"_13":136,"_33":137,"_35":138,"_24":25,"_139":-5,"_27":140},"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",[130],"30a2fd6d-86b5-4e0b-b6b0-259be381e47a",["D",1784619761802],3,[28],"c3774c06-fd70-4e4f-8779-4f6bfb5da5ce","sources","79fdcfce-5f2a-4697-bbdd-cb8f408619ff",4,["D",1784619194245],"directory",[146],"pulls","branches","forks","envVars",{"_159":62,"_161":62},"connections",{"_159":62,"_160":62},"count","unfilledCount","emptyCount",{"_43":145,"_32":146,"_30":147,"_132":-5,"_41":42,"_40":148,"_134":58,"_38":181,"_13":62,"_33":150,"_35":-5,"_24":25,"_139":-5,"_167":182,"_27":183},{"_43":173,"_32":174,"_30":175,"_132":147,"_41":42,"_40":176,"_134":58,"_38":177,"_13":136,"_33":137,"_35":178,"_24":25,"_139":-5,"_167":179,"_27":180},{"_43":141,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_134":25,"_38":170,"_13":143,"_33":34,"_35":37,"_24":25,"_139":-5,"_167":171,"_27":172},{"_43":129,"_32":130,"_30":131,"_132":-5,"_41":42,"_40":133,"_134":58,"_38":166,"_13":136,"_33":137,"_35":138,"_24":25,"_139":-5,"_167":168,"_27":169},["D",1784619599310],"children",[],[130],["D",1784619761802],[],[28],"b8f4c4a0-129d-42f9-a77b-cf8feff7ca49","bsky.ts","6ed64252-84d6-11f1-bf8a-1607ee4eb77e",7,["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",[],[146,174],["D",1784619194245],[163],[146],["D",1784618262313],{"_96":95,"_103":99},{"_96":95,"_97":-5,"_98":99,"_18":55,"_100":101,"_102":25},{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"ctx",{"_78":-5,"_123":221,"_222":223,"_224":225,"_226":25,"_227":25,"_228":25,"_229":58,"_230":-5,"_231":-7,"_232":-7,"_233":62,"_234":25,"_235":25,"_236":-5,"_237":25,"_238":25,"_239":25,"_240":-5},"ENV",{"_192":193,"_194":195,"_196":86,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218,"_219":220},"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 · v8