[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_231":232,"_233":234},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_102":84,"_27":96,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":25,"_116":117,"_118":119,"_120":-5,"_121":-5,"_122":123},"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":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",55,"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","test-ghl.ts","latestPath","fileId","54d1c1fc-7bf7-11f1-bb54-1607ee4eb77e","name","fileType","http","content","// Token-gated test endpoint for the scheduling engine. Never touches Bison and\n// never emails anyone. ?action=menus (default) computes proposal menus from the\n// REAL calendar (read-only). ?action=booktest runs a full book+cancel cycle on\n// the permanent test contact (sam@luminamg.com) - safe, but creates a\n// momentary real appointment.\nimport {\n counterProposal,\n isoForLocal,\n loadSlots,\n localNow,\n menuForPrompt,\n standardProposal,\n windowProposal,\n} from \"./scheduling.ts\";\nimport {\n bookAppointment,\n cancelAppointment,\n getUpcomingAppointment,\n upsertContact,\n} from \"./ghl.ts\";\nimport { coldEmailPipeline, reconcile, websiteIntel } from \"./crm.ts\";\n\n// One-off public .ics for Jim Sandford's Fri 2026-07-17 12pm CT call - his\n// GHL appointment record was deleted (2026-07-15 contact wipe) so the normal\n// per-appointment calendar links don't exist. Contains only the event time +\n// Zoom link (no secrets), served tokenless so the email link works for him.\nconst JIM_ICS = [\n \"BEGIN:VCALENDAR\",\n \"VERSION:2.0\",\n \"PRODID:-//Lumina//Free Campaign Call//EN\",\n \"BEGIN:VEVENT\",\n \"UID:lumina-sandford-20260717@luminamg.com\",\n \"DTSTAMP:20260716T020000Z\",\n \"DTSTART:20260717T170000Z\",\n \"DTEND:20260717T173000Z\",\n \"SUMMARY:Lumina Free Campaign Call\",\n \"DESCRIPTION:Zoom: https://us05web.zoom.us/j/83823105290?pwd=0AEz9q1xlF2Kk\",\n \" ZQbKkzghScqK0bb1t.1\",\n \"LOCATION:https://us05web.zoom.us/j/83823105290?pwd=0AEz9q1xlF2KkZQbKkzghS\",\n \" cqK0bb1t.1\",\n \"END:VEVENT\",\n \"END:VCALENDAR\",\n].join(\"\\r\\n\");\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n if (url.searchParams.get(\"action\") === \"jimics\") {\n return new Response(JIM_ICS, {\n headers: {\n \"Content-Type\": \"text/calendar; charset=utf-8\",\n \"Content-Disposition\": 'attachment; filename=\"lumina-call.ics\"',\n },\n });\n }\n if (url.searchParams.get(\"token\") !== Deno.env.get(\"WEBHOOK_SECRET\")) {\n return new Response(\"unauthorized\", { status: 401 });\n }\n const action = url.searchParams.get(\"action\") ?? \"menus\";\n const out: Record = { ghlKeySet: !!Deno.env.get(\"GHL_API_KEY\") };\n try {\n if (action === \"menus\") {\n for (const tz of [\"America/New_York\", \"America/Chicago\", \"America/Los_Angeles\"]) {\n const slots = await loadSlots(tz);\n const dates = Object.keys(slots).sort();\n const date = url.searchParams.get(\"date\") ?? dates[1];\n const mins = parseInt(url.searchParams.get(\"mins\") ?? \"600\", 10); // default 10:00\n const minDate = url.searchParams.get(\"minDate\") ?? \"\";\n out[tz] = {\n localNow: localNow(tz),\n days: dates.map((d) => `${d}: ${slots[d].length} slots`),\n standard: menuForPrompt(standardProposal(slots, tz, minDate)),\n counterFor: `${date} @ ${mins} mins`,\n counter: menuForPrompt(counterProposal(slots, tz, date, mins)),\n window_afternoon: menuForPrompt(windowProposal(slots, tz, date, [12 * 60, 17 * 60])),\n };\n }\n } else if (action === \"booktest\") {\n const tz = \"America/New_York\";\n const slots = await loadSlots(tz);\n const dates = Object.keys(slots).sort();\n const lastDate = dates[dates.length - 1];\n const slot = slots[lastDate][slots[lastDate].length - 1];\n const contactId = await upsertContact({\n email: \"sam@luminamg.com\",\n firstName: \"ReplyAgent\",\n lastName: \"IntegrationTest\",\n clinicName: \"Test Dental Clinic\",\n });\n const existing = await getUpcomingAppointment(contactId);\n let booked: string | null = null;\n let during: unknown = null;\n if (!existing) {\n const appt = await bookAppointment({\n contactId,\n startTime: slot,\n title: \"[TEST] scheduling engine e2e - auto-cancelled\",\n });\n booked = appt.id;\n during = await getUpcomingAppointment(contactId);\n await cancelAppointment(appt.id);\n }\n out.booktest = {\n slot,\n contactId,\n skippedBecauseExisting: !!existing,\n booked,\n upcomingDuringBooking: during,\n upcomingAfterCancel: await getUpcomingAppointment(contactId),\n };\n } else if (action === \"crmcheck\") {\n // Scope + pipeline discovery report. oppScope flips to true once Sam\n // adds the opportunities scopes to the Private Integration.\n try {\n const pipe = await coldEmailPipeline();\n out.oppScope = true;\n out.pipeline = pipe ?? \"scope OK but 'Cold Email' pipeline / Positive / Booked stages not found by name\";\n } catch (e) {\n out.oppScope = false;\n out.error_detail = String(e).slice(0, 300);\n }\n } else if (action === \"reconcile\") {\n // Manual reconciler run (bypasses the 15-min throttle). dry=1 previews.\n out.reconcile = await reconcile(url.searchParams.get(\"dry\") === \"1\", true);\n } else if (action === \"intel\") {\n // Website-intel probe: ?site=https://example.com\n const site = url.searchParams.get(\"site\") ?? \"\";\n out.intel = await websiteIntel({ custom_variables: [{ name: \"website\", value: site }] });\n } else if (action === \"iso\") {\n const date = url.searchParams.get(\"date\") ?? \"2026-07-20\";\n const mins = parseInt(url.searchParams.get(\"mins\") ?? \"600\", 10);\n out.iso = {};\n for (const tz of [\"America/New_York\", \"America/Chicago\", \"America/Denver\", \"America/Phoenix\", \"America/Los_Angeles\"]) {\n (out.iso as Record)[tz] = isoForLocal(date, mins, tz);\n }\n } else {\n return Response.json({ error: `unknown action ${action}` }, { status: 400 });\n }\n return Response.json(out);\n } catch (e) {\n return Response.json({ ...out, error: String(e) }, { status: 500 });\n }\n}\n","// Token-gated test endpoint for the scheduling engine. Never touches Bison and\n// never emails anyone. ?action=menus (default) computes proposal menus from the\n// REAL calendar (read-only). ?action=booktest runs a full book+cancel cycle on\n// the permanent test contact (sam@luminamg.com) - safe, but creates a\n// momentary real appointment.\nimport {\n counterProposal,\n isoForLocal,\n loadSlots,\n localNow,\n menuForPrompt,\n standardProposal,\n windowProposal,\n} from \"./scheduling.ts\";\nimport {\n bookAppointment,\n cancelAppointment,\n getUpcomingAppointment,\n upsertContact,\n} from \"./ghl.ts\";\nimport { checkDueEmails, coldEmailPipeline, reconcile, websiteIntel } from \"./crm.ts\";\n\n// One-off public .ics for Jim Sandford's Fri 2026-07-17 12pm CT call - his\n// GHL appointment record was deleted (2026-07-15 contact wipe) so the normal\n// per-appointment calendar links don't exist. Contains only the event time +\n// Zoom link (no secrets), served tokenless so the email link works for him.\nconst JIM_ICS = [\n \"BEGIN:VCALENDAR\",\n \"VERSION:2.0\",\n \"PRODID:-//Lumina//Free Campaign Call//EN\",\n \"BEGIN:VEVENT\",\n \"UID:lumina-sandford-20260717@luminamg.com\",\n \"DTSTAMP:20260716T020000Z\",\n \"DTSTART:20260717T170000Z\",\n \"DTEND:20260717T173000Z\",\n \"SUMMARY:Lumina Free Campaign Call\",\n \"DESCRIPTION:Zoom: https://us05web.zoom.us/j/83823105290?pwd=0AEz9q1xlF2Kk\",\n \" ZQbKkzghScqK0bb1t.1\",\n \"LOCATION:https://us05web.zoom.us/j/83823105290?pwd=0AEz9q1xlF2KkZQbKkzghS\",\n \" cqK0bb1t.1\",\n \"END:VEVENT\",\n \"END:VCALENDAR\",\n].join(\"\\r\\n\");\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n if (url.searchParams.get(\"action\") === \"jimics\") {\n return new Response(JIM_ICS, {\n headers: {\n \"Content-Type\": \"text/calendar; charset=utf-8\",\n \"Content-Disposition\": 'attachment; filename=\"lumina-call.ics\"',\n },\n });\n }\n if (url.searchParams.get(\"token\") !== Deno.env.get(\"WEBHOOK_SECRET\")) {\n return new Response(\"unauthorized\", { status: 401 });\n }\n const action = url.searchParams.get(\"action\") ?? \"menus\";\n const out: Record = { ghlKeySet: !!Deno.env.get(\"GHL_API_KEY\") };\n try {\n if (action === \"menus\") {\n for (const tz of [\"America/New_York\", \"America/Chicago\", \"America/Los_Angeles\"]) {\n const slots = await loadSlots(tz);\n const dates = Object.keys(slots).sort();\n const date = url.searchParams.get(\"date\") ?? dates[1];\n const mins = parseInt(url.searchParams.get(\"mins\") ?? \"600\", 10); // default 10:00\n const minDate = url.searchParams.get(\"minDate\") ?? \"\";\n out[tz] = {\n localNow: localNow(tz),\n days: dates.map((d) => `${d}: ${slots[d].length} slots`),\n standard: menuForPrompt(standardProposal(slots, tz, minDate)),\n counterFor: `${date} @ ${mins} mins`,\n counter: menuForPrompt(counterProposal(slots, tz, date, mins)),\n window_afternoon: menuForPrompt(windowProposal(slots, tz, date, [12 * 60, 17 * 60])),\n };\n }\n } else if (action === \"booktest\") {\n const tz = \"America/New_York\";\n const slots = await loadSlots(tz);\n const dates = Object.keys(slots).sort();\n const lastDate = dates[dates.length - 1];\n const slot = slots[lastDate][slots[lastDate].length - 1];\n const contactId = await upsertContact({\n email: \"sam@luminamg.com\",\n firstName: \"ReplyAgent\",\n lastName: \"IntegrationTest\",\n clinicName: \"Test Dental Clinic\",\n });\n const existing = await getUpcomingAppointment(contactId);\n let booked: string | null = null;\n let during: unknown = null;\n if (!existing) {\n const appt = await bookAppointment({\n contactId,\n startTime: slot,\n title: \"[TEST] scheduling engine e2e - auto-cancelled\",\n });\n booked = appt.id;\n during = await getUpcomingAppointment(contactId);\n await cancelAppointment(appt.id);\n }\n out.booktest = {\n slot,\n contactId,\n skippedBecauseExisting: !!existing,\n booked,\n upcomingDuringBooking: during,\n upcomingAfterCancel: await getUpcomingAppointment(contactId),\n };\n } else if (action === \"crmcheck\") {\n // Scope + pipeline discovery report. oppScope flips to true once Sam\n // adds the opportunities scopes to the Private Integration.\n try {\n const pipe = await coldEmailPipeline();\n out.oppScope = true;\n out.pipeline = pipe ?? \"scope OK but 'Cold Email' pipeline / Positive / Booked stages not found by name\";\n } catch (e) {\n out.oppScope = false;\n out.error_detail = String(e).slice(0, 300);\n }\n } else if (action === \"reconcile\") {\n // Manual reconciler run (bypasses the 15-min throttle). dry=1 previews.\n // Also the target of the GHL booking/cancellation workflows - piggyback\n // the due-email check so workflow pings deliver reminders too.\n out.dueEmails = await checkDueEmails(url.searchParams.get(\"dry\") === \"1\").catch((e) => String(e));\n out.reconcile = await reconcile(url.searchParams.get(\"dry\") === \"1\", true);\n } else if (action === \"intel\") {\n // Website-intel probe: ?site=https://example.com\n const site = url.searchParams.get(\"site\") ?? \"\";\n out.intel = await websiteIntel({ custom_variables: [{ name: \"website\", value: site }] });\n } else if (action === \"iso\") {\n const date = url.searchParams.get(\"date\") ?? \"2026-07-20\";\n const mins = parseInt(url.searchParams.get(\"mins\") ?? \"600\", 10);\n out.iso = {};\n for (const tz of [\"America/New_York\", \"America/Chicago\", \"America/Denver\", \"America/Phoenix\", \"America/Los_Angeles\"]) {\n (out.iso as Record)[tz] = isoForLocal(date, mins, tz);\n }\n } else {\n return Response.json({ error: `unknown action ${action}` }, { status: 400 });\n }\n return Response.json(out);\n } catch (e) {\n return Response.json({ ...out, error: String(e) }, { status: 500 });\n }\n}\n","createdAt",["D",1784168316963],"branchVersion","branchId","54481d2d-a3f3-4dfa-ab51-1abb2a0d7de9","id","e3dafc71-738c-40fe-ab70-9c5ae76a5d02","bison-reply-agent",["D",1783490909384],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","352b7b81-2d40-4ef8-babc-d1dd56767822","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f404e-e73e-709b-8be4-84c9207a4140","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_101":96},"org",{"_94":93,"_95":96,"_97":96,"_18":54,"_98":99,"_100":25},"branch",{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned",97,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","samy","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":227,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":228,"_78":229,"_80":230,"_82":25},"tree",[198,199,200,201,202,203,204],"files",[198,199,200,201,202,203,204],"counts",{"_187":60,"_188":184,"_189":60,"_190":191,"_192":193},"contents",[124,125,126,127,128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":179,"_32":180,"_30":181,"_134":-5,"_41":42,"_40":182,"_136":25,"_38":183,"_13":184,"_33":152,"_35":185,"_24":25,"_140":-5,"_27":186},{"_43":171,"_32":172,"_30":173,"_134":-5,"_41":42,"_40":174,"_136":25,"_38":175,"_13":176,"_33":152,"_35":177,"_24":25,"_140":-5,"_27":178},{"_43":163,"_32":164,"_30":165,"_134":-5,"_41":42,"_40":166,"_136":25,"_38":167,"_13":168,"_33":152,"_35":169,"_24":25,"_140":-5,"_27":170},{"_43":155,"_32":156,"_30":157,"_134":-5,"_41":42,"_40":158,"_136":119,"_38":159,"_13":60,"_33":160,"_35":161,"_24":25,"_140":-5,"_27":162},{"_43":146,"_32":147,"_30":148,"_134":-5,"_41":42,"_40":149,"_136":25,"_38":150,"_13":151,"_33":152,"_35":153,"_24":25,"_140":-5,"_27":154},{"_43":142,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_136":25,"_38":143,"_13":144,"_33":34,"_35":37,"_24":25,"_140":-5,"_27":145},{"_43":131,"_32":132,"_30":133,"_134":-5,"_41":42,"_40":135,"_136":25,"_38":137,"_13":138,"_33":34,"_35":139,"_24":25,"_140":-5,"_27":141},"88260068-6e6a-4287-85a3-9885b3a192ca","webhook.ts","a767a496-7a93-11f1-ad89-1607ee4eb77e","parentId",51,"latest",["D",1784168314566],22,"// Email Bison \"reply received\" -> analyze with Claude -> schedule/book via GHL\n// -> draft + send reply / alert Sam.\n// Two-phase model flow: call 1 classifies and extracts scheduling facts (no\n// drafting); code then resolves the timezone, checks real calendar availability,\n// books when appropriate, and computes a verified time menu; call 2 drafts the\n// reply and may only use times from that menu.\n// The playbook (voice, templates, facts, swipefile, mechanism) is compiled from\n// skill/*.md by scripts/deploy.py into playbook.ts.\n// DRY_RUN=true: classify + compute + draft + log + [DRY RUN] alerts, but no\n// Bison sends and no GHL bookings. Set DRY_RUN=false to go live.\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { email } from \"https://esm.town/v/std/email\";\nimport { PLAYBOOK } from \"./playbook.ts\";\nimport {\n bookAppointment,\n cancelAppointment,\n getUpcomingAppointment,\n rescheduleAppointment,\n} from \"./ghl.ts\";\nimport {\n checkDueEmails,\n type ContactEmails,\n contactEmailsFor,\n contactName,\n ensureContact,\n leadVar,\n lookupContact,\n markBooked,\n normalizePhone,\n reconcile,\n stripHtml,\n syncPositiveReply,\n websiteFromLead,\n websiteIntel,\n} from \"./crm.ts\";\nimport {\n counterProposal,\n findExactSlot,\n isoForLocal,\n loadSlots,\n localNow,\n menuForPrompt,\n minutesToLabel,\n type ProposalMenu,\n slotMinutes,\n standardProposal,\n tzAbbreviation,\n weekdayOf,\n windowProposal,\n} from \"./scheduling.ts\";\n\nconst MAX_AI_REPLIES_PER_LEAD = 7;\nconst MODEL = \"claude-sonnet-5\";\nconst BOOKING_LINK = \"https://links.luminamg.com/widget/booking/1nbt58J9c0CBZFyqCBQk\";\nconst FALLBACK_TZ = \"America/Los_Angeles\";\n\n// ---------- Claude plumbing ----------\n\nasync function claudeTool(\n system: string,\n messages: { role: string; content: string }[],\n tool: Record,\n maxTokens = 1500,\n): Promise {\n const resp = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": Deno.env.get(\"ANTHROPIC_API_KEY\") ?? \"\",\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: MODEL,\n max_tokens: maxTokens,\n system,\n tools: [tool],\n tool_choice: { type: \"tool\", name: (tool as any).name },\n messages,\n }),\n signal: AbortSignal.timeout(45_000),\n });\n if (!resp.ok) throw new Error(`anthropic ${resp.status}: ${await resp.text()}`);\n const data = await resp.json();\n const toolUse = (data.content ?? []).find((b: { type: string }) => b.type === \"tool_use\");\n if (!toolUse) throw new Error(\"no tool_use block in Claude response\");\n return toolUse.input;\n}\n\n// ---------- phase 1: classify + extract ----------\n\nconst ANALYSIS_PROMPT = `\nYou analyze replies to cold emails for Lumina (Facebook ads for dental clinics).\nDo NOT draft anything - classify the reply and extract scheduling facts. Code\nwill check the real calendar and a second pass drafts the reply.\n\nCATEGORIES (exactly one):\n1. \"contact_preference\" - they EXPLICITLY offer a number/channel to reach them\n on, or ask us to use one (text me, call me, WhatsApp, \"call my office\").\n Wins over all others. A phone number that merely sits in their signature\n block is NOT contact_preference - classify by the message itself (the number\n still gets extracted via phone_number below).\n2. \"referral\" - they hand the thread to someone else. Set new_contact_provided\n true only if the new person's EMAIL ADDRESS is in the reply.\n3. \"meeting_request\" - they want to talk/book/schedule, or show general interest\n without questions (\"sure\", \"ok\", \"sounds interesting\").\n4. \"info_request\" - they ask question(s) or want more info. Set answerable=false\n ONLY for genuine edge cases wholly outside a sales playbook (rare).\n5. \"not_positive\" - everything else: not interested, unsubscribe, hostile,\n \"we already have an agency\", \"how did you get my email\", vague non-committal.\n ALSO: any reply written by an automated/AI assistant (e.g. signatures like\n \"Sent from X's AI Assistant\", obviously templated auto-responses) is ALWAYS\n not_positive regardless of content. If genuinely unsure between not_positive\n and a positive category, pick not_positive.\n\nEXTRACTION (for every positive category):\n- prospect_first_name: how we'd greet them (\"Monica\", \"Dr. Song\") from their\n sign-off/signature, or the reply's From header when it is clearly a person's\n name (never a practice/office name). null if unknown.\n- prospect_full_name: their full name when determinable (\"Jim Sanford\"), with\n \"Dr.\" in front when they are a dentist/doctor (\"Dr. Jim Sanford\") - check the\n signature, sign-off, and the reply's From header. A From-header name counts\n ONLY when it is clearly a person, never a practice/office name. Omit if you\n only have a first name or nothing.\n- clinic_name: practice name from signature/thread/lead data. null if unknown.\n- timezone: IANA zone (e.g. \"America/New_York\") for the PROSPECT's location.\n Evidence priority: explicit statement in their reply > signature address >\n signature phone area code > lead data (address/phone custom variables) >\n practice name + campaign geography. Texas/Florida etc. split zones - resolve\n by city/area code, not state alone. null ONLY if there is no usable signal.\n timezone_evidence: one short sentence on what you used.\n- Proposed meeting time, ALWAYS in the PROSPECT's local timezone (they speak in\n their own zone unless they clearly reference ours; convert if they do):\n - proposed_date \"YYYY-MM-DD\" + proposed_time \"HH:MM\" (24h) when they name a\n specific time. Bare numbers like \"at 10\" = 10:00 unless context says pm.\n Resolve relative dates (\"tomorrow\", \"Tuesday\") with the current-time info\n provided in the input. Report past/too-soon times as-is - code handles it.\n - proposed_date + proposed_window (morning/afternoon/evening) when they name a\n day and rough window but no clock time (\"Tuesday afternoon\").\n - earliest_date \"YYYY-MM-DD\" when they state a broader availability window\n (\"some time next week\" -> next Monday; \"after the 20th\" -> the 21st; \"not\n this week\" -> next Monday). Every time we later propose must fall on or\n after it. Omit when they gave no such constraint.\n - all null when they didn't suggest any timing.\n- claims_booked: true if they say they already booked/scheduled on our calendar.\n- says_time_works: true if they affirm a specific time works (\"Tuesday at 2\n works\") - even casually.\n- wants_reschedule: true if they ask to MOVE an existing appointment (\"need to\n reschedule\", \"can't make Tuesday\", \"push it to next week\"). \"Cancel it and\n send me the link to rebook\" is a RESCHEDULE, not a cancel - the intent is a\n new time. If they name the new time, also fill proposed_date/time/window.\n- wants_cancel: true only if they want the appointment cancelled with NO intent\n to rebook (\"please cancel\", \"we won't be moving forward with the call\").\n- self_rescheduled: true if they say they ALREADY moved/rebooked it themselves\n on the calendar (done deal, not a request).\n- contact_details: contact_preference/referral only - the number / channel /\n person + email, plus any timing, verbatim as possible.\n- phone_number: the PROSPECT's own phone number when one appears ANYWHERE in\n their reply - explicitly written OR just in their signature block - verbatim.\n NOT numbers from quoted older messages in the thread, and never our own\n (925-730-9373). Omit if none.\n- phone_number_type (only when phone_number is present): \"personal\" when it\n reads as a direct/cell line (under their own name in a signature, labeled\n cell/mobile/direct, or \"call/text me at...\"), \"office\" when it reads as the\n practice's main line (practice-branded footer, office/front-desk label),\n else \"unknown\". phone_number_evidence: one short sentence on the signal.\n- original_offer: the concrete offer from the FIRST EMAIL WE SENT, short and\n near-verbatim (e.g. \"3-5 clear aligner cases every month, free test\n campaign\"). Omit if that email isn't provided.\n\nA reschedule/cancel request is still a positive-category reply (usually\nmeeting_request) unless the message also shows they're no longer interested.\n\nReturn via submit_analysis.`;\n\nconst ANALYSIS_TOOL = {\n name: \"submit_analysis\",\n description: \"Submit the classification and extracted scheduling facts.\",\n input_schema: {\n type: \"object\",\n properties: {\n category: {\n type: \"string\",\n enum: [\"contact_preference\", \"referral\", \"meeting_request\", \"info_request\", \"not_positive\"],\n },\n reasoning: { type: \"string\", description: \"One short sentence.\" },\n contact_details: { type: \"string\" },\n new_contact_provided: { type: \"boolean\" },\n answerable: { type: \"boolean\" },\n prospect_first_name: { type: \"string\" },\n clinic_name: { type: \"string\" },\n timezone: { type: \"string\", description: \"IANA zone or omit if unknown\" },\n timezone_evidence: { type: \"string\" },\n proposed_date: { type: \"string\", description: \"YYYY-MM-DD prospect-local\" },\n proposed_time: { type: \"string\", description: \"HH:MM 24h prospect-local\" },\n proposed_window: { type: \"string\", enum: [\"morning\", \"afternoon\", \"evening\"] },\n earliest_date: { type: \"string\", description: \"YYYY-MM-DD floor for proposals when they state a window like 'next week'\" },\n claims_booked: { type: \"boolean\" },\n says_time_works: { type: \"boolean\" },\n wants_reschedule: { type: \"boolean\" },\n wants_cancel: { type: \"boolean\" },\n self_rescheduled: { type: \"boolean\" },\n phone_number: { type: \"string\", description: \"The prospect's phone number if present anywhere in their reply (body or signature), verbatim\" },\n phone_number_type: { type: \"string\", enum: [\"personal\", \"office\", \"unknown\"] },\n phone_number_evidence: { type: \"string\", description: \"One short sentence\" },\n prospect_full_name: { type: \"string\", description: \"Full name, 'Dr.'-prefixed when a doctor\" },\n original_offer: { type: \"string\", description: \"The concrete offer from the first email we sent, short\" },\n },\n required: [\"category\", \"reasoning\"],\n },\n};\n\ntype Analysis = {\n category: string;\n reasoning: string;\n contact_details?: string;\n new_contact_provided?: boolean;\n answerable?: boolean;\n prospect_first_name?: string;\n clinic_name?: string;\n timezone?: string;\n timezone_evidence?: string;\n proposed_date?: string;\n proposed_time?: string;\n proposed_window?: string;\n earliest_date?: string;\n claims_booked?: boolean;\n says_time_works?: boolean;\n wants_reschedule?: boolean;\n wants_cancel?: boolean;\n self_rescheduled?: boolean;\n phone_number?: string;\n phone_number_type?: \"personal\" | \"office\" | \"unknown\";\n phone_number_evidence?: string;\n prospect_full_name?: string;\n original_offer?: string;\n};\n\n// ---------- phase 2: draft ----------\n\nconst DRAFT_TOOL = {\n name: \"submit_draft\",\n description: \"Submit the drafted reply.\",\n input_schema: {\n type: \"object\",\n properties: {\n reply_text: { type: \"string\", description: \"Plain text with real line breaks.\" },\n },\n required: [\"reply_text\"],\n },\n};\n\nconst DRAFT_PROMPT_HEAD = `\nYou draft replies to cold-email responses for Lumina (Facebook ads for dental\nclinics). You write AS the sender persona named in the input (the pen-name the\nprospect knows) - never any other name.\n\nRULES:\n- Follow the playbook below: voice.md governs tone, templates.md gives the exact\n shapes (blend when the reply spans several - swipefile.md shows how), facts.md\n is the only source of claims, MIRROR RULE for the free-campaign framing (the\n first email we sent in the thread is the source of truth for duration and any\n patient-count promise - never invent one).\n- READ THE ENTIRE THREAD FIRST. The templates fit ~95% of replies; when a thread\n has gone somewhere no template covers, compose naturally from voice.md and\n facts.md instead of forcing a template.\n- NEVER produce a reply that mirrors the structure of one of our previous\n messages in this thread. If an earlier message already used a template's\n skeleton (same greeting shape, same paragraph order, same CTA phrasing), vary\n this one - different opener, reordered or merged paragraphs, tighter length -\n while keeping the voice natural and non-verbose. Identical-looking emails\n read as a bot.\n- Greeting: \"Hey,\" plus their name when known (\"Hey Monica,\" / \"Hey Dr. Song,\"),\n then a short remark that fits the thread.\n- TIMES: you may ONLY mention meeting times that appear in the VERIFIED TIMES\n section of the input - never invent, shift, or add times. Write them with the\n weekday name and timezone label exactly as given (e.g. \"Friday at 10am ET\").\n Never say \"today\"/\"tomorrow\" - use the weekday name.\n- reply_text is PLAIN TEXT with real line breaks: blank line between paragraphs,\n the sign-off (\"Thanks,\" normally; \"Take care,\" on the reschedule/cancel\n templates) on its own line, persona first name on the next line, then exactly\n \"SDR, Lumina\" on the next. NO website in the signature (body mentions like\n \"You can find us at luminamg.com.\" are fine where a template has them). The\n signature goes on EVERY reply (short acks and back-and-forth follow-ups\n included), before any P.S. line. No HTML, no markdown, no em-dashes. Links\n are bare URLs.\n- The input specifies DRAFT MODE (which template shape applies), the P.S. line\n to use (if any), and whether this is a back-and-forth follow-up. In\n back-and-forth mode: drop the full template structure - short, looser,\n one-liner-ish per voice.md, but keep the calendar link when offering times.\n\nReturn via submit_draft.\n\n======================= PLAYBOOK =======================\n` + PLAYBOOK;\n\n// ---------- draft sanitation ----------\n\nconst BANNED_SNIPPETS = [\n \"i hope this finds you well\", \"furthermore,\", \"moreover,\", \"click here\",\n \"as an ai\", \"i'm an ai\", \"language model\",\n];\n\n// Old/alternate calendar URLs that may leak into drafts from earlier thread\n// messages - normalized to the canonical permanent link.\nconst STALE_LINKS = [\n \"https://links.luminamg.com/widget/bookings/lumina-intro-call\",\n];\n\nfunction mechanicalFixes(text: string): string {\n let out = text\n .replace(/[—–]/g, \" - \")\n .replace(/<[^>]+>/g, \"\")\n .replace(/\\r\\n/g, \"\\n\")\n .trim();\n for (const stale of STALE_LINKS) out = out.replaceAll(stale, BOOKING_LINK);\n return out;\n}\n\n// Every reply ends with this directly under the persona's first name (before\n// any P.S. line). Website removed from the signature 2026-07-14 (tentative -\n// Sam reworking the site); isSigLine still strips stray \"luminamg.com\" lines\n// the model may copy from older messages in the thread.\nconst SIGNATURE = \"SDR, Lumina\";\n\nfunction ensureSignature(text: string, senderName: string): string {\n const out = text.replace(/\\s+$/, \"\");\n if (!out) return out;\n const isSigLine = (l: string) =>\n /^\\s*SDR,?\\s*(?:at\\s+|@\\s*)?Lumina\\s*$/i.test(l) ||\n /^\\s*(?:https?:\\/\\/)?(?:www\\.)?luminamg\\.com\\/?\\s*$/i.test(l);\n // Drop whatever signature lines the model wrote (partial or misplaced),\n // then re-insert the canonical block right under the sign-off name line.\n const lines = out.split(\"\\n\").filter((l) => !isSigLine(l));\n const name = senderName.trim().toLowerCase();\n let nameIdx = -1;\n for (let i = lines.length - 1; i >= 0; i--) {\n if (lines[i].trim().toLowerCase().replace(/[,.]\\s*$/, \"\") === name) {\n nameIdx = i;\n break;\n }\n }\n if (nameIdx === -1) {\n // No sign-off at all (e.g. a short ack) - add one with the signature.\n return lines.join(\"\\n\").replace(/\\s+$/, \"\") + `\\n\\nThanks,\\n${senderName}\\n${SIGNATURE}`;\n }\n lines.splice(nameIdx + 1, 0, SIGNATURE);\n // Removing misplaced sig lines can leave stray blanks - tidy without touching content.\n return lines.join(\"\\n\").replace(/\\n{3,}/g, \"\\n\\n\").replace(/\\s+$/, \"\");\n}\n\nfunction normTimeToken(tok: string): string {\n return tok.toLowerCase().replace(/\\s+/g, \"\").replace(\":00\", \"\");\n}\n\nfunction violations(text: string, requireBooking: boolean, allowedTimes: Set | null, allowPhoneAsk: boolean): string[] {\n const problems: string[] = [];\n const lower = text.toLowerCase();\n for (const p of BANNED_SNIPPETS) {\n if (lower.includes(p)) problems.push(`banned phrase: \"${p}\"`);\n }\n if (requireBooking && !text.includes(BOOKING_LINK)) problems.push(\"booking link (bare URL) missing\");\n // The phone-ask line is first-reply-only (2026-07-15); a repeat down the\n // thread reads as a bot that forgot it already asked.\n if (!allowPhoneAsk && lower.includes(\"best number to reach you\")) {\n problems.push(\"the phone-ask line is only for first replies - remove it\");\n }\n if (allowedTimes) {\n for (const tok of text.match(/\\b\\d{1,2}(?::\\d{2})?\\s*(?:am|pm)\\b/gi) ?? []) {\n if (!allowedTimes.has(normTimeToken(tok))) {\n problems.push(`time \"${tok}\" is not in the verified times list`);\n }\n }\n }\n return problems;\n}\n\n// ---------- Bison API ----------\n\nfunction bisonHeaders() {\n return {\n \"Authorization\": `Bearer ${Deno.env.get(\"BISON_API_KEY\")}`,\n \"Accept\": \"application/json\",\n \"Content-Type\": \"application/json\",\n };\n}\n\n// The first campaign email is the source of truth for what was promised (spintax).\nasync function fetchFirstSentEmail(leadId: number): Promise {\n try {\n const resp = await fetch(\n `${Deno.env.get(\"BISON_BASE_URL\")}/api/leads/${leadId}/sent-emails`,\n { headers: bisonHeaders(), signal: AbortSignal.timeout(15_000) },\n );\n if (!resp.ok) return \"\";\n const data = await resp.json();\n const items = data?.data ?? [];\n if (!items.length) return \"\";\n items.sort((a: any, b: any) =>\n String(a.sent_at ?? a.created_at ?? \"\").localeCompare(String(b.sent_at ?? b.created_at ?? \"\"))\n );\n const first = items[0];\n const body = stripHtml(String(first.email_body ?? first.body ?? \"\")).slice(0, 1500);\n return `Subject: ${first.email_subject ?? first.subject ?? \"\"}\\n${body}`;\n } catch (e) {\n console.error(\"fetchFirstSentEmail failed:\", e);\n return \"\";\n }\n}\n\n// Bison's own interested-detection misses many positives, so we push our\n// classification back: marking the reply interested flips the lead's\n// per-campaign \"interested\" flag that Sam filters on in Bison's lead data.\nasync function markReplyInterested(replyId: number) {\n const resp = await fetch(\n `${Deno.env.get(\"BISON_BASE_URL\")}/api/replies/${replyId}/mark-as-interested`,\n { method: \"PATCH\", headers: bisonHeaders(), signal: AbortSignal.timeout(10_000) },\n );\n if (!resp.ok) throw new Error(`bison mark-as-interested ${resp.status}: ${(await resp.text()).slice(0, 300)}`);\n}\n\n// Bison wraps the message in HTML, so raw newlines render as nothing, and Gmail\n// strips

margins (both verified in Gmail).
per newline is the email-native\n// way: a blank line in the draft becomes

(visible empty line), a single\n// newline (Thanks, / name) becomes one
. URLs become clickable links.\nfunction textToHtml(text: string): string {\n const escaped = text.replace(/&/g, \"&\").replace(//g, \">\");\n let linked = escaped.replace(/(https?:\\/\\/[^\\s]+)/g, '$1');\n // Bare website mentions (signature line, \"find us at luminamg.com\") become a\n // real link; full URLs and subdomains are already handled above and the\n // preceding-char guard keeps this from touching them.\n linked = linked.replace(\n /(^|[\\s(])luminamg\\.com(?=$|[\\s).,!?:;])/gm,\n '$1luminamg.com',\n );\n return linked.replace(/\\n/g, \"
\");\n}\n\nasync function sendBisonReply(\n replyId: number,\n message: string,\n senderEmailId?: number,\n leadEmail?: string,\n) {\n // reply_all picks the right sender + recipients; we also pass them explicitly\n // (duplicates are ignored by Bison) so a strict validator can never reject us.\n const payload: Record = {\n reply_all: true,\n message: textToHtml(message),\n content_type: \"html\",\n inject_previous_email_body: true,\n };\n if (senderEmailId) payload.sender_email_id = senderEmailId;\n if (leadEmail) payload.to_emails = [{ name: null, email_address: leadEmail }];\n const resp = await fetch(\n `${Deno.env.get(\"BISON_BASE_URL\")}/api/replies/${replyId}/reply`,\n {\n method: \"POST\",\n headers: bisonHeaders(),\n body: JSON.stringify(payload),\n signal: AbortSignal.timeout(30_000),\n },\n );\n const text = await resp.text();\n if (!resp.ok) throw new Error(`bison reply ${resp.status}: ${text.slice(0, 500)}`);\n return text;\n}\n\nfunction cleanSubject(s: string): string {\n return String(s ?? \"\").replace(/^\\s*((re|fwd?|fw)\\s*:\\s*)+/i, \"\").trim();\n}\n\n// ---------- storage ----------\n\nasync function ensureTables() {\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS webhook_events (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n received_at TEXT DEFAULT (datetime('now')),\n method TEXT, body TEXT)`,\n );\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS processed_replies (\n reply_uuid TEXT PRIMARY KEY,\n status TEXT DEFAULT 'processing',\n processed_at TEXT DEFAULT (datetime('now')))`,\n );\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS ai_actions (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n ts TEXT DEFAULT (datetime('now')),\n lead_id INTEGER, lead_email TEXT,\n reply_id INTEGER, reply_uuid TEXT,\n category TEXT, action TEXT,\n reply_body TEXT, detail TEXT)`,\n );\n}\n\nasync function logAction(row: {\n lead_id?: number; lead_email?: string; reply_id?: number; reply_uuid?: string;\n category?: string; action: string; reply_body?: string; detail?: string;\n}) {\n await sqlite.execute({\n sql: `INSERT INTO ai_actions (lead_id, lead_email, reply_id, reply_uuid, category, action, reply_body, detail)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n row.lead_id ?? null, row.lead_email ?? null, row.reply_id ?? null,\n row.reply_uuid ?? null, row.category ?? null, row.action,\n row.reply_body ?? null, row.detail ?? null,\n ],\n });\n}\n\n// Alerts are best-effort: a slow/down email service must never kill reply\n// processing (it caused 60s gateway-timeout deaths in testing).\nasync function safeEmail(msg: { subject: string; text: string }): Promise {\n try {\n await Promise.race([\n email(msg),\n new Promise((_, rej) => setTimeout(() => rej(new Error(\"email timeout after 8s\")), 8000)),\n ]);\n return true;\n } catch (e) {\n console.error(\"alert email failed:\", e);\n await logAction({ action: \"alert_failed\", detail: `${msg.subject} :: ${String(e).slice(0, 300)}` }).catch(() => {});\n return false;\n }\n}\n\nasync function priorAiMessages(leadId: number): Promise {\n const res = await sqlite.execute({\n sql: `SELECT reply_body FROM ai_actions\n WHERE lead_id = ? AND action IN ('sent', 'drafted', 'booked_and_sent', 'rescheduled_and_sent', 'cancelled_and_sent') AND reply_body IS NOT NULL\n ORDER BY id ASC`,\n args: [leadId],\n });\n return res.rows.map((r: unknown[]) => String(r[0]));\n}\n\n// ---------- scheduling orchestration ----------\n\nconst WINDOWS: Record = {\n morning: [8 * 60, 11 * 60 + 30],\n afternoon: [12 * 60, 17 * 60],\n evening: [17 * 60, 20 * 60 + 30],\n};\n\ntype SchedulingOutcome = {\n mode:\n | \"booked\"\n | \"counter\"\n | \"propose\"\n | \"already_booked\"\n | \"rescheduled\"\n | \"reschedule_propose\"\n | \"cancelled\"\n | \"no_reply\"\n | \"no_calendar\";\n menu?: ProposalMenu;\n bookedLabel?: string; // \"Tuesday at 2pm ET\" (booked or rescheduled-to)\n proposedLabel?: string; // their unavailable ask, e.g. \"10am\"\n tz: string;\n tzAbbr: string;\n tzEvidence: string;\n detail: string; // for logs/alerts\n};\n\nasync function runScheduling(\n a: Analysis,\n lead: any,\n emails: ContactEmails,\n dryRun: boolean,\n): Promise {\n // Resolve timezone: model -> website intel fallback -> PT.\n let tz = a.timezone ?? \"\";\n let evidence = a.timezone_evidence ?? \"\";\n if (!tz) {\n const intel = await websiteIntel(lead);\n if (intel?.timezone) {\n tz = intel.timezone;\n evidence = `website: ${intel.evidence ?? \"site content\"}`;\n }\n }\n if (!tz) {\n tz = FALLBACK_TZ;\n evidence = \"no signal anywhere - defaulted to PT (labeled in copy)\";\n }\n // Guard against a hallucinated zone name blowing up Intl downstream.\n try {\n new Intl.DateTimeFormat(\"en-US\", { timeZone: tz });\n } catch {\n evidence = `model returned invalid zone \"${tz}\" - defaulted to PT`;\n tz = FALLBACK_TZ;\n }\n const tzAbbr = tzAbbreviation(tz);\n\n if (!Deno.env.get(\"GHL_API_KEY\")) {\n return { mode: \"no_calendar\", tz, tzAbbr, tzEvidence: evidence, detail: \"GHL_API_KEY not set - calendar-link-only reply\" };\n }\n\n // They already moved it themselves - the new confirmation flow covers them,\n // no reply needed.\n if (a.self_rescheduled) {\n return { mode: \"no_reply\", tz, tzAbbr, tzEvidence: evidence, detail: \"self-rescheduled - no reply per Sam's rule\" };\n }\n\n // Look up any existing upcoming appointment whenever the reply might be about\n // one (booked claim, time affirmation, reschedule/cancel ask, or a concrete\n // proposed time that may actually be a move).\n const mightHaveAppt = a.claims_booked || a.says_time_works || a.wants_reschedule ||\n a.wants_cancel || (a.proposed_date && a.proposed_time);\n let existing: { id: string; startTime: string } | null = null;\n if (mightHaveAppt) {\n const cid = await lookupContact(emails);\n if (cid) existing = await getUpcomingAppointment(cid).catch(() => null);\n }\n\n // Cancel with no intent to rebook: cancel it, then try to save the meeting\n // anyway (Sam's Cancel template proposes new times).\n if (a.wants_cancel) {\n let detail = \"cancel request; no upcoming appointment found\";\n if (existing) {\n if (!dryRun) {\n await cancelAppointment(existing.id);\n detail = `cancelled appointment ${existing.id} (was ${existing.startTime} location time)`;\n } else detail = `[dry run] would cancel ${existing.id} (${existing.startTime})`;\n }\n let menu: ProposalMenu | undefined;\n try {\n menu = standardProposal(await loadSlots(tz), tz, a.earliest_date ?? \"\");\n } catch { /* save attempt without times is still fine */ }\n return { mode: \"cancelled\", tz, tzAbbr, tzEvidence: evidence, menu, detail };\n }\n\n // Pure \"I booked\" / \"that works\" with an appointment on the books and no move\n // requested -> courteous close.\n if ((a.claims_booked || a.says_time_works) && existing && !a.wants_reschedule &&\n !(a.proposed_date && a.proposed_time)) {\n return {\n mode: \"already_booked\", tz, tzAbbr, tzEvidence: evidence,\n detail: `existing appointment ${existing.id} at ${existing.startTime} (location time)`,\n };\n }\n if (a.claims_booked && !existing) {\n // They say they booked but nothing is on the calendar (lag, other email) -\n // a courteous close beats pitching them times again.\n return { mode: \"already_booked\", tz, tzAbbr, tzEvidence: evidence, detail: \"claims booked; no appointment found - courteous close\" };\n }\n\n let slots;\n try {\n slots = await loadSlots(tz);\n } catch (e) {\n console.error(\"loadSlots failed:\", e);\n return { mode: \"no_calendar\", tz, tzAbbr, tzEvidence: evidence, detail: `GHL slots unavailable: ${String(e).slice(0, 200)}` };\n }\n\n // Reschedule ask without a concrete new time -> propose times (Sam's\n // Reschedule template). The existing appointment stays until they pick.\n if (a.wants_reschedule && !(a.proposed_date && a.proposed_time)) {\n const floor = a.earliest_date ?? \"\";\n const menu = a.proposed_date && a.proposed_window && WINDOWS[a.proposed_window]\n ? windowProposal(slots, tz, a.proposed_date, WINDOWS[a.proposed_window])\n : standardProposal(slots, tz, floor);\n return {\n mode: \"reschedule_propose\", tz, tzAbbr, tzEvidence: evidence,\n menu: menu.days.length ? menu : standardProposal(slots, tz, floor),\n detail: `reschedule request without a time; proposing${floor ? ` (floor ${floor})` : \"\"} (existing appt ${existing?.id ?? \"none\"} kept)`,\n };\n }\n\n // Explicit proposed time -> move an existing appointment, or book fresh, or counter.\n if (a.proposed_date && a.proposed_time) {\n const mins = parseInt(a.proposed_time.slice(0, 2), 10) * 60 + parseInt(a.proposed_time.slice(3, 5), 10);\n const label = minutesToLabel(mins);\n\n // Beyond the visible booking window (allowBookingFor): GHL still accepts\n // direct booking/rescheduling there - verified 2026-07-09: only the widget\n // window is bypassed, conflict + open-hours validation stay ACTIVE. So we\n // try it and let GHL be the validator; a 400 means taken/outside hours.\n const lastSlotDate = Object.keys(slots).sort().pop() ?? \"\";\n const daysOut = Math.round((Date.parse(`${a.proposed_date}T12:00:00Z`) - Date.now()) / 86_400_000);\n if (a.proposed_date > lastSlotDate && daysOut <= 60) {\n const iso = isoForLocal(a.proposed_date, mins, tz);\n const bookedLabel = `${weekdayOf(a.proposed_date, tz)} at ${label} ${tzAbbr}`;\n if (dryRun) {\n return {\n mode: existing ? \"rescheduled\" : \"booked\", tz, tzAbbr, tzEvidence: evidence, bookedLabel,\n detail: `[dry run] would ${existing ? \"move to\" : \"book\"} ${iso} (out-of-window direct)`,\n };\n }\n try {\n if (existing) {\n await rescheduleAppointment(existing.id, iso);\n return {\n mode: \"rescheduled\", tz, tzAbbr, tzEvidence: evidence, bookedLabel,\n detail: `moved appointment ${existing.id} to ${iso} (out-of-window direct)`,\n };\n }\n const nm = contactName(a, lead);\n const contactId = await ensureContact(emails, {\n firstName: nm.firstName,\n lastName: nm.lastName,\n phone: a.phone_number ?? (leadVar(lead, \"phone\") || undefined),\n clinicName: a.clinic_name ?? undefined,\n });\n const raced = await getUpcomingAppointment(contactId).catch(() => null);\n if (raced) {\n return {\n mode: \"already_booked\", tz, tzAbbr, tzEvidence: evidence,\n detail: `double-book guard: appointment ${raced.id} already at ${raced.startTime}`,\n };\n }\n const appt = await bookAppointment({\n contactId,\n startTime: iso,\n title: `Free campaign call - ${a.clinic_name ?? lead.first_name ?? lead.email}`,\n });\n return {\n mode: \"booked\", tz, tzAbbr, tzEvidence: evidence, bookedLabel,\n detail: `booked ${appt.id} at ${iso} (out-of-window direct)`,\n };\n } catch (e) {\n // Taken or outside open hours out there - counter with what we CAN see.\n const menu = standardProposal(slots, tz, a.earliest_date ?? \"\");\n return {\n mode: \"counter\", tz, tzAbbr, tzEvidence: evidence, menu, proposedLabel: label,\n detail: `out-of-window ${a.proposed_date} ${label} rejected by GHL (${String(e).slice(0, 120)}); countered`,\n };\n }\n }\n\n const exact = findExactSlot(slots, a.proposed_date, mins);\n if (exact) {\n const weekday = weekdayOf(a.proposed_date, tz);\n const bookedLabel = `${weekday} at ${label} ${tzAbbr}`;\n // An open proposed time from someone who already has an appointment is a\n // MOVE, whether or not they used the word \"reschedule\".\n if (existing) {\n if (!dryRun) {\n try {\n await rescheduleAppointment(existing.id, exact);\n } catch (e) {\n // GHL rejects moves overlapping the appointment's own current\n // block - cancel-and-rebook covers that edge.\n console.error(\"reschedule failed, falling back to cancel+rebook:\", e);\n await cancelAppointment(existing.id);\n const cid = await lookupContact(emails);\n await bookAppointment({\n contactId: cid!,\n startTime: exact,\n title: `Free campaign call - ${a.clinic_name ?? lead.first_name ?? lead.email}`,\n });\n }\n return {\n mode: \"rescheduled\", tz, tzAbbr, tzEvidence: evidence, bookedLabel,\n detail: `moved appointment ${existing.id} to ${exact} (${bookedLabel})`,\n };\n }\n return {\n mode: \"rescheduled\", tz, tzAbbr, tzEvidence: evidence, bookedLabel,\n detail: `[dry run] would move ${existing.id} to ${exact} (${bookedLabel})`,\n };\n }\n if (!dryRun) {\n const nm = contactName(a, lead);\n const contactId = await ensureContact(emails, {\n firstName: nm.firstName,\n lastName: nm.lastName,\n phone: a.phone_number ?? (leadVar(lead, \"phone\") || undefined),\n clinicName: a.clinic_name ?? undefined,\n });\n // Double-book guard for contacts that existed under a different email\n // spelling or booked between our lookup and now.\n const raced = await getUpcomingAppointment(contactId).catch(() => null);\n if (raced) {\n return {\n mode: \"already_booked\", tz, tzAbbr, tzEvidence: evidence,\n detail: `double-book guard: appointment ${raced.id} already at ${raced.startTime}`,\n };\n }\n const appt = await bookAppointment({\n contactId,\n startTime: exact,\n title: `Free campaign call - ${a.clinic_name ?? lead.first_name ?? lead.email}`,\n });\n return {\n mode: \"booked\", tz, tzAbbr, tzEvidence: evidence, bookedLabel,\n detail: `booked ${appt.id} at ${exact} (${bookedLabel})`,\n };\n }\n return {\n mode: \"booked\", tz, tzAbbr, tzEvidence: evidence, bookedLabel,\n detail: `[dry run] would book ${exact} (${bookedLabel})`,\n };\n }\n // Unavailable (taken, past, or under the 2h notice - free-slots excludes all).\n const menu = counterProposal(slots, tz, a.proposed_date, mins);\n return {\n mode: \"counter\", tz, tzAbbr, tzEvidence: evidence, menu, proposedLabel: label,\n detail: `their ${a.proposed_date} ${label} not bookable; countered${existing ? ` (existing appt ${existing.id} kept)` : \"\"}`,\n };\n }\n\n // Day + rough window, no clock time.\n if (a.proposed_date && a.proposed_window && WINDOWS[a.proposed_window]) {\n const menu = windowProposal(slots, tz, a.proposed_date, WINDOWS[a.proposed_window]);\n if (menu.days.length) {\n return { mode: \"propose\", tz, tzAbbr, tzEvidence: evidence, menu, detail: `window proposal for ${a.proposed_date} ${a.proposed_window}` };\n }\n const fallback = counterProposal(slots, tz, a.proposed_date, (WINDOWS[a.proposed_window][0] + WINDOWS[a.proposed_window][1]) / 2);\n return { mode: \"counter\", tz, tzAbbr, tzEvidence: evidence, menu: fallback, proposedLabel: a.proposed_window, detail: `their ${a.proposed_date} ${a.proposed_window} had no slots; countered` };\n }\n\n // No timing from them -> standard proposal (floored to any stated window).\n const menu = standardProposal(slots, tz, a.earliest_date ?? \"\");\n const now = localNow(tz);\n return {\n mode: \"propose\", tz, tzAbbr, tzEvidence: evidence, menu,\n detail: `standard proposal (their local time ${Math.floor(now.minutes / 60)}:${String(now.minutes % 60).padStart(2, \"0\")}${a.earliest_date ? `, floor ${a.earliest_date}` : \"\"})`,\n };\n}\n\n// ---------- handler ----------\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n if (url.searchParams.get(\"token\") !== Deno.env.get(\"WEBHOOK_SECRET\")) {\n return new Response(\"unauthorized\", { status: 401 });\n }\n const dryRun = (Deno.env.get(\"DRY_RUN\") ?? \"true\") !== \"false\";\n const tag = (s: string) => `${dryRun ? \"[DRY RUN] \" : \"\"}[Reply Agent] ${s}`;\n\n let body: any;\n try {\n body = await req.json();\n } catch {\n return Response.json({ ok: false, error: \"non-json body\" }, { status: 400 });\n }\n\n let processedUuid: string | null = null;\n await ensureTables();\n await sqlite.execute({\n sql: `INSERT INTO webhook_events (method, body) VALUES (?, ?)`,\n args: [req.method, JSON.stringify(body)],\n });\n\n try {\n if (body?.event?.type !== \"LEAD_REPLIED\") {\n return Response.json({ ok: true, skipped: \"not a LEAD_REPLIED event\" });\n }\n const reply = body?.data?.reply ?? {};\n const lead = body?.data?.lead ?? {};\n const campaign = body?.data?.campaign ?? {};\n const sender = body?.data?.sender_email ?? {};\n const senderName = (sender.name || \"Sam\").split(\" \")[0];\n const leadLabel = `${lead.first_name ?? \"\"} ${lead.last_name ?? \"\"} <${lead.email ?? \"?\"}>`.trim();\n const contactEmails = contactEmailsFor(reply, lead);\n\n if (reply.automated_reply === true) {\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id,\n reply_uuid: reply.uuid, action: \"skipped\", detail: \"automated_reply flag\",\n });\n return Response.json({ ok: true, skipped: \"automated reply\" });\n }\n\n // Crash-safe dedup: 'processing' rows older than 10 min are treated as dead\n // (the run was killed mid-flight) and the event is picked up again on Bison's\n // automatic retry. 'done' rows are never reprocessed.\n const replyUuid = reply.uuid ?? crypto.randomUUID();\n const dup = await sqlite.execute({\n sql: `SELECT status, processed_at >= datetime('now', '-10 minutes') AS fresh\n FROM processed_replies WHERE reply_uuid = ?`,\n args: [replyUuid],\n });\n if (dup.rows.length > 0) {\n const [status, fresh] = dup.rows[0] as [string, number];\n if (status === \"done\" || fresh) {\n return Response.json({ ok: true, skipped: \"duplicate delivery\" });\n }\n await sqlite.execute({\n sql: `UPDATE processed_replies SET processed_at = datetime('now'), status = 'processing' WHERE reply_uuid = ?`,\n args: [replyUuid],\n });\n } else {\n await sqlite.execute({\n sql: `INSERT INTO processed_replies (reply_uuid) VALUES (?)`,\n args: [replyUuid],\n });\n }\n processedUuid = replyUuid;\n const markDone = () =>\n sqlite.execute({\n sql: `UPDATE processed_replies SET status = 'done' WHERE reply_uuid = ?`,\n args: [replyUuid],\n });\n\n // Scheduled one-off emails (reminders): due-check is one cheap sqlite\n // query, so it runs on every event - whichever trigger fires first sends.\n try {\n const dueNote = await checkDueEmails(dryRun);\n if (dueNote !== \"no due emails\" && dueNote !== \"no GHL key\") {\n console.log(\"due emails:\", dueNote);\n await logAction({ action: \"scheduled_email\", detail: dueNote.slice(0, 900) });\n }\n } catch (e) {\n console.error(\"checkDueEmails failed:\", e);\n }\n\n // Self-booking reconciler piggybacks on webhook traffic (throttled to\n // >=15 min inside; ~2-5s when it actually runs). Keeps the Cold Email\n // pipeline in sync with the calendar even for widget self-bookings that\n // never touch this webhook.\n try {\n const recNote = await reconcile(dryRun);\n if (recNote !== \"throttled\") {\n console.log(\"reconcile:\", recNote);\n if (/->|created|matched/.test(recNote)) {\n await logAction({ action: \"crm_reconciled\", detail: recNote.slice(0, 900) });\n }\n }\n } catch (e) {\n console.error(\"reconcile failed:\", e);\n await logAction({ action: \"crm_failed\", detail: `reconcile: ${String(e).slice(0, 300)}` }).catch(() => {});\n }\n\n const prior = await priorAiMessages(lead.id ?? -1);\n if (prior.length >= MAX_AI_REPLIES_PER_LEAD) {\n await safeEmail({\n subject: tag(`Reply cap hit - take over: ${leadLabel}`),\n text: `The AI already wrote ${prior.length} replies to this lead and is stopping.\\n\\nCampaign: ${campaign.name}\\nTheir latest message:\\n${reply.text_body ?? \"\"}`,\n });\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id,\n reply_uuid: reply.uuid, action: \"alerted\", detail: \"reply cap reached\",\n });\n await markDone();\n return Response.json({ ok: true, skipped: \"reply cap\" });\n }\n\n const firstEmail = await fetchFirstSentEmail(lead.id);\n\n // Current time in the common US zones so the model can resolve \"tomorrow\"\n // etc. in the prospect's local zone.\n const nowRef = [\"America/New_York\", \"America/Chicago\", \"America/Denver\", \"America/Phoenix\", \"America/Los_Angeles\"]\n .map((z) => `${z}: ${new Date().toLocaleString(\"en-US\", { timeZone: z, weekday: \"long\", year: \"numeric\", month: \"2-digit\", day: \"2-digit\", hour: \"2-digit\", minute: \"2-digit\", hour12: false })}`)\n .join(\"\\n\");\n\n const leadVars = (lead.custom_variables ?? [])\n .map((v: any) => `${v.name}: ${v.value}`).join(\"\\n\");\n\n const context = [\n `Sender persona (reply as this name): ${senderName}`,\n `Campaign: ${campaign.name ?? \"?\"}`,\n `Prospect: ${leadLabel}${lead.company ? ` - ${lead.company}` : \"\"}`,\n leadVars ? `Lead data (from Email Bison):\\n${leadVars}` : \"\",\n `CURRENT TIME REFERENCE:\\n${nowRef}`,\n firstEmail\n ? `FIRST EMAIL WE SENT IN THIS THREAD (source of truth for the free-campaign framing and any patient-count promise):\\n${firstEmail}`\n : `(first sent email unavailable - use \"the free campaign\" with no duration/numbers)`,\n prior.length\n ? `Our previous AI-written messages in this thread:\\n${prior.map((b, i) => `--- message ${i + 1} ---\\n${b}`).join(\"\\n\")}`\n : \"\",\n `Subject: ${reply.email_subject ?? \"\"}`,\n reply.from_name || reply.from_email_address\n ? `Reply From header: ${reply.from_name ?? \"\"} <${reply.from_email_address ?? \"?\"}>`.trim()\n : \"\",\n `PROSPECT'S LATEST REPLY (may include quoted history below it):\\n${(reply.text_body ?? stripHtml(reply.html_body ?? \"\")).slice(0, 6000)}`,\n ].filter(Boolean).join(\"\\n\\n\");\n\n // ---- phase 1: classify + extract ----\n const analysis: Analysis = await claudeTool(ANALYSIS_PROMPT, [{ role: \"user\", content: context }], ANALYSIS_TOOL, 1000);\n console.log(\"analysis:\", JSON.stringify(analysis));\n\n if (analysis.category === \"not_positive\") {\n // Even a hard \"cancel, not interested\" must still clear the calendar.\n let cancelNote = \"\";\n if (analysis.wants_cancel && !dryRun && Deno.env.get(\"GHL_API_KEY\")) {\n try {\n const cid = await lookupContact(contactEmails);\n const appt = cid ? await getUpcomingAppointment(cid) : null;\n if (appt) {\n await cancelAppointment(appt.id);\n cancelNote = `; cancelled appointment ${appt.id} (${appt.startTime})`;\n }\n } catch (e) {\n console.error(\"cancel on not_positive failed:\", e);\n cancelNote = `; CANCEL FAILED: ${String(e).slice(0, 150)}`;\n }\n }\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id, reply_uuid: reply.uuid,\n category: analysis.category, action: \"skipped\", detail: analysis.reasoning + cancelNote,\n });\n await markDone();\n return Response.json({ ok: true, category: analysis.category, action: `none${cancelNote ? \" (appointment cancelled)\" : \"\"}` });\n }\n\n // Positive categories are pushed into Bison right away (even if drafting\n // later fails, the interest is real). Referral is excluded: Sam's templates\n // file groups \"Wrong Person\" under Uninterested - the person who replied\n // isn't the interested party. Best-effort: a Bison hiccup here must never\n // block the reply itself.\n if (!dryRun && reply.id && analysis.category !== \"referral\") {\n try {\n await markReplyInterested(reply.id);\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id, reply_uuid: reply.uuid,\n category: analysis.category, action: \"marked_interested\",\n });\n } catch (e) {\n console.error(\"markReplyInterested failed:\", e);\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id, reply_uuid: reply.uuid,\n category: analysis.category, action: \"mark_interested_failed\", detail: String(e).slice(0, 300),\n });\n }\n }\n\n // GHL is Sam's CRM (2026-07-15): every positive reply creates/enriches a\n // contact + a Positive-stage opportunity in the Cold Email pipeline.\n // Best-effort - a CRM hiccup never blocks the reply.\n let crmContactId: string | undefined;\n try {\n const crm = await syncPositiveReply({ analysis, lead, reply, dryRun });\n crmContactId = crm.contactId;\n console.log(\"crm sync:\", crm.note);\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id, reply_uuid: reply.uuid,\n category: analysis.category, action: \"crm_synced\", detail: crm.note.slice(0, 900),\n });\n } catch (e) {\n console.error(\"crm sync failed:\", e);\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id, reply_uuid: reply.uuid,\n category: analysis.category, action: \"crm_failed\", detail: String(e).slice(0, 300),\n }).catch(() => {});\n }\n\n // Any prospect phone number - explicitly written or just in their signature -\n // gets a heads-up to Sam: a quick call is by far the best channel (2026-07-14).\n // contact_preference and referral alerts already carry the contact details.\n if (analysis.phone_number && analysis.category !== \"contact_preference\" && analysis.category !== \"referral\") {\n // Personal vs office: the strongest signal is whether their number matches\n // the practice website's; the model's signature-placement read backs it\n // up. All best-effort - a dead website must never lose the alert.\n const replyPhone = normalizePhone(analysis.phone_number);\n const site = websiteFromLead(lead);\n const sitePhones = site && replyPhone ? ((await websiteIntel(lead))?.phones ?? []) : [];\n const fmt = (d: string) => `(${d.slice(0, 3)}) ${d.slice(3, 6)}-${d.slice(6)}`;\n let verdict: string;\n if (replyPhone && sitePhones.includes(replyPhone)) {\n verdict = `likely OFFICE - same number as their website (${site})`;\n } else if (replyPhone && sitePhones.length) {\n verdict = `likely PERSONAL/DIRECT - differs from their website's ${sitePhones.map(fmt).join(\", \")}`;\n } else if (replyPhone && site) {\n verdict = \"unknown - no number found on their website to compare\";\n } else {\n verdict = \"unknown - no website number to compare\";\n }\n if (analysis.phone_number_type && analysis.phone_number_type !== \"unknown\") {\n verdict += `; reads as ${analysis.phone_number_type} in the email${\n analysis.phone_number_evidence ? ` (${analysis.phone_number_evidence})` : \"\"\n }`;\n }\n\n const name = analysis.prospect_full_name ??\n analysis.prospect_first_name ??\n `${lead.first_name ?? \"?\"} (lead label - may be the office name)`;\n const offer = analysis.original_offer ||\n [leadVar(lead, \"treatment number\"), leadVar(lead, \"treatment type\"), leadVar(lead, \"treatment suffix\")]\n .filter(Boolean).join(\" \") || \"(unknown - check the original email below)\";\n const location = [leadVar(lead, \"city\"), leadVar(lead, \"state\")].filter(Boolean).join(\", \");\n const replierLine = `${reply.from_name ?? \"\"} <${reply.from_email_address ?? lead.email ?? \"?\"}>`.trim() +\n (reply.from_email_address && lead.email && reply.from_email_address.toLowerCase() !== lead.email.toLowerCase()\n ? ` | lead email: ${lead.email}`\n : \"\");\n\n await safeEmail({\n subject: tag(`Phone number spotted - give them a call: ${leadLabel}`),\n text: [\n `CALL PREP`,\n `Name: ${name}`,\n `Phone: ${analysis.phone_number}`,\n `Phone type: ${verdict}`,\n `Clinic: ${analysis.clinic_name ?? lead.company ?? \"?\"}`,\n `Location: ${location || \"?\"}${analysis.timezone ? ` | timezone: ${analysis.timezone}` : \"\"}`,\n `Reply from: ${replierLine}`,\n `Subject line: ${cleanSubject(reply.email_subject) || \"?\"}`,\n `Our sender: ${sender.email ?? \"?\"} (persona: ${senderName})`,\n `Offer: ${offer}`,\n ``,\n `THEIR REPLY`,\n `-----------`,\n `${reply.text_body ?? stripHtml(reply.html_body ?? \"\")}`,\n ``,\n `OUR ORIGINAL EMAIL`,\n `------------------`,\n `${firstEmail || \"(couldn't fetch it - check the thread in Bison)\"}`,\n ``,\n `The AI is still handling the email reply as usual - this is just so you can call them.`,\n ].join(\"\\n\"),\n });\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id, reply_uuid: reply.uuid,\n category: analysis.category, action: \"phone_alerted\",\n detail: `${analysis.phone_number} (${verdict})`,\n });\n }\n\n if (analysis.category === \"info_request\" && analysis.answerable === false) {\n await safeEmail({\n subject: tag(`Question outside playbook - take over: ${leadLabel}`),\n text:\n `A prospect asked something the playbook can't answer. The AI is NOT replying.\\n\\n` +\n `Prospect: ${leadLabel}\\nCampaign: ${campaign.name}\\nPersona they know: ${senderName}\\n` +\n `Why escalated: ${analysis.reasoning}\\n\\nTheir message:\\n${reply.text_body ?? \"\"}\\n\\n` +\n `Tip: answer them in Bison, then tell Claude Code the Q&A so it goes into facts.md for next time.`,\n });\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id, reply_uuid: reply.uuid,\n category: analysis.category, action: \"alerted\", detail: `unanswerable: ${analysis.reasoning}`,\n });\n await markDone();\n return Response.json({ ok: true, category: analysis.category, action: \"alerted\" });\n }\n\n // ---- scheduling (meeting_request / info_request only) ----\n const needsScheduling = analysis.category === \"meeting_request\" || analysis.category === \"info_request\";\n let sched: SchedulingOutcome | null = null;\n if (needsScheduling) {\n sched = await runScheduling(analysis, lead, contactEmails, dryRun);\n console.log(\"scheduling:\", JSON.stringify({ ...sched, menu: sched.menu ? menuForPrompt(sched.menu) : undefined }));\n }\n\n // Pipeline follows the calendar: agent-booked, agent-moved, and\n // detected self-bookings all land the opportunity in Booked.\n if (sched && (sched.mode === \"booked\" || sched.mode === \"rescheduled\" || sched.mode === \"already_booked\")) {\n try {\n const note = await markBooked(\n crmContactId ?? await lookupContact(contactEmails) ?? undefined,\n analysis.clinic_name ?? lead.company ?? lead.first_name ?? lead.email,\n dryRun,\n );\n console.log(\"crm booked:\", note);\n } catch (e) {\n console.error(\"markBooked failed:\", e);\n await logAction({ action: \"crm_failed\", detail: `markBooked: ${String(e).slice(0, 300)}` }).catch(() => {});\n }\n }\n\n // They already rebooked themselves - their new confirmation flow covers it.\n if (sched?.mode === \"no_reply\") {\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id, reply_uuid: reply.uuid,\n category: analysis.category, action: \"skipped\", detail: sched.detail,\n });\n await markDone();\n return Response.json({ ok: true, category: analysis.category, action: \"none (self-rescheduled)\" });\n }\n\n // ---- phase 2: draft ----\n const isFollowUp = prior.length > 0;\n let draftMode: string;\n let psLine = \"\";\n if (analysis.category === \"contact_preference\") {\n draftMode = \"PMOC_ACK: the short PMoC acknowledgment from templates.md - tell them to expect the {text/call/...} they asked for from our founder Sam (his number is 925-730-9373). MIRROR any timing they stated in their reply (e.g. \\\"to set up a time to talk Friday afternoon\\\") - say \\\"later today\\\" ONLY if they gave no timing. Nothing else, no links.\";\n } else if (analysis.category === \"referral\" && analysis.new_contact_provided === true) {\n draftMode = \"REFERRAL_INTRO: the Wrong Person template, second part - the intro email TO THE NEW PERSON, greeting them by name. Sam sends it manually, so make it final, no placeholders. Do not mention meeting times (no verified times available for this draft) - end the CTA with the calendar link.\";\n } else if (analysis.category === \"referral\") {\n draftMode = \"REFERRAL_ASK: the Wrong Person template, first part - ask the person who replied for the new contact's best email. No booking link, no times.\";\n } else if (sched?.mode === \"already_booked\") {\n draftMode = \"ALREADY_BOOKED: they booked (or say they did). One short, warm line confirming you saw it and you're looking forward to the call - e.g. \\\"saw the booking come through - talk then!\\\" adapted to the thread. No times, no calendar link, no pitch, no P.S.\";\n } else if (sched?.mode === \"booked\") {\n draftMode = `BOOKED_CONFIRMATION: you booked their proposed time - it's now on the calendar and the invite is on its way. Use the \"Ask for Call + Proposed Time\" template (\"Hey - works for me! Just sent you a calendar invite for ${sched.bookedLabel}. Excited to connect with you.\"). If their reply also asked questions, answer them briefly first per the playbook. No other times, no calendar link.`;\n psLine = \"P.S. If there's a better email for this, just let me know and I'll send the invite there instead.\";\n } else if (sched?.mode === \"rescheduled\") {\n draftMode = `RESCHEDULED_CONFIRMATION: their appointment is already MOVED to ${sched.bookedLabel} - done deal. Send a quick, courteous, brief confirmation (\"No worries at all - just moved us to ${sched.bookedLabel}. Talk then!\" adapted to the thread). No other times, no calendar link, no pitch.`;\n } else if (sched?.mode === \"reschedule_propose\") {\n draftMode = `RESCHEDULE_PROPOSE: they want to move their existing appointment but didn't name a new time. Use the \"Written Reschedule Request\" template: \"Hey, No worries at all - happy to reschedule. Does [VERIFIED TIMES] work for you instead?\" then the calendar line (\"Alternatively, have your pick at any available time on our calendar:\"), then \"Feel free to reach out if those times don't work and we can work something out.\" Sign off \"Take care,\". Their current appointment stays until they pick.`;\n } else if (sched?.mode === \"cancelled\") {\n draftMode = `CANCELLED_SAVE: their appointment is cancelled as they asked. Use the \"Written Cancellation Request\" template: \"Hey, No worries at all.\" then - IF their message leaves any door open - try to save it: \"Would [VERIFIED TIMES] work for you instead?\" plus the calendar line, closing \"Let me know if you have any questions or concerns.\" Sign off \"Take care,\". If their message is clearly final (firmly out, unhappy), skip the times and calendar entirely - just a warm, brief, door-open close.`;\n } else if (sched?.mode === \"counter\") {\n draftMode = `COUNTER: what they asked for (${sched.proposedLabel ?? \"their ask\"}) isn't open. Use the \"IF SLOT ISN'T OPEN\" template from templates.md, adapting the opener naturally to what they asked for, then offer the VERIFIED TIMES by day, then the calendar link line.`;\n } else if (sched?.mode === \"no_calendar\") {\n draftMode = \"PROPOSE_LINK_ONLY: the calendar couldn't be checked, so do not mention any specific times - answer per the playbook and end the CTA with the calendar link only.\";\n } else {\n draftMode = \"PROPOSE: answer their reply per the playbook templates, then propose the VERIFIED TIMES by day (\\\"How about Thursday at 3pm ET, Friday at 10am or 1pm ET, or Monday at 12pm or 4pm ET?\\\" - adapt wording to the list), then the calendar link line.\";\n }\n // Only fully-interested (meeting_request) first replies get a P.S.; the old\n // \"not a sales call\" P.S. for info requests is retired (2026-07-14).\n if (!psLine && !isFollowUp && analysis.category === \"meeting_request\" && sched && (sched.mode === \"counter\" || sched.mode === \"propose\" || sched.mode === \"no_calendar\")) {\n psLine = \"P.S. If those times don't work for you - feel free to send over your calendar link or some times that work for you\";\n }\n\n // Pry for their number on the FIRST reply when we don't already have one -\n // a phone call is Sam's best-converting channel (2026-07-15). Never on\n // follow-ups (reads as a bot re-asking), never when their reply already\n // carries a number (asking for what's in their signature = not listening),\n // and only in the time-proposing shapes (booked/reschedule/cancel lanes\n // either already captured a number via the booking widget or are the\n // wrong moment to ask).\n const askPhone = !isFollowUp && !analysis.phone_number && sched != null &&\n (sched.mode === \"propose\" || sched.mode === \"counter\" || sched.mode === \"no_calendar\");\n\n const draftInput = [\n context,\n `=== DRAFTING INSTRUCTIONS ===`,\n `DRAFT MODE: ${draftMode}`,\n sched?.menu ? `VERIFIED TIMES (the ONLY times you may mention, prospect-local ${sched.tzAbbr}):\\n${menuForPrompt(sched.menu)}` : \"\",\n sched ? `Prospect timezone: ${sched.tz} (${sched.tzAbbr}) - evidence: ${sched.tzEvidence}` : \"\",\n analysis.prospect_first_name ? `Greet them as: ${analysis.prospect_first_name}` : \"Their name is unknown - greet with just \\\"Hey,\\\"\",\n askPhone\n ? `PHONE ASK: include exactly this line, on its own line, right after the proposed-times question and before the calendar-link line (when no times are offered, directly before the calendar-link line): \"And what's the best number to reach you at?\" Skip it ONLY if their reply explicitly says not to call them.`\n : `Do NOT ask for their phone number in this reply (no \"best number to reach you\" line).`,\n psLine ? `End with exactly this P.S. line:\\n${psLine}` : \"No P.S. line on this reply.\",\n isFollowUp ? \"BACK-AND-FORTH MODE: this is a follow-up exchange - short and loose, no full template structure, no repeated P.S. boilerplate.\" : \"\",\n `Calendar link (bare URL when the mode calls for it): ${BOOKING_LINK}`,\n ].filter(Boolean).join(\"\\n\\n\");\n\n const messages: { role: string; content: string }[] = [{ role: \"user\", content: draftInput }];\n let draft = mechanicalFixes(String((await claudeTool(DRAFT_PROMPT_HEAD, messages, DRAFT_TOOL)).reply_text ?? \"\"));\n\n // Sanitation + one repair round.\n const requireBooking = sched?.mode === \"counter\" || sched?.mode === \"propose\" ||\n sched?.mode === \"reschedule_propose\" || (sched?.mode === \"no_calendar\") ||\n (analysis.category === \"referral\" && analysis.new_contact_provided === true);\n const allowedTimes: Set | null = sched?.menu || sched?.bookedLabel || sched?.proposedLabel\n ? new Set([\n ...(sched?.menu?.days.flatMap((d) => d.times) ?? []),\n ...(sched?.bookedLabel ? [sched.bookedLabel.split(\" at \")[1]?.split(\" \")[0] ?? \"\"] : []),\n ...(sched?.proposedLabel ? [sched.proposedLabel] : []),\n ].filter(Boolean).map(normTimeToken))\n : null;\n const strictDraft = analysis.category === \"meeting_request\" || analysis.category === \"info_request\" ||\n (analysis.category === \"referral\" && analysis.new_contact_provided !== true);\n\n let problems = violations(draft, requireBooking, allowedTimes, askPhone);\n if (draft === \"\") problems.push(\"empty draft\");\n if (problems.length) {\n messages.push(\n { role: \"assistant\", content: `Draft: ${draft}` },\n {\n role: \"user\",\n content:\n `Your draft failed these checks:\\n- ${problems.join(\"\\n- \")}\\n` +\n `Rewrite it to fix every item, same draft mode, and resubmit via the tool.`,\n },\n );\n draft = mechanicalFixes(String((await claudeTool(DRAFT_PROMPT_HEAD, messages, DRAFT_TOOL)).reply_text ?? \"\"));\n problems = violations(draft, requireBooking, allowedTimes, askPhone);\n if (draft === \"\") problems.push(\"empty draft\");\n if (problems.length) {\n const stateChanged = sched?.mode === \"booked\" || sched?.mode === \"rescheduled\" || sched?.mode === \"cancelled\";\n if (strictDraft && !stateChanged) {\n await safeEmail({\n subject: tag(`Draft failed checks - take over: ${leadLabel}`),\n text: `The AI's draft failed checks twice, so nothing was sent.\\n\\nProblems:\\n- ${problems.join(\"\\n- \")}\\n\\nDraft:\\n${draft}\\n\\nTheir message:\\n${reply.text_body ?? \"\"}`,\n });\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id, reply_uuid: reply.uuid,\n category: analysis.category, action: \"alerted\",\n reply_body: draft, detail: `failed checks: ${problems.join(\"; \")}`,\n });\n await markDone();\n return Response.json({ ok: true, category: analysis.category, action: \"alerted (draft failed checks)\" });\n }\n // Calendar state already changed - we MUST tell them something, so fall\n // back to the bare template. Soft drafts (PMoC/intro) just degrade.\n if (sched?.mode === \"booked\") {\n draft = `Hey - works for me! Just sent you a calendar invite for ${sched.bookedLabel}. Excited to connect with you.\\n\\nThanks,\\n${senderName}\\n\\nP.S. If there's a better email for this, just let me know and I'll send the invite there instead.`;\n } else if (sched?.mode === \"rescheduled\") {\n draft = `Hey - no worries at all, just moved us to ${sched.bookedLabel}. Talk then!\\n\\nThanks,\\n${senderName}`;\n } else if (sched?.mode === \"cancelled\") {\n draft = `Hey - no worries at all, just cancelled it. If you ever want to grab another time, here's our calendar: ${BOOKING_LINK}\\n\\nTake care,\\n${senderName}`;\n } else {\n draft = \"\";\n }\n }\n }\n if (draft) draft = ensureSignature(draft, senderName);\n console.log(\"draft:\", JSON.stringify({ mode: sched?.mode ?? analysis.category, draft }));\n\n // ---- routing ----\n\n // PMoC: send the one-line acknowledgment, then hand the actual outreach to Sam.\n if (analysis.category === \"contact_preference\") {\n let ackNote = \"no acknowledgment sent (draft failed) - consider sending one yourself\";\n if (draft) {\n if (dryRun) ackNote = \"[dry run] acknowledgment drafted but NOT sent\";\n else {\n try {\n await sendBisonReply(reply.id, draft, sender.id, lead.email);\n ackNote = \"the AI already sent them this acknowledgment\";\n } catch (e) {\n console.error(\"PMoC ack send failed:\", e);\n ackNote = `acknowledgment send FAILED - send one yourself (${String(e).slice(0, 200)})`;\n }\n }\n }\n await safeEmail({\n subject: tag(`Contact preference - reach out personally: ${leadLabel}`),\n text:\n `They gave a contact preference - the actual texting/calling is on you.\\n\\n` +\n `Prospect: ${leadLabel}\\nCampaign: ${campaign.name}\\nPersona they know: ${senderName}\\n` +\n `Details: ${analysis.contact_details ?? \"(see message)\"}\\n\\n` +\n `Acknowledgment (${ackNote}):\\n${draft || \"(none)\"}\\n\\nTheir message:\\n${reply.text_body ?? \"\"}`,\n });\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id, reply_uuid: reply.uuid,\n category: analysis.category, action: draft ? (dryRun ? \"drafted\" : \"sent\") : \"alerted\",\n reply_body: draft || undefined, detail: analysis.contact_details ?? analysis.reasoning,\n });\n await markDone();\n return Response.json({\n ok: true, category: analysis.category,\n action: draft && !dryRun ? \"ack sent + alerted\" : \"alerted\",\n });\n }\n\n // Referral with the new contact's email: the intro draft goes to Sam to send.\n if (analysis.category === \"referral\" && analysis.new_contact_provided === true) {\n await safeEmail({\n subject: tag(`Referral - intro drafted, send it to the new contact: ${leadLabel}`),\n text:\n `They referred us to someone else and included their contact. Sending to a new address isn't automated yet - copy the draft below into a fresh email.\\n\\n` +\n `New contact: ${analysis.contact_details ?? \"(see message)\"}\\nCampaign: ${campaign.name}\\nPersona they know: ${senderName}\\n\\n` +\n `Ready-to-send draft:\\n${draft || \"(draft failed - use the Wrong Person template)\"}\\n\\n` +\n `Their message:\\n${reply.text_body ?? \"\"}`,\n });\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id, reply_uuid: reply.uuid,\n category: analysis.category, action: \"alerted\",\n reply_body: draft || undefined, detail: analysis.contact_details ?? analysis.reasoning,\n });\n await markDone();\n return Response.json({ ok: true, category: analysis.category, action: \"alerted (intro drafted for Sam)\" });\n }\n\n // Everything else (referral-ask, already_booked, booked, counter, propose): send.\n if (!draft) {\n // soft-draft failure with nothing to send - nothing sensible to do beyond log\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id, reply_uuid: reply.uuid,\n category: analysis.category, action: \"skipped\", detail: \"no draft after repair (soft)\",\n });\n await markDone();\n return Response.json({ ok: true, category: analysis.category, action: \"skipped (no draft)\" });\n }\n\n const actionName = sched?.mode === \"booked\"\n ? \"booked_and_sent\"\n : sched?.mode === \"rescheduled\"\n ? \"rescheduled_and_sent\"\n : sched?.mode === \"cancelled\"\n ? \"cancelled_and_sent\"\n : \"sent\";\n if (dryRun) {\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id, reply_uuid: reply.uuid,\n category: analysis.category, action: \"drafted\", reply_body: draft,\n detail: `${sched?.detail ?? \"\"} | tz: ${sched?.tz ?? \"n/a\"} (${sched?.tzEvidence ?? \"\"})`.trim(),\n });\n await markDone();\n return Response.json({\n ok: true, category: analysis.category, action: \"drafted (dry run)\",\n mode: sched?.mode, draft,\n });\n }\n\n await sendBisonReply(reply.id, draft, sender.id, lead.email);\n await logAction({\n lead_id: lead.id, lead_email: lead.email, reply_id: reply.id, reply_uuid: reply.uuid,\n category: analysis.category, action: actionName, reply_body: draft,\n detail: `${sched?.detail ?? analysis.reasoning} | tz: ${sched?.tz ?? \"n/a\"} (${sched?.tzEvidence ?? \"\"})`.trim(),\n });\n await markDone();\n return Response.json({ ok: true, category: analysis.category, action: actionName, mode: sched?.mode });\n } catch (err) {\n console.error(\"handler error:\", err);\n if (processedUuid) {\n await sqlite.execute({\n sql: `DELETE FROM processed_replies WHERE reply_uuid = ? AND status = 'processing'`,\n args: [processedUuid],\n }).catch(() => {});\n }\n await logAction({ action: \"error\", detail: String(err).slice(0, 1000) });\n await safeEmail({\n subject: tag(\"Error - agent did nothing for this event\"),\n text: `The reply agent hit an error and took no action.\\n\\n${String(err)}\\n\\nPayload snippet:\\n${JSON.stringify(body).slice(0, 1500)}`,\n });\n return Response.json({ ok: false, error: String(err).slice(0, 300) }, { status: 500 });\n }\n}\n","label",[132],"b5436acf-61a2-4342-a46b-4d0194075a2f",["D",1784168316963],5,[28],"07f36837-442f-4e55-8733-8ed83e6b0f9b","scheduling.ts","5484ccb2-7bf7-11f1-bbeb-1607ee4eb77e",29,["D",1783649454091],2,"script","// Deterministic proposal engine for the reply agent. All decisions about WHICH\n// times to offer live here (code, testable), not in the model - the model only\n// phrases them. Rules from Sam, 2026-07-09:\n// - Times are always the prospect's local timezone; slots fetched from GHL in it.\n// - Ideal windows: 10:00, 12:00, 13:00, 16:00. Same-day special: 15:00 (only\n// when their reply lands before 10:00 their time -> 3-day shape).\n// - A taken time slides to the nearest 30-min interval, later preferred.\n// - Proposals use business days only (skip Sat/Sun); weekend times are still\n// BOOKED if the prospect asks for one - that rule is enforced by the caller\n// simply checking availability, not here.\n// - Counter-proposals (\"IF SLOT ISN'T OPEN\" template): proposed day at nearest\n// time, then two more days at their-time-if-free (else nearest) + an\n// alternate ideal, giving spread for flexibility.\n\nimport { fetchFreeSlots } from \"./ghl.ts\";\n\nexport type DayOptions = {\n date: string; // \"YYYY-MM-DD\" (prospect-local)\n weekday: string; // \"Friday\"\n times: string[]; // human labels: \"10am\", \"1:30pm\" (prospect-local)\n slotIso: Record; // label -> exact ISO slot for booking\n};\n\nexport type ProposalMenu = {\n timezone: string;\n tzAbbr: string; // \"PT\", \"ET\", ...\n days: DayOptions[];\n};\n\nconst IDEAL_MINUTES = [10 * 60, 12 * 60, 13 * 60, 16 * 60]; // 10a, 12p, 1p, 4p\nconst SAME_DAY_MINUTES = 15 * 60; // 3pm\n\n// ---------- small time helpers (no Date-math across zones; slots arrive\n// already rendered in the requested timezone, e.g. \"2026-07-10T13:15:00-07:00\") ----------\n\nexport function slotDate(slot: string): string {\n return slot.slice(0, 10);\n}\n\nexport function slotMinutes(slot: string): number {\n return parseInt(slot.slice(11, 13), 10) * 60 + parseInt(slot.slice(14, 16), 10);\n}\n\nexport function minutesToLabel(mins: number): string {\n const h24 = Math.floor(mins / 60);\n const m = mins % 60;\n const ampm = h24 < 12 ? \"am\" : \"pm\";\n const h = h24 % 12 === 0 ? 12 : h24 % 12;\n return m === 0 ? `${h}${ampm}` : `${h}:${String(m).padStart(2, \"0\")}${ampm}`;\n}\n\nexport function tzAbbreviation(timezone: string): string {\n const parts = new Intl.DateTimeFormat(\"en-US\", { timeZone: timezone, timeZoneName: \"short\" })\n .formatToParts(new Date());\n const raw = parts.find((p) => p.type === \"timeZoneName\")?.value ?? \"\";\n const m = raw.match(/^([A-Z])[DS]T$/); // PDT/PST -> PT, EDT/EST -> ET ...\n if (m) return `${m[1]}T`;\n const m2 = raw.match(/^([A-Z]{2,3})[DS]T$/); // AKDT -> AKT, HST -> HT\n if (m2) return `${m2[1]}T`;\n return raw;\n}\n\nexport function weekdayOf(date: string, timezone: string): string {\n return new Intl.DateTimeFormat(\"en-US\", { timeZone: timezone, weekday: \"long\" })\n .format(new Date(`${date}T12:00:00Z`));\n}\n\n// ISO start-time for an arbitrary prospect-local date+time with the correct\n// UTC offset for THAT date in that zone (DST-aware). Used for out-of-window\n// direct bookings, where no free-slots string exists to copy from.\nexport function isoForLocal(date: string, minutes: number, timezone: string): string {\n const probe = new Date(`${date}T12:00:00Z`);\n const raw = new Intl.DateTimeFormat(\"en-US\", { timeZone: timezone, timeZoneName: \"longOffset\" })\n .formatToParts(probe).find((p) => p.type === \"timeZoneName\")?.value ?? \"GMT+00:00\";\n const offset = raw === \"GMT\" ? \"+00:00\" : raw.replace(\"GMT\", \"\");\n const h = String(Math.floor(minutes / 60)).padStart(2, \"0\");\n const m = String(minutes % 60).padStart(2, \"0\");\n return `${date}T${h}:${m}:00${offset}`;\n}\n\nfunction isWeekend(date: string): boolean {\n const wd = weekdayOf(date, \"UTC\");\n return wd === \"Saturday\" || wd === \"Sunday\";\n}\n\n// Prospect-local \"now\" as {date, minutes}.\nexport function localNow(timezone: string): { date: string; minutes: number } {\n const s = new Date().toLocaleString(\"sv-SE\", { timeZone: timezone }); // \"YYYY-MM-DD HH:mm:ss\"\n return { date: s.slice(0, 10), minutes: parseInt(s.slice(11, 13), 10) * 60 + parseInt(s.slice(14, 16), 10) };\n}\n\n// ---------- slot lookup ----------\n\nexport type SlotsByDay = Record; // date -> ISO slots (prospect tz)\n\nexport async function loadSlots(timezone: string): Promise {\n return await fetchFreeSlots(6, timezone);\n}\n\nexport function findExactSlot(slots: SlotsByDay, date: string, minutes: number): string | null {\n return (slots[date] ?? []).find((s) => slotMinutes(s) === minutes) ?? null;\n}\n\n// Nearest available slot to a target time on a date, ON the 30-min grid,\n// later preferred on ties and generally (10:00 taken -> 10:30 before 9:30).\nexport function nearestSlot(slots: SlotsByDay, date: string, target: number): string | null {\n const candidates = (slots[date] ?? []).filter((s) => slotMinutes(s) % 30 === 0);\n if (!candidates.length) return null;\n let best: string | null = null;\n let bestScore = Infinity;\n for (const s of candidates) {\n const diff = slotMinutes(s) - target;\n // distance dominates; earlier slots get a half-step penalty so the later\n // of two equidistant options always wins\n const score = Math.abs(diff) * 2 + (diff < 0 ? 1 : 0);\n if (score < bestScore) {\n bestScore = score;\n best = s;\n }\n }\n return best;\n}\n\n// An available ideal-window time on a date, excluding times already used and\n// preferring spread: if the day's existing pick is in the morning, prefer an\n// afternoon ideal and vice versa.\nexport function idealSlot(\n slots: SlotsByDay,\n date: string,\n usedMinutes: number[],\n): string | null {\n const anchor = usedMinutes.length ? usedMinutes[usedMinutes.length - 1] : null;\n const order = [...IDEAL_MINUTES].sort((a, b) => {\n if (anchor === null) return a - b;\n return Math.abs(b - anchor) - Math.abs(a - anchor); // farthest from anchor first\n });\n for (const target of order) {\n // exact ideal time, else its nearest 30-min neighbor\n const s = findExactSlot(slots, date, target) ?? nearestSlot(slots, date, target);\n if (s && !usedMinutes.includes(slotMinutes(s))) return s;\n }\n return null;\n}\n\n// Next N business dates strictly after `fromDate` (and never before `minDate`,\n// the prospect's stated availability floor, e.g. \"next week\") that have slots.\nfunction nextBusinessDates(slots: SlotsByDay, fromDate: string, n: number, minDate = \"\"): string[] {\n const dates = Object.keys(slots)\n .filter((d) => d > fromDate && d >= minDate && !isWeekend(d))\n .sort();\n return dates.slice(0, n);\n}\n\nfunction buildDay(slots: SlotsByDay, timezone: string, date: string, isoTimes: string[]): DayOptions {\n const uniq = [...new Set(isoTimes)];\n const labels = uniq.map((s) => minutesToLabel(slotMinutes(s)));\n const slotIso: Record = {};\n uniq.forEach((s, i) => (slotIso[labels[i]] = s));\n return { date, weekday: weekdayOf(date, timezone), times: labels, slotIso };\n}\n\n// ---------- the two proposal shapes ----------\n\n// Scenario 2: interested, no time given. Before 10:00 their time -> same day at\n// 3pm + two business days (10a/1p then 12p/4p shapes via ideal windows).\n// Otherwise two business days x two times. `minDate` floors every proposal to\n// the prospect's stated window (\"some time next week\").\nexport function standardProposal(slots: SlotsByDay, timezone: string, minDate = \"\"): ProposalMenu {\n const now = localNow(timezone);\n const days: DayOptions[] = [];\n\n if (now.minutes < 10 * 60 && !isWeekend(now.date) && now.date >= minDate) {\n const s = findExactSlot(slots, now.date, SAME_DAY_MINUTES) ??\n nearestSlot(slots, now.date, SAME_DAY_MINUTES);\n if (s) days.push(buildDay(slots, timezone, now.date, [s]));\n }\n\n const PREFERRED: number[][] = [[10 * 60, 13 * 60], [12 * 60, 16 * 60]]; // day1: 10a/1p, day2: 12p/4p\n let dayIdx = 0;\n for (const date of nextBusinessDates(slots, now.date, 2, minDate)) {\n const targets = PREFERRED[Math.min(dayIdx, 1)];\n dayIdx++;\n const picked: string[] = [];\n for (const t of targets) {\n const s = findExactSlot(slots, date, t) ?? nearestSlot(slots, date, t);\n if (s && !picked.includes(s)) picked.push(s);\n }\n if (picked.length) days.push(buildDay(slots, timezone, date, picked));\n }\n\n return { timezone, tzAbbr: tzAbbreviation(timezone), days };\n}\n\n// Scenario 1 counter: their proposed date+time wasn't bookable. Proposed day at\n// nearest alternative, then two more days at their-time-if-free (else nearest)\n// plus an alternate ideal for spread. Weekend proposed date is honored for its\n// own day (they picked it) but follow-up days are business days.\nexport function counterProposal(\n slots: SlotsByDay,\n timezone: string,\n proposedDate: string,\n proposedMinutes: number,\n): ProposalMenu {\n const days: DayOptions[] = [];\n\n const near = nearestSlot(slots, proposedDate, proposedMinutes);\n if (near) {\n const ideal = idealSlot(slots, proposedDate, [slotMinutes(near)]);\n days.push(buildDay(slots, timezone, proposedDate, ideal ? [near, ideal] : [near]));\n }\n\n for (const date of nextBusinessDates(slots, proposedDate, 2)) {\n const first = findExactSlot(slots, date, proposedMinutes) ??\n nearestSlot(slots, date, proposedMinutes);\n if (!first) continue;\n const ideal = idealSlot(slots, date, [slotMinutes(first)]);\n days.push(buildDay(slots, timezone, date, ideal ? [first, ideal] : [first]));\n }\n\n return { timezone, tzAbbr: tzAbbreviation(timezone), days };\n}\n\n// Vague window (\"Tuesday?\", \"tomorrow afternoon\"): two available times inside\n// the window, spread apart. window: [startMinutes, endMinutes].\nexport function windowProposal(\n slots: SlotsByDay,\n timezone: string,\n date: string,\n window: [number, number],\n): ProposalMenu {\n const inWindow = (slots[date] ?? []).filter((s) => {\n const m = slotMinutes(s);\n return m >= window[0] && m <= window[1] && m % 30 === 0;\n });\n const days: DayOptions[] = [];\n if (inWindow.length) {\n const picks = inWindow.length > 1 ? [inWindow[0], inWindow[inWindow.length - 1]] : [inWindow[0]];\n days.push(buildDay(slots, timezone, date, picks));\n }\n return { timezone, tzAbbr: tzAbbreviation(timezone), days };\n}\n\n// Render a menu for the drafting prompt: verified times the model may use, and\n// nothing else.\nexport function menuForPrompt(menu: ProposalMenu): string {\n if (!menu.days.length) return \"(no verified times available - offer the calendar link only)\";\n return menu.days\n .map((d) => `${d.weekday} (${d.date}): ${d.times.map((t) => `${t} ${menu.tzAbbr}`).join(\" or \")}`)\n .join(\"\\n\");\n}\n",[147],"9d5a5aff-9e58-43ac-9f42-85a8b9e95ca0","reconcile-cron.ts","a6a40df4-80bc-11f1-9084-1607ee4eb77e",54,["D",1784168316285],"interval","// Interval val: precision backstop for time-sensitive CRM work - scheduled\n// reminder emails (checkDueEmails) and the calendar/pipeline reconciler.\n// The same checks piggyback on webhook traffic; this val guarantees they run\n// even in quiet periods. SCHEDULE IS SET IN THE VAL.TOWN DASHBOARD (this\n// file just needs \"every 15 min\" or faster - it's cheap and idempotent).\nimport { checkDueEmails, reconcile } from \"./crm.ts\";\n\nexport default async function () {\n const dryRun = (Deno.env.get(\"DRY_RUN\") ?? \"true\") !== \"false\";\n console.log(\"cron emails:\", await checkDueEmails(dryRun).catch((e) => String(e)));\n console.log(\"cron reconcile:\", await reconcile(dryRun).catch((e) => String(e)));\n}\n",[156],"f0992b31-4bfd-4d67-8fed-e665f4fb4bda","playbook.ts","a62caf46-7a9c-11f1-b4fc-1607ee4eb77e",42,["D",1784159053067],12,"// AUTO-GENERATED by scripts/deploy.py from skill/*.md - do not edit here.\nexport const PLAYBOOK = \"\\n# Voice & Style (derived from templates.md + swipefile.md, 2026-07-14)\\n\\nSource of truth: templates.md and swipefile.md - Sam's real, tested replies.\\nEverything here is distilled FROM those two files; when in doubt, reread them and\\nmatch. This replaces all older style guidance - including the 2026-07-08\\n\\\"educate them a little\\\" doctrine. Nobody wants to read a blocky three-paragraph\\nresponse: replies are SHORT, straight to the point, simple sentence structures.\\n\\n## The response shape (every positive reply follows it)\\n\\n1. **Greeting**: \\\"Hey,\\\" - with their name if it's in their reply or signature\\n (\\\"Hey Monica,\\\" / \\\"Hey Dr. Song,\\\"). Then a short remark that fits the thread:\\n \\\"great to hear!\\\" / \\\"totally fair question.\\\" / \\\"good question.\\\" / \\\"of course.\\\" /\\n \\\"happy to answer your questions.\\\" / \\\"thanks for getting back to me.\\\"\\n2. **Answer their question(s) directly** - short, plain terms, simple sentences,\\n one idea per paragraph, from facts.md. The new templates are the target\\n length; never pad an answer to seem thorough.\\n3. **Work the free campaign in** - it's the answer to almost every worry:\\n \\\"you get the same fully-managed service we provide to our ongoing clients -\\n the only difference is that we waive our service fee entirely, so you only\\n cover the ad costs directly paid to Meta.\\\"\\n4. **Only after answering, pivot to the CTA**: \\\"Let's do a quick call so we can\\n give you a rundown of the free campaign, what results you can expect, and\\n get the info we need to get your campaign live.\\\" Adapt the lead-in to the\\n thread (\\\"As for the call, ...\\\" if they asked for one; \\\"During the call,\\n I'll...\\\" if they already agreed to book). Never attach a duration to the\\n call - \\\"quick\\\" is the whole promise (the old \\\"15-minute\\\" is retired\\n 2026-07-15).\\n5. **Times + phone ask + calendar**: propose the verified times by day (\\\"How\\n about Friday at 10am or 1pm ET, or Monday at 12pm or 4pm ET?\\\"), weekday\\n names never \\\"today\\\"/\\\"tomorrow\\\", always the prospect's timezone label. When\\n the drafting instructions call for it (first reply, no number of theirs in\\n hand), the phone-ask line follows on its own line: \\\"And what's the best\\n number to reach you at?\\\" Then the calendar line: \\\"Or if it's easier, here's\\n our calendar: [link]\\\".\\n6. **Sign-off**: \\\"Thanks,\\\" on its own line, then the sender persona's first name\\n (the pen name on the sending account - NEVER any other name), then exactly\\n one signature line:\\n SDR, Lumina\\n No website in the signature (removed 2026-07-14, tentative). The signature\\n goes on EVERY reply we send, before any P.S. line.\\n7. **P.S.**: at most one, ONLY the two situations in templates.md (just booked\\n them in / first time offering times to a fully-interested reply). Everything\\n else gets NO P.S. - the old \\\"not a sales call\\\" P.S. is retired.\\n\\n## Back-and-forth mode (any reply after our first)\\n\\nOnce we're trading messages about times, drop the full template structure - it\\nreads automated if every email has the same skeleton. Go short and loose,\\none-liner-ish: \\\"Hey - I've got another call at 2pm, how about Thursday at 2pm or\\n4pm ET? Here's the calendar if easier: [link]\\\". Same voice, same verified-times\\nrule, no repeated P.S. boilerplate.\\n\\nCorollary: read the whole thread every time, and never let two of our messages\\nin one thread share the same skeleton (greeting shape, paragraph order, CTA\\nphrasing). Vary structure as you go - naturally, and always short.\\nSign-offs: \\\"Thanks,\\\" normally; \\\"Take care,\\\" on reschedule/cancel replies.\\nThe signature (persona name, then \\\"SDR, Lumina\\\") stays on every message, even\\nthe short loose ones - a repeated signature is normal email behavior and does\\nNOT count as a repeated skeleton.\\n\\n## Tone rules\\n\\n- **Short and direct.** Simple sentence structures, one idea per paragraph.\\n Every sentence either answers something, disarms a concern, or moves to the\\n CTA - anything else gets cut. When a template covers it, the template IS the\\n right length.\\n- **Plain natural human language.** Write like Sam texts a colleague: \\\"Hey -\\n works for me!\\\", \\\"totally fair question\\\", \\\"you pay nothing upfront\\\". A busy\\n dentist gets it on the first read. No jargon, no ad-tech vocabulary.\\n- **Warm, confident, zero pressure.** The free campaign carries the sale; the\\n reply never pushes. \\\"before you decide if you want to continue.\\\"\\n- **Empathy for skepticism**: \\\"I'm guessing you've been burned by other\\n marketers before\\\" - name the fear, then answer it with results-first.\\n- **Money is discussed plainly - but never volunteered.** \\\"$497/month or\\n $2,197 for six months paid upfront - that's 25% off, about 6 weeks free.\\\"\\n The recommended ad budget (around {CURRENCY}500 to Meta) is ONLY for\\n explicit ad-spend/budget questions (reverted 2026-07-15) - the fee-waiver\\n line stays number-free.\\n- **Zero friction between a positive reply and a booked call.** Never\\n volunteer numbers, durations, or commitments they didn't ask about - each\\n one is a fresh reason to pause. The goal of every reply is getting them\\n face-to-face on a call (or their phone number); details can live there.\\n- **Consistency bias**: when they asked for something (a call, a booking), remind\\n them: \\\"As for the call, ...\\\".\\n- **Match their energy - and the cold email's CTA.** The cold email now ends\\n with \\\"want to hear/learn more?\\\", so a bare \\\"Yes\\\" / \\\"Yeah sure\\\" means \\\"tell me\\n more\\\" - it gets the Tell Me More template, not a bare ask-for-call. An\\n explicit \\\"schedule the call\\\" gets the short Interested/Ask for Call shape.\\n\\n## Mechanics\\n\\n- PLAIN TEXT only - no HTML tags, no markdown. Real line breaks: blank line\\n between paragraphs; \\\"Thanks,\\\" on its own line, name on the next, then\\n \\\"SDR, Lumina\\\" on the next - no blank lines inside the block.\\n- Simple \\\"- \\\" bullet lists are fine where a template uses them (the Process\\n template) - they're in Sam's tested copy. Don't add bullets elsewhere.\\n- Links are bare URLs pasted inline (calendar), except the website in body\\n copy, which is written exactly \\\"luminamg.com\\\" - no https://, no trailing\\n slash (the send layer hyperlinks it automatically).\\n- Never output an em-dash or en-dash character; use \\\" - \\\" (or \\\"--\\\" like Sam\\n occasionally does).\\n- \\\":)\\\" is fine where Sam's copy uses it. Don't add emoji anywhere else.\\n- No corporate stiffness (\\\"I hope this finds you well\\\", \\\"at your convenience\\\",\\n \\\"rest assured\\\", \\\"Furthermore/Moreover/Additionally\\\").\\n- Prefer the templates' exact sentences over paraphrasing them - they're tested\\n copy. Adapt only the seams (greeting, transitions, what fits the thread and the\\n first cold email's framing) - but never force a template onto a reply it\\n doesn't fit.\\n\\n\\n\\n# Reply Templates (source of truth, together with swipefile.md)\\n\\nThese templates are Sam's tested copy (2026-07-14 shortened rewrite). They\\noverride every older instruction. Bodies are PLAIN TEXT with real line breaks\\n(see voice.md). Replies are SHORT and straight to the point - simple sentence\\nstructures, no three-paragraph walls. The initial cold email now ends with a\\n\\\"{Like to|Want to|Wanna} {hear|learn} more?\\\" CTA, so many replies are a bare\\n\\\"Yes\\\"/\\\"Sure\\\" - those get the Tell Me More template.\\n\\n{SENDER_FIRST_NAME} = the sender persona's first name (the pen name on the account\\nthat sent the campaign - Tiffany, Christina, etc. NEVER any other name).\\n{LENGTH_OF_CAMPAIGN} = the free-campaign duration promised in the FIRST email we\\nsent in that thread (MIRROR RULE in facts.md - never invent one).\\n{CURRENCY} = the prospect's local currency symbol. \\\"$\\\" by default and whenever\\nunsure; only switch (e.g. \\\"\\u00a3\\\") when the thread/lead is clearly outside the US.\\nCALENDAR = https://links.luminamg.com/widget/booking/1nbt58J9c0CBZFyqCBQk\\n\\n## Signature rule (applies to EVERY reply, no exceptions)\\n\\nEvery reply ends with the sign-off followed by this exact one-line signature,\\ndirectly under the persona's first name (before any P.S. line):\\n\\nThanks,\\n{SENDER_FIRST_NAME}\\nSDR, Lumina\\n\\nPlain text. It appears on every single reply - full templates, short\\nback-and-forth one-liners, and quick acks alike. The website does NOT go in the\\nsignature (removed 2026-07-14, tentative - Sam is reworking the site). Website\\nmentions in template BODIES (\\\"You can find us at luminamg.com.\\\") stay - the\\nsend layer hyperlinks them automatically.\\n\\n## Greeting rule (applies to every template)\\n\\nIf the prospect's name is in their reply or signature, greet them with it:\\n\\\"Hey Monica,\\\" / \\\"Hey Dr. Song,\\\" - otherwise just \\\"Hey,\\\". Then a short remark that\\nfits the thread: \\\"great to hear!\\\", \\\"totally fair question.\\\", \\\"good question.\\\",\\n\\\"of course.\\\", \\\"happy to answer your questions.\\\", \\\"thanks for getting back to me.\\\"\\n\\n## Proposing times (live GHL calendar integration)\\n\\nThe times in these templates ({X_DAY} at {TIME_1}...) are REAL: the system\\nchecks the live calendar and hands the draft a VERIFIED TIMES list. Rules:\\n- Only ever mention times from that verified list - never invent or shift one.\\n- Times are in the PROSPECT's timezone with the label (\\\"10am ET\\\").\\n- Use weekday names, never \\\"today\\\"/\\\"tomorrow\\\" (\\\"Friday at 10am or 1pm ET\\\").\\n- Standard shape: two days x two times. If their reply landed before 10am their\\n time, a same-day 3pm option leads and it becomes three days / five times.\\n- Proposals stick to business days (booking a weekend THEY asked for is fine).\\n- If the verified list is empty (calendar unreachable), offer no times - just\\n the calendar link line.\\n\\n## P.S. lines (at most one, ONLY these two situations)\\n\\n- We just booked them in: \\\"P.S. If there's a better email for this, just let me\\n know and I'll send the invite there instead.\\\"\\n- First time offering times to a fully-interested reply: \\\"P.S. If those times\\n don't work for you - feel free to send over your calendar link or some times\\n that work for you\\\"\\n- EVERYTHING ELSE: no P.S. at all. The old \\\"This isn't a sales call and you pay\\n nothing upfront :)\\\" P.S. is RETIRED - never use it.\\n\\n## The phone-ask line (2026-07-15)\\n\\n\\\"And what's the best number to reach you at?\\\" - getting their number is a big\\ndeal (a call converts far better than email). It sits on its own line between\\nthe proposed-times question and the calendar-link line. Include it ONLY when\\nthe drafting instructions say so: the system asks for it on the FIRST reply to\\na positive prospect whose reply doesn't already contain a number. Never in\\nfollow-ups down the thread, never in PMoC/referral/booked/reschedule/cancel\\nreplies, and never re-ask once asked.\\n\\n## The standard CTA block (referenced below as [CTA BLOCK])\\n\\nLet's do a quick call so we can give you a rundown of the free campaign, what results you can expect, and get the info we need to get your campaign live.\\n\\nHow about {X_DAY} at {TIME_1} or {TIME_2} or {Y_DAY} at {TIME_3} or {TIME_4}?\\n\\nAnd what's the best number to reach you at? <- only when instructed (phone-ask rule above)\\n\\nOr if it's easier, here's our calendar: CALENDAR\\n\\nThanks,\\n{SENDER_FIRST_NAME}\\nSDR, Lumina\\n\\n---\\n\\n## Generic (positive reply that doesn't map onto a template)\\n\\nUse the following structure:\\n\\nHey, [remark that makes sense given the thread]\\n\\n[answer their question(s) directly - short, plain terms, simple sentences;\\npull claims from facts.md only. Point to the free campaign where it helps:\\nthey see exactly what working with us looks like before paying us anything.]\\n\\nOnly after answering their questions, pivot to the CTA:\\n\\n[CTA BLOCK]\\n\\nNote: the justification for the call may change depending on earlier replies.\\n\\n---\\n\\n## Interested (they clearly want the call/booking)\\n\\nUse ONLY when they clearly ask to talk/book (\\\"schedule the call\\\", \\\"sure, let's\\nset something up\\\"). A bare \\\"Yes\\\"/\\\"Sure\\\" answering the cold email's\\n\\\"want to hear more?\\\" CTA is NOT this - that gets Tell Me More below.\\n\\nHey, great to hear!\\n\\n[CTA BLOCK]\\n\\n---\\n\\n## Tell Me More / Company Details\\n\\nThe default reply when they answer the cold email's \\\"hear/learn more?\\\" CTA with\\n\\\"Yes\\\" / \\\"Sure\\\" / \\\"send me more info\\\", ask what we do, or ask who we are.\\n\\nHey, of course.\\n\\nWe're Lumina. You can find us at luminamg.com.\\n\\nWe help dental clinics build a steady pipeline of high-ticket treatments with Meta ads.\\n\\nFor your first {LENGTH_OF_CAMPAIGN}, you get the same fully-managed service we provide to our ongoing clients. The only difference is that we waive our service fee entirely, so you only cover the ad costs directly paid to Meta.\\n\\n[CTA BLOCK]\\n\\n---\\n\\n## Need More Info: Process (they ask how it works / what we actually do)\\n\\nHey, of course!\\n\\nDuring your first {LENGTH_OF_CAMPAIGN} with us, here's what we do.\\n\\n- Produce 25 to 30 high-performing ads\\n- Build a landing page funnel that filters out junk leads\\n- Hand you a simple lead management system\\n\\n[CTA BLOCK]\\n\\n---\\n\\n## Need More Info: Price\\n\\nHey, totally fair question.\\n\\nFor your first {LENGTH_OF_CAMPAIGN}, you get the same fully-managed service we provide to our ongoing clients. The only difference is that we waive our service fee entirely, so you only cover the ad costs directly paid to Meta.\\n\\nIf you'd like to continue with us after the pilot campaign, our flagship plan starts at $497/month or $2,197 for six months paid upfront - that's 25% off, about 6 weeks free.\\n\\n[CTA BLOCK]\\n\\n---\\n\\n## Need More Info: Ad Budget (ONLY when they explicitly ask about ad spend/budget)\\n\\nHey, good question.\\n\\nFor your first {LENGTH_OF_CAMPAIGN} with us, we recommend budgeting around {CURRENCY}500 towards Meta ads.\\n\\nAt that level of spend, you can expect 2-3 patients showing up to their appointments. We can talk about scaling spend after the free campaign.\\n\\n[CTA BLOCK]\\n\\n---\\n\\n## Need More Info: Too Good to Be True (skepticism, \\\"what's the angle\\\", \\\"how do you profit\\\")\\n\\nHey, totally fair question.\\n\\nIt does sound too good to be true.\\n\\nI'm guessing you've been burned by other marketers before, so we'd rather get you results before you decide if you want to continue.\\n\\nIf you'd like to continue with us after the pilot campaign, our flagship plan starts at $497/month or $2,197 for six months paid upfront - that's 25% off, about 6 weeks free.\\n\\nFor us, it's a chance to get our foot in the door and onboard a practice that stays with us for years.\\n\\n[CTA BLOCK]\\n\\n---\\n\\n## Ask for Call\\n\\nHow about {X_DAY} at {TIME_1} or {TIME_2} or {Y_DAY} at {TIME_3} or {TIME_4}?\\n\\nAnd what's the best number to reach you at? <- only when instructed (phone-ask rule above)\\n\\nOr if it's easier, here's our calendar: CALENDAR\\n\\nThanks,\\n{SENDER_FIRST_NAME}\\nSDR, Lumina\\n\\n---\\n\\n## Ask for Call + Proposed Time (their time was open - the system already booked it)\\n\\nHey - works for me! Just sent you a calendar invite for {PROPOSED_TIME}. Excited to connect with you.\\n\\nThanks,\\n{SENDER_FIRST_NAME}\\nSDR, Lumina\\n\\nP.S. If there's a better email for this, just let me know and I'll send the invite there instead.\\n\\n(If their reply also asked questions, answer them briefly first per the playbook,\\nthen this confirmation. No other times, no calendar link.)\\n\\n---\\n\\n## IF SLOT ISN'T OPEN (their proposed time is taken)\\n\\nHey - I've got another call at {PROPOSED_TIME}. How about {PROPOSED_DAY} at {NEAREST_AVAILABLE_TIME}, {PROPOSED_DAY_AFTER} at {PROPOSED_TIME / NEAREST_AVAILABLE_TIME} or {ALTERNATE_TIME}, or {PROPOSED_DAY_AFTER_THAT} at {PROPOSED_TIME / NEAREST_AVAILABLE_TIME} or {ALTERNATE_TIME}.\\n\\nAnd what's the best number to reach you at? <- only when instructed (phone-ask rule above)\\n\\nOr if it's easier, here's our calendar: CALENDAR\\n\\nThanks,\\n{SENDER_FIRST_NAME}\\nSDR, Lumina\\n\\nP.S. If those times don't work for you - feel free to send over your calendar link or some times that work for you\\n\\n(All times come from the verified list: their day at the nearest open slot, then\\nthe next two days at their proposed time when it's free - if it worked for one\\nday it probably works the next - plus an alternate ideal time for spread.\\nAdapt the opener naturally if they asked for a window rather than a clock time.)\\n\\n---\\n\\n## Already booked (they self-booked or say they did)\\n\\nOne short, warm line confirming you saw it and you're looking forward to the\\ncall - e.g. \\\"Hey, saw the booking come through - talk then!\\\" adapted to the\\nthread. No times, no calendar link, no pitch, no P.S. - but still the sign-off\\nand signature block per the signature rule.\\n(If they say they already RESCHEDULED themselves: no reply at all - the\\nconfirmation flow covers them.)\\n\\n---\\n\\n## Written Reschedule Request (they ask to move the call, no new time named)\\n\\nThe system keeps their current appointment until a new time is agreed. Propose\\nverified times:\\n\\nHey,\\n\\nNo worries at all - happy to reschedule. Does {X_DAY} at {TIME_1} or {TIME_2} or {Y_DAY} at {TIME_3} or {TIME_4} work for you instead?\\n\\nAlternatively, have your pick at any available time on our calendar: CALENDAR\\n\\nFeel free to reach out if those times don't work and we can work something out.\\n\\nTake care,\\n{SENDER_FIRST_NAME}\\nSDR, Lumina\\n\\n(When they DO name a new open time, the system moves the appointment on the\\nspot - send only a quick, courteous, brief confirmation: \\\"No worries at all -\\njust moved us to {NEW_TIME}. Talk then!\\\" No times, no calendar link.)\\n\\n---\\n\\n## Written Cancellation Request (they ask to cancel)\\n\\nThe system cancels the appointment immediately - then this reply tries to save\\nthe meeting:\\n\\nHey,\\n\\nNo worries at all. Would {X_DAY} at {TIME_1} or {TIME_2} or {Y_DAY} at {TIME_3} or {TIME_4} work for you instead?\\n\\nAlternatively, have your pick at any available time on our calendar: CALENDAR\\n\\nLet me know if you have any questions or concerns.\\n\\nTake care,\\n{SENDER_FIRST_NAME}\\nSDR, Lumina\\n\\n(If their message is clearly final - firmly out, unhappy - skip the times and\\nthe calendar entirely: just a warm, brief, door-open close.)\\n\\n---\\n\\n## Preferred Method of Communication (PMoC)\\n\\nThey give a phone number or a preferred channel (text, call, WhatsApp). The agent\\nsends this short acknowledgment - nothing else, no links - and Sam gets an alert\\nwith the details so he does the actual texting/calling:\\n\\nHey, sounds good! Expect a {PMoC} from our founder Sam (his number is 925-730-9373) {TIMING}.\\n\\nThanks,\\n{SENDER_FIRST_NAME}\\nSDR, Lumina\\n\\n({PMoC} = \\\"text\\\" / \\\"call\\\" / whatever channel they asked for.\\n{TIMING}: MIRROR any timing they stated - if they said \\\"Friday afternoon\\\", write\\n\\\"to set up a time to talk Friday afternoon\\\". Only say \\\"later today\\\" when they\\ngave no timing at all. NEVER contradict their stated availability - a reply\\nthat ignores what they just told you loses the meeting.\\nA reply that mixes PMoC with a meeting request is still PMoC: acknowledge,\\nnever book over email - Sam sets the time up over text/call.)\\n\\n---\\n\\n## Wrong Person (referral)\\n\\n[IF NEW PROSPECT CONTACT ISN'T PROVIDED - the agent sends this reply itself]\\n\\nHey {INITIAL_PROSPECT_NAME}, thanks for pointing me in the right direction. What's {NEW_PROSPECT_NAME}'s best email so I can send them the details?\\n\\nThanks,\\n{SENDER_FIRST_NAME}\\nSDR, Lumina\\n\\n[TO NEW PROSPECT - INTERIM: the agent DRAFTS this but Sam sends it (sending to a\\nbrand-new address isn't wired up yet). The finished draft goes in Sam's alert.]\\n\\nHey {NEW_PROSPECT_NAME}, got in touch with {INITIAL_PROSPECT_NAME} and they told me that you're the right person to talk to about this.\\n\\nTLDR: We help dental clinics build a steady pipeline of high-ticket treatments with Meta ads, and it all starts with a free {LENGTH_OF_CAMPAIGN} campaign so you can see exactly what working with us looks like before paying us a cent.\\n\\n[CTA BLOCK]\\n\\n---\\n\\n## Anti-robotic rule (applies to the whole thread)\\n\\nAlways read the entire thread before drafting. Templates fit ~95% of replies,\\nbut never send a message that mirrors the structure of an earlier one in the\\nsame thread - same greeting shape, same paragraph order, same CTA phrasing\\nreads as a bot. Vary the opener, merge or reorder paragraphs, tighten the\\nlength as the thread deepens. And never box yourself into a template that\\ndoesn't fit what they actually said - when no template fits where the thread\\nhas gone, compose short and direct from voice.md + facts.md instead of\\nforcing one.\\n\\n\\n\\n# Canonical Facts (single source of truth, 2026-07-08 rewrite)\\n\\nAnswer questions from this file (and mechanism.md for how-it-works depth). If\\nthese facts conflict with anything in mechanism.md, THIS file wins.\\n\\n**Missing-info policy (changed 2026-07-08):** if we don't have the exact thing\\nthey asked for, that's fine - say so simply if needed, give the best adjacent info\\nwe DO have (what we do, the free campaign, pricing, website), and redirect to the\\ncall. Escalate (answerable=false) ONLY for genuine edge cases the playbook can't\\ntouch at all - not merely because one of their questions has no exact answer here.\\n\\n## The offer\\n\\n- We help dental clinics build a steady pipeline of high-ticket treatments with\\n Meta ads (Facebook/Instagram ONLY - no Google or other platforms).\\n- The cold email pitched a specialty-specific front-end (veneers, Invisalign,\\n implants, etc.). On the back end we bring patients for a variety of treatments.\\n- **Free first campaign (THE hook - work it into every info answer).** For their\\n first {LENGTH_OF_CAMPAIGN} they get the same fully-managed service as our\\n ongoing clients - the only difference is we waive our service fee entirely, so\\n they only cover the ad costs paid directly to Meta.\\n What we do during it: produce 25 to 30 high-performing ads,\\n build a landing page funnel that filters out junk leads, and hand them a\\n simple lead management system.\\n The cold emails are spintax, so each prospect was promised slightly different\\n wording: maybe \\\"2 weeks\\\", \\\"14 days\\\", \\\"10 days\\\", or just \\\"a pilot at no charge\\\",\\n possibly with a patient-count claim.\\n **MIRROR RULE: the first email we sent in THAT thread is the source of truth\\n for {LENGTH_OF_CAMPAIGN} and any patient-count promise.** If the first email\\n isn't available, say \\\"the free campaign\\\" with NO duration or numbers.\\n- The only thing we ask in return (the cold email P.S.): an honest video\\n testimonial if we deliver. Use this when they ask \\\"what's the catch?\\\".\\n\\n## Pricing (quote these plainly - no dancing around price)\\n\\n- **Paid package: Dental Growth Flagship - $497/month, or $2,197 for six months\\n paid upfront (that's 25% off - about 6 weeks free).** Lead with the monthly\\n number; the 6-month upfront is the discount option.\\n- Always frame it: our service fee is fully waived for the first campaign - they\\n only cover ad costs paid directly to Meta; they see exactly what working with\\n us looks like first, then decide.\\n- Month-to-month on the monthly plan; no long-term contract.\\n- Ad budget (reverted 2026-07-15 - ask-only again): the recommended\\n ~{CURRENCY}500 is NEVER volunteered - not in the fee-waiver copy, not in\\n price answers (the 2026-07-14 volunteering experiment is dead; volunteered\\n numbers add friction). It comes up ONLY when they explicitly ask about ad\\n spend/budget (the Ad Budget template): budget is up to them, paid directly\\n to Meta on their own card, we recommend around {CURRENCY}500 for the free\\n campaign - at that level of spend they can expect 2-3 patients showing up\\n to their appointments, and scaling spend is a conversation for after the\\n free campaign.\\n- No formal guarantee. \\\"What if it doesn't work?\\\" -> the free campaign exists\\n exactly so they can see how we work before paying anything.\\n- INTERNAL - NEVER SAY THIS TO A PROSPECT: free-campaign results tend to be worse\\n than steady-state (fresh ad account, Meta still learning). Don't volunteer it.\\n If pushed hard on exact free-campaign results, stay honest but positive\\n (campaigns get stronger as Meta learns) or escalate.\\n\\n## The call\\n\\n- A **quick Zoom call**: a rundown of the free campaign, what results they can\\n expect, and getting the info we need to create their ads. Never attach a\\n duration to it in copy (\\\"15-minute\\\" retired 2026-07-15 - it's just \\\"a quick\\n call\\\"). If they explicitly ask how long it takes: it's short - we block half\\n an hour on the calendar and often wrap sooner.\\n- Not a sales call - they pay nothing upfront. (Body-copy talking point when\\n they hesitate; the old P.S. line carrying it is retired.)\\n- Calendar link: https://links.luminamg.com/widget/booking/1nbt58J9c0CBZFyqCBQk\\n- The system checks the LIVE calendar: proposed times come from a verified list,\\n and when a prospect's requested time is open, the system books it on the spot\\n and the confirmation/invite emails go out automatically. Never mention a time\\n that isn't in the verified list.\\n\\n## Contact info & resources (what to send, and how eagerly)\\n\\n- **Website: https://luminamg.com/** - share confidently whenever they ask for a\\n website or company info.\\n- **Sam's phone: 925-730-9373** - every PMoC acknowledgment includes it (\\\"our\\n founder Sam (his number is 925-730-9373)\\\"). Outside PMoC, share it only in the\\n rare case they specifically need a number to reach us at. Prefer: give the\\n good info we have, then redirect to what we do / the free campaign / the call.\\n- **No LinkedIn to share.** Say so plainly (\\\"I don't have a LinkedIn to share\\\")\\n and pivot to the website or the call.\\n- **Founder videos (YouTube)** - only for the few cases where someone genuinely\\n wants deep how-it-works detail; most replies should NOT include them:\\n - How we get qualified leads: https://youtu.be/WlAQcaskL28?si=B4DryJm0hvTXYsBr\\n - How we convert leads into patients: https://youtu.be/PvFJuJSNZiI?si=FxUduRVYavk5PpXU\\n - The quantity and types of ads we produce: https://youtu.be/X_Cc8Iy3Hgg?si=xHSPFvrVpWCLuald\\n- General rule: we don't have everything (that's fine) - give what we do have,\\n then redirect their attention to what we do, the free campaign, and the call.\\n\\n## Leads & operations\\n\\n- Leads are exclusive to their practice.\\n- Their front desk calls the leads directly - nothing integrates with their\\n practice software (Dentrix etc.); they book into their own system.\\n- Pricier packages exist where our in-house team dials leads for them (mention\\n only if they ask about follow-up help; details on the call).\\n- To start we need: access to their Facebook page, plus offer specifics agreed\\n during onboarding. Existing social content is nice to have, not required.\\n- Launch: generally within 3 days after onboarding.\\n\\n## Company\\n\\n- Lumina (\\\"Lumina Marketing Group\\\" / LuminaMG), based in California (SF).\\n- In business for 2 years. Team size: stay vague, never give a number.\\n- No case studies or references yet - never claim any. Pivot: the free campaign\\n IS the proof; they see results themselves before paying.\\n\\n## Exclusivity\\n\\n- No formal exclusivity clause, but the positioning is: we don't work with\\n overlapping/competing practices - \\\"we won't step on anyone else's toes.\\\" Say it\\n confidently; never mention the absence of a clause.\\n\\n## \\\"We tried Facebook ads before and it flopped\\\"\\n\\nCommon reasons, and what we do differently: not enough ad creatives (we run 25-30\\ngenuinely different ones), unproven creatives, unqualified leads (we qualify them\\nbefore they book), and missing back-end practices (we hand over follow-up scripts\\nand train the front desk).\\n\\n## Special situations\\n\\n- **They give a phone number / preferred channel (PMoC)**: send the short PMoC\\n acknowledgment from templates.md - it names our founder Sam and his number\\n (925-730-9373) and MIRRORS any timing they stated (never \\\"later today\\\" if they\\n said \\\"Friday afternoon\\\"). Sam is alerted and does the actual texting/calling.\\n Speed matters. A PMoC mixed with a meeting request is still PMoC - never book\\n it over email; Sam sets the time up on their preferred channel.\\n A phone number that merely sits in their SIGNATURE is NOT a PMoC - reply to\\n their message normally (the system separately alerts Sam with the number so\\n he can call them).\\n- **They hand the thread to someone else (referral / wrong person)**: if the new\\n contact's email ISN'T given, the agent replies asking for it (Wrong Person\\n template part 1). If it IS given, the agent drafts the intro to the new person\\n (part 2) and Sam sends it - see templates.md INTERIM note.\\n- **They propose a specific meeting time**: the system checks the calendar and\\n books it if open (they get the invite automatically); if taken, counter with\\n the IF SLOT ISN'T OPEN template.\\n- **They say they booked / a time \\\"works\\\"**: the system checks the calendar for\\n an existing appointment first - if they're already booked, just the short\\n \\\"saw the booking come through\\\" line, never a re-pitch or a double-booking.\\n- **Reply written by an AI assistant** (\\\"Sent from X's AI Assistant\\\", templated\\n auto-responses): never a positive reply - always not_positive, no response.\\n- **\\\"Is this AI?\\\"**: don't answer; escalate. (Prospects realistically never ask.)\\n- **\\\"We already have an agency\\\"** / **\\\"How did you get my email?\\\"**: not_positive,\\n no reply.\\n\\n## FAQ quick answers\\n\\n- Cost? -> first campaign is the same fully-managed service with our fee waived\\n entirely; they only cover ad costs paid directly to Meta (no number unless\\n they ask about ad spend). Continuing afterward: flagship plan starts at\\n $497/month or $2,197 for six months upfront (25% off - about 6 weeks free).\\n- Ad budget? (deeper answer only if THEY brought up ad spend/budget) -> around\\n {CURRENCY}500 to Meta; expect 2-3 patients showing up to their appointments\\n at that spend; scaling is a conversation for after the free campaign.\\n- Too good to be true / what's your angle? -> it does sound that way; they've\\n probably been burned before, so we'd rather get them results before they\\n decide to continue - for us it's a foot in the door and a practice that\\n stays with us for years.\\n- Contract? -> month-to-month.\\n- How fast? -> live within ~3 days of finishing onboarding.\\n- What do you need from us? -> access to your Facebook page and a short\\n onboarding to agree on the offer.\\n- Who talks to the leads? -> your front desk calls them directly (done-for-you\\n dialing packages exist - covered on the call).\\n- Case studies? -> the free campaign is the proof - you see results before paying.\\n- What's the catch? -> an honest video testimonial if we deliver.\\n- Website? -> https://luminamg.com/ (share confidently).\\n- Where are you located? -> California.\\n\\n\\n\\n# Swipe File - Real Replies with Sam's Sample Responses (2026-07-14 rewrite)\\n\\nSource of truth together with templates.md - these override every older\\ninstruction. CONSULT THIS FILE BEFORE EVERY RESPONSE: find the example(s) closest\\nto the prospect's reply and mirror how Sam adapted, blended, and worded the\\ntemplates. Nearly every positive reply is a template used almost verbatim - the\\nchanges are the greeting, the connective tissue, and making it fit the thread and\\nthe first cold email's CTA. But cold email isn't deterministic: when a template\\ntruly doesn't fit what they said, don't box yourself in - adapt (Example 7 shows\\na lost meeting from following a template too closely).\\n\\nPlaceholders ({LENGTH_OF_CAMPAIGN}, {SENDER_FIRST_NAME}, {CURRENCY}, times) and\\nall rules (signature, P.S., verified times) are defined in templates.md.\\n\\n---\\n\\n## Example 1 - bare \\\"Yes\\\" to the cold email's \\\"hear more?\\\" CTA\\n\\nThe cold email ends with \\\"{Like to|Want to|Wanna} {hear|learn} more?\\\" - so a\\nbare \\\"Yes\\\" / \\\"Sure\\\" / \\\"Ok send info\\\" means TELL ME MORE, not \\\"book me\\\".\\n\\nProspect: \\\"Yes\\\"\\n\\nSam's response: the Tell Me More / Company Details template, verbatim:\\n\\n> Hey, of course.\\n>\\n> We're Lumina. You can find us at luminamg.com.\\n>\\n> We help dental clinics build a steady pipeline of high-ticket treatments with Meta ads.\\n>\\n> For your first {LENGTH_OF_CAMPAIGN}, you get the same fully-managed service we provide to our ongoing clients. The only difference is that we waive our service fee entirely, so you only cover the ad costs directly paid to Meta.\\n>\\n> Let's do a quick call so we can give you a rundown of the free campaign, what results you can expect, and get the info we need to get your campaign live.\\n>\\n> [times + calendar CTA]\\n>\\n> Thanks,\\n> {SENDER_FIRST_NAME}\\n> SDR, Lumina\\n\\nNotes: This is now the most common reply shape. They asked to hear more, so tell\\nthem more - short - then pivot to the call.\\n\\n---\\n\\n## Example 2 - string of questions (how, where, cost)\\n\\nProspect: \\\"Thanks Sam\\nhow do you do this, where are you located & how much does it cost?\\\"\\n\\nSam's response (Tell Me More + the Price pricing line, one seam added for\\nlocation):\\n\\n> Hey - happy to answer your questions.\\n>\\n> We're Lumina, based in California. You can find us at luminamg.com.\\n>\\n> We help dental clinics build a steady pipeline of high-ticket treatments with Meta ads.\\n>\\n> For your first {LENGTH_OF_CAMPAIGN}, you get the same fully-managed service we provide to our ongoing clients. The only difference is that we waive our service fee entirely, so you only cover the ad costs directly paid to Meta.\\n>\\n> If you'd like to continue with us after the pilot campaign, our flagship plan starts at $497/month or $2,197 for six months paid upfront - that's 25% off, about 6 weeks free.\\n>\\n> [CTA + times + calendar]\\n>\\n> Thanks,\\n> {SENDER_FIRST_NAME}\\n> SDR, Lumina\\n\\nNotes: Three questions, three short answers, one paragraph each - then the CTA.\\nThe fee-waiver paragraph answers \\\"how much\\\" for the free campaign; the flagship\\nline covers what comes after. No padding.\\n\\n---\\n\\n## Example 3 - pure price question\\n\\nProspect: \\\"Hello Sam, What would the cost be for the below?\\\"\\n\\nSam's response: the \\\"Need More Info: Price\\\" template, copied directly (greeting\\n\\\"Hey, totally fair question.\\\" - fee-waiver paragraph (no ad-spend number since\\n2026-07-15) - flagship pricing line - CTA).\\n\\nNotes: Directly copy and paste the Price template. As always, double check that\\nthe greeting, CTA, and structure make sense given their reply and our CTA in the\\ninitial email.\\n\\n---\\n\\n## Example 4 - referral WITH new contact provided\\n\\nProspect: \\\"Hello Sam,\\nThank you for reaching out to us. We appreciate your offer.\\nFor inquiries regarding marketing opportunities, please directly contact our marketing coordinator, Courtney, at courtney@petitedental.com.\\nBest regards, Monica\\nPetite Dental & Orthodontics\\\"\\n\\nSam's response (to the NEW contact - INTERIM: agent drafts, Sam sends):\\n\\n> Hey Courtney, got in touch with Monica and they told me that you're the right person to talk to about this.\\n>\\n> TLDR: We help dental clinics build a steady pipeline of high-ticket treatments with Meta ads, and it all starts with a free {LENGTH_OF_CAMPAIGN} campaign so you can see exactly what working with us looks like before paying us a cent.\\n>\\n> [CTA + times + calendar]\\n>\\n> Thanks,\\n> {SENDER_FIRST_NAME}\\n> SDR, Lumina\\n\\nNotes: Since the initial prospect gave the contact of the new prospect, directly\\nuse the applicable part of the \\\"Wrong Person\\\" template. The greeting uses the new\\nprospect's name.\\n\\n---\\n\\n## Example 5 - \\\"schedule the call\\\" + cost question (template blend)\\n\\nProspect: \\\"OK , Schedule the call . I need to know : * Estimated cost ? *\\\"\\n\\nSam's response: the \\\"Need More Info: Price\\\" template, but the CTA line becomes:\\n\\n> As for the call, how about {X_DAY} at {TIME_1} or {TIME_2} or {Y_DAY} at {TIME_3} or {TIME_4}?\\n>\\n> And what's the best number to reach you at?\\n>\\n> Or if it's easier, here's our calendar: [calendar]\\n\\nNotes: Mix \\\"Price\\\" and \\\"Ask for Call\\\". Replace the CTA section of \\\"Price\\\" with\\n\\\"Ask for Call\\\" and use language like \\\"As for the call\\\" to remind them that they\\nasked for the call, leveraging consistency bias. The phone-ask line appears\\nbecause this is a first reply and their message had no number (phone-ask rule\\nin templates.md).\\n\\n---\\n\\n## Example 6 - \\\"Sure we can book\\\" (explicit booking interest)\\n\\nSam's response:\\n\\n> Hey, great to hear!\\n>\\n> During the call, I'll give you a rundown of the free campaign, what results you can expect, and get the info we need to get your campaign live.\\n>\\n> [times + calendar CTA]\\n>\\n> Thanks,\\n> {SENDER_FIRST_NAME}\\n> SDR, Lumina\\n\\nNotes: Classic \\\"Interested\\\" reply - they explicitly want to book, so no Tell Me\\nMore needed. Since they said \\\"book\\\", the CTA opens \\\"During the call\\\"\\ninstead of \\\"Let's do a quick call\\\". No P.S. (the old \\\"not a sales\\ncall\\\" P.S. is retired); the first-time-offering-times P.S. may be appended per\\nthe P.S. rules.\\n\\n---\\n\\n## Example 7 - PMoC mixed with a meeting request (the Norton case - REAL, post-mortem)\\n\\nCold email (for context): \\\"Hey Dr. Norton - if I could bring your dental office\\n12-16 patients in 2 weeks on our dime through Meta ads, would that be worth a\\nquick convo? ... p.s. my only ask is an honest video shoutout if I deliver\\\"\\n\\nProspect: \\\"Yes, it would be. Probably have sometime Fri. afternoon but not\\nbefore. 770-401-0102\\\"\\n\\nWHAT THE AGENT SENT (WRONG - this lost the meeting):\\n\\n> Hey Dr. Norton, sounds good! Expect a call from me later today.\\n\\nIt stuck to the old PMoC template verbatim: \\\"later today\\\" directly contradicted\\nthe \\\"Friday afternoon, not before\\\" he had just stated - clearly demonstrating we\\ndidn't listen.\\n\\nSam's sample response (CORRECT - use as the exact reference):\\n\\n> Hey Dr. Norton, sounds good! Expect a few texts from our founder Sam (his number is 925-730-9373) to set up a time to talk Friday afternoon.\\n>\\n> Thanks,\\n> Jennifer\\n> SDR, Lumina\\n\\nTAKEAWAYS:\\n- ALL PMoC acknowledgments include Sam's name and phone number like the above.\\n- MIRROR their stated timing. \\\"Later today\\\" is only for when they gave none.\\n- A PMoC + meeting-request mix is still PMoC: the meeting does NOT get set up\\n over email - acknowledge, and Sam sets it up over text/call (he gets the\\n alert with their number and timing).\\n- You can't stick to templates verbatim in every case. When a reply fits, go\\n 100% template (that's most cases) - but don't box yourself in.\\n\\n---\\n\\n## Example 8 - ad budget question\\n\\nProspect: \\\"Hi Sam,\\nI am open to hearing more! How much should I expect to pay for the ad budget?\\\"\\n\\nSam's response: the \\\"Need More Info: Ad Budget\\\" template:\\n\\n> Hey, good question.\\n>\\n> For your first {LENGTH_OF_CAMPAIGN} with us, we recommend budgeting around {CURRENCY}500 towards Meta ads.\\n>\\n> At that level of spend, you can expect 2-3 patients showing up to their appointments. We can talk about scaling spend after the free campaign.\\n>\\n> [CTA + times + calendar]\\n>\\n> Thanks,\\n> {SENDER_FIRST_NAME}\\n> SDR, Lumina\\n\\nNotes: They explicitly asked about ad budget, so the dedicated template applies -\\nincluding the 2-3 patients expectation. Short answer, no what-we-do padding.\\n\\n---\\n\\n## Example 9 - process + \\\"how do you profit?\\\" (the Macedo case - template blend)\\n\\nProspect: \\\"Hello Abigail, Can you tell me more about your process and how would\\nyou be profiting from this deal?\\nThank you\\\"\\n\\nSam's sample response (blend of \\\"Process\\\" + \\\"Too Good to Be True\\\"):\\n\\n> Hey, totally fair questions.\\n>\\n> During your first {LENGTH_OF_CAMPAIGN} with us, here's what we do free of charge.\\n>\\n> - Produce 25 to 30 high-performing ads\\n> - Build a landing page funnel that filters out junk leads\\n> - Hand you a simple lead management system\\n>\\n> I'm guessing you've been burned by other marketers before, so we'd rather get you results before you decide if you want to continue.\\n>\\n> If you'd like to continue with us after the pilot campaign, our flagship plan starts at $497/month or $2,197 for six months paid upfront - that's 25% off, about 6 weeks free.\\n>\\n> For us, it's a chance to get our foot in the door and onboard a practice that stays with us for years.\\n>\\n> Let's do a quick call so we can give you a rundown of the free campaign, what results you can expect, and get the info we need to create your ads.\\n>\\n> [times + calendar CTA]\\n>\\n> Thanks,\\n> {SENDER_FIRST_NAME}\\n> SDR, Lumina\\n\\nNotes: Two questions, two templates: the Process bullets answer \\\"your process\\\",\\nthe Too Good to Be True paragraphs answer \\\"how do you profit\\\". The AI's earlier\\nattempt at this reply was rejected as WAY too long - it explained the whole\\nfunnel in dense paragraphs and buried the profit answer. Bullets + short\\nparagraphs win.\\n\\n---\\n\\n## Example 10 - \\\"How can we talk?\\\"\\n\\nSam's response:\\n\\n> Hey, thanks for getting back to me.\\n>\\n> We usually do a quick Zoom call so we can give you a rundown of the free campaign, what results you can expect, and get the info we need to get your campaign live.\\n>\\n> [times + calendar CTA]\\n>\\n> Thanks,\\n> {SENDER_FIRST_NAME}\\n> SDR, Lumina\\n\\nNotes: They asked HOW to connect, so answer that directly (\\\"a quick Zoom\\ncall\\\") and go straight to times. No P.S.\\n\\n---\\n\\n## Example 11 - \\\"sam from which company please ?\\\" / website + pricing asks\\n\\nSam's response: the \\\"Tell Me More / Company Details\\\" template verbatim, greeting\\nadapted (\\\"Hey, thanks for getting back to me.\\\"). The \\\"We're Lumina. You can find\\nus at luminamg.com.\\\" line answers who-are-you and website questions in one\\nstroke; if they also asked about pricing, add the flagship pricing line from the\\nPrice template (see Example 2).\\n\\nNotes: Company-info asks, website asks, and generic \\\"more info\\\" asks all land on\\nthe same merged template now.\\n\\n---\\n\\n## Example 12 - reschedule request with a stated window (real, Sam-approved)\\n\\nProspect (they had a booked call; office manager replying):\\n\\n\\\"Hi Kim!\\nI am sorry, I had miscommunication with Dan.\\nWe need to reschedule our appointment for some time next week.\\nWill you please cancel our appointment for tomorrow and send me the link to book for a different time next week. Thank you!\\nWarm Regards,\\nAngela Yeager\\nMarketing Coordinator & Business Team Member | Wynkoop Dentistry\\\"\\n\\nAI draft Sam loved:\\n\\n> Hey Angela,\\n>\\n> No worries at all - happy to reschedule. Here's our calendar so you can grab a time that works next week: https://links.luminamg.com/widget/booking/1nbt58J9c0CBZFyqCBQk\\n>\\n> Thanks,\\n> Kimberly\\n> SDR, Lumina\\n\\nNotes: Short, warm, zero friction - and it MIRRORS THEIR CONSTRAINT (\\\"a time\\nthat works next week\\\"). \\\"Cancel and send the link to book a different time\\\" is\\na RESCHEDULE, not a cancellation. When proposing concrete times for a reply\\nlike this, every offered time must fall inside their stated window (next week\\nmeans nothing this week) - the verified times list is already filtered for\\nthat, and the wording should still echo their constraint like this draft does.\\n\\n---\\n\\n## Corrections log (Sam's feedback on AI drafts - newest first)\\n\\n- 2026-07-15: FRICTION PASS. (1) \\\"15-minute\\\" is DEAD everywhere - it's just \\\"a\\n quick call\\\" / \\\"During the call, I'll...\\\" / \\\"a quick Zoom call\\\". (2) Ad spend\\n is ASK-ONLY again: the \\\"(we recommend budgeting around {CURRENCY}500)\\\"\\n parenthetical is removed from the fee-waiver copy and all templates; the\\n Ad Budget template (explicit ad-spend questions only) keeps it. (3) New\\n phone-ask line \\\"And what's the best number to reach you at?\\\" between the\\n times question and the calendar line - ONLY when the drafting instructions\\n include it (first reply, their message has no number); never on follow-ups.\\n Rationale: strip every turnoff between a positive reply and a booked call,\\n and pry for their number - a phone call is Sam's best-converting channel.\\n- 2026-07-14 (late): WEBSITE REMOVED FROM SIGNATURES (tentative - Sam is\\n reworking the site). Signature is now just persona name + \\\"SDR, Lumina\\\".\\n Website mentions in template BODIES (\\\"You can find us at luminamg.com.\\\")\\n stay.\\n- 2026-07-14: SHORTENED TEMPLATES rewrite (this file + templates.md). Replies\\n were too long - the \\\"educate them\\\" doctrine is dead; short, simple sentences\\n win. The cold email CTA is now \\\"want to hear/learn more?\\\" so bare-\\\"Yes\\\"\\n replies get Tell Me More. Ad spend: {CURRENCY}500 (was $750); the\\n volunteering-in-fee-waiver-copy part of this entry is SUPERSEDED by the\\n 2026-07-15 entry above (ask-only again). The \\\"not a\\n sales call\\\" P.S. is RETIRED - only the booked-invite and first-times P.S.\\n lines survive. PMoC acks name founder Sam + 925-730-9373 and mirror stated\\n timing (see Example 7). New templates: Process, Too Good to Be True.\\n- Still in force from earlier corrections: pricing is $497/month or $2,197 for\\n six months upfront (25% off - about 6 weeks free) - any older number ($749,\\n $1,797, \\\"three months\\\") is DEAD. Times are real (verified against the live\\n calendar) - never invent one. Signature block on every reply. \\\"thanks for\\n getting back to me\\\" is a fine greeting. Sign-off \\\"Thanks,\\\" (\\\"Take care,\\\" on\\n reschedule/cancel). Back-and-forth replies go short and loose instead of\\n re-running a full template.\\n\\n\\n\\n# Mechanism Deep Context (from Sam's founder videos)\\n\\nDistilled from the three YouTube walkthroughs. Use ONLY when a prospect asks a\\nspecific how-does-it-work question that facts.md doesn't cover, and translate to\\nplain, first-read-understandable language - never technical, never jargon. Items\\nmarked \\\"(general context)\\\" are instructional content, not necessarily what we do for\\nevery client. If anything here conflicts with facts.md, facts.md wins (e.g. the\\nvideos mention a \\\"free advisory call\\\" and typical ad spend of $1,500-3,000/mo; the\\ncurrent offer is the free first campaign, then $497/mo or $2,197 for six months\\nupfront (25% off), with around $500 of ad spend recommended during the free\\ncampaign).\\nNEVER dump this wholesale into a reply - pull the one or two ideas that\\nanswer the question, simply. When in doubt, share the right video link in the\\nbody instead of explaining.\\n\\n---\\n\\n## Video 1: How the lead-generation system works (youtu.be/WlAQcaskL28)\\n\\n### The core problem we solve\\nDentists' number-one fear with paid ads is being flooded with junk leads that waste the front desk's and treatment coordinator's time. Our system is built around deliberately making it slightly harder to book - the right amount of \\\"hoops\\\" filters out tire-kickers and price-shoppers while keeping real patients. Too few hoops brings in junk; too many scares off good patients. We aim for the middle.\\n\\n### The mechanism, step by step\\n1. **Ad on Facebook/Instagram** promotes a specific treatment offer (e.g., implants, Invisalign).\\n2. **A dedicated offer page** (not the practice's homepage) built to get one action: request a consult. It includes a short video explaining the treatment, **the price shown up front** (for a $6,000 Invisalign case, price is the top reason deals die - showing it early makes non-buyers remove themselves), financing options (to bring back good patients who just need payment plans), and a clear treatment timeline so people know exactly what they're signing up for.\\n3. **A qualifying questionnaire before anyone can see the calendar.** The booking calendar is treated as sacred - only people who pass budget questions (\\\"Invisalign runs $4,000-$8,000 - does that work?\\\") and health-readiness questions (gum disease, loose teeth, last checkup, how soon they want to start) ever get to book. People who don't qualify are routed to a follow-up sequence - often offered a checkup or a lower-cost treatment first, then brought back to the bigger treatment later.\\n4. **A small refundable deposit to lock the appointment.** Serious patients don't mind (they get it back); non-serious ones won't put a card down. Result: far fewer no-shows and higher treatment acceptance.\\n5. **Teaching Facebook who your best patients are.** Tracking code on the page reports back only *qualified* actions - a qualified lead, a booked consult, a started treatment. Facebook (which holds ~52,000 data points per person) then goes and finds more people like your paying patients, not like your junk leads. When your coordinator moves a patient to \\\"showed up qualified\\\" or \\\"started treatment\\\" in the pipeline, that gets sent back to Facebook automatically, so targeting keeps improving.\\n6. **Fast follow-up:** automated texting contacts new leads within about 60 seconds, while they're still warm.\\n\\n### What we specifically do for clients\\n- We never change a funnel until it has run **at least 3 days and $300 of spend** - enough data for an informed decision, not guesswork.\\n- For new clients (or polluted past data), we start by having Facebook find leads, then step down to optimizing for booked consults, then for started treatments, as data accumulates. If ad costs rise later, we step back up to widen the pool.\\n- We diagnose *where* to add or remove hoops using benchmarks: **1.5-3%** of ad viewers clicking, **5-7%** of visitors booking, **70-80%** showing up, **~30%** starting treatment. Whichever number lags tells us what to fix.\\n\\n### Objections this answers\\n- **\\\"Leads will be junk.\\\"** The whole system exists to pre-filter them, medically and financially.\\n- **\\\"Referral leads are better.\\\"** (general context) True - ads reach strangers, so ad leads will always feel colder; judge them against benchmarks, not word-of-mouth.\\n- **\\\"Low booking or close rates mean bad leads.\\\"** Often it's slow follow-up or an untrained coordinator - we address both with automation, scripts, and training.\\n\\n---\\n\\n## Video 2: How leads become booked patients (youtu.be/PvFJuJSNZiI)\\n\\n### The core idea: speed to lead\\nThe single biggest factor in turning a lead into a booked patient is how fast someone contacts them. A Harvard Business Review study found that responding within 5 minutes makes you **21x more likely** to convert a lead into a patient versus responding within 30 minutes. Yet the average dental practice takes **47 hours** to respond to new inquiries.\\n\\n(general context) Most practices lose patients not because the leads are bad, but because leads aren't followed up fast enough or persistently enough. Each lead costs real money (roughly a $100 bill) and can become a patient worth $10,000+ over their lifetime.\\n\\n### Why practices think this doesn't apply to them (common objection)\\nDentists often say \\\"my front desk is always on the phone.\\\" Two problems: (1) calls cluster at peak times - start of day, lunch, after hours - so more than one comes in at once and some get missed; (2) most practices have no hard data on missed calls or response time, so they go by feel.\\n\\n### The follow-up system\\nThree ways a lead can book, all offered right after they submit their info:\\n1. **We call them** - an outbound call a few minutes after they opt in, from a clear script: answer basic questions about candidacy, treatment, and pricing, then steer toward booking.\\n2. **They call the office** - handled the same way, plus capturing contact info for follow-up.\\n3. **They book themselves online** - self-scheduled patients have a **41% lower no-show rate** because they chose a time that truly works for them.\\n\\nIf a lead doesn't answer: same day, call twice, leave a voicemail, and text several times spaced hours apart. Days 1-2: two calls and two texts daily. Days 3-6: two calls and one text daily. After a week: a series of helpful emails (about the team, promotions, procedures) that builds enough trust to book later.\\n\\n**Personal touches that lift booking rates:** tailor messages to what the lead said on the intake questions (e.g., financing needs get monthly payment plan info), and send a short video of the doctor welcoming them - putting a face to the practice builds trust fast.\\n\\n### Scheduling practices that raise show rates\\n(general context) Keep plenty of open slots (availability directly drives bookings; aim for weekday 9am-3pm coverage); keep consults to ~45 minutes or less; 15-minute booking intervals; book no more than ~3 business days out and pull appointments earlier when possible - the further out, the more no-shows.\\n\\n### What Lumina actually does for clients\\nFor every practice we work with, we implement all these automations and hand over all the scripts and standard operating procedures - the whole follow-up and booking system is done for the practice, alongside running their ads.\\n\\n---\\n\\n## Video 3: The ads themselves (youtu.be/X_Cc8Iy3Hgg)\\n\\n### The short answer\\nFor each practice we build and run **25-30 genuinely different ads at all times** - not one ad copied 30 times with small tweaks. Each ad combines three ingredients: an **offer** (what brings a new patient in, like a new-patient special or a free consultation for a big-ticket treatment), an **angle** (the specific reason that patient cares - comfort, speed, price, trust), and a **format** (patient testimonial, before-and-after, the dentist talking to camera, a photo, or footage of the office and chairside care).\\n\\n### Why so many ads?\\n(general context) In 2025, Facebook/Instagram got dramatically better at matching each person with an ad they'll respond to (\\\"Meta Andromeda\\\" update) - and dental ad costs jumped **97% in one year**, the steepest rise of any industry on the platform. Practices still running two or three ads now pay far more per patient.\\n\\n(general context) Even for the same treatment, patients want different things: one Invisalign prospect is weighing clear aligners against metal braces (needs to hear discreet, faster, comfortable); another is price-shopping (wants the discount and freebies). One generic ad can't speak to both. Without variety you get \\\"ad fatigue\\\" - paying more per patient and getting fewer of them.\\n\\n### How we build them\\n- **Start broad:** launch a mix of offers, angles, and formats.\\n- **Find winners:** when one element clearly works, build ~30 fresh variations around it - new angles (credentials, friendly team, treatment timelines, what the first visit is like) and new formats.\\n- **Keep winners running, keep testing:** a proven winner gets its own budget and often keeps producing for months or years.\\n- **Give every ad a fair shot:** at least 3 days and ~$300 of spend before judging; we test big, meaningful differences, not tiny word tweaks.\\n\\n### Targeting by treatment\\nAds are built per treatment (Invisalign, veneers, implants, whitening, etc.) and, within each treatment, per patient motivation - the price-shopper, the anxious patient, the appearance-focused patient - so the ad each person sees feels written for them. That personal fit is how a smaller practice competes against big spenders in crowded markets.\\n\\n### Common questions this answers\\n- *\\\"Do you just run one ad for my practice?\\\"* No - 25-30 unique ones, refreshed as winners emerge.\\n- *\\\"Won't people get sick of seeing my ads?\\\"* That's exactly what the volume and variety prevent.\\n\";\n",[164],"c769cce4-b0b9-4243-a299-786ed014150d","ghl.ts","503799ae-7bee-11f1-9fbd-1607ee4eb77e",52,["D",1784168315260],6,"// GoHighLevel (LeadConnector) calendar integration for the reply agent.\n// Verified live 2026-07-09: free-slots, book, reschedule, cancel, contact upsert.\n// Not yet imported by webhook.ts - the wire-in (which times to propose, when to\n// book) comes once Sam specifies the rules.\n//\n// Env: GHL_API_KEY (Private Integration token, scopes: calendars r/w,\n// calendar events r/w, contacts r/w). Location/calendar ids are not secrets\n// (they appear in public booking URLs), so they live here as constants.\n\nconst GHL_BASE = \"https://services.leadconnectorhq.com\";\nexport const GHL_LOCATION_ID = \"89bBbANt0akkAawGIfdm\";\n// \"Lumina Free Campaign Call\" - the calendar behind links.luminamg.com/widget/booking/1nbt58J9c0CBZFyqCBQk\nexport const GHL_CALENDAR_ID = \"1nbt58J9c0CBZFyqCBQk\";\nexport const GHL_TIMEZONE = \"America/Los_Angeles\";\n\nasync function ghl(\n method: string,\n path: string,\n body?: unknown,\n version = \"2021-04-15\",\n): Promise {\n const resp = await fetch(GHL_BASE + path, {\n method,\n headers: {\n \"Authorization\": `Bearer ${Deno.env.get(\"GHL_API_KEY\")}`,\n \"Version\": version,\n \"Accept\": \"application/json\",\n \"Content-Type\": \"application/json\",\n },\n body: body === undefined ? undefined : JSON.stringify(body),\n signal: AbortSignal.timeout(15_000),\n });\n const text = await resp.text();\n if (!resp.ok) throw new Error(`ghl ${method} ${path} ${resp.status}: ${text.slice(0, 400)}`);\n return text ? JSON.parse(text) : {};\n}\n\n// Real-time availability. Returns { \"YYYY-MM-DD\": [\"2026-07-14T19:30:00-07:00\", ...] }\n// honoring the calendar's buffers, blocked slots, min-notice (2h) and booking\n// window (6 days). Slots are slot-interval spaced (15 min) for 30-min meetings.\nexport async function fetchFreeSlots(\n days = 6,\n timezone = GHL_TIMEZONE,\n): Promise> {\n const now = Date.now();\n const data = await ghl(\n \"GET\",\n `/calendars/${GHL_CALENDAR_ID}/free-slots?startDate=${now}&endDate=${now + days * 86_400_000}&timezone=${encodeURIComponent(timezone)}`,\n );\n const out: Record = {};\n for (const [day, v] of Object.entries(data)) {\n if (v && typeof v === \"object\" && Array.isArray((v as any).slots)) {\n out[day] = (v as any).slots;\n }\n }\n return out;\n}\n\n// Bookings must attach to a GHL contact; upsert dedupes by email (and phone -\n// a phone already on another contact is silently dropped, the upsert still\n// succeeds). Returns the contactId.\n// The clinic name is written to BOTH the standard companyName field and Sam's\n// user-created \"Clinic Name\" custom field (key clinic_name, id\n// gFa5tA51d3Q14cX4jPKv) - his booking notification reads the custom one.\nexport async function upsertContact(c: {\n email: string;\n firstName?: string;\n lastName?: string;\n phone?: string;\n clinicName?: string;\n}): Promise {\n const { clinicName, ...rest } = c;\n const body: Record = { locationId: GHL_LOCATION_ID, ...rest };\n if (clinicName) {\n body.companyName = clinicName;\n body.customFields = [{ key: \"clinic_name\", field_value: clinicName }];\n }\n const data = await ghl(\"POST\", \"/contacts/upsert\", body, \"2021-07-28\");\n const id = data?.contact?.id;\n if (!id) throw new Error(`ghl upsertContact: no contact id in response`);\n return id;\n}\n\n// startTime must be a free slot in ISO-with-offset form, exactly as returned by\n// fetchFreeSlots. toNotify:false suppresses GHL's native calendar emails; Sam's\n// own confirmation/reminder workflow fires regardless (it triggers on the\n// appointment itself). Returns { id, address } - address is the auto-created\n// Zoom link.\nexport async function bookAppointment(a: {\n contactId: string;\n startTime: string;\n title: string;\n}): Promise<{ id: string; address?: string }> {\n const data = await ghl(\"POST\", \"/calendars/events/appointments\", {\n calendarId: GHL_CALENDAR_ID,\n locationId: GHL_LOCATION_ID,\n contactId: a.contactId,\n startTime: a.startTime,\n title: a.title,\n appointmentStatus: \"confirmed\",\n toNotify: false,\n });\n if (!data?.id) throw new Error(\"ghl bookAppointment: no appointment id in response\");\n return { id: data.id, address: data.address };\n}\n\n// CAUTION (verified): GHL does NOT exempt the appointment's own block from the\n// availability check - rescheduling to a slot that overlaps the current one\n// (e.g. 20:30 -> 20:15 for a 30-min meeting) fails with \"slot no longer\n// available\". Cancel-and-rebook if that case ever matters.\nexport async function rescheduleAppointment(appointmentId: string, startTime: string) {\n return await ghl(\"PUT\", `/calendars/events/appointments/${appointmentId}`, {\n startTime,\n toNotify: false,\n });\n}\n\n// Sets appointmentStatus to \"cancelled\" (keeps the record; slots free up\n// immediately). Never hard-DELETE events.\nexport async function cancelAppointment(appointmentId: string) {\n return await ghl(\"PUT\", `/calendars/events/appointments/${appointmentId}`, {\n appointmentStatus: \"cancelled\",\n toNotify: false,\n });\n}\n\nexport async function getAppointment(appointmentId: string) {\n const data = await ghl(\"GET\", `/calendars/events/appointments/${appointmentId}`);\n return data?.appointment ?? data?.event ?? data;\n}\n\n// Full contact object (email, additionalEmails, phone, phoneLabel,\n// additionalPhones, customFields, tags, ...). Throws on 404.\nexport async function getContact(contactId: string): Promise {\n const data = await ghl(\"GET\", `/contacts/${contactId}`, undefined, \"2021-07-28\");\n return data?.contact ?? data;\n}\n\n// All events on the campaign calendar in [startMs, endMs] - includes cancelled\n// ones (filter by appointmentStatus). Used by the CRM reconciler.\nexport async function listCalendarEvents(startMs: number, endMs: number): Promise {\n const data = await ghl(\n \"GET\",\n `/calendars/events?locationId=${GHL_LOCATION_ID}&calendarId=${GHL_CALENDAR_ID}&startTime=${startMs}&endTime=${endMs}`,\n );\n return data?.events ?? [];\n}\n\n// Tags are add-only from our side (PUT tags replaces the whole array, so we\n// merge with what's there). Used to flag duplicate contacts for Sam's review.\nexport async function addContactTag(contactId: string, tag: string): Promise {\n const c = await getContact(contactId);\n const tags: string[] = Array.isArray(c?.tags) ? c.tags : [];\n if (tags.some((t) => t.toLowerCase() === tag.toLowerCase())) return;\n await ghl(\"PUT\", `/contacts/${contactId}`, { tags: [...tags, tag] }, \"2021-07-28\");\n}\n\n// ---------- opportunities (pipeline CRM) ----------\n// NOTE: these need the opportunities scopes on the Private Integration token.\n// Until Sam adds them, every call 401s with \"not authorized for this scope\" -\n// crm.ts detects that string and degrades to contact-only sync.\n\nexport async function listPipelines(): Promise {\n const data = await ghl(\"GET\", `/opportunities/pipelines?locationId=${GHL_LOCATION_ID}`, undefined, \"2021-07-28\");\n return data?.pipelines ?? [];\n}\n\nexport async function searchOpportunitiesByContact(contactId: string): Promise {\n const data = await ghl(\n \"GET\",\n `/opportunities/search?location_id=${GHL_LOCATION_ID}&contact_id=${contactId}`,\n undefined,\n \"2021-07-28\",\n );\n return data?.opportunities ?? [];\n}\n\nexport async function createOpportunity(o: {\n pipelineId: string;\n pipelineStageId: string;\n contactId: string;\n name: string;\n}): Promise {\n const data = await ghl(\"POST\", \"/opportunities/\", {\n locationId: GHL_LOCATION_ID,\n pipelineId: o.pipelineId,\n pipelineStageId: o.pipelineStageId,\n contactId: o.contactId,\n name: o.name,\n status: \"open\",\n }, \"2021-07-28\");\n const id = data?.opportunity?.id ?? data?.id;\n if (!id) throw new Error(\"ghl createOpportunity: no id in response\");\n return id;\n}\n\nexport async function updateOpportunity(id: string, fields: Record): Promise {\n return await ghl(\"PUT\", `/opportunities/${id}`, fields, \"2021-07-28\");\n}\n\n// One-off email through GHL conversations (lands in the contact's\n// conversation thread; sender fully controllable). Used by the scheduled\n// reminder queue in crm.ts.\nexport async function sendConversationEmail(m: {\n contactId: string;\n subject: string;\n html: string;\n emailFrom: string;\n emailFromName?: string;\n}): Promise {\n return await ghl(\"POST\", \"/conversations/messages\", { type: \"Email\", ...m }, \"2021-04-15\");\n}\n\nexport async function searchOpportunitiesByPipeline(pipelineId: string): Promise {\n const data = await ghl(\n \"GET\",\n `/opportunities/search?location_id=${GHL_LOCATION_ID}&pipeline_id=${pipelineId}&limit=100`,\n undefined,\n \"2021-07-28\",\n );\n return data?.opportunities ?? [];\n}\n\n// Update fields on an existing contact. additionalEmails must be the OBJECT\n// form [{ email: \"...\" }] - the bare-string form 422s, and the upsert endpoint\n// rejects the property entirely (both verified 2026-07-15), so extra emails\n// always go through here as a second call.\nexport async function updateContact(contactId: string, fields: Record) {\n return await ghl(\"PUT\", `/contacts/${contactId}`, fields, \"2021-07-28\");\n}\n\n// Search (never creates). Returns the contactId for an exact email match, or null.\nexport async function findContactByEmail(email: string): Promise {\n const data = await ghl(\n \"GET\",\n `/contacts/?locationId=${GHL_LOCATION_ID}&query=${encodeURIComponent(email)}`,\n undefined,\n \"2021-07-28\",\n );\n const hit = (data?.contacts ?? []).find(\n (c: any) => String(c.email ?? \"\").toLowerCase() === email.toLowerCase(),\n );\n return hit?.id ?? null;\n}\n\n// Upcoming (non-cancelled, future) appointment for a contact, or null. Used for\n// self-book detection AND as an idempotency guard before booking - never book a\n// contact who already has something on the calendar. startTime in the response\n// is location-local \"YYYY-MM-DD HH:mm:ss\", so we compare lexicographically\n// against \"now\" rendered in the location timezone.\nexport async function getUpcomingAppointment(\n contactId: string,\n): Promise<{ id: string; startTime: string } | null> {\n const data = await ghl(\"GET\", `/contacts/${contactId}/appointments`, undefined, \"2021-07-28\");\n const nowLocal = new Date().toLocaleString(\"sv-SE\", { timeZone: GHL_TIMEZONE }); // \"YYYY-MM-DD HH:mm:ss\"\n const upcoming = (data?.events ?? data?.appointments ?? [])\n .filter((a: any) =>\n a.appointmentStatus !== \"cancelled\" && a.appointmentStatus !== \"invalid\" &&\n String(a.startTime ?? \"\") > nowLocal\n )\n .sort((a: any, b: any) => String(a.startTime).localeCompare(String(b.startTime)));\n return upcoming[0] ? { id: upcoming[0].id, startTime: upcoming[0].startTime } : null;\n}\n",[172],"e6beb087-56b0-4daf-a22c-79966cdb898e","crm.ts","f53a3bf4-80ae-11f1-832a-1607ee4eb77e",53,["D",1784168315642],1,"// GHL-as-CRM sync (2026-07-15). GoHighLevel is Sam's CRM: every positive\n// reply creates/enriches a contact (person name, official clinic name from\n// the practice WEBSITE, replier-primary emails, labeled phone) and an\n// opportunity in the \"Cold Email\" pipeline (Positive -> Booked). A throttled\n// reconciler catches prospects who book themselves under a different email.\n// EVERYTHING here is best-effort: a CRM failure must never block a reply.\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { email as sendEmail } from \"https://esm.town/v/std/email\";\nimport {\n addContactTag,\n createOpportunity,\n findContactByEmail,\n getContact,\n listCalendarEvents,\n listPipelines,\n searchOpportunitiesByContact,\n searchOpportunitiesByPipeline,\n sendConversationEmail,\n updateContact,\n updateOpportunity,\n upsertContact,\n} from \"./ghl.ts\";\n\nconst MODEL = \"claude-sonnet-5\";\nexport const CLINIC_FIELD_ID = \"gFa5tA51d3Q14cX4jPKv\"; // Sam's \"Clinic Name\" custom field (key clinic_name)\nexport const FREE_MAIL = new Set([\n \"gmail.com\", \"yahoo.com\", \"outlook.com\", \"hotmail.com\", \"aol.com\", \"icloud.com\",\n \"me.com\", \"msn.com\", \"live.com\", \"comcast.net\", \"att.net\", \"verizon.net\", \"sbcglobal.net\",\n]);\n\n// ---------- shared pure helpers (webhook.ts imports these too) ----------\n\nexport function stripHtml(s: string): string {\n return s.replace(//gi, \"\").replace(//gi, \"\")\n .replace(/<[^>]+>/g, \" \").replace(/\\s+/g, \" \").trim();\n}\n\n// 10-digit US normalization; \"\" when the string doesn't contain a full number.\nexport function normalizePhone(s: string): string {\n const digits = String(s).replace(/\\D/g, \"\");\n if (digits.length === 10) return digits;\n if (digits.length === 11 && digits.startsWith(\"1\")) return digits.slice(1);\n return \"\";\n}\n\nexport function leadVar(lead: any, name: string): string {\n const v = (lead?.custom_variables ?? []).find(\n (v: any) => String(v.name).toLowerCase() === name,\n )?.value;\n return v ? String(v).trim() : \"\";\n}\n\nexport function websiteFromLead(lead: any): string | null {\n const site = leadVar(lead, \"website\");\n if (site) return site.startsWith(\"http\") ? site : `https://${site}`;\n const domain = String(lead?.email ?? \"\").split(\"@\")[1]?.toLowerCase();\n if (domain && !FREE_MAIL.has(domain)) return `https://${domain}`;\n return null;\n}\n\n// Who the booking confirmation must reach (the Jim Sandford lesson): PRIMARY\n// is the address the human actually replied from; the campaign lead email\n// (often a generic info@ inbox) rides along as an additional email.\nexport type ContactEmails = { primary: string; additional?: string };\n\nexport function contactEmailsFor(reply: any, lead: any): ContactEmails {\n const replier = String(reply?.from_email_address ?? \"\").trim().toLowerCase();\n const leadEmail = String(lead?.email ?? \"\").trim().toLowerCase();\n const primary = replier || leadEmail;\n return { primary, additional: leadEmail && leadEmail !== primary ? leadEmail : undefined };\n}\n\n// Best person name available: split the extracted full name (sans \"Dr.\"),\n// else the greet-name + lead fields. personName=true only for a real\n// first+last pair - placeholders must never block a later real-name upgrade.\nexport function contactName(\n a: { prospect_full_name?: string; prospect_first_name?: string },\n lead: any,\n): { firstName?: string; lastName?: string; personName: boolean } {\n const parts = String(a.prospect_full_name ?? \"\").replace(/^dr\\.?\\s+/i, \"\").trim().split(/\\s+/).filter(Boolean);\n if (parts.length >= 2) return { firstName: parts[0], lastName: parts.slice(1).join(\" \"), personName: true };\n return {\n firstName: a.prospect_first_name ?? lead.first_name ?? undefined,\n lastName: lead.last_name ?? undefined,\n personName: false,\n };\n}\n\nexport async function lookupContact(emails: ContactEmails): Promise {\n const byPrimary = await findContactByEmail(emails.primary).catch(() => null);\n if (byPrimary) return byPrimary;\n if (emails.additional) return await findContactByEmail(emails.additional).catch(() => null);\n return null;\n}\n\n// Find-or-create for booking paths. A contact found only under the lead email\n// has the generic inbox as primary - migrate it so confirmations land with\n// the actual person. Best-effort throughout.\nexport async function ensureContact(\n emails: ContactEmails,\n info: { firstName?: string; lastName?: string; phone?: string; clinicName?: string },\n): Promise {\n const byPrimary = await findContactByEmail(emails.primary).catch(() => null);\n if (byPrimary) return byPrimary;\n if (emails.additional) {\n const byLead = await findContactByEmail(emails.additional).catch(() => null);\n if (byLead) {\n await updateContact(byLead, {\n email: emails.primary,\n additionalEmails: [{ email: emails.additional }],\n }).catch((e) => console.error(\"contact primary-email fix failed:\", e));\n return byLead;\n }\n }\n const id = await upsertContact({ email: emails.primary, ...info });\n if (emails.additional) {\n await updateContact(id, { additionalEmails: [{ email: emails.additional }] })\n .catch((e) => console.error(\"additionalEmails set failed:\", e));\n }\n return id;\n}\n\n// Clinic-name normalization for comparisons: lowercase, alphanumeric+spaces,\n// professional suffixes stripped, so \"Merrily Sandford, DDS & Associates\"\n// matches \"merrily sandford associates\".\nexport function normalizeName(s: string): string {\n return String(s ?? \"\").toLowerCase().replace(/&/g, \" and \").replace(/[^a-z0-9\\s]/g, \" \")\n .split(/\\s+/).filter((w) => w && ![\"dds\", \"dmd\", \"pc\", \"pa\", \"pllc\", \"llc\", \"inc\", \"and\", \"the\", \"of\"].includes(w))\n .join(\" \");\n}\n\nexport function emailFromText(s: string): string | null {\n return String(s ?? \"\").match(/[a-z0-9._%+-]+@[a-z0-9.-]+\\.[a-z]{2,}/i)?.[0]?.toLowerCase() ?? null;\n}\n\nfunction nonFreemailDomains(...emails: (string | undefined)[]): string[] {\n return [...new Set(\n emails.filter(Boolean).map((e) => String(e).toLowerCase().split(\"@\")[1] ?? \"\")\n .filter((d) => d && !FREE_MAIL.has(d)),\n )];\n}\n\n// GHL phone-label enum (verified live): Home | Work | Mobile | Landline.\nexport function phoneLabelFor(type?: string): string | undefined {\n if (type === \"personal\") return \"Mobile\";\n if (type === \"office\") return \"Work\";\n return undefined;\n}\n\nfunction e164(raw?: string): string | undefined {\n if (!raw) return undefined;\n const n = normalizePhone(raw);\n return n ? `+1${n}` : String(raw).trim() || undefined;\n}\n\n// ---------- website intel (one fetch + one Claude call per site) ----------\n\nexport type Intel = { phones: string[]; clinicName?: string; timezone?: string; evidence?: string };\n\nconst INTEL_TOOL = {\n name: \"submit_website_intel\",\n description: \"Submit facts extracted from the practice website.\",\n input_schema: {\n type: \"object\",\n properties: {\n clinic_name: {\n type: \"string\",\n description: \"The practice's official name exactly as the website presents it (header/title/footer) - the full name, not a shortened salutation form. Omit if unclear.\",\n },\n timezone: { type: \"string\", description: \"IANA US timezone from address/city/state/area code, or omit\" },\n evidence: { type: \"string\", description: \"One short sentence on what you used\" },\n },\n required: [\"evidence\"],\n },\n};\n\nasync function claudeExtract(system: string, content: string, tool: Record): Promise {\n const resp = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": Deno.env.get(\"ANTHROPIC_API_KEY\") ?? \"\",\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: MODEL,\n max_tokens: 500,\n system,\n tools: [tool],\n tool_choice: { type: \"tool\", name: (tool as any).name },\n messages: [{ role: \"user\", content }],\n }),\n signal: AbortSignal.timeout(30_000),\n });\n if (!resp.ok) throw new Error(`anthropic ${resp.status}: ${await resp.text()}`);\n const data = await resp.json();\n return (data.content ?? []).find((b: { type: string }) => b.type === \"tool_use\")?.input ?? {};\n}\n\nconst intelCache = new Map>();\n\nexport function websiteIntel(lead: any): Promise {\n const site = websiteFromLead(lead);\n if (!site) return Promise.resolve(null);\n if (!intelCache.has(site)) {\n if (intelCache.size > 100) intelCache.clear();\n intelCache.set(\n site,\n fetchIntel(site).catch((e) => {\n console.error(\"websiteIntel failed:\", e);\n intelCache.delete(site); // don't cache transient failures\n return null;\n }),\n );\n }\n return intelCache.get(site)!;\n}\n\nasync function fetchIntel(url: string): Promise {\n const resp = await fetch(url, {\n headers: { \"User-Agent\": \"Mozilla/5.0 (compatible; LuminaBot)\" },\n signal: AbortSignal.timeout(8_000),\n });\n if (!resp.ok) return null;\n const html = (await resp.text()).slice(0, 300_000);\n const phones = new Set();\n for (const m of html.matchAll(/href=[\"']tel:([^\"']+)[\"']/gi)) {\n const n = normalizePhone(m[1]);\n if (n) phones.add(n);\n }\n for (const m of html.matchAll(/\$?\\b\\d{3}\$?[\\s.-]\\s?\\d{3}[\\s.-]\\d{4}\\b/g)) {\n const n = normalizePhone(m[0]);\n if (n) phones.add(n);\n }\n const text = stripHtml(html).slice(0, 4000);\n let extracted: any = {};\n if (text) {\n try {\n extracted = await claudeExtract(\n \"Extract the dental practice's OFFICIAL name and US timezone from its website text.\",\n `Website: ${url}\\n\\n${text}`,\n INTEL_TOOL,\n );\n } catch (e) {\n console.error(\"intel extract failed:\", e);\n }\n }\n return {\n phones: [...phones],\n clinicName: extracted.clinic_name || undefined,\n timezone: extracted.timezone || undefined,\n evidence: extracted.evidence || undefined,\n };\n}\n\n// ---------- sqlite state (throttle + one-time alerts) ----------\n\nasync function ensureCrmState() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS crm_state (key TEXT PRIMARY KEY, value TEXT)`);\n}\n\nasync function getState(key: string): Promise {\n const r = await sqlite.execute({ sql: `SELECT value FROM crm_state WHERE key = ?`, args: [key] });\n return r.rows.length ? String(r.rows[0][0]) : null;\n}\n\nasync function setState(key: string, value: string) {\n await sqlite.execute({\n sql: `INSERT INTO crm_state (key, value) VALUES (?, ?) ON CONFLICT(key) DO UPDATE SET value = excluded.value`,\n args: [key, value],\n });\n}\n\n// ---------- opportunities: pipeline discovery + scope guard ----------\n\nfunction isScopeError(e: unknown): boolean {\n return String(e).includes(\"not authorized for this scope\");\n}\n\n// One email to Sam the first time an opportunity call hits the missing scope,\n// then silence until the scope works (flag clears on first success).\nasync function alertScopeOnce() {\n await ensureCrmState();\n if (await getState(\"opp_scope_alerted\")) return;\n await setState(\"opp_scope_alerted\", new Date().toISOString());\n try {\n await Promise.race([\n sendEmail({\n subject: \"[Reply Agent] GHL opportunities scope missing - pipeline sync is off\",\n text: \"Contacts are syncing fine, but the Private Integration token can't touch opportunities, so nothing lands in the Cold Email pipeline.\\n\\n\" +\n \"Fix (2 min): GHL -> Settings -> Private Integrations -> your integration -> Edit scopes -> add View Opportunities + Edit Opportunities. If GHL rotates the token, update GHL_API_KEY on the val.\\n\\n\" +\n \"Verify after: hit the test endpoint with ?action=crmcheck - oppScope should flip to true. Everything self-heals from there (no redeploy).\",\n }),\n new Promise((_, rej) => setTimeout(() => rej(new Error(\"email timeout\")), 8000)),\n ]);\n } catch (e) {\n console.error(\"scope alert email failed:\", e);\n }\n}\n\ntype Pipeline = { pipelineId: string; positiveId: string; bookedId: string };\nlet pipelineCache: { at: number; data: Pipeline | null } | null = null;\n\n// Discover Sam's \"Cold Email\" pipeline + Positive/Booked stages BY NAME so a\n// rename in GHL degrades to a logged skip instead of writing to a wrong stage.\nexport async function coldEmailPipeline(): Promise {\n if (pipelineCache && Date.now() - pipelineCache.at < 3_600_000) return pipelineCache.data;\n const pipes = await listPipelines(); // throws on missing scope - callers guard\n const pipe = pipes.find((p: any) => String(p.name ?? \"\").toLowerCase().includes(\"cold email\"));\n const stageId = (name: string) =>\n pipe?.stages?.find((s: any) => String(s.name ?? \"\").toLowerCase().includes(name))?.id;\n const data = pipe && stageId(\"positive\") && stageId(\"booked\")\n ? { pipelineId: pipe.id, positiveId: stageId(\"positive\")!, bookedId: stageId(\"booked\")! }\n : null;\n if (!data) console.error(\"coldEmailPipeline: pipeline or Positive/Booked stage not found by name\");\n pipelineCache = { at: Date.now(), data };\n // Scope works - clear the one-time alert flag so a future regression re-alerts.\n await ensureCrmState();\n await setState(\"opp_scope_alerted\", \"\").catch(() => {});\n return data;\n}\n\nasync function ensureOpportunity(\n contactId: string,\n name: string,\n stage: \"positive\" | \"booked\",\n): Promise<{ opportunityId?: string; note: string }> {\n try {\n const pipe = await coldEmailPipeline();\n if (!pipe) return { note: \"pipeline/stages not found by name - opportunity skipped\" };\n const opps = await searchOpportunitiesByContact(contactId);\n const existing = (opps ?? []).find((o: any) => o.pipelineId === pipe.pipelineId);\n if (existing) {\n if (stage === \"booked\" && existing.pipelineStageId !== pipe.bookedId) {\n await updateOpportunity(existing.id, { pipelineStageId: pipe.bookedId });\n return { opportunityId: existing.id, note: \"opportunity moved to Booked\" };\n }\n return { opportunityId: existing.id, note: \"opportunity already exists\" };\n }\n const id = await createOpportunity({\n pipelineId: pipe.pipelineId,\n pipelineStageId: stage === \"booked\" ? pipe.bookedId : pipe.positiveId,\n contactId,\n name,\n });\n return { opportunityId: id, note: `opportunity created in ${stage === \"booked\" ? \"Booked\" : \"Positive\"}` };\n } catch (e) {\n if (isScopeError(e)) {\n await alertScopeOnce();\n return { note: \"opportunities scope missing (Sam alerted once)\" };\n }\n throw e;\n }\n}\n\n// ---------- contact enrichment ----------\n\n// Pure decision function: given the EXISTING GHL contact and what we know\n// now, return the minimal PUT body (or null). Never blanks a field, never\n// downgrades a person name, never clobbers a manually-edited clinic name.\nexport function buildContactDelta(c: any, want: {\n primaryEmail: string;\n additionalEmail?: string;\n firstName?: string;\n lastName?: string;\n personName: boolean;\n phone?: string;\n phoneLabel?: string;\n clinic?: string;\n clinicIsOfficial: boolean;\n bisonDerived: string[]; // clinic values we're allowed to overwrite with the official one\n}): Record | null {\n const delta: Record = {};\n const existingEmail = String(c.email ?? \"\").toLowerCase();\n const existingAdditional: string[] = (c.additionalEmails ?? []).map((e: any) => String(e.email ?? \"\").toLowerCase());\n\n // Emails: migrate a generic primary to the real one; otherwise just make\n // sure both addresses are on the contact.\n if (want.primaryEmail && existingEmail !== want.primaryEmail) {\n if (want.additionalEmail && existingEmail === want.additionalEmail) {\n delta.email = want.primaryEmail;\n delta.additionalEmails = [...new Set([...existingAdditional.filter((e) => e !== want.primaryEmail), want.additionalEmail])]\n .map((e) => ({ email: e }));\n } else if (!existingAdditional.includes(want.primaryEmail)) {\n delta.additionalEmails = [...existingAdditional, want.primaryEmail].map((e) => ({ email: e }));\n }\n } else if (want.additionalEmail && want.additionalEmail !== existingEmail && !existingAdditional.includes(want.additionalEmail)) {\n delta.additionalEmails = [...existingAdditional, want.additionalEmail].map((e) => ({ email: e }));\n }\n\n // Names: fill empty; upgrade a placeholder (no lastName) to a real person\n // name; never touch an existing first+last pair.\n if (want.firstName && !c.firstName) {\n delta.firstName = want.firstName;\n if (want.lastName) delta.lastName = want.lastName;\n } else if (want.personName && want.lastName && c.firstName && !c.lastName) {\n delta.firstName = want.firstName;\n delta.lastName = want.lastName;\n }\n\n // Phone: fill empty (with label); a different number appends to\n // additionalPhones; a matching number can gain a missing label.\n if (want.phone) {\n const wantNorm = normalizePhone(want.phone);\n const existingNorm = normalizePhone(String(c.phone ?? \"\"));\n const additionalNorms = (c.additionalPhones ?? []).map((p: any) => normalizePhone(String(p.phone ?? \"\")));\n if (!c.phone) {\n delta.phone = want.phone;\n if (want.phoneLabel) delta.phoneLabel = want.phoneLabel;\n } else if (wantNorm && existingNorm === wantNorm) {\n if (want.phoneLabel && !c.phoneLabel) delta.phoneLabel = want.phoneLabel;\n } else if (wantNorm && !additionalNorms.includes(wantNorm)) {\n delta.additionalPhones = [\n ...(c.additionalPhones ?? []).map((p: any) => ({ phone: p.phone, phoneLabel: p.phoneLabel })),\n { phone: want.phone, ...(want.phoneLabel ? { phoneLabel: want.phoneLabel } : {}) },\n ];\n }\n }\n\n // Clinic: fill empty; the official website name may replace Bison-derived\n // values only. An unrecognized existing value = Sam's manual edit - leave it.\n if (want.clinic) {\n const current = String(\n (c.customFields ?? []).find((f: any) => f.id === CLINIC_FIELD_ID)?.value ?? c.companyName ?? \"\",\n );\n const curN = normalizeName(current);\n const wantN = normalizeName(want.clinic);\n const replaceable = !curN || (want.clinicIsOfficial && want.bisonDerived.some((b) => normalizeName(b) === curN));\n if (replaceable && curN !== wantN) {\n delta.companyName = want.clinic;\n delta.customFields = [{ id: CLINIC_FIELD_ID, field_value: want.clinic }];\n }\n }\n\n return Object.keys(delta).length ? delta : null;\n}\n\n// ---------- the two webhook entry points ----------\n\ntype AnalysisLike = {\n category: string;\n prospect_full_name?: string;\n prospect_first_name?: string;\n clinic_name?: string;\n phone_number?: string;\n phone_number_type?: string;\n contact_details?: string;\n};\n\nexport async function syncPositiveReply(args: {\n analysis: AnalysisLike;\n lead: any;\n reply: any;\n dryRun: boolean;\n}): Promise<{ contactId?: string; opportunityId?: string; note: string }> {\n const { analysis: a, lead, reply, dryRun } = args;\n if (!Deno.env.get(\"GHL_API_KEY\")) return { note: \"no GHL key - CRM sync skipped\" };\n\n // Referral: the contact we track is the NEW person when their email was\n // shared; otherwise the practice inbox (we don't know the replier is the\n // right person - they just told us they aren't).\n let emails = contactEmailsFor(reply, lead);\n if (a.category === \"referral\") {\n const newEmail = emailFromText(a.contact_details ?? \"\");\n emails = newEmail\n ? { primary: newEmail, additional: String(lead?.email ?? \"\").toLowerCase() !== newEmail ? String(lead?.email ?? \"\").toLowerCase() || undefined : undefined }\n : { primary: String(lead?.email ?? \"\").toLowerCase() };\n if (!emails.primary) return { note: \"referral without any usable email - skipped\" };\n }\n\n const intel = await websiteIntel(lead);\n const bisonDerived = [a.clinic_name, lead.company, lead.first_name].filter(Boolean) as string[];\n const clinic = intel?.clinicName || a.clinic_name || lead.company || lead.first_name || undefined;\n // Referral name fields describe the REPLIER, not the new contact - skip them.\n const name = a.category === \"referral\" ? { firstName: undefined, lastName: undefined, personName: false } : contactName(a, lead);\n const firstName = name.firstName ?? clinic; // Sam's rule: no name at all -> clinic name as the visible name\n const phone = a.category === \"referral\" ? undefined : e164(a.phone_number);\n const phoneLabel = phone ? phoneLabelFor(a.phone_number_type) : undefined;\n const oppName = clinic ?? name.firstName ?? emails.primary;\n\n if (dryRun) {\n return { note: `[dry run] would sync contact ${emails.primary} (${firstName ?? \"?\"} ${name.lastName ?? \"\"}, clinic \"${clinic ?? \"?\"}\") + Positive opportunity` };\n }\n\n let contactId = await lookupContact(emails);\n let note: string;\n if (!contactId) {\n contactId = await upsertContact({\n email: emails.primary,\n firstName,\n lastName: name.lastName,\n phone,\n clinicName: clinic,\n });\n const extras: Record = {};\n if (emails.additional) extras.additionalEmails = [{ email: emails.additional }];\n if (phoneLabel) extras.phoneLabel = phoneLabel;\n if (Object.keys(extras).length) {\n await updateContact(contactId, extras).catch((e) => console.error(\"contact extras failed:\", e));\n }\n note = `contact created (${emails.primary})`;\n } else {\n const existing = await getContact(contactId);\n const delta = buildContactDelta(existing, {\n primaryEmail: emails.primary,\n additionalEmail: emails.additional,\n firstName: name.firstName, // only real names participate in upgrades\n lastName: name.lastName,\n personName: name.personName,\n phone,\n phoneLabel,\n clinic,\n clinicIsOfficial: Boolean(intel?.clinicName),\n bisonDerived,\n });\n if (delta) {\n await updateContact(contactId, delta);\n note = `contact enriched (${Object.keys(delta).join(\", \")})`;\n } else {\n note = \"contact up to date\";\n }\n }\n\n const opp = await ensureOpportunity(contactId, oppName, \"positive\");\n return { contactId, opportunityId: opp.opportunityId, note: `${note}; ${opp.note}` };\n}\n\nexport async function markBooked(contactId: string | undefined, oppName: string, dryRun: boolean): Promise {\n if (!contactId) return \"no contactId - skipped\";\n if (dryRun) return \"[dry run] would move opportunity to Booked\";\n const opp = await ensureOpportunity(contactId, oppName, \"booked\");\n return opp.note;\n}\n\n// ---------- scheduled one-off emails ----------\n// Queue rows land via direct sqlite INSERT (see NOTES.md); this checker runs\n// on webhook traffic, on every GHL-workflow ping, and from the interval val -\n// whichever fires first sends. Claim-by-UPDATE keeps concurrent invocations\n// from double-sending.\n\nasync function ensureEmailQueue() {\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS scheduled_emails (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n due_at TEXT, -- UTC 'YYYY-MM-DD HH:MM:SS'\n contact_id TEXT,\n subject TEXT,\n html TEXT,\n email_from TEXT,\n from_name TEXT,\n status TEXT DEFAULT 'pending',\n sent_at TEXT,\n detail TEXT)`,\n );\n}\n\nexport async function checkDueEmails(dryRun: boolean): Promise {\n if (!Deno.env.get(\"GHL_API_KEY\")) return \"no GHL key\";\n await ensureEmailQueue();\n const due = await sqlite.execute({\n sql: `SELECT id, contact_id, subject, html, email_from, from_name FROM scheduled_emails\n WHERE status = 'pending' AND due_at <= datetime('now') ORDER BY id`,\n args: [],\n });\n if (!due.rows.length) return \"no due emails\";\n const notes: string[] = [];\n for (const [id, contactId, subject, html, emailFrom, fromName] of due.rows as any[]) {\n if (dryRun) {\n notes.push(`[dry run] would send #${id} \"${subject}\"`);\n continue;\n }\n const claim = await sqlite.execute({\n sql: `UPDATE scheduled_emails SET status = 'sending' WHERE id = ? AND status = 'pending'`,\n args: [id],\n });\n if (claim.rowsAffected !== 1) continue; // another invocation got it\n try {\n await sendConversationEmail({\n contactId: String(contactId),\n subject: String(subject),\n html: String(html),\n emailFrom: String(emailFrom),\n emailFromName: fromName ? String(fromName) : undefined,\n });\n await sqlite.execute({\n sql: `UPDATE scheduled_emails SET status = 'sent', sent_at = datetime('now') WHERE id = ?`,\n args: [id],\n });\n notes.push(`sent #${id} \"${subject}\"`);\n } catch (e) {\n await sqlite.execute({\n sql: `UPDATE scheduled_emails SET status = 'failed', detail = ? WHERE id = ?`,\n args: [String(e).slice(0, 500), id],\n });\n notes.push(`FAILED #${id}: ${String(e).slice(0, 120)}`);\n // A dead reminder is time-sensitive - Sam needs to know immediately.\n try {\n await Promise.race([\n sendEmail({\n subject: `[Reply Agent] Scheduled email #${id} FAILED - send manually`,\n text: `Subject: ${subject}\\nContact: ${contactId}\\n\\nError:\\n${String(e).slice(0, 800)}`,\n }),\n new Promise((_, rej) => setTimeout(() => rej(new Error(\"email timeout\")), 8000)),\n ]);\n } catch { /* alert is best-effort */ }\n }\n }\n return notes.join(\"; \");\n}\n\n// ---------- self-booking reconciler ----------\n\n// Pure matcher: does this booked contact belong to one of our Positive-stage\n// contacts? Match on shared non-freemail email domain first (jim@x.com vs\n// info@x.com), then on normalized clinic name (covers personal-gmail\n// bookings). Sam's design, 2026-07-15.\nexport function matchBookingToCandidates(\n booked: { emails: (string | undefined)[]; clinic?: string },\n candidates: { contactId: string; opportunityId: string; emails: (string | undefined)[]; clinic?: string }[],\n): { contactId: string; opportunityId: string } | null {\n const bookedDomains = nonFreemailDomains(...booked.emails);\n const bookedClinic = normalizeName(booked.clinic ?? \"\");\n let clinicMatch: { contactId: string; opportunityId: string } | null = null;\n for (const cand of candidates) {\n const candDomains = nonFreemailDomains(...cand.emails);\n if (bookedDomains.some((d) => candDomains.includes(d))) return cand; // domain match wins\n if (!clinicMatch && bookedClinic && normalizeName(cand.clinic ?? \"\") === bookedClinic) clinicMatch = cand;\n }\n return clinicMatch;\n}\n\nfunction contactEmailsOf(c: any): (string | undefined)[] {\n return [c?.email, ...((c?.additionalEmails ?? []).map((e: any) => e.email))];\n}\n\nfunction contactClinicOf(c: any): string | undefined {\n return (c?.customFields ?? []).find((f: any) => f.id === CLINIC_FIELD_ID)?.value ?? c?.companyName ?? undefined;\n}\n\n// Sweep upcoming bookings and make the pipeline agree with the calendar.\n// Throttled (>=15 min) because it piggybacks on webhook traffic; force=true\n// from the manual test-endpoint action.\nexport async function reconcile(dryRun: boolean, force = false): Promise {\n if (!Deno.env.get(\"GHL_API_KEY\")) return \"no GHL key\";\n await ensureCrmState();\n if (!force) {\n const last = Number(await getState(\"reconcile_at\") ?? 0);\n if (Date.now() - last < 15 * 60_000) return \"throttled\";\n }\n await setState(\"reconcile_at\", String(Date.now()));\n\n let pipe: Pipeline | null;\n try {\n pipe = await coldEmailPipeline();\n } catch (e) {\n if (isScopeError(e)) {\n await alertScopeOnce();\n return \"opportunities scope missing\";\n }\n throw e;\n }\n if (!pipe) return \"pipeline/stages not found by name\";\n\n const now = Date.now();\n const events = (await listCalendarEvents(now - 24 * 3_600_000, now + 14 * 86_400_000))\n .filter((e: any) => e.appointmentStatus === \"confirmed\" && e.contactId);\n const notes: string[] = [];\n // Candidate pool (contacts sitting in Positive) is loaded lazily - most\n // sweeps find every booking already attached to an opportunity.\n let candidates: { contactId: string; opportunityId: string; emails: (string | undefined)[]; clinic?: string }[] | null = null;\n\n for (const ev of events.slice(0, 25)) {\n try {\n const opps = await searchOpportunitiesByContact(ev.contactId);\n const own = (opps ?? []).find((o: any) => o.pipelineId === pipe.pipelineId);\n if (own) {\n if (own.pipelineStageId === pipe.positiveId) {\n if (!dryRun) await updateOpportunity(own.id, { pipelineStageId: pipe.bookedId });\n notes.push(`moved ${ev.contactId} Positive->Booked${dryRun ? \" [dry run]\" : \"\"}`);\n }\n continue;\n }\n // Booking under a contact with no opportunity: probably a self-booking\n // duplicate of one of our Positive contacts.\n const booked = await getContact(ev.contactId);\n if (candidates === null) {\n candidates = [];\n const posOpps = await searchPositiveOpportunities(pipe);\n for (const o of posOpps.slice(0, 25)) {\n const c = await getContact(o.contactId ?? o.contact?.id).catch(() => null);\n if (c) candidates.push({ contactId: c.id, opportunityId: o.id, emails: contactEmailsOf(c), clinic: contactClinicOf(c) });\n }\n }\n const match = matchBookingToCandidates(\n { emails: contactEmailsOf(booked), clinic: contactClinicOf(booked) },\n candidates,\n );\n if (match) {\n if (!dryRun) {\n // The contact holding the APPOINTMENT becomes canonical: pull the\n // original's clinic/emails onto it, point the opportunity at it,\n // and tag the original for Sam to merge/delete (never auto-delete -\n // he may have added notes).\n const orig = await getContact(match.contactId).catch(() => null);\n const delta = orig\n ? buildContactDelta(booked, {\n primaryEmail: String(booked.email ?? \"\").toLowerCase(),\n additionalEmail: String(orig.email ?? \"\").toLowerCase() || undefined,\n firstName: undefined,\n lastName: undefined,\n personName: false,\n phone: orig.phone ?? undefined,\n phoneLabel: orig.phoneLabel ?? undefined,\n clinic: contactClinicOf(orig),\n clinicIsOfficial: false,\n bisonDerived: [],\n })\n : null;\n if (delta) await updateContact(ev.contactId, delta).catch((e) => console.error(\"booked-contact enrich failed:\", e));\n try {\n await updateOpportunity(match.opportunityId, { contactId: ev.contactId, pipelineStageId: pipe.bookedId });\n } catch {\n await updateOpportunity(match.opportunityId, { pipelineStageId: pipe.bookedId });\n }\n await addContactTag(match.contactId, \"duplicate-superseded\").catch(() => {});\n }\n notes.push(`self-booking ${ev.contactId} matched Positive contact ${match.contactId} -> Booked${dryRun ? \" [dry run]\" : \"\"}`);\n candidates = candidates.filter((c) => c.opportunityId !== match.opportunityId);\n } else {\n if (!dryRun) {\n const oppName = contactClinicOf(booked) ??\n (`${booked.firstName ?? \"\"} ${booked.lastName ?? \"\"}`.trim() || String(booked.email ?? ev.contactId));\n await ensureOpportunity(ev.contactId, oppName, \"booked\");\n }\n notes.push(`unmatched booking ${ev.contactId} -> Booked opportunity created${dryRun ? \" [dry run]\" : \"\"}`);\n }\n } catch (e) {\n if (isScopeError(e)) {\n await alertScopeOnce();\n return \"opportunities scope missing\";\n }\n console.error(\"reconcile event failed:\", ev.id, e);\n notes.push(`event ${ev.id} failed: ${String(e).slice(0, 120)}`);\n }\n }\n return notes.length ? notes.join(\"; \") : `all ${events.length} bookings already reconciled`;\n}\n\n// Filter client-side on the stage id - the search endpoint's stage filter\n// params are inconsistent across accounts, the pipeline filter is not.\nasync function searchPositiveOpportunities(pipe: Pipeline): Promise {\n return (await searchOpportunitiesByPipeline(pipe.pipelineId)).filter((o: any) =>\n o.pipelineStageId === pipe.positiveId && o.status !== \"lost\"\n );\n}\n",[180],"pulls","branches","forks","envVars",{"_194":196,"_197":60},"connections",{"_194":60,"_195":60},"count","unfilledCount",11,"emptyCount",{"_43":179,"_32":180,"_30":181,"_134":-5,"_41":42,"_40":182,"_136":25,"_38":224,"_13":184,"_33":152,"_35":185,"_24":25,"_140":-5,"_206":225,"_27":226},{"_43":171,"_32":172,"_30":173,"_134":-5,"_41":42,"_40":174,"_136":25,"_38":221,"_13":176,"_33":152,"_35":177,"_24":25,"_140":-5,"_206":222,"_27":223},{"_43":163,"_32":164,"_30":165,"_134":-5,"_41":42,"_40":166,"_136":25,"_38":218,"_13":168,"_33":152,"_35":169,"_24":25,"_140":-5,"_206":219,"_27":220},{"_43":155,"_32":156,"_30":157,"_134":-5,"_41":42,"_40":158,"_136":119,"_38":215,"_13":60,"_33":160,"_35":161,"_24":25,"_140":-5,"_206":216,"_27":217},{"_43":146,"_32":147,"_30":148,"_134":-5,"_41":42,"_40":149,"_136":25,"_38":212,"_13":151,"_33":152,"_35":153,"_24":25,"_140":-5,"_206":213,"_27":214},{"_43":142,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_136":25,"_38":209,"_13":144,"_33":34,"_35":37,"_24":25,"_140":-5,"_206":210,"_27":211},{"_43":131,"_32":132,"_30":133,"_134":-5,"_41":42,"_40":135,"_136":25,"_38":205,"_13":138,"_33":34,"_35":139,"_24":25,"_140":-5,"_206":207,"_27":208},["D",1784168314566],"children",[],[132],["D",1784168316963],[],[28],["D",1783649454091],[],[147],["D",1784168316285],[],[156],["D",1784159053067],[],[164],["D",1784168315260],[],[172],["D",1784168315642],[],[180],["D",1783490909384],{"_94":93,"_101":96},{"_94":93,"_95":96,"_97":96,"_18":54,"_98":99,"_100":25},{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_76":-5,"_121":264,"_265":266,"_267":268,"_269":25,"_270":25,"_271":25,"_272":119,"_273":-5,"_274":-7,"_275":-7,"_276":60,"_277":25,"_278":25,"_279":-5,"_280":25,"_281":25,"_282":25,"_283":-5},"ENV",{"_235":236,"_237":238,"_239":84,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263},"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 · v55