[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_109":110,"_111":112},"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","backend/cursor.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":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/backend/cursor.ts","extension","id","697ac195-7f25-4296-b408-fa26966eb78e","cursor.ts","fileId","4e742a84-9df8-11f1-b12f-1607ee4eb77e","parentId","31afd5aa-a5c9-4b98-9074-04ce71c64532","branchId","6924747a-bd7f-44f6-8ed7-64b4b4bc8bc0","branchVersion",374,"latest",true,"createdAt",["D",1787843951869],"version",49,"fileType","script","content","import { addMessageOnce, getChat, lastMessage, upsertChat } from \"./db.ts\";\nimport { cursorFetch } from \"./cursor-http.ts\";\n\nconst KICK_MS = 12_000;\n\nexport type RunStatus =\n | \"CREATING\"\n | \"RUNNING\"\n | \"FINISHED\"\n | \"ERROR\"\n | \"CANCELLED\"\n | \"EXPIRED\";\n\nexport type Started = {\n stamp: string;\n agentId?: string;\n runId?: string;\n};\n\nfunction mcpAllowlist() {\n return (Deno.env.get(\"MCP_VAL_ALLOWLIST\") ?? \"\")\n .split(\",\")\n .map((item) => item.trim())\n .filter(Boolean);\n}\n\nfunction valTownMcp() {\n const token = Deno.env.get(\"VALTOWN_MCP_TOKEN\");\n if (!token) return [];\n return [{\n name: \"valtown\",\n type: \"http\",\n url: \"https://api.val.town/v3/mcp\",\n headers: {\n Authorization: `Bearer ${token}`,\n },\n }];\n}\n\nfunction wrapPrompt(text: string, followUp: boolean) {\n const allowed = mcpAllowlist();\n const allowLine = allowed.length\n ? `You may only edit these vals: ${allowed.join(\", \")}. Refuse anything else.`\n : \"Only edit a Val Town val the user clearly names. If they do not name one, just talk — do not change code.\";\n if (followUp) {\n return [\n allowLine,\n \"Reply in the same language as the user. Be concise.\",\n \"\",\n text,\n ].join(\"\\n\");\n }\n const canEdit = valTownMcp().length > 0;\n return [\n \"You are chatting through a mobile web relay.\",\n canEdit\n ? \"You can edit the user's Val Town vals via the valtown MCP tools (list_vals, list_files, read_file, replace_in_file, create_file, update_file).\"\n : \"You cannot edit Val Town vals in this session — no MCP token is configured.\",\n \"Vals are identified as handle/valName, for example yuxiaoy/douban.\",\n allowLine,\n \"Reply in the same language as the user. Be concise.\",\n \"\",\n text,\n ].join(\"\\n\");\n}\n\nfunction newStamp() {\n return `cc-${Date.now()}`;\n}\n\nexport async function findAgentByStamp(stamp: string) {\n if (!stamp) return null;\n const items = await listAgents();\n return items.find((item) => item.name === stamp || item.name?.startsWith(`${stamp} `)) ?? null;\n}\n\nexport async function latestRun(agentId: string) {\n const data = await cursorFetch(`/agents/${agentId}/runs?limit=1`);\n const item = (data.items ?? [])[0];\n if (!item) return null;\n return {\n id: item.id as string,\n status: item.status as RunStatus | undefined,\n result: (item.result as string | undefined) ?? \"\",\n createdAt: item.createdAt as string | undefined,\n };\n}\n\nfunction stampMs(stamp: string) {\n if (!stamp.startsWith(\"cc-\")) return NaN;\n return Number(stamp.slice(3));\n}\n\nfunction runMatchesKickoff(\n run: { id: string; status?: string; createdAt?: string },\n stamp: string,\n trustStampAgent = false,\n) {\n const kicked = stampMs(stamp);\n if (run.status === \"CREATING\" || run.status === \"RUNNING\") {\n if (Number.isFinite(kicked) && run.createdAt) {\n return new Date(run.createdAt).getTime() >= kicked - 2000;\n }\n return true;\n }\n if (Number.isFinite(kicked) && run.createdAt) {\n return new Date(run.createdAt).getTime() >= kicked - 2000;\n }\n return trustStampAgent && Boolean(run.id);\n}\n\nexport async function recover(stamp: string, agentId?: string) {\n if (agentId) {\n const run = await latestRun(agentId);\n if (run && runMatchesKickoff(run, stamp)) return { stamp, agentId, runId: run.id };\n return { stamp, agentId };\n }\n if (!stamp) return { stamp };\n const found = await findAgentByStamp(stamp);\n if (!found) return { stamp };\n const run = await latestRun(found.id);\n if (run && runMatchesKickoff(run, stamp, true)) {\n return { stamp, agentId: found.id, runId: run.id };\n }\n return { stamp, agentId: found.id };\n}\n\nexport type ChatMode = \"agent\" | \"plan\";\n\nexport type ModelParam = { id: string; value: string };\n\nexport type ModelChoice = {\n id: string;\n label: string;\n aliases?: string[];\n supportsMax: boolean;\n params?: ModelParam[];\n maxParams?: ModelParam[];\n};\n\nexport type RawModel = {\n id: string;\n displayName?: string;\n aliases?: string[];\n supportsMaxMode?: boolean;\n maxContextForMaxMode?: number;\n parameters?: Array<{ id: string; displayName?: string; values?: Array<{ value: string; displayName?: string }> }>;\n variants?: Array<{\n displayName?: string;\n description?: string;\n isDefault?: boolean;\n params?: Array<{ id: string; value: string }>;\n }>;\n};\n\nfunction parseContextTokens(value?: string) {\n if (!value) return 0;\n const text = value.trim();\n const match = /^(\\d+(?:\\.\\d+)?)\\s*([km])$/i.exec(text);\n if (match) {\n return Number(match[1]) * (match[2].toLowerCase() === \"k\" ? 1_000 : 1_000_000);\n }\n const n = Number(text);\n return Number.isFinite(n) ? n : 0;\n}\n\nfunction paramList(params?: Array<{ id?: string; value?: string }>): ModelParam[] {\n return (params ?? [])\n .filter((item): item is ModelParam => Boolean(item.id && item.value !== undefined))\n .map((item) => ({ id: item.id, value: String(item.value) }));\n}\n\nfunction isEffortId(id?: string) {\n return /^(effort|reasoning|reasoning_effort)$/i.test(id ?? \"\");\n}\n\nfunction effortRank(value?: string) {\n if (!value) return 0;\n const key = value.toLowerCase().replace(/[\\s-]+/g, \"_\");\n if (key === \"low\") return 1;\n if (key === \"medium\" || key === \"mid\") return 2;\n if (key === \"high\") return 3;\n if (key === \"xhigh\" || key === \"extra_high\") return 4;\n if (key === \"max\" || key.startsWith(\"max\")) return 5;\n return 0;\n}\n\nfunction highestEffort(item: RawModel) {\n const values = (item.parameters ?? [])\n .filter((parameter) => isEffortId(parameter.id))\n .flatMap((parameter) => parameter.values ?? []);\n if (!values.length) return undefined;\n return values.reduce((best, cur) => effortRank(cur.value) >= effortRank(best.value) ? cur : best);\n}\n\nfunction effortParamOf(item: RawModel) {\n return (item.parameters ?? []).find((parameter) => isEffortId(parameter.id));\n}\n\nfunction biggestContext(item: RawModel) {\n const values = (item.parameters ?? [])\n .filter((parameter) => parameter.id === \"context\")\n .flatMap((parameter) => parameter.values ?? []);\n if (!values.length) return undefined;\n return values.reduce((best, cur) =>\n parseContextTokens(cur.value) >= parseContextTokens(best.value) ? cur : best\n );\n}\n\nfunction isFastVariant(variant: { params?: ModelParam[] }) {\n return (variant.params ?? []).some((item) => item.id === \"fast\" && item.value === \"true\");\n}\n\nfunction cloneParams(params?: ModelParam[]) {\n return (params ?? []).map((item) => ({ id: item.id, value: item.value }));\n}\n\nfunction setParam(params: ModelParam[], id: string, value: string) {\n const idx = params.findIndex((item) => item.id === id);\n if (idx >= 0) params[idx] = { id, value };\n else params.push({ id, value });\n}\n\nfunction paramsKey(params?: ModelParam[]) {\n return (params ?? []).map((item) => `${item.id}=${item.value}`).sort().join(\"&\");\n}\n\nfunction shortLabel(name: string, id?: string) {\n if (id === \"auto-smart\") return \"Auto · Router\";\n let label = name\n .replace(/\\s*\$(?:thinking|max(?:\\s*mode)?)\$/gi, \"\")\n .replace(/\\s+thinking$/i, \"\")\n .replace(/\\s+max(?:\\s*mode)?$/i, \"\")\n .trim();\n label = label.replace(/^Claude\\s+(\\S+)\\s+Sonnet/i, \"Sonnet $1\");\n label = label.replace(/^Claude\\s+(\\S+)\\s+Opus/i, \"Opus $1\");\n label = label.replace(/^Claude\\s+(\\S+)\\s+Haiku/i, \"Haiku $1\");\n label = label.replace(/^Claude\\s+(\\S+)\\s+Fable/i, \"Fable $1\");\n return label;\n}\n\nexport function toChoice(item: RawModel): ModelChoice {\n const variants = (item.variants ?? []).map((variant) => ({\n ...variant,\n params: paramList(variant.params),\n }));\n const baseVar = variants.find((variant) => variant.isDefault) ?? variants[0];\n const baseParams = cloneParams(baseVar?.params);\n const upgraded = cloneParams(baseParams);\n let changed = false;\n\n const effortDef = effortParamOf(item);\n const topEffort = highestEffort(item);\n if (effortDef && topEffort) {\n const current = baseParams.find((entry) => entry.id === effortDef.id)?.value;\n if (effortRank(topEffort.value) > effortRank(current)) {\n setParam(upgraded, effortDef.id, topEffort.value);\n changed = true;\n }\n }\n\n const topContext = biggestContext(item);\n if (topContext) {\n const current = baseParams.find((entry) => entry.id === \"context\")?.value;\n if (parseContextTokens(topContext.value) > parseContextTokens(current)) {\n setParam(upgraded, \"context\", topContext.value);\n changed = true;\n }\n }\n\n const maxFlag = (item.parameters ?? []).find((parameter) => /max/i.test(parameter.id));\n if (maxFlag) {\n const on = (maxFlag.values ?? []).find((value) => /^(true|1|yes)$/i.test(value.value))?.value ?? \"true\";\n const current = baseParams.find((entry) => entry.id === maxFlag.id)?.value;\n if (current !== on) {\n setParam(upgraded, maxFlag.id, on);\n changed = true;\n }\n }\n\n let maxParams = changed ? upgraded : undefined;\n if (maxParams) {\n const key = paramsKey(maxParams);\n const wantFast = isFastVariant({ params: baseParams });\n const matched =\n variants.find((variant) => paramsKey(variant.params) === key) ??\n variants.find((variant) => {\n if (isFastVariant(variant) !== wantFast) return false;\n const effortOk = !effortDef ||\n variant.params?.find((entry) => entry.id === effortDef.id)?.value ===\n upgraded.find((entry) => entry.id === effortDef.id)?.value;\n const contextOk =\n (variant.params?.find((entry) => entry.id === \"context\")?.value ?? \"\") ===\n (upgraded.find((entry) => entry.id === \"context\")?.value ?? \"\");\n return effortOk && contextOk;\n });\n if (matched) maxParams = matched.params;\n }\n\n const supportsMax = Boolean(maxParams && paramsKey(maxParams) !== paramsKey(baseParams));\n return {\n id: item.id,\n label: shortLabel(item.displayName ?? item.id, item.id),\n aliases: item.aliases,\n supportsMax,\n params: baseVar?.params,\n maxParams: supportsMax ? maxParams : undefined,\n };\n}\n\nfunction preferModelId(left: string, right: string) {\n if (left === \"auto\") return -1;\n if (right === \"auto\") return 1;\n return left.length - right.length;\n}\n\nlet modelsCache: { at: number; items: ModelChoice[] } | null = null;\n\nexport async function listModels() {\n if (modelsCache && Date.now() - modelsCache.at < 60_000) return modelsCache.items;\n const data = await cursorFetch(\"/models\", { timeoutMs: 15_000 });\n const items = (data.items ?? []) as RawModel[];\n const ids = new Set(items.map((item) => item.id));\n const aliasOf = new Map();\n for (const item of items) {\n for (const alias of item.aliases ?? []) aliasOf.set(alias, item.id);\n }\n const choices: ModelChoice[] = [];\n const seenLabel = new Map();\n for (const item of items) {\n const owner = aliasOf.get(item.id);\n if (owner && owner !== item.id && ids.has(owner)) continue;\n const choice = toChoice(item);\n const key = choice.label.toLowerCase();\n const existing = seenLabel.get(key);\n if (existing !== undefined) {\n if (preferModelId(choice.id, choices[existing].id) < 0) choices[existing] = choice;\n continue;\n }\n seenLabel.set(key, choices.length);\n choices.push(choice);\n }\n modelsCache = { at: Date.now(), items: choices };\n return choices;\n}\n\nfunction modelPayload(choice: ModelChoice | undefined, modelId: string, maxMode: boolean) {\n if (!choice) return { id: modelId };\n const params = maxMode && choice.supportsMax\n ? (choice.maxParams?.length ? choice.maxParams : choice.params)\n : choice.params;\n return params?.length ? { id: choice.id, params } : { id: choice.id };\n}\n\nexport type AgentRow = {\n id: string;\n name?: string;\n status?: string;\n createdAt?: string;\n updatedAt?: string;\n latestRunId?: string;\n url?: string;\n};\n\nexport async function listAgents() {\n const items: AgentRow[] = [];\n let cursor = \"\";\n for (let page = 0; page < 5; page++) {\n const query = new URLSearchParams({ limit: \"100\", includeArchived: \"false\" });\n if (cursor) query.set(\"cursor\", cursor);\n const data = await cursorFetch(`/agents?${query}`, { timeoutMs: 15_000 });\n const batch = (data.items ?? []) as AgentRow[];\n items.push(...batch);\n cursor = String(data.nextCursor ?? data.next_page_token ?? \"\");\n if (!cursor || batch.length === 0) break;\n }\n return items;\n}\n\nexport async function startChat(\n text: string,\n agentId?: string,\n modelId?: string,\n mode: ChatMode = \"agent\",\n maxMode = false,\n): Promise {\n const stamp = newStamp();\n const prompt = { text: wrapPrompt(text, Boolean(agentId)) };\n const mcpServers = valTownMcp();\n const payload: Record = { prompt, mcpServers, mode };\n const [models, current] = await Promise.all([\n modelId ? listModels().catch(() => [] as ModelChoice[]) : Promise.resolve([] as ModelChoice[]),\n agentId ? latestRun(agentId).catch(() => null) : Promise.resolve(null),\n ]);\n if (modelId) {\n const choice = models.find((item) => item.id === modelId || item.aliases?.includes(modelId));\n payload.model = modelPayload(choice, modelId, maxMode);\n }\n if (agentId && current && (current.status === \"RUNNING\" || current.status === \"CREATING\")) {\n throw new Error(\"run_in_progress\");\n }\n\n try {\n if (agentId) {\n const data = await cursorFetch(`/agents/${agentId}/runs`, {\n method: \"POST\",\n timeoutMs: KICK_MS,\n body: JSON.stringify(payload),\n });\n const run = data.run as { id: string };\n return { stamp, agentId, runId: run.id };\n }\n const data = await cursorFetch(\"/agents\", {\n method: \"POST\",\n timeoutMs: KICK_MS,\n body: JSON.stringify({ ...payload, name: stamp }),\n });\n const agent = data.agent as { id: string };\n const run = data.run as { id: string };\n return {\n stamp,\n agentId: agent.id,\n runId: run.id,\n };\n } catch (err) {\n if (String(err).includes(\"run_in_progress\")) throw err;\n const recovered = await recover(stamp, agentId).catch(() => ({ stamp, agentId }));\n if (recovered.agentId && recovered.runId) return recovered;\n if (String(err).includes(\"cursor_timeout\")) return { stamp, agentId: recovered.agentId };\n throw err;\n }\n}\n\nexport async function getRun(agentId: string, runId: string) {\n const data = await cursorFetch(`/agents/${agentId}/runs/${runId}`, { timeoutMs: 15_000 });\n return {\n id: data.id as string,\n agentId: data.agentId as string,\n status: data.status as RunStatus,\n result: (data.result as string | undefined) ?? \"\",\n durationMs: data.durationMs as number | undefined,\n };\n}\n\nexport function isActiveRun(status?: string) {\n return status === \"CREATING\" || status === \"RUNNING\";\n}\n\nconst STALE_RUN_MS = 2 * 60 * 60 * 1000;\n\nexport async function reconcileChat(agentId: string) {\n const last = await lastMessage(agentId);\n if (last?.role === \"assistant\") {\n const local = await getChat(agentId);\n return {\n live: null as { runId: string; status: string } | null,\n status: local?.run_status ?? undefined,\n runId: local?.latest_run_id ?? undefined,\n appended: null as { role: string; text: string; created_at: string } | null,\n };\n }\n const run = await latestRun(agentId);\n if (!run) {\n return {\n live: null as { runId: string; status: string } | null,\n status: undefined as string | undefined,\n runId: undefined as string | undefined,\n appended: null as { role: string; text: string; created_at: string } | null,\n };\n }\n await upsertChat(agentId, undefined, undefined, undefined, { id: run.id, status: run.status });\n if (run.status === \"FINISHED\") {\n const text = run.result || \"（已完成，没有文字回复）\";\n const wrote = await addMessageOnce(agentId, \"assistant\", text);\n return {\n live: null,\n status: run.status,\n runId: run.id,\n appended: wrote ? { role: \"assistant\", text, created_at: new Date().toISOString() } : null,\n };\n }\n if (isActiveRun(run.status) && run.status) {\n const age = run.createdAt ? Date.now() - new Date(run.createdAt).getTime() : 0;\n if (age > STALE_RUN_MS) {\n return { live: null, status: run.status, runId: run.id, appended: null };\n }\n return { live: { runId: run.id, status: run.status }, status: run.status, runId: run.id, appended: null };\n }\n return { live: null, status: run.status, runId: run.id, appended: null };\n}\n\nexport async function archiveAgent(agentId: string) {\n await cursorFetch(`/agents/${agentId}/archive`, { method: \"POST\", timeoutMs: 15_000 });\n}\n\nexport async function cancelRun(agentId: string, runId?: string) {\n let id = runId;\n if (!id) {\n const latest = await latestRun(agentId);\n id = latest?.id;\n }\n if (!id) return;\n try {\n await cursorFetch(`/agents/${agentId}/runs/${id}/cancel`, {\n method: \"POST\",\n timeoutMs: 15_000,\n });\n } catch (err) {\n const msg = String(err);\n if (msg.includes(\"409\") || msg.includes(\"run_not_cancellable\")) return;\n throw err;\n }\n}\n","deleted",false,"label",[47,24],"backend","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,"_108":104},"org",{"_9":10,"_102":-5,"_103":104,"_58":59,"_105":106,"_107":44},"branch",{"_37":92,"_11":93,"_22":30,"_94":48,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":12,"_101":10},"isOwned",376,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJObXd1QWdCZmVtaUh0bGU5TkswOG1sM0xheiIsImluaXRpYWxzIjoiRlkifQ","tier","free","canRestrictVals","profileImageUrl","ctx",{"_85":-5,"_142":143,"_144":145,"_146":147,"_148":44,"_149":44,"_150":44,"_151":34,"_152":-5,"_153":-7,"_154":-7,"_155":66,"_156":44,"_157":44,"_158":-5,"_159":44,"_160":44,"_161":44,"_162":-5},"ENV",{"_113":114,"_115":116,"_117":93,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139,"_140":141},"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"]