hi

\", { headers: { \"Content-Type\": \"text/html\" }}));\n */\nexport function wrapFetch<\n H extends (req: Request) => Promise | Response,\n>(\n handler: H,\n opts: VoiceEditOptions = {},\n): (req: Request) => Promise {\n return async (req: Request) => {\n const resp = await handler(req);\n return maybeInject(resp, opts);\n };\n}\n\nexport default voiceEdit;\n","deleted","label",[133],"0f2a19e8-5d1f-11f1-bc69-1607ee4eb77e","oauth-test.tsx","019e7f4e-f0e9-72ce-b45f-d710b7cbff25",["D",1780252340388],"http","/** @jsxImportSource https://esm.sh/hono/jsx */\nimport { Hono } from \"https://esm.sh/hono\";\nimport {\n getOAuthUserData,\n oauthMiddleware,\n} from \"https://esm.town/v/std/oauth/middleware.ts\";\n\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n const session = await getOAuthUserData(c.req.raw);\n\n return c.html(\n \n \n {session?.user\n ?

Logged in as {session.user.username}

\n : Log in}\n \n ,\n );\n});\n\nexport default oauthMiddleware(app.fetch);\n",[150],"84233ac8-5d23-11f1-a6b8-1607ee4eb77e","main.tsx",35,["D",1780254254718],3,"import { Hono } from \"npm:hono\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { parseVal, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport {\n getOAuthUserData,\n oauthMiddleware,\n} from \"https://esm.town/v/std/oauth/middleware.ts\";\nimport rtc from \"./routes/rtc.ts\";\nimport observer from \"./routes/observer.ts\";\nimport api from \"./routes/api.ts\";\nimport memory from \"./routes/memory.ts\";\n\nconst SOURCE_URL = parseVal(Deno.env.get(\"VALTOWN_ENTRYPOINT\")).links.self.val;\n\nconst app = new Hono();\n\napp.route(\"/rtc\", rtc);\napp.route(\"/observer\", observer);\napp.route(\"/api\", api);\napp.route(\"/api/memory\", memory);\napp.get(\"/source\", (c) => c.redirect(SOURCE_URL));\n\napp.get(\"/me\", async (c) => {\n const session = await getOAuthUserData(c.req.raw);\n if (!session) return c.json({ loggedIn: false });\n return c.json({\n loggedIn: true,\n username: session.user.username,\n profileImageUrl: session.user.links.profileImageUrl,\n });\n});\n\n// Token handoff — included for completeness but the studio is top-level\n// same-origin so cookies work and Bearer is rarely needed.\napp.get(\"/auth/token\", async (c) => {\n const session = await getOAuthUserData(c.req.raw);\n if (!session) return c.json({ loggedIn: false }, 401);\n return c.json({\n loggedIn: true,\n username: session.user.username,\n accessToken: session.accessToken,\n });\n});\n\napp.get(\"/\", () => serveFile(\"/frontend/studio.html\", import.meta.url));\napp.get(\"/memory\", () => serveFile(\"/frontend/memory.html\", import.meta.url));\napp.get(\"/favicon.ico\", async (c) => {\n const entry = parseVal(Deno.env.get(\"VALTOWN_ENTRYPOINT\"));\n const file = await blob.get(`${entry.name}/favicon.ico`);\n if (!file) return c.text(\"favicon not found\", 404);\n return new Response(file.body, {\n headers: {\n \"Content-Type\": \"image/x-icon\",\n \"Cache-Control\": \"public, max-age=31536000, immutable\",\n },\n });\n});\n\napp.onError((err) => Promise.reject(err));\n\nexport default oauthMiddleware(\n {\n scopes: [\n \"openid\",\n \"offline_access\",\n \"profile\",\n \"user_r\",\n \"val_rw\",\n \"project_rw\",\n \"blob_rw\",\n \"sqlite_rw\",\n \"telemetry_rw\",\n ],\n },\n app.fetch,\n);\n",[157],"a3d9504e-5d25-11f1-a413-1607ee4eb77e","README.md","019e7f4e-f0e9-72ce-b45f-ce6a004a3901",65,["D",1780255166884],4,"# hey-townie — Voice Edit Studio + face trigger\n\n**hey-townie** is a remix of the `talk-to-code` Voice Edit Studio: a\nvoice-controlled workspace for building and editing [Val Town](https://val.town)\nvals just by talking, powered by the OpenAI Realtime API — now with **on-device\nface detection that starts a call hands-free**. A small camera preview sits in\nthe bottom-right corner; when your face is detected close and confident enough,\na voice session starts automatically and the AI **greets you first by name**.\nThe call stays open until you end it (the talk button) or say \"goodbye\" (the AI\nhangs up itself).\n\nThe whole sidebar is now a **hamburger-summoned drawer at every screen width**\n(no permanent sidebar) — the face-tracking sliders live in it.\n\n## Face-triggered sessions\n\n- A persistent camera+mic stream feeds **MediaPipe FaceDetector**\n (`blaze_face_short_range`). The bottom-right PiP draws the detection box and a\n live confidence / face-size readout.\n- Two sliders (in the drawer) gate when a call fires: **min confidence** and\n **min closeness** (face size as % of frame — bigger = must be nearer). A call\n auto-starts on the rising edge of crossing *both* thresholds, only when\n logged in and idle, and re-arms after your face leaves the frame.\n- The AI can retune the gate by voice via **`set_face_tuning`** (\"you're too\n sensitive\", \"wait until I'm closer\"), and hang up via **`end_call`** when you\n say goodbye.\n- The mic is shared from the camera stream (cloned for the call), so there's a\n single permission prompt on load. Greeting audio may be blocked by the browser\n until your first interaction — clicking anywhere once unlocks it.\n\n## Per-user memory (one ledger, pinned = always-loaded)\n\nEach logged-in user gets a private, append-only \"second brain\" (SQLite, scoped by\nVal Town handle) so calls don't start from scratch. It's **one unified ledger**:\n\n- **Subjects** (projects, objects, topics — and **`me`** for the user themselves)\n each hold append-only **facts**; **edges** relate subjects.\n- A fact is **pinned** (auto-loads into the system prompt every call — the\n \"never start from scratch\" layer) or **unpinned** (recalled on demand). The\n pin flag is the single determiner of \"always-loaded vs on-demand\".\n- **Identity is not stored** — the user's name, handle, and email are pulled\n from their Val Town login (`/v2/me`) and injected into the prompt each call.\n\nTools (write only when asked): `remember_about_me` (pinned fact under `me`),\n`record_fact(subject_id, assertion, pin?)`, `recall_subject`, `recall_recent`,\n`link_subjects`, `retract_fact`. The agent is instructed to be conservative —\nwrite only on request, pin only for \"always remember…\", never dump memory\nunprompted.\n\nThe **🧠 Memory** page (`/memory`) is the dashboard: a \"📌 Always loaded\"\npanel, per-fact pin/unpin, subject timelines, manual entry, and the **mindmap**\n(force-graph of subjects + relations). Backend + API live in `routes/memory.ts`.\n\n## What it does\n\n- **Talk to edit** — describe a change (\"add a dark mode toggle\", \"make the\n header bigger\") and the AI edits the val's files, then reloads the preview.\n- **Open any val** — say _\"open my X\"_, **type a val name** in the box (a bare\n name resolves to your handle; `handle/name` and pasted val.town URLs work\n too), click one from **Recent vals**, or seed it with `?val=handle/name`.\n- **Create from scratch** — the **✨ Create a new val** button (or just asking\n the AI) spins up a minimal HTTP val with a starter page and loads it, so you\n have an instant canvas to iterate on.\n- **Newcomer-friendly** — the AI is briefed to assume the person may be brand\n new to this _and_ to Val Town, orient them in plain language, and offer a\n concrete first thing to build.\n- **Scenes & choreography** — vals can ship a `CHOREOGRAPHY.md`; the AI triggers\n pre-built overlays via the `set_scene` tool and can drive slideshows.\n\n## How it works\n\n1. The browser logs in with **Val Town OAuth** and opens a WebRTC mic\n connection.\n2. `POST /rtc` negotiates an **OpenAI Realtime** session, seeded with the\n official Townie system prompt plus a Studio-specific addendum, and attaches\n the signed-in user's **Val Town MCP** token so the AI can read/write their\n vals (`routes/agent.ts`).\n3. The AI calls **function tools** handled in the browser — `load_val`,\n `navigate_page`, `reload_site`, `set_scene`, `slide_next/prev/goto`,\n `set_face_tuning`, `end_call` — and the `val_town_mcp` tools for file edits.\n4. The preview iframe reloads **on demand** (via the `reload_site` tool or the\n \"↻ Reload site\" button) — auto-refresh polling is intentionally disabled.\n\n## Running your own / OpenAI key\n\nThe deployed studio runs on the owner's `OPENAI_API_KEY`. If that key is ever\nrejected or out of quota, the UI shows a **\"remix this val & add your own\n`OPENAI_API_KEY`\"** prompt instead of a cryptic error.\n\nTo run your own copy:\n\n1. **Remix** this val (the link in the error, or the Remix button on the val\n page).\n2. Set **`OPENAI_API_KEY`** (an OpenAI key with Realtime API access) in the\n remixed val's environment variable settings.\n3. Open the val's HTTP endpoint and start talking.\n\n## Environment variables\n\n- **`OPENAI_API_KEY`** _(required)_ — OpenAI key with Realtime API access. The\n app no longer crashes at startup when this is missing; instead `/rtc` returns\n a structured error the UI turns into the remix prompt above.\n\n## API endpoints\n\n- `GET /` — serves the studio (`frontend/studio.html`)\n- `POST /rtc?val=` — create a new WebRTC Realtime session (`val` is\n optional). Returns `{ code: \"openai\" | \"upstream\", ... }` on failure.\n- `POST /observer/:callId` — internal server-side session control (fire-and-forget)\n- `GET /me` — current login state\n- `GET /auth/token` — OAuth token handoff (rarely needed; the studio is\n same-origin)\n- `GET /source` — 302-redirects to this val's page on Val Town (used by the\n remix link, so it's correct even for remixed copies)\n- `GET /api/resolve-val?val=` — resolve a val to its live HTTP URL\n- `GET /api/recent-vals` — the signed-in user's most recent vals\n- `POST /api/create-val` — create a new public val with a minimal HTTP starter\n\n## Project structure\n\n```\n├── main.tsx # Entrypoint: OAuth middleware, route mounting, /me, /source, serves studio\n├── frontend/\n│ └── studio.html # The Voice Edit Studio UI (WebRTC, waveform, sidebar, load/create)\n└── routes/\n ├── agent.ts # Realtime session config: tools + Townie prompt + Studio addendum\n ├── rtc.ts # WebRTC session setup + OpenAI-error classification\n ├── observer.ts # Server-side session control (WebSocket to OpenAI)\n ├── api.ts # /api: resolve-val, recent-vals, create-val\n └── utils.ts # Realtime API URL/header helpers + hasOpenAIKey()\n```\n\nOther files (`routes/sip.ts`, `frontend/index.html`, `frontend/widget.html`,\n`frontend/sdk.js`, `sdk.ts`, `oauth-test.tsx`) are inherited from the\n`hello-realtime` base this was built on and are **not mounted** by `main.tsx`.\n\n## Notes\n\n- **If the AI says it can't edit files**, the Val Town OAuth token has gone\n stale — **log out and back in** from the sidebar to refresh it.\n- **The preview does not auto-refresh** — the AI reloads it after finishing\n edits, or you can hit \"↻ Reload site\".\n",[164],"0f29e68a-5d1f-11f1-bc69-1607ee4eb77e","routes","019e7f4e-f0e9-72ce-b45f-c857c83d866b",["D",1780252340388],"directory",[172],"0f291296-5d1f-11f1-bc69-1607ee4eb77e","frontend","019e7f4e-f0e9-72ce-b45f-ae5bf3b8c0b0",["D",1780252340388],[178],"pulls","branches","forks","envVars",{"_189":191,"_192":139},"connections",{"_189":42,"_190":42},"count","unfilledCount",2,"emptyCount",{"_18":177,"_20":178,"_134":179,"_136":-5,"_137":71,"_138":139,"_140":38,"_22":318,"_68":42,"_142":175,"_144":-5,"_146":26,"_147":-5,"_212":319,"_92":320},{"_18":311,"_20":312,"_134":313,"_136":179,"_137":71,"_138":139,"_140":38,"_22":314,"_68":42,"_142":103,"_144":315,"_146":26,"_147":-5,"_212":316,"_92":317},{"_18":302,"_20":303,"_134":304,"_136":179,"_137":71,"_138":305,"_140":38,"_22":306,"_68":307,"_142":103,"_144":308,"_146":26,"_147":-5,"_212":309,"_92":310},{"_18":295,"_20":296,"_134":297,"_136":179,"_137":71,"_138":139,"_140":38,"_22":298,"_68":42,"_142":143,"_144":299,"_146":26,"_147":-5,"_212":300,"_92":301},{"_18":286,"_20":287,"_134":288,"_136":179,"_137":71,"_138":289,"_140":38,"_22":290,"_68":291,"_142":103,"_144":292,"_146":26,"_147":-5,"_212":293,"_92":294},{"_18":279,"_20":280,"_134":281,"_136":179,"_137":71,"_138":139,"_140":38,"_22":282,"_68":42,"_142":103,"_144":283,"_146":26,"_147":-5,"_212":284,"_92":285},{"_18":171,"_20":172,"_134":173,"_136":-5,"_137":71,"_138":139,"_140":38,"_22":276,"_68":42,"_142":175,"_144":-5,"_146":26,"_147":-5,"_212":277,"_92":278},{"_18":267,"_20":268,"_134":269,"_136":173,"_137":71,"_138":270,"_140":38,"_22":271,"_68":272,"_142":143,"_144":273,"_146":26,"_147":-5,"_212":274,"_92":275},{"_18":260,"_20":261,"_134":262,"_136":173,"_137":71,"_138":139,"_140":38,"_22":263,"_68":42,"_142":143,"_144":264,"_146":26,"_147":-5,"_212":265,"_92":266},{"_18":252,"_20":253,"_134":254,"_136":173,"_137":71,"_138":255,"_140":38,"_22":256,"_68":139,"_142":143,"_144":257,"_146":26,"_147":-5,"_212":258,"_92":259},{"_18":245,"_20":246,"_134":247,"_136":173,"_137":71,"_138":139,"_140":38,"_22":248,"_68":42,"_142":143,"_144":249,"_146":26,"_147":-5,"_212":250,"_92":251},{"_18":238,"_20":239,"_134":240,"_136":173,"_137":71,"_138":69,"_140":38,"_22":241,"_68":191,"_142":143,"_144":242,"_146":26,"_147":-5,"_212":243,"_92":244},{"_18":231,"_20":232,"_134":233,"_136":173,"_137":71,"_138":139,"_140":38,"_22":234,"_68":42,"_142":143,"_144":235,"_146":26,"_147":-5,"_212":236,"_92":237},{"_18":224,"_20":225,"_134":226,"_136":173,"_137":71,"_138":139,"_140":38,"_22":227,"_68":42,"_142":143,"_144":228,"_146":26,"_147":-5,"_212":229,"_92":230},{"_18":163,"_20":164,"_134":165,"_136":-5,"_137":71,"_138":166,"_140":38,"_22":221,"_68":168,"_142":103,"_144":169,"_146":26,"_147":-5,"_212":222,"_92":223},{"_18":156,"_20":157,"_134":36,"_136":-5,"_137":71,"_138":158,"_140":38,"_22":218,"_68":160,"_142":153,"_144":161,"_146":26,"_147":-5,"_212":219,"_92":220},{"_18":149,"_20":150,"_134":151,"_136":-5,"_137":71,"_138":139,"_140":38,"_22":215,"_68":42,"_142":153,"_144":154,"_146":26,"_147":-5,"_212":216,"_92":217},{"_18":132,"_20":133,"_134":135,"_136":-5,"_137":71,"_138":139,"_140":38,"_22":211,"_68":42,"_142":143,"_144":145,"_146":26,"_147":-5,"_212":213,"_92":214},["D",1780252340388],"children",[],[133],["D",1780252340388],[],[150],["D",1780254254718],[],[157],["D",1780255166884],[],[164],"0f29d244-5d1f-11f1-bc69-1607ee4eb77e","utils.ts","019e7f4e-f0e9-72ce-b45f-c71bfdc261f2",["D",1780252340388],"const REALTIME_BASE_URL = \"https://api.openai.com/v1/realtime\";\nconst OPENAI_API_KEY = Deno.env.get(\"OPENAI_API_KEY\");\n\n// Whether an OpenAI key is configured on this deployment. We intentionally do\n// NOT throw at module load when it's missing — a freshly-remixed copy hasn't\n// had its OPENAI_API_KEY set yet, and throwing here would 500 every route\n// (including the studio page itself). Instead /rtc checks this and returns a\n// graceful \"bring your own key\" error the UI can act on.\nexport function hasOpenAIKey(): boolean {\n return !!OPENAI_API_KEY;\n}\n\n// Builds the URL for a Realtime API endpoint.\nexport function makeUrl(callId?: string, action?: string) {\n let url = REALTIME_BASE_URL;\n if (!callId) {\n // start call (POST)\n url += \"/calls\";\n } else if (action) {\n // accept, reject, hangup (POST)\n url += `/calls/${callId}/${action}`;\n } else {\n // observer (web socket)\n url += `?call_id=${callId}`;\n }\n return url;\n}\n\n// Builds the headers for a Realtime API endpoint.\nexport function makeHeaders(contentType?: string) {\n const obj: Record = {\n Authorization: `Bearer ${OPENAI_API_KEY}`,\n };\n if (contentType) obj[\"Content-Type\"] = contentType;\n return obj;\n}\n\n// Debug helper for printing Realtime API errors.\nexport async function getErrorText(resp: Response) {\n const errBody = await resp.text().catch(() => \"\");\n return `${resp.status} ${resp.statusText}: ${errBody}`;\n}",[],[172,225],"0f29beb2-5d1f-11f1-bc69-1607ee4eb77e","sip.ts","019e7f4e-f0e9-72ce-b45f-c12d5e9851b9",["D",1780252340388],"import { Hono } from \"npm:hono\";\nimport { Webhook } from \"npm:svix\";\nimport { makeSession } from \"./agent.ts\";\nimport { getErrorText, makeHeaders, makeUrl } from \"./utils.ts\";\n\nconst sip = new Hono();\n\n// POST /sip : webhook endpoint\nsip.post(\"/\", async (c) => {\n // Verify the webhook.\n const OPENAI_SIGNING_SECRET = Deno.env.get(\"OPENAI_SIGNING_SECRET\");\n if (!OPENAI_SIGNING_SECRET) {\n console.error(\"🔴 webhook secret not configured\");\n return c.text(\"Internal error\", 500);\n }\n const webhook = new Webhook(OPENAI_SIGNING_SECRET);\n const bodyStr = await c.req.text();\n let callId: string | undefined;\n let toNumber: string | undefined;\n try {\n const headers = Object.fromEntries(c.req.raw.headers.entries());\n const payload: any = webhook.verify(bodyStr, headers);\n callId = payload.data.call_id;\n toNumber = getToNumber(payload.data.sip_headers);\n const fromNumber = getFromNumber(payload.data.sip_headers);\n console.log(\"✅ verified webhook:\", callId, fromNumber, toNumber);\n } catch (error) {\n console.error(`🔴 verify failed: ${error}`);\n return c.text(\"Invalid signature\", 401);\n }\n\n // Accept the call. SIP calls come from phone users — there's no logged-in\n // Val Town user, so we don't attach an MCP token. The agent will run with\n // only the built-in `display_text` function tool (and no val.town MCP).\n const model = getModelForNumber(toNumber);\n const url = makeUrl(callId, \"accept\");\n const headers = makeHeaders(\"application/json\");\n const body = JSON.stringify(makeSession(model));\n const opts = { method: \"POST\", headers, body };\n const resp = await fetch(url, opts);\n if (!resp.ok) {\n console.error(`🔴 accept failed: ${await getErrorText(resp)}`);\n return c.text(\"Internal error\", 500);\n }\n console.log(\"✅ call accepted:\", callId);\n\n // Kick off observer in the background (fire-and-forget).\n const selfUrl = new URL(c.req.url);\n fetch(`${selfUrl.origin}/observer/${callId}`, { method: \"POST\" })\n .catch((e) => console.error(\"observer start failed:\", e));\n\n return c.newResponse(null);\n});\n\nconst getToNumber = headers => getNumberFromSipHeader(headers, \"to\");\nconst getFromNumber = headers => getNumberFromSipHeader(headers, \"from\");\n\nfunction getNumberFromSipHeader(headers: any, name: string) {\n const header = getSipHeader(headers, name);\n const match = header?.match(/sip:\\+?(\\d+)@/);\n return match ? `+${match[1]}` : undefined;\n}\n\nfunction getSipHeader(headers: any, name: string) {\n return headers.find((h) => h.name.toLowerCase() === name)?.value;\n}\n\nfunction getModelForNumber(number: string) {\n const map = { \"+14258000074\": \"gpt-realtime-mini\" };\n return map[number];\n}\n\nexport default sip;",[],[172,232],"a4bca580-5d37-11f1-ab82-1607ee4eb77e","rtc.ts","019e7f4e-f0e9-72ce-b45f-bd373311c535",["D",1780262899346],"import { Hono } from \"npm:hono\";\nimport { getOAuthUserData } from \"https://esm.town/v/std/oauth/middleware.ts\";\nimport { makeSession } from \"./agent.ts\";\nimport { getErrorText, hasOpenAIKey, makeHeaders, makeUrl } from \"./utils.ts\";\n\nconst rtc = new Hono();\n\n// POST /rtc?val= : create a new voice-edit-studio call.\n// `val` is optional — if omitted, the AI will start without an initial val\n// and the user can ask it to load one via the load_val tool.\nrtc.post(\"/\", async (c) => {\n let accessToken: string | undefined;\n let username = \"anonymous\";\n const session = await getOAuthUserData(c.req.raw);\n if (session) {\n accessToken = session.accessToken;\n username = session.user.username;\n } else {\n const auth = c.req.header(\"Authorization\") ||\n c.req.header(\"authorization\");\n if (auth && auth.startsWith(\"Bearer \")) {\n accessToken = auth.slice(7).trim();\n }\n }\n if (!accessToken) {\n return c.text(\"Unauthorized — log in first\", 401);\n }\n\n // No OpenAI key on this deployment → the voice agent can't run. Tell the UI\n // so it can prompt the user to remix and add their own key.\n if (!hasOpenAIKey()) {\n console.error(\"🔴 start call blocked: no OPENAI_API_KEY configured\");\n return c.json({\n code: \"openai\",\n status: 0,\n message: \"No OpenAI API key is configured on this val.\",\n }, 503);\n }\n\n const model = c.req.query(\"model\");\n const val = c.req.query(\"val\") || undefined;\n if (\n val && !/^[a-zA-Z][a-zA-Z0-9_-]{0,30}\\/[a-zA-Z][a-zA-Z0-9_-]{0,47}$/.test(val)\n ) {\n return c.text(`Invalid val identifier \"${val}\". Expected handle/name.`, 400);\n }\n\n const trigger = c.req.query(\"trigger\") || \"ui\";\n console.log(\n `🔑 starting studio call for @${username} via ${trigger}${val ? ` → ${val}` : \" (no initial val)\"}`,\n );\n\n const fd = new FormData();\n fd.set(\"sdp\", await c.req.text());\n fd.set(\n \"session\",\n JSON.stringify(await makeSession(model, false, accessToken, val, username)),\n );\n const opts = { method: \"POST\", headers: makeHeaders(), body: fd };\n const resp = await fetch(makeUrl(), opts);\n if (!resp.ok) {\n console.error(`🔴 start call failed: ${await getErrorText(resp)}`);\n const s = resp.status;\n // OpenAI rejected the key, or it's out of credit / quota / rate-limited.\n // 401/403 bad-or-disabled key, 402 billing, 429 rate limit or\n // insufficient_quota. Surface these as a \"bring your own key\" prompt.\n if (s === 401 || s === 402 || s === 403 || s === 429) {\n return c.json({\n code: \"openai\",\n status: s,\n message: \"The OpenAI API key was rejected or is out of quota.\",\n }, 502);\n }\n return c.json(\n { code: \"upstream\", status: s, message: \"Upstream error starting the call.\" },\n 502,\n );\n }\n\n const contentType = resp.headers.get(\"Content-Type\");\n const location = resp.headers.get(\"Location\");\n const callId = location?.split(\"/\").pop();\n console.log(\"✅ call created:\", callId);\n\n // Kick off observer in the background (fire-and-forget).\n const selfUrl = new URL(c.req.url);\n fetch(`${selfUrl.origin}/observer/${callId}`, { method: \"POST\" })\n .catch((e) => console.error(\"observer start failed:\", e));\n\n return c.newResponse(resp.body, {\n headers: {\n \"Content-Type\": contentType,\n \"Location\": location,\n },\n });\n});\n\nexport default rtc;\n",[],[172,239],"0f2998c4-5d1f-11f1-bc69-1607ee4eb77e","observer.ts","019e7f4e-f0e9-72ce-b45f-bb48b1137da5",["D",1780252340388],"import { Hono } from \"npm:hono\";\nimport WebSocket from \"npm:ws\";\nimport { createHandler } from \"./agent.ts\";\nimport { makeHeaders, makeUrl } from \"./utils.ts\";\n\nexport interface ObserverHandler {\n onInit(): void;\n onTool(name: string, args: any): void;\n onMcpCallCompleted(name: string, output: string | null): void;\n onOutputAudioStarted(): void;\n onOutputAudioStopped(): void;\n onOutputAudioCleared(): void;\n}\n\nexport class ObserverClient {\n private ws: WebSocket;\n private closeResolve: () => void;\n private closePromise: Promise;\n private handler: ObserverHandler;\n\n constructor(callId: string) {\n const url = makeUrl(callId);\n this.ws = new WebSocket(url, { headers: makeHeaders() });\n this.ws.on(\"open\", () => this.handleOpen());\n this.ws.on(\"message\", (data) => this.handleMessage(JSON.parse(data)));\n this.ws.on(\"error\", (err) => this.handleError(err));\n this.ws.on(\"close\", (ev) => this.handleClose(ev));\n this.closePromise = new Promise((resolve) =>\n this.closeResolve = resolve\n );\n this.handler = createHandler(this, callId);\n }\n createResponse() {\n this.sendMessage({ type: \"response.create\" });\n }\n async waitForClose() {\n await this.closePromise;\n }\n private sendMessage(message: any) {\n this.ws.send(JSON.stringify(message));\n }\n private handleOpen() {\n console.log(\"✅ websocket connected\");\n this.handler.onInit();\n }\n private async handleMessage(message: any) {\n if (!message.type.endsWith(\".delta\")) { // ignore verbose messages\n console.log(message);\n }\n switch (message.type) {\n case \"response.function_call_arguments.done\":\n this.handler.onTool(message.name, message.arguments);\n break;\n case \"response.output_item.done\":\n if (message.item?.type === \"mcp_call\") {\n this.handler.onMcpCallCompleted(message.item.name, message.item.output);\n }\n break;\n case \"output_audio_buffer.started\":\n this.handler.onOutputAudioStarted();\n break;\n case \"output_audio_buffer.stopped\":\n this.handler.onOutputAudioStopped();\n break;\n case \"output_audio_buffer.cleared\":\n this.handler.onOutputAudioCleared();\n break;\n }\n }\n private handleError(err: Error) {\n console.error(`🔴 websocket failed: ${err.message}`);\n this.closeResolve();\n }\n private handleClose(e: Event) {\n console.log(`websocket closed: ${e}`);\n this.closeResolve();\n }\n}\n\nconst observer = new Hono();\n\n// POST /observer/:callId : self-connect to establish a web socket\nobserver.post(\"/:callId\", async (c) => {\n const callId = c.req.param(\"callId\");\n const client = new ObserverClient(callId);\n await client.waitForClose();\n return c.newResponse(null);\n});\n\nexport default observer;",[],[172,246],"09d43de2-5d25-11f1-802a-1607ee4eb77e","memory.ts","7b05b1b4-5d23-11f1-b008-1607ee4eb77e",49,["D",1780254908509],"import { Hono } from \"npm:hono\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { getOAuthUserData } from \"https://esm.town/v/std/oauth/middleware.ts\";\n\n// Per-user, append-only \"second brain\" for hey-townie.\n//\n// ONE unified ledger of subjects + facts (+ edges between subjects). There is\n// no separate \"profile\" store — \"about me\" is simply the `me` subject. What\n// makes a fact preload into the system prompt every call is a single `pinned`\n// flag: pinned facts are always-loaded; unpinned facts are recalled on demand.\n// Facts are append-only with soft retraction (retracted_at) so we can fix a\n// wrong fact without losing the timeline. Everything is scoped by `owner`\n// (the logged-in Val Town handle).\n//\n// Identity (name / handle / email) is NOT stored here — it comes free from the\n// user's Val Town login and is injected into the prompt by agent.ts.\n\nlet schemaReady = false;\nasync function ensureSchema() {\n if (schemaReady) return;\n const stmts = [\n `CREATE TABLE IF NOT EXISTS subjects (\n owner TEXT NOT NULL,\n id TEXT NOT NULL,\n canonical_name TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n PRIMARY KEY (owner, id)\n )`,\n `CREATE TABLE IF NOT EXISTS facts (\n id TEXT PRIMARY KEY,\n owner TEXT NOT NULL,\n subject_id TEXT NOT NULL,\n assertion_text TEXT NOT NULL,\n source TEXT NOT NULL DEFAULT 'voice-agent',\n confidence REAL DEFAULT 1.0,\n pinned INTEGER NOT NULL DEFAULT 0,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n retracted_at DATETIME,\n retract_reason TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS edges (\n id TEXT PRIMARY KEY,\n owner TEXT NOT NULL,\n source_subject_id TEXT NOT NULL,\n target_subject_id TEXT NOT NULL,\n relation_type TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n retracted_at DATETIME\n )`,\n ];\n for (const sql of stmts) await sqlite.execute(sql);\n // Migration for any older DB that predates the `pinned` column.\n try {\n await sqlite.execute(`ALTER TABLE facts ADD COLUMN pinned INTEGER NOT NULL DEFAULT 0`);\n } catch (_) { /* already present */ }\n schemaReady = true;\n}\n\nconst uuid = () => crypto.randomUUID();\nconst kebab = (s: string) =>\n String(s || \"\").trim().toLowerCase()\n .replace(/[^a-z0-9]+/g, \"-\").replace(/^-+|-+$/g, \"\").slice(0, 64) ||\n \"untitled\";\n\n// ---------- Data helpers (getPinnedFacts is also used by agent.ts) ----------\n\n// The always-loaded layer: every pinned, unretracted fact, newest-relevant\n// last, with its subject name for context.\nexport async function getPinnedFacts(owner: string) {\n if (!owner || owner === \"anonymous\") return [];\n await ensureSchema();\n const r = await sqlite.execute({\n sql: `SELECT f.id, f.assertion_text AS text, f.created_at,\n f.subject_id, s.canonical_name\n FROM facts f\n JOIN subjects s ON s.owner = f.owner AND s.id = f.subject_id\n WHERE f.owner = ? AND f.pinned = 1 AND f.retracted_at IS NULL\n ORDER BY f.created_at ASC`,\n args: [owner],\n });\n return r.rows as any[];\n}\n\nasync function ensureSubject(owner: string, subjectId: string, canonicalName?: string) {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO subjects (owner, id, canonical_name) VALUES (?, ?, ?)`,\n args: [owner, subjectId, canonicalName || (subjectId === \"me\" ? \"About me\" : subjectId)],\n });\n}\n\nasync function recordFact(\n owner: string,\n subjectId: string,\n assertion: string,\n source = \"voice-agent\",\n canonicalName?: string,\n pinned = false,\n) {\n await ensureSchema();\n const sid = kebab(subjectId);\n await ensureSubject(owner, sid, canonicalName);\n const id = uuid();\n await sqlite.execute({\n sql: `INSERT INTO facts (id, owner, subject_id, assertion_text, source, pinned)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [id, owner, sid, assertion, source, pinned ? 1 : 0],\n });\n return { fact_id: id, subject_id: sid, pinned: !!pinned };\n}\n\nasync function setPinned(owner: string, factId: string, pinned: boolean) {\n await ensureSchema();\n const r = await sqlite.execute({\n sql: `UPDATE facts SET pinned = ? WHERE owner = ? AND id = ?`,\n args: [pinned ? 1 : 0, owner, factId],\n });\n return { ok: (r.rowsAffected ?? 0) > 0, pinned: !!pinned };\n}\n\nasync function getSubjectHistory(owner: string, subjectId: string, limit = 20) {\n await ensureSchema();\n const sid = kebab(subjectId);\n const subj = await sqlite.execute({\n sql: `SELECT id, canonical_name FROM subjects WHERE owner = ? AND id = ?`,\n args: [owner, sid],\n });\n const facts = await sqlite.execute({\n sql: `SELECT id, assertion_text, source, confidence, pinned, created_at,\n retracted_at, retract_reason\n FROM facts WHERE owner = ? AND subject_id = ?\n ORDER BY created_at DESC LIMIT ?`,\n args: [owner, sid, Math.max(1, Math.min(200, limit))],\n });\n return {\n subject_id: sid,\n canonical_name: (subj.rows[0] as any)?.canonical_name || sid,\n found: subj.rows.length > 0,\n facts: (facts.rows as any[]).map((f) => ({\n ...f, retracted: !!f.retracted_at, pinned: !!f.pinned,\n })),\n };\n}\n\nasync function getRecent(owner: string, hoursBack = 24) {\n await ensureSchema();\n const r = await sqlite.execute({\n sql: `SELECT f.subject_id, s.canonical_name, f.assertion_text, f.pinned, f.created_at\n FROM facts f\n JOIN subjects s ON s.owner = f.owner AND s.id = f.subject_id\n WHERE f.owner = ? AND f.retracted_at IS NULL\n AND f.created_at >= datetime('now', ?)\n ORDER BY f.created_at DESC LIMIT 60`,\n args: [owner, `-${Math.max(1, Math.min(8760, hoursBack))} hours`],\n });\n return r.rows as any[];\n}\n\nasync function getCurrentState(owner: string) {\n await ensureSchema();\n const r = await sqlite.execute({\n sql: `SELECT s.id AS subject_id, s.canonical_name,\n (SELECT f.assertion_text FROM facts f\n WHERE f.owner = s.owner AND f.subject_id = s.id AND f.retracted_at IS NULL\n ORDER BY f.created_at DESC LIMIT 1) AS latest_fact,\n (SELECT f.created_at FROM facts f\n WHERE f.owner = s.owner AND f.subject_id = s.id AND f.retracted_at IS NULL\n ORDER BY f.created_at DESC LIMIT 1) AS latest_at,\n (SELECT COUNT(*) FROM facts f\n WHERE f.owner = s.owner AND f.subject_id = s.id AND f.retracted_at IS NULL) AS fact_count,\n (SELECT COUNT(*) FROM facts f\n WHERE f.owner = s.owner AND f.subject_id = s.id AND f.retracted_at IS NULL AND f.pinned = 1) AS pinned_count\n FROM subjects s WHERE s.owner = ?\n ORDER BY latest_at DESC NULLS LAST`,\n args: [owner],\n });\n return r.rows as any[];\n}\n\nasync function getGraph(owner: string) {\n await ensureSchema();\n const subjects = await sqlite.execute({\n sql: `SELECT s.id, s.canonical_name,\n (SELECT COUNT(*) FROM facts f\n WHERE f.owner = s.owner AND f.subject_id = s.id AND f.retracted_at IS NULL) AS fact_count\n FROM subjects s WHERE s.owner = ?`,\n args: [owner],\n });\n const edges = await sqlite.execute({\n sql: `SELECT id, source_subject_id, target_subject_id, relation_type\n FROM edges WHERE owner = ? AND retracted_at IS NULL`,\n args: [owner],\n });\n return {\n nodes: (subjects.rows as any[]).map((s) => ({\n id: s.id, name: s.canonical_name, facts: Number(s.fact_count) || 0,\n })),\n links: (edges.rows as any[]).map((e) => ({\n source: e.source_subject_id, target: e.target_subject_id, relation: e.relation_type,\n })),\n };\n}\n\nasync function linkSubjects(owner: string, src: string, tgt: string, relation: string) {\n await ensureSchema();\n const s = kebab(src), t = kebab(tgt);\n await ensureSubject(owner, s);\n await ensureSubject(owner, t);\n const id = uuid();\n await sqlite.execute({\n sql: `INSERT INTO edges (id, owner, source_subject_id, target_subject_id, relation_type)\n VALUES (?, ?, ?, ?, ?)`,\n args: [id, owner, s, t, relation || \"relates-to\"],\n });\n return { edge_id: id, source: s, target: t };\n}\n\nasync function retractFact(owner: string, factId: string, reason: string) {\n await ensureSchema();\n const r = await sqlite.execute({\n sql: `UPDATE facts SET retracted_at = CURRENT_TIMESTAMP, retract_reason = ?\n WHERE owner = ? AND id = ? AND retracted_at IS NULL`,\n args: [reason || \"retracted\", owner, factId],\n });\n return { retracted: (r.rowsAffected ?? 0) > 0 };\n}\n\n// ---------- HTTP API (mounted at /api/memory) ----------\n\nconst app = new Hono();\n\nasync function owner(c: any): Promise {\n const s = await getOAuthUserData(c.req.raw);\n return s?.user?.username || null;\n}\nconst need = (c: any) => c.json({ error: \"Unauthorized — log in first\" }, 401);\n\n// The always-loaded set (pinned facts).\napp.get(\"/pinned\", async (c) => {\n const o = await owner(c);\n if (!o) return need(c);\n return c.json({ pinned: await getPinnedFacts(o) });\n});\n\n// Record a fact. Pass pin:true to make it always-load into the prompt.\napp.post(\"/fact\", async (c) => {\n const o = await owner(c);\n if (!o) return need(c);\n const body = await c.req.json().catch(() => ({}));\n const subject = String(body.subject_id || \"\").trim();\n const assertion = String(body.assertion_text || \"\").trim();\n if (!subject || !assertion) {\n return c.json({ error: \"subject_id and assertion_text are required\" }, 400);\n }\n const res = await recordFact(\n o, subject, assertion, body.source || \"voice-agent\", body.canonical_name, !!body.pin,\n );\n return c.json({ ok: true, ...res });\n});\n\n// Pin / unpin an existing fact (toggle whether it always-loads).\napp.post(\"/fact/:id/pin\", async (c) => {\n const o = await owner(c);\n if (!o) return need(c);\n const body = await c.req.json().catch(() => ({}));\n const pinned = body.pinned === undefined ? true : !!body.pinned;\n return c.json({ ok: true, ...(await setPinned(o, c.req.param(\"id\"), pinned)) });\n});\n\napp.post(\"/fact/:id/retract\", async (c) => {\n const o = await owner(c);\n if (!o) return need(c);\n const body = await c.req.json().catch(() => ({}));\n return c.json({ ok: true, ...(await retractFact(o, c.req.param(\"id\"), body.reason)) });\n});\n\napp.get(\"/subject/:id\", async (c) => {\n const o = await owner(c);\n if (!o) return need(c);\n const limit = parseInt(c.req.query(\"limit\") || \"20\", 10) || 20;\n return c.json(await getSubjectHistory(o, c.req.param(\"id\"), limit));\n});\n\napp.get(\"/recent\", async (c) => {\n const o = await owner(c);\n if (!o) return need(c);\n const hours = parseInt(c.req.query(\"hours\") || \"24\", 10) || 24;\n return c.json({ facts: await getRecent(o, hours) });\n});\n\napp.post(\"/edge\", async (c) => {\n const o = await owner(c);\n if (!o) return need(c);\n const body = await c.req.json().catch(() => ({}));\n const src = String(body.source_subject_id || body.source || \"\").trim();\n const tgt = String(body.target_subject_id || body.target || \"\").trim();\n if (!src || !tgt) return c.json({ error: \"source and target required\" }, 400);\n return c.json({\n ok: true,\n ...(await linkSubjects(o, src, tgt, body.relation_type || body.relation)),\n });\n});\n\napp.get(\"/state\", async (c) => {\n const o = await owner(c);\n if (!o) return need(c);\n return c.json({ owner: o, subjects: await getCurrentState(o) });\n});\n\napp.get(\"/graph\", async (c) => {\n const o = await owner(c);\n if (!o) return need(c);\n return c.json(await getGraph(o));\n});\n\n// Human ingestion from the dashboard form.\napp.post(\"/manual\", async (c) => {\n const o = await owner(c);\n if (!o) return need(c);\n const body = await c.req.json().catch(() => ({}));\n const subject = String(body.subject_id || \"\").trim();\n const assertion = String(body.assertion_text || \"\").trim();\n if (!subject || !assertion) {\n return c.json({ error: \"subject_id and assertion_text are required\" }, 400);\n }\n const res = await recordFact(o, subject, assertion, \"human-ui\", body.canonical_name, !!body.pin);\n return c.json({ ok: true, ...res });\n});\n\nexport default app;\n",[],[172,253],"0f2960d4-5d1f-11f1-bc69-1607ee4eb77e","api.ts","019e7f4e-f0e9-72ce-b45f-b7029cc2721b",["D",1780252340388],"import { Hono } from \"npm:hono\";\nimport { getOAuthUserData } from \"https://esm.town/v/std/oauth/middleware.ts\";\n\nconst api = new Hono();\nconst VT = \"https://api.val.town\";\n\nasync function getAccessToken(c: any): Promise {\n const session = await getOAuthUserData(c.req.raw);\n if (session) return session.accessToken;\n const auth = c.req.header(\"Authorization\") ||\n c.req.header(\"authorization\");\n if (auth && auth.startsWith(\"Bearer \")) return auth.slice(7).trim();\n return null;\n}\n\nfunction parseValId(valId: string): { handle: string; name: string } | null {\n const m = valId.match(\n /^([a-zA-Z][a-zA-Z0-9_-]{0,30})\\/([a-zA-Z][a-zA-Z0-9_-]{0,47})$/,\n );\n if (!m) return null;\n return { handle: m[1], name: m[2] };\n}\n\nasync function vt(token: string, path: string): Promise {\n return await fetch(`${VT}${path}`, {\n headers: { Authorization: `Bearer ${token}` },\n });\n}\nasync function vtJson(token: string, path: string): Promise {\n const resp = await vt(token, path);\n if (!resp.ok) {\n const body = (await resp.text()).slice(0, 200);\n throw new Error(`${path} → ${resp.status}: ${body}`);\n }\n return await resp.json();\n}\n\nasync function resolveVal(\n valId: string,\n token: string,\n): Promise<{ id: string; url: string; branchId: string | null }> {\n const parsed = parseValId(valId);\n if (!parsed) {\n throw new Error(`Invalid val identifier \"${valId}\". Expected handle/name.`);\n }\n\n // Alias lookup. /v2/alias/vals/{username}/{val_name} returns val metadata.\n const val = await vtJson(\n token,\n `/v2/alias/vals/${parsed.handle}/${parsed.name}`,\n ).catch((e) => {\n throw new Error(`Val not found: ${valId}. ${e.message?.slice(0, 120) || \"\"}`);\n });\n\n // List root files. path/recursive/offset/limit are all required by the spec.\n const filesData = await vtJson(\n token,\n `/v2/vals/${val.id}/files?path=&recursive=true&offset=0&limit=100`,\n );\n const files = filesData.data || [];\n const httpFiles = files.filter((f: any) => f.type === \"http\");\n // Prefer a canonical entry point (main.* / index.*) at the root; fall back\n // to the first HTTP file overall.\n const isEntry = (name: string) =>\n /^(main|index)\\.(tsx?|jsx?)$/i.test(name);\n const httpFile = httpFiles.find((f: any) =>\n isEntry(f.name) && (f.path === f.name || !f.path?.includes(\"/\"))\n ) || httpFiles[0];\n if (!httpFile) {\n throw new Error(\n `Val ${valId} has no HTTP file to serve. Create one with fileType: \"http\" — e.g. a Hono app exporting app.fetch.`,\n );\n }\n const endpoint = httpFile.links?.endpoint;\n if (!endpoint) {\n throw new Error(\n `HTTP file in ${valId} has no endpoint URL yet — it may still be deploying.`,\n );\n }\n\n // Find the main branch id for version polling.\n let branchId: string | null = null;\n try {\n const branchesData = await vtJson(\n token,\n `/v2/vals/${val.id}/branches?offset=0&limit=100`,\n );\n const branches = branchesData.data || [];\n const main = branches.find((b: any) => b.name === \"main\") || branches[0];\n branchId = main?.id || null;\n } catch (e) {\n console.warn(`[resolve-val] branch list failed:`, e);\n }\n\n return { id: val.id, url: endpoint, branchId };\n}\n\napi.get(\"/resolve-val\", async (c) => {\n const token = await getAccessToken(c);\n if (!token) return c.json({ error: \"Unauthorized\" }, 401);\n const valId = c.req.query(\"val\");\n if (!valId) return c.json({ error: \"Missing val\" }, 400);\n try {\n const info = await resolveVal(valId, token);\n return c.json(info);\n } catch (e) {\n return c.json({ error: (e as Error).message }, 400);\n }\n});\n\napi.get(\"/wait-for-val-update\", async (c) => {\n const token = await getAccessToken(c);\n if (!token) return c.json({ error: \"Unauthorized\" }, 401);\n const valId = c.req.query(\"valId\");\n const branchId = c.req.query(\"branchId\");\n const since = parseInt(c.req.query(\"since\") || \"0\", 10) || 0;\n if (!valId || !branchId) {\n return c.json({ error: \"Missing valId or branchId\" }, 400);\n }\n\n // ===== TEMP BLEED FIX — incident 2026-05-23 (val.town /auth + branches API overload) =====\n // The branch-version probe below is commented out so this route no longer\n // calls api.val.town at all. The loop still idles for 45s and returns\n // TIMEOUT, so already-open (\"zombie\") studio tabs keep polling at a harmless\n // ~1 req / 45s instead of generating ~30 val.town API calls per cycle.\n // Because it never returns \"UPDATED\", the studio iframe also stops auto-\n // reloading, which halts the /auth/signin redirect storm from the private\n // val loaded cross-origin in the iframe.\n // TO REVERT: uncomment the try/catch block below.\n const deadline = Date.now() + 45000;\n let lastSeen = since;\n while (Date.now() < deadline) {\n // try {\n // const branch = await vtJson(\n // token,\n // `/v2/vals/${valId}/branches/${branchId}`,\n // );\n // const v = Number(branch.version) || 0;\n // if (lastSeen > 0 && v > lastSeen) {\n // return c.json({ version: v, status: \"UPDATED\" });\n // }\n // if (lastSeen === 0) lastSeen = v;\n // } catch (e) {\n // return c.json({ error: (e as Error).message }, 500);\n // }\n await new Promise((r) => setTimeout(r, 1500));\n }\n return c.json({ version: lastSeen, status: \"TIMEOUT\" });\n});\n\n// List the user's most recently-updated vals, for the sidebar quick-load list.\napi.get(\"/recent-vals\", async (c) => {\n const token = await getAccessToken(c);\n if (!token) return c.json({ error: \"Unauthorized\" }, 401);\n try {\n // /v2/me/vals returns the authenticated user's vals, most-recent first.\n const listing = await vtJson(token, `/v2/me/vals?limit=10&offset=0`);\n const raw = listing.data || listing.vals || [];\n const vals = raw.map((v: any) => ({\n identifier: `${v.author?.username}/${v.name}`,\n name: v.name,\n privacy: v.privacy,\n }));\n return c.json({ vals });\n } catch (e) {\n console.error(\"[recent-vals]\", (e as Error).message);\n return c.json({ error: (e as Error).message }, 500);\n }\n});\n\n// Minimal starter page for a freshly-created val. A self-contained Hono HTTP\n// app so the studio can display it immediately — the newcomer sees a friendly\n// live page they can then iterate on by voice.\nconst STARTER_HTTP = `import { Hono } from \"npm:hono\";\n\nconst app = new Hono();\n\napp.get(\"/\", (c) =>\n c.html(\\`\n\n \n \n \n My new val\n \n \n \n

