[{"_1":2,"_220":-5,"_221":-5},"loaderData",{"_3":4,"_91":92,"_205":206},"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":43,"_98":72,"_99":100,"_101":102,"_149":150,"_182":183,"_184":185,"_191":192,"_164":-5,"_199":-5,"_200":-5,"_201":22,"_202":22,"_203":204},"handle","aibotcommander","name","Gemini-Nano-Banana-03","branchName","path","version",12,"project",{"_103":104,"_95":96,"_105":106,"_107":-5,"_108":22,"_109":110,"_111":112,"_113":114,"_14":115,"_116":-5,"_117":22,"_118":-5,"_119":32,"_16":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":130,"_133":134,"_136":137,"_148":22},"id","dee915b0-92f1-11f0-9744-0224a6c84d84","createdAt",["D",1758022797292],"deletedAt","legacyEnvVars","privacy","public","description","Generate beautifull images: https://poe.com/Gemini-Nano-Banana ","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/a768be3e-d743-45e3-cd9c-fbd1645e3800/square512","01993890-bc39-742c-bff5-53031d93b2cb","pinnedFileId","pinPreview","screenshotVersion","likeCount","01993890-bc39-742c-bff5-540390ef48e8","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_131":132},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/baf83437-f54d-463b-0a82-08c06fd5c400/square512","org",{"_93":94,"_135":132},"avatar","branch",{"_99":138,"_95":43,"_103":139,"_140":104,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":96,"_147":94},16,"deec200c-92f1-11f0-9744-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[151,172],{"_103":152,"_95":153,"_154":155,"_156":-5,"_157":139,"_158":159,"_160":161,"_105":162,"_99":32,"_163":164,"_165":166,"_167":22,"_168":-5,"_169":170,"_98":171},"def15374-92f1-11f0-9744-0224a6c84d84","README.md","fileId","01995253-0826-7686-9f90-627ecacbe5a1","parentId","branchId","branchVersion",1,"latest",true,["D",1758022797292],"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],{"_103":173,"_95":174,"_154":175,"_156":-5,"_157":139,"_158":100,"_160":22,"_105":176,"_99":177,"_163":178,"_165":179,"_167":22,"_168":-5,"_169":180,"_98":181},"edd55412-93ff-11f0-afef-0224a6c84d84","main.tsx","01995253-0826-7686-9f90-664f129142a2",["D",1758138786449],11,"http","import process from \"node:process\";\nimport { OpenAI } from \"npm:openai\";\nconst BASE_COST = 200; \nconst IMAGE_COST = 500;\n\ninterface ModelConfig {\n provider: \"google\" | \"openrouter\";\n model: string;\n endpoint: string;\n headers: Record;\n}\n\nconst IMAGE_MODEL: ModelConfig = {\n provider: \"google\",\n model: \"gemini-2.5-flash-image-preview\",\n endpoint:\n \"https://generativelanguage.googleapis.com/v1beta/models/gemini-2.5-flash-image-preview:generateContent\",\n headers: {\n \"Content-Type\": \"application/json\",\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\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 extractImageUrl(content: string): string | null {\n // Extract URLs from POE response\n const urlMatch = content.match(/https?:\\/\\/[^\\s]+\\.(jpg|jpeg|png|gif|webp)/i);\n if (urlMatch) return urlMatch[0];\n \n // Extract markdown image format\n const mdMatch = content.match(/!\\[.*?\\]\\((https?:\\/\\/[^\\)]+)\\)/);\n if (mdMatch) return mdMatch[1];\n \n // Extract any URL in the response\n const anyUrlMatch = content.match(/https?:\\/\\/[^\\s\\)]+/);\n return anyUrlMatch ? anyUrlMatch[0] : null;\n}\n\nasync function generateImageWithPoe(\n prompt: string,\n send: SendEventFn\n): Promise {\n let lastError = null;\n \n for (let i = 0; i < POE_API_KEYS.length; i++) {\n const apiKey = POE_API_KEYS[i];\n const keyNumber = i + 1;\n \n try {\n console.log(`Attempting Poe image generation with API key ${keyNumber}`);\n \n const poeClient = createPoeClient(apiKey);\n const imagePrompt = `Generate high-quality image: ${prompt}`;\n \n const chat = await poeClient.chat.completions.create({\n model: \"FLUX-schnell-DI\",\n messages: [{ role: \"user\", content: imagePrompt }],\n max_tokens: 1024,\n temperature: 0.8,\n });\n\n const content = chat.choices[0]?.message?.content;\n \n if (content) {\n const imageUrl = extractImageUrl(content);\n \n if (imageUrl) {\n send(\"text\", { \n text: `🎨 **Image Generated Successfully!**\\n\\n![Generated Image](${imageUrl})*` \n });\n return;\n } else {\n // If no URL found, send the content as-is (might contain image data or instructions)\n send(\"text\", { \n text: `🎨 **Image Generated!**\\n\\n${content}` \n });\n return;\n }\n } else {\n throw new Error(`No content received ${keyNumber}`);\n }\n \n } catch (error) {\n lastError = error;\n console.error(`API key ${keyNumber} failed:`, error.message);\n \n if (i < POE_API_KEYS.length - 1) {\n console.log(`Trying next API key (${keyNumber + 1})`);\n continue;\n }\n }\n }\n \n console.error(\"All API keys failed:\", lastError);\n send(\"error\", { \n text: `Image generation failed: All POE API keys exhausted. Last error: ${lastError?.message || 'Unknown error'}. Please try a different prompt.`, \n allow_retry: true \n });\n}\n\nasync function generateWithOpenRouter(\n prompt: string,\n send: SendEventFn\n): Promise {\n try {\n const response = await fetch(\"https://openrouter.ai/api/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${process.env.OPENROUTER_API_KEY}`,\n \"Content-Type\": \"application/json\",\n \"HTTP-Referer\": \"https://poe.com/Gemini-Nano-Banana\",\n \"X-Title\": \"Gemini-Nano-Banana\"\n },\n body: JSON.stringify({\n model: \"google/gemini-2.5-flash-image-preview\",\n messages: [\n {\n role: \"user\",\n content: prompt\n }\n ],\n max_tokens: 1024\n })\n });\n\n if (!response.ok) {\n throw new Error(`OpenRouter API error: ${response.status}`);\n }\n\n const result = await response.json();\n const content = result.choices?.[0]?.message?.content;\n \n if (content) {\n const imageUrl = extractImageUrl(content);\n \n if (imageUrl) {\n send(\"text\", { \n text: `🎨 **Image Generated Successfully!**\\n\\n![Generated Image](${imageUrl})\\n\\n*Generated using Flux 1.1 Pro via OpenRouter*` \n });\n } else {\n send(\"text\", { \n text: `🎨 **Image Generated!**\\n\\n${content}\\n\\n*Generated using Flux 1.1 Pro via OpenRouter*` \n });\n }\n } else {\n throw new Error(\"No content received from OpenRouter\");\n }\n \n } catch (error) {\n console.error(\"OpenRouter generation failed:\", error);\n throw error;\n }\n}\n\nasync function generateImage(\n prompt: string,\n send: SendEventFn\n): Promise {\n try {\n // First try OpenRouter with Flux model if available\n if (process.env.OPENROUTER_API_KEY) {\n try {\n await generateWithOpenRouter(prompt, send);\n return;\n } catch (error) {\n console.warn(\"OpenRouter failed, trying Gemini:\", error.message);\n }\n }\n \n // Try Gemini\n const imagePrompt = `Detailed image: ${prompt}.`;\n \n const payload = {\n contents: [{\n role: \"user\",\n parts: [{ text: imagePrompt }]\n }],\n generationConfig: {\n temperature: 0.8,\n maxOutputTokens: 1024,\n candidateCount: 1\n }\n };\n\n const url = `${IMAGE_MODEL.endpoint}?key=${process.env.GEMINI_API_KEY}`;\n \n const response = await fetch(url, {\n method: \"POST\",\n headers: IMAGE_MODEL.headers,\n body: JSON.stringify(payload),\n });\n\n if (!response.ok) {\n console.warn(\"Gemini image generation failed\");\n await generateImageWithPoe(prompt, send);\n return;\n }\n\n const result = await response.json();\n const generatedContent = result.candidates?.[0]?.content?.parts?.[0]?.text;\n \n if (generatedContent) {\n const imageUrl = extractImageUrl(generatedContent);\n \n if (imageUrl) {\n send(\"text\", { \n text: `🎨 **Image Generated Successfully!**\\n\\n![Generated Image](${imageUrl})\\n\\n*Generated using Gemini-2.5-Flash-Image-Preview*` \n });\n } else {\n send(\"text\", { \n text: `🎨 **Image Generated!**\\n\\n${generatedContent}\\n\\n*Generated using Gemini-2.5-Flash-Image-Preview*` \n });\n }\n } else {\n console.warn(\"No content from Gemini\");\n await generateImageWithPoe(prompt, send);\n }\n \n } catch (error) {\n console.error(\"Primary image generation error:\", error);\n console.warn(\"Attempting Poe fallback\");\n await generateImageWithPoe(prompt, send);\n }\n}\n\nasync function getResponse(req: Query, send: SendEventFn) {\n send(\"meta\", { content_type: \"text/markdown\" });\n\n if (\n req.query &&\n req.query.some((msg) => msg.attachments && msg.attachments.length > 0)\n ) {\n send(\"error\", {\n text:\n \"File uploads are not supported. Please send your message as text only.\",\n allow_retry: false,\n });\n send(\"done\", {});\n return;\n }\n\n const messages = req.query.map((msg) => {\n if (msg.attachments && msg.attachments.length > 0) {\n return null;\n }\n\n return {\n role: msg.role === \"bot\"\n ? \"assistant\"\n : msg.role as \"user\" | \"assistant\" | \"system\",\n content: msg.content,\n };\n }).filter(Boolean) as Array<{ role: string; content: string }>;\n\n const lastUserMessage = messages.filter((m) => m.role === \"user\").pop();\n if (!lastUserMessage) {\n await generateImage(\"Welcome! I'm an image generation bot. Here's a beautiful sunset landscape to start.\", send);\n send(\"done\", {});\n return;\n }\n\n const userContent = lastUserMessage.content;\n\n if (!userContent || userContent.trim().length === 0) {\n send(\"error\", {\n text: \"Please provide a description for the image you'd like me to generate.\",\n allow_retry: false,\n });\n send(\"done\", {});\n return;\n }\n\n await generateImage(userContent, send);\n send(\"done\", {});\n}\n\nasync function getBotSettings(): Promise {\n const rateCard = \"| Type | Price |\\n\" + \"|------|------|\\n\" +\n `| Image Generation | ${IMAGE_COST} points |\\n`;\n const costLabel = `${IMAGE_COST} points`;\n\n return {\n allow_attachments: false,\n expand_text_attachments: false,\n enable_multi_bot_chat_prompting: true,\n rate_card: rateCard,\n cost_label: costLabel,\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 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: { \"Content-Type\": \"application/json\" },\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) => console.error(\"get response error\", e))\n .finally(() => controller.close());\n },\n });\n\n return new Response(body, {\n status: 200,\n headers: { \"Content-Type\": \"text/event-stream\" },\n });\n}",[],[174],"files",[151,172],"counts",{"_186":32,"_187":159,"_188":159,"_189":190},"pulls","branches","forks","envVars",8,"contents",[193,196],{"_103":152,"_95":153,"_154":155,"_156":-5,"_157":139,"_158":159,"_160":161,"_105":194,"_99":32,"_163":164,"_165":166,"_167":22,"_168":-5,"_98":195},["D",1758022797292],[153],{"_103":173,"_95":174,"_154":175,"_156":-5,"_157":139,"_158":100,"_160":22,"_105":197,"_99":177,"_163":178,"_165":179,"_167":22,"_168":-5,"_98":198},["D",1758138786449],[174],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_101":207,"_99":100,"_212":213},{"_103":104,"_95":96,"_105":208,"_107":-5,"_108":22,"_109":110,"_111":112,"_113":114,"_14":115,"_116":-5,"_117":22,"_118":-5,"_119":32,"_16":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":209,"_133":210,"_136":211,"_148":22},["D",1758022797292],{"_93":94,"_131":132},{"_93":94,"_135":132},{"_99":138,"_95":43,"_103":139,"_140":104,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":96,"_147":94},"changes",[214],{"_164":215,"_217":218,"_98":174},{"_154":175,"_95":174,"_163":178,"_165":179,"_105":216,"_158":100,"_157":139},["D",1758138786449],"previous",{"_154":175,"_95":174,"_163":178,"_165":219},"import process from \"node:process\";\nimport { OpenAI } from \"npm:openai\";\nconst BASE_COST = 200; \nconst IMAGE_COST = 500;\n\ninterface ModelConfig {\n provider: \"google\" | \"openrouter\";\n model: string;\n endpoint: string;\n headers: Record;\n}\n\nconst IMAGE_MODEL: ModelConfig = {\n provider: \"google\",\n model: \"gemini-2.5-flash-image-preview\",\n endpoint:\n \"https://generativelanguage.googleapis.com/v1beta/models/gemini-2.5-flash-image-preview:generateContent\",\n headers: {\n \"Content-Type\": \"application/json\",\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\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 extractImageUrl(content: string): string | null {\n // Extract URLs from POE response\n const urlMatch = content.match(/https?:\\/\\/[^\\s]+\\.(jpg|jpeg|png|gif|webp)/i);\n if (urlMatch) return urlMatch[0];\n \n // Extract markdown image format\n const mdMatch = content.match(/!\\[.*?\\]\\((https?:\\/\\/[^\\)]+)\\)/);\n if (mdMatch) return mdMatch[1];\n \n // Extract any URL in the response\n const anyUrlMatch = content.match(/https?:\\/\\/[^\\s\\)]+/);\n return anyUrlMatch ? anyUrlMatch[0] : null;\n}\n\nasync function generateImageWithPoe(\n prompt: string,\n send: SendEventFn\n): Promise {\n let lastError = null;\n \n for (let i = 0; i < POE_API_KEYS.length; i++) {\n const apiKey = POE_API_KEYS[i];\n const keyNumber = i + 1;\n \n try {\n console.log(`Attempting Poe image generation with API key ${keyNumber}`);\n \n const poeClient = createPoeClient(apiKey);\n const imagePrompt = `Generate high-quality image: ${prompt}`;\n \n const chat = await poeClient.chat.completions.create({\n model: \"FLUX-schnell-DI\",\n messages: [{ role: \"user\", content: imagePrompt }],\n max_tokens: 1024,\n temperature: 0.8,\n });\n\n const content = chat.choices[0]?.message?.content;\n \n if (content) {\n const imageUrl = extractImageUrl(content);\n \n if (imageUrl) {\n send(\"text\", { \n text: `🎨 **Image Generated Successfully!**\\n\\n![Generated Image](${imageUrl})*` \n });\n return;\n } else {\n // If no URL found, send the content as-is (might contain image data or instructions)\n send(\"text\", { \n text: `🎨 **Image Generated!**\\n\\n${content}` \n });\n return;\n }\n } else {\n throw new Error(`No content received ${keyNumber}`);\n }\n \n } catch (error) {\n lastError = error;\n console.error(`API key ${keyNumber} failed:`, error.message);\n \n if (i < POE_API_KEYS.length - 1) {\n console.log(`Trying next API key (${keyNumber + 1})`);\n continue;\n }\n }\n }\n \n console.error(\"All API keys failed:\", lastError);\n send(\"error\", { \n text: `Image generation failed: All POE API keys exhausted. Last error: ${lastError?.message || 'Unknown error'}. Please try a different prompt.`, \n allow_retry: true \n });\n}\n\nasync function generateWithOpenRouter(\n prompt: string,\n send: SendEventFn\n): Promise {\n try {\n const response = await fetch(\"https://openrouter.ai/api/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${process.env.OPENROUTER_API_KEY}`,\n \"Content-Type\": \"application/json\",\n \"HTTP-Referer\": \"https://your-app.com\",\n \"X-Title\": \"Image Generation Bot\"\n },\n body: JSON.stringify({\n model: \"black-forest-labs/flux-1.1-pro\",\n messages: [\n {\n role: \"user\",\n content: prompt\n }\n ],\n max_tokens: 1024\n })\n });\n\n if (!response.ok) {\n throw new Error(`OpenRouter API error: ${response.status}`);\n }\n\n const result = await response.json();\n const content = result.choices?.[0]?.message?.content;\n \n if (content) {\n const imageUrl = extractImageUrl(content);\n \n if (imageUrl) {\n send(\"text\", { \n text: `🎨 **Image Generated Successfully!**\\n\\n![Generated Image](${imageUrl})\\n\\n*Generated using Flux 1.1 Pro via OpenRouter*` \n });\n } else {\n send(\"text\", { \n text: `🎨 **Image Generated!**\\n\\n${content}\\n\\n*Generated using Flux 1.1 Pro via OpenRouter*` \n });\n }\n } else {\n throw new Error(\"No content received from OpenRouter\");\n }\n \n } catch (error) {\n console.error(\"OpenRouter generation failed:\", error);\n throw error;\n }\n}\n\nasync function generateImage(\n prompt: string,\n send: SendEventFn\n): Promise {\n try {\n // First try OpenRouter with Flux model if available\n if (process.env.OPENROUTER_API_KEY) {\n try {\n await generateWithOpenRouter(prompt, send);\n return;\n } catch (error) {\n console.warn(\"OpenRouter failed, trying Gemini:\", error.message);\n }\n }\n \n // Try Gemini\n const imagePrompt = `Generate a high-quality image based on this description: ${prompt}. Create a detailed, visually appealing image that captures the essence of the request.`;\n \n const payload = {\n contents: [{\n role: \"user\",\n parts: [{ text: imagePrompt }]\n }],\n generationConfig: {\n temperature: 0.8,\n maxOutputTokens: 1024,\n candidateCount: 1\n }\n };\n\n const url = `${IMAGE_MODEL.endpoint}?key=${process.env.GEMINI_API_KEY}`;\n \n const response = await fetch(url, {\n method: \"POST\",\n headers: IMAGE_MODEL.headers,\n body: JSON.stringify(payload),\n });\n\n if (!response.ok) {\n console.warn(\"Gemini image generation failed, falling back to POE\");\n await generateImageWithPoe(prompt, send);\n return;\n }\n\n const result = await response.json();\n const generatedContent = result.candidates?.[0]?.content?.parts?.[0]?.text;\n \n if (generatedContent) {\n const imageUrl = extractImageUrl(generatedContent);\n \n if (imageUrl) {\n send(\"text\", { \n text: `🎨 **Image Generated Successfully!**\\n\\n![Generated Image](${imageUrl})\\n\\n*Generated using Gemini 2.5 Flash Image Preview*` \n });\n } else {\n send(\"text\", { \n text: `🎨 **Image Generated!**\\n\\n${generatedContent}\\n\\n*Generated using Gemini 2.5 Flash Image Preview*` \n });\n }\n } else {\n console.warn(\"No content from Gemini, falling back to POE\");\n await generateImageWithPoe(prompt, send);\n }\n \n } catch (error) {\n console.error(\"Primary image generation error:\", error);\n console.warn(\"Attempting Poe fallback\");\n await generateImageWithPoe(prompt, send);\n }\n}\n\nasync function getResponse(req: Query, send: SendEventFn) {\n send(\"meta\", { content_type: \"text/markdown\" });\n\n if (\n req.query &&\n req.query.some((msg) => msg.attachments && msg.attachments.length > 0)\n ) {\n send(\"error\", {\n text:\n \"File uploads are not supported. Please send your message as text only.\",\n allow_retry: false,\n });\n send(\"done\", {});\n return;\n }\n\n const messages = req.query.map((msg) => {\n if (msg.attachments && msg.attachments.length > 0) {\n return null;\n }\n\n return {\n role: msg.role === \"bot\"\n ? \"assistant\"\n : msg.role as \"user\" | \"assistant\" | \"system\",\n content: msg.content,\n };\n }).filter(Boolean) as Array<{ role: string; content: string }>;\n\n const lastUserMessage = messages.filter((m) => m.role === \"user\").pop();\n if (!lastUserMessage) {\n await generateImage(\"Welcome! I'm an image generation bot. Here's a beautiful sunset landscape to start.\", send);\n send(\"done\", {});\n return;\n }\n\n const userContent = lastUserMessage.content;\n\n if (!userContent || userContent.trim().length === 0) {\n send(\"error\", {\n text: \"Please provide a description for the image you'd like me to generate.\",\n allow_retry: false,\n });\n send(\"done\", {});\n return;\n }\n\n await generateImage(userContent, send);\n send(\"done\", {});\n}\n\nasync function getBotSettings(): Promise {\n const rateCard = \"| Type | Price |\\n\" + \"|------|------|\\n\" +\n `| Image Generation | ${IMAGE_COST} points |\\n`;\n const costLabel = `${IMAGE_COST} points`;\n\n return {\n allow_attachments: false,\n expand_text_attachments: false,\n enable_multi_bot_chat_prompting: true,\n rate_card: rateCard,\n cost_label: costLabel,\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 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: { \"Content-Type\": \"application/json\" },\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) => console.error(\"get response error\", e))\n .finally(() => controller.close());\n },\n });\n\n return new Response(body, {\n status: 200,\n headers: { \"Content-Type\": \"text/event-stream\" },\n });\n}","actionData","errors"]