Cold Dialer

HTTP val is up. See main.ts for routes.

\n `;\n}\n\nasync function routeSessionStart(req: Request): Promise {\n if (!checkAuth(req)) return json({ error: \"unauthorized\" }, 401);\n await ensureTables();\n\n const agentNumber = Deno.env.get(\"AGENT_NUMBER\");\n const fromNumber = Deno.env.get(\"TELNYX_FROM_NUMBER\");\n if (!agentNumber || !fromNumber) {\n return json({ error: \"AGENT_NUMBER / TELNYX_FROM_NUMBER not configured on this val\" }, 500);\n }\n\n const sessionId = crypto.randomUUID();\n const startedAt = new Date().toISOString();\n await sqlite.execute({\n sql: `INSERT INTO dialer_sessions (id, agent_number, status, started_at) VALUES (?, ?, ?, ?)`,\n args: [sessionId, agentNumber, \"starting\", startedAt],\n });\n\n const dial = await telnyxDial({\n to: agentNumber,\n from: fromNumber,\n clientState: { role: \"agent\", session_id: sessionId },\n timeoutSecs: 30,\n });\n\n if (!dial.ok) {\n await sqlite.execute({\n sql: `UPDATE dialer_sessions SET status = 'failed', ended_at = ? WHERE id = ?`,\n args: [new Date().toISOString(), sessionId],\n });\n return json({ error: \"telnyx dial failed\", detail: dial.raw }, 502);\n }\n\n return json({ session_id: sessionId, status: \"starting\" });\n}\n\nasync function routeSessionState(req: Request, sessionId: string): Promise {\n if (!checkAuth(req)) return json({ error: \"unauthorized\" }, 401);\n await ensureTables();\n const r = await sqlite.execute({\n sql: `SELECT id, agent_number, agent_call_control_id, status, started_at, ended_at FROM dialer_sessions WHERE id = ?`,\n args: [sessionId],\n });\n const row = (r.rows as any[])[0];\n if (!row) return json({ error: \"not found\" }, 404);\n const [id, agent_number, agent_call_control_id, status, started_at, ended_at] = row;\n return json({ id, agent_number, agent_call_control_id, status, started_at, ended_at });\n}\n\nasync function routeSessionEnd(req: Request): Promise {\n if (!checkAuth(req)) return json({ error: \"unauthorized\" }, 401);\n await ensureTables();\n const body = await req.json().catch(() => ({}));\n const sessionId = body.session_id;\n if (!sessionId) return json({ error: \"session_id required\" }, 400);\n\n const r = await sqlite.execute({\n sql: `SELECT agent_call_control_id FROM dialer_sessions WHERE id = ?`,\n args: [sessionId],\n });\n const callControlId = (r.rows as any[])[0]?.[0];\n if (callControlId) await telnyxHangup(callControlId);\n\n await sqlite.execute({\n sql: `UPDATE dialer_sessions SET status = 'ended', ended_at = ? WHERE id = ?`,\n args: [new Date().toISOString(), sessionId],\n });\n return json({ ok: true });\n}\n\n// ---- Telnyx webhook: the state machine --------------------------------------\n// Step 1 only handles the AGENT leg (call.answered -> status='ready',\n// call.hangup -> status='ended'). Lead-leg dialing/bridging is step 2.\n\nasync function routeWebhook(req: Request): Promise {\n const rawBody = await req.text();\n const publicKey = Deno.env.get(\"TELNYX_PUBLIC_KEY\");\n const sig = req.headers.get(\"telnyx-signature-ed25519\") || \"\";\n const timestamp = req.headers.get(\"telnyx-timestamp\") || \"\";\n\n // Fails OPEN if TELNYX_PUBLIC_KEY is unset (so you can test before you've\n // pulled the key from the Telnyx portal), fails CLOSED once it's set.\n if (publicKey) {\n const valid = await verifyTelnyxSignature(publicKey, sig, timestamp, rawBody);\n if (!valid) return cors(null, 401);\n }\n\n let evt: any;\n try {\n evt = JSON.parse(rawBody);\n } catch {\n return cors(null, 200); // malformed body — ack anyway, nothing to retry\n }\n\n const eventType = evt?.data?.event_type;\n const payload = evt?.data?.payload ?? {};\n const state = decodeClientState(payload.client_state);\n const callControlId = payload.call_control_id;\n\n await ensureTables();\n\n try {\n if (eventType === \"call.answered\" && state?.role === \"agent\") {\n await sqlite.execute({\n sql: `UPDATE dialer_sessions SET agent_call_control_id = ?, status = 'ready' WHERE id = ? AND status != 'ready'`,\n args: [callControlId, state.session_id as string],\n });\n } else if (eventType === \"call.hangup\" && state?.role === \"agent\") {\n await sqlite.execute({\n sql: `UPDATE dialer_sessions SET status = 'ended', ended_at = ? WHERE id = ? AND status != 'ended'`,\n args: [new Date().toISOString(), state.session_id as string],\n });\n }\n // Lead-role events (call.answered / call.bridged / call.hangup) are\n // step 2 — not handled yet.\n } catch (e) {\n console.error(\"webhook handling error\", e);\n }\n\n return cors(null, 200);\n}\n\nexport default async function (req: Request): Promise {\n if (req.method === \"OPTIONS\") return cors(null, 204);\n\n const url = new URL(req.url);\n const path = url.pathname;\n\n if (path === \"/\" && req.method === \"GET\") {\n return new Response(healthPage(), { headers: { \"content-type\": \"text/html\" } });\n }\n if (path === \"/session/start\" && req.method === \"POST\") return routeSessionStart(req);\n if (path === \"/session/end\" && req.method === \"POST\") return routeSessionEnd(req);\n const stateMatch = path.match(/^\\/session\\/([^/]+)\\/state$/);\n if (stateMatch && req.method === \"GET\") return routeSessionState(req, stateMatch[1]);\n if (path === \"/webhooks/telnyx\" && req.method === \"POST\") return routeWebhook(req);\n\n return json({ error: \"not found\" }, 404);\n}\n","label",[60],"19b02a74-0a28-4947-9f79-37db105cee7b",["D",1783414258192],"// Cold Dialer — shared stateless helpers for main.ts.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nexport { sqlite };\n\nexport function cors(body: string | null, status = 200, headers: Record = {}) {\n return new Response(body, {\n status,\n headers: {\n \"access-control-allow-origin\": \"*\",\n \"access-control-allow-headers\": \"Content-Type, Authorization\",\n \"access-control-allow-methods\": \"GET, POST, OPTIONS\",\n ...headers,\n },\n });\n}\n\nexport function json(data: unknown, status = 200) {\n return cors(JSON.stringify(data), status, { \"content-type\": \"application/json\" });\n}\n\n// Verbatim from LeadPulse's lib.ts — Deno Web Crypto Ed25519 verification of\n// Telnyx's `telnyx-signature-ed25519` / `telnyx-timestamp` webhook headers.\nexport async function verifyTelnyxSignature(\n publicKeyB64: string,\n signatureB64: string,\n timestamp: string,\n rawBody: string,\n): Promise {\n try {\n if (!publicKeyB64 || !signatureB64 || !timestamp) return false;\n const b64ToBytes = (b64: string) => Uint8Array.from(atob(b64), (c) => c.charCodeAt(0));\n const key = await crypto.subtle.importKey(\n \"raw\", b64ToBytes(publicKeyB64), { name: \"Ed25519\" }, false, [\"verify\"],\n );\n const signed = new TextEncoder().encode(`${timestamp}|${rawBody}`);\n return await crypto.subtle.verify(\"Ed25519\", key, b64ToBytes(signatureB64), signed);\n } catch (e) {\n console.error(\"Telnyx sig verify error\", e);\n return false;\n }\n}\n\nexport function encodeClientState(obj: Record): string {\n return btoa(JSON.stringify(obj));\n}\n\nexport function decodeClientState(b64: string | undefined | null): Record | null {\n if (!b64) return null;\n try {\n return JSON.parse(atob(b64));\n } catch {\n return null;\n }\n}\n\n// Bearer APP_SECRET gate for operator-facing routes (not the Telnyx webhook,\n// which Telnyx can't sign with our secret — that's protected by Ed25519\n// signature verification instead). Fails closed if APP_SECRET is unset.\nexport function checkAuth(req: Request): boolean {\n const secret = Deno.env.get(\"APP_SECRET\");\n if (!secret) return false;\n const header = req.headers.get(\"authorization\") || \"\";\n return header === `Bearer ${secret}`;\n}\n\nlet schemaReady = false;\nexport async function ensureTables() {\n if (schemaReady) return;\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS dialer_sessions (\n id TEXT PRIMARY KEY,\n agent_number TEXT NOT NULL,\n agent_call_control_id TEXT,\n status TEXT NOT NULL,\n started_at TEXT NOT NULL,\n ended_at TEXT\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS dialer_calls (\n id TEXT PRIMARY KEY,\n session_id TEXT NOT NULL,\n lead_id INTEGER NOT NULL,\n lead_call_control_id TEXT,\n status TEXT NOT NULL,\n disposition TEXT,\n started_at TEXT NOT NULL,\n answered_at TEXT,\n ended_at TEXT,\n duration_secs INTEGER\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS leads (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n business_name TEXT,\n phone TEXT NOT NULL,\n address TEXT,\n city TEXT,\n website TEXT,\n call_status TEXT NOT NULL DEFAULT 'pending',\n created_at TEXT NOT NULL\n )`);\n schemaReady = true;\n}\n\n// ---- Telnyx Call Control API ------------------------------------------------\n// NOTE (per the build spec): verify these request/response shapes against the\n// current Telnyx Call Control v2 docs before relying on them — they drift.\n\nconst TELNYX_API = \"https://api.telnyx.com/v2\";\n\nexport async function telnyxDial(opts: {\n to: string;\n from: string;\n clientState: Record;\n timeoutSecs?: number;\n}): Promise<{ ok: boolean; callControlId?: string; raw: unknown }> {\n const apiKey = Deno.env.get(\"TELNYX_API_KEY\");\n const connectionId = Deno.env.get(\"TELNYX_CONNECTION_ID\");\n const res = await fetch(`${TELNYX_API}/calls`, {\n method: \"POST\",\n headers: {\n \"authorization\": `Bearer ${apiKey}`,\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n connection_id: connectionId,\n to: opts.to,\n from: opts.from,\n client_state: encodeClientState(opts.clientState),\n timeout_secs: opts.timeoutSecs ?? 30,\n command_id: crypto.randomUUID(),\n }),\n });\n const raw = await res.json().catch(() => null);\n const callControlId = (raw as any)?.data?.call_control_id;\n return { ok: res.ok, callControlId, raw };\n}\n\nexport async function telnyxHangup(callControlId: string): Promise {\n const apiKey = Deno.env.get(\"TELNYX_API_KEY\");\n await fetch(`${TELNYX_API}/calls/${callControlId}/actions/hangup`, {\n method: \"POST\",\n headers: {\n \"authorization\": `Bearer ${apiKey}`,\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({ command_id: crypto.randomUUID() }),\n }).catch((e) => console.error(\"hangup error\", e));\n}\n",[75],"pulls","branches","forks","envVars",{"_175":20,"_177":20},"connections",{"_175":20,"_176":20},"count","unfilledCount","emptyCount",{"_29":164,"_13":75,"_58":74,"_39":-5,"_31":32,"_157":69,"_158":149,"_33":184,"_35":20,"_61":62,"_160":166,"_63":24,"_162":-5,"_181":185,"_132":186},{"_29":156,"_13":60,"_58":59,"_39":-5,"_31":32,"_157":78,"_158":149,"_33":180,"_35":36,"_61":83,"_160":161,"_63":24,"_162":-5,"_181":182,"_132":183},["D",1783414328080],"children",[],[60],["D",1783414258192],[],[75],["D",1783413111388],{"_11":12,"_131":66},{"_11":12,"_126":127,"_65":66,"_25":64,"_128":129,"_130":24},{"_35":78,"_13":16,"_29":32,"_118":84,"_119":-5,"_120":-5,"_121":-5,"_122":-5,"_123":-5,"_124":14,"_125":12},"ctx",{"_47":-5,"_151":224,"_225":226,"_227":228,"_229":24,"_230":24,"_231":24,"_232":149,"_233":-5,"_234":-7,"_235":-7,"_236":20,"_237":24,"_238":24,"_239":-5,"_240":24,"_241":24,"_242":24,"_243":-5},"ENV",{"_195":196,"_197":198,"_199":16,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

History