[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_235":236,"_237":238},"routes/_app.x.$handle.$name",{"_104":103,"_32":44,"_113":90,"_27":114,"_13":14,"_115":-5,"_11":116,"_117":118,"_119":120,"_121":122,"_123":124,"_20":-5,"_125":126,"_127":128,"_129":25,"_130":131,"_132":59,"_133":-5,"_134":-5,"_135":136},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":25,"_48":49,"_50":49,"_51":52,"_53":54,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",7,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":20,"_34":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":20,"_34":35},"deleted",false,"deletedHere","path","README.md","latestPath","fileId","019eb76e-b242-72f9-ad38-207faf17e107","name","fileType","content","# What's the simplest way to make an AI phone call?\n\nThis val serves a tiny form: you type a phone number, Vapi rings it, and an AI has a conversation with whoever answers. Vapi hosts the telephony and the live audio bridge to the model, so the whole demo is one POST to `https://api.vapi.ai/call` — one file, about seventy lines, no imports.\n\n## Setup\n\n1. **Remix this val** to get your own copy.\n2. **Get a Vapi API key** — sign up at [dashboard.vapi.ai](https://dashboard.vapi.ai) and copy your private key, then paste it as an env var in your val:\n\n 👉 [Add `VAPI_API_KEY` here](https://www.val.town/x/templates/vapi-phone-call/environment-variables?key=VAPI_API_KEY)\n\n3. **Create a phone number** in the Vapi dashboard (free Vapi numbers work for testing) and copy its ID:\n\n 👉 [Add `VAPI_PHONE_NUMBER_ID` here](https://www.val.town/x/templates/vapi-phone-call/environment-variables?key=VAPI_PHONE_NUMBER_ID)\n\n## Test it\n\nOpen the HTTP endpoint of [`main.ts`](https://www.val.town/x/templates/vapi-phone-call/code/main.ts), type your own number in E.164 format (`+15551234567`), and hit **Call me**. Your phone rings and the AI speaks first. Without the env vars set, the page shows a setup reminder instead of erroring.\n\n## Files\n\n- [`main.ts`](https://www.val.town/x/templates/vapi-phone-call/code/main.ts) — the form, and the one `fetch` that places the call\n\n## Notes\n\n- `FIRST_MESSAGE`, `SYSTEM_PROMPT`, `MODEL`, and `VOICE` at the top of `main.ts` control what the AI opens with, how it behaves, and how it sounds.\n- Call screening (like Google Voice's) answers before you do, so the AI spends its greeting on the screening robot and you join to silence — turn screening off when testing.\n- Free Vapi numbers are US-only and meant for testing.\n- From here you can add tool calls, transcripts, and post-call analysis — see [docs.vapi.ai](https://docs.vapi.ai).\n- Only call numbers you have consent to call — automated calls without consent violate TCPA/FCC rules.\n","# vapi-remote-mcp — a phone call Claude can drive, live\n\nRemix of [templates/vapi-phone-call](https://www.val.town/x/templates/vapi-phone-call) turned into a **remote MCP server**. The AI voice on the call is a pure puppet: its \"brain\" is an endpoint on this val that always returns an empty completion, so it never speaks on its own. Whatever agent is connected over MCP injects every line via Vapi's live-call control URL, and hears the callee through Vapi's transcript webhook.\n\n```\nClaude (any MCP client)\n │ /mcp tools: start_call · say · listen · get_status · end_call\n ▼\nthis val ──── POST api.vapi.ai/call ────▶ Vapi ────▶ 📱 callee\n ▲ │ │\n │ └── say ──▶ controlUrl (inject TTS) ─┤\n └── /webhook ◀── live transcripts ──────┘\n (SQLite event feed; /llm/chat/completions returns \"\" so the voice never freelances)\n```\n\n`listen` long-polls the event feed for up to 25s per call — chaining listens approximates holding the line open, which is how a turn-based agent stays \"on\" a real-time call. The operator can interleave any other tool calls between `listen` and `say`; the call just sits in silence for a beat.\n\n## Connect from Claude Code\n\n```sh\nclaude mcp add --transport http vapi-phone \"https://dcm31--019eb76eb24371fd8ce74920e76677d7.web.val.run/mcp?key=\"\n```\n\n`` is the value of this val's `MCP_KEY` env var (it is not in the code — the val is public).\n\n## Drive it with curl\n\n```sh\nBASE=\"https://dcm31--019eb76eb24371fd8ce74920e76677d7.web.val.run\"\ncurl -X POST \"$BASE/api/call/start?key=$KEY\" -d '{\"first_message\":\"Hey, it is Claude.\"}'\ncurl -X POST \"$BASE/api/call/listen?key=$KEY\" -d '{\"wait_seconds\":25}' --max-time 35\ncurl -X POST \"$BASE/api/call/say?key=$KEY\" -d '{\"text\":\"Nice. Talk soon!\", \"end_call_after\":true}'\ncurl \"$BASE/api/call/status?key=$KEY\"\ncurl -X POST \"$BASE/api/call/end?key=$KEY\"\n```\n\n## Watch a call live\n\nOpen `/?key=` on the endpoint — a self-refreshing feed of statuses, transcripts (user + assistant), injected `say` lines, and \"your-turn\" markers (fired whenever Vapi asks the silent brain for a response, i.e. the callee finished talking).\n\n## Files\n\n- `main.ts` — HTTP entry: routes, Vapi webhook, the silent `/llm/chat/completions` brain, debug page\n- `tools.ts` — the five tools, shared by MCP and REST\n- `mcp.ts` — minimal stateless streamable-HTTP MCP plumbing (no SDK)\n- `vapi.ts` — Vapi REST + live-call control client\n- `db.ts` — SQLite: `calls` + append-only `events`, with a per-call read cursor for `listen`\n\n## Env vars\n\n- `VAPI_API_KEY` — Vapi private key\n 👉 Add VAPI_API_KEY here: https://www.val.town/x/dcm31/vapi-remote-mcp/environment-variables?key=VAPI_API_KEY\n- `VAPI_PHONE_NUMBER_ID` — outbound caller ID from the Vapi dashboard\n 👉 Add VAPI_PHONE_NUMBER_ID here: https://www.val.town/x/dcm31/vapi-remote-mcp/environment-variables?key=VAPI_PHONE_NUMBER_ID\n- `DEFAULT_CALL_NUMBER` — E.164 number `start_call` dials when none is given\n 👉 Add DEFAULT_CALL_NUMBER here: https://www.val.town/x/dcm31/vapi-remote-mcp/environment-variables?key=DEFAULT_CALL_NUMBER\n- `MCP_KEY` — shared secret for /mcp, /api, the debug page, and the Vapi webhook\n 👉 Add MCP_KEY here: https://www.val.town/x/dcm31/vapi-remote-mcp/environment-variables?key=MCP_KEY\n\n## Notes\n\n- Latency etiquette: the operator thinks for a few seconds between turns; the assistant's `silenceTimeoutSeconds` is raised to 90 so Vapi doesn't hang up during the pause. Calls cap at 10 minutes.\n- The `say` control message is sent as `{type:\"say\", content}` with a `{type:\"say\", message}` fallback (docs and SDK disagree).\n- Free Vapi numbers are US-only; call screening (e.g. Google Voice) eats the first message.\n- Only call numbers you have consent to call — automated calls without consent violate TCPA/FCC rules.\n","createdAt",["D",1781194232612],"branchVersion","branchId","2a0f5ec6-0f27-4f92-8928-4cc63a7c88a2","id","512cd129-ca33-4230-88e5-cbd531eaf822","vapi-remote-mcp",["D",1781193945555],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Make an AI phone call with one fetch to Vapi","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/e638c970-aa12-42a0-ac97-631720749000/square512?exp=1789570799&sig=6db87c4a56e40b8f6557aaae59dcbb55732bc17d31ab15cd5907723d31afbf45","9319c175-2593-4f88-ba21-04f2ef7b1c28","pinnedFileId","019eb76e-b243-71fd-8ce7-4920e76677d7","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","d663a026-6449-42f6-9156-1d4a2d64d38c","tursoName","512cd129ca33423088e5cbd531eaf822","tursoHostname","512cd129ca33423088e5cbd531eaf822-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789494036282],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_104":103,"_112":108},"org",{"_104":103,"_105":106,"_107":108,"_18":55,"_109":110,"_111":25},"branch",{"_13":89,"_32":90,"_42":41,"_91":43,"_92":93,"_94":95,"_96":49,"_97":98,"_99":100,"_101":44,"_102":103},"isOwned",10,"main","projectId","forkedBranchId","1a083b45-4db0-4390-92b8-ef32e4f387fc","forkedBranchVersion",4,"forkedProjectPrivacy","forkedProjectId","bbf68a35-8f24-4158-8ec0-2bf5b96d1556","forkedProjectOrgId","019aa807-52c2-709c-928b-2029bae9a558","projectName","userHandle","dcm31","handle","displayName","Charlie","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/3e904faa-3764-4629-c475-f561a49b0000/square512?exp=1789570799&sig=bfafc9de3f25d020766c1a418088d2aa7a118e3408c10bafe80b0604dafaeba0","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_32":44,"_37":230,"_46":-5,"_47":25,"_48":49,"_50":49,"_51":52,"_53":54,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":231,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":232,"_84":233,"_86":234,"_88":25},"tree",[205,206,207,208,209,210],"files",[205,206,207,208,209,210],"counts",{"_195":63,"_196":181,"_197":181,"_198":199,"_200":201},"contents",[147,148,149,150,151,152],"upstreamProject",{"_42":98,"_32":144,"_51":52,"_53":54,"_48":49,"_82":145},"upstreamBranch",{"_42":93,"_37":137,"_138":139,"_32":90,"_91":98,"_13":140,"_92":-5,"_94":-5,"_141":142,"_46":-5,"_88":25,"_48":49,"_102":143,"_64":100,"_101":144},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1781187727955],"updatedAt",["D",1781307011317],17,"lockfileKey","1781307011407-esm.town_v_templates_vapi-phone-call@17-main","templates","vapi-phone-call",{"_104":143,"_112":146},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789570799&sig=257a5acfa0921f3bba1b6e04c40af81b331d69d65dd78c28728d8fa984364db5",{"_42":192,"_32":28,"_30":31,"_156":-5,"_40":41,"_39":14,"_158":25,"_37":193,"_13":181,"_33":20,"_34":36,"_24":25,"_162":-5,"_27":194},{"_42":185,"_32":186,"_30":187,"_156":-5,"_40":41,"_39":188,"_158":59,"_37":189,"_13":63,"_33":160,"_34":190,"_24":25,"_162":-5,"_27":191},{"_42":177,"_32":178,"_30":57,"_156":-5,"_40":41,"_39":179,"_158":59,"_37":180,"_13":181,"_33":182,"_34":183,"_24":25,"_162":-5,"_27":184},{"_42":170,"_32":171,"_30":172,"_156":-5,"_40":41,"_39":173,"_158":59,"_37":174,"_13":63,"_33":160,"_34":175,"_24":25,"_162":-5,"_27":176},{"_42":164,"_32":165,"_30":166,"_156":-5,"_40":41,"_39":95,"_158":59,"_37":167,"_13":63,"_33":160,"_34":168,"_24":25,"_162":-5,"_27":169},{"_42":153,"_32":154,"_30":155,"_156":-5,"_40":41,"_39":157,"_158":25,"_37":159,"_13":63,"_33":160,"_34":161,"_24":25,"_162":-5,"_27":163},"a8b9ebfe-c448-4888-a05e-565a0db9c219","vapi.ts","da970490-65af-11f1-833a-1607ee4eb77e","parentId",3,"latest",["D",1781194138598],"script","// Thin Vapi REST client: create the puppet call, live-call control, fetch call state.\n\nconst VAPI_BASE = \"https://api.vapi.ai\";\n\nfunction apiKey(): string {\n const k = Deno.env.get(\"VAPI_API_KEY\");\n if (!k) throw new Error(\"VAPI_API_KEY env var is not set\");\n return k;\n}\n\nexport async function createPuppetCall(opts: {\n number: string;\n firstMessage: string;\n origin: string; // this val's https origin\n}) {\n const secret = Deno.env.get(\"MCP_KEY\") ?? \"\";\n const body = {\n phoneNumberId: Deno.env.get(\"VAPI_PHONE_NUMBER_ID\"),\n customer: { number: opts.number },\n assistant: {\n firstMessage: opts.firstMessage,\n // The \"brain\" is /llm on this val, which always returns an empty\n // completion — so the assistant only ever says what `say` injects.\n model: { provider: \"custom-llm\", url: `${opts.origin}/llm`, model: \"claude-puppet\" },\n voice: { provider: \"openai\", voiceId: \"shimmer\" },\n server: { url: `${opts.origin}/webhook`, secret },\n serverMessages: [\"transcript\", \"status-update\", \"end-of-call-report\"],\n silenceTimeoutSeconds: 90, // the operator thinks between turns — don't hang up on the pause\n maxDurationSeconds: 600,\n },\n };\n console.log(\"vapi: creating call →\", opts.number);\n const res = await fetch(`${VAPI_BASE}/call`, {\n method: \"POST\",\n headers: { Authorization: `Bearer ${apiKey()}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n const data = await res.json();\n if (!res.ok) {\n console.log(\"vapi: create FAILED\", res.status, JSON.stringify(data).slice(0, 500));\n throw new Error(`Vapi ${res.status}: ${JSON.stringify(data)}`);\n }\n console.log(\"vapi: call created\", data.id, \"controlUrl:\", data.monitor?.controlUrl ? \"present\" : \"MISSING\");\n return data as { id: string; status?: string; monitor?: { controlUrl?: string; listenUrl?: string } };\n}\n\nexport async function control(controlUrl: string, payload: Record) {\n const res = await fetch(controlUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n });\n const text = await res.text();\n console.log(\"vapi control:\", payload.type, \"→\", res.status, text.slice(0, 200));\n return { status: res.status, body: text };\n}\n\n// Docs use `content`; the SDK's SayMessage type uses `message`. Try both.\nexport async function sayOnCall(controlUrl: string, text: string, endCallAfterSpoken = false) {\n const base: Record = { type: \"say\", content: text };\n if (endCallAfterSpoken) base.endCallAfterSpoken = true;\n let r = await control(controlUrl, base);\n if (r.status >= 400) {\n const alt: Record = { type: \"say\", message: text };\n if (endCallAfterSpoken) alt.endCallAfterSpoken = true;\n r = await control(controlUrl, alt);\n }\n return r;\n}\n\nexport async function endCallOnVapi(controlUrl: string) {\n return control(controlUrl, { type: \"end-call\" });\n}\n\nexport async function getCallLive(callId: string) {\n const res = await fetch(`${VAPI_BASE}/call/${callId}`, {\n headers: { Authorization: `Bearer ${apiKey()}` },\n });\n const data = await res.json();\n if (!res.ok) throw new Error(`Vapi GET /call ${res.status}: ${JSON.stringify(data).slice(0, 300)}`);\n return data;\n}\n","label",[154],"f8474379-9015-4d3c-8360-b1451dd93ee5","tools.ts","eaa1695c-65af-11f1-8f9f-1607ee4eb77e",["D",1781194165506],"// The five tools, defined once and exposed twice: over MCP (/mcp) and REST (/api/call/*).\n// `ctx.origin` is this val's https origin, derived per-request in main.ts.\n\nimport * as db from \"./db.ts\";\nimport { createPuppetCall, endCallOnVapi, getCallLive, sayOnCall } from \"./vapi.ts\";\n\nexport interface Ctx {\n origin: string;\n}\n\nconst ACTIVE = [\"starting\", \"queued\", \"ringing\", \"in-progress\", \"forwarding\"];\n\nasync function requireActiveCall(): Promise {\n const call = await db.latestCall();\n if (!call) throw new Error(\"No call yet — use start_call first.\");\n if (!ACTIVE.includes(call.status)) {\n throw new Error(\n `Latest call ${call.id} is '${call.status}'${call.ended_reason ? ` (${call.ended_reason})` : \"\"} — start a new one with start_call.`,\n );\n }\n return call;\n}\n\nconst fmt = (e: db.EventRow) => ({\n t: e.created_at.slice(11, 19),\n type: e.type,\n role: e.role,\n content: e.content,\n});\n\nexport const TOOLS = [\n {\n name: \"start_call\",\n description:\n \"Place an outbound phone call. The voice on the line is a pure puppet: after first_message it stays silent until you inject speech with `say`. Right after this returns, call `listen` (wait_seconds 25) to catch the pickup and the callee's first words. Etiquette: there is real latency between their speech and your `say` — acknowledge that early in the call.\",\n inputSchema: {\n type: \"object\",\n properties: {\n number: {\n type: \"string\",\n description: \"E.164 number to dial, e.g. +15551234567. Defaults to the DEFAULT_CALL_NUMBER env var.\",\n },\n first_message: { type: \"string\", description: \"What the voice says as soon as the callee picks up.\" },\n },\n },\n run: async (args: Record, ctx: Ctx) => {\n const prev = await db.latestCall();\n if (prev && ACTIVE.includes(prev.status)) {\n // Our DB may have missed an ending webhook — trust Vapi's live status.\n let stillActive = false;\n try {\n const live = await getCallLive(prev.id);\n if (live.status && live.status !== prev.status) {\n await db.setCallStatus(prev.id, live.status, live.endedReason ?? null);\n }\n stillActive = ACTIVE.includes(live.status);\n } catch (e) {\n console.log(\"start_call: live status check failed, allowing new call:\", String(e).slice(0, 120));\n }\n if (stillActive) throw new Error(`Call ${prev.id} is still active — end_call it first.`);\n }\n const number = String(args.number || Deno.env.get(\"DEFAULT_CALL_NUMBER\") || \"\");\n if (!number) throw new Error(\"No number given and DEFAULT_CALL_NUMBER is not set.\");\n const firstMessage = String(\n args.first_message ||\n \"Hey, it's Claude — I'm driving this call remotely, so give me a few seconds after you talk.\",\n );\n const call = await createPuppetCall({ number, firstMessage, origin: ctx.origin });\n const controlUrl = call.monitor?.controlUrl ?? \"\";\n await db.insertCall(call.id, controlUrl, number);\n await db.addEvent(call.id, \"status\", \"system\", `dialing ${number}`);\n return {\n call_id: call.id,\n status: call.status ?? \"queued\",\n control_url_present: Boolean(controlUrl),\n next: \"Call `listen` now (wait_seconds 25) and wait for pickup + their first words.\",\n };\n },\n },\n {\n name: \"say\",\n description:\n \"Speak on the live call (TTS). Keep it conversational and short — long monologues feel robotic. Set end_call_after true on your goodbye line to hang up cleanly after it plays.\",\n inputSchema: {\n type: \"object\",\n properties: {\n text: { type: \"string\", description: \"What to say, verbatim.\" },\n end_call_after: { type: \"boolean\", description: \"Hang up after this line finishes playing.\" },\n },\n required: [\"text\"],\n },\n run: async (args: Record) => {\n const call = await requireActiveCall();\n if (!call.control_url) throw new Error(\"No controlUrl stored for this call — cannot inject speech.\");\n const r = await sayOnCall(call.control_url, String(args.text), Boolean(args.end_call_after));\n await db.addEvent(call.id, \"say\", \"assistant\", String(args.text));\n if (r.status >= 400) throw new Error(`Vapi control rejected say (${r.status}): ${r.body.slice(0, 200)}`);\n return { ok: true, vapi_status: r.status, next: \"Call `listen` to hear their response.\" };\n },\n },\n {\n name: \"listen\",\n description:\n \"Long-poll for new call events (their speech, status changes). Blocks up to wait_seconds and returns as soon as something new arrives — chain listens to approximate an open line. Empty events means they haven't spoken yet: still thinking, or waiting on you.\",\n inputSchema: {\n type: \"object\",\n properties: {\n wait_seconds: { type: \"number\", description: \"Max seconds to wait (1-25, default 20).\" },\n },\n },\n run: async (args: Record) => {\n const call = await db.latestCall();\n if (!call) throw new Error(\"No call yet — use start_call first.\");\n const wait = Math.min(Math.max(Number(args.wait_seconds ?? 20), 1), 25);\n const deadline = Date.now() + wait * 1000;\n let cursor = call.cursor;\n while (true) {\n const events = await db.eventsAfter(call.id, cursor);\n const fresh = events.filter((e) => e.type !== \"say\"); // don't echo our own injected lines back\n const maxId = events.length ? events[events.length - 1].id : cursor;\n if (fresh.length) {\n await db.setCursor(call.id, maxId);\n const current = await db.getCall(call.id);\n const over = current && !ACTIVE.includes(current.status);\n return {\n events: fresh.map(fmt),\n call_status: current?.status ?? call.status,\n ...(over ? { note: `Call is over (${current?.ended_reason ?? current?.status}).` } : {}),\n };\n }\n if (maxId !== cursor) {\n cursor = maxId;\n await db.setCursor(call.id, maxId);\n }\n const current = await db.getCall(call.id);\n if (current && !ACTIVE.includes(current.status)) {\n return {\n events: [],\n call_status: current.status,\n note: `Call is over (${current.ended_reason ?? current.status}).`,\n };\n }\n if (Date.now() > deadline) {\n return {\n events: [],\n call_status: current?.status ?? \"unknown\",\n ...(current?.live_partial ? { hearing_now: current.live_partial } : {}),\n note: \"Nothing new. They may be waiting on you — `say` something, or `listen` again.\",\n };\n }\n await new Promise((r) => setTimeout(r, 800));\n }\n },\n },\n {\n name: \"get_status\",\n description:\n \"Snapshot of the latest call: live status straight from Vapi plus the recent event feed. Does not consume `listen`'s cursor.\",\n inputSchema: { type: \"object\", properties: {} },\n run: async () => {\n const call = await db.latestCall();\n if (!call) return { note: \"No calls yet.\" };\n let live: Record | null = null;\n try {\n live = await getCallLive(call.id);\n if (live?.status && live.status !== call.status) {\n await db.setCallStatus(call.id, String(live.status), (live.endedReason as string) ?? null);\n }\n } catch (e) {\n live = { error: String(e) };\n }\n const events = await db.recentEvents(call.id, 15);\n return {\n call_id: call.id,\n number: call.number,\n db_status: call.status,\n vapi_status: live?.status ?? null,\n ended_reason: live?.endedReason ?? call.ended_reason ?? null,\n started_at: call.created_at,\n recent_events: events.map(fmt),\n };\n },\n },\n {\n name: \"end_call\",\n description: \"Hang up the live call immediately. For a graceful exit prefer `say` with end_call_after=true.\",\n inputSchema: { type: \"object\", properties: {} },\n run: async () => {\n const call = await requireActiveCall();\n const r = await endCallOnVapi(call.control_url);\n await db.addEvent(call.id, \"status\", \"system\", \"end-call requested\");\n return { ok: r.status < 400, vapi_status: r.status };\n },\n },\n];\n\nexport async function runTool(name: string, args: Record, ctx: Ctx) {\n const tool = TOOLS.find((t) => t.name === name);\n if (!tool) throw new Error(`Unknown tool: ${name}`);\n console.log(\"tool:\", name, JSON.stringify(args ?? {}).slice(0, 200));\n return await tool.run(args ?? {}, ctx);\n}\n",[165],"c16afbc4-eec8-4ba9-bf0c-b7cdd8a70f21","mcp.ts","f16ad1ba-65af-11f1-ab94-1607ee4eb77e",5,["D",1781194176907],"// Minimal remote MCP server: stateless streamable HTTP, plain JSON responses,\n// no SDK. Handles initialize / ping / tools/list / tools/call; notifications get 202.\n\nimport { type Ctx, runTool, TOOLS } from \"./tools.ts\";\n\nconst KNOWN_VERSIONS = [\"2024-11-05\", \"2025-03-26\", \"2025-06-18\"];\n\nconst SERVER_INSTRUCTIONS =\n `Drive a live outbound phone call like a puppet: the voice only says what you tell it to.\nLoop: start_call → listen → say → listen → … → say(end_call_after=true).\nlisten long-polls up to 25s; chain listens to keep an ear on the line.\nLatency etiquette: the human hears silence while you think — keep replies short and snappy.\nYou can interleave other tool calls between listen and say; the call survives, the human just waits a beat.`;\n\nconst rpcResult = (id: unknown, result: unknown) => ({ jsonrpc: \"2.0\", id, result });\nconst rpcError = (id: unknown, code: number, message: string) => ({ jsonrpc: \"2.0\", id, error: { code, message } });\n\nasync function handleOne(msg: any, ctx: Ctx) {\n if (!msg || typeof msg !== \"object\" || typeof msg.method !== \"string\") {\n return rpcError(msg?.id ?? null, -32600, \"invalid request\");\n }\n if (msg.id === undefined) {\n console.log(\"mcp notification:\", msg.method);\n return null; // notifications get no body\n }\n console.log(\"mcp request:\", msg.method);\n switch (msg.method) {\n case \"initialize\": {\n const v = msg.params?.protocolVersion;\n return rpcResult(msg.id, {\n protocolVersion: KNOWN_VERSIONS.includes(v) ? v : \"2025-06-18\",\n capabilities: { tools: { listChanged: false } },\n serverInfo: { name: \"vapi-remote-mcp\", version: \"0.1.0\" },\n instructions: SERVER_INSTRUCTIONS,\n });\n }\n case \"ping\":\n return rpcResult(msg.id, {});\n case \"tools/list\":\n return rpcResult(msg.id, {\n tools: TOOLS.map(({ name, description, inputSchema }) => ({ name, description, inputSchema })),\n });\n case \"tools/call\": {\n try {\n const out = await runTool(msg.params?.name, msg.params?.arguments ?? {}, ctx);\n const text = typeof out === \"string\" ? out : JSON.stringify(out, null, 2);\n return rpcResult(msg.id, { content: [{ type: \"text\", text }], isError: false });\n } catch (e) {\n return rpcResult(msg.id, { content: [{ type: \"text\", text: String(e) }], isError: true });\n }\n }\n default:\n return rpcError(msg.id, -32601, `method not found: ${msg.method}`);\n }\n}\n\nexport async function handleMcp(req: Request, ctx: Ctx): Promise {\n if (req.method !== \"POST\") {\n return new Response(\"vapi-remote-mcp: POST JSON-RPC here (stateless streamable HTTP MCP).\", { status: 405 });\n }\n let body: unknown;\n try {\n body = await req.json();\n } catch {\n return Response.json(rpcError(null, -32700, \"parse error\"), { status: 400 });\n }\n const msgs = Array.isArray(body) ? body : [body];\n const replies: unknown[] = [];\n for (const m of msgs) {\n const r = await handleOne(m, ctx);\n if (r) replies.push(r);\n }\n if (!replies.length) return new Response(null, { status: 202 });\n return Response.json(Array.isArray(body) ? replies : replies[0]);\n}\n",[171],"63c86f50-9d31-4c6e-a0fb-4a7fed8cca15","main.ts",6,["D",1781194212424],1,"http","// vapi-remote-mcp — phone calls Claude can drive live, as a remote MCP server.\n//\n// /mcp remote MCP endpoint (start_call / say / listen / get_status / end_call)\n// /api/call/:action the same tools as plain REST (start, say, listen, status, end)\n// /webhook Vapi server events → SQLite (live transcript feed)\n// /llm/chat/completions the puppet's silent brain: always returns an empty completion\n// / live debug page (?key=MCP_KEY) — watch the call as it happens\n//\n// Auth: /mcp, /api/* take ?key=, x-api-key, or Authorization: Bearer = MCP_KEY.\n// /webhook checks x-vapi-secret (set on the assistant at call creation). /llm is open but harmless.\n\nimport { Hono } from \"npm:hono\";\nimport * as db from \"./db.ts\";\nimport { handleMcp } from \"./mcp.ts\";\nimport { runTool } from \"./tools.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\nconst KEY = () => Deno.env.get(\"MCP_KEY\") ?? \"\";\n\nfunction presentedKey(c: any): string {\n return c.req.query(\"key\")\n ?? c.req.header(\"x-api-key\")\n ?? (c.req.header(\"authorization\") ?? \"\").replace(/^Bearer\\s+/i, \"\");\n}\nconst authed = (c: any) => Boolean(KEY()) && presentedKey(c) === KEY();\nconst origin = (c: any) => new URL(c.req.url).origin;\n\n// ---------- remote MCP ----------\napp.all(\"/mcp\", (c) => {\n if (!authed(c)) return c.json({ error: \"unauthorized — pass ?key=MCP_KEY\" }, 401);\n return handleMcp(c.req.raw, { origin: origin(c) });\n});\n\n// ---------- REST mirror of the tools ----------\nconst REST: Record = {\n start: \"start_call\",\n say: \"say\",\n listen: \"listen\",\n status: \"get_status\",\n end: \"end_call\",\n};\n\napp.all(\"/api/call/:action\", async (c) => {\n if (!authed(c)) return c.json({ error: \"unauthorized\" }, 401);\n const tool = REST[c.req.param(\"action\")];\n if (!tool) return c.json({ error: \"unknown action — use start | say | listen | status | end\" }, 404);\n let args: Record = {};\n if (c.req.method === \"POST\") {\n try {\n args = await c.req.json();\n } catch { /* empty body is fine */ }\n }\n try {\n return c.json({ ok: true, result: await runTool(tool, args, { origin: origin(c) }) });\n } catch (e) {\n return c.json({ ok: false, error: String(e) }, 400);\n }\n});\n\n// state for the debug page\napp.get(\"/api/state\", async (c) => {\n if (!authed(c)) return c.json({ error: \"unauthorized\" }, 401);\n const call = await db.latestCall();\n if (!call) return c.json({ call: null, events: [] });\n const events = await db.recentEvents(call.id, 120);\n return c.json({ call, events });\n});\n\n// ---------- Vapi webhook ----------\napp.post(\"/webhook\", async (c) => {\n if ((c.req.header(\"x-vapi-secret\") ?? \"\") !== KEY()) {\n console.log(\"webhook: bad or missing x-vapi-secret\");\n return c.json({ error: \"bad secret\" }, 401);\n }\n const payload = await c.req.json().catch(() => ({}));\n const m = payload?.message ?? {};\n const callId: string = m?.call?.id ?? (await db.latestCall())?.id ?? \"unknown\";\n console.log(\"webhook:\", m.type, m.status ?? m.transcriptType ?? \"\", String(m.transcript ?? \"\").slice(0, 120));\n\n if (m.type === \"transcript\") {\n if (m.transcriptType === \"final\") {\n await db.addEvent(callId, \"transcript\", m.role ?? \"user\", m.transcript ?? \"\");\n await db.setPartial(callId, null);\n } else {\n await db.setPartial(callId, (m.role ?? \"?\") + \": \" + (m.transcript ?? \"\"));\n }\n } else if (m.type === \"status-update\") {\n await db.setCallStatus(callId, m.status ?? \"unknown\", m.endedReason ?? null);\n await db.addEvent(callId, \"status\", \"system\", String(m.status) + (m.endedReason ? \" (\" + m.endedReason + \")\" : \"\"));\n } else if (m.type === \"end-of-call-report\") {\n await db.setCallStatus(callId, \"ended\", m.endedReason ?? null);\n await db.addEvent(callId, \"report\", \"system\", String(m.summary ?? \"call ended\").slice(0, 600));\n }\n return c.json({});\n});\n\n// ---------- the puppet's silent brain ----------\napp.post(\"/llm/chat/completions\", async (c) => {\n const body = await c.req.json().catch(() => ({}));\n const msgs: Array<{ role: string; content: unknown }> = body?.messages ?? [];\n const lastUser = [...msgs].reverse().find((x) => x.role === \"user\");\n const heard = typeof lastUser?.content === \"string\" ? lastUser.content : JSON.stringify(lastUser?.content ?? \"\");\n console.log(\"llm turn — user said:\", heard.slice(0, 200));\n const call = await db.latestCall();\n if (call && heard) {\n await db.addEvent(call.id, \"your-turn\", \"system\", \"They finished a turn — reply with say.\");\n }\n // Empty completion = the puppet has nothing of its own to say.\n return c.json({\n id: \"puppet-silence\",\n object: \"chat.completion\",\n created: Math.floor(Date.now() / 1000),\n model: String(body?.model ?? \"claude-puppet\"),\n choices: [{ index: 0, message: { role: \"assistant\", content: \"\" }, finish_reason: \"stop\" }],\n usage: { prompt_tokens: 0, completion_tokens: 0, total_tokens: 0 },\n });\n});\n\n// ---------- live debug page ----------\nconst PAGE = `\n\n\nvapi-remote-mcp — live\n\n\n

📞 vapi-remote-mcp no call

\n\n`;\n\napp.get(\"/\", (c) => c.html(PAGE));\n\nexport default app.fetch;\n",[178],"d2359713-1485-428e-a725-e99b0a54b130","db.ts","d3f033e6-65af-11f1-9c42-1607ee4eb77e",2,["D",1781194127417],"// SQLite layer: calls + an append-only event feed per call.\n// The feed is what `listen` long-polls; `cursor` on the call row tracks\n// what the operator has already been shown.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nawait sqlite.batch([\n `CREATE TABLE IF NOT EXISTS calls (\n id TEXT PRIMARY KEY,\n control_url TEXT,\n status TEXT DEFAULT 'starting',\n ended_reason TEXT,\n live_partial TEXT,\n cursor INTEGER DEFAULT 0,\n number TEXT,\n created_at TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS events (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n call_id TEXT,\n type TEXT,\n role TEXT,\n content TEXT,\n created_at TEXT\n )`,\n]);\n\nconst now = () => new Date().toISOString();\n\nexport interface CallRow {\n id: string;\n control_url: string;\n status: string;\n ended_reason: string | null;\n live_partial: string | null;\n cursor: number;\n number: string;\n created_at: string;\n}\n\nexport interface EventRow {\n id: number;\n call_id: string;\n type: string;\n role: string;\n content: string;\n created_at: string;\n}\n\nexport async function insertCall(id: string, controlUrl: string, number: string) {\n await sqlite.execute({\n sql: `INSERT INTO calls (id, control_url, status, cursor, number, created_at) VALUES (?, ?, 'starting', 0, ?, ?)`,\n args: [id, controlUrl, number, now()],\n });\n}\n\nexport async function latestCall(): Promise {\n const r = await sqlite.execute(`SELECT * FROM calls ORDER BY created_at DESC LIMIT 1`);\n return (r.rows[0] as unknown as CallRow) ?? null;\n}\n\nexport async function getCall(id: string): Promise {\n const r = await sqlite.execute({ sql: `SELECT * FROM calls WHERE id = ?`, args: [id] });\n return (r.rows[0] as unknown as CallRow) ?? null;\n}\n\nexport async function setCallStatus(id: string, status: string, endedReason?: string | null) {\n await sqlite.execute({\n sql: `UPDATE calls SET status = ?, ended_reason = COALESCE(?, ended_reason) WHERE id = ?`,\n args: [status, endedReason ?? null, id],\n });\n}\n\nexport async function setPartial(id: string, partial: string | null) {\n await sqlite.execute({ sql: `UPDATE calls SET live_partial = ? WHERE id = ?`, args: [partial, id] });\n}\n\nexport async function setCursor(id: string, cursor: number) {\n await sqlite.execute({ sql: `UPDATE calls SET cursor = ? WHERE id = ?`, args: [cursor, id] });\n}\n\nexport async function addEvent(callId: string, type: string, role: string, content: string) {\n await sqlite.execute({\n sql: `INSERT INTO events (call_id, type, role, content, created_at) VALUES (?, ?, ?, ?, ?)`,\n args: [callId, type, role, content, now()],\n });\n}\n\nexport async function eventsAfter(callId: string, afterId: number): Promise {\n const r = await sqlite.execute({\n sql: `SELECT * FROM events WHERE call_id = ? AND id > ? ORDER BY id ASC`,\n args: [callId, afterId],\n });\n return r.rows as unknown as EventRow[];\n}\n\nexport async function recentEvents(callId: string, limit = 100): Promise {\n const r = await sqlite.execute({\n sql: `SELECT * FROM events WHERE call_id = ? ORDER BY id DESC LIMIT ?`,\n args: [callId, limit],\n });\n return (r.rows as unknown as EventRow[]).reverse();\n}\n",[186],"4f39ec25-d7a7-4e03-b0c5-c806f1d6feef",["D",1781194232612],[28],"pulls","branches","forks","envVars",{"_202":95,"_204":63},"connections",{"_202":63,"_203":63},"count","unfilledCount","emptyCount",{"_42":192,"_32":28,"_30":31,"_156":-5,"_40":41,"_39":14,"_158":25,"_37":227,"_13":181,"_33":20,"_34":36,"_24":25,"_162":-5,"_212":228,"_27":229},{"_42":185,"_32":186,"_30":187,"_156":-5,"_40":41,"_39":188,"_158":59,"_37":224,"_13":63,"_33":160,"_34":190,"_24":25,"_162":-5,"_212":225,"_27":226},{"_42":177,"_32":178,"_30":57,"_156":-5,"_40":41,"_39":179,"_158":59,"_37":221,"_13":181,"_33":182,"_34":183,"_24":25,"_162":-5,"_212":222,"_27":223},{"_42":170,"_32":171,"_30":172,"_156":-5,"_40":41,"_39":173,"_158":59,"_37":218,"_13":63,"_33":160,"_34":175,"_24":25,"_162":-5,"_212":219,"_27":220},{"_42":164,"_32":165,"_30":166,"_156":-5,"_40":41,"_39":95,"_158":59,"_37":215,"_13":63,"_33":160,"_34":168,"_24":25,"_162":-5,"_212":216,"_27":217},{"_42":153,"_32":154,"_30":155,"_156":-5,"_40":41,"_39":157,"_158":25,"_37":211,"_13":63,"_33":160,"_34":161,"_24":25,"_162":-5,"_212":213,"_27":214},["D",1781194138598],"children",[],[154],["D",1781194165506],[],[165],["D",1781194176907],[],[171],["D",1781194212424],[],[178],["D",1781194127417],[],[186],["D",1781194232612],[],[28],["D",1781193945555],["D",1789494036282],{"_104":103,"_112":108},{"_104":103,"_105":106,"_107":108,"_18":55,"_109":110,"_111":25},{"_13":89,"_32":90,"_42":41,"_91":43,"_92":93,"_94":95,"_96":49,"_97":98,"_99":100,"_101":44,"_102":103},"ctx",{"_82":-5,"_134":268,"_269":270,"_271":272,"_273":25,"_274":25,"_275":25,"_276":59,"_277":-5,"_278":-7,"_279":-7,"_280":63,"_281":25,"_282":25,"_283":-5,"_284":25,"_285":25,"_286":25,"_287":-5},"ENV",{"_239":240,"_241":242,"_243":90,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263,"_264":265,"_266":267},"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 · v7