Claude Managed Agent

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_386":387,"_388":389},"routes/_app.x.$handle.$name",{"_105":104,"_33":47,"_114":92,"_28":115,"_13":14,"_116":-5,"_11":117,"_118":119,"_120":121,"_122":123,"_124":125,"_20":-5,"_126":127,"_128":129,"_130":27,"_131":132,"_133":25,"_134":-5,"_135":-5,"_136":137},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_45":46,"_33":47,"_40":48,"_49":-5,"_50":27,"_51":52,"_53":52,"_54":55,"_56":57,"_18":58,"_59":60,"_61":25,"_62":-5,"_63":-5,"_64":65,"_66":67,"_68":69,"_70":71,"_72":73,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":85,"_86":87,"_88":89,"_90":27},"version",56,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":27,"_28":29,"_30":29},"file",{"_31":32,"_33":34,"_35":36,"_37":39,"_40":41,"_42":14,"_43":44,"_24":27},"previous",{"_31":32,"_33":34,"_35":36,"_37":38},"deleted",true,"deletedHere",false,"path","backend/_probe.ts","latestPath","fileId","c83d9d82-5e9c-11f1-804e-1607ee4eb77e","name","_probe.ts","fileType","script","content","import Anthropic from \"npm:@anthropic-ai/sdk@0.100.1\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { ensureConfig } from \"./agent.ts\";\n\nconst client = new Anthropic();\nconst BETA = \"managed-agents-2026-04-01\";\n\nexport default async function () {\n const log: any[] = [];\n try {\n const { agentId, envId } = await ensureConfig();\n log.push({ agentId, envId });\n\n const session = await client.beta.sessions.create({\n agent: agentId,\n environment_id: envId,\n title: \"probe\",\n });\n const sessionId = session.id;\n log.push({ sessionId });\n\n const stream = await client.beta.sessions.events.stream(sessionId);\n await client.beta.sessions.events.send(sessionId, {\n events: [{\n type: \"user.message\",\n content: [{\n type: \"text\",\n text:\n \"Use python with matplotlib to make a simple bar chart and save it to /tmp/chart.png. Then tell me you're done.\",\n }],\n }],\n });\n\n const eventTypes: Record = {};\n let toolResultSample: any = null;\n let toolUseSample: any = null;\n for await (const event of stream) {\n const e = event as any;\n eventTypes[event.type] = (eventTypes[event.type] ?? 0) + 1;\n if (event.type === \"agent.tool_result\" && !toolResultSample) {\n toolResultSample = JSON.parse(JSON.stringify(e));\n }\n if (event.type === \"agent.tool_use\" && !toolUseSample) {\n toolUseSample = JSON.parse(JSON.stringify(e));\n }\n if (event.type === \"session.error\") {\n log.push({ sessionError: e.error });\n break;\n }\n if (event.type === \"session.status_idle\") break;\n }\n log.push({ eventTypes });\n log.push({ toolUseSample });\n log.push({ toolResultSample });\n\n // Files API roundtrip\n let listData: any[] = [];\n for (let i = 0; i < 4; i++) {\n const res = await client.beta.files.list({ scope_id: sessionId, betas: [BETA] } as any);\n listData = res.data as any[];\n log.push({ attempt: i, listCount: listData.length, list: listData });\n if (listData.length > 0) break;\n await new Promise((r) => setTimeout(r, 1500));\n }\n\n if (listData.length > 0) {\n const f = listData[0];\n const dl = await client.beta.files.download(f.id, { betas: [BETA] } as any);\n const bytes = new Uint8Array(await (dl as any).arrayBuffer());\n log.push({ downloadedBytes: bytes.length, id: f.id });\n await blob.set(`file_${f.id}`, bytes);\n const keys = await blob.list(\"file_\");\n log.push({ blobKeys: (keys as any[]).map((k: any) => k.key) });\n const back = await blob.get(`file_${f.id}`);\n const backBytes = new Uint8Array(await (back as any).arrayBuffer());\n log.push({ readBackBytes: backBytes.length });\n await blob.delete(`file_${f.id}`);\n }\n } catch (err: any) {\n log.push({ thrown: String(err?.stack ?? err) });\n }\n await blob.set(\"_probe_result\", new TextEncoder().encode(JSON.stringify(log)));\n return { ok: true, n: log.length };\n}\n","import Anthropic from \"npm:@anthropic-ai/sdk@0.100.1\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { ensureConfig } from \"./agent.ts\";\n\nconst client = new Anthropic();\nconst BETA = \"managed-agents-2026-04-01\";\n\nexport default async function (_req: Request) {\n const log: any[] = [];\n try {\n const { agentId, envId } = await ensureConfig();\n log.push({ agentId, envId });\n\n const session = await client.beta.sessions.create({\n agent: agentId,\n environment_id: envId,\n title: \"probe\",\n });\n const sessionId = session.id;\n log.push({ sessionId });\n\n const stream = await client.beta.sessions.events.stream(sessionId);\n await client.beta.sessions.events.send(sessionId, {\n events: [{\n type: \"user.message\",\n content: [{\n type: \"text\",\n text:\n \"Use python with matplotlib to make a simple bar chart and save it to /tmp/chart.png. Then tell me you're done.\",\n }],\n }],\n });\n\n const eventTypes: Record = {};\n let toolResultSample: any = null;\n let toolUseSample: any = null;\n for await (const event of stream) {\n const e = event as any;\n eventTypes[event.type] = (eventTypes[event.type] ?? 0) + 1;\n if (event.type === \"agent.tool_result\" && !toolResultSample) {\n toolResultSample = JSON.parse(JSON.stringify(e));\n }\n if (event.type === \"agent.tool_use\" && !toolUseSample) {\n toolUseSample = JSON.parse(JSON.stringify(e));\n }\n if (event.type === \"session.error\") {\n log.push({ sessionError: e.error });\n break;\n }\n if (event.type === \"session.status_idle\") break;\n }\n log.push({ eventTypes });\n log.push({ toolUseSample });\n log.push({ toolResultSample });\n\n // Files API roundtrip with retry\n let listData: any[] = [];\n for (let i = 0; i < 4; i++) {\n const res = await client.beta.files.list({ scope_id: sessionId, betas: [BETA] } as any);\n listData = res.data as any[];\n log.push({ attempt: i, listCount: listData.length, list: listData });\n if (listData.length > 0) break;\n await new Promise((r) => setTimeout(r, 1500));\n }\n\n if (listData.length > 0) {\n const f = listData[0];\n const dl = await client.beta.files.download(f.id, { betas: [BETA] } as any);\n const bytes = new Uint8Array(await (dl as any).arrayBuffer());\n log.push({ downloadedBytes: bytes.length, id: f.id });\n await blob.set(`file_${f.id}`, bytes);\n const keys = await blob.list(\"file_\");\n log.push({ blobKeys: (keys as any[]).map((k: any) => k.key) });\n const back = await blob.get(`file_${f.id}`);\n const backBytes = new Uint8Array(await (back as any).arrayBuffer());\n log.push({ readBackBytes: backBytes.length });\n await blob.delete(`file_${f.id}`);\n }\n } catch (err: any) {\n log.push({ thrown: String(err?.stack ?? err) });\n }\n return Response.json(log);\n}\n","createdAt",["D",1780416383605],"branchVersion","branchId","f94618ba-5e96-11f1-a008-1607ee4eb77e","id","f93e0bca-5e96-11f1-a008-1607ee4eb77e","claude-managed-agents-ui",["D",1780413794401],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Interactive chat UI for a Claude Managed Agent","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/7bf29dd7-9190-4de2-045f-8245c9e11100/square512?exp=1789534799&sig=09a92b82815d40b1746bc08cf5b52c6bd0f7f20c4fd9efdc5dcbaac6597978e2","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","019e88ee-890a-72f8-a279-25160d2a5b36","pinPreview","pinMigrated","screenshotVersion","likeCount",1,"orgId","019aa807-52c2-709c-928b-2029bae9a558","tursoName","f93e0bca5e9611f1a0081607ee4eb77e","tursoHostname","f93e0bca5e9611f1a0081607ee4eb77e-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789495880338],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_105":104,"_113":109},"org",{"_105":104,"_106":107,"_108":109,"_18":-5,"_110":111,"_112":25},"branch",{"_13":91,"_33":92,"_45":44,"_93":46,"_94":95,"_96":97,"_98":52,"_99":100,"_101":67,"_102":47,"_103":104},"isOwned",121,"main","projectId","forkedBranchId","961078ea-f528-11ef-aa68-569c3dd06744","forkedBranchVersion",89,"forkedProjectPrivacy","forkedProjectId","96102714-f528-11ef-aa68-569c3dd06744","forkedProjectOrgId","projectName","userHandle","templates","handle","displayName","Templates","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789534799&sig=94d49ad984a50880ef894a3794e08842e7b9b626be771ff48da114d7d9a149ed","tier","business","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_45":46,"_33":47,"_40":381,"_49":-5,"_50":27,"_51":52,"_53":52,"_54":55,"_56":57,"_18":58,"_59":60,"_61":25,"_62":-5,"_63":-5,"_64":65,"_66":67,"_68":69,"_70":71,"_72":382,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":383,"_86":384,"_88":385,"_90":27},"tree",[193,200,215,216],"files",[193,194,195,196,197,198,199,200,201,202,203,204,205,206,207,208,209,210,211,212,213,214,215,216],"counts",{"_183":174,"_184":65,"_185":65,"_186":187,"_188":189},"contents",[148,149,150,151],"upstreamProject",{"_45":100,"_33":144,"_54":145,"_56":146,"_51":52,"_84":147},"upstreamBranch",{"_45":95,"_40":138,"_139":140,"_33":92,"_93":100,"_13":141,"_94":-5,"_96":-5,"_142":143,"_49":-5,"_90":27,"_51":52,"_103":104,"_66":67,"_102":144},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1740674013689],"updatedAt",["D",1785420707976],91,"lockfileKey","1785420708123-esm.town_v_templates_react-hono-starter@91-main","react-hono-starter","Starter template with client-side React & Hono server","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/64dc00cc-94d9-47dd-81b1-dde02610d900/square512?exp=1789534799&sig=2fe932419d898cd124d0961cab25a5a9c3bd76c8b30cb3b9e71257c7b34e60a2",{"_105":104,"_113":109},{"_45":177,"_33":178,"_31":179,"_154":-5,"_43":44,"_42":180,"_156":25,"_40":181,"_13":174,"_35":175,"_37":-5,"_24":27,"_161":-5,"_28":182},{"_45":170,"_33":171,"_31":172,"_154":-5,"_43":44,"_42":65,"_156":25,"_40":173,"_13":174,"_35":175,"_37":-5,"_24":27,"_161":-5,"_28":176},{"_45":163,"_33":164,"_31":165,"_154":-5,"_43":44,"_42":166,"_156":25,"_40":167,"_13":158,"_35":20,"_37":168,"_24":27,"_161":-5,"_28":169},{"_45":152,"_33":153,"_31":60,"_154":-5,"_43":44,"_42":155,"_156":27,"_40":157,"_13":158,"_35":159,"_37":160,"_24":27,"_161":47,"_28":162},"f1cac2f6-5e9c-11f1-ac44-1607ee4eb77e","index.ts","parentId",52,"latest",["D",1780416358953],4,"http","import { parseVal, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { oauthMiddleware } from \"https://esm.town/v/std/oauth/middleware.ts\";\nimport { Hono } from \"npm:hono\";\nimport * as db from \"./backend/db.ts\";\nimport { MESSAGE_LIMIT, requireUser } from \"./backend/auth.ts\";\nimport { ensureSession, runTurn } from \"./backend/agent.ts\";\nimport { getFileBytes } from \"./backend/files.ts\";\n\nconst app = new Hono();\n\n// Static frontend (public). The /auth/* routes are injected by oauthMiddleware.\napp.get(\"/\", () => serveFile(\"/frontend/index.html\"));\napp.get(\"/frontend/**/*\", (c) => serveFile(c.req.path));\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\n// Everything under /api/* requires a logged-in Val Town user.\napp.use(\"/api/*\", async (c, next) => {\n const user = await requireUser(c);\n if (!user) return c.json({ error: \"Log in with Val Town to continue.\" }, 401);\n c.set(\"user\", user);\n await next();\n});\n\n// Current user + usage against the per-user message limit.\napp.get(\"/api/me\", async (c) => {\n const user = c.get(\"user\") as { username: string; id: string };\n const used = await db.countUserMessages(user.id);\n return c.json({\n username: user.username,\n used,\n limit: MESSAGE_LIMIT,\n remaining: Math.max(0, MESSAGE_LIMIT - used),\n });\n});\n\n// Threads (scoped to the current user)\napp.get(\"/api/threads\", async (c) => {\n const user = c.get(\"user\") as { id: string };\n return c.json(await db.listThreadsForUser(user.id));\n});\napp.post(\"/api/threads\", async (c) => {\n const user = c.get(\"user\") as { id: string };\n const id = crypto.randomUUID();\n await db.createThread(id, \"New chat\", user.id);\n return c.json(await db.getThread(id));\n});\n\n// Serve a sandbox file the agent surfaced: bytes from blob, mime/name from the\n// matching message row. Images render inline; other files download.\napp.get(\"/api/files/:id\", async (c) => {\n const id = c.req.param(\"id\");\n const meta = await db.getFilePayload(id);\n if (!meta) return c.notFound();\n const res = await getFileBytes(id);\n const headers: Record = { \"Content-Type\": meta.mime };\n if (!meta.mime.startsWith(\"image/\")) {\n headers[\"Content-Disposition\"] = `attachment; filename=\"${meta.name}\"`;\n }\n return new Response(await res.arrayBuffer(), { headers });\n});\n\n// Poll for messages newer than the last row the client has seen (own threads only)\napp.get(\"/api/threads/:id/messages\", async (c) => {\n const user = c.get(\"user\") as { id: string };\n const thread = await db.getThread(c.req.param(\"id\"));\n if (!thread || thread.user_id !== user.id) return c.notFound();\n return c.json(await db.getMessages(thread.id, Number(c.req.query(\"after\") ?? 0)));\n});\n\n// One user turn. Enforce the per-user message limit FIRST, then: insert the user\n// row, ensure a session, and stream events into SQLite until idle. UI relies on polling.\napp.post(\"/api/threads/:id/messages\", async (c) => {\n const user = c.get(\"user\") as { id: string };\n const thread = await db.getThread(c.req.param(\"id\"));\n if (!thread || thread.user_id !== user.id) return c.notFound();\n\n const used = await db.countUserMessages(user.id);\n if (used >= MESSAGE_LIMIT) {\n return c.json(\n {\n error: `You've reached the ${MESSAGE_LIMIT}-message limit for this demo.`,\n remaining: 0,\n },\n 429,\n );\n }\n\n const { text } = await c.req.json();\n await db.addMessage(thread.id, \"user\", \"text\", text);\n if (thread.title === \"New chat\") await db.setTitle(thread.id, text.slice(0, 60));\n const sessionId = await ensureSession(thread);\n await runTurn(thread.id, sessionId, text);\n return c.json({ ok: true });\n});\n\n// Unwrap Hono errors so we get real stack traces instead of \"Internal Server Error\"\napp.onError((err) => Promise.reject(err));\n\nexport default oauthMiddleware(app.fetch);\n","label",[153],"b8f407a0-5e9a-11f1-af60-1607ee4eb77e","README.md","019e88ee-890a-72f8-a279-21928a58e16f",35,["D",1780415404602],"# Claude Managed Agent — Chat UI\n\nAn interactive chat UI for talking to a\n[Claude Managed Agent](https://platform.claude.com/docs/en/managed-agents/quickstart).\nEach thread is one stateful agent **session** — persistent history plus a\nsandbox with bash, file editing, and web tools. Hono (backend) + React\n(frontend), with Val Town SQLite for storage.\n\nWhere\n[`claude-managed-agents`](https://www.val.town/x/templates/claude-managed-agents)\nis a one-shot script, this is a multi-turn, multi-thread UI.\n\n## How it works\n\n- **A thread = one session.** The agent + environment are created **once**\n (lazily on first use) and their ids are cached in a `config` row — sessions\n pin to an agent version, so recreating them per request would be wrong. Each\n thread makes one session and reuses it for follow-up turns.\n- On a new user message the server inserts the user row, ensures the thread has\n a session, then **opens the event stream, sends the message, and writes each\n event to SQLite as it arrives** (`agent.message` → text, `agent.tool_use` →\n tool name, `session.error` → error), returning when the session goes idle.\n- The **frontend polls** `GET /api/threads/:id/messages?after=` about\n once a second and renders new rows in order. No SSE to the browser.\n- The built-in toolset runs in Anthropic's sandbox with\n `permission_policy: always_allow`, so tools just run — no approval prompts.\n- **Files the agent creates** (images, charts, PDFs) are surfaced after each\n turn. When the session goes idle, `backend/files.ts` lists the session's files\n via the Managed Agents Files API (`files.list({ scope_id })`), downloads any\n new ones (`files.download(id)`), stashes the bytes in `std/blob` (key\n `file_`), and writes a `messages` row for each — `type: \"image\"` for\n `image/*`, else `type: \"file\"`. The row's `content` is JSON\n `{ id, name, mime }`. The frontend renders images inline and other files as a\n `⬇ name` download link, both pointing at `GET /api/files/:id`, which streams\n the blob bytes with the right Content-Type.\n\n## Setup\n\nSet `ANTHROPIC_API_KEY` (from ).\nEverything else is created on the first message. Tweak the model or system\nprompt in `backend/agent.ts`.\n\n## Files\n\n- `index.ts` — Hono server + API routes\n- `backend/db.ts` — SQLite schema + helpers (`threads`, `messages`, `config`)\n- `backend/agent.ts` — Managed Agents: create-once config, per-thread session,\n per-turn streaming\n- `backend/files.ts` — surface sandbox files: Files API → `std/blob` →\n image/file message rows\n- `frontend/` — React chat UI (`App.tsx`, `Chat.tsx`, `api.ts`)\n\n## Backlog (not built yet)\n\n- **Stream reconnection.** The turn request stays open for the whole agent turn.\n If it dies before `session.status_idle`, reopen the stream and replay events\n for that `session_id` from the thread's `last_cursor` to resume writing to\n SQLite — session state is persisted server-side, so it's recoverable.\n- **Long turns** may exceed Val Town request limits → tied to the reconnection /\n background-execution work above.",[164],"f94df35a-5e96-11f1-a008-1607ee4eb77e","frontend","019e88ee-890a-72f8-a279-1cf939beedf1",["D",1780413794401],0,"directory",[171],"31cdaeaa-5e97-11f1-91e4-1607ee4eb77e","backend","d776a2ad-ff3e-4481-8dd0-5ebd71580eb6",2,["D",1780413889356],[178],"pulls","branches","forks","envVars",{"_190":65,"_192":174},"connections",{"_190":174,"_191":174},"count","unfilledCount","emptyCount",{"_45":177,"_33":178,"_31":179,"_154":-5,"_43":44,"_42":180,"_156":25,"_40":378,"_13":174,"_35":175,"_37":-5,"_24":27,"_161":-5,"_218":379,"_28":380},{"_45":374,"_33":34,"_31":32,"_154":179,"_43":44,"_42":14,"_156":27,"_40":375,"_13":346,"_35":36,"_37":39,"_24":27,"_161":-5,"_218":376,"_28":377},{"_45":366,"_33":367,"_31":368,"_154":179,"_43":44,"_42":369,"_156":27,"_40":370,"_13":180,"_35":159,"_37":371,"_24":27,"_161":-5,"_218":372,"_28":373},{"_45":358,"_33":359,"_31":360,"_154":179,"_43":44,"_42":361,"_156":27,"_40":362,"_13":158,"_35":36,"_37":363,"_24":27,"_161":-5,"_218":364,"_28":365},{"_45":350,"_33":351,"_31":352,"_154":179,"_43":44,"_42":353,"_156":25,"_40":354,"_13":174,"_35":36,"_37":355,"_24":27,"_161":-5,"_218":356,"_28":357},{"_45":341,"_33":342,"_31":343,"_154":179,"_43":44,"_42":344,"_156":27,"_40":345,"_13":346,"_35":36,"_37":347,"_24":27,"_161":-5,"_218":348,"_28":349},{"_45":333,"_33":334,"_31":335,"_154":179,"_43":44,"_42":336,"_156":27,"_40":337,"_13":65,"_35":36,"_37":338,"_24":27,"_161":-5,"_218":339,"_28":340},{"_45":170,"_33":171,"_31":172,"_154":-5,"_43":44,"_42":65,"_156":25,"_40":330,"_13":174,"_35":175,"_37":-5,"_24":27,"_161":-5,"_218":331,"_28":332},{"_45":326,"_33":255,"_31":249,"_154":172,"_43":44,"_42":65,"_156":25,"_40":327,"_13":174,"_35":175,"_37":-5,"_24":27,"_161":-5,"_218":328,"_28":329},{"_45":322,"_33":289,"_31":283,"_154":249,"_43":44,"_42":293,"_156":25,"_40":323,"_13":174,"_35":175,"_37":-5,"_24":27,"_161":-5,"_218":324,"_28":325},{"_45":314,"_33":315,"_31":316,"_154":283,"_43":44,"_42":317,"_156":25,"_40":318,"_13":174,"_35":36,"_37":319,"_24":27,"_161":-5,"_218":320,"_28":321},{"_45":306,"_33":307,"_31":308,"_154":283,"_43":44,"_42":309,"_156":25,"_40":310,"_13":174,"_35":36,"_37":311,"_24":27,"_161":-5,"_218":312,"_28":313},{"_45":298,"_33":299,"_31":300,"_154":283,"_43":44,"_42":301,"_156":27,"_40":302,"_13":174,"_35":36,"_37":303,"_24":27,"_161":-5,"_218":304,"_28":305},{"_45":290,"_33":291,"_31":292,"_154":283,"_43":44,"_42":293,"_156":27,"_40":294,"_13":174,"_35":36,"_37":295,"_24":27,"_161":-5,"_218":296,"_28":297},{"_45":280,"_33":281,"_31":282,"_154":283,"_43":44,"_42":284,"_156":25,"_40":285,"_13":174,"_35":36,"_37":286,"_24":27,"_161":-5,"_218":287,"_28":288},{"_45":272,"_33":273,"_31":274,"_154":249,"_43":44,"_42":275,"_156":27,"_40":276,"_13":65,"_35":36,"_37":277,"_24":27,"_161":-5,"_218":278,"_28":279},{"_45":264,"_33":265,"_31":266,"_154":249,"_43":44,"_42":267,"_156":27,"_40":268,"_13":65,"_35":36,"_37":269,"_24":27,"_161":-5,"_218":270,"_28":271},{"_45":256,"_33":257,"_31":258,"_154":249,"_43":44,"_42":259,"_156":27,"_40":260,"_13":174,"_35":36,"_37":261,"_24":27,"_161":-5,"_218":262,"_28":263},{"_45":246,"_33":247,"_31":248,"_154":249,"_43":44,"_42":250,"_156":25,"_40":251,"_13":180,"_35":36,"_37":252,"_24":27,"_161":-5,"_218":253,"_28":254},{"_45":239,"_33":240,"_31":241,"_154":172,"_43":44,"_42":65,"_156":27,"_40":242,"_13":174,"_35":20,"_37":243,"_24":27,"_161":-5,"_218":244,"_28":245},{"_45":231,"_33":232,"_31":233,"_154":172,"_43":44,"_42":234,"_156":27,"_40":235,"_13":180,"_35":20,"_37":236,"_24":27,"_161":-5,"_218":237,"_28":238},{"_45":224,"_33":225,"_31":226,"_154":172,"_43":44,"_42":65,"_156":25,"_40":227,"_13":174,"_35":36,"_37":228,"_24":27,"_161":-5,"_218":229,"_28":230},{"_45":163,"_33":164,"_31":165,"_154":-5,"_43":44,"_42":166,"_156":25,"_40":221,"_13":158,"_35":20,"_37":168,"_24":27,"_161":-5,"_218":222,"_28":223},{"_45":152,"_33":153,"_31":60,"_154":-5,"_43":44,"_42":155,"_156":27,"_40":217,"_13":158,"_35":159,"_37":160,"_24":27,"_161":47,"_218":219,"_28":220},["D",1780416358953],"children",[],[153],["D",1780415404602],[],[164],"f94deee6-5e96-11f1-a008-1607ee4eb77e","index.tsx","019e88ee-890a-72f8-a279-1a31fa3e7e92",["D",1780413794401],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client\";\nimport { App } from \"./components/App.tsx\";\n\nconst root = document.getElementById(\"root\");\nif (!root) {\n throw new Error(\"No root element found\");\n}\n\ncreateRoot(root).render();",[],[171,225],"e0db4678-5e9c-11f1-9ec8-1607ee4eb77e","index.html","019e88ee-890a-72f8-a279-15dc455934ab",42,["D",1780416330519],"\n\n \n \n \n Claude Managed Agent\n \n \n \n \n

