[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_188":189,"_190":191},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":59,"_127":-5,"_128":-5,"_129":130},"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":-5,"_18":55,"_56":57,"_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",47,"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","intercom.ts","latestPath","fileId","4f6447d0-7a4e-11f1-87e3-1607ee4eb77e","name","fileType","script","content","// Thin Intercom API client used by the voice agent tools + end-of-call webhook.\n\nconst BASE = \"https://api.intercom.io\";\n\nfunction headers() {\n return {\n \"Authorization\": `Bearer ${Deno.env.get(\"INTERCOM_TOKEN\")}`,\n \"Intercom-Version\": \"2.11\",\n \"Content-Type\": \"application/json\",\n \"Accept\": \"application/json\",\n };\n}\n\nasync function api(method: string, path: string, payload?: unknown) {\n const res = await fetch(BASE + path, {\n method,\n headers: headers(),\n body: payload === undefined ? undefined : JSON.stringify(payload),\n });\n const body = await res.json();\n if (!res.ok) {\n throw new Error(`Intercom ${method} ${path} -> ${res.status}: ${JSON.stringify(body).slice(0, 300)}`);\n }\n return body;\n}\n\nexport function stripHtml(html: string): string {\n return (html || \"\")\n .replace(/]*>/g, \"\\n- \")\n .replace(/<\\/p>|/g, \"\\n\")\n .replace(/<[^>]+>/g, \"\")\n .replace(/&/g, \"&\").replace(/</g, \"<\").replace(/>/g, \">\")\n .replace(/ /g, \" \").replace(/'|'/g, \"'\").replace(/"/g, '\"')\n .replace(/[ \\t]+/g, \" \")\n .replace(/\\n\\s*\\n+/g, \"\\n\\n\")\n .trim();\n}\n\nexport async function findContactByEmail(email: string) {\n const r = await api(\"POST\", \"/contacts/search\", {\n query: { field: \"email\", operator: \"=\", value: email.toLowerCase() },\n });\n return r.data?.[0];\n}\n\nexport async function findContactByPhone(phoneE164: string) {\n const r = await api(\"POST\", \"/contacts/search\", {\n query: { field: \"phone\", operator: \"=\", value: phoneE164 },\n });\n return r.data?.[0];\n}\n\n// Create an Intercom contact. Keyed by email (how Benepass identifies members); phone optional.\n// Intercom requires email or external_id, so we add a synthetic external_id when there's no email.\nexport async function createContact(opts: { name: string; email?: string; phone?: string }) {\n const payload: Record = { role: \"user\", name: opts.name };\n if (opts.email) payload.email = opts.email.toLowerCase();\n if (opts.phone) payload.phone = opts.phone;\n if (!opts.email) payload.external_id = `voice-${(opts.phone || opts.name).replace(/\\W/g, \"\")}-${Date.now()}`;\n return await api(\"POST\", \"/contacts\", payload);\n}\n\nexport async function searchArticles(phrase: string, limit = 3) {\n const r = await api(\n \"GET\",\n `/articles/search?phrase=${encodeURIComponent(phrase)}&state=published`,\n );\n const articles = r.data?.articles ?? [];\n return articles.slice(0, limit).map((a: any) => ({\n title: a.title,\n url: a.url || undefined,\n content: stripHtml(a.body).slice(0, 1200),\n }));\n}\n\nexport async function recentConversations(contactId: string, limit = 2) {\n const r = await api(\"POST\", \"/conversations/search\", {\n query: {\n operator: \"AND\",\n value: [\n { field: \"contact_ids\", operator: \"=\", value: contactId },\n { field: \"source.type\", operator: \"!=\", value: \"ticket_state_updated\" },\n ],\n },\n pagination: { per_page: 10 },\n });\n const convos = r.conversations ?? r.data ?? [];\n const out: any[] = [];\n for (const c of convos) {\n if (out.length >= limit) break;\n const full = await api(\"GET\", `/conversations/${c.id}`);\n // Skip tickets (they surface in conversation search but aren't chat history).\n if (full.ticket) continue;\n const opened = stripHtml(full.source?.body ?? \"\").slice(0, 400);\n const parts = (full.conversation_parts?.conversation_parts ?? [])\n .filter((p: any) => p.body)\n .map((p: any) => ({\n from: p.author?.type === \"admin\" ? \"Benepass Support\" : \"Member\",\n text: stripHtml(p.body).slice(0, 400),\n }));\n if (!opened && parts.length === 0) continue; // drop empty shells\n out.push({\n date: new Date((full.created_at ?? 0) * 1000).toISOString().slice(0, 10),\n opened_with: opened,\n messages: parts.slice(-4),\n });\n }\n return out;\n}\n\nexport interface TicketInput {\n contactId: string;\n title: string;\n description: string;\n issueType?: string;\n resolution?: string; // \"AI Resolved\" | \"Escalated to Human\" | \"Follow-up Needed\"\n language?: string;\n callId?: string;\n recordingUrl?: string;\n}\n\nconst SOURCE = \"Vapi Voice AI\";\n\nexport async function createTicket(t: TicketInput) {\n // Default \"Tickets\" ticket type in the workspace (not a custom type).\n const ticketTypeId = Deno.env.get(\"INTERCOM_TICKET_TYPE_ID_OVERRIDE\") ?? \"3085585\";\n // Consistent footer so a human agent always knows this came from the Vapi voice agent\n // and can jump straight to the call recording/transcript.\n const callLink = t.callId ? `https://dashboard.vapi.ai/calls/${t.callId}` : \"\";\n const footer = [\n \"\\n\\n— Created by Vapi Voice AI (phone) —\",\n t.callId ? `Call ID: ${t.callId}` : \"\",\n t.recordingUrl ? `Recording: ${t.recordingUrl}` : (callLink ? `Call: ${callLink}` : \"\"),\n ].filter(Boolean).join(\"\\n\");\n const attrs: Record = {\n \"_default_title_\": t.title,\n \"_default_description_\": t.description + footer,\n \"Source\": SOURCE,\n };\n if (t.issueType) attrs[\"Issue Type\"] = t.issueType;\n if (t.resolution) attrs[\"Resolution\"] = t.resolution;\n if (t.language) attrs[\"Language\"] = t.language;\n const r = await api(\"POST\", \"/tickets\", {\n ticket_type_id: ticketTypeId,\n contacts: [{ id: t.contactId }],\n ticket_attributes: attrs,\n });\n return { id: r.id, ticketTypeId };\n}\n\n// Mark a ticket resolved (used for AI-resolved calls so they auto-close;\n// escalations are left open in the human queue).\nexport async function resolveTicket(ticketId: string) {\n return await api(\"PUT\", `/tickets/${ticketId}`, { open: false, state: \"resolved\" });\n}\n","// Thin Intercom API client used by the voice agent tools + end-of-call webhook.\n\nconst BASE = \"https://api.intercom.io\";\n\nfunction headers() {\n return {\n \"Authorization\": `Bearer ${Deno.env.get(\"INTERCOM_TOKEN\")}`,\n \"Intercom-Version\": \"2.11\",\n \"Content-Type\": \"application/json\",\n \"Accept\": \"application/json\",\n };\n}\n\nasync function api(method: string, path: string, payload?: unknown) {\n const res = await fetch(BASE + path, {\n method,\n headers: headers(),\n body: payload === undefined ? undefined : JSON.stringify(payload),\n });\n const body = await res.json();\n if (!res.ok) {\n throw new Error(`Intercom ${method} ${path} -> ${res.status}: ${JSON.stringify(body).slice(0, 300)}`);\n }\n return body;\n}\n\nexport function stripHtml(html: string): string {\n return (html || \"\")\n .replace(/]*>/g, \"\\n- \")\n .replace(/<\\/p>|/g, \"\\n\")\n .replace(/<[^>]+>/g, \"\")\n .replace(/&/g, \"&\").replace(/</g, \"<\").replace(/>/g, \">\")\n .replace(/ /g, \" \").replace(/'|'/g, \"'\").replace(/"/g, '\"')\n .replace(/[ \\t]+/g, \" \")\n .replace(/\\n\\s*\\n+/g, \"\\n\\n\")\n .trim();\n}\n\nexport async function findContactByEmail(email: string) {\n const r = await api(\"POST\", \"/contacts/search\", {\n query: { field: \"email\", operator: \"=\", value: email.toLowerCase() },\n });\n return r.data?.[0];\n}\n\nexport async function findContactByPhone(phoneE164: string) {\n const r = await api(\"POST\", \"/contacts/search\", {\n query: { field: \"phone\", operator: \"=\", value: phoneE164 },\n });\n return r.data?.[0];\n}\n\n// Create an Intercom contact. Keyed by email (how Benepass identifies members); phone optional.\n// Intercom requires email or external_id, so we add a synthetic external_id when there's no email.\nexport async function createContact(opts: { name: string; email?: string; phone?: string }) {\n const payload: Record = { role: \"user\", name: opts.name };\n if (opts.email) payload.email = opts.email.toLowerCase();\n if (opts.phone) payload.phone = opts.phone;\n if (!opts.email) payload.external_id = `voice-${(opts.phone || opts.name).replace(/\\W/g, \"\")}-${Date.now()}`;\n return await api(\"POST\", \"/contacts\", payload);\n}\n\nexport async function searchArticles(phrase: string, limit = 3) {\n const r = await api(\n \"GET\",\n `/articles/search?phrase=${encodeURIComponent(phrase)}&state=published`,\n );\n const articles = r.data?.articles ?? [];\n return articles.slice(0, limit).map((a: any) => ({\n title: a.title,\n url: a.url || undefined,\n content: stripHtml(a.body).slice(0, 1200),\n }));\n}\n\nexport async function recentConversations(contactId: string, limit = 2) {\n const r = await api(\"POST\", \"/conversations/search\", {\n query: {\n operator: \"AND\",\n value: [\n { field: \"contact_ids\", operator: \"=\", value: contactId },\n { field: \"source.type\", operator: \"!=\", value: \"ticket_state_updated\" },\n ],\n },\n pagination: { per_page: 10 },\n });\n const convos = r.conversations ?? r.data ?? [];\n const out: any[] = [];\n for (const c of convos) {\n if (out.length >= limit) break;\n const full = await api(\"GET\", `/conversations/${c.id}`);\n // Skip tickets (they surface in conversation search but aren't chat history).\n if (full.ticket) continue;\n const opened = stripHtml(full.source?.body ?? \"\").slice(0, 400);\n const parts = (full.conversation_parts?.conversation_parts ?? [])\n .filter((p: any) => p.body)\n .map((p: any) => ({\n from: p.author?.type === \"admin\" ? \"Benepass Support\" : \"Member\",\n text: stripHtml(p.body).slice(0, 400),\n }));\n if (!opened && parts.length === 0) continue; // drop empty shells\n out.push({\n date: new Date((full.created_at ?? 0) * 1000).toISOString().slice(0, 10),\n opened_with: opened,\n messages: parts.slice(-4),\n });\n }\n return out;\n}\n\nexport interface TicketInput {\n contactId: string;\n title: string;\n description: string;\n issueType?: string;\n resolution?: string; // \"AI Resolved\" | \"Escalated to Human\" | \"Follow-up Needed\"\n language?: string;\n callId?: string;\n recordingUrl?: string;\n}\n\nconst SOURCE = \"Vapi Voice AI\";\n\nexport async function createTicket(t: TicketInput) {\n // Default \"Tickets\" ticket type in the workspace (not a custom type).\n const ticketTypeId = Deno.env.get(\"INTERCOM_TICKET_TYPE_ID_OVERRIDE\") ?? \"3085585\";\n // Consistent footer so a human agent always knows this came from the Vapi voice agent\n // and can jump straight to the call recording/transcript.\n const footer = [\n \"\\n\\n— Created by Vapi Voice AI (phone) —\",\n t.callId ? `Vapi Call ID: ${t.callId}` : \"\",\n t.recordingUrl ? `Recording: ${t.recordingUrl}` : \"\",\n ].filter(Boolean).join(\"\\n\");\n const attrs: Record = {\n \"_default_title_\": t.title,\n \"_default_description_\": t.description + footer,\n \"Source\": SOURCE,\n };\n if (t.issueType) attrs[\"Issue Type\"] = t.issueType;\n if (t.resolution) attrs[\"Resolution\"] = t.resolution;\n if (t.language) attrs[\"Language\"] = t.language;\n const r = await api(\"POST\", \"/tickets\", {\n ticket_type_id: ticketTypeId,\n contacts: [{ id: t.contactId }],\n ticket_attributes: attrs,\n });\n return { id: r.id, ticketTypeId };\n}\n\n// Mark a ticket resolved (used for AI-resolved calls so they auto-close;\n// escalations are left open in the human queue).\nexport async function resolveTicket(ticketId: string) {\n return await api(\"PUT\", `/tickets/${ticketId}`, { open: false, state: \"resolved\" });\n}\n","createdAt",["D",1783484788923],"branchVersion","branchId","e968d05d-94ad-4104-9cdd-f969193d97d5","id","24f9b62a-7a31-465f-82ae-95cfeb4539f0","benepass-demo",["D",1783461160403],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Benepass voice AI demo backend: mock member API + Intercom glue","imageUrl","28056148-fc13-432f-be05-37a4ce07f9db","pinnedFileId","72a2d216-7a4e-11f1-a950-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019e511e-6214-7719-8b29-0af034f4b069","tursoName","24f9b62a7a31465f82ae95cfeb4539f0","tursoHostname","24f9b62a7a31465f82ae95cfeb4539f0-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789525245864],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",51,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","prudhvinakkina","handle","displayName","Prudhvi Nakkina","avatar","https://lh3.googleusercontent.com/a/ACg8ocJhop25jm0wt-QSQjfGck498ZYGdD4MCM_ARgX-IyZCNlNiRl8=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":183,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":184,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":185,"_84":186,"_86":187,"_88":25},"tree",[170,171,172],"files",[170,171,172],"counts",{"_158":63,"_159":160,"_161":63,"_162":163,"_164":165},"contents",[131,132,133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":150,"_32":151,"_30":152,"_136":-5,"_41":42,"_40":153,"_138":59,"_38":154,"_13":155,"_33":34,"_35":156,"_24":25,"_143":-5,"_27":157},{"_43":146,"_32":28,"_30":31,"_136":-5,"_41":42,"_40":14,"_138":25,"_38":147,"_13":148,"_33":34,"_35":37,"_24":25,"_143":-5,"_27":149},{"_43":134,"_32":135,"_30":57,"_136":-5,"_41":42,"_40":137,"_138":25,"_38":139,"_13":140,"_33":141,"_35":142,"_24":25,"_143":144,"_27":145},"0e8ad7ad-ed67-4802-ac9c-957cd2e4a04f","main.tsx","parentId",46,"latest",["D",1783484405270],27,"http","// Benepass voice AI demo backend.\n// This file is the entirety of what \"Benepass engineering\" builds:\n// - POST /vapi/tools -> function-tool calls from the Vapi assistant (member data + Intercom)\n// - POST /vapi/webhook -> Vapi end-of-call report -> files an Intercom ticket for every call\n// - GET / -> status page\nimport { Hono } from \"npm:hono\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\nimport { findMemberByPhone, findMemberById, findMemberByEmail, normalizePhone, normalizeEmail, MEMBERS, type Member } from \"./data.ts\";\nimport * as ic from \"./intercom.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\nawait sqlite.batch([\n `CREATE TABLE IF NOT EXISTS phone_map (phone TEXT PRIMARY KEY, persona TEXT)`,\n `CREATE TABLE IF NOT EXISTS call_session (call_id TEXT PRIMARY KEY, persona TEXT, phone TEXT, updated_at INTEGER)`,\n `CREATE TABLE IF NOT EXISTS call_log (call_id TEXT PRIMARY KEY, phone TEXT, persona TEXT, ticket_id TEXT, disposition TEXT, summary TEXT, created_at INTEGER)`,\n // The member directory Benepass authenticates against — the \"roster\" the customer\n // would hand us. verifyMemberEmail checks a caller's work email against this table.\n `CREATE TABLE IF NOT EXISTS member_directory (email TEXT PRIMARY KEY, persona TEXT, name TEXT, employer TEXT)`,\n]);\n\n// Seed the directory from the mock member roster (idempotent).\nfor (const m of MEMBERS) {\n await sqlite.execute({\n sql: \"INSERT INTO member_directory (email, persona, name, employer) VALUES (?, ?, ?, ?) ON CONFLICT(email) DO UPDATE SET persona = excluded.persona, name = excluded.name, employer = excluded.employer\",\n args: [m.email.toLowerCase(), m.id, m.name, m.employer],\n });\n}\n\n// ---------- persona resolution (phone_map lets us alias real demo phones to personas) ----------\nasync function resolveMember(rawPhone: string): Promise {\n const n = normalizePhone(rawPhone);\n if (!n) return undefined;\n const r = await sqlite.execute({ sql: \"SELECT persona FROM phone_map WHERE phone = ?\", args: [n] });\n if (r.rows.length) return findMemberById(r.rows[0].persona as string);\n return findMemberByPhone(rawPhone);\n}\n\n// Resolve the member for a tool/call, preferring an explicit phone arg, then the caller's\n// number, then whatever we remembered earlier in this call. Persists the association so a\n// later escalation/ticket doesn't depend on the model re-passing the phone.\nasync function resolveForCall(args: ToolArgs, ctx: ToolCtx): Promise<{ member?: Member; phone: string }> {\n // Email (the verified identifier) wins, then an explicit/caller phone, then the session.\n let member = args.email ? findMemberByEmail(String(args.email)) : undefined;\n const explicit = args.phone || ctx.callerPhone;\n if (!member && explicit) member = await resolveMember(explicit);\n if (member) {\n await sqlite.execute({\n sql: \"INSERT INTO call_session (call_id, persona, phone, updated_at) VALUES (?, ?, ?, ?) ON CONFLICT(call_id) DO UPDATE SET persona = excluded.persona, phone = excluded.phone, updated_at = excluded.updated_at\",\n args: [ctx.callId, member.id, member.phones[0], Date.now()],\n });\n return { member, phone: member.phones[0] };\n }\n const s = await sqlite.execute({ sql: \"SELECT persona, phone FROM call_session WHERE call_id = ?\", args: [ctx.callId] });\n if (s.rows.length) {\n member = findMemberById(s.rows[0].persona as string);\n return { member, phone: (s.rows[0].phone as string) || ctx.callerPhone };\n }\n return { member: undefined, phone: ctx.callerPhone };\n}\n\n// Find or create the member's Intercom contact, keyed by their VERIFIED EMAIL (a member\n// verified in the directory may not exist in Intercom yet — first-time caller — so we create\n// them here). Falls back to a phone-keyed contact only for unknown callers.\nasync function intercomContactFor(m: Member | undefined, fallbackPhone: string) {\n if (m) {\n let c = await ic.findContactByEmail(m.email);\n if (!c) c = await ic.createContact({ name: m.name, email: m.email, phone: m.phones[0] });\n return c;\n }\n if (fallbackPhone) {\n let c = await ic.findContactByPhone(fallbackPhone);\n if (!c) c = await ic.createContact({ name: `Caller ${fallbackPhone}`, phone: fallbackPhone });\n return c;\n }\n return undefined;\n}\n\n// ---------- Vapi function tools ----------\ntype ToolArgs = Record;\ntype ToolCtx = { callerPhone: string; callId: string };\n\nconst tools: Record Promise> = {\n async getBenefits(args, ctx) {\n const { member: m } = await resolveForCall(args, ctx);\n if (!m) return { error: \"No member found.\" };\n return { member: m.name, employer: m.employer, benefits: m.benefits };\n },\n\n async getTransactions(args, ctx) {\n const { member: m } = await resolveForCall(args, ctx);\n if (!m) return { error: \"No member found.\" };\n return { member: m.name, transactions: m.transactions };\n },\n\n async getClaims(args, ctx) {\n const { member: m } = await resolveForCall(args, ctx);\n if (!m) return { error: \"No member found.\" };\n if (!m.claims.length) return { member: m.name, claims: [], message: \"No reimbursement claims on file.\" };\n return { member: m.name, claims: m.claims };\n },\n\n async searchHelpCenter(args) {\n const results = await ic.searchArticles(String(args.query || \"\"), 5);\n if (!results.length) return { results: [], message: \"No help center articles matched. Answer from general knowledge or offer escalation.\" };\n return { source: \"Benepass Help Center (Intercom)\", results };\n },\n\n async getChatHistory(args, ctx) {\n const { member: m } = await resolveForCall(args, ctx);\n if (!m) return { error: \"No member found.\" };\n const contact = await ic.findContactByEmail(m.email);\n if (!contact) return { history: [], message: \"No prior Intercom conversations for this member.\" };\n const history = await ic.recentConversations(contact.id, 2);\n return { member: m.name, source: \"Intercom conversation history\", history };\n },\n\n async createSupportTicket(args, ctx) {\n const { member: m, phone } = await resolveForCall(args, ctx);\n const contact = await intercomContactFor(m, phone);\n if (!contact) return { created: false, message: \"Could not resolve a contact for the ticket.\" };\n const ticket = await ic.createTicket({\n contactId: contact.id,\n title: String(args.title || \"Phone support request\"),\n description: String(args.summary || \"\"),\n issueType: args.issueType ? String(args.issueType) : undefined,\n resolution: String(args.resolution || \"Escalated to Human\"),\n language: args.language ? String(args.language) : undefined,\n callId: ctx.callId,\n });\n await sqlite.execute({\n sql: \"INSERT INTO call_log (call_id, phone, persona, ticket_id, disposition, summary, created_at) VALUES (?, ?, ?, ?, ?, ?, ?) ON CONFLICT(call_id) DO UPDATE SET ticket_id = excluded.ticket_id, disposition = excluded.disposition, summary = excluded.summary\",\n args: [ctx.callId, ctx.callerPhone, m?.id ?? null, String(ticket.id), String(args.resolution || \"Escalated to Human\"), String(args.summary || \"\"), Date.now()],\n });\n return { created: true, ticketId: ticket.id, message: `Intercom ticket ${ticket.id} created.` };\n },\n};\n\napp.post(\"/vapi/tools\", async (c) => {\n const body = await c.req.json();\n const msg = body.message ?? {};\n const ctx: ToolCtx = {\n callerPhone: msg.call?.customer?.number ?? \"\",\n callId: msg.call?.id ?? \"unknown\",\n };\n const calls = msg.toolCallList ?? msg.toolCalls ?? [];\n const results: { toolCallId: string; result: string }[] = [];\n for (const tc of calls) {\n const id = tc.id;\n const name = tc.name ?? tc.function?.name;\n let args = tc.arguments ?? tc.function?.arguments ?? {};\n if (typeof args === \"string\") { try { args = JSON.parse(args); } catch { args = {}; } }\n let result: unknown;\n try {\n const fn = tools[name];\n result = fn ? await fn(args, ctx) : { error: `Unknown tool: ${name}` };\n } catch (e) {\n console.error(`tool ${name} failed:`, e);\n result = { error: \"Temporary system issue. Apologize and offer to create a support ticket.\" };\n }\n results.push({ toolCallId: id, result: JSON.stringify(result) });\n }\n return c.json({ results });\n});\n\n// ---------- apiRequest tool target: verify a caller's work email against the member directory ----------\n// Vapi's apiRequest tool POSTs the schema-filled body directly, e.g. { \"email\": \"...\" }.\napp.post(\"/vapi/verify-email\", async (c) => {\n const body = await c.req.json().catch(() => ({}));\n const rawEmail = body.email ?? body.work_email ?? \"\";\n const email = normalizeEmail(String(rawEmail));\n let row = (await sqlite.execute({\n sql: \"SELECT persona, name, employer, email FROM member_directory WHERE email = ?\",\n args: [email],\n })).rows[0];\n // Accent/STT fallback: if no exact match, match on the unique email local-part token\n // (e.g. \"john at google\" or just \"john\" -> john@google.com). Safe for a small directory\n // of distinct first names; only matches when exactly one member matches.\n if (!row) {\n const words = String(rawEmail).toLowerCase().replace(/[^a-z0-9]+/g, \" \");\n const all = (await sqlite.execute(\"SELECT persona, name, employer, email FROM member_directory\")).rows;\n const hits = all.filter((r) => new RegExp(`\\\\b${String(r.email).split(\"@\")[0]}\\\\b`).test(words));\n if (hits.length === 1) row = hits[0];\n }\n if (!row) {\n return c.json({\n verified: false,\n message: \"No Benepass account found under that work email. Offer to try another email, or help with general questions / connect to a person.\",\n });\n }\n const m = findMemberById(row.persona as string)!;\n return c.json({\n verified: true,\n memberId: m.id,\n name: m.name,\n firstName: m.firstName,\n employer: m.employer,\n email: m.email,\n message: `Identity confirmed via work email. You may share ${m.firstName}'s account details. Use this email when calling account tools.`,\n });\n});\n\n// Find the member verified during the call by scanning the report's tool results for the\n// verifyMemberEmail result (deterministic — the result carries memberId). This is how the\n// end-of-call ticket gets attributed to the right person even though verify is an apiRequest.\nfunction memberFromReport(msg: any): Member | undefined {\n const msgs = msg.artifact?.messages ?? msg.messages ?? [];\n for (const mm of msgs) {\n if (mm.role !== \"tool_call_result\" && mm.role !== \"tool\") continue;\n const name = mm.name ?? mm.toolCallName ?? \"\";\n let result = mm.result;\n if (typeof result === \"string\") { try { result = JSON.parse(result); } catch { continue; } }\n if (result && result.verified && result.memberId) return findMemberById(result.memberId);\n if (name === \"verifyMemberEmail\" && result?.email) return findMemberByEmail(result.email);\n }\n return undefined;\n}\n\n// Pull the assistant's Structured Output result out of the end-of-call report.\n// Modern Vapi puts it at artifact.structuredOutputs[].result (an object matching\n// our schema). Falls back to the deprecated analysis.structuredData for safety.\nfunction extractStructuredOutput(msg: any): Record {\n const so = msg.artifact?.structuredOutputs ?? msg.call?.artifact?.structuredOutputs ?? {};\n for (const v of Object.values(so)) {\n const res = (v as any)?.result;\n if (res && typeof res === \"object\") return res;\n }\n return msg.analysis?.structuredData ?? {};\n}\n\n// ---------- Vapi server webhook: end-of-call report -> Intercom ticket for EVERY call ----------\napp.post(\"/vapi/webhook\", async (c) => {\n const body = await c.req.json();\n const msg = body.message ?? {};\n if (msg.type !== \"end-of-call-report\") return c.json({});\n const callId = msg.call?.id ?? \"unknown\";\n const callerPhone = msg.call?.customer?.number ?? \"\";\n const analysis = msg.analysis ?? {};\n const sd = extractStructuredOutput(msg);\n\n // If a ticket was already created mid-call (escalation), don't duplicate it.\n const existing = await sqlite.execute({ sql: \"SELECT ticket_id FROM call_log WHERE call_id = ?\", args: [callId] });\n if (existing.rows.length && existing.rows[0].ticket_id) {\n console.log(`call ${callId}: ticket ${existing.rows[0].ticket_id} already exists, skipping`);\n return c.json({});\n }\n\n // Attribute the ticket to the verified member: from the verify result in the report,\n // then the call session (account tools), then the caller's phone number.\n let m: Member | undefined = memberFromReport(msg);\n if (!m) {\n const sess = (await sqlite.execute({ sql: \"SELECT persona FROM call_session WHERE call_id = ?\", args: [callId] })).rows[0];\n if (sess) m = findMemberById(sess.persona as string);\n }\n if (!m) m = await resolveMember(callerPhone);\n // No verified member => the caller was never identified. Do NOT file a ticket or create a\n // phone-only contact — we only log tickets for verified members.\n if (!m) { console.log(`call ${callId}: caller never verified, no ticket filed`); return c.json({}); }\n const contact = await intercomContactFor(m, callerPhone);\n if (!contact) { console.error(`call ${callId}: no contact resolvable, skipping ticket`); return c.json({}); }\n\n const resolution = sd.resolution || \"AI Resolved\";\n const issueType = sd.issueType || \"General Inquiry\";\n const recordingUrl = msg.artifact?.recordingUrl ?? msg.recordingUrl ?? \"\";\n const ticket = await ic.createTicket({\n contactId: contact.id,\n title: `[Voice] ${issueType} — ${m?.name ?? callerPhone}`,\n description: analysis.summary ?? \"(no summary)\",\n issueType,\n resolution,\n language: sd.language || undefined,\n callId,\n recordingUrl,\n });\n // Every ticket stays OPEN in the inbox so it's visible on a live screen-share; the\n // Resolution attribute (AI Resolved vs Escalated to Human) carries the disposition.\n await sqlite.execute({\n sql: \"INSERT INTO call_log (call_id, phone, persona, ticket_id, disposition, summary, created_at) VALUES (?, ?, ?, ?, ?, ?, ?) ON CONFLICT(call_id) DO UPDATE SET ticket_id = excluded.ticket_id, disposition = excluded.disposition, summary = excluded.summary\",\n args: [callId, callerPhone, m?.id ?? null, String(ticket.id), String(resolution), String(analysis.summary ?? \"\"), Date.now()],\n });\n console.log(`call ${callId}: created ticket ${ticket.id} (${resolution})`);\n return c.json({});\n});\n\n// ---------- admin: map a real phone number to a demo persona ----------\napp.post(\"/admin/phone-map\", async (c) => {\n const { phone, persona } = await c.req.json();\n if (!phone || !findMemberById(persona)) return c.json({ error: \"need phone + valid persona (sarah|marcus|elena)\" }, 400);\n await sqlite.execute({\n sql: \"INSERT INTO phone_map (phone, persona) VALUES (?, ?) ON CONFLICT(phone) DO UPDATE SET persona = excluded.persona\",\n args: [normalizePhone(phone), persona],\n });\n return c.json({ ok: true, mapped: `${normalizePhone(phone)} -> ${persona}` });\n});\n\napp.get(\"/admin/phone-map\", async (c) => {\n const r = await sqlite.execute(\"SELECT phone, persona FROM phone_map\");\n return c.json(r.rows);\n});\n\n// ---------- status page ----------\napp.get(\"/\", async (c) => {\n const log = await sqlite.execute(\"SELECT * FROM call_log ORDER BY created_at DESC LIMIT 10\");\n const rows = log.rows.map((r: any) =>\n `${new Date(Number(r.created_at)).toLocaleString()}${r.phone}${r.persona ?? \"-\"}${r.disposition ?? \"-\"}${r.ticket_id ?? \"-\"}`\n ).join(\"\");\n return c.html(`Benepass × Vapi demo backend\n \n

Benepass × Vapi demo backend

This single small service is everything \"Benepass engineering\" provides. Vapi handles the voice agent, telephony, and orchestration.

POST /vapi/verify-email — authenticate a caller by checking their work email against the member directory
POST /vapi/tools — benefits, transactions, claims, Intercom KB search, chat history, ticket creation
POST /vapi/webhook — end-of-call report → Intercom ticket for every call (AI Resolved vs Escalated)

Demo members

\n \n \n \n

Member	Phone	Employer	Scenario
Sarah Chen	+1 415 555 0101	Hooli	Equinox card decline (wellness balance)
Marcus Johnson	+1 415 555 0102	Initech	Pending + denied reimbursement claims
Elena Rodriguez	+1 415 555 0103	Hooli	Commuter benefit (Spanish)

Recent calls

\n ${rows || \"\"}

Time	Caller	Persona	Disposition	Intercom ticket
none yet

View source

`);\n});\n\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\nexport default app.fetch;\n","label","benepass-vapi",[135],"12938dc2-7478-4b02-99e0-617266c28826",["D",1783484788923],7,[28],"9962cf15-72a8-4eab-8c2b-d82ea670eee6","data.ts","43c3173a-7a4e-11f1-a92c-1607ee4eb77e",41,["D",1783483320153],10,"// Mock Benepass member data. In production this is Benepass's own member/ledger API.\n\nexport interface Member {\n id: string;\n name: string;\n firstName: string;\n employer: string;\n email: string;\n phones: string[]; // E.164; extra numbers can be mapped via phone_map table\n benefits: Benefit[];\n transactions: Txn[];\n claims: Claim[];\n}\n\nexport interface Benefit {\n name: string;\n type: \"lifestyle\" | \"pretax\";\n cadence: string;\n allowance: number;\n remaining: number;\n resets: string;\n notes?: string;\n}\n\nexport interface Txn {\n date: string;\n merchant: string;\n amount: number;\n benefit: string;\n status: \"approved\" | \"declined\";\n declineReason?: string;\n}\n\nexport interface Claim {\n id: string;\n submitted: string;\n merchant: string;\n amount: number;\n benefit: string;\n status: \"approved\" | \"pending\" | \"denied\";\n detail: string;\n}\n\nexport const MEMBERS: Member[] = [\n {\n id: \"john\",\n name: \"John Miller\",\n firstName: \"John\",\n employer: \"Google\",\n email: \"john@google.com\",\n phones: [\"+14155550101\"],\n benefits: [\n { name: \"Wellness\", type: \"lifestyle\", cadence: \"monthly\", allowance: 150, remaining: 27.5, resets: \"1st of each month\", notes: \"Covers gyms, fitness classes, ski passes, wellness apps\" },\n { name: \"Commuter (pre-tax)\", type: \"pretax\", cadence: \"monthly\", allowance: 315, remaining: 180, resets: \"1st of each month\" },\n { name: \"Healthcare FSA\", type: \"pretax\", cadence: \"annual\", allowance: 3300, remaining: 1840, resets: \"Jan 1 (plan year)\" },\n ],\n transactions: [\n { date: \"2026-07-05\", merchant: \"Equinox\", amount: 185.0, benefit: \"Wellness\", status: \"declined\", declineReason: \"Insufficient benefit balance: purchase of $185.00 exceeds remaining monthly Wellness funds ($27.50). Wellness allowance resets on the 1st of each month.\" },\n { date: \"2026-07-03\", merchant: \"Barry's Bootcamp\", amount: 28.0, benefit: \"Wellness\", status: \"approved\" },\n { date: \"2026-07-01\", merchant: \"BART Clipper\", amount: 64.0, benefit: \"Commuter (pre-tax)\", status: \"approved\" },\n { date: \"2026-06-28\", merchant: \"CVS Pharmacy\", amount: 42.3, benefit: \"Healthcare FSA\", status: \"approved\" },\n ],\n claims: [],\n },\n {\n id: \"mike\",\n name: \"Mike Davis\",\n firstName: \"Mike\",\n employer: \"Yahoo\",\n email: \"mike@yahoo.com\",\n phones: [\"+14155550102\"],\n benefits: [\n { name: \"Wellness\", type: \"lifestyle\", cadence: \"monthly\", allowance: 100, remaining: 100, resets: \"1st of each month\" },\n { name: \"Professional Development\", type: \"lifestyle\", cadence: \"annual\", allowance: 1000, remaining: 650, resets: \"Jan 1\" },\n ],\n transactions: [\n { date: \"2026-06-20\", merchant: \"Coursera\", amount: 49.0, benefit: \"Professional Development\", status: \"approved\" },\n ],\n claims: [\n { id: \"CLM-2502\", submitted: \"2026-07-05\", merchant: \"Still Waters Massage\", amount: 120.0, benefit: \"Wellness\", status: \"pending\", detail: \"Under review. Reimbursement reviews complete within 3 business days; payout follows on the next payroll cycle.\" },\n { id: \"CLM-2481\", submitted: \"2026-06-28\", merchant: \"Gold's Gym\", amount: 89.0, benefit: \"Wellness\", status: \"denied\", detail: \"Denied 2026-06-30: receipt not itemized. The uploaded receipt shows the charge amount but is missing the membership period and provider details. Resubmit with an itemized receipt from the gym's member portal.\" },\n { id: \"CLM-2413\", submitted: \"2026-06-15\", merchant: \"Coursera\", amount: 49.0, benefit: \"Professional Development\", status: \"approved\", detail: \"Approved and paid out 2026-06-20 via payroll.\" },\n ],\n },\n {\n id: \"nick\",\n name: \"Nick Turner\",\n firstName: \"Nick\",\n employer: \"Microsoft\",\n email: \"nick@outlook.com\",\n phones: [\"+14155550103\"],\n benefits: [\n { name: \"Wellness\", type: \"lifestyle\", cadence: \"monthly\", allowance: 150, remaining: 150, resets: \"1st of each month\" },\n { name: \"Commuter (pre-tax)\", type: \"pretax\", cadence: \"monthly\", allowance: 315, remaining: 315, resets: \"1st of each month\" },\n { name: \"Healthcare FSA\", type: \"pretax\", cadence: \"annual\", allowance: 3300, remaining: 295, resets: \"Jan 1 (plan year)\" },\n ],\n transactions: [\n { date: \"2026-07-02\", merchant: \"MTA MetroCard\", amount: 33.0, benefit: \"Commuter (pre-tax)\", status: \"approved\" },\n ],\n claims: [],\n },\n];\n\nexport function normalizePhone(raw: string): string {\n const digits = (raw || \"\").replace(/\\D/g, \"\");\n return digits.slice(-10); // compare on last 10 digits\n}\n\nexport function findMemberByPhone(raw: string): Member | undefined {\n const n = normalizePhone(raw);\n if (!n) return undefined;\n return MEMBERS.find((m) => m.phones.some((p) => normalizePhone(p) === n));\n}\n\nexport function findMemberById(id: string): Member | undefined {\n return MEMBERS.find((m) => m.id === id);\n}\n\n// Normalize an email, tolerating spoken/STT forms like \"sarah dot chen at hooli dot com\".\nexport function normalizeEmail(raw: string): string {\n return (raw || \"\")\n .trim()\n .toLowerCase()\n .replace(/\\s+at\\s+/g, \"@\")\n .replace(/\\s+dot\\s+/g, \".\")\n .replace(/\\s+/g, \"\");\n}\n\nexport function findMemberByEmail(raw: string): Member | undefined {\n const e = normalizeEmail(raw);\n if (!e) return undefined;\n return MEMBERS.find((m) => m.email.toLowerCase() === e);\n}\n",[151],"pulls","branches",1,"forks","envVars",{"_166":168,"_169":63},"connections",{"_166":63,"_167":63},"count","unfilledCount",2,"emptyCount",{"_43":150,"_32":151,"_30":152,"_136":-5,"_41":42,"_40":153,"_138":59,"_38":180,"_13":155,"_33":34,"_35":156,"_24":25,"_143":-5,"_174":181,"_27":182},{"_43":146,"_32":28,"_30":31,"_136":-5,"_41":42,"_40":14,"_138":25,"_38":177,"_13":148,"_33":34,"_35":37,"_24":25,"_143":-5,"_174":178,"_27":179},{"_43":134,"_32":135,"_30":57,"_136":-5,"_41":42,"_40":137,"_138":25,"_38":173,"_13":140,"_33":141,"_35":142,"_24":25,"_143":144,"_174":175,"_27":176},["D",1783484405270],"children",[],[135],["D",1783484788923],[],[28],["D",1783483320153],[],[151],["D",1783461160403],["D",1789525245864],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_128":221,"_222":223,"_224":225,"_226":25,"_227":25,"_228":25,"_229":59,"_230":-5,"_231":-7,"_232":-7,"_233":63,"_234":25,"_235":25,"_236":-5,"_237":25,"_238":25,"_239":25,"_240":-5},"ENV",{"_192":193,"_194":195,"_196":90,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218,"_219":220},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","518c05f2c13b243481ef29134a5672756425e459","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 · v47