[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_110":111,"_112":113},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","yuxiaoy","name","cursor-chat","path","frontend/components/App.tsx","project",{"_22":49,"_11":12,"_35":50,"_51":-5,"_52":44,"_53":54,"_55":54,"_56":57,"_58":-5,"_59":60,"_61":62,"_63":34,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":75,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":87,"_88":89,"_90":91,"_92":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/yuxiaoy/cursor-chat/code/frontend/components/App.tsx","extension","id","2c488306-9ddd-4da9-a71e-88d889c4a629","App.tsx","fileId","01a0284c-1b46-711a-b262-fe9b76e404e7","parentId","01a0284c-1b46-711a-b263-0403d2c98081","branchId","6924747a-bd7f-44f6-8ed7-64b4b4bc8bc0","branchVersion",345,"latest",true,"createdAt",["D",1787842564256],"version",105,"fileType","script","content","/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useEffect, useRef, useState } from \"https://esm.sh/react@18.2.0?target=es2020\";\nimport { IconMenu, IconPlus } from \"./icons.tsx\";\nimport { LoginForm } from \"./Login.tsx\";\nimport { Sidebar } from \"./Sidebar.tsx\";\nimport { Transcript } from \"./Transcript.tsx\";\nimport { Composer } from \"./Composer.tsx\";\nimport { applyLiveEvent, emptyLive, readSse } from \"../sse.ts\";\nimport {\n type ChatItem,\n type ChatMode,\n type ChatMsg,\n type Model,\n type Status,\n clampSidebarW,\n DEFAULT_MAX_KEY,\n DEFAULT_MODE_KEY,\n DEFAULT_MODEL_KEY,\n draftKey,\n friendlyError,\n isDesktopMq,\n nextTempId,\n pushMsg,\n readSidebarW,\n readStore,\n SIDEBAR_COLLAPSE_KEY,\n SIDEBAR_DEFAULT,\n SIDEBAR_W_KEY,\n splitStoredModel,\n writeStore,\n} from \"../lib.ts\";\n\nexport function App() {\n const [status, setStatus] = useState(null);\n const [agentId, setAgentId] = useState(readStore(\"cursorChatAgentId\"));\n const [modelId, setModelId] = useState(splitStoredModel(readStore(DEFAULT_MODEL_KEY) || readStore(\"cursorChatModel\")).id);\n const [maxMode, setMaxMode] = useState(\n readStore(DEFAULT_MAX_KEY) === \"1\" || splitStoredModel(readStore(DEFAULT_MODEL_KEY) || readStore(\"cursorChatModel\")).max,\n );\n const [mode, setMode] = useState(\n readStore(DEFAULT_MODE_KEY) === \"plan\" || readStore(\"cursorChatMode\") === \"plan\" ? \"plan\" : \"agent\",\n );\n const [models, setModels] = useState([]);\n const [chats, setChats] = useState([]);\n const [input, setInput] = useState(\"\");\n const [busy, setBusy] = useState(false);\n const [stopping, setStopping] = useState(false);\n const [sidebar, setSidebar] = useState(false);\n const [sidebarW, setSidebarW] = useState(readSidebarW);\n const [desktopCollapsed, setDesktopCollapsed] = useState(readStore(SIDEBAR_COLLAPSE_KEY) === \"1\");\n const [desktop, setDesktop] = useState(isDesktopMq);\n const [resizing, setResizing] = useState(false);\n const [editingTitle, setEditingTitle] = useState(false);\n const [titleDraft, setTitleDraft] = useState(\"\");\n const [pendingDelete, setPendingDelete] = useState<{ id: string; seconds: number } | null>(null);\n const [messages, setMessages] = useState([]);\n const [live, setLive] = useState | null>(null);\n const [atBottom, setAtBottom] = useState(true);\n const bottom = useRef(null);\n const scroller = useRef(null);\n const atBottomRef = useRef(true);\n const box = useRef(null);\n const runRef = useRef<{ agentId: string; runId?: string } | null>(null);\n const cancelledRef = useRef(false);\n const streamAbort = useRef(null);\n const busyRef = useRef(false);\n const agentIdRef = useRef(agentId);\n const msgSeq = useRef(0);\n const resumeLock = useRef(null);\n const opRef = useRef(0);\n const drafts = useRef>({});\n const msgCache = useRef>({});\n const lastUserText = useRef(\"\");\n const pendingTimer = useRef(0);\n const pendingChat = useRef(null);\n const inputRef = useRef(input);\n const messagesRef = useRef(messages);\n const sidebarWRef = useRef(sidebarW);\n inputRef.current = input;\n messagesRef.current = messages;\n sidebarWRef.current = sidebarW;\n\n function rememberCurrent() {\n drafts.current[draftKey(agentIdRef.current)] = inputRef.current;\n if (agentIdRef.current) msgCache.current[agentIdRef.current] = messagesRef.current;\n }\n\n function setAgent(id: string | null) {\n rememberCurrent();\n agentIdRef.current = id;\n setAgentId(id);\n if (id) localStorage.setItem(\"cursorChatAgentId\", id);\n else localStorage.removeItem(\"cursorChatAgentId\");\n setInput(drafts.current[draftKey(id)] ?? \"\");\n setEditingTitle(false);\n }\n\n function markBusy(next: boolean) {\n busyRef.current = next;\n setBusy(next);\n if (!next) setStopping(false);\n }\n\n async function api(url: string, init?: RequestInit) {\n const res = await fetch(url, init);\n if (res.status === 401) {\n setStatus((s) => ({ configured: s?.configured ?? true, authed: false, mcp: s?.mcp }));\n throw new Error(\"登录已过期，请重新登录\");\n }\n return res;\n }\n\n async function refreshStatus() {\n try {\n setStatus(await (await fetch(\"/api/status\")).json());\n } catch {\n setStatus({ configured: false, authed: false });\n }\n }\n\n async function refreshChats() {\n try {\n const res = await api(\"/api/chats\");\n const data = await res.json();\n if (res.ok) setChats(data.items ?? []);\n } catch {\n // 401 already handled\n }\n }\n\n function patchChat(id: string, patch: Partial) {\n setChats((list) => {\n const idx = list.findIndex((item) => item.id === id);\n if (idx === -1) {\n return [{ id, title: patch.title || \"新对话\", ...patch }, ...list];\n }\n const next = [...list];\n next[idx] = { ...next[idx], ...patch };\n return next;\n });\n }\n\n async function loadWorkspace() {\n try {\n const [modelRes, chatRes] = await Promise.all([api(\"/api/models\"), api(\"/api/chats\")]);\n const modelData = await modelRes.json();\n const chatData = await chatRes.json();\n if (modelRes.ok) {\n const items = (modelData.items ?? []) as Model[];\n setModels(items);\n setModelId((current) => {\n const matched = items.find((item) => item.id === current);\n if (!matched && items[0]) {\n writeStore(DEFAULT_MODEL_KEY, items[0].id);\n return items[0].id;\n }\n return current;\n });\n setMaxMode((on) => {\n const current = splitStoredModel(readStore(DEFAULT_MODEL_KEY)).id || modelId;\n const matched = items.find((item) => item.id === current);\n if (matched && !matched.supportsMax && on) {\n writeStore(DEFAULT_MAX_KEY, \"0\");\n return false;\n }\n return on;\n });\n }\n if (chatRes.ok) setChats(chatData.items ?? []);\n } catch {\n // 401 already handled\n }\n }\n\n async function loadMessages(id: string) {\n const seq = ++msgSeq.current;\n try {\n const res = await api(`/api/chats/${id}/messages`);\n const data = await res.json();\n if (!res.ok || seq !== msgSeq.current || agentIdRef.current !== id) return;\n const items = (data.items ?? []).map((row: { id?: number; role: string; text: string }) => ({\n id: row.id ?? nextTempId(),\n role: row.role,\n text: row.text,\n })) as ChatMsg[];\n setMessages(items);\n msgCache.current[id] = items;\n const sync = await api(`/api/chats/${id}/sync`, { method: \"POST\" }).then((r) => r.json()).catch(() => null);\n if (seq !== msgSeq.current || agentIdRef.current !== id) return;\n if (sync?.appended) {\n setMessages((m) => {\n const next = pushMsg(m, { id: nextTempId(), role: \"assistant\", text: sync.appended.text });\n msgCache.current[id] = next;\n return next;\n });\n }\n const liveRun = sync?.live as { runId?: string; status?: string } | null;\n if (liveRun?.runId && !busyRef.current) {\n void resumeRun(id, liveRun.runId);\n }\n } catch (err) {\n if (seq !== msgSeq.current || agentIdRef.current !== id) return;\n setMessages((m) => pushMsg(m, { id: nextTempId(), role: \"system\", text: friendlyError(err) }));\n }\n }\n\n useEffect(() => {\n refreshStatus();\n }, []);\n\n useEffect(() => {\n if (status?.authed) loadWorkspace();\n }, [status?.authed]);\n\n useEffect(() => {\n if (!status?.authed || !agentId) return;\n if (busyRef.current && runRef.current?.agentId === agentId) return;\n loadMessages(agentId);\n }, [status?.authed, agentId]);\n\n useEffect(() => {\n if (!atBottomRef.current) {\n syncBottom();\n return;\n }\n bottom.current?.scrollIntoView({ behavior: \"smooth\" });\n }, [messages, busy, live]);\n\n useEffect(() => {\n const el = box.current;\n if (!el) return;\n el.style.height = \"auto\";\n el.style.height = `${Math.min(el.scrollHeight, Math.round(16 * 1.4 * 6))}px`;\n }, [input]);\n\n useEffect(() => {\n const mq = matchMedia(\"(min-width: 768px)\");\n const on = () => setDesktop(mq.matches);\n mq.addEventListener(\"change\", on);\n return () => mq.removeEventListener(\"change\", on);\n }, []);\n\n useEffect(() => {\n const timers = new Map();\n const onScroll = (e: Event) => {\n const el = e.target;\n if (!(el instanceof HTMLElement) || el === document.body || el === document.documentElement) return;\n el.classList.add(\"is-scrolling\");\n const prev = timers.get(el);\n if (prev) clearTimeout(prev);\n timers.set(el, window.setTimeout(() => {\n el.classList.remove(\"is-scrolling\");\n timers.delete(el);\n }, 700));\n };\n document.addEventListener(\"scroll\", onScroll, { capture: true, passive: true });\n return () => {\n document.removeEventListener(\"scroll\", onScroll, true);\n for (const id of timers.values()) clearTimeout(id);\n };\n }, []);\n\n function setCollapsed(next: boolean) {\n setDesktopCollapsed(next);\n writeStore(SIDEBAR_COLLAPSE_KEY, next ? \"1\" : \"0\");\n }\n\n function applySidebarW(n: number) {\n const next = clampSidebarW(n);\n sidebarWRef.current = next;\n setSidebarW(next);\n return next;\n }\n\n function persistSidebarW(n = sidebarWRef.current) {\n writeStore(SIDEBAR_W_KEY, String(n));\n }\n\n function startResize(e: PointerEvent) {\n if (e.button !== 0 || desktopCollapsed) return;\n e.preventDefault();\n const startX = e.clientX;\n const startW = sidebarWRef.current;\n setResizing(true);\n const move = (ev: PointerEvent) => {\n applySidebarW(startW + ev.clientX - startX);\n };\n const up = () => {\n window.removeEventListener(\"pointermove\", move);\n window.removeEventListener(\"pointerup\", up);\n setResizing(false);\n persistSidebarW();\n };\n window.addEventListener(\"pointermove\", move);\n window.addEventListener(\"pointerup\", up);\n }\n\n function nearBottom(el: HTMLElement) {\n return el.scrollHeight - el.scrollTop - el.clientHeight < 64;\n }\n\n function syncBottom() {\n const el = scroller.current;\n if (!el) return;\n const next = nearBottom(el);\n atBottomRef.current = next;\n setAtBottom(next);\n }\n\n function jumpBottom() {\n atBottomRef.current = true;\n setAtBottom(true);\n bottom.current?.scrollIntoView({ behavior: \"smooth\" });\n }\n\n function pickMode(next: ChatMode, asDefault = false) {\n setMode(next);\n if (!agentIdRef.current || asDefault) writeStore(DEFAULT_MODE_KEY, next);\n }\n\n function pickModel(next: string, asDefault = false) {\n setModelId(next);\n if (!agentIdRef.current || asDefault) writeStore(DEFAULT_MODEL_KEY, next);\n const item = models.find((model) => model.id === next);\n if (!item?.supportsMax && maxMode) {\n setMaxMode(false);\n if (!agentIdRef.current || asDefault) writeStore(DEFAULT_MAX_KEY, \"0\");\n }\n }\n\n function pickMax(next: boolean, asDefault = false) {\n setMaxMode(next);\n if (!agentIdRef.current || asDefault) writeStore(DEFAULT_MAX_KEY, next ? \"1\" : \"0\");\n }\n\n async function logout() {\n if (busyRef.current) await cancelRun();\n opRef.current += 1;\n markBusy(false);\n await fetch(\"/api/logout\", { method: \"POST\" });\n setAgent(null);\n setMessages([]);\n await refreshStatus();\n }\n\n function newChat() {\n msgSeq.current += 1;\n setAgent(null);\n setMessages([]);\n setSidebar(false);\n setModelId(readStore(DEFAULT_MODEL_KEY) || modelId);\n setMaxMode(readStore(DEFAULT_MAX_KEY) === \"1\");\n setMode(readStore(DEFAULT_MODE_KEY) === \"plan\" ? \"plan\" : \"agent\");\n atBottomRef.current = true;\n setAtBottom(true);\n box.current?.focus();\n }\n\n async function openChat(id: string) {\n if (id === agentIdRef.current) {\n setSidebar(false);\n return;\n }\n const chat = chats.find((item) => item.id === id);\n setAgent(id);\n const cached = msgCache.current[id];\n setMessages(cached ?? []);\n if (chat?.mode === \"plan\" || chat?.mode === \"agent\") setMode(chat.mode);\n if (chat?.model) {\n const stored = splitStoredModel(chat.model);\n setModelId(stored.id);\n setMaxMode(stored.max);\n }\n setSidebar(false);\n atBottomRef.current = true;\n setAtBottom(true);\n }\n\n function askDelete(id: string, e: Event) {\n e.stopPropagation();\n if (busyRef.current && runRef.current?.agentId === id) return;\n if (pendingDelete?.id && pendingDelete.id !== id) undoDelete();\n const chat = chats.find((item) => item.id === id) ?? null;\n pendingChat.current = chat;\n setChats((list) => list.filter((item) => item.id !== id));\n setPendingDelete({ id, seconds: 5 });\n window.clearInterval(pendingTimer.current);\n pendingTimer.current = window.setInterval(() => {\n setPendingDelete((cur) => {\n if (!cur || cur.id !== id) return cur;\n if (cur.seconds <= 1) {\n window.clearInterval(pendingTimer.current);\n void finalizeDelete(id);\n return null;\n }\n return { id, seconds: cur.seconds - 1 };\n });\n }, 1000);\n }\n\n async function finalizeDelete(id: string) {\n try {\n const res = await api(`/api/chats/${id}`, { method: \"DELETE\" });\n if (!res.ok) {\n const data = await res.json().catch(() => ({ error: \"删除失败\" }));\n undoDelete();\n setMessages((m) => pushMsg(m, { id: nextTempId(), role: \"system\", text: data.error ?? \"删除失败\" }));\n return;\n }\n delete msgCache.current[id];\n delete drafts.current[id];\n pendingChat.current = null;\n if (agentIdRef.current === id) newChat();\n } catch (err) {\n undoDelete();\n setMessages((m) => pushMsg(m, { id: nextTempId(), role: \"system\", text: friendlyError(err) }));\n }\n }\n\n function undoDelete() {\n window.clearInterval(pendingTimer.current);\n const chat = pendingChat.current;\n if (chat) setChats((list) => list.some((item) => item.id === chat.id) ? list : [chat, ...list]);\n pendingChat.current = null;\n setPendingDelete(null);\n }\n\n async function saveTitle() {\n const id = agentIdRef.current;\n const title = titleDraft.trim();\n setEditingTitle(false);\n if (!id || !title) return;\n patchChat(id, { title });\n await api(`/api/chats/${id}/title`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ title }),\n }).catch(() => undefined);\n }\n\n function appendHere(id: string, msg: ChatMsg) {\n if (!id) return;\n if (agentIdRef.current === id) {\n setMessages((m) => {\n const next = pushMsg(m, msg);\n msgCache.current[id] = next;\n return next;\n });\n return;\n }\n msgCache.current[id] = pushMsg(msgCache.current[id] ?? [], msg);\n }\n\n async function finishTurn(ids: { agentId: string; runId: string }, streamed: string, maxWait = 180) {\n if (cancelledRef.current) {\n if (streamed) appendHere(ids.agentId, { id: nextTempId(), role: \"assistant\", text: streamed });\n patchChat(ids.agentId, { status: \"CANCELLED\", runId: ids.runId, updatedAt: new Date().toISOString() });\n void refreshChats();\n return;\n }\n const finalized = await waitForRun(ids.agentId, ids.runId, maxWait).catch(() => streamed);\n const reply = finalized || streamed || \"（已完成，没有文字回复）\";\n appendHere(ids.agentId, { id: nextTempId(), role: \"assistant\", text: reply });\n patchChat(ids.agentId, { status: \"FINISHED\", runId: ids.runId, updatedAt: new Date().toISOString() });\n void refreshChats();\n }\n\n async function resumeRun(nextAgentId: string, runId: string) {\n const key = `${nextAgentId}:${runId}`;\n if (resumeLock.current === key || busyRef.current) return;\n const op = ++opRef.current;\n resumeLock.current = key;\n markBusy(true);\n setLive(emptyLive());\n cancelledRef.current = false;\n runRef.current = { agentId: nextAgentId, runId };\n atBottomRef.current = true;\n setAtBottom(true);\n try {\n const result = await streamRun(nextAgentId, runId, 30);\n await finishTurn({ agentId: nextAgentId, runId }, result || \"\", 30);\n } catch (err) {\n if (cancelledRef.current) return;\n appendHere(nextAgentId, { id: nextTempId(), role: \"system\", text: friendlyError(err) });\n } finally {\n if (resumeLock.current === key) resumeLock.current = null;\n if (opRef.current !== op) return;\n streamAbort.current = null;\n runRef.current = null;\n setLive(null);\n markBusy(false);\n }\n }\n\n async function send(e?: Event, preset?: string) {\n e?.preventDefault();\n const text = (preset ?? input).trim();\n if (!text || busyRef.current) return;\n lastUserText.current = text;\n const op = ++opRef.current;\n let committed = false;\n drafts.current[draftKey(agentIdRef.current)] = \"\";\n setInput(\"\");\n const thread: ChatMsg[] = [...messagesRef.current, { id: nextTempId(), role: \"user\", text }];\n setMessages(thread);\n if (agentIdRef.current) msgCache.current[agentIdRef.current] = thread;\n markBusy(true);\n setLive(emptyLive());\n atBottomRef.current = true;\n setAtBottom(true);\n cancelledRef.current = false;\n runRef.current = agentId ? { agentId } : null;\n try {\n const started = await api(\"/api/chat\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ text, agentId, modelId, mode, maxMode }),\n });\n const data = await started.json();\n if (!started.ok) throw new Error(data.error ?? \"发送失败\");\n if (data.agentId) {\n committed = true;\n runRef.current = { agentId: data.agentId, runId: data.runId };\n patchChat(data.agentId, {\n ...(agentId ? {} : { title: text.slice(0, 48) }),\n status: \"RUNNING\",\n runId: data.runId,\n model: maxMode ? `${modelId}|max` : modelId,\n mode,\n updatedAt: new Date().toISOString(),\n });\n setAgent(data.agentId);\n msgCache.current[data.agentId] = messagesRef.current;\n }\n if (cancelledRef.current) {\n await requestCancel(data.agentId || agentId, data.runId);\n return;\n }\n const ids = await waitForIds(data);\n if (cancelledRef.current) {\n await requestCancel(ids.agentId, ids.runId);\n return;\n }\n setAgent(ids.agentId);\n runRef.current = ids;\n if (!data.agentId) {\n await api(\"/api/messages\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ agentId: ids.agentId, text, model: modelId }),\n });\n committed = true;\n patchChat(ids.agentId, {\n ...(agentId ? {} : { title: text.slice(0, 48) }),\n status: \"RUNNING\",\n runId: ids.runId,\n updatedAt: new Date().toISOString(),\n });\n }\n const result = await streamRun(ids.agentId, ids.runId);\n await finishTurn(ids, result || \"\");\n } catch (err) {\n if (cancelledRef.current) return;\n const message = friendlyError(err);\n setMessages((m) => {\n let next = m;\n if (!committed) {\n for (let i = m.length - 1; i >= 0; i--) {\n if (m[i].role === \"user\" && m[i].text === text) {\n next = [...m.slice(0, i), ...m.slice(i + 1)];\n break;\n }\n if (m[i].role === \"assistant\") break;\n }\n }\n const withErr = [...next, { id: nextTempId(), role: \"system\" as const, text: message }];\n if (agentIdRef.current) msgCache.current[agentIdRef.current] = withErr;\n return withErr;\n });\n } finally {\n if (opRef.current !== op) return;\n streamAbort.current = null;\n runRef.current = null;\n setLive(null);\n markBusy(false);\n }\n }\n\n async function requestCancel(agent?: string | null, runId?: string) {\n if (!agent) return;\n const url = runId\n ? `/api/run/${agent}/${runId}/cancel`\n : `/api/chats/${agent}/cancel`;\n await api(url, { method: \"POST\" }).catch(() => undefined);\n }\n\n async function cancelRun() {\n if (!busyRef.current || cancelledRef.current) return;\n cancelledRef.current = true;\n setStopping(true);\n streamAbort.current?.abort();\n const run = runRef.current;\n await requestCancel(run?.agentId || agentId, run?.runId);\n appendHere(run?.agentId || agentId || \"\", { id: nextTempId(), role: \"system\", text: \"已停止这次运行\" });\n }\n\n async function waitForIds(started: { stamp?: string; agentId?: string; runId?: string }) {\n if (started.agentId && started.runId) {\n return { agentId: started.agentId, runId: started.runId };\n }\n for (let i = 0; i < 20; i++) {\n if (cancelledRef.current) throw new Error(\"已停止这次运行\");\n const q = new URLSearchParams();\n if (started.stamp) q.set(\"stamp\", started.stamp);\n if (started.agentId || agentId) q.set(\"agentId\", started.agentId || agentId || \"\");\n const res = await api(`/api/recover?${q}`);\n const data = await res.json();\n if (data.agentId) {\n runRef.current = { agentId: data.agentId, runId: data.runId };\n }\n if (data.agentId && data.runId) {\n return { agentId: data.agentId as string, runId: data.runId as string };\n }\n await new Promise((r) => setTimeout(r, 2000));\n }\n throw new Error(\"任务已提交，但还没拿到会话 ID，请稍后再试\");\n }\n\n async function streamRun(nextAgentId: string, runId: string, maxWait = 180) {\n const state = emptyLive();\n setLive({ ...state, tools: [] });\n let after = \"\";\n const ctrl = new AbortController();\n streamAbort.current = ctrl;\n let raf = 0;\n const paint = () => {\n if (raf) return;\n raf = requestAnimationFrame(() => {\n raf = 0;\n setLive({ ...state, tools: state.tools.map((item) => ({ ...item })) });\n });\n };\n try {\n for (let hop = 0; hop < 40; hop++) {\n if (cancelledRef.current) return state.text;\n const q = after ? `?after=${encodeURIComponent(after)}` : \"\";\n let res: Response;\n try {\n res = await api(`/api/run/${nextAgentId}/${runId}/stream${q}`, {\n headers: after ? { \"Last-Event-ID\": after } : undefined,\n signal: ctrl.signal,\n });\n } catch (err) {\n if (cancelledRef.current || (err instanceof DOMException && err.name === \"AbortError\")) {\n return state.text;\n }\n if (err instanceof Error && err.message.includes(\"登录已过期\")) throw err;\n return await waitForRun(nextAgentId, runId, maxWait) || state.text;\n }\n if (res.status === 410) {\n return await waitForRun(nextAgentId, runId, maxWait) || state.text;\n }\n if (!res.ok) {\n if (state.text || state.thinking || state.tools.length) {\n return await waitForRun(nextAgentId, runId, maxWait) || state.text;\n }\n const data = await res.json().catch(() => ({ error: \"流式输出失败\" }));\n throw new Error(data.error ?? \"流式输出失败\");\n }\n const outcome = await readSse(res, (ev) => {\n if (ev.id) after = ev.id;\n applyLiveEvent(state, ev);\n paint();\n if (ev.type === \"resume\") return \"reconnect\";\n if (ev.type === \"error\") return \"error\";\n if (ev.type === \"done\") return \"done\";\n if (ev.type === \"result\") {\n const runStatus = String(ev.data.status ?? \"\");\n if ([\"ERROR\", \"CANCELLED\", \"EXPIRED\"].includes(runStatus)) return \"error\";\n if (runStatus === \"FINISHED\") return \"done\";\n }\n }, () => cancelledRef.current);\n if (outcome === \"done\") return state.text;\n if (outcome === \"error\") {\n if (cancelledRef.current) return state.text;\n throw new Error(state.error || \"任务失败\");\n }\n if (outcome === \"abort\") return state.text;\n }\n return await waitForRun(nextAgentId, runId, maxWait) || state.text;\n } finally {\n if (streamAbort.current === ctrl) streamAbort.current = null;\n }\n }\n\n async function waitForRun(nextAgentId: string, runId: string, maxWait = 180) {\n for (let i = 0; i < maxWait; i++) {\n if (cancelledRef.current) return \"\";\n const res = await api(`/api/run/${nextAgentId}/${runId}`);\n const data = await res.json();\n if (!res.ok) throw new Error(data.error ?? \"查询失败\");\n if ([\"FINISHED\", \"ERROR\", \"CANCELLED\", \"EXPIRED\"].includes(data.status)) {\n if (data.status === \"FINISHED\") {\n await api(`/api/run/${nextAgentId}/${runId}/complete`, { method: \"POST\" }).catch(() => undefined);\n }\n if (data.status === \"CANCELLED\") return \"\";\n if (data.status !== \"FINISHED\") throw new Error(data.result || `任务 ${data.status}`);\n return data.result as string;\n }\n await new Promise((r) => setTimeout(r, 2000));\n }\n throw new Error(\"等待超时，任务可能还在云端跑\");\n }\n\n function onKey(e: KeyboardEvent & { isComposing?: boolean; nativeEvent?: { isComposing?: boolean } }) {\n if (e.key !== \"Enter\" || e.shiftKey) return;\n if (e.isComposing || e.nativeEvent?.isComposing || e.keyCode === 229) return;\n e.preventDefault();\n send();\n }\n\n if (!status) {\n return

正在连接…

;\n }\n\n if (!status.configured) {\n return (\n

还没配置完成

需要 CURSOR_API_KEY。改其它 val 再加 VALTOWN_MCP_TOKEN。

\n );\n }\n\n if (!status.authed) {\n return ;\n }\n\n const runningId = runRef.current?.agentId ?? null;\n const viewingLive = Boolean(busy && runningId && agentId === runningId);\n const sendLocked = Boolean(busy && !viewingLive);\n const current = chats.find((c) => c.id === agentId);\n const modelName = models.find((item) => item.id === modelId)?.label || modelId || \"模型\";\n const modelLine = maxMode && models.find((item) => item.id === modelId)?.supportsMax ? `${modelName} · Max` : modelName;\n const shellClass = [\n \"shell\",\n desktop && desktopCollapsed ? \"sidebar-collapsed\" : \"\",\n resizing ? \"resizing\" : \"\",\n ].filter(Boolean).join(\" \");\n\n return (\n