\n \n \n \n\n",[],[171,232],"f94de36a-5e96-11f1-a008-1607ee4eb77e","favicon.svg","019e88ee-890a-72f8-a279-127b4bb2ba62",["D",1780413794401],"\n",[],[171,240],"dd36236c-5e9c-11f1-8f62-1607ee4eb77e","api.ts","e8672b46-5e97-11f1-a823-1607ee4eb77e","019e88ee-890a-72f8-a279-0d2bca618dcd",40,["D",1780416324362],"export interface Thread {\n id: string;\n session_id: string | null;\n title: string;\n last_cursor: string | null;\n created_at: string;\n}\n\nexport interface Message {\n id: number;\n thread_id: string;\n role: \"user\" | \"assistant\" | \"system\";\n // content varies by type:\n // text → plain text\n // tool_use → JSON string { name, input }\n // tool_result → JSON string { output, is_error? }\n // image → JSON string { id, name, mime } (served at /api/files/)\n // file → JSON string { id, name, mime } (download at /api/files/)\n // error → plain text (rendered red)\n type: \"text\" | \"tool_use\" | \"tool_result\" | \"error\" | \"image\" | \"file\";\n content: string;\n created_at: string;\n}\n\nexport interface FilePayload {\n id: string;\n name: string;\n mime: string;\n}\n\nexport interface Me {\n username: string;\n used: number;\n limit: number;\n remaining: number;\n}\n\n// Thrown when an /api/* call returns 401 — the caller should show the login screen.\nexport class UnauthorizedError extends Error {\n constructor() {\n super(\"unauthorized\");\n this.name = \"UnauthorizedError\";\n }\n}\n\n// Thrown when a send hits the demo limit (HTTP 429).\nexport class LimitError extends Error {\n remaining: number;\n constructor(message: string, remaining: number) {\n super(message);\n this.name = \"LimitError\";\n this.remaining = remaining;\n }\n}\n\nasync function json(res: Response): Promise {\n if (res.status === 401) throw new UnauthorizedError();\n if (!res.ok) throw new Error(`${res.status} ${res.statusText}`);\n return res.json() as Promise;\n}\n\nexport const api = {\n // Returns the logged-in user + usage. Throws UnauthorizedError when not logged in.\n me(): Promise {\n return fetch(\"/api/me\").then((r) => json(r));\n },\n listThreads(): Promise {\n return fetch(\"/api/threads\").then((r) => json(r));\n },\n createThread(): Promise {\n return fetch(\"/api/threads\", { method: \"POST\" }).then((r) => json(r));\n },\n getMessages(threadId: string, after: number): Promise {\n return fetch(`/api/threads/${threadId}/messages?after=${after}`).then((r) =>\n json(r)\n );\n },\n // Stays open the whole turn. Resolves { ok: true }; throws LimitError on HTTP 429.\n async send(threadId: string, text: string): Promise<{ ok: true }> {\n const res = await fetch(`/api/threads/${threadId}/messages`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ text }),\n });\n if (res.status === 401) throw new UnauthorizedError();\n if (res.status === 429) {\n const body = await res.json().catch(() => ({})) as {\n error?: string;\n remaining?: number;\n };\n throw new LimitError(\n body.error ?? \"You've reached the demo message limit.\",\n body.remaining ?? 0,\n );\n }\n if (!res.ok) throw new Error(`${res.status} ${res.statusText}`);\n return res.json() as Promise<{ ok: true }>;\n },\n async logout(): Promise {\n await fetch(\"/auth/logout\", { method: \"POST\" }).catch(() => {});\n },\n};\n\nexport const SOURCE_VAL_URL = \"https://www.val.town/x/templates/claude-managed-agents-ui\";\n",[],[171,255,247],"components","fc6c89d8-5e9c-11f1-8d56-1607ee4eb77e","Composer.tsx","fc6c8ab4-5e9c-11f1-8d56-1607ee4eb77e",55,["D",1780416376801],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useState } from \"https://esm.sh/react@18.2.0\";\n\n// Sticky message composer. Disabled (with a reason) when busy or limit-reached.\nexport function Composer(\n { onSend, busy, disabled, disabledReason }: {\n onSend: (text: string) => void;\n busy: boolean;\n disabled?: boolean;\n disabledReason?: string;\n },\n) {\n const [text, setText] = useState(\"\");\n\n function submit() {\n const t = text.trim();\n if (!t || busy || disabled) return;\n onSend(t);\n setText(\"\");\n }\n\n return (\n

