[{"_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",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_116":-5,"_20":117,"_22":118,"_119":120,"_121":122,"_25":123,"_24":-5,"_124":-5,"_125":-5,"_126":53,"_127":128,"_129":53,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","amir5","name","appt_update_notify","branchName","main","version","path","","project",{"_33":61,"_13":14,"_45":62,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":-5,"_69":-5,"_70":71,"_72":-5,"_73":53,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":94,"_95":96,"_97":98,"_99":53},"tree",[56],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":55},"id","ffdef059-e747-4a6d-9603-b3135f35abe1","main.ts","fileId","45f70574-8625-11f1-b17e-1607ee4eb77e","parentId","branchId","6066b90a-8b89-4746-ac4e-53a182963eac","branchVersion",18,"latest",true,"createdAt",["D",1785669472908],17,"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.1 — the front-desk queue Kim's new hire works from, from 3 Aug.\n// 27 Jul, later same day: Rule 4 fixed after Kim asked whether the 23 Messenger numbers were\n// already used to book a Pup Talk. They weren't, but the rule had two real gaps — see Rule 4.\n// Also 27 Jul: Kim asked for email-capture ideas — first-contact task bodies (Rule 1, Rule 4) now\n// prompt the hire to grab an email address too when it comes up naturally, at zero extra cost.\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.\n// Tags that mean \"this is not a real lead\". Candice is marking duds by hand; until there is one\n// agreed tag, the system honours anything that plainly means the same thing, so her work is never\n// wasted and the queue never hands the hire someone she has already binned.\nconst DUD_TAGS = [\n \"spam likely\", \"not a lead\", \"no dog\", \"duplicate\", \"do not contact\", \"dnc\", \"dud\", \"junk\",\n];\nconst hasDud = (tags: string[] = []) =>\n tags.some((t) => DUD_TAGS.includes(String(t).trim().toLowerCase()));\n\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\";\nconst R4_CURSOR_KEY = \"tl_r4_cursor\"; // Rule 4's own backlog-walk position, independent of Rule 1\nconst R4_PAGE_SIZE = 100; // opportunities/search hard-caps limit at 100 (SEARCH_LIMIT_EXCEEDED above that)\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 // One person should never appear twice in the queue in a single pass.\n const plannedContacts = new Set();\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] && !hasDud(c.tags) && !plannedContacts.has(o.contactId)) {\n plannedContacts.add(o.contactId);\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 — grab an email address too if it comes up naturally.\\n` +\n `If you cannot reach them, leave a voicemail and send a text — then close this task, ` +\n `the follow-up is automatic from there.`,\n });\n }\n }\n\n // ---- Rule 4: a Messenger lead that just became reachable --------------\n // Ava collects phone numbers inside Messenger conversations, sometimes while booking a Pup\n // Talk in the same conversation and sometimes not — capturing the number and getting them on\n // the calendar are two different steps. Measured 27 Jul: 23 Messenger contacts had a number\n // and nothing had picked them up. Two real gaps found the same day, while checking Kim's\n // question about those 23, both fixed here:\n // 1. This reused Rule 1's fetch — the 100 MOST RECENT New Lead opportunities. Right for\n // Rule 1 (only wants the last 3 days), wrong here: this rule exists specifically to catch\n // OLD records that only just became reachable, and most of the 23 sit outside that\n // window. Now also walks the full New Lead backlog a page at a time across runs (cursor\n // below), on top of the fast pass over the recent page, so nothing is permanently missed.\n // 2. It never checked whether the contact already had an appointment booked, so someone Ava\n // had already gotten onto the calendar herself would still get \"ring and book the Pup\n // Talk\" — confusing, and exactly what Kim's question was really asking. Now checks\n // GET /contacts/{id}/appointments first and skips anyone who already has one.\n // Also now respects Candice's dud tags, same as every other rule — it didn't before.\n async function tryPlanReachable(o: any) {\n const c = o.contact ?? {};\n const tags: string[] = c.tags ?? [];\n const key = `reachable:${o.id}`;\n if (\n !tags.includes(\"messenger\") || !c.phone || ledger[key] ||\n hasDud(c.tags) || plannedContacts.has(o.contactId)\n ) return;\n try {\n const appt = await j(`${GHL}/contacts/${o.contactId}/appointments`, \"2021-07-28\");\n if ((appt.events ?? []).length > 0) return; // already on the calendar — nothing to do\n } catch {\n // Lookup failed — fall through and still surface the task. A redundant task costs a\n // minute; a real lead going unworked because a lookup hiccuped costs a customer.\n }\n const n = first(c.name ?? o.name);\n plan.push({\n key,\n contactId: o.contactId,\n rule: \"now-reachable\",\n title: n\n ? `We have a number for ${n} now — ring and book the Pup Talk`\n : `We have a number for this Messenger enquiry now — ring and book the Pup Talk`,\n body:\n `This one came in through Messenger, so we could not text or call them before. A ` +\n `phone number has since been added and nothing is booked yet — they can be worked ` +\n `normally now.\\nRing them, book the Pup Talk if they are interested, grab an email ` +\n `if it comes up naturally, and close this either way.`,\n });\n plannedContacts.add(o.contactId);\n }\n\n // Fast pass: anyone whose underlying lead is itself recent gets caught this same run.\n for (const o of opps.opportunities ?? []) await tryPlanReachable(o);\n\n // Backstop: walk the full New Lead backlog a page at a time so an old record that only just\n // became reachable is never permanently outside what this rule looks at. The cursor wraps\n // around on reaching the end, so the whole backlog sweeps roughly every few hours.\n const r4Cursor =\n (await blob.getJSON<{ startAfter?: number; startAfterId?: string }>(R4_CURSOR_KEY).catch(\n () => null,\n )) ?? {};\n let r4Url =\n `${GHL}/opportunities/search?location_id=${LOC}&pipeline_id=${PIPELINE}` +\n `&pipeline_stage_id=${STAGE_NEW_LEAD}&limit=${R4_PAGE_SIZE}`;\n if (r4Cursor.startAfter && r4Cursor.startAfterId) {\n r4Url += `&startAfter=${r4Cursor.startAfter}&startAfterId=${r4Cursor.startAfterId}`;\n }\n const r4Data = await j(r4Url, \"2021-07-28\");\n const r4Opps = r4Data.opportunities ?? [];\n for (const o of r4Opps) await tryPlanReachable(o);\n if (r4Opps.length < R4_PAGE_SIZE || !r4Data.meta?.startAfterId) {\n await blob.setJSON(R4_CURSOR_KEY, {}); // end of the backlog — start over from the top next run\n } else {\n await blob.setJSON(R4_CURSOR_KEY, {\n startAfter: r4Data.meta.startAfter,\n startAfterId: r4Data.meta.startAfterId,\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 2b — Kim (28 Jul): a plain cancellation gets the same phone call as a\n // no-show. \"A lot of cancels are people who wanted to come but had something come up.\"\n if (status === \"cancelled\" && !ledger[`cancel:${e.id}`]) {\n plan.push({\n key: `cancel:${e.id}`,\n contactId: e.contactId,\n rule: \"cancelled\",\n title: `Ring about the cancelled ${cal.name} on ${dayStr(e.startTime)}`,\n body:\n `They cancelled rather than no-showed, which usually means something came up, ` +\n `not that they went cold. Ring them and offer to rebook.\\n` +\n `If they rebook, book it now. If they are done, close this and mark them back ` +\n `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 // ---- Rule 6: an inbound message nobody has answered -------------------\n // Kim (28 Jul): the inbox carries live booking traffic; the unanswered-past-X rule is the\n // triage layer on top of the hire's monitoring, not a replacement for it. Requires the\n // Conversations read scope added to the PIT on 31 Jul; degrades silently to a log line\n // if the scope ever disappears.\n try {\n const UNANSWERED_MIN = 45; // old enough to be genuinely dropped, not \"mid-reply\"\n const UNANSWERED_LOOKBACK_H = 48; // older than this is the backlog's problem, not triage\n const cr = await j(\n `${GHL}/conversations/search?locationId=${LOC}&limit=100`,\n \"2021-04-15\",\n );\n const convos = cr.conversations ?? [];\n for (const c of convos) {\n if (!c.contactId || !c.lastMessageDate) continue;\n const typ = String(c.lastMessageType ?? \"\").toUpperCase();\n if (typ.includes(\"CALL\") || typ.includes(\"VOICEMAIL\") || typ.includes(\"REVIEW\")) continue;\n if (String(c.lastMessageDirection ?? \"\").toLowerCase() !== \"inbound\") continue;\n const ageMin = Math.floor((now - Number(c.lastMessageDate)) / 60000);\n if (ageMin < UNANSWERED_MIN || ageMin > UNANSWERED_LOOKBACK_H * 60) continue;\n const k = `unans:${c.id}:${c.lastMessageDate}`; // a newer inbound message re-arms\n if (ledger[k]) continue;\n const who = c.fullName || c.contactName || \"a customer\";\n const chan = typ.replace(\"TYPE_\", \"\").toLowerCase() || \"message\";\n plan.push({\n key: k,\n contactId: c.contactId,\n rule: \"unanswered\",\n title: `Unanswered ${chan} from ${who} — waiting ${ageMin} min`,\n body:\n `Their last message came in and nobody has replied. Open Conversations, read it, ` +\n `answer it, then close this task.\\n` +\n `If it needs Amir or Kim, reply holding them first — a held customer waits, an ` +\n `ignored one leaves.`,\n });\n }\n } catch (e) {\n out.log.push(`R6 conversations skipped: ${String(e).slice(0, 80)}`);\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.11\", 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","deleted",false,"label",[35],{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":59,"_18":60},["D",1785669472908],"children",[],[35],"24fbb9d9-55c5-4918-8f11-adcd7616ecfb",["D",1784762994400],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","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",{"_11":12,"_115":111},"org",{"_11":12,"_108":109,"_110":111,"_70":71,"_112":113,"_114":53},"branch",{"_17":42,"_13":16,"_33":40,"_100":61,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":14,"_107":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Amir","avatar","https://lh3.googleusercontent.com/a/ACg8ocILk3bwhcvrzozUWm7gxlKoBm7ZGtsgIkesW3ysOOsJ1rSQuA=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":61,"_13":14,"_45":150,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":-5,"_69":-5,"_70":71,"_72":-5,"_73":53,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":151,"_95":152,"_97":153,"_99":53},[147],"files",[147],"counts",{"_136":77,"_137":138,"_139":77,"_31":140,"_141":142},[134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":135},[35],"pulls","branches",1,"forks",{"_143":145,"_146":77},"connections",{"_143":77,"_144":77},"count","unfilledCount",3,"emptyCount",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":148,"_18":149},[],[35],["D",1784762994400],{"_11":12,"_115":111},{"_11":12,"_108":109,"_110":111,"_70":71,"_112":113,"_114":53},{"_17":42,"_13":16,"_33":40,"_100":61,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":14,"_107":12},"ctx",{"_93":-5,"_131":187,"_188":189,"_190":191,"_192":53,"_193":53,"_194":53,"_195":44,"_196":-5,"_197":-7,"_198":-7,"_199":77,"_200":53,"_201":53,"_202":-5,"_203":53,"_204":53,"_205":53,"_206":-5},"ENV",{"_158":159,"_160":161,"_162":16,"_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","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Code