[{"_1":2,"_260":-5,"_261":-5},"loaderData",{"_3":4,"_96":97,"_237":238},"root",{"_5":6,"_37":38,"_69":70},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":22,"_29":22,"_30":22,"_31":-5,"_32":33,"_34":22,"_35":22,"_36":22},"auth",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"tokenType","session_token","sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"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":22,"_80":77,"_81":77,"_82":77,"_83":77,"_84":85,"_94":22,"_95":22},"__clerk_ssr_state",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_86":22,"_21":22,"_87":77,"_88":89,"_90":77,"_91":48,"_92":22,"_93":77},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_98":99,"_100":101,"_102":-7,"_103":77,"_104":-7,"_105":106,"_165":166,"_197":198,"_199":200,"_212":213,"_179":-5,"_220":221,"_225":226,"_233":22,"_234":22,"_235":236},"handle","aibotcommander","name","Telegram-Image-Analyser-01","branchName","path","version","project",{"_107":108,"_100":101,"_109":110,"_111":-5,"_112":22,"_113":114,"_115":116,"_117":118,"_14":119,"_120":121,"_122":123,"_124":-5,"_125":-5,"_126":33,"_16":127,"_128":-5,"_129":-5,"_130":-5,"_131":-5,"_132":133,"_134":133,"_135":136,"_137":136,"_138":136,"_139":133,"_140":133,"_23":141,"_144":145,"_149":150,"_164":22},"id","6ea09972-2f27-11f1-9f83-42dde27851f2","createdAt",["D",1775198183130],"deletedAt","legacyEnvVars","privacy","public","description","Use it for free: https://t.me/chatgptimagecreator","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/6fd148a1-57c2-4852-649d-ed2d16434300/square512","01993890-bc39-742c-bff5-53031d93b2cb","pinnedFileId","019d520e-9f1b-728b-a9b9-38ecc3e28772","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,"_142":143},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/f13fd113-3e60-49cc-d2e1-6a7320ddbd00/square512","org",{"_98":99,"_146":143,"_14":119,"_147":148},"avatar","tier","free","branch",{"_104":151,"_100":46,"_107":152,"_153":108,"_154":155,"_156":157,"_158":114,"_159":160,"_161":127,"_162":101,"_163":99},7,"6ea71a40-2f27-11f1-9f83-42dde27851f2","projectId","forkedBranchId","0d275bb8-b8da-11f0-a285-0224a6c84d84","forkedBranchVersion",11,"forkedProjectPrivacy","forkedProjectId","0d2256cc-b8da-11f0-a285-0224a6c84d84","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[167,187],{"_107":168,"_100":169,"_170":171,"_172":-5,"_173":152,"_174":151,"_175":123,"_109":176,"_104":177,"_178":179,"_180":181,"_182":22,"_183":-5,"_184":185,"_103":186},"30a906f4-37f6-11f1-96d0-42b51c65c3df","README.md","fileId","019d520e-9f1b-728b-a9b9-379b5e95c7ee","parentId","branchId","branchVersion","latest",["D",1776166594291],1,"fileType","file","content","Looking at the code, I can see several issues that would prevent image generation from working:\n\n1. **`replace_response` events are appended instead of replacing** — Poe sends these to reset the text, but the code accumulates them, potentially doubling content or mishandling state.\n2. **Poe CDN URLs (`pfst.cf2.poecdn.net`) are tried with the Poe API bearer token first** — CDN signed URLs don't use bearer auth; sending that header may cause rejections.\n3. **The first attachment loop skips anything without `content_type`** — URLs extracted from markdown never have one, so they only reach the second loop after all typed attachments fail.\n4. **`extractAllUrls` trailing-char stripping can corrupt signed URL query params** (e.g. `=` in base64 signatures).\n\nHere's the fixed file:Here's a summary of every fix made:\n\n**1. `replace_response` events now actually replace text**\nThe old code did `resultText += parsed.text` for *every* SSE event, including `replace_response` (which is supposed to reset the whole message). This was tracked separately — `replaceText` wins over `incrementalText` when building the final string. This is critical because Poe image bots usually emit one `replace_response` containing the final markdown image link.\n\n**2. No bearer token sent to Poe CDN URLs**\n`pfst.cf2.poecdn.net` URLs are pre-signed — the auth is baked into the query string. Sending `Authorization: Bearer ` to the CDN can cause the request to be rejected or return unexpected content. The new `downloadUrl()` only adds the bearer token for `api.poe.com` requests.\n\n**3. CRLF-safe SSE parsing**\nAdded `buffer.replace(/\\r\\n/g, \"\\n\")` before boundary detection, so the parser works regardless of whether Poe uses LF or CRLF line endings.\n\n**4. URL extraction no longer strips `=` signs**\nThe old trailing-char strip removed `=` and `.`, which can corrupt base64-encoded query parameters in signed CDN URLs. The new `extractBareUrls()` only strips terminal punctuation that genuinely can't be part of a URL (`,`, `;`, `!`, `?`, `.`).\n\n**5. Four-pass image search with a dedicated poecdn scan**\nPass 1 → typed content-type attachments. Pass 2 → base64 data URIs. Pass 3 → all remaining URLs by magic-byte check. Pass 4 → regex scan of the full response text specifically for `pfst.cf2.poecdn.net` URLs, as a final safety net.","deleted","label","children",[],[169],{"_107":188,"_100":189,"_170":121,"_172":-5,"_173":152,"_174":190,"_175":123,"_109":191,"_104":192,"_178":193,"_180":194,"_182":22,"_183":-5,"_184":195,"_103":196},"087b7ef2-37f4-11f1-9661-42b51c65c3df","main.tsx",6,["D",1776165667891],5,"http","import { Bot, InputFile } 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 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 bot = new Bot(telegramToken);\nawait bot.init();\n\nconst POE_IMAGE_BOT_PRIMARY = \"Flux-1-Schnell-FW\";\nconst POE_IMAGE_BOT_FALLBACK = \"Flux-schnell-DI\";\nconst POE_VISION_PRIMARY = \"Gemma-4-31B\";\nconst POE_VISION_FALLBACK = \"Gemini-2.5-Flash-Lite\";\nconst POE_BOT_BASE_URL = \"https://api.poe.com/bot/\";\n\nconst POE_MAX_RETRIES = 3;\nconst POE_RETRY_BASE_DELAY_MS = 8_000;\n\ninterface PoeAttachment {\n url: string;\n content_type?: string;\n name?: string;\n}\n\ninterface PoeResponse {\n text: string;\n attachments: PoeAttachment[];\n}\n\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 () => {\n active = false;\n };\n}\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; // JPEG\n if (\n data[0] === 0x89 && data[1] === 0x50 && data[2] === 0x4E && data[3] === 0x47\n ) return true; // PNG\n if (\n data[0] === 0x52 && data[1] === 0x49 && data[2] === 0x46 && data[3] === 0x46\n ) return true; // WEBP (RIFF)\n if (data[0] === 0x47 && data[1] === 0x49 && data[2] === 0x46) return true; // GIF\n return false;\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 }\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(\n `https://api.telegram.org/file/bot${telegramToken}/${file.file_path}`,\n );\n if (!res.ok) throw new Error(`Failed to download Telegram file: ${res.status}`);\n return new Uint8Array(await res.arrayBuffer());\n}\n\n// FIX 1: Pass poeApiKey as optional auth header for Poe CDN URLs\nasync function downloadUrl(\n url: string,\n usePoeAuth = false,\n): Promise {\n try {\n const headers: Record = {};\n if (usePoeAuth) {\n headers[\"Authorization\"] = `Bearer ${poeApiKey}`;\n }\n const res = await fetch(url, { headers });\n if (!res.ok) {\n console.warn(`downloadUrl failed: ${res.status} for ${url.slice(0, 100)}`);\n return null;\n }\n return new Uint8Array(await res.arrayBuffer());\n } catch (err) {\n console.error(`Failed to download ${url}:`, err);\n return null;\n }\n}\n\n// FIX 2: More robust URL extraction — avoid truncating CDN URLs with query params\nfunction extractMarkdownUrls(text: string): string[] {\n return [...text.matchAll(/!\\[.*?\\]\\((https?:\\/\\/[^)\\s]+)\\)/g)].map((m) => m[1]);\n}\n\nfunction extractAllUrls(text: string): string[] {\n // Capture full URLs including query strings; only strip trailing punctuation\n return [...text.matchAll(/https?:\\/\\/[^\\s\"'<>\\]]+/gi)]\n .map((m) => m[0].replace(/[)>\\]\"',.:;!?]+$/, \"\"))\n .filter((url) => {\n try {\n new URL(url);\n return true;\n } catch {\n return false;\n }\n });\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\n// FIX 3: Normalise a wider set of field names Poe might return\nfunction normalizeAttachment(value: unknown): PoeAttachment | null {\n if (!value || typeof value !== \"object\") return null;\n const v = value as Record;\n const url =\n typeof v.url === \"string\"\n ? v.url\n : typeof v.attachment_url === \"string\"\n ? v.attachment_url\n : typeof v.download_url === \"string\" // ← NEW\n ? v.download_url\n : typeof v.image_url === \"string\" // ← NEW\n ? v.image_url\n : typeof v.file_url === \"string\" // ← NEW\n ? v.file_url\n : null;\n if (!url) return null;\n return {\n url,\n content_type:\n typeof v.content_type === \"string\"\n ? v.content_type\n : typeof v.mime_type === \"string\"\n ? v.mime_type\n : undefined,\n name: typeof v.name === \"string\" ? v.name : undefined,\n };\n}\n\nasync function callPoeBot(\n botName: string,\n message: string,\n attachments?: PoeAttachment[],\n timeoutMs = 120_000,\n): Promise {\n let lastError: Error | null = null;\n\n for (let attempt = 0; attempt <= POE_MAX_RETRIES; attempt++) {\n if (attempt > 0) {\n const delay = POE_RETRY_BASE_DELAY_MS * Math.pow(2, attempt - 1);\n console.warn(\n `Poe (${botName}) retry ${attempt}/${POE_MAX_RETRIES} after ${delay}ms…`,\n );\n await new Promise((r) => setTimeout(r, delay));\n }\n\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(\"Poe timeout\"), timeoutMs);\n\n try {\n const res = await fetch(\n `${POE_BOT_BASE_URL}${encodeURIComponent(botName)}`,\n {\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: [{\n role: \"user\",\n content: message,\n ...(attachments?.length ? { attachments } : {}),\n }],\n }),\n signal: controller.signal,\n },\n );\n\n if (!res.ok) {\n const body = await res.text().catch(() => \"\");\n const err = new Error(`Poe error: ${res.status} ${body}`);\n if (res.status >= 500 && attempt < POE_MAX_RETRIES) {\n console.warn(\n `Poe (${botName}) 5xx on attempt ${attempt + 1}: ${res.status}`,\n );\n lastError = err;\n continue;\n }\n throw err;\n }\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 const responseAttachments: PoeAttachment[] = [];\n let buffer = \"\", resultText = \"\";\n\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n buffer += decoder.decode(value, { stream: true });\n\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\n const eventLine = rawEvent.split(\"\\n\").find((l) =>\n l.startsWith(\"event:\")\n );\n const eventType = eventLine ? eventLine.slice(6).trim() : \"\";\n const dataText = rawEvent\n .split(\"\\n\")\n .filter((l) => l.startsWith(\"data:\"))\n .map((l) => l.slice(5).trim())\n .join(\"\\n\");\n\n if (!dataText || dataText === \"[DONE]\") continue;\n\n try {\n const parsed = JSON.parse(dataText);\n\n if (typeof parsed.text === \"string\") resultText += parsed.text;\n\n // FIX 4: Also handle \"text_chunk\" event type used by some Poe bots\n if (\n eventType === \"file_attachment\" ||\n eventType === \"attachment\" || // ← NEW\n parsed.type === \"file_attachment\" ||\n parsed.type === \"file\" || // ← NEW\n parsed.type === \"attachment\"\n ) {\n const att = normalizeAttachment(parsed);\n if (att) {\n console.log(`Poe attachment event: ${att.url.slice(0, 100)} [${att.content_type ?? \"?\"}]`);\n responseAttachments.push(att);\n }\n }\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\n // FIX 5: Also check top-level url/image_url fields on any event\n if (typeof parsed.url === \"string\" && !parsed.text) {\n const att = normalizeAttachment(parsed);\n if (att && !responseAttachments.some((a) => a.url === att.url)) {\n responseAttachments.push(att);\n }\n }\n } catch { /* ignore parse errors in SSE frames */ }\n }\n }\n\n // Extract URLs from text as fallback\n for (\n const url of [\n ...extractMarkdownUrls(resultText),\n ...extractAllUrls(resultText),\n ]\n ) {\n if (!responseAttachments.some((a) => a.url === url)) {\n responseAttachments.push({ url });\n }\n }\n\n return { text: resultText.trim(), attachments: responseAttachments };\n } catch (err) {\n if ((err as Error)?.name === \"AbortError\") throw err;\n if (lastError !== err) throw err;\n } finally {\n clearTimeout(timer);\n }\n }\n\n throw lastError ?? new Error(`Poe (${botName}) failed after ${POE_MAX_RETRIES} retries`);\n}\n\nasync function generateImageWithBot(\n botName: string,\n prompt: string,\n): Promise<{ data: Uint8Array; ext: string } | null> {\n console.log(`Generating image with Poe (${botName})…`);\n try {\n const { text, attachments } = await callPoeBot(botName, prompt, undefined, 120_000);\n console.log(`POE (${botName}) text preview: ${text.slice(0, 300)}`);\n console.log(\n `POE (${botName}) attachments (${attachments.length}):`,\n attachments.map((a) => `${a.url.slice(0, 120)} [${a.content_type ?? \"?\"}]`),\n );\n\n // Pass 1: typed attachments with image content-type\n for (const att of attachments) {\n if (!att.content_type?.startsWith(\"image/\")) continue;\n // FIX 6: Try with Poe auth first for CDN URLs, then without\n let data = await downloadUrl(att.url, true);\n if (!data || !isImageBytes(data)) data = await downloadUrl(att.url, false);\n if (data && isImageBytes(data)) {\n const ext = att.content_type === \"image/png\" ? \".png\" : \".jpg\";\n console.log(`POE image ✓ (${botName}) typed attachment (${data.length} bytes)`);\n return { data, ext };\n }\n }\n\n // Pass 2: all attachment URLs, check magic bytes\n const seen = new Set();\n for (const att of attachments) {\n if (seen.has(att.url)) continue;\n seen.add(att.url);\n if (att.url.startsWith(\"data:\")) {\n // FIX 7: Handle inline base64 data URIs from Poe\n const match = att.url.match(/^data:(image\\/[a-z+]+);base64,(.+)$/);\n if (match) {\n try {\n const bytes = Uint8Array.from(atob(match[2]), (c) => c.charCodeAt(0));\n if (isImageBytes(bytes)) {\n const ext = match[1] === \"image/png\" ? \".png\" : \".jpg\";\n console.log(`POE image ✓ (${botName}) base64 data URI (${bytes.length} bytes)`);\n return { data: bytes, ext };\n }\n } catch { /* ignore malformed base64 */ }\n }\n continue;\n }\n let data = await downloadUrl(att.url, true);\n if (!data || !isImageBytes(data)) data = await downloadUrl(att.url, false);\n if (data && isImageBytes(data)) {\n const ext = data[0] === 0x89 ? \".png\" : \".jpg\";\n console.log(\n `POE image ✓ (${botName}) magic-byte match ${att.url.slice(0, 80)} (${data.length} bytes)`,\n );\n return { data, ext };\n }\n }\n\n console.warn(`POE (${botName}) — no usable image found. Full text: ${text.slice(0, 500)}`);\n return null;\n } catch (err) {\n console.error(`POE image generation error (${botName}):`, err);\n return null;\n }\n}\n\nasync function generateImage(\n prompt: string,\n): Promise<{ data: Uint8Array; ext: string } | null> {\n const primary = await generateImageWithBot(POE_IMAGE_BOT_PRIMARY, prompt);\n if (primary) return primary;\n console.warn(\n `${POE_IMAGE_BOT_PRIMARY} failed — falling back to ${POE_IMAGE_BOT_FALLBACK}`,\n );\n return await generateImageWithBot(POE_IMAGE_BOT_FALLBACK, prompt);\n}\n\nasync function analyzeImageWithPoeBot(\n botName: string,\n imageData: Uint8Array,\n prompt: string,\n): Promise {\n console.log(`Analysing image with Poe (${botName})…`);\n try {\n const base64 = uint8ToBase64(imageData);\n const mimeType = imageData[0] === 0x89 ? \"image/png\" : \"image/jpeg\";\n const dataUri = `data:${mimeType};base64,${base64}`;\n const attachment: PoeAttachment = {\n url: dataUri,\n content_type: mimeType,\n name: \"uploaded_image\",\n };\n const { text } = await callPoeBot(\n botName,\n prompt || \"Describe this image in detail.\",\n [attachment],\n 120_000,\n );\n if (text && text.trim().length > 0) {\n console.log(`POE vision ✓ (${botName})`);\n return text.trim();\n }\n return null;\n } catch (err) {\n console.error(`Poe vision error (${botName}):`, err);\n return null;\n }\n}\n\nasync function analyzeImage(imageData: Uint8Array, prompt: string): Promise {\n const primary = await analyzeImageWithPoeBot(POE_VISION_PRIMARY, imageData, prompt);\n if (primary) return primary;\n console.warn(\n `${POE_VISION_PRIMARY} failed — falling back to ${POE_VISION_FALLBACK}`,\n );\n const fallback = await analyzeImageWithPoeBot(\n POE_VISION_FALLBACK,\n imageData,\n prompt,\n );\n if (fallback) return fallback;\n throw new Error(\"Both vision bots failed to analyse the image.\");\n}\n\nbot.command(\"start\", (ctx) =>\n ctx.reply(\n \"👋 *Welcome!* Here's what I can do:\\n\\n\" +\n \"🎨 *Generate images* — send me any text prompt and I'll create an image\\n\" +\n \"🔍 *Analyse images* — send me a photo (with an optional caption)\",\n { parse_mode: \"Markdown\" },\n )\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\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 analyzeImage(\n imageData,\n userMessage || \"Describe this image in detail.\",\n );\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(\n \"Sorry, I couldn't analyse that image right now. Please try again.\",\n );\n }\n return;\n }\n\n if (userMessage) {\n console.log(`Image generation from ${ctx.from?.id}: ${userMessage}`);\n const status = await ctx.reply(\n \"🎨 Generating your image… this may take a moment.\",\n );\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\n if (!result) {\n await ctx.reply(\n \"Sorry, image generation failed right now. Please try again later.\",\n );\n return;\n }\n\n // FIX 8: Wrap Uint8Array in a Blob — more reliable across runtimes than raw Uint8Array\n const mimeType = result.ext === \".png\" ? \"image/png\" : \"image/jpeg\";\n const blob = new Blob([result.data], { type: mimeType });\n\n await ctx.replyWithPhoto(\n new InputFile(blob, `generated${result.ext}`),\n { caption: \"🎨 Here's your generated image!\" },\n );\n return;\n }\n});\n\nconst SECRET_TOKEN = telegramToken.split(\":\")[1];\nlet webhookConfiguredFor: string | null = null;\n\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 {\n return false;\n }\n}\n\nasync function ensureWebhook(req: Request): Promise {\n const candidate = publicWebhookUrl ||\n (looksLikeValRunUrl(req.url) ? req.url : null);\n if (!candidate || webhookConfiguredFor === candidate) return;\n await bot.api.setWebhook(candidate, {\n secret_token: SECRET_TOKEN,\n drop_pending_updates: false,\n });\n webhookConfiguredFor = candidate;\n console.log(`Webhook set: ${candidate}`);\n}\n\nexport default async (req: Request): Promise => {\n try {\n await ensureWebhook(req);\n } catch (err) {\n console.error(\"ensureWebhook failed:\", err);\n }\n\n if (req.method === \"POST\") {\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\n let update: unknown;\n try {\n update = await req.json();\n } catch {\n return new Response(\"Bad Request\", { status: 400 });\n }\n\n bot.handleUpdate(update as Parameters[0]).catch(\n (err) => {\n console.error(\"handleUpdate error:\", err);\n },\n );\n return new Response(\"OK\", { status: 200 });\n }\n\n return new Response(\n `✅ Image bot is running.\\nWebhook: ${publicWebhookUrl ?? \"not configured\"}`,\n { status: 200, headers: { \"content-type\": \"text/plain; charset=utf-8\" } },\n );\n};",[],[189],"files",[167,187],"counts",{"_201":33,"_202":177,"_203":33,"_204":205,"_209":210},"pulls","branches","forks","envVars",{"_206":207,"_208":33},"count",4,"emptyCount","connections",{"_206":33,"_211":33},"unfilledCount","contents",[214,217],{"_107":168,"_100":169,"_170":171,"_172":-5,"_173":152,"_174":151,"_175":123,"_109":215,"_104":177,"_178":179,"_180":181,"_182":22,"_183":-5,"_103":216},["D",1776166594291],[169],{"_107":188,"_100":189,"_170":121,"_172":-5,"_173":152,"_174":190,"_175":123,"_109":218,"_104":192,"_178":193,"_180":194,"_182":22,"_183":-5,"_103":219},["D",1776165667891],[189],"upstreamProject",{"_107":160,"_100":222,"_115":116,"_117":223,"_113":114,"_23":224},"Telegram-Image-Analyser","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/29716895-4a8a-483c-5c16-e37948b63500/square512",{"_98":99,"_142":143},"upstreamBranch",{"_107":155,"_109":227,"_228":229,"_100":46,"_153":160,"_104":230,"_154":-5,"_156":-5,"_231":232,"_111":-5,"_164":22,"_113":114,"_163":99,"_16":127,"_162":222},["D",1762190711085],"updatedAt",["D",1776166572472],22,"lockfileKey","1776171509449-esm.town_v_aibotcommander_Telegram-Image-Analyser@22-main","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.environment-variables",{"_98":99,"_100":101,"_105":239,"_204":244,"_259":22},{"_107":108,"_100":101,"_109":240,"_111":-5,"_112":22,"_113":114,"_115":116,"_117":118,"_14":119,"_120":121,"_122":123,"_124":-5,"_125":-5,"_126":33,"_16":127,"_128":-5,"_129":-5,"_130":-5,"_131":-5,"_132":133,"_134":133,"_135":136,"_137":136,"_138":136,"_139":133,"_140":133,"_23":241,"_144":242,"_149":243,"_164":22},["D",1775198183130],{"_98":99,"_142":143},{"_98":99,"_146":143,"_14":119,"_147":148},{"_104":151,"_100":46,"_107":152,"_153":108,"_154":155,"_156":157,"_158":114,"_159":160,"_161":127,"_162":101,"_163":99},[245,250,253,256],{"_246":247,"_109":248,"_228":-5,"_115":77,"_249":22},"key","BOT_KEY",["D",1775198183130],"isEmpty",{"_246":251,"_109":252,"_228":-5,"_115":77,"_249":22},"HF_API_KEY",["D",1775198183130],{"_246":254,"_109":255,"_228":-5,"_115":77,"_249":22},"PUBLIC_WEBHOOK_URL",["D",1775198183130],{"_246":257,"_109":258,"_228":-5,"_115":77,"_249":22},"TELEGRAM_TOKEN",["D",1775198183130],"isTeamOrg","actionData","errors"]

Key	Description
BOT_KEY
HF_API_KEY
PUBLIC_WEBHOOK_URL
TELEGRAM_TOKEN

aibotcommander

Telegram-Image-Analyser-01

Environment variables