\n {disabled && disabledReason && (\n

\n {disabledReason}\n

\n )}\n

\n setText((e.target as HTMLTextAreaElement).value)}\n onKeyDown={(e) => {\n if (e.key === \"Enter\" && !e.shiftKey) {\n e.preventDefault();\n submit();\n }\n }}\n />\n \n {busy ? \"…\" : \"Send\"}\n \n

\n Press Enter to send · Shift+Enter for a new line\n

\n );\n}\n",[],[171,255,257],"48855664-5e99-11f1-8734-1607ee4eb77e","Chat.tsx","f078aca6-5e97-11f1-bd0e-1607ee4eb77e",23,["D",1780414786474],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useEffect, useRef, useState } from \"https://esm.sh/react@18.2.0\";\nimport type { FilePayload, Message } from \"./api.ts\";\n\nfunction MessageRow({ m }: { m: Message }) {\n // Files the agent created in its sandbox: images inline, others as a download.\n if (m.type === \"image\" || m.type === \"file\") {\n const f = JSON.parse(m.content) as FilePayload;\n const url = `/api/files/${f.id}`;\n return (\n

\n {m.type === \"image\"\n ? (\n \n {f.name}

\n \n )\n : (\n \n ⬇ {f.name}\n \n )}\n

\n );\n }\n if (m.role === \"user\") {\n return (\n

\n {m.content}\n

\n );\n }\n if (m.role === \"system\" && m.type === \"error\") {\n return

{m.content}

;\n }\n if (m.role === \"assistant\" && m.type === \"tool_use\") {\n return

🔧 {m.content}

;\n }\n return (\n

\n {m.content}\n

\n );\n}\n\nexport function Chat(\n { messages, onSend, busy }: {\n messages: Message[];\n onSend: (text: string) => void;\n busy: boolean;\n },\n) {\n const [text, setText] = useState(\"\");\n const endRef = useRef(null);\n\n useEffect(() => {\n endRef.current?.scrollIntoView({ behavior: \"smooth\" });\n }, [messages]);\n\n function submit() {\n const t = text.trim();\n if (!t) return;\n onSend(t);\n setText(\"\");\n }\n\n return (\n

\n {messages.length === 0\n ? (\n

\n Send a message to get started.\n

\n )\n : messages.map((m) => )}\n

\n );\n}\n",[],[171,255,265],"f9914d5c-5e97-11f1-9821-1607ee4eb77e","App.tsx","019e88ee-890a-72f8-a279-04f780b271a6",9,["D",1780414224516],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useEffect, useRef, useState } from \"https://esm.sh/react@18.2.0\";\nimport { api, type Message, type Thread } from \"./api.ts\";\nimport { Chat } from \"./Chat.tsx\";\n\nexport function App() {\n const [threads, setThreads] = useState([]);\n const [currentId, setCurrentId] = useState(null);\n const [messages, setMessages] = useState([]);\n const [busy, setBusy] = useState(false);\n const cursorRef = useRef(0);\n\n async function refreshThreads() {\n try {\n setThreads(await api.listThreads());\n } catch (_e) { /* ignore */ }\n }\n\n useEffect(() => {\n refreshThreads();\n }, []);\n\n function openThread(id: string) {\n setCurrentId(id);\n setMessages([]);\n cursorRef.current = 0;\n }\n\n async function newChat() {\n try {\n const t = await api.createThread();\n await refreshThreads();\n openThread(t.id);\n } catch (_e) { /* ignore */ }\n }\n\n // Poll the open thread for new messages.\n useEffect(() => {\n if (!currentId) return;\n let alive = true;\n async function poll() {\n try {\n const rows = await api.getMessages(currentId!, cursorRef.current);\n if (!alive || rows.length === 0) return;\n cursorRef.current = rows[rows.length - 1].id;\n setMessages((prev) => [...prev.filter((m) => m.id >= 0), ...rows]);\n } catch (_e) { /* ignore */ }\n }\n poll();\n const iv = setInterval(poll, 1000);\n return () => {\n alive = false;\n clearInterval(iv);\n };\n }, [currentId]);\n\n async function send(text: string) {\n if (!currentId) return;\n const optimistic: Message = {\n id: -1,\n thread_id: currentId,\n role: \"user\",\n type: \"text\",\n content: text,\n created_at: new Date().toISOString(),\n };\n setMessages((prev) => [...prev, optimistic]);\n setBusy(true);\n try {\n await api.send(currentId, text);\n } catch (_e) { /* ignore */ }\n setBusy(false);\n refreshThreads();\n }\n\n return (\n

