\n\n📥 [Download Music](${musicUrl})`;\n send(\"replace_response\", { text: musicResponse });\n return musicUrl;\n }\n }\n }\n }\n return null;\n }\n \n // Parallel execution for other tasks\n const parallelModels = poeModels.slice(0, 2);\n const promises: Promise<{ result: string | null; model: string }>[] = [];\n \n for (let keyIndex = 0; keyIndex < Math.min(POE_API_KEYS.length, 2); keyIndex++) {\n for (const model of parallelModels) {\n promises.push(\n callSinglePoeModel(model, enhancedPrompt, keyIndex, taskType, timeout, expectsMediaUrl)\n .then((result) => ({ result, model }))\n );\n }\n }\n \n const results = await Promise.allSettled(promises);\n const successful = results.find((r) => \n r.status === \"fulfilled\" && r.value.result !== null\n ) as PromiseFulfilledResult<{ result: string; model: string }>;\n \n if (successful) {\n if (expectsMediaUrl) {\n const urlMatch = successful.value.result.match(/https?:\\/\\/[^\\s\\)]+/i);\n if (urlMatch) {\n send(\"replace_response\", { text: `✅ **${taskType} completed**\\n\\n![Generated Media](${urlMatch[0]})` });\n return urlMatch[0];\n }\n }\n send(\"replace_response\", { text: successful.value.result });\n return successful.value.result;\n }\n \n return null;\n}\n\n// Intent Detection\nfunction detectIntent(content: string, hasAttachments: boolean): { intent: string; cleanedContent: string } {\n const lowerContent = content.toLowerCase();\n let cleanedContent = content;\n \n // Command suffixes\n const suffixes = [\n { suffix: \"--image\", intent: \"image_generation\" },\n { suffix: \"--video\", intent: \"video_generation\" },\n { suffix: \"--music\", intent: \"music_generation\" },\n { suffix: \"--search\", intent: \"search\" },\n { suffix: \"--research\", intent: \"deep_research\" },\n { suffix: \"--code\", intent: \"coding\" },\n { suffix: \"--feedback\", intent: \"feedback\" },\n { suffix: \"--remember\", intent: \"save_preference\" }\n ];\n \n for (const { suffix, intent } of suffixes) {\n if (cleanedContent.endsWith(suffix)) {\n cleanedContent = cleanedContent.substring(0, cleanedContent.length - suffix.length).trim();\n return { intent, cleanedContent };\n }\n }\n \n // Attachment handling\n if (hasAttachments) {\n if (lowerContent.includes(\"image\") || lowerContent.includes(\"analyze\")) {\n return { intent: \"image_analysis\", cleanedContent };\n }\n return { intent: \"file_analysis\", cleanedContent };\n }\n \n // Content-based detection\n if (lowerContent.includes(\"generate image\") || lowerContent.includes(\"create image\")) {\n return { intent: \"image_generation\", cleanedContent };\n }\n if (lowerContent.includes(\"generate video\") || lowerContent.includes(\"create video\")) {\n return { intent: \"video_generation\", cleanedContent };\n }\n if (lowerContent.includes(\"generate music\") || lowerContent.includes(\"create music\")) {\n return { intent: \"music_generation\", cleanedContent };\n }\n if (lowerContent.includes(\"code\") || lowerContent.includes(\"program\")) {\n return { intent: \"coding\", cleanedContent };\n }\n if (lowerContent.includes(\"search\") || lowerContent.includes(\"find information\")) {\n return { intent: \"search\", cleanedContent };\n }\n if (lowerContent.includes(\"remember\") || lowerContent.includes(\"save this preference\")) {\n return { intent: \"save_preference\", cleanedContent };\n }\n if (lowerContent.includes(\"what do you remember\") || lowerContent.includes(\"my preferences\")) {\n return { intent: \"show_preferences\", cleanedContent };\n }\n \n return { intent: \"text_generation\", cleanedContent };\n}\n\n// Main Response Handler\nasync function getResponse(req: Query, send: SendEventFn) {\n send(\"meta\", { content_type: \"text/markdown\" });\n \n const conversationId = req.conversation_id;\n const userId = req.user_id;\n \n // Save conversation metadata\n await saveConversation(conversationId, userId);\n \n // Get messages\n const messages = req.query.map((msg) => ({\n role: msg.role === \"bot\" ? \"assistant\" : msg.role,\n content: msg.content,\n attachments: msg.attachments || []\n }));\n \n const lastUserMessage = messages.filter((m) => m.role === \"user\").pop();\n if (!lastUserMessage) {\n send(\"text\", { text: \"👋 Hello! I'm your memory-enabled AI assistant. I can remember our conversations and your preferences. What can I help you with?\" });\n send(\"done\", {});\n return;\n }\n \n const userContent = lastUserMessage.content;\n const attachments = lastUserMessage.attachments || [];\n const { intent, cleanedContent } = detectIntent(userContent, attachments.length > 0);\n \n // Get conversation history\n const history = await getConversationHistory(conversationId, 10);\n const userPrefs = await getUserPreferences(userId);\n \n // Save user message\n await saveMessage(conversationId, \"user\", userContent, intent);\n \n try {\n let response: string | null = null;\n \n switch (intent) {\n case \"feedback\":\n await saveFeedback(userId, cleanedContent);\n response = \"✅ Thank you for your feedback! I've saved it for review.\";\n send(\"text\", { text: response });\n break;\n \n case \"save_preference\":\n const newPrefs = { ...userPrefs, lastSaved: cleanedContent, timestamp: Date.now() };\n await saveUserPreferences(userId, newPrefs);\n response = \"✅ I've saved your preference! I'll remember this for our future conversations.\";\n send(\"text\", { text: response });\n break;\n \n case \"show_preferences\":\n if (Object.keys(userPrefs).length === 0) {\n response = \"I don't have any saved preferences for you yet. Use '--remember' to save preferences!\";\n } else {\n response = `📝 **Your Saved Preferences:**\\n\\n${JSON.stringify(userPrefs, null, 2)}`;\n }\n send(\"text\", { text: response });\n break;\n \n case \"image_generation\":\n send(\"text\", { text: `🎨 Generating image...` });\n response = await callModelsWithFallback(POE_MODELS.imageGeneration, cleanedContent, send, \"Image Generation\", 15000, true);\n break;\n \n case \"video_generation\":\n send(\"text\", { text: `🎬 Generating video...` });\n response = await callModelsWithFallback(POE_MODELS.videoGeneration, cleanedContent, send, \"Video Generation\", 30000, true);\n break;\n \n case \"music_generation\":\n send(\"text\", { text: `🎵 Composing music...` });\n response = await callModelsWithFallback(POE_MODELS.musicGeneration, cleanedContent, send, \"Music Generation\", 30000, true);\n break;\n \n case \"coding\":\n send(\"text\", { text: `💻 Coding...` });\n response = await callModelsWithFallback(POE_MODELS.coding, cleanedContent, send, \"Coding\", 20000, false, history);\n break;\n \n case \"search\":\n send(\"text\", { text: `🔍 Searching...` });\n response = await callModelsWithFallback(POE_MODELS.search, cleanedContent, send, \"Web Search\", 15000);\n break;\n \n case \"deep_research\":\n send(\"text\", { text: `🔬 Researching...` });\n response = await callModelsWithFallback(POE_MODELS.deepResearch, cleanedContent, send, \"Deep Research\", 30000);\n break;\n \n case \"text_generation\":\n default:\n send(\"text\", { text: `💬 Thinking...` });\n response = await callModelsWithFallback(POE_MODELS.textGeneration, cleanedContent, send, \"Text Generation\", 15000, false, history);\n break;\n }\n \n // Save bot response\n if (response) {\n await saveMessage(conversationId, \"assistant\", response, intent);\n }\n \n if (!response && ![\"feedback\", \"save_preference\", \"show_preferences\"].includes(intent)) {\n send(\"error\", { text: `❌ Request failed. Please try again.`, allow_retry: true });\n }\n } catch (error) {\n console.error(\"Error:\", error);\n send(\"error\", { text: `Error: ${error.message}`, allow_retry: true });\n }\n \n send(\"done\", {});\n}\n\nasync function getBotSettings(): Promise {\n return {\n allow_attachments: true,\n expand_text_attachments: true,\n enable_multi_bot_chat_prompting: true,\n rate_card: \"| Feature | Cost |\\n|---------|------|\\n| All features | Free |\",\n cost_label: \"Free with memory\"\n };\n}\n\n// Types\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 attachments: { url: string; content_type: string; name: string; parsed_content?: string }[];\n }[];\n message_id: string;\n user_id: string;\n conversation_id: string;\n};\n\ntype Events = {\n meta: { content_type: string };\n text: { text: string };\n replace_response: { 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(`event: ${event}\\ndata: ${JSON.stringify(data)}\\n\\n`);\n}\n\n// Main Handler\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({ error: authResult.error }),\n { status: 401, headers: { \"Content-Type\": \"application/json\" } }\n );\n }\n }\n \n const reqBody = await req.json().catch(() => ({}));\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 return getResponse(reqBody, send)\n .catch((e) => {\n console.error(\"Error:\", e);\n send(\"error\", { text: `Error: ${e.message}`, allow_retry: true });\n })\n .finally(() => controller.close());\n }\n });\n \n return new Response(body, {\n status: 200,\n headers: { \"Content-Type\": \"text/event-stream\" }\n });\n}","deleted","label",[100],"permalink","https://www.val.town/x/RobooHood/Feedback-Chat/code/main.tsx","extension","actionData","errors"]