enabling postconnect

connectors/connector-hubspot/server.ts

@@ -1,5 +1,5 @@
 import {initHubspotSDK, type HubspotSDK} from '@opensdks/sdk-hubspot'
-import type {ConnectorServer} from '@openint/cdk'
+import {initNangoSDK, type ConnectorServer} from '@openint/cdk'
 import {Rx, rxjs} from '@openint/util'
 import {HUBSPOT_ENTITIES, hubspotHelpers, type hubspotSchemas} from './def'
 
@@ -40,11 +40,44 @@ export const hubspotServer = {
   },
   // TODO enable this once we look into the data model of connectOutput
   // and map most appropriate response for hubspot
-  // postConnect: (connectOutput) => ({
-  //   resourceExternalId: connectOutput.resourceExternalId,
-  //   settings: connectOutput.settings,
-  //   triggerDefaultSync: true,
-  // }),
+  postConnect: async (connectOutput, config, context) => {
+    console.log('hubspot postConnect input:', {
+      connectOutput,
+      config,
+      context,
+    })
+    // TODO: pass this context in via postConnect?
+    const nango = initNangoSDK({
+      headers: {authorization: `Bearer ${process.env['NANGO_SECRET_KEY']}`},
+    })
+    const nangoConnection = await nango
+      .GET('/connection/{connectionId}', {
+        params: {
+          path: {connectionId: connectOutput.connectionId},
+          query: {
+            provider_config_key: connectOutput.providerConfigKey,
+          },
+        },
+      })
+      .then((r) => r.data)
+
+    console.log('nangoConnection', JSON.stringify(nangoConnection, null, 2))
+    const _instance = initHubspotSDK({
+      headers: {
+        authorization: `Bearer ${nangoConnection.credentials.access_token}`,
+      },
+    })
+    const accountInfo = await _instance.crm_objects
+      .request('GET', '/integrations/v1/me', {})
+      .then((r) => r.data)
+    return {
+      resourceExternalId: accountInfo.portalId,
+      settings: {
+        oauth: nangoConnection,
+      },
+      triggerDefaultSync: true,
+    }
+  },
   // @ts-expect-error QQ why is typing failing here?
   sourceSync: ({instance: hubspot, streams, state}) => {
     async function* iterateEntities() {