\n \n

\n {currentId\n ? \n : (\n

\n Select a chat or start a new one to talk to your Claude Managed Agent.\n

\n )}\n

\n );\n}\n",[],[171,255,273],"f0f4f93c-5e9c-11f1-b355-1607ee4eb77e","ToolMessage.tsx","f0f4fa18-5e9c-11f1-b355-1607ee4eb77e","81d77aa6-31d1-47ae-9d3c-2fb6ebc65671",51,["D",1780416357558],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useState } from \"https://esm.sh/react@18.2.0\";\nimport type { Message } from \"../api.ts\";\n\n// Pretty-print whatever the content parses to; fall back to the raw string.\nfunction pretty(content: string): string {\n try {\n return JSON.stringify(JSON.parse(content), null, 2);\n } catch {\n return content;\n }\n}\n\n// Compact click-to-expand chip for tool_use / tool_result rows.\n// tool_use → 🔧 ▸ (parsed { name, input })\n// tool_result → 📤 result ▸ (parsed { output, is_error? }) — red when is_error.\nexport function ToolMessage({ m }: { m: Message }) {\n const [open, setOpen] = useState(false);\n\n let label: string;\n let icon: string;\n let isError = false;\n\n if (m.type === \"tool_use\") {\n icon = \"🔧\";\n let name = \"tool\";\n try {\n const parsed = JSON.parse(m.content) as { name?: string };\n if (parsed?.name) name = parsed.name;\n } catch { /* keep default */ }\n label = name;\n } else {\n // tool_result\n icon = \"📤\";\n label = \"result\";\n try {\n const parsed = JSON.parse(m.content) as { is_error?: boolean };\n isError = !!parsed?.is_error;\n } catch { /* keep default */ }\n }\n\n return (\n

