[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_149":150,"_151":152},"routes/_app.x.$handle.$name",{"_93":92,"_31":43,"_102":83,"_26":51,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":24,"_116":117,"_118":24,"_119":-5,"_120":-5,"_121":122},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":76,"_77":78,"_79":80,"_81":24},"version",1,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","main.ts","latestPath","fileId","f8d2c760-79e0-11f1-b35e-1607ee4eb77e","name","fileType","script","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","createdAt",["D",1783414257927],"branchVersion","branchId","d9ac8462-5fe6-4901-86a0-7037d6c4977f","id","3d9a0dda-96bf-42b3-a659-acb22bed96f6","cold-dialer-webhook",["D",1783413111388],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","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",{"_93":92,"_101":97},"org",{"_93":92,"_94":95,"_96":97,"_18":53,"_98":99,"_100":24},"branch",{"_13":82,"_31":83,"_41":40,"_84":42,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":43,"_91":92},"isOwned",3,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","jamesayres","handle","displayName","James Ayres","avatar","https://lh3.googleusercontent.com/a/ACg8ocJOBKkeJdcD8Vv48levfET0tNVodYvJRCFxAuAaNoagJBFNRYM=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_41":42,"_31":43,"_36":145,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":146,"_77":147,"_79":148,"_81":24},"tree",[140],"files",[140],"counts",{"_130":59,"_131":14,"_132":59,"_133":134,"_135":136},"contents",[123],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":124,"_31":27,"_29":30,"_125":-5,"_39":40,"_38":14,"_126":24,"_36":127,"_13":59,"_32":33,"_34":35,"_23":24,"_128":-5,"_26":129},"42b13617-412d-40b1-9e8a-8d039497f885","parentId","latest",["D",1783414257927],"label",[27],"pulls","branches","forks","envVars",{"_137":59,"_139":59},"connections",{"_137":59,"_138":59},"count","unfilledCount","emptyCount",{"_41":124,"_31":27,"_29":30,"_125":-5,"_39":40,"_38":14,"_126":24,"_36":141,"_13":59,"_32":33,"_34":35,"_23":24,"_128":-5,"_142":143,"_26":144},["D",1783414257927],"children",[],[27],["D",1783413111388],{"_93":92,"_101":97},{"_93":92,"_94":95,"_96":97,"_18":53,"_98":99,"_100":24},{"_13":82,"_31":83,"_41":40,"_84":42,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":43,"_91":92},"ctx",{"_75":-5,"_120":182,"_183":184,"_185":186,"_187":24,"_188":24,"_189":24,"_190":191,"_192":-5,"_193":-7,"_194":-7,"_195":59,"_196":24,"_197":24,"_198":-5,"_199":24,"_200":24,"_201":24,"_202":-5},"ENV",{"_153":154,"_155":156,"_157":83,"_158":159,"_160":161,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181},"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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v1