[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_204":205,"_206":207},"routes/_app.x.$handle.$name",{"_94":93,"_31":43,"_102":84,"_26":51,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":24,"_116":117,"_118":56,"_119":-5,"_120":-5,"_121":122},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":30,"_55":56,"_57":56,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":24},"version",6,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","tests.http.ts","latestPath","fileId","c5d543e2-b4d8-11f0-a3bf-0224a6c84d84","name","fileType","http","content","import { extractNitterRewrites } from \"./src/rewrite.ts\";\nimport { scenarios } from \"./tests/scenarios.ts\";\n\ninterface TestResult {\n name: string;\n ok: boolean;\n expected: unknown;\n actual: unknown;\n error?: string;\n}\n\nexport default async function (): Promise {\n const results: TestResult[] = [];\n\n for (const scenario of scenarios) {\n try {\n const actual = extractNitterRewrites(scenario.content);\n const ok = deepEqual(actual, scenario.expected);\n results.push({\n name: scenario.name,\n ok,\n expected: scenario.expected,\n actual,\n error: ok ? undefined : \"Mismatch between expected and actual rewrites\",\n });\n } catch (error) {\n results.push({\n name: scenario.name,\n ok: false,\n expected: scenario.expected,\n actual: null,\n error: error instanceof Error ? error.message : String(error),\n });\n }\n }\n\n const allPassed = results.every((result) => result.ok);\n\n return new Response(\n JSON.stringify({\n status: allPassed ? \"ok\" : \"failed\",\n passed: results.filter((result) => result.ok).length,\n failed: results.filter((result) => !result.ok).length,\n results,\n generatedAt: new Date().toISOString(),\n }),\n {\n status: allPassed ? 200 : 500,\n headers: {\n \"content-type\": \"application/json; charset=utf-8\",\n \"cache-control\": \"no-store\",\n },\n },\n );\n}\n\nfunction deepEqual(a: unknown, b: unknown): boolean {\n return JSON.stringify(a) === JSON.stringify(b);\n}\n","createdAt",["D",1761750357243],"branchVersion","branchId","db9aa85c-b4ce-11f0-b246-0224a6c84d84","id","db9a4164-b4ce-11f0-b246-0224a6c84d84","discordNitterBot",["D",1761746098901],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","f8b34481-b666-4e4c-b330-92f517c060c5","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","1fd640bc-f4e1-40ac-9627-06115c6756a0","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_101":97},"org",{"_94":93,"_95":-5,"_96":97,"_18":53,"_98":99,"_100":24},"branch",{"_13":83,"_31":84,"_41":40,"_85":42,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":43,"_92":93},"isOwned",7,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","ryi","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJWN01taHZBV3JpN1FyWUdabTlzQTM5YzBPcCJ9","tier","pro","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_41":42,"_31":43,"_36":200,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":30,"_55":56,"_57":56,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":201,"_78":202,"_80":203,"_82":24},"tree",[164,165,168,169],"files",[164,165,166,167,168,169],"counts",{"_154":60,"_155":144,"_156":60,"_157":158,"_159":160},"contents",[123,124,125,126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":148,"_31":149,"_29":150,"_128":-5,"_39":40,"_38":151,"_129":56,"_36":152,"_13":60,"_32":146,"_34":-5,"_23":24,"_131":-5,"_26":153},{"_41":141,"_31":142,"_29":143,"_128":-5,"_39":40,"_38":144,"_129":56,"_36":145,"_13":60,"_32":146,"_34":-5,"_23":24,"_131":-5,"_26":147},{"_41":133,"_31":134,"_29":135,"_128":-5,"_39":40,"_38":136,"_129":56,"_36":137,"_13":60,"_32":138,"_34":139,"_23":24,"_131":-5,"_26":140},{"_41":127,"_31":27,"_29":30,"_128":-5,"_39":40,"_38":14,"_129":56,"_36":130,"_13":60,"_32":33,"_34":35,"_23":24,"_131":-5,"_26":132},"c5d5431a-b4d8-11f0-a3bf-0224a6c84d84","parentId","latest",["D",1761750357243],"label",[27],"c5c5086a-b4d8-11f0-8c54-0224a6c84d84","bot.cron.ts","c5c50932-b4d8-11f0-8c54-0224a6c84d84",4,["D",1761750357235],"interval","import { blob } from \"https://esm.town/v/std/blob\";\nimport { extractNitterRewrites, type LinkRewrite } from \"./src/rewrite.ts\";\n\nconst DISCORD_API = \"https://discord.com/api/v10\";\nconst STATE_KEY = \"discordNitterBotState\";\n\nexport const cron = \"*/1 * * * *\"; // every minute\n\ninterface DiscordMessage {\n id: string;\n content: string;\n author: {\n id: string;\n username: string;\n bot?: boolean;\n };\n}\n\ninterface ChannelState {\n [channelId: string]: string | undefined;\n}\n\nexport default async function run() {\n const token = Deno.env.get(\"DISCORD_BOT_TOKEN\");\n if (!token) {\n throw new Error(\"Missing DISCORD_BOT_TOKEN environment variable\");\n }\n\n const channelIds = parseChannelIds(Deno.env.get(\"DISCORD_CHANNEL_IDS\"));\n if (channelIds.length === 0) {\n throw new Error(\"DISCORD_CHANNEL_IDS must include at least one channel id\");\n }\n\n const botUserId = Deno.env.get(\"DISCORD_BOT_USER_ID\") ?? null;\n\n const state = await readState();\n let hasChanges = false;\n\n for (const channelId of channelIds) {\n const lastSeen = state[channelId];\n const { latestId, responded } = await processChannel({\n channelId,\n token,\n lastSeen,\n botUserId,\n });\n\n if (latestId && latestId !== lastSeen) {\n state[channelId] = latestId;\n hasChanges = true;\n }\n\n if (responded.length > 0) {\n console.log(\n `[discord-nitter-bot] posted ${responded.length} mirror(s) in channel ${channelId}`,\n );\n }\n }\n\n if (hasChanges) {\n await blob.setJSON(STATE_KEY, state);\n }\n}\n\nasync function processChannel(opts: {\n channelId: string;\n token: string;\n lastSeen?: string;\n botUserId: string | null;\n}): Promise<{ latestId?: string; responded: string[] }> {\n let pageAfter = opts.lastSeen;\n let latestId = opts.lastSeen;\n const responded: string[] = [];\n\n for (;;) {\n const messages = await fetchMessages({\n channelId: opts.channelId,\n token: opts.token,\n after: pageAfter,\n });\n\n if (messages.length === 0) break;\n\n messages.sort((a, b) => compareSnowflakes(a.id, b.id));\n\n for (const message of messages) {\n latestId = message.id;\n\n if (!shouldProcessMessage(message, opts.botUserId)) continue;\n\n const rewrites = extractNitterRewrites(message.content);\n if (rewrites.length === 0) continue;\n\n const payload = buildReplyContent(message, rewrites);\n const sent = await sendReply({\n channelId: opts.channelId,\n messageId: message.id,\n token: opts.token,\n content: payload,\n mentionUserId: message.author.id,\n });\n\n if (sent) {\n responded.push(message.id);\n }\n }\n\n pageAfter = latestId;\n\n if (messages.length < 100) {\n break;\n }\n }\n\n return { latestId, responded };\n}\n\nfunction shouldProcessMessage(message: DiscordMessage, botUserId: string | null) {\n if (!message.content) return false;\n if (message.author?.bot) return false;\n if (botUserId && message.author?.id === botUserId) return false;\n return true;\n}\n\nasync function fetchMessages(opts: {\n channelId: string;\n token: string;\n after?: string;\n}): Promise {\n const params = new URLSearchParams({ limit: \"100\" });\n if (opts.after) params.set(\"after\", opts.after);\n\n const response = await fetch(\n `${DISCORD_API}/channels/${opts.channelId}/messages?${params.toString()}`,\n {\n headers: {\n Authorization: `Bot ${opts.token}`,\n },\n },\n );\n\n if (response.status === 429) {\n const retry = Number(response.headers.get(\"retry-after\") ?? \"1\") * 1000;\n console.warn(\n `[discord-nitter-bot] rate limited fetching messages; retrying after ${retry}ms`,\n );\n await delay(retry);\n return fetchMessages(opts);\n }\n\n if (!response.ok) {\n const text = await response.text();\n throw new Error(\n `Failed to fetch messages for channel ${opts.channelId}: ${response.status} ${text}`,\n );\n }\n\n const data = await response.json();\n return Array.isArray(data) ? data as DiscordMessage[] : [];\n}\n\nasync function sendReply(opts: {\n channelId: string;\n messageId: string;\n token: string;\n content: string;\n mentionUserId: string;\n}): Promise {\n const response = await fetch(\n `${DISCORD_API}/channels/${opts.channelId}/messages`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bot ${opts.token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n content: opts.content,\n message_reference: { message_id: opts.messageId },\n allowed_mentions: { users: [opts.mentionUserId] },\n }),\n },\n );\n\n if (response.status === 429) {\n const retry = Number(response.headers.get(\"retry-after\") ?? \"1\") * 1000;\n console.warn(\n `[discord-nitter-bot] rate limited sending reply; retrying after ${retry}ms`,\n );\n await delay(retry);\n return sendReply(opts);\n }\n\n if (!response.ok) {\n const text = await response.text();\n console.error(\n `Failed to send reply for message ${opts.messageId}: ${response.status} ${text}`,\n );\n return false;\n }\n\n return true;\n}\n\nfunction buildReplyContent(message: DiscordMessage, rewrites: LinkRewrite[]): string {\n const links = rewrites.map((rewrite) => rewrite.rewritten);\n const plural = links.length > 1 ? \"s\" : \"\";\n const bullets = links.map((link) => `• ${link}`).join(\"\\n\");\n return `<@${message.author.id}> mirror${plural}:\\n${bullets}`;\n}\n\nasync function readState(): Promise {\n try {\n const existing = await blob.getJSON(STATE_KEY);\n if (!existing || typeof existing !== \"object\") return {};\n return existing;\n } catch (error) {\n if (isNotFound(error)) {\n return {};\n }\n throw error;\n }\n}\n\nfunction parseChannelIds(value: string | undefined | null): string[] {\n if (!value) return [];\n return value.split(\",\").map((id) => id.trim()).filter(Boolean);\n}\n\nfunction compareSnowflakes(a: string, b: string): number {\n const bigintA = BigInt(a);\n const bigintB = BigInt(b);\n if (bigintA === bigintB) return 0;\n return bigintA < bigintB ? -1 : 1;\n}\n\nfunction isNotFound(error: unknown): boolean {\n return typeof error === \"object\" &&\n error !== null &&\n \"status\" in error &&\n (error as { status: number }).status === 404;\n}\n\nfunction delay(ms: number): Promise {\n return new Promise((resolve) => setTimeout(resolve, ms));\n}\n",[134],"c56dc94c-b4d8-11f0-9610-0224a6c84d84","tests","c56dca14-b4d8-11f0-9610-0224a6c84d84",1,["D",1761750356662],"directory",[142],"c58b5912-b4d8-11f0-9680-0224a6c84d84","src","c58b59b2-b4d8-11f0-9680-0224a6c84d84",2,["D",1761750356846],[149],"pulls","branches","forks","envVars",{"_161":60,"_163":60},"connections",{"_161":60,"_162":60},"count","unfilledCount","emptyCount",{"_41":148,"_31":149,"_29":150,"_128":-5,"_39":40,"_38":151,"_129":56,"_36":197,"_13":60,"_32":146,"_34":-5,"_23":24,"_131":-5,"_171":198,"_26":199},{"_41":141,"_31":142,"_29":143,"_128":-5,"_39":40,"_38":144,"_129":56,"_36":194,"_13":60,"_32":146,"_34":-5,"_23":24,"_131":-5,"_171":195,"_26":196},{"_41":186,"_31":187,"_29":188,"_128":143,"_39":40,"_38":189,"_129":56,"_36":190,"_13":60,"_32":182,"_34":191,"_23":24,"_131":-5,"_171":192,"_26":193},{"_41":177,"_31":178,"_29":179,"_128":143,"_39":40,"_38":180,"_129":56,"_36":181,"_13":60,"_32":182,"_34":183,"_23":24,"_131":-5,"_171":184,"_26":185},{"_41":133,"_31":134,"_29":135,"_128":-5,"_39":40,"_38":136,"_129":56,"_36":174,"_13":60,"_32":138,"_34":139,"_23":24,"_131":-5,"_171":175,"_26":176},{"_41":127,"_31":27,"_29":30,"_128":-5,"_39":40,"_38":14,"_129":56,"_36":170,"_13":60,"_32":33,"_34":35,"_23":24,"_131":-5,"_171":172,"_26":173},["D",1761750357243],"children",[],[27],["D",1761750357235],[],[134],"c5cb4b62-b4d8-11f0-8fa6-0224a6c84d84","scenarios.ts","c5cb4c3e-b4d8-11f0-8fa6-0224a6c84d84",5,["D",1761750357260],"script","import type { LinkRewrite } from \"../src/rewrite.ts\";\n\nexport interface RewriteScenario {\n name: string;\n content: string;\n expected: LinkRewrite[];\n}\n\nexport const scenarios: RewriteScenario[] = [\n {\n name: \"rewrites standard twitter.com links\",\n content: \"Check this out https://twitter.com/example/status/1234567890123456789\",\n expected: [{\n original: \"https://twitter.com/example/status/1234567890123456789\",\n rewritten: \"https://nitter.net/example/status/1234567890123456789\",\n }],\n },\n {\n name: \"rewrites x.com and preserves query params\",\n content: \"https://x.com/foo/status/1?s=20&t=abcd\",\n expected: [{\n original: \"https://x.com/foo/status/1?s=20&t=abcd\",\n rewritten: \"https://nitter.net/foo/status/1?s=20&t=abcd\",\n }],\n },\n {\n name: \"deduplicates identical links\",\n content: \"https://twitter.com/foo/status/1 https://twitter.com/foo/status/1\",\n expected: [{\n original: \"https://twitter.com/foo/status/1\",\n rewritten: \"https://nitter.net/foo/status/1\",\n }],\n },\n {\n name: \"strips trailing punctuation from matches\",\n content: \"Did you see this? https://twitter.com/foo/status/1). Wild!\",\n expected: [{\n original: \"https://twitter.com/foo/status/1\",\n rewritten: \"https://nitter.net/foo/status/1\",\n }],\n },\n {\n name: \"supports alternate twitter frontends\",\n content: \"mirror https://vxtwitter.com/foo/status/1, please\",\n expected: [{\n original: \"https://vxtwitter.com/foo/status/1\",\n rewritten: \"https://nitter.net/foo/status/1\",\n }],\n },\n {\n name: \"ignores unrelated links\",\n content: \"https://example.com and https://youtube.com/watch?v=1\",\n expected: [],\n },\n];\n",[],[142,178],"c5a584e0-b4d8-11f0-9680-0224a6c84d84","rewrite.test.ts","c5a5858a-b4d8-11f0-9680-0224a6c84d84",3,["D",1761750357030],"import { assertEquals } from \"https://deno.land/std@0.224.0/assert/mod.ts\";\nimport { extractNitterRewrites } from \"../src/rewrite.ts\";\nimport { scenarios } from \"./scenarios.ts\";\n\nfor (const scenario of scenarios) {\n Deno.test(scenario.name, () => {\n const rewrites = extractNitterRewrites(scenario.content);\n assertEquals(rewrites, scenario.expected);\n });\n}\n",[],[142,187],["D",1761750356662],[166,167],[142],["D",1761750356846],[],[149],["D",1761746098901],{"_94":93,"_101":97},{"_94":93,"_95":-5,"_96":97,"_18":53,"_98":99,"_100":24},{"_13":83,"_31":84,"_41":40,"_85":42,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":43,"_92":93},"ctx",{"_76":-5,"_120":237,"_238":239,"_240":241,"_242":24,"_243":24,"_244":24,"_245":56,"_246":-5,"_247":-7,"_248":-7,"_249":60,"_250":24,"_251":24,"_252":-5,"_253":24,"_254":24,"_255":24,"_256":-5},"ENV",{"_208":209,"_210":211,"_212":84,"_213":214,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236},"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 · v6