FIX: connections migration por favor funciona

src/modules/connection/client.service.ts

@@ -240,12 +240,21 @@ export class ConnectionClientService implements OnModuleInit {
       'DEBUG_ConnectionsMigrations - ' + JSON.stringify(customer_connections),
     );
 
-    const migrations = customer_connections.map((cc) => {
+    const migrations: {
+      customer_name: string;
+      status: any[];
+      productConnectionsMissing: ConnectionApiConnection[];
+      productNetworkConfigsMissing: ConnectionsApiNetworkConfig[];
+    }[] = [];
+    for (const customer_connection of customer_connections) {
       const productConnectionsMissing: ConnectionApiConnection[] = [];
       const productNetworkConfigsMissing: ConnectionsApiNetworkConfig[] = [];
+      const status: any[] = [];
+      let updatePromises: Promise<any>[] = [];
+
       this.logger.info(
         'DEBUG_ConnectionsMigrations - customer_connections ' +
-          JSON.stringify(cc),
+          JSON.stringify(customer_connection),
       );
       const {
         customer_name,
@@ -254,102 +263,108 @@ export class ConnectionClientService implements OnModuleInit {
         productNetworkConfigs,
         platformNetworkConfigs,
         customer_id,
-      } = cc;
+      } = customer_connection;
 
-      platformConnections &&
-        platformConnections.forEach((plc) => {
-          const productConnection = productConnections.find(
-            (prc) => prc.id === plc.config_id,
-          );
-          if (!productConnection) productConnectionsMissing.push(plc);
-        });
+      platformConnections?.forEach((plc) => {
+        const productConnection = productConnections.find(
+          (prc) => prc.id === plc.config_id,
+        );
+        if (!productConnection) productConnectionsMissing.push(plc);
+      });
+      platformNetworkConfigs?.forEach((platNetConfig) => {
+        const productNetworkConfig = productNetworkConfigs.find(
+          (prodNetConfig) => prodNetConfig.id === platNetConfig.config_id,
+        );
+        if (!productNetworkConfig)
+          productNetworkConfigsMissing.push(platNetConfig);
+      });
+      if (apply) {
+        for (const network_config of productNetworkConfigsMissing) {
+          const networkConfigToCatalog = {
+            id: network_config.config_id,
+            created_at: network_config.created_at,
+            updated_at: network_config.updated_at,
+            customer_name: customer_name,
+            customer_id: customer_id,
+            user_id: '',
+            network_type_id: '',
+            network_type_name: network_config.type,
+            type: network_config.type,
+            plugin: network_config.plugin,
+            name: network_config.name,
+            description: network_config.description,
+            properties: undefined,
+            keywords: undefined,
+            tags: undefined,
+          };
 
-      platformNetworkConfigs &&
-        platformNetworkConfigs.forEach((platNetConfig) => {
-          const productNetworkConfig = productNetworkConfigs.find(
-            (prodNetConfig) => prodNetConfig.id === platNetConfig.config_id,
-          );
-          if (!productNetworkConfig)
-            productNetworkConfigsMissing.push(platNetConfig);
-        });
-
-      const updatePromises: Promise<any>[] = [];
-      for (const network_config of productNetworkConfigsMissing) {
-        const networkConfigToCatalog = {
-          id: network_config.config_id,
-          created_at: network_config.created_at,
-          updated_at: network_config.updated_at,
-          customer_name: customer_name,
-          customer_id: customer_id,
-          user_id: '',
-          network_type_id: '',
-          network_type_name: network_config.type,
-          type: network_config.type,
-          plugin: network_config.plugin,
-          name: network_config.name,
-          description: network_config.description,
-          properties: undefined,
-          keywords: undefined,
-          tags: undefined,
-        };
-
-        if (apply) {
           updatePromises.push(
             this.catalogExistingConnection({
               networkConfig: networkConfigToCatalog,
             }),
           );
         }
-      }
-      for (const connection of productConnectionsMissing) {
-        const connector = connectors.find(
-          (c) => c._source.plugin === connection.plugin,
-        );
-        const connectionToCatalog = {
-          id: connection.config_id,
-          created_at: connection.created_at,
-          updated_at: new Date().toISOString(),
-          customer_id: customer_id,
-          user_id: '',
-          plugin: connection.plugin,
-          name: connection.name,
-          description: connection.description,
-          image_url: connector._source.image,
-          network_config_id: connection.network_config_id,
-          type: connection.type,
-          connector_id: connector._id,
-          connector_name: connector._source.name,
-          in_use: 1,
-          username: '',
-          customer_name,
-        };
 
-        if (apply) {
+        this.logger.info(
+          'DEBUG_ConnectionsMigrations - Creating missing network configs for customer' +
+            customer_name +
+            ' - ' +
+            JSON.stringify(customer_connection),
+        );
+        const updateStatuses = await Promise.all(updatePromises);
+        status.push(...updateStatuses);
+        updatePromises = [];
+        for (const connection of productConnectionsMissing) {
+          const connector = connectors.find(
+            (c) => c._source.plugin === connection.plugin,
+          );
+          const connectionToCatalog = {
+            id: connection.config_id,
+            created_at: connection.created_at,
+            updated_at: new Date().toISOString(),
+            customer_id: customer_id,
+            user_id: '',
+            plugin: connection.plugin,
+            name: connection.name,
+            description: connection.description,
+            image_url: connector._source.image,
+            network_config_id: connection.network_config_id,
+            type: connection.type,
+            connector_id: connector._id,
+            connector_name: connector._source.name,
+            in_use: 1,
+            username: '',
+            customer_name,
+          };
+
           updatePromises.push(
             this.catalogExistingConnection({ connection: connectionToCatalog }),
           );
         }
+        this.logger.info(
+          'DEBUG_ConnectionsMigrations - Creating missing connections for customer' +
+            ' - ' +
+            customer_name +
+            JSON.stringify(customer_connection),
+        );
+        const updateStatuses_2 = await Promise.all(updatePromises);
+        status.push(...updateStatuses_2);
       }
-      return {
+
+      this.logger.info(
+        'DEBUG_ConnectionsMigrations - migrations for customer ' +
+          customer_name +
+          ' - ' +
+          JSON.stringify(customer_connection),
+      );
+      migrations.push({
         customer_name,
-        updatePromises,
+        status,
         productConnectionsMissing,
         productNetworkConfigsMissing,
-      };
-    });
-    const customersStatus: any[] = [];
-    for (const migration of migrations) {
-      let status: any[] = [];
-      if (apply) {
-        status = await Promise.all(migration.updatePromises);
-      }
-      customersStatus.push({
-        customer: migration.customer_name,
-        status,
-        productConnectionsMissing: migration.productConnectionsMissing,
-        productNetworkConfigsMissing: migration.productNetworkConfigsMissing,
       });
     }
-    return { customersStatus };
+
+    return { migrations };
   }
 }