[{"_1":2,"_182":-5,"_183":-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","e045394ed6f334fd4e4536b7c7b55e16bdb48edc","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,"_179":180,"_181":-5},"handle","RobooHood","name","Public-Memory-GPT","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","a2254316-33db-11f1-948f-42b51c65c3df","createdAt",["D",1775715383597],"deletedAt","legacyEnvVars","privacy","public","description","https://poe.com/Public-Memory-GPT","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/86f4da1d-2498-489d-d4fb-154e4ac18500/square512","25a33e90-1def-11f0-8458-d7daa68fe194","pinnedFileId","019d70e2-799a-76aa-988d-622e571a753c","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","e54478ee-7c91-4914-a560-525ba174a661","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_98":99,"_141":142},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/dea1728e-0705-4aeb-d340-76cf90896100/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",10,"a22d084e-33db-11f1-948f-42b51c65c3df","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":171,"_172":173,"_174":175,"_176":20,"_177":-5,"_102":178},"b727ad7e-33e2-11f1-9fce-42b51c65c3df","fileId","parentId","branchId","branchVersion","latest",["D",1775718425354],9,"fileType","http","content","import serve, { events, forward } from \"https://esm.town/v/jeffreyyoung/poe_bot?v=46\";\n\n/* ── Bot roster ───────────────────────────────────────────── */\nconst PRIMARY_BOT = \"GPT-5.3-Codex-Spark\";\nconst FALLBACK_BOTS = [\"Kimi-K2.5-FW\", \"Qwen3.5-397B-A17B-T\", \"Gemma-4-31B\"] as const;\nconst SEARCH_BOT = \"Gemma-4-31B\";\nconst INTENT_BOT = \"Gemma-4-31B\";\nconst MEMORY_DB = \"Memory-DB\";\n\nconst OMNI_EXTS = new Set([\"webp\",\"xlsx\",\"py\",\"html\",\"js\",\"csv\",\"docx\",\"mp3\",\"mp4\",\"pdf\"]);\nconst IMAGE_EXTS = new Set([\"png\",\"jpg\",\"jpeg\",\"gif\",\"avif\",\"tiff\",\"ico\",\"svg\",\"heic\"]);\nconst FLAG_RE = /--(?:search|image|upscale|poe|video|voice)\\b/g;\n\ntype BotKey = \"omni\"|\"cheapOmni\"|\"deepseekV3\"|\"chat\"|\"search\"|\"image\"|\"upscale\"|\"poe\"|\"video\"|\"voice\";\n\nconst BOTS: Record = {\n omni: PRIMARY_BOT,\n cheapOmni: \"Kimi-K2.5-FW\",\n deepseekV3: PRIMARY_BOT,\n chat: PRIMARY_BOT,\n search: SEARCH_BOT,\n image: \"Image-Photo\",\n upscale: \"Clarity-Upscaler\",\n poe: \"Poe-Bot-Finder\",\n video: \"Wan-2.6-N\",\n voice: \"Sonic-3.0\",\n};\n\nconst MEMORY_BOT_KEYS = new Set([\"chat\",\"omni\",\"cheapOmni\",\"deepseekV3\"]);\n\n/* ── Helpers ──────────────────────────────────────────────── */\n\nfunction ext(url: string): string {\n return (url.split(\"?\")[0].split(\".\").pop() ?? \"\").toLowerCase();\n}\n\nfunction mimeBase(ct: string): string {\n return (ct ?? \"\").split(\"/\")[0].toLowerCase();\n}\n\nfunction buildGenericRateCard(): string {\n return (\n \"| Type | Rate (USD) | Rate (Points) |\\n\" +\n \"|------|------------|---------------|\\n\" +\n \"| Text Input | $0.90/1M tokens | 30 pts/1k tokens |\\n\" +\n \"| Text Output | $1.71/1M tokens | 60 pts/1k tokens |\\n\" +\n \"| Image/Media | Variable | Variable |\"\n );\n}\n\n/** FIX 1: Race a promise against a timeout to prevent hanging auxiliary calls. */\nfunction withTimeout(promise: Promise, ms: number, label: string): Promise {\n return new Promise((resolve, reject) => {\n const timer = setTimeout(() => reject(new Error(`${label} timed out after ${ms}ms`)), ms);\n promise.then(\n (v) => { clearTimeout(timer); resolve(v); },\n (e) => { clearTimeout(timer); reject(e); },\n );\n });\n}\n\nfunction resolveBot(req: any): BotKey {\n const lastMsg = req.query.at(-1);\n const content = (lastMsg?.content ?? \"\").toLowerCase();\n const attachments = lastMsg?.attachments ?? [];\n\n if (content.includes(\"--search\")) return \"search\";\n if (content.includes(\"--image\")) return \"image\";\n if (content.includes(\"--upscale\")) return \"upscale\";\n if (content.includes(\"--poe\")) return \"poe\";\n if (content.includes(\"--video\")) return \"video\";\n if (content.includes(\"--voice\")) return \"voice\";\n\n if (attachments.length > 0) {\n const { url = \"\", content_type = \"\" } = attachments[0];\n const e = ext(url);\n const mb = mimeBase(content_type);\n if (e === \"bmp\" || content_type === \"image/bmp\") return \"deepseekV3\";\n if (OMNI_EXTS.has(e)) return \"omni\";\n if (IMAGE_EXTS.has(e) || mb === \"image\") return \"cheapOmni\";\n if (mb === \"audio\" || mb === \"video\") return \"omni\";\n return \"omni\";\n }\n return \"chat\";\n}\n\nfunction stripFlags(req: any): any {\n const query = req.query.map((m: any) => ({ ...m }));\n const last = query.at(-1);\n if (last?.role === \"user\" && typeof last.content === \"string\") {\n last.content = last.content.replace(FLAG_RE, \"\").trim();\n }\n return { ...req, query };\n}\n\nfunction auxReq(req: any, text: string): any {\n return {\n ...req,\n query: [{\n role: \"user\",\n content: text,\n message_id: `aux_${Date.now()}_${Math.random().toString(36).slice(2, 8)}`,\n attachments: [],\n }],\n };\n}\n\n/** FIX 2: Guard against non-text events (e.g. \"done\", \"error\") when collecting. */\nasync function collectText(stream: AsyncIterable): Promise {\n let out = \"\";\n for await (const msg of stream) {\n if (msg.event === \"text\") out += msg.data?.text ?? \"\";\n if (msg.event === \"error\") throw new Error(msg.data?.text ?? \"stream error\");\n }\n return out;\n}\n\n/* ── Memory layer (all calls are time-boxed) ─────────────── */\n\nconst AUX_TIMEOUT_MS = 4_000; // per memory-db call\nconst INTENT_TIMEOUT_MS = 5_000; // intent classification\nconst MEMORY_TOTAL_MS = 10_000; // total budget for the whole memory phase\n\nasync function memOp(req: any, cmd: string): Promise {\n return withTimeout(\n collectText(forward({ query: auxReq(req, cmd), toBotName: MEMORY_DB, accessKey: req.access_key })),\n AUX_TIMEOUT_MS,\n `memOp(${cmd.slice(0, 30)})`,\n );\n}\n\ninterface MemOp {\n action: \"get\"|\"search\"|\"store\"|\"random_fact\"|\"none\";\n keyword?: string;\n topic?: string;\n content?: string;\n emotion?: string;\n importance?: number;\n}\n\nfunction parseOps(text: string): MemOp[] {\n const m = text.match(/```json\\s*(\\{.*?\\})\\s*```/s) ?? text.match(/(\\{.*\\})/s);\n if (!m) return [{ action: \"none\" }];\n try {\n const p = JSON.parse(m[1]);\n if (Array.isArray(p?.operations)) return p.operations;\n } catch { /* malformed JSON → skip */ }\n return [{ action: \"none\" }];\n}\n\nasync function analyzeIntent(req: any, userText: string, chatCtx: string): Promise {\n const ctx = chatCtx ? `\\n\\nRecent conversation:\\n${chatCtx}` : \"\";\n const prompt =\n `Decide what memory operations to perform.\\nUser: \"${userText}\"${ctx}\\n\\n` +\n `Operations: \"search\" (keyword), \"get\", \"store\" (topic, content, emotion?, importance 1-10), \"random_fact\", \"none\".\\n` +\n `Output ONLY:\\n\\`\\`\\`json\\n{\"operations\":[{\"action\":\"none\"}]}\\n\\`\\`\\``;\n\n const raw = await withTimeout(\n collectText(forward({ query: auxReq(req, prompt), toBotName: INTENT_BOT, accessKey: req.access_key })),\n INTENT_TIMEOUT_MS,\n \"analyzeIntent\",\n );\n return parseOps(raw);\n}\n\n/**\n * FIX 3: Wrap the entire memory phase in a total timeout so that even if\n * individual calls succeed but the sum is too slow, we gracefully degrade.\n */\nasync function buildMemoryCtx(req: any, userText: string, history: any[]): Promise {\n try {\n return await withTimeout(\n _buildMemoryCtxInner(req, userText, history),\n MEMORY_TOTAL_MS,\n \"buildMemoryCtx\",\n );\n } catch {\n // Memory is optional — if it times out or errors, just skip it.\n return \"\";\n }\n}\n\nasync function _buildMemoryCtxInner(req: any, userText: string, history: any[]): Promise {\n const chatCtx = history.slice(-6)\n .map((m: any) => `${m.role === \"user\" ? \"User\" : \"Bot\"}: ${(m.content ?? \"\").slice(0, 200)}`)\n .join(\"\\n\");\n\n const ops = await analyzeIntent(req, userText, chatCtx);\n const parts: string[] = [];\n\n /**\n * FIX 4: Run independent memory ops in parallel instead of sequentially.\n * Separate into \"fire-and-forget\" stores vs. reads that we need results from.\n */\n const readPromises: Promise[] = [];\n const storePromises: Promise[] = [];\n\n for (const op of ops) {\n switch (op.action) {\n case \"get\":\n readPromises.push(\n memOp(req, \"GET\")\n .then((r) => `[Top memories]:\\n${r}`)\n .catch(() => null),\n );\n break;\n\n case \"search\":\n if (op.keyword) {\n readPromises.push(\n memOp(req, `SEARCH\\ntopic: ${op.keyword}`)\n .then((r) => `[Memories '${op.keyword}']:\\n${r}`)\n .catch(() => null),\n );\n }\n break;\n\n case \"store\": {\n const imp = Math.max(1, Math.min(10, op.importance ?? 5));\n let cmd = `POST\\ntopic: ${op.topic ?? \"general\"}\\ncontent: ${op.content ?? userText}`;\n if (op.emotion) cmd += `\\nemotion: ${op.emotion}`;\n cmd += `\\nimportance: ${imp}`;\n // Stores don't block the response — fire and forget.\n storePromises.push(\n memOp(req, cmd)\n .then((r) => { parts.push(`[Stored '${op.topic ?? \"general\"}']:\\n${r}`); })\n .catch(() => {}),\n );\n break;\n }\n\n case \"random_fact\":\n readPromises.push(\n memOp(req, \"GET\")\n .then((raw) => {\n const mems = JSON.parse(raw);\n if (Array.isArray(mems) && mems.length) {\n const m = mems[Math.floor(Math.random() * mems.length)];\n return `[Random fact — topic:'${m.topic}', content:'${m.content}'. Share naturally.]`;\n }\n return null;\n })\n .catch(() => null),\n );\n break;\n\n case \"none\":\n default:\n break;\n }\n }\n\n // Wait for reads (we need them for context) + stores (best-effort).\n const [reads] = await Promise.all([\n Promise.all(readPromises),\n Promise.allSettled(storePromises),\n ]);\n\n for (const r of reads) {\n if (r) parts.push(r);\n }\n\n return parts.join(\"\\n\\n\");\n}\n\n/* ── Forwarding with fallback ─────────────────────────────── */\n\n/**\n * FIX 5: Buffer a small amount from each bot before yielding, so that if the\n * first bot immediately errors we don't send partial junk to the user.\n * Also properly pass `query` — not the raw request — to `forward()`.\n */\nasync function* forwardWithFallback(\n req: any,\n primary: string,\n fallbacks: readonly string[],\n): AsyncGenerator {\n const chain = [primary, ...fallbacks];\n\n for (let i = 0; i < chain.length; i++) {\n const bot = chain[i];\n try {\n const stream = forward({ query: req, toBotName: bot, accessKey: req.access_key });\n const buffer: any[] = [];\n let errored = false;\n\n for await (const msg of stream) {\n if (msg.event === \"error\") {\n errored = true;\n break;\n }\n // Buffer the first message to make sure the bot is actually responding.\n if (buffer.length === 0) {\n buffer.push(msg);\n // First chunk received — flush buffer and stream the rest directly.\n for (const b of buffer) yield b;\n } else {\n yield msg;\n }\n }\n\n // If we buffered something and didn't error, we're done.\n if (!errored && buffer.length > 0) return;\n // If errored but we already yielded text, we can't cleanly retry.\n if (errored && buffer.length > 0) return;\n // Otherwise try next bot in chain.\n } catch {\n // Network / runtime error — try next bot.\n }\n }\n\n yield events.text(\"❌ All bots in the fallback chain failed. Please try again.\");\n}\n\n/* ── System prompt ────────────────────────────────────────── */\n\nconst SYSTEM_PROMPT =\n \"You are a helpful AI assistant with persistent memory. \" +\n \"Reference past memories naturally ('I remember you mentioned…'). \" +\n \"Acknowledge newly stored memories briefly. \" +\n \"Share random facts lightheartedly. If no memories are relevant, chat normally without mentioning them.\";\n\n/* ── Main handler ─────────────────────────────────────────── */\n\nexport default serve({\n async *handleMessage(req) {\n yield events.meta({ content_type: \"text/markdown\", suggested_replies: true });\n\n const botKey = resolveBot(req);\n const cleaned = stripFlags(req);\n const lastMsg = cleaned.query.at(-1);\n let finalReq = cleaned;\n\n /* Build memory context (time-boxed, non-fatal). */\n if (MEMORY_BOT_KEYS.has(botKey) && lastMsg?.role === \"user\") {\n const userText = lastMsg.content as string;\n const memCtx = await buildMemoryCtx(req, userText, cleaned.query.slice(0, -1));\n\n if (memCtx) {\n const augmented = [...cleaned.query];\n augmented[augmented.length - 1] = {\n ...lastMsg,\n content:\n `[SYSTEM]: ${SYSTEM_PROMPT}\\n\\n` +\n `---\\n[INTERNAL MEMORY CONTEXT — incorporate naturally, never expose raw data]:\\n${memCtx}\\n---\\n\\n` +\n `User: ${userText}`,\n };\n finalReq = { ...cleaned, query: augmented };\n }\n }\n\n /** FIX 6: Proper error handling with unknown-typed catch. */\n try {\n yield* forwardWithFallback(\n finalReq,\n BOTS[botKey],\n botKey === \"search\" ? [] : [...FALLBACK_BOTS],\n );\n } catch (e: unknown) {\n const msg = e instanceof Error ? e.message : String(e);\n yield events.text(`❌ Routing failed: ${msg}`);\n }\n\n yield events.done();\n },\n\n settings: {\n allow_attachments: true,\n expand_text_attachments: false,\n enable_multi_bot_chat_prompting: true,\n enable_suggested_replies: true,\n rate_card: buildGenericRateCard(),\n supports_system_messages: true,\n suggested_replies: true,\n server_bot_dependencies: {\n ...Object.fromEntries(Object.values(BOTS).map((n) => [n, 1])),\n [MEMORY_DB]: 1,\n [INTENT_BOT]: 1,\n },\n },\n});","deleted","label",[103],"permalink","https://www.val.town/x/RobooHood/Public-Memory-GPT/code/main.tsx","extension","actionData","errors"]