[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_231":232,"_233":234},"routes/_app.x.$handle.$name",{"_103":102,"_31":43,"_112":89,"_26":113,"_13":14,"_114":-5,"_11":115,"_116":117,"_118":119,"_120":121,"_122":123,"_20":-5,"_124":125,"_126":127,"_128":24,"_129":130,"_131":58,"_132":-5,"_133":-5,"_134":135},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":53,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":24},"version",5,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","mcp.ts","latestPath","fileId","f16ad1ba-65af-11f1-ab94-1607ee4eb77e","name","fileType","script","content","// 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","createdAt",["D",1781194176907],"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","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",{"_103":102,"_111":107},"org",{"_103":102,"_104":105,"_106":107,"_18":54,"_108":109,"_110":24},"branch",{"_13":88,"_31":89,"_41":40,"_90":42,"_91":92,"_93":94,"_95":48,"_96":97,"_98":99,"_100":43,"_101":102},"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",{"_41":42,"_31":43,"_36":226,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":53,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":227,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":228,"_83":229,"_85":230,"_87":24},"tree",[201,202,203,204,205,206],"files",[201,202,203,204,205,206],"counts",{"_191":62,"_192":173,"_193":173,"_194":195,"_196":197},"contents",[146,147,148,149,150,151],"upstreamProject",{"_41":97,"_31":143,"_50":51,"_52":53,"_47":48,"_81":144},"upstreamBranch",{"_41":92,"_36":136,"_137":138,"_31":89,"_90":97,"_13":139,"_91":-5,"_93":-5,"_140":141,"_45":-5,"_87":24,"_47":48,"_101":142,"_63":99,"_100":143},"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",{"_103":142,"_111":145},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789545599&sig=2316df07e67031dd48e537f6ce0c4c14b92716fed790ec83ecf27974cc65aa31",{"_41":185,"_31":186,"_29":187,"_155":-5,"_39":40,"_38":173,"_157":24,"_36":188,"_13":62,"_32":20,"_34":189,"_23":24,"_160":-5,"_26":190},{"_41":178,"_31":179,"_29":180,"_155":-5,"_39":40,"_38":181,"_157":58,"_36":182,"_13":62,"_32":33,"_34":183,"_23":24,"_160":-5,"_26":184},{"_41":171,"_31":172,"_29":56,"_155":-5,"_39":40,"_38":173,"_157":24,"_36":174,"_13":62,"_32":175,"_34":176,"_23":24,"_160":-5,"_26":177},{"_41":168,"_31":27,"_29":30,"_155":-5,"_39":40,"_38":14,"_157":58,"_36":169,"_13":62,"_32":33,"_34":35,"_23":24,"_160":-5,"_26":170},{"_41":162,"_31":163,"_29":164,"_155":-5,"_39":40,"_38":94,"_157":58,"_36":165,"_13":62,"_32":33,"_34":166,"_23":24,"_160":-5,"_26":167},{"_41":152,"_31":153,"_29":154,"_155":-5,"_39":40,"_38":156,"_157":24,"_36":158,"_13":62,"_32":33,"_34":159,"_23":24,"_160":-5,"_26":161},"a8b9ebfe-c448-4888-a05e-565a0db9c219","vapi.ts","da970490-65af-11f1-833a-1607ee4eb77e","parentId",3,"latest",["D",1781194138598],"// 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",[153],"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",[163],"c16afbc4-eec8-4ba9-bf0c-b7cdd8a70f21",["D",1781194176907],[27],"97ca52fa-3f6c-4099-a998-cc991fe68b09","main.ts",1,["D",1781193945555],"http","// 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",[172],"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",[179],"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",[186],"pulls","branches","forks","envVars",{"_198":94,"_200":62},"connections",{"_198":62,"_199":62},"count","unfilledCount","emptyCount",{"_41":185,"_31":186,"_29":187,"_155":-5,"_39":40,"_38":173,"_157":24,"_36":223,"_13":62,"_32":20,"_34":189,"_23":24,"_160":-5,"_208":224,"_26":225},{"_41":178,"_31":179,"_29":180,"_155":-5,"_39":40,"_38":181,"_157":58,"_36":220,"_13":62,"_32":33,"_34":183,"_23":24,"_160":-5,"_208":221,"_26":222},{"_41":171,"_31":172,"_29":56,"_155":-5,"_39":40,"_38":173,"_157":24,"_36":217,"_13":62,"_32":175,"_34":176,"_23":24,"_160":-5,"_208":218,"_26":219},{"_41":168,"_31":27,"_29":30,"_155":-5,"_39":40,"_38":14,"_157":58,"_36":214,"_13":62,"_32":33,"_34":35,"_23":24,"_160":-5,"_208":215,"_26":216},{"_41":162,"_31":163,"_29":164,"_155":-5,"_39":40,"_38":94,"_157":58,"_36":211,"_13":62,"_32":33,"_34":166,"_23":24,"_160":-5,"_208":212,"_26":213},{"_41":152,"_31":153,"_29":154,"_155":-5,"_39":40,"_38":156,"_157":24,"_36":207,"_13":62,"_32":33,"_34":159,"_23":24,"_160":-5,"_208":209,"_26":210},["D",1781194138598],"children",[],[153],["D",1781194165506],[],[163],["D",1781194176907],[],[27],["D",1781193945555],[],[172],["D",1781194127417],[],[179],["D",1781193945555],[],[186],["D",1781193945555],["D",1789494036282],{"_103":102,"_111":107},{"_103":102,"_104":105,"_106":107,"_18":54,"_108":109,"_110":24},{"_13":88,"_31":89,"_41":40,"_90":42,"_91":92,"_93":94,"_95":48,"_96":97,"_98":99,"_100":43,"_101":102},"ctx",{"_81":-5,"_133":264,"_265":266,"_267":268,"_269":24,"_270":24,"_271":24,"_272":58,"_273":-5,"_274":-7,"_275":-7,"_276":62,"_277":24,"_278":24,"_279":-5,"_280":24,"_281":24,"_282":24,"_283":-5},"ENV",{"_235":236,"_237":238,"_239":89,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263},"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 · v5