\n {sidebar && \n

\n {editingTitle && agentId\n ? (\n setTitleDraft(e.target.value)}\n onBlur={saveTitle}\n onKeyDown={(e) => {\n if (e.key === \"Enter\") { e.preventDefault(); saveTitle(); }\n if (e.key === \"Escape\") setEditingTitle(false);\n }}\n />\n )\n : (\n {\n if (!agentId) return;\n setTitleDraft(current?.title || \"\");\n setEditingTitle(true);\n }}\n >\n {current?.title || (agentId ? \"继续对话\" : \"新对话\")}\n \n )}\n

{modelLine}

\n \n \n send(undefined, hint)}\n onRetry={() => lastUserText.current && send(undefined, lastUserText.current)}\n />\n void}\n onSubmit={send}\n onMode={(next) => pickMode(next, !agentId)}\n onModel={(next) => pickModel(next, !agentId)}\n onMax={(next) => pickMax(next, !agentId)}\n onCancel={cancelRun}\n />\n \n

\n );\n}\n","deleted",false,"label",[47,48,24],"frontend","components","97ce4900-8329-43bb-b758-880f88637a91",["D",1787382471418],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Mobile chat relay to Cursor + Val Town","imageUrl","userId","96c2793d-57c8-41d2-a49a-d1ee82f9dd24","pinnedFileId","01a0284c-1b46-711a-b263-211c80180a34","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","93515af8-c7b7-459c-9bf2-3bb3df310a75","tursoName","97ce4900832943bbb758880f88637a91","tursoHostname","97ce4900832943bbb758880f88637a91-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789474853273],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_109":105},"org",{"_9":10,"_103":-5,"_104":105,"_59":60,"_106":107,"_108":44},"branch",{"_37":93,"_11":94,"_22":30,"_95":49,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":12,"_102":10},"isOwned",376,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJObXd1QWdCZmVtaUh0bGU5TkswOG1sM0xheiIsImluaXRpYWxzIjoiRlkifQ","tier","free","canRestrictVals","profileImageUrl","ctx",{"_86":-5,"_143":144,"_145":146,"_147":148,"_149":44,"_150":44,"_151":44,"_152":34,"_153":-5,"_154":-7,"_155":-7,"_156":67,"_157":44,"_158":44,"_159":-5,"_160":44,"_161":44,"_162":44,"_163":-5},"ENV",{"_114":115,"_116":117,"_118":94,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138,"_139":140,"_141":142},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","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","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]