📞 dispatch-my-human no call

\n\n`;\n\napp.get(\"/\", (c) => {\n if (c.req.query(\"t\")) return c.html(PAGE);\n return c.text(landing(new URL(c.req.url).origin));\n});\n\nexport default app.fetch;\n",[121],"3aa76144609f42b0fb9276c72ea7fb37ce5cecc6f6372910e6d0fd6d1d6a005f","d8998367-4057-4d9f-b069-188df6ddc795","019ec8e3-8fe9-75a2-9f23-e932794ecdea",15,["D",1781487178890],"// dispatch-my-human — a PUBLIC remote MCP server that dispatches an autonomous\n// voice agent to phone your human, handle the conversation itself, and report back.\n// Unlike the puppet sibling (call-my-human), the Vapi agent here has a REAL brain:\n// it runs the whole call in-stack (low latency, no per-turn round-trip), then Vapi's\n// post-call analysis returns a structured report.\n// BYOK: connecting users pass their own Vapi creds in the connection URL.\n// No env vars, no server-side keys, no signup.\n//\n// /mcp?vapi_key=…&phone_number_id=…&human_number=%2B1555… ← connect here\n// /api/call/:action same tools as REST (dispatch, report, listen, say, status, end)\n// /webhook/:tenant Vapi server events → SQLite (transcripts + end-of-call analysis)\n// / plain GET = setup instructions; /?t= = live transcript feed\n//\n// A tenant is a short hash of the caller's Vapi key — it scopes call state per user\n// and routes Vapi's webhooks back to the right feed. Keys are never stored.\n\nimport { Hono } from \"npm:hono\";\nimport * as db from \"./db.ts\";\nimport { handleMcp } from \"./mcp.ts\";\nimport { type Ctx, runTool } from \"./tools.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\nasync function tenantOf(key: string): Promise {\n const d = await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(key));\n return [...new Uint8Array(d)].slice(0, 6).map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nasync function buildCtx(c: any): Promise {\n const q = (k: string) => c.req.query(k) || null;\n const bearer = (c.req.header(\"authorization\") ?? \"\").replace(/^Bearer\\s+/i, \"\") || null;\n const vapiKey = q(\"vapi_key\") ?? bearer;\n return {\n origin: new URL(c.req.url).origin,\n vapiKey,\n phoneNumberId: q(\"phone_number_id\"),\n humanNumber: q(\"human_number\"),\n model: q(\"model\") || \"gpt-4o\", // the agent's brain; override with &model= in the URL\n tenant: vapiKey ? await tenantOf(vapiKey) : null,\n };\n}\n\n// ---------- remote MCP ----------\napp.all(\"/mcp\", async (c) => handleMcp(c.req.raw, await buildCtx(c)));\n\n// ---------- REST mirror of the tools ----------\nconst REST: Record = {\n dispatch: \"dispatch_call\",\n report: \"await_report\",\n answer: \"provide_answer\",\n listen: \"listen\",\n say: \"say\",\n status: \"get_status\",\n end: \"end_call\",\n};\n\napp.all(\"/api/call/:action\", async (c) => {\n const tool = REST[c.req.param(\"action\")];\n if (!tool) return c.json({ error: \"unknown action — use dispatch | report | answer | listen | say | 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, await buildCtx(c)) });\n } catch (e) {\n return c.json({ ok: false, error: String(e) }, 400);\n }\n});\n\n// state for the live feed page (tenant id is required — it is unguessable without the key)\napp.get(\"/api/state\", async (c) => {\n const t = c.req.query(\"t\");\n if (!t) return c.json({ error: \"pass ?t= (shown in start_call/get_status results)\" }, 400);\n const call = await db.latestCall(t);\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 (per tenant) ----------\napp.post(\"/webhook/:tenant\", async (c) => {\n const tenant = c.req.param(\"tenant\");\n if ((c.req.header(\"x-vapi-secret\") ?? \"\") !== tenant) {\n console.log(\"webhook: bad or missing x-vapi-secret for tenant\", tenant);\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(tenant))?.id ?? \"unknown\";\n console.log(\"webhook:\", tenant, m.type, m.status ?? m.transcriptType ?? \"\", String(m.transcript ?? \"\").slice(0, 120));\n\n const mtype = String(m.type ?? \"\");\n if (mtype.startsWith(\"transcript\")) {\n // type is \"transcript\" or the documented variant 'transcript[transcriptType=\"final\"]'\n const ttype = m.transcriptType ?? (mtype.includes(\"final\") ? \"final\" : \"partial\");\n if (ttype === \"final\") {\n await db.addEvent(tenant, 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 (mtype === \"conversation-update\") {\n // Fallback transcript source: backfill any user lines the transcript events missed.\n const conv = (m.conversation ?? m.messages ?? []) as Array>;\n const users = conv\n .filter((x) => x.role === \"user\")\n .map((x) => String(x.message ?? x.content ?? \"\"))\n .filter(Boolean);\n if (users.length) {\n const seen = new Set(\n (await db.recentEvents(callId, 80))\n .filter((e) => e.type === \"transcript\" && e.role === \"user\")\n .map((e) => e.content),\n );\n for (const u of users) {\n if (!seen.has(u)) {\n await db.addEvent(tenant, callId, \"transcript\", \"user\", u);\n seen.add(u);\n }\n }\n }\n } else if (mtype === \"status-update\") {\n await db.setCallStatus(callId, m.status ?? \"unknown\", m.endedReason ?? null);\n await db.addEvent(tenant, callId, \"status\", \"system\", String(m.status) + (m.endedReason ? \" (\" + m.endedReason + \")\" : \"\"));\n } else if (mtype === \"end-of-call-report\") {\n // Analysis (summary + structuredData) is computed at end-of-call and rides\n // along in this report. await_report waits for the \"analysis\" event below.\n await db.setCallStatus(callId, \"ended\", m.endedReason ?? null);\n const analysis = m?.analysis ?? {};\n const summary = analysis.summary ?? m.summary ?? \"call ended\";\n await db.addEvent(tenant, callId, \"report\", \"system\", String(summary).slice(0, 1000));\n if (analysis.structuredData !== undefined && analysis.structuredData !== null) {\n await db.addEvent(tenant, callId, \"analysis\", \"system\", JSON.stringify(analysis.structuredData));\n }\n }\n return c.json({});\n});\n\n// ---------- escape hatch: blocking tool endpoint (per tenant) ----------\n// The agent calls ask_operator; Vapi POSTs here and waits up to the tool's\n// server timeout. We record the question, then block until the operator answers\n// via provide_answer (or we time out), and return the answer as the tool result.\napp.post(\"/tool/:tenant\", async (c) => {\n const tenant = c.req.param(\"tenant\");\n const secret = c.req.header(\"x-vapi-secret\") ?? \"\";\n if (secret && secret !== tenant) {\n console.log(\"tool: bad x-vapi-secret for tenant\", tenant);\n return c.json({ error: \"bad secret\" }, 401);\n }\n const payload = await c.req.json().catch(() => ({}));\n const m = payload?.message ?? {};\n const tc = (m.toolCallList ?? [])[0] ?? {};\n const toolCallId: string = tc.id ?? tc.toolCall?.id ?? \"unknown\";\n // Vapi may send arguments as an object OR a JSON string, and under .arguments\n // or .function.arguments depending on shape — handle all of them.\n let rawArgs: unknown = tc.arguments ?? tc.function?.arguments ?? tc.toolCall?.function?.arguments ?? {};\n if (typeof rawArgs === \"string\") {\n try { rawArgs = JSON.parse(rawArgs); } catch { rawArgs = {}; }\n }\n const a = (rawArgs ?? {}) as Record;\n const question = String(a.question ?? a.q ?? \"\").trim() || \"(the agent asked for help but gave no question)\";\n const callId: string = m?.call?.id ?? (await db.latestCall(tenant))?.id ?? \"unknown\";\n console.log(\"tool ask_operator:\", tenant, toolCallId, question.slice(0, 160));\n\n const escId = await db.insertEscalation(tenant, callId, toolCallId, question);\n await db.addEvent(tenant, callId, \"escalation\", \"system\", question);\n\n // Block until the operator answers (provide_answer) — stay under the tool's 45s timeout.\n const deadline = Date.now() + 42_000;\n while (Date.now() < deadline) {\n const esc = await db.getEscalation(escId);\n if (esc?.answer != null) {\n await db.addEvent(tenant, callId, \"answer\", \"assistant\", esc.answer);\n return c.json({ results: [{ toolCallId, result: esc.answer }] });\n }\n await new Promise((r) => setTimeout(r, 700));\n }\n // No operator answer in time — clear the pending flag and hand the agent a graceful line.\n await db.answerEscalation(escId, \"(timed out — operator did not answer in time)\");\n await db.addEvent(tenant, callId, \"escalation\", \"system\", \"(no operator answer in time — agent moved on)\");\n return c.json({\n results: [{\n toolCallId,\n result: \"I couldn't reach my operator on that just now — let's keep going and I'll have them follow up.\",\n }],\n });\n});\n\n// ---------- landing + live feed ----------\nfunction landing(origin: string): string {\n return `dispatch-my-human — send an agent to phone your human (public remote MCP server)\n\nDispatch an autonomous voice agent to call your human, run the whole\nconversation itself, and hand you back a structured report. You brief it once\n(objective + context + questions); it talks, hangs up, and you collect the\nresult. The agent has a real LLM brain running in-stack, so the call is\nlow-latency and natural — you don't drive it turn by turn.\n\nTools: dispatch_call · await_report · listen · say · get_status · end_call.\nThe headline loop is just dispatch_call → await_report. listen/say are optional\nsupervisor hooks (eavesdrop on, or barge into, a live call).\n\nBring your own keys from https://dashboard.vapi.ai (private key + phone number ID).\nThe agent's brain uses your Vapi account's bundled OpenAI model (gpt-4o by\ndefault; override with &model=). No extra LLM key needed for OpenAI models.\n\nConnect from Claude Code:\n\n claude mcp add --transport http dispatch-my-human \\\\\n \"${origin}/mcp?vapi_key=YOUR_KEY&phone_number_id=YOUR_PHONE_ID&human_number=%2B15551234567\"\n\nNo MCP client? The tools speak plain REST with the same query params:\n POST ${origin}/api/call/dispatch {\"objective\": \"...\", \"context\": \"...\", \"questions\": [\"...\"]}\n POST ${origin}/api/call/report {\"wait_seconds\": 25} (long-polls; use a 35s timeout, repeat until done:true)\n POST ${origin}/api/call/listen {\"wait_seconds\": 25} (optional: eavesdrop live)\n POST ${origin}/api/call/say {\"text\": \"...\", \"end_call_after\": false} (optional: barge in)\n POST ${origin}/api/call/status · POST ${origin}/api/call/end\n\nNotes:\n • human_number is the default number dispatch_call dials — your cell. The +\n MUST be URL-encoded as %2B.\n • Works in any MCP client that takes a URL (claude.ai custom connectors too).\n • Watch a call live: dispatch_call returns a watch_url.\n • Free Vapi numbers are flaky (occasional dead bridges, a DAILY outbound\n limit). Import a Twilio number into Vapi for reliability.\n • Privacy: your key is read per-request and never stored. Call transcripts\n and reports ARE stored in this val's SQLite, scoped to a hash of your key.\n Want full custody? Remix this val — it has no other config.\n\nSibling: dcm31/call-my-human is the puppet version (you drive every word).\nSource + README: https://www.val.town/x/dcm31/dispatch-my-human\n`;\n}\n\nconst PAGE = `\n\n\ndispatch-my-human — live\n\n\n

