Code artifact and Get Connectors Tags

src/clients/auth/client.service.ts

@@ -1,8 +1,8 @@
 import { Logger, OnModuleInit, Inject } from '@nestjs/common';
 import { ClientGrpc } from '@nestjs/microservices';
 
-import { ProtoServices } from '@victorradael/protospack-v2/dist/lib/Duc';
-import { AuthProtoService as AuthServiceInterface } from '@victorradael/protospack-v2/dist/lib/Duc/interfaces/write-service';
+import { ProtoServices } from 'protospack-v2/dist/lib/Duc';
+import { AuthProtoService as AuthServiceInterface } from 'protospack-v2/dist/lib/Duc/interfaces/write-service';
 import {
   AuthGetPublicKeysResponse,
   AuthSignInRequest,
@@ -25,7 +25,7 @@ import {
   AuthVerifyResetPasswordCodeResponse,
   AuthConfirmResetPasswordRequest,
   AuthConfirmResetPasswordResponse,
-} from '@victorradael/protospack-v2/dist/lib/Duc/interfaces/messages';
+} from 'protospack-v2/dist/lib/Duc/interfaces/messages';
 
 import grpcHandler from '../../utils/grpcHandler';
 

src/clients/connector/client.config.ts

@@ -1,6 +1,6 @@
 import { credentials } from '@grpc/grpc-js';
 import { ClientOptions, Transport } from '@nestjs/microservices';
