Fix production watched-minute billing sync (#6)

* fix(billing): sync watched minutes reliably

* fix(billing): align local storage usage

Author: richiemcilroy

apps/site/lib/billing.ts

@@ -515,7 +515,6 @@ async function localUsage(context: DashboardAccessContext) {
       WHERE asset.organization_id = $1::uuid
         AND asset.deleted_at IS NULL
         AND asset.duration_ms IS NOT NULL
-        AND asset.max_resolution_tier IN ('720p', '1080p', '2k', '4k')
     `,
     [context.organizationId]
   );

apps/site/lib/db/schema.ts

@@ -302,7 +302,6 @@ export const billingStorageSpans = rend.table(
       .notNull()
       .references(() => assets.id, { onDelete: "cascade" }),
     duration_ms: bigint("duration_ms", { mode: "number" }).notNull(),
-    resolution_tier: text("resolution_tier").notNull(),
     started_at: timestamp("started_at", { withTimezone: true }).notNull().defaultNow(),
     ended_at: timestamp("ended_at", { withTimezone: true }),
     created_at: timestamp("created_at", { withTimezone: true }).notNull().defaultNow(),
@@ -314,7 +313,6 @@ export const billingStorageSpans = rend.table(
       .where(sql`${table.ended_at} IS NULL`),
     index("billing_storage_spans_org_window_idx").on(
       table.organization_id,
-      table.resolution_tier,
       table.started_at,
       table.ended_at
     ),

migrations/0019_simplify_billing_storage_spans.sql

@@ -0,0 +1,8 @@
+DROP INDEX IF EXISTS rend.billing_storage_spans_org_window_idx;
+
+ALTER TABLE rend.billing_storage_spans
+  DROP CONSTRAINT IF EXISTS billing_storage_spans_resolution_tier_check,
+  DROP COLUMN IF EXISTS resolution_tier;
+
+CREATE INDEX IF NOT EXISTS billing_storage_spans_org_window_idx
+  ON rend.billing_storage_spans(organization_id, started_at, ended_at);