[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_156":157,"_158":159},"routes/_app.x.$handle.$name",{"_16":17,"_20":21,"_83":65,"_84":31,"_63":-7,"_85":-5,"_13":86,"_87":88,"_11":89,"_90":91,"_92":93,"_94":-5,"_95":-5,"_96":-5,"_97":26,"_98":99,"_100":101,"_102":-5,"_103":-5,"_104":105},"routes/_app.x.$handle.$name.search.$(branch)",{"_11":12,"_13":14,"_15":-5,"_16":17},"files",[],"project",{"_18":19,"_20":21,"_22":23,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":-5,"_36":26,"_37":-5,"_38":-5,"_39":40,"_41":42,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":57,"_58":59,"_60":61,"_62":26},"query","handle","jamesayres","id","3d9a0dda-96bf-42b3-a659-acb22bed96f6","name","cold-dialer-webhook","createdAt",["D",1783413111388],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","","imageUrl","userId","479e4e9c-8457-43bf-9d25-06399436a4f4","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019eb632-84fe-70e4-9a7f-19a05e40a2f8","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_16":17,"_82":78},"org",{"_16":17,"_75":76,"_77":78,"_33":34,"_79":80,"_81":26},"branch",{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"isOwned","version",3,"main","d9ac8462-5fe6-4901-86a0-7037d6c4977f","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","James Ayres","avatar","https://lh3.googleusercontent.com/a/ACg8ocJOBKkeJdcD8Vv48levfET0tNVodYvJRCFxAuAaNoagJBFNRYM=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","path","adoptOrgId",{"_18":19,"_20":21,"_22":152,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":-5,"_36":26,"_37":-5,"_38":-5,"_39":40,"_41":42,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":153,"_58":154,"_60":155,"_62":26},"tree",[143,144],[143,144],"counts",{"_133":40,"_134":117,"_135":40,"_136":137,"_138":139},"contents",[106,107],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_18":125,"_20":126,"_110":127,"_112":-5,"_113":66,"_114":128,"_115":101,"_22":129,"_63":40,"_118":130,"_120":131,"_122":26,"_123":-5,"_84":132},{"_18":108,"_20":109,"_110":111,"_112":-5,"_113":66,"_114":64,"_115":101,"_22":116,"_63":117,"_118":119,"_120":121,"_122":26,"_123":-5,"_84":124},"17e63a08-2360-4623-b775-7708def1448f","main.ts","fileId","f8d2c760-79e0-11f1-b35e-1607ee4eb77e","parentId","branchId","branchVersion","latest",["D",1783414328080],1,"fileType","http","content","// Cold Dialer — HTTP val. Progressive dialer backend (Telnyx Call Control + SQLite).\n// Deploy with `vt push`. Standalone project — NOT shared with LeadPulse/LeadBlitz.\n//\n// Env vars (set on THIS val — Val.town env vars are per-val, not account-wide):\n// TELNYX_API_KEY Bearer auth for Call Control commands\n// TELNYX_CONNECTION_ID Call Control App connection id\n// TELNYX_FROM_NUMBER Presentation CLI, a voice-capable Telnyx VMN (E.164)\n// AGENT_NUMBER Your mobile, E.164 (e.g. +447...)\n// TELNYX_PUBLIC_KEY Ed25519 public key for webhook signature verification\n// APP_SECRET Shared secret for operator routes (Bearer auth)\n//\n// Build order (step 1, this file): schema + /session/start + agent-leg\n// call.answered handler. Goal: prove the agent's mobile rings and the session\n// reaches status='ready'. Lead dialing / bridging / disposition come next.\n\nimport {\n sqlite, cors, json, checkAuth, ensureTables,\n decodeClientState, telnyxDial, telnyxHangup,\n verifyTelnyxSignature,\n} from \"./lib.ts\";\n\nfunction healthPage(): string {\n return `\n

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","deleted","label",[109],"19b02a74-0a28-4947-9f79-37db105cee7b","lib.ts","f8fb381c-79e0-11f1-86f5-1607ee4eb77e",2,["D",1783414258192],"script","// 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",[126],"pulls","branches","forks","envVars",{"_140":40,"_142":40},"connections",{"_140":40,"_141":40},"count","unfilledCount","emptyCount",{"_18":125,"_20":126,"_110":127,"_112":-5,"_113":66,"_114":128,"_115":101,"_22":149,"_63":40,"_118":130,"_120":131,"_122":26,"_123":-5,"_146":150,"_84":151},{"_18":108,"_20":109,"_110":111,"_112":-5,"_113":66,"_114":64,"_115":101,"_22":145,"_63":117,"_118":119,"_120":121,"_122":26,"_123":-5,"_146":147,"_84":148},["D",1783414328080],"children",[],[109],["D",1783414258192],[],[126],["D",1783413111388],{"_16":17,"_82":78},{"_16":17,"_75":76,"_77":78,"_33":34,"_79":80,"_81":26},{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"ctx",{"_56":-5,"_103":189,"_190":191,"_192":193,"_194":26,"_195":26,"_196":26,"_197":101,"_198":-5,"_199":-7,"_200":-7,"_201":40,"_202":26,"_203":26,"_204":-5,"_205":26,"_206":26,"_207":26,"_208":-5},"ENV",{"_160":161,"_162":163,"_164":65,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Search