[{"_1":2,"_239":-5,"_240":-5},"loaderData",{"_3":4,"_93":94,"_215":216},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":22,"_29":22,"_30":22,"_31":-5,"_32":33,"_34":22,"_35":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","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","d77a825f5103e272ed35e20cce4085d40e5ebe8e","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":22,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":22,"_92":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",{"_83":22,"_21":22,"_84":74,"_85":86,"_87":74,"_88":47,"_89":22,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_95":96,"_97":98,"_99":45,"_100":101,"_102":103,"_104":105,"_159":160,"_189":190,"_191":192,"_204":205,"_173":206,"_209":-5,"_210":-5,"_211":22,"_212":22,"_213":214},"handle","RobooHood","name","Free-Omni-Telegram","branchName","path","main.tsx","version",69,"project",{"_106":107,"_97":98,"_108":109,"_110":-5,"_111":22,"_112":113,"_114":115,"_116":117,"_14":118,"_119":120,"_121":122,"_123":122,"_124":-5,"_125":33,"_16":126,"_127":-5,"_128":-5,"_129":130,"_131":130,"_132":133,"_134":133,"_135":133,"_136":130,"_137":130,"_23":138,"_141":142,"_146":147,"_158":22},"id","18a3ab06-ba4f-11f0-9425-0224a6c84d84","createdAt",["D",1762350932695],"deletedAt","legacyEnvVars","privacy","public","description","https://poe.com/Cheap-Omni","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/b326da34-267d-474e-88e5-5c16b9787f00/square512","25a33e90-1def-11f0-8458-d7daa68fe194","pinnedFileId","019a544d-22c4-74ad-9ffa-d14f4b401148","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","e54478ee-7c91-4914-a560-525ba174a661","tursoName","tursoHostname","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,"_14":118,"_144":145},"avatar","tier","free","branch",{"_102":148,"_97":45,"_106":149,"_150":107,"_151":-5,"_152":-5,"_153":-5,"_154":-5,"_155":-5,"_156":98,"_157":96},74,"18a7272c-ba4f-11f0-9425-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[161,181],{"_106":162,"_97":163,"_164":165,"_166":-5,"_167":149,"_168":169,"_170":122,"_108":171,"_102":33,"_172":173,"_174":175,"_176":22,"_177":-5,"_178":179,"_100":180},"18aca10c-ba4f-11f0-9425-0224a6c84d84","README.md","fileId","019a544d-22c2-7485-b0b0-bd02d8c62b93","parentId","branchId","branchVersion",1,"latest",["D",1762350932695],"fileType","file","content","a simple poe bot\n\nthings to note:\n- don't put underscores (_) in the name, it stops working\n","deleted","label","children",[],[163],{"_106":182,"_97":101,"_164":120,"_166":-5,"_167":149,"_168":103,"_170":22,"_108":183,"_102":184,"_172":185,"_174":186,"_176":22,"_177":-5,"_178":187,"_100":188},"02a21902-0688-11f1-8f0e-42dde27851f2",["D",1770731665453],68,"http","import {\n Bot,\n InputFile,\n webhookCallback,\n} from \"https://deno.land/x/grammy@v1.35.0/mod.ts\";\n\nif (!Deno.env.get(\"TELEGRAM_TOKEN\")) {\n throw new Error(\"TELEGRAM_TOKEN is not set\");\n}\nconst telegramToken = Deno.env.get(\"TELEGRAM_TOKEN\")!;\n\n// NVIDIA API as primary for text\nconst nvidiaApiKey = Deno.env.get(\"NVIDIA_API_KEY\");\n\n// OpenRouter as fallback\nconst openrouterApiKey = Deno.env.get(\"OPENROUTER_API_KEY\");\nconst openrouterApiKey2 = Deno.env.get(\"OPENROUTER_API_KEY2\");\n\nconst poeApiKey = Deno.env.get(\"POE_API_KEY\");\n\nconst bot = new Bot(telegramToken);\n\n// NVIDIA NIM models (primary for text)\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];\n\n// NVIDIA Vision models\nconst NVIDIA_VISION_MODELS = [\n \"meta/llama-3.2-11b-vision-instruct\",\n \"meta/llama-3.2-90b-vision-instruct\",\n \"nvidia/vila\",\n];\n\n// OpenRouter fallback models\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];\n\n// OpenRouter vision fallback models\nconst OPENROUTER_VISION_MODELS = [\n \"opengvlab/internvl3-2b:free\",\n \"meta-llama/llama-3.2-11b-vision-instruct:free\",\n];\n\n// Poe vision bots (tried first for image analysis)\nconst POE_VISION_BOTS = [\n \"Gemini-2.5-Flash-Lite\",\n \"Cheap-Omni\",\n \"Grok-4.1-fast-non-reasoning\",\n \"assistant\",\n];\n\nconst POE_IMAGE_BOT = \"Flux-1-Schnell-FW\";\n\nconst NVIDIA_DOCUMENT_MODELS = [\n \"nvidia/llama-3.1-nemotron-70b-instruct\",\n \"meta/llama-3.1-70b-instruct\",\n];\n\nconst OPENROUTER_DOCUMENT_MODELS = [\n \"tngtech/deepseek-r1t2-chimera:free\",\n \"tngtech/deepseek-r1t-chimera:free\",\n];\n\n// ============ POE SSE PARSING ============\n\ninterface PoeAttachment {\n url: string;\n content_type: string;\n name: string;\n}\n\nasync function parsePoeSSEResponse(\n response: Response\n): Promise<{ text: string; attachments: PoeAttachment[] }> {\n const reader = response.body?.getReader();\n if (!reader) throw new Error(\"No response body\");\n\n const decoder = new TextDecoder();\n let buffer = \"\";\n let finalText = \"\";\n const attachments: PoeAttachment[] = [];\n\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n\n buffer += decoder.decode(value, { stream: true });\n const lines = buffer.split(\"\\n\");\n buffer = lines.pop() || \"\";\n\n for (const line of lines) {\n if (line.startsWith(\"data: \")) {\n const dataStr = line.slice(6).trim();\n if (dataStr === \"[DONE]\") continue;\n\n try {\n const data = JSON.parse(dataStr);\n if (data.text) finalText = data.text;\n if (data.attachments && Array.isArray(data.attachments)) {\n for (const att of data.attachments) {\n if (att.url && att.content_type?.startsWith(\"image/\")) {\n attachments.push({\n url: att.url,\n content_type: att.content_type,\n name: att.name || \"image\",\n });\n }\n }\n }\n } catch {\n // Skip malformed JSON\n }\n }\n }\n }\n\n return { text: finalText, attachments };\n}\n\n// ============ NVIDIA API CALLS ============\n\nasync function callNvidiaApi(\n model: string,\n messages: Array<{ role: string; content: unknown }>,\n maxTokens: number = 1024\n): Promise {\n if (!nvidiaApiKey) return null;\n\n try {\n const response = await fetch(\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({\n model,\n messages,\n max_tokens: maxTokens,\n temperature: 0.7,\n top_p: 0.9,\n }),\n }\n );\n\n if (!response.ok) {\n console.error(`NVIDIA ${model} failed: ${response.status}`);\n return null;\n }\n\n const data = await response.json();\n const content = data.choices?.[0]?.message?.content;\n if (content?.trim()) {\n console.log(`NVIDIA success with ${model}`);\n return content;\n }\n return null;\n } catch (error) {\n console.error(`NVIDIA ${model} error:`, error);\n return null;\n }\n}\n\nasync function callOpenRouterApi(\n model: string,\n messages: Array<{ role: string; content: unknown }>,\n apiKey: string,\n maxTokens: number = 1024\n): Promise {\n try {\n const response = await fetch(\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({\n model,\n messages,\n max_tokens: maxTokens,\n }),\n }\n );\n\n if (!response.ok) {\n console.error(`OpenRouter ${model} failed: ${response.status}`);\n return null;\n }\n\n const data = await response.json();\n const content = data.choices?.[0]?.message?.content;\n if (content?.trim()) {\n console.log(`OpenRouter success with ${model}`);\n return content;\n }\n return null;\n } catch (error) {\n console.error(`OpenRouter ${model} error:`, error);\n return null;\n }\n}\n\n// ============ TEXT GENERATION ============\n\nasync function generateWithOpenRouter(\n message: string,\n systemPrompt: string = \"You are a chat user. Answer concise.\"\n): Promise {\n const messages = [\n { role: \"system\", content: systemPrompt },\n { role: \"user\", content: message },\n ];\n\n // Try NVIDIA first\n for (const model of NVIDIA_MODELS) {\n const result = await callNvidiaApi(model, messages);\n if (result) return result;\n }\n\n // Fallback to OpenRouter\n const apiKeys = [openrouterApiKey, openrouterApiKey2].filter(\n Boolean\n ) as string[];\n\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\n throw new Error(\"All text generation models failed\");\n}\n\n// ============ VISION (IMAGE ANALYSIS) ============\n\nasync function analyzeImageWithPoe(\n imageBase64: string,\n imageUrl: string,\n prompt: string\n): Promise {\n if (!poeApiKey) {\n console.log(\"POE_API_KEY not configured\");\n return null;\n }\n\n for (const botName of POE_VISION_BOTS) {\n try {\n console.log(`Poe vision attempt: ${botName}`);\n\n // Try with base64 data URL first (more reliable)\n const imageContent = `data:image/jpeg;base64,${imageBase64}`;\n\n const response = await fetch(`https://api.poe.com/bot/${botName}`, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${poeApiKey}`,\n \"Content-Type\": \"application/json\",\n Accept: \"text/event-stream\",\n },\n body: JSON.stringify({\n version: \"1.0\",\n type: \"query\",\n query: [\n {\n role: \"user\",\n content: prompt,\n content_type: \"text/markdown\",\n attachments: [\n {\n url: imageContent,\n content_type: \"image/jpeg\",\n name: \"image.jpg\",\n },\n ],\n },\n ],\n user_id: \"\",\n conversation_id: \"\",\n message_id: crypto.randomUUID(),\n }),\n });\n\n if (!response.ok) {\n const errorText = await response.text();\n console.error(`Poe ${botName} failed: ${response.status} - ${errorText}`);\n continue; // Try next bot\n }\n\n const { text } = await parsePoeSSEResponse(response);\n if (text?.trim()) {\n console.log(`Poe vision success with ${botName}`);\n return text;\n }\n console.log(`Poe ${botName} returned empty response`);\n } catch (error) {\n console.error(`Poe ${botName} error:`, error);\n }\n }\n\n // Try with URL as fallback for all bots\n for (const botName of POE_VISION_BOTS) {\n try {\n console.log(`Poe vision URL attempt: ${botName}`);\n\n const response = await fetch(`https://api.poe.com/bot/${botName}`, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${poeApiKey}`,\n \"Content-Type\": \"application/json\",\n Accept: \"text/event-stream\",\n },\n body: JSON.stringify({\n version: \"1.0\",\n type: \"query\",\n query: [\n {\n role: \"user\",\n content: prompt,\n content_type: \"text/markdown\",\n attachments: [\n {\n url: imageUrl,\n content_type: \"image/jpeg\",\n name: \"image.jpg\",\n },\n ],\n },\n ],\n user_id: \"\",\n conversation_id: \"\",\n message_id: crypto.randomUUID(),\n }),\n });\n\n if (!response.ok) {\n console.error(`Poe ${botName} URL failed: ${response.status}`);\n continue;\n }\n\n const { text } = await parsePoeSSEResponse(response);\n if (text?.trim()) {\n console.log(`Poe vision URL success with ${botName}`);\n return text;\n }\n } catch (error) {\n console.error(`Poe ${botName} URL error:`, error);\n }\n }\n\n return null;\n}\n\nasync function tryNvidiaVision(\n model: string,\n imageBase64: string,\n prompt: string\n): Promise {\n if (!nvidiaApiKey) return null;\n\n try {\n console.log(`NVIDIA Vision attempt: ${model}`);\n const response = await fetch(\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({\n model,\n messages: [\n {\n role: \"user\",\n content: [\n { type: \"text\", text: prompt },\n {\n type: \"image_url\",\n image_url: {\n url: `data:image/jpeg;base64,${imageBase64}`,\n },\n },\n ],\n },\n ],\n max_tokens: 1024,\n }),\n }\n );\n\n if (!response.ok) {\n console.error(`NVIDIA Vision ${model} failed: ${response.status}`);\n return null;\n }\n\n const data = await response.json();\n const content = data.choices?.[0]?.message?.content;\n if (content?.trim()) {\n console.log(`NVIDIA Vision success with ${model}`);\n return content;\n }\n return null;\n } catch (error) {\n console.error(`NVIDIA Vision ${model} error:`, error);\n return null;\n }\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 response = await fetch(\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({\n model,\n messages: [\n {\n role: \"user\",\n content: [\n { type: \"text\", text: prompt },\n { type: \"image_url\", image_url: { url: imageSource } },\n ],\n },\n ],\n }),\n }\n );\n\n if (!response.ok) {\n console.error(`OpenRouter Vision ${model} failed: ${response.status}`);\n return null;\n }\n\n const data = await response.json();\n const content = data.choices?.[0]?.message?.content;\n if (content?.trim()) {\n console.log(`OpenRouter Vision success with ${model}`);\n return content;\n }\n return null;\n } catch (error) {\n console.error(`OpenRouter Vision ${model} error:`, error);\n return null;\n }\n}\n\n/**\n * Vision pipeline:\n * 1) Poe Vision bots (primary - GPT-4o-Mini, Claude, Gemini)\n * 2) NVIDIA Vision models (fallback)\n * 3) OpenRouter Vision models (final fallback)\n */\nasync function generateWithVision(\n imageBase64: string,\n imageUrl: string,\n prompt: string\n): Promise {\n // 1. Try Poe Vision first (multiple bots)\n console.log(\"Trying Poe vision models first...\");\n const poeResult = await analyzeImageWithPoe(imageBase64, imageUrl, prompt);\n if (poeResult) return poeResult;\n\n // 2. Try NVIDIA Vision models\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\n // 3. Try OpenRouter Vision models\n console.log(\"NVIDIA failed, trying OpenRouter vision...\");\n const apiKeys = [openrouterApiKey, openrouterApiKey2].filter(\n Boolean\n ) as string[];\n\n for (const apiKey of apiKeys) {\n for (const model of OPENROUTER_VISION_MODELS) {\n // Try URL first\n const urlResult = await tryOpenRouterVision(\n model,\n imageUrl,\n prompt,\n apiKey\n );\n if (urlResult) return urlResult;\n\n // Try base64\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\n throw new Error(\"All vision models failed\");\n}\n\n// ============ DOCUMENT PROCESSING ============\n\nasync function extractTextFromDocument(\n fileBase64: string,\n _fileName: string\n): Promise {\n try {\n const decoder = new TextDecoder(\"utf-8\", {\n fatal: false,\n ignoreBOM: true,\n });\n const bytes = Uint8Array.from(atob(fileBase64), (c) =>\n c.charCodeAt(0)\n );\n\n const isPDF =\n bytes[0] === 0x25 &&\n bytes[1] === 0x50 &&\n bytes[2] === 0x44 &&\n bytes[3] === 0x46;\n\n if (isPDF) {\n console.log(\"Detected PDF file - extracting text\");\n const pdfText = decoder.decode(bytes);\n const textChunks: string[] = [];\n\n const btMatches = pdfText.matchAll(/BT\\s+(.*?)\\s+ET/gs);\n for (const match of btMatches) {\n const content = match[1];\n const tjMatches = content.matchAll(/\\((.*?)\\)\\s*Tj/g);\n for (const tjMatch of tjMatches) {\n textChunks.push(tjMatch[1]);\n }\n }\n\n if (textChunks.length > 0) {\n return textChunks.join(\" \").trim();\n }\n\n return pdfText\n .replace(/[^\\x20-\\x7E\\n\\r]/g, \" \")\n .replace(/\\s+/g, \" \")\n .trim();\n }\n\n const textContent = decoder.decode(bytes);\n return textContent\n .replace(/\\r\\n/g, \"\\n\")\n .replace(/[^\\x20-\\x7E\\n\\r\\t]/g, \"\")\n .trim();\n } catch (error) {\n console.error(\"Text extraction error:\", error);\n throw new Error(\n `Failed to extract text: ${error instanceof Error ? error.message : \"Unknown error\"}`\n );\n }\n}\n\nasync function processDocument(\n fileBase64: string,\n fileName: string,\n prompt: string\n): Promise {\n const textContent = await extractTextFromDocument(fileBase64, fileName);\n\n if (textContent.length < 10) {\n throw new Error(\"Insufficient text content extracted from document\");\n }\n\n console.log(`Extracted ${textContent.length} characters from ${fileName}`);\n\n const maxLength = 12000;\n const documentContent =\n textContent.length > maxLength\n ? textContent.substring(0, maxLength) + \"\\n\\n[Document truncated...]\"\n : textContent;\n\n const messages = [\n { role: \"system\", content: `Analyze the attached document: \"${fileName}\"` },\n {\n role: \"user\",\n content: `Document content:\\n\\n${documentContent}\\n\\nUser request: ${prompt}`,\n },\n ];\n\n // Try NVIDIA models first\n for (const model of NVIDIA_DOCUMENT_MODELS) {\n const result = await callNvidiaApi(model, messages, 2000);\n if (result) return result;\n }\n\n // Fallback to OpenRouter\n const apiKeys = [openrouterApiKey, openrouterApiKey2].filter(\n Boolean\n ) as string[];\n\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\n // Return extracted text if all models fail\n return `📄 Document: ${fileName}\\n\\nExtracted text (first 1000 chars):\\n\\n${textContent.substring(0, 1000)}${textContent.length > 1000 ? \"...\" : \"\"}`;\n}\n\n// ============ IMAGE GENERATION ============\n\nasync function generateImageWithPoe(\n prompt: string\n): Promise {\n if (!poeApiKey) return null;\n\n try {\n console.log(`Poe image gen: ${POE_IMAGE_BOT}`);\n const response = await fetch(`https://api.poe.com/bot/${POE_IMAGE_BOT}`, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${poeApiKey}`,\n \"Content-Type\": \"application/json\",\n Accept: \"text/event-stream\",\n },\n body: JSON.stringify({\n version: \"1.0\",\n type: \"query\",\n query: [\n {\n role: \"user\",\n content: prompt,\n content_type: \"text/markdown\",\n },\n ],\n user_id: \"\",\n conversation_id: \"\",\n message_id: crypto.randomUUID(),\n }),\n });\n\n if (!response.ok) {\n console.error(`Poe ${POE_IMAGE_BOT} failed: ${response.status}`);\n return null;\n }\n\n const { attachments } = await parsePoeSSEResponse(response);\n if (attachments.length > 0) {\n console.log(`Poe ${POE_IMAGE_BOT} generated image successfully`);\n return attachments[0].url;\n }\n return null;\n } catch (error) {\n console.error(`Poe ${POE_IMAGE_BOT} error:`, error);\n return null;\n }\n}\n\nasync function generateImageWithPollinations(\n prompt: string\n): 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\n const checkResponse = await fetch(imageUrl, { method: \"HEAD\" });\n if (checkResponse.ok) {\n console.log(\"Pollinations.ai success\");\n return imageUrl;\n }\n return null;\n } catch (error) {\n console.error(\"Pollinations.ai error:\", error);\n return null;\n }\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\n const pollinationsUrl = await generateImageWithPollinations(prompt);\n if (pollinationsUrl) return { url: pollinationsUrl, isBase64: false };\n\n return null;\n}\n\n// ============ FILE DOWNLOAD ============\n\nasync function downloadFile(\n fileId: string\n): Promise<{ data: Uint8Array; url: string }> {\n try {\n const file = await bot.api.getFile(fileId);\n const tgUrl = `https://api.telegram.org/file/bot${telegramToken}/${file.file_path}`;\n const response = await fetch(tgUrl);\n if (!response.ok) {\n throw new Error(`File download failed: ${response.status}`);\n }\n const data = new Uint8Array(await response.arrayBuffer());\n\n let publicUrl = tgUrl;\n try {\n const formData = new FormData();\n formData.append(\n \"file\",\n new Blob([data], { type: \"image/jpeg\" }),\n \"image.jpg\"\n );\n const uploadResp = await fetch(\"https://tmpfiles.org/api/v1/upload\", {\n method: \"POST\",\n body: formData,\n });\n if (uploadResp.ok) {\n const uploadData = await uploadResp.json();\n if (uploadData?.data?.url) {\n publicUrl = uploadData.data.url.replace(\n \"tmpfiles.org/\",\n \"tmpfiles.org/dl/\"\n );\n console.log(`Uploaded to public URL: ${publicUrl}`);\n }\n }\n } catch (uploadErr) {\n console.log(\"Public upload failed, using TG URL:\", uploadErr);\n }\n\n return { data, url: publicUrl };\n } catch (error) {\n console.error(\"Download error:\", error);\n throw error;\n }\n}\n\n// ============ AUTO SEARCH ============\n\ninterface AutoSearch {\n chatId: number;\n query: string;\n lastRun: number;\n}\n\nconst autoSearches = new Map();\n\nasync function performWebSearch(query: string): Promise {\n try {\n return await generateWithOpenRouter(\n query,\n \"You are a chat user. Answer concise.\"\n );\n } catch (error) {\n console.error(\"Search error:\", error);\n return \"Search unavailable.\";\n }\n}\n\nasync function runAutoSearches() {\n const now = Date.now();\n const eightHours = 8 * 60 * 60 * 1000;\n\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(\n search.chatId,\n `🔍 Auto Search: \"${search.query}\"\\n\\n${result}`\n );\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}\n\nsetInterval(runAutoSearches, 30 * 60 * 1000);\n\n// ============ HELPERS ============\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}\n\n// ============ BOT COMMANDS ============\n\nbot.command(\"start\", (ctx) => {\n const isGroup =\n ctx.chat?.type === \"group\" || ctx.chat?.type === \"supergroup\";\n if (!isGroup) {\n return ctx.reply(\"Join group: https://t.me/chatgpt_deutsch\");\n }\n return ctx.reply(\"Poe AI access: https://poe.com/Open-Hat-Lab\");\n});\n\nbot.command(\"search\", async (ctx) => {\n const isGroup =\n ctx.chat?.type === \"group\" || ctx.chat?.type === \"supergroup\";\n if (!isGroup)\n return ctx.reply(\"Group only: https://t.me/chatgpt_deutsch\");\n\n const query = ctx.message?.text?.replace(\"/search\", \"\").trim();\n if (!query) return ctx.reply(\"Usage: /search \");\n\n try {\n await ctx.replyWithChatAction(\"typing\");\n const response = await generateWithOpenRouter(\n query,\n \"You are a chat user. Answer concise.\"\n );\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-Hat-Lab\");\n }\n});\n\nbot.command(\"auto_search\", async (ctx) => {\n const isGroup =\n ctx.chat?.type === \"group\" || ctx.chat?.type === \"supergroup\";\n if (!isGroup) return ctx.reply(\"Group only\");\n\n const query = ctx.message?.text?.replace(\"/auto_search\", \"\").trim();\n if (!query) return ctx.reply(\"Usage: /auto_search \");\n\n const chatId = ctx.chat.id;\n const key = `${chatId}:${query}`;\n autoSearches.set(key, { chatId, query, lastRun: Date.now() });\n\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});\n\nbot.command(\"list_searches\", (ctx) => {\n const isGroup =\n ctx.chat?.type === \"group\" || ctx.chat?.type === \"supergroup\";\n if (!isGroup) return ctx.reply(\"Group only\");\n\n const searches = Array.from(autoSearches.values()).filter(\n (s) => s.chatId === ctx.chat.id\n );\n if (searches.length === 0) return ctx.reply(\"No active searches\");\n\n const list = searches.map((s, i) => `${i + 1}. \"${s.query}\"`).join(\"\\n\");\n return ctx.reply(`Active searches:\\n\\n${list}`);\n});\n\nbot.command(\"stop_search\", (ctx) => {\n const isGroup =\n ctx.chat?.type === \"group\" || ctx.chat?.type === \"supergroup\";\n if (!isGroup) return ctx.reply(\"Group only\");\n\n const query = ctx.message?.text?.replace(\"/stop_search\", \"\").trim();\n if (!query) return ctx.reply(\"Usage: /stop_search \");\n\n const key = `${ctx.chat.id}:${query}`;\n if (autoSearches.delete(key)) {\n return ctx.reply(`✅ Stopped: \"${query}\"`);\n }\n return ctx.reply(`❌ Not found: \"${query}\"`);\n});\n\nbot.command(\"image\", async (ctx) => {\n const isGroup =\n ctx.chat?.type === \"group\" || ctx.chat?.type === \"supergroup\";\n if (!isGroup)\n return ctx.reply(\"Group only: https://t.me/chatgpt_deutsch\");\n\n const prompt = ctx.message?.text?.replace(\"/image\", \"\").trim();\n if (!prompt || prompt.length < 3) {\n return ctx.reply(\"Usage: /image \");\n }\n\n try {\n await ctx.replyWithChatAction(\"upload_photo\");\n const result = await generateImage(prompt);\n\n if (result) {\n if (result.isBase64) {\n const base64Data = result.url.split(\",\")[1];\n const imageBuffer = Uint8Array.from(atob(base64Data), (c) =>\n c.charCodeAt(0)\n );\n await ctx.replyWithPhoto(new InputFile(imageBuffer, \"image.png\"), {\n caption: `🎨 \"${prompt}\"`,\n });\n } else {\n await ctx.replyWithPhoto(result.url, { caption: `🎨 \"${prompt}\"` });\n }\n } else {\n await ctx.reply(\"Image generation failed.\");\n }\n } catch (error) {\n console.error(\"Image error:\", error);\n await ctx.reply(\n `Generation error: ${error instanceof Error ? error.message : \"Unknown\"}`\n );\n }\n});\n\n// ============ MESSAGE HANDLER ============\n\nbot.on(\"message\", async (ctx) => {\n const isGroup =\n ctx.chat?.type === \"group\" || ctx.chat?.type === \"supergroup\";\n if (!isGroup) {\n return ctx.reply(\"Join: https://t.me/chatgpt_deutsch\");\n }\n\n const messageText = ctx.message?.text || ctx.message?.caption || \"\";\n const photo = ctx.message?.photo;\n const document = ctx.message?.document;\n\n // --- Image generation from text ---\n if (isImageGenerationRequest(messageText)) {\n let prompt = messageText;\n for (const prefix of [\n \"generate image\",\n \"gpt photo\",\n \"create image\",\n \"image of\",\n \"/image\",\n ]) {\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\n try {\n await ctx.replyWithChatAction(\"upload_photo\");\n const result = await generateImage(prompt);\n\n if (result) {\n if (result.isBase64) {\n const base64Data = result.url.split(\",\")[1];\n const imageBuffer = Uint8Array.from(atob(base64Data), (c) =>\n c.charCodeAt(0)\n );\n await ctx.replyWithPhoto(new InputFile(imageBuffer, \"image.png\"), {\n caption: `🎨 \"${prompt}\"`,\n });\n } else {\n await ctx.replyWithPhoto(result.url, { caption: `🎨 \"${prompt}\"` });\n }\n } else {\n await ctx.reply(\"All image providers unavailable.\");\n }\n } catch (error) {\n console.error(\"Auto image error:\", error);\n await ctx.reply(\"Use /image \");\n }\n return;\n }\n\n // --- Image analysis (photo sent) ---\n if (photo) {\n try {\n await ctx.replyWithChatAction(\"typing\");\n const largestPhoto = photo[photo.length - 1];\n console.log(`Processing photo: ${largestPhoto.file_id}`);\n\n const { data: imageData, url: imageUrl } = await downloadFile(\n largestPhoto.file_id\n );\n\n let base64 = \"\";\n const chunkSize = 8192;\n for (let i = 0; i < imageData.length; i += chunkSize) {\n const chunk = imageData.subarray(i, i + chunkSize);\n base64 += btoa(String.fromCharCode(...chunk));\n }\n\n const prompt = messageText || \"Describe this image concisely\";\n\n console.log(`Image size: ${imageData.length} bytes`);\n\n const response = await generateWithVision(base64, imageUrl, prompt);\n await ctx.reply(response);\n } catch (error) {\n console.error(\"Vision error:\", error);\n await ctx.reply(\n `Image analysis failed: ${error instanceof Error ? error.message : \"Unknown error\"}`\n );\n }\n return;\n }\n\n // --- Document processing ---\n if (document) {\n try {\n await ctx.replyWithChatAction(\"typing\");\n const fileName = document.file_name || \"document\";\n console.log(\n `Processing document: ${fileName}, size: ${document.file_size} bytes`\n );\n\n if (document.file_size && document.file_size > 20 * 1024 * 1024) {\n return ctx.reply(\"Maximum size: 20MB\");\n }\n\n const { data: fileData } = await downloadFile(document.file_id);\n const base64 = btoa(String.fromCharCode(...fileData));\n const prompt = messageText || \"Summarize this document.\";\n\n console.log(\n `Document downloaded: ${fileData.length} bytes, prompt: \"${prompt}\"`\n );\n\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(\n `Document processing failed: ${error instanceof Error ? error.message : \"Unknown error\"}`\n );\n }\n return;\n }\n});\n\n// ============ ERROR HANDLER & WEBHOOK ============\n\nbot.catch((err) => {\n console.error(\"Bot error:\", err);\n});\n\nconst SECRET_TOKEN =\n Deno.env.get(\"OPENROUTER_API_KEY\") || crypto.randomUUID();\nconst handleUpdate = webhookCallback(\n bot,\n \"std/http\",\n undefined,\n undefined,\n SECRET_TOKEN\n);\n\nexport default async (req: Request): Promise => {\n try {\n const url = new URL(req.url);\n const webhookUrl = `${url.protocol}//${url.host}${url.pathname}`;\n await bot.api.setWebhook(webhookUrl, { secret_token: SECRET_TOKEN });\n } catch (error) {\n console.error(\"Webhook setup error:\", error);\n }\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\n return new Response(\"Bot active\", {\n status: 200,\n headers: { \"content-type\": \"text/html\" },\n });\n};",[],[101],"files",[161,181],"counts",{"_193":33,"_194":169,"_195":169,"_196":197,"_201":202},"pulls","branches","forks","envVars",{"_198":199,"_200":33},"count",8,"emptyCount","connections",{"_198":33,"_203":33},"unfilledCount","contents",[],{"_106":182,"_97":101,"_164":120,"_166":-5,"_167":149,"_168":103,"_170":22,"_108":207,"_102":184,"_172":185,"_174":186,"_176":22,"_177":-5,"_100":208},["D",1770731665453],[101],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_95":96,"_97":98,"_99":45,"_102":103,"_100":101,"_104":217,"_159":222,"_189":229,"_173":230,"_204":232,"_233":-5,"_234":-5,"_235":-5,"_236":-5,"_237":238,"_196":-5},{"_106":107,"_97":98,"_108":218,"_110":-5,"_111":22,"_112":113,"_114":115,"_116":117,"_14":118,"_119":120,"_121":122,"_123":122,"_124":-5,"_125":33,"_16":126,"_127":-5,"_128":-5,"_129":130,"_131":130,"_132":133,"_134":133,"_135":133,"_136":130,"_137":130,"_23":219,"_141":220,"_146":221,"_158":22},["D",1762350932695],{"_95":96,"_139":140},{"_95":96,"_143":140,"_14":118,"_144":145},{"_102":148,"_97":45,"_106":149,"_150":107,"_151":-5,"_152":-5,"_153":-5,"_154":-5,"_155":-5,"_156":98,"_157":96},[223,226],{"_106":162,"_97":163,"_164":165,"_166":-5,"_167":149,"_168":169,"_170":122,"_108":171,"_102":33,"_172":173,"_174":175,"_176":22,"_177":-5,"_178":224,"_100":225},[],[163],{"_106":182,"_97":101,"_164":120,"_166":-5,"_167":149,"_168":103,"_170":22,"_108":183,"_102":184,"_172":185,"_174":186,"_176":22,"_177":-5,"_178":227,"_100":228},[],[101],[223,226],{"_106":182,"_97":101,"_164":120,"_166":-5,"_167":149,"_168":103,"_170":22,"_108":207,"_102":184,"_172":185,"_174":186,"_176":22,"_177":-5,"_100":231},[101],[],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]