openapi is not using stripe

Author: Yostra

apps/supabase/src/edge-functions/stripe-backfill-worker.ts

@@ -7,9 +7,9 @@
  * to detect if all streams have completed.
  */
 
-import Stripe from 'npm:stripe'
 import pg from 'npm:pg@8'
 import { buildResourceRegistry } from '@stripe/source-stripe'
+import { resolveOpenApiSpec } from '@stripe/openapi'
 import { upsertMany } from '@stripe/destination-postgres'
 
 // Module-level singletons (reused across requests in Deno edge functions)
@@ -22,9 +22,10 @@ const PAGES_PER_INVOCATION = Number(Deno.env.get('PAGES_PER_INVOCATION')) || 10
 const schemaName = Deno.env.get('SYNC_SCHEMA_NAME') ?? 'stripe'
 const safeSchema = schemaName.replace(/"/g, '""')
 
-const stripe = new Stripe(Deno.env.get('STRIPE_SECRET_KEY')!)
+const stripeKey = Deno.env.get('STRIPE_SECRET_KEY')!
 const pool = new pg.Pool({ connectionString: dbUrl, max: 2 })
-const registry = buildResourceRegistry(stripe)
+const resolved = await resolveOpenApiSpec({ apiVersion: '2020-08-27' })
+const registry = buildResourceRegistry(resolved.spec, stripeKey)
 
 /** Find the resource config whose tableName matches the given stream name. */
 function findConfigByTableName(stream: string) {
@@ -117,7 +118,7 @@ Deno.serve(async (req) => {
     let newRecords = 0
 
     for (let page = 0; page < PAGES_PER_INVOCATION && hasMore; page++) {
-      const params: Stripe.PaginationParams = { limit: 100 }
+      const params: { limit: number; starting_after?: string } = { limit: 100 }
       if (cursor) params.starting_after = cursor
 
       const response = await listFn(params)

apps/supabase/src/edge-functions/stripe-webhook.ts

@@ -4,7 +4,7 @@ import sourceStripe, {
 } from '@stripe/source-stripe'
 import destinationPostgres, { type Config as DestConfig } from '@stripe/destination-postgres'
 import { catalogFromRegistry } from '@stripe/source-stripe'
-import Stripe from 'npm:stripe'
+import { resolveOpenApiSpec } from '@stripe/openapi'
 
 Deno.serve(async (req) => {
   if (req.method !== 'POST') {
@@ -36,8 +36,8 @@ Deno.serve(async (req) => {
     batch_size: 100,
   }
 
-  const stripe = new Stripe(stripeKey)
-  const registry = buildResourceRegistry(stripe)
+  const resolved = await resolveOpenApiSpec({ apiVersion: '2020-08-27' })
+  const registry = buildResourceRegistry(resolved.spec, stripeKey)
   const catalog = catalogFromRegistry(registry)
 
   try {

apps/supabase/src/edge-functions/stripe-worker.ts

@@ -7,9 +7,9 @@
  * stripe-backfill-worker for parallel per-stream backfill.
  */
 
-import Stripe from 'npm:stripe'
 import pg from 'npm:pg@8'
 import { buildResourceRegistry, catalogFromRegistry } from '@stripe/source-stripe'
+import { resolveOpenApiSpec } from '@stripe/openapi'
 
 // Module-level singletons (reused across requests in Deno edge functions)
 const dbUrl = Deno.env.get('SUPABASE_DB_URL')
@@ -21,9 +21,10 @@ const SYNC_INTERVAL = Number(Deno.env.get('SYNC_INTERVAL')) || 60 * 60 * 24 * 7
 const schemaName = Deno.env.get('SYNC_SCHEMA_NAME') ?? 'stripe'
 const safeSchema = schemaName.replace(/"/g, '""')
 
-const stripe = new Stripe(Deno.env.get('STRIPE_SECRET_KEY')!)
+const stripeKey = Deno.env.get('STRIPE_SECRET_KEY')!
 const pool = new pg.Pool({ connectionString: dbUrl, max: 2 })
-const registry = buildResourceRegistry(stripe)
+const resolved = await resolveOpenApiSpec({ apiVersion: '2020-08-27' })
+const registry = buildResourceRegistry(resolved.spec, stripeKey)
 
 Deno.serve(async (req) => {
   // Auth: validate Bearer token against vault worker secret