[{"_1":2,"_181":-5,"_182":-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,"_162":163,"_178":179,"_180":-5},"handle","aibotcommander","name","Poe-Telegram","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":-5,"_128":-5,"_129":-5,"_130":-5,"_131":132,"_133":132,"_134":135,"_136":135,"_137":135,"_138":132,"_139":132,"_23":140,"_143":144,"_148":149,"_161":20},"id","b2e980c6-2f27-11f1-95c1-42dde27851f2","createdAt",["D",1775198297634],"deletedAt","legacyEnvVars","privacy","public","description","not working","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/0a46d059-8e3e-4fc4-2820-0b2076fa8400/square512","01993890-bc39-742c-bff5-53031d93b2cb","pinnedFileId","019d5210-5ece-7073-991b-7d7683b62d56","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","01993890-bc39-742c-bff5-540390ef48e8","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_98":99,"_141":142},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/f13fd113-3e60-49cc-d2e1-6a7320ddbd00/square512","org",{"_98":99,"_145":142,"_12":118,"_146":147},"avatar","tier","free","branch",{"_150":151,"_100":46,"_106":152,"_153":107,"_154":-5,"_155":-5,"_156":-5,"_157":-5,"_158":-5,"_159":101,"_160":99},"version",1,"b2f69d88-2f27-11f1-95c1-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_106":164,"_100":103,"_165":120,"_166":-5,"_167":152,"_168":151,"_169":122,"_108":170,"_150":33,"_171":172,"_173":174,"_175":20,"_176":-5,"_102":177},"b2fc22c6-2f27-11f1-95c1-42dde27851f2","fileId","parentId","branchId","branchVersion","latest",["D",1775198297634],"fileType","http","content","import { Bot, InputFile, webhookCallback, } from \"https://deno.land/x/grammy@v1.35.0/mod.ts\";\n\nconst telegramToken = Deno.env.get(\"TELEGRAM_TOKEN\");\nconst poeApiKey = Deno.env.get(\"POE_API_KEY\");\nconst openRouterApiKey = Deno.env.get(\"OPENROUTER_API_KEY\");\nconst publicWebhookUrl = Deno.env.get(\"PUBLIC_WEBHOOK_URL\");\n\nif (!telegramToken) throw new Error(\"TELEGRAM_TOKEN is not set\");\nif (!poeApiKey) throw new Error(\"POE_API_KEY is not set\");\n\n// ─── Model lists ────────────────────────────────────────────────────────────\nconst VIDEO_GENERATION_MODELS = [\"Wan-2.6-N\", \"Wan-2.6\"];\nconst VISION_MODELS = [\n \"nvidia/nemotron-nano-9b-v2:free\",\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];\nconst DOCUMENT_MODELS = [\n \"tngtech/deepseek-r1t2-chimera:free\",\n \"tngtech/deepseek-r1t-chimera:free\",\n \"nex-agi/deepseek-v3.1-nex-n1:free\",\n];\n\nconst POE_VISION_FALLBACK = \"Gemini-3.1-flash-lite\";\nconst TEXT_FALLBACK_POE_MODEL = \"Gemini-3.1-flash-lite\";\nconst POE_BOT_BASE_URL = \"https://api.poe.com/bot/\";\nconst MAX_POE_WAIT_MS = 8 * 60 * 1000;\nconst MAX_VIDEO_BYTES = 45 * 1024 * 1024;\nconst TARGET_VIDEO_MB = 43;\n\n// ─── Pollinations config (free, no API key required) ─────────────────────────\nconst POLLINATIONS_MODELS = [\"flux\", \"turbo\", \"gptimage\"] as const;\ntype PollinationsModel = typeof POLLINATIONS_MODELS[number];\n\nconst POLLINATIONS_IMAGE_BASE = \"https://image.pollinations.ai/prompt\";\n\nconst bot = new Bot(telegramToken);\n\n// ─── Types ───────────────────────────────────────────────────────────────────\ntype PoeAttachment = { url: string; content_type?: string; name?: string };\ntype PoeResult = { text: string; attachments: PoeAttachment[] };\n\n// ─── Video helpers ───────────────────────────────────────────────────────────\nasync function probeVideoDuration(filePath: string): Promise {\n try {\n const cmd = new Deno.Command(\"ffprobe\", {\n args: [\"-v\",\"error\",\"-show_entries\",\"format=duration\",\n \"-of\",\"default=noprint_wrappers=1:nokey=1\", filePath],\n stdout: \"piped\", stderr: \"piped\",\n });\n const { success, stdout } = await cmd.output();\n if (!success) return null;\n const duration = parseFloat(new TextDecoder().decode(stdout).trim());\n return isNaN(duration) ? null : duration;\n } catch { return null; }\n}\n\nasync function compressVideoForTelegram(inputPath: string, outputPath: string): Promise {\n const duration = await probeVideoDuration(inputPath);\n const audioBitrateKbps = 128;\n if (duration && duration > 0) {\n const totalBitrateKbps = Math.floor((TARGET_VIDEO_MB * 8192) / duration);\n const videoBitrateKbps = Math.max(100, totalBitrateKbps - audioBitrateKbps);\n console.log(`Compressing: duration=${duration.toFixed(1)}s, vbr=${videoBitrateKbps}kbps`);\n const pass1 = new Deno.Command(\"ffmpeg\", {\n args: [\"-y\",\"-i\",inputPath,\"-c:v\",\"libx264\",\"-b:v\",`${videoBitrateKbps}k`,\n \"-pass\",\"1\",\"-an\",\"-f\",\"null\",\"/dev/null\"],\n stdout: \"null\", stderr: \"piped\",\n });\n const r1 = await pass1.output();\n if (!r1.success) console.warn(\"FFmpeg pass 1 stderr:\", new TextDecoder().decode(r1.stderr).slice(-300));\n const pass2 = new Deno.Command(\"ffmpeg\", {\n args: [\"-y\",\"-i\",inputPath,\"-c:v\",\"libx264\",\"-b:v\",`${videoBitrateKbps}k`,\n \"-pass\",\"2\",\"-c:a\",\"aac\",\"-b:a\",`${audioBitrateKbps}k`,\n \"-movflags\",\"+faststart\", outputPath],\n stdout: \"null\", stderr: \"piped\",\n });\n const r2 = await pass2.output();\n if (!r2.success) throw new Error(\"FFmpeg pass 2 failed: \" + new TextDecoder().decode(r2.stderr).slice(-500));\n } else {\n console.log(\"Duration unknown — using CRF 28 fallback\");\n const cmd = new Deno.Command(\"ffmpeg\", {\n args: [\"-y\",\"-i\",inputPath,\"-c:v\",\"libx264\",\"-crf\",\"28\",\"-preset\",\"fast\",\n \"-c:a\",\"aac\",\"-b:a\",`${audioBitrateKbps}k`,\"-movflags\",\"+faststart\", outputPath],\n stdout: \"null\", stderr: \"piped\",\n });\n const { success, stderr } = await cmd.output();\n if (!success) throw new Error(\"FFmpeg CRF encode failed: \" + new TextDecoder().decode(stderr).slice(-500));\n }\n}\n\n// ─── Keyword / intent helpers ─────────────────────────────────────────────────\nfunction lower(s: string) { return s.toLowerCase(); }\n\nfunction shouldGenerateImage(message: string): boolean {\n const msg = lower(message);\n const gen = [\"generate\",\"create\",\"make\",\"draw\",\"paint\",\"design\"];\n const img = [\"image\",\"picture\",\"photo\",\"illustration\",\"art\",\"artwork\",\"graphic\"];\n const vid = [\"video\",\"movie\",\"clip\",\"animation\"];\n return gen.some(w => msg.includes(w)) && img.some(w => msg.includes(w)) && !vid.some(w => msg.includes(w));\n}\n\nfunction shouldGenerateVideo(message: string): boolean {\n const msg = lower(message);\n const gen = [\"generate\",\"create\",\"make\",\"render\",\"produce\",\"animate\"];\n const vid = [\"video\",\"movie\",\"clip\",\"animation\",\"cinematic\"];\n return (gen.some(w => msg.includes(w)) || msg.includes(\"video generate\")) && vid.some(w => msg.includes(w));\n}\n\n/** Returns true for messages that would be enriched by a visual companion */\nfunction wantsVisualCompanion(message: string): boolean {\n const msg = lower(message);\n // Skip short messages, greetings, simple questions unlikely to benefit from an image\n const skipWords = [\"hello\",\"hi\",\"hey\",\"thanks\",\"thank\",\"ok\",\"okay\",\"bye\",\"what is your\",\"who are\",\"how are\",\"help\",\"start\"];\n if (skipWords.some(w => msg.includes(w))) return false;\n // Skip very short messages\n if (message.trim().split(/\\s+/).length < 4) return false;\n return true;\n}\n\nfunction getAttachmentKind(contentType?: string): \"image\" | \"video\" | \"audio\" | \"file\" {\n const ct = lower(contentType || \"\");\n if (ct.startsWith(\"image/\")) return \"image\";\n if (ct.startsWith(\"video/\")) return \"video\";\n if (ct.startsWith(\"audio/\")) return \"audio\";\n return \"file\";\n}\n\n// ─── Poe attachment helpers ───────────────────────────────────────────────────\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 :\n 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 :\n typeof v.mime_type === \"string\" ? v.mime_type : undefined,\n name: typeof v.name === \"string\" ? v.name : undefined,\n };\n}\n\nfunction extractAttachments(payload: unknown): PoeAttachment[] {\n const results: PoeAttachment[] = [];\n const seen = new Set();\n const containers: Array> = [];\n if (payload && typeof payload === \"object\") {\n containers.push(payload as Record);\n const p = payload as Record;\n for (const key of [\"response\",\"message\",\"delta\",\"data\"]) {\n const nested = p[key];\n if (nested && typeof nested === \"object\") containers.push(nested as Record);\n }\n }\n for (const container of containers) {\n const one = normalizeAttachment(container.attachment);\n if (one && !seen.has(one.url)) { seen.add(one.url); results.push(one); }\n const many = container.attachments;\n if (Array.isArray(many)) {\n for (const item of many) {\n const att = normalizeAttachment(item);\n if (att && !seen.has(att.url)) { seen.add(att.url); results.push(att); }\n }\n }\n }\n return results;\n}\n\n// ─── Message splitting ────────────────────────────────────────────────────────\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}\n\n// ─── Utils ────────────────────────────────────────────────────────────────────\nfunction uint8ToBase64(data: Uint8Array): string {\n const chunkSize = 0x8000;\n let binary = \"\";\n for (let i = 0; i < data.length; i += chunkSize)\n binary += String.fromCharCode(...data.subarray(i, i + chunkSize));\n return btoa(binary);\n}\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}\n\n// ─── Poe helpers ──────────────────────────────────────────────────────────────\nasync function uploadUrlToPoe(fileUrl: string, fileName: string): Promise {\n const res = await fetch(\"https://api.poe.com/rpc/file_attachment_3RD_PARTY_POST\", {\n method: \"POST\",\n headers: { Authorization: `Bearer ${poeApiKey}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ download_url: fileUrl, download_filename: fileName }),\n });\n if (!res.ok) throw new Error(`Poe file upload failed: ${res.status}`);\n const att = normalizeAttachment(await res.json());\n if (!att) throw new Error(\"Poe file upload returned no usable attachment\");\n return att;\n}\n\nasync function callPoeBot(\n botName: string,\n message: string,\n options?: { attachments?: PoeAttachment[]; parameters?: Record; timeoutMs?: number },\n): Promise {\n const timeoutMs = options?.timeoutMs ?? MAX_POE_WAIT_MS;\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(\"Poe request 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\", type: \"query\",\n query: [{\n role: \"user\", content: message,\n ...(options?.attachments?.length ? { attachments: options.attachments } : {}),\n ...(options?.parameters ? { parameters: options.parameters } : {}),\n }],\n }),\n signal: controller.signal,\n });\n if (!res.ok) {\n const err = await res.text().catch(() => \"\");\n throw new Error(`Poe API error for ${botName}: ${res.status} ${res.statusText} ${err}`.trim());\n }\n const reader = res.body?.getReader();\n if (!reader) throw new Error(\"Poe response has no body\");\n const decoder = new TextDecoder();\n let buffer = \"\", resultText = \"\";\n const attachments: PoeAttachment[] = [];\n const seenUrls = new Set();\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 dataLines = rawEvent.split(\"\\n\")\n .filter(l => l.startsWith(\"data:\")).map(l => l.slice(5).trim());\n if (!dataLines.length) continue;\n const dataText = dataLines.join(\"\\n\");\n if (dataText === \"[DONE]\") continue;\n let payload: any;\n try { payload = JSON.parse(dataText); } catch { continue; }\n if (typeof payload.text === \"string\") resultText += payload.text;\n for (const att of extractAttachments(payload)) {\n if (!seenUrls.has(att.url)) { seenUrls.add(att.url); attachments.push(att); }\n }\n }\n }\n return { text: resultText.trim(), attachments };\n } finally { clearTimeout(timer); }\n}\n\n// ─── Image validation ─────────────────────────────────────────────────────────\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; // JPEG\n if (data[0] === 0x89 && data[1] === 0x50 && data[2] === 0x4E && data[3] === 0x47) return true; // PNG\n if (data[0] === 0x52 && data[1] === 0x49 && data[2] === 0x46 && data[3] === 0x46) return true; // WEBP\n if (data[0] === 0x47 && data[1] === 0x49 && data[2] === 0x46) return true; // GIF\n return false;\n}\n\n// ─── Pollinations image (free, no API key) ────────────────────────────────────\n/**\n * Generate an image via Pollinations.ai — completely free, no API key needed.\n * Tries multiple models in order and returns the first successful result.\n */\nasync function generateImageWithPollinations(\n prompt: string,\n model: PollinationsModel = \"flux\",\n): Promise<{ data: Uint8Array; name: string } | null> {\n const seed = Math.floor(Math.random() * 1_000_000);\n const url = `${POLLINATIONS_IMAGE_BASE}/${encodeURIComponent(prompt)}`\n + `?model=${model}&width=1024&height=1024&nologo=true&seed=${seed}`;\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(), 60_000); // 60 s timeout\n try {\n console.log(`Requesting Pollinations image (model=${model}):`, url);\n const res = await fetch(url, { signal: controller.signal });\n if (!res.ok) {\n console.error(`Pollinations fetch failed (${model}):`, res.status, res.statusText);\n return null;\n }\n const ct = res.headers.get(\"content-type\") ?? \"\";\n const data = new Uint8Array(await res.arrayBuffer());\n console.log(`Pollinations (${model}) response: ${ct}, ${data.byteLength} bytes`);\n if (!isImageBytes(data)) {\n const preview = new TextDecoder().decode(data.slice(0, 200));\n console.error(`Pollinations (${model}) returned non-image bytes. Preview:`, preview);\n return null;\n }\n const name = data[0] === 0x89 ? \"generated-image.png\" : \"generated-image.jpg\";\n return { data, name };\n } catch (err) {\n console.error(`Pollinations image generation failed (${model}):`, err);\n return null;\n } finally {\n clearTimeout(timer);\n }\n}\n\n/**\n * Try all Pollinations models in order, return first success.\n */\nasync function generateImageWithPollinationsFallback(\n prompt: string,\n): Promise<{ data: Uint8Array; name: string } | null> {\n for (const model of POLLINATIONS_MODELS) {\n const result = await generateImageWithPollinations(prompt, model);\n if (result) return result;\n }\n return null;\n}\n\n// ─── Local visual keyword extractor (no HTTP, no external API, cannot throw) ──\nconst STOP_WORDS = new Set([\n \"a\",\"an\",\"the\",\"is\",\"are\",\"was\",\"were\",\"be\",\"been\",\"being\",\n \"have\",\"has\",\"had\",\"do\",\"does\",\"did\",\"will\",\"would\",\"could\",\"should\",\n \"may\",\"might\",\"shall\",\"can\",\"i\",\"me\",\"my\",\"we\",\"our\",\"you\",\"your\",\n \"he\",\"his\",\"she\",\"her\",\"it\",\"its\",\"they\",\"their\",\"what\",\"which\",\"who\",\n \"this\",\"that\",\"these\",\"those\",\"and\",\"but\",\"or\",\"for\",\"if\",\"then\",\"than\",\n \"as\",\"at\",\"by\",\"in\",\"of\",\"on\",\"to\",\"up\",\"with\",\"about\",\"into\",\"from\",\n \"please\",\"tell\",\"give\",\"explain\",\"describe\",\"write\",\"say\",\"show\",\"find\",\n \"how\",\"why\",\"when\",\"where\",\"yes\",\"no\",\"not\",\"just\",\"also\",\"very\",\"more\",\n]);\n\n/**\n * Extract a short image-friendly prompt from the user's message.\n * Pure synchronous — no HTTP calls, no AbortSignal, never throws.\n */\nfunction extractVisualKeyword(userMessage: string): string {\n const words = userMessage\n .replace(/[^\\w\\s]/g, \" \")\n .toLowerCase()\n .split(/\\s+/)\n .filter(w => w.length > 2 && !STOP_WORDS.has(w));\n const seen = new Set();\n const unique = words.filter(w => seen.has(w) ? false : (seen.add(w), true));\n const keyword = unique.slice(0, 6).join(\" \").trim();\n console.log(\"Visual keyword:\", keyword || userMessage.slice(0, 80));\n return keyword || userMessage.slice(0, 80);\n}\n\n// ─── Video generation ─────────────────────────────────────────────────────────\nasync function generateVideoWithPoe(prompt: string): Promise<{ data: Uint8Array; name: string } | null> {\n for (const model of VIDEO_GENERATION_MODELS) {\n let inputPath: string | null = null;\n let outputPath: string | null = null;\n try {\n console.log(`Trying video generation with ${model}`);\n const result = await callPoeBot(model, prompt, { timeoutMs: MAX_POE_WAIT_MS });\n const videoAtt = result.attachments.find(a => getAttachmentKind(a.content_type) === \"video\")\n ?? result.attachments[0];\n if (!videoAtt) { console.warn(`No attachment from ${model}`); continue; }\n console.log(\"Fetching video from:\", videoAtt.url);\n const res = await fetch(videoAtt.url);\n if (!res.ok) { console.error(`Fetch failed (${model}):`, res.status); continue; }\n const rawBytes = new Uint8Array(await res.arrayBuffer());\n const rawMB = (rawBytes.byteLength / 1024 / 1024).toFixed(1);\n console.log(`Raw video size: ${rawMB} MB`);\n if (rawBytes.byteLength <= MAX_VIDEO_BYTES) {\n return { data: rawBytes, name: videoAtt.name || \"wan-video.mp4\" };\n }\n console.log(`Video is ${rawMB} MB — compressing with FFmpeg…`);\n inputPath = await Deno.makeTempFile({ suffix: \".mp4\" });\n outputPath = await Deno.makeTempFile({ suffix: \"_out.mp4\" });\n await Deno.writeFile(inputPath, rawBytes);\n await compressVideoForTelegram(inputPath, outputPath);\n const compressed = await Deno.readFile(outputPath);\n const compressedMB = (compressed.byteLength / 1024 / 1024).toFixed(1);\n console.log(`Compressed size: ${compressedMB} MB`);\n if (compressed.byteLength > MAX_VIDEO_BYTES) {\n console.warn(`Still ${compressedMB} MB after compression — trying next model`);\n continue;\n }\n return { data: compressed, name: videoAtt.name || \"wan-video.mp4\" };\n } catch (err) {\n console.error(`Video model failed (${model}):`, err);\n } finally {\n if (inputPath) Deno.remove(inputPath).catch(() => {});\n if (outputPath) Deno.remove(outputPath).catch(() => {});\n for (const f of [\"ffmpeg2pass-0.log\",\"ffmpeg2pass-0.log.mbtree\"])\n Deno.remove(f).catch(() => {});\n }\n }\n return null;\n}\n\n// ─── Vision helpers ───────────────────────────────────────────────────────────\nasync function analyzeImageWithPoe(imageUrl: string, prompt: string): Promise {\n try {\n const att = await uploadUrlToPoe(imageUrl, \"telegram-image.jpg\");\n const result = await callPoeBot(POE_VISION_FALLBACK, prompt, { attachments: [att] });\n return result.text || null;\n } catch (err) {\n console.error(\"Poe vision fallback failed:\", err);\n return null;\n }\n}\n\nasync function callOpenRouter(model: string, message: string, imageBase64?: string): Promise {\n if (!openRouterApiKey) return null;\n const content: any[] = [{ type: \"text\", text: message }];\n if (imageBase64) content.unshift({ type: \"image_url\", image_url: { url: `data:image/jpeg;base64,${imageBase64}` } });\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({ model, messages: [{ role: \"user\", content }] }),\n });\n if (!res.ok) throw new Error(`OpenRouter error: ${res.status} ${await res.text().catch(() => \"\")}`);\n return (await res.json()).choices?.[0]?.message?.content || null;\n}\n\nasync function analyzeImageWithOpenRouter(imageBase64: string, prompt: string): Promise {\n for (const model of VISION_MODELS) {\n try {\n const result = await callOpenRouter(model, prompt, imageBase64);\n if (result) return result;\n } catch (err) { console.error(`Vision model failed (${model}):`, err); }\n }\n return null;\n}\n\nasync function processTextWithOpenRouter(message: string): Promise {\n for (const model of DOCUMENT_MODELS) {\n try {\n const result = await callOpenRouter(model, message);\n if (result) return result;\n } catch (err) { console.error(`Text model failed (${model}):`, err); }\n }\n return null;\n}\n\nasync function handleImageAnalysis(imageData: Uint8Array, imageUrl: string, prompt: string): Promise {\n if (openRouterApiKey) {\n const result = await analyzeImageWithOpenRouter(uint8ToBase64(imageData), prompt);\n if (result) return result;\n }\n const poeResult = await analyzeImageWithPoe(imageUrl, prompt);\n if (poeResult) return poeResult;\n throw new Error(\"All vision models failed\");\n}\n\n// ─── Bot handlers ─────────────────────────────────────────────────────────────\nbot.command(\"start\", async (ctx) => {\n await ctx.reply(\"✅ Bot is running.\");\n});\n\nbot.on(\"message\", async (ctx) => {\n const userMessage = ctx.msg?.caption || ctx.msg?.text || \"\";\n const photo = ctx.msg?.photo;\n\n // ── Video generation ────────────────────────────────────────────────────────\n if (userMessage && shouldGenerateVideo(userMessage)) {\n console.log(`Video generation request from ${ctx.from?.id}: ${userMessage}`);\n try {\n await ctx.reply(\"🎬 Generating your video with Wan… this can take a few minutes.\");\n await ctx.replyWithChatAction(\"upload_video\");\n const video = await generateVideoWithPoe(userMessage);\n if (!video) { await ctx.reply(\"Sorry, I couldn't generate a video right now. Please try again later.\"); return; }\n await ctx.replyWithVideo(new InputFile(video.data, video.name), {\n caption: \"🎬 Generated with Wan\", supports_streaming: true,\n });\n } catch (err) {\n console.error(\"Video generation error:\", err);\n await ctx.reply(\"Sorry, video generation failed. Please try again later.\");\n }\n return;\n }\n\n // ── Explicit image generation ────────────────────────────────────────────────\n if (userMessage && shouldGenerateImage(userMessage)) {\n console.log(`Image generation request from ${ctx.from?.id}: ${userMessage}`);\n try {\n await ctx.replyWithChatAction(\"upload_photo\");\n // Use full fallback chain across all Pollinations models\n const image = await generateImageWithPollinationsFallback(userMessage);\n if (!image) { await ctx.reply(\"Sorry, I couldn't generate the image. Please try again later.\"); return; }\n await ctx.replyWithPhoto(new InputFile(image.data, image.name), { caption: \"🎨 Generated with Pollinations (free)\" });\n } catch (err) {\n console.error(\"Image generation error:\", err);\n await ctx.reply(\"Sorry, image generation failed. Please try again later.\");\n }\n return;\n }\n\n // ── Image/photo analysis ─────────────────────────────────────────────────────\n if (photo) {\n console.log(`Image analysis request from ${ctx.from?.id}: ${userMessage || \"[image only]\"}`);\n try {\n await ctx.replyWithChatAction(\"typing\");\n const largestPhoto = photo[photo.length - 1];\n const imageData = await downloadTelegramFile(largestPhoto.file_id);\n const file = await bot.api.getFile(largestPhoto.file_id);\n if (!file.file_path) throw new Error(\"Telegram file_path missing\");\n const telegramImageUrl = `https://api.telegram.org/file/bot${telegramToken}/${file.file_path}`;\n const result = await handleImageAnalysis(imageData, telegramImageUrl, userMessage || \"Describe this image in detail.\");\n for (const chunk of splitTelegramMessage(result)) await ctx.reply(chunk);\n } catch (err) {\n console.error(\"Vision API error:\", err);\n await ctx.reply(\"Sorry, I couldn't analyze that image right now.\");\n }\n return;\n }\n\n // ── Text message → reply + auto-generated visual companion ──────────────────\n if (userMessage) {\n console.log(`Text request from ${ctx.from?.id}: ${userMessage}`);\n try {\n await ctx.replyWithChatAction(\"typing\");\n\n // 1. Get text response\n let response = await processTextWithOpenRouter(userMessage);\n if (!response) {\n console.log(\"Falling back to Poe text model...\");\n response = (await callPoeBot(TEXT_FALLBACK_POE_MODEL, userMessage)).text || null;\n }\n if (!response) { await ctx.reply(\"Sorry, I couldn't generate a reply.\"); return; }\n\n // 2. Send text reply first\n for (const chunk of splitTelegramMessage(response)) await ctx.reply(chunk);\n\n // 3. Optionally attach a relevant Pollinations image (free, no key)\n if (wantsVisualCompanion(userMessage)) {\n try {\n await ctx.replyWithChatAction(\"upload_photo\");\n // Extract a visual keyword summarising the exchange\n const keyword = extractVisualKeyword(userMessage);\n const image = await generateImageWithPollinationsFallback(keyword);\n if (image) {\n await ctx.replyWithPhoto(new InputFile(image.data, image.name), {\n caption: `🖼 Visual: ${keyword}`,\n });\n }\n } catch (imgErr) {\n // Non-fatal — image companion is best-effort\n console.warn(\"Visual companion failed (non-fatal):\", imgErr);\n }\n }\n } catch (err) {\n console.error(\"Text processing error:\", err);\n await ctx.reply(\"Sorry, something went wrong while processing your message.\");\n }\n return;\n }\n\n console.log(`Unsupported message type from ${ctx.from?.id}. Ignored.`);\n});\n\n// ─── Webhook setup ────────────────────────────────────────────────────────────\nconst SECRET_TOKEN = telegramToken.split(\":\")[1];\nconst handleUpdate = webhookCallback(bot, \"std/http\", undefined, undefined, SECRET_TOKEN);\nlet webhookConfiguredFor: string | null = null;\n\nfunction looksLikePublicWebhookUrl(urlString: string): boolean {\n try {\n const url = new URL(urlString);\n return url.protocol === \"https:\" &&\n (url.hostname.endsWith(\".web.val.run\") || url.hostname.endsWith(\".val.run\"));\n } catch { return false; }\n}\n\nasync function ensureWebhook(req: Request): Promise {\n const candidate = publicWebhookUrl || (looksLikePublicWebhookUrl(req.url) ? req.url : null);\n if (!candidate) { console.log(\"Skipping setWebhook:\", req.url); return; }\n if (webhookConfiguredFor === candidate) return;\n await bot.api.setWebhook(candidate, { secret_token: SECRET_TOKEN, drop_pending_updates: false });\n webhookConfiguredFor = candidate;\n console.log(`Webhook configured for ${candidate}`);\n}\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 try { return await handleUpdate(req); }\n catch (err) { console.error(\"Error handling update:\", err); return new Response(\"OK\", { status: 200 }); }\n }\n return new Response(\n [\"✅ Telegram bot is running.\",\n publicWebhookUrl\n ? `Using PUBLIC_WEBHOOK_URL: ${publicWebhookUrl}`\n : \"Tip: set PUBLIC_WEBHOOK_URL to your real *.web.val.run or custom val.run endpoint.\"].join(\"\\n\"),\n { status: 200, headers: { \"content-type\": \"text/plain; charset=utf-8\" } },\n );\n};","deleted","label",[103],"permalink","https://www.val.town/x/aibotcommander/Poe-Telegram/code/main.tsx","extension","actionData","errors"]