[{"_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",6,"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","06e8ca02-682a-11f1-b273-1607ee4eb77e","name","fileType","interval","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\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst SEND_WINDOW_START = 9; // 9am inclusive\nconst SEND_WINDOW_END = 18; // 6pm 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 = () =>\n 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(\n template: string,\n lead: { name: string | null },\n): string {\n return (template || \"\")\n .replace(/\\{first_name\\}/gi, firstName(lead.name))\n .replace(/\\{name\\}/gi, lead.name || firstName(lead.name));\n}\n\nfunction londonHour(): number {\n const parts = new Intl.DateTimeFormat(\"en-GB\", {\n timeZone: SEND_WINDOW_TZ,\n hour: \"numeric\",\n 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\nasync function sendSMS(\n to: string,\n text: string,\n from?: string | null,\n): Promise {\n const apiKey = Deno.env.get(\"TELNYX_API_KEY\");\n const fromNumber = from || Deno.env.get(\"TELNYX_FROM_NUMBER\");\n if (!apiKey || !fromNumber) {\n console.error(\"sendSMS: missing Telnyx env vars\");\n return false;\n }\n try {\n const res = await fetch(\"https://api.telnyx.com/v2/messages\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${apiKey}`,\n },\n body: JSON.stringify({ from: fromNumber, to, text }),\n });\n if (!res.ok) {\n console.error(\"Telnyx send failed\", res.status, await res.text());\n return false;\n }\n return true;\n } catch (e) {\n console.error(\"Telnyx send error\", e);\n return false;\n }\n}\n\nexport default async function () {\n // Respect the 9am-6pm 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.\n const due = await sqlite.execute({\n sql: `SELECT q.id, q.phone_number, c.opening_message, c.from_number\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, fromNumber] = 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:\n `SELECT name, opted_out, assigned_number FROM leads WHERE phone_number = ?`,\n args: [phone],\n });\n const lead = (leadRes.rows as any[])[0];\n if (!lead || lead[1]) {\n await sqlite.execute({\n sql: `UPDATE campaign_queue SET status = 'cancelled' WHERE id = ?`,\n args: [queueId],\n });\n continue;\n }\n\n const text = applyTemplate(openingMessage, { name: lead[0] });\n const sent = await sendSMS(phone, text, fromNumber || lead[2]);\n\n if (sent) {\n await sqlite.execute({\n sql:\n `UPDATE campaign_queue SET status = 'sent', sent_at = ? WHERE id = ?`,\n args: [new Date().toISOString(), queueId],\n });\n await sqlite.execute({\n sql:\n `INSERT INTO messages (phone_number, direction, text, timestamp) VALUES (?, 'campaign', ?, ?)`,\n args: [phone, text, new Date().toISOString()],\n });\n await sqlite.execute({\n sql:\n `UPDATE leads SET status = 'sent' WHERE phone_number = ? AND status = 'active'`,\n args: [phone],\n });\n } else {\n await sqlite.execute({\n sql: `UPDATE campaign_queue SET status = 'failed' WHERE id = ?`,\n args: [queueId],\n });\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}","// LeadPulse — campaign sender (CRON val) — FREE-TIER version\n// Trigger: Cron, schedule \"*/15 * * * *\". Shares DB with webhook-receiver.\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst SEND_WINDOW_START = 9;\nconst SEND_WINDOW_END = 18;\nconst SEND_WINDOW_TZ = \"Europe/London\";\nconst RUN_BUDGET_MS = 50_000;\nconst MAX_PER_RUN = 4;\nconst MIN_GAP_MS = 8_000;\nconst MAX_GAP_MS = 20_000;\n\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\nconst randGap = () =>\n 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(\n template: string,\n lead: { name: string | null },\n): string {\n return (template || \"\").replace(/\\{first_name\\}/gi, firstName(lead.name))\n .replace(/\\{name\\}/gi, lead.name || firstName(lead.name));\n}\nfunction londonHour(): number {\n const parts = new Intl.DateTimeFormat(\"en-GB\", {\n timeZone: SEND_WINDOW_TZ,\n hour: \"numeric\",\n hour12: false,\n }).formatToParts(new Date());\n return parseInt(parts.find((p) => p.type === \"hour\")?.value ?? \"0\", 10) % 24;\n}\nasync function sendSMS(\n to: string,\n text: string,\n from?: string | null,\n): Promise {\n const apiKey = Deno.env.get(\"TELNYX_API_KEY\");\n const fromNumber = from || Deno.env.get(\"TELNYX_FROM_NUMBER\");\n if (!apiKey || !fromNumber) {\n console.error(\"sendSMS: missing Telnyx env vars\");\n return false;\n }\n try {\n const res = await fetch(\"https://api.telnyx.com/v2/messages\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${apiKey}`,\n },\n body: JSON.stringify({ from: fromNumber, to, text }),\n });\n if (!res.ok) {\n console.error(\"Telnyx send failed\", res.status, await res.text());\n return false;\n }\n return true;\n } catch (e) {\n console.error(\"Telnyx send error\", e);\n return false;\n }\n}\n\nexport default async function () {\n const hour = londonHour();\n if (hour < SEND_WINDOW_START || hour >= SEND_WINDOW_END) return;\n const startedAt = Date.now();\n const now = new Date().toISOString();\n const due = await sqlite.execute({\n sql: `SELECT q.id, q.phone_number, c.opening_message, q.send_number\n FROM campaign_queue q JOIN campaigns c ON c.id = q.campaign_id\n WHERE q.status = 'pending' AND c.status = 'running' AND q.send_after <= ?\n ORDER BY q.send_after ASC LIMIT ?`,\n args: [now, MAX_PER_RUN],\n });\n const rows = due.rows as any[];\n for (let i = 0; i < rows.length; i++) {\n if (Date.now() - startedAt > RUN_BUDGET_MS) break;\n const [queueId, phone, openingMessage, sendNumber] = rows[i];\n const leadRes = await sqlite.execute({\n sql:\n `SELECT name, opted_out, assigned_number FROM leads WHERE phone_number = ?`,\n args: [phone],\n });\n const lead = (leadRes.rows as any[])[0];\n if (!lead || lead[1]) {\n await sqlite.execute({\n sql: `UPDATE campaign_queue SET status = 'cancelled' WHERE id = ?`,\n args: [queueId],\n });\n continue;\n }\n const text = applyTemplate(openingMessage, { name: lead[0] });\n const sent = await sendSMS(phone, text, sendNumber || lead[2]);\n if (sent) {\n await sqlite.execute({\n sql:\n `UPDATE campaign_queue SET status = 'sent', sent_at = ? WHERE id = ?`,\n args: [new Date().toISOString(), queueId],\n });\n await sqlite.execute({\n sql:\n `INSERT INTO messages (phone_number, direction, text, timestamp) VALUES (?, 'campaign', ?, ?)`,\n args: [phone, text, new Date().toISOString()],\n });\n await sqlite.execute({\n sql:\n `UPDATE leads SET status = 'sent' WHERE phone_number = ? AND status = 'active'`,\n args: [phone],\n });\n } else {\n await sqlite.execute({\n sql: `UPDATE campaign_queue SET status = 'failed' WHERE id = ?`,\n args: [queueId],\n });\n }\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 await sqlite.execute(\n `UPDATE campaigns SET status = 'completed' WHERE status = 'running' AND id NOT IN (SELECT DISTINCT campaign_id FROM campaign_queue WHERE status = 'pending') AND id IN (SELECT DISTINCT campaign_id FROM campaign_queue)`,\n );\n}","createdAt",["D",1781473532872],"branchVersion","branchId","67ffd779-9760-48d6-be5c-30a8d75367b4","id","8fb4a2d5-d229-4c60-b50a-73527c7aa533","cron15mins",["D",1781466513859],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","cron","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",13,"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},"fb6697f3-aa7d-4edf-ba55-7c7eedd11005","parentId","latest",["D",1781473532872],5,"label",[28],"pulls","branches",1,"forks","envVars",{"_142":144,"_145":61},"connections",{"_142":61,"_143":61},"count","unfilledCount",4,"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",1781473532872],"children",[],[28],["D",1781466513859],{"_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 · v6