[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_170":171,"_172":173},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_129":-5,"_20":130,"_22":131,"_132":133,"_134":135,"_25":136,"_24":-5,"_137":-5,"_138":-5,"_139":54,"_140":141,"_142":45,"_143":-5,"_144":-5,"_145":146},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","jamesayres","name","cold-dialer-webhook","branchName","main","version","path","","project",{"_34":75,"_13":14,"_46":76,"_77":-5,"_78":54,"_79":80,"_81":80,"_82":19,"_83":-5,"_84":85,"_86":-5,"_87":54,"_88":-5,"_89":-5,"_90":62,"_91":92,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":98,"_99":98,"_100":101,"_102":101,"_103":101,"_104":98,"_105":98,"_106":107,"_108":109,"_110":111,"_112":54},"tree",[66,67],"file","contents",[32,33],"upstream","pull","ahead","behind","envVars",{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":61,"_17":62,"_49":63,"_51":64,"_53":54,"_55":-5,"_18":65},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":47,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_18":56},"id","17e63a08-2360-4623-b775-7708def1448f","main.ts","fileId","f8d2c760-79e0-11f1-b35e-1607ee4eb77e","parentId","branchId","d9ac8462-5fe6-4901-86a0-7037d6c4977f","branchVersion",3,"latest",true,"createdAt",["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",false,"label",[36],"19b02a74-0a28-4947-9f79-37db105cee7b","lib.ts","f8fb381c-79e0-11f1-86f5-1607ee4eb77e",2,["D",1783414258192],0,"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",[58],{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":72,"_17":62,"_49":63,"_51":64,"_53":54,"_55":-5,"_69":73,"_18":74},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":68,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_69":70,"_18":71},["D",1783414328080],"children",[],[36],["D",1783414258192],[],[58],"3d9a0dda-96bf-42b3-a659-acb22bed96f6",["D",1783413111388],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","479e4e9c-8457-43bf-9d25-06399436a4f4","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","019eb632-84fe-70e4-9a7f-19a05e40a2f8","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_128":124},"org",{"_11":12,"_121":122,"_123":124,"_84":85,"_125":126,"_127":54},"branch",{"_17":43,"_13":16,"_34":41,"_113":75,"_114":-5,"_115":-5,"_116":-5,"_117":-5,"_118":-5,"_119":14,"_120":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","James Ayres","avatar","https://lh3.googleusercontent.com/a/ACg8ocJOBKkeJdcD8Vv48levfET0tNVodYvJRCFxAuAaNoagJBFNRYM=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_34":75,"_13":14,"_46":166,"_77":-5,"_78":54,"_79":80,"_81":80,"_82":19,"_83":-5,"_84":85,"_86":-5,"_87":54,"_88":-5,"_89":-5,"_90":62,"_91":92,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":98,"_99":98,"_100":101,"_102":101,"_103":101,"_104":98,"_105":98,"_106":167,"_108":168,"_110":169,"_112":54},[160,161],"files",[160,161],"counts",{"_151":62,"_152":48,"_153":62,"_31":154,"_155":156},[147,148],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":61,"_17":62,"_49":63,"_51":64,"_53":54,"_55":-5,"_18":150},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":47,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_18":149},[36],[58],"pulls","branches","forks",{"_157":62,"_159":62},"connections",{"_157":62,"_158":62},"count","unfilledCount","emptyCount",{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":72,"_17":62,"_49":63,"_51":64,"_53":54,"_55":-5,"_69":164,"_18":165},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":68,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_69":162,"_18":163},[],[36],[],[58],["D",1783413111388],{"_11":12,"_128":124},{"_11":12,"_121":122,"_123":124,"_84":85,"_125":126,"_127":54},{"_17":43,"_13":16,"_34":41,"_113":75,"_114":-5,"_115":-5,"_116":-5,"_117":-5,"_118":-5,"_119":14,"_120":12},"ctx",{"_106":-5,"_144":203,"_204":205,"_206":207,"_208":54,"_209":54,"_210":54,"_211":45,"_212":-5,"_213":-7,"_214":-7,"_215":62,"_216":54,"_217":54,"_218":-5,"_219":54,"_220":54,"_221":54,"_222":-5},"ENV",{"_174":175,"_176":177,"_178":16,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202},"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"]