[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_193":194,"_195":196},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_105":86,"_27":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":58,"_123":-5,"_124":-5,"_125":126},"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":-5,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",63,"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","warmCallReminder.ts","latestPath","fileId","d1892f6a-8876-11f1-99a8-1607ee4eb77e","name","fileType","interval","content","// AIR — Warm Call Reminder\n// Runs every 30 minutes. Finds any booked call in the Airtable \"Sales Calls\"\n// table whose start time falls ~5 hours from now, and pings Telegram.\n//\n// The window is [now+4h45m, now+5h15m). At a 30-minute cadence those windows\n// tile exactly, so every call fires exactly once — no duplicates, no gaps,\n// and no extra \"Reminded\" checkbox field needed in Airtable.\n//\n// Required val.town environment variables:\n// AIRTABLE_TOKEN (already set — used by airBookAppointment)\n// WARMCALL_BOT_TOKEN (the SECOND bot, dedicated to warm-call reminders,\n// so these land in their own Telegram thread and do\n// not mix with the AIR booking alerts)\n// WARMCALL_CHAT_ID (optional — falls back to TELEGRAM_CHAT_ID, since\n// Anders' personal chat id is the same for any bot)\n//\n// Set TEST_MODE=1 in the query string when deployed as an http val to preview\n// what would be sent without actually sending it.\n\nconst BASE_ID = \"appufYpiORDVFQ71x\";\nconst SALES_CALLS = \"tbleWRws0e03altKS\";\n\nconst LEAD_MINUTES = 300; // 5 hours\nconst HALF_WINDOW_MINUTES = 15; // ±15 min → a 30 min window\nconst TZ = \"America/Los_Angeles\";\n\n// Statuses that mean the call is dead — never remind on these.\nconst DEAD_STATUSES = [\"done\", \"completed\", \"complete\", \"cancelled\", \"canceled\", \"no show\", \"lost\", \"closed\"];\n\ntype Rec = { id: string; fields: Record };\n\nfunction fmtWhen(iso: string): string {\n const d = new Date(iso);\n const day = d.toLocaleDateString(\"en-US\", {\n timeZone: TZ, weekday: \"short\", month: \"short\", day: \"numeric\",\n });\n const time = d.toLocaleTimeString(\"en-US\", {\n timeZone: TZ, hour: \"numeric\", minute: \"2-digit\",\n });\n return `${day} at ${time}`;\n}\n\nfunction minutesUntil(iso: string, now: number): number {\n return Math.round((new Date(iso).getTime() - now) / 60000);\n}\n\nfunction esc(s: string): string {\n return String(s).replace(/&/g, \"&\").replace(//g, \">\");\n}\n\n// Pull the most useful chunk of the prep notes: the wedge and the opener.\nfunction prepSnippet(notes: string): string {\n if (!notes) return \"\";\n const markers = [\"THE WEDGE\", \"THE OPENER\", \"OPENER -\"];\n for (const m of markers) {\n const i = notes.indexOf(m);\n if (i !== -1) {\n const chunk = notes.slice(i, i + 420).trim();\n return chunk.length < notes.length - i ? chunk + \"…\" : chunk;\n }\n }\n return notes.slice(0, 420).trim() + (notes.length > 420 ? \"…\" : \"\");\n}\n\nfunction buildMessage(f: Record, mins: number, backup = false): string {\n const biz = f[\"Business\"] || f[\"Call\"] || \"Unknown business\";\n const when = f[\"When\"] ? fmtWhen(f[\"When\"]) : \"time not set\";\n const who = f[\"With\"] || \"\";\n const phone = f[\"Phone\"] || \"\";\n const hrs = (mins / 60).toFixed(1).replace(/\\.0$/, \"\");\n\n const lines = [\n `⏰ Warm call in ~${hrs} hours`,\n ``,\n `${esc(biz)}`,\n `🕐 ${esc(when)}`,\n ];\n if (who) lines.push(`👤 ${esc(who)}`);\n if (phone) lines.push(`📞 ${esc(phone)}`);\n\n const snip = prepSnippet(f[\"Prep Notes\"] || \"\");\n if (snip) {\n lines.push(``, `${esc(snip)}`);\n }\n if (backup) {\n lines.push(``, `(sent via the alerts bot — the warm-call bot token is not working)`);\n }\n return lines.join(\"\\n\");\n}\n\nasync function tokenWorks(token: string): Promise {\n try {\n const r = await fetch(`https://api.telegram.org/bot${token}/getMe`);\n const j = await r.json();\n return !!j.ok;\n } catch {\n return false;\n }\n}\n\nasync function fetchCalls(token: string): Promise {\n const out: Rec[] = [];\n let offset = \"\";\n do {\n const url = `https://api.airtable.com/v0/${BASE_ID}/${SALES_CALLS}?pageSize=100${offset ? `&offset=${offset}` : \"\"}`;\n const r = await fetch(url, { headers: { Authorization: `Bearer ${token}` } });\n if (!r.ok) throw new Error(`Airtable ${r.status}: ${await r.text()}`);\n const j = await r.json();\n out.push(...(j.records || []));\n offset = j.offset || \"\";\n } while (offset);\n return out;\n}\n\nasync function sendTelegram(botToken: string, chatId: string, text: string) {\n const r = await fetch(`https://api.telegram.org/bot${botToken}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chatId,\n text,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n }),\n });\n const body = await r.text();\n if (!r.ok) throw new Error(`Telegram ${r.status}: ${body}`);\n return body;\n}\n\nexport async function run(opts: { dryRun?: boolean; overrideWindow?: boolean } = {}) {\n const airtableToken = Deno.env.get(\"AIRTABLE_TOKEN\");\n // Dedicated warm-call bot, with the alerts bot as a delivery backstop.\n // Original intent was loud failure over silent cross-delivery, but a broken\n // WARMCALL_BOT_TOKEN would mean silently missing a real call — worse. So we\n // fall back and flag it in the message body instead.\n const warmToken = Deno.env.get(\"WARMCALL_BOT_TOKEN\");\n const alertsToken = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const warmOk = warmToken ? await tokenWorks(warmToken) : false;\n const usingBackup = !warmOk && !!alertsToken;\n const botToken = warmOk ? warmToken : alertsToken;\n // Chat id is per-person, not per-bot, so reusing the existing one is fine.\n const chatId = Deno.env.get(\"WARMCALL_CHAT_ID\") || Deno.env.get(\"TELEGRAM_CHAT_ID\");\n\n const missing = [\n !airtableToken && \"AIRTABLE_TOKEN\",\n !botToken && \"WARMCALL_BOT_TOKEN (and no TELEGRAM_BOT_TOKEN to fall back on)\",\n !chatId && \"WARMCALL_CHAT_ID (or TELEGRAM_CHAT_ID)\",\n ].filter(Boolean);\n\n if (missing.length && !opts.dryRun) {\n console.error(`[warmCallReminder] missing env vars: ${missing.join(\", \")}`);\n return { ok: false, missing };\n }\n\n const now = Date.now();\n const lo = now + (LEAD_MINUTES - HALF_WINDOW_MINUTES) * 60000;\n const hi = now + (LEAD_MINUTES + HALF_WINDOW_MINUTES) * 60000;\n\n const records = await fetchCalls(airtableToken!);\n const due: Rec[] = [];\n\n for (const rec of records) {\n const f = rec.fields || {};\n const when = f[\"When\"];\n if (!when) continue;\n\n const status = String(f[\"Status\"] || \"\").toLowerCase();\n if (DEAD_STATUSES.some((d) => status.includes(d))) continue;\n\n const t = new Date(when).getTime();\n if (Number.isNaN(t)) continue;\n\n if (opts.overrideWindow) {\n if (t > now) due.push(rec); // preview: every future call\n } else if (t >= lo && t < hi) {\n due.push(rec);\n }\n }\n\n const results: any[] = [];\n for (const rec of due) {\n const mins = minutesUntil(rec.fields[\"When\"], now);\n const msg = buildMessage(rec.fields, mins, usingBackup);\n if (opts.dryRun) {\n results.push({ id: rec.id, business: rec.fields[\"Business\"], minutesOut: mins, preview: msg });\n } else {\n try {\n await sendTelegram(botToken!, chatId!, msg);\n results.push({ id: rec.id, business: rec.fields[\"Business\"], sent: true });\n console.log(`[warmCallReminder] sent for ${rec.fields[\"Business\"]}`);\n } catch (e) {\n results.push({ id: rec.id, business: rec.fields[\"Business\"], sent: false, error: String(e) });\n console.error(`[warmCallReminder] FAILED ${rec.fields[\"Business\"]}: ${e}`);\n }\n }\n }\n\n return {\n ok: true,\n bot: warmOk ? \"warm-call bot\" : usingBackup ? \"alerts bot (backup)\" : \"none\",\n scanned: records.length,\n windowPT: [new Date(lo).toLocaleString(\"en-US\", { timeZone: TZ }), new Date(hi).toLocaleString(\"en-US\", { timeZone: TZ })],\n matched: due.length,\n results,\n };\n}\n\nexport default async function (): Promise {\n const out = await run();\n console.log(JSON.stringify(out));\n}\n","// AIR — Warm Call Reminder\n// Runs every 30 minutes. Finds any booked call in the Airtable \"Sales Calls\"\n// table whose start time falls ~5 hours from now, and pings Telegram.\n//\n// The window is [now+4h45m, now+5h15m). At a 30-minute cadence those windows\n// tile exactly, so every call fires exactly once — no duplicates, no gaps,\n// and no extra \"Reminded\" checkbox field needed in Airtable.\n//\n// SCHEDULE — cron `*/30 * * * *`. Do not switch this to a delay-based schedule.\n// Two reasons, both learned the hard way on 2026-07-26:\n// 1. It had silently been set to \"every 1 hour\", which does not match the\n// 30-minute window above. Half of every hour was uncovered, so roughly\n// half of all warm calls got no reminder at all and nothing complained.\n// 2. Delay schedules drift. Log timestamps ran 12:23AM -> 3:30PM in one day,\n// about 7 minutes of slip. Drift leaves an uncovered sliver each cycle\n// even at the correct nominal cadence. Cron fires on :00/:30 exactly.\n// If you change HALF_WINDOW_MINUTES, change the cron to match, or the\n// \"tile exactly\" promise above quietly stops being true.\n//\n// Required val.town environment variables:\n// AIRTABLE_TOKEN (already set — used by airBookAppointment)\n// WARMCALL_BOT_TOKEN (the SECOND bot, dedicated to warm-call reminders,\n// so these land in their own Telegram thread and do\n// not mix with the AIR booking alerts)\n// WARMCALL_CHAT_ID (optional — falls back to TELEGRAM_CHAT_ID, since\n// Anders' personal chat id is the same for any bot)\n//\n// Set TEST_MODE=1 in the query string when deployed as an http val to preview\n// what would be sent without actually sending it.\n\nconst BASE_ID = \"appufYpiORDVFQ71x\";\nconst SALES_CALLS = \"tbleWRws0e03altKS\";\n\nconst LEAD_MINUTES = 300; // 5 hours\nconst HALF_WINDOW_MINUTES = 15; // ±15 min → a 30 min window\nconst TZ = \"America/Los_Angeles\";\n\n// Statuses that mean the call is dead — never remind on these.\nconst DEAD_STATUSES = [\"done\", \"completed\", \"complete\", \"cancelled\", \"canceled\", \"no show\", \"lost\", \"closed\"];\n\ntype Rec = { id: string; fields: Record };\n\nfunction fmtWhen(iso: string): string {\n const d = new Date(iso);\n const day = d.toLocaleDateString(\"en-US\", {\n timeZone: TZ, weekday: \"short\", month: \"short\", day: \"numeric\",\n });\n const time = d.toLocaleTimeString(\"en-US\", {\n timeZone: TZ, hour: \"numeric\", minute: \"2-digit\",\n });\n return `${day} at ${time}`;\n}\n\nfunction minutesUntil(iso: string, now: number): number {\n return Math.round((new Date(iso).getTime() - now) / 60000);\n}\n\nfunction esc(s: string): string {\n return String(s).replace(/&/g, \"&\").replace(//g, \">\");\n}\n\n// Pull the most useful chunk of the prep notes: the wedge and the opener.\nfunction prepSnippet(notes: string): string {\n if (!notes) return \"\";\n const markers = [\"THE WEDGE\", \"THE OPENER\", \"OPENER -\"];\n for (const m of markers) {\n const i = notes.indexOf(m);\n if (i !== -1) {\n const chunk = notes.slice(i, i + 420).trim();\n return chunk.length < notes.length - i ? chunk + \"…\" : chunk;\n }\n }\n return notes.slice(0, 420).trim() + (notes.length > 420 ? \"…\" : \"\");\n}\n\nfunction buildMessage(f: Record, mins: number, backup = false): string {\n const biz = f[\"Business\"] || f[\"Call\"] || \"Unknown business\";\n const when = f[\"When\"] ? fmtWhen(f[\"When\"]) : \"time not set\";\n const who = f[\"With\"] || \"\";\n const phone = f[\"Phone\"] || \"\";\n const hrs = (mins / 60).toFixed(1).replace(/\\.0$/, \"\");\n\n const lines = [\n `⏰ Warm call in ~${hrs} hours`,\n ``,\n `${esc(biz)}`,\n `🕐 ${esc(when)}`,\n ];\n if (who) lines.push(`👤 ${esc(who)}`);\n if (phone) lines.push(`📞 ${esc(phone)}`);\n\n const snip = prepSnippet(f[\"Prep Notes\"] || \"\");\n if (snip) {\n lines.push(``, `${esc(snip)}`);\n }\n if (backup) {\n lines.push(``, `(sent via the alerts bot — the warm-call bot token is not working)`);\n }\n return lines.join(\"\\n\");\n}\n\nasync function tokenWorks(token: string): Promise {\n try {\n const r = await fetch(`https://api.telegram.org/bot${token}/getMe`);\n const j = await r.json();\n return !!j.ok;\n } catch {\n return false;\n }\n}\n\nasync function fetchCalls(token: string): Promise {\n const out: Rec[] = [];\n let offset = \"\";\n do {\n const url = `https://api.airtable.com/v0/${BASE_ID}/${SALES_CALLS}?pageSize=100${offset ? `&offset=${offset}` : \"\"}`;\n const r = await fetch(url, { headers: { Authorization: `Bearer ${token}` } });\n if (!r.ok) throw new Error(`Airtable ${r.status}: ${await r.text()}`);\n const j = await r.json();\n out.push(...(j.records || []));\n offset = j.offset || \"\";\n } while (offset);\n return out;\n}\n\nasync function sendTelegram(botToken: string, chatId: string, text: string) {\n const r = await fetch(`https://api.telegram.org/bot${botToken}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chatId,\n text,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n }),\n });\n const body = await r.text();\n if (!r.ok) throw new Error(`Telegram ${r.status}: ${body}`);\n return body;\n}\n\nexport async function run(opts: { dryRun?: boolean; overrideWindow?: boolean } = {}) {\n const airtableToken = Deno.env.get(\"AIRTABLE_TOKEN\");\n // Dedicated warm-call bot, with the alerts bot as a delivery backstop.\n // Original intent was loud failure over silent cross-delivery, but a broken\n // WARMCALL_BOT_TOKEN would mean silently missing a real call — worse. So we\n // fall back and flag it in the message body instead.\n const warmToken = Deno.env.get(\"WARMCALL_BOT_TOKEN\");\n const alertsToken = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const warmOk = warmToken ? await tokenWorks(warmToken) : false;\n const usingBackup = !warmOk && !!alertsToken;\n const botToken = warmOk ? warmToken : alertsToken;\n // Chat id is per-person, not per-bot, so reusing the existing one is fine.\n const chatId = Deno.env.get(\"WARMCALL_CHAT_ID\") || Deno.env.get(\"TELEGRAM_CHAT_ID\");\n\n const missing = [\n !airtableToken && \"AIRTABLE_TOKEN\",\n !botToken && \"WARMCALL_BOT_TOKEN (and no TELEGRAM_BOT_TOKEN to fall back on)\",\n !chatId && \"WARMCALL_CHAT_ID (or TELEGRAM_CHAT_ID)\",\n ].filter(Boolean);\n\n if (missing.length && !opts.dryRun) {\n console.error(`[warmCallReminder] missing env vars: ${missing.join(\", \")}`);\n return { ok: false, missing };\n }\n\n const now = Date.now();\n const lo = now + (LEAD_MINUTES - HALF_WINDOW_MINUTES) * 60000;\n const hi = now + (LEAD_MINUTES + HALF_WINDOW_MINUTES) * 60000;\n\n const records = await fetchCalls(airtableToken!);\n const due: Rec[] = [];\n\n for (const rec of records) {\n const f = rec.fields || {};\n const when = f[\"When\"];\n if (!when) continue;\n\n const status = String(f[\"Status\"] || \"\").toLowerCase();\n if (DEAD_STATUSES.some((d) => status.includes(d))) continue;\n\n const t = new Date(when).getTime();\n if (Number.isNaN(t)) continue;\n\n if (opts.overrideWindow) {\n if (t > now) due.push(rec); // preview: every future call\n } else if (t >= lo && t < hi) {\n due.push(rec);\n }\n }\n\n const results: any[] = [];\n for (const rec of due) {\n const mins = minutesUntil(rec.fields[\"When\"], now);\n const msg = buildMessage(rec.fields, mins, usingBackup);\n if (opts.dryRun) {\n results.push({ id: rec.id, business: rec.fields[\"Business\"], minutesOut: mins, preview: msg });\n } else {\n try {\n await sendTelegram(botToken!, chatId!, msg);\n results.push({ id: rec.id, business: rec.fields[\"Business\"], sent: true });\n console.log(`[warmCallReminder] sent for ${rec.fields[\"Business\"]}`);\n } catch (e) {\n results.push({ id: rec.id, business: rec.fields[\"Business\"], sent: false, error: String(e) });\n console.error(`[warmCallReminder] FAILED ${rec.fields[\"Business\"]}: ${e}`);\n }\n }\n }\n\n return {\n ok: true,\n bot: warmOk ? \"warm-call bot\" : usingBackup ? \"alerts bot (backup)\" : \"none\",\n scanned: records.length,\n windowPT: [new Date(lo).toLocaleString(\"en-US\", { timeZone: TZ }), new Date(hi).toLocaleString(\"en-US\", { timeZone: TZ })],\n matched: due.length,\n results,\n };\n}\n\nexport default async function (): Promise {\n const out = await run();\n console.log(JSON.stringify(out));\n}\n","createdAt",["D",1785105594601],"branchVersion","branchId","e3cbae3a-3e5d-43de-9326-7c6a0d258101","id","a936d0be-71b4-48f7-bc4e-0840cbcb0bc6","airBookAppointment",["D",1783998470573],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","5a072328-1f44-4d09-b8a0-7919504ab306","pinnedFileId","c081faa4-8712-11f1-ba8b-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019e5c50-a8bf-778d-aaf9-5ede2971faa5","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_104":100},"org",{"_96":95,"_97":98,"_99":100,"_18":54,"_101":102,"_103":25},"branch",{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"isOwned",67,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","timothylawrence","handle","displayName","Timothy Lawrence","avatar","https://lh3.googleusercontent.com/a/ACg8ocJ-QXv4wwoyobVsfZEjp7nCiQrTDtRRy_t2AK6YRWGNRQQYLLA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":189,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":190,"_80":191,"_82":192,"_84":25},"tree",[172,173,174,175],"files",[172,173,174,175],"counts",{"_162":62,"_163":151,"_164":62,"_165":166,"_167":168},"contents",[127,128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":154,"_32":155,"_30":156,"_132":-5,"_41":42,"_40":157,"_133":58,"_38":158,"_13":159,"_33":143,"_35":160,"_24":25,"_136":-5,"_27":161},{"_43":146,"_32":147,"_30":148,"_132":-5,"_41":42,"_40":149,"_133":58,"_38":150,"_13":151,"_33":34,"_35":152,"_24":25,"_136":-5,"_27":153},{"_43":138,"_32":139,"_30":56,"_132":-5,"_41":42,"_40":140,"_133":58,"_38":141,"_13":142,"_33":143,"_35":144,"_24":25,"_136":-5,"_27":145},{"_43":131,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_133":58,"_38":134,"_13":135,"_33":34,"_35":37,"_24":25,"_136":-5,"_27":137},"4ee54994-a093-4dc3-adab-a0716ee68c2f","parentId","latest",["D",1785105594601],3,"label",[28],"61b6e429-7091-4c51-b0b2-994d3fd91b0e","tintCallAlert.ts",58,["D",1785105069820],5,"http","// tintCallAlert — ElevenLabs post-call webhook for The Tint Place (Angel).\n// (1) Forwards the raw transcript on to the workspace Airtable webhook so existing\n// conversation logging is preserved. (2) Texts a caller+summary recap via\n// SignalWire so nobody has to type notes. Ignores other agents.\n// Env: SIGNALWIRE_TOKEN, TINT_ALERT_TO, optional TINT_ALERT_FROM.\n//\n// TINT_ALERT_TO was set 2026-07-26 to Anders' cell, NOT Angel's. Deliberate and\n// temporary: SignalWire is still on trial, which only delivers to verified\n// numbers, and Angel's +13237972755 is not verified yet. Routing to Anders means\n// a human actually reads the recap today instead of it going to the hardcoded\n// fallback below, which belongs to neither of them. Flip TINT_ALERT_TO to Angel's\n// number once his caller ID is verified and the trial restriction is cleared.\n//\n// Test: POST {\"test_to\":\"+1...\"} sends a labeled test SMS (skips Airtable forward).\n// Note that test_to bypasses TINT_ALERT_TO, so it does NOT prove the env var\n// is live. Use GET ?diag=1 for that: it reports config without sending\n// anything and without revealing any secret.\nconst AGENT_ID = \"agent_5401ky0pgmhhe1rsmwhcz9y69qfp\"; // The Tint Place (agent still named \"AIR - Tint Monsters\")\nconst AIRTABLE_WEBHOOK = \"https://hooks.airtable.com/workflows/v1/genericWebhook/appufYpiORDVFQ71x/wflmjev9hHsrd4jf4/wtrI8s5yRQrPTfqHp\";\nconst SW_SPACE = \"bluewater-detailing\";\nconst SW_PROJECT = Deno.env.get(\"SIGNALWIRE_PROJECT_ID\") || \"0fd0c309-7bbe-4315-8b33-8bca84f00a98\";\nconst SW_TOKEN = Deno.env.get(\"SIGNALWIRE_TOKEN\");\nconst FROM = Deno.env.get(\"TINT_ALERT_FROM\") || \"+13237399465\";\nconst TO = Deno.env.get(\"TINT_ALERT_TO\") || \"+19095076318\";\n\nasync function sendSms(to: string, text: string) {\n const url = `https://${SW_SPACE}.signalwire.com/api/laml/2010-04-01/Accounts/${SW_PROJECT}/Messages.json`;\n const auth = btoa(`${SW_PROJECT}:${SW_TOKEN}`);\n const form = new URLSearchParams({ From: FROM, To: to, Body: text });\n const r = await fetch(url, { method: \"POST\", headers: { Authorization: `Basic ${auth}`, \"Content-Type\": \"application/x-www-form-urlencoded\" }, body: form });\n return { ok: r.ok, status: r.status, resp: (await r.text()).slice(0, 300) };\n}\n\n// Masks a phone number to its last four digits. Enough to confirm which number is\n// configured without publishing it on a public endpoint.\nfunction mask(n: string | undefined) {\n return n ? `••••••${n.slice(-4)}` : null;\n}\n\nexport default async function (req: Request) {\n // Read-only config check. Sends nothing, touches nothing, leaks no secrets.\n if (req.method === \"GET\" && new URL(req.url).searchParams.get(\"diag\") === \"1\") {\n return Response.json({\n diag: true,\n signalwireTokenSet: Boolean(SW_TOKEN),\n alertToEnvSet: Boolean(Deno.env.get(\"TINT_ALERT_TO\")),\n alertToMasked: mask(TO),\n usingHardcodedFallback: !Deno.env.get(\"TINT_ALERT_TO\"),\n fromMasked: mask(FROM),\n });\n }\n if (req.method !== \"POST\") return new Response(\"tintCallAlert ok\");\n const raw = await req.text();\n let body: any = {};\n try { body = JSON.parse(raw); } catch {}\n const isTest = typeof body?.test_to === \"string\" && body.test_to.length > 5;\n\n const data = body?.data ?? body;\n const agentId = data?.agent_id ?? data?.metadata?.agent_id;\n if (!isTest && agentId && agentId !== AGENT_ID) return Response.json({ skipped: \"other agent\", agentId });\n\n // Preserve existing Airtable logging by forwarding the untouched payload.\n let forwarded = false;\n if (!isTest) {\n try { const fr = await fetch(AIRTABLE_WEBHOOK, { method: \"POST\", headers: { \"Content-Type\": \"application/json\" }, body: raw }); forwarded = fr.ok; } catch {}\n }\n\n const caller = data?.metadata?.phone_call?.external_number\n ?? data?.conversation_initiation_client_data?.dynamic_variables?.[\"system__caller_id\"] ?? \"unknown\";\n const summary = data?.analysis?.transcript_summary ?? data?.analysis?.summary ?? \"(no summary available)\";\n const text = isTest\n ? ((typeof body?.test_message === \"string\" && body.test_message.length > 0)\n ? body.test_message\n : `TEST — The Tint Place AI receptionist alerts are live.`)\n : `The Tint Place — call handled by Selena\\nFrom: ${caller}\\n\\n${summary}`;\n\n if (!SW_TOKEN) return Response.json({ ok: false, reason: \"SIGNALWIRE_TOKEN not set\", forwarded, would_send: text });\n const to = isTest ? body.test_to : TO;\n const res = await sendSms(to, text);\n return Response.json({ test: isTest, forwarded, to, ...res });\n}\n",[139],"1104467f-ab77-47ec-a30a-fd1246a6e19b","driftCheckCron.ts","d4c5fdae-8941-11f1-8602-1607ee4eb77e",60,["D",1785105201086],1,"// driftCheckCron — scheduled runner for airConfigDriftMonitor.\n//\n// The actual checking lives in airConfigDriftMonitor.ts (a separate val, type\n// http). This file only calls it on a schedule and makes failure loud.\n//\n// Why this file lives in airBookAppointment rather than next to the monitor:\n// val.town env vars are per-val, and TELEGRAM_BOT_TOKEN / TELEGRAM_CHAT_ID are\n// already set here. The monitor is a plain public HTTP endpoint, so calling it\n// across vals costs nothing, and putting the runner here means drift alerts\n// reach a phone instead of dying in a log nobody opens.\n//\n// Env: TELEGRAM_BOT_TOKEN, TELEGRAM_CHAT_ID (both already present).\n// Schedule is set in the val.town UI, not here. Val.town evaluates cron in UTC.\n\nconst MONITOR = \"https://timothylawrence--586dfa487ef311f1a0681607ee4eb77e.web.val.run\";\n\nfunction esc(s: string): string {\n return String(s).replace(/&/g, \"&\").replace(//g, \">\");\n}\n\nasync function alert(text: string) {\n const botToken = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const chatId = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n if (!botToken || !chatId) {\n console.error(\"[driftCheckCron] cannot alert: TELEGRAM_BOT_TOKEN or TELEGRAM_CHAT_ID missing\");\n return;\n }\n const r = await fetch(`https://api.telegram.org/bot${botToken}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text, parse_mode: \"HTML\", disable_web_page_preview: true }),\n });\n if (!r.ok) console.error(`[driftCheckCron] Telegram ${r.status}: ${await r.text()}`);\n}\n\n// Flattens the monitor's per-check `issues` arrays into readable lines.\nfunction summarize(result: any): string[] {\n const lines: string[] = [];\n const checks: Array<[string, any]> = [\n [\"init webhook\", result.initWebhook],\n [\"AIR agent\", result.airAgent],\n [\"SALES agent\", result.salesAgent],\n [\"TINT agent\", result.tintAgent],\n [\"active clients\", result.activeClients],\n ];\n for (const [label, check] of checks) {\n if (!check || check.ok) continue;\n for (const issue of check.issues ?? []) lines.push(`• ${esc(label)}: ${esc(issue)}`);\n if (!(check.issues ?? []).length) lines.push(`• ${esc(label)}: failed with no issue detail`);\n }\n return lines;\n}\n\n// Exported so the alerting path can be exercised for real against\n// `${MONITOR}?selftest=1` without waiting for actual drift. An alerting path\n// that has never fired once is not a verified alerting path.\nexport async function run(monitorUrl: string = MONITOR): Promise {\n let result: any;\n try {\n const r = await fetch(monitorUrl);\n if (!r.ok) throw new Error(`monitor returned HTTP ${r.status}`);\n result = await r.json();\n } catch (e) {\n // The monitor being unreachable is itself a failure worth waking up for.\n // A silent catch here would turn the whole monitor into decoration.\n console.error(`[driftCheckCron] monitor unreachable: ${e}`);\n await alert(`🚨 Config drift monitor is DOWN\\n\\nCould not reach airConfigDriftMonitor.\\n\\n${esc(String(e))}`);\n return;\n }\n\n if (result.ok) {\n console.log(`[OK] drift monitor clean ${result.checkedAt}`);\n return;\n }\n\n const lines = summarize(result);\n console.error(\"[DRIFT DETECTED]\", JSON.stringify(result, null, 2));\n await alert(\n [\n `🚨 Config drift detected`,\n ``,\n ...lines,\n ``,\n `Checked ${esc(result.checkedAt ?? \"unknown time\")}. Either something changed by accident, or a deliberate change shipped without updating the baseline in airConfigDriftMonitor.ts.`,\n ...(result.selftest ? [``, `(SELFTEST — this is a drill, nothing is actually broken.)`] : []),\n ].join(\"\\n\"),\n );\n}\n\nexport default async function (): Promise {\n await run();\n}\n",[147],"b60d4522-935a-4e69-abc6-f14a5b876c8c","airBookAppointment.ts","4c20facc-7f31-11f1-a53e-1607ee4eb77e",24,["D",1784945017572],6,"// AIR — bookAppointment tool — v3 (adds per-client Guest Email for calendar invites)\n// ElevenLabs server tool calls this when a caller wants to book. Writes a row to the\n// Airtable Bookings table (Status = \"pending\"), which fires the \"Booking Created\"\n// automation (Google Calendar + Telegram). \"Guest Email\" is resolved per business so\n// each client's own owner is invited to their bookings — never another client's.\n// Requires AIRTABLE_TOKEN with data.records:write scope on base appufYpiORDVFQ71x.\n\nconst AIRTABLE_TOKEN = Deno.env.get(\"AIRTABLE_TOKEN\");\nconst BASE_ID = \"appufYpiORDVFQ71x\";\nconst BOOKINGS_TABLE = \"tblM4JCdLX94Utx1O\"; // Bookings\n\n// Per-client owner email -> added as a Google Calendar guest on that client's bookings.\nconst OWNER_EMAIL: Record = {\n \"Tint Monsters\": \"tintmonster1@gmail.com\",\n \"The Tint Place\": \"tintmonster1@gmail.com\",\n \"The Tint Shop\": \"tintmonster1@gmail.com\",\n};\n\nexport default async function (req: Request): Promise {\n try {\n const body = await req.json();\n const { name, phone, service_type, requested_datetime, notes, business_name } = body;\n const guestEmail = OWNER_EMAIL[(business_name ?? \"\").trim()] ?? \"\";\n\n const airtableResp = await fetch(\n `https://api.airtable.com/v0/${BASE_ID}/${BOOKINGS_TABLE}`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${AIRTABLE_TOKEN}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n fields: {\n \"Name\": name ?? \"\",\n \"Phone\": phone ?? \"\",\n \"Business\": business_name ?? \"\",\n \"Service Type\": service_type ?? \"\",\n \"Requested Datetime\": requested_datetime ?? \"\",\n \"Status\": \"pending\",\n \"Source Assistant\": \"AIR\",\n \"Notes\": notes ?? \"\",\n \"Guest Email\": guestEmail,\n },\n }),\n },\n );\n\n if (!airtableResp.ok) {\n const errText = await airtableResp.text();\n console.error(\"Airtable error:\", errText);\n return Response.json({\n success: false,\n message:\n \"I couldn't save that booking just now, but I've noted your details and someone will confirm shortly.\",\n });\n }\n\n console.log(\"Booking created:\", name, business_name, service_type, requested_datetime, \"guest:\", guestEmail);\n return Response.json({\n success: true,\n message: `Appointment request recorded for ${name} on ${requested_datetime}.`,\n });\n } catch (err) {\n console.error(\"airBookAppointment threw:\", err);\n return Response.json({\n success: false,\n message: \"Something went wrong saving the booking.\",\n });\n }\n}\n",[155],"pulls","branches","forks","envVars",{"_169":159,"_171":62},"connections",{"_169":62,"_170":62},"count","unfilledCount","emptyCount",{"_43":154,"_32":155,"_30":156,"_132":-5,"_41":42,"_40":157,"_133":58,"_38":186,"_13":159,"_33":143,"_35":160,"_24":25,"_136":-5,"_177":187,"_27":188},{"_43":146,"_32":147,"_30":148,"_132":-5,"_41":42,"_40":149,"_133":58,"_38":183,"_13":151,"_33":34,"_35":152,"_24":25,"_136":-5,"_177":184,"_27":185},{"_43":138,"_32":139,"_30":56,"_132":-5,"_41":42,"_40":140,"_133":58,"_38":180,"_13":142,"_33":143,"_35":144,"_24":25,"_136":-5,"_177":181,"_27":182},{"_43":131,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_133":58,"_38":176,"_13":135,"_33":34,"_35":37,"_24":25,"_136":-5,"_177":178,"_27":179},["D",1785105594601],"children",[],[28],["D",1785105069820],[],[139],["D",1785105201086],[],[147],["D",1784945017572],[],[155],["D",1783998470573],{"_96":95,"_104":100},{"_96":95,"_97":98,"_99":100,"_18":54,"_101":102,"_103":25},{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"ctx",{"_78":-5,"_124":226,"_227":228,"_229":230,"_231":25,"_232":25,"_233":25,"_234":58,"_235":-5,"_236":-7,"_237":-7,"_238":62,"_239":25,"_240":25,"_241":-5,"_242":25,"_243":25,"_244":25,"_245":-5},"ENV",{"_197":198,"_199":200,"_201":86,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225},"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"]

Diff · v63