[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_344":345,"_346":347},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_106":88,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":25,"_124":-5,"_125":-5,"_126":127},"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":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",146,"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","slack.ts","latestPath","fileId","f6198156-5ad4-11f1-adee-ee650bb23af1","name","fileType","script","content","// Slack digest formatting + posting via the Slack Web API.\n// Uses SLACK_TOKEN provided by Val Town's Slack integration (dashboard).\n// Bot displays as \"Daily ARR Digest\" (username override in postToSlack).\n\nimport type { ARRReport, ARRSegment } from \"./report.ts\";\nimport { WebClient } from \"npm:@slack/web-api\";\n\ntype SlackBlock = Record;\n\nconst SLACK_CHANNEL = \"C014X5SQ9R7\"; // #general\n\n// ---- Formatting helpers -----------------------------------------------------\nconst DASH = \"—\";\n\nconst EMOJI = {\n total: \"⭐\",\n selfServe: \"👩‍🔬\",\n enterprise: \"🏫\",\n usage: \"🧑‍💻\",\n} as const;\nconst DOT = {\n new: \"🟢\",\n expansion: \"🔵\",\n contraction: \"🟠\",\n churn: \"🔴\",\n} as const;\n\nconst usd = (n: number) =>\n Math.round(Math.abs(n)).toLocaleString(\"en-US\", {\n style: \"currency\",\n currency: \"USD\",\n maximumFractionDigits: 0,\n });\n\nconst signedUsd = (n: number) => {\n const r = Math.round(n);\n return r === 0 ? \"$0\" : (r > 0 ? \"+\" : \"−\") + usd(r);\n};\n\nconst signedPct = (f: number) => {\n const p = f * 100;\n return (p > 0 ? \"+\" : p < 0 ? \"−\" : \"\") + Math.abs(p).toFixed(2) + \"%\";\n};\n\nconst arrow = (n: number) => (n > 0 ? \"▲\" : n < 0 ? \"▼\" : \"\");\n\nconst arrText = (seg: ARRSegment) => (seg.arr === null ? DASH : usd(seg.arr));\n\nfunction netLine(seg: ARRSegment): string {\n if (seg.netChange === null) return `Net change: ${DASH}`;\n const a = arrow(seg.netChange);\n const pct = seg.netChangePct !== null ? ` (${signedPct(seg.netChangePct)})` : \"\";\n return `Net change: ${a ? a + \" \" : \"\"}${signedUsd(seg.netChange)}${pct}`;\n}\n\n// New enterprise accounts, one per line — rendered as a small context block,\n// same style as the self-serve breakdown.\nfunction newAccountsText(seg: ARRSegment): string | undefined {\n return seg.newAccounts?.length ? seg.newAccounts.join(\"\\n\") : undefined;\n}\n\n// Outage note shown when a segment is rendering its cached last-good value.\nfunction staleNote(seg: ARRSegment): string | undefined {\n return seg.staleAsOf\n ? `⚠️ Source outage — showing last good value (${seg.staleAsOf})`\n : undefined;\n}\n\nfunction breakdownText(seg: ARRSegment): string | undefined {\n const bd = seg.breakdown;\n if (!bd) return undefined;\n return [\n `${DOT.new} New ${signedUsd(bd.new)} ${DOT.expansion} Expansion ${signedUsd(bd.expansion)}`,\n `${DOT.contraction} Contraction ${signedUsd(bd.contraction)} ${DOT.churn} Churn ${signedUsd(bd.churn)}`,\n ].join(\"\\n\");\n}\n\n// ---- Digest formatter -------------------------------------------------------\nexport function formatARRReport(\n r: ARRReport,\n): { text: string; blocks: SlackBlock[] } {\n const lines = [\n `${EMOJI.total} Total ARR: ${arrText(r.total)}`,\n ` ${netLine(r.total)}`,\n ``,\n `${EMOJI.selfServe} Self Serve ARR (Stripe): ${arrText(r.selfServe)}`,\n ` ${netLine(r.selfServe)}`,\n ...(breakdownText(r.selfServe)?.split(\"\\n\").map((l) => ` ${l}`) ?? []),\n ...(staleNote(r.selfServe) ? [` ${staleNote(r.selfServe)}`] : []),\n ``,\n `${EMOJI.enterprise} Enterprise ARR (HubSpot): ${arrText(r.enterprise)}`,\n ` ${netLine(r.enterprise)}`,\n ...(r.enterprise.newAccounts ?? []).map((n) => ` ${n}`),\n ...(staleNote(r.enterprise) ? [` ${staleNote(r.enterprise)}`] : []),\n ``,\n `${EMOJI.usage} Usage Revenue Run Rate (Stripe): ${arrText(r.usage)}`,\n ` ${netLine(r.usage)}`,\n ...(staleNote(r.usage) ? [` ${staleNote(r.usage)}`] : []),\n ];\n const text = lines.join(\"\\n\");\n\n const segment = (\n emoji: string,\n label: string,\n seg: ARRSegment,\n bd?: string,\n ): SlackBlock[] => {\n const blocks: SlackBlock[] = [\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: `${emoji} *${label}:* ${arrText(seg)}\\n\\n${netLine(seg)}`,\n },\n },\n ];\n if (bd) {\n blocks.push({\n type: \"context\",\n elements: [{ type: \"mrkdwn\", text: bd }],\n });\n }\n const stale = staleNote(seg);\n if (stale) {\n blocks.push({\n type: \"context\",\n elements: [{ type: \"mrkdwn\", text: stale }],\n });\n }\n return blocks;\n };\n\n const blocks: SlackBlock[] = [\n ...segment(EMOJI.total, \"Total ARR\", r.total),\n { type: \"divider\" },\n ...segment(\n EMOJI.selfServe,\n \"Self Serve ARR (Stripe)\",\n r.selfServe,\n breakdownText(r.selfServe),\n ),\n { type: \"divider\" },\n ...segment(\n EMOJI.enterprise,\n \"Enterprise ARR (HubSpot)\",\n r.enterprise,\n newAccountsText(r.enterprise),\n ),\n { type: \"divider\" },\n ...segment(EMOJI.usage, \"Usage Revenue Run Rate (Stripe)\", r.usage),\n ];\n\n return { text, blocks };\n}\n\n// ---- Post to Slack via Web API ----------------------------------------------\nexport async function postToSlack(payload: {\n text: string;\n blocks?: SlackBlock[];\n}) {\n const token = Deno.env.get(\"SLACK_TOKEN\");\n if (!token) throw new Error(\"Missing SLACK_TOKEN env var\");\n\n const client = new WebClient(token);\n await client.conversations.join({ channel: SLACK_CHANNEL }).catch(() => {});\n await client.chat.postMessage({\n channel: SLACK_CHANNEL,\n text: payload.text,\n blocks: payload.blocks as any,\n username: \"Daily ARR Digest\",\n icon_emoji: \":bar_chart:\",\n });\n}\n","// Slack digest formatting + posting via the Slack Web API.\n// Uses SLACK_TOKEN provided by Val Town's Slack integration (dashboard).\n// Bot displays as \"Daily ARR Digest\" (username override in postToSlack).\n\nimport type { ARRReport, ARRSegment } from \"./report.ts\";\nimport { WebClient } from \"npm:@slack/web-api\";\n\ntype SlackBlock = Record;\n\nconst SLACK_CHANNEL = \"C014X5SQ9R7\"; // #general\n\n// ---- Formatting helpers -----------------------------------------------------\nconst DASH = \"—\";\n\nconst EMOJI = {\n total: \"⭐\",\n selfServe: \"👩‍🔬\",\n enterprise: \"🏫\",\n usage: \"🧑‍💻\",\n} as const;\nconst DOT = {\n new: \"🟢\",\n expansion: \"🔵\",\n contraction: \"🟠\",\n churn: \"🔴\",\n} as const;\n\nconst usd = (n: number) =>\n Math.round(Math.abs(n)).toLocaleString(\"en-US\", {\n style: \"currency\",\n currency: \"USD\",\n maximumFractionDigits: 0,\n });\n\nconst signedUsd = (n: number) => {\n const r = Math.round(n);\n return r === 0 ? \"$0\" : (r > 0 ? \"+\" : \"−\") + usd(r);\n};\n\nconst signedPct = (f: number) => {\n const p = f * 100;\n return (p > 0 ? \"+\" : p < 0 ? \"−\" : \"\") + Math.abs(p).toFixed(2) + \"%\";\n};\n\nconst arrow = (n: number) => (n > 0 ? \"▲\" : n < 0 ? \"▼\" : \"\");\n\nconst arrText = (seg: ARRSegment) => (seg.arr === null ? DASH : usd(seg.arr));\n\nfunction netLine(seg: ARRSegment): string {\n if (seg.netChange === null) return `Net change: ${DASH}`;\n const a = arrow(seg.netChange);\n const pct = seg.netChangePct !== null ? ` (${signedPct(seg.netChangePct)})` : \"\";\n return `Net change: ${a ? a + \" \" : \"\"}${signedUsd(seg.netChange)}${pct}`;\n}\n\n// New enterprise accounts, one per line — rendered as a small context block,\n// same style as the self-serve breakdown.\nfunction newAccountsText(seg: ARRSegment): string | undefined {\n return seg.newAccounts?.length ? seg.newAccounts.join(\"\\n\") : undefined;\n}\n\n// Outage note shown when a segment is rendering its cached last-good value.\nfunction staleNote(seg: ARRSegment): string | undefined {\n return seg.staleAsOf\n ? `⚠️ Source unavailable or failed validation — showing last good value (${seg.staleAsOf})`\n : undefined;\n}\n\nfunction breakdownText(seg: ARRSegment): string | undefined {\n const bd = seg.breakdown;\n if (!bd) return undefined;\n return [\n `${DOT.new} New ${signedUsd(bd.new)} ${DOT.expansion} Expansion ${signedUsd(bd.expansion)}`,\n `${DOT.contraction} Contraction ${signedUsd(bd.contraction)} ${DOT.churn} Churn ${signedUsd(bd.churn)}`,\n ].join(\"\\n\");\n}\n\n// ---- Digest formatter -------------------------------------------------------\nexport function formatARRReport(\n r: ARRReport,\n): { text: string; blocks: SlackBlock[] } {\n const lines = [\n `${EMOJI.total} Total ARR: ${arrText(r.total)}`,\n ` ${netLine(r.total)}`,\n ``,\n `${EMOJI.selfServe} Self Serve ARR (Stripe): ${arrText(r.selfServe)}`,\n ` ${netLine(r.selfServe)}`,\n ...(breakdownText(r.selfServe)?.split(\"\\n\").map((l) => ` ${l}`) ?? []),\n ...(staleNote(r.selfServe) ? [` ${staleNote(r.selfServe)}`] : []),\n ``,\n `${EMOJI.enterprise} Enterprise ARR (HubSpot): ${arrText(r.enterprise)}`,\n ` ${netLine(r.enterprise)}`,\n ...(r.enterprise.newAccounts ?? []).map((n) => ` ${n}`),\n ...(staleNote(r.enterprise) ? [` ${staleNote(r.enterprise)}`] : []),\n ``,\n `${EMOJI.usage} Usage Revenue Run Rate (Stripe): ${arrText(r.usage)}`,\n ` ${netLine(r.usage)}`,\n ...(staleNote(r.usage) ? [` ${staleNote(r.usage)}`] : []),\n ];\n const text = lines.join(\"\\n\");\n\n const segment = (\n emoji: string,\n label: string,\n seg: ARRSegment,\n bd?: string,\n ): SlackBlock[] => {\n const blocks: SlackBlock[] = [\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: `${emoji} *${label}:* ${arrText(seg)}\\n\\n${netLine(seg)}`,\n },\n },\n ];\n if (bd) {\n blocks.push({\n type: \"context\",\n elements: [{ type: \"mrkdwn\", text: bd }],\n });\n }\n const stale = staleNote(seg);\n if (stale) {\n blocks.push({\n type: \"context\",\n elements: [{ type: \"mrkdwn\", text: stale }],\n });\n }\n return blocks;\n };\n\n const blocks: SlackBlock[] = [\n ...segment(EMOJI.total, \"Total ARR\", r.total),\n { type: \"divider\" },\n ...segment(\n EMOJI.selfServe,\n \"Self Serve ARR (Stripe)\",\n r.selfServe,\n breakdownText(r.selfServe),\n ),\n { type: \"divider\" },\n ...segment(\n EMOJI.enterprise,\n \"Enterprise ARR (HubSpot)\",\n r.enterprise,\n newAccountsText(r.enterprise),\n ),\n { type: \"divider\" },\n ...segment(EMOJI.usage, \"Usage Revenue Run Rate (Stripe)\", r.usage),\n ];\n\n return { text, blocks };\n}\n\n// ---- Post to Slack via Web API ----------------------------------------------\nexport async function postToSlack(payload: {\n text: string;\n blocks?: SlackBlock[];\n}) {\n const token = Deno.env.get(\"SLACK_TOKEN\");\n if (!token) throw new Error(\"Missing SLACK_TOKEN env var\");\n\n const client = new WebClient(token);\n await client.conversations.join({ channel: SLACK_CHANNEL }).catch(() => {});\n await client.chat.postMessage({\n channel: SLACK_CHANNEL,\n text: payload.text,\n blocks: payload.blocks as any,\n username: \"Daily ARR Digest\",\n icon_emoji: \":bar_chart:\",\n });\n}\n","createdAt",["D",1789091741815],"branchVersion","branchId","b4b4d058-5ad4-11f1-9419-ee650bb23af1","id","b4b31b00-5ad4-11f1-9419-ee650bb23af1","arr-bot",["D",1780000503639],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Slack bot: daily Stripe + HubSpot ARR report","imageUrl","8ad5f245-a3c1-4df3-9e50-f79fb44e9037","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e702f-9c4a-738c-b373-eee5c08e6c44","tursoName","b4b31b005ad411f19419ee650bb23af1","tursoHostname","b4b31b005ad411f19419ee650bb23af1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789509043237],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":-5},"org",{"_98":97,"_99":100,"_101":-5,"_18":-5,"_102":103,"_104":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",163,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","consensus","handle","displayName","Consensus","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":339,"_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":65,"_66":67,"_68":340,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":341,"_82":342,"_84":343,"_86":25},"tree",[274,275,276,277,278,279,280,281,282,283,284,285,286,287,288,289],"files",[274,275,276,277,278,279,280,281,282,283,284,285,286,287,288,289],"counts",{"_264":61,"_265":151,"_266":61,"_267":268,"_269":270},"contents",[128,129,130,131,132,133,134,135,136,137,138,139,140,141,142,143],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":256,"_32":257,"_30":258,"_147":-5,"_41":42,"_40":259,"_149":25,"_38":260,"_13":261,"_33":20,"_35":262,"_24":25,"_153":-5,"_27":263},{"_43":249,"_32":250,"_30":251,"_147":-5,"_41":42,"_40":252,"_149":25,"_38":253,"_13":194,"_33":34,"_35":254,"_24":25,"_153":-5,"_27":255},{"_43":241,"_32":242,"_30":243,"_147":-5,"_41":42,"_40":244,"_149":171,"_38":245,"_13":246,"_33":34,"_35":247,"_24":25,"_153":-5,"_27":248},{"_43":234,"_32":235,"_30":236,"_147":-5,"_41":42,"_40":237,"_149":171,"_38":238,"_13":61,"_33":224,"_35":239,"_24":25,"_153":-5,"_27":240},{"_43":227,"_32":228,"_30":229,"_147":-5,"_41":42,"_40":230,"_149":171,"_38":231,"_13":61,"_33":20,"_35":232,"_24":25,"_153":-5,"_27":233},{"_43":219,"_32":220,"_30":221,"_147":-5,"_41":42,"_40":222,"_149":171,"_38":223,"_13":202,"_33":224,"_35":225,"_24":25,"_153":-5,"_27":226},{"_43":212,"_32":213,"_30":214,"_147":-5,"_41":42,"_40":215,"_149":171,"_38":216,"_13":61,"_33":34,"_35":217,"_24":25,"_153":-5,"_27":218},{"_43":205,"_32":206,"_30":207,"_147":-5,"_41":42,"_40":208,"_149":171,"_38":209,"_13":61,"_33":34,"_35":210,"_24":25,"_153":-5,"_27":211},{"_43":197,"_32":198,"_30":199,"_147":-5,"_41":42,"_40":200,"_149":171,"_38":201,"_13":202,"_33":34,"_35":203,"_24":25,"_153":-5,"_27":204},{"_43":189,"_32":190,"_30":191,"_147":-5,"_41":42,"_40":192,"_149":171,"_38":193,"_13":194,"_33":34,"_35":195,"_24":25,"_153":-5,"_27":196},{"_43":182,"_32":183,"_30":184,"_147":-5,"_41":42,"_40":185,"_149":171,"_38":186,"_13":61,"_33":34,"_35":187,"_24":25,"_153":-5,"_27":188},{"_43":175,"_32":176,"_30":177,"_147":-5,"_41":42,"_40":178,"_149":25,"_38":179,"_13":160,"_33":34,"_35":180,"_24":25,"_153":-5,"_27":181},{"_43":167,"_32":168,"_30":169,"_147":-5,"_41":42,"_40":170,"_149":171,"_38":172,"_13":61,"_33":34,"_35":173,"_24":25,"_153":-5,"_27":174},{"_43":163,"_32":28,"_30":31,"_147":-5,"_41":42,"_40":14,"_149":25,"_38":164,"_13":165,"_33":34,"_35":37,"_24":25,"_153":-5,"_27":166},{"_43":155,"_32":156,"_30":157,"_147":-5,"_41":42,"_40":158,"_149":25,"_38":159,"_13":160,"_33":34,"_35":161,"_24":25,"_153":-5,"_27":162},{"_43":144,"_32":145,"_30":146,"_147":-5,"_41":42,"_40":148,"_149":25,"_38":150,"_13":151,"_33":34,"_35":152,"_24":25,"_153":-5,"_27":154},"c13e4033-0ceb-41e7-bd71-8ee6f1bf53a0","usage.ts","2e542248-6e48-11f1-971d-1607ee4eb77e","parentId",91,"latest",["D",1782139607619],1,"// Stripe API usage run-rate via the Analytics API.\n//\n// Run rate = trailing 28 complete days of metered \"usage revenue\" × 13\n// (4 weeks × 13 ≈ a full year). Source metric:\n// `usage_based_billing.gross_usage_revenue` — the same number the Stripe\n// dashboard shows under Billing overview → Usage (\"Usage revenue\"), already\n// FX-converted to USD by Stripe.\n//\n// Window is the 28 days ending YESTERDAY (today's partial day excluded). We\n// request a few extra days and slice(-28) so any timezone-boundary sliver at\n// the start drops off and we always sum exactly 28 complete days.\n//\n// Net change = today's run rate vs the run rate as-of yesterday (the same\n// 28-day window shifted back one day). Computed from the same response, so no\n// snapshot state is needed; it's null until there's a full prior window.\n//\n// Auth: STRIPE_SECRET_KEY must have the Analytics read permission (in addition\n// to the Sigma scopes used by stripe.ts).\n\nconst ANALYTICS_URL = \"https://api.stripe.com/v2/data/analytics/metric_query\";\nconst VERSION = \"2026-04-22.preview\";\n\nexport interface UsageRunRate {\n runRate: number; // trailing-28d usage revenue × 13, USD\n windowRevenue: number; // trailing-28d usage revenue, USD\n netChange: number | null; // run rate vs prior day's run rate, USD\n netChangePct: number | null; // fraction of prior run rate\n windowStart: string; // first day in window (YYYY-MM-DD)\n windowEnd: string; // last day in window (YYYY-MM-DD)\n}\n\nexport async function fetchApiUsageRunRate(): Promise {\n const key = Deno.env.get(\"STRIPE_SECRET_KEY\");\n if (!key) throw new Error(\"Missing STRIPE_SECRET_KEY env var\");\n\n const now = new Date();\n // today 00:00 UTC — exclusive end, so today's partial day is never counted.\n const endsAt = new Date(Date.UTC(now.getUTCFullYear(), now.getUTCMonth(), now.getUTCDate()));\n const startsAt = new Date(endsAt.getTime() - 35 * 86_400_000); // extra days; sliced to 28 below\n\n const res = await fetch(ANALYTICS_URL, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${key}`,\n \"Stripe-Version\": VERSION,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n metrics: [{ name: \"usage_based_billing.gross_usage_revenue\" }],\n starts_at: startsAt.toISOString(),\n ends_at: endsAt.toISOString(),\n granularity: \"day\",\n currency: \"usd\",\n }),\n });\n if (!res.ok) {\n throw new Error(`Stripe Analytics ${res.status}: ${await res.text()}`);\n }\n\n const data = await res.json() as {\n data?: { timestamp?: string; results?: { value?: number }[] }[];\n };\n\n const todayStr = endsAt.toISOString().slice(0, 10);\n const series = (data.data ?? [])\n .map((b) => ({\n day: String(b.timestamp ?? \"\").slice(0, 10),\n usd: (b.results ?? []).reduce((s, r) => s + Number(r.value ?? 0), 0) / 100,\n }))\n .filter((d) => d.day < todayStr) // drop today's partial day\n .sort((a, b) => (a.day < b.day ? -1 : 1));\n\n const sum = (xs: { usd: number }[]) => xs.reduce((s, d) => s + d.usd, 0);\n const window28 = series.slice(-28); // trailing 28 complete days (ends yesterday)\n const priorWindow28 = series.slice(-29, -1); // same window shifted back one day\n\n const windowRevenue = sum(window28);\n const runRate = windowRevenue * 13;\n\n let netChange: number | null = null;\n let netChangePct: number | null = null;\n if (priorWindow28.length === 28) {\n const priorRunRate = sum(priorWindow28) * 13;\n netChange = runRate - priorRunRate;\n netChangePct = priorRunRate ? netChange / priorRunRate : null;\n }\n\n return {\n runRate,\n windowRevenue,\n netChange,\n netChangePct,\n windowStart: window28[0]?.day ?? \"\",\n windowEnd: window28[window28.length - 1]?.day ?? \"\",\n };\n}\n","label",[145],"897c9813-eccf-47d7-90bc-6bb69e954240","stripe.ts","ee25b5fa-5ad4-11f1-909e-ee650bb23af1",145,["D",1789091740513],9,"// Stripe ARR via Sigma (Reports API v2 Query Runs) — matches the dashboard.\n//\n// Why Sigma instead of summing the /v1/subscriptions REST endpoint:\n// The dashboard's MRR/ARR is NOT a naive sum of subscription line items.\n// Stripe pre-computes a signed `mrr_change` for every subscription-item\n// event (already accounting for discounts, trials=$0, proration, quantity,\n// upgrades/downgrades, cancellations) in the table\n// `subscription_item_change_events_v2_beta`. Cumulatively summing those\n// deltas reproduces the dashboard MRR exactly; ARR = MRR * 12.\n// This is the same source Stripe's own \"Total ARR\" Sigma template uses.\n//\n// It's also multi-currency: mrr_change is in each sub's own currency, so we\n// convert to USD using the daily `exchange_rates_from_usd` table (mirroring\n// the dashboard's FX handling).\n//\n// Event-type allow-list: the `_v2_beta` table's taxonomy changes without\n// notice. On 2026-09-09 Stripe backfilled TRIAL_START / TRIAL_END /\n// CONVERT_TRIAL rows; CONVERT_TRIAL carries MRR that ACTIVE_START already\n// counts, which inflated a naive SUM(mrr_change) by ~73% for two digests.\n// Every query below is restricted to the ACTIVE_* types, so anything new\n// Stripe adds falls out until it's deliberately classified here.\n//\n// Sanity guard: fetchStripeARRReport() cross-checks the computed ARR against\n// Stripe's own `revenue.arr` Analytics metric and throws if they diverge by\n// more than ARR_GUARD_TOLERANCE. report.ts turns that throw into the\n// stale-value fallback with a warning, so a suspect headline is never posted.\n//\n// All amounts returned in US dollars.\n\nimport { runSigmaQuery } from \"./sigma.ts\";\n\n// event_type -> movement bucket (taxonomy of subscription_item_change_events_v2_beta):\n// ACTIVE_START -> new (incl. reactivations)\n// ACTIVE_UPGRADE / ACTIVE_QUANTITY_INCREASE -> expansion\n// ACTIVE_DOWNGRADE / ACTIVE_QUANTITY_DECREASE -> contraction\n// ACTIVE_END -> churn\n// TRIAL_START / TRIAL_END / CONVERT_TRIAL -> excluded (see header)\nconst ACTIVE_EVENT_TYPES =\n `('ACTIVE_START','ACTIVE_END','ACTIVE_UPGRADE','ACTIVE_DOWNGRADE','ACTIVE_QUANTITY_INCREASE','ACTIVE_QUANTITY_DECREASE')`;\n\nexport interface DayMovement {\n day: string; // YYYY-MM-DD\n total: number; // total ARR as of end of this day (USD)\n new: number; // new ARR added (incl. reactivations), USD\n expansion: number; // upgrades / quantity increases, USD\n contraction: number; // downgrades / quantity decreases, USD (negative)\n churn: number; // cancellations, USD (negative)\n net: number; // sum of the movement buckets, USD\n}\n\nconst minorToDollars = (s: string | undefined) => Number(s ?? 0) / 100;\n\n// Shared FX CTEs: rate map per day (dashboard shifts the rate table back one\n// day) plus the latest published rate as a fallback for unpublished days.\nconst FX_CTES = `\nfx AS (\n SELECT date - INTERVAL '1' DAY AS date,\n CAST(JSON_PARSE(buy_currency_exchange_rates) AS MAP(VARCHAR, DOUBLE)) AS rate\n FROM exchange_rates_from_usd\n),\nfx_latest AS (SELECT rate FROM fx ORDER BY date DESC LIMIT 1)\n`;\n\n// ---- Total current ARR ------------------------------------------------------\n// Current MRR per currency = SUM of all mrr_change to date. Convert each\n// currency to USD at the latest published FX rate, sum, * 12.\nconst TOTAL_ARR_SQL = `\nWITH fx_latest AS (\n SELECT CAST(JSON_PARSE(buy_currency_exchange_rates) AS MAP(VARCHAR, DOUBLE)) AS rate\n FROM exchange_rates_from_usd\n ORDER BY date DESC\n LIMIT 1\n),\nmrr AS (\n SELECT currency, SUM(CAST(mrr_change AS DOUBLE)) AS mrr_minor\n FROM subscription_item_change_events_v2_beta\n WHERE event_type IN ${ACTIVE_EVENT_TYPES}\n GROUP BY currency\n)\nSELECT CAST(ROUND(SUM(m.mrr_minor / element_at(f.rate, m.currency)) * 12) AS BIGINT) AS arr_usd_minor\nFROM mrr m\nCROSS JOIN fx_latest f\nWHERE element_at(f.rate, m.currency) IS NOT NULL\n`;\n\nexport async function fetchStripeARR(): Promise {\n const { rows } = await runSigmaQuery(TOTAL_ARR_SQL);\n return minorToDollars(rows[0]?.arr_usd_minor);\n}\n\n// ---- Daily ARR movement, bucketed ------------------------------------------\n// Per local-event day: new / expansion / contraction / churn / net, in USD.\nfunction movementSQL(days: number): string {\n const n = Math.max(1, Math.floor(days));\n return `\nWITH ${FX_CTES},\nev AS (\n SELECT DATE(local_event_timestamp) AS day, currency, event_type,\n CAST(mrr_change AS DOUBLE) AS mrr_change\n FROM subscription_item_change_events_v2_beta\n WHERE DATE(local_event_timestamp) >= CURRENT_DATE - INTERVAL '${n}' DAY\n AND event_type IN ${ACTIVE_EVENT_TYPES}\n),\nconv AS (\n SELECT e.day, e.event_type,\n e.mrr_change / COALESCE(element_at(f.rate, e.currency),\n element_at(lf.rate, e.currency)) AS mrr_usd\n FROM ev e\n LEFT JOIN fx f ON f.date = e.day\n CROSS JOIN fx_latest lf\n)\nSELECT\n CAST(day AS VARCHAR) AS day,\n CAST(ROUND(SUM(IF(event_type = 'ACTIVE_START', mrr_usd, 0)) * 12) AS BIGINT) AS new_minor,\n CAST(ROUND(SUM(IF(event_type IN ('ACTIVE_UPGRADE','ACTIVE_QUANTITY_INCREASE'), mrr_usd, 0)) * 12) AS BIGINT) AS expansion_minor,\n CAST(ROUND(SUM(IF(event_type IN ('ACTIVE_DOWNGRADE','ACTIVE_QUANTITY_DECREASE'), mrr_usd, 0)) * 12) AS BIGINT) AS contraction_minor,\n CAST(ROUND(SUM(IF(event_type = 'ACTIVE_END', mrr_usd, 0)) * 12) AS BIGINT) AS churn_minor,\n CAST(ROUND(SUM(mrr_usd) * 12) AS BIGINT) AS net_minor\nFROM conv\nGROUP BY day\n`;\n}\n\n// ---- Total ARR as of the end of each day -----------------------------------\n// Cumulative MRR per currency forward-filled across a daily spine (same\n// approach as the dashboard's ARR template), FX-converted at each day's rate,\n// * 12. Window-limited at the end so the cumulative carries full history.\nfunction dailyTotalSQL(days: number): string {\n const n = Math.max(1, Math.floor(days));\n return `\nWITH ${FX_CTES},\nchanges AS (\n SELECT DATE(local_event_timestamp) AS day, currency,\n SUM(CAST(mrr_change AS DOUBLE)) AS d_mrr\n FROM subscription_item_change_events_v2_beta\n WHERE event_type IN ${ACTIVE_EVENT_TYPES}\n GROUP BY 1, 2\n),\nwindow_days AS (\n SELECT d AS day\n FROM UNNEST(SEQUENCE(CURRENT_DATE - INTERVAL '${n}' DAY, CURRENT_DATE, INTERVAL '1' DAY)) t(d)\n),\n-- cumulative MRR per currency as of each window day = all changes on/before it\ncum AS (\n SELECT wd.day, ch.currency, SUM(ch.d_mrr) AS cum_mrr\n FROM window_days wd\n JOIN changes ch ON ch.day <= wd.day\n GROUP BY wd.day, ch.currency\n)\nSELECT\n CAST(c.day AS VARCHAR) AS day,\n CAST(ROUND(SUM(c.cum_mrr /\n COALESCE(element_at(f.rate, c.currency), element_at(lf.rate, c.currency))) * 12) AS BIGINT) AS total_arr_minor\nFROM cum c\nLEFT JOIN fx f ON f.date = c.day\nCROSS JOIN fx_latest lf\nGROUP BY c.day\n`;\n}\n\nexport async function fetchStripeARRMovementByDay(\n days = 7,\n): Promise {\n // Run movement + running-total queries concurrently, then merge by day.\n const [mv, tot] = await Promise.all([\n runSigmaQuery(movementSQL(days)),\n runSigmaQuery(dailyTotalSQL(days)),\n ]);\n\n const moveByDay = new Map(mv.rows.map((r) => [r.day, r]));\n return tot.rows // dense: one row per day in window\n .map((r) => {\n const m = moveByDay.get(r.day);\n return {\n day: r.day,\n total: minorToDollars(r.total_arr_minor),\n new: minorToDollars(m?.new_minor),\n expansion: minorToDollars(m?.expansion_minor),\n contraction: minorToDollars(m?.contraction_minor),\n churn: minorToDollars(m?.churn_minor),\n net: minorToDollars(m?.net_minor),\n };\n })\n .sort((a, b) => (a.day < b.day ? 1 : -1)); // newest first\n}\n\n// ---- Sanity guard: Stripe's own ARR metric ---------------------------------\n// Independent reference from the Analytics API (`revenue.arr`, latest day).\n// Returns null — and the guard is skipped — if the Analytics call itself\n// fails, so an Analytics outage can't take the digest down with it.\nconst ARR_GUARD_TOLERANCE = 0.05; // 5% — normal drift vs the metric is ~0.1-1%\n\nasync function fetchStripeReferenceARR(): Promise {\n const key = Deno.env.get(\"STRIPE_SECRET_KEY\");\n if (!key) return null;\n const now = new Date();\n const endsAt = new Date(Date.UTC(now.getUTCFullYear(), now.getUTCMonth(), now.getUTCDate()));\n const startsAt = new Date(endsAt.getTime() - 3 * 86_400_000);\n try {\n const res = await fetch(\"https://api.stripe.com/v2/data/analytics/metric_query\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${key}`,\n \"Stripe-Version\": \"2026-04-22.preview\",\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n metrics: [{ name: \"revenue.arr\" }],\n starts_at: startsAt.toISOString(),\n ends_at: endsAt.toISOString(),\n granularity: \"day\",\n currency: \"usd\",\n }),\n });\n if (!res.ok) {\n console.warn(`ARR guard: Analytics ${res.status} — skipping cross-check`);\n return null;\n }\n const data = await res.json() as {\n data?: { results?: { value?: string | number }[] }[];\n };\n const latest = data.data?.at(-1)?.results?.[0]?.value;\n return latest === undefined ? null : Number(latest) / 100;\n } catch (err) {\n console.warn(`ARR guard: ${(err as Error).message} — skipping cross-check`);\n return null;\n }\n}\n\n// ---- Assembled report for the daily digest ---------------------------------\n// Headline ARR = current total; \"net change\" covers the most recent complete\n// day (the day before today), with % expressed against that day's starting ARR.\nexport interface StripeARRReport {\n asOfARR: number; // current self-serve ARR (all currencies -> USD)\n day: string; // the day the net change covers (YYYY-MM-DD)\n net: number;\n netPct: number; // fraction of prior-day ARR (0.0001 = 0.01%)\n new: number;\n expansion: number;\n contraction: number;\n churn: number;\n}\n\nexport async function fetchStripeARRReport(): Promise {\n const [series, reference] = await Promise.all([\n fetchStripeARRMovementByDay(8), // newest-first, incl. today\n fetchStripeReferenceARR(),\n ]);\n const today = new Date().toISOString().slice(0, 10);\n const i = series.findIndex((m) => m.day < today); // most recent complete day\n const row = series[i] ?? series[0];\n const prior = series[i + 1]; // the day before the reporting day\n const priorARR = prior?.total ?? row.total - row.net;\n const asOfARR = series[0]?.total ?? row.total;\n\n if (reference !== null && reference > 0) {\n const diff = (asOfARR - reference) / reference;\n console.log(\n `ARR guard: computed $${Math.round(asOfARR).toLocaleString()} vs Stripe revenue.arr $${Math.round(reference).toLocaleString()} (${(diff * 100).toFixed(2)}%)`,\n );\n if (Math.abs(diff) > ARR_GUARD_TOLERANCE) {\n throw new Error(\n `ARR sanity check failed: computed $${Math.round(asOfARR).toLocaleString()} vs Stripe revenue.arr $${Math.round(reference).toLocaleString()} (${(diff * 100).toFixed(1)}% off) — refusing to post a suspect number`,\n );\n }\n }\n\n return {\n asOfARR,\n day: row.day,\n net: row.net,\n netPct: priorARR ? row.net / priorARR : 0,\n new: row.new,\n expansion: row.expansion,\n contraction: row.contraction,\n churn: row.churn,\n };\n}\n",[156],"e41ca117-22b2-4d3b-965e-68f59ed78416",["D",1789091741815],25,[28],"1fa15d5c-5af1-11f1-81a2-ee650bb23af1","sigma.ts","1fa15e24-5af1-11f1-81a2-ee650bb23af1",17,true,["D",1780012708937],"// Run a SQL query against Stripe Sigma via the Reports API v2 Query Runs.\n// Pattern: submit SQL -> poll until \"succeeded\" -> download CSV -> parse rows.\n//\n// Requires STRIPE_SECRET_KEY with `reporting_write` + `sigma_api_write` scopes\n// (shown as \"Sigma\" and \"Sigma API\" in the dashboard) and an active Sigma sub.\n// Queries cold-start a query engine, so expect ~20-40s latency per call.\n\nconst VERSION = \"2026-04-22.preview\";\nconst BASE = \"https://api.stripe.com/v2/data/reporting/query_runs\";\n\nfunction getKey(): string {\n const k = Deno.env.get(\"STRIPE_SECRET_KEY\");\n if (!k) throw new Error(\"Missing STRIPE_SECRET_KEY env var\");\n return k;\n}\n\ninterface QueryRun {\n id: string;\n status: \"running\" | \"succeeded\" | \"failed\" | \"canceled\";\n status_details?: unknown;\n result?: { file?: { download_url?: { url?: string } } } | null;\n}\n\n// Minimal RFC-4180 CSV parser: quoted fields, embedded commas/newlines, \"\" escapes.\nfunction parseCSV(text: string): string[][] {\n const rows: string[][] = [];\n let row: string[] = [];\n let field = \"\";\n let inQuotes = false;\n for (let i = 0; i < text.length; i++) {\n const c = text[i];\n if (inQuotes) {\n if (c === '\"') {\n if (text[i + 1] === '\"') {\n field += '\"';\n i++;\n } else inQuotes = false;\n } else field += c;\n } else if (c === '\"') inQuotes = true;\n else if (c === \",\") {\n row.push(field);\n field = \"\";\n } else if (c === \"\\n\") {\n row.push(field);\n rows.push(row);\n row = [];\n field = \"\";\n } else if (c !== \"\\r\") field += c;\n }\n if (field.length > 0 || row.length > 0) {\n row.push(field);\n rows.push(row);\n }\n return rows;\n}\n\nexport interface SigmaResult {\n columns: string[];\n rows: Record[];\n}\n\nexport async function runSigmaQuery(\n sql: string,\n { timeoutMs = 150_000, pollMs = 3000 }: { timeoutMs?: number; pollMs?: number } = {},\n): Promise {\n const headers = {\n Authorization: `Bearer ${getKey()}`,\n \"Stripe-Version\": VERSION,\n \"Content-Type\": \"application/json\",\n };\n\n const submit = await fetch(BASE, {\n method: \"POST\",\n headers,\n body: JSON.stringify({ sql }),\n });\n if (!submit.ok) {\n throw new Error(`Sigma submit ${submit.status}: ${await submit.text()}`);\n }\n let run = await submit.json() as QueryRun;\n\n const deadline = Date.now() + timeoutMs;\n while (run.status === \"running\") {\n if (Date.now() > deadline) {\n throw new Error(`Sigma query timed out after ${timeoutMs}ms (id ${run.id})`);\n }\n await new Promise((r) => setTimeout(r, pollMs));\n const res = await fetch(`${BASE}/${run.id}`, { headers });\n if (!res.ok) throw new Error(`Sigma poll ${res.status}: ${await res.text()}`);\n run = await res.json() as QueryRun;\n }\n\n if (run.status !== \"succeeded\") {\n throw new Error(`Sigma query ${run.status}: ${JSON.stringify(run.status_details)}`);\n }\n\n const url = run.result?.file?.download_url?.url;\n if (!url) throw new Error(\"Sigma query succeeded but returned no download URL\");\n const csv = await (await fetch(url)).text();\n\n const table = parseCSV(csv);\n if (table.length === 0) return { columns: [], rows: [] };\n const [columns, ...dataRows] = table;\n const rows = dataRows\n .filter((r) => r.length === columns.length)\n .map((r) => Object.fromEntries(columns.map((c, i) => [c, r[i]])));\n return { columns, rows };\n}\n",[168],"ba43d37a-928c-4b7f-b1dd-b558c613ac53","report.ts","8ce396ca-5af4-11f1-9141-ee650bb23af1",120,["D",1785692586029],"// Cross-source ARR report model assembled for the Slack digest.\n//\n// Self-serve (Stripe) is live via Sigma.\n// Enterprise (HubSpot) sums a deal property across closed-won deals, with\n// daily SQLite snapshots for net change tracking.\n// Usage run-rate (Stripe Analytics) is trailing-28d metered usage revenue × 13.\n// Total = self-serve + enterprise + usage run-rate.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { fetchStripeARRReport } from \"./stripe.ts\";\nimport { fetchEnterpriseARR } from \"./hubspot.ts\";\nimport { fetchApiUsageRunRate } from \"./usage.ts\";\n\nexport interface ARRSegment {\n arr: number | null;\n netChange: number | null;\n netChangePct: number | null;\n breakdown?: {\n new: number;\n expansion: number;\n contraction: number;\n churn: number;\n };\n newAccounts?: string[]; // enterprise only: deals closed-won since prior day\n staleAsOf?: string; // set when the source is down and arr is the cached last good value (YYYY-MM-DD)\n}\n\nexport interface ARRReport {\n periodLabel: string;\n total: ARRSegment;\n selfServe: ARRSegment;\n enterprise: ARRSegment;\n usage: ARRSegment;\n}\n\n// ---- Last-good cache --------------------------------------------------------\n// A failing source must not take down the whole digest. Each successful fetch\n// caches its headline number; when a source is down we show that cached value,\n// clearly marked as stale, instead of \"—\". (Seen live: Stripe's preview\n// Analytics metric erroring server-side for days at a time.)\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS segment_last_good (\n segment TEXT PRIMARY KEY,\n arr_usd REAL NOT NULL,\n day TEXT NOT NULL\n )\n`);\n\nasync function rememberGood(segment: string, arr: number) {\n await sqlite.execute({\n sql: \"INSERT OR REPLACE INTO segment_last_good (segment, arr_usd, day) VALUES (?, ?, ?)\",\n args: [segment, arr, new Date().toISOString().slice(0, 10)],\n });\n}\n\n// Segment shown when its source is down: last good value marked stale, or\n// fully blank (\"—\") if the source has never succeeded.\nasync function staleSegment(segment: string): Promise {\n const res = await sqlite.execute({\n sql: \"SELECT arr_usd, day FROM segment_last_good WHERE segment = ?\",\n args: [segment],\n });\n const row = res.rows[0] as Record | undefined;\n return row\n ? {\n arr: row.arr_usd as number,\n netChange: null,\n netChangePct: null,\n staleAsOf: row.day as string,\n }\n : { arr: null, netChange: null, netChangePct: null };\n}\n\nconst settle = (p: Promise, label: string): Promise =>\n p.catch((err) => {\n console.error(`${label} fetch failed: ${(err as Error).message}`);\n return null;\n });\n\nexport async function buildARRReport(): Promise {\n const [s, e, u] = await Promise.all([\n settle(fetchStripeARRReport(), \"self-serve (Stripe Sigma)\"),\n settle(fetchEnterpriseARR(), \"enterprise (HubSpot)\"),\n settle(fetchApiUsageRunRate(), \"usage run-rate (Stripe Analytics)\"),\n ]);\n\n const selfServe: ARRSegment = s\n ? {\n arr: s.asOfARR,\n netChange: s.net,\n netChangePct: s.netPct,\n breakdown: {\n new: s.new,\n expansion: s.expansion,\n contraction: s.contraction,\n churn: s.churn,\n },\n }\n : await staleSegment(\"selfServe\");\n if (s) await rememberGood(\"selfServe\", s.asOfARR);\n\n const enterprise: ARRSegment = e\n ? {\n arr: e.arr,\n netChange: e.netChange,\n netChangePct: e.netChangePct,\n newAccounts: e.newAccounts,\n }\n : await staleSegment(\"enterprise\");\n if (e) await rememberGood(\"enterprise\", e.arr);\n\n const usage: ARRSegment = u\n ? {\n arr: u.runRate,\n netChange: u.netChange,\n netChangePct: u.netChangePct,\n }\n : await staleSegment(\"usage\");\n if (u) await rememberGood(\"usage\", u.runRate);\n\n // Total = self-serve + enterprise + usage run-rate. Stale values count\n // toward the sum (better than faking a giant one-day drop); the stale note\n // on the affected section flags the caveat. Net change sums whichever\n // segments have a delta (stale segments contribute 0). Total renders \"—\"\n // only when a segment is down with no cached value at all.\n const segments = [selfServe, enterprise, usage];\n const anyDown = segments.some((seg) => seg.arr === null);\n const totalArr = anyDown\n ? null\n : segments.reduce((t, seg) => t + (seg.arr ?? 0), 0);\n const totalNetChange =\n totalArr === null || segments.every((seg) => seg.netChange === null)\n ? null\n : segments.reduce((t, seg) => t + (seg.netChange ?? 0), 0);\n const priorTotal = totalNetChange !== null && totalArr !== null\n ? totalArr - totalNetChange\n : null;\n const totalNetChangePct =\n priorTotal && totalNetChange !== null ? totalNetChange / priorTotal : null;\n\n const total: ARRSegment = {\n arr: totalArr,\n netChange: totalNetChange,\n netChangePct: totalNetChangePct,\n };\n\n const periodLabel = s?.day ?? new Date().toISOString().slice(0, 10);\n return { periodLabel, total, selfServe, enterprise, usage };\n}\n",[176],"d838d7dd-2287-4c15-9b89-9b165282e5d8","query-usage.ts","2fe816aa-6e48-11f1-b57c-1607ee4eb77e",89,["D",1782139174552],"// Manual validation: prints the API usage run-rate (trailing 28d × 13) and the\n// window it covers. Spot-check the window revenue against the Stripe dashboard:\n// Billing overview → Usage → \"Usage revenue\" (Last 4 weeks).\n\nimport { fetchApiUsageRunRate } from \"./usage.ts\";\n\nconst usd = (n: number) =>\n n.toLocaleString(\"en-US\", { style: \"currency\", currency: \"USD\", maximumFractionDigits: 2 });\n\nconst r = await fetchApiUsageRunRate();\nconsole.log(`Window: ${r.windowStart} → ${r.windowEnd} (28 complete days)`);\nconsole.log(`Trailing 28d usage revenue: ${usd(r.windowRevenue)}`);\nconsole.log(`API run rate (× 13): ${usd(r.runRate)}`);\n",[183],"164d31e8-5af3-11f1-8592-ee650bb23af1","query-stripe.ts","81fe9de0-5ad6-11f1-805b-ee650bb23af1",23,["D",1780013552266],3,"// Manual validation script — run with run_file to check Stripe ARR vs the\n// Stripe dashboard. Prints:\n// 1. Total active ARR (USD)\n// 2. Daily breakdown for the last N days: new / expansion / contraction /\n// churn / net movement, plus total ARR as of end of each day (USD).\n//\n// Source: Stripe Sigma (subscription_item_change_events_v2_beta), the same\n// table the dashboard's ARR derives from. See stripe.ts for the queries.\n\nimport { fetchStripeARR, fetchStripeARRMovementByDay } from \"./stripe.ts\";\n\nconst DAYS = 7;\n\nconst fmt = (n: number) =>\n n.toLocaleString(\"en-US\", {\n style: \"currency\",\n currency: \"USD\",\n maximumFractionDigits: 0,\n });\nconst c = (n: number) => fmt(n).padStart(12);\nconst cWide = (n: number) => fmt(n).padStart(14);\n\nconst [total, movement] = await Promise.all([\n fetchStripeARR(),\n fetchStripeARRMovementByDay(DAYS),\n]);\n\nconsole.log(\"=\".repeat(92));\nconsole.log(`Total Stripe ARR (current, all currencies -> USD): ${fmt(total)}`);\nconsole.log(\"=\".repeat(92));\nconsole.log();\nconsole.log(`Daily breakdown — last ${DAYS} days (USD):`);\nconsole.log(\n \" note: 'new' includes reactivations; net = new + expansion + contraction + churn\",\n);\nconsole.log(\n \" 'total arr' = running total ARR as of end of that day\",\n);\nconsole.log(\"-\".repeat(92));\nconsole.log(\n \"DAY\".padEnd(12) +\n \"NEW\".padStart(12) +\n \"EXPANSION\".padStart(12) +\n \"CONTRACT\".padStart(12) +\n \"CHURN\".padStart(12) +\n \"NET\".padStart(12) +\n \"TOTAL ARR\".padStart(14),\n);\nconsole.log(\"-\".repeat(92));\n\nfor (const m of movement) {\n console.log(\n m.day.padEnd(12) +\n c(m.new) +\n c(m.expansion) +\n c(m.contraction) +\n c(m.churn) +\n c(m.net) +\n cWide(m.total),\n );\n}\nconsole.log(\"-\".repeat(92));\n\nconst sum = (k: \"new\" | \"expansion\" | \"contraction\" | \"churn\" | \"net\") =>\n movement.reduce((s, m) => s + m[k], 0);\nconsole.log(\n \"SUM(flows)\".padEnd(12) +\n c(sum(\"new\")) +\n c(sum(\"expansion\")) +\n c(sum(\"contraction\")) +\n c(sum(\"churn\")) +\n c(sum(\"net\")) +\n cWide(movement[0]?.total ?? 0), // current ARR (latest day)\n);\n",[190],"d4257cc2-5b05-11f1-b2d4-ee650bb23af1","query-hubspot.ts","b4a981d2-5b04-11f1-b0ac-ee650bb23af1",67,["D",1780021601725],2,"// Manual validation script: queries HubSpot for closed-won deals across all\n// pipelines, prints per-deal amount + term + computed ACV, and shows the total\n// the bot will report. Useful for spot-checking against the source-of-truth\n// sheet whenever the multi-year math feels off.\n\nimport { fetchEnterpriseARR } from \"./hubspot.ts\";\n\nconst usd = (n: number) =>\n Math.round(n).toLocaleString(\"en-US\", {\n style: \"currency\",\n currency: \"USD\",\n maximumFractionDigits: 0,\n });\n\nconst token = Deno.env.get(\"HUBSPOT_TOKEN\")!;\nconst res = await fetch(\"https://api.hubapi.com/crm/v3/objects/deals/search\", {\n method: \"POST\",\n headers: { Authorization: `Bearer ${token}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n filterGroups: [{\n filters: [{\n propertyName: \"dealstage\",\n operator: \"IN\",\n values: [\"closedwon\", \"238829588\"],\n }],\n }],\n properties: [\"dealname\", \"amount\", \"term_years\", \"pipeline\", \"closedate\"],\n limit: 100,\n }),\n});\nconst data = await res.json();\nconst pipelineLabel = (p: string) =>\n p === \"default\" ? \"Sales\" : p === \"139030823\" ? \"Trial\" : p;\n\nconst rows = (data.results ?? [])\n .map((d: any) => {\n const amount = Number(d.properties.amount ?? 0);\n const term = Number(d.properties.term_years ?? 0);\n const acv = term > 0 ? amount / term : amount;\n return {\n name: d.properties.dealname ?? \"(no name)\",\n amount,\n term,\n acv,\n pipeline: pipelineLabel(d.properties.pipeline ?? \"\"),\n closedate: (d.properties.closedate ?? \"\").slice(0, 10),\n };\n })\n .sort((a: any, b: any) => b.acv - a.acv);\n\nconsole.log(`Closed-won deals across both pipelines: ${rows.length}\\n`);\nconsole.log(\n ` ${\"name\".padEnd(55)} ${\"amount\".padStart(10)} ${\"term\".padStart(5)} ${\"ACV\".padStart(10)} pipeline closedate`,\n);\nfor (const r of rows) {\n const termStr = r.term > 0 ? `${r.term}yr` : \"—\";\n console.log(\n ` ${r.name.slice(0, 55).padEnd(55)} ${usd(r.amount).padStart(10)} ${termStr.padStart(5)} ${usd(r.acv).padStart(10)} ${r.pipeline.padEnd(7)} ${r.closedate}`,\n );\n}\n\nconst totalACV = rows.reduce((t: number, r: any) => t + r.acv, 0);\nconst totalAmount = rows.reduce((t: number, r: any) => t + r.amount, 0);\nconst dealsMissingTerm = rows.filter((r: any) => r.term === 0).length;\n\nconsole.log(`\\nTotal amount (TCV): ${usd(totalAmount)}`);\nconsole.log(`Total ACV (what we send): ${usd(totalACV)}`);\nconsole.log(`Deals missing term_years: ${dealsMissingTerm} of ${rows.length} (treated as 1yr)`);\n\nconsole.log(`\\n--- via fetchEnterpriseARR() (what the bot will report) ---`);\nconst r = await fetchEnterpriseARR();\nconsole.log(`Enterprise ARR: ${usd(r.arr)}`);\nconsole.log(`Net change vs yesterday: ${\n r.netChange === null ? \"— (no prior snapshot yet)\" : usd(r.netChange)\n}`);\n",[198],"5c8f53b7-8036-4753-997d-fe201e9ca363","probe-analytics.ts","d2f75846-8f50-11f1-9a8e-1607ee4eb77e",128,["D",1785771272449],"// Throwaway: systematic diagnostic of the failing Analytics usage metric.\n// Captures Stripe request IDs (req_...) for a support ticket.\n\nconst KEY = Deno.env.get(\"STRIPE_SECRET_KEY\")!;\nconst H = {\n Authorization: `Bearer ${KEY}`,\n \"Stripe-Version\": \"2026-04-22.preview\",\n \"Content-Type\": \"application/json\",\n};\n\nasync function q(label: string, body: Record) {\n const res = await fetch(\"https://api.stripe.com/v2/data/analytics/metric_query\", {\n method: \"POST\",\n headers: H,\n body: JSON.stringify(body),\n });\n const text = await res.text();\n let detail = \"\";\n try {\n const j = JSON.parse(text);\n if (res.ok) {\n const buckets = j?.data?.length ?? 0;\n const sum = (j?.data ?? []).reduce(\n (s: number, b: any) => s + (b.results ?? []).reduce((t: number, r: any) => t + Number(r.value ?? 0), 0),\n 0,\n );\n detail = `${buckets} buckets, sum $${(sum / 100).toFixed(2)}`;\n } else {\n const reqId = (j?.error?.request_log_url ?? \"\").split(\"/\").pop();\n detail = `${j?.error?.code} | ${reqId}`;\n }\n } catch {\n detail = text.slice(0, 100);\n }\n console.log(`${res.ok ? \"✅\" : \"❌\"} [${res.status}] ${label} — ${detail}`);\n}\n\nconst USAGE = \"usage_based_billing.gross_usage_revenue\";\n\n// -- Is it still failing right now? Current window.\nawait q(\"usage: current 28d window\", {\n metrics: [{ name: USAGE }],\n starts_at: \"2026-07-05T00:00:00Z\",\n ends_at: \"2026-08-02T00:00:00Z\",\n granularity: \"day\",\n currency: \"usd\",\n});\n\n// -- Historical windows that DEFINITELY worked before (validated Jun 22 + ran daily Jul 17-30).\nawait q(\"usage: all-June window (worked on Jun 22)\", {\n metrics: [{ name: USAGE }],\n starts_at: \"2026-06-01T00:00:00Z\",\n ends_at: \"2026-06-22T00:00:00Z\",\n granularity: \"day\",\n currency: \"usd\",\n});\nawait q(\"usage: May window\", {\n metrics: [{ name: USAGE }],\n starts_at: \"2026-05-01T00:00:00Z\",\n ends_at: \"2026-05-15T00:00:00Z\",\n granularity: \"day\",\n currency: \"usd\",\n});\n\n// -- Single day, minimal request.\nawait q(\"usage: single day Jul 1, no currency\", {\n metrics: [{ name: USAGE }],\n starts_at: \"2026-07-01T00:00:00Z\",\n ends_at: \"2026-07-02T00:00:00Z\",\n granularity: \"day\",\n});\n\n// -- With group_by / filters (dimensions: price, product, customer, meter).\nawait q(\"usage: group_by meter\", {\n metrics: [{ name: USAGE }],\n starts_at: \"2026-07-20T00:00:00Z\",\n ends_at: \"2026-07-27T00:00:00Z\",\n granularity: \"day\",\n currency: \"usd\",\n group_by: [\"meter\"],\n});\n\n// -- Week/month granularity.\nawait q(\"usage: week granularity\", {\n metrics: [{ name: USAGE }],\n starts_at: \"2026-07-01T00:00:00Z\",\n ends_at: \"2026-07-29T00:00:00Z\",\n granularity: \"week\",\n currency: \"usd\",\n});\n\n// -- Control: other metrics on the same account/key/version still fine?\nawait q(\"control: revenue.mrr same window\", {\n metrics: [{ name: \"revenue.mrr\" }],\n starts_at: \"2026-07-26T00:00:00Z\",\n ends_at: \"2026-08-02T00:00:00Z\",\n granularity: \"day\",\n currency: \"usd\",\n});\nawait q(\"control: revenue.arr same window\", {\n metrics: [{ name: \"revenue.arr\" }],\n starts_at: \"2026-07-26T00:00:00Z\",\n ends_at: \"2026-08-02T00:00:00Z\",\n granularity: \"day\",\n currency: \"usd\",\n});\n\n// -- Both metrics in ONE request: does usage poison a mixed query?\nawait q(\"mixed: mrr + usage in one request\", {\n metrics: [{ name: \"revenue.mrr\" }, { name: USAGE }],\n starts_at: \"2026-07-26T00:00:00Z\",\n ends_at: \"2026-08-02T00:00:00Z\",\n granularity: \"day\",\n currency: \"usd\",\n});\n",[206],"a2082b06-5af4-11f1-9dc8-ee650bb23af1","preview.ts","a2082bba-5af4-11f1-9dc8-ee650bb23af1",29,["D",1780014216205],"// Preview the Slack ARR digest WITHOUT posting. Run with run_file.\n// Prints the plain-text fallback and the Block Kit JSON so you can eyeball the\n// exact message the bot will send.\n\nimport { buildARRReport } from \"./report.ts\";\nimport { formatARRReport } from \"./slack.ts\";\n\nconst report = await buildARRReport();\nconst { text, blocks } = formatARRReport(report);\n\nconsole.log(\"====== SLACK MESSAGE (text fallback) ======\\n\");\nconsole.log(text);\nconsole.log(\"\\n====== BLOCK KIT JSON ======\\n\");\nconsole.log(JSON.stringify(blocks, null, 2));\n",[213],"3dabdb9e-5af9-11f1-a1d3-ee650bb23af1","main.ts","ea9783aa-5ad4-11f1-8fe8-ee650bb23af1",39,["D",1780016195304],"interval","// arr-bot — daily Stripe + HubSpot ARR digest, posted to Slack.\n// Schedule is configured in the interval settings (default: 14:00 UTC = 10am ET).\n// See README for env var setup.\n//\n// Pipeline: report.ts assembles the cross-source ARR model -> slack.ts formats\n// it into Block Kit -> postToSlack delivers it. HubSpot (enterprise) and the\n// combined total render as \"—\" until HubSpot is wired in.\n\nimport { buildARRReport } from \"./report.ts\";\nimport { formatARRReport, postToSlack } from \"./slack.ts\";\n\nexport default async function (_interval: { lastRunAt?: Date }) {\n const report = await buildARRReport();\n const message = formatARRReport(report);\n await postToSlack(message);\n console.log(`Posted ARR digest (net change for ${report.periodLabel}):\\n${message.text}`);\n}\n",[220],"99bfd9ad-6c61-4f15-85cb-31dbb7e00bd2","keepalive.txt","d2e6049a-8e99-11f1-90bd-1607ee4eb77e",126,["D",1785692674453],"last keepalive: (not yet run)\n",[228],"22c55fc0-d24e-42f6-a0d6-7e0752b66f77","keepalive.ts","d3d8423c-8e99-11f1-8585-1607ee4eb77e",127,["D",1785692676042],"// Weekly keep-alive: Val Town's free tier pauses ALL scheduled vals after ~14\n// days without account activity — and cron runs themselves don't count, only\n// authenticated account actions do. This cron rewrites keepalive.txt via the\n// Val Town REST API once a week; the API edit registers as account activity\n// and resets the inactivity clock, so the daily digest cron never pauses.\n//\n// Requires VAL_TOWN_API_KEY — create at https://www.val.town/settings/api\n// with \"Val: Read and write\" scope.\n//\n// Chicken-and-egg caveat: if crons are ever paused anyway (e.g. the token\n// expired), this can't revive them — any manual edit/run un-pauses everything,\n// after which this takes over again.\n\nconst TOKEN = Deno.env.get(\"VAL_TOWN_API_KEY\");\n\nexport default async function () {\n if (!TOKEN) throw new Error(\"Missing VAL_TOWN_API_KEY env var\");\n const headers = {\n Authorization: `Bearer ${TOKEN}`,\n \"Content-Type\": \"application/json\",\n };\n\n // Resolve this val's id by alias (org handle / val name).\n const aliasRes = await fetch(\n \"https://api.val.town/v2/alias/vals/consensus/arr-bot\",\n { headers },\n );\n if (!aliasRes.ok) {\n throw new Error(`alias lookup ${aliasRes.status}: ${await aliasRes.text()}`);\n }\n const { id } = await aliasRes.json();\n\n const res = await fetch(\n `https://api.val.town/v2/vals/${id}/files?path=keepalive.txt`,\n {\n method: \"PUT\",\n headers,\n body: JSON.stringify({\n content: `last keepalive: ${new Date().toISOString()}\\n`,\n }),\n },\n );\n if (!res.ok) {\n throw new Error(`keepalive edit ${res.status}: ${await res.text()}`);\n }\n console.log(`Keepalive edit OK at ${new Date().toISOString()}`);\n}\n",[235],"b6f19dfe-3048-4b60-9efa-d7ab234a86a8","hubspot.ts","f3a0248e-5ad4-11f1-b57f-ee650bb23af1",103,["D",1784250371119],13,"// Fetch enterprise ARR from HubSpot — sum of (amount / term_years) across\n// closed-won deals in BOTH pipelines (Sales + Trial), with daily SQLite\n// snapshots for net change tracking.\n//\n// Consensus's HubSpot:\n// - Two pipelines: Sales Pipeline (id=\"default\", closed-won stage \"closedwon\")\n// and Trial Pipeline (id=139030823, closed-won stage 238829588).\n// - hs_arr / hs_acv / hs_tcv are not populated (Sales Hub Pro feature),\n// so we derive ACV ourselves: `amount / term_years`.\n// - `term_years` is a custom deal property maintained by sales (Karthik/Eric).\n// When blank or 0, we fall back to `amount` (single-year assumption).\n//\n// Auth: HUBSPOT_TOKEN must be a Service Key (or Private App access token) with\n// scope `crm.objects.deals.read`. Create at app.hubspot.com → Settings →\n// Integrations → Service Keys.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst HUBSPOT_API = \"https://api.hubapi.com\";\n\n// ---- SQLite snapshot tables -------------------------------------------------\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS enterprise_arr_daily (\n day TEXT PRIMARY KEY,\n arr_usd REAL NOT NULL\n )\n`);\n\n// Per-day set of closed-won deals, so each run can diff against the prior\n// day's set and report newly signed accounts by name.\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS enterprise_deals_daily (\n day TEXT NOT NULL,\n deal_id TEXT NOT NULL,\n deal_name TEXT NOT NULL,\n PRIMARY KEY (day, deal_id)\n )\n`);\n\nfunction todayStr(): string {\n return new Date().toISOString().slice(0, 10);\n}\n\nfunction yesterdayStr(): string {\n const d = new Date();\n d.setDate(d.getDate() - 1);\n return d.toISOString().slice(0, 10);\n}\n\n// Closed-won stage IDs across all deal pipelines.\n// Discovered via GET /crm/v3/pipelines/deals (run-once probe; not in this repo).\nconst CLOSED_WON_STAGES = [\n \"closedwon\", // Sales Pipeline\n \"238829588\", // Trial Pipeline → \"Closed Won\"\n];\n\n// ---- HubSpot deal fetching --------------------------------------------------\n// Returns every closed-won deal (across all pipelines) with the requested\n// properties. The search endpoint's `IN` operator on `dealstage` lets us span\n// pipelines in one query.\nasync function fetchClosedWonDeals(\n token: string,\n properties: string[],\n): Promise<{ id: string; properties: Record }[]> {\n const out: { id: string; properties: Record }[] = [];\n let after: string | undefined;\n\n while (true) {\n const body: Record = {\n filterGroups: [\n {\n filters: [\n { propertyName: \"dealstage\", operator: \"IN\", values: CLOSED_WON_STAGES },\n ],\n },\n ],\n properties,\n limit: 100,\n };\n if (after) body.after = after;\n\n const res = await fetch(`${HUBSPOT_API}/crm/v3/objects/deals/search`, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(body),\n });\n if (!res.ok) {\n throw new Error(`HubSpot ${res.status}: ${await res.text()}`);\n }\n\n const data = await res.json() as {\n results: { id: string; properties: Record }[];\n paging?: { next?: { after: string } };\n };\n\n out.push(...data.results);\n after = data.paging?.next?.after;\n if (!after) break;\n }\n\n return out;\n}\n\n// ---- Public API -------------------------------------------------------------\nexport interface EnterpriseARRResult {\n arr: number;\n netChange: number | null;\n netChangePct: number | null;\n newAccounts: string[]; // deals closed-won since the prior day's snapshot\n}\n\n// ACV per deal: amount / term_years. Falls back to amount when term_years is\n// missing or 0 (treats blank as single-year).\nfunction dealACV(props: Record): number {\n const amount = Number(props.amount ?? 0);\n const term = Number(props.term_years ?? 0);\n return term > 0 ? amount / term : amount;\n}\n\nexport async function fetchEnterpriseARR(): Promise {\n const token = Deno.env.get(\"HUBSPOT_TOKEN\");\n if (!token) throw new Error(\"Missing HUBSPOT_TOKEN env var\");\n\n const deals = await fetchClosedWonDeals(token, [\"dealname\", \"amount\", \"term_years\"]);\n const totalARR = deals.reduce((t, d) => t + dealACV(d.properties), 0);\n\n // Store today's snapshot.\n await sqlite.execute({\n sql: \"INSERT OR REPLACE INTO enterprise_arr_daily (day, arr_usd) VALUES (?, ?)\",\n args: [todayStr(), totalARR],\n });\n\n // Store today's deal set and diff against yesterday's to find new accounts.\n const dealName = (d: { properties: Record }) =>\n d.properties.dealname ?? \"(unnamed deal)\";\n if (deals.length > 0) {\n await sqlite.batch(deals.map((d) => ({\n sql: \"INSERT OR REPLACE INTO enterprise_deals_daily (day, deal_id, deal_name) VALUES (?, ?, ?)\",\n args: [todayStr(), d.id, dealName(d)],\n })));\n }\n\n const prevDeals = await sqlite.execute({\n sql: \"SELECT deal_id FROM enterprise_deals_daily WHERE day = ?\",\n args: [yesterdayStr()],\n });\n let newAccounts: string[] = [];\n if (prevDeals.rows.length > 0) {\n // Only diff when a prior snapshot exists — on the very first run every\n // deal would otherwise read as \"new\".\n const prevIds = new Set(\n prevDeals.rows.map((r) => String((r as Record).deal_id)),\n );\n newAccounts = deals.filter((d) => !prevIds.has(d.id)).map(dealName);\n }\n\n // Look up yesterday's value for net change.\n const prior = await sqlite.execute({\n sql: \"SELECT arr_usd FROM enterprise_arr_daily WHERE day = ?\",\n args: [yesterdayStr()],\n });\n\n const priorARR = prior.rows.length > 0\n ? (prior.rows[0] as Record).arr_usd as number\n : undefined;\n const netChange = priorARR !== undefined ? totalARR - priorARR : null;\n const netChangePct = priorARR && netChange !== null\n ? netChange / priorARR\n : null;\n\n return { arr: totalARR, netChange, netChangePct, newAccounts };\n}\n",[242],"3116cc6b-a6d7-4ae9-919e-8c6fc0d379fe","diag-arr-jump.ts","1cc4307a-ad83-11f1-982b-1607ee4eb77e",144,["D",1789091623163],"// Throwaway diagnostic (round 3): candidate fixes vs Stripe's own revenue.arr\n// (Sep 10 = $10,954,670). (1) ACTIVE_* event types only; (2) ACTIVE_* + exact\n// duplicate rows removed. Plus the MRR carried by each trial event type, to\n// document what leaked in.\n\nimport { runSigmaQuery } from \"./sigma.ts\";\n\nconst FX = `\nfx_latest AS (\n SELECT CAST(JSON_PARSE(buy_currency_exchange_rates) AS MAP(VARCHAR, DOUBLE)) AS rate\n FROM exchange_rates_from_usd ORDER BY date DESC LIMIT 1\n)`;\nconst ACTIVE = `('ACTIVE_START','ACTIVE_END','ACTIVE_UPGRADE','ACTIVE_DOWNGRADE','ACTIVE_QUANTITY_INCREASE','ACTIVE_QUANTITY_DECREASE')`;\n\nconst total = (base: string) => `\nWITH ${FX},\nmrr AS (SELECT currency, SUM(CAST(mrr_change AS DOUBLE)) AS mrr_minor FROM (${base}) GROUP BY currency)\nSELECT CAST(ROUND(SUM(m.mrr_minor / element_at(f.rate, m.currency)) * 12 / 100.0) AS BIGINT) AS arr_usd\nFROM mrr m CROSS JOIN fx_latest f\nWHERE element_at(f.rate, m.currency) IS NOT NULL\n`;\n\nconst ALL_ROWS = `SELECT currency, mrr_change FROM subscription_item_change_events_v2_beta`;\nconst ACTIVE_ROWS = `SELECT currency, mrr_change FROM subscription_item_change_events_v2_beta WHERE event_type IN ${ACTIVE}`;\nconst ACTIVE_DEDUP_ROWS = `\n SELECT currency, mrr_change FROM (\n SELECT DISTINCT subscription_item_id, event_type, local_event_timestamp, mrr_change, currency\n FROM subscription_item_change_events_v2_beta WHERE event_type IN ${ACTIVE}\n )`;\n\nconst TRIAL_MRR = `\nWITH ${FX}\nSELECT event_type,\n CAST(ROUND(SUM(CAST(mrr_change AS DOUBLE) / element_at(f.rate, currency)) * 12 / 100.0) AS BIGINT) AS arr_contribution_usd\nFROM subscription_item_change_events_v2_beta CROSS JOIN fx_latest f\nWHERE event_type NOT IN ${ACTIVE} AND element_at(f.rate, currency) IS NOT NULL\nGROUP BY event_type\n`;\n\nconst [all, active, dedup, trial] = await Promise.all([\n runSigmaQuery(total(ALL_ROWS)),\n runSigmaQuery(total(ACTIVE_ROWS)),\n runSigmaQuery(total(ACTIVE_DEDUP_ROWS)),\n runSigmaQuery(TRIAL_MRR),\n]);\n\nconst REF = 10954670;\nconst show = (label: string, v: string) => {\n const n = Number(v);\n console.log(`${label.padEnd(34)} $${n.toLocaleString()} vs Stripe ${((n - REF) / REF * 100).toFixed(2)}%`);\n};\nshow(\"all rows (current, broken)\", all.rows[0].arr_usd);\nshow(\"ACTIVE_* only\", active.rows[0].arr_usd);\nshow(\"ACTIVE_* only + exact dedup\", dedup.rows[0].arr_usd);\nconsole.log(\"\\nARR carried by non-ACTIVE event types (what leaked in):\");\nfor (const r of trial.rows) console.log(` ${r.event_type.padEnd(16)} $${Number(r.arr_contribution_usd).toLocaleString()}`);\n",[250],"9580e160-5afa-11f1-a203-ee650bb23af1","README.md","fbca5e22-5ad4-11f1-8ac7-ee650bb23af1",44,["D",1780016772167],5,"# arr-bot\n\nDaily Stripe + HubSpot ARR digest, posted to Slack.\n\n## Required env vars\n\nSet these in the Val Town env var editor (one click per link):\n\n👉 Add STRIPE_SECRET_KEY here: https://www.val.town/x/consensus/arr-bot/environment-variables?key=STRIPE_SECRET_KEY\n\n👉 Add HUBSPOT_TOKEN here: https://www.val.town/x/consensus/arr-bot/environment-variables?key=HUBSPOT_TOKEN\n\nSLACK_TOKEN is auto-configured by Val Town's Slack integration (connect via the val dashboard).\n\n## Optional env vars\n\n👉 Add HUBSPOT_ARR_PROPERTY here: https://www.val.town/x/consensus/arr-bot/environment-variables?key=HUBSPOT_ARR_PROPERTY\n\n👉 Add HUBSPOT_PIPELINE_STAGE here: https://www.val.town/x/consensus/arr-bot/environment-variables?key=HUBSPOT_PIPELINE_STAGE\n\n- `HUBSPOT_ARR_PROPERTY` — deal property summed for ARR. Default `amount`. Set to `hs_arr` or your custom property if different.\n- `HUBSPOT_PIPELINE_STAGE` — dealstage filter. Default `closedwon`. Use the internal stage ID if you have custom pipelines.\n\n## Where to create credentials\n\n- **Stripe** — https://dashboard.stripe.com/apikeys → create a Restricted Key. Needs `reporting_write` + `sigma_api_write` (shown as **Sigma** + **Sigma API**), and an active Sigma subscription. ARR is read from Sigma, not the Subscriptions REST endpoint, so it matches the dashboard.\n- **HubSpot** — https://app.hubspot.com/private-apps → create Private App with scope `crm.objects.deals.read`.\n- **Slack** — connected via Val Town's dashboard Slack integration. Posts to `#test` (channel ID hardcoded in `slack.ts`).\n\n## Files\n\n- `main.ts` — interval handler (cron entry point); builds the report and posts it to Slack\n- `report.ts` — `buildARRReport()` assembles the cross-source model (self-serve + enterprise + total)\n- `stripe.ts` — self-serve ARR via Stripe Sigma: current total + daily movement (new / expansion / contraction / churn), multi-currency → USD. Matches the dashboard (sums pre-computed `mrr_change`, × 12).\n- `sigma.ts` — `runSigmaQuery()` client for the Stripe Sigma Query Run API (submit → poll → download CSV)\n- `hubspot.ts` — `fetchHubSpotARR()` sums a deal property across a pipeline stage (enterprise segment; not yet wired into the digest)\n- `slack.ts` — `formatARRReport()` builds the Block Kit digest; `postToSlack()` delivers via Slack Web API\n- `query-stripe.ts` — manual validation script: prints total ARR + a daily breakdown table\n- `preview.ts` — renders the Slack message without posting (dry run)\n\n## Schedule\n\nInterval is set in the val's interval settings (configured separately from file content). Currently: daily at 01:00 UTC (6pm PT). Note: Val Town cron is UTC-only and does not adjust for DST, so this is 6pm during PDT (summer) and 5pm during PST (winter).\n",[257],"pulls","branches","forks","envVars",{"_271":202,"_273":61},"connections",{"_271":202,"_272":61},"count","unfilledCount","emptyCount",{"_43":256,"_32":257,"_30":258,"_147":-5,"_41":42,"_40":259,"_149":25,"_38":336,"_13":261,"_33":20,"_35":262,"_24":25,"_153":-5,"_291":337,"_27":338},{"_43":249,"_32":250,"_30":251,"_147":-5,"_41":42,"_40":252,"_149":25,"_38":333,"_13":194,"_33":34,"_35":254,"_24":25,"_153":-5,"_291":334,"_27":335},{"_43":241,"_32":242,"_30":243,"_147":-5,"_41":42,"_40":244,"_149":171,"_38":330,"_13":246,"_33":34,"_35":247,"_24":25,"_153":-5,"_291":331,"_27":332},{"_43":234,"_32":235,"_30":236,"_147":-5,"_41":42,"_40":237,"_149":171,"_38":327,"_13":61,"_33":224,"_35":239,"_24":25,"_153":-5,"_291":328,"_27":329},{"_43":227,"_32":228,"_30":229,"_147":-5,"_41":42,"_40":230,"_149":171,"_38":324,"_13":61,"_33":20,"_35":232,"_24":25,"_153":-5,"_291":325,"_27":326},{"_43":219,"_32":220,"_30":221,"_147":-5,"_41":42,"_40":222,"_149":171,"_38":321,"_13":202,"_33":224,"_35":225,"_24":25,"_153":-5,"_291":322,"_27":323},{"_43":212,"_32":213,"_30":214,"_147":-5,"_41":42,"_40":215,"_149":171,"_38":318,"_13":61,"_33":34,"_35":217,"_24":25,"_153":-5,"_291":319,"_27":320},{"_43":205,"_32":206,"_30":207,"_147":-5,"_41":42,"_40":208,"_149":171,"_38":315,"_13":61,"_33":34,"_35":210,"_24":25,"_153":-5,"_291":316,"_27":317},{"_43":197,"_32":198,"_30":199,"_147":-5,"_41":42,"_40":200,"_149":171,"_38":312,"_13":202,"_33":34,"_35":203,"_24":25,"_153":-5,"_291":313,"_27":314},{"_43":189,"_32":190,"_30":191,"_147":-5,"_41":42,"_40":192,"_149":171,"_38":309,"_13":194,"_33":34,"_35":195,"_24":25,"_153":-5,"_291":310,"_27":311},{"_43":182,"_32":183,"_30":184,"_147":-5,"_41":42,"_40":185,"_149":171,"_38":306,"_13":61,"_33":34,"_35":187,"_24":25,"_153":-5,"_291":307,"_27":308},{"_43":175,"_32":176,"_30":177,"_147":-5,"_41":42,"_40":178,"_149":25,"_38":303,"_13":160,"_33":34,"_35":180,"_24":25,"_153":-5,"_291":304,"_27":305},{"_43":167,"_32":168,"_30":169,"_147":-5,"_41":42,"_40":170,"_149":171,"_38":300,"_13":61,"_33":34,"_35":173,"_24":25,"_153":-5,"_291":301,"_27":302},{"_43":163,"_32":28,"_30":31,"_147":-5,"_41":42,"_40":14,"_149":25,"_38":297,"_13":165,"_33":34,"_35":37,"_24":25,"_153":-5,"_291":298,"_27":299},{"_43":155,"_32":156,"_30":157,"_147":-5,"_41":42,"_40":158,"_149":25,"_38":294,"_13":160,"_33":34,"_35":161,"_24":25,"_153":-5,"_291":295,"_27":296},{"_43":144,"_32":145,"_30":146,"_147":-5,"_41":42,"_40":148,"_149":25,"_38":290,"_13":151,"_33":34,"_35":152,"_24":25,"_153":-5,"_291":292,"_27":293},["D",1782139607619],"children",[],[145],["D",1789091740513],[],[156],["D",1789091741815],[],[28],["D",1780012708937],[],[168],["D",1785692586029],[],[176],["D",1782139174552],[],[183],["D",1780013552266],[],[190],["D",1780021601725],[],[198],["D",1785771272449],[],[206],["D",1780014216205],[],[213],["D",1780016195304],[],[220],["D",1785692674453],[],[228],["D",1785692676042],[],[235],["D",1784250371119],[],[242],["D",1789091623163],[],[250],["D",1780016772167],[],[257],["D",1780000503639],["D",1789509043237],{"_98":97,"_105":-5},{"_98":97,"_99":100,"_101":-5,"_18":-5,"_102":103,"_104":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_125":377,"_378":379,"_380":381,"_382":25,"_383":25,"_384":25,"_385":171,"_386":-5,"_387":-7,"_388":-7,"_389":61,"_390":25,"_391":25,"_392":-5,"_393":25,"_394":25,"_395":25,"_396":-5},"ENV",{"_348":349,"_350":351,"_352":88,"_353":354,"_355":356,"_357":358,"_359":360,"_361":362,"_363":364,"_365":366,"_367":368,"_369":370,"_371":372,"_373":374,"_375":376},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v146