[{"_1":2,"_189":-5,"_190":-5},"loaderData",{"_3":4,"_96":97},"root",{"_5":6,"_37":38,"_69":70},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20,"_36":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isBusinessOrgMember","isHigherTownieTier","ENV",{"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","e51bad5fadd85163deda19ce4085f9f29f43aa4b","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_71":72},"__internal_clerk_state",{"_73":74,"_75":48,"_76":77,"_78":77,"_79":20,"_80":77,"_81":77,"_82":77,"_83":77,"_84":85,"_94":20,"_95":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_86":20,"_19":20,"_87":77,"_88":89,"_90":77,"_91":48,"_92":20,"_93":77},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_98":99,"_100":101,"_102":103,"_104":105,"_168":169,"_186":187,"_188":-5},"handle","cricks_unmixed4u","name","telegramBotStarter","path","router.ts","project",{"_106":107,"_100":101,"_108":109,"_110":-5,"_111":20,"_112":113,"_114":115,"_116":-5,"_12":117,"_118":119,"_120":121,"_122":-5,"_123":-5,"_124":33,"_14":125,"_126":127,"_128":129,"_130":131,"_132":-5,"_133":134,"_135":134,"_136":137,"_138":137,"_139":137,"_140":134,"_141":134,"_23":142,"_145":146,"_150":151,"_167":20},"id","c8d19156-34ec-11f1-8937-42b51c65c3df","createdAt",["D",1775832701083],"deletedAt","legacyEnvVars","privacy","public","description","Telegram Bot that receives and responds to messages","imageUrl","0b86c720-ddc6-11ef-94bf-d1c3ffb48162","pinnedFileId","019d77e0-9940-769a-8c3e-b00cc25ccc8b","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","7018ec7d-7a8e-4e8f-93d1-ab6a7334ca50","tursoName","c8d1915634ec11f1893742b51c65c3df","tursoHostname","c8d1915634ec11f1893742b51c65c3df-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1775921465400],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_98":99,"_143":144},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJzSEJuSGdYT2dQSmprejVnU0VqalpDaWhKUSJ9","org",{"_98":99,"_147":144,"_12":117,"_148":149},"avatar","tier","pro","branch",{"_152":153,"_100":46,"_106":154,"_155":107,"_156":157,"_158":159,"_160":113,"_161":162,"_163":164,"_165":101,"_166":99},"version",56,"c8da965c-34ec-11f1-8937-42b51c65c3df","projectId","forkedBranchId","94596346-ff4f-11ef-842f-569c3dd06744","forkedBranchVersion",35,"forkedProjectPrivacy","forkedProjectId","94591576-ff4f-11ef-842f-569c3dd06744","forkedProjectOrgId","c606f87f-4d7e-48c8-9c39-ef5ab94aec49","projectName","userHandle","isOwned","file",{"_106":170,"_100":103,"_171":172,"_173":-5,"_174":154,"_175":176,"_177":121,"_108":178,"_152":33,"_179":180,"_181":182,"_183":20,"_184":-5,"_102":185},"a31cb36e-35dc-11f1-98b4-42b51c65c3df","fileId","a31cb44a-35dc-11f1-98b4-42b51c65c3df","parentId","branchId","branchVersion",46,"latest",["D",1775935717061],"fileType","script","content","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","deleted","label",[103],"permalink","https://www.val.town/x/cricks_unmixed4u/telegramBotStarter/code/router.ts","extension","actionData","errors"]