[{"_1":2,"_178":-5,"_179":-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","59ec1ef0e18859058993800a2105674ef41eefe7","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,"_158":159,"_175":176,"_177":-5},"handle","aibotcommander","name","Free-Omni-Telegram","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":-5,"_121":-5,"_122":33,"_14":123,"_124":-5,"_125":-5,"_126":-5,"_127":128,"_129":128,"_130":131,"_132":131,"_133":131,"_134":128,"_135":128,"_23":136,"_139":140,"_144":145,"_157":20},"id","f7101d26-1985-11f1-a019-42dde27851f2","createdAt",["D",1772819858966],"deletedAt","legacyEnvVars","privacy","public","description","https://poe.com/Cheap-Omni","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/2b0f2606-6237-41c9-eeb1-6baae789bd00/square512","01993890-bc39-742c-bff5-53031d93b2cb","pinnedFileId","019cc44c-486c-7186-b345-45f2f8ca511c","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","01993890-bc39-742c-bff5-540390ef48e8","tursoName","tursoHostname","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_137":138},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/6223ecdc-40b4-4d83-ca44-9ce051c53800/square512","org",{"_95":96,"_141":138,"_12":115,"_142":143},"avatar","tier","free","branch",{"_146":147,"_97":45,"_103":148,"_149":104,"_150":-5,"_151":-5,"_152":-5,"_153":-5,"_154":-5,"_155":98,"_156":96},"version",10,"f7480b32-1985-11f1-a019-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":160,"_97":100,"_161":117,"_162":-5,"_163":148,"_164":147,"_165":119,"_105":166,"_146":167,"_168":169,"_170":171,"_172":20,"_173":-5,"_99":174},"87649f96-1ad0-11f1-991b-42dde27851f2","fileId","parentId","branchId","branchVersion","latest",["D",1772961835202],9,"fileType","http","content","import { Bot, InputFile, webhookCallback } from \"https://deno.land/x/grammy@v1.35.0/mod.ts\";\nif (!Deno.env.get(\"TELEGRAM_TOKEN\")) {\n throw new Error(\"TELEGRAM_TOKEN is not set\");\n}\nconst telegramToken = Deno.env.get(\"TELEGRAM_TOKEN\")!;\nconst nvidiaApiKey = Deno.env.get(\"NVIDIA_API_KEY\");\nconst openrouterApiKey = Deno.env.get(\"OPENROUTER_API_KEY\");\nconst openrouterApiKey2 = Deno.env.get(\"OPENROUTER_API_KEY2\");\nconst poeApiKey = Deno.env.get(\"POE_API_KEY\");\nconst bot = new Bot(telegramToken);\nconst NVIDIA_MODELS = [\n \"meta/llama-3.1-8b-instruct\",\n \"meta/llama-3.1-70b-instruct\",\n \"nvidia/llama-3.1-nemotron-70b-instruct\",\n \"mistralai/mistral-7b-instruct-v0.3\",\n] as const;\nconst NVIDIA_VISION_MODELS = [\n \"meta/llama-3.2-11b-vision-instruct\",\n \"meta/llama-3.2-90b-vision-instruct\",\n \"nvidia/vila\",\n] as const;\nconst OPENROUTER_MODELS = [\n \"meta-llama/llama-3.2-3b-instruct:free\",\n \"nousresearch/hermes-3-llama-3.1-405b:free\",\n \"arcee-ai/trinity-mini:free\",\n] as const;\nconst OPENROUTER_VISION_MODELS = [\n \"opengvlab/internvl3-2b:free\",\n \"meta-llama/llama-3.2-11b-vision-instruct:free\",\n] as const;\nconst POE_VISION_MODELS = [\n \"Gemini-3.1-Flash-lite\",\n \"Gemini-3.0-Flash\",\n] as const;\nconst POE_IMAGE_BOT = \"ImageResponseBotDemo\";\nconst POE_VIDEO_MODEL = \"Wan-2.6-N\";\nconst NVIDIA_DOCUMENT_MODELS = [\n \"nvidia/llama-3.1-nemotron-70b-instruct\",\n \"meta/llama-3.1-70b-instruct\",\n] as const;\nconst OPENROUTER_DOCUMENT_MODELS = [\n \"tngtech/deepseek-r1t2-chimera:free\",\n \"tngtech/deepseek-r1t-chimera:free\",\n] as const;\nconst DEFAULT_TIMEOUT_MS = 60_000;\nconst LONG_TIMEOUT_MS = 8 * 60 * 1000;\nconst VIDEO_TIMEOUT_MS = 12 * 60 * 1000;\nconst MAX_TELEGRAM_VIDEO_BYTES = 45 * 1024 * 1024;\ntype ChatMessage = {\n role: \"system\" | \"user\" | \"assistant\" | \"tool\";\n content: unknown;\n name?: string;\n tool_calls?: unknown[];\n tool_call_id?: string;\n};\ntype DownloadedTelegramFile = {\n data: Uint8Array;\n mimeType: string | null;\n};\ntype GrammyCtx = { chat?: { type: string } };\nfunction sleep(ms: number): Promise {\n return new Promise((resolve) => setTimeout(resolve, ms));\n}\nasync function fetchWithTimeout(\n input: string | URL | Request,\n init: RequestInit = {},\n timeoutMs = DEFAULT_TIMEOUT_MS,\n): Promise {\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(`Timeout after ${timeoutMs}ms`), timeoutMs);\n try {\n return await fetch(input, { ...init, signal: controller.signal });\n } finally {\n clearTimeout(timer);\n }\n}\nasync function fetchJsonWithRetry(\n url: string,\n init: RequestInit,\n options: {\n timeoutMs?: number;\n retries?: number;\n retryStatuses?: number[];\n } = {},\n): Promise {\n const timeoutMs = options.timeoutMs ?? DEFAULT_TIMEOUT_MS;\n const retries = options.retries ?? 3;\n const retryStatuses = options.retryStatuses ?? [429, 500, 502, 503, 504];\n let lastError: unknown;\n for (let attempt = 1; attempt <= retries; attempt++) {\n try {\n const response = await fetchWithTimeout(url, init, timeoutMs);\n if (response.ok) return response;\n if (!retryStatuses.includes(response.status) || attempt === retries) {\n return response;\n }\n const backoff = Math.min(1000 * 2 ** (attempt - 1), 10_000);\n console.warn(`Retrying ${url} after HTTP ${response.status}, attempt ${attempt}/${retries}`);\n await sleep(backoff);\n } catch (error) {\n lastError = error;\n if (attempt === retries) throw error;\n const backoff = Math.min(1000 * 2 ** (attempt - 1), 10_000);\n console.warn(`Retrying ${url} after error, attempt ${attempt}/${retries}`, error);\n await sleep(backoff);\n }\n }\n throw lastError instanceof Error ? lastError : new Error(\"Unknown fetch retry error\");\n}\nfunction uint8ArrayToBase64(bytes: Uint8Array): string {\n let binary = \"\";\n const chunkSize = 0x8000;\n for (let i = 0; i < bytes.length; i += chunkSize) {\n binary += String.fromCharCode(...bytes.subarray(i, i + chunkSize));\n }\n return btoa(binary);\n}\nfunction base64ToUint8Array(base64: string): Uint8Array {\n const binary = atob(base64);\n const out = new Uint8Array(binary.length);\n for (let i = 0; i < binary.length; i++) {\n out[i] = binary.charCodeAt(i);\n }\n return out;\n}\nfunction normalizeContentToText(value: unknown): string {\n if (typeof value === \"string\") return value;\n if (value == null) return \"\";\n if (Array.isArray(value)) {\n return value.map((v) => normalizeContentToText(v)).filter(Boolean).join(\"\\n\");\n }\n if (typeof value === \"object\") {\n const obj = value as Record;\n const preferredKeys = [\"text\", \"content\", \"url\", \"download_url\", \"message\", \"title\", \"description\"];\n const parts: string[] = [];\n for (const key of preferredKeys) {\n if (key in obj) {\n const text = normalizeContentToText(obj[key]);\n if (text) parts.push(text);\n }\n }\n for (const [key, val] of Object.entries(obj)) {\n if (preferredKeys.includes(key)) continue;\n const text = normalizeContentToText(val);\n if (text) parts.push(text);\n }\n return parts.join(\"\\n\");\n }\n return String(value);\n}\nfunction collectUrlsDeep(value: unknown, acc: string[] = []): string[] {\n if (typeof value === \"string\") {\n const matches = value.match(/https?:\\/\\/[^\\s\"'<>`)\\]]+/gi);\n if (matches) acc.push(...matches);\n return acc;\n }\n if (Array.isArray(value)) {\n for (const item of value) collectUrlsDeep(item, acc);\n return acc;\n }\n if (value && typeof value === \"object\") {\n for (const val of Object.values(value as Record)) {\n collectUrlsDeep(val, acc);\n }\n }\n return acc;\n}\nfunction extractUrlFromText(text: string): string | null {\n const mdMatch = text.match(/\\[.*?\\]\\((https?:\\/\\/[^\\s)]+)\\)/);\n if (mdMatch) return mdMatch[1];\n const extMatch = text.match(/(https?:\\/\\/[^\\s\"'<>]+\\.(mp4|webm|mov|avi|mkv|m4v)(\\?[^\\s\"'<>]*)?)/i);\n if (extMatch) return extMatch[1];\n const anyMatch = text.match(/(https?:\\/\\/[^\\s\"'<>)\\]]+)/);\n if (anyMatch) return anyMatch[1];\n return null;\n}\nfunction pickBestVideoUrl(value: unknown): string | null {\n const urls = collectUrlsDeep(value);\n const preferred = urls.find((u) => /\\.(mp4|webm|mov|avi|mkv|m4v)(\\?|$)/i.test(u));\n if (preferred) return preferred;\n const likelyVideo = urls.find((u) => /(video|mp4|webm|mov|avi|mkv|m4v|cdn|poecdn)/i.test(u));\n if (likelyVideo) return likelyVideo;\n const text = normalizeContentToText(value);\n return extractUrlFromText(text);\n}\nfunction pickBestImageUrl(value: unknown): string | null {\n const urls = collectUrlsDeep(value);\n const preferred = urls.find((u) => /\\.(png|jpg|jpeg|webp|gif)(\\?|$)/i.test(u));\n if (preferred) return preferred;\n const text = normalizeContentToText(value);\n const match = text.match(/(https?:\\/\\/[^\\s\"'<>]+\\.(png|jpg|jpeg|webp|gif)(\\?[^\\s\"'<>]*)?)/i);\n return match?.[1] ?? extractUrlFromText(text);\n}\nfunction guessVideoFilename(url: string, contentType: string | null): string {\n if (contentType?.includes(\"webm\")) return \"video.webm\";\n if (contentType?.includes(\"quicktime\") || contentType?.includes(\"mov\")) return \"video.mov\";\n const extMatch = url.match(/\\.(mp4|webm|mov|avi|mkv|m4v)(\\?|$)/i);\n if (extMatch) return `video.${extMatch[1].toLowerCase()}`;\n return \"video.mp4\";\n}\nfunction isGroupChat(ctx: GrammyCtx): boolean {\n return ctx.chat?.type === \"group\" || ctx.chat?.type === \"supergroup\";\n}\nfunction stripCommand(text: string, command: string): string {\n const regex = new RegExp(`^\\\\/${command}(?:@\\\\w+)?\\\\s*`, \"i\");\n return text.replace(regex, \"\").trim();\n}\nfunction isImageGenerationRequest(text: string): boolean {\n if (!text) return false;\n const lower = text.toLowerCase().trim();\n const keywords = [\n \"generate image\",\n \"gpt photo\",\n \"create image\",\n \"image of\",\n \"photo of\",\n \"draw\",\n \"illustrate\",\n \"/image\",\n \"--image\",\n ];\n return keywords.some((k) => lower.startsWith(k));\n}\nfunction isVideoGenerationRequest(text: string): boolean {\n if (!text) return false;\n return /\\bvideo\\b/i.test(text);\n}\nasync function startChatActionHeartbeat(\n ctx: any,\n action: \"typing\" | \"upload_photo\" | \"upload_video\",\n everyMs = 4000,\n): Promise<() => void> {\n let active = true;\n (async () => {\n while (active) {\n try { await ctx.replyWithChatAction(action); } catch { }\n await sleep(everyMs);\n }\n })();\n return () => { active = false; };\n}\n/**\n * Compress video bytes to under maxBytes using ffmpeg CBR two-pass-equivalent.\n * Probes duration with ffprobe to calculate target bitrate.\n * Outputs H.264/AAC MP4 with faststart for Telegram streaming compatibility.\n * Returns null if ffmpeg is unavailable or all compression attempts fail.\n */\nasync function compressVideo(\n inputBytes: Uint8Array,\n inputFilename: string,\n maxBytes = MAX_TELEGRAM_VIDEO_BYTES,\n): Promise {\n const tmpIn = await Deno.makeTempFile({ suffix: `_in_${inputFilename}` });\n const tmpOut = await Deno.makeTempFile({ suffix: \"_out.mp4\" });\n try {\n await Deno.writeFile(tmpIn, inputBytes);\n // Probe duration to derive CBR target\n let durationSec = 0;\n try {\n const probe = new Deno.Command(\"ffprobe\", {\n args: [\n \"-v\", \"error\",\n \"-show_entries\", \"format=duration\",\n \"-of\", \"default=noprint_wrappers=1:nokey=1\",\n tmpIn,\n ],\n stdout: \"piped\",\n stderr: \"piped\",\n });\n const probeResult = await probe.output();\n const probeText = new TextDecoder().decode(probeResult.stdout).trim();\n durationSec = parseFloat(probeText) || 0;\n } catch (e) {\n console.warn(\"ffprobe unavailable, using fallback bitrate:\", e);\n }\n // target_kbps = (maxBytes * 8 * 0.90) / duration_sec / 1000\n // 0.90 = 10% headroom for container overhead\n let targetKbps = 800;\n if (durationSec > 1) {\n targetKbps = Math.floor((maxBytes * 8 * 0.90) / durationSec / 1000);\n targetKbps = Math.max(targetKbps, 200);\n }\n const videoBitrateKbps = Math.floor(targetKbps * 0.88);\n const audioBitrateKbps = Math.min(Math.floor(targetKbps * 0.12), 128);\n console.log(\n `Compressing: ${(inputBytes.length / 1024 / 1024).toFixed(2)}MB, ` +\n `duration=${durationSec.toFixed(1)}s → ` +\n `v=${videoBitrateKbps}kbps a=${audioBitrateKbps}kbps`,\n );\n const ffmpeg = new Deno.Command(\"ffmpeg\", {\n args: [\n \"-y\",\n \"-i\", tmpIn,\n \"-c:v\", \"libx264\",\n \"-preset\", \"fast\",\n \"-b:v\", `${videoBitrateKbps}k`,\n \"-maxrate\", `${Math.floor(videoBitrateKbps * 1.5)}k`,\n \"-bufsize\", `${videoBitrateKbps * 2}k`,\n \"-c:a\", \"aac\",\n \"-b:a\", `${audioBitrateKbps}k`,\n \"-movflags\", \"+faststart\",\n \"-pix_fmt\", \"yuv420p\",\n tmpOut,\n ],\n stdout: \"piped\",\n stderr: \"piped\",\n });\n const result = await ffmpeg.output();\n if (!result.success) {\n const stderr = new TextDecoder().decode(result.stderr);\n console.error(\"ffmpeg failed:\", stderr.slice(-800));\n return null;\n }\n const compressed = await Deno.readFile(tmpOut);\n console.log(\n `Compression result: ${(inputBytes.length / 1024 / 1024).toFixed(2)}MB → ` +\n `${(compressed.length / 1024 / 1024).toFixed(2)}MB`,\n );\n return compressed;\n } catch (error) {\n console.error(\"compressVideo error:\", error);\n return null;\n } finally {\n try { await Deno.remove(tmpIn); } catch { }\n try { await Deno.remove(tmpOut); } catch { }\n }\n}\nasync function callPoeApi(\n model: string,\n messages: ChatMessage[],\n maxTokens = 1024,\n): Promise {\n if (!poeApiKey) return null;\n try {\n console.log(`Poe API attempt: ${model}`);\n const response = await fetchJsonWithRetry(\n \"https://api.poe.com/v1/chat/completions\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${poeApiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ model, messages, max_tokens: maxTokens, stream: false }),\n },\n { timeoutMs: LONG_TIMEOUT_MS, retries: 3 },\n );\n if (!response.ok) {\n const errorText = await response.text();\n console.error(`Poe ${model} failed: ${response.status} - ${errorText}`);\n return null;\n }\n const data = await response.json();\n const content = data?.choices?.[0]?.message?.content;\n const text = normalizeContentToText(content).trim();\n if (text) {\n console.log(`Poe success with ${model}`);\n return text;\n }\n return null;\n } catch (error) {\n console.error(`Poe ${model} error:`, error);\n return null;\n }\n}\nasync function generateVideoWithPoe(prompt: string): Promise {\n if (!poeApiKey) return null;\n try {\n console.log(`Poe video gen: ${POE_VIDEO_MODEL}`);\n const response = await fetchJsonWithRetry(\n \"https://api.poe.com/v1/chat/completions\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${poeApiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: POE_VIDEO_MODEL,\n messages: [{ role: \"user\", content: prompt }],\n max_tokens: 1024,\n stream: false,\n }),\n },\n { timeoutMs: VIDEO_TIMEOUT_MS, retries: 3 },\n );\n if (!response.ok) {\n const errorText = await response.text();\n console.error(`Poe ${POE_VIDEO_MODEL} failed: ${response.status} - ${errorText}`);\n return null;\n }\n const data = await response.json();\n const content = data?.choices?.[0]?.message?.content;\n const url =\n pickBestVideoUrl(content) ||\n pickBestVideoUrl(data) ||\n extractUrlFromText(normalizeContentToText(content));\n if (url) {\n console.log(`Video URL: ${url}`);\n return url;\n }\n console.error(\"No video URL in Poe response:\", JSON.stringify(data, null, 2));\n return null;\n } catch (error) {\n console.error(`Poe ${POE_VIDEO_MODEL} error:`, error);\n return null;\n }\n}\nasync function callNvidiaApi(\n model: string,\n messages: ChatMessage[],\n maxTokens = 1024,\n): Promise {\n if (!nvidiaApiKey) return null;\n try {\n console.log(`NVIDIA API attempt: ${model}`);\n const response = await fetchJsonWithRetry(\n \"https://integrate.api.nvidia.com/v1/chat/completions\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${nvidiaApiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ model, messages, max_tokens: maxTokens, temperature: 0.7, top_p: 0.9 }),\n },\n { timeoutMs: LONG_TIMEOUT_MS, retries: 2 },\n );\n if (!response.ok) {\n const errorText = await response.text();\n console.error(`NVIDIA ${model} failed: ${response.status} - ${errorText}`);\n return null;\n }\n const data = await response.json();\n const content = data?.choices?.[0]?.message?.content;\n const text = normalizeContentToText(content).trim();\n if (text) {\n console.log(`NVIDIA success with ${model}`);\n return text;\n }\n return null;\n } catch (error) {\n console.error(`NVIDIA ${model} error:`, error);\n return null;\n }\n}\nasync function callOpenRouterApi(\n model: string,\n messages: ChatMessage[],\n apiKey: string,\n maxTokens = 1024,\n): Promise {\n try {\n console.log(`OpenRouter API attempt: ${model}`);\n const response = await fetchJsonWithRetry(\n \"https://openrouter.ai/api/v1/chat/completions\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ model, messages, max_tokens: maxTokens }),\n },\n { timeoutMs: LONG_TIMEOUT_MS, retries: 2 },\n );\n if (!response.ok) {\n const errorText = await response.text();\n console.error(`OpenRouter ${model} failed: ${response.status} - ${errorText}`);\n return null;\n }\n const data = await response.json();\n const content = data?.choices?.[0]?.message?.content;\n const text = normalizeContentToText(content).trim();\n if (text) {\n console.log(`OpenRouter success with ${model}`);\n return text;\n }\n return null;\n } catch (error) {\n console.error(`OpenRouter ${model} error:`, error);\n return null;\n }\n}\nasync function generateText(\n message: string,\n systemPrompt = \"You are a chat user. Answer concise.\",\n): Promise {\n const messages: ChatMessage[] = [\n { role: \"system\", content: systemPrompt },\n { role: \"user\", content: message },\n ];\n for (const model of NVIDIA_MODELS) {\n const result = await callNvidiaApi(model, messages);\n if (result) return result;\n }\n const apiKeys = [openrouterApiKey, openrouterApiKey2].filter(Boolean) as string[];\n for (const apiKey of apiKeys) {\n for (const model of OPENROUTER_MODELS) {\n const result = await callOpenRouterApi(model, messages, apiKey);\n if (result) return result;\n }\n }\n throw new Error(\"All text generation models failed\");\n}\nasync function analyzeImageWithPoe(imageBase64: string, prompt: string): Promise {\n if (!poeApiKey) return null;\n for (const model of POE_VISION_MODELS) {\n try {\n console.log(`Poe vision attempt: ${model}`);\n const messages: ChatMessage[] = [\n {\n role: \"user\",\n content: [\n { type: \"text\", text: prompt },\n { type: \"image_url\", image_url: { url: `data:image/jpeg;base64,${imageBase64}` } },\n ],\n },\n ];\n const result = await callPoeApi(model, messages, 1024);\n if (result) return result;\n } catch (error) {\n console.error(`Poe vision ${model} error:`, error);\n }\n }\n return null;\n}\nasync function tryNvidiaVision(\n model: string,\n imageBase64: string,\n prompt: string,\n): Promise {\n if (!nvidiaApiKey) return null;\n try {\n console.log(`NVIDIA Vision attempt: ${model}`);\n const messages: ChatMessage[] = [\n {\n role: \"user\",\n content: [\n { type: \"text\", text: prompt },\n { type: \"image_url\", image_url: { url: `data:image/jpeg;base64,${imageBase64}` } },\n ],\n },\n ];\n return await callNvidiaApi(model, messages, 1024);\n } catch (error) {\n console.error(`NVIDIA Vision ${model} error:`, error);\n return null;\n }\n}\nasync function tryOpenRouterVision(\n model: string,\n imageSource: string,\n prompt: string,\n apiKey: string,\n): Promise {\n try {\n console.log(`OpenRouter Vision attempt: ${model}`);\n const messages: ChatMessage[] = [\n {\n role: \"user\",\n content: [\n { type: \"text\", text: prompt },\n { type: \"image_url\", image_url: { url: imageSource } },\n ],\n },\n ];\n return await callOpenRouterApi(model, messages, apiKey, 1024);\n } catch (error) {\n console.error(`OpenRouter Vision ${model} error:`, error);\n return null;\n }\n}\nasync function generateWithVision(imageBase64: string, prompt: string): Promise {\n console.log(\"Trying Poe vision models first...\");\n const poeResult = await analyzeImageWithPoe(imageBase64, prompt);\n if (poeResult) return poeResult;\n console.log(\"Poe failed, trying NVIDIA vision...\");\n for (const model of NVIDIA_VISION_MODELS) {\n const result = await tryNvidiaVision(model, imageBase64, prompt);\n if (result) return result;\n }\n console.log(\"NVIDIA failed, trying OpenRouter vision...\");\n const apiKeys = [openrouterApiKey, openrouterApiKey2].filter(Boolean) as string[];\n for (const apiKey of apiKeys) {\n for (const model of OPENROUTER_VISION_MODELS) {\n const b64Result = await tryOpenRouterVision(\n model,\n `data:image/jpeg;base64,${imageBase64}`,\n prompt,\n apiKey,\n );\n if (b64Result) return b64Result;\n }\n }\n throw new Error(\"All vision models failed\");\n}\nasync function extractTextFromDocument(fileBase64: string, _fileName: string): Promise {\n try {\n const decoder = new TextDecoder(\"utf-8\", { fatal: false, ignoreBOM: true });\n const bytes = base64ToUint8Array(fileBase64);\n const isPDF =\n bytes.length >= 4 &&\n bytes[0] === 0x25 &&\n bytes[1] === 0x50 &&\n bytes[2] === 0x44 &&\n bytes[3] === 0x46;\n if (isPDF) {\n console.log(\"Detected PDF - extracting text\");\n const pdfText = decoder.decode(bytes);\n const textChunks: string[] = [];\n const btMatches = pdfText.matchAll(/BT\\s+([\\s\\S]*?)\\s+ET/g);\n for (const match of btMatches) {\n const content = match[1];\n const tjMatches = content.matchAll(/\\(((?:[^()\\\\]|\\\\[\\s\\S])*)\\)\\s*Tj/g);\n for (const tjMatch of tjMatches) {\n const raw = tjMatch[1]\n .replace(/\\\\n/g, \"\\n\")\n .replace(/\\\\r/g, \"\\r\")\n .replace(/\\\\t/g, \"\\t\")\n .replace(/\\\\([()\\\\\\n])/g, \"$1\");\n if (raw.trim()) textChunks.push(raw);\n }\n }\n if (textChunks.length > 0) return textChunks.join(\" \").trim();\n return pdfText.replace(/[^\\x20-\\x7E\\n\\r]/g, \" \").replace(/\\s+/g, \" \").trim();\n }\n return decoder.decode(bytes).replace(/\\r\\n/g, \"\\n\").replace(/[^\\x20-\\x7E\\n\\r\\t]/g, \"\").trim();\n } catch (error) {\n console.error(\"Text extraction error:\", error);\n throw new Error(`Failed to extract text: ${error instanceof Error ? error.message : \"Unknown error\"}`);\n }\n}\nasync function processDocument(\n fileBase64: string,\n fileName: string,\n prompt: string,\n): Promise {\n const textContent = await extractTextFromDocument(fileBase64, fileName);\n if (textContent.length < 10) throw new Error(\"Insufficient text content extracted from document\");\n console.log(`Extracted ${textContent.length} characters from ${fileName}`);\n const maxLength = 12_000;\n const documentContent =\n textContent.length > maxLength\n ? `${textContent.substring(0, maxLength)}\\n\\n[Document truncated...]`\n : textContent;\n const messages: ChatMessage[] = [\n { role: \"system\", content: `Analyze the attached document: \"${fileName}\"` },\n { role: \"user\", content: `Document content:\\n\\n${documentContent}\\n\\nUser request: ${prompt}` },\n ];\n for (const model of NVIDIA_DOCUMENT_MODELS) {\n const result = await callNvidiaApi(model, messages, 2000);\n if (result) return result;\n }\n const apiKeys = [openrouterApiKey, openrouterApiKey2].filter(Boolean) as string[];\n for (const apiKey of apiKeys) {\n for (const model of OPENROUTER_DOCUMENT_MODELS) {\n const result = await callOpenRouterApi(model, messages, apiKey, 2000);\n if (result) return result;\n }\n }\n return `📄 Document: ${fileName}\\n\\nExtracted text (first 1000 chars):\\n\\n${textContent.substring(0, 1000)}${textContent.length > 1000 ? \"...\" : \"\"}`;\n}\nasync function generateImageWithPoe(prompt: string): Promise {\n if (!poeApiKey) return null;\n try {\n console.log(`Poe image gen: ${POE_IMAGE_BOT}`);\n const response = await fetchJsonWithRetry(\n \"https://api.poe.com/v1/chat/completions\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${poeApiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: POE_IMAGE_BOT,\n messages: [{ role: \"user\", content: prompt }],\n stream: false,\n }),\n },\n { timeoutMs: LONG_TIMEOUT_MS, retries: 3 },\n );\n if (!response.ok) {\n const errorText = await response.text();\n console.error(`Poe ${POE_IMAGE_BOT} failed: ${response.status} - ${errorText}`);\n return null;\n }\n const data = await response.json();\n const content = data?.choices?.[0]?.message?.content;\n const url = pickBestImageUrl(content) || pickBestImageUrl(data);\n if (url) {\n console.log(`Poe image generated`);\n return url;\n }\n console.log(`Poe ${POE_IMAGE_BOT} returned no image`);\n return null;\n } catch (error) {\n console.error(`Poe ${POE_IMAGE_BOT} error:`, error);\n return null;\n }\n}\nasync function generateImageWithPollinations(prompt: string): Promise {\n try {\n console.log(\"Trying Pollinations.ai\");\n const encodedPrompt = encodeURIComponent(prompt);\n const imageUrl = `https://image.pollinations.ai/prompt/${encodedPrompt}?width=1024&height=1024&nologo=true`;\n const check = await fetchWithTimeout(imageUrl, { method: \"HEAD\" }, 15_000);\n if (!check.ok) {\n console.warn(`Pollinations HEAD check failed: ${check.status}`);\n return null;\n }\n return imageUrl;\n } catch (error) {\n console.error(\"Pollinations.ai error:\", error);\n return null;\n }\n}\nasync function generateImage(\n prompt: string,\n): Promise<{ url: string; isBase64: boolean } | null> {\n const poeUrl = await generateImageWithPoe(prompt);\n if (poeUrl) return { url: poeUrl, isBase64: false };\n const pollinationsUrl = await generateImageWithPollinations(prompt);\n if (pollinationsUrl) return { url: pollinationsUrl, isBase64: false };\n return null;\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 tgUrl = `https://api.telegram.org/file/bot${telegramToken}/${file.file_path}`;\n const response = await fetchWithTimeout(tgUrl, {}, LONG_TIMEOUT_MS);\n if (!response.ok) throw new Error(`File download failed: ${response.status}`);\n return {\n data: new Uint8Array(await response.arrayBuffer()),\n mimeType: response.headers.get(\"content-type\"),\n };\n}\nasync function downloadExternalBinary(\n url: string,\n timeoutMs = VIDEO_TIMEOUT_MS,\n): Promise<{ bytes: Uint8Array; contentType: string | null }> {\n const response = await fetchWithTimeout(\n url,\n { headers: { \"User-Agent\": \"TelegramBot/1.0\" } },\n timeoutMs,\n );\n if (!response.ok) throw new Error(`External file fetch failed: ${response.status}`);\n const bytes = new Uint8Array(await response.arrayBuffer());\n if (bytes.length === 0) throw new Error(\"External file response was empty\");\n return { bytes, contentType: response.headers.get(\"content-type\") };\n}\ninterface AutoSearch {\n chatId: number;\n query: string;\n lastRun: number;\n}\nconst autoSearches = new Map();\nasync function performWebSearch(query: string): Promise {\n try {\n return await generateText(query, \"You are a helpful assistant. Answer concisely based on your knowledge.\");\n } catch (error) {\n console.error(\"Search error:\", error);\n return \"Search unavailable.\";\n }\n}\nasync function runAutoSearches() {\n const now = Date.now();\n const eightHours = 8 * 60 * 60 * 1000;\n for (const [key, search] of autoSearches.entries()) {\n if (now - search.lastRun >= eightHours) {\n try {\n const result = await performWebSearch(search.query);\n await bot.api.sendMessage(search.chatId, `🔍 Auto Search: \"${search.query}\"\\n\\n${result}`);\n search.lastRun = now;\n autoSearches.set(key, search);\n } catch (error) {\n console.error(`Auto search failed for ${search.chatId}:`, error);\n }\n }\n }\n}\nsetInterval(runAutoSearches, 30 * 60 * 1000);\nbot.command(\"start\", (ctx) => {\n if (!isGroupChat(ctx)) return ctx.reply(\"Join group: https://t.me/chatgpt_deutsch\");\n return ctx.reply(\"Poe AI access: https://poe.com/Open-Source-Lab\");\n});\nbot.command(\"search\", async (ctx) => {\n if (!isGroupChat(ctx)) return ctx.reply(\"Group only: https://t.me/chatgpt_deutsch\");\n const query = stripCommand(ctx.message?.text ?? \"\", \"search\");\n if (!query) return ctx.reply(\"Usage: /search \");\n try {\n await ctx.replyWithChatAction(\"typing\");\n const response = await generateText(query, \"You are a chat user. Answer concise.\");\n await ctx.reply(response);\n } catch (error) {\n console.error(\"Search error:\", error);\n await ctx.reply(\"Search failed. Try: https://poe.com/Open-Source-Lab\");\n }\n});\nbot.command(\"auto_search\", async (ctx) => {\n if (!isGroupChat(ctx)) return ctx.reply(\"Group only\");\n const query = stripCommand(ctx.message?.text ?? \"\", \"auto_search\");\n if (!query) return ctx.reply(\"Usage: /auto_search \");\n const chatId = ctx.chat.id;\n const key = `${chatId}:${query}`;\n autoSearches.set(key, { chatId, query, lastRun: Date.now() });\n await ctx.replyWithChatAction(\"typing\");\n const result = await performWebSearch(query);\n await ctx.reply(`✅ Auto search: \"${query}\"\\nUpdates every 8h.\\n\\n${result}`);\n});\nbot.command(\"list_searches\", (ctx) => {\n if (!isGroupChat(ctx)) return ctx.reply(\"Group only\");\n const searches = Array.from(autoSearches.values()).filter((s) => s.chatId === ctx.chat.id);\n if (searches.length === 0) return ctx.reply(\"No active searches\");\n const list = searches.map((s, i) => `${i + 1}. \"${s.query}\"`).join(\"\\n\");\n return ctx.reply(`Active searches:\\n\\n${list}`);\n});\nbot.command(\"stop_search\", (ctx) => {\n if (!isGroupChat(ctx)) return ctx.reply(\"Group only\");\n const query = stripCommand(ctx.message?.text ?? \"\", \"stop_search\");\n if (!query) return ctx.reply(\"Usage: /stop_search \");\n const key = `${ctx.chat.id}:${query}`;\n if (autoSearches.delete(key)) return ctx.reply(`✅ Stopped: \"${query}\"`);\n return ctx.reply(`❌ Not found: \"${query}\"`);\n});\nbot.command(\"image\", async (ctx) => {\n if (!isGroupChat(ctx)) return ctx.reply(\"Group only: https://t.me/chatgpt_deutsch\");\n const prompt = stripCommand(ctx.message?.text ?? \"\", \"image\");\n if (!prompt || prompt.length < 3) return ctx.reply(\"Usage: /image \");\n try {\n await ctx.replyWithChatAction(\"upload_photo\");\n const result = await generateImage(prompt);\n if (!result) {\n await ctx.reply(\"Image generation failed.\");\n return;\n }\n if (result.isBase64) {\n const base64Data = result.url.split(\",\")[1];\n const imageBuffer = base64ToUint8Array(base64Data);\n await ctx.replyWithPhoto(new InputFile(imageBuffer, \"image.png\"), { caption: `🎨 \"${prompt}\"` });\n } else {\n await ctx.replyWithPhoto(result.url, { caption: `🎨 \"${prompt}\"` });\n }\n } catch (error) {\n console.error(\"Image error:\", error);\n await ctx.reply(`Generation error: ${error instanceof Error ? error.message : \"Unknown\"}`);\n }\n});\nbot.on(\"message\", async (ctx) => {\n if (!isGroupChat(ctx)) return ctx.reply(\"Join: https://t.me/chatgpt_deutsch\");\n const messageText = ctx.message?.text ?? ctx.message?.caption ?? \"\";\n const photo = ctx.message?.photo;\n const document = ctx.message?.document;\n if (messageText.startsWith(\"/\")) return;\n // ── VIDEO GENERATION ────────────────────────────────────────────────────────\n if (isVideoGenerationRequest(messageText) && !photo && !document) {\n if (!poeApiKey) {\n await ctx.reply(\"Video generation unavailable: POE_API_KEY not set.\");\n return;\n }\n const statusMsg = await ctx.reply(\"🎬 Generating video… this may take several minutes.\");\n const stopHeartbeat = await startChatActionHeartbeat(ctx, \"upload_video\");\n try {\n // Step 1: Poe generation → video URL\n const videoUrl = await generateVideoWithPoe(messageText);\n if (!videoUrl) {\n await ctx.reply(\"❌ No video URL returned. Try a more specific prompt.\");\n return;\n }\n // Step 2: Download binary from CDN (auth-gated, Telegram can't fetch directly)\n let rawBytes: Uint8Array;\n let contentType: string | null = null;\n try {\n const downloaded = await downloadExternalBinary(videoUrl, VIDEO_TIMEOUT_MS);\n rawBytes = downloaded.bytes;\n contentType = downloaded.contentType;\n console.log(`Downloaded: ${(rawBytes.length / 1024 / 1024).toFixed(2)}MB type=${contentType}`);\n } catch (downloadError) {\n console.error(\"CDN download failed:\", downloadError);\n await ctx.reply(\n `❌ CDN download failed: ${downloadError instanceof Error ? downloadError.message : \"Unknown\"}.\\n` +\n `Direct link (may expire quickly): ${videoUrl}`,\n );\n return;\n }\n // Step 3: Compress if over limit\n let videoBytes = rawBytes;\n if (rawBytes.length > MAX_TELEGRAM_VIDEO_BYTES) {\n const rawMB = (rawBytes.length / 1024 / 1024).toFixed(1);\n console.log(`Video ${rawMB}MB exceeds limit — compressing…`);\n await ctx.reply(`⚙️ Compressing video (${rawMB}MB → target <45MB)…`);\n const compressed = await compressVideo(rawBytes, guessVideoFilename(videoUrl, contentType));\n if (!compressed) {\n await ctx.reply(\n `⚠️ ffmpeg compression unavailable. Video is ${rawMB}MB — exceeds Telegram's 45MB cap.\\n` +\n `Direct link (may expire): ${videoUrl}`,\n );\n return;\n }\n const compressedMB = (compressed.length / 1024 / 1024).toFixed(1);\n if (compressed.length > MAX_TELEGRAM_VIDEO_BYTES) {\n await ctx.reply(\n `⚠️ Post-compression size ${compressedMB}MB still exceeds 45MB cap.\\n` +\n `Direct link (may expire): ${videoUrl}`,\n );\n return;\n }\n videoBytes = compressed;\n contentType = \"video/mp4\";\n console.log(`Compression OK: ${compressedMB}MB`);\n }\n // Step 4: Send as InputFile (bypasses Telegram's URL fetch entirely)\n const filename = contentType === \"video/mp4\"\n ? \"video.mp4\"\n : guessVideoFilename(videoUrl, contentType);\n console.log(`Sending ${(videoBytes.length / 1024 / 1024).toFixed(2)}MB as ${filename}`);\n await ctx.replyWithVideo(\n new InputFile(videoBytes, filename),\n { caption: `🎬 \"${messageText}\"`, supports_streaming: true },\n );\n try { await ctx.api.deleteMessage(ctx.chat.id, statusMsg.message_id); } catch { }\n } catch (error) {\n console.error(\"Video pipeline error:\", error);\n await ctx.reply(`❌ Video error: ${error instanceof Error ? error.message : \"Unknown\"}`);\n } finally {\n stopHeartbeat();\n }\n return;\n }\n // ── IMAGE GENERATION ────────────────────────────────────────────────────────\n if (isImageGenerationRequest(messageText)) {\n let prompt = messageText;\n for (const prefix of [\"generate image\", \"gpt photo\", \"create image\", \"image of\", \"/image\"]) {\n if (prompt.toLowerCase().startsWith(prefix)) {\n prompt = prompt.substring(prefix.length).trim();\n break;\n }\n }\n if (prompt.length < 3) return ctx.reply(\"Provide image description\");\n try {\n await ctx.replyWithChatAction(\"upload_photo\");\n const result = await generateImage(prompt);\n if (!result) {\n await ctx.reply(\"All image providers unavailable.\");\n return;\n }\n if (result.isBase64) {\n const base64Data = result.url.split(\",\")[1];\n const imageBuffer = base64ToUint8Array(base64Data);\n await ctx.replyWithPhoto(new InputFile(imageBuffer, \"image.png\"), { caption: `🎨 \"${prompt}\"` });\n } else {\n await ctx.replyWithPhoto(result.url, { caption: `🎨 \"${prompt}\"` });\n }\n } catch (error) {\n console.error(\"Auto image error:\", error);\n await ctx.reply(\"Use /image \");\n }\n return;\n }\n // ── PHOTO ANALYSIS ──────────────────────────────────────────────────────────\n if (photo) {\n try {\n await ctx.replyWithChatAction(\"typing\");\n const largestPhoto = photo[photo.length - 1];\n const { data: imageData } = await downloadTelegramFile(largestPhoto.file_id);\n const base64 = uint8ArrayToBase64(imageData);\n const prompt = messageText || \"Describe this image concisely in 3 sentences\";\n const response = await generateWithVision(base64, prompt);\n await ctx.reply(response);\n } catch (error) {\n console.error(\"Vision error:\", error);\n await ctx.reply(`Image analysis failed: ${error instanceof Error ? error.message : \"Unknown error\"}`);\n }\n return;\n }\n // ── DOCUMENT ANALYSIS ───────────────────────────────────────────────────────\n if (document) {\n try {\n await ctx.replyWithChatAction(\"typing\");\n const fileName = document.file_name || \"document\";\n if (document.file_size && document.file_size > 20 * 1024 * 1024) {\n return ctx.reply(\"Maximum size: 20MB\");\n }\n const { data: fileData } = await downloadTelegramFile(document.file_id);\n const base64 = uint8ArrayToBase64(fileData);\n const prompt = messageText || \"Summarize this document.\";\n const response = await processDocument(base64, fileName, prompt);\n await ctx.reply(response);\n } catch (error) {\n console.error(\"Document error:\", error);\n await ctx.reply(`Document processing failed: ${error instanceof Error ? error.message : \"Unknown error\"}`);\n }\n return;\n }\n // ── TEXT ────────────────────────────────────────────────────────────────────\n if (messageText.trim()) {\n try {\n await ctx.replyWithChatAction(\"typing\");\n const response = await generateText(messageText);\n await ctx.reply(response);\n } catch (error) {\n console.error(\"Text error:\", error);\n await ctx.reply(\"Text generation failed.\");\n }\n }\n});\nbot.catch((err) => {\n console.error(\"Bot error:\", err);\n});\nconst SECRET_TOKEN = telegramToken.split(\":\")[1] || crypto.randomUUID();\nconst handleUpdate = webhookCallback(bot, \"std/http\", undefined, undefined, SECRET_TOKEN);\nexport default async (req: Request): Promise => {\n try {\n await bot.api.setWebhook(req.url, { secret_token: SECRET_TOKEN });\n } catch (error) {\n console.warn(\"Webhook setup error (non-fatal):\", error);\n }\n if (req.method === \"POST\") {\n try {\n return await handleUpdate(req);\n } catch (error) {\n console.error(\"Update error:\", error);\n return new Response(\"OK\", { status: 200 });\n }\n }\n return new Response(\"Bot active\", { status: 200, headers: { \"content-type\": \"text/html; charset=utf-8\" } });\n};","deleted","label",[100],"permalink","https://www.val.town/x/aibotcommander/Free-Omni-Telegram/code/main.tsx","extension","actionData","errors"]