feat: map (our) Jira to the multiple jira integrations from nango and adjust dependencies

Author: mbani01

services/apps/cron_service/src/jobs/nangoConnectionCleanup.job.ts

@@ -29,10 +29,9 @@ const job: IJobDefinition = {
     await initNangoCloudClient()
     const dbConnection = await getDbConnection(READ_DB_CONFIG(), 3, 0)
 
-    const allIntegrations = await fetchNangoIntegrationData(
-      pgpQx(dbConnection),
-      ALL_NANGO_INTEGRATIONS.map(nangoIntegrationToPlatform),
-    )
+    const allIntegrations = await fetchNangoIntegrationData(pgpQx(dbConnection), [
+      ...new Set(ALL_NANGO_INTEGRATIONS.map(nangoIntegrationToPlatform)),
+    ])
 
     const nangoConnections = await getNangoConnections()
 

services/apps/cron_service/src/jobs/nangoMonitoring.job.ts

@@ -34,10 +34,9 @@ const job: IJobDefinition = {
     await initNangoCloudClient()
     const dbConnection = await getDbConnection(READ_DB_CONFIG(), 3, 0)
 
-    const allIntegrations = await fetchNangoIntegrationData(
-      pgpQx(dbConnection),
-      ALL_NANGO_INTEGRATIONS.map(nangoIntegrationToPlatform),
-    )
+    const allIntegrations = await fetchNangoIntegrationData(pgpQx(dbConnection), [
+      ...new Set(ALL_NANGO_INTEGRATIONS.map(nangoIntegrationToPlatform)),
+    ])
 
     const nangoConnections = await getNangoConnections()
 
@@ -75,7 +74,9 @@ const job: IJobDefinition = {
           ctx.log.warn(`${int.platform} integration with id "${int.id}" is not connected to Nango!`)
         } else {
           const results = await getNangoConnectionStatus(
-            int.platform as NangoIntegration,
+            int.platform == PlatformType.JIRA
+              ? (int.settings.nangoIntegrationName as NangoIntegration)
+              : (int.platform as NangoIntegration),
             nangoConnection.connection_id,
           )
 

services/apps/cron_service/src/jobs/nangoTrigger.job.ts

@@ -28,15 +28,14 @@ const job: IJobDefinition = {
 
     const dbConnection = await getDbConnection(READ_DB_CONFIG(), 3, 0)
 
-    const integrationsToTrigger = await fetchNangoIntegrationData(
-      pgpQx(dbConnection),
-      ALL_NANGO_INTEGRATIONS.map(nangoIntegrationToPlatform),
-    )
+    const integrationsToTrigger = await fetchNangoIntegrationData(pgpQx(dbConnection), [
+      ...new Set(ALL_NANGO_INTEGRATIONS.map(nangoIntegrationToPlatform)),
+    ])
 
     for (const int of integrationsToTrigger) {
       const { id, settings } = int
 
-      const platform = platformToNangoIntegration(int.platform as PlatformType)
+      const platform = platformToNangoIntegration(int.platform as PlatformType, settings)
 
       if (platform === NangoIntegration.GITHUB && !settings.nangoMapping) {
         // ignore non-nango github integrations

services/apps/nango_worker/src/bin/full-resync.ts

@@ -30,7 +30,10 @@ setImmediate(async () => {
     )
 
     if (integration) {
-      const nangoIntegration = platformToNangoIntegration(integration.platform as PlatformType)
+      const nangoIntegration = platformToNangoIntegration(
+        integration.platform as PlatformType,
+        integration.settings,
+      )
 
       try {
         const toTrigger: string[] = []

services/apps/nango_worker/src/bin/trigger-onboarding-for-model.ts

@@ -34,7 +34,10 @@ setImmediate(async () => {
       log.info(
         `Triggering nango integration check for integrationId '${integrationId}' and connectionId '${connectionId}'!`,
       )
-      const providerConfigKey = platformToNangoIntegration(integration.platform as PlatformType)
+      const providerConfigKey = platformToNangoIntegration(
+        integration.platform as PlatformType,
+        integration.settings,
+      )
 
       await dbConnection.none(
         `