\n setOpen((v) => !v)}\n class={`inline-flex items-center gap-1.5 rounded-full border px-3 py-1 text-xs font-medium ${\n isError\n ? \"border-red-200 bg-red-50 text-red-700 hover:bg-red-100\"\n : \"border-neutral-200 bg-neutral-100 text-neutral-700 hover:bg-neutral-200\"\n }`}\n >\n {icon}\n {label}\n \n ▸\n \n \n {open && (\n

\n            {pretty(m.content)}\n

\n )}\n

\n );\n}\n",[],[171,255,289,281],"messages","e4f11ba2-5e9c-11f1-9b38-1607ee4eb77e","TextMessage.tsx","e4f11c60-5e9c-11f1-9b38-1607ee4eb77e",45,["D",1780416337399],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport type { Message } from \"../api.ts\";\n\n// Plain text. User messages are right-aligned blue bubbles; assistant/system\n// text is a left-aligned neutral bubble. Whitespace is preserved (no markdown lib).\nexport function TextMessage({ m }: { m: Message }) {\n const isUser = m.role === \"user\";\n return (\n

\n \n {m.content}\n

\n );\n}\n",[],[171,255,289,291],"f7a23970-5e9c-11f1-9ec8-1607ee4eb77e","MessageList.tsx","f7a23a06-5e9c-11f1-9ec8-1607ee4eb77e",54,["D",1780416368758],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useEffect, useRef } from \"https://esm.sh/react@18.2.0\";\nimport type { Message } from \"../api.ts\";\nimport { TextMessage } from \"./TextMessage.tsx\";\nimport { ToolMessage } from \"./ToolMessage.tsx\";\nimport { ImageMessage } from \"./ImageMessage.tsx\";\nimport { FileMessage } from \"./FileMessage.tsx\";\n\n// Render one message row based on its type per the locked contract.\nfunction MessageRow({ m }: { m: Message }) {\n switch (m.type) {\n case \"tool_use\":\n case \"tool_result\":\n return ;\n case \"image\":\n return ;\n case \"file\":\n return ;\n case \"error\":\n return (\n

