get entities

src/clients/inputs/client.service.ts

@@ -1,4 +1,9 @@
-import { OnModuleInit, Inject, HttpException } from '@nestjs/common';
+import {
+  OnModuleInit,
+  Inject,
+  HttpException,
+  HttpStatus,
+} from '@nestjs/common';
 import { ClientGrpc } from '@nestjs/microservices';
 import {
   DecodeGrpcStruct,
@@ -268,4 +273,20 @@ export class InputsClientService implements OnModuleInit {
   // getOauthTokens(input){
 
   // }
+
+  async getAvailableEntities(data) {
+    console.log('InputClientService', 'GetAvailableEntities');
+    objectSnakeToCamel(data);
+    const response = await lastValueFrom(
+      this.inputService.GetAvailableEntities(data),
+    ).catch((err) => {
+      console.log(err);
+      if (err.details && err.details.includes('400'))
+        throw new HttpException('Plugin inválido', HttpStatus.BAD_REQUEST);
+      throw new HttpException(err.details, HttpStatus.INTERNAL_SERVER_ERROR);
+    });
+    objectCamelToSnake(response);
+
+    return response;
+  }
 }

src/modules/inputs/inputs.controller.ts

@@ -14,7 +14,16 @@ import { InputNewCreateRequest } from '@victorradael/protospack';
 
 @Controller('inputs')
 export class InputsController {
-  constructor(private inputsClientService: InputsClientService) {}
+  inputService: InputsService;
+  constructor(private inputsClientService: InputsClientService) {
+    this.inputService = new InputsService(this.inputsClientService);
+  }
+  @Get('available-entities/:plugin')
+  async getAvailableEntities(@Body() body, @Param() params) {
+    const { info } = body;
+    const { plugin } = params;
+    return await this.inputService.getAvailableEntities({ info, plugin });
+  }
 
   @Post('/test-connection')
   async testConnection(@Body() data) {

src/modules/inputs/inputs.service.ts

@@ -1,6 +1,7 @@
 import { Body, HttpException, HttpStatus, Injectable } from '@nestjs/common';
 import { Timeout } from '@nestjs/schedule';
 import CronParser, { CronExpression } from 'cron-parser';
+import { lastValueFrom } from 'rxjs';
 import { InputsClientService } from 'src/clients/inputs/client.service';
 import { IIdRequest, Info } from 'src/clients/inputs/interfaces';
 
@@ -70,7 +71,9 @@ export class InputsService {
         return response;
     }
   }
-
+  async getAvailableEntities(data): Promise<{ entities: string[] }> {
+    return await this.inputClient.getAvailableEntities(data);
+  }
   async findAll(body) {
     try {
       const findAllInputResponse: any = await this.inputClient.findAll(body);