OpenAI Realtime API Voice Agent

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_271":272,"_273":274},"routes/_app.x.$handle.$name",{"_111":110,"_38":52,"_119":97,"_33":120,"_13":14,"_121":-5,"_11":122,"_123":124,"_125":126,"_127":128,"_129":130,"_26":-5,"_131":132,"_133":134,"_135":31,"_136":137,"_138":66,"_139":-5,"_140":-5,"_141":142},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_50":51,"_38":52,"_45":53,"_54":-5,"_55":31,"_56":57,"_58":57,"_59":60,"_61":-5,"_19":62,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":70,"_71":72,"_73":74,"_75":76,"_77":78,"_79":-5,"_80":81,"_82":81,"_83":84,"_85":84,"_86":84,"_87":81,"_88":81,"_89":90,"_91":92,"_93":94,"_95":31},"version",33,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","9177da42-c529-4172-baa5-e0acb4ced4c3","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":39,"_40":41,"_42":44,"_45":46,"_47":14,"_48":49,"_30":31},"previous",{"_36":37,"_38":39,"_40":41,"_42":43},"deleted",false,"deletedHere","path","routes/agent.ts","latestPath","fileId","019d8705-54fa-7761-a068-8d4dc61ae936","name","agent.ts","fileType","script","content","import { ObserverClient, ObserverHandler } from \"./observer.ts\";\nimport { getErrorText, makeHeaders, makeUrl } from \"./utils.ts\";\n\nconst MODEL = \"gpt-realtime-2\";\nconst TRANSCRIBE_MODEL = \"gpt-4o-transcribe\";\nconst NR_TYPE = \"near_field\";\n\nconst towniePrompt =\n await (await fetch(\"https://www.val.town/townie/system-prompt\"))\n .text();\n\nconst VOICE = \"marin\";\n\n// Builds the declarative session configuration for a Realtime API session.\n// The video parameter is accepted but not added to the session config —\n// video input works automatically via the WebRTC video track; the model\n// receives video frames without any special session-level flag.\nexport function makeSession(modelOverride?: string, _video?: boolean) {\n const model = modelOverride || MODEL;\n return {\n type: \"realtime\",\n model,\n instructions: towniePrompt,\n audio: {\n input: {\n noise_reduction: { type: NR_TYPE },\n transcription: { model: TRANSCRIBE_MODEL },\n },\n output: { voice: VOICE },\n },\n tools: [\n {\n type: \"mcp\",\n server_label: \"val_town_mcp\",\n server_url: \"https://api.val.town/v3/mcp\",\n require_approval: \"never\",\n headers: {\n \"Authorization\": `Bearer ${Deno.env.get(\"VAL_TOWN_API_KEY_2\")}`,\n },\n },\n {\n type: \"function\",\n name: \"display_text\",\n description:\n \"Display formatted text to the user's screen. Use this to show code snippets, links, lists, or any information that is better read than heard. The content supports full markdown including links, code blocks, bold, italic, lists, etc. Always use this tool when sharing URLs, code, or structured information.\",\n parameters: {\n type: \"object\",\n properties: {\n title: {\n type: \"string\",\n description: \"A short title for the displayed content\",\n },\n content: {\n type: \"string\",\n description:\n \"The markdown-formatted text content to display. Include links as [text](url), code as ```lang blocks, etc.\",\n },\n },\n required: [\"content\"],\n },\n },\n ],\n };\n}\n\n// AgentHandler implements the agent runtime behavior (tool calling, etc).\nclass AgentHandler implements ObserverHandler {\n private audioActive = false;\n private callEnding = false;\n constructor(private client: ObserverClient, private callId: string) {}\n onInit() {\n // Trigger a response immediately.\n // this.client.createResponse();\n }\n async onTool(name: string, _args: any) {\n console.log(\"🔧 function tool call:\", name, _args);\n }\n async onMcpCallCompleted(name: string, output: string | null) {\n console.log(\"🔧 MCP call completed:\", name, output?.slice(0, 200));\n // After an MCP tool call completes, the model has the results in context\n // but won't automatically generate a follow-up response. We need to\n // explicitly trigger a new response so it speaks the results.\n this.client.createResponse();\n }\n async onOutputAudioStarted() {\n this.audioActive = true;\n }\n async onOutputAudioStopped() {\n // Shut down the call and websocket once audio has finished spooling.\n this.audioActive = false;\n if (this.callEnding) {\n await this.hangup();\n }\n }\n async onOutputAudioCleared() {\n this.audioActive = false;\n }\n private async hangup() {\n const url = makeUrl(this.callId, \"hangup\");\n const resp = await fetch(url, { method: \"POST\", headers: makeHeaders() });\n if (!resp.ok) {\n console.error(`🔴 end call failed: ${await getErrorText(resp)}`);\n return;\n }\n\n console.log(\"✅ call ended\");\n }\n}\n\n// Creates the runtime handler for the session.\nexport function createHandler(client: ObserverClient, callId: string) {\n return new AgentHandler(client, callId);\n}","import { ObserverClient, ObserverHandler } from \"./observer.ts\";\nimport { getErrorText, makeHeaders, makeUrl } from \"./utils.ts\";\n\nconst MODEL = \"gpt-realtime-2\";\nconst TRANSCRIBE_MODEL = \"gpt-4o-transcribe\";\nconst NR_TYPE = \"near_field\";\n\nconst towniePrompt =\n await (await fetch(\"https://www.val.town/townie/system-prompt\"))\n .text();\n\nconst VOICE = \"marin\";\n\n// Builds the declarative session configuration for a Realtime API session.\n//\n// `accessToken` is a Val Town API token used to authenticate the embedded MCP\n// tool call to api.val.town. When the call originates from a logged-in user\n// (WebRTC flow), pass their OAuth access token so the MCP server acts on their\n// behalf. When omitted (e.g. SIP phone calls with no user identity), the MCP\n// tool is not attached and the model will not be able to read/edit vals.\n//\n// The video parameter is accepted but not added to the session config —\n// video input works automatically via the WebRTC video track; the model\n// receives video frames without any special session-level flag.\nexport function makeSession(\n modelOverride?: string,\n _video?: boolean,\n accessToken?: string,\n) {\n const model = modelOverride || MODEL;\n\n const tools: any[] = [\n {\n type: \"function\",\n name: \"display_text\",\n description:\n \"Display formatted text to the user's screen. Use this to show code snippets, links, lists, or any information that is better read than heard. The content supports full markdown including links, code blocks, bold, italic, lists, etc. Always use this tool when sharing URLs, code, or structured information.\",\n parameters: {\n type: \"object\",\n properties: {\n title: {\n type: \"string\",\n description: \"A short title for the displayed content\",\n },\n content: {\n type: \"string\",\n description:\n \"The markdown-formatted text content to display. Include links as [text](url), code as ```lang blocks, etc.\",\n },\n },\n required: [\"content\"],\n },\n },\n ];\n\n // Only attach the Val Town MCP server if we have an access token to\n // authenticate it with. Without one, the MCP endpoint would 401.\n if (accessToken) {\n tools.unshift({\n type: \"mcp\",\n server_label: \"val_town_mcp\",\n server_url: \"https://api.val.town/v3/mcp\",\n require_approval: \"never\",\n headers: {\n \"Authorization\": `Bearer ${accessToken}`,\n },\n });\n }\n\n return {\n type: \"realtime\",\n model,\n instructions: towniePrompt,\n audio: {\n input: {\n noise_reduction: { type: NR_TYPE },\n transcription: { model: TRANSCRIBE_MODEL },\n },\n output: { voice: VOICE },\n },\n tools,\n };\n}\n\n// AgentHandler implements the agent runtime behavior (tool calling, etc).\nclass AgentHandler implements ObserverHandler {\n private audioActive = false;\n private callEnding = false;\n constructor(private client: ObserverClient, private callId: string) {}\n onInit() {\n // Trigger a response immediately.\n // this.client.createResponse();\n }\n async onTool(name: string, _args: any) {\n console.log(\"🔧 function tool call:\", name, _args);\n }\n async onMcpCallCompleted(name: string, output: string | null) {\n console.log(\"🔧 MCP call completed:\", name, output?.slice(0, 200));\n // After an MCP tool call completes, the model has the results in context\n // but won't automatically generate a follow-up response. We need to\n // explicitly trigger a new response so it speaks the results.\n this.client.createResponse();\n }\n async onOutputAudioStarted() {\n this.audioActive = true;\n }\n async onOutputAudioStopped() {\n // Shut down the call and websocket once audio has finished spooling.\n this.audioActive = false;\n if (this.callEnding) {\n await this.hangup();\n }\n }\n async onOutputAudioCleared() {\n this.audioActive = false;\n }\n private async hangup() {\n const url = makeUrl(this.callId, \"hangup\");\n const resp = await fetch(url, { method: \"POST\", headers: makeHeaders() });\n if (!resp.ok) {\n console.error(`🔴 end call failed: ${await getErrorText(resp)}`);\n return;\n }\n\n console.log(\"✅ call ended\");\n }\n}\n\n// Creates the runtime handler for the session.\nexport function createHandler(client: ObserverClient, callId: string) {\n return new AgentHandler(client, callId);\n}\n","createdAt",["D",1778187876403],"branchVersion","branchId","53c6585e-373c-11f1-83b9-42b51c65c3df","id","53c0860e-373c-11f1-83b9-42b51c65c3df","hello-realtime-townie",["D",1776086766746],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Sample app for the OpenAI Realtime API","imageUrl","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","019d8705-54fa-7761-a068-abcc39ccfece","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","e81e7335-6d4c-4764-a902-d0962bbfa9f7","tursoName","53c0860e373c11f183b942b51c65c3df","tursoHostname","53c0860e373c11f183b942b51c65c3df-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789500689328],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_111":110,"_118":114},"org",{"_111":110,"_112":-5,"_113":114,"_19":62,"_115":116,"_117":31},"branch",{"_13":96,"_38":97,"_50":49,"_98":51,"_99":100,"_101":102,"_103":57,"_104":105,"_106":107,"_108":52,"_109":110},"isOwned",50,"main","projectId","forkedBranchId","be33420e-792a-11f0-bfa3-0224a6c84d84","forkedBranchVersion",375,"forkedProjectPrivacy","forkedProjectId","be2e762a-792a-11f0-bfa3-0224a6c84d84","forkedProjectOrgId","9c125825-8df1-4029-a26d-29049e9bd5a3","projectName","userHandle","stevekrouse","handle","displayName","avatar","https://images.clerk.dev/uploaded/img_2PqHa2Gsy93xQrjh2w78Xu0cChW.jpeg","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_50":51,"_38":52,"_45":266,"_54":-5,"_55":31,"_56":57,"_58":57,"_59":60,"_61":-5,"_19":62,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":70,"_71":72,"_73":74,"_75":76,"_77":267,"_79":-5,"_80":81,"_82":81,"_83":84,"_85":84,"_86":84,"_87":81,"_88":81,"_89":268,"_91":269,"_93":270,"_95":31},"tree",[200,202,208,209],"files",[200,201,202,203,204,205,206,207,208,209],"counts",{"_188":165,"_189":190,"_191":192,"_193":194,"_195":196},"contents",[155,156,157,158],"upstreamProject",{"_50":105,"_38":152,"_59":60,"_61":-5,"_56":57,"_89":153},"upstreamBranch",{"_50":100,"_45":143,"_144":145,"_38":97,"_98":105,"_13":146,"_99":147,"_101":148,"_149":150,"_54":-5,"_95":31,"_56":57,"_109":151,"_71":107,"_108":152},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1755188493466],"updatedAt",["D",1778178264384],379,"e004ac78-4230-11f0-834a-76b3cceeab13",47,"lockfileKey","1778178275619-esm.town_v_jubertioai_hello-realtime@379-main","jubertioai","hello-realtime",{"_111":151,"_118":154},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/61901958-12bd-49a3-43e9-2f67f1617200/square512?exp=1789567199&sig=465233add66c65d8f5bd931125370b08b09edf5c595cee224020d48ef67ab93a",{"_50":183,"_38":184,"_36":185,"_161":-5,"_48":49,"_47":165,"_163":66,"_45":186,"_13":70,"_40":181,"_42":-5,"_30":31,"_168":-5,"_33":187},{"_50":177,"_38":178,"_36":179,"_161":-5,"_48":49,"_47":165,"_163":66,"_45":180,"_13":70,"_40":181,"_42":-5,"_30":31,"_168":-5,"_33":182},{"_50":171,"_38":172,"_36":173,"_161":-5,"_48":49,"_47":165,"_163":66,"_45":174,"_13":70,"_40":26,"_42":175,"_30":31,"_168":-5,"_33":176},{"_50":159,"_38":160,"_36":64,"_161":-5,"_48":49,"_47":162,"_163":31,"_45":164,"_13":165,"_40":166,"_42":167,"_30":31,"_168":169,"_33":170},"1ec452d8-37f4-11f1-baeb-42b51c65c3df","main.tsx","parentId",29,"latest",["D",1776165705281],1,"http","import { Hono } from \"npm:hono\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { parseVal, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\n// import mcp from \"./routes/mcp.ts\";\nimport rtc from \"./routes/rtc.ts\";\nimport sip from \"./routes/sip.ts\";\nimport observer from \"./routes/observer.ts\";\n\nconst SOURCE_URL = parseVal(Deno.env.get(\"VALTOWN_ENTRYPOINT\")).links.self.val;\n\nconst app = new Hono();\napp.route(\"/rtc\", rtc);\napp.route(\"/sip\", sip);\napp.route(\"/observer\", observer);\n// app.route(\"/mcp\", mcp);\napp.get(\"/source\", (c) => c.redirect(SOURCE_URL));\n\napp.get(\"/\", () => serveFile(\"/frontend/index.html\", import.meta.url));\napp.get(\"/favicon.ico\", async (c) => {\n const entry = parseVal(Deno.env.get(\"VALTOWN_ENTRYPOINT\"));\n const file = await blob.get(`${entry.name}/favicon.ico`);\n if (!file) {\n return c.text(\"favicon not found\", 404);\n }\n return new Response(file.body, {\n headers: {\n \"Content-Type\": \"image/x-icon\",\n \"Cache-Control\": \"public, max-age=31536000, immutable\",\n },\n });\n});\n\napp.onError((err) => Promise.reject(err));\n\nexport default app.fetch;","label","townie-realtime",[160],"53cbbc86-373c-11f1-83b9-42b51c65c3df","README.md","019d8705-54fa-7761-a068-a5181925a024",["D",1776086766746],"# hello-realtime\n\n**Hello Realtime** is a OpenAI Realtime app that supports both WebRTC and SIP\n(telephone) users. You can access the app via WebRTC at\n[hello-realtime.val.run](https://hello-realtime.val.run), or via SIP by calling\n425-800-0042.\n\nThis demo shows off the new SIP API, the new all-in-one WebRTC API, and the new\nserver-side websocket interface.\n\nIf you remix the app, you'll just need to pop in your own `OPENAI_API_KEY` (from\n[platform.openai.com](https://platform.openai.com)), and if you want SIP, the\n`OPENAI_SIGNING_SECRET`.\n\n## Architecture\n\n1. **WebRTC Flow**:\n - Browser connects to frontend\n - creates WebRTC offer\n - `/rtc` endpoint handles SDP negotiation with OpenAI\n - observer established to monitor session\n2. **SIP Flow**:\n - Phone calls triggers webhook\n - `/sip` endpoint verifies webhook and accepts call\n - observer established to monitor session\n\n## API Endpoints\n\n- `GET /` - serves the WebRTC-based app\n- `POST /rtc` - creates a new WebRTC-based Realtime API session\n - Supports optional `model` URL parameter to override the default model\n - Example: `POST /rtc?model=gpt-4o-realtime-preview`\n- `POST /sip` - handles an incoming Realtime API SIP call\n- `POST /observer` - internal endpoint to establish a Realtime API websocket for\n session control\n\n## Project Structure\n\n```\n├── frontend/ \n│ └── index.html # HTML/JS application for WebRTC\n├── main.tsx # Main entrypoint for the val.town app\n└── routes/\n |\n ├── agent.ts # Realtime API session configuration and tools\n ├── observer.ts # Server-side session control for SIP & WebRTC\n ├── rtc.ts # WebRTC session setup\n ├── sip.ts # SIP webhook handling and session setup\n └── utils.ts # Various HTTP helpers\n```\n\n## File Links\n\n- [`frontend/index.html`](./frontend/index.html)\n- [`main.tsx`](./main.tsx)\n- [`routes/agent.ts`](./routes/agent.ts)\n- [`routes/observer.ts`](./routes/observer.ts)\n- [`routes/rtc.ts`](./routes/rtc.ts)\n- [`routes/sip.ts`](./routes/sip.ts)\n- [`routes/utils.ts`](./routes/utils.ts)",[172],"53cbbb0a-373c-11f1-83b9-42b51c65c3df","routes","019d8705-54fa-7761-a068-a3313eec009e",["D",1776086766746],"directory",[178],"53cb7bae-373c-11f1-83b9-42b51c65c3df","frontend","019d8705-54fa-7761-a068-88c6188f174a",["D",1776086766746],[184],"pulls","branches",2,"forks",3,"envVars",{"_197":190,"_199":70},"connections",{"_197":70,"_198":70},"count","unfilledCount","emptyCount",{"_50":183,"_38":184,"_36":185,"_161":-5,"_48":49,"_47":165,"_163":66,"_45":263,"_13":70,"_40":181,"_42":-5,"_30":31,"_168":-5,"_211":264,"_33":265},{"_50":255,"_38":256,"_36":257,"_161":185,"_48":49,"_47":258,"_163":31,"_45":259,"_13":190,"_40":26,"_42":260,"_30":31,"_168":-5,"_211":261,"_33":262},{"_50":177,"_38":178,"_36":179,"_161":-5,"_48":49,"_47":165,"_163":66,"_45":252,"_13":70,"_40":181,"_42":-5,"_30":31,"_168":-5,"_211":253,"_33":254},{"_50":247,"_38":39,"_36":37,"_161":179,"_48":49,"_47":14,"_163":66,"_45":248,"_13":249,"_40":41,"_42":44,"_30":31,"_168":-5,"_211":250,"_33":251},{"_50":239,"_38":240,"_36":241,"_161":179,"_48":49,"_47":242,"_163":66,"_45":243,"_13":190,"_40":41,"_42":244,"_30":31,"_168":-5,"_211":245,"_33":246},{"_50":231,"_38":232,"_36":233,"_161":179,"_48":49,"_47":234,"_163":31,"_45":235,"_13":165,"_40":41,"_42":236,"_30":31,"_168":-5,"_211":237,"_33":238},{"_50":224,"_38":225,"_36":226,"_161":179,"_48":49,"_47":165,"_163":31,"_45":227,"_13":70,"_40":41,"_42":228,"_30":31,"_168":-5,"_211":229,"_33":230},{"_50":217,"_38":218,"_36":219,"_161":179,"_48":49,"_47":165,"_163":66,"_45":220,"_13":70,"_40":41,"_42":221,"_30":31,"_168":-5,"_211":222,"_33":223},{"_50":171,"_38":172,"_36":173,"_161":-5,"_48":49,"_47":165,"_163":66,"_45":214,"_13":70,"_40":26,"_42":175,"_30":31,"_168":-5,"_211":215,"_33":216},{"_50":159,"_38":160,"_36":64,"_161":-5,"_48":49,"_47":162,"_163":31,"_45":210,"_13":165,"_40":166,"_42":167,"_30":31,"_168":169,"_211":212,"_33":213},["D",1776165705281],"children",[],[160],["D",1776086766746],[],[172],"53cbb448-373c-11f1-83b9-42b51c65c3df","utils.ts","019d8705-54fa-7761-a068-9c94857ce1ed",["D",1776086766746],"const REALTIME_BASE_URL = \"https://api.openai.com/v1/realtime\";\nconst OPENAI_API_KEY = Deno.env.get(\"OPENAI_API_KEY\");\nif (!OPENAI_API_KEY) {\n throw new Error(\"🔴 OpenAI API key not configured\");\n}\n\n// Builds the URL for a Realtime API endpoint.\nexport function makeUrl(callId?: string, action?: string) {\n let url = REALTIME_BASE_URL;\n if (!callId) {\n // start call (POST)\n url += \"/calls\";\n } else if (action) {\n // accept, reject, hangup (POST)\n url += `/calls/${callId}/${action}`;\n } else {\n // observer (web socket)\n url += `?call_id=${callId}`;\n }\n return url;\n}\n\n// Builds the headers for a Realtime API endpoint.\nexport function makeHeaders(contentType?: string) {\n const obj: Record = {\n Authorization: `Bearer ${OPENAI_API_KEY}`,\n };\n if (contentType) obj[\"Content-Type\"] = contentType;\n return obj;\n}\n\n// Debug helper for printing Realtime API errors.\nexport async function getErrorText(resp: Response) {\n const errBody = await resp.text().catch(() => \"\");\n return `${resp.status} ${resp.statusText}: ${errBody}`;\n}",[],[178,218],"53cba44e-373c-11f1-83b9-42b51c65c3df","sip.ts","019d8705-54fa-7761-a068-9bc0320eecb7",["D",1776086766746],"import { Hono } from \"npm:hono\";\nimport { Webhook } from \"npm:svix\";\nimport { makeSession } from \"./agent.ts\";\nimport { getErrorText, makeHeaders, makeUrl } from \"./utils.ts\";\n\nconst sip = new Hono();\n\n// POST /sip : webhook endpoint\nsip.post(\"/\", async (c) => {\n // Verify the webhook.\n const OPENAI_SIGNING_SECRET = Deno.env.get(\"OPENAI_SIGNING_SECRET\");\n if (!OPENAI_SIGNING_SECRET) {\n console.error(\"🔴 webhook secret not configured\");\n return c.text(\"Internal error\", 500);\n }\n const webhook = new Webhook(OPENAI_SIGNING_SECRET);\n const bodyStr = await c.req.text();\n let callId: string | undefined;\n let toNumber: string | undefined;\n try {\n const headers = Object.fromEntries(c.req.raw.headers.entries());\n const payload: any = webhook.verify(bodyStr, headers);\n callId = payload.data.call_id;\n toNumber = getToNumber(payload.data.sip_headers);\n const fromNumber = getFromNumber(payload.data.sip_headers);\n console.log(\"✅ verified webhook:\", callId, fromNumber, toNumber);\n } catch (error) {\n console.error(`🔴 verify failed: ${error}`);\n return c.text(\"Invalid signature\", 401);\n }\n\n // Accept the call.\n const model = getModelForNumber(toNumber);\n const url = makeUrl(callId, \"accept\");\n const headers = makeHeaders(\"application/json\");\n const body = JSON.stringify(makeSession(model));\n const opts = { method: \"POST\", headers, body };\n const resp = await fetch(url, opts);\n if (!resp.ok) {\n console.error(`🔴 accept failed: ${await getErrorText(resp)}`);\n return c.text(\"Internal error\", 500);\n }\n console.log(\"✅ call accepted:\", callId);\n\n // Kick off observer in the background (fire-and-forget).\n const selfUrl = new URL(c.req.url);\n fetch(`${selfUrl.origin}/observer/${callId}`, { method: \"POST\" })\n .catch((e) => console.error(\"observer start failed:\", e));\n\n return c.newResponse(null);\n});\n\nconst getToNumber = headers => getNumberFromSipHeader(headers, \"to\");\nconst getFromNumber = headers => getNumberFromSipHeader(headers, \"from\");\n\nfunction getNumberFromSipHeader(headers: any, name: string) {\n const header = getSipHeader(headers, name);\n const match = header?.match(/sip:\\+?(\\d+)@/);\n return match ? `+${match[1]}` : undefined;\n}\n\nfunction getSipHeader(headers: any, name: string) {\n return headers.find((h) => h.name.toLowerCase() === name)?.value;\n}\n\nfunction getModelForNumber(number: string) {\n const map = { \"+14258000074\": \"gpt-realtime-mini\" };\n return map[number];\n}\n\nexport default sip;",[],[178,225],"eed15cac-37f2-11f1-8358-42b51c65c3df","rtc.ts","019d8705-54fa-7761-a068-976e7d341d86",27,["D",1776165195323],"import { Hono } from \"npm:hono\";\nimport { makeSession } from \"./agent.ts\";\nimport { getErrorText, makeHeaders, makeUrl } from \"./utils.ts\";\n\nconst rtc = new Hono();\n\n// POST /rtc : create a new call\nrtc.post(\"/\", async (c) => {\n // Extract model parameter from URL if provided\n const model = c.req.query(\"model\");\n if (model !== undefined) {\n console.log(\"🔧 Model parameter received:\", model);\n }\n\n // Parse video flag from query (?video=true)\n const video = c.req.query(\"video\") === \"true\";\n if (video) {\n console.log(\"📹 Video mode enabled\");\n }\n \n // Create the call.\n const fd = new FormData();\n fd.set(\"sdp\", await c.req.text());\n fd.set(\"session\", JSON.stringify(makeSession(model, video)));\n const opts = { method: \"POST\", headers: makeHeaders(), body: fd };\n const resp = await fetch(makeUrl(), opts);\n if (!resp.ok) {\n console.error(`🔴 start call failed: ${await getErrorText(resp)}`);\n return c.text(\"Internal error\", 500);\n }\n\n const contentType = resp.headers.get(\"Content-Type\");\n const location = resp.headers.get(\"Location\");\n const callId = location?.split(\"/\").pop();\n console.log(\"✅ call created:\", callId);\n\n // Kick off observer in the background (fire-and-forget).\n const selfUrl = new URL(c.req.url);\n fetch(`${selfUrl.origin}/observer/${callId}`, { method: \"POST\" })\n .catch((e) => console.error(\"observer start failed:\", e));\n\n const responseHeaders = {\n \"Content-Type\": contentType,\n \"Location\": location,\n };\n return c.newResponse(resp.body, { headers: responseHeaders });\n});\n\nexport default rtc;",[],[178,232],"7c29d172-37f0-11f1-880b-42b51c65c3df","observer.ts","019d8705-54fa-7761-a068-91275444e97e",24,["D",1776164143983],"import { Hono } from \"npm:hono\";\nimport WebSocket from \"npm:ws\";\nimport { createHandler } from \"./agent.ts\";\nimport { makeHeaders, makeUrl } from \"./utils.ts\";\n\nexport interface ObserverHandler {\n onInit(): void;\n onTool(name: string, args: any): void;\n onMcpCallCompleted(name: string, output: string | null): void;\n onOutputAudioStarted(): void;\n onOutputAudioStopped(): void;\n onOutputAudioCleared(): void;\n}\n\nexport class ObserverClient {\n private ws: WebSocket;\n private closeResolve: () => void;\n private closePromise: Promise;\n private handler: ObserverHandler;\n\n constructor(callId: string) {\n const url = makeUrl(callId);\n this.ws = new WebSocket(url, { headers: makeHeaders() });\n this.ws.on(\"open\", () => this.handleOpen());\n this.ws.on(\"message\", (data) => this.handleMessage(JSON.parse(data)));\n this.ws.on(\"error\", (err) => this.handleError(err));\n this.ws.on(\"close\", (ev) => this.handleClose(ev));\n this.closePromise = new Promise((resolve) =>\n this.closeResolve = resolve\n );\n this.handler = createHandler(this, callId);\n }\n createResponse() {\n this.sendMessage({ type: \"response.create\" });\n }\n async waitForClose() {\n await this.closePromise;\n }\n private sendMessage(message: any) {\n this.ws.send(JSON.stringify(message));\n }\n private handleOpen() {\n console.log(\"✅ websocket connected\");\n this.handler.onInit();\n }\n private async handleMessage(message: any) {\n if (!message.type.endsWith(\".delta\")) { // ignore verbose messages\n console.log(message);\n }\n switch (message.type) {\n case \"response.function_call_arguments.done\":\n this.handler.onTool(message.name, message.arguments);\n break;\n case \"response.output_item.done\":\n if (message.item?.type === \"mcp_call\") {\n this.handler.onMcpCallCompleted(message.item.name, message.item.output);\n }\n break;\n case \"output_audio_buffer.started\":\n this.handler.onOutputAudioStarted();\n break;\n case \"output_audio_buffer.stopped\":\n this.handler.onOutputAudioStopped();\n break;\n case \"output_audio_buffer.cleared\":\n this.handler.onOutputAudioCleared();\n break;\n }\n }\n private handleError(err: Error) {\n console.error(`🔴 websocket failed: ${err.message}`);\n this.closeResolve();\n }\n private handleClose(e: Event) {\n console.log(`websocket closed: ${e}`);\n this.closeResolve();\n }\n}\n\nconst observer = new Hono();\n\n// POST /observer/:callId : self-connect to establish a web socket\nobserver.post(\"/:callId\", async (c) => {\n const callId = c.req.param(\"callId\");\n const client = new ObserverClient(callId);\n await client.waitForClose();\n return c.newResponse(null);\n});\n\nexport default observer;",[],[178,240],"5aaf9ff2-4a58-11f1-b7d6-ee650bb23af1",["D",1778187876403],20,[],[178,39],["D",1776086766746],[203,204,205,206,207],[178],"059adc62-3800-11f1-a538-42b51c65c3df","index.html","019d8705-54fa-7761-a068-8455826e2ed1",31,["D",1776170817022],"\n\n \n \n \n OpenAI Realtime API Voice Agent\n \n \n \n \n \n\n

\n\n

\n\n \n \n",[],[184,256],["D",1776086766746],[201],[184],["D",1776086766746],["D",1789500689328],{"_111":110,"_118":114},{"_111":110,"_112":-5,"_113":114,"_19":62,"_115":116,"_117":31},{"_13":96,"_38":97,"_50":49,"_98":51,"_99":100,"_101":102,"_103":57,"_104":105,"_106":107,"_108":52,"_109":110},"ctx",{"_89":-5,"_140":304,"_305":306,"_307":308,"_309":31,"_310":31,"_311":31,"_312":66,"_313":-5,"_314":-7,"_315":-7,"_316":70,"_317":31,"_318":31,"_319":-5,"_320":31,"_321":31,"_322":31,"_323":-5},"ENV",{"_275":276,"_277":278,"_279":97,"_280":281,"_282":283,"_284":285,"_286":287,"_288":289,"_290":291,"_292":293,"_294":295,"_296":297,"_298":299,"_300":301,"_302":303},"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"]

Realtime Agent

Diff · v33