[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_154":155,"_156":157},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_103":84,"_27":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":25,"_121":-5,"_122":-5,"_123":124},"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",13,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","45f70574-8625-11f1-b17e-1607ee4eb77e","name","fileType","interval","content","// APPT UPDATE NOTIFY v1.0 — texts the customer when a staff-rescheduled appointment changes time.\n// Built 23 Jul 2026 after the 23 Jul reschedule case: staff moved a Service Dog Pick-Up by phone and\n// nothing texted her — GHL has no published workflow for reschedules (AppointmentUpdate sits in draft),\n// no Service Dog Pick-Up confirmation workflow at all, and the calendar has zero notifications.\n//\n// HOW IT WORKS\n// Every 15 min: list ALL calendars (minus the 2 Pups Club class calendars), fetch events from\n// now-1d to now+60d, and diff each event's startTime against blob state.\n// - Known event whose startTime CHANGED, status confirmed/new, new start in the future\n// -> SMS the contact the new time. (At-most-once: state updated BEFORE sending; cap 3/run.)\n// - New event ids are recorded silently (booking confirmations remain the per-calendar workflows' job\n// — this val NEVER sends on new bookings, so no double-texting).\n// - Cancelled events update state silently (v1 scope: reschedules only).\n// Test mode: set env APPTN_TEST=true to reroute every send to TEST_PHONE via contact upsert.\n//\n// State blobs: apptn_state (per-run report) · apptn_events (id -> {s: startTime}) · apptn_last_error\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst GHL = \"https://services.leadconnectorhq.com\";\nconst TOKEN = Deno.env.get(\"GHL_TOKEN\");\nconst LOC = \"BQHJ19uohldYe3eqA0bl\";\nconst EXCLUDE_CALS = new Set([\n \"cCmCBJGScp2R0JvfYlCj\", // Community Group Lesson (Pups Club - has its own announce val)\n \"PF1pYhk5QIrhBD33wUk0\", // P.U.P.S Club Community lesson\n]);\n// v1.1: reads APPTN_TEST (renamed from TEST_MODE — a UI env-var edit corrupted the old value).\n// LIVE is the default: test mode only when APPTN_TEST is exactly \"true\".\nconst TEST_MODE = (Deno.env.get(\"APPTN_TEST\") ?? \"\").trim().toLowerCase() === \"true\";\nconst TEST_PHONE = Deno.env.get(\"TEST_PHONE\");\nconst HORIZON_DAYS = 60;\nconst MAX_NOTIFY_PER_RUN = 3;\n\n// v1.7 — CANCELLATION GUARD.\n//\n// GoHighLevel does not remove a contact from a reminder workflow when their appointment is\n// cancelled. A contact already parked on a wait step stays parked and the reminder fires on\n// schedule for a booking that no longer exists. Confirmed live 27 Jul: a customer cancelled at\n// 11:05 and was reminded at 12:03, then had to ask a second time.\n//\n// The obvious fix is a guard workflow built in the interface. This does it from here instead,\n// because the API exposes DELETE /contacts/{id}/workflow/{wf} and that means the fix can be a\n// system rather than a thing someone remembers to do.\n//\n// SAFETY — the reason this is conservative rather than clever:\n// GoHighLevel's API cannot report which workflow a calendar triggers, nor which workflows a\n// contact is currently enrolled in. Any calendar-to-workflow mapping would be name-matching,\n// and name-matching on this account has already been wrong once. So the rule avoids needing a\n// mapping at all: a contact is only touched when EVERY one of their bookings in the horizon is\n// cancelled. Someone with nothing booked should not be receiving a reminder about anything, so\n// removal from every reminder chain is correct regardless of which one they were actually in.\n// A DELETE for a workflow they were never in is a harmless no-op.\nconst GUARD_ENABLED = (Deno.env.get(\"APPTN_GUARD\") ?? \"on\").toLowerCase() !== \"off\";\nconst MAX_GUARD_PER_RUN = 5; // a bug here would touch client records; cap the blast radius\n\n// Published reminder/confirmation workflows. Over-inclusive on purpose — see above.\nconst REMINDER_WORKFLOWS: Record = {\n \"ed9b9f1f-d329-48c0-96e1-95f6d33267bf\": \"Boarding Pick-Up - Confirmation + Reminder\",\n \"e325d629-e5f0-4bfc-943b-a3e6ad2bc93d\": \"Boarding Drop-Off - Confirmation + Reminder\",\n \"77e5d6ce-682a-4ba4-82f7-a8ddba902384\": \"General Pick Up > Confirmation + reminders\",\n \"0287f0a0-b3b0-45a4-92a7-ecd18971a62c\": \"Basic Drop Off > Confirmation + reminders\",\n \"8ae9ec30-9cd7-4115-b6b2-887124b768f6\": \"Community Drop Off > Confirmation + reminders\",\n \"eb4b4a73-1d46-44a0-8204-29718a7bc05b\": \"Bundle Drop Off > Confirmation + reminders\",\n \"6c3d44ad-4aa7-4861-9518-03ce55829f86\": \"Leash Free Drop Off > Confirmation + reminders\",\n \"a4f39500-7e3e-445f-9f7f-3e0761c6082a\": \"Service Dog Drop Off > Confirmation + reminders\",\n \"509ab141-7698-40a3-bb69-72c61f4a2c31\": \"Service Dog Drop Off [Confirmation + Reminder]\",\n \"abb37b6f-4e11-4544-8836-f933511c5c12\": \"Private Lesson Confirmation and Reminders\",\n \"3bcbe539-8336-437b-a281-2cb8e2b53e62\": \"Meet & Greet Reminders\",\n};\n\nasync function j(url: string, ver: string, init?: RequestInit) {\n // v1.4 — transient-failure retry WITH rate-limit awareness.\n //\n // GoHighLevel allows 100 requests per rolling 10-second window (x-ratelimit-max: 100,\n // x-ratelimit-interval-milliseconds: 10000). Over that line it does NOT return 429 — it\n // returns 401 or 403, which is indistinguishable from a dead token at the call site.\n // This val walks 22+ calendars every 15 minutes, so under any concurrent load it was\n // quietly losing whole calendars for a cycle: measured live on 2026-07-26, a burst of 24\n // calendar reads returned 403 on all 24, and a 1.5s-spaced repeat of the same three\n // returned 200 on all three.\n //\n // A silently skipped calendar is exactly the failure this val exists to prevent, so 401 and\n // 403 are retried rather than trusted. A genuinely revoked token still surfaces: it fails\n // all three attempts and every calendar, which the watchdog detects separately as\n // \"ran fine but read zero calendars and zero appointments\".\n let last: unknown;\n for (let attempt = 0; attempt < 4; attempt++) {\n if (attempt > 0) await new Promise((r) => setTimeout(r, 800 * attempt * attempt));\n let r: Response;\n try {\n r = await fetch(url, {\n ...init,\n headers: {\n Authorization: `Bearer ${TOKEN}`,\n Version: ver,\n \"Content-Type\": \"application/json\",\n ...(init?.headers ?? {}),\n },\n });\n } catch (e) {\n last = e;\n continue; // network blip — retry\n }\n if (r.ok) {\n // Back off proactively while there is still headroom, rather than reactively after\n // being refused. Cheaper than a retry and it keeps whole calendars from being lost.\n const left = Number(r.headers.get(\"x-ratelimit-remaining\") ?? \"100\");\n if (left < 20) await new Promise((res) => setTimeout(res, 1200));\n else if (left < 45) await new Promise((res) => setTimeout(res, 400));\n return r.json();\n }\n const body = (await r.text()).slice(0, 150);\n const err = new Error(`${r.status} ${url.split(\"?\")[0]} ${body}`);\n const retryable = r.status === 429 || r.status === 401 || r.status === 403 || r.status >= 500;\n if (!retryable) throw err;\n last = err;\n }\n throw last instanceof Error ? last : new Error(\"request failed after retries\");\n}\n\nfunction fmtWhen(iso: string) {\n const d = new Date(iso);\n const date = d.toLocaleDateString(\"en-US\", {\n timeZone: \"America/New_York\", weekday: \"long\", month: \"short\", day: \"numeric\",\n });\n const time = d.toLocaleTimeString(\"en-US\", {\n timeZone: \"America/New_York\", hour: \"numeric\", minute: \"2-digit\",\n });\n return `${date} at ${time}`;\n}\n\n\n// ===========================================================================\n// TASK LAYER v1.0 — the front-desk queue Kim's new hire works from, from 3 Aug.\n//\n// It lives inside this val rather than its own because val.town scopes environment variables\n// per val and offers no API to set them — a separate val would sit inert until someone pasted\n// the GoHighLevel token in by hand. This val already holds that token and already walks every\n// calendar, which is exactly what two of the three rules need. Merging removes a manual step\n// from the critical path before the hire starts, and saves ~22 duplicate API calls a run.\n//\n// The tasks are ordinary native GoHighLevel tasks. The hire cannot tell the difference and does\n// not need to. If these rules are later rebuilt as native workflows, set the mode back to \"dry\"\n// and nothing about their experience changes. A scaffold, not a dependency.\n//\n// MODE lives in the `tl_mode` blob (\"dry\" | \"live\") rather than an env var, so it can be flipped\n// without anyone opening val.town. It starts DRY: it computes exactly what it would create,\n// writes that to `tl_plan`, and creates nothing. Nothing here messages a customer — the worst\n// failure is a staff member seeing an unexpected task, which is why live is a decision.\nconst PIPELINE = \"FXt1UpCVBufbF0v3pfyf\";\nconst STAGE_NEW_LEAD = \"ccb18375-9aa1-40aa-a071-1581ca739533\";\n\n// Everything already in the account is assigned to this user; new tasks follow suit rather than\n// inventing an owner. An unassigned task appears in nobody's list, which is worse than no task.\nconst ASSIGN_TO = Deno.env.get(\"TASKS_ASSIGNEE\") ?? \"ZEIunFR1vZvYJEoPTnU1\";\n\nconst MAX_TASKS_PER_RUN = 12; // a runaway loop here fills a real person's day with noise\nconst NEW_LEAD_WINDOW_DAYS = 3; // only genuinely new leads; the 3,245 backlog is not a task queue\nconst LOOKBACK_DAYS = 7;\n\n// Appointments that are a sales conversation — attending one creates the three-way decision.\n// Everything else (drop-offs, pick-ups, lessons) is service delivery and needs no judgement call.\nconst SALES_CALENDARS = [\n \"Pup Talk Phone Call\",\n \"Free Training Day\",\n \"Free Dog Training Day\",\n \"Meet & Greet\",\n];\n\nconst LEDGER_KEY = \"tl_done\";\nconst STATE_KEY = \"tl_state\";\nconst PLAN_KEY = \"tl_plan\";\n\nconst MODE_KEY = \"tl_mode\";\n/**\n * First name for a task title. Many leads arrive from missed calls where the name lookup failed,\n * so the \"name\" is a phone fragment — a task reading \"Call (704) — first contact\" tells the hire\n * nothing and looks broken. Anything that is not clearly a name degrades to a neutral phrase.\n */\nconst first = (s?: string): string => {\n const tok = (s ?? \"\").trim().split(/\\s+/)[0] ?? \"\";\n const clean = tok.replace(/[^A-Za-z'-]/g, \"\");\n if (clean.length < 2 || /\\d/.test(tok)) return \"\";\n return clean.charAt(0).toUpperCase() + clean.slice(1).toLowerCase();\n};\nconst dayStr = (iso: string) =>\n new Date(iso).toLocaleDateString(\"en-US\", {\n timeZone: \"America/New_York\",\n weekday: \"long\",\n month: \"short\",\n day: \"numeric\",\n });\n/** Due at 5pm New York today — a task due \"now\" reads as already late. */\nfunction dueToday(): string {\n const d = new Date();\n d.setUTCHours(21, 0, 0, 0);\n if (d.getTime() < Date.now()) d.setUTCDate(d.getUTCDate() + 1);\n return d.toISOString();\n}\n\ninterface Planned {\n key: string;\n contactId: string;\n title: string;\n body: string;\n rule: string;\n}\n\nasync function runTaskLayer(): Promise {\n const out: any = {\n ok: true,\n v: \"1.0\",\n ts: new Date().toISOString(),\n mode: \"dry\",\n created: 0,\n planned: 0,\n log: [] as string[],\n };\n const modeBlob = await blob.getJSON<{ mode?: string }>(MODE_KEY).catch(() => null);\n const LIVE = String(modeBlob?.mode ?? \"dry\").toLowerCase() === \"live\";\n out.mode = LIVE ? \"LIVE\" : \"dry\";\n try {\n if (!TOKEN) throw new Error(\"GHL_TOKEN not set\");\n const now = Date.now();\n const ledger: Record =\n (await blob.getJSON(LEDGER_KEY).catch(() => null)) ?? {};\n const plan: Planned[] = [];\n\n // ---- Rule 1: a new lead we can actually reach ------------------------\n // Deliberately narrow. 82% of the New Lead stage has neither phone nor email (Messenger\n // leads, which pass no contact details), and the 3,245-record backlog is not a task queue —\n // turning it into one would bury the hire on day one. Only genuinely new, genuinely\n // contactable leads become tasks.\n const opps = await j(\n `${GHL}/opportunities/search?location_id=${LOC}&pipeline_id=${PIPELINE}` +\n `&pipeline_stage_id=${STAGE_NEW_LEAD}&limit=100`,\n \"2021-07-28\",\n );\n for (const o of opps.opportunities ?? []) {\n const c = o.contact ?? {};\n const reachable = !!(c.phone || c.email);\n const created = Date.parse(o.createdAt ?? o.dateAdded ?? \"\") || 0;\n const fresh = created > now - NEW_LEAD_WINDOW_DAYS * 86400_000;\n const key = `lead:${o.id}`;\n if (reachable && fresh && !ledger[key]) {\n plan.push({\n key,\n contactId: o.contactId,\n rule: \"new-lead\",\n title: (() => { const n = first(c.name ?? o.name); return n ? `Call ${n} — first contact, book a Pup Talk` : `Call the new enquiry — first contact, book a Pup Talk`; })(),\n body:\n `New enquiry, not yet spoken to. Ring them, and if they answer, book the Pup Talk ` +\n `while you have them.\\nIf you cannot reach them, leave a voicemail and send a text — ` +\n `then close this task, the follow-up is automatic from there.`,\n });\n }\n }\n\n // ---- Rules 2 and 3: what the calendar already knows -------------------\n const calsResp = await j(`${GHL}/calendars/?locationId=${LOC}`, \"2021-04-15\");\n const cals = (calsResp.calendars ?? []).filter((c: any) => c.isActive);\n const start = now - LOOKBACK_DAYS * 86400_000;\n for (const cal of cals) {\n let evs: any[] = [];\n try {\n const r = await j(\n `${GHL}/calendars/events?locationId=${LOC}&calendarId=${cal.id}` +\n `&startTime=${start}&endTime=${now}`,\n \"2021-04-15\",\n );\n evs = r.events ?? [];\n } catch (e) {\n out.log.push(`cal ${String(cal.id).slice(0, 6)} ERR ${String(e).slice(0, 60)}`);\n continue;\n }\n for (const e of evs) {\n const status = (e.appointmentStatus ?? \"\").toLowerCase();\n if (!e.contactId) continue;\n\n // Rule 2 — a no-show is a phone call, not a label.\n if (status === \"noshow\" && !ledger[`noshow:${e.id}`]) {\n plan.push({\n key: `noshow:${e.id}`,\n contactId: e.contactId,\n rule: \"no-show\",\n title: `Ring about the missed ${cal.name} on ${dayStr(e.startTime)}`,\n body:\n `They booked and did not come. Ring them — most of the time it is simply that ` +\n `something came up.\\nIf they want to rebook, book it now. If they have gone cold, ` +\n `close this and mark them as back into nurture.`,\n });\n }\n\n // Rule 3 — the only genuine judgement call in the whole system.\n if (\n status === \"showed\" &&\n SALES_CALENDARS.some((n) => (cal.name ?? \"\").toLowerCase().includes(n.toLowerCase())) &&\n !ledger[`decide:${e.id}`]\n ) {\n plan.push({\n key: `decide:${e.id}`,\n contactId: e.contactId,\n rule: \"decision\",\n title: `Did they buy? — ${cal.name}, ${dayStr(e.startTime)}`,\n body:\n `They came in. One of three things is true, and only you can say which:\\n` +\n ` BOUGHT — they have paid or committed to a program.\\n` +\n ` DECLINED — a clear no, for now or for good.\\n` +\n ` NURTURE — interested but not deciding yet.\\n\\n` +\n `Pick one and close this task. If you are not sure, ring them and ask — an unclosed ` +\n `task is better than a wrong answer, but a record left with no answer is worse ` +\n `than both, because nothing will ever pick it up again.`,\n });\n }\n }\n }\n\n out.planned = plan.length;\n const batch = plan.slice(0, MAX_TASKS_PER_RUN);\n await blob.setJSON(PLAN_KEY, {\n ts: out.ts,\n mode: out.mode,\n total: plan.length,\n sample: plan.slice(0, 25),\n });\n\n if (!LIVE) {\n out.log.push(\n `DRY RUN — ${plan.length} task(s) would be created (${\n batch.length\n } this run). Nothing written. See the tl_plan blob.`,\n );\n } else {\n for (const p of batch) {\n try {\n await j(`${GHL}/contacts/${p.contactId}/tasks`, \"2021-07-28\", {\n method: \"POST\",\n body: JSON.stringify({\n title: p.title,\n body: p.body,\n dueDate: dueToday(),\n completed: false,\n assignedTo: ASSIGN_TO,\n }),\n });\n ledger[p.key] = out.ts;\n out.created++;\n } catch (e) {\n out.log.push(`FAILED ${p.rule} ${p.key.slice(0, 22)}: ${String(e).slice(0, 70)}`);\n }\n }\n if (out.created) {\n const entries = Object.entries(ledger).sort((a, b) =>\n String(a[1]).localeCompare(String(b[1])),\n );\n await blob.setJSON(LEDGER_KEY, Object.fromEntries(entries.slice(-3000)));\n out.log.push(`created ${out.created} task(s)`);\n }\n }\n if (!out.log.length) out.log.push(\"nothing to do\");\n await blob.setJSON(STATE_KEY, out);\n return out;\n } catch (e) {\n out.ok = false;\n out.log.push(String(e).slice(0, 200));\n await blob.setJSON(\"tl_last_error\", { at: new Date().toISOString(), error: String(e) });\n await blob.setJSON(STATE_KEY, out);\n return out;\n }\n}\n\n// ===========================================================================\n\nexport default async function cron() {\n const out: any = { ok: true, v: \"1.9\", ts: new Date().toISOString(), testMode: TEST_MODE, sent: 0, failed: 0, log: [] as string[] };\n try {\n // 1. calendars (all active, minus exclusions)\n const calsResp = await j(`${GHL}/calendars/?locationId=${LOC}`, \"2021-04-15\");\n const cals = (calsResp.calendars ?? []).filter((c: any) => !EXCLUDE_CALS.has(c.id) && c.isActive !== false);\n out.calendars = cals.length;\n\n // 2. events across all calendars\n const now = Date.now();\n const start = now - 86400000, end = now + HORIZON_DAYS * 86400000;\n const events: any[] = [];\n for (const c of cals) {\n try {\n const r = await j(\n `${GHL}/calendars/events?locationId=${LOC}&calendarId=${c.id}&startTime=${start}&endTime=${end}`,\n \"2021-04-15\",\n );\n for (const e of r.events ?? []) events.push(e);\n } catch (err) {\n out.log.push(`cal ${c.id.slice(0, 6)} ERR ${String(err).slice(0, 80)}`);\n }\n }\n out.events = events.length;\n\n // v1.5 — CANCELLED-BUT-FUTURE DETECTOR.\n //\n // Reported by the client 27 Jul: a customer cancelled a boarding drop-off at 11:05 and still\n // received a reminder for it at 12:03, then had to ask a second time. Verified in the account.\n //\n // The cause is not this val. In GoHighLevel, cancelling an appointment does NOT pull a contact\n // out of a reminder workflow they are already sitting inside — a contact parked on a wait step\n // stays parked, and the send fires on schedule regardless of whether the appointment still\n // exists. The workflow needs an explicit exit; nothing about the cancellation provides one.\n //\n // Fixing that is interface work. What this does is make the condition VISIBLE, so a customer\n // is never again the thing that notices. Every cancelled appointment whose start time is still\n // in the future is a pending wrong message, and it is listed here until the appointment's\n // start time passes or the workflow exit is built.\n // Test contacts sit on cancelled future bookings for months at a time. Counting them would\n // make this warning permanently true, which is the fastest way to make it permanently ignored\n // — the same alert-fatigue mistake the watchdog already had to be corrected for once.\n const TEST_CONTACTS = new Set([\n \"lizYkqwFdIbMc5JwbXNh\", // \"help test\"\n \"mxf92ajJDtsZMHqJxAKv\", // \"ApptNotify TEST\" — our own reschedule-notifier test record\n ]);\n const cancelledFuture = events\n .filter((e) =>\n [\"cancelled\", \"canceled\"].includes((e.appointmentStatus ?? \"\").toLowerCase()) &&\n new Date(e.startTime).getTime() > now &&\n !TEST_CONTACTS.has(e.contactId)\n )\n .map((e) => ({\n id: e.id,\n contactId: e.contactId,\n calendar: e.calendarId,\n startTime: e.startTime,\n cancelledAt: e.dateUpdated ?? null,\n }));\n await blob.setJSON(\"apptn_cancelled_future\", {\n ts: new Date().toISOString(),\n n: cancelledFuture.length,\n items: cancelledFuture.slice(0, 50),\n });\n out.cancelledFuture = cancelledFuture.length;\n if (cancelledFuture.length) {\n out.log.push(`${cancelledFuture.length} cancelled appt(s) still in the future`);\n }\n\n // --- act on them ------------------------------------------------------\n if (GUARD_ENABLED && cancelledFuture.length) {\n const guarded: Record =\n (await blob.getJSON(\"apptn_guarded\").catch(() => null)) ?? {};\n\n // Only contacts whose entire booking picture is cancelled. One live appointment anywhere\n // in the horizon disqualifies them — they still need their reminders for that one.\n const liveByContact = new Set(\n events\n .filter((e) =>\n ![\"cancelled\", \"canceled\", \"invalid\"].includes(\n (e.appointmentStatus ?? \"\").toLowerCase(),\n ) && new Date(e.startTime).getTime() > now\n )\n .map((e) => e.contactId),\n );\n\n const candidates = cancelledFuture\n .filter((c) => c.contactId && !liveByContact.has(c.contactId) && !guarded[c.id])\n .slice(0, MAX_GUARD_PER_RUN);\n\n let removed = 0;\n for (const c of candidates) {\n let ok = 0;\n for (const wfId of Object.keys(REMINDER_WORKFLOWS)) {\n try {\n await j(`${GHL}/contacts/${c.contactId}/workflow/${wfId}`, \"2021-07-28\", {\n method: \"DELETE\",\n });\n ok++;\n } catch { /* a workflow they were never in — harmless */ }\n // 11 workflows x 5 contacts is a burst; GoHighLevel refuses at 100 per 10s and does\n // it with a 401, which would look like a dead token to anyone reading the logs later.\n await new Promise((r) => setTimeout(r, 250));\n }\n // Ledger keyed by APPOINTMENT id, not contact id: a contact who cancels again later is a\n // new event and must be guarded again.\n guarded[c.id] = new Date().toISOString();\n removed++;\n out.log.push(`guarded ${String(c.contactId).slice(0, 8)} (${ok} wf) for cancelled ${c.startTime.slice(0, 10)}`);\n }\n if (removed) {\n // Keep the ledger from growing without bound.\n const entries = Object.entries(guarded).sort((a, b) => String(a[1]).localeCompare(String(b[1])));\n const trimmed = Object.fromEntries(entries.slice(-500));\n await blob.setJSON(\"apptn_guarded\", trimmed);\n out.guarded = removed;\n }\n const skipped = cancelledFuture.filter((c) => c.contactId && liveByContact.has(c.contactId)).length;\n if (skipped) out.log.push(`${skipped} cancelled appt(s) skipped — contact still has a live booking`);\n }\n\n // 3. state + baseline\n const known: Record =\n (await blob.getJSON(\"apptn_events\").catch(() => null)) ?? {};\n const first = !(await blob.getJSON(\"apptn_baselined\").catch(() => null));\n if (first) {\n const init: Record = {};\n for (const e of events) init[e.id] = { s: e.startTime };\n await blob.setJSON(\"apptn_events\", init);\n await blob.setJSON(\"apptn_baselined\", true);\n out.log.push(`baseline ${events.length} events, no sends`);\n await blob.setJSON(\"apptn_state\", out);\n console.log(\"APPTN\", JSON.stringify(out));\n return out;\n }\n\n // 4. diff: reschedules = known id, startTime changed, future, not cancelled\n const changed = events.filter((e) =>\n known[e.id] &&\n known[e.id].s !== e.startTime &&\n ![\"cancelled\", \"invalid\", \"noshow\"].includes((e.appointmentStatus ?? \"\").toLowerCase()) &&\n new Date(e.startTime).getTime() > now\n );\n out.changed = changed.length;\n\n // 5. update state FIRST (at-most-once), for everything seen this run\n // v1.2 FIX: a reschedule pushed past the per-run cap must KEEP its OLD known start-time.\n // v1.1 wrote every event at its NEW time before applying the cap, so a deferred reschedule\n // looked unchanged on the next run and was SILENTLY NEVER SENT. That bit hardest on a bulk\n // reschedule (a closure, a weather day) — precisely the case this val exists to cover.\n const deferredIds = new Set(changed.slice(MAX_NOTIFY_PER_RUN).map((e) => e.id));\n const next: Record = {};\n for (const e of events) {\n next[e.id] = deferredIds.has(e.id) ? known[e.id] : { s: e.startTime };\n }\n await blob.setJSON(\"apptn_events\", next);\n\n const toNotify = changed.slice(0, MAX_NOTIFY_PER_RUN);\n if (changed.length > MAX_NOTIFY_PER_RUN) {\n out.log.push(`cap: ${changed.length - MAX_NOTIFY_PER_RUN} notification(s) DEFERRED to the next run (state preserved)`);\n }\n if (!toNotify.length) {\n out.log.push(\"no reschedules\");\n await blob.setJSON(\"apptn_state\", out);\n console.log(\"APPTN\", JSON.stringify(out));\n return out;\n }\n\n // 6. notify\n for (const e of toNotify) {\n try {\n let contactId = e.contactId;\n let first = \"\";\n try {\n const c = await j(`${GHL}/contacts/${e.contactId}`, \"2021-07-28\");\n first = c.contact?.firstName ?? \"\";\n if (!c.contact?.phone && !TEST_MODE) {\n out.log.push(`skip ${e.id.slice(0, 6)}: contact has no phone`);\n continue;\n }\n } catch (_) { /* proceed with id only */ }\n if (TEST_MODE) {\n if (!TEST_PHONE) throw new Error(\"APPTN_TEST on but TEST_PHONE unset\");\n const up = await j(`${GHL}/contacts/upsert`, \"2021-07-28\", {\n method: \"POST\",\n body: JSON.stringify({ locationId: LOC, phone: TEST_PHONE, firstName: \"ApptNotify\", lastName: \"TEST\" }),\n });\n contactId = up.contact?.id ?? up.id;\n }\n const hi = first ? `Hi ${first}, ` : \"Hi, \";\n const msg = `${TEST_MODE ? \"[TEST] \" : \"\"}${hi}your appointment with The Dogs Spot has been updated to ${fmtWhen(e.startTime)}. Reply here with any questions - The Dogs Spot`;\n await j(`${GHL}/conversations/messages`, \"2021-04-15\", {\n method: \"POST\",\n body: JSON.stringify({ type: \"SMS\", contactId, message: msg }),\n });\n out.sent++;\n out.log.push(`notified ${e.id.slice(0, 8)} -> ${fmtWhen(e.startTime)}${TEST_MODE ? \" [TEST reroute]\" : \"\"}`);\n } catch (err) {\n out.failed++;\n out.log.push(`FAIL ${e.id.slice(0, 8)}: ${String(err).slice(0, 120)}`);\n }\n }\n // Task layer runs last and is fully isolated: a fault in the queue must never stop a\n // customer being told their appointment moved.\n try {\n out.tasks = await runTaskLayer();\n } catch (e) {\n out.log.push(`tasklayer ERR ${String(e).slice(0, 90)}`);\n }\n\n await blob.setJSON(\"apptn_state\", out);\n console.log(\"APPTN\", JSON.stringify(out));\n return out;\n } catch (err) {\n out.ok = false;\n out.error = String(err);\n await blob.setJSON(\"apptn_last_error\", { at: new Date().toISOString(), error: String(err) }).catch(() => {});\n await blob.setJSON(\"apptn_state\", out).catch(() => {});\n console.log(\"APPTN\", JSON.stringify(out));\n return out;\n }\n}\n","// APPT UPDATE NOTIFY v1.0 — texts the customer when a staff-rescheduled appointment changes time.\n// Built 23 Jul 2026 after the 23 Jul reschedule case: staff moved a Service Dog Pick-Up by phone and\n// nothing texted her — GHL has no published workflow for reschedules (AppointmentUpdate sits in draft),\n// no Service Dog Pick-Up confirmation workflow at all, and the calendar has zero notifications.\n//\n// HOW IT WORKS\n// Every 15 min: list ALL calendars (minus the 2 Pups Club class calendars), fetch events from\n// now-1d to now+60d, and diff each event's startTime against blob state.\n// - Known event whose startTime CHANGED, status confirmed/new, new start in the future\n// -> SMS the contact the new time. (At-most-once: state updated BEFORE sending; cap 3/run.)\n// - New event ids are recorded silently (booking confirmations remain the per-calendar workflows' job\n// — this val NEVER sends on new bookings, so no double-texting).\n// - Cancelled events update state silently (v1 scope: reschedules only).\n// Test mode: set env APPTN_TEST=true to reroute every send to TEST_PHONE via contact upsert.\n//\n// State blobs: apptn_state (per-run report) · apptn_events (id -> {s: startTime}) · apptn_last_error\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst GHL = \"https://services.leadconnectorhq.com\";\nconst TOKEN = Deno.env.get(\"GHL_TOKEN\");\nconst LOC = \"BQHJ19uohldYe3eqA0bl\";\nconst EXCLUDE_CALS = new Set([\n \"cCmCBJGScp2R0JvfYlCj\", // Community Group Lesson (Pups Club - has its own announce val)\n \"PF1pYhk5QIrhBD33wUk0\", // P.U.P.S Club Community lesson\n]);\n// v1.1: reads APPTN_TEST (renamed from TEST_MODE — a UI env-var edit corrupted the old value).\n// LIVE is the default: test mode only when APPTN_TEST is exactly \"true\".\nconst TEST_MODE = (Deno.env.get(\"APPTN_TEST\") ?? \"\").trim().toLowerCase() === \"true\";\nconst TEST_PHONE = Deno.env.get(\"TEST_PHONE\");\nconst HORIZON_DAYS = 60;\nconst MAX_NOTIFY_PER_RUN = 3;\n\n// v1.7 — CANCELLATION GUARD.\n//\n// GoHighLevel does not remove a contact from a reminder workflow when their appointment is\n// cancelled. A contact already parked on a wait step stays parked and the reminder fires on\n// schedule for a booking that no longer exists. Confirmed live 27 Jul: a customer cancelled at\n// 11:05 and was reminded at 12:03, then had to ask a second time.\n//\n// The obvious fix is a guard workflow built in the interface. This does it from here instead,\n// because the API exposes DELETE /contacts/{id}/workflow/{wf} and that means the fix can be a\n// system rather than a thing someone remembers to do.\n//\n// SAFETY — the reason this is conservative rather than clever:\n// GoHighLevel's API cannot report which workflow a calendar triggers, nor which workflows a\n// contact is currently enrolled in. Any calendar-to-workflow mapping would be name-matching,\n// and name-matching on this account has already been wrong once. So the rule avoids needing a\n// mapping at all: a contact is only touched when EVERY one of their bookings in the horizon is\n// cancelled. Someone with nothing booked should not be receiving a reminder about anything, so\n// removal from every reminder chain is correct regardless of which one they were actually in.\n// A DELETE for a workflow they were never in is a harmless no-op.\nconst GUARD_ENABLED = (Deno.env.get(\"APPTN_GUARD\") ?? \"on\").toLowerCase() !== \"off\";\nconst MAX_GUARD_PER_RUN = 5; // a bug here would touch client records; cap the blast radius\n\n// Published reminder/confirmation workflows. Over-inclusive on purpose — see above.\nconst REMINDER_WORKFLOWS: Record = {\n \"ed9b9f1f-d329-48c0-96e1-95f6d33267bf\": \"Boarding Pick-Up - Confirmation + Reminder\",\n \"e325d629-e5f0-4bfc-943b-a3e6ad2bc93d\": \"Boarding Drop-Off - Confirmation + Reminder\",\n \"77e5d6ce-682a-4ba4-82f7-a8ddba902384\": \"General Pick Up > Confirmation + reminders\",\n \"0287f0a0-b3b0-45a4-92a7-ecd18971a62c\": \"Basic Drop Off > Confirmation + reminders\",\n \"8ae9ec30-9cd7-4115-b6b2-887124b768f6\": \"Community Drop Off > Confirmation + reminders\",\n \"eb4b4a73-1d46-44a0-8204-29718a7bc05b\": \"Bundle Drop Off > Confirmation + reminders\",\n \"6c3d44ad-4aa7-4861-9518-03ce55829f86\": \"Leash Free Drop Off > Confirmation + reminders\",\n \"a4f39500-7e3e-445f-9f7f-3e0761c6082a\": \"Service Dog Drop Off > Confirmation + reminders\",\n \"509ab141-7698-40a3-bb69-72c61f4a2c31\": \"Service Dog Drop Off [Confirmation + Reminder]\",\n \"abb37b6f-4e11-4544-8836-f933511c5c12\": \"Private Lesson Confirmation and Reminders\",\n \"3bcbe539-8336-437b-a281-2cb8e2b53e62\": \"Meet & Greet Reminders\",\n};\n\nasync function j(url: string, ver: string, init?: RequestInit) {\n // v1.4 — transient-failure retry WITH rate-limit awareness.\n //\n // GoHighLevel allows 100 requests per rolling 10-second window (x-ratelimit-max: 100,\n // x-ratelimit-interval-milliseconds: 10000). Over that line it does NOT return 429 — it\n // returns 401 or 403, which is indistinguishable from a dead token at the call site.\n // This val walks 22+ calendars every 15 minutes, so under any concurrent load it was\n // quietly losing whole calendars for a cycle: measured live on 2026-07-26, a burst of 24\n // calendar reads returned 403 on all 24, and a 1.5s-spaced repeat of the same three\n // returned 200 on all three.\n //\n // A silently skipped calendar is exactly the failure this val exists to prevent, so 401 and\n // 403 are retried rather than trusted. A genuinely revoked token still surfaces: it fails\n // all three attempts and every calendar, which the watchdog detects separately as\n // \"ran fine but read zero calendars and zero appointments\".\n let last: unknown;\n for (let attempt = 0; attempt < 4; attempt++) {\n if (attempt > 0) await new Promise((r) => setTimeout(r, 800 * attempt * attempt));\n let r: Response;\n try {\n r = await fetch(url, {\n ...init,\n headers: {\n Authorization: `Bearer ${TOKEN}`,\n Version: ver,\n \"Content-Type\": \"application/json\",\n ...(init?.headers ?? {}),\n },\n });\n } catch (e) {\n last = e;\n continue; // network blip — retry\n }\n if (r.ok) {\n // Back off proactively while there is still headroom, rather than reactively after\n // being refused. Cheaper than a retry and it keeps whole calendars from being lost.\n const left = Number(r.headers.get(\"x-ratelimit-remaining\") ?? \"100\");\n if (left < 20) await new Promise((res) => setTimeout(res, 1200));\n else if (left < 45) await new Promise((res) => setTimeout(res, 400));\n return r.json();\n }\n const body = (await r.text()).slice(0, 150);\n const err = new Error(`${r.status} ${url.split(\"?\")[0]} ${body}`);\n const retryable = r.status === 429 || r.status === 401 || r.status === 403 || r.status >= 500;\n if (!retryable) throw err;\n last = err;\n }\n throw last instanceof Error ? last : new Error(\"request failed after retries\");\n}\n\nfunction fmtWhen(iso: string) {\n const d = new Date(iso);\n const date = d.toLocaleDateString(\"en-US\", {\n timeZone: \"America/New_York\", weekday: \"long\", month: \"short\", day: \"numeric\",\n });\n const time = d.toLocaleTimeString(\"en-US\", {\n timeZone: \"America/New_York\", hour: \"numeric\", minute: \"2-digit\",\n });\n return `${date} at ${time}`;\n}\n\n\n// ===========================================================================\n// TASK LAYER v1.0 — the front-desk queue Kim's new hire works from, from 3 Aug.\n//\n// It lives inside this val rather than its own because val.town scopes environment variables\n// per val and offers no API to set them — a separate val would sit inert until someone pasted\n// the GoHighLevel token in by hand. This val already holds that token and already walks every\n// calendar, which is exactly what two of the three rules need. Merging removes a manual step\n// from the critical path before the hire starts, and saves ~22 duplicate API calls a run.\n//\n// The tasks are ordinary native GoHighLevel tasks. The hire cannot tell the difference and does\n// not need to. If these rules are later rebuilt as native workflows, set the mode back to \"dry\"\n// and nothing about their experience changes. A scaffold, not a dependency.\n//\n// MODE lives in the `tl_mode` blob (\"dry\" | \"live\") rather than an env var, so it can be flipped\n// without anyone opening val.town. It starts DRY: it computes exactly what it would create,\n// writes that to `tl_plan`, and creates nothing. Nothing here messages a customer — the worst\n// failure is a staff member seeing an unexpected task, which is why live is a decision.\nconst PIPELINE = \"FXt1UpCVBufbF0v3pfyf\";\nconst STAGE_NEW_LEAD = \"ccb18375-9aa1-40aa-a071-1581ca739533\";\n\n// Everything already in the account is assigned to this user; new tasks follow suit rather than\n// inventing an owner. An unassigned task appears in nobody's list, which is worse than no task.\nconst ASSIGN_TO = Deno.env.get(\"TASKS_ASSIGNEE\") ?? \"ZEIunFR1vZvYJEoPTnU1\";\n\nconst MAX_TASKS_PER_RUN = 12; // a runaway loop here fills a real person's day with noise\nconst NEW_LEAD_WINDOW_DAYS = 3; // only genuinely new leads; the 3,245 backlog is not a task queue\nconst LOOKBACK_DAYS = 7;\n\n// Appointments that are a sales conversation — attending one creates the three-way decision.\n// Everything else (drop-offs, pick-ups, lessons) is service delivery and needs no judgement call.\nconst SALES_CALENDARS = [\n \"Pup Talk Phone Call\",\n \"Free Training Day\",\n \"Free Dog Training Day\",\n \"Meet & Greet\",\n];\n\nconst LEDGER_KEY = \"tl_done\";\nconst STATE_KEY = \"tl_state\";\nconst PLAN_KEY = \"tl_plan\";\n\nconst MODE_KEY = \"tl_mode\";\n/**\n * First name for a task title. Many leads arrive from missed calls where the name lookup failed,\n * so the \"name\" is a phone fragment — a task reading \"Call (704) — first contact\" tells the hire\n * nothing and looks broken. Anything that is not clearly a name degrades to a neutral phrase.\n */\nconst first = (s?: string): string => {\n const tok = (s ?? \"\").trim().split(/\\s+/)[0] ?? \"\";\n const clean = tok.replace(/[^A-Za-z'-]/g, \"\");\n if (clean.length < 2 || /\\d/.test(tok)) return \"\";\n return clean.charAt(0).toUpperCase() + clean.slice(1).toLowerCase();\n};\nconst dayStr = (iso: string) =>\n new Date(iso).toLocaleDateString(\"en-US\", {\n timeZone: \"America/New_York\",\n weekday: \"long\",\n month: \"short\",\n day: \"numeric\",\n });\n/** Due at 5pm New York today — a task due \"now\" reads as already late. */\nfunction dueToday(): string {\n const d = new Date();\n d.setUTCHours(21, 0, 0, 0);\n if (d.getTime() < Date.now()) d.setUTCDate(d.getUTCDate() + 1);\n return d.toISOString();\n}\n\ninterface Planned {\n key: string;\n contactId: string;\n title: string;\n body: string;\n rule: string;\n}\n\nasync function runTaskLayer(): Promise {\n const out: any = {\n ok: true,\n v: \"1.0\",\n ts: new Date().toISOString(),\n mode: \"dry\",\n created: 0,\n planned: 0,\n log: [] as string[],\n };\n const modeBlob = await blob.getJSON<{ mode?: string }>(MODE_KEY).catch(() => null);\n const LIVE = String(modeBlob?.mode ?? \"dry\").toLowerCase() === \"live\";\n out.mode = LIVE ? \"LIVE\" : \"dry\";\n try {\n if (!TOKEN) throw new Error(\"GHL_TOKEN not set\");\n const now = Date.now();\n const ledger: Record =\n (await blob.getJSON(LEDGER_KEY).catch(() => null)) ?? {};\n const plan: Planned[] = [];\n\n // ---- Rule 1: a new lead we can actually reach ------------------------\n // Deliberately narrow. 82% of the New Lead stage has neither phone nor email (Messenger\n // leads, which pass no contact details), and the 3,245-record backlog is not a task queue —\n // turning it into one would bury the hire on day one. Only genuinely new, genuinely\n // contactable leads become tasks.\n const opps = await j(\n `${GHL}/opportunities/search?location_id=${LOC}&pipeline_id=${PIPELINE}` +\n `&pipeline_stage_id=${STAGE_NEW_LEAD}&limit=100`,\n \"2021-07-28\",\n );\n for (const o of opps.opportunities ?? []) {\n const c = o.contact ?? {};\n const reachable = !!(c.phone || c.email);\n const created = Date.parse(o.createdAt ?? o.dateAdded ?? \"\") || 0;\n const fresh = created > now - NEW_LEAD_WINDOW_DAYS * 86400_000;\n const key = `lead:${o.id}`;\n if (reachable && fresh && !ledger[key]) {\n plan.push({\n key,\n contactId: o.contactId,\n rule: \"new-lead\",\n title: (() => { const n = first(c.name ?? o.name); return n ? `Call ${n} — first contact, book a Pup Talk` : `Call the new enquiry — first contact, book a Pup Talk`; })(),\n body:\n `New enquiry, not yet spoken to. Ring them, and if they answer, book the Pup Talk ` +\n `while you have them.\\nIf you cannot reach them, leave a voicemail and send a text — ` +\n `then close this task, the follow-up is automatic from there.`,\n });\n }\n }\n\n // ---- Rules 2 and 3: what the calendar already knows -------------------\n const calsResp = await j(`${GHL}/calendars/?locationId=${LOC}`, \"2021-04-15\");\n const cals = (calsResp.calendars ?? []).filter((c: any) => c.isActive);\n const start = now - LOOKBACK_DAYS * 86400_000;\n for (const cal of cals) {\n let evs: any[] = [];\n try {\n const r = await j(\n `${GHL}/calendars/events?locationId=${LOC}&calendarId=${cal.id}` +\n `&startTime=${start}&endTime=${now}`,\n \"2021-04-15\",\n );\n evs = r.events ?? [];\n } catch (e) {\n out.log.push(`cal ${String(cal.id).slice(0, 6)} ERR ${String(e).slice(0, 60)}`);\n continue;\n }\n for (const e of evs) {\n const status = (e.appointmentStatus ?? \"\").toLowerCase();\n if (!e.contactId) continue;\n\n // Rule 2 — a no-show is a phone call, not a label.\n if (status === \"noshow\" && !ledger[`noshow:${e.id}`]) {\n plan.push({\n key: `noshow:${e.id}`,\n contactId: e.contactId,\n rule: \"no-show\",\n title: `Ring about the missed ${cal.name} on ${dayStr(e.startTime)}`,\n body:\n `They booked and did not come. Ring them — most of the time it is simply that ` +\n `something came up.\\nIf they want to rebook, book it now. If they have gone cold, ` +\n `close this and mark them as back into nurture.`,\n });\n }\n\n // Rule 3 — the only genuine judgement call in the whole system.\n if (\n status === \"showed\" &&\n SALES_CALENDARS.some((n) => (cal.name ?? \"\").toLowerCase().includes(n.toLowerCase())) &&\n !ledger[`decide:${e.id}`]\n ) {\n plan.push({\n key: `decide:${e.id}`,\n contactId: e.contactId,\n rule: \"decision\",\n title: `Did they buy? — ${cal.name}, ${dayStr(e.startTime)}`,\n body:\n `They came in. One of three things is true, and only you can say which:\\n` +\n ` BOUGHT — they have paid or committed to a program.\\n` +\n ` DECLINED — a clear no, for now or for good.\\n` +\n ` NURTURE — interested but not deciding yet.\\n\\n` +\n `Pick one and close this task. If you are not sure, ring them and ask — an unclosed ` +\n `task is better than a wrong answer, but a record left with no answer is worse ` +\n `than both, because nothing will ever pick it up again.`,\n });\n }\n }\n }\n\n out.planned = plan.length;\n const batch = plan.slice(0, MAX_TASKS_PER_RUN);\n await blob.setJSON(PLAN_KEY, {\n ts: out.ts,\n mode: out.mode,\n total: plan.length,\n sample: plan.slice(0, 25),\n });\n\n if (!LIVE) {\n out.log.push(\n `DRY RUN — ${plan.length} task(s) would be created (${\n batch.length\n } this run). Nothing written. See the tl_plan blob.`,\n );\n } else {\n for (const p of batch) {\n try {\n await j(`${GHL}/contacts/${p.contactId}/tasks`, \"2021-07-28\", {\n method: \"POST\",\n body: JSON.stringify({\n title: p.title,\n body: p.body,\n dueDate: dueToday(),\n completed: false,\n assignedTo: ASSIGN_TO,\n }),\n });\n ledger[p.key] = out.ts;\n out.created++;\n } catch (e) {\n out.log.push(`FAILED ${p.rule} ${p.key.slice(0, 22)}: ${String(e).slice(0, 70)}`);\n }\n }\n if (out.created) {\n const entries = Object.entries(ledger).sort((a, b) =>\n String(a[1]).localeCompare(String(b[1])),\n );\n await blob.setJSON(LEDGER_KEY, Object.fromEntries(entries.slice(-3000)));\n out.log.push(`created ${out.created} task(s)`);\n }\n }\n if (!out.log.length) out.log.push(\"nothing to do\");\n await blob.setJSON(STATE_KEY, out);\n return out;\n } catch (e) {\n out.ok = false;\n out.log.push(String(e).slice(0, 200));\n await blob.setJSON(\"tl_last_error\", { at: new Date().toISOString(), error: String(e) });\n await blob.setJSON(STATE_KEY, out);\n return out;\n }\n}\n\n// ===========================================================================\n\nexport default async function cron() {\n const out: any = { ok: true, v: \"1.10\", ts: new Date().toISOString(), testMode: TEST_MODE, sent: 0, failed: 0, log: [] as string[] };\n try {\n // 1. calendars (all active, minus exclusions)\n const calsResp = await j(`${GHL}/calendars/?locationId=${LOC}`, \"2021-04-15\");\n const cals = (calsResp.calendars ?? []).filter((c: any) => !EXCLUDE_CALS.has(c.id) && c.isActive !== false);\n out.calendars = cals.length;\n\n // 2. events across all calendars\n const now = Date.now();\n const start = now - 86400000, end = now + HORIZON_DAYS * 86400000;\n const events: any[] = [];\n for (const c of cals) {\n try {\n const r = await j(\n `${GHL}/calendars/events?locationId=${LOC}&calendarId=${c.id}&startTime=${start}&endTime=${end}`,\n \"2021-04-15\",\n );\n for (const e of r.events ?? []) events.push(e);\n } catch (err) {\n out.log.push(`cal ${c.id.slice(0, 6)} ERR ${String(err).slice(0, 80)}`);\n }\n }\n out.events = events.length;\n\n // v1.5 — CANCELLED-BUT-FUTURE DETECTOR.\n //\n // Reported by the client 27 Jul: a customer cancelled a boarding drop-off at 11:05 and still\n // received a reminder for it at 12:03, then had to ask a second time. Verified in the account.\n //\n // The cause is not this val. In GoHighLevel, cancelling an appointment does NOT pull a contact\n // out of a reminder workflow they are already sitting inside — a contact parked on a wait step\n // stays parked, and the send fires on schedule regardless of whether the appointment still\n // exists. The workflow needs an explicit exit; nothing about the cancellation provides one.\n //\n // Fixing that is interface work. What this does is make the condition VISIBLE, so a customer\n // is never again the thing that notices. Every cancelled appointment whose start time is still\n // in the future is a pending wrong message, and it is listed here until the appointment's\n // start time passes or the workflow exit is built.\n // Test contacts sit on cancelled future bookings for months at a time. Counting them would\n // make this warning permanently true, which is the fastest way to make it permanently ignored\n // — the same alert-fatigue mistake the watchdog already had to be corrected for once.\n const TEST_CONTACTS = new Set([\n \"lizYkqwFdIbMc5JwbXNh\", // \"help test\"\n \"mxf92ajJDtsZMHqJxAKv\", // \"ApptNotify TEST\" — our own reschedule-notifier test record\n ]);\n const cancelledFuture = events\n .filter((e) =>\n [\"cancelled\", \"canceled\"].includes((e.appointmentStatus ?? \"\").toLowerCase()) &&\n new Date(e.startTime).getTime() > now &&\n !TEST_CONTACTS.has(e.contactId)\n )\n .map((e) => ({\n id: e.id,\n contactId: e.contactId,\n calendar: e.calendarId,\n startTime: e.startTime,\n cancelledAt: e.dateUpdated ?? null,\n }));\n await blob.setJSON(\"apptn_cancelled_future\", {\n ts: new Date().toISOString(),\n n: cancelledFuture.length,\n items: cancelledFuture.slice(0, 50),\n });\n out.cancelledFuture = cancelledFuture.length;\n if (cancelledFuture.length) {\n out.log.push(`${cancelledFuture.length} cancelled appt(s) still in the future`);\n }\n\n // --- act on them ------------------------------------------------------\n if (GUARD_ENABLED && cancelledFuture.length) {\n const guarded: Record =\n (await blob.getJSON(\"apptn_guarded\").catch(() => null)) ?? {};\n\n // Only contacts whose entire booking picture is cancelled. One live appointment anywhere\n // in the horizon disqualifies them — they still need their reminders for that one.\n const liveByContact = new Set(\n events\n .filter((e) =>\n ![\"cancelled\", \"canceled\", \"invalid\"].includes(\n (e.appointmentStatus ?? \"\").toLowerCase(),\n ) && new Date(e.startTime).getTime() > now\n )\n .map((e) => e.contactId),\n );\n\n const candidates = cancelledFuture\n .filter((c) => c.contactId && !liveByContact.has(c.contactId) && !guarded[c.id])\n .slice(0, MAX_GUARD_PER_RUN);\n\n let removed = 0;\n for (const c of candidates) {\n let ok = 0;\n for (const wfId of Object.keys(REMINDER_WORKFLOWS)) {\n try {\n await j(`${GHL}/contacts/${c.contactId}/workflow/${wfId}`, \"2021-07-28\", {\n method: \"DELETE\",\n });\n ok++;\n } catch { /* a workflow they were never in — harmless */ }\n // 11 workflows x 5 contacts is a burst; GoHighLevel refuses at 100 per 10s and does\n // it with a 401, which would look like a dead token to anyone reading the logs later.\n await new Promise((r) => setTimeout(r, 250));\n }\n // Ledger keyed by APPOINTMENT id, not contact id: a contact who cancels again later is a\n // new event and must be guarded again.\n guarded[c.id] = new Date().toISOString();\n removed++;\n out.log.push(`guarded ${String(c.contactId).slice(0, 8)} (${ok} wf) for cancelled ${c.startTime.slice(0, 10)}`);\n }\n if (removed) {\n // Keep the ledger from growing without bound.\n const entries = Object.entries(guarded).sort((a, b) => String(a[1]).localeCompare(String(b[1])));\n const trimmed = Object.fromEntries(entries.slice(-500));\n await blob.setJSON(\"apptn_guarded\", trimmed);\n out.guarded = removed;\n }\n const skipped = cancelledFuture.filter((c) => c.contactId && liveByContact.has(c.contactId)).length;\n if (skipped) out.log.push(`${skipped} cancelled appt(s) skipped — contact still has a live booking`);\n }\n\n // Task layer runs HERE, not at the end. The reschedule section below returns early on the\n // common \"nothing moved\" path, and on the first-run baseline — putting this after them meant\n // it never executed at all on a quiet day, which is most days. Fully isolated: a fault in\n // the queue must never stop a customer being told their appointment moved.\n try {\n out.tasks = await runTaskLayer();\n } catch (e) {\n out.log.push(`tasklayer ERR ${String(e).slice(0, 90)}`);\n }\n\n // 3. state + baseline\n const known: Record =\n (await blob.getJSON(\"apptn_events\").catch(() => null)) ?? {};\n const first = !(await blob.getJSON(\"apptn_baselined\").catch(() => null));\n if (first) {\n const init: Record = {};\n for (const e of events) init[e.id] = { s: e.startTime };\n await blob.setJSON(\"apptn_events\", init);\n await blob.setJSON(\"apptn_baselined\", true);\n out.log.push(`baseline ${events.length} events, no sends`);\n await blob.setJSON(\"apptn_state\", out);\n console.log(\"APPTN\", JSON.stringify(out));\n return out;\n }\n\n // 4. diff: reschedules = known id, startTime changed, future, not cancelled\n const changed = events.filter((e) =>\n known[e.id] &&\n known[e.id].s !== e.startTime &&\n ![\"cancelled\", \"invalid\", \"noshow\"].includes((e.appointmentStatus ?? \"\").toLowerCase()) &&\n new Date(e.startTime).getTime() > now\n );\n out.changed = changed.length;\n\n // 5. update state FIRST (at-most-once), for everything seen this run\n // v1.2 FIX: a reschedule pushed past the per-run cap must KEEP its OLD known start-time.\n // v1.1 wrote every event at its NEW time before applying the cap, so a deferred reschedule\n // looked unchanged on the next run and was SILENTLY NEVER SENT. That bit hardest on a bulk\n // reschedule (a closure, a weather day) — precisely the case this val exists to cover.\n const deferredIds = new Set(changed.slice(MAX_NOTIFY_PER_RUN).map((e) => e.id));\n const next: Record = {};\n for (const e of events) {\n next[e.id] = deferredIds.has(e.id) ? known[e.id] : { s: e.startTime };\n }\n await blob.setJSON(\"apptn_events\", next);\n\n const toNotify = changed.slice(0, MAX_NOTIFY_PER_RUN);\n if (changed.length > MAX_NOTIFY_PER_RUN) {\n out.log.push(`cap: ${changed.length - MAX_NOTIFY_PER_RUN} notification(s) DEFERRED to the next run (state preserved)`);\n }\n if (!toNotify.length) {\n out.log.push(\"no reschedules\");\n await blob.setJSON(\"apptn_state\", out);\n console.log(\"APPTN\", JSON.stringify(out));\n return out;\n }\n\n // 6. notify\n for (const e of toNotify) {\n try {\n let contactId = e.contactId;\n let first = \"\";\n try {\n const c = await j(`${GHL}/contacts/${e.contactId}`, \"2021-07-28\");\n first = c.contact?.firstName ?? \"\";\n if (!c.contact?.phone && !TEST_MODE) {\n out.log.push(`skip ${e.id.slice(0, 6)}: contact has no phone`);\n continue;\n }\n } catch (_) { /* proceed with id only */ }\n if (TEST_MODE) {\n if (!TEST_PHONE) throw new Error(\"APPTN_TEST on but TEST_PHONE unset\");\n const up = await j(`${GHL}/contacts/upsert`, \"2021-07-28\", {\n method: \"POST\",\n body: JSON.stringify({ locationId: LOC, phone: TEST_PHONE, firstName: \"ApptNotify\", lastName: \"TEST\" }),\n });\n contactId = up.contact?.id ?? up.id;\n }\n const hi = first ? `Hi ${first}, ` : \"Hi, \";\n const msg = `${TEST_MODE ? \"[TEST] \" : \"\"}${hi}your appointment with The Dogs Spot has been updated to ${fmtWhen(e.startTime)}. Reply here with any questions - The Dogs Spot`;\n await j(`${GHL}/conversations/messages`, \"2021-04-15\", {\n method: \"POST\",\n body: JSON.stringify({ type: \"SMS\", contactId, message: msg }),\n });\n out.sent++;\n out.log.push(`notified ${e.id.slice(0, 8)} -> ${fmtWhen(e.startTime)}${TEST_MODE ? \" [TEST reroute]\" : \"\"}`);\n } catch (err) {\n out.failed++;\n out.log.push(`FAIL ${e.id.slice(0, 8)}: ${String(err).slice(0, 120)}`);\n }\n }\n await blob.setJSON(\"apptn_state\", out);\n console.log(\"APPTN\", JSON.stringify(out));\n return out;\n } catch (err) {\n out.ok = false;\n out.error = String(err);\n await blob.setJSON(\"apptn_last_error\", { at: new Date().toISOString(), error: String(err) }).catch(() => {});\n await blob.setJSON(\"apptn_state\", out).catch(() => {});\n console.log(\"APPTN\", JSON.stringify(out));\n return out;\n }\n}\n","createdAt",["D",1785159837345],"branchVersion","branchId","6066b90a-8b89-4746-ac4e-53a182963eac","id","24fbb9d9-55c5-4918-8f11-adcd7616ecfb","appt_update_notify",["D",1784762994400],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","d26e64e6-cd39-4be1-b5b4-1de11cc555f8","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f56fd-bd59-724f-8163-80ffcf8235dd","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_102":98},"org",{"_94":93,"_95":96,"_97":98,"_18":54,"_99":100,"_101":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",18,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","amir5","handle","displayName","Amir","avatar","https://lh3.googleusercontent.com/a/ACg8ocILk3bwhcvrzozUWm7gxlKoBm7ZGtsgIkesW3ysOOsJ1rSQuA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":150,"_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":151,"_78":152,"_80":153,"_82":25},"tree",[145],"files",[145],"counts",{"_133":60,"_134":135,"_136":60,"_137":138,"_139":140},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":129,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_27":132},"c1089a81-d7e0-49c6-8620-21471200c79b","parentId","latest",["D",1785159837345],12,"label",[28],"pulls","branches",1,"forks","envVars",{"_141":143,"_144":60},"connections",{"_141":60,"_142":60},"count","unfilledCount",3,"emptyCount",{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":146,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_147":148,"_27":149},["D",1785159837345],"children",[],[28],["D",1784762994400],{"_94":93,"_102":98},{"_94":93,"_95":96,"_97":98,"_18":54,"_99":100,"_101":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,"_122":187,"_188":189,"_190":191,"_192":25,"_193":25,"_194":25,"_195":196,"_197":-5,"_198":-7,"_199":-7,"_200":60,"_201":25,"_202":25,"_203":-5,"_204":25,"_205":25,"_206":25,"_207":-5},"ENV",{"_158":159,"_160":161,"_162":84,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v13