\n {m.content}\n

\n );\n case \"text\":\n default:\n return ;\n }\n}\n\nexport function MessageList({ messages }: { messages: Message[] }) {\n const endRef = useRef(null);\n\n useEffect(() => {\n endRef.current?.scrollIntoView({ behavior: \"smooth\" });\n }, [messages]);\n\n return (\n

\n {messages.map((m) => )}\n

\n );\n}\n",[],[171,255,289,299],"e797fc04-5e9c-11f1-84f0-1607ee4eb77e","ImageMessage.tsx","e797fcc2-5e9c-11f1-84f0-1607ee4eb77e",46,["D",1780416341853],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport type { FilePayload, Message } from \"../api.ts\";\n\n// An image the agent produced in its sandbox, rendered inline.\nexport function ImageMessage({ m }: { m: Message }) {\n let f: FilePayload;\n try {\n f = JSON.parse(m.content) as FilePayload;\n } catch {\n return

[unreadable image]

;\n }\n const url = `/api/files/${f.id}`;\n return (\n

\n \n {f.name}

\n \n

{f.name}

\n );\n}\n",[],[171,255,289,307],"eb8f3ed0-5e9c-11f1-8834-1607ee4eb77e","FileMessage.tsx","eb8f3f84-5e9c-11f1-8834-1607ee4eb77e",49,["D",1780416348504],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport type { FilePayload, Message } from \"../api.ts\";\n\n// A non-image file the agent produced — rendered as a download link.\nexport function FileMessage({ m }: { m: Message }) {\n let f: FilePayload;\n try {\n f = JSON.parse(m.content) as FilePayload;\n } catch {\n return

[unreadable file]

