[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_335":336,"_337":338},"routes/_app.x.$handle.$name",{"_100":99,"_32":44,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":59,"_127":-5,"_128":-5,"_129":130},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":25,"_48":49,"_50":49,"_51":52,"_53":54,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",74,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":20,"_34":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":20,"_34":35},"deleted",false,"deletedHere","path","README.md","latestPath","fileId","9954b224-643e-11f1-a5d7-1607ee4eb77e","name","fileType","content","# stripe-mirror\n\nYour Stripe account, mirrored into a SQLite database you can query — built to\npower ARR charts like the ones in\n[Val Town's investor updates](https://blog.val.town/2026-april), and any other\nrevenue question you'd rather answer with SQL than with API calls.\n\n## The problem this solves\n\n1. **The Stripe API is rate limited**, so getting all of your data out is the\n hard part. The mirror backfills everything once — in parallel, just under the\n limit — then stays in sync from the Events API.\n2. **Subscriptions are mutable** — upgrades, prorations, cancellations, credit\n notes — so any honest revenue math needs every invoice for all time, not the\n most recent page.\n3. **It's free and fully yours.** Unlike Stripe Sigma or Data Pipeline, there's\n nothing to pay for and nothing you can't change: it's a few hundred lines of\n TypeScript in your own val, same model as\n [Supabase's Stripe Sync Engine](https://supabase.com/blog/stripe-sync-engine-integration).\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** — the \"Queue full re-sync\" button on `/admin` queues a fresh\n full walk at any time. It upserts over existing rows, so the mirror stays\n 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, month-over-month growth\n labels included\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👉\n[Add DASHBOARD_PASSWORD here](https://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- `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/arr.ts`, `lib/chart.tsx` — the monthly ARR series and the SVG chart\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.","# stripe-mirror\n\nYour Stripe account, mirrored into a SQLite database you can query — built to\npower ARR charts like the ones in\n[Val Town's investor updates](https://blog.val.town/2026-april), and any other\nrevenue question you'd rather answer with SQL than with API calls.\n\n## The problem this solves\n\n1. **The Stripe API is rate limited**, so getting all of your data out is the\n hard part. The mirror backfills everything once — in parallel, just under the\n limit — then stays in sync from the Events API.\n2. **Subscriptions are mutable** — upgrades, prorations, cancellations, credit\n notes — so any honest revenue math needs every invoice for all time, not the\n most recent page.\n3. **It's free and fully yours.** Unlike Stripe Sigma or Data Pipeline, there's\n nothing to pay for and nothing you can't change: it's a few hundred lines of\n TypeScript in your own val, same model as\n [Supabase's Stripe Sync Engine](https://supabase.com/blog/stripe-sync-engine-integration).\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** — the \"Queue full re-sync\" button on `/admin` queues a fresh\n full walk at any time. It upserts over existing rows, so the mirror stays\n 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, month-over-month growth\n labels included\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👉\n[Add DASHBOARD_PASSWORD here](https://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- `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/arr.ts`, `lib/chart.tsx` — the monthly ARR series and the SVG chart\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, queue a re-sync from `/admin` 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.","createdAt",["D",1781041864591],"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=1789570799&sig=79d162916b051180593161402e153914ca42f3e601daae8830099cf68fe5dc35","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",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":-5,"_105":106,"_107":59},"branch",{"_13":89,"_32":90,"_42":41,"_91":43,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":44,"_98":99},"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=1789570799&sig=257a5acfa0921f3bba1b6e04c40af81b331d69d65dd78c28728d8fa984364db5","tier","business","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_32":44,"_37":330,"_46":-5,"_47":25,"_48":49,"_50":49,"_51":52,"_53":54,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":331,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":332,"_84":333,"_86":334,"_88":25},"tree",[184,199,200,201,202],"files",[184,185,186,187,188,189,190,191,192,193,194,195,196,197,198,199,200,201,202],"counts",{"_174":152,"_175":170,"_176":152,"_177":178,"_179":180},"contents",[131,132,133,134,135],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":167,"_32":168,"_30":169,"_138":-5,"_40":41,"_39":170,"_140":59,"_37":171,"_13":152,"_33":172,"_34":-5,"_24":25,"_145":-5,"_27":173},{"_42":163,"_32":28,"_30":31,"_138":-5,"_40":41,"_39":14,"_140":25,"_37":164,"_13":165,"_33":20,"_34":36,"_24":25,"_145":-5,"_27":166},{"_42":156,"_32":157,"_30":158,"_138":-5,"_40":41,"_39":63,"_140":59,"_37":159,"_13":152,"_33":160,"_34":161,"_24":25,"_145":-5,"_27":162},{"_42":147,"_32":148,"_30":149,"_138":-5,"_40":41,"_39":150,"_140":59,"_37":151,"_13":152,"_33":153,"_34":154,"_24":25,"_145":-5,"_27":155},{"_42":136,"_32":137,"_30":57,"_138":-5,"_40":41,"_39":139,"_140":59,"_37":141,"_13":142,"_33":143,"_34":144,"_24":25,"_145":44,"_27":146},"13fdad4a-289a-423b-8c6f-e7532f920777","index.tsx","parentId",60,"latest",["D",1781041500117],5,"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 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","label",[137],"65affa8b-8bd5-438b-9619-3d66d53e2321","cron.ts","7d8f4162-643e-11f1-93e9-1607ee4eb77e",10,["D",1781035498220],0,"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",[148],"2f79552b-7912-49d9-95ea-21471b48334c","config.ts","3569068e-643e-11f1-af85-1607ee4eb77e",["D",1781035377171],"script","// 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",[157],"2f657199-037a-4944-9163-e342e85f0d3e",["D",1781041864591],20,[28],"b527262a-1d83-40fe-8ce4-b71503f5711f","lib","2e7297be-643e-11f1-812a-1607ee4eb77e",1,["D",1781035365512],"directory",[168],"pulls","branches","forks","envVars",{"_181":170,"_183":152},"connections",{"_181":152,"_182":152},"count","unfilledCount","emptyCount",{"_42":167,"_32":168,"_30":169,"_138":-5,"_40":41,"_39":170,"_140":59,"_37":327,"_13":152,"_33":172,"_34":-5,"_24":25,"_145":-5,"_204":328,"_27":329},{"_42":319,"_32":320,"_30":321,"_138":169,"_40":41,"_39":322,"_140":59,"_37":323,"_13":152,"_33":160,"_34":324,"_24":25,"_145":-5,"_204":325,"_27":326},{"_42":311,"_32":312,"_30":313,"_138":169,"_40":41,"_39":314,"_140":59,"_37":315,"_13":170,"_33":160,"_34":316,"_24":25,"_145":-5,"_204":317,"_27":318},{"_42":303,"_32":304,"_30":305,"_138":169,"_40":41,"_39":306,"_140":59,"_37":307,"_13":152,"_33":160,"_34":308,"_24":25,"_145":-5,"_204":309,"_27":310},{"_42":295,"_32":296,"_30":297,"_138":169,"_40":41,"_39":298,"_140":59,"_37":299,"_13":152,"_33":160,"_34":300,"_24":25,"_145":-5,"_204":301,"_27":302},{"_42":287,"_32":288,"_30":289,"_138":169,"_40":41,"_39":290,"_140":59,"_37":291,"_13":227,"_33":160,"_34":292,"_24":25,"_145":-5,"_204":293,"_27":294},{"_42":279,"_32":280,"_30":281,"_138":169,"_40":41,"_39":282,"_140":59,"_37":283,"_13":152,"_33":160,"_34":284,"_24":25,"_145":-5,"_204":285,"_27":286},{"_42":272,"_32":273,"_30":274,"_138":169,"_40":41,"_39":268,"_140":59,"_37":275,"_13":152,"_33":160,"_34":276,"_24":25,"_145":-5,"_204":277,"_27":278},{"_42":263,"_32":264,"_30":265,"_138":169,"_40":41,"_39":266,"_140":25,"_37":267,"_13":268,"_33":160,"_34":269,"_24":25,"_145":-5,"_204":270,"_27":271},{"_42":255,"_32":256,"_30":257,"_138":169,"_40":41,"_39":258,"_140":59,"_37":259,"_13":152,"_33":160,"_34":260,"_24":25,"_145":-5,"_204":261,"_27":262},{"_42":247,"_32":248,"_30":249,"_138":169,"_40":41,"_39":250,"_140":59,"_37":251,"_13":152,"_33":160,"_34":252,"_24":25,"_145":-5,"_204":253,"_27":254},{"_42":240,"_32":241,"_30":242,"_138":169,"_40":41,"_39":142,"_140":59,"_37":243,"_13":152,"_33":160,"_34":244,"_24":25,"_145":-5,"_204":245,"_27":246},{"_42":232,"_32":233,"_30":234,"_138":169,"_40":41,"_39":235,"_140":59,"_37":236,"_13":152,"_33":160,"_34":237,"_24":25,"_145":-5,"_204":238,"_27":239},{"_42":224,"_32":225,"_30":226,"_138":169,"_40":41,"_39":227,"_140":59,"_37":228,"_13":152,"_33":160,"_34":229,"_24":25,"_145":-5,"_204":230,"_27":231},{"_42":216,"_32":217,"_30":218,"_138":169,"_40":41,"_39":219,"_140":59,"_37":220,"_13":63,"_33":160,"_34":221,"_24":25,"_145":-5,"_204":222,"_27":223},{"_42":163,"_32":28,"_30":31,"_138":-5,"_40":41,"_39":14,"_140":25,"_37":213,"_13":165,"_33":20,"_34":36,"_24":25,"_145":-5,"_204":214,"_27":215},{"_42":156,"_32":157,"_30":158,"_138":-5,"_40":41,"_39":63,"_140":59,"_37":210,"_13":152,"_33":160,"_34":161,"_24":25,"_145":-5,"_204":211,"_27":212},{"_42":147,"_32":148,"_30":149,"_138":-5,"_40":41,"_39":150,"_140":59,"_37":207,"_13":152,"_33":153,"_34":154,"_24":25,"_145":-5,"_204":208,"_27":209},{"_42":136,"_32":137,"_30":57,"_138":-5,"_40":41,"_39":139,"_140":59,"_37":203,"_13":142,"_33":143,"_34":144,"_24":25,"_145":44,"_204":205,"_27":206},["D",1781041500117],"children",[],[137],["D",1781035498220],[],[148],["D",1781035377171],[],[157],["D",1781041864591],[],[28],"bbefe646-7e98-4a58-b374-8ececf88f2c5","views.tsx","e2a61548-6444-11f1-a056-1607ee4eb77e",62,["D",1781041657400],"/** @jsxImportSource npm:hono/jsx */\n// Shared layout and UI bits for all pages. No client JS anywhere — buttons\n// are plain HTML forms.\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\n\n// Resolved at runtime so remixes link to their own val, not the template.\nexport const VAL_URL = (() => {\n try {\n return parseVal(import.meta.url).links.self.val;\n } catch {\n return \"https://www.val.town/x/templates/stripe-mirror\";\n }\n})();\nexport const ENV_VAR_URL = `${VAL_URL}/environment-variables?key=STRIPE_API_KEY`;\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}\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",[],[168,217],"97f397f8-e8fe-49f5-b2fd-57bfb5d02499","stripe.ts","40aca0e6-643e-11f1-af79-1607ee4eb77e",4,["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",[],[168,225],"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",[],[168,233],"65ddb154-8b84-498b-bb0b-1f660d40c464","schema.ts","4bb211ce-643e-11f1-afcf-1607ee4eb77e",["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",[],[168,241],"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",[],[168,248],"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",[],[168,256],"8a59ced4-0aac-4ede-b9e0-892a8a8c331c","landing.tsx","ea8a299e-6448-11f1-a213-1607ee4eb77e",63,["D",1781041670461],9,"/** @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 { ENV_VAR_URL, Layout, VAL_URL } 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\ntype LandingProps = {\n arr: ArrSeries;\n hasKey: boolean;\n};\n\nexport function Landing({ arr, hasKey }: LandingProps) {\n return (\n \n

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

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

