[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_379":380,"_381":382},"routes/_app.x.$handle.$name",{"_102":101,"_32":46,"_111":92,"_27":112,"_13":14,"_113":-5,"_11":114,"_115":116,"_117":118,"_119":120,"_121":122,"_20":-5,"_123":-5,"_124":-5,"_125":25,"_126":127,"_128":61,"_129":-5,"_130":-5,"_131":132},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_32":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":56,"_18":57,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":65,"_66":67,"_68":69,"_70":71,"_72":73,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":85,"_86":87,"_88":89,"_90":25},"version",49,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","lib/chart.tsx","latestPath","fileId","69a21862-644a-11f1-9bd0-1607ee4eb77e","name","chart.tsx","fileType","script","content","/** @jsxImportSource npm:hono/jsx */\n// Stacked-bar ARR chart, rendered server-side as plain SVG — no client JS.\n// Each bar shows month-over-month growth and the dollar total, investor-update\n// style.\nimport type { ArrSeries } from \"./arr.ts\";\n\n// Generous top padding: the landing page overlaps its headline into this\n// empty \"sky\" above the bars.\nconst W = 760;\nconst H = 380;\nconst PAD = { top: 96, right: 6, bottom: 26, left: 62 };\n\nconst dollars = (cents: number) => `$${Math.round(cents / 100).toLocaleString()}`;\n\nfunction niceMax(value: number): number {\n const pow = Math.pow(10, Math.floor(Math.log10(value || 1)));\n for (const m of [1, 1.5, 2, 2.5, 3, 4, 5, 6, 8, 10]) {\n if (m * pow >= value * 1.05) return m * pow;\n }\n return 10 * pow;\n}\n\nexport function ArrChart({ arr }: { arr: ArrSeries }) {\n const { months, products, colors } = arr;\n if (!months.length) return null;\n const yMax = niceMax(Math.max(...months.map((m) => m.total)));\n const plotW = W - PAD.left - PAD.right;\n const plotH = H - PAD.top - PAD.bottom;\n const y = (v: number) => H - PAD.bottom - (v / yMax) * plotH;\n const step = plotW / months.length;\n const barW = Math.min(step * 0.62, 64);\n const ticks = [1, 2, 3, 4].map((i) => (yMax / 4) * i);\n\n return (\n

\n {[...products].reverse().map((product, i) => (\n \n \n \n {product}\n \n ))}\n

\n \n

\n );\n}\n","/** @jsxImportSource npm:hono/jsx */\n// Stacked-bar ARR chart, rendered server-side as plain SVG — no client JS.\n// Each bar shows month-over-month growth and the dollar total, investor-update\n// style.\nimport type { ArrSeries } from \"./arr.ts\";\n\n// Generous top padding: the landing page overlaps its headline into this\n// empty \"sky\" above the bars.\nconst W = 760;\nconst H = 380;\nconst PAD = { top: 96, right: 6, bottom: 26, left: 62 };\n\nconst dollars = (cents: number) => `$${Math.round(cents / 100).toLocaleString()}`;\n\nfunction niceMax(value: number): number {\n const pow = Math.pow(10, Math.floor(Math.log10(value || 1)));\n for (const m of [1, 1.5, 2, 2.5, 3, 4, 5, 6, 8, 10]) {\n if (m * pow >= value * 1.05) return m * pow;\n }\n return 10 * pow;\n}\n\nexport function ArrChart({ arr }: { arr: ArrSeries }) {\n const { months, products, colors } = arr;\n if (!months.length) return null;\n const yMax = niceMax(Math.max(...months.map((m) => m.total)));\n const plotW = W - PAD.left - PAD.right;\n const plotH = H - PAD.top - PAD.bottom;\n const y = (v: number) => H - PAD.bottom - (v / yMax) * plotH;\n const step = plotW / months.length;\n const barW = Math.min(step * 0.62, 64);\n const ticks = [1, 2, 3, 4].map((i) => (yMax / 4) * i);\n\n return (\n

\n \n