live · just created

Your new val is running 🎉

This page is yours. Tell the assistant what you'd like to build:

\"make this my personal homepage\" · \"build a tip calculator\" · \"add a countdown to the new year\"

\n \n\\`));\n\napp.onError((err) => Promise.reject(err));\n\nexport default app.fetch;\n`;\n\n// Create a brand-new val with a minimal HTTP page, so the studio (or a total\n// newcomer who clicks \"Create a new val\") gets an instantly-loadable canvas.\n// We create the val PUBLIC on purpose: (1) private/unlisted require a pro/\n// business org, so public is the only privacy that works for brand-new\n// free-tier signups, and (2) it sidesteps the cross-origin auth-redirect storm\n// that private vals cause when loaded in the studio iframe (incident\n// 2026-05-23). The user can flip privacy later from Val Town.\napi.post(\"/create-val\", async (c) => {\n const token = await getAccessToken(c);\n if (!token) return c.json({ error: \"Unauthorized\" }, 401);\n\n let desiredName = \"\";\n try {\n const body = await c.req.json().catch(() => ({}));\n desiredName = String(body?.name || \"\").trim();\n } catch { /* no body is fine */ }\n\n // Coerce whatever the user typed into a valid val name: must start with a\n // letter, then letters/digits/-/_ only.\n function sanitize(n: string): string {\n let s = n.toLowerCase()\n .replace(/[^a-z0-9\\-_]+/g, \"-\")\n .replace(/^[^a-z]+/, \"\")\n .replace(/-+/g, \"-\")\n .replace(/^-|-$/g, \"\");\n return s.slice(0, 40);\n }\n const base = sanitize(desiredName) || \"my-app\";\n\n // Create the val, retrying with a short random suffix if the name is taken.\n let val: any = null;\n let lastErr = \"\";\n for (let attempt = 0; attempt < 5; attempt++) {\n const name = attempt === 0\n ? base\n : `${base}-${Math.random().toString(36).slice(2, 6)}`;\n const resp = await fetch(`${VT}/v2/vals`, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ name, privacy: \"public\" }),\n });\n if (resp.ok) {\n val = await resp.json();\n break;\n }\n if (resp.status === 409) {\n lastErr = `name \"${name}\" already taken`;\n continue;\n }\n lastErr = (await resp.text()).slice(0, 200);\n break;\n }\n if (!val) return c.json({ error: `Couldn't create val: ${lastErr}` }, 400);\n\n // Add the minimal HTTP file so the studio can serve a page.\n const fileResp = await fetch(\n `${VT}/v2/vals/${val.id}/files?path=${encodeURIComponent(\"main.tsx\")}`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ type: \"http\", content: STARTER_HTTP }),\n },\n );\n const username = val.author?.username;\n const identifier = `${username}/${val.name}`;\n if (!fileResp.ok) {\n const t = (await fileResp.text()).slice(0, 200);\n return c.json(\n { error: `Created ${identifier} but couldn't add a page: ${t}`, identifier },\n 400,\n );\n }\n const file = await fileResp.json();\n return c.json({\n identifier,\n name: val.name,\n url: file?.links?.endpoint || null,\n });\n});\n\nexport default api;\n",[],[172,261],"2b8ed0be-5d25-11f1-bc7b-1607ee4eb77e","agent.ts","019e7f4e-f0e9-72ce-b45f-b285ed040749",54,["D",1780254965068],12,"import { ObserverClient, ObserverHandler } from \"./observer.ts\";\nimport { getErrorText, makeHeaders, makeUrl } from \"./utils.ts\";\nimport { getPinnedFacts } from \"./memory.ts\";\n\nconst MODEL = \"gpt-realtime-2\";\nconst TRANSCRIBE_MODEL = \"gpt-4o-transcribe\";\nconst NR_TYPE = \"near_field\";\nconst VOICE = \"marin\";\n\n// Load the official Val Town \"Townie\" system prompt at module init, exactly\n// like stevekrouse/hello-realtime-townie does. This is the battle-tested\n// prompt that makes the model genuinely competent at reading/creating/editing\n// vals via the val_town_mcp tools. We append a Studio-specific addendum below\n// (iframe workspace + load_val/navigate_page/slide tools). Wrapped in a\n// try/catch so a transient fetch failure can't take the whole val down.\nlet towniePrompt = \"\";\ntry {\n towniePrompt =\n await (await fetch(\"https://www.val.town/townie/system-prompt\")).text();\n} catch (e) {\n console.error(\"⚠️ failed to fetch townie system prompt:\", e);\n}\n\n// Studio-specific instructions, layered on top of the Townie prompt. Everything\n// the Townie prompt says about editing vals (file types, HTTP handlers, sqlite,\n// blob, conventions, the val_town_mcp tools) still applies — this just adds the\n// workspace controls unique to this deployment and tunes the voice style.\nfunction studioAddendum(initialVal?: string, username?: string): string {\n return `\n\n---\n\n# Voice Edit Studio (this deployment)\n\nYou are running inside **Studio**, a voice-controlled workspace. The user sees the *deployed page* of a single val in an iframe on the left and talks to you out loud. Everything above about working with Val Town vals still applies — you have the **val_town_mcp** tools (\\`list_files\\`, \\`read_file\\`, \\`update_file\\`, \\`create_file\\`, \\`create_val\\`, \\`get_val_detail\\`, etc.). Always pass the val identifier as the \\`val\\` argument. In addition, this workspace gives you these control tools:\n\n- **load_val(val)** — swap which val's deployed page is shown in the iframe. Pass a \"handle/name\" identifier. Use for \"open my X\", \"show Y\", \"switch to Z\".\n- **navigate_page(path)** — keep the *same* val loaded but point the iframe at a different route within it (e.g. \\`/forklift\\` or \\`/\\`). A bare slug (\"forklift\") is accepted. Use for \"go to the X page\", \"next/previous example\", \"back to the home/gallery\". This is NOT for switching vals — use \\`load_val\\` for that.\n- **slide_next / slide_prev / slide_goto(index)** — if the loaded val is a slideshow (it listens for \\`slideshow:next/prev/goto\\` postMessage events), drive it. Safe no-op on vals that don't listen.\n- **reload_site** — reload the iframe to show your latest edits. The preview does not auto-refresh.\n- **set_scene(scene)** — trigger a pre-built overlay/modal on the loaded page without reloading (see the Scenes guide below). \\`set_scene(\"\")\\` closes it.\n\n## Choreography & scenes\n\nSome vals ship a **\\`CHOREOGRAPHY.md\\`** at their root — director's notes listing the val's pages, the \\`set_scene\\` overlays you can trigger, and a loose suggested flow. **When you load a val, read its CHOREOGRAPHY.md once** (e.g. \\`read_file(\"dcm31/design-gallery\", \"CHOREOGRAPHY.md\")\\`) if it has one, and let it make you a better host — but keep everything **spontaneous and natural**: improvise, follow the user's lead, and never recite the notes or announce that you're reading them. Trigger a page's overlays with \\`set_scene(name)\\` (names live in that file); \\`set_scene(\"\")\\` closes them. \\`dcm31/design-gallery\\` is the main showcase and has a full CHOREOGRAPHY.md.\n\n## Studio rules\n- ${\n username\n ? `The user's Val Town handle is **${username}**. When they say \"open foo\" without an owner, default to \\`load_val(\"${username}/foo\")\\`. If they say \"Steve's val foo\", use \\`load_val(\"stevekrouse/foo\")\\`.`\n : `When the user names a val without an owner, assume it's theirs.`\n }\n- The studio can only display vals that have an **HTTP file**. When creating a new val to show, call \\`create_val\\` with \\`initialFile.fileType: \"http\"\\` (a minimal Hono app exporting \\`app.fetch\\`), then \\`load_val\\` it. Don't pass a \\`description\\` of 64+ chars (the validator rejects it). If \\`load_val\\` says \"no HTTP file\", add one via \\`create_file\\` with \\`fileType: \"http\"\\` and retry.\n- The preview does **not** auto-refresh. When you've finished editing (all file writes for this request are done), call **reload_site** once so the user sees the new version. Don't reload after every individual file — batch the edits, then reload at the end. The user can also hit the \"Reload site\" button themselves.\n- **Be terse — this is voice, and the user can see the page.** Confirm in one short sentence (\"Updated main.tsx — added the button.\" / \"Created and loaded ${\n username || \"your-handle\"\n }/foo.\"). Don't read code aloud unless asked. Before a non-trivial change, say in one line what you'll do.\n- Treat the user as the val's owner.\n- ${\n initialVal\n ? `The val currently loaded in the studio is: **${initialVal}**.`\n : `No val is loaded yet. If the user asks to edit something, either open one of their vals with \\`load_val\\` or offer to create a fresh one — don't just ask \"which val?\" and stop.`\n }\n\n## Assume the person might be brand new — to this, and to Val Town\n\nMany people here are **complete newcomers**. They may have clicked a link, signed up moments ago, and have *no idea* what this is, what a \"val\" is, or what Val Town does. Some have never written a line of code. **Never assume prior knowledge.** Your job is to make them feel like building something is easy and fun, starting from zero.\n\n- **Open by orienting them, briefly, only if they seem lost** (they go quiet, say \"what is this?\", \"how does this work?\", \"I don't know what to do\"). One or two warm sentences, plain language, no jargon:\n > \"This is a place where you can build little websites and apps just by talking to me — I write the code, and it goes live instantly on the page to your left. Want to make something? Tell me an idea, even a rough one, and I'll start.\"\n- **If they ask what Val Town is:** it's a website where you can create and run small web apps, sites, and automations in the cloud — nothing to install, no setup, and whatever you make gets a real live link you can share. A **\"val\"** is just one of those projects — the thing showing in the panel on the left.\n- **Offer a concrete first step instead of an open-ended question.** Newcomers freeze on \"what do you want to build?\" Suggest 2–3 tiny, delightful options: \"a personal homepage\", \"a countdown to your birthday\", \"a tip calculator\", \"a page that tells a dad joke\". Then **just build it** — \\`create_val\\` (with \\`initialFile.fileType: \"http\"\\`), \\`load_val\\` it, and show them.\n- **Translate, don't lecture.** Avoid \"deploy\", \"endpoint\", \"HTTP handler\", \"Deno\", \"repo\", \"commit\". Say \"it's live\", \"your page\", \"the link\", \"the code\". Only go technical if *they* do.\n- **Narrate lightly so the magic is visible.** \"Okay — making you a page now… done, take a look on the left. Want it a different color?\" Keep it to a sentence; they can see the result.\n- **Never make them feel behind.** No \"as you probably know\", no assuming they understand a term. Celebrate small wins.\n- They don't need to type anything or learn commands — talking is enough. (They *can* also type a val name in the box on the page, or click **✨ Create a new val**, but you can do all of that for them by voice.)\n\n## Face-triggered sessions (this deployment)\n\nThis studio watches the user's webcam with on-device face detection. **This session was started automatically the moment their face was detected close and confident enough** — they did not click anything. So:\n\n- **You speak first.** Open with a short, warm, spontaneous greeting${\n username\n ? `, by name — the person is **${username}** (use just their first name, e.g. \"Hey ${\n username.split(/[^A-Za-z]/)[0] || username\n }!\").`\n : ` (a friendly hello; you don't know their name yet).`\n } One sentence, then invite them to build something. Don't explain that a camera or face detection started the call unless they ask.\n- **Ending the call:** when the user says goodbye / bye / see you / talk later / \"I'm done\", give a brief one-line sign-off and then call **end_call**. Keep the session open otherwise — they'll end it by voice or with the on-screen button.\n- **Tuning the trigger:** if they say things like \"you're too sensitive\", \"wait until I'm closer\", \"trigger from farther away\", \"be more eager to greet me\", call **set_face_tuning** (relative nudges or absolute values). Confirm in a few words.\n\n## Long-term memory (per user) — one ledger, use it sparingly\n\nThere is ONE memory: **subjects** (projects, objects, topics — and **'me'** for the user themselves) each holding append-only **facts**. A fact is either:\n- **Pinned** → it auto-loads into your prompt every call (see \"Always-loaded memory\" above if any exist). This is the \"never start from scratch\" layer.\n- **Unpinned** → recalled on demand.\n\nYou already know the user's **name, handle, and email from their login** (see \"Who you're talking to\") — never store those.\n\nTools: **remember_about_me(text)** (shortcut: a pinned fact under 'me' — for lasting personal preferences); **record_fact(subject_id, assertion_text, pin?)** (pin=true only for \"always remember…\" type requests); **recall_subject(subject_id)** / **recall_recent()** to read; **link_subjects(...)** to relate subjects in the mindmap; **retract_fact(fact_id, reason)** to fix a mistake.\n\n**Be conservative — this is the user's brain, not a scratchpad:**\n- **Only WRITE when asked** (\"remember that…\", \"note this\", \"always keep in mind…\", \"connect X to Y\"). Never record facts reflexively. Confirm in a few words when you do (\"Got it — pinned that.\").\n- **Decide pin vs not by their words:** \"always remember / from now on / keep in mind\" → pin=true; a plain \"remember that X about Y\" → unpinned under subject Y.\n- **Reading is cheap:** pinned facts load automatically; call recall_subject / recall_recent when relevant or asked. Don't dump memory unprompted.\n- They can see, pin/unpin, and edit everything (including the mindmap) on the **Memory** page (🧠 in the menu).`;\n}\n\nfunction buildSystemPrompt(initialVal?: string, username?: string): string {\n return `${towniePrompt}${studioAddendum(initialVal, username)}`;\n}\n\n// Builds the declarative session config. accessToken is required to give the\n// AI val.town MCP access; initialVal seeds the system prompt. Video is never\n// streamed in this deployment (the _video param is accepted but ignored).\nexport async function makeSession(\n modelOverride?: string,\n _video?: boolean,\n accessToken?: string,\n initialVal?: string,\n username?: string,\n) {\n const model = modelOverride || MODEL;\n\n // Identity comes free from the Val Town login — inject name/handle/email so\n // the agent already knows who it's talking to and never has to ask or store\n // it. (Best-effort; falls back to just the handle.)\n let identitySection = \"\";\n if (username && username !== \"anonymous\") {\n let display = `@${username}`;\n let email = \"\";\n if (accessToken) {\n try {\n const r = await fetch(\"https://api.val.town/v2/me\", {\n headers: { Authorization: `Bearer ${accessToken}` },\n });\n if (r.ok) {\n const u = await r.json();\n if (u.username) display = (u.name ? `${u.name} ` : \"\") + `@${u.username}`;\n if (u.email) email = u.email;\n }\n } catch (_) { /* fall back to handle */ }\n }\n identitySection = `\\n\\n## Who you're talking to\\n` +\n `You are speaking with ${display}${email ? ` (email: ${email})` : \"\"}. ` +\n `You know this from their Val Town login — don't ask for or store their name, handle, or email.`;\n }\n\n // Pinned facts auto-load into the prompt every call (the always-loaded layer),\n // so the agent never starts from scratch with a returning user.\n let memorySection = \"\";\n if (username && username !== \"anonymous\") {\n try {\n const pinned = await getPinnedFacts(username);\n if (pinned.length) {\n memorySection = `\\n\\n## Always-loaded memory (pinned)\\n` +\n `Durable facts ${username} pinned for you to always keep in mind (oldest first). Weave them in naturally — do NOT recite them as a list or announce that you \"remember\" unless relevant.\\n` +\n pinned\n .map((p) =>\n `- ${p.text} _(${p.canonical_name}, since ${String(p.created_at).slice(0, 10)})_`\n )\n .join(\"\\n\");\n }\n } catch (e) {\n console.error(\"⚠️ failed to load pinned facts:\", e);\n }\n }\n\n const tools: any[] = [\n {\n type: \"function\",\n name: \"load_val\",\n description:\n \"Switch which val is loaded in the studio's iframe workspace. Pass a val identifier like 'handle/name'. The studio resolves it to the deployed URL and swaps the iframe. Use whenever the user says 'open X', 'show Y', 'switch to Z'.\",\n parameters: {\n type: \"object\",\n properties: {\n val: {\n type: \"string\",\n description: \"Val identifier in handle/name form, e.g. 'dcm31/voice-edit-demo'.\",\n },\n },\n required: [\"val\"],\n },\n },\n {\n type: \"function\",\n name: \"slide_next\",\n description:\n \"If the loaded val is a slideshow that supports postMessage navigation, advance to the next slide. The studio sends a 'slideshow:next' message to the iframe. Safe to call even if the iframe doesn't listen — it's a no-op.\",\n parameters: { type: \"object\", properties: {} },\n },\n {\n type: \"function\",\n name: \"slide_prev\",\n description:\n \"Go back one slide in the loaded slideshow.\",\n parameters: { type: \"object\", properties: {} },\n },\n {\n type: \"function\",\n name: \"slide_goto\",\n description:\n \"Jump to a specific slide by zero-based index in the loaded slideshow.\",\n parameters: {\n type: \"object\",\n properties: {\n index: {\n type: \"integer\",\n description: \"Zero-based slide index. 0 = first slide.\",\n },\n },\n required: [\"index\"],\n },\n },\n {\n type: \"function\",\n name: \"navigate_page\",\n description:\n \"Navigate WITHIN the currently loaded val to a different page/route — keeps the same val loaded but points the iframe at a new path. Pass a path like '/forklift' or '/'. A bare slug like 'forklift' is also accepted. Use for 'go to the X page', 'next/previous example', 'back to the gallery', 'open /foo'. This is NOT for switching to a different val — use load_val for that.\",\n parameters: {\n type: \"object\",\n properties: {\n path: {\n type: \"string\",\n description:\n \"Path within the currently loaded val, e.g. '/tidewater' or '/'. A bare slug ('tidewater') is normalized to '/tidewater'.\",\n },\n },\n required: [\"path\"],\n },\n },\n {\n type: \"function\",\n name: \"reload_site\",\n description:\n \"Reload the page currently shown in the studio iframe (cache-busted) so the user sees your latest edits. The preview does NOT auto-refresh, so this is how saved changes become visible. Batch all your file edits first, then call reload_site ONCE at the end.\",\n parameters: { type: \"object\", properties: {} },\n },\n {\n type: \"function\",\n name: \"set_scene\",\n description:\n \"Trigger a pre-built 'scene' on the page currently loaded in the studio — an overlay/modal/state change that appears ON TOP of the current page without reloading or losing context. Pass a scene name from that page's scene list (see the Scenes guide below). set_scene('') or set_scene('close') closes any open overlay. Use for things like 'show me the lint results', 'open the abort scenario', 'preview it on a phone', 'drill into yield'. Only meaningful when the relevant specimen page is loaded.\",\n parameters: {\n type: \"object\",\n properties: {\n scene: {\n type: \"string\",\n description:\n \"Scene name from the loaded page's scene list, e.g. 'lint'. Empty string or 'close' closes overlays.\",\n },\n },\n required: [\"scene\"],\n },\n },\n {\n type: \"function\",\n name: \"set_face_tuning\",\n description:\n \"Adjust the face-detection gate that auto-starts a session when the user's face is close and confident enough. Use when the user asks to make detection more/less sensitive, or to trigger when they're closer/farther from the camera. You can set absolute values and/or pass a relative nudge. The studio applies it to the on-screen sliders immediately.\",\n parameters: {\n type: \"object\",\n properties: {\n min_confidence: {\n type: \"number\",\n description: \"Absolute minimum detection confidence to count as a face, 0.0–1.0 (higher = stricter).\",\n },\n min_face_size: {\n type: \"number\",\n description: \"Absolute minimum face size as % of frame width, 1–100. Higher = the face must be CLOSER to trigger.\",\n },\n relative: {\n type: \"string\",\n enum: [\"more_sensitive\", \"less_sensitive\", \"closer\", \"farther\"],\n description: \"Relative nudge: 'more_sensitive'/'less_sensitive' adjust confidence; 'closer'/'farther' adjust the required face size.\",\n },\n },\n },\n },\n {\n type: \"function\",\n name: \"end_call\",\n description:\n \"Hang up / end the current voice session. Call this right AFTER you say a brief goodbye, when the user says bye, goodbye, see you, talk later, or that they're done. The studio lets your goodbye finish playing, then disconnects.\",\n parameters: { type: \"object\", properties: {} },\n },\n {\n type: \"function\",\n name: \"remember_about_me\",\n description:\n \"Convenience for saving a DURABLE, PINNED fact about the USER themselves (their role, preferences, how they like you to behave) under the 'me' subject. Pinned = it auto-loads into your context at the START of every future call. NOTE: you already know their name, handle, and email from their login — do NOT save those. ONLY call this when the user explicitly asks you to always remember something, or states a lasting personal preference. One short sentence.\",\n parameters: {\n type: \"object\",\n properties: {\n text: {\n type: \"string\",\n description: \"One short, durable fact/preference about the user, e.g. 'Prefers terse answers.'\",\n },\n },\n required: [\"text\"],\n },\n },\n {\n type: \"function\",\n name: \"record_fact\",\n description:\n \"Record a fact about a SUBJECT (a project, object, concept, topic — or 'me' for the user) into long-term memory. ONLY when the user asks you to remember/note something. Use a stable kebab-case subject_id so facts about the same thing group together. Set pin=true ONLY if they want it always-loaded into every future call (e.g. 'always remember…', 'keep in mind…'); otherwise leave it unpinned and it'll be recalled on demand.\",\n parameters: {\n type: \"object\",\n properties: {\n subject_id: {\n type: \"string\",\n description: \"Stable kebab-case id, e.g. 'bambu-a1-mini', 'kratky-hydroponics', or 'me'.\",\n },\n assertion_text: {\n type: \"string\",\n description: \"The specific fact, state change, or observation to remember.\",\n },\n canonical_name: {\n type: \"string\",\n description: \"Optional human-readable name for the subject (used only when first created).\",\n },\n pin: {\n type: \"boolean\",\n description: \"If true, this fact always-loads into the prompt every future call. Default false (recall on demand).\",\n },\n },\n required: [\"subject_id\", \"assertion_text\"],\n },\n },\n {\n type: \"function\",\n name: \"recall_subject\",\n description:\n \"Read the chronological history of facts about one subject so you can reason about its current state and how it changed over time. Use when the user asks what you know about something, or when it's clearly relevant.\",\n parameters: {\n type: \"object\",\n properties: {\n subject_id: { type: \"string\", description: \"Kebab-case subject id to look up.\" },\n limit: { type: \"integer\", description: \"Max facts to return (default 20).\" },\n },\n required: [\"subject_id\"],\n },\n },\n {\n type: \"function\",\n name: \"recall_recent\",\n description:\n \"Pull a digest of the user's most recent memory activity across all subjects. Useful to orient yourself, but don't recite it — use it to inform the conversation.\",\n parameters: {\n type: \"object\",\n properties: {\n hours_back: { type: \"integer\", description: \"Look-back window in hours (default 24).\" },\n },\n },\n },\n {\n type: \"function\",\n name: \"link_subjects\",\n description:\n \"Create a relationship between two subjects in the mindmap (e.g. 'requires', 'blocks', 'references'). Only when the user asks to connect things.\",\n parameters: {\n type: \"object\",\n properties: {\n source_subject_id: { type: \"string\", description: \"Kebab-case id of the source subject.\" },\n target_subject_id: { type: \"string\", description: \"Kebab-case id of the target subject.\" },\n relation_type: { type: \"string\", description: \"Short relation label, e.g. 'requires', 'blocks', 'references'.\" },\n },\n required: [\"source_subject_id\", \"target_subject_id\", \"relation_type\"],\n },\n },\n {\n type: \"function\",\n name: \"retract_fact\",\n description:\n \"Mark a previously recorded fact as no longer valid (without deleting history) — use to correct a mistake when the user tells you something you recorded was wrong. Pass the fact_id from recall_subject.\",\n parameters: {\n type: \"object\",\n properties: {\n fact_id: { type: \"string\", description: \"The id of the fact to retract.\" },\n reason: { type: \"string\", description: \"Why it's no longer valid.\" },\n },\n required: [\"fact_id\", \"reason\"],\n },\n },\n ];\n if (accessToken) {\n tools.unshift({\n type: \"mcp\",\n server_label: \"val_town_mcp\",\n server_url: \"https://api.val.town/v3/mcp\",\n require_approval: \"never\",\n headers: { Authorization: `Bearer ${accessToken}` },\n });\n }\n\n return {\n type: \"realtime\",\n model,\n instructions: buildSystemPrompt(initialVal, username) + identitySection + memorySection,\n audio: {\n input: {\n noise_reduction: { type: NR_TYPE },\n transcription: { model: TRANSCRIBE_MODEL },\n },\n output: { voice: VOICE },\n },\n tools,\n };\n}\n\nclass AgentHandler implements ObserverHandler {\n private callEnding = false;\n constructor(private client: ObserverClient, private callId: string) {}\n onInit() {}\n async onTool(name: string, _args: any) {\n console.log(\"🔧 function tool call:\", name, _args);\n }\n async onMcpCallCompleted(name: string, output: string | null) {\n console.log(\"🔧 MCP call completed:\", name, output?.slice(0, 200));\n this.client.createResponse();\n }\n async onOutputAudioStarted() {}\n async onOutputAudioStopped() {\n if (this.callEnding) await this.hangup();\n }\n async onOutputAudioCleared() {}\n private async hangup() {\n const url = makeUrl(this.callId, \"hangup\");\n const resp = await fetch(url, { method: \"POST\", headers: makeHeaders() });\n if (!resp.ok) {\n console.error(`🔴 end call failed: ${await getErrorText(resp)}`);\n return;\n }\n console.log(\"✅ call ended\");\n }\n}\n\nexport function createHandler(client: ObserverClient, callId: string) {\n return new AgentHandler(client, callId);\n}\n",[],[172,268],["D",1780252340388],[200,201,202,203,204,205,206],[172],"0f28c1e2-5d1f-11f1-bc69-1607ee4eb77e","widget.html","019e7f4e-f0e9-72ce-b45f-a9b214d3821b",["D",1780252340388],"\n\n \n \n \n Voice Edit\n \n \n \n

