[{"_1":2,"_172":-5,"_173":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":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","notificationCount",0,"flagDenols","ENV",{"_36":37,"_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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","5f86047c78fbcbbdc94436f811a86add7eaf8c7a","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",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":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",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_146":147,"_169":170,"_171":-5},"handle","yawnxyz","name","chatter","path","frontend/core/messages.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":72,"_110":-5,"_12":111,"_112":-5,"_113":20,"_114":-5,"_115":32,"_14":116,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_23":126,"_129":130,"_132":133,"_145":20},"id","b9276202-7616-11f0-8fe4-0224a6c84d84","createdAt",["D",1754850041617],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","a8270e74-6479-475a-8025-9b69544ee0e7","pinnedFileId","pinPreview","screenshotVersion","likeCount","8319defa-6e1a-46d4-ba66-2114ffd3360b","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://images.clerk.dev/oauth_github/img_2NnaHhpxNuH1xWRIRjQNoo16TVc.jpeg","org",{"_93":94,"_131":128},"avatar","branch",{"_134":135,"_95":43,"_101":136,"_137":102,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},"version",269,"b927b48c-7616-11f0-8fe4-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":148,"_95":149,"_150":151,"_152":153,"_154":136,"_155":156,"_157":158,"_103":159,"_134":32,"_160":161,"_162":163,"_164":20,"_165":-5,"_97":166},"3425ad76-a432-11f0-aaa2-0224a6c84d84","messages.ts","fileId","3425ae48-a432-11f0-aaa2-0224a6c84d84","parentId","8fdb7fc2-78f1-11f0-bbe7-0224a6c84d84","branchId","branchVersion",218,"latest",true,["D",1759919597863],"fileType","script","content","// Message operations\nimport type { UIMessage } from '../types.ts';\nimport type { AppState } from './db.ts';\nimport { slugifyTitle, loadChats, loadSessions } from './sessions.ts';\n\n/**\n * Ensure a chat exists for edits (creates if needed)\n */\nexport async function ensureChatExistsForEdits(state: AppState, opts: { force?: boolean } = {}): Promise {\n try {\n const force = !!opts.force;\n if (state.currentChatId && state.db) return state.currentChatId;\n if (!state.db) return null;\n \n // Only create a chat if there is some user-origin content or forced by the caller\n const hasUserInput = !!(state.chatInput && state.chatInput.trim());\n const hasUserMessage = Array.isArray(state.messages) && state.messages!.some(m => m && m.role === 'user' && String(m.content || '').trim());\n if (!force && !hasUserInput && !hasUserMessage) return null;\n \n const base = (state.chatInput && state.chatInput.trim()) || 'New chat';\n const title = base.substring(0, 60);\n const slug = slugifyTitle(title);\n const createdAt = Date.now();\n let id: number | null = null;\n \n // Prefer sessions\n try {\n if (state.db.sessions) {\n id = await state.db.sessions.add({\n title,\n slug,\n createdAt,\n updatedAt: createdAt,\n tree: {\n messages: [],\n branches: [{ id: 1, leafMessageId: null, name: 'main', createdAt }],\n activeBranchId: 1,\n branchingEnabled: true\n }\n });\n }\n } catch (_) {\n /* ignore */\n }\n \n if (!id) {\n id = await state.db.chats.add({ title, slug, createdAt });\n }\n \n // Load the appropriate list\n if (state.db.sessions) {\n await loadSessions(state);\n // Initialize session tree state\n state.sessionTree = {\n messages: [],\n branches: [{ id: 1, leafMessageId: null, name: 'main', createdAt }],\n activeBranchId: 1,\n branchingEnabled: true\n };\n state.currentBranchId = 1;\n } else {\n await loadChats(state);\n // Initialize per-chat prompt defaults (legacy mode only)\n try {\n await state.db.chats.update(id, { systemPromptId: null, systemPromptText: '' });\n } catch (_) {\n /* ignore */\n }\n }\n \n state.currentChatId = id;\n state.activeSearchId = id;\n try {\n typeof state.updateDocumentTitle === 'function' && state.updateDocumentTitle();\n } catch (_) {\n /* ignore */\n }\n return id;\n } catch (_) {\n return null;\n }\n}\n\n/**\n * Persist a message at an index\n */\nexport async function persistMessageAtIndex(state: AppState, idx: number): Promise {\n try {\n const m = state.messages?.[idx];\n if (!m || !state.db) return null;\n \n // If sessions exist, assign a stable local id if missing and return; saves are debounced\n if (state.db.sessions) {\n if (!m.id) {\n const nextId = (() => {\n try {\n const ids = (state.messages || []).map(mm => Number(mm.id || 0)).filter(n => Number.isFinite(n));\n const maxId = ids.length ? Math.max(...ids) : 0;\n return maxId + 1;\n } catch (_) {\n return (idx + 1);\n }\n })();\n state.messages![idx].id = nextId;\n }\n try {\n state.debouncedSaveSession && state.debouncedSaveSession();\n } catch (_) {\n /* ignore */\n }\n return state.messages![idx].id;\n }\n \n let chatId = state.currentChatId;\n if (!chatId) chatId = await ensureChatExistsForEdits(state, { force: true });\n if (!chatId) return null;\n \n const createdAt = m.createdAt || Date.now();\n const role = m.role || 'assistant';\n const content = String(m.content || '');\n const reasoning = String(m.reasoning || '');\n const row = {\n id: m.id,\n chatId,\n createdAt,\n role,\n content,\n reasoning,\n model: (m && m.model != null) ? m.model : null,\n promptLabel: (Object.prototype.hasOwnProperty.call(m, 'promptLabel') ? (m.promptLabel ?? null) : null)\n };\n \n const newId = await state.db.messages.put(row);\n if (!m.id) {\n state.messages![idx].id = newId;\n }\n state.messages![idx].chatId = chatId;\n state.messages![idx].createdAt = createdAt;\n return newId || m.id || null;\n } catch (_) {\n return null;\n }\n}\n\n/**\n * Delete a single message\n */\nexport async function deleteMessage(state: AppState, idx: number): Promise {\n try {\n if (!Array.isArray(state.messages) || idx == null || idx < 0 || idx >= state.messages!.length) return;\n \n const msg = state.messages![idx];\n const messageId = msg && msg.id != null ? msg.id : null;\n \n try {\n if (state.db && !state.db.sessions && messageId != null) {\n await state.db.messages.delete(messageId);\n }\n } catch (_) {\n /* ignore */\n }\n \n try {\n if (messageId != null) {\n if (state.messageReasoningMap && state.messageReasoningMap[messageId] != null) {\n delete state.messageReasoningMap[messageId];\n }\n if (state.expandedReasoningMap && state.expandedReasoningMap[messageId] != null) {\n delete state.expandedReasoningMap[messageId];\n }\n }\n } catch (_) {\n /* ignore */\n }\n \n try {\n state.messages!.splice(idx, 1);\n if (state.copiedMap && state.copiedMap[idx]) {\n delete state.copiedMap[idx];\n }\n } catch (_) {\n /* ignore */\n }\n \n if (state.editingMessageIdx === idx) {\n state.editingMessageIdx = null;\n state.editingMessageId = null;\n state.editingMessageText = '';\n state.editingMessageOriginal = '';\n } else if (typeof state.editingMessageIdx === 'number' && state.editingMessageIdx > idx) {\n state.editingMessageIdx = state.editingMessageIdx - 1;\n }\n } catch (_) {\n /* ignore */\n }\n}\n\n/**\n * Delete all messages below an index\n */\nexport async function deleteMessagesBelow(state: AppState, idx: number): Promise {\n try {\n if (!Array.isArray(state.messages) || idx == null || idx < 0 || idx >= state.messages!.length) return;\n \n const thisChatId = state.currentChatId;\n const toRemove = (state.messages || []).slice(idx + 1);\n \n try {\n if (state.db && !state.db.sessions) {\n for (const msg of toRemove) {\n const messageId = msg && msg.id != null ? msg.id : null;\n if (messageId != null) {\n try {\n await state.db.messages.delete(messageId);\n } catch (_) {\n /* ignore */\n }\n }\n if (messageId != null) {\n if (state.messageReasoningMap && state.messageReasoningMap[messageId] != null) {\n delete state.messageReasoningMap[messageId];\n }\n if (state.expandedReasoningMap && state.expandedReasoningMap[messageId] != null) {\n delete state.expandedReasoningMap[messageId];\n }\n }\n }\n }\n } catch (_) {\n /* ignore */\n }\n \n try {\n state.messages = (state.messages || []).slice(0, idx + 1);\n if (state.copiedMap) {\n try {\n const keys = Object.keys(state.copiedMap);\n for (const k of keys) {\n const i = Number(k);\n if (Number.isFinite(i) && i > idx) delete state.copiedMap[i];\n }\n } catch (_) {\n /* ignore */\n }\n }\n } catch (_) {\n /* ignore */\n }\n \n if (typeof state.editingMessageIdx === 'number' && state.editingMessageIdx > idx) {\n state.editingMessageIdx = null;\n state.editingMessageId = null;\n state.editingMessageText = '';\n state.editingMessageOriginal = '';\n }\n \n try {\n if (state.streamingChats && thisChatId && state.streamingChats[thisChatId]) {\n delete state.streamingChats[thisChatId];\n }\n } catch (_) {\n /* ignore */\n }\n \n state.scrollToBottom && state.scrollToBottom();\n } catch (_) {\n /* ignore */\n }\n}\n\n/**\n * Rerun from a user message (in sessions mode, this forks)\n */\nexport async function rerunFromUser(state: AppState, idx: number): Promise {\n try {\n if (state.isStreamingForCurrent) return;\n if (!Array.isArray(state.messages) || idx == null || idx < 0 || idx >= state.messages!.length) return;\n \n const m = state.messages![idx];\n if (!m || m.role !== 'user') return;\n \n // In sessions mode with branching enabled, use coreForkAtMessage to create a new branch\n if (state.db && state.db.sessions && state.sessionTree && state.sessionTree.branchingEnabled && state.currentChatId) {\n const { forkAtMessage: coreForkAtMessage } = await import('./branchManager.ts');\n await coreForkAtMessage(state, state.currentChatId, idx);\n return;\n }\n \n // Legacy mode\n try {\n state.messages = (state.messages || []).slice(0, idx + 1);\n if (state.copiedMap) {\n try {\n const keys = Object.keys(state.copiedMap);\n for (const k of keys) {\n const i = Number(k);\n if (Number.isFinite(i) && i > idx) delete state.copiedMap[i];\n }\n } catch (_) {\n /* ignore */\n }\n }\n } catch (_) {\n /* ignore */\n }\n \n if (typeof state.streamAssistant === 'function') {\n await state.streamAssistant();\n }\n } catch (_) {\n /* ignore */\n }\n}\n\n/**\n * Rerun / regenerate assistant response (in sessions mode, this forks)\n */\nexport async function rerunAssistant(state: AppState, idx: number): Promise {\n try {\n if (state.isStreamingForCurrent) return;\n if (!Array.isArray(state.messages) || idx == null || idx < 0 || idx >= state.messages!.length) return;\n \n const m = state.messages![idx];\n if (!m || m.role !== 'assistant') return;\n \n // In sessions mode with branching, use forkAndRegenerate\n if (state.db && state.db.sessions && state.sessionTree && state.sessionTree.branchingEnabled && state.currentChatId) {\n const { forkAndRegenerate: coreForkAndRegenerate } = await import('./branchManager.ts');\n await coreForkAndRegenerate(state, state.currentChatId, idx);\n return;\n }\n \n // Legacy mode: find previous user message\n let prevUserIdx = -1;\n for (let i = idx - 1; i >= 0; i--) {\n if (state.messages![i] && state.messages![i].role === 'user') {\n prevUserIdx = i;\n break;\n }\n }\n \n if (prevUserIdx < 0) return;\n \n try {\n state.messages = (state.messages || []).slice(0, prevUserIdx + 1);\n if (state.copiedMap) {\n try {\n const keys = Object.keys(state.copiedMap);\n for (const k of keys) {\n const i = Number(k);\n if (Number.isFinite(i) && i > prevUserIdx) delete state.copiedMap[i];\n }\n } catch (_) {\n /* ignore */\n }\n }\n } catch (_) {\n /* ignore */\n }\n \n if (typeof state.streamAssistant === 'function') {\n await state.streamAssistant();\n }\n } catch (_) {\n /* ignore */\n }\n}\n\n","deleted","label",[167,168,149],"frontend","core","permalink","https://www.val.town/x/yawnxyz/chatter/code/frontend/core/messages.ts","extension","actionData","errors"]