[{"_1":2,"_182":-5,"_183":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":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","isTeamOrgMember","ENV",{"_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,"_64":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","7721b06a805a6662fde743a1ec849364175efb5b","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",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":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",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_162":163,"_179":180,"_181":-5},"handle","RobooHood","name","Memory-Omni-02","path","main.tsx","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":112,"_113":114,"_12":115,"_116":117,"_118":119,"_120":-5,"_121":-5,"_122":33,"_14":123,"_124":125,"_126":127,"_128":129,"_130":129,"_131":132,"_133":132,"_134":132,"_135":129,"_136":129,"_23":137,"_140":141,"_145":146,"_161":20},"id","a12e9e14-fa36-11f0-b78f-42dde27851f2","createdAt",["D",1769377298765],"deletedAt","legacyEnvVars","privacy","public","description","https://poe.com/Cheap-Omni","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/67c45da2-0864-4a99-1f63-946f1a3a3600/square512","25a33e90-1def-11f0-8458-d7daa68fe194","pinnedFileId","019bf71a-f9a0-74ea-9038-29cc666c007e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","e54478ee-7c91-4914-a560-525ba174a661","tursoName","a12e9e14fa3611f0b78f42dde27851f2","tursoHostname","a12e9e14fa3611f0b78f42dde27851f2-val-town.aws-us-east-2.turso.io","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_138":139},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/dea1728e-0705-4aeb-d340-76cf90896100/square512","org",{"_95":96,"_142":139,"_12":115,"_143":144},"avatar","tier","free","branch",{"_147":148,"_97":45,"_103":149,"_150":104,"_151":152,"_153":154,"_155":110,"_156":157,"_158":123,"_159":98,"_160":96},"version",2,"a1357252-fa36-11f0-b78f-42dde27851f2","projectId","forkedBranchId","95bcdbd8-fa34-11f0-b173-42dde27851f2","forkedBranchVersion",3,"forkedProjectPrivacy","forkedProjectId","95b80f40-fa34-11f0-b173-42dde27851f2","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":164,"_97":100,"_165":117,"_166":-5,"_167":149,"_168":148,"_169":119,"_105":170,"_147":171,"_172":173,"_174":175,"_176":20,"_177":-5,"_99":178},"f45481fc-fa37-11f0-81f7-42dde27851f2","fileId","parentId","branchId","branchVersion","latest",["D",1769377867771],1,"fileType","http","content","import process from \"node:process\";\nimport { OpenAI } from \"npm:openai\";\nimport sqlite from \"https://esm.town/v/std/db/main.ts\";\n\n// Initialize database tables\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS conversations (\n conversation_id TEXT PRIMARY KEY,\n user_id TEXT,\n created_at INTEGER,\n last_updated INTEGER\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n conversation_id TEXT,\n role TEXT,\n content TEXT,\n timestamp INTEGER,\n intent TEXT,\n FOREIGN KEY (conversation_id) REFERENCES conversations(conversation_id)\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS user_feedback (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id TEXT,\n feedback TEXT,\n timestamp INTEGER\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS user_facts (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id TEXT NOT NULL,\n fact_key TEXT NOT NULL,\n fact_value TEXT NOT NULL,\n source_message TEXT,\n created_at INTEGER,\n updated_at INTEGER,\n UNIQUE(user_id, fact_key)\n )\n`);\n\nawait sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_user_facts_user ON user_facts(user_id)\n`);\n\n// Constants\nconst BOT_ACCESS_KEY = process.env.BOT_ACCESS_KEY;\nconst POE_API_KEYS = [process.env.POE_API_KEY].filter(Boolean) as string[];\n\nconst POE_MODELS = {\n imageGeneration: [\"Flux-schnell-DI\", \"Flux-schnell\"],\n textGeneration: [\"Gemini-2.0-Flash-lite\", \"GPT-4o-mini\", \"Phi-4-DI\", \"Solar-Pro-2\"],\n coding: [\"Grok-4.1-fast-reasoning\", \"Gemini-2.0-Flash-lite\", \"Autonomous-Coder\"],\n fileAnalysis: [\"Gemini-2.0-Flash-lite\", \"GLM-4.5-Omni\", \"GPT-OSS-120B-Omni\"],\n imageAnalysis: [\"Aya-Vision\"],\n search: [\"Gemini-2.0-flash-lite\", \"Gemini-2.0-flash\"],\n deepResearch: [\"Deep-AI-Search\", \"Web-Search-AI\", \"Gemini-2.0-flash-lite\", \"Gemini-2.0-flash\"],\n videoGeneration: [\"Wan-2.6-N\", \"LTX-2-Audio\", \"Real-Video-Generator\", \"Video-Generator-Pro\"],\n musicGeneration: [\"Wan-2.6-N\", \"Hailuo-Music-v1.5\", \"Lyria\"],\n soundGeneration: [\"Stable-Audio-2.5\", \"Stable-Audio-2.0\"],\n factExtraction: [\"Gemini-2.0-Flash-lite\", \"GPT-4o-mini\"]\n};\n\n// Helper to sanitize values for SQLite\nfunction sanitize(value: any): any {\n if (value === undefined) return null;\n if (typeof value === \"string\") return value;\n if (typeof value === \"number\") return value;\n if (value === null) return null;\n return String(value);\n}\n\n// Generate a fallback ID if not provided\nfunction ensureId(id: string | undefined | null, prefix: string = \"id\"): string {\n if (id && typeof id === \"string\" && id.trim().length > 0) {\n return id.trim();\n }\n return `${prefix}_${Date.now()}_${Math.random().toString(36).substring(2, 9)}`;\n}\n\n// Memory Management Functions\nasync function saveConversation(conversationId: string, userId: string): Promise {\n const safeConvId = ensureId(conversationId, \"conv\");\n const safeUserId = ensureId(userId, \"user\");\n const now = Date.now();\n \n try {\n await sqlite.execute(\n `INSERT OR REPLACE INTO conversations (conversation_id, user_id, created_at, last_updated) \n VALUES (?, ?, COALESCE((SELECT created_at FROM conversations WHERE conversation_id = ?), ?), ?)`,\n [safeConvId, safeUserId, safeConvId, now, now]\n );\n } catch (error) {\n console.error(\"Error saving conversation:\", error);\n }\n}\n\nasync function saveMessage(\n conversationId: string, \n role: string, \n content: string, \n intent?: string\n): Promise {\n const safeConvId = ensureId(conversationId, \"conv\");\n const safeRole = sanitize(role) || \"user\";\n const safeContent = sanitize(content) || \"\";\n const safeIntent = sanitize(intent) || \"\";\n const timestamp = Date.now();\n \n try {\n await sqlite.execute(\n `INSERT INTO messages (conversation_id, role, content, timestamp, intent) VALUES (?, ?, ?, ?, ?)`,\n [safeConvId, safeRole, safeContent, timestamp, safeIntent]\n );\n } catch (error) {\n console.error(\"Error saving message:\", error);\n }\n}\n\nasync function getConversationHistory(conversationId: string, limit: number = 10): Promise {\n const safeConvId = ensureId(conversationId, \"conv\");\n const safeLimit = typeof limit === \"number\" && limit > 0 ? limit : 10;\n \n try {\n const result = await sqlite.execute(\n `SELECT role, content, timestamp, intent FROM messages \n WHERE conversation_id = ? \n ORDER BY timestamp DESC LIMIT ?`,\n [safeConvId, safeLimit]\n );\n return (result.rows || []).reverse();\n } catch (error) {\n console.error(\"Error getting conversation history:\", error);\n return [];\n }\n}\n\n// Universal fact extraction using LLM\nasync function extractFactsWithLLM(\n userId: string,\n userMessage: string,\n assistantResponse: string\n): Promise {\n if (!userMessage || userMessage.trim().length < 5) return;\n if (POE_API_KEYS.length === 0) return;\n \n const extractionPrompt = `Analyze this conversation and extract any personal facts about the user that would be useful to remember for future conversations.\n\nUSER MESSAGE: \"${userMessage}\"\n${assistantResponse ? `ASSISTANT RESPONSE: \"${assistantResponse.substring(0, 500)}\"` : \"\"}\n\nExtract facts as a JSON array. Each fact should have:\n- \"key\": a short, lowercase, underscore-separated identifier (e.g., \"name\", \"favorite_color\", \"job_title\", \"programming_language\", \"pet_name\")\n- \"value\": the actual information\n\nRules:\n- Only extract FACTUAL information the user explicitly stated about themselves\n- Do NOT extract questions, requests, or hypotheticals\n- Do NOT extract temporary states (e.g., \"currently typing\", \"asking a question\")\n- DO extract: personal info, preferences, skills, relationships, locations, work info, hobbies, etc.\n- Keep keys consistent and reusable (use \"location\" not \"lives_in_new_york\")\n- If no facts are found, return an empty array: []\n\nReturn ONLY valid JSON array, no explanation. Example:\n[{\"key\": \"name\", \"value\": \"John\"}, {\"key\": \"favorite_language\", \"value\": \"Python\"}]`;\n\n try {\n const apiKey = POE_API_KEYS[0];\n const client = new OpenAI({\n apiKey: apiKey,\n baseURL: \"https://api.poe.com/v1\",\n });\n \n const response = await Promise.race([\n client.chat.completions.create({\n model: POE_MODELS.factExtraction[0],\n messages: [{ role: \"user\", content: extractionPrompt }],\n max_tokens: 500,\n temperature: 0.1,\n }),\n new Promise((_, reject) => \n setTimeout(() => reject(new Error(\"Timeout\")), 8000)\n )\n ]);\n \n const content = response.choices[0]?.message?.content;\n if (!content) return;\n \n // Parse JSON from response\n const jsonMatch = content.match(/\\[[\\s\\S]*\\]/);\n if (!jsonMatch) return;\n \n const facts = JSON.parse(jsonMatch[0]);\n if (!Array.isArray(facts)) return;\n \n // Save each extracted fact\n for (const fact of facts) {\n if (fact.key && fact.value && typeof fact.key === \"string\" && typeof fact.value === \"string\") {\n const cleanKey = fact.key.toLowerCase().replace(/[^a-z0-9_]/g, \"_\").substring(0, 50);\n const cleanValue = fact.value.trim().substring(0, 500);\n if (cleanKey && cleanValue) {\n await saveFact(userId, cleanKey, cleanValue, userMessage.substring(0, 200));\n }\n }\n }\n \n console.log(`Extracted ${facts.length} facts from message`);\n } catch (error: any) {\n // Silent fail - fact extraction is non-critical\n console.log(\"Fact extraction skipped:\", error.message);\n }\n}\n\n// Save a fact\nasync function saveFact(\n userId: string, \n key: string, \n value: string,\n sourceMessage?: string\n): Promise {\n const safeUserId = ensureId(userId, \"user\");\n const safeKey = sanitize(key) || \"note\";\n const safeValue = (sanitize(value) || \"\").substring(0, 500);\n const safeSource = (sanitize(sourceMessage) || \"\").substring(0, 200);\n const now = Date.now();\n \n if (!safeValue) return;\n \n try {\n await sqlite.execute(\n `INSERT INTO user_facts (user_id, fact_key, fact_value, source_message, created_at, updated_at)\n VALUES (?, ?, ?, ?, ?, ?)\n ON CONFLICT(user_id, fact_key) DO UPDATE SET\n fact_value = excluded.fact_value, \n source_message = excluded.source_message,\n updated_at = excluded.updated_at`,\n [safeUserId, safeKey, safeValue, safeSource, now, now]\n );\n } catch (error) {\n console.error(\"Error saving fact:\", error);\n }\n}\n\n// Save explicit fact from --remember command\nasync function saveExplicitFact(userId: string, content: string): Promise {\n if (!content || typeof content !== \"string\" || content.trim().length === 0) {\n return \"Nothing to save. Usage: `your fact here --remember` or `key: value --remember`\";\n }\n \n // Try to parse \"key: value\" or \"key = value\" format\n const kvMatch = content.match(/^([^:=]+)[:=]\\s*(.+)$/);\n if (kvMatch) {\n const key = kvMatch[1].trim().toLowerCase().replace(/\\s+/g, \"_\").replace(/[^a-z0-9_]/g, \"\");\n const value = kvMatch[2].trim();\n if (key && value) {\n await saveFact(userId, key, value, \"explicit save\");\n return `✅ Saved: **${key}** = \"${value}\"`;\n }\n }\n \n // Otherwise, use LLM to determine a good key\n if (POE_API_KEYS.length > 0) {\n try {\n const client = new OpenAI({\n apiKey: POE_API_KEYS[0],\n baseURL: \"https://api.poe.com/v1\",\n });\n \n const response = await Promise.race([\n client.chat.completions.create({\n model: POE_MODELS.factExtraction[0],\n messages: [{ \n role: \"user\", \n content: `Generate a short, lowercase, underscore-separated key for this fact: \"${content}\"\n \nReturn ONLY the key, nothing else. Examples: \"favorite_food\", \"pet_name\", \"work_schedule\", \"allergy\"` \n }],\n max_tokens: 50,\n temperature: 0.1,\n }),\n new Promise((_, reject) => \n setTimeout(() => reject(new Error(\"Timeout\")), 5000)\n )\n ]);\n \n let key = response.choices[0]?.message?.content?.trim().toLowerCase().replace(/[^a-z0-9_]/g, \"_\") || \"\";\n if (key && key.length > 0 && key.length < 50) {\n await saveFact(userId, key, content, \"explicit save\");\n return `✅ Saved as **${key}**: \"${content.substring(0, 100)}${content.length > 100 ? \"...\" : \"\"}\"`;\n }\n } catch {\n // Fall through to default\n }\n }\n \n // Fallback: use timestamp-based key\n const key = `note_${Date.now()}`;\n await saveFact(userId, key, content, \"explicit save\");\n return `✅ Saved note: \"${content.substring(0, 50)}${content.length > 50 ? \"...\" : \"\"}\"`;\n}\n\n// Get all facts for a user\nasync function getUserFacts(userId: string): Promise> {\n const safeUserId = ensureId(userId, \"user\");\n \n try {\n const result = await sqlite.execute(\n `SELECT fact_key, fact_value FROM user_facts WHERE user_id = ? ORDER BY updated_at DESC`,\n [safeUserId]\n );\n \n const facts: Record = {};\n for (const row of result.rows || []) {\n facts[String(row.fact_key || \"\")] = String(row.fact_value || \"\");\n }\n return facts;\n } catch (error) {\n console.error(\"Error getting user facts:\", error);\n return {};\n }\n}\n\n// Get facts as context string for AI\nasync function getFactsContext(userId: string): Promise {\n const facts = await getUserFacts(userId);\n const entries = Object.entries(facts);\n if (entries.length === 0) return \"\";\n \n const lines: string[] = [\"[User Information - Use this to personalize responses]\"];\n for (const [key, value] of entries) {\n const readableKey = key.replace(/_/g, \" \");\n lines.push(`- ${readableKey}: ${value}`);\n }\n return lines.join(\"\\n\");\n}\n\n// Delete a specific fact\nasync function deleteFact(userId: string, key: string): Promise {\n const safeUserId = ensureId(userId, \"user\");\n const normalizedKey = (key || \"\").trim().toLowerCase().replace(/\\s+/g, \"_\").replace(/[^a-z0-9_]/g, \"\");\n \n if (!normalizedKey) return false;\n \n try {\n // Try exact match first\n let result = await sqlite.execute(\n `DELETE FROM user_facts WHERE user_id = ? AND fact_key = ?`,\n [safeUserId, normalizedKey]\n );\n \n if ((result.rowsAffected || 0) > 0) return true;\n \n // Try partial match\n result = await sqlite.execute(\n `DELETE FROM user_facts WHERE user_id = ? AND fact_key LIKE ?`,\n [safeUserId, `%${normalizedKey}%`]\n );\n \n return (result.rowsAffected || 0) > 0;\n } catch (error) {\n console.error(\"Error deleting fact:\", error);\n return false;\n }\n}\n\n// Clear all facts for user\nasync function clearAllFacts(userId: string): Promise {\n const safeUserId = ensureId(userId, \"user\");\n \n try {\n const result = await sqlite.execute(\n `DELETE FROM user_facts WHERE user_id = ?`,\n [safeUserId]\n );\n return result.rowsAffected || 0;\n } catch (error) {\n console.error(\"Error clearing facts:\", error);\n return 0;\n }\n}\n\nasync function saveFeedback(userId: string, feedback: string): Promise {\n const safeUserId = ensureId(userId, \"user\");\n const safeFeedback = sanitize(feedback) || \"\";\n const timestamp = Date.now();\n \n if (!safeFeedback) return;\n \n try {\n await sqlite.execute(\n `INSERT INTO user_feedback (user_id, feedback, timestamp) VALUES (?, ?, ?)`,\n [safeUserId, safeFeedback, timestamp]\n );\n } catch (error) {\n console.error(\"Error saving feedback:\", error);\n }\n}\n\n// Authentication\nfunction authenticateRequest(req: Request): { isValid: boolean; error?: string } {\n if (!BOT_ACCESS_KEY) {\n console.warn(\"Warning: BOT_ACCESS_KEY not set\");\n return { isValid: true };\n }\n const providedKey = req.headers.get(\"Authorization\")?.replace(\"Bearer \", \"\") || \n req.headers.get(\"X-API-Key\") || \n req.headers.get(\"X-Bot-Access-Key\");\n if (!providedKey) {\n return { isValid: false, error: \"Missing authentication\" };\n }\n if (providedKey !== BOT_ACCESS_KEY) {\n return { isValid: false, error: \"Invalid BOT_ACCESS_KEY\" };\n }\n return { isValid: true };\n}\n\n// POE Client\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 selectOptimalTokens(contentLength: number, taskType: string): number {\n if ([\"Image Generation\", \"Video Generation\", \"Music Generation\"].includes(taskType)) {\n return 1024;\n }\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 | any[], \n apiKeyIndex: number, \n taskType: string, \n timeout: number = 15000, \n expectsMediaUrl: boolean = false\n): Promise {\n try {\n const apiKey = POE_API_KEYS[apiKeyIndex];\n if (!apiKey) {\n console.error(`No API key at index ${apiKeyIndex}`);\n return null;\n }\n \n const poeClient = createPoeClient(apiKey);\n const contentLength = typeof prompt === \"string\" ? prompt.length : JSON.stringify(prompt).length;\n const maxTokens = selectOptimalTokens(contentLength, taskType);\n \n console.log(`Trying ${model} with API key ${apiKeyIndex + 1} for ${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 // Handle Poe-specific attachments\n const poeMessage = message as any;\n if (expectsMediaUrl && poeMessage?.attachments && Array.isArray(poeMessage.attachments)) {\n const mediaAttachment = poeMessage.attachments.find((att: any) => \n att.content_type && (\n att.content_type.startsWith(\"image/\") || \n att.content_type.startsWith(\"video/\") || \n att.content_type.startsWith(\"audio/\")\n )\n );\n if (mediaAttachment?.url) {\n console.log(`✅ ${model} returned media URL: ${mediaAttachment.url}`);\n return mediaAttachment.url;\n }\n }\n \n if (expectsMediaUrl && content) {\n const urlMatch = content.match(/https?:\\/\\/[^\\s\\)]+/i);\n if (urlMatch) {\n console.log(`✅ ${model} returned URL in text: ${urlMatch[0]}`);\n return urlMatch[0];\n }\n }\n \n return content && content.trim().length > 0 ? content : null;\n } catch (error: any) {\n console.error(`❌ ${model} failed:`, error.message);\n return null;\n }\n}\n\nasync function callModelsWithFallback(\n poeModels: string[], \n prompt: string | any[], \n send: SendEventFn, \n taskType: string, \n timeout: number = 15000, \n expectsMediaUrl: boolean = false,\n conversationHistory?: any[],\n factsContext?: string\n): Promise {\n if (POE_API_KEYS.length === 0) {\n send(\"replace_response\", { text: \"❌ No API keys configured.\" });\n return null;\n }\n \n let enhancedPrompt = prompt;\n \n // Add context for text generation\n if (taskType === \"Text Generation\" || taskType === \"Coding\") {\n const contextParts: string[] = [];\n \n if (factsContext && factsContext.length > 0) {\n contextParts.push(factsContext);\n }\n \n if (conversationHistory && conversationHistory.length > 0) {\n const historyContext = conversationHistory\n .slice(-5)\n .map(msg => `${msg.role}: ${String(msg.content || \"\").substring(0, 200)}`)\n .join(\"\\n\");\n contextParts.push(`[Recent conversation]\\n${historyContext}`);\n }\n \n if (contextParts.length > 0) {\n enhancedPrompt = `${contextParts.join(\"\\n\\n\")}\\n\\n[Current request]\\n${prompt}`;\n }\n }\n \n // Music generation special handling\n if (taskType === \"Music Generation\") {\n console.log(`🎵 Composing music...`);\n for (const model of poeModels) {\n for (let keyIndex = 0; keyIndex < POE_API_KEYS.length; keyIndex++) {\n const result = await callSinglePoeModel(model, enhancedPrompt, keyIndex, taskType, timeout, expectsMediaUrl);\n if (result) {\n const urlMatch = result.match(/https?:\\/\\/[^\\s\\)]+/i);\n if (urlMatch) {\n const musicUrl = urlMatch[0];\n const musicResponse = `✅ **Music Generation completed**\n\n🎵 **Your music is ready!**\n\n📥 [Download/Play Music](${musicUrl})`;\n send(\"replace_response\", { text: musicResponse });\n return musicUrl;\n }\n }\n }\n }\n send(\"replace_response\", { text: \"❌ Music generation failed. Please try again.\" });\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 }> | undefined;\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 if (!content || typeof content !== \"string\") {\n return { intent: \"text_generation\", cleanedContent: \"\" };\n }\n \n const lowerContent = content.toLowerCase();\n let cleanedContent = content;\n \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 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 if (lowerContent.includes(\"generate image\") || lowerContent.includes(\"create image\") || lowerContent.includes(\"draw\")) {\n return { intent: \"image_generation\", cleanedContent };\n }\n if (lowerContent.includes(\"generate video\") || lowerContent.includes(\"create video\") || lowerContent.includes(\"make video\")) {\n return { intent: \"video_generation\", cleanedContent };\n }\n if (lowerContent.includes(\"generate music\") || lowerContent.includes(\"create music\") || lowerContent.includes(\"compose\")) {\n return { intent: \"music_generation\", cleanedContent };\n }\n if (lowerContent.match(/^(write |create |make |build )?(code|script|function|program)/i)) {\n return { intent: \"coding\", cleanedContent };\n }\n if (lowerContent.includes(\"search for\") || lowerContent.includes(\"look up\") || lowerContent.includes(\"find info\")) {\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('ve| have) i told you/i)) {\n return { intent: \"show_memory\", cleanedContent };\n }\n if (lowerContent.match(/forget (?:that|everything|all|my)/i) || lowerContent.match(/clear (?:my )?memory/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 const entries = Object.entries(facts);\n \n if (entries.length === 0) {\n return `🧠 **Memory Empty**\n\nI don't have any saved information about you yet.\n\n**How I learn about you:**\n- Just chat naturally! I'll automatically remember important details you share.\n- Use \\`--remember\\` to explicitly save something: \\`I love pizza --remember\\`\n- Use \\`key: value --remember\\` for specific facts: \\`timezone: PST --remember\\`\n\n**Other commands:**\n- \\`--memory\\` - Show what I remember\n- \\`--forget \\` - Remove a specific fact\n- \\`--clear\\` - Clear all memory`;\n }\n \n const lines: string[] = [\"🧠 **What I Remember About You**\\n\"];\n \n // Group facts for better display\n for (const [key, value] of entries) {\n const readableKey = key.replace(/_/g, \" \").replace(/\\b\\w/g, c => c.toUpperCase());\n lines.push(`• **${readableKey}**: ${value}`);\n }\n \n lines.push(`\\n---\\n*${entries.length} fact${entries.length !== 1 ? \"s\" : \"\"} stored*`);\n lines.push(\"*Use `--forget ` to remove or `--clear` to reset all*\");\n \n return lines.join(\"\\n\");\n}\n\n// Main Response Handler\nasync function getResponse(req: Query, send: SendEventFn): Promise {\n send(\"meta\", { content_type: \"text/markdown\" });\n \n const conversationId = ensureId(req.conversation_id, \"conv\");\n const userId = ensureId(req.user_id, \"user\");\n \n await saveConversation(conversationId, userId);\n \n const queryMessages = Array.isArray(req.query) ? req.query : [];\n const messages = queryMessages.map((msg) => ({\n role: msg.role === \"bot\" ? \"assistant\" : (msg.role || \"user\"),\n content: msg.content || \"\",\n attachments: msg.attachments || []\n }));\n \n const lastUserMessage = messages.filter((m) => m.role === \"user\").pop();\n if (!lastUserMessage || !lastUserMessage.content) {\n send(\"text\", { text: `👋 Hello! I'm your AI assistant with memory.\n\nI automatically remember things you tell me about yourself across our conversations.\n\n**Commands:**\n• \\`--remember\\` - Explicitly save a fact\n• \\`--memory\\` - Show what I remember\n• \\`--forget \\` - Remove a fact\n• \\`--clear\\` - Clear all memory\n• \\`--image\\` - Generate an image\n• \\`--video\\` - Generate a video\n• \\`--music\\` - Generate music\n• \\`--search\\` - Search the web\n• \\`--code\\` - Write code` });\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 const history = await getConversationHistory(conversationId, 10);\n const factsContext = await getFactsContext(userId);\n \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 : `❓ Couldn't find \"${cleanedContent}\" in memory. Use \\`--memory\\` to see what I remember.`;\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} fact${clearedCount !== 1 ? \"s\" : \"\"} 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(\n POE_MODELS.imageGeneration, cleanedContent, send, \"Image Generation\", 15000, true\n );\n break;\n \n case \"video_generation\":\n send(\"text\", { text: `🎬 Generating video...` });\n response = await callModelsWithFallback(\n POE_MODELS.videoGeneration, cleanedContent, send, \"Video Generation\", 30000, true\n );\n break;\n \n case \"music_generation\":\n send(\"text\", { text: `🎵 Composing music...` });\n response = await callModelsWithFallback(\n POE_MODELS.musicGeneration, cleanedContent, send, \"Music Generation\", 30000, true\n );\n break;\n \n case \"coding\":\n send(\"text\", { text: `💻 Writing code...` });\n response = await callModelsWithFallback(\n POE_MODELS.coding, cleanedContent, send, \"Coding\", 20000, false, history, factsContext\n );\n break;\n \n case \"search\":\n send(\"text\", { text: `🔍 Searching...` });\n response = await callModelsWithFallback(\n POE_MODELS.search, cleanedContent, send, \"Web Search\", 15000\n );\n break;\n \n case \"deep_research\":\n send(\"text\", { text: `🔬 Researching...` });\n response = await callModelsWithFallback(\n POE_MODELS.deepResearch, cleanedContent, send, \"Deep Research\", 30000\n );\n break;\n \n case \"image_analysis\":\n send(\"text\", { text: `🖼️ Analyzing image...` });\n response = await callModelsWithFallback(\n POE_MODELS.imageAnalysis, cleanedContent, send, \"Image Analysis\", 20000\n );\n break;\n \n case \"file_analysis\":\n send(\"text\", { text: `📄 Analyzing file...` });\n response = await callModelsWithFallback(\n POE_MODELS.fileAnalysis, cleanedContent, send, \"File Analysis\", 20000\n );\n break;\n \n case \"text_generation\":\n default:\n send(\"text\", { text: `💬 Thinking...` });\n response = await callModelsWithFallback(\n POE_MODELS.textGeneration, cleanedContent, send, \"Text Generation\", 15000, false, history, factsContext\n );\n break;\n }\n \n // Save bot response\n if (response) {\n await saveMessage(conversationId, \"assistant\", response, intent);\n \n // Extract facts in the background (non-blocking for text generation)\n if (intent === \"text_generation\" && cleanedContent.length > 10) {\n extractFactsWithLLM(userId, cleanedContent, response).catch(() => {});\n }\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: any) {\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: Record;\n};\n\ntype SendEventFn = (\n eventName: EventName,\n data: Events[EventName]\n) => void;\n\nfunction encodeEvent(event: string, data: any = {}): Uint8Array {\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 return new Response(null, {\n status: 204,\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization, X-API-Key, X-Bot-Access-Key\"\n }\n });\n }\n \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 let reqBody: any = {};\n try {\n reqBody = await req.json();\n } catch {\n return new Response(\n JSON.stringify({ error: \"Invalid JSON body\" }),\n { status: 400, headers: { \"Content-Type\": \"application/json\" } }\n );\n }\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: SendEventFn = (event, data) => {\n controller.enqueue(encodeEvent(event, data));\n };\n return getResponse(reqBody as Query, send)\n .catch((e: any) => {\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-02/code/main.tsx","extension","actionData","errors"]