Voice Edit

Editing –

\n\n

\n \n $\"\"$ \n Log in with Val Town\n \n

\n Lets the AI edit this val on your behalf via your Val Town account.\n

\n\n

\n @\n \n

Click the green circle to start talking. Click again to stop.

\n\n

\n No val specified. Add ?val=handle/name to the script src or set data-val.\n

\n\n

\n\n \n \n\n",[],[178,280],"a18e5af2-5d37-11f1-9c48-1607ee4eb77e","studio.html","019e7f4e-f0e9-72ce-b45f-a4ccb0030c41",74,["D",1780262894002],34,"\n\n \n \n \n Voice Edit Studio\n \n \n \n

\n \n

Nothing loaded yet

Open one of your vals, or create a new one — then talk to build it.

\n \n

\n New here? Click Start talking and just say what you\n want to make — the assistant writes and runs the code for you. You\n can also seed a val via ?val=handle/name.\n

\n\n \n \n

\n\n

Voice Edit Studio

\n Source ↗\n

\n\n

Editing

No val loaded

\n\n

Account

\n \n $\"\"$ \n Log in with Val Town\n \n

\n @\n \n

\n\n

Open a val

\n \n \n

\n\n

Recent vals

\n\n

\n \n Open site ↗\n Open code in Val Town ↗\n 🧠 Memory & mindmap ↗\n