\n );\n}\n","createdAt",["D",1781041140248],"branchVersion","branchId","41ab6bde-e273-4dba-99ae-7e8f9d01de9f","id","aca55a8a-72ee-4b8b-84aa-0a0762b4d677","stripe-mirror",["D",1781035360700],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Mirror your Stripe account into SQLite to power ARR/MRR charts","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/522abc55-169d-4249-6a64-9e9382e58300/square512?exp=1789588799&sig=f81b1a9bb4b6b2355a9576be81e165d19ff62042763c2bec31be4b35b76365b9","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","e70f460e-6444-11f1-b2c1-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",2,"orgId","019aa807-52c2-709c-928b-2029bae9a558","tursoName","aca55a8a72ee4b8b84aa0a0762b4d677","tursoHostname","aca55a8a72ee4b8b84aa0a0762b4d677-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789501878689],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_102":101,"_110":106},"org",{"_102":101,"_103":104,"_105":106,"_18":-5,"_107":108,"_109":61},"branch",{"_13":91,"_32":92,"_44":43,"_93":45,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":46,"_100":101},"isOwned",78,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","templates","handle","displayName","Templates","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789588799&sig=6ce4a653b65ad390b6349a1b0a383cb839cc380a1beaf91551581c108538875d","tier","business","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_44":45,"_32":46,"_39":374,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":56,"_18":57,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":65,"_66":67,"_68":69,"_70":71,"_72":375,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":376,"_86":377,"_88":378,"_90":25},"tree",[212,228,229,230,231,232,233,234],"files",[212,213,214,215,216,217,218,219,220,221,222,223,224,225,226,227,228,229,230,231,232,233,234],"counts",{"_202":148,"_203":198,"_204":148,"_205":206,"_207":208},"contents",[133,134,135,136,137,138,139,140],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":195,"_32":196,"_30":197,"_144":-5,"_42":43,"_41":198,"_146":61,"_39":199,"_13":148,"_34":200,"_36":-5,"_24":25,"_150":-5,"_27":201},{"_44":188,"_32":189,"_30":190,"_144":-5,"_42":43,"_41":191,"_146":25,"_39":192,"_13":145,"_34":20,"_36":193,"_24":25,"_150":-5,"_27":194},{"_44":181,"_32":182,"_30":183,"_144":-5,"_42":43,"_41":184,"_146":25,"_39":185,"_13":148,"_34":35,"_36":186,"_24":25,"_150":-5,"_27":187},{"_44":175,"_32":176,"_30":177,"_144":-5,"_42":43,"_41":65,"_146":61,"_39":178,"_13":148,"_34":35,"_36":179,"_24":25,"_150":-5,"_27":180},{"_44":167,"_32":168,"_30":169,"_144":-5,"_42":43,"_41":170,"_146":61,"_39":171,"_13":148,"_34":172,"_36":173,"_24":25,"_150":-5,"_27":174},{"_44":159,"_32":160,"_30":59,"_144":-5,"_42":43,"_41":161,"_146":25,"_39":162,"_13":163,"_34":164,"_36":165,"_24":25,"_150":46,"_27":166},{"_44":152,"_32":153,"_30":154,"_144":-5,"_42":43,"_41":155,"_146":25,"_39":156,"_13":148,"_34":35,"_36":157,"_24":25,"_150":-5,"_27":158},{"_44":141,"_32":142,"_30":143,"_144":-5,"_42":43,"_41":145,"_146":25,"_39":147,"_13":148,"_34":35,"_36":149,"_24":25,"_150":-5,"_27":151},"25811622-4894-41af-ae6b-fa3abe725eda","status.ts","847a127c-643e-11f1-9777-1607ee4eb77e","parentId",13,"latest",["D",1781035509818],0,"// Prints row counts and sync progress.\nimport { sqlite } from \"./lib/db.ts\";\nimport { ensureSchema } from \"./lib/schema.ts\";\n\nawait ensureSchema();\n\nconst tables = [\n \"stripe_customers\",\n \"stripe_products\",\n \"stripe_prices\",\n \"stripe_subscriptions\",\n \"stripe_subscription_items\",\n \"stripe_invoices\",\n \"stripe_invoice_lines\",\n \"stripe_credit_notes\",\n];\nfor (const table of tables) {\n const result = await sqlite.execute(`SELECT COUNT(*) AS n FROM ${table}`);\n console.log(`${table}: ${result.rows[0].n}`);\n}\n\nconsole.log(\"\\nbackfill state:\");\nconst state = await sqlite.execute(\n `SELECT resource, status, cursor, last_run_at, last_error FROM sync_state ORDER BY resource`,\n);\nfor (const row of state.rows) console.log(JSON.stringify(row));\n\nconst events = await sqlite.execute(`SELECT * FROM event_state WHERE key = 'events'`);\nconsole.log(\"\\nevents cursor:\", JSON.stringify(events.rows[0] ?? null));\n","label",[142],"df5e6272-e8ad-47fa-8917-ec0b4adf788a","resync.ts","82759d20-643e-11f1-a2c4-1607ee4eb77e",12,["D",1781035506449],"// Queue a full re-sync: every enabled table gets re-walked from the beginning\n// of Stripe history with upserts. Nothing is deleted first, so the mirror\n// stays queryable throughout. Use after changing config.ts, recovering from\n// a long outage (> EVENT_RETENTION_DAYS), or whenever you want to be sure.\nimport { ensureSchema } from \"./lib/schema.ts\";\nimport { resetForResync } from \"./lib/state.ts\";\n\nawait ensureSchema();\nawait resetForResync();\nconsole.log(\"All enabled tables queued for re-sync. Run backfill.ts to drive it now, or let the cron work through it.\");\n",[153],"0cb5881c-d75e-4edb-9692-d98be65d506f","index.tsx",44,["D",1781040680088],4,"http","/** @jsxImportSource npm:hono/jsx */\n// HTTP entrypoint: / is a public landing page about the mirror, /admin is the\n// status page with sync controls, /data is a read-only row browser.\nimport { Hono } from \"npm:hono\";\nimport { basicAuth } from \"npm:hono/basic-auth\";\nimport { hasPendingBackfill, runBackfill } from \"./lib/backfill.ts\";\nimport { runEventSync } from \"./lib/events.ts\";\nimport { eventState, mrrByProduct, syncStatus, tableCounts } from \"./lib/metrics.ts\";\nimport { ensureSchema } from \"./lib/schema.ts\";\nimport { resetForResync } from \"./lib/state.ts\";\nimport { Admin } from \"./lib/admin.tsx\";\nimport { arrSeries } from \"./lib/arr.ts\";\nimport { BROWSABLE, fetchRow, fetchRows, RowDetail, TableIndex, TableRows } from \"./lib/browse.tsx\";\nimport { Landing } from \"./lib/landing.tsx\";\n\nconst app = new Hono();\n\n// The landing page stays public. /admin and /data expose revenue numbers and\n// customer data, so they get basic auth (username \"admin\") once\n// DASHBOARD_PASSWORD is set.\nconst password = Deno.env.get(\"DASHBOARD_PASSWORD\");\nif (password) {\n const gate = basicAuth({ username: \"admin\", password });\n app.use(\"/admin\", gate);\n app.use(\"/admin/*\", gate);\n app.use(\"/data\", gate);\n app.use(\"/data/*\", gate);\n}\n\nconst hasKey = () => Boolean(Deno.env.get(\"STRIPE_API_KEY\"));\n\napp.get(\"/\", async (c) => {\n await ensureSchema();\n const [counts, events, mrr, arr] = await Promise.all([\n tableCounts(),\n eventState(),\n mrrByProduct(),\n arrSeries(),\n ]);\n return c.html();\n});\n\napp.get(\"/admin\", async (c) => {\n await ensureSchema();\n const [mrr, counts, sync, events, pending] = await Promise.all([\n mrrByProduct(),\n tableCounts(),\n syncStatus(),\n eventState(),\n hasPendingBackfill(),\n ]);\n return c.html(\n ,\n );\n});\n\n// One bounded slice of whatever the cron would do next: a ~45s backfill chunk\n// if one is pending, otherwise an Events API pass. (HTTP requests are capped\n// at 1 minute, hence the smaller budget than the cron's.)\napp.post(\"/admin/sync\", async (c) => {\n await ensureSchema();\n if (await hasPendingBackfill()) await runBackfill(45_000);\n else await runEventSync();\n return c.redirect(\"/admin\");\n});\n\napp.post(\"/admin/resync\", async (c) => {\n await ensureSchema();\n await resetForResync();\n return c.redirect(\"/admin\");\n});\n\napp.get(\"/data\", async (c) => {\n await ensureSchema();\n return c.html();\n});\n\napp.get(\"/data/:table\", async (c) => {\n const table = c.req.param(\"table\");\n if (!BROWSABLE.includes(table)) return c.notFound();\n const offset = Math.max(0, Number(c.req.query(\"offset\")) || 0);\n const { rows, hasMore } = await fetchRows(table, offset);\n return c.html();\n});\n\napp.get(\"/data/:table/:id\", async (c) => {\n const table = c.req.param(\"table\");\n if (!BROWSABLE.includes(table)) return c.notFound();\n const row = await fetchRow(table, c.req.param(\"id\"));\n if (!row) return c.notFound();\n return c.html();\n});\n\nexport default app.fetch;\n",[160],"65affa8b-8bd5-438b-9619-3d66d53e2321","cron.ts","7d8f4162-643e-11f1-93e9-1607ee4eb77e",10,["D",1781035498220],"interval","// Runs every 5 minutes. While a backfill is pending it advances the backfill\n// (time-boxed); otherwise it does a cheap incremental sync from the Stripe\n// Events API. See README.md.\nimport { RUN_BUDGET_MS } from \"./config.ts\";\nimport { hasPendingBackfill, runBackfill } from \"./lib/backfill.ts\";\nimport { runEventSync } from \"./lib/events.ts\";\nimport { ensureSchema } from \"./lib/schema.ts\";\n\nexport default async function (interval: Interval) {\n if (!Deno.env.get(\"STRIPE_API_KEY\")) {\n console.log(\"STRIPE_API_KEY is not set yet — see README.md for setup.\");\n return { ok: false, missing: \"STRIPE_API_KEY\" };\n }\n await ensureSchema();\n const summary = (await hasPendingBackfill())\n ? await runBackfill(RUN_BUDGET_MS)\n : await runEventSync();\n console.log(JSON.stringify(summary));\n return summary;\n}\n",[168],"2f79552b-7912-49d9-95ea-21471b48334c","config.ts","3569068e-643e-11f1-af85-1607ee4eb77e",["D",1781035377171],"// Configuration for the Stripe → SQLite mirror.\n\n// Which Stripe resources to mirror. Set one to false and the cron stops\n// touching it (existing rows stay put). Set a new one to true and the next\n// cron run automatically backfills it from the beginning of time.\nexport const TABLES = {\n customers: true,\n products: true,\n prices: true,\n subscriptions: true, // also fills stripe_subscription_items\n invoices: true, // also fills stripe_invoice_lines\n credit_notes: true,\n} as const;\n\nexport type Resource = keyof typeof TABLES;\n\nexport function enabledResources(): Resource[] {\n return (Object.keys(TABLES) as Resource[]).filter((resource) => TABLES[resource]);\n}\n\n// --- Rate limiting ----------------------------------------------------------\n// Stripe's default API limits are 100 read requests/sec in live mode and\n// 25/sec in test mode. All requests in this val flow through one token bucket\n// pinned to RATE_LIMIT_FRACTION of that, so the backfill can fan out\n// aggressively while staying safely under the limit and leaving headroom for\n// your production traffic.\nexport const RATE_LIMIT_FRACTION = 0.8;\nexport const LIVE_READS_PER_SECOND = 100;\nexport const TEST_READS_PER_SECOND = 25;\n\n// Upper bound on simultaneous in-flight requests.\nexport const MAX_CONCURRENCY = 25;\n\n// Stripe's max list page size.\nexport const PAGE_SIZE = 100;\n\n// The events sync re-reads this far behind its cursor, so a crashed or\n// overlapping run can never skip an event (already-seen ids are deduped).\nexport const EVENT_OVERLAP_SECONDS = 10 * 60;\n\n// Processed event ids are kept this long for dedupe, then pruned.\nexport const EVENT_RETENTION_DAYS = 30;\n\n// Wall-clock budget for backfill work inside one run.\nexport const RUN_BUDGET_MS = 3.5 * 60 * 1000;\n",[176],"edb00123-6562-4d27-8ef2-0acecbfd6d87","backfill.ts","80508aa0-643e-11f1-9112-1607ee4eb77e",11,["D",1781035502829],"// Run this manually to drive the initial backfill (or a queued re-sync)\n// without waiting for the cron's 5-minute slices. Run it again if it reports\n// work remaining. Don't run two copies at once — the rate limiter is\n// per-process, so parallel copies would overshoot the 80% budget (the data\n// stays correct either way; every write is an upsert).\nimport { RUN_BUDGET_MS } from \"./config.ts\";\nimport { hasPendingBackfill, runBackfill } from \"./lib/backfill.ts\";\nimport { ensureSchema } from \"./lib/schema.ts\";\n\nawait ensureSchema();\nif (!(await hasPendingBackfill())) {\n console.log(\"Nothing pending — the backfill is complete. Run resync.ts first if you want a full re-sync.\");\n} else {\n const summary = await runBackfill(RUN_BUDGET_MS);\n console.log(JSON.stringify(summary, null, 2));\n if (!summary.done) {\n console.log(\"Time budget used up with work remaining — run this again, or let the cron finish it.\");\n }\n}\n",[182],"d97cc7fc-aee1-465f-9140-15adee4041c0","README.md","9954b224-643e-11f1-a5d7-1607ee4eb77e",46,["D",1781040753206],"# stripe-mirror\n\nYour whole Stripe account, mirrored into a SQLite database you can query.\n\n```sql\nSELECT p.name, SUM(l.amount) / 100.0 AS revenue\nFROM stripe_invoice_lines l\nJOIN stripe_invoices i ON i.id = l.invoice_id\nJOIN stripe_products p ON p.id = l.product_id\nWHERE i.status = 'paid'\nGROUP BY p.name ORDER BY revenue DESC;\n```\n\n## The problem this solves\n\nSubscription billing data is **mutable history**. Subscriptions get upgraded,\ndowngraded, prorated, and canceled; invoices get voided and credited. To answer\neven basic questions — MRR by product, revenue by month, churn — you need _all\ninvoices for all time_, not just recent ones.\n\nThe Stripe API fights you on this. Lists are cursor-paginated 100 at a time,\nline items are a nested sub-list with their own pagination, everything is\nrate-limited, and you can't join or aggregate across objects at all. Recomputing\nanything from the API takes thousands of sequential requests, every time.\n\nThe fix (same model as\n[Supabase's Stripe Sync Engine](https://supabase.com/blog/stripe-sync-engine-integration))\nis to maintain a local mirror and query it with SQL. This val is that,\nself-contained on Val Town: no Postgres to run, no webhook endpoint to secure —\njust a Stripe API key.\n\n## How it works\n\nThree mechanisms, all writing with idempotent upserts keyed on Stripe ids:\n\n1. **Backfill** — walks every enabled resource's list endpoint through all of\n history. All resources run in parallel and child fetches fan out further; a\n shared token bucket holds total throughput at **80% of Stripe's rate limit**\n (100 reads/sec live, 25/sec test), so years of data land in minutes without\n starving your production traffic. Progress is checkpointed page by page, so\n it resumes cleanly across runs.\n2. **Incremental cron (every 5 minutes)** — `cron.ts` polls the\n [Events API](https://docs.stripe.com/api/events) for what changed, refetches\n those objects from Stripe (the event payload is never trusted as the source\n of truth), and upserts just those rows. A typical run touches zero or a\n handful of objects.\n3. **Re-sync** — run `resync.ts` to queue a fresh full walk at any time. It\n upserts over existing rows, so the mirror stays queryable while it runs.\n\nThe event cursor starts when the schema is first created, so anything that\nchanges _during_ the backfill is replayed by the cron afterward — no gap between\nthe two.\n\n## Setup\n\n1. **Get a Stripe API key** —\n [use this link to create a key with reqiuired read-only permissions](https://dashboard.stripe.com/apikeys/create?name=stripe-mirror&permissions%5B%5D=rak_customer_read&permissions%5B%5D=rak_product_read&permissions%5B%5D=rak_price_read&permissions%5B%5D=rak_plan_read&permissions%5B%5D=rak_subscription_read&permissions%5B%5D=rak_invoice_read&permissions%5B%5D=rak_credit_note_read&permissions%5B%5D=rak_event_read)\n (Customers, Products, Prices, Subscriptions, Invoices, Credit Notes, Events)\n2. **Paste it as an env var in this val** -\n [use this link to add `STRIPE_API_KEY`](https://www.val.town/x/templates/stripe-mirror/environment-variables?key=STRIPE_API_KEY)\n\n3. **Open your val's site** and go to `/admin` — click **Run backfill slice**,\n or do nothing; the cron advances the backfill automatically in 5-minute\n slices.\n\n## The site\n\n`index.tsx` serves three pages (server-rendered Hono JSX, no client JS):\n\n- `/` — a public landing page with a live ARR chart (stacked by product,\n month-over-month growth labels) and headline stats\n- `/admin` — MRR/ARR, MRR by product, sync job status, and buttons for \"Sync\n now\" and \"Queue full re-sync\"\n- `/data` — a read-only browser for the mirrored tables: page through rows,\n click an id to see the complete raw Stripe object\n\n`/admin` and `/data` show revenue numbers and customer data, so set a password\nto put them behind basic auth (username `admin`; the landing page stays public):\n\n👉 Add DASHBOARD_PASSWORD here:\nhttps://www.val.town/x/templates/stripe-mirror/environment-variables?key=DASHBOARD_PASSWORD\n\nPrefer scripts to buttons? `backfill.ts`, `resync.ts`, and `status.ts` do the\nsame jobs from the editor.\n\n## Tables\n\n| Table | Source |\n| ---------------------------------------------------- | ------------------------------ |\n| `stripe_customers` | `/v1/customers` |\n| `stripe_products` | `/v1/products` |\n| `stripe_prices` | `/v1/prices` |\n| `stripe_subscriptions` + `stripe_subscription_items` | `/v1/subscriptions?status=all` |\n| `stripe_invoices` + `stripe_invoice_lines` | `/v1/invoices` |\n| `stripe_credit_notes` | `/v1/credit_notes` |\n\nEach table promotes a few columns for joins and indexing, and keeps the\n**complete Stripe object** as JSON in `raw`. Anything not promoted is one\n`json_extract` away:\n\n```sql\nSELECT json_extract(raw, '$.metadata.plan_tier') AS tier, COUNT(*)\nFROM stripe_subscriptions WHERE status = 'active' GROUP BY tier;\n```\n\n## Configuring what syncs\n\nEverything tunable lives in `config.ts`: which tables to mirror, the rate-limit\nfraction, concurrency, and retention. Turn a resource off and the sync leaves it\nalone; turn a new one on and the next cron run backfills it from the beginning,\nautomatically.\n\n## Example queries\n\nMonthly recognized revenue (invoice line periods, prorations included):\n\n```sql\nSELECT strftime('%Y-%m', period_start, 'unixepoch') AS month,\n SUM(amount) / 100.0 AS revenue\nFROM stripe_invoice_lines l\nJOIN stripe_invoices i ON i.id = l.invoice_id\nWHERE i.status = 'paid'\nGROUP BY month ORDER BY month;\n```\n\nActive MRR by product:\n\n```sql\nSELECT pr.name, SUM(p.unit_amount * si.quantity) / 100.0 AS mrr\nFROM stripe_subscription_items si\nJOIN stripe_subscriptions s ON s.id = si.subscription_id\nJOIN stripe_prices p ON p.id = si.price_id\nJOIN stripe_products pr ON pr.id = p.product_id\nWHERE s.status = 'active' AND p.recurring_interval = 'month'\nGROUP BY pr.name ORDER BY mrr DESC;\n```\n\n## Files\n\n- `cron.ts` — 5-minute interval: advances a pending backfill, otherwise events\n sync\n- `index.tsx` — the site: landing page, /admin status + controls, /data browser\n- `backfill.ts` / `resync.ts` / `status.ts` — script equivalents, run manually\n- `config.ts` — tables, rate limits, tuning knobs\n- `lib/stripe.ts` — rate-limited Stripe client (token bucket + concurrency\n gate + 429/5xx retry)\n- `lib/backfill.ts`, `lib/events.ts` — the two sync engines\n- `lib/schema.ts`, `lib/rows.ts`, `lib/state.ts`, `lib/db.ts` — tables,\n object→row mapping, cursors, upsert helper\n- `lib/metrics.ts` — MRR/ARR and status queries\n- `lib/landing.tsx`, `lib/admin.tsx`, `lib/browse.tsx`, `lib/views.tsx` — the\n three pages and shared layout\n\n## Limits and notes\n\n- Stripe only retains **30 days** of events. If the cron is ever paused longer\n than that, run `resync.ts` to catch up.\n- Deletions arrive via events (the refetch 404s and the row is dropped). Objects\n deleted while the cron was paused past retention are only cleaned up by a\n re-sync.\n- Charges, payment intents, refunds, and disputes aren't mirrored by default. To\n add a resource: a toggle in `config.ts`, a list entry in `lib/backfill.ts`, a\n row mapper in `lib/rows.ts`, a table in `lib/schema.ts`, and (for live\n updates) a case in `lib/events.ts`.\n- The rate limiter is per-process: don't run `backfill.ts` twice simultaneously,\n or lower `RATE_LIMIT_FRACTION` if other systems share the same Stripe key's\n budget.\n- Sandbox quirk: objects attached to\n [test clocks](https://docs.stripe.com/billing/testing/test-clocks) don't\n appear in Stripe's list endpoints, so the backfill can't see them — they\n arrive via the events sync instead. Production data is unaffected.",[189],"b527262a-1d83-40fe-8ce4-b71503f5711f","lib","2e7297be-643e-11f1-812a-1607ee4eb77e",1,["D",1781035365512],"directory",[196],"pulls","branches","forks","envVars",{"_209":198,"_211":148},"connections",{"_209":148,"_210":148},"count","unfilledCount","emptyCount",{"_44":195,"_32":196,"_30":197,"_144":-5,"_42":43,"_41":198,"_146":61,"_39":371,"_13":148,"_34":200,"_36":-5,"_24":25,"_150":-5,"_236":372,"_27":373},{"_44":363,"_32":364,"_30":365,"_144":197,"_42":43,"_41":366,"_146":61,"_39":367,"_13":148,"_34":35,"_36":368,"_24":25,"_150":-5,"_236":369,"_27":370},{"_44":355,"_32":356,"_30":357,"_144":197,"_42":43,"_41":358,"_146":25,"_39":359,"_13":148,"_34":35,"_36":360,"_24":25,"_150":-5,"_236":361,"_27":362},{"_44":348,"_32":182,"_30":349,"_144":197,"_42":43,"_41":350,"_146":61,"_39":351,"_13":148,"_34":35,"_36":352,"_24":25,"_150":-5,"_236":353,"_27":354},{"_44":340,"_32":341,"_30":342,"_144":197,"_42":43,"_41":343,"_146":61,"_39":344,"_13":148,"_34":35,"_36":345,"_24":25,"_150":-5,"_236":346,"_27":347},{"_44":336,"_32":33,"_30":31,"_144":197,"_42":43,"_41":14,"_146":25,"_39":337,"_13":65,"_34":35,"_36":38,"_24":25,"_150":-5,"_236":338,"_27":339},{"_44":328,"_32":329,"_30":330,"_144":197,"_42":43,"_41":331,"_146":61,"_39":332,"_13":148,"_34":35,"_36":333,"_24":25,"_150":-5,"_236":334,"_27":335},{"_44":320,"_32":321,"_30":322,"_144":197,"_42":43,"_41":323,"_146":61,"_39":324,"_13":148,"_34":35,"_36":325,"_24":25,"_150":-5,"_236":326,"_27":327},{"_44":312,"_32":313,"_30":314,"_144":197,"_42":43,"_41":315,"_146":25,"_39":316,"_13":65,"_34":35,"_36":317,"_24":25,"_150":-5,"_236":318,"_27":319},{"_44":304,"_32":305,"_30":306,"_144":197,"_42":43,"_41":307,"_146":61,"_39":308,"_13":148,"_34":35,"_36":309,"_24":25,"_150":-5,"_236":310,"_27":311},{"_44":296,"_32":297,"_30":298,"_144":197,"_42":43,"_41":299,"_146":61,"_39":300,"_13":148,"_34":35,"_36":301,"_24":25,"_150":-5,"_236":302,"_27":303},{"_44":288,"_32":289,"_30":290,"_144":197,"_42":43,"_41":291,"_146":61,"_39":292,"_13":148,"_34":35,"_36":293,"_24":25,"_150":-5,"_236":294,"_27":295},{"_44":280,"_32":281,"_30":282,"_144":197,"_42":43,"_41":283,"_146":25,"_39":284,"_13":148,"_34":35,"_36":285,"_24":25,"_150":-5,"_236":286,"_27":287},{"_44":272,"_32":273,"_30":274,"_144":197,"_42":43,"_41":275,"_146":61,"_39":276,"_13":148,"_34":35,"_36":277,"_24":25,"_150":-5,"_236":278,"_27":279},{"_44":265,"_32":266,"_30":267,"_144":197,"_42":43,"_41":163,"_146":61,"_39":268,"_13":148,"_34":35,"_36":269,"_24":25,"_150":-5,"_236":270,"_27":271},{"_44":257,"_32":258,"_30":259,"_144":197,"_42":43,"_41":260,"_146":25,"_39":261,"_13":198,"_34":35,"_36":262,"_24":25,"_150":-5,"_236":263,"_27":264},{"_44":188,"_32":189,"_30":190,"_144":-5,"_42":43,"_41":191,"_146":25,"_39":254,"_13":145,"_34":20,"_36":193,"_24":25,"_150":-5,"_236":255,"_27":256},{"_44":181,"_32":182,"_30":183,"_144":-5,"_42":43,"_41":184,"_146":25,"_39":251,"_13":148,"_34":35,"_36":186,"_24":25,"_150":-5,"_236":252,"_27":253},{"_44":175,"_32":176,"_30":177,"_144":-5,"_42":43,"_41":65,"_146":61,"_39":248,"_13":148,"_34":35,"_36":179,"_24":25,"_150":-5,"_236":249,"_27":250},{"_44":167,"_32":168,"_30":169,"_144":-5,"_42":43,"_41":170,"_146":61,"_39":245,"_13":148,"_34":172,"_36":173,"_24":25,"_150":-5,"_236":246,"_27":247},{"_44":159,"_32":160,"_30":59,"_144":-5,"_42":43,"_41":161,"_146":25,"_39":242,"_13":163,"_34":164,"_36":165,"_24":25,"_150":46,"_236":243,"_27":244},{"_44":152,"_32":153,"_30":154,"_144":-5,"_42":43,"_41":155,"_146":25,"_39":239,"_13":148,"_34":35,"_36":157,"_24":25,"_150":-5,"_236":240,"_27":241},{"_44":141,"_32":142,"_30":143,"_144":-5,"_42":43,"_41":145,"_146":25,"_39":235,"_13":148,"_34":35,"_36":149,"_24":25,"_150":-5,"_236":237,"_27":238},["D",1781035509818],"children",[],[142],["D",1781035506449],[],[153],["D",1781040680088],[],[160],["D",1781035498220],[],[168],["D",1781035377171],[],[176],["D",1781035502829],[],[182],["D",1781040753206],[],[189],"02414297-f1bc-409f-8b14-b153b47173a6","views.tsx","e2a61548-6444-11f1-a056-1607ee4eb77e",30,["D",1781039955753],"/** @jsxImportSource npm:hono/jsx */\n// Shared layout and UI bits for all pages. No client JS anywhere — buttons\n// are plain HTML forms.\n\nexport function Layout({ title, children }: { title: string; children?: unknown }) {\n return (\n \n \n {title}\n \n \n \n \n

