📞 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",[167],"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",[175],"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",[181],"pulls","branches",2,"forks","envVars",{"_194":142,"_196":43},"connections",{"_194":43,"_195":43},"count","unfilledCount","emptyCount",{"_18":180,"_20":181,"_137":182,"_139":-5,"_140":72,"_141":162,"_143":39,"_22":219,"_69":43,"_146":103,"_148":184,"_150":26,"_151":-5,"_204":220,"_92":221},{"_18":174,"_20":175,"_137":176,"_139":-5,"_140":72,"_141":162,"_143":39,"_22":216,"_69":43,"_146":147,"_148":178,"_150":26,"_151":-5,"_204":217,"_92":218},{"_18":166,"_20":167,"_137":168,"_139":-5,"_140":72,"_141":169,"_143":39,"_22":213,"_69":162,"_146":171,"_148":172,"_150":26,"_151":-5,"_204":214,"_92":215},{"_18":159,"_20":160,"_137":161,"_139":-5,"_140":72,"_141":162,"_143":39,"_22":210,"_69":43,"_146":147,"_148":164,"_150":26,"_151":-5,"_204":211,"_92":212},{"_18":153,"_20":154,"_137":155,"_139":-5,"_140":72,"_141":70,"_143":39,"_22":207,"_69":142,"_146":147,"_148":157,"_150":26,"_151":-5,"_204":208,"_92":209},{"_18":135,"_20":136,"_137":138,"_139":-5,"_140":72,"_141":142,"_143":39,"_22":203,"_69":145,"_146":147,"_148":149,"_150":26,"_151":-5,"_204":205,"_92":206},["D",1781488729407],"children",[],[136],["D",1781489854992],[],[154],["D",1781488662285],[],[160],["D",1781488743551],[],[167],["D",1781488662285],[],[175],["D",1781488662285],[],[181],["D",1781486817181],["D",1789509672838],{"_16":17,"_90":86},{"_16":17,"_83":84,"_85":86,"_34":35,"_87":88,"_89":26},{"_69":70,"_20":71,"_18":72,"_73":19,"_74":75,"_76":77,"_78":28,"_79":19,"_80":45,"_81":21,"_82":17},"ctx",{"_62":-5,"_113":260,"_261":262,"_263":264,"_265":26,"_266":26,"_267":26,"_268":39,"_269":-5,"_270":-7,"_271":-7,"_272":43,"_273":26,"_274":26,"_275":-5,"_276":26,"_277":26,"_278":26,"_279":-5},"ENV",{"_231":232,"_233":234,"_235":119,"_236":237,"_238":239,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259},"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"]

Search