openapi doesn't use sdk

Author: Yostra

packages/source-stripe/src/index.ts

@@ -117,7 +117,7 @@ const source = {
     const resolved = await resolveOpenApiSpec({
       apiVersion: config.api_version ?? '2020-08-27',
     })
-    const registry = buildResourceRegistry(makeClient(config), resolved.spec, config.api_key)
+    const registry = buildResourceRegistry(resolved.spec, config.api_key)
     try {
       const parser = new SpecParser()
       const parsed = parser.parse(resolved.spec, {
@@ -173,7 +173,7 @@ const source = {
     const resolved = await resolveOpenApiSpec({
       apiVersion: config.api_version ?? '2020-08-27',
     })
-    const registry = buildResourceRegistry(stripe, resolved.spec, config.api_key)
+    const registry = buildResourceRegistry(resolved.spec, config.api_key)
     const streamNames = new Set(catalog.streams.map((s) => s.stream.name))
 
     // Event-driven mode: iterate over incoming webhook inputs

packages/source-stripe/src/resourceRegistry.ts

@@ -1,13 +1,11 @@
-import Stripe from 'stripe'
 import type { ResourceConfig } from './types'
 import type { OpenApiSpec, NestedEndpoint } from '@stripe/openapi'
 import {
   discoverListEndpoints,
   discoverNestedEndpoints,
+  isV2Path,
   buildListFn,
   buildRetrieveFn,
-  canResolveSdkResource,
-  isV2Path,
   RUNTIME_REQUIRED_TABLES as OPENAPI_RUNTIME_REQUIRED_TABLES,
 } from '@stripe/openapi'
 
@@ -65,7 +63,6 @@ export const RESOURCE_TABLE_NAME_MAP: Record<string, string> = Object.fromEntrie
  * All resources get list + retrieve functions derived dynamically from the spec paths.
  */
 export function buildResourceRegistry(
-  stripe: Stripe,
   spec: OpenApiSpec,
   apiKey: string
 ): Record<string, ResourceConfig> {
@@ -76,7 +73,6 @@ export function buildResourceRegistry(
 
   for (const [tableName, endpoint] of endpoints) {
     const v2 = isV2Path(endpoint.apiPath)
-    if (!v2 && !canResolveSdkResource(stripe, endpoint.apiPath)) continue
 
     const children = nestedEndpoints
       .filter((n: NestedEndpoint) => n.parentTableName === tableName)
@@ -95,8 +91,8 @@ export function buildResourceRegistry(
       supportsLimit: endpoint.supportsLimit,
       sync: true,
       dependencies: [],
-      listFn: buildListFn(stripe, endpoint.apiPath, apiKey),
-      retrieveFn: buildRetrieveFn(stripe, endpoint.apiPath, apiKey),
+      listFn: buildListFn(apiKey, endpoint.apiPath),
+      retrieveFn: buildRetrieveFn(apiKey, endpoint.apiPath),
       nestedResources: children.length > 0 ? children : undefined,
     }
     registry[tableName] = config

packages/source-stripe/src/types.ts

@@ -1,4 +1,5 @@
-import Stripe from 'stripe'
+import type Stripe from 'stripe'
+import type { ListFn, RetrieveFn } from '@stripe/openapi'
 import type { RevalidateEntityName } from './resourceRegistry'
 
 /**
@@ -30,19 +31,10 @@ export type BaseResourceConfig = {
 }
 
 export type ResourceConfig = BaseResourceConfig & {
-  /** Function to list items from Stripe API */
-  listFn?: (params: Stripe.PaginationParams & { created?: Stripe.RangeQueryParam }) => Promise<{
-    data: unknown[]
-    has_more: boolean
-    pageCursor?: string
-  }>
-  /** Function to retrieve a single item by ID from Stripe API */
-  // eslint-disable-next-line @typescript-eslint/no-explicit-any
-  retrieveFn?: (id: string) => Promise<Stripe.Response<any>>
+  listFn?: ListFn
+  retrieveFn?: RetrieveFn
   /** Whether the list API supports the `limit` parameter */
   supportsLimit?: boolean
-  /** Optional list of sub-resources to expand during upsert/fetching (e.g. 'refunds', 'listLineItems') */
-  listExpands?: Record<string, (id: string) => Promise<Stripe.ApiList<{ id?: string }>>>[]
   /** Nested child resources discovered from the spec (e.g. subscription items under subscriptions) */
   nestedResources?: {
     tableName: string