FIX: fix catalog route to use openSearch

src/modules/catalog/catalog-client.ts

@@ -0,0 +1,35 @@
+import {
+  ClientsProviderAsyncOptions,
+  GrpcOptions,
+  Transport,
+} from '@nestjs/microservices';
+import { credentials } from '@grpc/grpc-js';
+import { Catalog } from '@dadosfera/protospack-v2';
+
+export class CatalogClientConfiguration {
+  public name = 'CatalogClientConfiguration';
+  private config: GrpcOptions = {
+    transport: Transport.GRPC,
+    options: {
+      url: process.env.PIFACTORY_URL,
+      package: [
+        Catalog.ProtoPackages.ReadPackage,
+        Catalog.ProtoPackages.WritePackage,
+      ],
+
+      protoPath: [
+        Catalog.ProtoPaths.ReadFilePath,
+        Catalog.ProtoPaths.WriteFilePath,
+      ],
+      loader: {
+        keepCase: true,
+        enums: String,
+        defaults: false,
+      },
+    },
+  };
+  providerOptions: ClientsProviderAsyncOptions = {
+    name: this.name,
+    ...this.config,
+  };
+}

src/modules/catalog/catalog.controller.ts

@@ -13,6 +13,7 @@ import { AuthenticateCondition } from '../../authentication/authentication.decor
 import { PERMISSIONS_GROUPS } from '../../authentication/permissions.enum';
 import { CatalogService } from './catalog.service';
 import { DadosferaLogger } from '@dadosfera/dadosfera-logs';
+import { PackTheMetadata } from 'src/utils/ PackTheMetadata';
 
 @ApiTags('Catalog')
 @Controller('catalog')
@@ -48,14 +49,24 @@ export class CatalogController {
 
   @Get('all')
   async catalogAll(@Body() body) {
+    const { user_id, customer, customer_id } = body.info;
     this.logger.info(`/catalog - ON CATALOG ALL ROUTE`, {
       user: body.info.user_id,
       customer: body.info.customer,
     });
 
-    const res = await this.catalogService.catalogAll(body);
+    const metadata = PackTheMetadata({
+      user_id,
+      customer_id,
+      customer_name: customer,
+    });
 
-    return res;
+    const res = await this.catalogService.getAllOpenSearchDataAssets(
+      body,
+      metadata,
+    );
+
+    return { tables: res.data_assets };
   }
 
   @Get('data_apps')

src/modules/catalog/catalog.module.ts

@@ -4,9 +4,20 @@ import { DadosferaLogger } from '@dadosfera/dadosfera-logs';
 
 import { CatalogController } from './catalog.controller';
 import { CatalogService } from './catalog.service';
+import { PipelinesService } from '../pipelinesV2/pipelines.service';
+import { CatalogClientConfiguration } from './catalog-client';
+import { ClientsModule } from '@nestjs/microservices';
+import { PipelinesModule as OldPipelineModule } from 'src/modules/pipelines/pipelines.module';
+
+const client = new CatalogClientConfiguration();
 
 @Module({
+  imports: [
+    ClientsModule.register([client.providerOptions]),
+    OldPipelineModule,
+  ],
   controllers: [CatalogController],
   providers: [CatalogService, DadosferaLogger],
+  exports: [CatalogService],
 })
 export class CatalogModule {}

src/modules/catalog/catalog.service.ts

@@ -1,6 +1,32 @@
+import DadosferaLogger from '@dadosfera/dadosfera-logs/dist';
+import { ReadService } from '@dadosfera/protospack-v2/dist/lib/Catalog';
+import { ProtoServices } from '@dadosfera/protospack-v2/dist/lib/Catalog';
+import { Messages } from '@dadosfera/protospack-v2/dist/lib/Catalog';
+import { Inject, OnModuleInit } from '@nestjs/common';
+import { ClientGrpc } from '@nestjs/microservices';
 import axios from 'axios';
+import { lastValueFrom } from 'rxjs';
+import { CatalogClientConfiguration } from './catalog-client';
+
+class CatalogService implements OnModuleInit {
+  catalogReadService: ReadService.CatalogReadServices;
+  logger: any;
+  constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
+    @Inject(CatalogClientConfiguration.name)
+    private readonly grpcClient: ClientGrpc,
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
+
+  onModuleInit() {
+    this.catalogReadService =
+      this.grpcClient.getService<ReadService.CatalogReadServices>(
+        ProtoServices.CatalogReadServices,
+      );
+  }
 
-class CatalogService {
   _getNimbusUrl(body) {
     const customer = body.info.customer.toLowerCase();
 
@@ -41,6 +67,27 @@ class CatalogService {
     return data;
   }
 
+  async getAllOpenSearchDataAssets(
+    data: Messages.GetAllDataAssetsRequest,
+    metadata,
+  ) {
+    this.logger.info('CatalogService - getAllOpenSearchDashboard');
+
+    const response = await lastValueFrom(
+      this.catalogReadService.GetAllDataAssets(data, metadata),
+    )
+      .then((res) => {
+        this.logger.info('Done');
+        return JSON.parse(res.data_assets);
+      })
+      .catch((err) => {
+        this.logger.error(err.message);
+        throw new Error(err);
+      });
+
+    return { data_assets: response };
+  }
+
   async getOneDashboardMetabase(id, body) {
     const nimbusUrl = this._getNimbusUrl(body);
     const { data } = await axios.get(