\n \n

\n )\n : (\n

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

\n )}\n

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

\n\n

\n \n \n \n

\n\n

\n \n \n \n

\n\n

Get your own

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

{title}

{text}

\n );\n}\n",[],[168,264],"d3f018cc-077c-4bf6-a95a-d302512915c4","events.ts","77a2ac4e-643e-11f1-8747-1607ee4eb77e",["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",[],[168,273],"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",[],[168,280],"b5cd1428-8a47-46b7-a2ac-cb9c79fdac84","chart.tsx","69a21862-644a-11f1-9bd0-1607ee4eb77e",53,["D",1781041324018],"/** @jsxImportSource npm:hono/jsx */\n// ARR bar chart, rendered server-side as plain SVG — no client JS. Each bar\n// shows month-over-month growth and the dollar total, investor-update 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 };\nconst BAR_COLOR = \"#6366f1\";\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 } = 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",[],[168,288],"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",[],[168,296],"8e985576-9329-43c3-b40a-f80973e1bb73","backfill.ts","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",[],[168,304],"26eae079-bc0a-4a70-9d64-4333c28863a3","arr.ts","618e60c2-644a-11f1-ae60-1607ee4eb77e",52,["D",1781041313099],"// 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.\nimport { sqlite } from \"./db.ts\";\n\nexport type ArrMonth = { label: string; total: number; growth: number | null };\nexport type ArrSeries = { months: ArrMonth[] };\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 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 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 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 months: ArrMonth[] = [];\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 const at = Math.floor(Math.min(monthEnd.getTime(), now.getTime()) / 1000);\n let total = 0;\n for (const line of lines) {\n if (line.start <= at && at < line.end) total += annualized(line);\n }\n months.push({ label: monthEnd.toLocaleString(\"en-US\", { month: \"short\" }), total, growth: null });\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 };\n}\n",[],[168,312],"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",[],[168,320],["D",1781035365512],[185,186,187,188,189,190,191,192,193,194,195,196,197,198],[168],["D",1781035360700],["D",1789501878689],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":-5,"_105":106,"_107":59},{"_13":89,"_32":90,"_42":41,"_91":43,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":44,"_98":99},"ctx",{"_82":-5,"_128":368,"_369":370,"_371":372,"_373":25,"_374":25,"_375":25,"_376":59,"_377":-5,"_378":-7,"_379":-7,"_380":152,"_381":25,"_382":25,"_383":-5,"_384":25,"_385":25,"_386":25,"_387":-5},"ENV",{"_339":340,"_341":342,"_343":90,"_344":345,"_346":347,"_348":349,"_350":351,"_352":353,"_354":355,"_356":357,"_358":359,"_360":361,"_362":363,"_364":365,"_366":367},"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 · v74