[{"_1":2,"_174":-5,"_175":-5},"loaderData",{"_3":4,"_92":93},"root",{"_5":6,"_35":36,"_65":66},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20,"_34":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","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_37":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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","16f2931b3e0f3a1f0749f6d2640b9447dd6106a9","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",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":46,"_72":73,"_74":73,"_75":20,"_76":73,"_77":73,"_78":73,"_79":73,"_80":81,"_90":20,"_91":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",{"_82":20,"_19":20,"_83":73,"_84":85,"_86":73,"_87":46,"_88":20,"_89":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_94":95,"_96":97,"_98":99,"_100":101,"_155":156,"_171":172,"_173":-5},"handle","RobooHood","name","Omni-Model-Telegram-01","path","main.tsx","project",{"_102":103,"_96":97,"_104":105,"_106":-5,"_107":20,"_108":109,"_110":111,"_112":113,"_12":114,"_115":116,"_117":118,"_119":-5,"_120":-5,"_121":32,"_14":122,"_123":124,"_125":124,"_126":127,"_128":127,"_129":127,"_130":124,"_131":124,"_23":132,"_135":136,"_138":139,"_154":20},"id","cf26d27a-eec2-11f0-82a5-42dde27851f2","createdAt",["D",1768118091491],"deletedAt","legacyEnvVars","privacy","public","description","https://poe.com/Cheap-Omni","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/7562bbd2-76d2-4958-6ddd-845c581ed900/square512","25a33e90-1def-11f0-8458-d7daa68fe194","pinnedFileId","019bac0c-fefb-724d-8648-721e2ddcc51d","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","e54478ee-7c91-4914-a560-525ba174a661","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_94":95,"_133":134},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/dea1728e-0705-4aeb-d340-76cf90896100/square512","org",{"_94":95,"_137":134,"_12":114},"avatar","branch",{"_140":141,"_96":44,"_102":142,"_143":103,"_144":145,"_146":147,"_148":109,"_149":150,"_151":122,"_152":97,"_153":95},"version",1,"cf28ba54-eec2-11f0-82a5-42dde27851f2","projectId","forkedBranchId","18a7272c-ba4f-11f0-9425-0224a6c84d84","forkedBranchVersion",42,"forkedProjectPrivacy","forkedProjectId","18a3ab06-ba4f-11f0-9425-0224a6c84d84","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_102":157,"_96":99,"_158":116,"_159":-5,"_160":142,"_161":141,"_162":118,"_104":163,"_140":32,"_164":165,"_166":167,"_168":20,"_169":-5,"_98":170},"cf2b15f6-eec2-11f0-82a5-42dde27851f2","fileId","parentId","branchId","branchVersion","latest",["D",1768118091491],"fileType","http","content","import {\n Bot,\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\nif (!Deno.env.get(\"OPENROUTER_API_KEY\")) {\n throw new Error(\"OPENROUTER_API_KEY is not set\");\n}\nconst openrouterApiKey = Deno.env.get(\"OPENROUTER_API_KEY\")!;\nconst openrouterApiKey2 = Deno.env.get(\"OPENROUTER_API_KEY2\");\n\nif (!Deno.env.get(\"POE_API_KEY\")) {\n throw new Error(\"POE_API_KEY is not set\");\n}\nconst poeApiKey = Deno.env.get(\"POE_API_KEY\")!;\n\nconst bot = new Bot(telegramToken);\n\nconst OPENROUTER_MODELS = [\n \"meta-llama/llama-3.2-3b-instruct:free\",\n \"amazon/nova-2-lite-v1:free\",\n \"arcee-ai/trinity-mini:free\"\n];\n\nconst VISION_MODELS = [\n \"nvidia/nemotron-nano-9b-v2:free\",\n \"nvidia/nemotron-nano-12b-v2-vl:free\",\n \"google/gemini-2.0-flash-exp:free\",\n \"google/gemini-flash-1.5-8b:free\",\n \"meta-llama/llama-3.2-11b-vision-instruct:free\"\n];\n\nconst DOCUMENT_MODELS = [\n \"tngtech/deepseek-r1t2-chimera:free\",\n \"tngtech/deepseek-r1t-chimera:free\",\n \"nex-agi/deepseek-v3.1-nex-n1:free\",\n \"GPT-4o-mini\",\n \"Gemini-2.0-flash-lite\"\n];\n\nconst IMAGE_GENERATION_BOTS = [\n \"cheap-image-creator\",\n \"Flux-schnell-DI\",\n \"ImageResponseBotDemo\"\n];\n\nasync function generateWithOpenRouter(\n message: string,\n systemPrompt: string = \"You are a chat user. Answer concise.\",\n isSearch: boolean = false\n): Promise {\n const apiKeys = [openrouterApiKey];\n if (openrouterApiKey2) {\n apiKeys.push(openrouterApiKey2);\n }\n\n for (const apiKey of apiKeys) {\n for (const model of OPENROUTER_MODELS) {\n try {\n const response = await fetch(\"https://openrouter.ai/api/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: model,\n messages: [\n { role: \"system\", content: systemPrompt },\n { role: \"user\", content: message }\n ],\n }),\n });\n\n if (!response.ok) {\n console.error(`Model ${model} failed: ${response.status}`);\n continue;\n }\n\n const data = await response.json();\n return data.choices[0].message.content;\n } catch (error) {\n console.error(`Error with ${model}:`, error);\n continue;\n }\n }\n }\n throw new Error(\"All models failed\");\n}\n\nasync function generateWithVision(\n imageBase64: string,\n prompt: string\n): Promise {\n const apiKeys = [openrouterApiKey];\n if (openrouterApiKey2) {\n apiKeys.push(openrouterApiKey2);\n }\n\n // Try OpenRouter vision models first\n for (const apiKey of apiKeys) {\n for (const model of VISION_MODELS) {\n try {\n console.log(`Vision attempt: ${model}`);\n const response = await fetch(\"https://openrouter.ai/api/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: model,\n messages: [\n {\n role: \"user\",\n content: [\n { type: \"text\", text: prompt },\n {\n type: \"image_url\",\n image_url: { url: `data:image/jpeg;base64,${imageBase64}` }\n }\n ]\n }\n ],\n }),\n });\n\n if (!response.ok) {\n const errorText = await response.text();\n console.error(`Vision ${model} failed: ${response.status} - ${errorText}`);\n continue;\n }\n\n const data = await response.json();\n return data.choices[0].message.content;\n } catch (error) {\n console.error(`Vision error ${model}:`, error);\n continue;\n }\n }\n }\n\n console.log(\"All OpenRouter vision models failed, trying Poe API fallback\");\n return await generateVisionViaPoe(imageBase64, prompt);\n}\n\nasync function generateVisionViaPoe(imageBase64: string, prompt: string): Promise {\n try {\n console.log(\"Attempting Poe vision with Aya-Vision bot\");\n\n const response = await fetch(`https://api.poe.com/bot/Aya-Vision`, {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${poeApiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n version: \"1.0\",\n type: \"query\",\n query: [{\n role: \"user\",\n content: prompt,\n content_type: \"text/markdown\",\n timestamp: Date.now() * 1000000,\n message_id: `msg_${Date.now()}`,\n attachments: [{\n url: `data:image/jpeg;base64,${imageBase64}`,\n content_type: \"image/jpeg\",\n name: \"image.jpg\"\n }]\n }],\n user_id: \"telegram_bot\",\n conversation_id: `tg_vision_${Date.now()}`,\n message_id: `msg_${Date.now()}`,\n }),\n });\n\n if (!response.ok) {\n const errorText = await response.text();\n console.error(`Poe API error: ${response.status} - ${errorText}`);\n throw new Error(`Poe API returned ${response.status}: ${errorText}`);\n }\n\n const reader = response.body?.getReader();\n if (!reader) throw new Error(\"No response body from Poe\");\n\n const decoder = new TextDecoder();\n let buffer = \"\";\n let fullText = \"\";\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:\")) continue;\n const data = line.substring(5).trim();\n if (data === \"[DONE]\") continue;\n\n try {\n const parsed = JSON.parse(data);\n if (parsed.text) {\n fullText += parsed.text;\n }\n } catch (e) {\n // Ignore parse errors for partial JSON\n }\n }\n }\n\n if (fullText.trim()) {\n console.log(`Poe vision success: ${fullText.length} chars`);\n return fullText;\n }\n throw new Error(\"No text received from Poe vision API\");\n } catch (error) {\n console.error(\"Poe vision error:\", error);\n throw new Error(`All vision models failed: ${error instanceof Error ? error.message : 'Unknown error'}`);\n }\n}\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 = Uint8Array.from(atob(fileBase64), c => c.charCodeAt(0));\n\n // Check if it's a PDF (starts with %PDF)\n const isPDF = bytes[0] === 0x25 && bytes[1] === 0x50 && bytes[2] === 0x44 && bytes[3] === 0x46;\n\n if (isPDF) {\n console.log(\"Detected PDF file - extracting text\");\n // Extract text between stream objects and clean up\n const pdfText = decoder.decode(bytes);\n const textChunks: string[] = [];\n\n // Simple PDF text extraction - look for text between BT and ET markers\n const btMatches = pdfText.matchAll(/BT\\s+(.*?)\\s+ET/gs);\n for (const match of btMatches) {\n const content = match[1];\n // Extract text from Tj commands\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 // Fallback: extract all printable text\n return pdfText.replace(/[^\\x20-\\x7E\\n\\r]/g, ' ')\n .replace(/\\s+/g, ' ')\n .trim();\n }\n\n // For text files\n const textContent = decoder.decode(bytes);\n const cleanText = textContent\n .replace(/\\r\\n/g, '\\n')\n .replace(/[^\\x20-\\x7E\\n\\r\\t]/g, '')\n .trim();\n\n return cleanText;\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}\n\nasync function processDocumentWithOpenRouter(fileBase64: string, fileName: string, prompt: string): Promise {\n const apiKeys = [openrouterApiKey];\n if (openrouterApiKey2) {\n apiKeys.push(openrouterApiKey2);\n }\n\n // Extract text content from document\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 // Limit to reasonable size for context\n const maxLength = 12000;\n const documentContent = textContent.length > maxLength\n ? textContent.substring(0, maxLength) + \"\\n\\n[Document truncated...]\"\n : textContent;\n\n const systemPrompt = `You are analyzing a document named \"${fileName}\". Provide a helpful response based on the document content.`;\n const userMessage = `Document content:\\n\\n${documentContent}\\n\\nUser request: ${prompt}`;\n\n // Try document-specific models\n for (const apiKey of apiKeys) {\n for (const model of DOCUMENT_MODELS) {\n try {\n console.log(`Document processing attempt: ${model}`);\n const response = await fetch(\"https://openrouter.ai/api/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: model,\n messages: [\n { role: \"system\", content: systemPrompt },\n { role: \"user\", content: userMessage }\n ],\n max_tokens: 2000,\n }),\n });\n\n if (!response.ok) {\n const errorText = await response.text();\n console.error(`Document model ${model} failed: ${response.status} - ${errorText}`);\n continue;\n }\n\n const data = await response.json();\n const result = data.choices[0].message.content;\n console.log(`Document processing success with ${model}`);\n return result;\n } catch (error) {\n console.error(`Document error ${model}:`, error);\n continue;\n }\n }\n }\n\n throw new Error(\"All OpenRouter document models failed\");\n}\n\nasync function processDocumentViaPoe(fileBase64: string, fileName: string, prompt: string): Promise {\n try {\n console.log(\"Attempting Poe document processing with DeepSeek2.5\");\n\n // Try to extract text and send as content if file processing fails\n let textContent = \"\";\n try {\n textContent = await extractTextFromDocument(fileBase64, fileName);\n } catch (e) {\n console.log(\"Could not extract text, will try file attachment\");\n }\n\n const response = await fetch(`https://api.poe.com/bot/DeepSeek2.5`, {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${poeApiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n version: \"1.0\",\n type: \"query\",\n query: [{\n role: \"user\",\n content: textContent\n ? `Document \"${fileName}\":\\n\\n${textContent.substring(0, 8000)}\\n\\n${prompt}`\n : `${prompt}\\n\\nDocument attached: ${fileName}`,\n content_type: \"text/markdown\",\n timestamp: Date.now() * 1000000,\n message_id: `msg_${Date.now()}`,\n attachments: textContent ? [] : [{\n url: `data:application/octet-stream;base64,${fileBase64}`,\n content_type: fileName.endsWith('.pdf') ? \"application/pdf\" : \"text/plain\",\n name: fileName\n }]\n }],\n user_id: \"telegram_bot\",\n conversation_id: `tg_doc_${Date.now()}`,\n message_id: `msg_${Date.now()}`,\n }),\n });\n\n if (!response.ok) {\n const errorText = await response.text();\n console.error(`Poe document error: ${response.status} - ${errorText}`);\n throw new Error(`Poe API returned ${response.status}: ${errorText}`);\n }\n\n const reader = response.body?.getReader();\n if (!reader) throw new Error(\"No response body from Poe\");\n\n const decoder = new TextDecoder();\n let buffer = \"\";\n let fullText = \"\";\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:\")) continue;\n const data = line.substring(5).trim();\n if (data === \"[DONE]\") continue;\n\n try {\n const parsed = JSON.parse(data);\n if (parsed.text) {\n fullText += parsed.text;\n }\n } catch (e) {\n // Ignore parse errors\n }\n }\n }\n\n if (fullText.trim()) {\n console.log(`Poe document success: ${fullText.length} chars`);\n return fullText;\n }\n\n throw new Error(\"No text received from Poe document API\");\n } catch (error) {\n console.error(\"Poe document processing error:\", error);\n throw error;\n }\n}\n\nasync function processDocument(fileBase64: string, fileName: string, prompt: string): Promise {\n try {\n console.log(`Processing document: ${fileName} (${fileBase64.length} bytes base64)`);\n\n // Try OpenRouter document models first\n try {\n const result = await processDocumentWithOpenRouter(fileBase64, fileName, prompt);\n return result;\n } catch (error) {\n console.error(\"OpenRouter document processing failed:\", error);\n console.log(\"Falling back to Poe API\");\n }\n\n // Try Poe API as fallback\n try {\n const result = await processDocumentViaPoe(fileBase64, fileName, prompt);\n return result;\n } catch (error) {\n console.error(\"Poe document processing failed:\", error);\n }\n\n // Last resort: try to extract and summarize text directly\n try {\n const textContent = await extractTextFromDocument(fileBase64, fileName);\n if (textContent.length >= 10) {\n const summary = `📄 Document: ${fileName}\\n\\nExtracted text (first 1000 chars):\\n\\n${textContent.substring(0, 1000)}${textContent.length > 1000 ? '...' : ''}\\n\\nFull document processing failed, but text was extracted. You can ask questions about this content.`;\n return summary;\n }\n } catch (e) {\n console.error(\"Text extraction fallback failed:\", e);\n }\n\n return \"❌ Unable to process document. All processing methods failed. Please ensure the document contains readable text.\";\n } catch (error) {\n console.error(\"Document processing error:\", error);\n return `❌ Document processing failed: ${error instanceof Error ? error.message : 'Unknown error'}`;\n }\n}\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(query, \"You are a chat user. Answer concise.\", true);\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\nasync function tryPoeImageBot(botName: string, prompt: string): Promise {\n try {\n console.log(`Trying image generation with Poe bot: ${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 },\n body: JSON.stringify({\n version: \"1.0\",\n type: \"query\",\n query: [{\n role: \"user\",\n content: prompt,\n content_type: \"text/markdown\",\n timestamp: Date.now() * 1000000,\n message_id: `msg_${Date.now()}`\n }],\n user_id: \"telegram_bot\",\n conversation_id: `tg_img_${Date.now()}`,\n message_id: `msg_${Date.now()}`,\n }),\n });\n\n if (!response.ok) {\n const errorText = await response.text();\n console.error(`Poe bot ${botName} error: ${response.status} - ${errorText}`);\n return null;\n }\n\n const reader = response.body?.getReader();\n if (!reader) return null;\n\n const decoder = new TextDecoder();\n let imageUrl: string | null = null;\n let buffer = \"\";\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:\")) continue;\n const data = line.substring(5).trim();\n if (data === \"[DONE]\") continue;\n\n try {\n const parsed = JSON.parse(data);\n if (parsed.text) {\n const match = parsed.text.match(/(https?:\\/\\/[^\\s\\)\\]\\\"\\'\\<\\>]+\\.(?:png|jpg|jpeg|webp|gif))/i);\n if (match) imageUrl = match[1];\n }\n if (parsed.url) imageUrl = parsed.url;\n if (parsed.attachments?.[0]?.url) imageUrl = parsed.attachments[0].url;\n } catch (e) {\n // Ignore parse errors\n }\n }\n }\n\n if (imageUrl) {\n console.log(`Image generated successfully with ${botName}: ${imageUrl}`);\n }\n return imageUrl;\n } catch (error) {\n console.error(`POE image bot ${botName} error:`, error);\n return null;\n }\n}\n\nasync function generateImageViaPoe(prompt: string): Promise {\n for (const botName of IMAGE_GENERATION_BOTS) {\n const imageUrl = await tryPoeImageBot(botName, prompt);\n if (imageUrl) {\n return imageUrl;\n }\n console.log(`Bot ${botName} failed, trying next fallback...`);\n }\n\n console.error(\"All image generation bots failed\");\n return null;\n}\n\nfunction isImageGenerationRequest(text: string): boolean {\n if (!text) return false;\n const lower = text.toLowerCase().trim();\n const keywords = [\"generate image\", \"gpt photo\", \"create image\", \"image of\", \"photo of\", \"draw\", \"illustrate\", \"/image\"];\n return keywords.some(k => lower.startsWith(k));\n}\n\nasync function downloadFile(fileId: string): Promise {\n try {\n const file = await bot.api.getFile(fileId);\n const url = `https://api.telegram.org/file/bot${telegramToken}/${file.file_path}`;\n const response = await fetch(url);\n if (!response.ok) {\n throw new Error(`File download failed: ${response.status}`);\n }\n return new Uint8Array(await response.arrayBuffer());\n } catch (error) {\n console.error(\"Download error:\", error);\n throw error;\n }\n}\n\nbot.command(\"start\", (ctx) => {\n const isGroup = 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 = ctx.chat?.type === \"group\" || ctx.chat?.type === \"supergroup\";\n if (!isGroup) 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(query, \"You are a chat user. Answer concise.\", true);\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 = 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\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 = 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(s => s.chatId === ctx.chat.id);\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 = 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 = ctx.chat?.type === \"group\" || ctx.chat?.type === \"supergroup\";\n if (!isGroup) 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 imageUrl = await generateImageViaPoe(prompt);\n if (imageUrl) {\n await ctx.replyWithPhoto(imageUrl, { caption: `🎨 \"${prompt}\"` });\n } else {\n await ctx.reply(\"Image generation failed. All bots unavailable.\");\n }\n } catch (error) {\n console.error(\"Image error:\", error);\n await ctx.reply(\"Generation error\");\n }\n});\n\nbot.on(\"message\", async (ctx) => {\n const isGroup = 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 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\n try {\n await ctx.replyWithChatAction(\"upload_photo\");\n const imageUrl = await generateImageViaPoe(prompt);\n if (imageUrl) {\n await ctx.replyWithPhoto(imageUrl, { caption: `🎨 \"${prompt}\"` });\n } else {\n await ctx.reply(\"Generation failed. All image bots unavailable.\");\n }\n } catch (error) {\n console.error(\"Auto image error:\", error);\n await ctx.reply(\"Use /image \");\n }\n return;\n }\n\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 imageData = await downloadFile(largestPhoto.file_id);\n const base64 = btoa(String.fromCharCode(...imageData));\n const prompt = messageText || \"Describe this image in detail.\";\n\n console.log(`Image size: ${imageData.length} bytes, prompt: ${prompt}`);\n\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\n if (document) {\n try {\n await ctx.replyWithChatAction(\"typing\");\n const fileName = document.file_name || \"document\";\n console.log(`Processing document: ${fileName}, size: ${document.file_size} bytes`);\n\n // Check file size (Telegram limit is typically 20MB)\n if (document.file_size && document.file_size > 20 * 1024 * 1024) {\n return ctx.reply(\"❌ File too large. Maximum size: 20MB\");\n }\n\n const fileData = await downloadFile(document.file_id);\n const base64 = btoa(String.fromCharCode(...fileData));\n const prompt = messageText || \"Summarize this document.\";\n\n console.log(`Document downloaded: ${fileData.length} bytes, processing with prompt: \"${prompt}\"`);\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(`❌ Document processing failed: ${error instanceof Error ? error.message : 'Unknown error'}`);\n }\n return;\n }\n});\n\nbot.catch((err) => {\n console.error(\"Bot error:\", err);\n});\n\nconst SECRET_TOKEN = Deno.env.get(\"OPENROUTER_API_KEY\") || crypto.randomUUID();\nconst handleUpdate = webhookCallback(bot, \"std/http\", undefined, undefined, SECRET_TOKEN);\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\", { status: 200, headers: { \"content-type\": \"text/html\" } });\n};","deleted","label",[99],"permalink","https://www.val.town/x/RobooHood/Omni-Model-Telegram-01/code/main.tsx","extension","actionData","errors"]