\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",[],[86,128],"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",[],[86,136],"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",[],[86,144],"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",[],[86,152],"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",[],[86,159],"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",[],[86,167],"c50a054d-a85d-435a-a92c-787f362de294","landing.tsx","ea8a299e-6448-11f1-a213-1607ee4eb77e",77,["D",1781041882282],11,"/** @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

Get your own

\n \n );\n}\n\n",[],[86,175],"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",[],[86,184],"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",[],[86,192],"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",[],[86,200],"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",[],[86,208],"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",[],[86,216],"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",[],[86,224],"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",[],[86,232],"aca55a8a-72ee-4b8b-84aa-0a0762b4d677",["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","userId","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","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",{"_11":12,"_297":293},"org",{"_11":12,"_290":291,"_292":293,"_250":-5,"_294":295,"_296":48},"branch",{"_17":80,"_13":16,"_37":44,"_282":239,"_283":-5,"_284":-5,"_285":-5,"_286":-5,"_287":-5,"_288":14,"_289":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Templates","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789588799&sig=6ce4a653b65ad390b6349a1b0a383cb839cc380a1beaf91551581c108538875d","tier","business","canRestrictVals","profileImageUrl","adoptOrgId",{"_37":239,"_13":14,"_49":392,"_241":-5,"_242":57,"_243":244,"_245":244,"_246":247,"_248":249,"_250":251,"_252":41,"_253":48,"_254":-5,"_255":-5,"_256":72,"_257":258,"_259":260,"_261":262,"_263":393,"_265":-5,"_266":267,"_268":267,"_269":270,"_271":270,"_272":270,"_273":267,"_274":267,"_275":394,"_277":395,"_279":396,"_281":57},[335,350,351,352,353],"files",[335,336,337,338,339,340,341,342,343,344,345,346,347,348,349,350,351,352,353],"counts",{"_326":65,"_327":88,"_328":65,"_31":329,"_330":331},[316,317,318,319,320],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_37":85,"_13":86,"_40":87,"_42":-5,"_43":44,"_45":88,"_47":48,"_49":89,"_17":65,"_52":90,"_54":-5,"_56":57,"_58":-5,"_18":325},{"_37":77,"_13":78,"_40":79,"_42":-5,"_43":44,"_45":80,"_47":48,"_49":81,"_17":82,"_52":24,"_54":83,"_56":57,"_58":-5,"_18":324},{"_37":69,"_13":70,"_40":71,"_42":-5,"_43":44,"_45":72,"_47":48,"_49":73,"_17":65,"_52":74,"_54":75,"_56":57,"_58":-5,"_18":323},{"_37":60,"_13":61,"_40":62,"_42":-5,"_43":44,"_45":63,"_47":48,"_49":64,"_17":65,"_52":66,"_54":67,"_56":57,"_58":-5,"_18":322},{"_37":38,"_13":39,"_40":41,"_42":-5,"_43":44,"_45":46,"_47":48,"_49":50,"_17":51,"_52":53,"_54":55,"_56":57,"_58":14,"_18":321},[39],[61],[70],[78],[86],"pulls","branches","forks",{"_332":88,"_334":65},"connections",{"_332":65,"_333":65},"count","unfilledCount","emptyCount",{"_37":85,"_13":86,"_40":87,"_42":-5,"_43":44,"_45":88,"_47":48,"_49":110,"_17":65,"_52":90,"_54":-5,"_56":57,"_58":-5,"_98":390,"_18":391},{"_37":231,"_13":232,"_40":233,"_42":87,"_43":44,"_45":234,"_47":48,"_49":235,"_17":65,"_52":74,"_54":236,"_56":57,"_58":-5,"_98":388,"_18":389},{"_37":223,"_13":224,"_40":225,"_42":87,"_43":44,"_45":226,"_47":48,"_49":227,"_17":88,"_52":74,"_54":228,"_56":57,"_58":-5,"_98":386,"_18":387},{"_37":215,"_13":216,"_40":217,"_42":87,"_43":44,"_45":218,"_47":48,"_49":219,"_17":65,"_52":74,"_54":220,"_56":57,"_58":-5,"_98":384,"_18":385},{"_37":207,"_13":208,"_40":209,"_42":87,"_43":44,"_45":210,"_47":48,"_49":211,"_17":65,"_52":74,"_54":212,"_56":57,"_58":-5,"_98":382,"_18":383},{"_37":199,"_13":200,"_40":201,"_42":87,"_43":44,"_45":202,"_47":48,"_49":203,"_17":138,"_52":74,"_54":204,"_56":57,"_58":-5,"_98":380,"_18":381},{"_37":191,"_13":192,"_40":193,"_42":87,"_43":44,"_45":194,"_47":48,"_49":195,"_17":65,"_52":74,"_54":196,"_56":57,"_58":-5,"_98":378,"_18":379},{"_37":183,"_13":184,"_40":185,"_42":87,"_43":44,"_45":186,"_47":48,"_49":187,"_17":65,"_52":74,"_54":188,"_56":57,"_58":-5,"_98":376,"_18":377},{"_37":174,"_13":175,"_40":176,"_42":87,"_43":44,"_45":177,"_47":48,"_49":178,"_17":179,"_52":74,"_54":180,"_56":57,"_58":-5,"_98":374,"_18":375},{"_37":166,"_13":167,"_40":168,"_42":87,"_43":44,"_45":169,"_47":48,"_49":170,"_17":65,"_52":74,"_54":171,"_56":57,"_58":-5,"_98":372,"_18":373},{"_37":158,"_13":159,"_40":160,"_42":87,"_43":44,"_45":161,"_47":48,"_49":162,"_17":65,"_52":74,"_54":163,"_56":57,"_58":-5,"_98":370,"_18":371},{"_37":151,"_13":152,"_40":153,"_42":87,"_43":44,"_45":51,"_47":48,"_49":154,"_17":65,"_52":74,"_54":155,"_56":57,"_58":-5,"_98":368,"_18":369},{"_37":143,"_13":144,"_40":145,"_42":87,"_43":44,"_45":146,"_47":48,"_49":147,"_17":65,"_52":74,"_54":148,"_56":57,"_58":-5,"_98":366,"_18":367},{"_37":135,"_13":136,"_40":137,"_42":87,"_43":44,"_45":138,"_47":48,"_49":139,"_17":65,"_52":74,"_54":140,"_56":57,"_58":-5,"_98":364,"_18":365},{"_37":127,"_13":128,"_40":129,"_42":87,"_43":44,"_45":130,"_47":48,"_49":131,"_17":72,"_52":74,"_54":132,"_56":57,"_58":-5,"_98":362,"_18":363},{"_37":77,"_13":78,"_40":79,"_42":-5,"_43":44,"_45":80,"_47":48,"_49":107,"_17":82,"_52":24,"_54":83,"_56":57,"_58":-5,"_98":360,"_18":361},{"_37":69,"_13":70,"_40":71,"_42":-5,"_43":44,"_45":72,"_47":48,"_49":104,"_17":65,"_52":74,"_54":75,"_56":57,"_58":-5,"_98":358,"_18":359},{"_37":60,"_13":61,"_40":62,"_42":-5,"_43":44,"_45":63,"_47":48,"_49":101,"_17":65,"_52":66,"_54":67,"_56":57,"_58":-5,"_98":356,"_18":357},{"_37":38,"_13":39,"_40":41,"_42":-5,"_43":44,"_45":46,"_47":48,"_49":97,"_17":51,"_52":53,"_54":55,"_56":57,"_58":14,"_98":354,"_18":355},[],[39],[],[61],[],[70],[],[78],[],[86,128],[],[86,136],[],[86,144],[],[86,152],[],[86,159],[],[86,167],[],[86,175],[],[86,184],[],[86,192],[],[86,200],[],[86,208],[],[86,216],[],[86,224],[],[86,232],[336,337,338,339,340,341,342,343,344,345,346,347,348,349],[86],["D",1781035360700],["D",1789501878689],{"_11":12,"_297":293},{"_11":12,"_290":291,"_292":293,"_250":-5,"_294":295,"_296":48},{"_17":80,"_13":16,"_37":44,"_282":239,"_283":-5,"_284":-5,"_285":-5,"_286":-5,"_287":-5,"_288":14,"_289":12},"ctx",{"_275":-5,"_313":430,"_431":432,"_433":434,"_435":57,"_436":57,"_437":57,"_438":48,"_439":-5,"_440":-7,"_441":-7,"_442":65,"_443":57,"_444":57,"_445":-5,"_446":57,"_447":57,"_448":57,"_449":-5},"ENV",{"_401":402,"_403":404,"_405":16,"_406":407,"_408":409,"_410":411,"_412":413,"_414":415,"_416":417,"_418":419,"_420":421,"_422":423,"_424":425,"_426":427,"_428":429},"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"]

Code