\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_memory\" },\n { suffix: \"--forget\", intent: \"forget_memory\" },\n { suffix: \"--clear\", intent: \"clear_memory\" },\n { suffix: \"--memory\", intent: \"show_memory\" }\n ];\n \n for (const { suffix, intent } of suffixes) {\n if (cleanedContent.toLowerCase().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.match(/what do you (?:remember|know) about me/i) || \n lowerContent.match(/show (?:my )?memory/i) ||\n lowerContent.match(/what have i told you/i)) {\n return { intent: \"show_memory\", cleanedContent };\n }\n if (lowerContent.match(/forget (?:that|everything|all)/i)) {\n return { intent: \"clear_memory\", cleanedContent };\n }\n \n return { intent: \"text_generation\", cleanedContent };\n}\n\n// Format facts for display\nfunction formatFactsDisplay(facts: Record>): string {\n if (Object.keys(facts).length === 0) {\n return \"🧠 **Memory Empty**\\n\\nI don't have any saved information about you yet.\\n\\n**How to save:**\\n- Say things like \\\"My name is X\\\" or \\\"I live in Y\\\"\\n- Use `--remember` to save explicit facts\\n- Example: `favorite color: blue --remember`\";\n }\n \n const lines: string[] = [\"🧠 **What I Remember About You**\\n\"];\n \n const categoryNames: Record = {\n personal: \"👤 Personal\",\n preferences: \"⭐ Preferences\", \n technical: \"💻 Technical\",\n context: \"📋 Context\",\n explicit: \"📝 Saved Notes\",\n notes: \"📌 Notes\"\n };\n \n for (const [category, items] of Object.entries(facts)) {\n const displayName = categoryNames[category] || `📁 ${category}`;\n lines.push(`**${displayName}**`);\n for (const [key, value] of Object.entries(items)) {\n const readableKey = key.replace(/_/g, \" \").replace(/^./, c => c.toUpperCase());\n lines.push(` • ${readableKey}: ${value}`);\n }\n lines.push(\"\");\n }\n \n lines.push(\"---\\n*Use `--forget ` to remove or `--clear` to reset all*\");\n return lines.join(\"\\n\");\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 facts about you across conversations.\\n\\n**Commands:**\\n- `--remember` - Save a fact\\n- `--memory` - Show what I remember\\n- `--forget ` - Remove a fact\\n- `--clear` - Clear all memory\" });\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 and facts\n const history = await getConversationHistory(conversationId, 10);\n const factsContext = await getFactsContext(userId);\n \n // Auto-extract facts from message\n const extractedCount = await saveExtractedFacts(userId, userContent);\n if (extractedCount > 0) {\n console.log(`Auto-extracted ${extractedCount} facts from message`);\n }\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_memory\":\n const saveResult = await saveExplicitFact(userId, cleanedContent);\n response = `✅ ${saveResult}`;\n send(\"text\", { text: response });\n break;\n \n case \"forget_memory\":\n const deleted = await deleteFact(userId, cleanedContent);\n response = deleted \n ? `✅ Forgot: \"${cleanedContent}\"`\n : `❓ I don't have anything saved for \"${cleanedContent}\"`;\n send(\"text\", { text: response });\n break;\n \n case \"clear_memory\":\n const clearedCount = await clearAllFacts(userId);\n response = clearedCount > 0\n ? `✅ Cleared ${clearedCount} saved facts from memory.`\n : \"🧠 Memory was already empty.\";\n send(\"text\", { text: response });\n break;\n \n case \"show_memory\":\n const facts = await getUserFacts(userId);\n response = formatFactsDisplay(facts);\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, factsContext);\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, factsContext);\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_memory\", \"forget_memory\", \"clear_memory\", \"show_memory\"].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/Memory-Omni-01/code/main.tsx","extension","actionData","errors"]