[{"_1":2,"_180":-5,"_181":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":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","isTeamOrgMember","ENV",{"_38":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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","a69f784cf38fcbd34e6fd976b04c7e81f8ef261c","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","API_URL","https://api.val.town","clerkState",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":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",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_160":161,"_177":178,"_179":-5},"handle","RobooHood","name","Telegram-Image-Analyser-02","path","main.tsx","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":112,"_113":114,"_12":115,"_116":117,"_118":119,"_120":119,"_121":-5,"_122":33,"_14":123,"_124":125,"_126":127,"_128":-5,"_129":130,"_131":130,"_132":133,"_134":133,"_135":133,"_136":130,"_137":130,"_23":138,"_141":142,"_146":147,"_159":20},"id","5d68c5ae-b8d9-11f0-9b3c-0224a6c84d84","createdAt",["D",1762190416294],"deletedAt","legacyEnvVars","privacy","public","description","Telegram current","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/873d914f-8b69-4188-e3fa-5f43852da200/square512","25a33e90-1def-11f0-8458-d7daa68fe194","pinnedFileId","019a4abb-d9e3-74ba-9cb7-9be988d2f8d6","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","e54478ee-7c91-4914-a560-525ba174a661","tursoName","5d68c5aeb8d911f09b3c0224a6c84d84","tursoHostname","5d68c5aeb8d911f09b3c0224a6c84d84-val-town.aws-us-east-2.turso.io","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_139":140},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/dea1728e-0705-4aeb-d340-76cf90896100/square512","org",{"_95":96,"_143":140,"_12":115,"_144":145},"avatar","tier","free","branch",{"_148":149,"_97":45,"_103":150,"_151":104,"_152":-5,"_153":-5,"_154":-5,"_155":-5,"_156":-5,"_157":98,"_158":96},"version",38,"5d6e654a-b8d9-11f0-9b3c-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":162,"_97":100,"_163":117,"_164":-5,"_165":150,"_166":149,"_167":119,"_105":168,"_148":169,"_170":171,"_172":173,"_174":20,"_175":-5,"_99":176},"5d5d500a-1b73-11f1-af0e-42dde27851f2","fileId","parentId","branchId","branchVersion","latest",["D",1773031772665],36,"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\nconst VIDEO_GENERATION_MODELS = [\"Wan-2.6-N\", \"Wan-2.6\"];\n\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];\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;\n\n/** Hard ceiling Telegram accepts via Bot API */\nconst MAX_VIDEO_BYTES = 45 * 1024 * 1024;\n/** Encode slightly under the limit so overshoot is safe */\nconst TARGET_VIDEO_MB = 43;\n\nconst bot = new Bot(telegramToken);\n\ntype PoeAttachment = { url: string; content_type?: string; name?: string };\ntype PoeResult = { text: string; attachments: PoeAttachment[] };\n\n// ---------------------------------------------------------------------------\n// FFmpeg helpers\n// ---------------------------------------------------------------------------\n\n/** Returns the duration in seconds of a video file, or null on failure. */\nasync function probeVideoDuration(filePath: string): Promise {\n try {\n const cmd = new Deno.Command(\"ffprobe\", {\n args: [\n \"-v\", \"error\",\n \"-show_entries\", \"format=duration\",\n \"-of\", \"default=noprint_wrappers=1:nokey=1\",\n filePath,\n ],\n stdout: \"piped\",\n 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 {\n return null;\n }\n}\n\n/**\n * Re-encodes `inputPath` → `outputPath` targeting TARGET_VIDEO_MB.\n *\n * Uses two-pass CBR when duration is known, falls back to CRF 28 otherwise.\n */\nasync function compressVideoForTelegram(inputPath: string, outputPath: string): Promise {\n const duration = await probeVideoDuration(inputPath);\n const audioBitrateKbps = 128;\n\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\n // Pass 1 — analysis only, no output file\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) {\n console.warn(\"FFmpeg pass 1 stderr:\", new TextDecoder().decode(r1.stderr).slice(-300));\n }\n\n // Pass 2 — actual encode\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) {\n throw new Error(\"FFmpeg pass 2 failed: \" + new TextDecoder().decode(r2.stderr).slice(-500));\n }\n } else {\n // Fallback: CRF mode\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) {\n throw new Error(\"FFmpeg CRF encode failed: \" + new TextDecoder().decode(stderr).slice(-500));\n }\n }\n}\n\n// ---------------------------------------------------------------------------\n// Shared utils\n// ---------------------------------------------------------------------------\n\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\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\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\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\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\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\n const decoder = new TextDecoder();\n let buffer = \"\", resultText = \"\";\n const attachments: PoeAttachment[] = [];\n const seenUrls = new Set();\n\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 {\n clearTimeout(timer);\n }\n}\n\n// ---------------------------------------------------------------------------\n// Image generation — Pollinations.ai (free, no API key)\n// ---------------------------------------------------------------------------\n\n/** Returns true if the bytes start with a known image magic signature. */\nfunction isImageBytes(data: Uint8Array): boolean {\n if (data.length < 4) return false;\n // JPEG: FF D8 FF\n if (data[0] === 0xFF && data[1] === 0xD8 && data[2] === 0xFF) return true;\n // PNG: 89 50 4E 47\n if (data[0] === 0x89 && data[1] === 0x50 && data[2] === 0x4E && data[3] === 0x47) return true;\n // WebP: RIFF....WEBP\n if (data[0] === 0x52 && data[1] === 0x49 && data[2] === 0x46 && data[3] === 0x46) return true;\n // GIF: GIF8\n if (data[0] === 0x47 && data[1] === 0x49 && data[2] === 0x46) return true;\n return false;\n}\n\nasync function generateImageWithPollinations(\n prompt: string,\n): Promise<{ data: Uint8Array; name: string } | null> {\n try {\n const seed = Math.floor(Math.random() * 1_000_000);\n const url =\n `https://image.pollinations.ai/prompt/${encodeURIComponent(prompt)}` +\n `?model=flux&width=1024&height=1024&nologo=true&seed=${seed}`;\n console.log(\"Requesting Pollinations image:\", url);\n\n const res = await fetch(url);\n if (!res.ok) {\n console.error(\"Pollinations fetch failed:\", res.status, res.statusText);\n return null;\n }\n\n const ct = res.headers.get(\"content-type\") ?? \"\";\n console.log(\"Pollinations content-type:\", ct);\n\n const data = new Uint8Array(await res.arrayBuffer());\n console.log(`Pollinations response size: ${data.byteLength} bytes`);\n\n // Validate actual bytes — content-type alone can lie (e.g. error HTML pages)\n if (!isImageBytes(data)) {\n const preview = new TextDecoder().decode(data.slice(0, 200));\n console.error(\"Pollinations returned non-image bytes. Preview:\", preview);\n return null;\n }\n\n // Determine extension from magic bytes\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:\", err);\n return null;\n }\n}\n\n// ---------------------------------------------------------------------------\n// Video generation — Poe + automatic FFmpeg compression\n// ---------------------------------------------------------------------------\n\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\n const videoAtt =\n result.attachments.find(a => getAttachmentKind(a.content_type) === \"video\")\n ?? result.attachments[0];\n if (!videoAtt) { console.warn(`No attachment from ${model}`); continue; }\n\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\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\n // Already within limit — send as-is\n if (rawBytes.byteLength <= MAX_VIDEO_BYTES) {\n return { data: rawBytes, name: videoAtt.name || \"wan-video.mp4\" };\n }\n\n // Needs compression\n console.log(`Video is ${rawMB} MB — compressing with FFmpeg to fit under 45 MB…`);\n inputPath = await Deno.makeTempFile({ suffix: \".mp4\" });\n outputPath = await Deno.makeTempFile({ suffix: \"_out.mp4\" });\n\n await Deno.writeFile(inputPath, rawBytes);\n await compressVideoForTelegram(inputPath, outputPath);\n\n const compressed = await Deno.readFile(outputPath);\n const compressedMB = (compressed.byteLength / 1024 / 1024).toFixed(1);\n console.log(`Compressed size: ${compressedMB} MB`);\n\n if (compressed.byteLength > MAX_VIDEO_BYTES) {\n console.warn(`Still ${compressedMB} MB after compression — trying next model`);\n continue;\n }\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 // clean up two-pass log files ffmpeg creates in the working dir\n for (const f of [\"ffmpeg2pass-0.log\", \"ffmpeg2pass-0.log.mbtree\"]) {\n Deno.remove(f).catch(() => {});\n }\n }\n }\n return null;\n}\n\n// ---------------------------------------------------------------------------\n// Vision / text helpers\n// ---------------------------------------------------------------------------\n\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) { console.error(\"Poe vision fallback failed:\", err); return null; }\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// ---------------------------------------------------------------------------\n// Bot handlers\n// ---------------------------------------------------------------------------\n\nbot.command(\"start\", async (ctx) => { await ctx.reply(\"✅ Bot is running.\"); });\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) {\n await ctx.reply(\"Sorry, I couldn't generate a video right now. Please try again later.\");\n return;\n }\n await ctx.replyWithVideo(new InputFile(video.data, video.name), {\n caption: \"🎬 Generated with Wan\",\n supports_streaming: true,\n });\n return;\n } catch (err) {\n console.error(\"Video generation error:\", err);\n await ctx.reply(\"Sorry, video generation failed. Please try again later.\");\n return;\n }\n }\n\n // ── 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 const image = await generateImageWithPollinations(userMessage);\n if (!image) {\n await ctx.reply(\"Sorry, I couldn't generate the image. Please try again later.\");\n return;\n }\n await ctx.replyWithPhoto(\n new InputFile(image.data, image.name),\n { caption: \"🎨 Generated image\" },\n );\n return;\n } catch (err) {\n console.error(\"Image generation error:\", err);\n await ctx.reply(\"Sorry, image generation failed. Please try again later.\");\n return;\n }\n }\n\n // ── Image 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 return;\n } catch (err) {\n console.error(\"Vision API error:\", err);\n await ctx.reply(\"Sorry, I couldn't analyze that image right now.\");\n return;\n }\n }\n\n // ── Text processing ───────────────────────────────────────────────────────\n if (userMessage) {\n console.log(`Text request from ${ctx.from?.id}: ${userMessage}`);\n try {\n await ctx.replyWithChatAction(\"typing\");\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 for (const chunk of splitTelegramMessage(response)) await ctx.reply(chunk);\n return;\n } catch (err) {\n console.error(\"Text processing error:\", err);\n await ctx.reply(\"Sorry, something went wrong while processing your message.\");\n return;\n }\n }\n\n console.log(`Unsupported message type from ${ctx.from?.id}. Ignored.`);\n});\n\n// ---------------------------------------------------------------------------\n// Webhook bootstrap\n// ---------------------------------------------------------------------------\n\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\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\n return new Response(\n [\"✅ Telegram bot is running.\",\n publicWebhookUrl ? `Using PUBLIC_WEBHOOK_URL: ${publicWebhookUrl}`\n : \"Tip: set PUBLIC_WEBHOOK_URL to your real *.web.val.run or custom val.run endpoint.\"]\n .join(\"\\n\"),\n { status: 200, headers: { \"content-type\": \"text/plain; charset=utf-8\" } },\n );\n};","deleted","label",[100],"permalink","https://www.val.town/x/RobooHood/Telegram-Image-Analyser-02/code/main.tsx","extension","actionData","errors"]