\n \n {children}\n

\n \n \n );\n}\n\nexport function Card({ label, value, note }: { label: string; value: string; note?: string }) {\n return (\n

{label}

{value}

\n {note &&

{note}

}\n

\n );\n}\n\nexport function Section({ title, children }: { title: string; children?: unknown }) {\n return (\n

{title}

\n {children}\n

\n );\n}\n\nexport function StatusBadge({ status }: { status: string }) {\n const styles: Record = {\n done: \"bg-emerald-500/10 text-emerald-300\",\n pending: \"bg-amber-500/10 text-amber-300\",\n error: \"bg-red-500/10 text-red-300\",\n };\n return (\n \n {status}\n \n );\n}\n\nexport const money = (cents: number, currency: string) =>\n new Intl.NumberFormat(\"en-US\", {\n style: \"currency\",\n currency: currency.toUpperCase(),\n maximumFractionDigits: 0,\n }).format(cents / 100);\n",[],[196,258],"97f397f8-e8fe-49f5-b2fd-57bfb5d02499","stripe.ts","40aca0e6-643e-11f1-af79-1607ee4eb77e",["D",1781035396088],"// Rate-limited Stripe REST client. Every request flows through a token\n// bucket pinned to RATE_LIMIT_FRACTION of Stripe's documented read limit,\n// plus a concurrency cap — so callers can fire requests in parallel freely\n// and throughput lands at ~80% of what Stripe allows.\nimport {\n LIVE_READS_PER_SECOND,\n MAX_CONCURRENCY,\n PAGE_SIZE,\n RATE_LIMIT_FRACTION,\n TEST_READS_PER_SECOND,\n} from \"../config.ts\";\n\nconst API_BASE = \"https://api.stripe.com\";\nconst MAX_RETRIES = 5;\n\nexport type StripeList = { data?: T[]; has_more?: boolean };\n\nexport function apiKey(): string {\n const key = Deno.env.get(\"STRIPE_API_KEY\");\n if (!key) throw new Error(\"STRIPE_API_KEY is not set — see README.md for setup\");\n return key;\n}\n\nfunction readsPerSecond(): number {\n const limit = apiKey().includes(\"_test_\") ? TEST_READS_PER_SECOND : LIVE_READS_PER_SECOND;\n return Math.max(1, Math.floor(limit * RATE_LIMIT_FRACTION));\n}\n\n// --- token bucket: refills once per second ---\nlet tokens = 0;\nlet windowStart = 0;\n\nasync function acquireToken() {\n while (true) {\n const now = Date.now();\n if (now - windowStart >= 1000) {\n windowStart = now;\n tokens = readsPerSecond();\n }\n if (tokens > 0) {\n tokens--;\n return;\n }\n await sleep(windowStart + 1000 - now + 5);\n }\n}\n\n// --- concurrency gate ---\nlet inFlight = 0;\nconst waiting: Array<() => void> = [];\n\nasync function acquireSlot() {\n if (inFlight >= MAX_CONCURRENCY) await new Promise((resolve) => waiting.push(resolve));\n inFlight++;\n}\n\nfunction releaseSlot() {\n inFlight--;\n waiting.shift()?.();\n}\n\nexport class NotFound extends Error {}\n\nexport async function stripeGet(path: string, params: Record = {}): Promise {\n const url = new URL(API_BASE + path);\n for (const [key, value] of Object.entries(params)) {\n for (const v of Array.isArray(value) ? value : [value]) url.searchParams.append(key, v);\n }\n await acquireSlot();\n try {\n for (let attempt = 0; ; attempt++) {\n await acquireToken();\n const res = await fetch(url, { headers: { Authorization: `Bearer ${apiKey()}` } });\n if (res.ok) return await res.json();\n const body = await res.text();\n if (res.status === 404) throw new NotFound(`Stripe GET ${path} 404`);\n const retryable = res.status === 429 || res.status >= 500;\n if (!retryable || attempt >= MAX_RETRIES) {\n throw new Error(`Stripe GET ${path} ${res.status}: ${body.slice(0, 300)}`);\n }\n const retryAfter = Number(res.headers.get(\"retry-after\"));\n await sleep((retryAfter > 0 ? retryAfter : 2 ** attempt) * 1000);\n }\n } finally {\n releaseSlot();\n }\n}\n\n// Returns null instead of throwing when the object no longer exists.\nexport async function stripeGetMaybe(path: string, params: Record = {}): Promise {\n try {\n return await stripeGet(path, params);\n } catch (error) {\n if (error instanceof NotFound) return null;\n throw error;\n }\n}\n\n// Fetch every page of a list endpoint (used for child lists like the rare\n// invoice with >100 lines).\nexport async function listAll(path: string, params: Record = {}): Promise {\n const all: any[] = [];\n let startingAfter: string | undefined;\n while (true) {\n const page = await stripeGet(path, {\n ...params,\n limit: String(PAGE_SIZE),\n ...(startingAfter ? { starting_after: startingAfter } : {}),\n }) as StripeList;\n const data = page.data ?? [];\n all.push(...data);\n if (!page.has_more || data.length === 0) return all;\n startingAfter = String(data.at(-1).id);\n }\n}\n\nfunction sleep(ms: number) {\n return new Promise((resolve) => setTimeout(resolve, Math.max(ms, 0)));\n}\n",[],[196,266],"3999f387-4a61-4a70-a40a-51c60c39cafc","state.ts","602e97c6-643e-11f1-9a79-1607ee4eb77e",7,["D",1781035448949],"// Sync bookkeeping: backfill cursors per resource and the events cursor.\nimport { enabledResources, EVENT_RETENTION_DAYS, Resource } from \"../config.ts\";\nimport { batchWrite, sqlite } from \"./db.ts\";\n\nexport type PendingResource = { resource: Resource; cursor: string | null };\n\nexport async function pendingResources(): Promise {\n const enabled = enabledResources();\n const result = await sqlite.execute(`SELECT resource, cursor FROM sync_state WHERE status = 'pending'`);\n return result.rows\n .map((row) => ({\n resource: String(row.resource) as Resource,\n cursor: row.cursor == null ? null : String(row.cursor),\n }))\n .filter((row) => enabled.includes(row.resource));\n}\n\nexport async function saveCursor(resource: string, cursor: string | null) {\n await sqlite.execute({\n sql: `UPDATE sync_state SET cursor = ?, last_run_at = ?, last_error = NULL WHERE resource = ?`,\n args: [cursor, new Date().toISOString(), resource],\n });\n}\n\nexport async function markDone(resource: string) {\n await sqlite.execute({\n sql: `UPDATE sync_state SET status = 'done', cursor = NULL, last_run_at = ?, last_error = NULL WHERE resource = ?`,\n args: [new Date().toISOString(), resource],\n });\n}\n\nexport async function markError(resource: string, message: string) {\n await sqlite.execute({\n sql: `UPDATE sync_state SET last_run_at = ?, last_error = ? WHERE resource = ?`,\n args: [new Date().toISOString(), message, resource],\n });\n}\n\n// Queue every enabled resource for a fresh full walk (keeps existing rows;\n// the walk upserts over them).\nexport async function resetForResync() {\n await sqlite.batch(enabledResources().map((resource) => ({\n sql: `UPDATE sync_state SET status = 'pending', cursor = NULL, last_error = NULL WHERE resource = ?`,\n args: [resource],\n })));\n}\n\n// --- events cursor ---\n\nexport async function eventCursor(): Promise {\n const result = await sqlite.execute(`SELECT last_event_created FROM event_state WHERE key = 'events'`);\n return Number(result.rows[0]?.last_event_created ?? 0);\n}\n\nexport async function saveEventCursor(created: number) {\n await sqlite.execute({\n sql: `UPDATE event_state SET last_event_created = ?, updated_at = ?, last_error = NULL WHERE key = 'events'`,\n args: [created, new Date().toISOString()],\n });\n}\n\nexport async function markEventError(message: string) {\n await sqlite.execute({\n sql: `UPDATE event_state SET updated_at = ?, last_error = ? WHERE key = 'events'`,\n args: [new Date().toISOString(), message],\n });\n}\n\nexport async function knownEventIds(ids: string[]): Promise> {\n const known = new Set();\n for (let i = 0; i < ids.length; i += 100) {\n const chunk = ids.slice(i, i + 100);\n const placeholders = chunk.map(() => \"?\").join(\", \");\n const result = await sqlite.execute({\n sql: `SELECT id FROM stripe_events WHERE id IN (${placeholders})`,\n args: chunk,\n });\n for (const row of result.rows) known.add(String(row.id));\n }\n return known;\n}\n\nexport async function recordEvents(events: { id: string; type: string; created: number }[]) {\n const processedAt = new Date().toISOString();\n await batchWrite(events.map((event) => ({\n sql: `INSERT INTO stripe_events (id, type, created, processed_at) VALUES (?, ?, ?, ?)\n ON CONFLICT(id) DO NOTHING`,\n args: [event.id, event.type, Number(event.created ?? 0), processedAt],\n })));\n const cutoff = Math.floor(Date.now() / 1000) - EVENT_RETENTION_DAYS * 24 * 60 * 60;\n await sqlite.execute({ sql: `DELETE FROM stripe_events WHERE created < ?`, args: [cutoff] });\n}\n",[],[196,273],"5badda46-68e5-4253-a94c-cccaa7c4d97f","sql.tsx","6d430ae4-644a-11f1-bf59-1607ee4eb77e",41,["D",1781040624859],"/** @jsxImportSource npm:hono/jsx */\n// Tiny server-side SQL syntax highlighter — tokenizes into JSX spans, no\n// client JS and no highlighting library.\n\nconst KEYWORDS = new Set([\n \"select\",\n \"from\",\n \"join\",\n \"left\",\n \"inner\",\n \"on\",\n \"where\",\n \"and\",\n \"or\",\n \"group\",\n \"order\",\n \"by\",\n \"as\",\n \"desc\",\n \"asc\",\n \"limit\",\n \"not\",\n \"null\",\n \"in\",\n]);\n\nconst TOKEN = /('[^']*')|(\\d+(?:\\.\\d+)?)|([a-zA-Z_][a-zA-Z0-9_]*)|(\\s+)|(.)/g;\n\nexport function Sql({ code }: { code: string }) {\n const tokens = [...code.matchAll(TOKEN)];\n return (\n

\n      {tokens.map((token, i) => {\n        const [text, str, num, word] = token;\n        if (str) return {text};\n        if (num) return {text};\n        if (word) {\n          if (KEYWORDS.has(word.toLowerCase())) return {text};\n          const next = tokens[i + 1];\n          if (next && next[0] === \"(\") return {text};\n          return {text};\n        }\n        return {text};\n      })}\n

\n );\n}\n",[],[196,281],"65ddb154-8b84-498b-bb0b-1f660d40c464","schema.ts","4bb211ce-643e-11f1-afcf-1607ee4eb77e",5,["D",1781035414579],"import { enabledResources } from \"../config.ts\";\nimport { sqlite } from \"./db.ts\";\n\n// Every mirror table promotes a few columns for indexing/joins and keeps the\n// complete Stripe object as JSON in `raw` — anything not promoted is still\n// queryable with json_extract(raw, '$.field').\nconst TABLES = [\n `CREATE TABLE IF NOT EXISTS stripe_customers (\n id TEXT PRIMARY KEY,\n name TEXT,\n email TEXT,\n created INTEGER,\n raw TEXT NOT NULL,\n synced_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS stripe_products (\n id TEXT PRIMARY KEY,\n name TEXT,\n active INTEGER,\n raw TEXT NOT NULL,\n synced_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS stripe_prices (\n id TEXT PRIMARY KEY,\n product_id TEXT,\n currency TEXT,\n unit_amount INTEGER,\n recurring_interval TEXT,\n recurring_interval_count INTEGER,\n raw TEXT NOT NULL,\n synced_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS stripe_subscriptions (\n id TEXT PRIMARY KEY,\n customer_id TEXT,\n status TEXT,\n created INTEGER,\n raw TEXT NOT NULL,\n synced_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS stripe_subscription_items (\n id TEXT PRIMARY KEY,\n subscription_id TEXT NOT NULL,\n price_id TEXT,\n quantity INTEGER NOT NULL DEFAULT 1,\n raw TEXT NOT NULL,\n synced_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS stripe_invoices (\n id TEXT PRIMARY KEY,\n customer_id TEXT,\n subscription_id TEXT,\n status TEXT,\n total INTEGER,\n currency TEXT,\n created INTEGER,\n raw TEXT NOT NULL,\n synced_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS stripe_invoice_lines (\n id TEXT PRIMARY KEY,\n invoice_id TEXT NOT NULL,\n subscription_id TEXT,\n price_id TEXT,\n product_id TEXT,\n amount INTEGER,\n period_start INTEGER,\n period_end INTEGER,\n proration INTEGER NOT NULL DEFAULT 0,\n raw TEXT NOT NULL,\n synced_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS stripe_credit_notes (\n id TEXT PRIMARY KEY,\n invoice_id TEXT,\n customer_id TEXT,\n amount INTEGER,\n status TEXT,\n created INTEGER,\n raw TEXT NOT NULL,\n synced_at TEXT NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS sync_state (\n resource TEXT PRIMARY KEY,\n status TEXT NOT NULL DEFAULT 'pending',\n cursor TEXT,\n last_run_at TEXT,\n last_error TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS event_state (\n key TEXT PRIMARY KEY,\n last_event_created INTEGER NOT NULL DEFAULT 0,\n updated_at TEXT,\n last_error TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS stripe_events (\n id TEXT PRIMARY KEY,\n type TEXT NOT NULL,\n created INTEGER NOT NULL,\n processed_at TEXT NOT NULL\n )`,\n];\n\nconst INDEXES = [\n `CREATE INDEX IF NOT EXISTS idx_invoices_customer ON stripe_invoices(customer_id)`,\n `CREATE INDEX IF NOT EXISTS idx_invoices_subscription ON stripe_invoices(subscription_id)`,\n `CREATE INDEX IF NOT EXISTS idx_invoices_created ON stripe_invoices(created)`,\n `CREATE INDEX IF NOT EXISTS idx_invoice_lines_invoice ON stripe_invoice_lines(invoice_id)`,\n `CREATE INDEX IF NOT EXISTS idx_invoice_lines_price ON stripe_invoice_lines(price_id)`,\n `CREATE INDEX IF NOT EXISTS idx_invoice_lines_subscription ON stripe_invoice_lines(subscription_id)`,\n `CREATE INDEX IF NOT EXISTS idx_subscriptions_customer ON stripe_subscriptions(customer_id)`,\n `CREATE INDEX IF NOT EXISTS idx_subscription_items_subscription ON stripe_subscription_items(subscription_id)`,\n `CREATE INDEX IF NOT EXISTS idx_prices_product ON stripe_prices(product_id)`,\n `CREATE INDEX IF NOT EXISTS idx_credit_notes_invoice ON stripe_credit_notes(invoice_id)`,\n `CREATE INDEX IF NOT EXISTS idx_events_created ON stripe_events(created)`,\n];\n\nexport async function ensureSchema() {\n await sqlite.batch([...TABLES, ...INDEXES].map((sql) => ({ sql, args: [] })));\n\n // Seed state rows. A resource newly enabled in config.ts starts 'pending',\n // so the next cron run backfills it automatically.\n await sqlite.batch(enabledResources().map((resource) => ({\n sql: `INSERT INTO sync_state (resource, status) VALUES (?, 'pending') ON CONFLICT(resource) DO NOTHING`,\n args: [resource],\n })));\n\n // The event cursor starts at \"now\": history before this moment is the\n // backfill's job, and changes made during the backfill replay through events.\n await sqlite.execute({\n sql: `INSERT INTO event_state (key, last_event_created) VALUES ('events', ?) ON CONFLICT(key) DO NOTHING`,\n args: [Math.floor(Date.now() / 1000)],\n });\n}\n",[],[196,289],"c0eea8b4-8382-48f4-97be-f32bd71f540d","rows.ts","58f57420-643e-11f1-a315-1607ee4eb77e",6,["D",1781035436828],"// Maps raw Stripe objects to mirror-table upsert statements.\nimport { Statement, upsert } from \"./db.ts\";\n\n// Stripe fields can be an id string or an expanded object; normalize to id.\nexport function objectId(value: unknown): string | null {\n if (!value) return null;\n if (typeof value === \"string\") return value || null;\n return String((value as { id?: unknown }).id ?? \"\") || null;\n}\n\nexport function customerRow(customer: any, syncedAt: string): Statement {\n return upsert(\"stripe_customers\", {\n id: customer.id,\n name: customer.name,\n email: customer.email,\n created: customer.created,\n raw: JSON.stringify(customer),\n synced_at: syncedAt,\n });\n}\n\nexport function productRow(product: any, syncedAt: string): Statement {\n return upsert(\"stripe_products\", {\n id: product.id,\n name: product.name,\n active: product.active ? 1 : 0,\n raw: JSON.stringify(product),\n synced_at: syncedAt,\n });\n}\n\nexport function priceRow(price: any, syncedAt: string): Statement {\n return upsert(\"stripe_prices\", {\n id: price.id,\n product_id: objectId(price.product),\n currency: price.currency,\n unit_amount: price.unit_amount,\n recurring_interval: price.recurring?.interval,\n recurring_interval_count: price.recurring?.interval_count,\n raw: JSON.stringify(price),\n synced_at: syncedAt,\n });\n}\n\nexport function creditNoteRow(note: any, syncedAt: string): Statement {\n return upsert(\"stripe_credit_notes\", {\n id: note.id,\n invoice_id: objectId(note.invoice),\n customer_id: objectId(note.customer),\n amount: note.amount,\n status: note.status,\n created: note.created,\n raw: JSON.stringify(note),\n synced_at: syncedAt,\n });\n}\n\n// An invoice and its line items are written together: stale lines are deleted\n// first so removed or regenerated lines never linger.\nexport function invoiceRows(invoice: any, lines: any[], syncedAt: string): Statement[] {\n const invoiceId = String(invoice.id);\n return [\n { sql: `DELETE FROM stripe_invoice_lines WHERE invoice_id = ?`, args: [invoiceId] },\n upsert(\"stripe_invoices\", {\n id: invoiceId,\n customer_id: objectId(invoice.customer),\n subscription_id: invoiceSubscriptionId(invoice),\n status: invoice.status,\n total: invoice.total,\n currency: invoice.currency,\n created: invoice.created,\n raw: JSON.stringify(invoice),\n synced_at: syncedAt,\n }),\n ...lines.map((line) =>\n upsert(\"stripe_invoice_lines\", {\n id: line.id,\n invoice_id: invoiceId,\n subscription_id: lineSubscriptionId(invoice, line),\n price_id: linePriceId(line),\n product_id: lineProductId(line),\n amount: line.amount,\n period_start: line.period?.start,\n period_end: line.period?.end,\n proration: lineProration(line) ? 1 : 0,\n raw: JSON.stringify(line),\n synced_at: syncedAt,\n })\n ),\n ];\n}\n\nexport function subscriptionRows(sub: any, items: any[], syncedAt: string): Statement[] {\n const subId = String(sub.id);\n return [\n { sql: `DELETE FROM stripe_subscription_items WHERE subscription_id = ?`, args: [subId] },\n upsert(\"stripe_subscriptions\", {\n id: subId,\n customer_id: objectId(sub.customer),\n status: sub.status,\n created: sub.created,\n raw: JSON.stringify(sub),\n synced_at: syncedAt,\n }),\n ...items.map((item) =>\n upsert(\"stripe_subscription_items\", {\n id: item.id,\n subscription_id: subId,\n price_id: objectId(item.price),\n quantity: item.quantity ?? 1,\n raw: JSON.stringify(item),\n synced_at: syncedAt,\n })\n ),\n ];\n}\n\nexport function deleteInvoice(invoiceId: string): Statement[] {\n return [\n { sql: `DELETE FROM stripe_invoice_lines WHERE invoice_id = ?`, args: [invoiceId] },\n { sql: `DELETE FROM stripe_invoices WHERE id = ?`, args: [invoiceId] },\n ];\n}\n\nexport function deleteSubscription(subId: string): Statement[] {\n return [\n { sql: `DELETE FROM stripe_subscription_items WHERE subscription_id = ?`, args: [subId] },\n { sql: `DELETE FROM stripe_subscriptions WHERE id = ?`, args: [subId] },\n ];\n}\n\nexport function deleteRow(table: string, id: string): Statement {\n return { sql: `DELETE FROM ${table} WHERE id = ?`, args: [id] };\n}\n\n// Newer Stripe API versions put line price/product under pricing.price_details\n// and the subscription under parent.*; older versions used price/plan and\n// top-level subscription fields. Check both shapes.\nfunction linePriceId(line: any): string | null {\n return line.pricing?.price_details?.price ?? objectId(line.price) ?? objectId(line.plan);\n}\n\nfunction lineProductId(line: any): string | null {\n return line.pricing?.price_details?.product ?? objectId(line.price?.product) ?? objectId(line.plan?.product);\n}\n\nfunction lineSubscriptionId(invoice: any, line: any): string | null {\n return objectId(line.parent?.subscription_item_details?.subscription)\n ?? objectId(line.subscription)\n ?? invoiceSubscriptionId(invoice);\n}\n\nfunction invoiceSubscriptionId(invoice: any): string | null {\n return objectId(invoice.subscription) ?? objectId(invoice.parent?.subscription_details?.subscription);\n}\n\nfunction lineProration(line: any): boolean {\n return Boolean(line.parent?.subscription_item_details?.proration ?? line.proration ?? false);\n}\n",[],[196,297],"a79deded-3ae5-4f37-8087-046d2f80b508","metrics.ts","ce6de98e-6444-11f1-a4dc-1607ee4eb77e",16,["D",1781038210894],"// SQL behind the dashboard: MRR/ARR rollups and sync status reads.\nimport { sqlite } from \"./db.ts\";\n\nexport type MrrRow = { product: string; currency: string; mrrCents: number; subscribers: number };\n\n// Normalizes month/year recurring prices to monthly amounts (yearly ÷ 12,\n// interval_count respected). Day/week intervals are rare and ignored.\nexport async function mrrByProduct(): Promise {\n const result = await sqlite.execute(`\n SELECT COALESCE(pr.name, p.product_id, 'unknown') AS product,\n COALESCE(p.currency, 'usd') AS currency,\n CAST(SUM(p.unit_amount * si.quantity /\n (CASE p.recurring_interval WHEN 'year' THEN 12.0 ELSE 1.0 END\n * COALESCE(p.recurring_interval_count, 1))) AS INTEGER) AS mrr_cents,\n COUNT(DISTINCT s.id) AS subscribers\n FROM stripe_subscription_items si\n JOIN stripe_subscriptions s ON s.id = si.subscription_id\n JOIN stripe_prices p ON p.id = si.price_id\n LEFT JOIN stripe_products pr ON pr.id = p.product_id\n WHERE s.status = 'active'\n AND p.recurring_interval IN ('month', 'year')\n AND p.unit_amount IS NOT NULL\n GROUP BY product, p.currency\n ORDER BY mrr_cents DESC\n `);\n return result.rows.map((row) => ({\n product: String(row.product),\n currency: String(row.currency),\n mrrCents: Number(row.mrr_cents ?? 0),\n subscribers: Number(row.subscribers ?? 0),\n }));\n}\n\nexport type SyncRow = {\n resource: string;\n status: string;\n lastRunAt: string | null;\n lastError: string | null;\n};\n\nexport async function syncStatus(): Promise {\n const result = await sqlite.execute(\n `SELECT resource, status, last_run_at, last_error FROM sync_state ORDER BY resource`,\n );\n return result.rows.map((row) => ({\n resource: String(row.resource),\n status: String(row.status),\n lastRunAt: row.last_run_at == null ? null : String(row.last_run_at),\n lastError: row.last_error == null ? null : String(row.last_error),\n }));\n}\n\nexport type EventState = { lastEventCreated: number; updatedAt: string | null; lastError: string | null };\n\nexport async function eventState(): Promise {\n const result = await sqlite.execute(`SELECT * FROM event_state WHERE key = 'events'`);\n const row = result.rows[0] ?? {};\n return {\n lastEventCreated: Number(row.last_event_created ?? 0),\n updatedAt: row.updated_at == null ? null : String(row.updated_at),\n lastError: row.last_error == null ? null : String(row.last_error),\n };\n}\n\nconst COUNT_TABLES = [\n \"stripe_customers\",\n \"stripe_products\",\n \"stripe_prices\",\n \"stripe_subscriptions\",\n \"stripe_subscription_items\",\n \"stripe_invoices\",\n \"stripe_invoice_lines\",\n \"stripe_credit_notes\",\n];\n\nexport async function tableCounts(): Promise<{ table: string; count: number }[]> {\n return await Promise.all(COUNT_TABLES.map(async (table) => {\n const result = await sqlite.execute(`SELECT COUNT(*) AS n FROM ${table}`);\n return { table, count: Number(result.rows[0]?.n ?? 0) };\n }));\n}\n",[],[196,305],"d8bc57eb-72aa-4613-beec-5b0590d4b4fc","landing.tsx","ea8a299e-6448-11f1-a213-1607ee4eb77e",47,["D",1781040884178],"/** @jsxImportSource npm:hono/jsx */\n// Public landing page. Few words; the live chart does the talking.\nimport type { ArrSeries } from \"./arr.ts\";\nimport { ArrChart } from \"./chart.tsx\";\nimport type { EventState, MrrRow } from \"./metrics.ts\";\nimport { Sql } from \"./sql.tsx\";\nimport { Layout, money } from \"./views.tsx\";\n\nconst KEY_LINK =\n \"https://dashboard.stripe.com/apikeys/create?name=stripe-mirror&permissions%5B%5D=rak_customer_read&permissions%5B%5D=rak_product_read&permissions%5B%5D=rak_price_read&permissions%5B%5D=rak_plan_read&permissions%5B%5D=rak_subscription_read&permissions%5B%5D=rak_invoice_read&permissions%5B%5D=rak_credit_note_read&permissions%5B%5D=rak_event_read\";\n\nconst EXAMPLE_SQL = `SELECT strftime('%Y-%m', period_start, 'unixepoch') AS month,\n SUM(amount) / 100.0 AS revenue\nFROM stripe_invoice_lines l\nJOIN stripe_invoices i ON i.id = l.invoice_id\nWHERE i.status = 'paid'\nGROUP BY month ORDER BY month;`;\n\ntype LandingProps = {\n mrr: MrrRow[];\n counts: { table: string; count: number }[];\n events: EventState;\n arr: ArrSeries;\n hasKey: boolean;\n};\n\nexport function Landing({ mrr, counts, arr, hasKey }: LandingProps) {\n const currency = mrr[0]?.currency ?? \"usd\";\n const mrrTotal = mrr.reduce((sum, row) => sum + row.mrrCents, 0);\n const count = (table: string) => counts.find((c) => c.table === `stripe_${table}`)?.count ?? 0;\n return (\n \n

\n Your Stripe account, in a{\" \"}\n \n SQLite database\n {\" \"}\n you can query.\n

\n\n

ARR

\n \n \n live — synced from a sandboxed Stripe account with fake customers\n \n

\n {arr.months.length\n ? \n : (\n

\n {hasKey ? \"The chart draws itself once the first sync lands.\" : \"Connect a Stripe key and this chart draws itself.\"}\n

\n )}\n

\n The chart every investor update needs — straight from your own invoices.\n

\n\n

\n \n \n \n \n

\n\n

\n \n \n \n

\n\n

Then it's just SQL

\n \n

\n\n

Get your own

\n \n Remix this val\n \n
\n Create a read-only Stripe key — permissions\n prefilled\n
\n Add it as STRIPE_API_KEY. The cron handles the rest.\n

\n \n );\n}\n\nfunction Chip({ value, label }: { value: string; label: string }) {\n return (\n

{value}

{label}

\n );\n}\n\nfunction Mini({ title, text }: { title: string; text: string }) {\n return (\n

{title}

{text}

\n );\n}\n",[],[196,313],"d3f018cc-077c-4bf6-a95a-d302512915c4","events.ts","77a2ac4e-643e-11f1-8747-1607ee4eb77e",9,["D",1781035488296],"// Incremental sync driven by the Stripe Events API. Reads events since the\n// stored cursor (minus an overlap window), dedupes already-processed event\n// ids, then refetches the canonical objects that changed — in parallel — and\n// upserts them. Event payloads are never trusted as the source of truth; the\n// fresh GET is, so out-of-order events can't write stale data.\nimport { EVENT_OVERLAP_SECONDS, PAGE_SIZE, TABLES } from \"../config.ts\";\nimport { batchWrite, Statement } from \"./db.ts\";\nimport { invoiceLines, subscriptionItems } from \"./backfill.ts\";\nimport {\n creditNoteRow,\n customerRow,\n deleteInvoice,\n deleteRow,\n deleteSubscription,\n invoiceRows,\n objectId,\n priceRow,\n productRow,\n subscriptionRows,\n} from \"./rows.ts\";\nimport { stripeGet, stripeGetMaybe, StripeList } from \"./stripe.ts\";\nimport { eventCursor, knownEventIds, markEventError, recordEvents, saveEventCursor } from \"./state.ts\";\n\nconst MAX_EVENT_PAGES = 20;\n\ntype StripeEvent = { id: string; type: string; created: number; data?: { object?: any } };\n\nexport async function runEventSync() {\n try {\n const cursor = await eventCursor();\n const since = Math.max(0, cursor - EVENT_OVERLAP_SECONDS);\n const events = await fetchEventsSince(since);\n const known = await knownEventIds(events.map((event) => event.id));\n const unseen = events.filter((event) => !known.has(event.id));\n const targets = collectTargets(unseen);\n const counts = await syncTargets(targets);\n await recordEvents(unseen);\n const maxCreated = events.reduce((max, event) => Math.max(max, Number(event.created ?? 0)), cursor);\n await saveEventCursor(maxCreated);\n return { mode: \"events\", events: events.length, unseen: unseen.length, ...counts };\n } catch (error) {\n await markEventError(error instanceof Error ? error.message : String(error));\n throw error;\n }\n}\n\ntype Targets = {\n invoices: Set;\n credit_notes: Set;\n subscriptions: Set;\n customers: Set;\n prices: Set;\n products: Set;\n ignored: Set;\n};\n\nfunction collectTargets(events: StripeEvent[]): Targets {\n const targets: Targets = {\n invoices: new Set(),\n credit_notes: new Set(),\n subscriptions: new Set(),\n customers: new Set(),\n prices: new Set(),\n products: new Set(),\n ignored: new Set(),\n };\n for (const event of events) {\n const object = event.data?.object;\n const id = objectId(object);\n if (!object || !id) continue; // e.g. invoice.upcoming has no id\n switch (object.object) {\n case \"invoice\":\n targets.invoices.add(id);\n break;\n case \"credit_note\":\n targets.credit_notes.add(id);\n break;\n case \"subscription\":\n targets.subscriptions.add(id);\n break;\n case \"subscription_item\":\n addIf(targets.subscriptions, objectId(object.subscription));\n break;\n case \"invoiceitem\":\n addIf(targets.invoices, objectId(object.invoice));\n break;\n case \"customer\":\n targets.customers.add(id);\n break;\n case \"price\":\n targets.prices.add(id);\n break;\n case \"product\":\n targets.products.add(id);\n break;\n default:\n targets.ignored.add(event.type);\n }\n }\n return targets;\n}\n\n// Refetch every changed object concurrently (the rate limiter does the\n// pacing). A 404 or deleted flag means the object is gone — drop our row.\nasync function syncTargets(targets: Targets) {\n const syncedAt = new Date().toISOString();\n const refetch = (enabled: boolean, ids: Set, fn: (id: string) => Promise) =>\n enabled ? Promise.all([...ids].map(fn)) : Promise.resolve([]);\n\n const groups = await Promise.all([\n refetch(TABLES.invoices, targets.invoices, async (id) => {\n const invoice = await stripeGetMaybe(`/v1/invoices/${id}`);\n if (!invoice) return deleteInvoice(id);\n return invoiceRows(invoice, await invoiceLines(invoice), syncedAt);\n }),\n refetch(TABLES.credit_notes, targets.credit_notes, async (id) => {\n const note = await stripeGetMaybe(`/v1/credit_notes/${id}`);\n return note ? [creditNoteRow(note, syncedAt)] : [deleteRow(\"stripe_credit_notes\", id)];\n }),\n refetch(TABLES.subscriptions, targets.subscriptions, async (id) => {\n const sub = await stripeGetMaybe(`/v1/subscriptions/${id}`);\n if (!sub) return deleteSubscription(id);\n return subscriptionRows(sub, await subscriptionItems(sub), syncedAt);\n }),\n refetch(TABLES.customers, targets.customers, async (id) => {\n const customer = await stripeGetMaybe(`/v1/customers/${id}`);\n if (!customer || customer.deleted) return [deleteRow(\"stripe_customers\", id)];\n return [customerRow(customer, syncedAt)];\n }),\n refetch(TABLES.prices, targets.prices, async (id) => {\n const price = await stripeGetMaybe(`/v1/prices/${id}`);\n return price ? [priceRow(price, syncedAt)] : [deleteRow(\"stripe_prices\", id)];\n }),\n refetch(TABLES.products, targets.products, async (id) => {\n const product = await stripeGetMaybe(`/v1/products/${id}`);\n if (!product || product.deleted) return [deleteRow(\"stripe_products\", id)];\n return [productRow(product, syncedAt)];\n }),\n ]);\n\n const stmts = groups.flat(2);\n await batchWrite(stmts);\n return {\n changed: {\n invoices: targets.invoices.size,\n credit_notes: targets.credit_notes.size,\n subscriptions: targets.subscriptions.size,\n customers: targets.customers.size,\n prices: targets.prices.size,\n products: targets.products.size,\n },\n upserts: stmts.length,\n ignored: [...targets.ignored].sort(),\n };\n}\n\nasync function fetchEventsSince(createdGte: number): Promise {\n const events: StripeEvent[] = [];\n let startingAfter: string | undefined;\n for (let i = 0; i < MAX_EVENT_PAGES; i++) {\n const page = await stripeGet(\"/v1/events\", {\n limit: String(PAGE_SIZE),\n \"created[gte]\": String(createdGte),\n ...(startingAfter ? { starting_after: startingAfter } : {}),\n }) as StripeList;\n const data = page.data ?? [];\n events.push(...data);\n if (!page.has_more || data.length === 0) break;\n startingAfter = String(data.at(-1)!.id);\n }\n return events;\n}\n\nfunction addIf(target: Set, id: string | null) {\n if (id) target.add(id);\n}\n",[],[196,321],"0369a34c-077d-4445-8ca6-462dc82ea33e","db.ts","38241008-643e-11f1-822e-1607ee4eb77e",3,["D",1781035381773],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport { sqlite };\n\nexport type Statement = { sql: string; args: unknown[] };\n\n// sqlite.batch is transactional; chunk large write sets to keep batches sane.\nexport async function batchWrite(stmts: Statement[]) {\n for (let i = 0; i < stmts.length; i += 200) {\n await sqlite.batch(stmts.slice(i, i + 200) as any);\n }\n}\n\n// Build an idempotent upsert from a column map. Every mirror table keys on\n// `id`, which is what makes backfill, re-sync, and event replay all safe to\n// run repeatedly and concurrently.\nexport function upsert(table: string, cols: Record): Statement {\n const keys = Object.keys(cols);\n const updates = keys.filter((k) => k !== \"id\").map((k) => `${k} = excluded.${k}`).join(\", \");\n return {\n sql: `INSERT INTO ${table} (${keys.join(\", \")}) VALUES (${keys.map(() => \"?\").join(\", \")})\n ON CONFLICT(id) DO UPDATE SET ${updates}`,\n args: keys.map((k) => cols[k] ?? null),\n };\n}\n",[],[196,329],"4e4885ff-9a9c-4bac-b81f-59ab12924f1f",["D",1781041140248],[],[196,33],"6c8cc290-aa5e-4f39-a6a5-e390416b0d32","browse.tsx","0471b0fc-6449-11f1-9d6f-1607ee4eb77e",33,["D",1781040019384],"/** @jsxImportSource npm:hono/jsx */\n// Lightweight read-only browser for the mirrored rows: /data lists tables,\n// /data/:table pages through rows, /data/:table/:id shows the full raw JSON.\nimport { sqlite } from \"./db.ts\";\nimport { Layout, Section } from \"./views.tsx\";\n\nexport const BROWSABLE = [\n \"stripe_customers\",\n \"stripe_products\",\n \"stripe_prices\",\n \"stripe_subscriptions\",\n \"stripe_subscription_items\",\n \"stripe_invoices\",\n \"stripe_invoice_lines\",\n \"stripe_credit_notes\",\n];\nconst PAGE = 50;\n\nexport async function fetchRows(table: string, offset: number) {\n if (!BROWSABLE.includes(table)) throw new Error(`not browsable: ${table}`);\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${table} ORDER BY id LIMIT ? OFFSET ?`,\n args: [PAGE + 1, offset],\n });\n return { rows: result.rows.slice(0, PAGE), hasMore: result.rows.length > PAGE };\n}\n\nexport async function fetchRow(table: string, id: string) {\n if (!BROWSABLE.includes(table)) throw new Error(`not browsable: ${table}`);\n const result = await sqlite.execute({ sql: `SELECT * FROM ${table} WHERE id = ?`, args: [id] });\n return result.rows[0] ?? null;\n}\n\nexport function TableIndex({ counts }: { counts: { table: string; count: number }[] }) {\n return (\n \n

Browse the mirror

\n The raw mirrored tables. Every row keeps the complete Stripe object as JSON in its raw column.\n

\n \n \n {counts.map((c) => (\n \n \n \n \n ))}\n \n

\n {c.table}\n

{c.count.toLocaleString()} rows

\n \n );\n}\n\nconst truncate = (value: unknown) => {\n const text = value == null ? \"\" : String(value);\n return text.length > 60 ? text.slice(0, 57) + \"…\" : text;\n};\n\nexport function TableRows(\n { table, rows, offset, hasMore }: { table: string; rows: Record[]; offset: number; hasMore: boolean },\n) {\n const columns = rows.length ? Object.keys(rows[0]).filter((c) => c !== \"raw\") : [];\n return (\n \n

{table}

\n all tables · click an id for the full Stripe\n object\n

\n {rows.length === 0 ?

No rows{offset > 0 ? \" on this page\" : \" yet\"}.

: (\n

\n \n \n \n {columns.map((column) => )}\n \n \n \n {rows.map((row) => (\n \n {columns.map((column) =>\n column === \"id\"\n ? (\n \n )\n : \n )}\n \n ))}\n \n

{column}
\n \n {String(row.id)}\n \n	{truncate(row[column])}

\n )}\n

\n {offset > 0 && (\n \n ← previous\n \n )}\n {hasMore && (\n next →\n )}\n

\n \n );\n}\n\nexport function RowDetail({ table, row }: { table: string; row: Record }) {\n const raw = (() => {\n try {\n return JSON.stringify(JSON.parse(String(row.raw)), null, 2);\n } catch {\n return String(row.raw ?? \"\");\n }\n })();\n return (\n \n

{String(row.id)}

\n {table} · synced{\" \"}\n {String(row.synced_at ?? \"\")}\n

\n \n \n {Object.entries(row).filter(([key]) => key !== \"raw\").map(([key, value]) => (\n \n \n \n \n ))}\n \n

{key}

{value == null ? \"—\" : String(value)}

{raw}

\n \n );\n}\n",[],[196,341],"8e985576-9329-43c3-b40a-f80973e1bb73","6b1d76ac-643e-11f1-85c4-1607ee4eb77e",8,["D",1781035467271],"// Full historical sync. Each enabled resource walks its Stripe list endpoint\n// with a resumable cursor; all resources run in parallel, and within a page\n// the per-invoice/per-subscription child fetches fan out too. The shared\n// limiter in stripe.ts keeps total throughput at ~80% of Stripe's rate limit.\n// Safe to interrupt anywhere: progress is saved page by page and every write\n// is an upsert.\nimport { PAGE_SIZE, Resource } from \"../config.ts\";\nimport { batchWrite, Statement } from \"./db.ts\";\nimport { creditNoteRow, customerRow, invoiceRows, priceRow, productRow, subscriptionRows } from \"./rows.ts\";\nimport { listAll, stripeGet, StripeList } from \"./stripe.ts\";\nimport { markDone, markError, pendingResources, saveCursor } from \"./state.ts\";\n\nconst LIST: Record }> = {\n customers: { path: \"/v1/customers\" },\n products: { path: \"/v1/products\" },\n prices: { path: \"/v1/prices\" },\n subscriptions: { path: \"/v1/subscriptions\", params: { status: \"all\" } },\n invoices: { path: \"/v1/invoices\" },\n credit_notes: { path: \"/v1/credit_notes\" },\n};\n\nexport async function hasPendingBackfill(): Promise {\n return (await pendingResources()).length > 0;\n}\n\nexport async function runBackfill(budgetMs: number) {\n const deadline = Date.now() + budgetMs;\n const pending = await pendingResources();\n const results = await Promise.all(pending.map(async ({ resource, cursor }) => {\n try {\n return await syncResource(resource, cursor, deadline);\n } catch (error) {\n const message = error instanceof Error ? error.message : String(error);\n await markError(resource, message);\n return { resource, error: message };\n }\n }));\n return { mode: \"backfill\", results, done: !(await hasPendingBackfill()) };\n}\n\nasync function syncResource(resource: Resource, cursor: string | null, deadline: number) {\n let pages = 0;\n let objects = 0;\n while (Date.now() < deadline) {\n const page = await stripeGet(LIST[resource].path, {\n limit: String(PAGE_SIZE),\n ...LIST[resource].params,\n ...(cursor ? { starting_after: cursor } : {}),\n }) as StripeList;\n const data = page.data ?? [];\n await batchWrite(await pageStatements(resource, data));\n pages += 1;\n objects += data.length;\n if (!page.has_more || data.length === 0) {\n await markDone(resource);\n return { resource, pages, objects, done: true };\n }\n cursor = String(data.at(-1).id);\n await saveCursor(resource, cursor);\n }\n return { resource, pages, objects, done: false };\n}\n\nasync function pageStatements(resource: Resource, data: any[]): Promise {\n const syncedAt = new Date().toISOString();\n switch (resource) {\n case \"customers\":\n return data.map((customer) => customerRow(customer, syncedAt));\n case \"products\":\n return data.map((product) => productRow(product, syncedAt));\n case \"prices\":\n return data.map((price) => priceRow(price, syncedAt));\n case \"credit_notes\":\n return data.map((note) => creditNoteRow(note, syncedAt));\n case \"invoices\":\n return (await Promise.all(data.map(async (invoice) =>\n invoiceRows(invoice, await invoiceLines(invoice), syncedAt)\n ))).flat();\n case \"subscriptions\":\n return (await Promise.all(data.map(async (sub) =>\n subscriptionRows(sub, await subscriptionItems(sub), syncedAt)\n ))).flat();\n }\n}\n\n// List responses embed the first page of lines/items; only the rare object\n// with more than that costs an extra fetch.\nexport async function invoiceLines(invoice: any): Promise {\n if (!invoice.lines?.has_more) return invoice.lines?.data ?? [];\n return await listAll(`/v1/invoices/${invoice.id}/lines`);\n}\n\nexport async function subscriptionItems(sub: any): Promise {\n if (!sub.items?.has_more) return sub.items?.data ?? [];\n return await listAll(\"/v1/subscription_items\", { subscription: String(sub.id) });\n}\n",[],[196,182],"c2550b81-5c67-4740-87ab-b151721dd9ec","arr.ts","618e60c2-644a-11f1-ae60-1607ee4eb77e",39,["D",1781040605216],"// Monthly ARR series for the landing chart, computed from mirrored invoice\n// lines: at each month-end snapshot, sum the annualized amount of every paid\n// line whose service period covers that moment, stacked by product.\nimport { sqlite } from \"./db.ts\";\n\nexport type ArrMonth = { label: string; total: number; growth: number | null; segments: number[] };\nexport type ArrSeries = { months: ArrMonth[]; products: string[]; colors: string[] };\n\n// Bottom-of-stack first (cheapest tier), matching the classic ARR chart look.\nconst PALETTE = [\"#5b7fa6\", \"#e9a23b\", \"#d96b66\", \"#8b7bb8\", \"#5aa074\"];\n\nexport async function arrSeries(maxMonths = 13): Promise {\n const result = await sqlite.execute(`\n SELECT l.amount, l.period_start, l.period_end,\n COALESCE(pr.name, p.product_id, 'other') AS product,\n p.recurring_interval AS recurring_interval\n FROM stripe_invoice_lines l\n JOIN stripe_invoices i ON i.id = l.invoice_id\n LEFT JOIN stripe_prices p ON p.id = l.price_id\n LEFT JOIN stripe_products pr ON pr.id = p.product_id\n WHERE i.status = 'paid' AND l.amount > 0\n `);\n const lines = result.rows.map((row) => ({\n amount: Number(row.amount),\n start: Number(row.period_start),\n end: Number(row.period_end),\n product: String(row.product),\n interval: row.recurring_interval == null ? null : String(row.recurring_interval),\n }));\n\n const annualized = (line: typeof lines[number]) =>\n line.interval === \"year\"\n ? line.amount\n : line.interval === \"month\"\n ? line.amount * 12\n : line.end > line.start\n ? line.amount * (365.25 * 86400) / (line.end - line.start)\n : 0;\n\n // Month-end snapshots; the current month's snapshot is \"now\".\n const now = new Date();\n const snaps: { label: string; at: number }[] = [];\n for (let back = maxMonths - 1; back >= 0; back--) {\n const monthEnd = new Date(now.getFullYear(), now.getMonth() - back + 1, 0, 23, 59, 59);\n snaps.push({\n label: monthEnd.toLocaleString(\"en-US\", { month: \"short\" }),\n at: Math.floor(Math.min(monthEnd.getTime(), now.getTime()) / 1000),\n });\n }\n\n // Rank products by average annualized line amount: cheapest tier at the\n // bottom of the stack.\n const sums = new Map();\n for (const line of lines) {\n const entry = sums.get(line.product) ?? { total: 0, count: 0 };\n entry.total += annualized(line);\n entry.count += 1;\n sums.set(line.product, entry);\n }\n const products = [...sums.keys()].sort(\n (a, b) => sums.get(a)!.total / sums.get(a)!.count - sums.get(b)!.total / sums.get(b)!.count,\n );\n\n const months = snaps.map(({ label, at }) => {\n const segments = products.map(() => 0);\n for (const line of lines) {\n if (line.start <= at && at < line.end) {\n segments[products.indexOf(line.product)] += annualized(line);\n }\n }\n const total = segments.reduce((sum, v) => sum + v, 0);\n return { label, total, growth: null as number | null, segments };\n });\n\n // Drop empty leading months, then compute month-over-month growth.\n const first = months.findIndex((month) => month.total > 0);\n const trimmed = first === -1 ? [] : months.slice(first);\n for (let i = 1; i < trimmed.length; i++) {\n const prev = trimmed[i - 1].total;\n if (prev > 0) trimmed[i].growth = Math.round(((trimmed[i].total - prev) / prev) * 100);\n }\n\n return { months: trimmed, products, colors: products.map((_, i) => PALETTE[i % PALETTE.length]) };\n}\n",[],[196,356],"e6a647de-4804-4c63-9589-10869b34dbae","admin.tsx","fadba818-6448-11f1-9695-1607ee4eb77e",32,["D",1781040003397],"/** @jsxImportSource npm:hono/jsx */\n// Status page: the live state of this mirror — revenue metrics computed with\n// SQL over the local tables (no Stripe API calls), sync job health, and\n// buttons to drive syncs on demand.\nimport type { EventState, MrrRow, SyncRow } from \"./metrics.ts\";\nimport { Card, Layout, money, Section, StatusBadge } from \"./views.tsx\";\n\ntype AdminProps = {\n mrr: MrrRow[];\n counts: { table: string; count: number }[];\n sync: SyncRow[];\n events: EventState;\n pending: boolean;\n hasKey: boolean;\n};\n\nexport function Admin({ mrr, counts, sync, events, pending, hasKey }: AdminProps) {\n const totals = new Map();\n for (const row of mrr) totals.set(row.currency, (totals.get(row.currency) ?? 0) + row.mrrCents);\n return (\n \n

Mirror status

\n Everything below is computed from the local SQLite mirror — no Stripe API calls on this page.\n

\n {!hasKey && (\n

\n STRIPE_API_KEY is not set, so nothing can sync yet. See the README for one-click setup.\n

\n )}\n

\n {[...totals.entries()].map(([currency, cents]) => (\n <>\n \n \n \n ))}\n {totals.size === 0 && }\n

\n {mrr.length > 0 && (\n

\n \n \n \n \n \n \n \n \n \n {mrr.map((row) => (\n \n \n \n \n \n ))}\n \n

Product	Subscribers	MRR
{row.product}	{row.subscribers}	{money(row.mrrCents, row.currency)}

\n )}\n

\n Each table backfills once (status goes pending → done), then the 5-minute cron keeps everything fresh from\n the Events API. The events cursor shows how far that incremental sync has read.\n

\n \n \n {sync.map((row) => (\n \n \n \n \n \n ))}\n \n \n \n \n \n \n

{row.resource}	\n \n	{row.lastError ?? row.lastRunAt ?? \"never run\"}
events cursor	\n \n	\n {events.lastError ?? (events.lastEventCreated\n ? `caught up to ${new Date(events.lastEventCreated * 1000).toISOString()}`\n : \"not started\")}\n

\n {counts.map((c) => (\n <>\n \n {c.table.replace(\"stripe_\", \"\")} {c.count}\n \n {\" · \"}\n \n ))}\n browse all\n

\n \n \n

\n {pending\n ? \"Backfill in progress: each click runs a ~45s slice; the cron also advances it every 5 minutes.\"\n : \"Sync now pulls recent changes from the Events API. Re-sync re-walks all of Stripe history with upserts.\"}\n

\n \n );\n}\n",[],[196,364],["D",1781035365512],[213,214,215,216,217,218,219,220,221,222,223,224,225,226,227],[196],["D",1781035360700],["D",1789501878689],{"_102":101,"_110":106},{"_102":101,"_103":104,"_105":106,"_18":-5,"_107":108,"_109":61},{"_13":91,"_32":92,"_44":43,"_93":45,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":46,"_100":101},"ctx",{"_84":-5,"_130":412,"_413":414,"_415":416,"_417":25,"_418":25,"_419":25,"_420":61,"_421":-5,"_422":-7,"_423":-7,"_424":148,"_425":25,"_426":25,"_427":-5,"_428":25,"_429":25,"_430":25,"_431":-5},"ENV",{"_383":384,"_385":386,"_387":92,"_388":389,"_390":391,"_392":393,"_394":395,"_396":397,"_398":399,"_400":401,"_402":403,"_404":405,"_406":407,"_408":409,"_410":411},"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 · v49