[{"_1":2,"_181":-5,"_182":-5},"loaderData",{"_3":4,"_96":97},"root",{"_5":6,"_37":38,"_69":70},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20,"_36":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isBusinessOrgMember","isHigherTownieTier","ENV",{"_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":66,"_67":68},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","efeea19332d9bfe7de1049656877be9cb817c45f","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","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","API_URL","https://api.val.town","clerkState",{"_71":72},"__internal_clerk_state",{"_73":74,"_75":48,"_76":77,"_78":77,"_79":20,"_80":77,"_81":77,"_82":77,"_83":77,"_84":85,"_94":20,"_95":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",{"_86":20,"_19":20,"_87":77,"_88":89,"_90":77,"_91":48,"_92":20,"_93":77},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_98":99,"_100":101,"_102":103,"_104":105,"_162":163,"_178":179,"_180":-5},"handle","aibotcommander","name","Z-Image","path","main.tsx","project",{"_106":107,"_100":101,"_108":109,"_110":-5,"_111":20,"_112":113,"_114":115,"_116":117,"_12":118,"_119":120,"_121":122,"_123":-5,"_124":-5,"_125":33,"_14":126,"_127":-5,"_128":-5,"_129":-5,"_130":-5,"_131":132,"_133":132,"_134":135,"_136":135,"_137":135,"_138":132,"_139":132,"_23":140,"_143":144,"_148":149,"_161":20},"id","a7b4963a-2a88-11f1-8533-42dde27851f2","createdAt",["D",1774690184223],"deletedAt","legacyEnvVars","privacy","public","description","https://poe.com/Z-Image-LoRA","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/5d26245c-2542-454f-919c-fe5b2ed43800/square512","01993890-bc39-742c-bff5-53031d93b2cb","pinnedFileId","019d33c7-2c7b-74ea-9e3e-dacf21dc3e06","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","01993890-bc39-742c-bff5-540390ef48e8","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_98":99,"_141":142},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/f13fd113-3e60-49cc-d2e1-6a7320ddbd00/square512","org",{"_98":99,"_145":142,"_12":118,"_146":147},"avatar","tier","free","branch",{"_150":151,"_100":46,"_106":152,"_153":107,"_154":-5,"_155":-5,"_156":-5,"_157":-5,"_158":-5,"_159":101,"_160":99},"version",1,"a7b954ae-2a88-11f1-8533-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_106":164,"_100":103,"_165":120,"_166":-5,"_167":152,"_168":151,"_169":122,"_108":170,"_150":33,"_171":172,"_173":174,"_175":20,"_176":-5,"_102":177},"a7bdefbe-2a88-11f1-8533-42dde27851f2","fileId","parentId","branchId","branchVersion","latest",["D",1774690184223],"fileType","http","content","import process from \"node:process\";\n\nconst BASE_COST = 2000;\nconst K_LENGTH = 32;\nconst IMAGE_TIMEOUT_MS = 20000;\nconst VIDEO_TIMEOUT_MS = 30000;\n\n// Image generation bots ordered cheapest first; Z Image Turbo LoRA is the default\nconst IMAGE_GEN_BOTS = [\n { name: \"Z Image Turbo LoRA\", handle: \"Z-Image-Turbo-LoRA\", supportsImageInput: false }, // default\n { name: \"Image Turbo LoRA\", handle: \"Image-Turbo-LoRA\", supportsImageInput: false },\n { name: \"Qwen-Image Text to Image\", handle: \"Qwen-Image-T2I\", supportsImageInput: false },\n { name: \"Qwen-Image Edit\", handle: \"Qwen-Image-Edit\", supportsImageInput: true },\n { name: \"Flux.1 Kontext Dev\", handle: \"FLUX-Kontext-Dev\", supportsImageInput: true },\n];\n\nconst NOVITA_VISION_MODELS = [\n \"qwen/qwen2.5-vl-72b-instruct\",\n \"meta-llama/llama-3.2-90b-vision-instruct\",\n \"qwen/qwen2-vl-7b-instruct\",\n \"meta-llama/llama-3.2-11b-vision-instruct\",\n \"qwen/z-image-turbo\",\n];\n\nfunction authenticateRequest(req: Request): { success: boolean; error?: string } {\n try {\n const expectedBotKey = process.env.BOT_KEY;\n if (!expectedBotKey) {\n return { success: false, error: \"bot key not configured\" };\n }\n if (expectedBotKey.length !== K_LENGTH) {\n return { success: false, error: \"Invalid bot key configuration\" };\n }\n const authHeader = req.headers.get(\"Authorization\");\n if (!authHeader) {\n return { success: false, error: \"Missing Authorization header\" };\n }\n let providedKey = \"\";\n if (authHeader.startsWith(\"Bearer \")) {\n providedKey = authHeader.substring(7);\n } else if (authHeader.startsWith(\"BOT_KEY \")) {\n providedKey = authHeader.substring(8);\n } else {\n providedKey = authHeader;\n }\n if (!providedKey) {\n return { success: false, error: \"Invalid Authorization header format\" };\n }\n if (providedKey.length !== K_LENGTH) {\n return { success: false, error: \"Invalid length\" };\n }\n if (!constantTimeEquals(providedKey, expectedBotKey)) {\n return { success: false, error: \"Invalid bot key\" };\n }\n return { success: true };\n } catch (error) {\n console.error(\"Authentication error:\", error);\n return { success: false, error: \"Authentication failed\" };\n }\n}\n\nfunction constantTimeEquals(a: string, b: string): boolean {\n if (a.length !== b.length) {\n return false;\n }\n let result = 0;\n for (let i = 0; i < a.length; i++) {\n result |= a.charCodeAt(i) ^ b.charCodeAt(i);\n }\n return result === 0;\n}\n\nfunction fetchWithTimeout(url: string, options: RequestInit, timeoutMs: number): Promise {\n const controller = new AbortController();\n const id = setTimeout(() => controller.abort(), timeoutMs);\n return fetch(url, { ...options, signal: controller.signal }).finally(() => clearTimeout(id));\n}\n\nasync function processImageWithPoe(attachment: any): Promise {\n const fileData = await fetchWithTimeout(attachment.url, {}, IMAGE_TIMEOUT_MS).then((r) => r.arrayBuffer());\n const base64Data = Buffer.from(fileData).toString(\"base64\");\n const mimeType = attachment.content_type;\n const dataUrl = `data:${mimeType};base64,${base64Data}`;\n const payload = {\n version: \"1.0\",\n type: \"query\",\n query: [\n {\n role: \"user\",\n content: `Analyze this image: ${attachment.name}`,\n content_type: \"text/markdown\",\n timestamp: Date.now() * 1000,\n message_id: `msg_${Date.now()}`,\n attachments: [{ url: dataUrl, content_type: mimeType, name: attachment.name }],\n },\n ],\n message_id: `query_${Date.now()}`,\n user_id: \"bot_user\",\n conversation_id: `conv_${Date.now()}`,\n metadata: \"\",\n };\n const response = await fetchWithTimeout(\n \"https://api.poe.com/bot/Z-Image-Lightning\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${process.env.POE_API_KEY}`,\n \"Content-Type\": \"application/json\",\n Accept: \"text/event-stream\",\n },\n body: JSON.stringify(payload),\n },\n IMAGE_TIMEOUT_MS,\n );\n if (!response.ok) {\n const errorText = await response.text().catch(() => \"Unknown error\");\n throw new Error(`Poe API failed: ${response.status} - ${errorText}`);\n }\n const reader = response.body!.getReader();\n const decoder = new TextDecoder();\n let buffer = \"\";\n let result = \"\";\n let currentEvent = \"\";\n try {\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n buffer += decoder.decode(value, { stream: true });\n const lines = buffer.split(\"\\n\");\n buffer = lines.pop() || \"\";\n for (const line of lines) {\n if (line.startsWith(\"event: \")) {\n currentEvent = line.slice(7).trim();\n } else if (line.startsWith(\"data: \")) {\n const data = line.slice(6).trim();\n if (!data || currentEvent === \"done\") continue;\n try {\n const parsed = JSON.parse(data);\n if (currentEvent === \"text\" && parsed.text) {\n result += parsed.text;\n }\n } catch (e) {\n console.warn(\"Poe SSE parse error:\", e);\n }\n }\n }\n }\n } finally {\n reader.releaseLock();\n }\n if (!result) throw new Error(\"No content returned from Poe\");\n return result;\n}\n\nasync function processImageWithNovitaModel(attachment: any, model: string): Promise {\n const fileData = await fetchWithTimeout(attachment.url, {}, IMAGE_TIMEOUT_MS).then((r) => r.arrayBuffer());\n const base64Data = Buffer.from(fileData).toString(\"base64\");\n const mimeType = attachment.content_type;\n const payload = {\n model,\n messages: [\n {\n role: \"user\",\n content: [\n { type: \"text\", text: `Analyze image ${attachment.name}` },\n { type: \"image_url\", image_url: { url: `data:${mimeType};base64,${base64Data}` } },\n ],\n },\n ],\n max_tokens: 2048,\n temperature: 0.7,\n };\n const response = await fetchWithTimeout(\n \"https://api.novita.ai/v3/openai/chat/completions\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${process.env.NOVITA_API_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(payload),\n },\n IMAGE_TIMEOUT_MS,\n );\n if (!response.ok) {\n const errorText = await response.text().catch(() => \"Unknown error\");\n throw new Error(`Novita model ${model} failed: ${response.status} - ${errorText}`);\n }\n const result = await response.json();\n const content = result.choices?.[0]?.message?.content;\n if (!content) throw new Error(`No content from Novita model ${model}`);\n return content;\n}\n\nasync function processImageWithNovita(attachment: any): Promise {\n let lastError: Error | null = null;\n for (const model of NOVITA_VISION_MODELS) {\n try {\n console.log(`Trying Novita model: ${model}`);\n const result = await processImageWithNovitaModel(attachment, model);\n console.log(`Novita model ${model} succeeded`);\n return result;\n } catch (err) {\n lastError = err as Error;\n console.warn(`Novita model ${model} failed: ${lastError.message}`);\n }\n }\n throw new Error(`All Novita models failed. Last error: ${lastError?.message}`);\n}\n\nasync function processVideoWithGemini(attachment: any): Promise {\n const fileData = await fetchWithTimeout(attachment.url, {}, VIDEO_TIMEOUT_MS).then((r) => r.arrayBuffer());\n const base64Data = Buffer.from(fileData).toString(\"base64\");\n const mimeType = attachment.content_type;\n const payload = {\n contents: [\n {\n parts: [\n { text: `Analyze video ${attachment.name}` },\n { inline_data: { mime_type: mimeType, data: base64Data } },\n ],\n },\n ],\n generationConfig: { temperature: 0.7, maxOutputTokens: 2048 },\n };\n const response = await fetchWithTimeout(\n `https://generativelanguage.googleapis.com/v1beta/models/gemini-1.5-flash-latest:generateContent?key=${process.env.GEMINI_API_KEY}`,\n {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n },\n VIDEO_TIMEOUT_MS,\n );\n if (!response.ok) {\n const errorText = await response.text().catch(() => \"Unknown error\");\n throw new Error(`Gemini API failed: ${response.status} - ${errorText}`);\n }\n const result = await response.json();\n const text = result.candidates?.[0]?.content?.parts?.[0]?.text;\n if (!text) throw new Error(\"No content returned from Gemini\");\n return text;\n}\n\nfunction checkFileType(fileName: string): { type: \"image\" | \"video\" | \"audio\" | \"text\" | \"pdf\" | \"unsupported\"; isSupported: boolean } {\n const lower = fileName.toLowerCase();\n if ([\".jpeg\", \".jpg\", \".png\", \".webp\", \".heic\"].some((e) => lower.endsWith(e))) return { type: \"image\", isSupported: true };\n if ([\".webm\"].some((e) => lower.endsWith(e))) return { type: \"video\", isSupported: true };\n if ([\".mp3\", \".wav\", \".ogg\", \".m4a\", \".flac\"].some((e) => lower.endsWith(e))) return { type: \"audio\", isSupported: false };\n if ([\".txt\", \".json\", \".js\", \".ts\", \".jsx\", \".tsx\", \".html\", \".css\", \".xml\", \".md\", \".csv\"].some((e) => lower.endsWith(e))) return { type: \"text\", isSupported: true };\n if (lower.endsWith(\".pdf\")) return { type: \"pdf\", isSupported: true };\n if ([\".gif\", \".bmp\", \".tiff\", \".svg\"].some((e) => lower.endsWith(e))) return { type: \"image\", isSupported: false };\n if ([\".mp4\", \".avi\", \".mov\", \".mkv\"].some((e) => lower.endsWith(e))) return { type: \"video\", isSupported: false };\n return { type: \"unsupported\", isSupported: false };\n}\n\nfunction hasUnsupportedFiles(attachments: any[]): boolean {\n return attachments.some((attachment) => {\n const { isSupported } = checkFileType(attachment.name || \"\");\n return !isSupported;\n });\n}\n\nasync function processFileAttachment(attachment: any): Promise {\n try {\n if (attachment.parsed_content) return attachment.parsed_content;\n const fileName = attachment.name || \"\";\n const { type, isSupported } = checkFileType(fileName);\n if (type === \"image\") {\n if (!isSupported) return `Unsupported image format: ${attachment.name}`;\n try {\n return await processImageWithPoe(attachment);\n } catch (poeError) {\n console.warn(\"Poe processing failed, trying Novita:\", (poeError as Error).message);\n try {\n return await processImageWithNovita(attachment);\n } catch (novitaError) {\n return `Image file: ${attachment.name}. All processors failed: ${(novitaError as Error).message}`;\n }\n }\n }\n if (type === \"audio\") return `Unsupported audio file: ${attachment.name}`;\n if (type === \"video\") {\n if (!isSupported) return `Unsupported video format: ${attachment.name}`;\n try {\n return await processVideoWithGemini(attachment);\n } catch (geminiError) {\n return `Video file: ${attachment.name}. Processing failed: ${(geminiError as Error).message}`;\n }\n }\n if (attachment.url) {\n try {\n const fileResponse = await fetchWithTimeout(attachment.url, { headers: { \"User-Agent\": \"Mozilla/5.0 (compatible; FileProcessor/1.0)\" } }, 10000);\n if (fileResponse.ok) {\n if (type === \"text\") {\n const textContent = await fileResponse.text();\n return textContent.substring(0, 2000) + (textContent.length > 2000 ? \"...(truncated)\" : \"\");\n } else if (type === \"pdf\") {\n return `PDF file content from ${attachment.name}. Content extraction requires specialized processing.`;\n } else {\n return `Binary file: ${attachment.name}. Unable to extract text content.`;\n }\n }\n } catch (directError) {\n console.warn(\"Direct file processing error:\", (directError as Error).message);\n }\n }\n return `File ${attachment.name}. File processing service unavailable.`;\n } catch (error) {\n console.error(\"File processing error:\", error);\n return `File ${attachment.name} - Processing error: ${(error as Error).message}`;\n }\n}\n\n/**\n * Calls a single Poe image generation bot and streams its SSE events back to the client.\n *\n * - supportsImageInput=false (text-to-image bots): image analysis text is appended to the\n * last user message so the bot has context about any uploaded reference image.\n * - supportsImageInput=true (image editing bots): the raw image attachments from the last\n * user message are forwarded directly so the bot can perform pixel-level editing.\n *\n * Returns true when at least one text/replace_response chunk was forwarded.\n */\nasync function callImageGenBot(\n botHandle: string,\n supportsImageInput: boolean,\n req: Query,\n fileAnalysisResults: string,\n send: SendEventFn,\n): Promise {\n const poeQuery = req.query.map((msg, idx) => {\n const isLastUser = idx === req.query.length - 1 && msg.role === \"user\";\n let content = msg.content;\n\n // Text-to-image bots: enrich prompt with the pre-analysed image description\n if (!supportsImageInput && isLastUser && fileAnalysisResults) {\n content += `\\n\\nReference image description:\\n${fileAnalysisResults}`;\n }\n\n const poeMsg: any = {\n role: msg.role === \"bot\" ? \"bot\" : \"user\",\n content,\n content_type: \"text/markdown\",\n timestamp: (Date.now() - (req.query.length - 1 - idx) * 100) * 1000,\n message_id: `msg_${Date.now()}_${idx}`,\n attachments: [] as Attachment[],\n };\n\n // Image editing bots: pass the actual image attachments from the last user message\n if (supportsImageInput && isLastUser && msg.attachments?.length > 0) {\n poeMsg.attachments = msg.attachments.filter(\n (a: Attachment) => checkFileType(a.name || \"\").type === \"image\",\n );\n }\n\n return poeMsg;\n });\n\n const payload = {\n version: \"1.0\",\n type: \"query\",\n query: poeQuery,\n message_id: `query_${Date.now()}`,\n user_id: \"bot_user\",\n conversation_id: req.conversation_id,\n metadata: \"\",\n };\n\n const response = await fetchWithTimeout(\n `https://api.poe.com/bot/${botHandle}`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${process.env.POE_API_KEY}`,\n \"Content-Type\": \"application/json\",\n Accept: \"text/event-stream\",\n },\n body: JSON.stringify(payload),\n },\n IMAGE_TIMEOUT_MS,\n );\n\n if (!response.ok) {\n const errorText = await response.text().catch(() => \"Unknown error\");\n throw new Error(`Bot ${botHandle} failed: ${response.status} - ${errorText}`);\n }\n\n if (!response.body) throw new Error(`No response body from ${botHandle}`);\n\n const reader = response.body.getReader();\n const decoder = new TextDecoder();\n let buffer = \"\";\n let currentEvent = \"\";\n let hasContent = false;\n\n try {\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(\"event: \")) {\n currentEvent = line.slice(7).trim();\n } else if (line.startsWith(\"data: \")) {\n const data = line.slice(6).trim();\n if (!data || currentEvent === \"done\") continue;\n try {\n const parsed = JSON.parse(data);\n if (currentEvent === \"text\" && parsed.text) {\n send(\"text\", { text: parsed.text });\n hasContent = true;\n } else if (currentEvent === \"replace_response\" && parsed.text !== undefined) {\n send(\"replace_response\", { text: parsed.text });\n hasContent = true;\n } else if (currentEvent === \"suggested_reply\" && parsed.text) {\n send(\"suggested_reply\", { text: parsed.text });\n } else if (currentEvent === \"error\") {\n throw new Error(parsed.text || \"Bot returned an error\");\n }\n } catch (e) {\n const err = e as Error;\n if (err.message === \"Bot returned an error\") throw e;\n console.warn(`SSE parse error (${botHandle}):`, e);\n }\n }\n }\n }\n } finally {\n reader.releaseLock();\n }\n\n return hasContent;\n}\n\nasync function getResponse(req: Query, send: SendEventFn) {\n send(\"meta\", { content_type: \"text/markdown\" });\n\n let fileAnalysisResults = \"\";\n let hasFiles = false;\n\n if (req.query.length > 0) {\n const lastMessage = req.query[req.query.length - 1];\n if (lastMessage.attachments && lastMessage.attachments.length > 0) {\n if (hasUnsupportedFiles(lastMessage.attachments)) {\n send(\"error\", { text: \"This file is not supported. Supported formats: JPEG, PNG, WebP, HEIC, WebM, PDF, and text files.\", allow_retry: false });\n send(\"done\", {});\n return;\n }\n hasFiles = true;\n send(\"text\", { text: \"Thinking...\\n\\n\" });\n for (const attachment of lastMessage.attachments) {\n try {\n const { type } = checkFileType(attachment.name || \"\");\n if (type === \"audio\") send(\"text\", { text: `Processing audio file...\\n` });\n else if (type === \"video\") send(\"text\", { text: `Processing video file...\\n` });\n else if (type === \"image\") send(\"text\", { text: `Processing image file...\\n` });\n const analysisResult = await processFileAttachment(attachment);\n fileAnalysisResults += `Content from ${attachment.name}:\\n${analysisResult}\\n\\n`;\n } catch (error) {\n fileAnalysisResults += `Error processing ${attachment.name}: ${(error as Error).message}\\n\\n`;\n }\n }\n }\n }\n\n // Try image generation bots cheapest first, falling back on failure or empty response\n for (let i = 0; i < IMAGE_GEN_BOTS.length; i++) {\n const bot = IMAGE_GEN_BOTS[i];\n try {\n if (hasFiles) send(\"replace_response\", { text: \"\" });\n\n console.log(`Trying image gen bot: ${bot.name}`);\n const success = await callImageGenBot(\n bot.handle,\n bot.supportsImageInput,\n req,\n fileAnalysisResults,\n send,\n );\n\n if (success) {\n console.log(`Image generation succeeded: ${bot.name}`);\n send(\"done\", {});\n return;\n }\n console.warn(`${bot.name} returned no content, trying next bot`);\n } catch (error) {\n console.error(`${bot.name} error:`, (error as Error).message);\n if (i === IMAGE_GEN_BOTS.length - 1) {\n send(\"error\", {\n text: `Error: All image generation bots unavailable. ${(error as Error).message}`,\n allow_retry: true,\n });\n break;\n }\n console.warn(`Falling back from ${bot.name}:`, (error as Error).message);\n await sleep(1000);\n }\n }\n\n send(\"done\", {});\n}\n\nasync function getBotSettings(): Promise {\n const rateCard = `| Type | Price |\\n|------|------|\\n| Message Cost | ${BASE_COST} points |\\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: `${BASE_COST} points`,\n supports_system_messages: true,\n suggested_replies: true,\n };\n}\n\nconst sleep = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms));\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 supports_system_messages?: boolean;\n suggested_replies?: boolean;\n};\n\ntype Attachment = {\n url: string;\n content_type: string;\n name: string;\n parsed_content?: string;\n};\n\ntype Message = {\n role: \"system\" | \"user\" | \"bot\";\n content: string;\n content_type: string;\n timestamp: number;\n message_id: string;\n feedback: { type: \"like\" | \"dislike\"; reason?: string }[];\n attachments: Attachment[];\n};\n\ntype Query = {\n version: string;\n type: \"query\";\n query: Message[];\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 = (eventName: EventName, data: Events[EventName]) => void;\n\nfunction encodeEvent(event: string, data: any = {}) {\n return new TextEncoder().encode(`event: ${event}\\ndata: ${JSON.stringify(data)}\\n\\n`);\n}\n\nexport default async function (req: Request): Promise {\n if (req.method === \"OPTIONS\") {\n return new Response(null, {\n status: 200,\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n \"Access-Control-Max-Age\": \"86400\",\n },\n });\n }\n\n const authResult = authenticateRequest(req);\n if (!authResult.success) {\n console.error(\"Authentication failed:\", authResult.error);\n return new Response(JSON.stringify({ error: \"Authentication failed\", details: authResult.error }), {\n status: 401,\n headers: { \"Content-Type\": \"application/json\", \"Access-Control-Allow-Origin\": \"*\" },\n });\n }\n\n let reqBody: any;\n try {\n reqBody = await req.json();\n } catch (e) {\n return new Response(JSON.stringify({ error: \"Invalid JSON in request body\" }), {\n status: 400,\n headers: { \"Content-Type\": \"application/json\", \"Access-Control-Allow-Origin\": \"*\" },\n });\n }\n\n console.log(\"Authenticated request body:\", JSON.stringify(reqBody, null, 2));\n\n if (reqBody.type === \"settings\") {\n try {\n const settings = await getBotSettings();\n return new Response(JSON.stringify(settings), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\", \"Access-Control-Allow-Origin\": \"*\" },\n });\n } catch (error) {\n return new Response(JSON.stringify({ error: \"Failed to get bot settings\" }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\", \"Access-Control-Allow-Origin\": \"*\" },\n });\n }\n }\n\n if (!reqBody.query || !Array.isArray(reqBody.query)) {\n return new Response(JSON.stringify({ error: \"Invalid query format\" }), {\n status: 400,\n headers: { \"Content-Type\": \"application/json\", \"Access-Control-Allow-Origin\": \"*\" },\n });\n }\n\n const body = new ReadableStream({\n start(controller) {\n const send = (event: string, data: any) => {\n try { controller.enqueue(encodeEvent(event, data)); } catch (e) { console.error(\"Error sending event:\", e); }\n };\n return getResponse(reqBody as Query, send)\n .catch((e) => {\n console.error(\"Get response error:\", e);\n send(\"error\", { text: `Internal error: ${(e as Error).message}`, allow_retry: true });\n })\n .finally(() => {\n try { controller.close(); } catch (e) { console.warn(\"Error closing controller:\", e); }\n });\n },\n });\n\n return new Response(body, {\n status: 200,\n headers: {\n \"Content-Type\": \"text/event-stream\",\n \"Cache-Control\": \"no-cache\",\n \"Connection\": \"keep-alive\",\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n },\n });\n}","deleted","label",[103],"permalink","https://www.val.town/x/aibotcommander/Z-Image/code/main.tsx","extension","actionData","errors"]