FIX: protospack version

Alpha -> Beta

.gitignore

@@ -29,7 +29,7 @@ lerna-debug.log*
 
 # IDE - VSCode
 .vscode/*
-!.vscode/settings.json
+#!.vscode/settings.json
 !.vscode/tasks.json
 !.vscode/launch.json
 !.vscode/extensions.json

package.json

@@ -31,7 +31,7 @@
     "@nestjs/platform-express": "^8.4.3",
     "@nestjs/schedule": "^1.1.0",
     "@nestjs/swagger": "^5.2.1",
-    "@victorradael/protospack": "^2.3.0",
+    "@victorradael/protospack": "2.3.0",
     "axios": "^0.25.0",
     "dotenv": "^14.2.0",
     "helmet": "^5.0.2",

src/clients/auth/client.config.ts

@@ -10,7 +10,9 @@ export class AuthClient {
       options: {
         url: process.env.DUC_URL,
         package: DucPackages,
-        credentials: credentials.createSsl(),
+        credentials: process.env.LOCAL_ENV
+          ? undefined
+          : credentials.createSsl(),
         protoPath: DucProtoFilePath,
         loader: {
           enums: String,

src/clients/inputs/client.config.ts

@@ -10,7 +10,9 @@ export class InputsClientConfiguration {
       options: {
         url: process.env.INFACTORY_URL,
         package: InputPackages,
-        credentials: credentials.createSsl(),
+        credentials: process.env.LOCAL_ENV
+          ? undefined
+          : credentials.createSsl(),
         protoPath: InputProtoFilePath,
         loader: {
           enums: String,

src/clients/outputs/client.config.ts

@@ -9,7 +9,9 @@ export class OutputsClientConfiguration {
       options: {
         url: process.env.OTFACTORY_URL,
         package: OutputPackages,
-        credentials: credentials.createSsl(),
+        credentials: process.env.LOCAL_ENV
+          ? undefined
+          : credentials.createSsl(),
         protoPath: OutputProtoFilePath,
         loader: {
           enums: String,

src/clients/pipelines/client.config.ts

@@ -12,7 +12,9 @@ export class PipelinesClientConfiguration {
       options: {
         url: process.env.PIFACTORY_URL,
         package: PipelinePackages,
-        credentials: credentials.createSsl(),
+        credentials: process.env.LOCAL_ENV
+          ? undefined
+          : credentials.createSsl(),
         protoPath: PipelineProtoFilePath,
         loader: {
           enums: String,

src/clients/pipelines/client.service.ts

@@ -61,7 +61,7 @@ export class PipelinesClientService implements OnModuleInit {
     const findAllPipelineResponse = await new Promise((resolve, reject) => {
       this.pipelineService.FindAll(objectSnakeToCamel(data)).subscribe({
         next(x) {
-          resolve(x);
+          resolve(x.pipelines);
         },
         error(err) {
           console.log('Observable Error');

src/modules/inputs/inputs.service.ts

@@ -14,7 +14,11 @@ export class InputsService {
         data.plugin == 'json' ||
         data.plugin == 'parquet'
       ) {
-        const createInputResponse = await this.inputClient.createS3Inputs(data);
+        const { info, ...input } = data;
+        const createInputResponse = await this.inputClient.createS3Inputs({
+          input,
+          info,
+        });
         return createInputResponse;
       } else {
         const createInputResponse = await this.inputClient.create(data);

src/modules/pipelines/pipelines.service.ts

@@ -8,7 +8,7 @@ export class PipelinesService {
   constructor(private pipelineClient: PipelinesClientService) {}
 
   adjustPayload(payload) {
-    payload.input = payload.input.input_s3 || payload.input.input_jdbc;
+    payload.input = payload.input?.input_s3 || payload.input?.input_jdbc;
   }
 
   async create(createPipelineDto) {
@@ -18,7 +18,7 @@ export class PipelinesService {
       );
 
       const pipeline = objectCamelToSnake(createPipelineResponse);
-      this.adjustPayload(pipeline);
+      this.adjustPayload(pipeline.pipeline);
 
       return pipeline;
     } catch (err) {
@@ -32,7 +32,7 @@ export class PipelinesService {
       const findOnePipelineResponse = await this.pipelineClient.findOne(data);
 
       const pipeline = objectCamelToSnake(findOnePipelineResponse);
-      this.adjustPayload(pipeline);
+      this.adjustPayload(pipeline.pipeline);
 
       return pipeline;
     } catch (err) {
@@ -48,7 +48,7 @@ export class PipelinesService {
       pipelines.forEach((pipeline) => {
         this.adjustPayload(pipeline);
       });
-      return pipelines;
+      return { pipelines };
     } catch (err) {
       throw new HttpException(err.message, HttpStatus.NOT_FOUND);
     }