Telegram Video Transcription Bot

Send a video URL (YouTube, TikTok, Instagram, X/Twitter, Facebook) to get a transcript.

`,\n { status: 200, headers: { \"content-type\": \"text/html\" } },\n );\n};\n",[],[104],{"_109":296,"_100":297,"_175":298,"_177":-5,"_178":156,"_179":299,"_181":124,"_111":300,"_105":236,"_183":226,"_185":301,"_186":22,"_187":-5,"_188":302,"_103":303},"b391dbf8-34f5-11f1-83d5-42b51c65c3df","poll-jobs.ts","7fbdd22e-34ef-11f1-bcc8-42b51c65c3df",26,["D",1775836530931],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst TOKEN = Deno.env.get(\"TELEGRAM_TOKEN\")!;\nconst SUPADATA_API_KEY = Deno.env.get(\"SUPADATA_API_KEY\")!;\nconst MAX_LEN = 4000;\n\n// Jobs older than 1 hour are considered expired (Supadata results expire after 1 hour)\nconst JOB_TTL_MS = 60 * 60 * 1000;\n\nasync function sendMessage(chatId: number, text: string, extra: object = {}) {\n await fetch(`https://api.telegram.org/bot${TOKEN}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text, ...extra }),\n });\n}\n\nasync function sendTranscript(chatId: number, transcript: string) {\n if (transcript.length <= MAX_LEN) {\n await sendMessage(chatId, `📝 *Transcript:*\\n\\n${transcript}`, { parse_mode: \"Markdown\" });\n return;\n }\n const chunks: string[] = [];\n for (let i = 0; i < transcript.length; i += MAX_LEN) {\n chunks.push(transcript.slice(i, i + MAX_LEN));\n }\n for (let i = 0; i < chunks.length; i++) {\n await sendMessage(chatId, `📝 *Transcript (part ${i + 1}/${chunks.length}):*\\n\\n${chunks[i]}`, {\n parse_mode: \"Markdown\",\n });\n }\n}\n\nexport default async function (_interval: Interval) {\n const result = await sqlite.execute(\n `SELECT job_id, chat_id, url, created_at FROM transcript_jobs`,\n );\n\n if (result.rows.length === 0) return;\n\n console.log(`Polling ${result.rows.length} pending transcript job(s)…`);\n\n for (const row of result.rows) {\n const { job_id, chat_id, url, created_at } = row as {\n job_id: string;\n chat_id: number;\n url: string;\n created_at: number;\n };\n\n // Drop expired jobs\n if (Date.now() - created_at > JOB_TTL_MS) {\n console.log(`Job ${job_id} expired, dropping`);\n await sqlite.execute({\n sql: `DELETE FROM transcript_jobs WHERE job_id = ?`,\n args: [job_id],\n });\n await sendMessage(chat_id, `❌ Transcription timed out for: ${url}\\nPlease try again.`);\n continue;\n }\n\n // Poll Supadata for job status\n const res = await fetch(\n `https://api.supadata.ai/v1/transcript/${job_id}`,\n { headers: { \"x-api-key\": SUPADATA_API_KEY } },\n );\n\n if (!res.ok) {\n console.log(`Job ${job_id}: HTTP ${res.status}, skipping`);\n continue;\n }\n\n const data = await res.json();\n console.log(`Job ${job_id}: status=${data.status}`);\n\n if (data.status === \"completed\") {\n await sqlite.execute({\n sql: `DELETE FROM transcript_jobs WHERE job_id = ?`,\n args: [job_id],\n });\n await sendTranscript(chat_id, data.result.content as string);\n } else if (data.status === \"failed\") {\n await sqlite.execute({\n sql: `DELETE FROM transcript_jobs WHERE job_id = ?`,\n args: [job_id],\n });\n await sendMessage(chat_id, `❌ Transcription failed for: ${url}\\n${data.error?.message ?? \"Unknown error\"}`);\n }\n }\n}\n",[],[297],{"_109":305,"_100":306,"_175":307,"_177":-5,"_178":156,"_179":308,"_181":124,"_111":309,"_105":33,"_183":255,"_185":310,"_186":22,"_187":-5,"_188":311,"_103":312},"a31cb36e-35dc-11f1-98b4-42b51c65c3df","router.ts","a31cb44a-35dc-11f1-98b4-42b51c65c3df",46,["D",1775935717061],"import { Annotation, END, START, StateGraph } from \"npm:@langchain/langgraph\";\nimport { ChatAnthropic } from \"npm:@langchain/anthropic\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// ── Types ─────────────────────────────────────────────────────────────────\n\nconst RouterAnnotation = Annotation.Root({\n text: Annotation(),\n chatId: Annotation(),\n classification: Annotation<\"transcription\" | \"claude\" | \"unknown\">(),\n extractedUrl: Annotation(),\n reply: Annotation(),\n asyncJobQueued: Annotation(),\n});\n\nexport type RouterResult = {\n classification: \"transcription\" | \"claude\" | \"unknown\";\n reply: string;\n asyncJobQueued: boolean;\n};\n\n// ── Constants ─────────────────────────────────────────────────────────────\n\nexport const VIDEO_URL_REGEX =\n /https?:\\/\\/(www\\.)?(youtube\\.com\\/watch|youtu\\.be\\/|tiktok\\.com\\/|instagram\\.com\\/(reel|p)\\/|x\\.com\\/\\w+\\/status\\/|twitter\\.com\\/\\w+\\/status\\/|facebook\\.com\\/(reel|watch|video))[^\\s]*/i;\n\nconst SUPADATA_API_KEY = Deno.env.get(\"SUPADATA_API_KEY\")!;\n\nconst haiku = new ChatAnthropic({\n model: \"claude-haiku-4-5-20251001\",\n apiKey: Deno.env.get(\"ANTHROPIC_API_KEY\")!,\n maxTokens: 20,\n});\n\n// ── Nodes ─────────────────────────────────────────────────────────────────\n\nasync function classifyNode(\n state: typeof RouterAnnotation.State,\n): Promise> {\n const urlMatch = state.text.match(VIDEO_URL_REGEX);\n const detectedUrl = urlMatch ? urlMatch[0] : null;\n\n const systemPrompt = `You are a message classifier for a Telegram bot.\nClassify the user's message into exactly one of these categories:\n- \"transcription\": the message contains a video URL (YouTube, TikTok, Instagram, X/Twitter, Facebook) that should be transcribed\n- \"claude\": the message is a question, instruction, or request that should be answered by an AI assistant\n- \"unknown\": the message is none of the above (greeting, random text, unsupported URL, etc.)\n\n${detectedUrl ? `HINT: A video URL was detected: ${detectedUrl}` : \"HINT: No video URL was detected in the message.\"}\n\nReply with ONLY one word: transcription, claude, or unknown.`;\n\n const response = await haiku.invoke([\n { role: \"system\", content: systemPrompt },\n { role: \"user\", content: state.text },\n ]);\n\n const raw = (response.content as string).trim().toLowerCase();\n const classification: \"transcription\" | \"claude\" | \"unknown\" =\n raw === \"transcription\" ? \"transcription\"\n : raw === \"claude\" ? \"claude\"\n : \"unknown\";\n\n return {\n classification,\n extractedUrl: detectedUrl,\n reply: classification === \"unknown\"\n ? \"Please send a video URL (YouTube, TikTok, Instagram, X/Twitter, or Facebook) or ask me a question!\"\n : \"\",\n asyncJobQueued: false,\n };\n}\n\nasync function handleTranscriptionNode(\n state: typeof RouterAnnotation.State,\n): Promise> {\n const url = state.extractedUrl!;\n\n const res = await fetch(\n `https://api.supadata.ai/v1/transcript?url=${encodeURIComponent(url)}&text=true`,\n { headers: { \"x-api-key\": SUPADATA_API_KEY } },\n );\n\n if (res.status === 200) {\n const data = await res.json();\n return { reply: data.content as string, asyncJobQueued: false };\n }\n\n if (res.status === 202) {\n const { jobId } = await res.json();\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO transcript_jobs (job_id, chat_id, url, created_at) VALUES (?, ?, ?, ?)`,\n args: [jobId, state.chatId, url, Date.now()],\n });\n return {\n reply:\n \"⏳ This video is long — transcription is running in the background. I'll send you the result when it's ready (usually a few minutes).\",\n asyncJobQueued: true,\n };\n }\n\n const errData = await res.json().catch(() => ({}));\n return {\n reply: `❌ Could not start transcription: ${(errData as { message?: string })?.message ?? `HTTP ${res.status}`}`,\n asyncJobQueued: false,\n };\n}\n\nfunction handleClaudeNode(): Partial {\n // Pass-through marker — actual Claude call happens in index.ts as fire-and-forget\n // to avoid exceeding the webhook timeout.\n return { reply: \"\", asyncJobQueued: false };\n}\n\n// ── Graph ─────────────────────────────────────────────────────────────────\n\nfunction routingDecision(state: typeof RouterAnnotation.State): string {\n return state.classification;\n}\n\nconst workflow = new StateGraph(RouterAnnotation)\n .addNode(\"classify\", classifyNode)\n .addNode(\"handle_transcription\", handleTranscriptionNode)\n .addNode(\"handle_claude\", handleClaudeNode)\n .addEdge(START, \"classify\")\n .addConditionalEdges(\"classify\", routingDecision, {\n transcription: \"handle_transcription\",\n claude: \"handle_claude\",\n unknown: END,\n })\n .addEdge(\"handle_transcription\", END)\n .addEdge(\"handle_claude\", END);\n\nconst graph = workflow.compile();\n\n// ── Public API ────────────────────────────────────────────────────────────\n\nexport async function routeMessage(\n text: string,\n chatId: number,\n): Promise {\n const finalState = await graph.invoke({\n text,\n chatId,\n classification: \"unknown\" as const,\n extractedUrl: null,\n reply: \"\",\n asyncJobQueued: false,\n });\n\n return {\n classification: finalState.classification,\n reply: finalState.reply,\n asyncJobQueued: finalState.asyncJobQueued,\n };\n}\n",[],[306],{"_109":314,"_100":315,"_175":316,"_177":-5,"_178":156,"_179":317,"_181":124,"_111":318,"_105":33,"_183":255,"_185":319,"_186":22,"_187":-5,"_188":320,"_103":321},"454db0f6-34f3-11f1-a2ab-42b51c65c3df","send-test.ts","454db1be-34f3-11f1-a2ab-42b51c65c3df",21,["D",1775835486944],"// Run this script to send a test message to yourself via the Telegram bot\nconst token = Deno.env.get(\"TELEGRAM_TOKEN\");\nconst chatId = Deno.env.get(\"TELEGRAM_USER_ID\");\n\nif (!token || !chatId) {\n throw new Error(\"TELEGRAM_TOKEN or TELEGRAM_USER_ID is not set\");\n}\n\nconst res = await fetch(`https://api.telegram.org/bot${token}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chatId,\n text: \"👋 Test message from your Val Town bot! It's working.\",\n }),\n});\n\nconst data = await res.json();\nif (!data.ok) {\n throw new Error(`Telegram API error: ${JSON.stringify(data)}`);\n}\n\nconsole.log(\"✅ Message sent!\", data.result.message_id);\n",[],[315],{"_109":323,"_100":324,"_175":325,"_177":-5,"_178":156,"_179":326,"_181":124,"_111":327,"_105":196,"_183":255,"_185":328,"_186":22,"_187":-5,"_188":329,"_103":330},"834a66b8-35bd-11f1-add9-42b51c65c3df","set-webhook.ts","6fed01a4-34f3-11f1-bba1-42b51c65c3df",37,["D",1775922349279],"const token = Deno.env.get(\"TELEGRAM_TOKEN\")!;\nconst webhookUrl = \"https://cricks_unmixed4u--019d77e09940769a8c3eb00cc25ccc8b.web.val.run\";\n\n// Delete existing webhook first\nconst del = await fetch(`https://api.telegram.org/bot${token}/deleteWebhook?drop_pending_updates=true`);\nconsole.log(\"deleteWebhook:\", await del.json());\n\n// Re-register\nconst set = await fetch(`https://api.telegram.org/bot${token}/setWebhook`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ url: webhookUrl, drop_pending_updates: true }),\n});\nconsole.log(\"setWebhook:\", await set.json());\n\n// Verify\nconst info = await fetch(`https://api.telegram.org/bot${token}/getWebhookInfo`);\nconsole.log(\"getWebhookInfo:\", await info.json());\n",[],[324],"files",[172,190,202,209,219,230,240,249,259,268,277,286,295,304,313,322],"counts",{"_335":33,"_336":236,"_337":33,"_338":339,"_343":344},"pulls","branches","forks","envVars",{"_340":341,"_342":33},"count",6,"emptyCount","connections",{"_340":33,"_345":33},"unfilledCount","contents",[],{"_109":287,"_100":104,"_175":122,"_177":-5,"_178":156,"_179":288,"_181":22,"_111":349,"_105":290,"_183":291,"_185":292,"_186":22,"_187":-5,"_103":350},["D",1775835873001],[104],"upstreamProject",{"_109":164,"_100":101,"_117":118,"_119":-5,"_115":116,"_23":353},{"_98":354,"_146":355},"std","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJVaVhpQ1BId3dscVpBbkdZVWlMNjJtcjkxWS5wbmcifQ","upstreamBranch",{"_109":159,"_111":358,"_359":360,"_100":46,"_157":164,"_105":161,"_158":-5,"_160":-5,"_361":362,"_113":-5,"_169":22,"_115":116,"_168":354,"_16":166,"_167":101},["D",1741790272811],"updatedAt",["D",1741794858963],"lockfileKey","1744586807645-esm.town_v_std_telegramBotStarter@35-main","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_98":99,"_100":101,"_102":46,"_105":106,"_103":104,"_107":369,"_170":375,"_331":440,"_197":441,"_346":444,"_445":446,"_449":-5,"_450":155,"_451":33,"_452":453,"_338":-5},{"_109":110,"_100":101,"_111":370,"_113":-5,"_114":22,"_115":116,"_117":118,"_119":-5,"_14":120,"_121":122,"_123":124,"_125":-5,"_126":-5,"_127":33,"_16":128,"_129":130,"_131":132,"_133":371,"_135":-5,"_136":137,"_138":137,"_139":140,"_141":140,"_142":140,"_143":137,"_144":137,"_23":372,"_148":373,"_153":374,"_169":22},["D",1775832701083],["D",1775921465400],{"_98":99,"_146":147},{"_98":99,"_150":147,"_14":120,"_151":152},{"_105":155,"_100":46,"_109":156,"_157":110,"_158":159,"_160":161,"_162":116,"_163":164,"_165":166,"_167":101,"_168":99},[376,384,392,396,400,404,408,412,416,420,424,428,432,436],{"_109":173,"_100":174,"_175":176,"_177":-5,"_178":156,"_179":180,"_181":124,"_111":377,"_105":33,"_183":184,"_185":-5,"_186":22,"_187":-5,"_188":378,"_103":383},["D",1775894396155],[379],{"_109":191,"_100":192,"_175":193,"_177":176,"_178":156,"_179":194,"_181":22,"_111":380,"_105":196,"_183":197,"_185":198,"_186":22,"_187":-5,"_188":381,"_103":382},["D",1775922779471],[],[174,192],[174],{"_109":203,"_100":204,"_175":205,"_177":-5,"_178":156,"_179":206,"_181":124,"_111":385,"_105":33,"_183":184,"_185":-5,"_186":22,"_187":-5,"_188":386,"_103":391},["D",1775894396363],[387],{"_109":210,"_100":211,"_175":212,"_177":205,"_178":156,"_179":213,"_181":124,"_111":388,"_105":33,"_183":197,"_185":215,"_186":22,"_187":-5,"_188":389,"_103":390},["D",1775894396567],[],[204,211],[204],{"_109":220,"_100":221,"_175":222,"_177":-5,"_178":156,"_179":223,"_181":124,"_111":393,"_105":225,"_183":226,"_185":227,"_186":22,"_187":-5,"_188":394,"_103":395},["D",1775833666167],[],[221],{"_109":231,"_100":232,"_175":233,"_177":-5,"_178":156,"_179":234,"_181":124,"_111":397,"_105":236,"_183":226,"_185":237,"_186":22,"_187":-5,"_188":398,"_103":399},["D",1775923024608],[],[232],{"_109":241,"_100":242,"_175":243,"_177":-5,"_178":156,"_179":244,"_181":124,"_111":401,"_105":236,"_183":226,"_185":246,"_186":22,"_187":-5,"_188":402,"_103":403},["D",1775836775801],[],[242],{"_109":250,"_100":251,"_175":252,"_177":-5,"_178":156,"_179":253,"_181":124,"_111":405,"_105":33,"_183":255,"_185":256,"_186":22,"_187":-5,"_188":406,"_103":407},["D",1775835527597],[],[251],{"_109":260,"_100":261,"_175":262,"_177":-5,"_178":156,"_179":106,"_181":22,"_111":409,"_105":264,"_183":255,"_185":265,"_186":22,"_187":-5,"_188":410,"_103":411},["D",1775935717081],[],[261],{"_109":269,"_100":270,"_175":271,"_177":-5,"_178":156,"_179":272,"_181":124,"_111":413,"_105":33,"_183":255,"_185":274,"_186":22,"_187":-5,"_188":414,"_103":415},["D",1775836672529],[],[270],{"_109":278,"_100":279,"_175":280,"_177":-5,"_178":156,"_179":281,"_181":124,"_111":417,"_105":33,"_183":255,"_185":283,"_186":22,"_187":-5,"_188":418,"_103":419},["D",1775836542240],[],[279],{"_109":287,"_100":104,"_175":122,"_177":-5,"_178":156,"_179":288,"_181":22,"_111":421,"_105":290,"_183":291,"_185":292,"_186":22,"_187":-5,"_188":422,"_103":423},["D",1775835873001],[],[104],{"_109":296,"_100":297,"_175":298,"_177":-5,"_178":156,"_179":299,"_181":124,"_111":425,"_105":236,"_183":226,"_185":301,"_186":22,"_187":-5,"_188":426,"_103":427},["D",1775836530931],[],[297],{"_109":305,"_100":306,"_175":307,"_177":-5,"_178":156,"_179":308,"_181":124,"_111":429,"_105":33,"_183":255,"_185":310,"_186":22,"_187":-5,"_188":430,"_103":431},["D",1775935717061],[],[306],{"_109":314,"_100":315,"_175":316,"_177":-5,"_178":156,"_179":317,"_181":124,"_111":433,"_105":33,"_183":255,"_185":319,"_186":22,"_187":-5,"_188":434,"_103":435},["D",1775835486944],[],[315],{"_109":323,"_100":324,"_175":325,"_177":-5,"_178":156,"_179":326,"_181":124,"_111":437,"_105":196,"_183":255,"_185":328,"_186":22,"_187":-5,"_188":438,"_103":439},["D",1775922349279],[],[324],[376,379,384,387,392,396,400,404,408,412,416,420,424,428,432,436],{"_109":287,"_100":104,"_175":122,"_177":-5,"_178":156,"_179":288,"_181":22,"_111":442,"_105":290,"_183":291,"_185":292,"_186":22,"_187":-5,"_103":443},["D",1775835873001],[104],[],"upstream",{"_109":159,"_111":447,"_359":448,"_100":46,"_157":164,"_105":161,"_158":-5,"_160":-5,"_361":362,"_113":-5,"_169":22,"_115":116,"_168":354,"_16":166,"_167":101},["D",1741790272811],["D",1741794858963],"pull","ahead","behind","templates",[],"actionData","errors"]