\n\n

Face tracking

\n \n \n Auto-start a call when it sees me\n \n

Min confidence0.50

\n \n

Min closeness (face size)50%

\n \n

Loading face model…

\n \n \n Also start when I say “hey townie”\n \n

Off.

\n\n

\n \n

\n Tell the AI \"open my X\" or ask it to make a new val.\n

\n\n

starting camera…

\n\n

\n\n \n \n\n",[],[178,287],"0f27c7ba-5d1f-11f1-bc69-1607ee4eb77e","sdk.js","019e7f4e-f0e9-72ce-b45f-a3038c60fc58",["D",1780252340388],"// voice-edit-sdk loader.\n//\n// Drops a small green-circle iframe widget on the host page (bottom-right).\n// All call UI (login, mic, WebRTC, audio) lives same-origin inside the iframe.\n//\n// When the host val is hot-reloaded via live-reload5 (or similar), instead of\n// letting the browser navigate the whole document (which would kill the\n// iframe and drop the call), we long-poll for version bumps ourselves and\n// hot-patch the DOM in place — replacing the body's visible content while\n// leaving the iframe untouched. The call keeps going.\n//\n// \n\n(function () {\n if (window.__voiceEditSdkInstalled) return;\n window.__voiceEditSdkInstalled = true;\n\n const SELF_SCRIPT = document.currentScript ||\n (function () {\n const all = document.getElementsByTagName(\"script\");\n for (let i = all.length - 1; i >= 0; i--) {\n if (all[i].src && /\\/sdk\\.js(?:\\?|$)/.test(all[i].src)) return all[i];\n }\n return null;\n })();\n\n const SDK_ORIGIN = SELF_SCRIPT\n ? new URL(SELF_SCRIPT.src, window.location.href).origin\n : window.location.origin;\n\n function resolveVal() {\n if (SELF_SCRIPT) {\n if (SELF_SCRIPT.dataset && SELF_SCRIPT.dataset.val) {\n return SELF_SCRIPT.dataset.val.trim();\n }\n try {\n const u = new URL(SELF_SCRIPT.src, window.location.href);\n const q = u.searchParams.get(\"val\");\n if (q) return q.trim();\n } catch {}\n }\n if (typeof window.VOICE_EDIT_VAL === \"string\") {\n return window.VOICE_EDIT_VAL.trim();\n }\n return \"\";\n }\n\n const VAL = resolveVal();\n const WIDGET_ID = \"voice-edit-widget\";\n let iframe = null;\n let callActive = false;\n\n function mount() {\n const widgetUrl = new URL(\"/widget\", SDK_ORIGIN);\n if (VAL) widgetUrl.searchParams.set(\"val\", VAL);\n iframe = document.createElement(\"iframe\");\n iframe.src = widgetUrl.toString();\n iframe.title = \"Voice Edit\";\n iframe.id = WIDGET_ID;\n iframe.allow = \"microphone; autoplay\";\n iframe.setAttribute(\n \"sandbox\",\n \"allow-scripts allow-same-origin allow-popups allow-popups-to-escape-sandbox allow-forms\",\n );\n iframe.style.cssText = [\n \"position:fixed\",\n \"bottom:0\",\n \"right:0\",\n \"width:72px\",\n \"height:72px\",\n \"border:0\",\n \"background:transparent\",\n \"color-scheme:normal\",\n \"z-index:2147483647\",\n \"pointer-events:auto\",\n ].join(\";\");\n\n window.addEventListener(\"message\", (ev) => {\n if (ev.origin !== SDK_ORIGIN) return;\n const m = ev.data;\n if (!m || typeof m !== \"object\") return;\n if (m.type === \"voice-edit:resize\") {\n const w = Math.max(40, Math.min(800, Number(m.width) || 72));\n const h = Math.max(40, Math.min(800, Number(m.height) || 72));\n iframe.style.width = w + \"px\";\n iframe.style.height = h + \"px\";\n } else if (m.type === \"voice-edit:call-state\") {\n callActive = !!m.active;\n }\n });\n\n document.body.appendChild(iframe);\n }\n\n // -------- Smart patch: keep the iframe alive across val edits --------\n //\n // We poll /__lastUpdatedAt ourselves (using the original fetch so any other\n // live-reload's wrappers don't interfere). On a real version bump we fetch\n // the new HTML and apply it as a DOM patch instead of navigating, so the\n // iframe element (and the running call inside it) is never removed from\n // the document.\n //\n // We also intercept the host page's /__lastUpdatedAt poll for any\n // co-installed live-reload client (e.g. live-reload5) and feed it a fake\n // \"TIMEOUT\" so it never triggers `location.href = …`. We do the reloads.\n const origFetch = window.fetch.bind(window);\n const ourPollMarker = \"_voiceedit=1\";\n\n window.fetch = function (input, init) {\n try {\n const url = typeof input === \"string\"\n ? input\n : (input && input.url) ? input.url : \"\";\n if (\n /\\/__lastUpdatedAt(?:$|\\?)/.test(url) && !url.includes(ourPollMarker)\n ) {\n // Hold the third-party live-reload poll harmlessly. It will get\n // status:TIMEOUT after a delay and naturally re-poll.\n return new Promise((resolve) => {\n setTimeout(\n () =>\n resolve(\n new Response(\n JSON.stringify({ lastUpdatedAt: 0, status: \"TIMEOUT\" }),\n { headers: { \"Content-Type\": \"application/json\" } },\n ),\n ),\n 30000,\n );\n });\n }\n } catch {}\n return origFetch(input, init);\n };\n\n let lastSeenVersion = 0;\n async function ourPollLoop() {\n while (true) {\n try {\n const sep = window.location.pathname.includes(\"?\") ? \"&\" : \"?\";\n const url = \"/__lastUpdatedAt\" + sep + ourPollMarker;\n const r = await origFetch(url, { cache: \"no-store\" });\n const d = await r.json().catch(() => ({}));\n const v = Number(d.lastUpdatedAt) || 0;\n if (v > 0) {\n if (lastSeenVersion === 0) {\n lastSeenVersion = v;\n } else if (v > lastSeenVersion) {\n lastSeenVersion = v;\n try {\n await smartPatch();\n } catch (e) {\n console.warn(\n \"[voice-edit] smart-patch failed, falling back to reload\",\n e,\n );\n if (!callActive) location.reload();\n }\n }\n }\n if (d.status !== \"TIMEOUT\") {\n // Whatever live-reload server we're talking to didn't long-poll —\n // sleep a beat before polling again so we don't hammer.\n await new Promise((r) => setTimeout(r, 1000));\n }\n } catch {\n await new Promise((r) => setTimeout(r, 2000));\n }\n }\n }\n\n async function smartPatch() {\n const resp = await origFetch(window.location.href, {\n cache: \"no-store\",\n credentials: \"same-origin\",\n });\n if (!resp.ok) throw new Error(\"fetch new html: \" + resp.status);\n const html = await resp.text();\n const newDoc = new DOMParser().parseFromString(html, \"text/html\");\n\n // Update and replace any inline <style> tags in <head>.\n if (newDoc.title) document.title = newDoc.title;\n const oldStyles = Array.from(document.head.querySelectorAll(\"style\"));\n oldStyles.forEach((s) => s.remove());\n Array.from(newDoc.head.querySelectorAll(\"style\")).forEach((s) => {\n document.head.appendChild(s.cloneNode(true));\n });\n\n // Replace body children, but never touch the voice-edit iframe.\n const widget = document.getElementById(WIDGET_ID);\n const toRemove = [];\n document.body.childNodes.forEach((c) => {\n if (c !== widget) toRemove.push(c);\n });\n toRemove.forEach((c) => c.remove());\n\n // Insert new body children before the widget (so it stays last/visible).\n // Skip <script> tags: original scripts are still running; re-injecting\n // them would duplicate side-effects (e.g. live-reload pollers).\n Array.from(newDoc.body.childNodes).forEach((nc) => {\n if (nc.nodeName === \"SCRIPT\") return;\n const adopted = document.importNode(nc, true);\n if (widget) document.body.insertBefore(adopted, widget);\n else document.body.appendChild(adopted);\n });\n }\n\n if (document.readyState === \"loading\") {\n document.addEventListener(\"DOMContentLoaded\", () => {\n mount();\n ourPollLoop();\n }, { once: true });\n } else {\n mount();\n ourPollLoop();\n }\n})();\n",[],[178,296],"c4c939da-5d2b-11f1-81a0-1607ee4eb77e","memory.html","d9149d74-5d23-11f1-a38c-1607ee4eb77e",67,["D",1780257799148],8,"<!DOCTYPE html>\n<html lang=\"en\">\n<head>\n <meta charset=\"utf-8\" />\n <meta name=\"viewport\" content=\"width=device-width, initial-scale=1\" />\n <title>hey-townie · memory\n \n \n \n\n\n

