Merge pull request #134 from dadosfera/fix/connections-migration

Fix: connections migration

src/modules/connection/client.service.ts

@@ -26,16 +26,22 @@ import {
   ConnectionsApiNetworkConfig,
   NetworkConfigDto,
 } from '../network-config/dto/network-config';
+import DadosferaLogger from '@dadosfera/dadosfera-logs/dist';
 
 export class ConnectionClientService implements OnModuleInit {
   private connectionServiceRead: ConnectionManager.ReadService.ConnectionManagerReadServices;
   private connectionServiceWrite: ConnectionManager.WriteService.ConnectionManagerWriteServices;
+  logger: DadosferaLogger;
+
   constructor(
     @Inject(ConnectionClientConfiguration.name)
     private readonly grpcClient: ClientGrpc,
     private usersService: UsersService,
     private connectorService: ConnectorClientService,
-  ) {}
+    private dadosferaLogger: DadosferaLogger,
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   onModuleInit() {
     this.connectionServiceWrite =
@@ -214,14 +220,26 @@ export class ConnectionClientService implements OnModuleInit {
         this.INTERNAL_getAllConnections({ customer_name }).then((res) => ({
           customer_name,
           customer_id,
-          platformConnections: JSON.parse(res.platformConnections),
-          productConnections: JSON.parse(res.productConnections),
-          productNetworkConfigs: JSON.parse(res.productNetworkConfigs),
-          platformNetworkConfigs: JSON.parse(res.platformNetworkConfigs),
+          platformConnections: res.platformConnections
+            ? JSON.parse(res.platformConnections)
+            : [],
+          productConnections: res.productConnections
+            ? JSON.parse(res.productConnections)
+            : [],
+          productNetworkConfigs: res.productNetworkConfigs
+            ? JSON.parse(res.productNetworkConfigs)
+            : [],
+          platformNetworkConfigs: res.platformNetworkConfigs
+            ? JSON.parse(res.platformNetworkConfigs)
+            : [],
         })),
       );
     });
     const customer_connections = await Promise.all(promises);
+    this.logger.info(
+      'DEBUG-ConnectionsMigrations',
+      JSON.stringify(customer_connections),
+    );
 
     const productConnectionsMissing: ConnectionApiConnection[] = [];
     const productNetworkConfigsMissing: ConnectionsApiNetworkConfig[] = [];
@@ -235,20 +253,22 @@ export class ConnectionClientService implements OnModuleInit {
         customer_id,
       } = cc;
 
-      platformConnections.forEach((plc) => {
-        const productConnection = productConnections.find(
-          (prc) => prc.id === plc.config_id,
-        );
-        if (!productConnection) productConnectionsMissing.push(plc);
-      });
+      platformConnections &&
+        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);
-      });
+      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) {

src/modules/connector/connector.controller.ts

@@ -107,7 +107,7 @@ export class ConnectorController {
     @Headers('dadosfera-lang') language,
     @Query() queries: GetAllDto,
   ) {
-    this.logger.info('/upload - Upload Connector Route');
+    this.logger.info('/GET - getAllConnectors Route');
     if (!language) language = 'en-us';
 
     const { search, size, page, ...filters } = queries;
@@ -120,7 +120,7 @@ export class ConnectorController {
       page: page || 1,
     });
 
-    const connectors = JSON.parse(response.connectors).connectors;
+    const connectors = JSON.parse(response.connectors);
 
     return {
       message: response.message,
@@ -153,7 +153,7 @@ export class ConnectorController {
     @Param('plugin') plugin: string,
     @Query('version') version: string,
   ) {
-    this.logger.info('/upload - Upload Connector Route');
+    this.logger.info('/GET/:plugin - getConnector Route');
     if (!language) language = 'en-us';
 
     const pluginId = `${plugin}-${version}`;