📞 dispatch-my-human no call

\n\n`;\n\napp.get(\"/\", (c) => {\n if (c.req.query(\"t\")) return c.html(PAGE);\n return c.text(landing(new URL(c.req.url).origin));\n});\n\nexport default app.fetch;\n",[121],"c779f83392a51a1c360f60b1420c7ab9bc53534983630678cffc126afe422e43",["D",1781486817181],"legacyEnvVars","httpPrivacy","description","Public remote MCP: your agent phones you. BYO Vapi keys, no env.","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/e638c970-aa12-42a0-ac97-631720749000/square512?exp=1789538399&sig=b574d59f3ce72883c37701b86b525644a13dbc14dae4664476356d12a8447f58","userId","9319c175-2593-4f88-ba21-04f2ef7b1c28","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"tursoName","f8ce04b714714c488b9d3105b5ad1b75","tursoHostname","f8ce04b714714c488b9d3105b5ad1b75-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789509672838],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_183":179},"org",{"_11":12,"_176":177,"_178":179,"_147":148,"_180":181,"_182":51},"branch","displayName","Charlie","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/3e904faa-3764-4629-c475-f561a49b0000/square512?exp=1789538399&sig=83566187000d9e503ce3f44b6a102e11c71d18c14c583824b36dc207748badf5","tier","pro","canRestrictVals","profileImageUrl","","adoptOrgId",{"_32":40,"_13":14,"_34":275,"_49":-5,"_141":51,"_52":53,"_142":53,"_143":144,"_145":146,"_147":148,"_149":134,"_150":26,"_151":-5,"_152":-5,"_153":154,"_55":56,"_155":156,"_157":158,"_159":276,"_161":-5,"_162":163,"_164":163,"_165":166,"_167":166,"_168":166,"_169":163,"_170":163,"_171":277,"_173":278,"_175":279,"_50":51},"tree",[254,255,256,257,258,259],"files",[254,255,256,257,258,259],"counts",{"_244":154,"_245":101,"_246":154,"_247":248,"_249":250},"contents",[214,215,216,217,218,219],"file","upstreamProject",{"_32":210,"_13":211,"_143":212,"_145":184,"_52":53,"_171":213},"upstreamBranch",{"_32":33,"_34":208,"_36":209,"_13":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":-5,"_50":51,"_52":53,"_54":12,"_55":56,"_57":14},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1781486817181],["D",1787611872489],"115c4677-1932-4e3d-a81a-e71d5939f255","call-my-human","Public remote MCP: your agent phones you. BYO Vapi keys",{"_11":12,"_183":179},{"_32":238,"_13":239,"_80":240,"_82":-5,"_83":59,"_84":128,"_86":26,"_34":241,"_41":154,"_89":195,"_91":242,"_66":51,"_93":-5,"_73":243},{"_32":232,"_13":233,"_80":234,"_82":-5,"_83":59,"_84":128,"_86":26,"_34":235,"_41":154,"_89":90,"_91":236,"_66":51,"_93":-5,"_73":237},{"_32":124,"_13":121,"_80":125,"_82":-5,"_83":59,"_84":126,"_86":26,"_34":230,"_41":128,"_89":129,"_91":130,"_66":51,"_93":-5,"_73":231},{"_32":224,"_13":225,"_80":226,"_82":-5,"_83":59,"_84":128,"_86":26,"_34":227,"_41":154,"_89":90,"_91":228,"_66":51,"_93":-5,"_73":229},{"_32":108,"_13":105,"_80":109,"_82":-5,"_83":59,"_84":58,"_86":26,"_34":222,"_41":85,"_89":90,"_91":111,"_66":51,"_93":-5,"_73":223},{"_32":79,"_13":74,"_80":81,"_82":-5,"_83":59,"_84":85,"_86":26,"_34":220,"_41":88,"_89":90,"_91":92,"_66":51,"_93":-5,"_73":221},["D",1781488729407],[74],["D",1781489854992],[105],"4fb5d04e-67be-44c6-bbab-181608e93351","mcp.ts","019ec8ff-b70b-705e-aff8-9df2f2aee4ef",["D",1781488662285],"// 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 `dispatch-my-human-escape: dispatch an autonomous voice agent to phone your human and run the call itself — WITH an escape hatch back to you.\nThe agent has a REAL brain and drives the conversation. But when the human asks something outside its brief, it calls for backup and the call PAUSES until YOU answer.\nPrimary loop:\n 1. dispatch_call({ objective, context?, questions?, number?, first_message?, max_minutes? }) — hand off the call.\n 2. await_report({ wait_seconds }) — long-polls. It returns ONE of:\n • needs_answer:true with an { escalation: { question } } — the agent is stuck on an off-brief question. Reply with provide_answer({ text }), then call await_report again.\n • done:true with { summary, objective_met, answers[], followups, transcript } — the call is over.\n 3. provide_answer({ text }) — your answer is fed back to the agent (a \"let me check on that\" plays for the human meanwhile) and it relays it in its own words.\nGive a crisp objective, dump context, and list the questions you want answered. Optional: listen (eavesdrop), say (barge in), get_status, end_call.\nSetup: connection URL needs vapi_key and phone_number_id (and ideally human_number, E.164 with + as %2B) from dashboard.vapi.ai. Brain runs on your Vapi OpenAI model (gpt-4o default; &model= to override).`;\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, \"tenant:\", ctx.tenant ?? \"none\");\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: \"dispatch-my-human-escape\", version: \"1.0.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(\"call-my-human: POST JSON-RPC here (stateless streamable HTTP MCP). GET / for setup.\", {\n status: 405,\n });\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",[225],["D",1781488743551],[121],"eb37fa2b-5a05-4337-a408-b0195ed1d8c7","db.ts","019ec8ff-b70b-705e-aff8-9775ffb4795b",["D",1781488662285],"// SQLite layer: calls + an append-only event feed per call, scoped by tenant.\n// A tenant is a short hash of the caller's Vapi key — every connecting user\n// gets their own call history on this shared public server.\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 tenant TEXT,\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 tenant TEXT,\n call_id TEXT,\n type TEXT,\n role TEXT,\n content TEXT,\n created_at TEXT\n )`,\n // Escape hatch: a mid-call question the agent routes to the operator. The\n // blocking /tool endpoint inserts a row and waits for `answer` to be filled.\n `CREATE TABLE IF NOT EXISTS escalations (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n tenant TEXT,\n call_id TEXT,\n tool_call_id TEXT,\n question TEXT,\n answer TEXT,\n created_at TEXT,\n answered_at TEXT\n )`,\n]);\n// Remixed schema may predate the tenant column — add it if missing.\ntry {\n await sqlite.execute(`ALTER TABLE calls ADD COLUMN tenant TEXT`);\n} catch { /* already there */ }\ntry {\n await sqlite.execute(`ALTER TABLE events ADD COLUMN tenant TEXT`);\n} catch { /* already there */ }\n\nconst now = () => new Date().toISOString();\n\nexport interface CallRow {\n id: string;\n tenant: 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 tenant: string;\n call_id: string;\n type: string;\n role: string;\n content: string;\n created_at: string;\n}\n\nexport async function insertCall(tenant: string, id: string, controlUrl: string, number: string) {\n await sqlite.execute({\n sql: `INSERT INTO calls (id, tenant, control_url, status, cursor, number, created_at)\n VALUES (?, ?, ?, 'starting', 0, ?, ?)`,\n args: [id, tenant, controlUrl, number, now()],\n });\n}\n\nexport async function latestCall(tenant: string): Promise {\n const r = await sqlite.execute({\n sql: `SELECT * FROM calls WHERE tenant = ? ORDER BY created_at DESC LIMIT 1`,\n args: [tenant],\n });\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(tenant: string, callId: string, type: string, role: string, content: string) {\n await sqlite.execute({\n sql: `INSERT INTO events (tenant, call_id, type, role, content, created_at) VALUES (?, ?, ?, ?, ?, ?)`,\n args: [tenant, 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 hasTranscript(callId: string): Promise {\n const r = await sqlite.execute({\n sql: `SELECT 1 FROM events WHERE call_id = ? AND type = 'transcript' LIMIT 1`,\n args: [callId],\n });\n return r.rows.length > 0;\n}\n\nexport async function latestEventOfType(callId: string, type: string): Promise {\n const r = await sqlite.execute({\n sql: `SELECT * FROM events WHERE call_id = ? AND type = ? ORDER BY id DESC LIMIT 1`,\n args: [callId, type],\n });\n return (r.rows[0] as unknown as EventRow) ?? null;\n}\n\nexport async function transcriptLines(callId: string, limit = 200): Promise {\n const r = await sqlite.execute({\n sql: `SELECT * FROM events WHERE call_id = ? AND type = 'transcript' ORDER BY id ASC LIMIT ?`,\n args: [callId, limit],\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\n// ---------- escalations (the escape hatch) ----------\n\nexport interface EscalationRow {\n id: number;\n tenant: string;\n call_id: string;\n tool_call_id: string;\n question: string;\n answer: string | null;\n created_at: string;\n answered_at: string | null;\n}\n\nexport async function insertEscalation(\n tenant: string,\n callId: string,\n toolCallId: string,\n question: string,\n): Promise {\n const r = await sqlite.execute({\n sql: `INSERT INTO escalations (tenant, call_id, tool_call_id, question, created_at)\n VALUES (?, ?, ?, ?, ?) RETURNING id`,\n args: [tenant, callId, toolCallId, question, now()],\n });\n return Number((r.rows[0] as unknown as { id: number }).id);\n}\n\nexport async function getEscalation(id: number): Promise {\n const r = await sqlite.execute({ sql: `SELECT * FROM escalations WHERE id = ?`, args: [id] });\n return (r.rows[0] as unknown as EscalationRow) ?? null;\n}\n\n// The oldest still-unanswered question for this tenant (FIFO).\nexport async function pendingEscalation(tenant: string): Promise {\n const r = await sqlite.execute({\n sql: `SELECT * FROM escalations WHERE tenant = ? AND answer IS NULL ORDER BY id ASC LIMIT 1`,\n args: [tenant],\n });\n return (r.rows[0] as unknown as EscalationRow) ?? null;\n}\n\nexport async function answerEscalation(id: number, answer: string) {\n await sqlite.execute({\n sql: `UPDATE escalations SET answer = ?, answered_at = ? WHERE id = ? AND answer IS NULL`,\n args: [answer, now(), id],\n });\n}\n",[233],"883bb33f-327c-4608-9698-dde552e774df","README.md","019ec8ff-b70b-705e-aff8-93d0bee43f4e",["D",1781488662285],"# dispatch-my-human — send an agent to phone your human 📞\n\nA **public remote MCP server**: connect it to any AI agent and it can dispatch an *autonomous* voice agent to phone your human, **run the whole conversation itself**, hang up, and hand back a structured report. The sibling [dcm31/call-my-human](https://www.val.town/x/dcm31/call-my-human) is a *puppet* — you drive every word over a dumb pipe, which is high-latency. This one un-lobotomizes the agent: it has a real LLM brain running **inside Vapi's stack**, so there's no per-turn round-trip back to your reasoning loop. Same BYOK design: **no env vars, no server-side keys, no signup**.\n\n```\nyour agent (any MCP client)\n │ dispatch_call({ objective, context, questions }) ← brief it ONCE\n ▼\nthis val ──── POST api.vapi.ai/call (your key) ────▶ Vapi ─── gpt-4o brain ──▶ 📱 you\n ▲ │ │ (runs the call itself,\n │ │ │ ends it with endCall)\n │ └── await_report ◀── end-of-call analysis ──────┘\n └── /webhook/ ◀── transcripts + structured report ──┘\n```\n\nThe agent carries the call: it opens, stays on objective, gets your answers, and uses Vapi's `endCall` tool to hang up. When it ends, Vapi's **analysis plan** auto-extracts a summary + an answer to each question you asked + any follow-ups, and `await_report` returns it.\n\n## The loop\n\nJust two tools for the common case:\n\n1. **`dispatch_call`** `{ objective, context?, questions?, number?, first_message?, caller_identity?, max_minutes? }` — hand off the call.\n2. **`await_report`** `{ wait_seconds }` — long-polls; keep calling it until `done:true`. Returns `{ summary, objective_met, answers[], followups, transcript }`.\n\nOptional supervisor hooks (you usually won't need them):\n\n- **`listen`** — eavesdrop on the live call in realtime.\n- **`say`** — barge in with a verbatim line (e.g. correct the agent or feed it a fact).\n- **`get_status`**, **`end_call`** — snapshot / abort.\n\n## Connect\n\nYou need two values from [dashboard.vapi.ai](https://dashboard.vapi.ai): your **private key** and a **phone number ID** (free Vapi numbers work, US-only).\n\n```sh\nclaude mcp add --transport http dispatch-my-human \\\n \"https://dcm31--019ec8902328734fa4beeb375dc81ac4.web.val.run/mcp?vapi_key=YOUR_KEY&phone_number_id=YOUR_PHONE_ID&human_number=%2B15551234567\"\n```\n\n- `human_number` = your cell, the default callee. **The `+` must be URL-encoded as `%2B`.**\n- The brain runs on your Vapi account's bundled **OpenAI** model (`gpt-4o` default). No extra LLM key needed for OpenAI models. Override with `&model=gpt-4o-mini` (faster) or any Vapi-supported model.\n- Any MCP client that takes a URL works (claude.ai custom connectors included). `Authorization: Bearer ` is accepted in place of the `vapi_key` param.\n- Then tell your agent: *\"if you get stuck, dispatch a call to me and ask.\"*\n\n## Example\n\n> Agent: `dispatch_call({ objective: \"Decide whether to ship the v2 release tonight\", context: \"QA found one minor cosmetic bug, nothing functional. The marketing email is scheduled for 8am.\", questions: [\"Ship tonight or hold for the fix?\", \"If we hold, what's the new target?\"], caller_identity: \"Charlie's AI assistant\" })`\n>\n> …agent calls, talks it through, hangs up…\n>\n> Agent: `await_report({})` → `{ objective_met: true, answers: [{question:\"Ship tonight or hold for the fix?\", answer:\"Ship tonight\"}, {question:\"If we hold, what's the new target?\", answer:\"N/A — shipping\"}], summary: \"...\", followups: \"Wants a Slack ping once it's live.\" }`\n\n## Watching a call live\n\n`dispatch_call` and `get_status` return a `watch_url` (`/?t=`) — a self-refreshing feed of statuses, both-sides transcript, and the final structured report.\n\n## Testing with curl\n\n```sh\nBASE=\"https://dcm31--019ec8902328734fa4beeb375dc81ac4.web.val.run\"\nQ=\"vapi_key=YOUR_KEY&phone_number_id=YOUR_PHONE_ID&human_number=%2B15551234567\"\ncurl -X POST \"$BASE/api/call/dispatch?$Q\" -d '{\"objective\":\"Confirm Friday dinner\",\"questions\":[\"Still on for Friday?\",\"What time?\"]}'\ncurl -X POST \"$BASE/api/call/report?$Q\" -d '{\"wait_seconds\":25}' --max-time 35 # repeat until done:true\n```\n\n## Files\n\n- `main.ts` — routes, per-tenant Vapi webhook (transcripts + end-of-call analysis), landing + live feed\n- `tools.ts` — the tools, shared by MCP and REST; builds the agent's system prompt from your brief\n- `vapi.ts` — Vapi REST client: native-model call creation with the `endCall` tool + structured-data analysis plan\n- `mcp.ts` — minimal stateless streamable-HTTP MCP plumbing (no SDK)\n- `db.ts` — SQLite: tenant-scoped `calls` + append-only `events` (transcripts, report, structured analysis)\n\n## Multi-tenancy & privacy\n\n- Your Vapi key is read per-request and **never stored**. It travels TLS-encrypted to this val and on to Vapi, like any BYOK MCP server.\n- Call state, transcripts, and reports **are stored** in this val's SQLite, scoped by a `tenant` = first 12 hex chars of SHA-256(your key) — unguessable without the key, and it's how Vapi's webhooks find their way back (`/webhook/`, verified via `x-vapi-secret`).\n- Want full custody? **Remix this val** — it needs zero configuration.\n\n## Notes\n\n- The agent ends calls itself via Vapi's `endCall` tool once the objective is met; `max_minutes` (default 10) is a hard cap. 30s of mutual silence also ends it.\n- Latency is set by Vapi's STT→LLM→TTS pipeline (~1-2s/turn), not your agent's reasoning loop — that's the whole point vs. the puppet.\n- Post-call analysis (summary + structured data) completes a few seconds *after* the call ends, so `await_report` may return `done:false` once right at hangup — just call it again.\n- Free Vapi numbers are test-grade (occasional dead bridges, a daily outbound limit). Import a Twilio number into Vapi for reliability.\n- Only call numbers you have consent to call — automated calls without consent violate TCPA/FCC rules.\n",[239],"pulls","branches","forks","envVars",{"_251":85,"_253":154},"connections",{"_251":154,"_252":154},"count","unfilledCount","emptyCount",{"_32":238,"_13":239,"_80":240,"_82":-5,"_83":59,"_84":128,"_86":26,"_34":272,"_41":154,"_89":195,"_91":242,"_66":51,"_93":-5,"_94":273,"_73":274},{"_32":232,"_13":233,"_80":234,"_82":-5,"_83":59,"_84":128,"_86":26,"_34":269,"_41":154,"_89":90,"_91":236,"_66":51,"_93":-5,"_94":270,"_73":271},{"_32":124,"_13":121,"_80":125,"_82":-5,"_83":59,"_84":126,"_86":26,"_34":127,"_41":128,"_89":129,"_91":130,"_66":51,"_93":-5,"_94":267,"_73":268},{"_32":224,"_13":225,"_80":226,"_82":-5,"_83":59,"_84":128,"_86":26,"_34":264,"_41":154,"_89":90,"_91":228,"_66":51,"_93":-5,"_94":265,"_73":266},{"_32":108,"_13":105,"_80":109,"_82":-5,"_83":59,"_84":58,"_86":26,"_34":110,"_41":85,"_89":90,"_91":111,"_66":51,"_93":-5,"_94":262,"_73":263},{"_32":79,"_13":74,"_80":81,"_82":-5,"_83":59,"_84":85,"_86":26,"_34":87,"_41":88,"_89":90,"_91":92,"_66":51,"_93":-5,"_94":260,"_73":261},[],[74],[],[105],["D",1781488662285],[],[225],[],[121],["D",1781488662285],[],[233],["D",1781488662285],[],[239],["D",1781486817181],["D",1789509672838],{"_11":12,"_183":179},{"_11":12,"_176":177,"_178":179,"_147":148,"_180":181,"_182":51},{"_41":58,"_13":16,"_32":59,"_39":40,"_43":33,"_45":60,"_61":53,"_62":40,"_63":56,"_57":14,"_54":12},"ctx",{"_171":-5,"_205":313,"_314":315,"_316":317,"_318":51,"_319":51,"_320":51,"_321":26,"_322":-5,"_323":-7,"_324":-7,"_325":154,"_326":51,"_327":51,"_328":-5,"_329":51,"_330":51,"_331":51,"_332":-5},"ENV",{"_284":285,"_286":287,"_288":38,"_289":290,"_291":292,"_293":294,"_295":296,"_297":298,"_299":300,"_301":302,"_303":304,"_305":306,"_307":308,"_309":310,"_311":312},"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"]

Compare

Mergeasync-escapeintomain

Hmain.ts+5-15

tools.ts+19-4

vapi.ts+17-10