-import { ConnectorManager } from '@victorradael/protospack-v2';
+import { ConnectorManager } from 'protospack-v2';
 
 export class ConnectorClientConfiguration {
   config(): ClientOptions {

src/clients/connector/client.service.ts

@@ -5,7 +5,7 @@ import {
   HttpStatus,
 } from '@nestjs/common';
 import { ClientGrpc } from '@nestjs/microservices';
-import { ConnectorManager } from '@victorradael/protospack-v2';
+import { ConnectorManager } from 'protospack-v2';
 import { from } from 'rxjs';
 
 export class ConnectorClientService implements OnModuleInit {
@@ -200,6 +200,33 @@ export class ConnectorClientService implements OnModuleInit {
     return result;
   }
 
+  async getConnectorsTags() {
+    const observable = from(this.connectorServiceRead.GetConnectorsTags({}));
+    const result = await new Promise((resolve, reject) => {
+      observable.subscribe({
+        next(x) {
+          resolve(x);
+        },
+        error(err) {
+          console.log('Observable Error');
+          reject(err);
+        },
+        complete() {
+          console.log('done');
+        },
+      });
+    }).catch((err) => {
+      throw new HttpException(
+        err.details,
+        err.code === 6 ? HttpStatus.CONFLICT : 400,
+      );
+    });
+
+    console.log('ConnectorClientService', 'getAllConnectors');
+
+    return result;
+  }
+
   async deleteConnector(plugin: string, version: string) {
     const observable = from(
       this.connectorServiceWrite.DeleteConnector({

src/clients/duc/client.config.ts

@@ -1,9 +1,6 @@
 import { credentials } from '@grpc/grpc-js';
 import { ClientOptions, Transport } from '@nestjs/microservices';
-import {
-  ProtoPackages,
-  ProtoPaths,
-} from '@victorradael/protospack-v2/dist/lib/Duc';
+import { ProtoPackages, ProtoPaths } from 'protospack-v2/dist/lib/Duc';
 
 export class DucClient {
   config(): ClientOptions {
@@ -12,9 +9,10 @@ export class DucClient {
       options: {
         url: process.env.DUC_URL,
         package: ProtoPackages.WritePackage,
-        credentials: process.env.LOCAL_ENV
-          ? undefined
-          : credentials.createSsl(),
+        credentials:
+          process.env.LOCAL_ENV === 'local'
+            ? undefined
+            : credentials.createSsl(),
         protoPath: ProtoPaths.WriteFilePath,
         loader: {
           keepCase: true,

src/clients/inputs/client.config.ts

@@ -1,7 +1,7 @@
 import { credentials } from '@grpc/grpc-js';
 import { ClientOptions, Transport } from '@nestjs/microservices';
 
-import { InputPackages, InputProtoFilePath } from '@victorradael/protospack';
+import { InputPackages, InputProtoFilePath } from 'protospack';
 
 export class InputsClientConfiguration {
   config(): ClientOptions {

src/clients/inputs/client.service.ts

@@ -15,7 +15,7 @@ import {
   InputService,
   TestConnectionGetColumnsRequest,
   TestConnectionRequest,
-} from '@victorradael/protospack';
+} from 'protospack';
 import axios, { AxiosRequestConfig } from 'axios';
 import { lastValueFrom } from 'rxjs';
 import { InputModel } from 'src/modules/inputs/dtos/input.model';

src/clients/outputs/client.config.ts

@@ -1,4 +1,4 @@
-import { OutputPackages, OutputProtoFilePath } from '@victorradael/protospack';
+import { OutputPackages, OutputProtoFilePath } from 'protospack';
 import { ClientOptions, Transport } from '@nestjs/microservices';
 import { credentials } from '@grpc/grpc-js';
 

src/clients/outputs/client.service.ts

@@ -3,7 +3,7 @@ import { ClientGrpc, Payload } from '@nestjs/microservices';
 import {
   OutputServicesNames,
   OutputsServiceInterface,
-} from '@victorradael/protospack';
+} from 'protospack';
 import {
   objectCamelToSnake,
   objectSnakeToCamel,

src/clients/permissions/client.service.ts

@@ -1,12 +1,12 @@
 import { Logger, OnModuleInit, Inject } from '@nestjs/common';
 import { ClientGrpc } from '@nestjs/microservices';
 
-import { ProtoServices } from '@victorradael/protospack-v2/dist/lib/Duc';
-import { PermissionsProtoService as PermissionsServiceInterface } from '@victorradael/protospack-v2/dist/lib/Duc/interfaces/write-service';
+import { ProtoServices } from 'protospack-v2/dist/lib/Duc';
+import { PermissionsProtoService as PermissionsServiceInterface } from 'protospack-v2/dist/lib/Duc/interfaces/write-service';
 import {
   Empty,
   InjectPermissionsRequest,
-} from '@victorradael/protospack-v2/dist/lib/Duc/interfaces/messages';
+} from 'protospack-v2/dist/lib/Duc/interfaces/messages';
 
 import grpcHandler from '../../utils/grpcHandler';
 

src/clients/pipelines/client.config.ts

@@ -2,7 +2,7 @@ import { ClientOptions, Transport } from '@nestjs/microservices';
 import {
   PipelinePackages,
   PipelineProtoFilePath,
-} from '@victorradael/protospack';
+} from 'protospack';
 import { credentials } from '@grpc/grpc-js';
 
 export class PipelinesClientConfiguration {

src/clients/pipelines/client.service.ts

@@ -8,7 +8,7 @@ import { ClientGrpc, Payload } from '@nestjs/microservices';
 import {
   PipelineServicesNames,
   PipelinesServiceInterface,
-} from '@victorradael/protospack';
+} from 'protospack';
 import { lastValueFrom } from 'rxjs';
 import {
   objectCamelToSnake,

src/clients/transformations/client.config.ts

@@ -2,7 +2,7 @@ import { ClientOptions, Transport } from '@nestjs/microservices';
 import {
   TransformationPackages,
   TransformationProtoFilePath,
-} from '@victorradael/protospack';
+} from 'protospack';
 import { credentials } from '@grpc/grpc-js';
 
 export class TransformationsClientConfiguration {

src/clients/transformations/client.service.ts

@@ -1,6 +1,6 @@
 import { Controller, Inject, OnModuleInit, Post } from '@nestjs/common';
 import { ClientGrpc } from '@nestjs/microservices';
-import { TransformationsServiceInterface } from '@victorradael/protospack';
+import { TransformationsServiceInterface } from 'protospack';
 import {
   objectCamelToSnake,
   objectSnakeToCamel,

src/modules/auth/auth.controller.ts

@@ -19,7 +19,7 @@ import {
   AuthEnableTotpMfaRequest,
   AuthDisableTotpMfaRequest,
   AuthVerifyTotpMfaRequest,
-} from '@victorradael/protospack-v2/dist/lib/Duc/interfaces/messages';
+} from 'protospack-v2/dist/lib/Duc/interfaces/messages';
 
 import { AuthClientService } from '../../clients/auth/client.service';
 import { PermissionsClientService } from '../../clients/permissions/client.service';

src/modules/connector/connector.controller.ts

@@ -78,6 +78,11 @@ export class ConnectorController {
     };
   }
 
+  @Get('/tags')
+  async getConnectorsTags() {
+    return await this.connectorClientService.getConnectorsTags();
+  }
+
   @Get('/:plugin')
   async getConnector(
     @Param('plugin') plugin: string,

src/modules/inputs/inputs.service.ts

@@ -1,6 +1,6 @@
 import { Body, HttpException, HttpStatus, Injectable } from '@nestjs/common';
 import { Timeout } from '@nestjs/schedule';
-import { DecodeGrpcStruct } from '@victorradael/protospack';
+import { DecodeGrpcStruct } from 'protospack';
 import CronParser, { CronExpression } from 'cron-parser';
 import { InputsClientService } from 'src/clients/inputs/client.service';
 import { IIdRequest, Info } from 'src/clients/inputs/interfaces';

src/modules/pipelines/pipelines.service.ts

@@ -1,5 +1,5 @@
 import { HttpException, HttpStatus, Injectable } from '@nestjs/common';
-import { DecodeGrpcStruct } from '@victorradael/protospack';
+import { DecodeGrpcStruct } from 'protospack';
 import { PipelinesClientService } from 'src/clients/pipelines/client.service';
 import { IIdRequest, Info } from 'src/clients/pipelines/interfaces';
 import { objectCamelToSnake } from 'src/utils/CaseConverter';