[{"_1":2,"_184":-5,"_185":-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","efeea19332d9bfe7de1049656877be9cb817c45f","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,"_165":166,"_181":182,"_183":-5},"handle","aibotcommander","name","Telegram-Image-Analyser-03","path","main.tsx","project",{"_106":107,"_100":101,"_108":109,"_110":-5,"_111":20,"_112":113,"_114":115,"_116":117,"_12":118,"_119":120,"_121":122,"_123":-5,"_124":-5,"_125":33,"_14":126,"_127":128,"_129":130,"_131":132,"_133":-5,"_134":135,"_136":135,"_137":138,"_139":138,"_140":138,"_141":135,"_142":135,"_23":143,"_146":147,"_151":152,"_164":20},"id","d61c3a48-2f27-11f1-9a73-42dde27851f2","createdAt",["D",1775198356715],"deletedAt","legacyEnvVars","privacy","public","description","not current","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/4fcb0e75-4b2d-4524-1438-7a7a97282700/square512","01993890-bc39-742c-bff5-53031d93b2cb","pinnedFileId","019d5211-4536-739f-827d-9b9f709aa0c9","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","01993890-bc39-742c-bff5-540390ef48e8","tursoName","d61c3a482f2711f19a7342dde27851f2","tursoHostname","d61c3a482f2711f19a7342dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1776208856590],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_98":99,"_144":145},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/f13fd113-3e60-49cc-d2e1-6a7320ddbd00/square512","org",{"_98":99,"_148":145,"_12":118,"_149":150},"avatar","tier","free","branch",{"_153":154,"_100":46,"_106":155,"_156":107,"_157":-5,"_158":-5,"_159":-5,"_160":-5,"_161":-5,"_162":101,"_163":99},"version",1,"d61fc9ba-2f27-11f1-9a73-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_106":167,"_100":103,"_168":120,"_169":-5,"_170":155,"_171":154,"_172":122,"_108":173,"_153":33,"_174":175,"_176":177,"_178":20,"_179":-5,"_102":180},"d622cc00-2f27-11f1-9a73-42dde27851f2","fileId","parentId","branchId","branchVersion","latest",["D",1775198356715],"fileType","http","content","import { Bot, InputFile, webhookCallback } from \"https://deno.land/x/grammy@v1.35.0/mod.ts\";\nconst telegramToken = Deno.env.get(\"TELEGRAM_TOKEN\");\nconst poeApiKey = Deno.env.get(\"POE_API_KEY\");\nconst openRouterApiKey = Deno.env.get(\"OPENROUTER_API_KEY\");\nconst hfApiKey = Deno.env.get(\"HF_API_KEY\");\nconst publicWebhookUrl = Deno.env.get(\"PUBLIC_WEBHOOK_URL\");\nif (!telegramToken) throw new Error(\"TELEGRAM_TOKEN is not set\");\nif (!poeApiKey) throw new Error(\"POE_API_KEY is not set\");\nif (!openRouterApiKey) throw new Error(\"OPENROUTER_API_KEY is not set\");\nconst bot = new Bot(telegramToken);\nconst POE_IMAGE_BOT = \"ImageResponseBotDemo\";\nconst POE_VIDEO_BOT = \"VIDEO_DEMO\";\nconst POE_BOT_BASE_URL = \"https://api.poe.com/bot/\";\nconst POLLINATIONS_IMAGE_BASE = \"https://image.pollinations.ai/prompt\";\nconst HF_VIDEO_MODEL = \"https://api-inference.huggingface.co/models/damo-vilab/text-to-video-ms-1.7b\";\nconst OPENROUTER_VISION_MODELS = [\n \"nvidia/nemotron-nano-12b-v2-vl:free\",\n \"google/gemini-2.0-flash-exp:free\",\n \"google/gemini-flash-1.5-8b:free\",\n \"meta-llama/llama-3.2-11b-vision-instruct:free\",\n];\ninterface PoeAttachment {\n url: string;\n content_type?: string;\n name?: string;\n}\ninterface PoeResponse {\n text: string;\n attachments: PoeAttachment[];\n}\n// ── Periodic chat action ──────────────────────────────────────────────────────\n// Telegram chat actions expire after 5 s; re-send every 4 s until cancel() is called.\nfunction keepChatAction(\n chatId: number,\n action: \"typing\" | \"upload_photo\" | \"upload_video\",\n): () => void {\n let active = true;\n (async () => {\n while (active) {\n await bot.api.sendChatAction(chatId, action).catch(() => {});\n await new Promise((r) => setTimeout(r, 4_000));\n }\n })();\n return () => { active = false; };\n}\nfunction shouldGenerateImage(message: string): boolean {\n const msg = message.toLowerCase();\n const genVerbs = [\"generate\", \"create\", \"make\", \"draw\", \"paint\", \"design\", \"produce\", \"render\", \"show\"];\n const imgNouns = [\"image\", \"picture\", \"photo\", \"illustration\", \"art\", \"artwork\", \"graphic\", \"portrait\", \"painting\"];\n return genVerbs.some(w => msg.includes(w)) && imgNouns.some(w => msg.includes(w));\n}\nfunction shouldGenerateVideo(message: string): boolean {\n const msg = message.toLowerCase();\n const genVerbs = [\"generate\", \"create\", \"make\", \"produce\", \"render\", \"animate\"];\n const vidNouns = [\"video\", \"animation\", \"clip\", \"movie\", \"film\", \"gif\", \"motion\"];\n return genVerbs.some(w => msg.includes(w)) && vidNouns.some(w => msg.includes(w));\n}\nfunction isImageBytes(data: Uint8Array): boolean {\n if (data.length < 4) return false;\n if (data[0] === 0xFF && data[1] === 0xD8 && data[2] === 0xFF) return true;\n if (data[0] === 0x89 && data[1] === 0x50 && data[2] === 0x4E && data[3] === 0x47) return true;\n if (data[0] === 0x52 && data[1] === 0x49 && data[2] === 0x46 && data[3] === 0x46) return true;\n if (data[0] === 0x47 && data[1] === 0x49 && data[2] === 0x46) return true;\n return false;\n}\nfunction isVideoBytes(data: Uint8Array): boolean {\n if (data.length < 8) return false;\n if (data[4] === 0x66 && data[5] === 0x74 && data[6] === 0x79 && data[7] === 0x70) return true;\n if (data[0] === 0x1A && data[1] === 0x45 && data[2] === 0xDF && data[3] === 0xA3) return true;\n if (data[0] === 0x52 && data[1] === 0x49 && data[2] === 0x46 && data[3] === 0x46) return true;\n return false;\n}\nfunction uint8ToBase64(data: Uint8Array): string {\n const chunkSize = 0x8000;\n let binary = \"\";\n for (let i = 0; i < data.length; i += chunkSize) binary += String.fromCharCode(...data.subarray(i, i + chunkSize));\n return btoa(binary);\n}\nasync function downloadTelegramFile(fileId: string): Promise {\n const file = await bot.api.getFile(fileId);\n if (!file.file_path) throw new Error(\"Telegram file_path missing\");\n const res = await fetch(`https://api.telegram.org/file/bot${telegramToken}/${file.file_path}`);\n if (!res.ok) throw new Error(`Failed to download Telegram file: ${res.status}`);\n return new Uint8Array(await res.arrayBuffer());\n}\nasync function downloadUrl(url: string): Promise {\n try {\n const res = await fetch(url);\n if (!res.ok) return null;\n return new Uint8Array(await res.arrayBuffer());\n } catch (err) {\n console.error(`Failed to download ${url}:`, err);\n return null;\n }\n}\nfunction extractMarkdownUrls(text: string): string[] {\n return [...text.matchAll(/!\\[.*?\\]\\((https?:\\/\\/[^\\s)]+)\\)/g)].map(m => m[1]);\n}\nfunction extractBareMediaUrls(text: string): string[] {\n return [...text.matchAll(/https?:\\/\\/\\S+\\.(jpg|jpeg|png|gif|webp|mp4|webm|mov)\\S*/gi)]\n .map(m => m[0].replace(/[)>\\]\"']+$/, \"\"));\n}\nfunction splitTelegramMessage(text: string, limit = 4096): string[] {\n if (text.length <= limit) return [text];\n const parts: string[] = [];\n let remaining = text;\n while (remaining.length > limit) {\n let idx = remaining.lastIndexOf(\"\\n\", limit);\n if (idx < Math.floor(limit * 0.7)) idx = remaining.lastIndexOf(\" \", limit);\n if (idx < Math.floor(limit * 0.7)) idx = limit;\n parts.push(remaining.slice(0, idx));\n remaining = remaining.slice(idx).trimStart();\n }\n if (remaining) parts.push(remaining);\n return parts;\n}\nfunction normalizeAttachment(value: unknown): PoeAttachment | null {\n if (!value || typeof value !== \"object\") return null;\n const v = value as Record;\n const url = typeof v.url === \"string\" ? v.url : typeof v.attachment_url === \"string\" ? v.attachment_url : null;\n if (!url) return null;\n return {\n url,\n content_type: typeof v.content_type === \"string\" ? v.content_type : typeof v.mime_type === \"string\" ? v.mime_type : undefined,\n name: typeof v.name === \"string\" ? v.name : undefined,\n };\n}\nasync function callPoeBot(\n botName: string,\n message: string,\n attachments?: PoeAttachment[],\n timeoutMs = 120_000,\n): Promise {\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(\"Poe timeout\"), timeoutMs);\n try {\n const res = await fetch(`${POE_BOT_BASE_URL}${encodeURIComponent(botName)}`, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${poeApiKey}`,\n \"Content-Type\": \"application/json\",\n \"HTTP-Referer\": publicWebhookUrl ?? \"https://val.town\",\n \"X-Title\": \"Val Town Telegram Bot\",\n },\n body: JSON.stringify({\n version: \"1.0\",\n type: \"query\",\n query: [{ role: \"user\", content: message, ...(attachments?.length ? { attachments } : {}) }],\n }),\n signal: controller.signal,\n });\n if (!res.ok) throw new Error(`Poe error: ${res.status} ${await res.text().catch(() => \"\")}`);\n const reader = res.body?.getReader();\n if (!reader) throw new Error(\"Poe response has no body\");\n const decoder = new TextDecoder();\n const responseAttachments: PoeAttachment[] = [];\n let buffer = \"\", resultText = \"\";\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n buffer += decoder.decode(value, { stream: true });\n while (true) {\n const boundary = buffer.indexOf(\"\\n\\n\");\n if (boundary === -1) break;\n const rawEvent = buffer.slice(0, boundary);\n buffer = buffer.slice(boundary + 2);\n const eventLine = rawEvent.split(\"\\n\").find(l => l.startsWith(\"event:\"));\n const eventType = eventLine ? eventLine.slice(6).trim() : \"\";\n const dataText = rawEvent.split(\"\\n\").filter(l => l.startsWith(\"data:\")).map(l => l.slice(5).trim()).join(\"\\n\");\n if (!dataText || dataText === \"[DONE]\") continue;\n try {\n const parsed = JSON.parse(dataText);\n if (typeof parsed.text === \"string\") resultText += parsed.text;\n if (eventType === \"file_attachment\" || parsed.type === \"file_attachment\" || parsed.type === \"attachment\") {\n const att = normalizeAttachment(parsed);\n if (att) responseAttachments.push(att);\n }\n if (Array.isArray(parsed.attachments)) {\n for (const a of parsed.attachments) {\n const att = normalizeAttachment(a);\n if (att) responseAttachments.push(att);\n }\n }\n } catch { }\n }\n }\n for (const url of [...extractMarkdownUrls(resultText), ...extractBareMediaUrls(resultText)]) {\n if (!responseAttachments.some(a => a.url === url)) responseAttachments.push({ url });\n }\n return { text: resultText.trim(), attachments: responseAttachments };\n } finally {\n clearTimeout(timer);\n }\n}\n// ── Image generation ─────────────────────────────────────────────────────────\nasync function generateImageWithPollinations(prompt: string): Promise<{ data: Uint8Array; ext: string } | null> {\n try {\n console.log(\"Generating image with Pollinations.ai…\");\n const seed = Math.floor(Math.random() * 2_147_483_647);\n const url = `${POLLINATIONS_IMAGE_BASE}/${encodeURIComponent(prompt)}?width=1024&height=1024&nologo=true&seed=${seed}&model=flux`;\n const res = await fetch(url, { signal: AbortSignal.timeout(90_000) });\n if (!res.ok) throw new Error(`Pollinations HTTP ${res.status}`);\n const data = new Uint8Array(await res.arrayBuffer());\n if (!isImageBytes(data)) throw new Error(\"Pollinations returned non-image payload\");\n const ext = data[0] === 0x89 ? \".png\" : \".jpg\";\n console.log(`Pollinations image ✓ (${data.length} bytes, ${ext})`);\n return { data, ext };\n } catch (err) {\n console.error(\"Pollinations image error:\", err);\n return null;\n }\n}\nasync function generateImageWithPoe(prompt: string): Promise<{ data: Uint8Array; ext: string } | null> {\n console.log(`Generating image with Poe (${POE_IMAGE_BOT}) [fallback]…`);\n try {\n const { attachments } = await callPoeBot(POE_IMAGE_BOT, prompt, undefined, 120_000);\n for (const att of attachments) {\n const isImg = att.content_type?.startsWith(\"image/\") || /\\.(jpg|jpeg|png|gif|webp)(\\?|$)/i.test(att.url);\n if (!isImg) continue;\n const data = await downloadUrl(att.url);\n if (data && isImageBytes(data)) {\n return { data, ext: att.url.endsWith(\".png\") || att.content_type === \"image/png\" ? \".png\" : \".jpg\" };\n }\n }\n for (const att of attachments) {\n const data = await downloadUrl(att.url);\n if (data && isImageBytes(data)) return { data, ext: data[0] === 0x89 ? \".png\" : \".jpg\" };\n }\n return null;\n } catch (err) {\n console.error(\"Poe image error:\", err);\n return null;\n }\n}\nasync function generateImage(prompt: string): Promise<{ data: Uint8Array; ext: string } | null> {\n return (await generateImageWithPollinations(prompt)) ?? (await generateImageWithPoe(prompt));\n}\n// ── Video generation — HuggingFace FIRST, Poe fallback ───────────────────────\n// HF model cold-starts can take 3-4 min; we rely on keepChatAction() to keep\n// Telegram's upload indicator alive while we wait.\nasync function generateVideoWithHuggingFace(prompt: string): Promise<{ data: Uint8Array; ext: string } | null> {\n console.log(\"Generating video with HuggingFace (damo-vilab) [primary]…\");\n try {\n const headers: Record = { \"Content-Type\": \"application/json\" };\n if (hfApiKey) headers[\"Authorization\"] = `Bearer ${hfApiKey}`;\n const res = await fetch(HF_VIDEO_MODEL, {\n method: \"POST\",\n headers,\n body: JSON.stringify({ inputs: prompt, parameters: { num_frames: 16, num_inference_steps: 25 } }),\n signal: AbortSignal.timeout(240_000),\n });\n if (!res.ok) {\n const body = await res.text().catch(() => \"\");\n throw new Error(`HF HTTP ${res.status}: ${body.slice(0, 200)}`);\n }\n const contentType = res.headers.get(\"content-type\") ?? \"\";\n const data = new Uint8Array(await res.arrayBuffer());\n if (!isVideoBytes(data)) {\n throw new Error(`HF returned non-video payload: ${new TextDecoder().decode(data.slice(0, 200))}`);\n }\n const ext = contentType.includes(\"webm\") ? \".webm\" : \".mp4\";\n console.log(`HuggingFace video ✓ (${data.length} bytes)`);\n return { data, ext };\n } catch (err) {\n console.error(\"HuggingFace video error:\", err);\n return null;\n }\n}\nasync function generateVideoWithPoe(prompt: string): Promise<{ data: Uint8Array; ext: string; url?: string } | null> {\n console.log(`Generating video with Poe (${POE_VIDEO_BOT}) [fallback]…`);\n try {\n const { text, attachments } = await callPoeBot(POE_VIDEO_BOT, prompt, undefined, 180_000);\n for (const att of attachments) {\n const data = await downloadUrl(att.url);\n if (!data) continue;\n if (isVideoBytes(data)) {\n const ext = att.content_type === \"video/webm\" ? \".webm\" : att.url.includes(\".gif\") ? \".gif\" : \".mp4\";\n return { data, ext, url: att.url };\n }\n if ((att.content_type?.startsWith(\"video/\") || /\\.(mp4|webm|mov|gif)(\\?|$)/i.test(att.url)) && isImageBytes(data)) {\n return { data, ext: \".gif\", url: att.url };\n }\n }\n console.warn(`Poe video: no usable bytes. Text preview: ${text.slice(0, 200)}`);\n return null;\n } catch (err) {\n console.error(\"Poe video error:\", err);\n return null;\n }\n}\n// HuggingFace → Poe\nasync function generateVideo(prompt: string): Promise<{ data: Uint8Array; ext: string; url?: string } | null> {\n return (await generateVideoWithHuggingFace(prompt)) ?? (await generateVideoWithPoe(prompt));\n}\n// ── Vision ───────────────────────────────────────────────────────────────────\nasync function analyzeImageWithOpenRouter(imageData: Uint8Array, prompt: string): Promise {\n const base64 = uint8ToBase64(imageData);\n for (const model of OPENROUTER_VISION_MODELS) {\n try {\n console.log(`Trying OpenRouter vision model: ${model}`);\n const res = await fetch(\"https://openrouter.ai/api/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${openRouterApiKey}`,\n \"Content-Type\": \"application/json\",\n \"HTTP-Referer\": publicWebhookUrl ?? \"https://val.town\",\n \"X-Title\": \"Val Town Telegram Bot\",\n },\n body: JSON.stringify({\n model,\n messages: [{\n role: \"user\",\n content: [\n { type: \"image_url\", image_url: { url: `data:image/jpeg;base64,${base64}` } },\n { type: \"text\", text: prompt },\n ],\n }],\n }),\n });\n if (!res.ok) { console.warn(`OpenRouter ${model} → ${res.status}`); continue; }\n const json = await res.json();\n const text = json.choices?.[0]?.message?.content;\n if (text) { console.log(`OpenRouter vision ✓ (${model})`); return text; }\n } catch (err) {\n console.error(`OpenRouter ${model} error:`, err);\n }\n }\n throw new Error(\"All OpenRouter vision models failed\");\n}\n// ── Bot handlers ─────────────────────────────────────────────────────────────\nbot.command(\"start\", ctx =>\n ctx.reply(\n \"👋 *Welcome!* Here's what I can do:\\n\\n\" +\n \"🔍 *Analyse images* — send me a photo\\n\" +\n \"🎨 *Generate images* — try _\\\"draw a sunset over mountains\\\"_\\n\" +\n \"🎬 *Generate videos* — try _\\\"create a video of ocean waves\\\"_\",\n { parse_mode: \"Markdown\" },\n ),\n);\nbot.on(\"message\", async (ctx) => {\n const userMessage = ctx.msg?.caption || ctx.msg?.text || \"\";\n const photo = ctx.msg?.photo;\n const chatId = ctx.chat.id;\n // ── Video\n if (userMessage && shouldGenerateVideo(userMessage)) {\n console.log(`Video generation from ${ctx.from?.id}: ${userMessage}`);\n const status = await ctx.reply(\"🎬 Generating your video… this may take a minute or two.\");\n const cancelAction = keepChatAction(chatId, \"upload_video\");\n const result = await generateVideo(userMessage);\n cancelAction();\n await ctx.api.deleteMessage(chatId, status.message_id).catch(() => {});\n if (!result) {\n await ctx.reply(\"Sorry, video generation failed on all providers right now. Please try again later.\");\n return;\n }\n try {\n if (result.ext === \".gif\") {\n await ctx.replyWithAnimation(new InputFile(result.data, `generated${result.ext}`), { caption: \"🎬 Generated video\" });\n } else {\n await ctx.replyWithVideo(new InputFile(result.data, `generated${result.ext}`), { caption: \"🎬 Generated video\" });\n }\n } catch (err) {\n console.error(\"Failed to send video via Telegram:\", err);\n if (result.url) {\n await ctx.reply(`🎬 Video generated! Direct link:\\n${result.url}`);\n } else {\n await ctx.reply(\"Video was generated but couldn't be sent — the file may exceed Telegram's 50 MB limit.\");\n }\n }\n return;\n }\n // ── Image\n if (userMessage && shouldGenerateImage(userMessage)) {\n console.log(`Image generation from ${ctx.from?.id}: ${userMessage}`);\n const status = await ctx.reply(\"🎨 Generating your image… this may take a moment.\");\n const cancelAction = keepChatAction(chatId, \"upload_photo\");\n const result = await generateImage(userMessage);\n cancelAction();\n await ctx.api.deleteMessage(chatId, status.message_id).catch(() => {});\n if (!result) {\n await ctx.reply(\"Sorry, image generation failed on all providers right now. Please try again later.\");\n return;\n }\n await ctx.replyWithPhoto(new InputFile(result.data, `generated${result.ext}`), { caption: \"🎨 Generated image\" });\n return;\n }\n // ── Vision analysis\n if (photo) {\n console.log(`Image analysis from ${ctx.from?.id}: ${userMessage || \"[no caption]\"}`);\n const cancelAction = keepChatAction(chatId, \"typing\");\n try {\n const largestPhoto = photo[photo.length - 1];\n const imageData = await downloadTelegramFile(largestPhoto.file_id);\n const analysis = await analyzeImageWithOpenRouter(imageData, userMessage || \"Describe this image in detail.\");\n cancelAction();\n for (const chunk of splitTelegramMessage(analysis)) await ctx.reply(chunk);\n } catch (err) {\n cancelAction();\n console.error(\"Vision error:\", err);\n await ctx.reply(\"Sorry, I couldn't analyse that image right now. Please try again.\");\n }\n return;\n }\n // ── Fallthrough\n if (userMessage) {\n await ctx.reply(\n \"I can:\\n\" +\n \"• 🔍 *Analyse images* — send me a photo\\n\" +\n \"• 🎨 *Generate images* — try _\\\"draw a cat in space\\\"_\\n\" +\n \"• 🎬 *Generate videos* — try _\\\"create a video of a waterfall\\\"_\",\n { parse_mode: \"Markdown\" },\n );\n }\n});\n// ── Webhook bootstrap ─────────────────────────────────────────────────────────\n// CRITICAL FIX: Validate secret then fire-and-forget bot.handleUpdate().\n// Returning 200 immediately prevents Telegram from timing out and retrying\n// the update while image/video generation (up to 240 s) is still in flight.\nconst SECRET_TOKEN = telegramToken.split(\":\")[1];\nlet webhookConfiguredFor: string | null = null;\nfunction looksLikeValRunUrl(url: string): boolean {\n try {\n const u = new URL(url);\n return u.protocol === \"https:\" && u.hostname.endsWith(\".val.run\");\n } catch { return false; }\n}\nasync function ensureWebhook(req: Request): Promise {\n const candidate = publicWebhookUrl || (looksLikeValRunUrl(req.url) ? req.url : null);\n if (!candidate || webhookConfiguredFor === candidate) return;\n await bot.api.setWebhook(candidate, { secret_token: SECRET_TOKEN, drop_pending_updates: false });\n webhookConfiguredFor = candidate;\n console.log(`Webhook set: ${candidate}`);\n}\nexport default async (req: Request): Promise => {\n try { await ensureWebhook(req); } catch (err) { console.error(\"ensureWebhook failed:\", err); }\n if (req.method === \"POST\") {\n // Reject tampered requests before doing any work\n const incomingSecret = req.headers.get(\"X-Telegram-Bot-Api-Secret-Token\");\n if (incomingSecret !== SECRET_TOKEN) {\n return new Response(\"Forbidden\", { status: 403 });\n }\n let update: unknown;\n try {\n update = await req.json();\n } catch {\n return new Response(\"Bad Request\", { status: 400 });\n }\n // Fire-and-forget: bot.handleUpdate() may run for minutes (video gen).\n // Returning 200 immediately tells Telegram the update was received,\n // preventing duplicate delivery while generation is in progress.\n bot.handleUpdate(update as Parameters[0]).catch(err => {\n console.error(\"handleUpdate error:\", err);\n });\n return new Response(\"OK\", { status: 200 });\n }\n return new Response(\n `✅ Image & Video bot is running.\\nWebhook: ${publicWebhookUrl ?? \"not configured\"}`,\n { status: 200, headers: { \"content-type\": \"text/plain; charset=utf-8\" } },\n );\n};","deleted","label",[103],"permalink","https://www.val.town/x/aibotcommander/Telegram-Image-Analyser-03/code/main.tsx","extension","actionData","errors"]