;\n }\n const url = `/api/files/${f.id}`;\n return (\n

\n \n ⬇\n {f.name}\n \n

\n );\n}\n",[],[171,255,289,315],"e4f1275a-5e9c-11f1-9b38-1607ee4eb77e",["D",1780416337399],[203,204,205,206,207],[171,255,289],"f94de068-5e96-11f1-a008-1607ee4eb77e",["D",1780413794401],[202,208,209,210,211],[171,255],["D",1780413794401],[201,212,213,214],[171],"4e1ba8e8-5e9a-11f1-bcc6-1607ee4eb77e","files.ts","2d47e1f0-5e99-11f1-a841-1607ee4eb77e",32,["D",1780415225342],"import Anthropic from \"npm:@anthropic-ai/sdk@0.100.1\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { addMessage, getMessages } from \"./db.ts\";\n\n// Files the agent creates in its sandbox are surfaced via the Managed Agents\n// Files API, scoped to the session: `files.list({ scope_id })` enumerates them\n// (id, filename, mime_type), and `files.download(id)` returns the bytes. Val Town\n// has no filesystem, so we copy each new file into std/blob and record a row.\nconst client = new Anthropic();\nconst BETA = \"managed-agents-2026-04-01\";\n\n// Content payload stored on image/file message rows. The frontend reads `id` to\n// build the /api/files/:id URL, plus `name`/`mime` for display + downloads.\nexport interface FilePayload {\n id: string;\n name: string;\n mime: string;\n}\n\nconst blobKey = (id: string) => `file_${id}`;\n\n// Read the bytes we stashed in blob storage for a served file.\nexport const getFileBytes = (id: string) => blob.get(blobKey(id));\n\n// After a turn, mirror any session files the thread hasn't surfaced yet into blob\n// storage and write an image/file row for each. Images render inline; everything\n// else becomes a download link.\nexport async function syncSessionFiles(threadId: string, sessionId: string) {\n const seen = new Set(\n (await getMessages(threadId, 0))\n .filter((m: any) => m.type === \"image\" || m.type === \"file\")\n .map((m: any) => (JSON.parse(m.content) as FilePayload).id),\n );\n\n const res = await client.beta.files.list(\n { scope_id: sessionId, betas: [BETA] } as any,\n );\n const fresh = (res.data as any[]).filter((f) =>\n f.downloadable !== false && !seen.has(f.id)\n );\n\n await Promise.all(fresh.map(async (f) => {\n const dl = await client.beta.files.download(f.id, { betas: [BETA] } as any);\n const bytes = new Uint8Array(await (dl as any).arrayBuffer());\n await blob.set(blobKey(f.id), bytes);\n const mime: string = f.mime_type ?? \"application/octet-stream\";\n const payload: FilePayload = { id: f.id, name: f.filename ?? f.id, mime };\n const type = mime.startsWith(\"image/\") ? \"image\" : \"file\";\n await addMessage(threadId, \"assistant\", type, JSON.stringify(payload));\n }));\n}",[],[178,334],"e7c2fb98-5e9c-11f1-94a9-1607ee4eb77e","db.ts","31cd7692-5e97-11f1-91e4-1607ee4eb77e",47,["D",1780416342125],3,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// A thread = one Managed Agent session. Messages stream into SQLite; the\n// frontend polls for new rows. `config` caches the create-once agent + env ids.\nawait sqlite.batch([\n `CREATE TABLE IF NOT EXISTS config (key TEXT PRIMARY KEY, value TEXT)`,\n `CREATE TABLE IF NOT EXISTS threads (\n id TEXT PRIMARY KEY, session_id TEXT, title TEXT,\n last_cursor TEXT, created_at TEXT DEFAULT CURRENT_TIMESTAMP)`,\n `CREATE TABLE IF NOT EXISTS messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT, thread_id TEXT,\n role TEXT, type TEXT, content TEXT, created_at TEXT DEFAULT CURRENT_TIMESTAMP)`,\n]);\n\n// Per-user ownership of threads. Idempotent: ignore \"duplicate column\" on re-run.\ntry {\n await sqlite.execute(`ALTER TABLE threads ADD COLUMN user_id TEXT`);\n} catch (_e) { /* column already exists */ }\n\nconst one = async (sql: string, args: unknown[] = []) =>\n (await sqlite.execute({ sql, args })).rows[0];\nconst all = async (sql: string, args: unknown[] = []) =>\n (await sqlite.execute({ sql, args })).rows;\n\nexport const getConfig = async (key: string) =>\n (await one(`SELECT value FROM config WHERE key = ?`, [key]))?.value as string | undefined;\nexport const setConfig = (key: string, value: string) =>\n sqlite.execute({ sql: `INSERT OR REPLACE INTO config VALUES (?, ?)`, args: [key, value] });\n\nexport const listThreads = () => all(`SELECT * FROM threads ORDER BY created_at DESC`);\nexport const listThreadsForUser = (userId: string) =>\n all(`SELECT * FROM threads WHERE user_id = ? ORDER BY created_at DESC`, [userId]);\nexport const getThread = (id: string) => one(`SELECT * FROM threads WHERE id = ?`, [id]);\nexport const createThread = (id: string, title: string, userId: string) =>\n sqlite.execute({\n sql: `INSERT INTO threads (id, title, user_id) VALUES (?, ?, ?)`,\n args: [id, title, userId],\n });\n\n// Count this user's user-role messages across all their threads (the rate-limit basis).\nexport const countUserMessages = async (userId: string) =>\n Number(\n (await one(\n `SELECT COUNT(*) AS n FROM messages m\n JOIN threads t ON m.thread_id = t.id\n WHERE t.user_id = ? AND m.role = 'user'`,\n [userId],\n ))?.n ?? 0,\n );\nexport const setTitle = (id: string, title: string) =>\n sqlite.execute({ sql: `UPDATE threads SET title = ? WHERE id = ?`, args: [title, id] });\nexport const setSession = (id: string, sessionId: string) =>\n sqlite.execute({ sql: `UPDATE threads SET session_id = ? WHERE id = ?`, args: [sessionId, id] });\nexport const setCursor = (id: string, cursor: string) =>\n sqlite.execute({ sql: `UPDATE threads SET last_cursor = ? WHERE id = ?`, args: [cursor, id] });\n\nexport const addMessage = (threadId: string, role: string, type: string, content: string) =>\n sqlite.execute({\n sql: `INSERT INTO messages (thread_id, role, type, content) VALUES (?, ?, ?, ?)`,\n args: [threadId, role, type, content],\n });\nexport const getMessages = (threadId: string, after: number) =>\n all(`SELECT * FROM messages WHERE thread_id = ? AND id > ? ORDER BY id`, [threadId, after]);\n\n// Look up the { id, name, mime } payload for a surfaced file row by its file id,\n// so the /api/files/:id route can serve the right Content-Type + filename.\nexport const getFilePayload = async (fileId: string) => {\n const row = await one(\n `SELECT content FROM messages WHERE type IN ('image', 'file')\n AND content LIKE ? ORDER BY id DESC LIMIT 1`,\n [`%${fileId}%`],\n );\n return row ? JSON.parse(row.content as string) as { id: string; name: string; mime: string } : null;\n};\n",[],[178,342],"dfa1bae4-5e9c-11f1-ae30-1607ee4eb77e","auth.ts","dfa1bb84-5e9c-11f1-ae30-1607ee4eb77e",41,["D",1780416328492],"import { getOAuthUserData } from \"https://esm.town/v/std/oauth/middleware.ts\";\nimport type { Context } from \"npm:hono\";\nimport * as db from \"./db.ts\";\n\n// Per-user cap on user-role messages, counted globally across all the user's threads.\nexport const MESSAGE_LIMIT = 50;\n\nexport type User = { id: string; username: string };\n\n// Resolve the current Val Town user from the request's OAuth session, or null\n// if unauthenticated. We key threads/usage on a stable id (username).\nexport async function requireUser(c: Context): Promise {\n const session = await getOAuthUserData(c.req.raw);\n const u = session?.user;\n if (!u) return null;\n const username = u.username as string;\n return { id: String(u.id ?? username), username };\n}\n\n// How many user-role messages this user has sent (across all their threads).\nexport const countUsage = (userId: string) => db.countUserMessages(userId);\n",[],[178,351],"450214f4-5e9a-11f1-a139-1607ee4eb77e","agent.ts","df88de02-5e97-11f1-a3de-1607ee4eb77e",30,["D",1780415210079],"import Anthropic from \"npm:@anthropic-ai/sdk@0.100.1\";\nimport {\n addMessage,\n getConfig,\n setConfig,\n setCursor,\n setSession,\n} from \"./db.ts\";\nimport { syncSessionFiles } from \"./files.ts\";\n\nconst client = new Anthropic();\nconst MODEL = \"claude-opus-4-8\";\nconst SYSTEM =\n \"You are a helpful coding assistant working in a sandbox. Use your tools (bash, file editing, web) to actually do the work, then briefly summarize what you did.\";\n\n// Create the agent + environment ONCE and cache their ids. Agents are versioned\n// configs and sessions pin to a version, so recreating them per request is wrong.\nexport async function ensureConfig() {\n const agentId = await getConfig(\"agent_id\");\n const envId = await getConfig(\"environment_id\");\n if (agentId && envId) return { agentId, envId };\n\n const agent = await client.beta.agents.create({\n name: \"Managed Agent Demo\",\n model: MODEL,\n system: SYSTEM,\n // Built-in toolset runs in Anthropic's sandbox; always_allow = run without prompting.\n tools: [{\n type: \"agent_toolset_20260401\",\n default_config: { permission_policy: { type: \"always_allow\" } },\n }],\n });\n const environment = await client.beta.environments.create({\n name: \"demo-env\",\n config: { type: \"cloud\", networking: { type: \"unrestricted\" } },\n });\n await setConfig(\"agent_id\", agent.id);\n await setConfig(\"environment_id\", environment.id);\n return { agentId: agent.id, envId: environment.id };\n}\n\n// Each thread gets one session, created lazily and reused for follow-up turns.\nexport async function ensureSession(thread: any) {\n if (thread.session_id) return thread.session_id as string;\n const { agentId, envId } = await ensureConfig();\n const session = await client.beta.sessions.create({\n agent: agentId,\n environment_id: envId,\n title: thread.title,\n });\n await setSession(thread.id, session.id);\n return session.id;\n}\n\n// One turn: open the stream, send the message, then persist each event to SQLite\n// until the session goes idle. The frontend polls those rows as they land.\nexport async function runTurn(\n threadId: string,\n sessionId: string,\n text: string,\n) {\n const stream = await client.beta.sessions.events.stream(sessionId);\n await client.beta.sessions.events.send(sessionId, {\n events: [{ type: \"user.message\", content: [{ type: \"text\", text }] }],\n });\n for await (const event of stream) {\n const e = event as any;\n if (e.id) await setCursor(threadId, e.id);\n if (event.type === \"agent.message\") {\n for (const block of e.content) {\n if (block.type === \"text\") {\n await addMessage(threadId, \"assistant\", \"text\", block.text);\n }\n }\n } else if (event.type === \"agent.tool_use\") {\n await addMessage(threadId, \"assistant\", \"tool_use\", e.name);\n } else if (event.type === \"session.error\") {\n await addMessage(\n threadId,\n \"system\",\n \"error\",\n e.error?.message ?? \"session error\",\n );\n break;\n } else if (event.type === \"session.status_idle\") {\n break;\n }\n }\n // Surface any files the agent created in its sandbox this turn (images render\n // inline; other downloadables become links). Best-effort: never fail the turn.\n try {\n await syncSessionFiles(threadId, sessionId);\n } catch (_e) { /* ignore */ }\n}",[],[178,359],"f49446f6-5e9c-11f1-90a6-1607ee4eb77e","_read.ts","e9361f1e-5e9c-11f1-a0be-1607ee4eb77e",53,["D",1780416363629],"import { blob } from \"https://esm.town/v/std/blob\";\n\nexport default async function (_req: Request) {\n const b = await blob.get(\"_probe_result\");\n if (!b) return Response.json({ found: false });\n const txt = await (b as any).text();\n return new Response(txt, { headers: { \"content-type\": \"application/json\" } });\n}\n",[],[178,367],"007bf5cc-5e9d-11f1-80e2-1607ee4eb77e",["D",1780416383605],[],[178,34],["D",1780413889356],[194,195,196,197,198,199],[178],["D",1780413794401],["D",1789495880338],{"_105":104,"_113":109},{"_105":104,"_106":107,"_108":109,"_18":-5,"_110":111,"_112":25},{"_13":91,"_33":92,"_45":44,"_93":46,"_94":95,"_96":97,"_98":52,"_99":100,"_101":67,"_102":47,"_103":104},"ctx",{"_84":-5,"_135":419,"_420":421,"_422":423,"_424":27,"_425":27,"_426":27,"_427":25,"_428":-5,"_429":-7,"_430":-7,"_431":174,"_432":27,"_433":27,"_434":-5,"_435":27,"_436":27,"_437":27,"_438":-5},"ENV",{"_390":391,"_392":393,"_394":92,"_395":396,"_397":398,"_399":400,"_401":402,"_403":404,"_405":406,"_407":408,"_409":410,"_411":412,"_413":414,"_415":416,"_417":418},"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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v56