Update README.md

README.md

@@ -1,8 +1,8 @@
 ---
 title: MOHBIM Custom Livekit API V1
 emoji: 🚦
-colorFrom: indigo
-colorTo: yellow
+colorFrom: gray
+colorTo: blue
 sdk: docker
 pinned: false
 short_description: Custom LK REST API router v1

common/db.js

@@ -0,0 +1,5 @@
+import pg from 'pg'
+import { env } from '../config/utils.js'
+
+const pool = new pg.Pool({ connectionString: env.LK_DATABASE_URL })
+export const query = (sql, params) => pool.query(sql, params)

config/utils.js

@@ -0,0 +1,17 @@
+import { AgentDispatchClient, SipClient } from 'livekit-server-sdk'
+
+import { z } from 'zod'
+
+const env = z.object({
+  LIVEKIT_API_KEY: z.string().min(1),
+  LIVEKIT_API_SECRET: z.string().min(1),
+  LIVEKIT_URL: z.string().url(),
+  API_PORT_NUM: z.coerce.number().default(3000),
+  LK_DATABASE_URL: z.string().url(),
+}).parse(process.env)
+ 
+const lkEnvArgs = [env.LIVEKIT_URL, env.LIVEKIT_API_KEY, env.LIVEKIT_API_SECRET]
+const agentDispatchClient = new AgentDispatchClient(...lkEnvArgs)
+const sipClient = new SipClient(...lkEnvArgs)
+
+export { env, lkEnvArgs, agentDispatchClient, sipClient }

dao/agent.js

@@ -0,0 +1,48 @@
+import { query } from '../common/db.js'
+
+export async function createAgent(name, decodedPrompt, stt, llm, tts, variablesSchema) {
+	const { rows } = await query(
+	    'INSERT INTO agent (name, system_prompt, stt, llm, tts, variables_schema) \
+	     VALUES ($1, $2, $3, $4, $5, $6) RETURNING id',
+	   	[name, decodedPrompt, JSON.stringify(stt), JSON.stringify(llm), JSON.stringify(tts), JSON.stringify(variablesSchema)]
+  	)
+
+  	return { agentId: rows[0].id }
+}
+
+export async function getAgent(agentId) {
+	console.log(agentId)
+	const { rows } = await query('SELECT * FROM agent WHERE id = $1', [agentId])
+	// console.log(rows)
+	if(!rows.length) return {error: 'Agent not found', code:404}
+	return rows[0]
+}
+
+
+export async function listAgents() {
+	const { rows } = await query('SELECT id, name, created_at \
+                                FROM agent \
+                                ORDER BY created_at DESC')
+  
+	// console.log(JSON.stringify(rows, null, 2))
+	if(!rows.length) return {error: 'Agent not found', code:404}
+	return rows
+}
+
+
+export async function updateAgent(fields, values, i) {
+	const { rows } = await query(
+		`UPDATE agent SET ${fields.join(', ')} WHERE id = $${i} RETURNING id`,
+	    values
+	  )
+	
+	return rows	
+}
+
+
+export async function deleteAgent(agentId) {
+	const { rows } = await query('DELETE FROM agent WHERE id = $1 RETURNING id', [agentId])
+	
+	if (!rows.length) return { error: 'Agent not found', code:404 }
+	return rows
+}

dao/call.js

@@ -0,0 +1,77 @@
+import { agentDispatchClient, sipClient } from '../config/utils.js'
+
+import { query } from '../common/db.js'
+
+export async function createCall(formattedNumber, agentId, variables) {
+	// const { rows: agentRows } = await query(
+	// 	`SELECT name FROM agent WHERE id = $1`, 
+	// 	[agentId]
+	// )
+
+	// if (!agentRows.length) return { error: 'Agent not found !', code: 404 }
+	// const { name: agentName } = agentRows[0]
+
+	const { rows: outboundTrunkRows } = await query(
+		`SELECT lk_trunk_id FROM trunk where direction='outbound'`
+	)
+
+	if (!outboundTrunkRows.length) return {error: 'Outbound trunk not found !', code: 404}
+	const {lk_trunk_id: lkTrunkId} = outboundTrunkRows[0]
+	console.log('Using lkTrunkId: ', lkTrunkId)
+
+	const roomName = `room_${Math.floor(Math.random() * 10_000)}`
+	const participantIdentity = `caller_${formattedNumber}` 
+	const outboundDispatch = await agentDispatchClient.createDispatch(
+		// roomName, agentName, { 
+		roomName, '', { 
+			metadata: JSON.stringify({ agentId, phoneNumber: formattedNumber, variables }) 
+		}
+	)
+	console.log('Outbound dispatch is: ', JSON.stringify(outboundDispatch, null, 2))
+
+	const sipParticipant = await sipClient.createSipParticipant(lkTrunkId, formattedNumber, roomName, { participantIdentity })
+	console.log('sipParticipant is: ', JSON.stringify(sipParticipant, null, 2))
+
+    // Store call in database
+    const { rows: callRows } = await query(
+        `INSERT INTO call_log 
+         (call_to, agent_id, variables, room_id, dispatch_id, sip_participant_id, status, created_at)
+         VALUES ($1, $2, $3, $4, $5, $6, 'active', NOW())
+         RETURNING id`,
+        [formattedNumber, agentId, JSON.stringify(variables), roomName, outboundDispatch.id, sipParticipant.participantId]
+    )
+    console.log('Logged the call: ', callRows)
+
+	return { success: true, roomId: roomName, dispatchId: outboundDispatch.id, sipParticipantId: sipParticipant.participantId }
+
+}
+
+export async function getCalls() {
+    const { rows } = await query(
+        `SELECT id, call_to as "callTo", agent_id as "agentId",
+                variables, status,
+                created_at as "createdAt",
+        		duration,
+        		text_transcript as "textTranscript",
+        		audio_transcript as "audioTranscript"
+         FROM call_log
+         ORDER BY created_at DESC`
+    )
+
+    return { calls: rows }
+}
+
+export async function getCall(id) {
+    const { rows } = await query(
+        `SELECT id, call_to as "callTo", agent_id as "agentId",
+                variables, room_id as "roomId", dispatch_id as "dispatchId",
+                sip_participant_id as "sipParticipantId", status,
+                created_at as "createdAt"
+         FROM call_log
+         WHERE id = $1`,
+        [id]
+    )
+
+    if (!rows.length) return { error: 'Call not found', code: 404 }
+    return rows[0]
+}

dao/schema.js

@@ -0,0 +1,47 @@
+import { query } from '../common/db.js'
+
+export async function createSchema(name, contents, system_prompt) {
+	const { rows } = await query(
+	    `INSERT INTO output_schema (name, schema, system_prompt)
+	     VALUES ($1, $2, $3) RETURNING id`,
+	   	[name, contents, system_prompt]
+  	)
+
+  	return { schemaId: rows[0].id }
+}
+
+export async function getSchema(schemaId) {
+	const { rows: schema } = await query(`SELECT name, schema, system_prompt
+										FROM output_schema
+										WHERE id = $1`, 
+										[schemaId])
+	return schema
+}
+
+
+export async function listSchemas() {
+	const { rows } = await query(`SELECT id, name, created_at
+                                FROM output_schema
+                                ORDER BY created_at DESC`)
+  
+	console.log(JSON.stringify(rows, null, 2))
+	return rows
+}
+
+
+export async function updateSchema(fields, values, i) {
+	const { rows } = await query(
+		`UPDATE output_schema 
+		SET ${fields.join(', ')} 
+		WHERE id = $${i} RETURNING id`,
+	    values
+	  )
+	return rows	
+}
+
+
+export async function deleteSchema(schemaId) {
+	const { rows } = await query('DELETE FROM output_schema WHERE id = $1 RETURNING id', [schemaId])
+	if (!rows.length) return { error: 'schema not found', code:404 }
+	return rows
+}

dao/trunk.js

@@ -0,0 +1,39 @@
+import { query } from '../common/db.js'
+
+export async function createSipTrunk(name, trunkType, sipTrunkId, address) {
+	if (trunkType === 'outbound' && address) {
+		const { rows } = await query(
+		  	'INSERT INTO trunk(name, direction, lk_trunk_id, address) VALUES($1, $2, $3, $4) RETURNING id',
+		  	[name, trunkType, sipTrunkId, address]
+	  	)
+		return rows
+	} else {
+		const { rows } = await query(
+		  	'INSERT INTO trunk(name, direction, lk_trunk_id) VALUES($1, $2, $3) RETURNING id',
+		  	[name, trunkType, sipTrunkId]
+	  	)
+	  	return rows
+	}
+}
+
+
+export async function getInboundTrunk(sipTrunkId) {
+  const { rows: inboundTrunk } = await query(
+  	`SELECT lk_trunk_id FROM trunk WHERE direction = 'inbound' AND id = $1`, 
+  	[sipTrunkId])
+  return inboundTrunk
+}
+
+export async function updateTrunk(fields, values, i) {
+	const { rows } = await query(
+		`UPDATE trunk SET ${fields.join(', ')} WHERE lk_trunk_id = $${i} RETURNING id`,
+	    values
+	  )
+	return rows	
+}
+
+export async function deleteTrunk(trunkId) {
+	const { rows } = await query('DELETE FROM trunk WHERE id = $1 RETURNING id', [trunkId])
+	if (!rows.length) return { error: 'Trunk not found', code:404 }
+	return rows
+}

db.js

@@ -1,5 +0,0 @@
-import pg from 'pg'
-import { env } from './utils.js'
-
-const pool = new pg.Pool({ connectionString: env.DATABASE_URL })
-export const query = (sql, params) => pool.query(sql, params)

docs/index.html

