[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_234":235,"_236":237},"routes/_app.x.$handle.$name",{"_104":103,"_32":45,"_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",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":55,"_18":56,"_57":31,"_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",6,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","019eb76e-b243-71fd-8ce7-4920e76677d7","name","fileType","http","content","// The simplest Vapi demo: one fetch to api.vapi.ai/call and your phone rings.\n// Setup is two env vars from https://dashboard.vapi.ai — see README.md.\n\nconst FIRST_MESSAGE = \"Hey! This is a demo call from a val. How's your day going?\";\nconst SYSTEM_PROMPT =\n \"You're a friendly voice assistant on a short demo call. Keep every reply to one or two casual sentences.\";\n\n// gpt-4o through Vapi's standard pipeline sounds clean on free Vapi numbers;\n// native realtime models need an imported Twilio number to sound right.\nconst MODEL = \"gpt-4o\";\nconst VOICE = \"shimmer\";\n\nasync function placeCall(number: string) {\n const res = await fetch(\"https://api.vapi.ai/call\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${Deno.env.get(\"VAPI_API_KEY\")}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n phoneNumberId: Deno.env.get(\"VAPI_PHONE_NUMBER_ID\"),\n customer: { number }, // E.164, e.g. +15551234567\n assistant: {\n firstMessage: FIRST_MESSAGE,\n model: { provider: \"openai\", model: MODEL, messages: [{ role: \"system\", content: SYSTEM_PROMPT }] },\n voice: { provider: \"openai\", voiceId: VOICE },\n },\n }),\n });\n const data = await res.json();\n if (!res.ok) throw new Error(`Vapi ${res.status}: ${JSON.stringify(data)}`);\n return data;\n}\n\nconst esc = (s: string) => s.replace(/[&<>\"]/g, (c) => ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\", '\"': \""\" }[c] ?? c));\n\nfunction page(body: string) {\n return new Response(\n `\n\n\nAI phone call\n\n

📞 AI phone call

\n${body}\n`,\n { headers: { \"content-type\": \"text/html\" } },\n );\n}\n\nconst FORM = `\n

Enter a number and Vapi rings it — an AI (${MODEL}) chats with whoever picks up.

\n`;\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") return page(FORM);\n if (!Deno.env.get(\"VAPI_API_KEY\") || !Deno.env.get(\"VAPI_PHONE_NUMBER_ID\")) {\n return page(`

⚠️ Set the VAPI_API_KEY and VAPI_PHONE_NUMBER_ID env vars first — see README.md.

`);\n }\n const number = String((await req.formData()).get(\"number\") ?? \"\").trim();\n try {\n const call = await placeCall(number);\n return page(`

☎️ Calling ${esc(number)}… (call ${esc(String(call.id ?? \"\"))})

Make another call

`);\n } catch (e) {\n return page(`

❌ ${esc(String(e))}

Try again

`);\n }\n}\n","// 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","createdAt",["D",1781194212424],"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=1789545599&sig=b2a66e91e83c62bfaba4414598dd42cdb9043aa864f313b13d0365e152e3088e","9319c175-2593-4f88-ba21-04f2ef7b1c28","pinnedFileId","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":56,"_109":110,"_111":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":93,"_94":95,"_96":50,"_97":98,"_99":100,"_101":45,"_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=1789545599&sig=a8da35ef71655bebef6a4600a21351bd7f28e3bed5ff684593eef639c5d17466","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":229,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":55,"_18":56,"_57":31,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":230,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":231,"_84":232,"_86":233,"_88":25},"tree",[204,205,206,207,208,209],"files",[204,205,206,207,208,209],"counts",{"_194":63,"_195":179,"_196":179,"_197":198,"_199":200},"contents",[147,148,149,150,151,152],"upstreamProject",{"_43":98,"_32":144,"_52":53,"_54":55,"_49":50,"_82":145},"upstreamBranch",{"_43":93,"_38":137,"_138":139,"_32":90,"_91":98,"_13":140,"_92":-5,"_94":-5,"_141":142,"_47":-5,"_88":25,"_49":50,"_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=1789545599&sig=2316df07e67031dd48e537f6ce0c4c14b92716fed790ec83ecf27974cc65aa31",{"_43":188,"_32":189,"_30":190,"_156":-5,"_41":42,"_40":179,"_158":25,"_38":191,"_13":63,"_33":20,"_35":192,"_24":25,"_162":-5,"_27":193},{"_43":181,"_32":182,"_30":183,"_156":-5,"_41":42,"_40":184,"_158":59,"_38":185,"_13":63,"_33":160,"_35":186,"_24":25,"_162":-5,"_27":187},{"_43":177,"_32":28,"_30":31,"_156":-5,"_41":42,"_40":14,"_158":59,"_38":178,"_13":179,"_33":34,"_35":37,"_24":25,"_162":-5,"_27":180},{"_43":170,"_32":171,"_30":172,"_156":-5,"_41":42,"_40":173,"_158":59,"_38":174,"_13":63,"_33":160,"_35":175,"_24":25,"_162":-5,"_27":176},{"_43":164,"_32":165,"_30":166,"_156":-5,"_41":42,"_40":95,"_158":59,"_38":167,"_13":63,"_33":160,"_35":168,"_24":25,"_162":-5,"_27":169},{"_43":153,"_32":154,"_30":155,"_156":-5,"_41":42,"_40":157,"_158":25,"_38":159,"_13":63,"_33":160,"_35":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",["D",1781194212424],1,[28],"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",[182],"30f9f05b-d0f2-4bb1-acc0-64cabf16f2c5","README.md","019eb76e-b242-72f9-ad38-207faf17e107",["D",1781193945555],"# 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",[189],"pulls","branches","forks","envVars",{"_201":95,"_203":63},"connections",{"_201":63,"_202":63},"count","unfilledCount","emptyCount",{"_43":188,"_32":189,"_30":190,"_156":-5,"_41":42,"_40":179,"_158":25,"_38":226,"_13":63,"_33":20,"_35":192,"_24":25,"_162":-5,"_211":227,"_27":228},{"_43":181,"_32":182,"_30":183,"_156":-5,"_41":42,"_40":184,"_158":59,"_38":223,"_13":63,"_33":160,"_35":186,"_24":25,"_162":-5,"_211":224,"_27":225},{"_43":177,"_32":28,"_30":31,"_156":-5,"_41":42,"_40":14,"_158":59,"_38":220,"_13":179,"_33":34,"_35":37,"_24":25,"_162":-5,"_211":221,"_27":222},{"_43":170,"_32":171,"_30":172,"_156":-5,"_41":42,"_40":173,"_158":59,"_38":217,"_13":63,"_33":160,"_35":175,"_24":25,"_162":-5,"_211":218,"_27":219},{"_43":164,"_32":165,"_30":166,"_156":-5,"_41":42,"_40":95,"_158":59,"_38":214,"_13":63,"_33":160,"_35":168,"_24":25,"_162":-5,"_211":215,"_27":216},{"_43":153,"_32":154,"_30":155,"_156":-5,"_41":42,"_40":157,"_158":25,"_38":210,"_13":63,"_33":160,"_35":161,"_24":25,"_162":-5,"_211":212,"_27":213},["D",1781194138598],"children",[],[154],["D",1781194165506],[],[165],["D",1781194176907],[],[171],["D",1781194212424],[],[28],["D",1781194127417],[],[182],["D",1781193945555],[],[189],["D",1781193945555],["D",1789494036282],{"_104":103,"_112":108},{"_104":103,"_105":106,"_107":108,"_18":56,"_109":110,"_111":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":93,"_94":95,"_96":50,"_97":98,"_99":100,"_101":45,"_102":103},"ctx",{"_82":-5,"_134":267,"_268":269,"_270":271,"_272":25,"_273":25,"_274":25,"_275":59,"_276":-5,"_277":-7,"_278":-7,"_279":63,"_280":25,"_281":25,"_282":-5,"_283":25,"_284":25,"_285":25,"_286":-5},"ENV",{"_238":239,"_240":241,"_242":90,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266},"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 · v6