Transcarent × Vapi

\n Transcarent sandbox · synthetic data\n

\n\n

Members

Provider directory

MCP tools the agent discovered

Appointments booked by the voice agent

No appointments yet — book one on a call and it lands here.

What Vapi sends your systems when a call ends

Waiting for the next call to end…

\n\n\n\n`;\n",[],[197],"e7ec9fde-30ac-4ec9-be08-04643902044a","main.ts",["D",1787003984634],"http","import { Hono } from \"npm:hono\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { TOOL_DEFINITIONS, toolCall } from \"./tools.ts\";\nimport { bookedSetOf, bookingsLoad, providerSlotsUpcoming } from \"./slots.ts\";\nimport { CLAIMS, MEMBERS, PROVIDERS } from \"./data.ts\";\nimport { portalHtml } from \"./portal.ts\";\n\n/**\n * One server, three jobs — deliberately, because this is the demo's point:\n * /mcp the MCP tool surface the voice agent discovers (Streamable HTTP)\n * / the demo portal (backend context, live appointments, webhook feed)\n * /webhook Vapi's end-of-call-report receiver (\"what lands in your systems\")\n *\n * MCP is implemented directly against the JSON-RPC wire format rather than via\n * the SDK: the SDK's transport assumes Node stream internals that are awkward\n * on Deno, and the protocol surface here is small. Stateless, no Mcp-Session-Id.\n */\n\nconst SERVER_INFO = { name: \"transcarent-sandbox\", version: \"1.0.0\" };\nconst FALLBACK_PROTOCOL_VERSION = \"2025-03-26\";\nconst REPORTS_KEY = \"tc-sandbox-reports\";\n\ntype JsonRpcRequest = {\n jsonrpc: \"2.0\";\n id?: string | number | null;\n method: string;\n params?: { name?: string; arguments?: Record; protocolVersion?: string };\n};\n\nconst resultOf = (id: string | number | null | undefined, result: unknown) => ({\n jsonrpc: \"2.0\" as const,\n id: id ?? null,\n result,\n});\n\nconst errorOf = (id: string | number | null | undefined, code: number, message: string) => ({\n jsonrpc: \"2.0\" as const,\n id: id ?? null,\n error: { code, message },\n});\n\nconst messageHandle = async (msg: JsonRpcRequest): Promise => {\n const { method, id, params } = msg;\n\n // Notifications carry no id and get no response body.\n if (method.startsWith(\"notifications/\")) return null;\n\n if (method === \"initialize\") {\n return resultOf(id, {\n protocolVersion: params?.protocolVersion ?? FALLBACK_PROTOCOL_VERSION,\n capabilities: { tools: { listChanged: false } },\n serverInfo: SERVER_INFO,\n });\n }\n\n if (method === \"ping\") return resultOf(id, {});\n\n if (method === \"tools/list\") return resultOf(id, { tools: TOOL_DEFINITIONS });\n\n if (method === \"tools/call\") {\n const name = params?.name ?? \"\";\n const args = params?.arguments ?? {};\n try {\n const output = await toolCall(name, args);\n return resultOf(id, {\n content: [{ type: \"text\", text: JSON.stringify(output) }],\n isError: false,\n });\n } catch (err) {\n const detail = err instanceof Error ? err.message : String(err);\n return resultOf(id, {\n content: [{ type: \"text\", text: `Tool ${name} failed: ${detail}` }],\n isError: true,\n });\n }\n }\n\n return errorOf(id, -32601, `Method not found: ${method}`);\n};\n\nconst app = new Hono();\n\napp.get(\"/\", (c) => c.html(portalHtml));\n\napp.get(\"/info\", (c) =>\n c.json({\n service: \"Transcarent demo — MCP server, portal, and webhook receiver\",\n purpose: \"Vapi voice agent demo. All member, provider, and claims data is synthetic.\",\n mcp_endpoint: new URL(\"/mcp\", c.req.url).toString(),\n webhook_endpoint: new URL(\"/webhook\", c.req.url).toString(),\n transport: \"streamable-http\",\n tools: TOOL_DEFINITIONS.map((t) => t.name),\n })\n);\n\napp.get(\"/api/state\", async (c) => {\n const bookings = await bookingsLoad();\n const reports = ((await blob.getJSON(REPORTS_KEY)) as unknown[] | undefined) ?? [];\n const booked = bookedSetOf(bookings);\n return c.json({\n members: MEMBERS.map((m) => ({\n memberId: m.memberId,\n firstName: m.firstName,\n lastName: m.lastName,\n planName: m.planName,\n deductibleTotal: m.deductibleTotal,\n deductibleMet: m.deductibleMet,\n outOfPocketMax: m.outOfPocketMax,\n outOfPocketMet: m.outOfPocketMet,\n primaryCareProviderName: m.primaryCareProviderName ?? null,\n claimCount: CLAIMS.filter((cl) => cl.memberId === m.memberId).length,\n benefits: Object.values(m.benefits).map((b) => ({ name: b.name, covered: b.covered })),\n })),\n providers: PROVIDERS.map((p) => {\n const slots = providerSlotsUpcoming(p, booked);\n return {\n name: p.name,\n specialty: p.specialty,\n practice: p.practice,\n distanceMiles: p.distanceMiles,\n inNetwork: p.inNetwork,\n acceptingNewPatients: p.acceptingNewPatients,\n upcomingSlots: slots,\n nextAvailable: slots[0] ??\n (p.acceptingNewPatients ? \"No openings in the next two weeks\" : \"Not accepting new patients\"),\n };\n }),\n tools: TOOL_DEFINITIONS.map((t) => ({\n name: t.name,\n description: t.description.split(\". \")[0] + \".\",\n })),\n bookings,\n reports,\n });\n});\n\napp.post(\"/webhook\", async (c) => {\n let body: { message?: Record };\n try {\n body = await c.req.json();\n } catch {\n return c.json({ error: \"invalid json\" }, 400);\n }\n const m = (body.message ?? {}) as Record;\n if (m.type !== \"end-of-call-report\") return c.json({ received: true, ignored: m.type ?? \"unknown\" });\n\n const artifact = (m.artifact ?? {}) as Record;\n const soMap = (artifact.structuredOutputs ?? {}) as Record;\n const call = (m.call ?? {}) as Record;\n const secs = typeof m.durationSeconds === \"number\" ? Math.round(m.durationSeconds) : null;\n\n const entry = {\n receivedAt: new Date().toISOString().replace(\"T\", \" \").slice(0, 19) + \" UTC\",\n callId: (call.id as string) ?? \"\",\n endedReason: (m.endedReason as string) ?? \"\",\n durationText: secs === null ? \"\" : `${Math.floor(secs / 60)}m ${secs % 60}s`,\n structuredOutputs: Object.values(soMap).map((o) => ({ name: o.name ?? \"?\", result: o.result ?? null })),\n // Excerpt, not the full report: enough to be credible on screen without\n // storing transcripts and presigned URLs in a public demo blob.\n raw: {\n type: m.type,\n endedReason: m.endedReason,\n durationSeconds: m.durationSeconds,\n summary: (m.analysis as Record | undefined)?.summary ?? null,\n structuredOutputs: soMap,\n cost: m.cost ?? null,\n },\n };\n\n const existing = ((await blob.getJSON(REPORTS_KEY)) as unknown[] | undefined) ?? [];\n await blob.setJSON(REPORTS_KEY, [...existing.slice(-11), entry]);\n return c.json({ received: true });\n});\n\n// Some MCP clients probe GET /mcp for a server-initiated SSE stream. This server\n// does not offer one; 405 is the spec-sanctioned way to say so.\napp.get(\"/mcp\", (c) => c.text(\"This MCP server does not offer an SSE stream. Use POST.\", 405));\n\napp.post(\"/mcp\", async (c) => {\n let payload: JsonRpcRequest | JsonRpcRequest[];\n try {\n payload = await c.req.json();\n } catch {\n return c.json(errorOf(null, -32700, \"Parse error\"), 400);\n }\n\n if (Array.isArray(payload)) {\n const responses = (await Promise.all(payload.map(messageHandle))).filter((r) => r !== null);\n if (responses.length === 0) return c.body(null, 202);\n return c.json(responses);\n }\n\n const response = await messageHandle(payload);\n if (response === null) return c.body(null, 202);\n return c.json(response);\n});\n\napp.onError((err) => Promise.reject(err));\n\nexport default app.fetch;\n",[],[205],["D",1787003961031],[],[18],["D",1787003961031],{"_11":12,"_126":74},{"_11":12,"_121":122,"_73":74,"_30":72,"_123":124,"_125":24},{"_38":111,"_13":16,"_32":35,"_112":76,"_113":64,"_114":65,"_115":80,"_116":117,"_118":41,"_119":14,"_120":12},"ctx",{"_53":-5,"_147":251,"_252":253,"_254":255,"_256":24,"_257":24,"_258":24,"_259":88,"_260":-5,"_261":-7,"_262":-7,"_263":26,"_264":24,"_265":24,"_266":-5,"_267":24,"_268":24,"_269":24,"_270":-5},"ENV",{"_222":223,"_224":225,"_226":16,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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"]

History · data.ts