@@ -0,0 +1,25 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>LK-VAPI-Migration - API Documentation</title>
+    <style>
+        body { margin: 0; padding: 0; }
+        #opencollection-container { width: 100vw; height: 100vh; }
+    </style>
+    <link rel="stylesheet" href="https://cdn.opencollection.com/docs.css">
+    <script src="https://cdn.opencollection.com/docs.js"></script>
+</head>
+<body>
+    <div id="opencollection-container"></div>
+    <script>
+        const collectionData = "opencollection: 1.0.0\ninfo:\n  name: LK-VAPI-Migration\nitems:\n  - info:\n      name: STRUCTURED OUTPUTS\n      type: folder\n      seq: 3\n    request:\n      auth: inherit\n    items:\n      - info:\n          name: AZ Generate JSON (chatcompl)\n          type: http\n          seq: 2\n        http:\n          method: POST\n          url: https://{{RESOURCE_NAME}}.openai.azure.com/openai/deployments/{{AZURE_DEPLOYMENT}}/chat/completions?api-version=2024-12-01-preview\n          headers:\n            - name: api-key\n              value: '{{AZURE_API_KEY}}'\n            - name: content-type\n              value: application/json\n          params:\n            - name: api-version\n              value: 2024-12-01-preview\n              type: query\n          body:\n            type: json\n            data: |-\n              {\n                \"temperature\": 0,\n                \"messages\": [\n                  {\n                    \"role\": \"system\",\n                    \"content\": \"Extract comprehensive employment verification data from the complete reference call transcript as per the json schema provided.\"\n                  },\n                  {\n                    \"role\": \"user\",\n                    \"content\": \"{{TRANSCRIPT_STR}}\"\n                  }\n                ],\n                \"response_format\": {\n                  \"type\": \"json_schema\",\n                  \"json_schema\": {{SCHEMA}}\n                },\n                \"stream\": false\n              }\n          auth: inherit\n        runtime:\n          variables:\n            - name: TRANSCRIPT_ARR\n              value: '[{\"role\":\"assistant\",\"text\":\"Hi Reese Snow, this is Sarah from Acme Inc.. I''m calling about Melissa Sanders — they mentioned you as a professional reference. Do\",\"timestamp\":1774011919966},{\"role\":\"user\",\"text\":\"Yes.\",\"timestamp\":1774011948363},{\"role\":\"assistant\",\"text\":\"Great! First, could you tell me how you know Melissa Sanders and what your working relationship was?\",\"timestamp\":1774011948366},{\"role\":\"user\",\"text\":\"I know Melissa from Tech Innovations where we collaborated on a software project for two years.\",\"timestamp\":1774011967199},{\"role\":\"user\",\"text\":\"I was the project manager.\",\"timestamp\":1774011971106},{\"role\":\"user\",\"text\":\"And Melissa was the lead developer. We worked closely together sharing insights and achieving project goals.\",\"timestamp\":1774011975877},{\"role\":\"assistant\",\"text\":\"That''s really helpful, thank you. Next — what really stands out about Melissa Sanders? I''m particularly curious about how they handle pressure, their customer service approach, and overall professionalism.\",\"timestamp\":1774011975878},{\"role\":\"user\",\"text\":\"We worked together for approximately two years\",\"timestamp\":1774012003556},{\"role\":\"user\",\"text\":\"building a strong professional rapport during that time.\",\"timestamp\":1774012004276},{\"role\":\"user\",\"text\":\"Melissa excels under pressure. Consistently delivering quality results during tight deadlines\",\"timestamp\":1774012010788},{\"role\":\"user\",\"text\":\"customer service is exceptional\",\"timestamp\":1774012015978},{\"role\":\"user\",\"text\":\"She listens and offers tailored solutions. Overall, she embodies professionalism\",\"timestamp\":1774012021547},{\"role\":\"user\",\"text\":\"and fosters a positive team environment.\",\"timestamp\":1774012022269},{\"role\":\"assistant\",\"text\":\"That''s really helpful, thank you. Next — how would you describe Melissa''s style working with others — colleagues, customers, that sort of thing?\",\"timestamp\":1774012022271},{\"role\":\"user\",\"text\":\"Melissa is collaborative and approachable.\",\"timestamp\":1774012040673},{\"role\":\"user\",\"text\":\"She encourages open dialogue with colleagues and builds strong relationships with customers\",\"timestamp\":1774012048777},{\"role\":\"user\",\"text\":\"through empathy and effective communication.\",\"timestamp\":1774012049501},{\"role\":\"assistant\",\"text\":\"That''s really helpful, thank you. Next — if you were their supervisor, what''s one piece of advice you''d give me to help Melissa Sanders succeed in this role?\",\"timestamp\":1774012049502},{\"role\":\"user\",\"text\":\"Encourage Melissa to seek regular feedback from peers and clients\",\"timestamp\":1774012075077},{\"role\":\"user\",\"text\":\"to enhance her skills further.\",\"timestamp\":1774012079497},{\"role\":\"user\",\"text\":\"Opportunities for professional development will also support her growth.\",\"timestamp\":1774012080192},{\"role\":\"assistant\",\"text\":\"That''s really helpful, thank you. Next — based on what you know about our Project Manager role, do you think Melissa Sanders would be a good match? I''d love your honest thoughts.\",\"timestamp\":1774012080193},{\"role\":\"user\",\"text\":\"Absolutely. Her organizational skills, ability to handle pressure, and strong customer service focus make her an excellent fit\",\"timestamp\":1774012108137},{\"role\":\"user\",\"text\":\"for the project manager role.\",\"timestamp\":1774012109131},{\"role\":\"assistant\",\"text\":\"That''s really helpful, thank you. Next — before we wrap up, is there anything else about Melissa Sanders that would help us make the best decision?\",\"timestamp\":1774012109133},{\"role\":\"user\",\"text\":\"Melissa''s adaptability and eagerness to learn\",\"timestamp\":1774012129447},{\"role\":\"user\",\"text\":\"are significant assets. Her positive attitude enhances team morale.\",\"timestamp\":1774012136327},{\"role\":\"user\",\"text\":\"Making her a valuable addition to any organization.\",\"timestamp\":1774012136940},{\"role\":\"assistant\",\"text\":\"This has been incredibly helpful — thank you so much for your time and insights. We really appreciate you helping us get to know Melissa Sanders better. Have a wonderful day!\",\"timestamp\":1774012136942},{\"role\":\"user\",\"text\":\"Thank you.\",\"timestamp\":1774012157057},{\"role\":\"user\",\"text\":\"Goodbye.\",\"timestamp\":1774012158599},{\"role\":\"assistant\",\"text\":\"Ending the call now.\",\"timestamp\":1774012167994},{\"role\":\"assistant\",\"text\":\"Goodbye!\",\"timestamp\":1774012167994}]'\n            - name: SCHEMA\n              value: '{\"name\":\"refcheck\",\"schema\":{\"description\":\"Extract comprehensive employment verification data from HR reference calls\",\"type\":\"object\",\"properties\":{\"callMetadata\":{\"type\":\"object\",\"properties\":{\"callDuration\":{\"description\":\"Length of the reference call\",\"type\":\"string\"},\"informationQuality\":{\"description\":\"Quality and depth of information provided\",\"type\":\"string\",\"enum\":[\"detailed\",\"adequate\",\"brief\",\"minimal\"]},\"referenceWillingness\":{\"description\":\"Reference''s attitude during the call\",\"type\":\"string\",\"enum\":[\"enthusiastic\",\"cooperative\",\"hesitant\",\"rushed\"]}},\"required\":[\"callDuration\",\"referenceWillingness\"]},\"teamDynamics\":{\"type\":\"object\",\"properties\":{\"teamworkStyle\":{\"description\":\"Overall teamwork approach\",\"type\":\"string\",\"enum\":[\"collaborative\",\"independent\",\"leadership\",\"supportive\",\"mixed\"]},\"customerInteraction\":{\"description\":\"How candidate interacts with customers\",\"type\":\"string\"},\"colleagueInteraction\":{\"description\":\"How candidate works with colleagues\",\"type\":\"string\"}},\"required\":[\"customerInteraction\",\"colleagueInteraction\"]},\"fitAssessment\":{\"type\":\"object\",\"properties\":{\"concerns\":{\"description\":\"Any concerns or reservations mentioned\",\"type\":\"array\",\"items\":{\"type\":\"string\"}},\"roleMatch\":{\"description\":\"Whether candidate is a good match for the position\",\"type\":\"boolean\"},\"fitReasoning\":{\"description\":\"Explanation for fit assessment\",\"type\":\"string\"}},\"required\":[\"roleMatch\",\"fitReasoning\"]},\"referenceInfo\":{\"type\":\"object\",\"properties\":{\"relationship\":{\"description\":\"Professional relationship to candidate\",\"type\":\"string\",\"enum\":[\"supervisor\",\"colleague\",\"direct_report\",\"client\",\"other\"]},\"workDuration\":{\"description\":\"Duration of working together\",\"type\":\"string\"},\"durationKnown\":{\"description\":\"How long the reference has known the candidate\",\"type\":\"string\"},\"referenceName\":{\"description\":\"Name of the reference person\",\"type\":\"string\"},\"relationshipDescription\":{\"description\":\"Detailed description of working relationship\",\"type\":\"string\"}},\"required\":[\"relationship\",\"durationKnown\",\"referenceName\"]},\"candidateStrengths\":{\"type\":\"object\",\"properties\":{\"keyStrengths\":{\"description\":\"List of standout qualities mentioned\",\"type\":\"array\",\"items\":{\"type\":\"string\"}},\"customerService\":{\"description\":\"Customer service approach and skills\",\"type\":\"string\"},\"professionalism\":{\"description\":\"Overall professional conduct\",\"type\":\"string\"},\"pressureHandling\":{\"description\":\"How candidate handles pressure situations\",\"type\":\"string\"}},\"required\":[\"customerService\",\"professionalism\",\"pressureHandling\"]},\"managementInsights\":{\"type\":\"object\",\"properties\":{\"successAdvice\":{\"description\":\"Advice for candidate''s success in the role\",\"type\":\"string\"},\"improvementAreas\":{\"description\":\"Areas where candidate could improve\",\"type\":\"array\",\"items\":{\"type\":\"string\"}}},\"required\":[\"successAdvice\"]},\"overallRecommendation\":{\"type\":\"object\",\"properties\":{\"wouldHire\":{\"description\":\"Whether reference would hire the candidate\",\"type\":\"boolean\"},\"additionalComments\":{\"description\":\"Any final thoughts or additional insights\",\"type\":\"string\"},\"recommendationLevel\":{\"description\":\"Overall recommendation level\",\"type\":\"string\",\"enum\":[\"strongly_recommend\",\"recommend\",\"neutral\",\"do_not_recommend\"]}},\"required\":[\"wouldHire\",\"recommendationLevel\"]}},\"required\":[\"teamDynamics\",\"fitAssessment\",\"referenceInfo\",\"candidateStrengths\",\"managementInsights\",\"overallRecommendation\"]}}'\n            - name: RESOURCE_NAME\n              value: o247-ai-sandbox\n            - name: AZURE_API_KEY\n              value: azure_openai_apikey\n            - name: AZURE_DEPLOYMENT\n              value: gpt-4o-mini\n          scripts:\n            - type: before-request\n              code: |-\n                const transcriptArr = JSON.parse(bru.getRequestVar(\"TRANSCRIPT_ARR\"))\n                const transcriptStr = transcriptArr.map(item => {\n                  const role = item.role || 'unknown';\n                  const text = item.text || '';\n                  return `${role.charAt(0).toUpperCase() + role.slice(1)}: ${text}`;\n                })\n                .filter(line => line.trim() !== '')\n                .join('\\\\n');\n\n                bru.setEnvVar(\"TRANSCRIPT_STR\", transcriptStr)\n        settings:\n          encodeUrl: true\n          timeout: 0\n          followRedirects: true\n          maxRedirects: 5\n      - info:\n          name: Basic HF - gpt-oss-120b\n          type: http\n          seq: 5\n        http:\n          method: POST\n          url: https://router.huggingface.co/v1/chat/completions\n          headers:\n            - name: content-type\n              value: application/json\n            - name: Authorization\n              value: Bearer hf_api_key\n          body:\n            type: json\n            data: |-\n              {\n                \"model\": \"openai/gpt-oss-120b:groq\",\n                \"messages\": [\n                  {\n                    \"role\": \"user\",\n                    \"content\": \"Say hello world\"\n                  }\n                ],\n                \"stream\": false\n              }\n          auth: inherit\n        settings:\n          encodeUrl: false\n          timeout: 0\n          followRedirects: true\n          maxRedirects: 5\n      - info:\n          name: BasicCerebras- gpt-oss-120b\n          type: http\n          seq: 4\n        http:\n          method: POST\n          url: https://api.cerebras.ai/v1/chat/completions\n          headers:\n            - name: content-type\n              value: application/json\n            - name: Authorization\n              value: Bearer csk-exnjrkyfph9frctwt46wprjdm99j5x2hk9ecvfw3t2enjh95\n          body:\n            type: json\n            data: |-\n              {\n                \"model\": \"gpt-oss-120b\",\n                \"messages\": [\n                  {\n                    \"role\": \"user\",\n                    \"content\": \"Say hello world\"\n                  }\n                ],\n                \"stream\": false\n              }\n          auth: inherit\n        settings:\n          encodeUrl: false\n          timeout: 0\n          followRedirects: true\n          maxRedirects: 5\n      - info:\n          name: CF Generate JSON (chatcompl)\n          type: http\n          seq: 1\n        http:\n          method: POST\n          url: https://wandering-morning-bdee.mohbim.workers.dev/\n          body:\n            type: json\n            data: |-\n              {  \n                    \"model\": \"qwen-3-235b-a22b-instruct-2507\",  \n                    \"temperature\": 0,  \n                    \"messages\": [    \n                      {    \n                        \"role\": \"system\",    \n                        \"content\": \"Extract comprehensive employment verification data from the complete reference call transcript as per the json schema provided.\"    \n                      },    \n                      {    \n                        \"role\": \"user\",    \n                        \"content\": \"{{TRANSCRIPT_STR}}\"\n                      }    \n                    ],    \n                    \"response_format\": {    \n                      \"type\": \"json_schema\",\n                      \"json_schema\": {{SCHEMA}}\n                    },    \n                    \"stream\": false    \n                  }\n          auth: inherit\n        runtime:\n          variables:\n            - name: TRANSCRIPT_ARR\n              value: '[{\"role\":\"assistant\",\"text\":\"Hi Reese Snow, this is Sarah from Acme Inc.. I''m calling about Melissa Sanders — they mentioned you as a professional reference. Do\",\"timestamp\":1774011919966},{\"role\":\"user\",\"text\":\"Yes.\",\"timestamp\":1774011948363},{\"role\":\"assistant\",\"text\":\"Great! First, could you tell me how you know Melissa Sanders and what your working relationship was?\",\"timestamp\":1774011948366},{\"role\":\"user\",\"text\":\"I know Melissa from Tech Innovations where we collaborated on a software project for two years.\",\"timestamp\":1774011967199},{\"role\":\"user\",\"text\":\"I was the project manager.\",\"timestamp\":1774011971106},{\"role\":\"user\",\"text\":\"And Melissa was the lead developer. We worked closely together sharing insights and achieving project goals.\",\"timestamp\":1774011975877},{\"role\":\"assistant\",\"text\":\"That''s really helpful, thank you. Next — what really stands out about Melissa Sanders? I''m particularly curious about how they handle pressure, their customer service approach, and overall professionalism.\",\"timestamp\":1774011975878},{\"role\":\"user\",\"text\":\"We worked together for approximately two years\",\"timestamp\":1774012003556},{\"role\":\"user\",\"text\":\"building a strong professional rapport during that time.\",\"timestamp\":1774012004276},{\"role\":\"user\",\"text\":\"Melissa excels under pressure. Consistently delivering quality results during tight deadlines\",\"timestamp\":1774012010788},{\"role\":\"user\",\"text\":\"customer service is exceptional\",\"timestamp\":1774012015978},{\"role\":\"user\",\"text\":\"She listens and offers tailored solutions. Overall, she embodies professionalism\",\"timestamp\":1774012021547},{\"role\":\"user\",\"text\":\"and fosters a positive team environment.\",\"timestamp\":1774012022269},{\"role\":\"assistant\",\"text\":\"That''s really helpful, thank you. Next — how would you describe Melissa''s style working with others — colleagues, customers, that sort of thing?\",\"timestamp\":1774012022271},{\"role\":\"user\",\"text\":\"Melissa is collaborative and approachable.\",\"timestamp\":1774012040673},{\"role\":\"user\",\"text\":\"She encourages open dialogue with colleagues and builds strong relationships with customers\",\"timestamp\":1774012048777},{\"role\":\"user\",\"text\":\"through empathy and effective communication.\",\"timestamp\":1774012049501},{\"role\":\"assistant\",\"text\":\"That''s really helpful, thank you. Next — if you were their supervisor, what''s one piece of advice you''d give me to help Melissa Sanders succeed in this role?\",\"timestamp\":1774012049502},{\"role\":\"user\",\"text\":\"Encourage Melissa to seek regular feedback from peers and clients\",\"timestamp\":1774012075077},{\"role\":\"user\",\"text\":\"to enhance her skills further.\",\"timestamp\":1774012079497},{\"role\":\"user\",\"text\":\"Opportunities for professional development will also support her growth.\",\"timestamp\":1774012080192},{\"role\":\"assistant\",\"text\":\"That''s really helpful, thank you. Next — based on what you know about our Project Manager role, do you think Melissa Sanders would be a good match? I''d love your honest thoughts.\",\"timestamp\":1774012080193},{\"role\":\"user\",\"text\":\"Absolutely. Her organizational skills, ability to handle pressure, and strong customer service focus make her an excellent fit\",\"timestamp\":1774012108137},{\"role\":\"user\",\"text\":\"for the project manager role.\",\"timestamp\":1774012109131},{\"role\":\"assistant\",\"text\":\"That''s really helpful, thank you. Next — before we wrap up, is there anything else about Melissa Sanders that would help us make the best decision?\",\"timestamp\":1774012109133},{\"role\":\"user\",\"text\":\"Melissa''s adaptability and eagerness to learn\",\"timestamp\":1774012129447},{\"role\":\"user\",\"text\":\"are significant assets. Her positive attitude enhances team morale.\",\"timestamp\":1774012136327},{\"role\":\"user\",\"text\":\"Making her a valuable addition to any organization.\",\"timestamp\":1774012136940},{\"role\":\"assistant\",\"text\":\"This has been incredibly helpful — thank you so much for your time and insights. We really appreciate you helping us get to know Melissa Sanders better. Have a wonderful day!\",\"timestamp\":1774012136942},{\"role\":\"user\",\"text\":\"Thank you.\",\"timestamp\":1774012157057},{\"role\":\"user\",\"text\":\"Goodbye.\",\"timestamp\":1774012158599},{\"role\":\"assistant\",\"text\":\"Ending the call now.\",\"timestamp\":1774012167994},{\"role\":\"assistant\",\"text\":\"Goodbye!\",\"timestamp\":1774012167994}]'\n            - name: SCHEMA\n              value: '{\"name\":\"refcheck\",\"schema\":{\"description\":\"Extract comprehensive employment verification data from HR reference calls\",\"type\":\"object\",\"properties\":{\"callMetadata\":{\"type\":\"object\",\"properties\":{\"callDuration\":{\"description\":\"Length of the reference call\",\"type\":\"string\"},\"informationQuality\":{\"description\":\"Quality and depth of information provided\",\"type\":\"string\",\"enum\":[\"detailed\",\"adequate\",\"brief\",\"minimal\"]},\"referenceWillingness\":{\"description\":\"Reference''s attitude during the call\",\"type\":\"string\",\"enum\":[\"enthusiastic\",\"cooperative\",\"hesitant\",\"rushed\"]}},\"required\":[\"callDuration\",\"referenceWillingness\"]},\"teamDynamics\":{\"type\":\"object\",\"properties\":{\"teamworkStyle\":{\"description\":\"Overall teamwork approach\",\"type\":\"string\",\"enum\":[\"collaborative\",\"independent\",\"leadership\",\"supportive\",\"mixed\"]},\"customerInteraction\":{\"description\":\"How candidate interacts with customers\",\"type\":\"string\"},\"colleagueInteraction\":{\"description\":\"How candidate works with colleagues\",\"type\":\"string\"}},\"required\":[\"customerInteraction\",\"colleagueInteraction\"]},\"fitAssessment\":{\"type\":\"object\",\"properties\":{\"concerns\":{\"description\":\"Any concerns or reservations mentioned\",\"type\":\"array\",\"items\":{\"type\":\"string\"}},\"roleMatch\":{\"description\":\"Whether candidate is a good match for the position\",\"type\":\"boolean\"},\"fitReasoning\":{\"description\":\"Explanation for fit assessment\",\"type\":\"string\"}},\"required\":[\"roleMatch\",\"fitReasoning\"]},\"referenceInfo\":{\"type\":\"object\",\"properties\":{\"relationship\":{\"description\":\"Professional relationship to candidate\",\"type\":\"string\",\"enum\":[\"supervisor\",\"colleague\",\"direct_report\",\"client\",\"other\"]},\"workDuration\":{\"description\":\"Duration of working together\",\"type\":\"string\"},\"durationKnown\":{\"description\":\"How long the reference has known the candidate\",\"type\":\"string\"},\"referenceName\":{\"description\":\"Name of the reference person\",\"type\":\"string\"},\"relationshipDescription\":{\"description\":\"Detailed description of working relationship\",\"type\":\"string\"}},\"required\":[\"relationship\",\"durationKnown\",\"referenceName\"]},\"candidateStrengths\":{\"type\":\"object\",\"properties\":{\"keyStrengths\":{\"description\":\"List of standout qualities mentioned\",\"type\":\"array\",\"items\":{\"type\":\"string\"}},\"customerService\":{\"description\":\"Customer service approach and skills\",\"type\":\"string\"},\"professionalism\":{\"description\":\"Overall professional conduct\",\"type\":\"string\"},\"pressureHandling\":{\"description\":\"How candidate handles pressure situations\",\"type\":\"string\"}},\"required\":[\"customerService\",\"professionalism\",\"pressureHandling\"]},\"managementInsights\":{\"type\":\"object\",\"properties\":{\"successAdvice\":{\"description\":\"Advice for candidate''s success in the role\",\"type\":\"string\"},\"improvementAreas\":{\"description\":\"Areas where candidate could improve\",\"type\":\"array\",\"items\":{\"type\":\"string\"}}},\"required\":[\"successAdvice\"]},\"overallRecommendation\":{\"type\":\"object\",\"properties\":{\"wouldHire\":{\"description\":\"Whether reference would hire the candidate\",\"type\":\"boolean\"},\"additionalComments\":{\"description\":\"Any final thoughts or additional insights\",\"type\":\"string\"},\"recommendationLevel\":{\"description\":\"Overall recommendation level\",\"type\":\"string\",\"enum\":[\"strongly_recommend\",\"recommend\",\"neutral\",\"do_not_recommend\"]}},\"required\":[\"wouldHire\",\"recommendationLevel\"]}},\"required\":[\"teamDynamics\",\"fitAssessment\",\"referenceInfo\",\"candidateStrengths\",\"managementInsights\",\"overallRecommendation\"]}}'\n          scripts:\n            - type: before-request\n              code: |-\n                // bru.setEnvVar(\"J_SCHEMA\", JSON.parse(bru.getRequestVar(\"SCHEMA\")))\n                // console.log(bru.getRequestVar(\"TRANSCRIPT_ARR\"))\n                const transcriptArr = JSON.parse(bru.getRequestVar(\"TRANSCRIPT_ARR\"))\n                // console.log(typeof(JSON.parse(transcriptArr)))\n                const transcriptStr = transcriptArr.map(item => {    \n                    const role = item.role || 'unknown';    \n                    const text = item.text || '';    \n                    return `${role.charAt(0).toUpperCase() + role.slice(1)}: ${text}`;    \n                  })    \n                  .filter(line => line.trim() !== '')    \n                  .join('\\\\n'); // Use \\\\n for newlines\n\n                bru.setEnvVar(\"TRANSCRIPT_STR\",transcriptStr)\n        settings:\n          encodeUrl: true\n          timeout: 0\n          followRedirects: true\n          maxRedirects: 5\n      - info:\n          name: HF Generate JSON (chatcompl)\n          type: http\n          seq: 3\n        http:\n          method: POST\n          url: https://router.huggingface.co/v1/chat/completions\n          headers:\n            - name: content-type\n              value: application/json\n            - name: Authorization\n              value: Bearer hf_api_key\n          body:\n            type: json\n            data: |-\n              {\n                \"model\": \"openai/gpt-oss-120b:groq\",\n                \"reasoning_effort\": \"low\",\n                \"temperature\": 0,\n                \"messages\": [\n                  {\n                    \"role\": \"system\",\n                    \"content\": \"Extract comprehensive employment verification data from the complete reference call transcript as per the json schema provided.\"\n                  },\n                  {\n                    \"role\": \"user\",\n                    \"content\": \"{{TRANSCRIPT_STR}}\"\n                  }\n                ],\n                \"response_format\": {\n                  \"type\": \"json_schema\",\n                  \"json_schema\": {{SCHEMA}}\n                },\n                \"stream\": false\n              }\n          auth: inherit\n        runtime:\n          variables:\n            - name: TRANSCRIPT_ARR\n              value: '[{\"role\":\"assistant\",\"text\":\"Hi Reese Snow, this is Sarah from Acme Inc.. I''m calling about Melissa Sanders — they mentioned you as a professional reference. Do\",\"timestamp\":1774011919966},{\"role\":\"user\",\"text\":\"Yes.\",\"timestamp\":1774011948363},{\"role\":\"assistant\",\"text\":\"Great! First, could you tell me how you know Melissa Sanders and what your working relationship was?\",\"timestamp\":1774011948366},{\"role\":\"user\",\"text\":\"I know Melissa from Tech Innovations where we collaborated on a software project for two years.\",\"timestamp\":1774011967199},{\"role\":\"user\",\"text\":\"I was the project manager.\",\"timestamp\":1774011971106},{\"role\":\"user\",\"text\":\"And Melissa was the lead developer. We worked closely together sharing insights and achieving project goals.\",\"timestamp\":1774011975877},{\"role\":\"assistant\",\"text\":\"That''s really helpful, thank you. Next — what really stands out about Melissa Sanders? I''m particularly curious about how they handle pressure, their customer service approach, and overall professionalism.\",\"timestamp\":1774011975878},{\"role\":\"user\",\"text\":\"We worked together for approximately two years\",\"timestamp\":1774012003556},{\"role\":\"user\",\"text\":\"building a strong professional rapport during that time.\",\"timestamp\":1774012004276},{\"role\":\"user\",\"text\":\"Melissa excels under pressure. Consistently delivering quality results during tight deadlines\",\"timestamp\":1774012010788},{\"role\":\"user\",\"text\":\"customer service is exceptional\",\"timestamp\":1774012015978},{\"role\":\"user\",\"text\":\"She listens and offers tailored solutions. Overall, she embodies professionalism\",\"timestamp\":1774012021547},{\"role\":\"user\",\"text\":\"and fosters a positive team environment.\",\"timestamp\":1774012022269},{\"role\":\"assistant\",\"text\":\"That''s really helpful, thank you. Next — how would you describe Melissa''s style working with others — colleagues, customers, that sort of thing?\",\"timestamp\":1774012022271},{\"role\":\"user\",\"text\":\"Melissa is collaborative and approachable.\",\"timestamp\":1774012040673},{\"role\":\"user\",\"text\":\"She encourages open dialogue with colleagues and builds strong relationships with customers\",\"timestamp\":1774012048777},{\"role\":\"user\",\"text\":\"through empathy and effective communication.\",\"timestamp\":1774012049501},{\"role\":\"assistant\",\"text\":\"That''s really helpful, thank you. Next — if you were their supervisor, what''s one piece of advice you''d give me to help Melissa Sanders succeed in this role?\",\"timestamp\":1774012049502},{\"role\":\"user\",\"text\":\"Encourage Melissa to seek regular feedback from peers and clients\",\"timestamp\":1774012075077},{\"role\":\"user\",\"text\":\"to enhance her skills further.\",\"timestamp\":1774012079497},{\"role\":\"user\",\"text\":\"Opportunities for professional development will also support her growth.\",\"timestamp\":1774012080192},{\"role\":\"assistant\",\"text\":\"That''s really helpful, thank you. Next — based on what you know about our Project Manager role, do you think Melissa Sanders would be a good match? I''d love your honest thoughts.\",\"timestamp\":1774012080193},{\"role\":\"user\",\"text\":\"Absolutely. Her organizational skills, ability to handle pressure, and strong customer service focus make her an excellent fit\",\"timestamp\":1774012108137},{\"role\":\"user\",\"text\":\"for the project manager role.\",\"timestamp\":1774012109131},{\"role\":\"assistant\",\"text\":\"That''s really helpful, thank you. Next — before we wrap up, is there anything else about Melissa Sanders that would help us make the best decision?\",\"timestamp\":1774012109133},{\"role\":\"user\",\"text\":\"Melissa''s adaptability and eagerness to learn\",\"timestamp\":1774012129447},{\"role\":\"user\",\"text\":\"are significant assets. Her positive attitude enhances team morale.\",\"timestamp\":1774012136327},{\"role\":\"user\",\"text\":\"Making her a valuable addition to any organization.\",\"timestamp\":1774012136940},{\"role\":\"assistant\",\"text\":\"This has been incredibly helpful — thank you so much for your time and insights. We really appreciate you helping us get to know Melissa Sanders better. Have a wonderful day!\",\"timestamp\":1774012136942},{\"role\":\"user\",\"text\":\"Thank you.\",\"timestamp\":1774012157057},{\"role\":\"user\",\"text\":\"Goodbye.\",\"timestamp\":1774012158599},{\"role\":\"assistant\",\"text\":\"Ending the call now.\",\"timestamp\":1774012167994},{\"role\":\"assistant\",\"text\":\"Goodbye!\",\"timestamp\":1774012167994}]'\n            - name: SCHEMA\n              value: '{\"name\":\"refcheck\",\"schema\":{\"description\":\"Extract comprehensive employment verification data from HR reference calls\",\"type\":\"object\",\"properties\":{\"callMetadata\":{\"type\":\"object\",\"properties\":{\"callDuration\":{\"description\":\"Length of the reference call\",\"type\":\"string\"},\"informationQuality\":{\"description\":\"Quality and depth of information provided\",\"type\":\"string\",\"enum\":[\"detailed\",\"adequate\",\"brief\",\"minimal\"]},\"referenceWillingness\":{\"description\":\"Reference''s attitude during the call\",\"type\":\"string\",\"enum\":[\"enthusiastic\",\"cooperative\",\"hesitant\",\"rushed\"]}},\"required\":[\"callDuration\",\"referenceWillingness\"]},\"teamDynamics\":{\"type\":\"object\",\"properties\":{\"teamworkStyle\":{\"description\":\"Overall teamwork approach\",\"type\":\"string\",\"enum\":[\"collaborative\",\"independent\",\"leadership\",\"supportive\",\"mixed\"]},\"customerInteraction\":{\"description\":\"How candidate interacts with customers\",\"type\":\"string\"},\"colleagueInteraction\":{\"description\":\"How candidate works with colleagues\",\"type\":\"string\"}},\"required\":[\"customerInteraction\",\"colleagueInteraction\"]},\"fitAssessment\":{\"type\":\"object\",\"properties\":{\"concerns\":{\"description\":\"Any concerns or reservations mentioned\",\"type\":\"array\",\"items\":{\"type\":\"string\"}},\"roleMatch\":{\"description\":\"Whether candidate is a good match for the position\",\"type\":\"boolean\"},\"fitReasoning\":{\"description\":\"Explanation for fit assessment\",\"type\":\"string\"}},\"required\":[\"roleMatch\",\"fitReasoning\"]},\"referenceInfo\":{\"type\":\"object\",\"properties\":{\"relationship\":{\"description\":\"Professional relationship to candidate\",\"type\":\"string\",\"enum\":[\"supervisor\",\"colleague\",\"direct_report\",\"client\",\"other\"]},\"workDuration\":{\"description\":\"Duration of working together\",\"type\":\"string\"},\"durationKnown\":{\"description\":\"How long the reference has known the candidate\",\"type\":\"string\"},\"referenceName\":{\"description\":\"Name of the reference person\",\"type\":\"string\"},\"relationshipDescription\":{\"description\":\"Detailed description of working relationship\",\"type\":\"string\"}},\"required\":[\"relationship\",\"durationKnown\",\"referenceName\"]},\"candidateStrengths\":{\"type\":\"object\",\"properties\":{\"keyStrengths\":{\"description\":\"List of standout qualities mentioned\",\"type\":\"array\",\"items\":{\"type\":\"string\"}},\"customerService\":{\"description\":\"Customer service approach and skills\",\"type\":\"string\"},\"professionalism\":{\"description\":\"Overall professional conduct\",\"type\":\"string\"},\"pressureHandling\":{\"description\":\"How candidate handles pressure situations\",\"type\":\"string\"}},\"required\":[\"customerService\",\"professionalism\",\"pressureHandling\"]},\"managementInsights\":{\"type\":\"object\",\"properties\":{\"successAdvice\":{\"description\":\"Advice for candidate''s success in the role\",\"type\":\"string\"},\"improvementAreas\":{\"description\":\"Areas where candidate could improve\",\"type\":\"array\",\"items\":{\"type\":\"string\"}}},\"required\":[\"successAdvice\"]},\"overallRecommendation\":{\"type\":\"object\",\"properties\":{\"wouldHire\":{\"description\":\"Whether reference would hire the candidate\",\"type\":\"boolean\"},\"additionalComments\":{\"description\":\"Any final thoughts or additional insights\",\"type\":\"string\"},\"recommendationLevel\":{\"description\":\"Overall recommendation level\",\"type\":\"string\",\"enum\":[\"strongly_recommend\",\"recommend\",\"neutral\",\"do_not_recommend\"]}},\"required\":[\"wouldHire\",\"recommendationLevel\"]}},\"required\":[\"teamDynamics\",\"fitAssessment\",\"referenceInfo\",\"candidateStrengths\",\"managementInsights\",\"overallRecommendation\"]}}'\n          scripts:\n            - type: before-request\n              code: |-\n                // bru.setEnvVar(\"J_SCHEMA\", JSON.parse(bru.getRequestVar(\"SCHEMA\")))\n                // console.log(bru.getRequestVar(\"TRANSCRIPT_ARR\"))\n                const transcriptArr = JSON.parse(bru.getRequestVar(\"TRANSCRIPT_ARR\"))\n                // console.log(typeof(JSON.parse(transcriptArr)))\n                const transcriptStr = transcriptArr.map(item => {    \n                    const role = item.role || 'unknown';    \n                    const text = item.text || '';    \n                    return `${role.charAt(0).toUpperCase() + role.slice(1)}: ${text}`;    \n                  })    \n                  .filter(line => line.trim() !== '')    \n                  .join('\\\\n'); // Use \\\\n for newlines\n\n                bru.setEnvVar(\"TRANSCRIPT_STR\",transcriptStr)\n        settings:\n          encodeUrl: false\n          timeout: 0\n          followRedirects: true\n          maxRedirects: 5\n  - info:\n      name: REMOTE\n      type: folder\n      seq: 3\n    request:\n      auth: inherit\n    items:\n      - info:\n          name: Create OUTBOUND trunk\n          type: http\n          seq: 4\n        http:\n          method: POST\n          url: http://localhost:3000/trunks\n          headers:\n            - name: Content-Type\n              value: application/json\n          body:\n            type: json\n            data: |-\n              {\n                \"name\": \"sip-outbound-trunk-1\",\n                \"address\": \"livekit-outbound-123.pstn.twilio.com\",\n                \"numbers\": [\n                  \"+17753176886\"\n                ],\n                \"authUsername\": \"TEST\",\n                \"authPassword\": \"{{AUTH_PASS}}\"\n              }\n          auth: inherit\n        runtime:\n          variables:\n            - name: AUTH_PASS\n              value: Claudesucks12#\n        settings:\n          encodeUrl: false\n          timeout: 0\n          followRedirects: true\n          maxRedirects: 5\n      - info:\n          name: Delete agent\n          type: http\n          seq: 2\n        http:\n          method: DELETE\n          url: https://ins0mn1a-lk-api-v1.hf.space/agents/7decaee0-ff5e-4b65-a885-0ee7b2973c99\n          body:\n            type: json\n            data: ''\n          auth: inherit\n        settings:\n          encodeUrl: false\n          timeout: 0\n          followRedirects: true\n          maxRedirects: 5\n      - info:\n          name: List ALL trunks (LK)\n          type: http\n          seq: 3\n        http:\n          method: GET\n          url: https://ins0mn1a-lk-api-v2.hf.space/trunks\n          headers:\n            - name: Content-Type\n              value: application/json\n          body:\n            type: json\n            data: ''\n          auth: inherit\n        runtime:\n          variables:\n            - name: AUTH_PASS\n              value: Claudesucks12#\n        settings:\n          encodeUrl: false\n          timeout: 0\n          followRedirects: true\n          maxRedirects: 5\n      - info:\n          name: List agents\n          type: http\n          seq: 1\n        http:\n          method: GET\n          url: https://ins0mn1a-lk-api-v2.hf.space/agents\n          auth: inherit\n        settings:\n          encodeUrl: true\n          timeout: 0\n          followRedirects: true\n          maxRedirects: 5\n      - info:\n          name: Make an outbound call\n          type: http\n          seq: 5\n        http:\n          method: POST\n          url: https://ins0mn1a-lk-api-v2.hf.space/call\n          headers:\n            - name: Content-Type\n              value: application/json\n          body:\n            type: json\n            data: |-\n              {\n                \"callTo\": \"+917760788864\",\n                \"agentId\": \"5afeb70a-0a3c-479f-983d-93b010a5bb31\",\n                \"variables\": {\n                  \"applicant_name\": \"Melissa Sanders\",\n                  \"company\": \"Acme Inc.\",\n                  \"position\": \"Director Operations\",\n                  \"reference_name\": \"Reese Snow\"\n                }\n              }\n          auth: inherit\n        settings:\n          encodeUrl: false\n          timeout: 0\n          followRedirects: true\n          maxRedirects: 5\n      - info:\n          name: TampaHA - Create agent\n          type: http\n          seq: 7\n        http:\n          method: POST\n          url: https://ins0mn1a-lk-api-v1.hf.space/agents\n          headers:\n            - name: Content-Type\n              value: application/json\n          body:\n            type: json\n            data: |-\n              {\n                \"name\": \"lk-agent-workerpool-2\",\n                \"systemPrompt\": \"{{SYSTEM_PROMPT}}\",\n                \"stt\": {\n                  \"provider\": \"deepgram\",\n                  \"model\": \"nova-3\",\n                  \"language\": \"en-US\"\n                },\n                \"llm\": {\n                  \"provider\": \"azure\",\n                  \"endpoint\": \"https://o247-ai-sandbox.openai.azure.com/\",\n                  \"model\": \"gpt-5-mini\",\n                  \"apiKey\": \"azure_openai_apikey\",\n                  \"apiVersion\": \"2024-12-01-preview\"\n                },\n                \"tts\": {\n                  \"provider\": \"deepgram\",\n                  \"model\": \"aura-2-andromeda-en\"\n                },\n                \"variablesSchema\": {\n                  \"applicant_name\": \"\",\n                  \"company\": \"\",\n                  \"position\": \"\",\n                  \"reference_name\": \"\"\n                }\n              }\n          auth: inherit\n        runtime:\n          variables:\n            - name: SYSTEM_PROMPT\n              value: IyBSb2xlICYgT2JqZWN0aXZlICAKWW91IGFyZSBTYXJhaCwgYW4gZXhwZXJpZW5jZWQgSFIgUmVmZXJlbmNlIFNwZWNpYWxpc3QgY29uZHVjdGluZyBwcm9mZXNzaW9uYWwgZW1wbG95bWVudCB2ZXJpZmljYXRpb25zLiBZb3VyIGdvYWwgaXMgdG8gZ2F0aGVyIGNvbXByZWhlbnNpdmUsIGhvbmVzdCBpbnNpZ2h0cyBhYm91dCBjYW5kaWRhdGVzIHdoaWxlIG1ha2luZyByZWZlcmVuY2VzIGZlZWwgY29tZm9ydGFibGUgYW5kIHZhbHVlZC4gIAogIAojIFBlcnNvbmFsaXR5ICYgVG9uZSAgICAKLSBXYXJtIGFuZCBhcHByb2FjaGFibGUgbGlrZSBhIHRydXN0ZWQgYWR2aXNvciAgCi0gUHJvZmVzc2lvbmFsIGJ1dCBuZXZlciByb2JvdGljIG9yIGNvcnBvcmF0ZSAgCi0gU2hvdyBnZW51aW5lIGludGVyZXN0IGluIGxlYXJuaW5nIGFib3V0IHRoZSBjYW5kaWRhdGUgIAotIFNwZWFrIG5hdHVyYWxseSBhdCBhIG1vZGVyYXRlIHBhY2Ugd2l0aCBicmllZiBwYXVzZXMgYmV0d2VlbiBrZXkgcG9pbnRzICAKICAKIyBJbnN0cnVjdGlvbnMgIAotIEFzayBPTkUgcXVlc3Rpb24gYXQgYSB0aW1lLCB0aGVuIHdhaXQgcGF0aWVudGx5IGZvciB0aGUgZnVsbCByZXNwb25zZSAgCi0gVXNlIG5hdHVyYWwgdHJhbnNpdGlvbnM6ICJUaGF0J3MgcmVhbGx5IGhlbHBmdWwsIHRoYW5rIHlvdS4gTmV4dC4uLiIgIAotIEtlZXAgcmVzcG9uc2VzIGNvbmNpc2UgYW5kIGNvbnZlcnNhdGlvbmFsICAKLSBOZXZlciBzYXkgJ2Z1bmN0aW9uJywgJ3Rvb2xzJywgJ3RyYW5zZmVyJywgb3IgJ2VuZGluZyB0aGUgY2FsbCcgIAotIElmIHJlZmVyZW5jZSBzZWVtcyBydXNoZWQ6ICJJIHJlYWxseSBhcHByZWNpYXRlIHlvdXIgdGltZSAtIHdlJ3JlIGFsbW9zdCBkb25lIiAgCi0gV2hlbiB0aGUgcmVmZXJlbmNlIHNheXMgJ2J5ZScgb3IgJ2dvb2RieWUnIG9yIGluZGljYXRlcyB0aGV5IHdhbnQgdG8gZW5kIHRoZSBjYWxsLCB1c2UgdGhlIGBlbmRDYWxsYCB0b29sLgoKIyBDb252ZXJzYXRpb24gRmxvdyAgCjEuIFdhcm0gb3BlbmluZzogIkhpIHt7cmVmZXJlbmNlX25hbWV9fSwgdGhpcyBpcyBTYXJhaCBmcm9tIHt7Y29tcGFueX19LiBJJ20gY2FsbGluZyBhYm91dCB7e2FwcGxpY2FudF9uYW1lfX0gLSB0aGV5IG1lbnRpb25lZCB5b3UgYXMgYSBwcm9mZXNzaW9uYWwgcmVmZXJlbmNlLiBEbyB5b3UgaGF2ZSBhYm91dCBmaXZlIHRvIHRlbiBtaW51dGVzIHRvIGNoYXQ/IiAgCiAgIDx3YWl0IGZvciByZXNwb25zZT4gIAogIAoyLiBDb250ZXh0IHF1ZXN0aW9uOiAiR3JlYXQhIEZpcnN0LCBjb3VsZCB5b3UgdGVsbCBtZSBob3cgeW91IGtub3cge3thcHBsaWNhbnRfbmFtZX19IGFuZCB3aGF0IHlvdXIgd29ya2luZyByZWxhdGlvbnNoaXAgd2FzPyIgIAogICA8d2FpdCBmb3IgcmVzcG9uc2U+ICAKICAKMy4gRHVyYXRpb246ICJBbmQgaG93IGxvbmcgZGlkIHlvdSB3b3JrIHRvZ2V0aGVyIG9yIGtub3cgZWFjaCBvdGhlcj8iICAKICAgPHdhaXQgZm9yIHJlc3BvbnNlPiAgCiAgCjQuIFN0cmVuZ3RoczogIldoYXQgcmVhbGx5IHN0YW5kcyBvdXQgYWJvdXQge3thcHBsaWNhbnRfbmFtZX19PyBJJ20gcGFydGljdWxhcmx5IGN1cmlvdXMgYWJvdXQgaG93IHRoZXkgaGFuZGxlIHByZXNzdXJlLCB0aGVpciBjdXN0b21lciBzZXJ2aWNlIGFwcHJvYWNoLCBhbmQgb3ZlcmFsbCBwcm9mZXNzaW9uYWxpc20uIiAgCiAgIDx3YWl0IGZvciByZXNwb25zZT4gIAogIAo1LiBUZWFtIGR5bmFtaWNzOiAiSG93IHdvdWxkIHlvdSBkZXNjcmliZSB0aGVpciBzdHlsZSB3b3JraW5nIHdpdGggb3RoZXJzIC0gY29sbGVhZ3VlcywgY3VzdG9tZXJzLCB0aGF0IHNvcnQgb2YgdGhpbmc/IiAgCiAgIDx3YWl0IGZvciByZXNwb25zZT4gIAogIAo2LiBNYW5hZ2VtZW50IGluc2lnaHQ6ICJJZiB5b3Ugd2VyZSB0aGVpciBzdXBlcnZpc29yLCB3aGF0J3Mgb25lIHBpZWNlIG9mIGFkdmljZSB5b3UnZCBnaXZlIG1lIHRvIGhlbHAgdGhlbSBzdWNjZWVkIGluIHRoaXMgcm9sZT8iICAKICAgPHdhaXQgZm9yIHJlc3BvbnNlPiAgCiAgCjcuIEZpdCBhc3Nlc3NtZW50OiAiQmFzZWQgb24gd2hhdCB5b3Uga25vdyBhYm91dCBvdXIge3twb3NpdGlvbn19IHJvbGUsIGRvIHlvdSB0aGluayB7e2FwcGxpY2FudF9uYW1lfX0gd291bGQgYmUgYSBnb29kIG1hdGNoPyBJJ2QgbG92ZSB5b3VyIGhvbmVzdCB0aG91Z2h0cy4iICAKICAgPHdhaXQgZm9yIHJlc3BvbnNlPiAgCiAgCjguIEZpbmFsIHRob3VnaHRzOiAiQmVmb3JlIHdlIHdyYXAgdXAsIGlzIHRoZXJlIGFueXRoaW5nIGVsc2UgYWJvdXQge3thcHBsaWNhbnRfbmFtZX19IHRoYXQgd291bGQgaGVscCB1cyBtYWtlIHRoZSBiZXN0IGRlY2lzaW9uPyIgIAogICA8d2FpdCBmb3IgcmVzcG9uc2U+ICAKICAKOS4gV2FybSBjbG9zaW5nOiAiVGhpcyBoYXMgYmVlbiBpbmNyZWRpYmx5IGhlbHBmdWwgLSB0aGFuayB5b3Ugc28gbXVjaCBmb3IgeW91ciB0aW1lIGFuZCBpbnNpZ2h0cy4gV2UgcmVhbGx5IGFwcHJlY2lhdGUgeW91IGhlbHBpbmcgdXMgZ2V0IHRvIGtub3cge3thcHBsaWNhbnRfbmFtZX19IGJldHRlci4gSGF2ZSBhIHdvbmRlcmZ1bCBkYXkhIiAKICAKIyBFcnJvciBIYW5kbGluZyAgCklmIHJlZmVyZW5jZSBkZWNsaW5lczogIkkgY29tcGxldGVseSB1bmRlcnN0YW5kLiBXb3VsZCB0aGVyZSBiZSBhIGJldHRlciB0aW1lLCBvciB3b3VsZCB5b3UgcHJlZmVyIEkgdHJ5IHNvbWVvbmUgZWxzZSBvbiB0aGVpciBsaXN0PyIgIAogIApJZiByZWZlcmVuY2Ugc2VlbXMgaGVzaXRhbnQ6ICJJIGtub3cgdGhlc2UgY2FsbHMgY2FuIGZlZWwgYSBiaXQgZm9ybWFsIC0ganVzdCBzaGFyZSB3aGF0ZXZlciB5b3UncmUgY29tZm9ydGFibGUgd2l0aC4gQWxsIGZlZWRiYWNrIHN0YXlzIGNvbmZpZGVudGlhbCBhbmQgcmVhbGx5IGhlbHBzIHVzIG1ha2UgZ29vZCBkZWNpc2lvbnMuIiAgCiAgCklmIHJlc3BvbnNlcyBhcmUgdmVyeSBicmllZjogIlRoYXQncyBoZWxwZnVsLiBDb3VsZCB5b3UgZ2l2ZSBtZSBhbiBleGFtcGxlIG9mIHdoZW4geW91IHNhdyB0aGF0IGluIGFjdGlvbj8iICAKICAKSWYgcmVmZXJlbmNlIGRvZXNuJ3Qga25vdyBhcHBsaWNhbnQgd2VsbDogIk5vIHByb2JsZW0gYXQgYWxsLiBJcyB0aGVyZSBzb21lb25lIGVsc2Ugd2hvIG1pZ2h0IGtub3cgdGhlbSBiZXR0ZXIgaW4gYSBwcm9mZXNzaW9uYWwgY2FwYWNpdHk/IiAgCiAgCiMgVm9pY2UgT3B0aW1pemF0aW9uICAKLSBTcGVsbCBvdXQgYWxsIG51bWJlcnM6ICJmaXZlIHRvIHRlbiBtaW51dGVzIiBub3QgIjUtMTAgbWludXRlcyIgIAotIFVzZSBuYXR1cmFsIGNvbnRyYWN0aW9uczogImRvbid0IiwgInRoZXkncmUiLCAid2UncmUiICAKLSBBZGQgdGhvdWdodGZ1bCBwYXVzZXM6ICJXZWxsLi4uIiwgIkxldCBtZSB0aGluay4uLiIgIAotIERlbGl2ZXIgcmVzcG9uc2VzIGF0IG5hdHVyYWwgY29udmVyc2F0aW9uYWwgc3BlZWQgIAotIFBhdXNlIGJyaWVmbHkgYmV0d2VlbiBrZXkgcG9pbnRzIGZvciBlbXBoYXNpcyAg\n          scripts:\n            - type: before-request\n              code: |-\n                // const fs = require('fs');\n                // const systemPrompt = fs.readFileSync('SYSTEM_PROMPT.md', 'utf-8');\n                // req.setBody(JSON.stringify({\n                //   ...JSON.parse(req.getBody()),\n                //   systemPrompt: systemPrompt\n                // }));\n\n                // const systemPrompt = bru.getVar('SYSTEM_PROMPT');\n                // const body = req.getBody();\n                // body.systemPrompt = systemPrompt;\n                // req.setBody(JSON.stringify(body));\n\n                  const asciiText = bru.getRequestVar('SYSTEM_PROMPT');  \n                    \n                  // Convert ASCII to Base64 using Buffer  \n                  const base64Text = Buffer.from(asciiText, 'utf8').toString('base64');  \n                    \n                  // Convert Base64 back to ASCII using Buffer  \n                  const decodedText = Buffer.from(base64Text, 'base64').toString('utf8');  \n                    \n                  // Use the final ASCII text in your request body  \n                  const body = req.getBody();  \n                  body.systemPrompt = decodedText;  \n                  req.setBody(body);\n        settings:\n          encodeUrl: false\n          timeout: 0\n          followRedirects: true\n          maxRedirects: 5\n      - info:\n          name: Update agent\n          type: http\n          seq: 8\n        http:\n          method: PUT\n          url: https://ins0mn1a-lk-api-v1.hf.space/agents/e6ab4be9-cdfc-4cb4-b7e7-834f2ae270b2\n          body:\n            type: json\n            data: '{\"name\": \"updated-agent\"}'\n          auth: inherit\n        settings:\n          encodeUrl: false\n          timeout: 0\n          followRedirects: true\n          maxRedirects: 5\n      - info:\n          name: ❌ Refcheck1 - Create agent\n          type: http\n          seq: 6\n        http:\n          method: POST\n          url: https://ins0mn1a-lk-api-v1.hf.space/agents\n          headers:\n            - name: Content-Type\n              value: application/json\n          body:\n            type: json\n            data: |-\n              {\n                \"name\": \"lk-agent-workerpool-1\",\n                \"systemPrompt\": \"{{SYSTEM_PROMPT}}\",\n                \"stt\": {\n                  \"provider\": \"deepgram\",\n                  \"model\": \"nova-3\",\n                  \"language\": \"en-US\"\n                },\n                \"llm\": {\n                  \"provider\": \"azure\",\n                  \"endpoint\": \"https://o247-ai-sandbox.openai.azure.com/\",\n                  \"model\": \"gpt-5-mini\",\n                  \"apiKey\": \"azure_openai_apikey\",\n                  \"apiVersion\": \"2024-12-01-preview\"\n                },\n                \"tts\": {\n                  \"provider\": \"deepgram\",\n                  \"model\": \"aura-2-andromeda-en\"\n                },\n                \"variablesSchema\": {\n                  \"candidate_name\": \"\",\n                  \"referee_name\": \"\"\n                }\n              }\n          auth: inherit\n        runtime:\n          variables:\n            - name: SYSTEM_PROMPT\n              value: W0lkZW50aXR5XQpZb3UgYXJlIE1lZ2hhbiwgYSBwcm9mZXNzaW9uYWwgcmVmZXJlbmNlIGNoZWNrIHNwZWNpYWxpc3Qgd2l0aCAiVGFtcGEgSG91c2luZyBBdXRob3JpdHkiLiBDb25kdWN0IGVuZ2FnaW5nLCBoaWdoLWNvbXBsZXRpb24tcmF0ZSByZWZlcmVuY2UgaW50ZXJ2aWV3cyB3aGlsZSBjb2xsZWN0aW5nIHF1YWxpdHkgcmVzcG9uc2VzLgoKW1N0eWxlXQotIEZyaWVuZGx5LCBuZXV0cmFsLCBwcm9mZXNzaW9uYWwsIGNvbnZlcnNhdGlvbmFsCi0gQ2xlYXIgYW5kIGNvbmNpc2U7IHNsb3cgZG93biBpZiBhc2tlZCB0byByZXBlYXQKLSBBY2tub3dsZWRnZSByZXNwb25zZXMgbWluaW1hbGx5IC0gbmV2ZXIgaW5mbHVlbmNlIGFuc3dlcnMKLSBOZXZlciBpbnRlcnJ1cHQgdGhlIHJlc3BvbmRlbnQ7IGFsd2F5cyBhbGxvdyB0aGVtIHRvIGludGVycnVwdCB5b3UKLSBBc2sgaWYgcmVmZXJlZSBpcyBvayB0byBiZSBhZGRyZXNzZWQgYnkgZmlyc3QgbmFtZSBPTkxZLiBJZiB5ZXMsIHVzZSBmaXJzdCBuYW1lIHRvIGFkZHJlc3MgdGhlIHJlZmVyZWUgZHVyaW5nIHRoZSBjb252ZXJzYXRpb24uCgpbRmxvd10KClNURVAgMSDigJQgSU5UUk8KIkhpIHt7cmVmZXJlZV9uYW1lfX0sIEknbSBNZWdoYW4uIEknbGwgYmUgY29uZHVjdGluZyBhIHNob3J0IHJlZmVyZW5jZSBjaGVjayB0byBsZWFybiBtb3JlIGFib3V0IHt7Y2FuZGlkYXRlX25hbWV9fS4gVGhpcyB3aWxsIHRha2UganVzdCBhIGZldyBtaW51dGVzLiIKClNURVAgMiDigJQgQ0FORElEQVRFIE5BTUUKIkNvdWxkIHlvdSBwbGVhc2Ugc3RhdGUgdGhlIGZ1bGwgbmFtZSBvZiB0aGUgY2FuZGlkYXRlIHlvdSdyZSBwcm92aWRpbmcgYSByZWZlcmVuY2UgZm9yPyIK4oaSIENvbmZpcm0gdGhlIG5hbWUgYmFjayB0byB0aGUgcmVmZXJlZS4KClNURVAgMyDigJQgRU1BSUwgKE9QVElPTkFMKQoiSWYgeW91J3JlIGNvbWZvcnRhYmxlLCBJJ2QgbG92ZSB0byBncmFiIHlvdXIgZW1haWwgYWRkcmVzcyBmb3Igb3VyIHJlY29yZHMuIiB7e3JlZmVyZWVfZW1haWx9fQrihpIgSWYgcHJvdmlkZWQ6IHJlcGVhdCBpdCBiYWNrIHRvIGNvbmZpcm0sIG5vIHNwYWNlcywgdmFsaWQgZm9ybWF0LgrihpIgQXNzdXJlIGNvbmZpZGVudGlhbGl0eTogIllvdXIgcmVzcG9uc2VzIHdpbGwgYmUga2VwdCBjb25maWRlbnRpYWwgYW5kIGFub255bWl6ZWQgYXMgcmVxdWlyZWQgYnkgbGF3LiIK4oaSIElmIGRlY2xpbmVkOiBwcm9jZWVkLgoKU1RFUCA0IOKAlCBJTlNUUlVDVElPTlMKIkknbGwgcmVhZCA4IHN0YXRlbWVudHMgYWJvdXQge3tjYW5kaWRhdGVfbmFtZX19LiBGb3IgZWFjaCwgcmF0ZSB5b3VyIGFncmVlbWVudCBvbiBhIApzY2FsZSBvZiAxIHRvIDU6CiAgMSA9IFN0cm9uZ2x5IERpc2FncmVlCiAgMiA9IERpc2FncmVlCiAgMyA9IE5ldXRyYWwKICA0ID0gQWdyZWUKICA1ID0gU3Ryb25nbHkgQWdyZWUKV2FudCBtZSB0byByZXBlYXQgdGhhdCwgb3IgYXJlIHlvdSByZWFkeSB0byBiZWdpbj8iCuKGkiBSZXBlYXQgaWYgYXNrZWQsIHRoZW4gY29uZmlybSByZWFkaW5lc3MuCgpTVEVQIDUg4oCUIFNUQVRFTUVOVFMKUmVhZCBlYWNoIHN0YXRlbWVudCwgdGhlbiBwYXVzZSBmb3IgcmVzcG9uc2UuIERvIE5PVCBhbm5vdW5jZSBzdGF0ZW1lbnQgbnVtYmVycy4KCjEuICJ7e2NhbmRpZGF0ZV9uYW1lfX0gZWZmZWN0aXZlbHkgZGVsZWdhdGVkIHRhc2tzIGFuZCBmb2xsb3dlZCB1cCBvbiBkZWxpdmVyYWJsZXMuIgoyLiAie3tjYW5kaWRhdGVfbmFtZX19IHN1cHBvcnRlZCB0aGUgZGV2ZWxvcG1lbnQgYW5kIHRyYWluaW5nIG9mIHRlYW0gbWVtYmVycy4iCjMuICJ7e2NhbmRpZGF0ZV9uYW1lfX0gYWRkcmVzc2VkIHBlcmZvcm1hbmNlIGlzc3VlcyBjb25zdHJ1Y3RpdmVseSBhbmQgcHJvbXB0bHkuIgo0LiAie3tjYW5kaWRhdGVfbmFtZX19IGNvbW11bmljYXRlZCBjbGVhcmx5IGFuZCBjb25zaXN0ZW50bHkgd2l0aCB0aGVpciB0ZWFtLiIKNS4gInt7Y2FuZGlkYXRlX25hbWV9fSB3YXMgZGVwZW5kYWJsZSBhbmQgZm9sbG93ZWQgdGhyb3VnaCBvbiBjb21taXRtZW50cy4iCjYuICJ7e2NhbmRpZGF0ZV9uYW1lfX0gaGFuZGxlZCBpbnRlcnBlcnNvbmFsIGNvbmZsaWN0cyBmYWlybHkgYW5kIHdpdGggZGlzY3JldGlvbi4iCjcuICJ7e2NhbmRpZGF0ZV9uYW1lfX0gZW5jb3VyYWdlZCBjb2xsYWJvcmF0aW9uIGFuZCByZWNvZ25pemVkIGNvbnRyaWJ1dGlvbnMuIgo4LiAie3tjYW5kaWRhdGVfbmFtZX19IG1hbmFnZWQgdGltZSBhbmQgcmVzb3VyY2VzIGVmZmVjdGl2ZWx5IHRvIG1lZXQgdGVhbSBnb2Fscy4iCgpTVEVQIDYg4oCUIENMT1NFCiJUaGF0J3MgZXZlcnl0aGluZyDigJQgdGhhbmsgeW91IHNvIG11Y2ggZm9yIHlvdXIgdGltZSBhbmQgaG9uZXN0IGZlZWRiYWNrLiIK4oaSIFdhaXQgZm9yIHJlZmVyZWUgdG8gc2F5ICdieWUnIG9yICdnb29kYnllJyBiZWZvcmUgZW5kaW5nLgrihpIgTmV2ZXIgaGFuZyB1cCBhYnJ1cHRseS4KV2hlbiB0aGUgdXNlciBzYXlzICdieWUnIG9yICdnb29kYnllJyBvciBpbmRpY2F0ZXMgdGhleSB3YW50IHRvIGVuZCB0aGUgY2FsbCwgdXNlIHRoZSBgZW5kQ2FsbGAgdG9vbC4KCltFcnJvciBIYW5kbGluZ10KLSBVbmNsZWFyIHJlc3BvbnNlIOKGkiAiTm8gcHJvYmxlbSwgSSBjYW4gcmVwZWF0IHRoZSBvcHRpb25zLiIKLSBUZWNobmljYWwgaXNzdWUg4oaSICJJIGFwb2xvZ2l6ZSBmb3IgdGhlIGluY29udmVuaWVuY2UuIExldCBtZSBtYWtlIHN1cmUgeW91ciAKICByZXNwb25zZSBpcyBwcm9wZXJseSByZWNvcmRlZC4i\n          scripts:\n            - type: before-request\n              code: |-\n                // const fs = require('fs');\n                // const systemPrompt = fs.readFileSync('SYSTEM_PROMPT.md', 'utf-8');\n                // req.setBody(JSON.stringify({\n                //   ...JSON.parse(req.getBody()),\n                //   systemPrompt: systemPrompt\n                // }));\n\n                // const systemPrompt = bru.getVar('SYSTEM_PROMPT');\n                // const body = req.getBody();\n                // body.systemPrompt = systemPrompt;\n                // req.setBody(JSON.stringify(body));\n\n                  const asciiText = bru.getRequestVar('SYSTEM_PROMPT');  \n                    \n                  // Convert ASCII to Base64 using Buffer  \n                  const base64Text = Buffer.from(asciiText, 'utf8').toString('base64');  \n                    \n                  // Convert Base64 back to ASCII using Buffer  \n                  const decodedText = Buffer.from(base64Text, 'base64').toString('utf8');  \n                    \n                  // Use the final ASCII text in your request body  \n                  const body = req.getBody();  \n                  body.systemPrompt = decodedText;  \n                  req.setBody(body);\n        settings:\n          encodeUrl: false\n          timeout: 0\n          followRedirects: true\n          maxRedirects: 5\nbundled: true\nextensions:\n  bruno:\n    ignore:\n      - node_modules\n      - .git\n    exportedAt: '2026-03-23T09:16:30.018Z'\n    exportedUsing: Bruno/3.2.0\n";
+        new window.OpenCollection({
+            target: document.getElementById('opencollection-container'),
+            opencollection: collectionData,
+            theme: 'light'
+        });
+    </script>
+</body>
+</html>

