feat: Rename header to x-customer-id

supaglue-labs · Feb 7, 2024 · 3d0e85f · 3d0e85f
1 parent 98bc126
commit 3d0e85f
Show file tree

Hide file tree

Showing 4 changed files with 17 additions and 10 deletions.
diff --git a/main/scripts/test-api.ts b/main/scripts/test-api.ts
@@ -2,9 +2,9 @@ import {initBYOSupaglueSDK} from '@supaglue/sdk'
 
 const supaglue = initBYOSupaglueSDK({
   headers: {
-    'x-connection-id': 'outreach1',
+    'x-customer-id': 'outreach1',
     'x-provider-name': 'outreach',
-    // 'x-connection-id': 'test-connection-id',
+    // 'x-customer-id': 'test-connection-id',
     // 'x-provider-name': 'salesforce',
   },
 })
@@ -53,7 +53,7 @@ main()
 
 // const supaglue = initBYOSupaglueSDK({
 //   headers: {
-//     'x-connection-id': 'hubspot1',
+//     'x-customer-id': 'hubspot1',
 //     'x-provider-name': 'hubspot',
 //   },
 // })

diff --git a/packages/sdk/index.ts b/packages/sdk/index.ts
@@ -11,7 +11,7 @@ export type BYOSupaglueSDKTypes = SDKTypes<
   oasTypes,
   Omit<ClientOptions, 'headers'> & {
     headers: {
-      'x-connection-id': string
+      'x-customer-id': string
       'x-provider-name': string
       [k: string]: string
     }

diff --git a/packages/vdk/trpc.ts b/packages/vdk/trpc.ts
@@ -22,11 +22,11 @@ export const publicProcedure = trpc.procedure
 
 export const remoteProcedure = publicProcedure.use(
   async ({next, ctx, path}) => {
-    const connectionId = ctx.headers.get('x-connection-id')
-    if (!connectionId) {
+    const customerId = ctx.headers.get('x-customer-id')
+    if (!customerId) {
       throw new TRPCError({
         code: 'BAD_REQUEST',
-        message: 'x-connection-id header is required',
+        message: 'x-customer-id header is required',
       })
     }
     const providerName = ctx.headers.get('x-provider-name')
@@ -47,13 +47,20 @@ export const remoteProcedure = publicProcedure.use(
 
     const nangoLink = nangoProxyLink({
       secretKey: ctx.nangoSecretKey,
-      connectionId,
+      connectionId: ctx.headers.get('x-connection-id') ?? customerId,
       providerConfigKey:
         ctx.headers.get('x-provider-config-key') ?? providerName,
     })
 
     return next({
-      ctx: {...ctx, path, connectionId, providerName, provider, nangoLink},
+      ctx: {
+        ...ctx,
+        path,
+        connectionId: customerId,
+        providerName,
+        provider,
+        nangoLink,
+      },
     })
   },
 )

diff --git a/packages/worker/routines.ts b/packages/worker/routines.ts
@@ -88,7 +88,7 @@ export async function syncConnection({
 
   const supaglue = initBYOSupaglueSDK({
     headers: {
-      'x-connection-id': connection_id,
+      'x-customer-id': connection_id,
       'x-provider-name': provider_config_key,
     },
   })