[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_155":156,"_157":158},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":25,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",4,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","e227ccb8-6f3b-11f1-9034-1607ee4eb77e","name","fileType","script","content","// LeadPulse — campaign sender (CRON val) — FREE-TIER version\n// Trigger: Cron, schedule \"*/15 * * * *\" (every 15 min — the free-tier minimum).\n// Shares the same Val.town SQLite database as webhook-receiver.\n// Env vars (account-wide): TELNYX_API_KEY, TELNYX_FROM_NUMBER\n//\n// Free tier reality: cron fires at most every 15 min and each run is killed at\n// 60s. So we can't drip one message per minute. Instead each run sends a small\n// batch, spaced a few seconds apart, and STOPS well before the 60s cap — the\n// leftover queue is picked up on the next run. Volume stays low and non-bursty,\n// which keeps the carrier happy. When you move to Val.town Pro, switch the\n// schedule to \"* * * * *\" and (optionally) raise MAX_PER_RUN / the gap to use\n// the proper 30s-2min spacing.\n\n// ───────────────────────────────────────────────────────────────────────────\n// SANDBOX DATA ISOLATION (mirrors webhook-receiver-sandbox/lib.ts)\n// std/sqlite is one account-wide DB shared by every val, so every query here is\n// transparently redirected to TABLE_PREFIX-prefixed tables (`leads`->`sb_leads`)\n// so this sandbox cron can never touch the live production queue/leads. Set\n// TABLE_PREFIX = \"\" to point back at the production tables.\n// ───────────────────────────────────────────────────────────────────────────\nimport { sqlite as _rawSqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst TABLE_PREFIX = \"lb_\"; // LeadBlitz tables (isolated from LeadPulse's prod tables on the shared DB)\nconst _TABLES = [\n \"campaign_queue\", \"unrouted_messages\", \"leads_new\", \"settings_new\",\n \"campaigns\", \"messages\", \"agents\", \"clients\", \"folders\", \"leads\",\n \"numbers\", \"settings\",\n];\nfunction prefixSql(sql: string): string {\n if (!TABLE_PREFIX) return sql;\n let out = sql;\n for (const t of _TABLES) out = out.replace(new RegExp(\"\\\\b\" + t + \"\\\\.\", \"g\"), TABLE_PREFIX + t + \".\");\n out = out.replace(\n /(table_info\$\\s*)(\"?)([a-zA-Z_][a-zA-Z0-9_]*)\\2(\\s*\$)/gi,\n (m, pre, q, name, post) => (_TABLES.includes(name) ? `${pre}${q}${TABLE_PREFIX}${name}${q}${post}` : m),\n );\n out = out.replace(\n /\\b(from|join|into|update|references|rename\\s+to|table(?:\\s+if\\s+not\\s+exists)?)\\s+(\"?)([a-zA-Z_][a-zA-Z0-9_]*)\\2/gi,\n (m, kw, q, name) => (_TABLES.includes(name) ? `${kw} ${q}${TABLE_PREFIX}${name}${q}` : m),\n );\n return out;\n}\nfunction _rewriteArg(arg: any): any {\n if (typeof arg === \"string\") return prefixSql(arg);\n if (arg && typeof arg.sql === \"string\") return { ...arg, sql: prefixSql(arg.sql) };\n return arg;\n}\nconst sqlite = {\n execute: (arg: any) => _rawSqlite.execute(_rewriteArg(arg)),\n batch: (stmts: any[], mode?: any) => (_rawSqlite as any).batch(stmts.map(_rewriteArg), mode),\n};\n\nconst SEND_WINDOW_START = 9; // 9am inclusive\nconst SEND_WINDOW_END = 20; // 8pm exclusive\nconst SEND_WINDOW_TZ = \"Europe/London\";\n\nconst RUN_BUDGET_MS = 50_000; // stay safely under the 60s free-tier execution cap\nconst MAX_PER_RUN = 4; // hard cap on sends per run\nconst MIN_GAP_MS = 8_000; // min pause between sends within a run (8s)\nconst MAX_GAP_MS = 20_000; // max pause between sends within a run (20s)\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\nconst randGap = () => MIN_GAP_MS + Math.floor(Math.random() * (MAX_GAP_MS - MIN_GAP_MS));\n\nfunction firstName(name: string | null): string {\n if (!name) return \"there\";\n return name.trim().split(/\\s+/)[0] || \"there\";\n}\nfunction applyTemplate(template: string, lead: { name: string | null }): string {\n return (template || \"\")\n .replace(/\\{first_name\\}/gi, firstName(lead.name))\n .replace(/\\{name\\}/gi, lead.name || firstName(lead.name));\n}\n\nconst GSM_EXT = \"^{}\\\\[~]|€\";\nconst GSM_BASE = \"@£$¥èéùìòÇ\\nØø\\rÅåΔ_ΦΓΛΩΠΨΣΘΞ ÆæßÉ !\\\"#¤%&'()*+,-./0123456789:;<=>?¡ABCDEFGHIJKLMNOPQRSTUVWXYZÄÖÑÜ§¿abcdefghijklmnopqrstuvwxyzäöñüà\";\nconst GSM_CHARS = new Set((GSM_BASE + GSM_EXT).split(\"\"));\n// Keep campaign messages GSM-7 (cheap) — strip emojis / smart punctuation.\nfunction gsmify(text: string): string {\n if (!text) return text;\n let t = String(text)\n .replace(/[‘’‚′‵]/g, \"'\").replace(/[“”„″]/g, '\"').replace(/[–—―]/g, \"-\").replace(/…/g, \"...\")\n .replace(/[ ]/g, \" \").replace(/[•·]/g, \"-\").replace(/™/g, \"(TM)\").replace(/®/g, \"(R)\").replace(/©/g, \"(C)\");\n t = Array.from(t).filter((ch) => GSM_CHARS.has(ch)).join(\"\");\n return t.replace(/[ \\t]{2,}/g, \" \").replace(/ +\\n/g, \"\\n\").trim();\n}\n\nfunction londonHour(): number {\n const parts = new Intl.DateTimeFormat(\"en-GB\", {\n timeZone: SEND_WINDOW_TZ, hour: \"numeric\", hour12: false,\n }).formatToParts(new Date());\n const h = parts.find((p) => p.type === \"hour\")?.value ?? \"0\";\n return parseInt(h, 10) % 24;\n}\n\n// Mobile-gateway routing (mirrors lib.ts): gateway-tagged numbers send through\n// the Android phone via sms-gate.app; everything else via Telnyx.\nasync function channelForNumber(from?: string | null): Promise {\n if (!from) return \"telnyx\";\n try {\n const r = await sqlite.execute({ sql: `SELECT channel FROM numbers WHERE phone_number = ?`, args: [from] });\n const row = (r.rows as any[])[0];\n return row && row[0] ? String(row[0]) : \"telnyx\";\n } catch { return \"telnyx\"; }\n}\nasync function sendViaGateway(to: string, text: string): Promise {\n const user = Deno.env.get(\"SMSGATE_USER\");\n const pass = Deno.env.get(\"SMSGATE_PASS\");\n if (!user || !pass) { console.error(\"sendViaGateway: missing SMSGATE_USER / SMSGATE_PASS\"); return false; }\n try {\n const res = await fetch(\"https://api.sms-gate.app/3rdparty/v1/messages\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", \"Authorization\": \"Basic \" + btoa(`${user}:${pass}`) },\n body: JSON.stringify({ textMessage: { text: gsmify(text) }, phoneNumbers: [to] }),\n });\n if (!res.ok) { console.error(\"sms-gate send failed\", res.status, await res.text()); return false; }\n return true;\n } catch (e) { console.error(\"sms-gate send error\", e); return false; }\n}\n\nasync function sendSMS(to: string, text: string, from?: string | null): Promise {\n if (await channelForNumber(from) === \"gateway\") return sendViaGateway(to, text);\n const apiKey = Deno.env.get(\"TELNYX_API_KEY\");\n const fromNumber = from || Deno.env.get(\"TELNYX_FROM_NUMBER\");\n if (!apiKey || !fromNumber) { console.error(\"sendSMS: missing Telnyx env vars\"); return false; }\n try {\n const res = await fetch(\"https://api.telnyx.com/v2/messages\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", \"Authorization\": `Bearer ${apiKey}` },\n body: JSON.stringify({ from: fromNumber, to, text }),\n });\n if (!res.ok) { console.error(\"Telnyx send failed\", res.status, await res.text()); return false; }\n return true;\n } catch (e) { console.error(\"Telnyx send error\", e); return false; }\n}\n\nexport default async function () {\n // Respect the 9am-8pm send window (UK time).\n const hour = londonHour();\n if (hour < SEND_WINDOW_START || hour >= SEND_WINDOW_END) return;\n\n const startedAt = Date.now();\n const now = new Date().toISOString();\n\n // Pull due items from running campaigns only. client_id rides along from the\n // campaign so every per-lead lookup/write stays scoped to the right client.\n const due = await sqlite.execute({\n sql: `SELECT q.id, q.phone_number, c.opening_message, q.send_number, c.client_id\n FROM campaign_queue q\n JOIN campaigns c ON c.id = q.campaign_id\n WHERE q.status = 'pending'\n AND c.status = 'running'\n AND q.send_after <= ?\n ORDER BY q.send_after ASC\n LIMIT ?`,\n args: [now, MAX_PER_RUN],\n });\n\n const rows = due.rows as any[];\n for (let i = 0; i < rows.length; i++) {\n // Safety: never run past the execution budget (free tier kills at 60s).\n if (Date.now() - startedAt > RUN_BUDGET_MS) break;\n\n const [queueId, phone, openingMessage, sendNumber, clientId] = rows[i];\n\n // Re-check the lead at send time — they may have opted out since queueing.\n const leadRes = await sqlite.execute({\n sql: `SELECT name, opted_out, assigned_number FROM leads WHERE client_id = ? AND phone_number = ?`,\n args: [clientId, phone],\n });\n const lead = (leadRes.rows as any[])[0];\n if (!lead || lead[1]) {\n await sqlite.execute({ sql: `UPDATE campaign_queue SET status = 'cancelled' WHERE id = ?`, args: [queueId] });\n continue;\n }\n\n const text = gsmify(applyTemplate(openingMessage, { name: lead[0] }));\n // Send from the number this lead was assigned (falls back to the lead's\n // number, then TELNYX_FROM_NUMBER).\n const fromUsed = sendNumber || lead[2] || Deno.env.get(\"TELNYX_FROM_NUMBER\") || null;\n const sent = await sendSMS(phone, text, fromUsed);\n\n if (sent) {\n await sqlite.execute({\n sql: `UPDATE campaign_queue SET status = 'sent', sent_at = ? WHERE id = ?`,\n args: [new Date().toISOString(), queueId],\n });\n await sqlite.execute({\n sql: `INSERT INTO messages (client_id, phone_number, direction, text, timestamp, channel_number) VALUES (?, ?, 'campaign', ?, ?, ?)`,\n args: [clientId, phone, text, new Date().toISOString(), fromUsed],\n });\n await sqlite.execute({\n sql: `UPDATE leads SET status = 'sent' WHERE client_id = ? AND phone_number = ? AND status = 'active'`,\n args: [clientId, phone],\n });\n } else {\n await sqlite.execute({ sql: `UPDATE campaign_queue SET status = 'failed' WHERE id = ?`, args: [queueId] });\n }\n\n // Pause before the next send (skip after the last one, and only if it fits\n // the remaining budget) so a batch isn't a single instantaneous burst.\n if (i < rows.length - 1) {\n const gap = randGap();\n if (Date.now() - startedAt + gap > RUN_BUDGET_MS) break;\n await sleep(gap);\n }\n }\n\n // Auto-complete campaigns with nothing left to send.\n await sqlite.execute(`\n UPDATE campaigns SET status = 'completed'\n WHERE status = 'running'\n AND id NOT IN (SELECT DISTINCT campaign_id FROM campaign_queue WHERE status = 'pending')\n AND id IN (SELECT DISTINCT campaign_id FROM campaign_queue)\n `);\n}\n","// LeadPulse — campaign sender (CRON val) — FREE-TIER version\n// Trigger: Cron, schedule \"*/15 * * * *\" (every 15 min — the free-tier minimum).\n// Shares the same Val.town SQLite database as webhook-receiver.\n// Env vars (account-wide): TELNYX_API_KEY, TELNYX_FROM_NUMBER\n//\n// Free tier reality: cron fires at most every 15 min and each run is killed at\n// 60s. So we can't drip one message per minute. Instead each run sends a small\n// batch, spaced a few seconds apart, and STOPS well before the 60s cap — the\n// leftover queue is picked up on the next run. Volume stays low and non-bursty,\n// which keeps the carrier happy. When you move to Val.town Pro, switch the\n// schedule to \"* * * * *\" and (optionally) raise MAX_PER_RUN / the gap to use\n// the proper 30s-2min spacing.\n\n// ───────────────────────────────────────────────────────────────────────────\n// SANDBOX DATA ISOLATION (mirrors webhook-receiver-sandbox/lib.ts)\n// std/sqlite is one account-wide DB shared by every val, so every query here is\n// transparently redirected to TABLE_PREFIX-prefixed tables (`leads`->`sb_leads`)\n// so this sandbox cron can never touch the live production queue/leads. Set\n// TABLE_PREFIX = \"\" to point back at the production tables.\n// ───────────────────────────────────────────────────────────────────────────\nimport { sqlite as _rawSqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst TABLE_PREFIX = \"lb_\"; // LeadBlitz tables (isolated from LeadPulse's prod tables on the shared DB)\nconst _TABLES = [\n \"campaign_queue\", \"unrouted_messages\", \"leads_new\", \"settings_new\",\n \"campaigns\", \"messages\", \"agents\", \"clients\", \"folders\", \"leads\",\n \"numbers\", \"settings\",\n];\nfunction prefixSql(sql: string): string {\n if (!TABLE_PREFIX) return sql;\n let out = sql;\n for (const t of _TABLES) out = out.replace(new RegExp(\"\\\\b\" + t + \"\\\\.\", \"g\"), TABLE_PREFIX + t + \".\");\n out = out.replace(\n /(table_info\$\\s*)(\"?)([a-zA-Z_][a-zA-Z0-9_]*)\\2(\\s*\$)/gi,\n (m, pre, q, name, post) => (_TABLES.includes(name) ? `${pre}${q}${TABLE_PREFIX}${name}${q}${post}` : m),\n );\n out = out.replace(\n /\\b(from|join|into|update|references|rename\\s+to|table(?:\\s+if\\s+not\\s+exists)?)\\s+(\"?)([a-zA-Z_][a-zA-Z0-9_]*)\\2/gi,\n (m, kw, q, name) => (_TABLES.includes(name) ? `${kw} ${q}${TABLE_PREFIX}${name}${q}` : m),\n );\n return out;\n}\nfunction _rewriteArg(arg: any): any {\n if (typeof arg === \"string\") return prefixSql(arg);\n if (arg && typeof arg.sql === \"string\") return { ...arg, sql: prefixSql(arg.sql) };\n return arg;\n}\nconst sqlite = {\n execute: (arg: any) => _rawSqlite.execute(_rewriteArg(arg)),\n batch: (stmts: any[], mode?: any) => (_rawSqlite as any).batch(stmts.map(_rewriteArg), mode),\n};\n\n// Base URL of the lb-redirect click-tracking proxy. Override with the\n// REDIRECT_BASE_URL env var on this cron val; defaults to the live lb-redirect.\nconst REDIRECT_BASE = Deno.env.get(\"REDIRECT_BASE_URL\") || \"https://jamesayres--ac533cc8730311f1b7fc1607ee4eb77e.web.val.run\";\n\nconst SEND_WINDOW_START = 9; // 9am inclusive\nconst SEND_WINDOW_END = 20; // 8pm exclusive\nconst SEND_WINDOW_TZ = \"Europe/London\";\n\nconst RUN_BUDGET_MS = 50_000; // stay safely under the 60s free-tier execution cap\nconst MAX_PER_RUN = 4; // hard cap on sends per run\nconst MIN_GAP_MS = 8_000; // min pause between sends within a run (8s)\nconst MAX_GAP_MS = 20_000; // max pause between sends within a run (20s)\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\nconst randGap = () => MIN_GAP_MS + Math.floor(Math.random() * (MAX_GAP_MS - MIN_GAP_MS));\n\nfunction firstName(name: string | null): string {\n if (!name) return \"there\";\n return name.trim().split(/\\s+/)[0] || \"there\";\n}\nfunction applyTemplate(template: string, lead: { name: string | null }): string {\n return (template || \"\")\n .replace(/\\{first_name\\}/gi, firstName(lead.name))\n .replace(/\\{name\\}/gi, lead.name || firstName(lead.name));\n}\n\nconst GSM_EXT = \"^{}\\\\[~]|€\";\nconst GSM_BASE = \"@£$¥èéùìòÇ\\nØø\\rÅåΔ_ΦΓΛΩΠΨΣΘΞ ÆæßÉ !\\\"#¤%&'()*+,-./0123456789:;<=>?¡ABCDEFGHIJKLMNOPQRSTUVWXYZÄÖÑÜ§¿abcdefghijklmnopqrstuvwxyzäöñüà\";\nconst GSM_CHARS = new Set((GSM_BASE + GSM_EXT).split(\"\"));\n// Keep campaign messages GSM-7 (cheap) — strip emojis / smart punctuation.\nfunction gsmify(text: string): string {\n if (!text) return text;\n let t = String(text)\n .replace(/[‘’‚′‵]/g, \"'\").replace(/[“”„″]/g, '\"').replace(/[–—―]/g, \"-\").replace(/…/g, \"...\")\n .replace(/[ ]/g, \" \").replace(/[•·]/g, \"-\").replace(/™/g, \"(TM)\").replace(/®/g, \"(R)\").replace(/©/g, \"(C)\");\n t = Array.from(t).filter((ch) => GSM_CHARS.has(ch)).join(\"\");\n return t.replace(/[ \\t]{2,}/g, \" \").replace(/ +\\n/g, \"\\n\").trim();\n}\n\nfunction londonHour(): number {\n const parts = new Intl.DateTimeFormat(\"en-GB\", {\n timeZone: SEND_WINDOW_TZ, hour: \"numeric\", hour12: false,\n }).formatToParts(new Date());\n const h = parts.find((p) => p.type === \"hour\")?.value ?? \"0\";\n return parseInt(h, 10) % 24;\n}\n\n// Mobile-gateway routing (mirrors lib.ts): gateway-tagged numbers send through\n// the Android phone via sms-gate.app; everything else via Telnyx.\nasync function channelForNumber(from?: string | null): Promise {\n if (!from) return \"telnyx\";\n try {\n const r = await sqlite.execute({ sql: `SELECT channel FROM numbers WHERE phone_number = ?`, args: [from] });\n const row = (r.rows as any[])[0];\n return row && row[0] ? String(row[0]) : \"telnyx\";\n } catch { return \"telnyx\"; }\n}\nasync function sendViaGateway(to: string, text: string): Promise {\n const user = Deno.env.get(\"SMSGATE_USER\");\n const pass = Deno.env.get(\"SMSGATE_PASS\");\n if (!user || !pass) { console.error(\"sendViaGateway: missing SMSGATE_USER / SMSGATE_PASS\"); return false; }\n try {\n const res = await fetch(\"https://api.sms-gate.app/3rdparty/v1/messages\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", \"Authorization\": \"Basic \" + btoa(`${user}:${pass}`) },\n body: JSON.stringify({ textMessage: { text: gsmify(text) }, phoneNumbers: [to] }),\n });\n if (!res.ok) { console.error(\"sms-gate send failed\", res.status, await res.text()); return false; }\n return true;\n } catch (e) { console.error(\"sms-gate send error\", e); return false; }\n}\n\nasync function sendSMS(to: string, text: string, from?: string | null): Promise {\n if (await channelForNumber(from) === \"gateway\") return sendViaGateway(to, text);\n const apiKey = Deno.env.get(\"TELNYX_API_KEY\");\n const fromNumber = from || Deno.env.get(\"TELNYX_FROM_NUMBER\");\n if (!apiKey || !fromNumber) { console.error(\"sendSMS: missing Telnyx env vars\"); return false; }\n try {\n const res = await fetch(\"https://api.telnyx.com/v2/messages\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", \"Authorization\": `Bearer ${apiKey}` },\n body: JSON.stringify({ from: fromNumber, to, text }),\n });\n if (!res.ok) { console.error(\"Telnyx send failed\", res.status, await res.text()); return false; }\n return true;\n } catch (e) { console.error(\"Telnyx send error\", e); return false; }\n}\n\nexport default async function () {\n // Respect the 9am-8pm send window (UK time).\n const hour = londonHour();\n if (hour < SEND_WINDOW_START || hour >= SEND_WINDOW_END) return;\n\n const startedAt = Date.now();\n const now = new Date().toISOString();\n\n // Pull due items from running campaigns only. client_id rides along from the\n // campaign so every per-lead lookup/write stays scoped to the right client.\n const due = await sqlite.execute({\n sql: `SELECT q.id, q.phone_number, c.opening_message, q.send_number, c.client_id, q.track_token\n FROM campaign_queue q\n JOIN campaigns c ON c.id = q.campaign_id\n WHERE q.status = 'pending'\n AND c.status = 'running'\n AND q.send_after <= ?\n ORDER BY q.send_after ASC\n LIMIT ?`,\n args: [now, MAX_PER_RUN],\n });\n\n const rows = due.rows as any[];\n for (let i = 0; i < rows.length; i++) {\n // Safety: never run past the execution budget (free tier kills at 60s).\n if (Date.now() - startedAt > RUN_BUDGET_MS) break;\n\n const [queueId, phone, openingMessage, sendNumber, clientId, trackToken] = rows[i];\n\n // Re-check the lead at send time — they may have opted out since queueing.\n const leadRes = await sqlite.execute({\n sql: `SELECT name, opted_out, assigned_number FROM leads WHERE client_id = ? AND phone_number = ?`,\n args: [clientId, phone],\n });\n const lead = (leadRes.rows as any[])[0];\n if (!lead || lead[1]) {\n await sqlite.execute({ sql: `UPDATE campaign_queue SET status = 'cancelled' WHERE id = ?`, args: [queueId] });\n continue;\n }\n\n // {booking_link} expands to this lead's click-tracked redirect URL.\n const trackedLink = trackToken ? `${REDIRECT_BASE}/r?t=${encodeURIComponent(trackToken)}` : \"\";\n const body = applyTemplate(openingMessage, { name: lead[0] }).replace(/\\{booking_link\\}/gi, trackedLink);\n const text = gsmify(body);\n // Send from the number this lead was assigned (falls back to the lead's\n // number, then TELNYX_FROM_NUMBER).\n const fromUsed = sendNumber || lead[2] || Deno.env.get(\"TELNYX_FROM_NUMBER\") || null;\n const sent = await sendSMS(phone, text, fromUsed);\n\n if (sent) {\n await sqlite.execute({\n sql: `UPDATE campaign_queue SET status = 'sent', sent_at = ? WHERE id = ?`,\n args: [new Date().toISOString(), queueId],\n });\n await sqlite.execute({\n sql: `INSERT INTO messages (client_id, phone_number, direction, text, timestamp, channel_number) VALUES (?, ?, 'campaign', ?, ?, ?)`,\n args: [clientId, phone, text, new Date().toISOString(), fromUsed],\n });\n await sqlite.execute({\n sql: `UPDATE leads SET status = 'sent' WHERE client_id = ? AND phone_number = ? AND status = 'active'`,\n args: [clientId, phone],\n });\n } else {\n await sqlite.execute({ sql: `UPDATE campaign_queue SET status = 'failed' WHERE id = ?`, args: [queueId] });\n }\n\n // Pause before the next send (skip after the last one, and only if it fits\n // the remaining budget) so a batch isn't a single instantaneous burst.\n if (i < rows.length - 1) {\n const gap = randGap();\n if (Date.now() - startedAt + gap > RUN_BUDGET_MS) break;\n await sleep(gap);\n }\n }\n\n // Auto-complete campaigns with nothing left to send.\n await sqlite.execute(`\n UPDATE campaigns SET status = 'completed'\n WHERE status = 'running'\n AND id NOT IN (SELECT DISTINCT campaign_id FROM campaign_queue WHERE status = 'pending')\n AND id IN (SELECT DISTINCT campaign_id FROM campaign_queue)\n `);\n}\n","createdAt",["D",1782660163579],"branchVersion","branchId","744ff5db-4b0b-4d5b-8e1b-6dbec3a3b41e","id","6a32f516-6c7c-445a-8ebb-308a10d7ab89","cron15mins-sandbox",["D",1782243813398],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","LeadPulse SANDBOX clone of cron15mins (sb_ tables)","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",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",5,"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",{"_43":44,"_32":45,"_38":151,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":152,"_79":153,"_81":154,"_83":25},"tree",[146],"files",[146],"counts",{"_134":61,"_135":136,"_137":61,"_138":139,"_140":141},"contents",[126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":130,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_27":133},"85442112-a90a-4048-9f5a-8be371d5f9c2","parentId","latest",["D",1782660163579],3,"label",[28],"pulls","branches",1,"forks","envVars",{"_142":144,"_145":61},"connections",{"_142":61,"_143":61},"count","unfilledCount",2,"emptyCount",{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":147,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_148":149,"_27":150},["D",1782660163579],"children",[],[28],["D",1782243813398],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_123":188,"_189":190,"_191":192,"_193":25,"_194":25,"_195":25,"_196":197,"_198":-5,"_199":-7,"_200":-7,"_201":61,"_202":25,"_203":25,"_204":-5,"_205":25,"_206":25,"_207":25,"_208":-5},"ENV",{"_159":160,"_161":162,"_163":85,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187},"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 · v4