🧠 hey-townie memory

\n \n \n ← Back to studio\n

\n\n \n\n \n\n \n\n\n",[],[178,303],"0f27844e-5d1f-11f1-bc69-1607ee4eb77e","index.html","019e7f4e-f0e9-72ce-b45f-9e35875be4b0",["D",1780252340388],"\n\n \n \n \n Voice Edit SDK\n \n \n \n

Voice Edit SDK

\n One line of code, and any Val Town val gets a little green circle in\n the corner that lets you voice-edit its source.\n

\n\n

Usage — Hono

Two lines added to any val you own. The val identifier is auto-detected:

import { voiceEdit } from \"https://esm.town/v/dcm31/voice-edit-sdk/sdk.ts\";\napp.use(voiceEdit());

\n\n

Usage — plain fetch handler

import { wrapFetch } from \"https://esm.town/v/dcm31/voice-edit-sdk/sdk.ts\";\nexport default wrapFetch(myHandler);

\n\n

Or: plain HTML snippet

If you'd rather paste a script tag into your HTML:

<script src=\"/sdk.js\" data-val=\"handle/name\" defer></script>

\n\n

What it does

\n Adds a small green circle in the bottom-right corner. Click to expand\n a login card, sign in with Val Town, then click again to start talking.\n The AI uses your Val Town MCP token to read and edit the host val's\n source — say things like \"add a button that says hello\" or\n \"in main.tsx, change the title to 'Welcome'\". Refresh the\n page to see edits live.\n

