UPDATE: Added S3 Input Creation

.github/workflows/deploy.yml

@@ -38,7 +38,6 @@ jobs:
         with:
           semantic_version: 16
           extra_plugins: |
-            @saithodev/semantic-release-backmerge
             conventional-changelog-eslint
           branches: |
             [

.releaserc.json

@@ -26,18 +26,6 @@
         "preset": "eslint"
       }
     ],
-    [
-      "@saithodev/semantic-release-backmerge",
-      {
-        "branches": [
-          { "from": "main", "to": "alpha" },
-          { "from": "main", "to": "beta" }
-        ],
-        "backmergeStrategy": "merge",
-        "clearWorkspace": true,
-        "restoreWorkspace": true
-      }
-    ],
     "@semantic-release/npm",
     "@semantic-release/github"
   ]

package.json

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

src/clients/auth/client.service.ts

@@ -162,11 +162,11 @@ export class AuthClientService implements OnModuleInit {
   async resendeConfirmationCode({
     username,
   }: AuthResendConfirmationCodeRequest): Promise<any> {
-    console.log('AuthClientService', 'resendeConfirmationCode');
+    console.log('AuthClientService', 'resendConfirmationCode');
 
     const authResendConfirmationCodeRequestReturn = await new Promise(
       (resolve, reject) => {
-        this.authService.resendeConfirmationCode({ username }).subscribe({
+        this.authService.resendConfirmationCode({ username }).subscribe({
           next(x) {
             resolve(x);
           },

src/clients/inputs/client.service.ts

@@ -1,6 +1,7 @@
 import { OnModuleInit, Inject } from '@nestjs/common';
 import { ClientGrpc } from '@nestjs/microservices';
 import {
+  InputCreateS3Request,
   InputNewCreateRequest,
   InputService,
   TestConnectionGetColumnsRequest,
@@ -50,6 +51,31 @@ export class InputsClientService implements OnModuleInit {
     return createInputResponse;
   }
 
+  async createS3Inputs(createInputDto: InputCreateS3Request) {
+    console.log('InputClientService', 'Create');
+
+    const createInputResponse = await new Promise((resolve, reject) => {
+      this.inputService.CreateS3(objectSnakeToCamel(createInputDto)).subscribe({
+        next(x) {
+          resolve(objectCamelToSnake(x));
+        },
+        error(err) {
+          console.log('Observable Error');
+          reject(err);
+        },
+        complete() {
+          console.log('done');
+        },
+      });
+    })
+      .then((res) => res)
+      .catch((err) => {
+        throw new Error(err);
+      });
+
+    return createInputResponse;
+  }
+
   async findOne(data: IIdRequest) {
     console.log('InputClientService', 'FindOne');
 

src/modules/inputs/inputs.service.ts

@@ -1,6 +1,5 @@
 import { Body, HttpException, HttpStatus, Injectable } from '@nestjs/common';
 import { Timeout } from '@nestjs/schedule';
-import { InputNewCreateRequest } from '@victorradael/protospack';
 import { InputsClientService } from 'src/clients/inputs/client.service';
 import { IIdRequest, Info } from 'src/clients/inputs/interfaces';
 
@@ -8,11 +7,19 @@ import { IIdRequest, Info } from 'src/clients/inputs/interfaces';
 export class InputsService {
   constructor(private inputClient: InputsClientService) {}
 
-  async create(@Body() data: InputNewCreateRequest) {
+  async create(@Body() data) {
     try {
-      const createInputResponse = await this.inputClient.create(data);
-
-      return createInputResponse;
+      if (
+        data.plugin == 'csv' ||
+        data.plugin == 'json' ||
+        data.plugin == 'parquet'
+      ) {
+        const createInputResponse = await this.inputClient.createS3Inputs(data);
+        return createInputResponse;
+      } else {
+        const createInputResponse = await this.inputClient.create(data);
+        return createInputResponse;
+      }
     } catch (err) {
       throw new HttpException(err.message, HttpStatus.NOT_FOUND);
     }