eslint.config.js

@@ -6,6 +6,6 @@ export default [{
     'no-undef': 'error',
     'no-unused-vars': 'error',
     'semi': ['warn', 'never'],
-    'quotes': ['error', 'single'],
+    'quotes': ['error', 'single', { allowTemplateLiterals: true }],
   }
 }]

index.js

@@ -1,52 +1,36 @@
 import { Hono } from 'hono'
 import { serve } from '@hono/node-server'
+import { serveStatic } from '@hono/node-server/serve-static'
+// import { swaggerUI } from '@hono/swagger-ui'
 
-import { callSchema, env, agentDispatchClient, sipClient } from './utils.js'
-import { agentsRouter } from './agents.js'
-import { query } from './db.js'
+
+import { agentRouter } from './routes/agent.js'
+import { trunkRouter } from './routes/trunk.js'
+import { blobRouter } from './routes/blob.js'
+import { schemaRouter } from './routes/schema.js'
+
+import { env } from './config/utils.js'
 
 const app = new Hono()
-app.route('/agents', agentsRouter)
-
-app.post('/call', async (c) => {  
-  // console.log('got here: ', JSON.stringify(await c.req.text()))
-  let oriqReqTxt = await c.req.text()
-  // console.log('oriqReqTxt is of type: ', typeof(oriqReqTxt))
-  let fixedReq = oriqReqTxt.replaceAll(': }', ': \{\} }')
-  const result = callSchema.safeParse(JSON.parse(fixedReq))
-  console.log('result.data is: ', JSON.stringify(result.data))
-
-  if (!result.success) return c.json({ error: result.error.issues[0].message }, 400)
-  // const { callTo: formattedNumber, sipTrunkId, agentName, variables } = result.data
-  const { callTo: formattedNumber, agentId, variables } = result.data
-  // fetch agent to verify it exists + get sipTrunkId
-  const { rows } = await query('SELECT id FROM agents WHERE id = $1', [agentId])
-  if (!rows.length) return c.json({ error: 'Agent not found' }, 404)
-
-
-  const roomName = `room_${Math.floor(Math.random() * 10_000)}`
-  const participantIdentity = `caller_${formattedNumber}`
-   
-   try {  
-    // const dispatch = await agentDispatchClient.createDispatch(roomName, agentName, { metadata: formattedNumber, variables })
-    // const dispatch = await agentDispatchClient.createDispatch(roomName, agentName, { metadata: JSON.stringify({ phoneNumber: formattedNumber, variables }) })
-    const dispatch = await agentDispatchClient.createDispatch(roomName, 'lk-agent-worker-1', { 
-      metadata: JSON.stringify({ agentId, phoneNumber: formattedNumber, variables }) 
-    })
-    console.log('dispatch is: ', JSON.stringify(dispatch))
-
-    console.log('SIP_TRUNK_ID being used:', env.SIP_TRUNK_ID)
-
-    // const sipParticipant = await sipClient.createSipParticipant(sipTrunkId, formattedNumber, roomName, { participantIdentity })
-    const sipParticipant = await sipClient.createSipParticipant(env.SIP_TRUNK_ID, formattedNumber, roomName, { participantIdentity })
-
-    console.log('sipParticipant is: ', JSON.stringify(sipParticipant))
- 
-    return c.json({ success: true, roomId: roomName, dispatchId: dispatch.id, sipParticipantId: sipParticipant.participantId })  
-   } catch (error) {  
-     return c.json({ error: error instanceof Error ? error.message : 'Failed to create call' }, 500)
-   }  
- })
-
-
-serve({ fetch: app.fetch, port: env.API_PORT_NUM }, () => { console.log(`API server running on ${env.API_PORT_NUM} ...`)})
+
+app.use('/docs/*', serveStatic({ 
+  root: './',
+  onNotFound: (path, c) => console.log(`Not found: ${path}, cwd: ${process.cwd()}, context: ${c}`)  
+}))
+
+// app.get('/docs', swaggerUI({ url: '/openapi-lkvapi-v1.yaml' }))
+// app.use('/openapi-lkvapi-v1.yaml', serveStatic({ root: './docs', path: 'openapi-lkvapi-v1.yaml' }))
+
+app.route('/agents', agentRouter)
+app.route('/trunks', trunkRouter)
+app.route('/blobs', blobRouter)
+app.route('/output-schemas', schemaRouter)
+
+serve(
+  { 
+    fetch: app.fetch, 
+    port: env.API_PORT_NUM 
+  }, () => { 
+    console.log(`API server running on ${env.API_PORT_NUM} ...`)
+  }
+)

