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",[],[285],{"_108":294,"_100":295,"_174":296,"_176":-5,"_177":155,"_178":297,"_180":123,"_110":298,"_105":234,"_182":224,"_184":299,"_185":22,"_186":-5,"_187":300,"_103":301},"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",[],[295],{"_108":303,"_100":304,"_174":305,"_176":-5,"_177":155,"_178":306,"_180":123,"_110":307,"_105":33,"_182":253,"_184":308,"_185":22,"_186":-5,"_187":309,"_103":310},"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",[],[304],{"_108":312,"_100":313,"_174":314,"_176":-5,"_177":155,"_178":315,"_180":123,"_110":316,"_105":33,"_182":253,"_184":317,"_185":22,"_186":-5,"_187":318,"_103":319},"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",[],[313],{"_108":321,"_100":322,"_174":323,"_176":-5,"_177":155,"_178":324,"_180":123,"_110":325,"_105":326,"_182":253,"_184":327,"_185":22,"_186":-5,"_187":328,"_103":329},"834a66b8-35bd-11f1-add9-42b51c65c3df","set-webhook.ts","6fed01a4-34f3-11f1-bba1-42b51c65c3df",37,["D",1775922349279],2,"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",[],[322],"files",[171,189,200,207,217,228,238,247,257,266,274,283,293,302,311,320],"counts",{"_334":33,"_335":234,"_336":33,"_337":338,"_342":343},"pulls","branches","forks","envVars",{"_339":340,"_341":33},"count",6,"emptyCount","connections",{"_339":33,"_344":33},"unfilledCount","contents",[],{"_108":267,"_100":104,"_174":268,"_176":-5,"_177":155,"_178":269,"_180":123,"_110":348,"_105":33,"_182":253,"_184":271,"_185":22,"_186":-5,"_103":349},["D",1775836672529],[104],"upstreamProject",{"_108":163,"_100":101,"_116":117,"_118":-5,"_114":115,"_23":352},{"_98":353,"_145":354},"std","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJVaVhpQ1BId3dscVpBbkdZVWlMNjJtcjkxWS5wbmcifQ","upstreamBranch",{"_108":158,"_110":357,"_358":359,"_100":46,"_156":163,"_105":160,"_157":-5,"_159":-5,"_360":361,"_112":-5,"_168":22,"_114":115,"_167":353,"_16":165,"_166":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.code.$",{"_98":99,"_100":101,"_102":46,"_105":-7,"_103":104,"_106":368,"_169":374,"_330":439,"_195":440,"_345":443,"_444":445,"_448":-5,"_449":154,"_450":33,"_451":452,"_337":-5},{"_108":109,"_100":101,"_110":369,"_112":-5,"_113":22,"_114":115,"_116":117,"_118":-5,"_14":119,"_120":121,"_122":123,"_124":-5,"_125":-5,"_126":33,"_16":127,"_128":129,"_130":131,"_132":370,"_134":-5,"_135":136,"_137":136,"_138":139,"_140":139,"_141":139,"_142":136,"_143":136,"_23":371,"_147":372,"_152":373,"_168":22},["D",1775832701083],["D",1775921465400],{"_98":99,"_145":146},{"_98":99,"_149":146,"_14":119,"_150":151},{"_105":154,"_100":46,"_108":155,"_156":109,"_157":158,"_159":160,"_161":115,"_162":163,"_164":165,"_166":101,"_167":99},[375,383,391,395,399,403,407,411,415,419,423,427,431,435],{"_108":172,"_100":173,"_174":175,"_176":-5,"_177":155,"_178":179,"_180":123,"_110":376,"_105":33,"_182":183,"_184":-5,"_185":22,"_186":-5,"_187":377,"_103":382},["D",1775894396155],[378],{"_108":190,"_100":191,"_174":192,"_176":175,"_177":155,"_178":154,"_180":123,"_110":379,"_105":194,"_182":195,"_184":196,"_185":22,"_186":-5,"_187":380,"_103":381},["D",1775936402396],[],[173,191],[173],{"_108":201,"_100":202,"_174":203,"_176":-5,"_177":155,"_178":204,"_180":123,"_110":384,"_105":33,"_182":183,"_184":-5,"_185":22,"_186":-5,"_187":385,"_103":390},["D",1775894396363],[386],{"_108":208,"_100":209,"_174":210,"_176":203,"_177":155,"_178":211,"_180":123,"_110":387,"_105":33,"_182":195,"_184":213,"_185":22,"_186":-5,"_187":388,"_103":389},["D",1775894396567],[],[202,209],[202],{"_108":218,"_100":219,"_174":220,"_176":-5,"_177":155,"_178":221,"_180":123,"_110":392,"_105":223,"_182":224,"_184":225,"_185":22,"_186":-5,"_187":393,"_103":394},["D",1775833666167],[],[219],{"_108":229,"_100":230,"_174":231,"_176":-5,"_177":155,"_178":232,"_180":123,"_110":396,"_105":234,"_182":224,"_184":235,"_185":22,"_186":-5,"_187":397,"_103":398},["D",1775923024608],[],[230],{"_108":239,"_100":240,"_174":241,"_176":-5,"_177":155,"_178":242,"_180":123,"_110":400,"_105":234,"_182":224,"_184":244,"_185":22,"_186":-5,"_187":401,"_103":402},["D",1775836775801],[],[240],{"_108":248,"_100":249,"_174":250,"_176":-5,"_177":155,"_178":251,"_180":123,"_110":404,"_105":33,"_182":253,"_184":254,"_185":22,"_186":-5,"_187":405,"_103":406},["D",1775835527597],[],[249],{"_108":258,"_100":259,"_174":260,"_176":-5,"_177":155,"_178":261,"_180":123,"_110":408,"_105":223,"_182":253,"_184":263,"_185":22,"_186":-5,"_187":409,"_103":410},["D",1775935836843],[],[259],{"_108":267,"_100":104,"_174":268,"_176":-5,"_177":155,"_178":269,"_180":123,"_110":412,"_105":33,"_182":253,"_184":271,"_185":22,"_186":-5,"_187":413,"_103":414},["D",1775836672529],[],[104],{"_108":275,"_100":276,"_174":277,"_176":-5,"_177":155,"_178":278,"_180":123,"_110":416,"_105":33,"_182":253,"_184":280,"_185":22,"_186":-5,"_187":417,"_103":418},["D",1775836542240],[],[276],{"_108":284,"_100":285,"_174":121,"_176":-5,"_177":155,"_178":286,"_180":123,"_110":420,"_105":288,"_182":289,"_184":290,"_185":22,"_186":-5,"_187":421,"_103":422},["D",1775935717217],[],[285],{"_108":294,"_100":295,"_174":296,"_176":-5,"_177":155,"_178":297,"_180":123,"_110":424,"_105":234,"_182":224,"_184":299,"_185":22,"_186":-5,"_187":425,"_103":426},["D",1775836530931],[],[295],{"_108":303,"_100":304,"_174":305,"_176":-5,"_177":155,"_178":306,"_180":123,"_110":428,"_105":33,"_182":253,"_184":308,"_185":22,"_186":-5,"_187":429,"_103":430},["D",1775935717061],[],[304],{"_108":312,"_100":313,"_174":314,"_176":-5,"_177":155,"_178":315,"_180":123,"_110":432,"_105":33,"_182":253,"_184":317,"_185":22,"_186":-5,"_187":433,"_103":434},["D",1775835486944],[],[313],{"_108":321,"_100":322,"_174":323,"_176":-5,"_177":155,"_178":324,"_180":123,"_110":436,"_105":326,"_182":253,"_184":327,"_185":22,"_186":-5,"_187":437,"_103":438},["D",1775922349279],[],[322],[375,378,383,386,391,395,399,403,407,411,415,419,423,427,431,435],{"_108":267,"_100":104,"_174":268,"_176":-5,"_177":155,"_178":269,"_180":123,"_110":441,"_105":33,"_182":253,"_184":271,"_185":22,"_186":-5,"_103":442},["D",1775836672529],[104],[],"upstream",{"_108":158,"_110":446,"_358":447,"_100":46,"_156":163,"_105":160,"_157":-5,"_159":-5,"_360":361,"_112":-5,"_168":22,"_114":115,"_167":353,"_16":165,"_166":101},["D",1741790272811],["D",1741794858963],"pull","ahead","behind","templates",[],"actionData","errors"]