[{"_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":53,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":25,"_120":-5,"_121":-5,"_122":123},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",12,"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","21d21e12-85b8-11f1-ba54-1607ee4eb77e","name","fileType","interval","content","// PUPS CLUB AUTO-SEND v2.2 — session announcements via NEW SESSION START-TIME (fixed 25 Jul 2026)\n//\n// WHY v2.1 (v2.0 was silently correct and operationally useless):\n// v2.0 only announced when a booking appeared under a MARKER contact (the owner account /\n// \"2/10 Class booking\"). Live audit of 120 days of calendar history on 25 Jul 2026:\n// 56 bookings across 25 distinct session times — the marker gesture was used ZERO times.\n// Staff open a session by booking a REAL CUSTOMER into the new slot from the GHL\n// contact-details page (48/56 events, source \"contactdetails_page\", user ZEIunFR1vZvYJEoPTnU1).\n// So on 25 Jul staff opened the 8 Aug 14:30 session by booking a customer -> v2.0 saw a\n// non-marker booking -> ignored it by design -> Kim: \"no text messages went out\".\n// The code was doing exactly what it was told. What it was told never happens.\n//\n// HOW v2.1 WORKS (the signal that actually exists):\n// A SESSION == a start-time. Bookings cluster: every real session in 120 days of history is\n// N bookings sharing one startTime (n=1..6). Announce on the FIRST booking seen at a\n// start-time we have never seen before. Every later booking at that same time is deduped\n// by pups2_seen_times, so a session announces exactly ONCE no matter how many people book it.\n// Marker bookings still work (kept as an explicit \"announce this\" gesture) but are no longer required.\n//\n// GUARDRAILS (new in 2.1, because the trigger is now broader):\n// - LEAD_TIME_MIN_H: a start-time under 24h away never announces. Real sessions are opened\n// days-to-weeks ahead (median lead time in history ~9 days); a same-day booking is someone\n// joining, not a session opening.\n// - MAX_ANNOUNCE_PER_RUN 3 (unchanged) + MAX_ANNOUNCE_PER_DAY 2 (new): hard blast ceiling.\n// Historic rate is ~1 session per 5 days, so 2/day can only ever bite on a runaway.\n// - cancelled/invalid/noshow excluded; marker contacts never texted; state written BEFORE\n// sending (at-most-once); TEST_MODE reroutes everything to TEST_PHONE.\n//\n// State blobs: pups2_seen_ids · pups2_seen_times · pups2_stage · pups2_state (per-run report) ·\n// pups2_last_error · pups2_day (new: daily announce counter). (pups_* blobs are v1 artifacts, ignored.)\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 CALS = [\n \"cCmCBJGScp2R0JvfYlCj\", // \"Community Group Lesson\" — the public widget class calendar\n \"PF1pYhk5QIrhBD33wUk0\", // \"P.U.P.S Club Community lesson\" — staff New-Appointment calendar\n];\n// Markers are no longer the trigger — kept so they are never TEXTED, and still work as an\n// explicit \"announce this\" gesture if staff ever use it.\nconst MARKERS: Record = {\n RhmsmLjIthVLYSDDPeKe: \"owner account\",\n \"1oRNQi1dv35OVKCDiib9\": \"Class booking (staff placeholder)\",\n};\nconst PIPELINE_ID = \"zL57WmEx2QFfS6QFwlAA\"; // PUPS Community Subscription\nconst STAGE_NAME = \"active subscriber\";\nconst STAGE_ID_FALLBACK = \"cfb69f99-a6ac-4d17-82f6-bd1951e12c71\"; // re-verified live 25 Jul\nconst TEST_MODE = (Deno.env.get(\"TEST_MODE\") ?? \"true\") !== \"false\";\nconst TEST_PHONE = Deno.env.get(\"TEST_PHONE\");\nconst BOOK = \"https://api.leadconnectorhq.com/widget/booking/cCmCBJGScp2R0JvfYlCj\";\nconst HORIZON_DAYS = 60;\nconst MAX_ANNOUNCE_PER_RUN = 3;\nconst MAX_ANNOUNCE_PER_DAY = 2;\nconst LEAD_TIME_MIN_H = 24;\nconst DEAD = [\"cancelled\", \"invalid\", \"noshow\"];\n\nasync function j(url: string, ver: string, init?: RequestInit) {\n // v2.3 — transient-failure retry. GoHighLevel returns sporadic 500s and 429s; before this,\n // a single 5xx threw and killed the entire cron run, silently skipping that cycle's sends.\n // Recorded example: 2026-07-25T15:39:14Z \"500 /calendars/ Internal server error\".\n // Retries only on 429/5xx (never on 4xx, which are real errors worth surfacing).\n let last: unknown;\n for (let attempt = 0; attempt < 3; attempt++) {\n if (attempt > 0) await new Promise((r) => setTimeout(r, 600 * 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) return r.json();\n const body = (await r.text()).slice(0, 200);\n const err = new Error(`${r.status} ${url.split(\"?\")[0]} ${body}`);\n if (r.status !== 429 && r.status < 500) throw err; // real error, do not retry\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}`; // \"Saturday, Aug 8 at 2:30 PM\" — exactly the string Kim approved\n}\n\nfunction etDayKey(ms: number) {\n return new Date(ms).toLocaleDateString(\"en-CA\", { timeZone: \"America/New_York\" }); // YYYY-MM-DD\n}\n\nasync function activeSubscribers(): Promise<{ id: string; phone: string; name: string }[]> {\n // stage id resolved by NAME (survives renames/config drift), cached 24h, hard fallback to the known id\n let cached = await blob.getJSON(\"pups2_stage\").catch(() => null) as { id: string; ts: number } | null;\n if (!cached || Date.now() - cached.ts > 86400000) {\n let id = STAGE_ID_FALLBACK;\n try {\n const pl = await j(`${GHL}/opportunities/pipelines?locationId=${LOC}`, \"2021-07-28\");\n const p = (pl.pipelines ?? []).find((p: any) => p.id === PIPELINE_ID);\n const hit = p?.stages?.find((s: any) => (s.name ?? \"\").toLowerCase() === STAGE_NAME);\n if (hit?.id) id = hit.id;\n } catch (_) { /* keep fallback */ }\n cached = { id, ts: Date.now() };\n await blob.setJSON(\"pups2_stage\", cached);\n }\n const r = await j(\n `${GHL}/opportunities/search?location_id=${LOC}&pipeline_id=${PIPELINE_ID}&limit=100`,\n \"2021-07-28\",\n );\n return (r.opportunities ?? [])\n .filter((o: any) =>\n (o.pipelineStageId === cached!.id || o.pipelineStageUId === cached!.id) &&\n o.status === \"open\" && !MARKERS[o.contactId]\n )\n .map((o: any) => ({\n id: o.contact?.id ?? o.contactId,\n phone: o.contact?.phone,\n name: o.contact?.name ?? \"\",\n }))\n .filter((x: any) => x.id && x.phone);\n}\n\nexport default async function cron() {\n const out: any = { ok: true, v: \"2.3\", ts: new Date().toISOString(), testMode: TEST_MODE, sent: 0, failed: 0, log: [] as string[] };\n try {\n // 1. collect current future events on both calendars\n const now = Date.now(), end = now + HORIZON_DAYS * 86400000;\n const events: any[] = [];\n for (const cal of CALS) {\n const r = await j(\n `${GHL}/calendars/events?locationId=${LOC}&calendarId=${cal}&startTime=${now}&endTime=${end}`,\n \"2021-04-15\",\n );\n for (const e of r.events ?? []) events.push({ ...e, _cal: cal });\n }\n out.events = events.length;\n\n // 2. seen-state + baseline\n const seenIds: string[] = (await blob.getJSON(\"pups2_seen_ids\").catch(() => null)) ?? [];\n const seenTimes: string[] = (await blob.getJSON(\"pups2_seen_times\").catch(() => null)) ?? [];\n const first = seenIds.length === 0 && !(await blob.getJSON(\"pups2_baselined\").catch(() => null));\n if (first) {\n await blob.setJSON(\"pups2_seen_ids\", events.map((e) => e.id).slice(-800));\n await blob.setJSON(\"pups2_seen_times\", [...new Set(events.map((e) => e.startTime))].slice(-400));\n await blob.setJSON(\"pups2_baselined\", true);\n out.log.push(`baseline ${events.length} events, no sends`);\n await blob.setJSON(\"pups2_state\", out);\n console.log(\"PUPS2\", JSON.stringify(out));\n return out;\n }\n\n // 3. NEW SESSION = a live future booking at a start-time we have never seen.\n // (v2.0 required MARKERS[e.contactId] here — that gate is what silenced the 8 Aug session.)\n const fresh = events.filter((e) => !seenIds.includes(e.id));\n out.fresh = fresh.length;\n const cutoff = now + LEAD_TIME_MIN_H * 3600000;\n const eligible = fresh.filter((e) =>\n !DEAD.includes((e.appointmentStatus ?? \"\").toLowerCase()) &&\n new Date(e.startTime).getTime() > cutoff &&\n !seenTimes.includes(e.startTime)\n );\n // one announcement per start-time, earliest-booked first\n const bySlot = new Map();\n for (const e of eligible.sort((a, b) => (a.dateAdded ?? \"\").localeCompare(b.dateAdded ?? \"\"))) {\n if (!bySlot.has(e.startTime)) bySlot.set(e.startTime, e);\n }\n let announceable = [...bySlot.values()];\n const skipped = fresh.length - eligible.length;\n if (skipped > 0) out.log.push(`${skipped} new booking(s) ignored (known session / <${LEAD_TIME_MIN_H}h out / cancelled)`);\n\n // 3b. daily blast ceiling\n const dayKey = etDayKey(now);\n const dayRec = (await blob.getJSON(\"pups2_day\").catch(() => null)) as { d: string; n: number } | null;\n const usedToday = dayRec && dayRec.d === dayKey ? dayRec.n : 0;\n const dayRoom = Math.max(0, MAX_ANNOUNCE_PER_DAY - usedToday);\n const cap = Math.min(dayRoom, MAX_ANNOUNCE_PER_RUN);\n const toAnnounce = announceable.slice(0, cap);\n const heldBack = announceable.slice(cap);\n if (heldBack.length) {\n out.log.push(`cap: ${heldBack.length} announcement(s) DEFERRED to a later run (${usedToday}/${MAX_ANNOUNCE_PER_DAY} used today) — their ids stay unseen so they are not lost`);\n }\n\n // 4. mark fresh events as seen BEFORE sending (at-most-once semantics).\n // v2.2 FIX: a session held back by either cap must NOT have its booking ids marked seen —\n // v2.1 marked every fresh id, so a deferred session became invisible on the next run and was\n // silently never announced. Same bug class as appt_update_notify v1.1. Its start-time is also\n // still absent from pups2_seen_times, so the next run picks it up cleanly.\n const heldIds = new Set(heldBack.map((e) => e.id));\n const toMarkSeen = fresh.filter((e) => !heldIds.has(e.id));\n if (toMarkSeen.length) {\n await blob.setJSON(\"pups2_seen_ids\", [...seenIds, ...toMarkSeen.map((e) => e.id)].slice(-800));\n }\n if (!toAnnounce.length) {\n out.log.push(\"no new sessions\");\n await blob.setJSON(\"pups2_state\", out);\n console.log(\"PUPS2\", JSON.stringify(out));\n return out;\n }\n await blob.setJSON(\n \"pups2_seen_times\",\n [...seenTimes, ...toAnnounce.map((e) => e.startTime)].slice(-400),\n );\n await blob.setJSON(\"pups2_day\", { d: dayKey, n: usedToday + toAnnounce.length });\n\n // 5. resolve recipients\n let recipients: { id: string; phone: string; name: string }[];\n if (TEST_MODE) {\n if (!TEST_PHONE) throw new Error(\"TEST_MODE 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: \"PupsClub\", lastName: \"TEST\" }),\n });\n recipients = [{ id: up.contact?.id ?? up.id, phone: TEST_PHONE, name: \"TEST (Amir)\" }];\n } else {\n recipients = await activeSubscribers();\n }\n out.recipients = recipients.length;\n\n // 6. send — approved wording, verbatim\n for (const e of toAnnounce) {\n const msg = `${TEST_MODE ? \"[TEST] \" : \"\"}Pups Club: a new Community Group Lesson just opened for ${fmtWhen(e.startTime)}. Spots fill fast - grab yours here: ${BOOK} - The Dogs Spot`;\n out.log.push(`announcing ${e.startTime} (opened by booking ${e.id}${MARKERS[e.contactId] ? `, marker: ${MARKERS[e.contactId]}` : \"\"})`);\n for (const rcp of recipients) {\n if (rcp.id === e.contactId) continue; // never text the person the opening booking is under\n try {\n await j(`${GHL}/conversations/messages`, \"2021-04-15\", {\n method: \"POST\",\n body: JSON.stringify({ type: \"SMS\", contactId: rcp.id, message: msg }),\n });\n out.sent++;\n out.log.push(`sent -> ${rcp.name || rcp.phone}`);\n } catch (err) {\n out.failed++;\n out.log.push(`FAIL -> ${rcp.name || rcp.phone}: ${String(err).slice(0, 120)}`);\n }\n }\n }\n await blob.setJSON(\"pups2_state\", out);\n console.log(\"PUPS2\", JSON.stringify(out));\n return out;\n } catch (err) {\n out.ok = false;\n out.error = String(err);\n await blob.setJSON(\"pups2_last_error\", { at: new Date().toISOString(), error: String(err) }).catch(() => {});\n await blob.setJSON(\"pups2_state\", out).catch(() => {});\n console.log(\"PUPS2\", JSON.stringify(out));\n return out;\n }\n}\n","// PUPS CLUB AUTO-SEND v2.2 — session announcements via NEW SESSION START-TIME (fixed 25 Jul 2026)\n//\n// WHY v2.1 (v2.0 was silently correct and operationally useless):\n// v2.0 only announced when a booking appeared under a MARKER contact (the owner account /\n// \"2/10 Class booking\"). Live audit of 120 days of calendar history on 25 Jul 2026:\n// 56 bookings across 25 distinct session times — the marker gesture was used ZERO times.\n// Staff open a session by booking a REAL CUSTOMER into the new slot from the GHL\n// contact-details page (48/56 events, source \"contactdetails_page\", user ZEIunFR1vZvYJEoPTnU1).\n// So on 25 Jul staff opened the 8 Aug 14:30 session by booking a customer -> v2.0 saw a\n// non-marker booking -> ignored it by design -> Kim: \"no text messages went out\".\n// The code was doing exactly what it was told. What it was told never happens.\n//\n// HOW v2.1 WORKS (the signal that actually exists):\n// A SESSION == a start-time. Bookings cluster: every real session in 120 days of history is\n// N bookings sharing one startTime (n=1..6). Announce on the FIRST booking seen at a\n// start-time we have never seen before. Every later booking at that same time is deduped\n// by pups2_seen_times, so a session announces exactly ONCE no matter how many people book it.\n// Marker bookings still work (kept as an explicit \"announce this\" gesture) but are no longer required.\n//\n// GUARDRAILS (new in 2.1, because the trigger is now broader):\n// - LEAD_TIME_MIN_H: a start-time under 24h away never announces. Real sessions are opened\n// days-to-weeks ahead (median lead time in history ~9 days); a same-day booking is someone\n// joining, not a session opening.\n// - MAX_ANNOUNCE_PER_RUN 3 (unchanged) + MAX_ANNOUNCE_PER_DAY 2 (new): hard blast ceiling.\n// Historic rate is ~1 session per 5 days, so 2/day can only ever bite on a runaway.\n// - cancelled/invalid/noshow excluded; marker contacts never texted; state written BEFORE\n// sending (at-most-once); TEST_MODE reroutes everything to TEST_PHONE.\n//\n// State blobs: pups2_seen_ids · pups2_seen_times · pups2_stage · pups2_state (per-run report) ·\n// pups2_last_error · pups2_day (new: daily announce counter). (pups_* blobs are v1 artifacts, ignored.)\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 CALS = [\n \"cCmCBJGScp2R0JvfYlCj\", // \"Community Group Lesson\" — the public widget class calendar\n \"PF1pYhk5QIrhBD33wUk0\", // \"P.U.P.S Club Community lesson\" — staff New-Appointment calendar\n];\n// Markers are no longer the trigger — kept so they are never TEXTED, and still work as an\n// explicit \"announce this\" gesture if staff ever use it.\nconst MARKERS: Record = {\n RhmsmLjIthVLYSDDPeKe: \"owner account\",\n \"1oRNQi1dv35OVKCDiib9\": \"Class booking (staff placeholder)\",\n};\nconst PIPELINE_ID = \"zL57WmEx2QFfS6QFwlAA\"; // PUPS Community Subscription\nconst STAGE_NAME = \"active subscriber\";\nconst STAGE_ID_FALLBACK = \"cfb69f99-a6ac-4d17-82f6-bd1951e12c71\"; // re-verified live 25 Jul\nconst TEST_MODE = (Deno.env.get(\"TEST_MODE\") ?? \"true\") !== \"false\";\nconst TEST_PHONE = Deno.env.get(\"TEST_PHONE\");\nconst BOOK = \"https://api.leadconnectorhq.com/widget/booking/cCmCBJGScp2R0JvfYlCj\";\nconst HORIZON_DAYS = 60;\nconst MAX_ANNOUNCE_PER_RUN = 3;\nconst MAX_ANNOUNCE_PER_DAY = 2;\nconst LEAD_TIME_MIN_H = 24;\nconst DEAD = [\"cancelled\", \"invalid\", \"noshow\"];\n\nasync function j(url: string, ver: string, init?: RequestInit) {\n // v2.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, 200);\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}`; // \"Saturday, Aug 8 at 2:30 PM\" — exactly the string Kim approved\n}\n\nfunction etDayKey(ms: number) {\n return new Date(ms).toLocaleDateString(\"en-CA\", { timeZone: \"America/New_York\" }); // YYYY-MM-DD\n}\n\nasync function activeSubscribers(): Promise<{ id: string; phone: string; name: string }[]> {\n // stage id resolved by NAME (survives renames/config drift), cached 24h, hard fallback to the known id\n let cached = await blob.getJSON(\"pups2_stage\").catch(() => null) as { id: string; ts: number } | null;\n if (!cached || Date.now() - cached.ts > 86400000) {\n let id = STAGE_ID_FALLBACK;\n try {\n const pl = await j(`${GHL}/opportunities/pipelines?locationId=${LOC}`, \"2021-07-28\");\n const p = (pl.pipelines ?? []).find((p: any) => p.id === PIPELINE_ID);\n const hit = p?.stages?.find((s: any) => (s.name ?? \"\").toLowerCase() === STAGE_NAME);\n if (hit?.id) id = hit.id;\n } catch (_) { /* keep fallback */ }\n cached = { id, ts: Date.now() };\n await blob.setJSON(\"pups2_stage\", cached);\n }\n const r = await j(\n `${GHL}/opportunities/search?location_id=${LOC}&pipeline_id=${PIPELINE_ID}&limit=100`,\n \"2021-07-28\",\n );\n return (r.opportunities ?? [])\n .filter((o: any) =>\n (o.pipelineStageId === cached!.id || o.pipelineStageUId === cached!.id) &&\n o.status === \"open\" && !MARKERS[o.contactId]\n )\n .map((o: any) => ({\n id: o.contact?.id ?? o.contactId,\n phone: o.contact?.phone,\n name: o.contact?.name ?? \"\",\n }))\n .filter((x: any) => x.id && x.phone);\n}\n\nexport default async function cron() {\n const out: any = { ok: true, v: \"2.4\", ts: new Date().toISOString(), testMode: TEST_MODE, sent: 0, failed: 0, log: [] as string[] };\n try {\n // 1. collect current future events on both calendars\n const now = Date.now(), end = now + HORIZON_DAYS * 86400000;\n const events: any[] = [];\n for (const cal of CALS) {\n const r = await j(\n `${GHL}/calendars/events?locationId=${LOC}&calendarId=${cal}&startTime=${now}&endTime=${end}`,\n \"2021-04-15\",\n );\n for (const e of r.events ?? []) events.push({ ...e, _cal: cal });\n }\n out.events = events.length;\n\n // 2. seen-state + baseline\n const seenIds: string[] = (await blob.getJSON(\"pups2_seen_ids\").catch(() => null)) ?? [];\n const seenTimes: string[] = (await blob.getJSON(\"pups2_seen_times\").catch(() => null)) ?? [];\n const first = seenIds.length === 0 && !(await blob.getJSON(\"pups2_baselined\").catch(() => null));\n if (first) {\n await blob.setJSON(\"pups2_seen_ids\", events.map((e) => e.id).slice(-800));\n await blob.setJSON(\"pups2_seen_times\", [...new Set(events.map((e) => e.startTime))].slice(-400));\n await blob.setJSON(\"pups2_baselined\", true);\n out.log.push(`baseline ${events.length} events, no sends`);\n await blob.setJSON(\"pups2_state\", out);\n console.log(\"PUPS2\", JSON.stringify(out));\n return out;\n }\n\n // 3. NEW SESSION = a live future booking at a start-time we have never seen.\n // (v2.0 required MARKERS[e.contactId] here — that gate is what silenced the 8 Aug session.)\n const fresh = events.filter((e) => !seenIds.includes(e.id));\n out.fresh = fresh.length;\n const cutoff = now + LEAD_TIME_MIN_H * 3600000;\n const eligible = fresh.filter((e) =>\n !DEAD.includes((e.appointmentStatus ?? \"\").toLowerCase()) &&\n new Date(e.startTime).getTime() > cutoff &&\n !seenTimes.includes(e.startTime)\n );\n // one announcement per start-time, earliest-booked first\n const bySlot = new Map();\n for (const e of eligible.sort((a, b) => (a.dateAdded ?? \"\").localeCompare(b.dateAdded ?? \"\"))) {\n if (!bySlot.has(e.startTime)) bySlot.set(e.startTime, e);\n }\n let announceable = [...bySlot.values()];\n const skipped = fresh.length - eligible.length;\n if (skipped > 0) out.log.push(`${skipped} new booking(s) ignored (known session / <${LEAD_TIME_MIN_H}h out / cancelled)`);\n\n // 3b. daily blast ceiling\n const dayKey = etDayKey(now);\n const dayRec = (await blob.getJSON(\"pups2_day\").catch(() => null)) as { d: string; n: number } | null;\n const usedToday = dayRec && dayRec.d === dayKey ? dayRec.n : 0;\n const dayRoom = Math.max(0, MAX_ANNOUNCE_PER_DAY - usedToday);\n const cap = Math.min(dayRoom, MAX_ANNOUNCE_PER_RUN);\n const toAnnounce = announceable.slice(0, cap);\n const heldBack = announceable.slice(cap);\n if (heldBack.length) {\n out.log.push(`cap: ${heldBack.length} announcement(s) DEFERRED to a later run (${usedToday}/${MAX_ANNOUNCE_PER_DAY} used today) — their ids stay unseen so they are not lost`);\n }\n\n // 4. mark fresh events as seen BEFORE sending (at-most-once semantics).\n // v2.2 FIX: a session held back by either cap must NOT have its booking ids marked seen —\n // v2.1 marked every fresh id, so a deferred session became invisible on the next run and was\n // silently never announced. Same bug class as appt_update_notify v1.1. Its start-time is also\n // still absent from pups2_seen_times, so the next run picks it up cleanly.\n const heldIds = new Set(heldBack.map((e) => e.id));\n const toMarkSeen = fresh.filter((e) => !heldIds.has(e.id));\n if (toMarkSeen.length) {\n await blob.setJSON(\"pups2_seen_ids\", [...seenIds, ...toMarkSeen.map((e) => e.id)].slice(-800));\n }\n if (!toAnnounce.length) {\n out.log.push(\"no new sessions\");\n await blob.setJSON(\"pups2_state\", out);\n console.log(\"PUPS2\", JSON.stringify(out));\n return out;\n }\n await blob.setJSON(\n \"pups2_seen_times\",\n [...seenTimes, ...toAnnounce.map((e) => e.startTime)].slice(-400),\n );\n await blob.setJSON(\"pups2_day\", { d: dayKey, n: usedToday + toAnnounce.length });\n\n // 5. resolve recipients\n let recipients: { id: string; phone: string; name: string }[];\n if (TEST_MODE) {\n if (!TEST_PHONE) throw new Error(\"TEST_MODE 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: \"PupsClub\", lastName: \"TEST\" }),\n });\n recipients = [{ id: up.contact?.id ?? up.id, phone: TEST_PHONE, name: \"TEST (Amir)\" }];\n } else {\n recipients = await activeSubscribers();\n }\n out.recipients = recipients.length;\n\n // 6. send — approved wording, verbatim\n for (const e of toAnnounce) {\n const msg = `${TEST_MODE ? \"[TEST] \" : \"\"}Pups Club: a new Community Group Lesson just opened for ${fmtWhen(e.startTime)}. Spots fill fast - grab yours here: ${BOOK} - The Dogs Spot`;\n out.log.push(`announcing ${e.startTime} (opened by booking ${e.id}${MARKERS[e.contactId] ? `, marker: ${MARKERS[e.contactId]}` : \"\"})`);\n for (const rcp of recipients) {\n if (rcp.id === e.contactId) continue; // never text the person the opening booking is under\n try {\n await j(`${GHL}/conversations/messages`, \"2021-04-15\", {\n method: \"POST\",\n body: JSON.stringify({ type: \"SMS\", contactId: rcp.id, message: msg }),\n });\n out.sent++;\n out.log.push(`sent -> ${rcp.name || rcp.phone}`);\n } catch (err) {\n out.failed++;\n out.log.push(`FAIL -> ${rcp.name || rcp.phone}: ${String(err).slice(0, 120)}`);\n }\n }\n }\n await blob.setJSON(\"pups2_state\", out);\n console.log(\"PUPS2\", JSON.stringify(out));\n return out;\n } catch (err) {\n out.ok = false;\n out.error = String(err);\n await blob.setJSON(\"pups2_last_error\", { at: new Date().toISOString(), error: String(err) }).catch(() => {});\n await blob.setJSON(\"pups2_state\", out).catch(() => {});\n console.log(\"PUPS2\", JSON.stringify(out));\n return out;\n }\n}\n","createdAt",["D",1785085884291],"branchVersion","branchId","431e7370-56d6-4f2e-907a-dd6e6906e5ca","id","c1229491-7c67-4590-879a-a0aac989ad6a","pupsclub_autosend",["D",1784716131287],"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":55,"_99":100,"_101":25},"branch",{"_13":14,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned","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":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":151,"_79":152,"_81":153,"_83":25},"tree",[145],"files",[145],"counts",{"_133":61,"_134":135,"_136":61,"_137":138,"_139":140},"contents",[124],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":125,"_32":28,"_30":31,"_126":-5,"_41":42,"_40":14,"_127":128,"_38":129,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_27":132},"81bdba11-129d-48fc-9207-6e1435d88ecd","parentId","latest",true,["D",1785085884291],11,"label",[28],"pulls","branches",1,"forks","envVars",{"_141":143,"_144":61},"connections",{"_141":61,"_142":61},"count","unfilledCount",3,"emptyCount",{"_43":125,"_32":28,"_30":31,"_126":-5,"_41":42,"_40":14,"_127":128,"_38":146,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_147":148,"_27":149},["D",1785085884291],"children",[],[28],["D",1784716131287],{"_94":93,"_102":98},{"_94":93,"_95":96,"_97":98,"_18":55,"_99":100,"_101":25},{"_13":14,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_77":-5,"_121":187,"_188":189,"_190":191,"_192":25,"_193":25,"_194":25,"_195":128,"_196":-5,"_197":-7,"_198":-7,"_199":61,"_200":25,"_201":25,"_202":-5,"_203":25,"_204":25,"_205":25,"_206":-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","fdb67791413f4386b4dbf18f354029a617f6160f","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v12