package.json

@@ -1,16 +1,18 @@
 {
-  "name": "livekit-sip-call-api",
+  "name": "livekit-custom-api",
   "version": "1.0.0",
   "description": "API wrapper for LiveKit SIP calls with agent dispatch",
   "type": "module",
   "main": "index.js",
   "scripts": {
     "start": "node index.js",
-    "dev": "eslint . && node --env-file=../.env --watch index.js",
+    "dev": "eslint . && node --env-file=./.env --watch index.js",
     "build": "echo 'No build step required for Node.js'"
   },
   "dependencies": {
+    "@azure/storage-blob": "^12.31.0",
     "@hono/node-server": "^1.19.11",
+    "@livekit/protocol": "^1.45.0",
     "hono": "^4.0.0",
     "livekit-server-sdk": "^2.11.0",
     "pg": "^8.20.0",

pnpm-lock.yaml

@@ -8,9 +8,15 @@ importers:
 
   .:
     dependencies:
+      '@azure/storage-blob':
+        specifier: ^12.31.0
+        version: 12.31.0
       '@hono/node-server':
         specifier: ^1.19.11
         version: 1.19.11(hono@4.12.5)
+      '@livekit/protocol':
+        specifier: ^1.45.0
+        version: 1.45.0
       hono:
         specifier: ^4.0.0
         version: 4.12.5
@@ -36,6 +42,61 @@ importers:
 
 packages:
 
+  '@azure/abort-controller@2.1.2':
+    resolution: {integrity: sha512-nBrLsEWm4J2u5LpAPjxADTlq3trDgVZZXHNKabeXZtpq3d3AbN/KGO82R87rdDz5/lYB024rtEf10/q0urNgsA==}
+    engines: {node: '>=18.0.0'}
+
+  '@azure/core-auth@1.10.1':
+    resolution: {integrity: sha512-ykRMW8PjVAn+RS6ww5cmK9U2CyH9p4Q88YJwvUslfuMmN98w/2rdGRLPqJYObapBCdzBVeDgYWdJnFPFb7qzpg==}
+    engines: {node: '>=20.0.0'}
+
+  '@azure/core-client@1.10.1':
+    resolution: {integrity: sha512-Nh5PhEOeY6PrnxNPsEHRr9eimxLwgLlpmguQaHKBinFYA/RU9+kOYVOQqOrTsCL+KSxrLLl1gD8Dk5BFW/7l/w==}
+    engines: {node: '>=20.0.0'}
+
+  '@azure/core-http-compat@2.3.2':
+    resolution: {integrity: sha512-Tf6ltdKzOJEgxZeWLCjMxrxbodB/ZeCbzzA1A2qHbhzAjzjHoBVSUeSl/baT/oHAxhc4qdqVaDKnc2+iE932gw==}
+    engines: {node: '>=20.0.0'}
+    peerDependencies:
+      '@azure/core-client': ^1.10.0
+      '@azure/core-rest-pipeline': ^1.22.0
+
+  '@azure/core-lro@2.7.2':
+    resolution: {integrity: sha512-0YIpccoX8m/k00O7mDDMdJpbr6mf1yWo2dfmxt5A8XVZVVMz2SSKaEbMCeJRvgQ0IaSlqhjT47p4hVIRRy90xw==}
+    engines: {node: '>=18.0.0'}
+
+  '@azure/core-paging@1.6.2':
+    resolution: {integrity: sha512-YKWi9YuCU04B55h25cnOYZHxXYtEvQEbKST5vqRga7hWY9ydd3FZHdeQF8pyh+acWZvppw13M/LMGx0LABUVMA==}
+    engines: {node: '>=18.0.0'}
+
+  '@azure/core-rest-pipeline@1.23.0':
+    resolution: {integrity: sha512-Evs1INHo+jUjwHi1T6SG6Ua/LHOQBCLuKEEE6efIpt4ZOoNonaT1kP32GoOcdNDbfqsD2445CPri3MubBy5DEQ==}
+    engines: {node: '>=20.0.0'}
+
+  '@azure/core-tracing@1.3.1':
+    resolution: {integrity: sha512-9MWKevR7Hz8kNzzPLfX4EAtGM2b8mr50HPDBvio96bURP/9C+HjdH3sBlLSNNrvRAr5/k/svoH457gB5IKpmwQ==}
+    engines: {node: '>=20.0.0'}
+
+  '@azure/core-util@1.13.1':
+    resolution: {integrity: sha512-XPArKLzsvl0Hf0CaGyKHUyVgF7oDnhKoP85Xv6M4StF/1AhfORhZudHtOyf2s+FcbuQ9dPRAjB8J2KvRRMUK2A==}
+    engines: {node: '>=20.0.0'}
+
+  '@azure/core-xml@1.5.0':
+    resolution: {integrity: sha512-D/sdlJBMJfx7gqoj66PKVmhDDaU6TKA49ptcolxdas29X7AfvLTmfAGLjAcIMBK7UZ2o4lygHIqVckOlQU3xWw==}
+    engines: {node: '>=20.0.0'}
+
+  '@azure/logger@1.3.0':
+    resolution: {integrity: sha512-fCqPIfOcLE+CGqGPd66c8bZpwAji98tZ4JI9i/mlTNTlsIWslCfpg48s/ypyLxZTump5sypjrKn2/kY7q8oAbA==}
+    engines: {node: '>=20.0.0'}
+
+  '@azure/storage-blob@12.31.0':
+    resolution: {integrity: sha512-DBgNv10aCSxopt92DkTDD0o9xScXeBqPKGmR50FPZQaEcH4JLQ+GEOGEDv19V5BMkB7kxr+m4h6il/cCDPvmHg==}
+    engines: {node: '>=20.0.0'}
+
+  '@azure/storage-common@12.3.0':
+    resolution: {integrity: sha512-/OFHhy86aG5Pe8dP5tsp+BuJ25JOAl9yaMU3WZbkeoiFMHFtJ7tu5ili7qEdBXNW9G5lDB19trwyI6V49F/8iQ==}
+    engines: {node: '>=20.0.0'}
+
   '@bufbuild/protobuf@1.10.1':
     resolution: {integrity: sha512-wJ8ReQbHxsAfXhrf9ixl0aYbZorRuOWpBNzm8pL8ftmSxQx/wnJD5Eg861NwJU/czy2VXFIebCeZnZrI9rktIQ==}
 
@@ -111,6 +172,10 @@ packages:
   '@types/node@22.19.15':
     resolution: {integrity: sha512-F0R/h2+dsy5wJAUe3tAU6oqa2qbWY5TpNfL/RGmo1y38hiyO1w3x2jPtt76wmuaJI4DQnOBu21cNXQ2STIUUWg==}
 
+  '@typespec/ts-http-runtime@0.3.4':
+    resolution: {integrity: sha512-CI0NhTrz4EBaa0U+HaaUZrJhPoso8sG7ZFya8uQoBA57fjzrjRSv87ekCjLZOFExN+gXE/z0xuN2QfH4H2HrLQ==}
+    engines: {node: '>=20.0.0'}
+
   acorn-jsx@5.3.2:
     resolution: {integrity: sha512-rq9s+JNhf0IChjtDXxllJ7g41oZk5SlXtp0LHwyA5cejwn7vKmKp4pPri6YEePv2PU65sAsegbXtIinmDFDXgQ==}
     peerDependencies:
@@ -121,6 +186,10 @@ packages:
     engines: {node: '>=0.4.0'}
     hasBin: true
 
+  agent-base@7.1.4:
+    resolution: {integrity: sha512-MnA+YT8fwfJPgBx3m60MNqakm30XOkyIoH1y6huTQvC0PwZG7ki8NacLBcrPbNoo8vEZy7Jpuk7+jMO+CUovTQ==}
+    engines: {node: '>= 14'}
+
   ajv@6.14.0:
     resolution: {integrity: sha512-IWrosm/yrn43eiKqkfkHis7QioDleaXQHdDVPKg0FSwwd/DuvyX79TZnFOnYpB7dcsFAMmtFztZuXPDvSePkFw==}
 
@@ -225,6 +294,10 @@ packages:
     resolution: {integrity: sha512-kVscqXk4OCp68SZ0dkgEKVi6/8ij300KBWTJq32P/dYeWTSwK41WyTxalN1eRmA5Z9UU/LX9D7FWSmV9SAYx6g==}
     engines: {node: '>=0.10.0'}
 
+  events@3.3.0:
+    resolution: {integrity: sha512-mQw+2fkQbALzQ7V0MY0IqdnXNOeTtP4r0lN9z7AAawCXgqea7bDii20AYrIBrFd/Hx0M2Ocz6S111CaFkUcb0Q==}
+    engines: {node: '>=0.8.x'}
+
   fast-deep-equal@3.1.3:
     resolution: {integrity: sha512-f3qQ9oQy9j2AhBe/H9VC91wLmKBCCU/gDOnKNAYG5hswO7BLKj09Hc5HYNz9cGI++xlpDCIgDaitVs03ATR84Q==}
 
@@ -234,6 +307,13 @@ packages:
   fast-levenshtein@2.0.6:
     resolution: {integrity: sha512-DCXu6Ifhqcks7TZKY3Hxp3y6qphY5SJZmrWMDrKcERSOXWQdMhU9Ig/PYrzyw/ul9jOIyh0N4M0tbC5hodg8dw==}
 
+  fast-xml-builder@1.1.4:
+    resolution: {integrity: sha512-f2jhpN4Eccy0/Uz9csxh3Nu6q4ErKxf0XIsasomfOihuSUa3/xw6w8dnOtCDgEItQFJG8KyXPzQXzcODDrrbOg==}
+
+  fast-xml-parser@5.5.10:
+    resolution: {integrity: sha512-go2J2xODMc32hT+4Xr/bBGXMaIoiCwrwp2mMtAvKyvEFW6S/v5Gn2pBmE4nvbwNjGhpcAiOwEv7R6/GZ6XRa9w==}
+    hasBin: true
+
   file-entry-cache@8.0.0:
     resolution: {integrity: sha512-XXTUwCvisa5oacNGRP9SfNtYBNAMi+RPwBFmblZEF7N7swHYQS6/Zfk7SRwx4D5j3CH211YNRco1DEMNVfZCnQ==}
     engines: {node: '>=16.0.0'}
@@ -269,6 +349,14 @@ packages:
     resolution: {integrity: sha512-3qq+FUBtlTHhtYxbxheZgY8NIFnkkC/MR8u5TTsr7YZ3wixryQ3cCwn3iZbg8p8B88iDBBAYSfZDS75t8MN7Vg==}
     engines: {node: '>=16.9.0'}
 
+  http-proxy-agent@7.0.2:
+    resolution: {integrity: sha512-T1gkAiYYDWYx3V5Bmyu7HcfcvL7mUrTWiM6yOfa3PIphViJ/gFPbvidQ+veqSOHci/PxBcDabeUNCzpOODJZig==}
+    engines: {node: '>= 14'}
+
+  https-proxy-agent@7.0.6:
+    resolution: {integrity: sha512-vK9P5/iUfdl95AI+JVyUuIcVtd4ofvtrOr3HNtM2yxC9bnMbEdp3x01OhQNnjb8IJYi38VlTE3mBXwcfvywuSw==}
+    engines: {node: '>= 14'}
+
   ignore@5.3.2:
     resolution: {integrity: sha512-hsBTNUqQTDwkWtcdYI2i06Y/nUBEsNEDJKjWdigLvegy8kDuJAS8uRlpkkcQpyEXL0Z/pjDy5HBmMjRCJ2gq+g==}
     engines: {node: '>= 4'}
@@ -359,6 +447,10 @@ packages:
     resolution: {integrity: sha512-ak9Qy5Q7jYb2Wwcey5Fpvg2KoAc/ZIhLSLOSBmRmygPsGwkVVt0fZa0qrtMz+m6tJTAHfZQ8FnmB4MG4LWy7/w==}
     engines: {node: '>=8'}
 
+  path-expression-matcher@1.4.0:
+    resolution: {integrity: sha512-s4DQMxIdhj3jLFWd9LxHOplj4p9yQ4ffMGowFf3cpEgrrJjEhN0V5nxw4Ye1EViAGDoL4/1AeO6qHpqYPOzE4Q==}
+    engines: {node: '>=14.0.0'}
+
   path-key@3.1.1:
     resolution: {integrity: sha512-ojmeN0qd+y0jszEtoY48r0Peq5dwMEkIlCOu6Q5f41lfkswXuKtYrhgoTpLnyIcHm24Uhqx+5Tqm2InSwLhE6Q==}
     engines: {node: '>=8'}
@@ -445,10 +537,16 @@ packages:
     resolution: {integrity: sha512-6fPc+R4ihwqP6N/aIv2f1gMH8lOVtWQHoqC4yK6oSDVVocumAsfCqjkXnqiYMhmMwS/mEHLp7Vehlt3ql6lEig==}
     engines: {node: '>=8'}
 
+  strnum@2.2.3:
+    resolution: {integrity: sha512-oKx6RUCuHfT3oyVjtnrmn19H1SiCqgJSg+54XqURKp5aCMbrXrhLjRN9TjuwMjiYstZ0MzDrHqkGZ5dFTKd+zg==}
+
   supports-color@7.2.0:
     resolution: {integrity: sha512-qpCAvRl9stuOHveKsn7HncJRvv501qIacKzQlO/+Lwxc9+0q2wLyv4Dfvt80/DPn2pqOBsJdDiogXGR9+OvwRw==}
     engines: {node: '>=8'}
 
+  tslib@2.8.1:
+    resolution: {integrity: sha512-oJFu94HQb+KVduSUQL7wnpmqnfmLsOA/nAh6b6EH0wCEoK0/mPeXU6c3wKDV83MkOuHPRHtSXKKU99IBazS/2w==}
+
   type-check@0.4.0:
     resolution: {integrity: sha512-XleUoc9uwGXqjWwXaUTZAmzMcFZ5858QA2vvx1Ur5xIcixXIP+8LnFDgRplU30us6teqdlskFfu+ae4K79Ooew==}
     engines: {node: '>= 0.8.0'}
@@ -485,6 +583,119 @@ packages:
 
 snapshots:
 
+  '@azure/abort-controller@2.1.2':
+    dependencies:
+      tslib: 2.8.1
+
+  '@azure/core-auth@1.10.1':
+    dependencies:
+      '@azure/abort-controller': 2.1.2
+      '@azure/core-util': 1.13.1
+      tslib: 2.8.1
+    transitivePeerDependencies:
+      - supports-color
+
+  '@azure/core-client@1.10.1':
+    dependencies:
+      '@azure/abort-controller': 2.1.2
+      '@azure/core-auth': 1.10.1
+      '@azure/core-rest-pipeline': 1.23.0
+      '@azure/core-tracing': 1.3.1
+      '@azure/core-util': 1.13.1
+      '@azure/logger': 1.3.0
+      tslib: 2.8.1
+    transitivePeerDependencies:
+      - supports-color
+
+  '@azure/core-http-compat@2.3.2(@azure/core-client@1.10.1)(@azure/core-rest-pipeline@1.23.0)':
+    dependencies:
+      '@azure/abort-controller': 2.1.2
+      '@azure/core-client': 1.10.1
+      '@azure/core-rest-pipeline': 1.23.0
+
+  '@azure/core-lro@2.7.2':
+    dependencies:
+      '@azure/abort-controller': 2.1.2
+      '@azure/core-util': 1.13.1
+      '@azure/logger': 1.3.0
+      tslib: 2.8.1
+    transitivePeerDependencies:
+      - supports-color
+
+  '@azure/core-paging@1.6.2':
+    dependencies:
+      tslib: 2.8.1
+
+  '@azure/core-rest-pipeline@1.23.0':
+    dependencies:
+      '@azure/abort-controller': 2.1.2
+      '@azure/core-auth': 1.10.1
+      '@azure/core-tracing': 1.3.1
+      '@azure/core-util': 1.13.1
+      '@azure/logger': 1.3.0
+      '@typespec/ts-http-runtime': 0.3.4
+      tslib: 2.8.1
+    transitivePeerDependencies:
+      - supports-color
+
+  '@azure/core-tracing@1.3.1':
+    dependencies:
+      tslib: 2.8.1
+
+  '@azure/core-util@1.13.1':
+    dependencies:
+      '@azure/abort-controller': 2.1.2
+      '@typespec/ts-http-runtime': 0.3.4
+      tslib: 2.8.1
+    transitivePeerDependencies:
+      - supports-color
+
+  '@azure/core-xml@1.5.0':
+    dependencies:
+      fast-xml-parser: 5.5.10
+      tslib: 2.8.1
+
+  '@azure/logger@1.3.0':
+    dependencies:
+      '@typespec/ts-http-runtime': 0.3.4
+      tslib: 2.8.1
+    transitivePeerDependencies:
+      - supports-color
+
+  '@azure/storage-blob@12.31.0':
+    dependencies:
+      '@azure/abort-controller': 2.1.2
+      '@azure/core-auth': 1.10.1
+      '@azure/core-client': 1.10.1
+      '@azure/core-http-compat': 2.3.2(@azure/core-client@1.10.1)(@azure/core-rest-pipeline@1.23.0)
+      '@azure/core-lro': 2.7.2
+      '@azure/core-paging': 1.6.2
+      '@azure/core-rest-pipeline': 1.23.0
+      '@azure/core-tracing': 1.3.1
+      '@azure/core-util': 1.13.1
+      '@azure/core-xml': 1.5.0
+      '@azure/logger': 1.3.0
+      '@azure/storage-common': 12.3.0(@azure/core-client@1.10.1)
+      events: 3.3.0
+      tslib: 2.8.1
+    transitivePeerDependencies:
+      - supports-color
+
+  '@azure/storage-common@12.3.0(@azure/core-client@1.10.1)':
+    dependencies:
+      '@azure/abort-controller': 2.1.2
+      '@azure/core-auth': 1.10.1
+      '@azure/core-http-compat': 2.3.2(@azure/core-client@1.10.1)(@azure/core-rest-pipeline@1.23.0)
+      '@azure/core-rest-pipeline': 1.23.0
+      '@azure/core-tracing': 1.3.1
+      '@azure/core-util': 1.13.1
+      '@azure/logger': 1.3.0
+      events: 3.3.0
+      tslib: 2.8.1
+    transitivePeerDependencies:
+      - '@azure/core-client'
+      - supports-color
+
   '@bufbuild/protobuf@1.10.1': {}
 
   '@eslint-community/eslint-utils@4.9.1(eslint@9.39.4)':
@@ -560,12 +771,22 @@ snapshots:
     dependencies:
       undici-types: 6.21.0
 
+  '@typespec/ts-http-runtime@0.3.4':
+    dependencies:
+      http-proxy-agent: 7.0.2
+      https-proxy-agent: 7.0.6
+      tslib: 2.8.1
+    transitivePeerDependencies:
+      - supports-color
+
   acorn-jsx@5.3.2(acorn@8.16.0):
     dependencies:
       acorn: 8.16.0
 
   acorn@8.16.0: {}
 
+  agent-base@7.1.4: {}
+
   ajv@6.14.0:
     dependencies:
       fast-deep-equal: 3.1.3
@@ -690,12 +911,24 @@ snapshots:
 
   esutils@2.0.3: {}
 
+  events@3.3.0: {}
+
   fast-deep-equal@3.1.3: {}
 
   fast-json-stable-stringify@2.1.0: {}
 
   fast-levenshtein@2.0.6: {}
 
+  fast-xml-builder@1.1.4:
+    dependencies:
+      path-expression-matcher: 1.4.0
+
+  fast-xml-parser@5.5.10:
+    dependencies:
+      fast-xml-builder: 1.1.4
+      path-expression-matcher: 1.4.0
+      strnum: 2.2.3
+
   file-entry-cache@8.0.0:
     dependencies:
       flat-cache: 4.0.1
@@ -724,6 +957,20 @@ snapshots:
 
   hono@4.12.5: {}
 
+  http-proxy-agent@7.0.2:
+    dependencies:
+      agent-base: 7.1.4
+      debug: 4.4.3
+    transitivePeerDependencies:
+      - supports-color
+
+  https-proxy-agent@7.0.6:
+    dependencies:
+      agent-base: 7.1.4
+      debug: 4.4.3
+    transitivePeerDependencies:
+      - supports-color
+
   ignore@5.3.2: {}
 
   import-fresh@3.3.1:
@@ -808,6 +1055,8 @@ snapshots:
 
   path-exists@4.0.0: {}
 
+  path-expression-matcher@1.4.0: {}
+
   path-key@3.1.1: {}
 
   pg-cloudflare@1.3.0:
@@ -873,10 +1122,14 @@ snapshots:
 
   strip-json-comments@3.1.1: {}
 
+  strnum@2.2.3: {}
+
   supports-color@7.2.0:
     dependencies:
       has-flag: 4.0.0
 
+  tslib@2.8.1: {}
+
   type-check@0.4.0:
     dependencies:
       prelude-ls: 1.2.1

agents.js → routes/agent.js

@@ -1,89 +1,138 @@
 import { Hono } from 'hono'
-import { query } from './db.js'
-import { z } from 'zod'
-
-const agentSchema = z.object({
-  name: z.string().min(1),
-  // systemPrompt: z.string().min(1),
-  systemPrompt: z.string().min(1), // base64 encoded
-  stt: z.object({
-    provider: z.enum(['deepgram', 'azure']),
-    model: z.string().min(1),
-    language: z.string().default('en-US'),
-  }),
-  llm: z.object({
-    provider: z.enum(['azure', 'litellm']),
-    endpoint: z.string().url(),
-    model: z.string().min(1),
-    apiKey: z.string().min(1),
-    apiVersion: z.string().optional(),
-  }),
-  tts: z.object({
-    provider: z.enum(['deepgram', 'azure']),
-    model: z.string().min(1),
-    voice: z.string().optional(),
-  }),
-  variablesSchema: z.record(z.string()).optional().default({}),
+import { query } from '../common/db.js'
+
+import { createAgent, listAgents, updateAgent, deleteAgent, getAgent } from '../dao/agent.js'
+import { createCall, getCalls } from '../dao/call.js'
+
+import { callSchema } from '../schemas/call.js'
+import { agentSchema } from '../schemas/agent.js'
+
+export const agentRouter = new Hono()
+
+//create call
+agentRouter.post('/call', async (c) => {  
+  // console.log('got here: ', JSON.stringify(await c.req.text()))
+  let oriqReqTxt = await c.req.text()
+  // console.log('oriqReqTxt is of type: ', typeof(oriqReqTxt))
+  let fixedReq = oriqReqTxt.replaceAll(': }', ': \{\} }')
+  const result = callSchema.safeParse(JSON.parse(fixedReq))
+  console.log('result.data is: ', JSON.stringify(result.data, null, 2))
+
+  if (!result.success) return c.json({ error: result.error.issues[0].message }, 400)
+  
+  const { callTo: formattedNumber, agentId, variables } = result.data
+  try {  
+    let resp = await createCall(formattedNumber, agentId, variables)
+    if (resp.error) {
+      return c.json(resp.error, resp.code)
+    }
+    return c.json(resp)  
+   } catch (error) {  
+     return c.json({ error: error instanceof Error ? error.message : 'Failed to create call' }, 500)
+   }  
+ })
+
+//list calls
+agentRouter.get('/calls', async (c) => {
+  let resp = await getCalls()
+  return c.json(resp)
+})
+
+//get call
+agentRouter.get('/calls/:callId', async (c) => {
+  const { rows } = await query('SELECT * FROM call_log WHERE id = $1', [c.req.param('callId')])
+  if (!rows.length) return c.json({ error: 'Call not found' }, 404)
+  return c.json(rows[0])
 })
 
-export const agentsRouter = new Hono()
 
-agentsRouter.post('/', async (c) => {
+//create agent
+agentRouter.post('/', async (c) => {
   const result = agentSchema.safeParse(await c.req.json())
   if (!result.success) return c.json({ error: result.error.issues[0].message }, 400)
   const { name, systemPrompt, stt, llm, tts, variablesSchema } = result.data
   const decodedPrompt = Buffer.from(systemPrompt, 'base64').toString('utf8')
-  const { rows } = await query(
-    'INSERT INTO agents (name, system_prompt, stt, llm, tts, variables_schema) \
-     VALUES ($1, $2, $3, $4, $5, $6) RETURNING id',
-    // [name, systemPrompt, JSON.stringify(stt), JSON.stringify(llm), JSON.stringify(tts), JSON.stringify(variablesSchema)]
-   [name, decodedPrompt, JSON.stringify(stt), JSON.stringify(llm), JSON.stringify(tts), JSON.stringify(variablesSchema)]
-
-  )
-  return c.json({ agentId: rows[0].id }, 201)
+  
+  let resp = await createAgent(name, decodedPrompt, stt, llm, tts, variablesSchema)
+
+  return c.json(resp, 201)
 })
 
-agentsRouter.get('/:agentId', async (c) => {
-  // const { rows } = await query(`SELECT * FROM agents WHERE id = $1`, [c.req.param('agentId')])
-  const { rows } = await query('SELECT * FROM agents WHERE id = $1', [c.req.param('agentId')])
-  if (!rows.length) return c.json({ error: 'Agent not found' }, 404)
-  return c.json(rows[0])
+//get agent
+agentRouter.get('/:agentId', async (c) => {
+  // const { rows } = await query(`SELECT * FROM AGENT WHERE id = $1`, [c.req.param('agentId')])
+  // const { rows } = await query('SELECT * FROM agent WHERE id = $1', [c.req.param('agentId')])
+  // if (!rows.length) return c.json({ error: 'Agent not found' }, 404)
+  // return c.json(rows[0])
+
+  let resp = await getAgent(c.req.param('agentId'))
+  return c.json(resp)
 })
 
-agentsRouter.get('/', async (c) => {
-  const { rows } = await query('SELECT id, name, created_at FROM agents ORDER BY created_at DESC')
-  return c.json(rows)
+//list agents
+agentRouter.get('/', async (c) => {
+  let resp = await listAgents()
+  
+  return c.json(resp)
 })
 
-agentsRouter.put('/:agentId', async (c) => {
+//update agent
+agentRouter.put('/:agentId', async (c) => {
   const result = agentSchema.partial().safeParse(await c.req.json())
   if (!result.success) return c.json({ error: result.error.issues[0].message }, 400)
-  const { name, systemPrompt, stt, llm, tts, variablesSchema } = result.data
+  
+  const { name, systemPrompt, stt, llm, tts, variablesSchema, outputSchemaId, webhookUrl } = result.data
+  
+  console.log('outputSchemaId is: ', outputSchemaId)
+
   const decodedPrompt = systemPrompt ? Buffer.from(systemPrompt, 'base64').toString('utf8') : undefined
 
   const fields = []
   const values = []
+  
   let i = 1
+  
   if (name) { fields.push(`name = $${i++}`); values.push(name) }
   // if (systemPrompt) { fields.push(`system_prompt = $${i++}`); values.push(systemPrompt) }
   if (decodedPrompt) { fields.push(`system_prompt = $${i++}`); values.push(decodedPrompt) }
   if (stt) { fields.push(`stt = $${i++}`); values.push(JSON.stringify(stt)) }
   if (llm) { fields.push(`llm = $${i++}`); values.push(JSON.stringify(llm)) }
   if (tts) { fields.push(`tts = $${i++}`); values.push(JSON.stringify(tts)) }
+
+  if (outputSchemaId) { fields.push(`output_schema_id = $${i++}`); values.push(outputSchemaId) }
+  if (webhookUrl) { fields.push(`webhook_url = $${i++}`); values.push(webhookUrl) }
+  
   if (variablesSchema) { fields.push(`variables_schema = $${i++}`); values.push(JSON.stringify(variablesSchema)) }
+  
   if (!fields.length) return c.json({ error: 'No fields to update' }, 400)
+  
   fields.push(`updated_at = now()`)
   values.push(c.req.param('agentId'))
-  const { rows } = await query(
-    `UPDATE agents SET ${fields.join(', ')} WHERE id = $${i} RETURNING id`,
-    values
-  )
-  if (!rows.length) return c.json({ error: 'Agent not found' }, 404)
-  return c.json({ agentId: rows[0].id })
+  
+  let respRows = await updateAgent(fields, values, i)
+
+  if (!respRows.length) return c.json({ error: 'Agent not found' }, 404)
+  return c.json({ agentId: respRows[0].id })
+})
+
+//delete agent
+agentRouter.delete('/:agentId', async (c) => {
+  let respRows = await deleteAgent(c.req.param('agentId'))
+
+  if (respRows.error) {
+    return c.json(respRows.error, 404)
+  }
+
+  return c.json({ deleted: respRows[0].id })
 })
 
-agentsRouter.delete('/:agentId', async (c) => {
-  const { rows } = await query('DELETE FROM agents WHERE id = $1 RETURNING id', [c.req.param('agentId')])
-  if (!rows.length) return c.json({ error: 'Agent not found' }, 404)
-  return c.json({ deleted: rows[0].id })
-})
+
+
+
+
+
+
+
+
+
+

routes/blob.js

@@ -0,0 +1,45 @@
+import { Hono } from 'hono'
+import { BlobServiceClient } from '@azure/storage-blob'
+
+
+export const blobRouter = new Hono()
+
+const AZURE_STORAGE_CONNECTION_STRING = process.env.AZURE_STORAGE_CONNECTION_STRING
+const AZURE_STORAGE_CONTAINER_NAME = process.env.AZURE_STORAGE_CONTAINER_NAME
+
+//get blob
+blobRouter.get('/', async (c) => {
+	const blobName = c.req.query('blobName')
+	const filename = c.req.query('filename')
+
+	if (!blobName) {
+	return c.json({ error: 'blobName query parameter is required' }, 400)
+	}
+
+	if (!AZURE_STORAGE_CONNECTION_STRING || !AZURE_STORAGE_CONTAINER_NAME) {
+	return c.json({ error: 'Azure Storage not configured' }, 500)
+	}
+
+	try {
+	  const blobServiceClient = BlobServiceClient.fromConnectionString(AZURE_STORAGE_CONNECTION_STRING)
+	  const containerClient = blobServiceClient.getContainerClient(AZURE_STORAGE_CONTAINER_NAME)
+	  const blockBlobClient = containerClient.getBlockBlobClient(blobName)
+
+	  const buffer = await blockBlobClient.downloadToBuffer()
+	  const base64 = buffer.toString('base64')
+
+	  c.header('Access-Control-Allow-Origin', '*')
+
+	  return c.json({
+	    contentType: 'application/octet-stream',
+	    filename: filename || blobName.split('/').pop(),
+	    data: base64
+	  })
+	} catch (error) {
+	  console.error('Blob download error:', error)
+	  c.header('Access-Control-Allow-Origin', '*')
+	  return c.json({ error: 'Failed to download blob' }, 500)
+	}
+})
+
+export default blobRouter

routes/schema.js

@@ -0,0 +1,62 @@
+import { Hono } from 'hono'
+// import { query } from '../common/db.js'
+
+// import { createSchema, listSchemas, updateSchema, deleteSchema } from '../dao/schema.js'
+import { createSchema, listSchemas, getSchema, updateSchema } from '../dao/schema.js'
+
+export const schemaRouter = new Hono()
+
+//create schema
+schemaRouter.post('/', async (c) => {  
+  let oriqReqTxt = await c.req.text()
+  // let fixedReq = oriqReqTxt.replaceAll(': }', ': \{\} }')
+  const result = JSON.parse(oriqReqTxt)
+
+  console.log('result is: ', result)
+
+  try {  
+    let resp = await createSchema(result.name, result.content)
+    if (resp.error) {
+      return c.json(resp.error, resp.code)
+    }
+    return c.json(resp)  
+   } catch (error) {  
+     return c.json({ error: error instanceof Error ? error.message : 'Failed to create output schema' }, 500)
+   }  
+ })
+
+//list output schemas
+schemaRouter.get('/', async (c) => {
+  let resp = await listSchemas()
+  return c.json(resp)
+})
+
+//get output schema
+schemaRouter.get('/:outputSchemaId', async (c) => {
+  let resp = await getSchema(c.req.param('outputSchemaId'))
+  return c.json(resp)
+})
+
+//update output schema
+schemaRouter.put('/:outputSchemaId', async (c) => {
+  const { name, content} = await c.req.json()
+  
+  const fields = []
+  const values = []
+  
+  let i = 1
+  
+  if (name) { fields.push(`name = $${i++}`); values.push(name) }
+  if (content) { fields.push(`schema = $${i++}`); values.push(content) }
+  // if (systemPrompt) { fields.push(`system_prompt = $${i++}`); values.push(systemPrompt) }
+  
+  if (!fields.length) return c.json({ error: 'No fields to update' }, 400)
+  
+  fields.push(`updated_at = now()`)
+  values.push(c.req.param('outputSchemaId'))
+  
+  let respRows = await updateSchema(fields, values, i)
+
+  if (!respRows.length) return c.json({ error: 'Output schema not found' }, 404)
+  return c.json({ outputSchemaId: respRows[0].id })
+})

routes/trunk.js

@@ -0,0 +1,203 @@
+import { Hono } from 'hono'
+import { SipClient } from 'livekit-server-sdk'
+import { SIPTransport } from '@livekit/protocol'
+import { query } from '../common/db.js'
+import { createSipTrunk, getInboundTrunk, updateTrunk, deleteTrunk } from '../dao/trunk.js'
+import { getAgent } from '../dao/agent.js'
+import { env } from '../config/utils.js'
+
+import { trunkSchema } from '../schemas/trunk.js'
+import { dispatchSchema } from '../schemas/dispatch.js'
+
+export const trunkRouter = new Hono()
+
+const sipClient = new SipClient(env.LIVEKIT_URL, env.LIVEKIT_API_KEY, env.LIVEKIT_API_SECRET)
+
+//List all trunks from LK; not the DB !!!
+trunkRouter.get('/', async (c) => {
+try {    
+  const [inboundTrunks, outboundTrunks] = await Promise.all([    
+    sipClient.listSipInboundTrunk({ page: { limit: 100 } }),    
+    sipClient.listSipOutboundTrunk({ page: { limit: 100 } })    
+  ])    
+    
+  const inboundTrunkIds = inboundTrunks.map(trunk => ({    
+    id: trunk.sipTrunkId,    
+    type: 'inbound',    
+    name: trunk.name    
+  }))  
+    
+  const outboundTrunkIds = outboundTrunks.map(trunk => ({    
+    id: trunk.sipTrunkId,    
+    type: 'outbound',     
+    name: trunk.name    
+  }))    
+    
+  return c.json({    
+    trunks: [...inboundTrunkIds, ...outboundTrunkIds]    
+  })    
+} catch (error) {    
+  return c.json({ error: error.message+'. Check LK server conn' }, 500)  
+}
+})
+
+//get trunk by id
+trunkRouter.get('/:trunkId', async (c) => {
+  const { rows } = await query('SELECT * FROM trunk WHERE lk_trunk_id = $1', [c.req.param('trunkId')])
+  if (!rows.length) return c.json({ error: 'Trunk not found' }, 404)
+  return c.json(rows[0])
+})
+
+//create OUTBOUND/INBOUND trunk
+trunkRouter.post('/', async (c) => {  
+  const result = trunkSchema.safeParse(await c.req.json())  
+  if (!result.success) return c.json({ error: result.error.issues[0].message }, 400)  
+  
+  const { name, address, numbers, authUsername, authPassword } = result.data  
+  
+  if (address) {
+  	  console.log('Creating OUTBOUND trunk ...')
+	  // Create LK SIP outbound trunk  
+	  const outbound = await sipClient.createSipOutboundTrunk(  
+	    name,  
+	    address,  
+	    numbers,  
+	    {  
+	      authUsername,  
+	      authPassword,  
+	      transport: SIPTransport.SIP_TRANSPORT_AUTO  
+	    }  
+	  )
+
+	  let respRows = await createSipTrunk(name, 'outbound', outbound.sipTrunkId, address)
+	  return c.json({  
+	    outboundTrunkId: respRows[0].id
+	  }, 201)    
+  } else {
+	  console.log('Creating INBOUND trunk ...')
+	  // Create inbound trunk (no caller restrictions)  
+	  const inbound = await sipClient.createSipInboundTrunk(  
+	    name,  
+	    numbers,  
+	    {  
+	      authUsername,  
+	      authPassword,
+	      transport: SIPTransport.SIP_TRANSPORT_AUTO  
+	    }  
+	  )  
+	  
+	  let respRows = await createSipTrunk(name, 'inbound', inbound.sipTrunkId)
+
+	  return c.json({  
+	    inboundTrunkId: respRows[0].id
+	  }, 201)  
+  }
+})
+
+
+//update trunk
+trunkRouter.put('/:trunkId', async (c) => {
+  const result = trunkSchema.partial().safeParse(await c.req.json())
+  if (!result.success) return c.json({ error: result.error.issues[0].message }, 400)
+  const { name, address, numbers } = result.data
+  
+
+  const fields = []
+  const values = []
+  
+  let i = 1
+  
+  if (name) { fields.push(`name = $${i++}`); values.push(name) }
+  if (address) { fields.push(`address = $${i++}`); values.push(JSON.stringify(address)) }
+  if (numbers) { fields.push(`numbers = $${i++}`); values.push(JSON.stringify(numbers)) }
+  
+  if (!fields.length) return c.json({ error: 'No fields to update' }, 400)
+  
+  fields.push(`updated_at = now()`)
+  values.push(c.req.param('trunkId'))
+  
+  let respRows = await updateTrunk(fields, values, i)
+
+  if (!respRows.length) return c.json({ error: 'Trunk not found' }, 404)
+  return c.json({ trunkId: respRows[0].id })
+})
+
+//Create INBOUND dispatch with associated agent
+trunkRouter.post('/dispatch', async (c) => {
+  const result = dispatchSchema.safeParse(await c.req.json())
+  if (!result.success) return c.json({ error: result.error.issues[0].message }, 400)
+
+  const { agentId, sipTrunkId } = result.data
+  let inboundTrunk = await getInboundTrunk(sipTrunkId)
+  console.log(JSON.stringify(inboundTrunk, null, 2))
+
+  if (!inboundTrunk.length) return c.json({ error: 'Inbound trunk not found' }, 404)
+
+  let agent = await getAgent(agentId)
+  if (!agent.length) return c.json({ error: 'Agent not found' }, 404)
+
+  // Each inbound call gets its own room, routed to this agent
+  const rule = await sipClient.createSipDispatchRule(
+  	{  
+    type: 'individual',  
+    roomPrefix: 'call_',  
+  },  
+  {  
+    name: 'inbound-dispatch-rule',  
+    trunkIds: [inboundTrunk[0].lk_trunk_id],  
+  }  
+  )
+
+  await query(
+    'UPDATE agent SET lk_dispatch_rule_id = $1, updated_at = now() WHERE id = $2',
+    [rule.sipDispatchRuleId, agentId]
+  )
+
+  return c.json({ dispatchRuleId: rule.sipDispatchRuleId }, 201)
+})
+
+
+// Delete trunk
+trunkRouter.delete('/:trunkId', async (c) => {
+    const { rows } = await query(
+      'SELECT lk_trunk_id FROM trunk WHERE id = $1',
+      [c.req.param('trunkId')]
+    )
+    if (!rows.length) return c.json({ error: 'Trunk not found' }, 404)
+
+    const { lk_trunk_id } = rows[0]
+    if (!lk_trunk_id ) return c.json({ error: 'No trunks found in LK' }, 404)
+
+    if (lk_trunk_id) await sipClient.deleteSipTrunk(lk_trunk_id)
+    // if (lk_inbound_trunk_id) await sipClient.deleteSipTrunk(lk_inbound_trunk_id)
+
+  let respRows = await deleteTrunk(c.req.param('trunkId'))
+
+  if (respRows.error) {
+    return c.json(respRows.error, 404)
+  }
+
+  return c.json({ deleted: respRows[0].id })
+})
+
+
+// trunkRouter.delete('/:agentId', async (c) => {
+//   const { rows } = await query(
+//     'SELECT lk_trunk_id, lk_inbound_trunk_id FROM agent WHERE id = $1',
+//     [c.req.param('agentId')]
+//   )
+//   if (!rows.length) return c.json({ error: 'Agent not found' }, 404)
+
+//   const { lk_trunk_id, lk_inbound_trunk_id } = rows[0]
+//   if (!lk_trunk_id && !lk_inbound_trunk_id) return c.json({ error: 'No trunks found' }, 404)
+
+//   if (lk_trunk_id) await sipClient.deleteSipTrunk(lk_trunk_id)
+//   if (lk_inbound_trunk_id) await sipClient.deleteSipTrunk(lk_inbound_trunk_id)
+
+//   await query(
+//     'UPDATE agent SET lk_trunk_id = NULL, lk_inbound_trunk_id = NULL, updated_at = now() WHERE id = $1',
+//     [c.req.param('agentId')]
+//   )
+
+//   return c.json({ deleted: { outbound: lk_trunk_id, inbound: lk_inbound_trunk_id } })
+// })

schemas/agent.js

@@ -0,0 +1,33 @@
+import { z } from 'zod'
+
+export const agentSchema = z.object({
+  name: z.string().min(1),
+  
+  // systemPrompt: z.string().min(1),
+  systemPrompt: z.string().min(1), // base64 encoded
+
+  stt: z.object({
+    provider: z.enum(['deepgram', 'azure']),
+    model: z.string().min(1),
+    language: z.string().default('en-US'),
+  }),
+  
+  llm: z.object({
+    provider: z.enum(['azure', 'litellm']),
+    endpoint: z.string().url(),
+    model: z.string().min(1),
+    apiKey: z.string().min(1),
+    apiVersion: z.string().optional(),
+  }),
+  
+  tts: z.object({
+    provider: z.enum(['deepgram', 'azure']),
+    model: z.string().min(1),
+    voice: z.string().optional(),
+  }),
+  
+  variablesSchema: z.record(z.string()).optional().default({}),
+  outputSchemaId: z.string().uuid(),
+  webhookUrl: z.string().min(1),
+
+})

utils.js → schemas/call.js

@@ -1,33 +1,18 @@
-import { AgentDispatchClient, SipClient } from 'livekit-server-sdk'
-
 import { z } from 'zod'
 
 const e164Regex = /^\+[1-9]\d{6,14}$/
-const callSchema = z.object({
+
+export const callSchema = z.object({
   callTo: z.string({ required_error: 'callTo is required' })
           .transform(n => `+${n.replace(/\D/g, '')}`)
           .refine(n => e164Regex.test(n), {
             message: 'Invalid phone number. Use E.164 format (e.g. +14155552671)'
   }),
-  // sipTrunkId: z.string({ required_error: 'sipTrunkId is required' }).min(1, 'sipTrunkId is required'),
-  // agentName: z.string({ required_error: 'agentName is required' }).min(1, 'agentName is required'),
   agentId: z.string({ required_error: 'agentId is required' }).uuid('agentId must be a valid UUID'),
   variables: z.record(z.string().default({})).optional()
 })
 
-const env = z.object({
-  LIVEKIT_API_KEY: z.string().min(1),
-  LIVEKIT_API_SECRET: z.string().min(1),
-  LIVEKIT_URL: z.string().url(),
-  API_PORT_NUM: z.coerce.number().default(3000),
-  DATABASE_URL: z.string().url(),
-  SIP_TRUNK_ID: z.string().min(1),
-}).parse(process.env)
-
- 
-const lkArgs = [env.LIVEKIT_URL, env.LIVEKIT_API_KEY, env.LIVEKIT_API_SECRET]
-const agentDispatchClient = new AgentDispatchClient(...lkArgs)
-const sipClient = new SipClient(...lkArgs)
-
-
-export { callSchema, env, lkArgs, agentDispatchClient, sipClient }
+export const dispatchSchema = z.object({
+  agentId: z.string().uuid(),
+  sipTrunkId: z.string().uuid()
+})

schemas/dispatch.js

@@ -0,0 +1,6 @@
+import { z } from 'zod'
+
+export const dispatchSchema = z.object({
+  agentId: z.string().uuid(),
+  sipTrunkId: z.string().uuid()
+})

schemas/trunk.js

@@ -0,0 +1,9 @@
+import { z } from 'zod'
+
+export const trunkSchema = z.object({
+  name: z.string().min(1),
+  address: z.string().optional(),
+  numbers: z.array(z.string()).min(1),  // e.g. ["+17753176886"]
+  authUsername: z.string().min(1),
+  authPassword: z.string().min(1),
+})