fix: remove default tenantId fallback

Author: mbani01

services/apps/integration_run_worker/src/service/integrationRunService.ts

@@ -1,4 +1,4 @@
-import { DEFAULT_TENANT_ID, singleOrDefault } from '@crowd/common'
+import { singleOrDefault } from '@crowd/common'
 import {
   IntegrationRunWorkerEmitter,
   IntegrationStreamWorkerEmitter,
@@ -295,10 +295,8 @@ export default class IntegrationRunService extends LoggerBase {
     const cache = new RedisCache(`int-${runInfo.integrationType}`, this.redisClient, this.log)
 
     const nangoConfig = NANGO_CONFIG()
-    const nangoId =
-      // eslint-disable-next-line @typescript-eslint/no-explicit-any
-      (runInfo.integrationSettings as any)?.nangoId ||
-      `${DEFAULT_TENANT_ID}-${runInfo.integrationType}`
+    // eslint-disable-next-line @typescript-eslint/no-explicit-any
+    const nangoId = (runInfo.integrationSettings as any)?.nangoId
     const context: IGenerateStreamsContext = {
       onboarding: runInfo.onboarding,
       serviceSettings: {

services/apps/integration_stream_worker/src/service/integrationStreamService.ts

@@ -1,4 +1,4 @@
-import { DEFAULT_TENANT_ID, addSeconds, singleOrDefault } from '@crowd/common'
+import { addSeconds, singleOrDefault } from '@crowd/common'
 import {
   DataSinkWorkerEmitter,
   IntegrationRunWorkerEmitter,
@@ -284,10 +284,8 @@ export default class IntegrationStreamService extends LoggerBase {
     )
 
     const nangoConfig = NANGO_CONFIG()
-    const nangoId =
-      // eslint-disable-next-line @typescript-eslint/no-explicit-any
-      (streamInfo.integrationSettings as any)?.nangoId ||
-      `${DEFAULT_TENANT_ID}-${streamInfo.integrationType}`
+    // eslint-disable-next-line @typescript-eslint/no-explicit-any
+    const nangoId = (streamInfo.integrationSettings as any)?.nangoId
     const context: IProcessWebhookStreamContext = {
       serviceSettings: {
         nangoUrl: nangoConfig.url,
@@ -450,10 +448,8 @@ export default class IntegrationStreamService extends LoggerBase {
     )
 
     const nangoConfig = NANGO_CONFIG()
-    const nangoId =
-      // eslint-disable-next-line @typescript-eslint/no-explicit-any
-      (streamInfo.integrationSettings as any)?.nangoId ||
-      `${DEFAULT_TENANT_ID}-${streamInfo.integrationType}`
+    // eslint-disable-next-line @typescript-eslint/no-explicit-any
+    const nangoId = (streamInfo.integrationSettings as any)?.nangoId
     const context: IProcessStreamContext = {
       onboarding: streamInfo.onboarding,
       serviceSettings: {