[{"_1":2,"_234":-5,"_235":-5},"loaderData",{"_3":4,"_91":92,"_217":218},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":22,"_29":22,"_30":22,"_31":32,"_33":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","notificationCount",0,"flagDenols","ENV",{"_36":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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","86c278eb598060f33e9f047762b0f599ada2ba10","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",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":22,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":22,"_90":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",{"_81":22,"_21":22,"_82":72,"_83":84,"_85":72,"_86":45,"_87":22,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_93":94,"_95":96,"_97":-7,"_98":72,"_99":-7,"_100":101,"_149":150,"_182":183,"_184":185,"_191":192,"_164":-5,"_199":200,"_204":205,"_213":22,"_214":22,"_215":216},"handle","MadeiInGermany","name","Sonoma-Omni","branchName","path","version","project",{"_102":103,"_95":96,"_104":105,"_106":-5,"_107":22,"_108":109,"_110":-5,"_111":-5,"_14":112,"_113":-5,"_114":22,"_115":-5,"_116":32,"_16":117,"_118":119,"_120":119,"_121":122,"_123":122,"_124":122,"_125":119,"_126":119,"_23":127,"_130":131,"_133":134,"_148":22},"id","c73624fe-949e-11f0-b426-0224a6c84d84","createdAt",["D",1758207011633],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","01995b22-1b41-771e-a0ac-a4cfc92d3606","pinnedFileId","pinPreview","screenshotVersion","likeCount","01995b22-1b41-771e-a0ac-a96f3508eae1","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_128":129},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/0d36b22b-1313-4153-e173-746bdb12a000/square512","org",{"_93":94,"_132":129},"avatar","branch",{"_99":135,"_95":43,"_102":136,"_137":103,"_138":139,"_140":141,"_142":109,"_143":144,"_145":117,"_146":96,"_147":94},11,"c73b50fa-949e-11f0-b426-0224a6c84d84","projectId","forkedBranchId","8d3735f4-9453-11f0-8351-0224a6c84d84","forkedBranchVersion",12,"forkedProjectPrivacy","forkedProjectId","8d334d4a-9453-11f0-8351-0224a6c84d84","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[151,172],{"_102":152,"_95":153,"_154":155,"_156":-5,"_157":136,"_158":159,"_160":161,"_104":162,"_99":32,"_163":164,"_165":166,"_167":22,"_168":-5,"_169":170,"_98":171},"c7415752-949e-11f0-b426-0224a6c84d84","README.md","fileId","01995d4d-eb76-7559-9dd7-00204d708ce4","parentId","branchId","branchVersion",1,"latest",true,["D",1758207011633],"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",[],[153],{"_102":173,"_95":174,"_154":175,"_156":-5,"_157":136,"_158":135,"_160":161,"_104":176,"_99":177,"_163":178,"_165":179,"_167":22,"_168":-5,"_169":180,"_98":181},"5a613600-94a5-11f0-9d2b-0224a6c84d84","main.tsx","01995d4d-eb76-7559-9dd7-04b69055f3da",["D",1758209835505],10,"http","import process from \"node:process\";\nimport { OpenAI } from \"npm:openai\";\n\nconst IMAGE_COST = 400;\nconst TEXT_COST = 400;\nconst FILE_ANALYSIS_COST = 400;\nconst SEARCH_COST = 400;\n\nconst BOT_ACCESS_KEY = process.env.BOT_ACCESS_KEY;\n\ninterface ModelConfig {\n provider: \"google\" | \"poe\" | \"openrouter\";\n model: string;\n endpoint: string;\n headers: Record;\n}\n\nconst SONOMA_DUSK_CONFIG: ModelConfig = {\n provider: \"poe\",\n model: \"Sonoma-Dusk-Alpha\",\n endpoint: \"https://api.poe.com/v1\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n};\n\nconst SONOMA_SKY_CONFIG: ModelConfig = {\n provider: \"poe\",\n model: \"Sonoma-Sky-Alpha\",\n endpoint: \"https://api.poe.com/v1\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n};\n\nconst GROQ_LLAMA_CONFIG: ModelConfig = {\n provider: \"openrouter\",\n model: \"meta-llama/llama-3.2-90b-vision-instruct\",\n endpoint: \"https://openrouter.ai/api/v1\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n};\n\nconst GROQ_MIXTRAL_CONFIG: ModelConfig = {\n provider: \"openrouter\",\n model: \"mistralai/mixtral-8x7b-instruct\",\n endpoint: \"https://openrouter.ai/api/v1\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n};\n\nconst POE_MODELS = {\n imageGeneration: [\n \"Flux-schnell\",\n \"Flux-schnell-DI\",\n \"ImageCreatorSD\",\n \"Free-GPT-Image-1\",\n ],\n textGeneration: [\n \"Sonoma-Dusk-Alpha\",\n \"Sonoma-Sky-Alpha\",\n \"Qwen3-235B-A22B\",\n \"Gemini-1.5-Flash\",\n \"Llama-3.1-8b-DI\",\n ],\n claudeSpecific: [\n \"Free-claude-sonnet-4\",\n \"Free-Claude-Opus-4.1\",\n ],\n fileAnalysis: [\n \"Sonoma-Dusk-Alpha\",\n \"Sonoma-Sky-Alpha\",\n \"Qwen3-235B-A22B\",\n \"Gemini-1.5-Flash\",\n ],\n imageAnalysis: [\n \"Sonoma-Dusk-Alpha\",\n \"Sonoma-Sky-Alpha\",\n \"Llama-3.1-8b-DI\",\n \"Qwen3-235B-A22B\",\n ],\n search: [\n \"Sonoma-Sky-Alpha\",\n \"Gemini-1.5-Flash-Search\",\n \"Multi-Web-Search\",\n \"Compound-Mini\",\n ],\n};\n\nconst OPENROUTER_MODELS = {\n textGeneration: [\n \"meta-llama/llama-3.2-90b-vision-instruct\",\n \"mistralai/mixtral-8x7b-instruct\",\n \"meta-llama/llama-3.1-70b-instruct\",\n ],\n fileAnalysis: [\n \"meta-llama/llama-3.2-90b-vision-instruct\",\n \"mistralai/mixtral-8x7b-instruct\",\n ],\n imageAnalysis: [\n \"meta-llama/llama-3.2-90b-vision-instruct\",\n ],\n};\n\nconst POE_API_KEYS = [\n process.env.POE_API_KEY,\n process.env.POE_API_KEY2,\n process.env.POE_API_KEY3,\n].filter(Boolean);\n\nconst OPENROUTER_API_KEY = process.env.OPENROUTER_API_KEY;\n\nfunction authenticateRequest(\n req: Request,\n): { isValid: boolean; error?: string } {\n if (!BOT_ACCESS_KEY) {\n console.warn(\"Warning: BOT_ACCESS_KEY is not set in environment variables\");\n return { isValid: true };\n }\n\n const providedKey =\n req.headers.get(\"Authorization\")?.replace(\"Bearer \", \"\") ||\n req.headers.get(\"X-API-Key\") ||\n req.headers.get(\"X-Bot-Access-Key\");\n\n if (!providedKey) {\n return {\n isValid: false,\n error:\n \"Missing authentication. Please provide BOT_ACCESS_KEY in Authorization header, X-API-Key header, or X-Bot-Access-Key header.\",\n };\n }\n\n if (providedKey !== BOT_ACCESS_KEY) {\n return {\n isValid: false,\n error: \"Invalid BOT_ACCESS_KEY. Access denied.\",\n };\n }\n\n return { isValid: true };\n}\n\nfunction createPoeClient(apiKey: string): OpenAI {\n return new OpenAI({\n apiKey: apiKey || \"YOUR_POE_API_KEY\",\n baseURL: \"https://api.poe.com/v1\",\n });\n}\n\nfunction createOpenRouterClient(): OpenAI {\n return new OpenAI({\n apiKey: OPENROUTER_API_KEY || \"YOUR_OPENROUTER_API_KEY\",\n baseURL: \"https://openrouter.ai/api/v1\",\n });\n}\n\nfunction selectOptimalTokens(contentLength: number, taskType: string): number {\n if (taskType === \"Image Generation\") return 1024;\n if (contentLength < 100) return 1024;\n if (contentLength < 500) return 1500;\n return 2048;\n}\n\nasync function callSinglePoeModel(\n model: string,\n prompt: string,\n apiKeyIndex: number,\n taskType: string,\n timeout: number = 15000,\n isImageGeneration: boolean = false,\n): Promise {\n try {\n const apiKey = POE_API_KEYS[apiKeyIndex];\n const poeClient = createPoeClient(apiKey);\n const maxTokens = selectOptimalTokens(prompt.length, taskType);\n\n const chatPromise = poeClient.chat.completions.create({\n model: model,\n messages: [{ role: \"user\", content: prompt }],\n max_tokens: maxTokens,\n temperature: 0.8,\n });\n\n const timeoutPromise = new Promise((_, reject) => {\n setTimeout(() => reject(new Error(\"Request timeout\")), timeout);\n });\n\n const chat = await Promise.race([chatPromise, timeoutPromise]);\n const message = chat.choices[0]?.message;\n const content = message?.content;\n\n if (\n isImageGeneration && message?.attachments &&\n message.attachments.length > 0\n ) {\n const imageAttachment = message.attachments.find((att) =>\n att.content_type && att.content_type.startsWith(\"image/\")\n );\n if (imageAttachment && imageAttachment.url) {\n return imageAttachment.url;\n }\n }\n\n return content && content.trim().length > 0 ? content : null;\n } catch (error) {\n console.error(\n `Poe model ${model} failed with API key ${apiKeyIndex + 1}:`,\n error.message,\n );\n return null;\n }\n}\n\nasync function callSingleOpenRouterModel(\n model: string,\n prompt: string,\n taskType: string,\n timeout: number = 15000,\n): Promise {\n try {\n if (!OPENROUTER_API_KEY) {\n console.warn(\"OpenRouter API key not available\");\n return null;\n }\n\n const openRouterClient = createOpenRouterClient();\n const maxTokens = selectOptimalTokens(prompt.length, taskType);\n\n const chatPromise = openRouterClient.chat.completions.create({\n model: model,\n messages: [{ role: \"user\", content: prompt }],\n max_tokens: maxTokens,\n temperature: 0.8,\n });\n\n const timeoutPromise = new Promise((_, reject) => {\n setTimeout(() => reject(new Error(\"Request timeout\")), timeout);\n });\n\n const chat = await Promise.race([chatPromise, timeoutPromise]);\n const content = chat.choices[0]?.message?.content;\n\n return content && content.trim().length > 0 ? content : null;\n } catch (error) {\n console.error(\n `OpenRouter model ${model} failed:`,\n error.message,\n );\n return null;\n }\n}\n\nasync function callModelsWithFallback(\n poeModels: string[],\n openRouterModels: string[],\n prompt: string,\n send: SendEventFn,\n taskType: string,\n timeout: number = 15000,\n isImageGeneration: boolean = false,\n): Promise {\n const parallelModels = poeModels.slice(0, 2);\n const remainingPoeModels = poeModels.slice(2);\n\n const promises: Promise<\n { result: string | null; model: string; keyIndex: number; provider: string }\n >[] = [];\n\n for (\n let keyIndex = 0;\n keyIndex < Math.min(POE_API_KEYS.length, 2);\n keyIndex++\n ) {\n for (const model of parallelModels) {\n promises.push(\n callSinglePoeModel(\n model,\n prompt,\n keyIndex,\n taskType,\n timeout,\n isImageGeneration,\n ).then((result) => ({ result, model, keyIndex, provider: \"poe\" })),\n );\n }\n }\n\n try {\n const results = await Promise.allSettled(promises);\n const successful = results.find((r) =>\n r.status === \"fulfilled\" && r.value.result !== null\n ) as PromiseFulfilledResult<\n { result: string; model: string; keyIndex: number; provider: string }\n >;\n\n if (successful) {\n console.log(\n `Success with ${successful.value.model} (${successful.value.provider}, API key ${\n successful.value.keyIndex + 1\n })`,\n );\n\n if (isImageGeneration) {\n const urlMatch = successful.value.result.match(\n /https?:\\/\\/[^\\s]+\\.(jpg|jpeg|png|gif|webp)/i,\n );\n if (urlMatch) {\n send(\"replace_response\", {\n text: `🎨 **${taskType} completed**\\n\\n![Generated Image](${\n urlMatch[0]\n })`,\n });\n return urlMatch[0];\n } else {\n send(\"replace_response\", {\n text: `🎨 **${taskType} completed**\\n\\n${successful.value.result}`,\n });\n }\n } else {\n // For text generation, return pure AI response without status formatting\n if (taskType === \"Text Generation\") {\n send(\"replace_response\", {\n text: successful.value.result,\n });\n } else {\n // Keep status formatting for other task types (File Analysis, etc.)\n send(\"replace_response\", {\n text: `✅ **${taskType} completed**\\n\\n${successful.value.result}`,\n });\n }\n }\n return successful.value.result;\n }\n } catch (error) {\n console.error(\"Parallel Poe model execution failed:\", error);\n }\n\n if (remainingPoeModels.length > 0) {\n console.log(\"Trying remaining Poe models sequentially...\");\n for (const model of remainingPoeModels) {\n for (let keyIndex = 0; keyIndex < POE_API_KEYS.length; keyIndex++) {\n const result = await callSinglePoeModel(\n model,\n prompt,\n keyIndex,\n taskType,\n timeout,\n isImageGeneration,\n );\n if (result) {\n console.log(`Success with ${model} (poe, API key ${keyIndex + 1})`);\n if (isImageGeneration) {\n const urlMatch = result.match(\n /https?:\\/\\/[^\\s]+\\.(jpg|jpeg|png|gif|webp)/i,\n );\n if (urlMatch) {\n send(\"replace_response\", {\n text: `🎨 **${taskType} completed**\\n\\n![Generated Image](${\n urlMatch[0]\n })`,\n });\n return urlMatch[0];\n } else {\n send(\"replace_response\", {\n text: `🎨 **${taskType} completed**\\n\\n${result}`,\n });\n }\n } else {\n // For text generation, return pure AI response without status formatting\n if (taskType === \"Text Generation\") {\n send(\"replace_response\", {\n text: result,\n });\n } else {\n // Keep status formatting for other task types\n send(\"replace_response\", {\n text: `✅ **${taskType} completed**\\n\\n${result}`,\n });\n }\n }\n return result;\n }\n }\n }\n }\n\n if (!isImageGeneration && openRouterModels.length > 0) {\n console.log(\"Falling back to OpenRouter Groq models...\");\n for (const model of openRouterModels) {\n const result = await callSingleOpenRouterModel(\n model,\n prompt,\n taskType,\n timeout,\n );\n if (result) {\n console.log(`Success with ${model} (openrouter groq)`);\n // For text generation, return pure AI response without status formatting\n if (taskType === \"Text Generation\") {\n send(\"replace_response\", {\n text: result,\n });\n } else {\n // Keep status formatting for other task types\n send(\"replace_response\", {\n text: `✅ **${taskType} completed (OpenRouter)**\\n\\n${result}`,\n });\n }\n return result;\n }\n }\n }\n\n return null;\n}\n\nasync function imageToBase64(\n imageUrl: string,\n): Promise<{ data: string; mimeType: string }> {\n try {\n const response = await fetch(imageUrl, { timeout: 8000 });\n if (!response.ok) {\n throw new Error(`Failed to fetch image: ${response.status}`);\n }\n\n const arrayBuffer = await response.arrayBuffer();\n const buffer = Buffer.from(arrayBuffer);\n const mimeType = response.headers.get(\"content-type\") || \"image/jpeg\";\n\n return {\n data: buffer.toString(\"base64\"),\n mimeType: mimeType,\n };\n } catch (error) {\n console.error(\"Error converting image to base64:\", error);\n throw error;\n }\n}\n\nasync function generateImage(prompt: string, send: SendEventFn): Promise {\n let cleanPrompt = prompt;\n if (cleanPrompt.endsWith(\"--image\")) {\n cleanPrompt = cleanPrompt.substring(0, cleanPrompt.length - 7).trim();\n }\n\n const imagePrompt = `Detailed ${cleanPrompt}`;\n\n send(\"text\", { text: `🎨 Generating image...` });\n\n const result = await callModelsWithFallback(\n POE_MODELS.imageGeneration,\n [],\n imagePrompt,\n send,\n \"Image Generation\",\n 15000,\n true,\n );\n\n if (!result) {\n send(\"error\", {\n text: `❌ Image generation failed: All models exhausted.`,\n allow_retry: true,\n });\n }\n}\n\nasync function generateText(\n prompt: string,\n send: SendEventFn,\n useClaudeModels: boolean = false,\n): Promise {\n send(\"text\", { text: `💬 Thinking...` });\n\n const models = useClaudeModels\n ? POE_MODELS.claudeSpecific\n : POE_MODELS.textGeneration;\n const fallbackModels = useClaudeModels\n ? []\n : OPENROUTER_MODELS.textGeneration;\n\n const result = await callModelsWithFallback(\n models,\n fallbackModels,\n prompt,\n send,\n \"Text Generation\",\n 15000,\n );\n\n if (!result) {\n send(\"error\", {\n text: `❌ Text generation failed: All models exhausted.`,\n allow_retry: true,\n });\n }\n}\n\nasync function analyzeFile(\n fileContent: string,\n fileName: string,\n userPrompt: string,\n send: SendEventFn,\n): Promise {\n if (!fileContent || fileContent.trim().length === 0) {\n send(\"error\", {\n text:\n `❌ File analysis failed: No content found in ${fileName}. Please ensure the file is not empty and is in a supported format.`,\n allow_retry: true,\n });\n return;\n }\n\n const maxContentLength = 8000;\n let processedContent = fileContent;\n if (fileContent.length > maxContentLength) {\n processedContent = fileContent.substring(0, maxContentLength) +\n \"\\n\\n[Content truncated for analysis...]\";\n }\n\n let analysisPrompt: string;\n if (!userPrompt || userPrompt.trim().length === 0) {\n analysisPrompt =\n `Analyze file (${fileName}). Provide key insights and summary:\\n\\n${processedContent}`;\n } else {\n analysisPrompt =\n `${userPrompt}\\n\\nFile (${fileName}):\\n${processedContent}`;\n }\n\n send(\"text\", { text: `📄 Processing file: ${fileName}...` });\n\n const result = await callModelsWithFallback(\n POE_MODELS.fileAnalysis,\n OPENROUTER_MODELS.fileAnalysis,\n analysisPrompt,\n send,\n \"File Analysis\",\n 20000,\n );\n\n if (!result) {\n send(\"error\", {\n text: `❌ File analysis failed: All models exhausted.`,\n allow_retry: true,\n });\n }\n}\n\nasync function analyzeImage(\n imageUrl: string,\n userPrompt: string,\n send: SendEventFn,\n): Promise {\n let analysisPrompt: string;\n if (!userPrompt || userPrompt.trim().length === 0) {\n analysisPrompt = `Provide detailed analysis of this image`;\n } else {\n analysisPrompt = `${userPrompt}`;\n }\n\n send(\"text\", { text: `🔍 Analyzing image...` });\n\n const imageAnalysisPrompt =\n `Analyze image: ${imageUrl}\\n\\nUser's request: ${analysisPrompt}`;\n\n const result = await callModelsWithFallback(\n POE_MODELS.imageAnalysis,\n OPENROUTER_MODELS.imageAnalysis,\n imageAnalysisPrompt,\n send,\n \"Image Analysis\",\n 15000,\n );\n\n if (!result) {\n send(\"error\", {\n text: `❌ Image analysis failed: All models exhausted.`,\n allow_retry: true,\n });\n }\n}\n\nasync function performSearch(query: string, send: SendEventFn): Promise {\n const searchPrompt = `Search current information about: ${query}`;\n\n send(\"text\", { text: `🔍 Searching the web: ${query}...` });\n\n const result = await callModelsWithFallback(\n POE_MODELS.search,\n [],\n searchPrompt,\n send,\n \"Web Search\",\n 15000,\n );\n\n if (!result) {\n send(\"error\", {\n text: `❌ Search failed: All models exhausted.`,\n allow_retry: true,\n });\n }\n}\n\nfunction detectIntent(\n content: string,\n hasAttachments: boolean,\n): { intent: string; useClaudeModels: boolean } {\n const lowerContent = content.toLowerCase();\n let useClaudeModels = false;\n\n if (content.endsWith(\"--claude\") || content.endsWith(\"--opus\")) {\n useClaudeModels = true;\n }\n\n let cleanContent = content;\n if (cleanContent.endsWith(\"--claude\")) {\n cleanContent = cleanContent.substring(0, cleanContent.length - 8).trim();\n } else if (cleanContent.endsWith(\"--opus\")) {\n cleanContent = cleanContent.substring(0, cleanContent.length - 6).trim();\n }\n\n if (cleanContent.endsWith(\"--image\")) {\n return { intent: \"image_generation\", useClaudeModels };\n }\n\n if (\n cleanContent.startsWith(\"search for \") ||\n cleanContent.endsWith(\"--search\")\n ) {\n return { intent: \"search\", useClaudeModels };\n }\n\n if (hasAttachments) {\n if (\n lowerContent.includes(\"image\") ||\n lowerContent.includes(\"picture\") ||\n lowerContent.includes(\"photo\") ||\n lowerContent.includes(\"analyze\") ||\n lowerContent.includes(\"what\") ||\n lowerContent.includes(\"describe\")\n ) {\n return { intent: \"image_analysis\", useClaudeModels };\n }\n return { intent: \"file_analysis\", useClaudeModels };\n }\n\n if (\n lowerContent.includes(\"generate image\") ||\n lowerContent.includes(\"create image\") ||\n lowerContent.includes(\"draw\") ||\n lowerContent.includes(\"picture of\") ||\n lowerContent.includes(\"image of\")\n ) {\n return { intent: \"image_generation\", useClaudeModels };\n }\n\n if (\n lowerContent.includes(\"search\") ||\n lowerContent.includes(\"find information\") ||\n lowerContent.includes(\"look up\") ||\n lowerContent.includes(\"what is\") ||\n lowerContent.includes(\"do a search\")\n ) {\n return { intent: \"search\", useClaudeModels };\n }\n\n return { intent: \"text_generation\", useClaudeModels };\n}\n\nasync function getResponse(req: Query, send: SendEventFn) {\n send(\"meta\", { content_type: \"text/markdown\" });\n\n const messages = req.query.map((msg) => ({\n role: msg.role === \"bot\"\n ? \"assistant\"\n : msg.role as \"user\" | \"assistant\" | \"system\",\n content: msg.content,\n attachments: msg.attachments || [],\n }));\n\n const lastUserMessage = messages.filter((m) => m.role === \"user\").pop();\n\n if (!lastUserMessage) {\n send(\"text\", { text: \"👋 What would you like to do today?\" });\n send(\"done\", {});\n return;\n }\n\n const userContent = lastUserMessage.content;\n const attachments = lastUserMessage.attachments || [];\n\n const { intent, useClaudeModels } = detectIntent(\n userContent,\n attachments.length > 0,\n );\n\n try {\n switch (intent) {\n case \"image_generation\":\n await generateImage(userContent, send);\n break;\n\n case \"file_analysis\":\n if (attachments.length > 0) {\n const file = attachments[0];\n if (file.content_type && file.content_type.startsWith(\"video/\")) {\n send(\"error\", {\n text: \"Video files are not supported yet.\",\n allow_retry: false,\n });\n break;\n }\n\n let fileContent = file.parsed_content;\n if (!fileContent && file.name) {\n fileContent =\n `File: ${file.name} (${file.content_type})\\nFile URL: ${file.url}\\n\\nNote: Content could not be extracted. Please describe what you'd like to know about this file.`;\n }\n\n if (!fileContent || fileContent.trim().length === 0) {\n send(\"error\", {\n text:\n `❌ Could not extract content from ${file.name}. Please ensure the file is in a supported format and not corrupted.`,\n allow_retry: true,\n });\n break;\n }\n\n await analyzeFile(fileContent, file.name, userContent, send);\n } else {\n send(\"error\", {\n text: \"Please attach a file for analysis.\",\n allow_retry: false,\n });\n }\n break;\n\n case \"image_analysis\":\n if (attachments.length > 0) {\n const imageAttachment = attachments.find((att) =>\n att.content_type && att.content_type.startsWith(\"image/\")\n );\n if (imageAttachment && imageAttachment.url) {\n await analyzeImage(imageAttachment.url, userContent, send);\n } else {\n send(\"error\", {\n text: \"This file type is not supported.\",\n allow_retry: false,\n });\n }\n } else {\n send(\"error\", {\n text: \"Please attach an image for analysis.\",\n allow_retry: false,\n });\n }\n break;\n\n case \"search\":\n let cleanQuery = userContent;\n if (cleanQuery.startsWith(\"search the web \")) {\n cleanQuery = cleanQuery.substring(15).trim();\n }\n if (cleanQuery.endsWith(\"--search\")) {\n cleanQuery = cleanQuery.substring(0, cleanQuery.length - 8).trim();\n }\n if (cleanQuery.endsWith(\"--claude\")) {\n cleanQuery = cleanQuery.substring(0, cleanQuery.length - 8).trim();\n } else if (cleanQuery.endsWith(\"--opus\")) {\n cleanQuery = cleanQuery.substring(0, cleanQuery.length - 6).trim();\n }\n await performSearch(cleanQuery || userContent, send);\n break;\n\n case \"text_generation\":\n default:\n let cleanPrompt = userContent;\n if (cleanPrompt.endsWith(\"--claude\")) {\n cleanPrompt = cleanPrompt.substring(0, cleanPrompt.length - 8).trim();\n } else if (cleanPrompt.endsWith(\"--opus\")) {\n cleanPrompt = cleanPrompt.substring(0, cleanPrompt.length - 6).trim();\n }\n await generateText(cleanPrompt, send, useClaudeModels);\n break;\n }\n } catch (error) {\n console.error(\"Error in getResponse:\", error);\n send(\"error\", {\n text: `An unexpected error occurred: ${error.message}. Please try again.`,\n allow_retry: true,\n });\n }\n\n send(\"done\", {});\n}\n\nasync function getBotSettings(): Promise {\n const rateCard = \"| Type | Price |\\n\" +\n \"|-----------|-------|\\n\" +\n `| Input (image) | ${IMAGE_COST} points/message |\\n` +\n `| Input (file) | ${FILE_ANALYSIS_COST} points/message |\\n` +\n `| Input (text) | ${TEXT_COST} points/message |\\n` +\n `| Output (search) | ${SEARCH_COST} points/message |\\n` +\n `| Output (image) | ${IMAGE_COST} points/message |\\n`;\n\n return {\n allow_attachments: true,\n expand_text_attachments: true,\n enable_multi_bot_chat_prompting: true,\n rate_card: rateCard,\n cost_label: \"400 points\",\n };\n}\n\ntype BotSettings = {\n allow_attachments?: boolean;\n expand_text_attachments?: boolean;\n enable_multi_bot_chat_prompting?: boolean;\n rate_card?: string;\n cost_label?: string;\n};\n\ntype Query = {\n version: string;\n type: \"query\";\n query: {\n role: \"system\" | \"user\" | \"bot\";\n content: string;\n content_type: string;\n timestamp: number;\n message_id: string;\n feedback: {\n type: \"like\" | \"dislike\";\n reason?: string;\n }[];\n attachments: {\n url: string;\n content_type: string;\n name: string;\n parsed_content?: string;\n }[];\n }[];\n message_id: string;\n user_id: string;\n conversation_id: string;\n metadata: string;\n language_code: string;\n};\n\ntype Events = {\n meta: { content_type: string };\n text: { text: string };\n replace_response: { text: string };\n suggested_reply: { text: string };\n error: { allow_retry?: boolean; text: string };\n done: {};\n};\n\ntype SendEventFn = (\n eventName: EventName,\n data: Events[EventName],\n) => void;\n\nfunction encodeEvent(event: string, data: any = {}) {\n return new TextEncoder().encode(\n `event: ${event}\\ndata: ${JSON.stringify(data)}\\n\\n`,\n );\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"OPTIONS\") {\n const authResult = authenticateRequest(req);\n if (!authResult.isValid) {\n return new Response(\n JSON.stringify({\n error: authResult.error,\n status: \"authentication_failed\",\n }),\n {\n status: 401,\n headers: {\n \"Content-Type\": \"application/json\",\n \"WWW-Authenticate\": 'Bearer realm=\"Bot API\"',\n },\n },\n );\n }\n }\n\n const reqBody = await req.json().catch((e) => {\n console.error(\"body parse error\", e);\n return {};\n });\n\n console.log(\"body\", reqBody);\n\n if (reqBody.type === \"settings\") {\n return new Response(JSON.stringify(await getBotSettings()), {\n status: 200,\n headers: {\n \"Content-Type\": \"application/json\",\n },\n });\n }\n\n const body = new ReadableStream({\n start(controller) {\n const send = (event, data) => {\n controller.enqueue(encodeEvent(event, data));\n };\n\n return getResponse(reqBody, send)\n .catch((e) => {\n console.error(\"get response error\", e);\n send(\"error\", {\n text: `Fatal error: ${e.message}`,\n allow_retry: true,\n });\n })\n .finally(() => controller.close());\n },\n });\n\n return new Response(body, {\n status: 200,\n headers: {\n \"Content-Type\": \"text/event-stream\",\n },\n });\n}",[],[174],"files",[151,172],"counts",{"_186":32,"_187":159,"_188":159,"_189":190},"pulls","branches","forks","envVars",8,"contents",[193,196],{"_102":152,"_95":153,"_154":155,"_156":-5,"_157":136,"_158":159,"_160":161,"_104":194,"_99":32,"_163":164,"_165":166,"_167":22,"_168":-5,"_98":195},["D",1758207011633],[153],{"_102":173,"_95":174,"_154":175,"_156":-5,"_157":136,"_158":135,"_160":161,"_104":197,"_99":177,"_163":178,"_165":179,"_167":22,"_168":-5,"_98":198},["D",1758209835505],[174],"upstreamProject",{"_102":144,"_95":201,"_110":-5,"_111":202,"_108":109,"_23":203},"Gemini-2-5-Pro","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/bdedb77a-7f7c-44b4-fc84-541fa3fbd300/square512",{"_93":94,"_128":129},"upstreamBranch",{"_102":139,"_104":206,"_207":208,"_95":43,"_137":144,"_99":141,"_138":209,"_140":210,"_211":212,"_106":-5,"_148":22,"_108":109,"_147":94,"_16":117,"_146":201},["D",1758174702026],"updatedAt",["D",1758179819815],"ae50feb8-93dc-11f0-bd15-0224a6c84d84",4,"lockfileKey","1758179847408-esm.town_v_MadeiInGermany_Gemini-2-5-Pro@12-main","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.remixes",{"_93":94,"_95":96,"_100":219,"_188":224,"_231":232},{"_102":103,"_95":96,"_104":220,"_106":-5,"_107":22,"_108":109,"_110":-5,"_111":-5,"_14":112,"_113":-5,"_114":22,"_115":-5,"_116":32,"_16":117,"_118":119,"_120":119,"_121":122,"_123":122,"_124":122,"_125":119,"_126":119,"_23":221,"_130":222,"_133":223,"_148":22},["D",1758207011633],{"_93":94,"_128":129},{"_93":94,"_132":129},{"_99":135,"_95":43,"_102":136,"_137":103,"_138":139,"_140":141,"_142":109,"_143":144,"_145":117,"_146":96,"_147":94},[225],{"_102":226,"_95":227,"_110":-5,"_111":-5,"_108":109,"_14":112,"_16":117,"_148":22,"_23":228,"_130":229,"_113":-5,"_114":22,"_104":230,"_116":32},"4c087e9c-94aa-11f0-bcf9-0224a6c84d84","Veo-3-Omni",{"_93":94,"_128":129},{"_93":94,"_132":129},["D",1758211958936],"upstream",{"_102":144,"_95":201,"_110":-5,"_111":202,"_108":109,"_23":233},{"_93":94,"_128":129},"actionData","errors"]