[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_101":102,"_103":104},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","samy","name","bison-reply-agent","path","crm.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":-5,"_53":-5,"_54":55,"_56":-5,"_57":42,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/samy/bison-reply-agent/code/crm.ts","extension","id","9743834a-b142-4c22-97c9-b9faebd27bf0","fileId","f53a3bf4-80ae-11f1-832a-1607ee4eb77e","parentId","branchId","54481d2d-a3f3-4dfa-ab51-1abb2a0d7de9","branchVersion",96,"latest",true,"createdAt",["D",1786127125948],"version",8,"fileType","script","content","// 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 listPipelines,\n searchOpportunitiesByContact,\n searchOpportunitiesByPipeline,\n sendConversationEmail,\n updateContact,\n updateOpportunity,\n upsertContact,\n} from \"./ghl.ts\";\nimport { calendarConfigured, listCalendarEvents } from \"./calendly.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// Do we already hold a number the PROSPECT gave us (this reply or any prior\n// one - phone_alerted rows log every extraction)? Lead-var/office numbers\n// don't count: the direct number is the prize, so asking stays worthwhile.\n// Gates both phone asks (CTA + booking confirmation): once true, never ask.\nexport async function prospectPhoneKnown(leadId: number | undefined, extractedNow?: string | null): Promise {\n if (extractedNow) return true;\n if (!leadId) return false;\n try {\n const r = await sqlite.execute({\n sql: `SELECT 1 FROM ai_actions WHERE lead_id = ? AND action = 'phone_alerted' LIMIT 1`,\n args: [leadId],\n });\n return (r.rows?.length ?? 0) > 0;\n } catch {\n return false;\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[]; emails: 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\nexport async 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\n// siteOverride lets call-prep run intel on a website discovered via web\n// search when the lead record has none (the BookYourData personal-email case).\nexport function websiteIntel(lead: any, siteOverride?: string): Promise {\n const site = siteOverride ?? 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 const emails = new Set();\n const scrapeContacts = (h: string) => {\n for (const m of h.matchAll(/href=[\"']tel:([^\"']+)[\"']/gi)) {\n const n = normalizePhone(m[1]);\n if (n) phones.add(n);\n }\n for (const m of h.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 for (const m of h.matchAll(/href=[\"']mailto:([^\"'?]+)/gi)) {\n const e = m[1].trim().toLowerCase();\n if (e.includes(\"@\")) emails.add(e);\n }\n for (const m of h.matchAll(/\\b[A-Za-z0-9._%+-]+@[A-Za-z0-9.-]+\\.[A-Za-z]{2,}\\b/g)) {\n const e = m[0].toLowerCase();\n // regex over raw HTML picks up asset filenames and tracker junk\n if (!/\\.(png|jpe?g|gif|svg|webp|css|js)$/.test(e) && !/sentry|wixpress|example\\.|schema\\.org/.test(e)) {\n emails.add(e);\n }\n }\n };\n scrapeContacts(html);\n // The office email often lives only on the contact page - one bounded extra\n // fetch when the homepage has none.\n if (!emails.size) {\n try {\n const base = new URL(url);\n let contactUrl = \"\";\n for (const m of html.matchAll(/href=[\"']([^\"'#?]+)[\"']/gi)) {\n try {\n const u = new URL(m[1], base);\n if (u.host === base.host && /contact/i.test(u.pathname)) {\n contactUrl = u.href;\n break;\n }\n } catch {\n continue;\n }\n }\n if (contactUrl) {\n const cresp = await fetch(contactUrl, {\n headers: { \"User-Agent\": \"Mozilla/5.0 (compatible; LuminaBot)\" },\n signal: AbortSignal.timeout(8_000),\n });\n if (cresp.ok) scrapeContacts((await cresp.text()).slice(0, 300_000));\n }\n } catch (e) {\n console.error(\"contact-page scrape failed:\", e);\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 emails: [...emails].slice(0, 5),\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// ---------- per-lead mute (Sam is handling the thread manually) ----------\n//\n// Muted leads get NO auto-reply: the webhook exits before drafting and just\n// alerts Sam. Stored in crm_state as \"mute:\" -> ISO timestamp, matched\n// against both the campaign lead email and the address the human actually\n// replies from. Managed on the admin page (test-ghl.ts ?action=mutes);\n// manual-only, no expiry.\n\nconst muteKey = (email: string) => `mute:${email.trim().toLowerCase()}`;\n\nexport async function muteLead(email: string) {\n await ensureCrmState();\n await setState(muteKey(email), new Date().toISOString());\n}\n\nexport async function unmuteLead(email: string) {\n await ensureCrmState();\n await sqlite.execute({ sql: `DELETE FROM crm_state WHERE key = ?`, args: [muteKey(email)] });\n}\n\n// First match wins; returns the muted_at timestamp or null.\nexport async function mutedSince(emails: (string | undefined)[]): Promise {\n await ensureCrmState();\n for (const e of emails) {\n if (!e || !e.trim()) continue;\n const v = await getState(muteKey(e));\n if (v) return v;\n }\n return null;\n}\n\nexport async function listMutes(): Promise<{ email: string; muted_at: string }[]> {\n await ensureCrmState();\n const r = await sqlite.execute(`SELECT key, value FROM crm_state WHERE key LIKE 'mute:%' ORDER BY value DESC`);\n return r.rows.map((row: any) => ({ email: String(row[0]).slice(\"mute:\".length), muted_at: String(row[1]) }));\n}\n\n// ---------- per-lead preferred email (the Bomi Kim lesson, 2026-08-05) ----------\n//\n// When a prospect explicitly gives a better address (\"send it to my gmail\"),\n// it must survive the thread: every later booking/confirmation goes there,\n// and the \"is there a better address?\" ask never repeats. Stored in\n// crm_state as \"prefemail:\".\n\nconst prefKey = (leadEmail: string) => `prefemail:${String(leadEmail).trim().toLowerCase()}`;\n\nexport async function setPreferredEmail(leadEmail: string, email: string) {\n if (!leadEmail?.trim() || !email?.trim()) return;\n await ensureCrmState();\n await setState(prefKey(leadEmail), String(email).trim().toLowerCase());\n}\n\nexport async function getPreferredEmail(leadEmail: string | undefined): Promise {\n if (!leadEmail?.trim()) return null;\n await ensureCrmState();\n return await getState(prefKey(leadEmail));\n}\n\n// Preferred beats reply-From beats lead email; the displaced primary rides\n// along as additional so appointment lookups still match either address.\nexport function resolveContactEmails(reply: any, lead: any, preferred: string | null): ContactEmails {\n const base = contactEmailsFor(reply, lead);\n if (!preferred || preferred === base.primary) return base;\n return { primary: preferred, additional: base.primary };\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 preferred?: string | null;\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 // Own-domain guard: replies/bookings from @luminamg.com addresses are Sam\n // or test traffic, never a prospect - keep them out of the CRM entirely.\n if (contactEmailsFor(reply, lead).primary.endsWith(\"@luminamg.com\")) {\n return { note: \"own-domain reply - CRM sync skipped\" };\n }\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 = a.category === \"referral\"\n ? contactEmailsFor(reply, lead)\n : resolveContactEmails(reply, lead, args.preferred ?? null);\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 CALENDLY bookings and make the GHL pipeline agree with the\n// calendar. Throttled (>=15 min) because it piggybacks on webhook traffic;\n// force=true from the manual test-endpoint action and Calendly webhooks.\nexport async function reconcile(dryRun: boolean, force = false): Promise {\n if (!Deno.env.get(\"GHL_API_KEY\")) return \"no GHL key\";\n if (!calendarConfigured()) return \"calendly not configured\";\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) => e.status === \"active\" && e.inviteeEmail);\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 // Own-domain guard: bookings by @luminamg.com invitees are Sam or test\n // traffic (booktest/caltest), never a prospect - skip CRM processing.\n if (ev.inviteeEmail.toLowerCase().endsWith(\"@luminamg.com\")) continue;\n // Calendly events carry invitee identity, not a GHL contact - resolve\n // (or create) the CRM contact by the invitee email. Agent-booked\n // invitees always exist already via ensureContact; a missing contact\n // means a self-booking under an email GHL has never seen.\n let contactId = await findContactByEmail(ev.inviteeEmail).catch(() => null);\n if (!contactId) {\n if (dryRun) {\n notes.push(`[dry run] would create contact for unknown invitee ${ev.inviteeEmail}`);\n continue;\n }\n const nameParts = String(ev.inviteeName ?? \"\").split(/\\s+/).filter(Boolean);\n contactId = await upsertContact({\n email: ev.inviteeEmail,\n firstName: nameParts[0],\n lastName: nameParts.slice(1).join(\" \") || undefined,\n });\n }\n const opps = await searchOpportunitiesByContact(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 ${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(contactId).catch(() => null) ??\n { id: contactId, email: ev.inviteeEmail };\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 // inviteeName doubles as a clinic-name candidate: Calendly self-book\n // forms often get the practice name typed into the name field.\n { emails: contactEmailsOf(booked), clinic: contactClinicOf(booked) ?? (ev.inviteeName || undefined) },\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(contactId, delta).catch((e) => console.error(\"booked-contact enrich failed:\", e));\n try {\n await updateOpportunity(match.opportunityId, { contactId: 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 ${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 ?? contactId));\n await ensureOpportunity(contactId, oppName, \"booked\");\n }\n notes.push(`unmatched booking ${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","deleted",false,"label",[14],"e3dafc71-738c-40fe-ab70-9c5ae76a5d02",["D",1783490909384],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","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",{"_9":10,"_100":95},"org",{"_9":10,"_94":95,"_96":95,"_54":55,"_97":98,"_99":42},"branch",{"_35":84,"_11":85,"_22":28,"_86":45,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":12,"_93":10},"isOwned",97,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","ctx",{"_77":-5,"_134":135,"_136":137,"_138":139,"_140":42,"_141":42,"_142":42,"_143":32,"_144":-5,"_145":-7,"_146":-7,"_147":61,"_148":42,"_149":42,"_150":-5,"_151":42,"_152":42,"_153":42,"_154":-5},"ENV",{"_105":106,"_107":108,"_109":85,"_110":111,"_112":113,"_114":115,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]