\n\n

How it works

\n The script injects an <iframe> pointing at this\n val's /widget page.\n
\n The widget runs same-origin, so OAuth, WebRTC, and audio all live\n inside it — no cross-origin cookie or CORS issues.\n
\n On connect, the OpenAI Realtime API is given the Val Town MCP server\n plus your access token, scoped to the val you specified.\n
\n The circle pulses with the AI's voice volume via an\n AnalyserNode on the remote audio track.\n

\n\n

Auth status

Checking…

\n\n \n

\n\n \n \n\n",[],[178,312],["D",1780252340388],[194,195,196,197,198],[178],["D",1780252340388],["D",1789501263826],{"_16":17,"_90":86},{"_16":17,"_83":84,"_85":86,"_33":34,"_87":88,"_89":26},{"_68":69,"_20":70,"_18":71,"_72":19,"_73":74,"_75":76,"_77":28,"_78":79,"_80":44,"_81":21,"_82":17},"ctx",{"_61":-5,"_113":359,"_360":361,"_362":363,"_364":26,"_365":26,"_366":26,"_367":38,"_368":-5,"_369":-7,"_370":-7,"_371":42,"_372":26,"_373":26,"_374":-5,"_375":26,"_376":26,"_377":26,"_378":-5},"ENV",{"_330":331,"_332":333,"_334":70,"_335":336,"_337":338,"_339":340,"_341":342,"_343":344,"_345":346,"_347":348,"_349":350,"_351":352,"_353":354,"_355":356,"_357":358},"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"]

hi

Your new val is running 🎉

Voice Edit

Nothing loaded yet

🧠 hey-townie memory

📌 Always loaded into the AI (pinned)

Add a fact (manual)

Subjects

Mindmap

Timeline

Voice Edit SDK

Usage — Hono

Usage — plain fetch handler

Or: plain HTML snippet

What it does

How it works

Auth status

Search