FIX: CI

Beta

.github/workflows/deploy.yml

@@ -7,6 +7,22 @@ on:
       - main
 
 jobs:
+  extract_environment:
+    runs-on: ubuntu-latest
+    outputs:
+      environment: ${{ steps.extract_environment.outputs.environment }}
+    steps:
+      - name: Extract Environment
+        run: |
+          if [ ${GITHUB_REF} == "refs/heads/main" ]; then
+            echo "##[set-output name=environment;]$(echo "prd")"
+          elif [ ${GITHUB_REF} == "refs/heads/alpha" ]; then
+            echo "##[set-output name=environment;]$(echo "dev")"
+          elif [ ${GITHUB_REF} == "refs/heads/beta" ]; then
+            echo "##[set-output name=environment;]$(echo "stg")"
+          fi
+        id: extract_environment
+
   deploy:
     runs-on: self-hosted
     steps:
@@ -70,6 +86,7 @@ jobs:
       - name: Configure AWS Region
         if: steps.semantic.outputs.new_release_published == 'true'
         uses: aws-actions/configure-aws-credentials@v1
+        id: aws
         with:
           aws-region: us-east-1
 
@@ -78,9 +95,11 @@ jobs:
         shell: bash
         run: |
           if [ ${GITHUB_REF} == "refs/heads/main" ]; then
-            echo "##[set-output name=result;]$(echo "production")"
-          else
-            echo "##[set-output name=result;]$(echo ${GITHUB_REF#refs/heads/})"
+            echo "##[set-output name=result;]$(echo "prd")"
+          elif [ ${GITHUB_REF} == "refs/heads/alpha" ]; then
+            echo "##[set-output name=result;]$(echo "dev")"
+          elif [ ${GITHUB_REF} == "refs/heads/beta" ]; then
+            echo "##[set-output name=result;]$(echo "stg")"
           fi
         id: extract_environment
 
@@ -94,6 +113,7 @@ jobs:
         env:
           ENV: ${{ steps.extract_environment.outputs.result }}
           IMAGE_TAG: ${{ steps.semantic.outputs.new_release_version }}
+          ACCOUNT_ID: ${{ steps.aws.outputs.aws-account-id }}
           NPM_TOKEN: ${{ secrets.NPM_TOKEN }}
         run: |
           docker-compose -f build.docker-compose.yml build --build-arg NPM_TOKEN=${NPM_TOKEN}
@@ -104,9 +124,11 @@ jobs:
         env:
           ENV: ${{ steps.extract_environment.outputs.result }}
           IMAGE_TAG: ${{ steps.semantic.outputs.new_release_version }}
+          ACCOUNT_ID: ${{ steps.aws.outputs.aws-account-id }}
         run: |
           sed -i -e "s/\${ENV}/$ENV/g" docker-compose.yml
           sed -i -e "s/\${IMAGE_TAG}/$IMAGE_TAG/g" docker-compose.yml
+          sed -i -e "s/\${ACCOUNT_ID}/$ACCOUNT_ID/g" docker-compose.yml
           zip deploy.zip docker-compose.yml  -r .ebextensions
 
       - name: Deploy AWS Beanstalk

.github/workflows/test.yml

@@ -16,6 +16,7 @@ jobs:
       - name: Install Docker Compose
         run: |
           python3 -m pip install docker-compose --upgrade
+
       - name: Build
         env:
           ENV: test
@@ -24,13 +25,22 @@ jobs:
         run: |
           export ENV=test
           export IMAGE_TAG=test
+          export ACCOUNT_ID=test
           docker-compose -f build.docker-compose.yml build --build-arg NPM_TOKEN=${NPM_TOKEN}
+
       - name: Run Test
         env:
           ENV: test
           IMAGE_TAG: test
+          ACCOUNT_ID: test
           NPM_TOKEN: ${{ secrets.NPM_TOKEN }}
         run: |
           export ENV=test
           export IMAGE_TAG=test
-          docker-compose -f build.docker-compose.yml run -e NPM_TOKEN=${NPM_TOKEN} --rm --entrypoint="npm run test" maestro
+          docker-compose -f build.docker-compose.yml run -e NPM_TOKEN=${NPM_TOKEN} --rm --entrypoint="npm run test" maestro
+
+      - name: Remove Docker's Trash
+        continue-on-error: true
+        run: |
+          docker system prune
+          docker rmi -f $(docker images -aq)

.releaserc.json

@@ -33,7 +33,9 @@
           { "from": "main", "to": "alpha" },
           { "from": "main", "to": "beta" }
         ],
-        "backmergeStrategy": "merge"
+        "backmergeStrategy": "merge",
+        "clearWorkspace": true,
+        "restoreWorkspace": true
       }
     ],
     "@semantic-release/npm",

README.md

@@ -1,6 +1,4 @@
 <p align="center">
   <image src="./assets/maestro.svg" style="width:10rem">
   <h1 align="center">Maestro</h1>
-</p>
-
-x
+</p>

build.docker-compose.yml

@@ -2,4 +2,4 @@ version: "3.8"
 services:
   maestro:
     build: .
-    image: 468720548566.dkr.ecr.us-east-1.amazonaws.com/microservices/maestro_${ENV}:${IMAGE_TAG}
+    image: ${ACCOUNT_ID}.dkr.ecr.us-east-1.amazonaws.com/microservices/maestro_${ENV}:${IMAGE_TAG}

docker-compose.yml

@@ -1,7 +1,7 @@
 version: "3.8"
 services:
   maestro:
-    image: 468720548566.dkr.ecr.us-east-1.amazonaws.com/microservices/maestro_${ENV}:${IMAGE_TAG}
+    image: ${ACCOUNT_ID}.dkr.ecr.us-east-1.amazonaws.com/microservices/maestro_${ENV}:${IMAGE_TAG}
     container_name: maestro
     restart: always
     ports:

package-lock.json

@@ -14,9 +14,9 @@
       }
     },
     "@angular-devkit/core": {
-      "version": "13.2.6",
-      "resolved": "https://registry.npmjs.org/@angular-devkit/core/-/core-13.2.6.tgz",
-      "integrity": "sha512-8h2mWdBTN/dYwZuzKMg2IODlOWMdbJcpQG4XVrkk9ejCPP+3aX5Aa3glCe/voN6eBNiRfs8YDM0jxmpN2aWVtg==",
+      "version": "13.3.0",
+      "resolved": "https://registry.npmjs.org/@angular-devkit/core/-/core-13.3.0.tgz",
+      "integrity": "sha512-8YrreVbWlJVZnk5zs4vfkRItrPEtWhUcxWOBfYT/Kwu4FwJVAnNuhJAxxXOAQ2Ckd7cv30Idh/RFVLbTZ5Gs9w==",
       "dev": true,
       "requires": {
         "ajv": "8.9.0",
@@ -45,12 +45,12 @@
       }
     },
     "@angular-devkit/schematics": {
-      "version": "13.2.6",
-      "resolved": "https://registry.npmjs.org/@angular-devkit/schematics/-/schematics-13.2.6.tgz",
-      "integrity": "sha512-mPgSqdnZRuPSMeUA+T+mwVCrq2yhXpcYm1/Rjbhy09CyHs4wSrFv21WHCrE6shlvXpcmwr0n+I0DIeagAPmjUA==",
+      "version": "13.3.0",
+      "resolved": "https://registry.npmjs.org/@angular-devkit/schematics/-/schematics-13.3.0.tgz",
+      "integrity": "sha512-hq7tqnB3uVT/iDgqWWZ4kvnijeAcgd4cfLzZiCPaYn1nuhZf0tWsho6exhJ/odMZHvVp7w8OibqWiUKxNY9zHA==",
       "dev": true,
       "requires": {
-        "@angular-devkit/core": "13.2.6",
+        "@angular-devkit/core": "13.3.0",
         "jsonc-parser": "3.0.0",
         "magic-string": "0.25.7",
         "ora": "5.4.1",
@@ -75,13 +75,13 @@
       }
     },
     "@angular-devkit/schematics-cli": {
-      "version": "13.2.6",
-      "resolved": "https://registry.npmjs.org/@angular-devkit/schematics-cli/-/schematics-cli-13.2.6.tgz",
-      "integrity": "sha512-VdMLn4DoTswjk+1RL+pod8EwLkzh8pMT2OBJ9dhsITru1sr0/2nhsqRwZzZylAXjrFwdfPj1E/vfcAfSkmMGvw==",
+      "version": "13.3.0",
+      "resolved": "https://registry.npmjs.org/@angular-devkit/schematics-cli/-/schematics-cli-13.3.0.tgz",
+      "integrity": "sha512-DXT+k4228Ke1zCoU9QxPhXm1xzeYBs5aqgMWhyjXdkfDokJcjQM79CSVLHdKX/OLgR51qhnQ5qVFEHHhVV40EQ==",
       "dev": true,
       "requires": {
-        "@angular-devkit/core": "13.2.6",
-        "@angular-devkit/schematics": "13.2.6",
+        "@angular-devkit/core": "13.3.0",
+        "@angular-devkit/schematics": "13.3.0",
         "ansi-colors": "4.1.1",
         "inquirer": "8.2.0",
         "minimist": "1.2.5",
@@ -615,9 +615,9 @@
       }
     },
     "@grpc/grpc-js": {
-      "version": "1.5.8",
-      "resolved": "https://registry.npmjs.org/@grpc/grpc-js/-/grpc-js-1.5.8.tgz",
-      "integrity": "sha512-sfoF2yMVJcqEoX8E3o9+idUckv/w4cM+lt3U7Qz6GUBLgxAh1NS/3fEZKOMhwdvOEgWvPqbls/EgLXGKI0sm2A==",
+      "version": "1.5.10",
+      "resolved": "https://registry.npmjs.org/@grpc/grpc-js/-/grpc-js-1.5.10.tgz",
+      "integrity": "sha512-++oAubX/7rJzlqH0ShyzDENNNDHYrlttdc3NM40KlaVQDcgGqQknuPoavmyTC+oNUDyxPCX5dHceKhfcgN3tiw==",
       "requires": {
         "@grpc/proto-loader": "^0.6.4",
         "@types/node": ">=12.12.47"
@@ -1008,14 +1008,14 @@
       }
     },
     "@nestjs/cli": {
-      "version": "8.2.3",
-      "resolved": "https://registry.npmjs.org/@nestjs/cli/-/cli-8.2.3.tgz",
-      "integrity": "sha512-p//DACefn40VClXroxzS+2pkSdaXYvKKcr4bFOUBMTdJqT9he+U9ifcJUkg/h1bFU/Y8SS2cUsTyl0ZBHHHRcw==",
+      "version": "8.2.4",
+      "resolved": "https://registry.npmjs.org/@nestjs/cli/-/cli-8.2.4.tgz",
+      "integrity": "sha512-9zNV9oMtaz1vwLO3WXviD0wzRpyiaLWJZ7KCIZLk62U22RDNRsbtLLDS52Wkig5L8UU7Z1xRfrEv+s3f9keysQ==",
       "dev": true,
       "requires": {
-        "@angular-devkit/core": "13.2.6",
-        "@angular-devkit/schematics": "13.2.6",
-        "@angular-devkit/schematics-cli": "13.2.6",
+        "@angular-devkit/core": "13.3.0",
+        "@angular-devkit/schematics": "13.3.0",
+        "@angular-devkit/schematics-cli": "13.3.0",
         "@nestjs/schematics": "^8.0.3",
         "chalk": "3.0.0",
         "chokidar": "3.5.3",
@@ -1035,12 +1035,47 @@
         "typescript": "4.6.2",
         "webpack": "5.70.0",
         "webpack-node-externals": "3.0.0"
+      },
+      "dependencies": {
+        "json5": {
+          "version": "1.0.1",
+          "resolved": "https://registry.npmjs.org/json5/-/json5-1.0.1.tgz",
+          "integrity": "sha512-aKS4WQjPenRxiQsC93MNfjx+nbF4PAdYzmd/1JIj8HYzqfbu86beTuNgXDzPknWk0n0uARlyewZo4s++ES36Ow==",
+          "dev": true,
+          "requires": {
+            "minimist": "^1.2.0"
+          }
+        },
+        "strip-bom": {
+          "version": "3.0.0",
+          "resolved": "https://registry.npmjs.org/strip-bom/-/strip-bom-3.0.0.tgz",
+          "integrity": "sha1-IzTBjpx1n3vdVv3vfprj1YjmjtM=",
+          "dev": true
+        },
+        "tsconfig-paths": {
+          "version": "3.14.0",
+          "resolved": "https://registry.npmjs.org/tsconfig-paths/-/tsconfig-paths-3.14.0.tgz",
+          "integrity": "sha512-cg/1jAZoL57R39+wiw4u/SCC6Ic9Q5NqjBOb+9xISedOYurfog9ZNmKJSxAnb2m/5Bq4lE9lhUcau33Ml8DM0g==",
+          "dev": true,
+          "requires": {
+            "@types/json5": "^0.0.29",
+            "json5": "^1.0.1",
+            "minimist": "^1.2.0",
+            "strip-bom": "^3.0.0"
+          }
+        },
+        "typescript": {
+          "version": "4.6.2",
+          "resolved": "https://registry.npmjs.org/typescript/-/typescript-4.6.2.tgz",
+          "integrity": "sha512-HM/hFigTBHZhLXshn9sN37H085+hQGeJHJ/X7LpBWLID/fbc2acUMfU+lGD98X81sKP+pFa9f0DZmCwB9GnbAg==",
+          "dev": true
+        }
       }
     },
     "@nestjs/common": {
-      "version": "8.4.1",
-      "resolved": "https://registry.npmjs.org/@nestjs/common/-/common-8.4.1.tgz",
-      "integrity": "sha512-g6beLHvJ2cCIdlW8Uui8rQh3+oxLOBLzDIk3yWH4ocp2HEgOJwF0iUv/pk33tFuwbXESIGMK8K165cpZUjNoxA==",
+      "version": "8.4.3",
+      "resolved": "https://registry.npmjs.org/@nestjs/common/-/common-8.4.3.tgz",
+      "integrity": "sha512-QIhWykB7IPOwHQB/K9wMwmQKibQ5dhg9dt8ySOoD36uFFwN3RJQelzMFF9Rtu7hrMPk6pSyismEUKQ8BZMUD9w==",
       "requires": {
         "axios": "0.26.1",
         "iterare": "1.2.1",
@@ -1077,9 +1112,9 @@
       }
     },
     "@nestjs/core": {
-      "version": "8.4.1",
-      "resolved": "https://registry.npmjs.org/@nestjs/core/-/core-8.4.1.tgz",
-      "integrity": "sha512-JUV2cy/5z8MS2SRwszLmyOCclMMlyumxIbC1YFFlnSInhu7ODhrHLIMztyGmyAIuaehbOnyXPtHkjl01rHxc5w==",
+      "version": "8.4.3",
+      "resolved": "https://registry.npmjs.org/@nestjs/core/-/core-8.4.3.tgz",
+      "integrity": "sha512-1etUwTR5jTCTcNh6MW1tFYrHMCvcdIzJ3Z9O9ETR8EYIsphhzsxxRCa0dfb9peKJEQpl6SkoGOILIFkxfokOPw==",
       "requires": {
         "@nuxtjs/opencollective": "0.3.2",
         "fast-safe-stringify": "2.1.1",
@@ -1096,9 +1131,9 @@
       "integrity": "sha512-NFvofzSinp00j5rzUd4tf+xi9od6383iY0JP7o0Bnu1fuItAUkWBgc4EKuIQ3D+c2QI3i9pG1kDWAeY27EMGtg=="
     },
     "@nestjs/microservices": {
-      "version": "8.4.1",
-      "resolved": "https://registry.npmjs.org/@nestjs/microservices/-/microservices-8.4.1.tgz",
-      "integrity": "sha512-w5T4DZJQNPhN/d/pdAO6bO1YUpAgiPfNmKwflaFtuyJzJjak+naOctx+3bc1eatrsbP+JEj6oCBVBuDIWHfcOQ==",
+      "version": "8.4.3",
+      "resolved": "https://registry.npmjs.org/@nestjs/microservices/-/microservices-8.4.3.tgz",
+      "integrity": "sha512-/ZT5wo1s65J9Cqp2g5eNrYO34VH7/qUkDu4jJyZCT61I9UqpO49J3+1YIAHfmJJzHcrenjgt1sBtlFhwPR3Lgg==",
       "requires": {
         "iterare": "1.2.1",
         "json-socket": "0.3.0",
@@ -1106,9 +1141,9 @@
       }
     },
     "@nestjs/platform-express": {
-      "version": "8.4.1",
-      "resolved": "https://registry.npmjs.org/@nestjs/platform-express/-/platform-express-8.4.1.tgz",
-      "integrity": "sha512-c18zuhoegJsS1vZueGaNyvU8mLyFtS+6FJ2WAzDOXNpchpq0okrEPdKBifIisWuxgffQYKIufoK73vEfXSfDLg==",
+      "version": "8.4.3",
+      "resolved": "https://registry.npmjs.org/@nestjs/platform-express/-/platform-express-8.4.3.tgz",
+      "integrity": "sha512-MXXaShhWRChf7jKBrvRKjCFX84ii/4245TcB8Gei7UAGzDRHbM08lpLXDR+wUUUtC8rN2gWu8d8IGptAnqMGpA==",
       "requires": {
         "body-parser": "1.19.2",
         "cors": "2.8.5",
@@ -1175,9 +1210,9 @@
       }
     },
     "@nestjs/swagger": {
-      "version": "5.2.0",
-      "resolved": "https://registry.npmjs.org/@nestjs/swagger/-/swagger-5.2.0.tgz",
-      "integrity": "sha512-wcW2KCe7irwBw0WKsb03uFk4gnjqNcAcJxXGZxi6ljFiDgyLrQtx5MpE95o703tnn4V/hZR8MqMNFOXuup7Pqw==",
+      "version": "5.2.1",
+      "resolved": "https://registry.npmjs.org/@nestjs/swagger/-/swagger-5.2.1.tgz",
+      "integrity": "sha512-7dNa08WCnTsW/oAk3Ujde+z64JMfNm19DhpXasFR8oJp/9pggYAbYU927HpA+GJsSFJX6adjIRZsCKUqaGWznw==",
       "requires": {
         "@nestjs/mapped-types": "1.0.1",
         "lodash": "4.17.21",
@@ -1185,9 +1220,9 @@
       }
     },
     "@nestjs/testing": {
-      "version": "8.4.1",
-      "resolved": "https://registry.npmjs.org/@nestjs/testing/-/testing-8.4.1.tgz",
-      "integrity": "sha512-LOvsLuNh2eRwAtyeoIZWmUZ08wt7QrPrKQujWuRyv+vBYtC+FLHjqreWLpwG2yulNEoQs9Qlr2ubPvFGT1953g==",
+      "version": "8.4.3",
+      "resolved": "https://registry.npmjs.org/@nestjs/testing/-/testing-8.4.3.tgz",
+      "integrity": "sha512-6+b2UCObr5onv7TG398VUdkNeU9n+f+TeTvlzmZlp9LKIAS4ZxDxwpdLDl5m/AssdkaZpfb0u755BJfKP5wbNw==",
       "dev": true,
       "requires": {
         "optional": "0.1.4",
@@ -1604,9 +1639,9 @@
       }
     },
     "@types/supertest": {
-      "version": "2.0.11",
-      "resolved": "https://registry.npmjs.org/@types/supertest/-/supertest-2.0.11.tgz",
-      "integrity": "sha512-uci4Esokrw9qGb9bvhhSVEjd6rkny/dk5PK/Qz4yxKiyppEI+dOPlNrZBahE3i+PoKFYyDxChVXZ/ysS/nrm1Q==",
+      "version": "2.0.12",
+      "resolved": "https://registry.npmjs.org/@types/supertest/-/supertest-2.0.12.tgz",
+      "integrity": "sha512-X3HPWTwXRerBZS7Mo1k6vMVR1Z6zmJcDVn5O/31whe0tnjE4te6ZJSJGq1RiqHPjzPdMTfjCFogDJmwng9xHaQ==",
       "dev": true,
       "requires": {
         "@types/superagent": "*"
@@ -1628,14 +1663,14 @@
       "dev": true
     },
     "@typescript-eslint/eslint-plugin": {
-      "version": "5.15.0",
-      "resolved": "https://registry.npmjs.org/@typescript-eslint/eslint-plugin/-/eslint-plugin-5.15.0.tgz",
-      "integrity": "sha512-u6Db5JfF0Esn3tiAKELvoU5TpXVSkOpZ78cEGn/wXtT2RVqs2vkt4ge6N8cRCyw7YVKhmmLDbwI2pg92mlv7cA==",
+      "version": "5.17.0",
+      "resolved": "https://registry.npmjs.org/@typescript-eslint/eslint-plugin/-/eslint-plugin-5.17.0.tgz",
+      "integrity": "sha512-qVstvQilEd89HJk3qcbKt/zZrfBZ+9h2ynpAGlWjWiizA7m/MtLT9RoX6gjtpE500vfIg8jogAkDzdCxbsFASQ==",
       "dev": true,
       "requires": {
-        "@typescript-eslint/scope-manager": "5.15.0",
-        "@typescript-eslint/type-utils": "5.15.0",
-        "@typescript-eslint/utils": "5.15.0",
+        "@typescript-eslint/scope-manager": "5.17.0",
+        "@typescript-eslint/type-utils": "5.17.0",
+        "@typescript-eslint/utils": "5.17.0",
         "debug": "^4.3.2",
         "functional-red-black-tree": "^1.0.1",
         "ignore": "^5.1.8",
@@ -1645,52 +1680,52 @@
       }
     },
     "@typescript-eslint/parser": {
-      "version": "5.15.0",
-      "resolved": "https://registry.npmjs.org/@typescript-eslint/parser/-/parser-5.15.0.tgz",
-      "integrity": "sha512-NGAYP/+RDM2sVfmKiKOCgJYPstAO40vPAgACoWPO/+yoYKSgAXIFaBKsV8P0Cc7fwKgvj27SjRNX4L7f4/jCKQ==",
+      "version": "5.17.0",
+      "resolved": "https://registry.npmjs.org/@typescript-eslint/parser/-/parser-5.17.0.tgz",
+      "integrity": "sha512-aRzW9Jg5Rlj2t2/crzhA2f23SIYFlF9mchGudyP0uiD6SenIxzKoLjwzHbafgHn39dNV/TV7xwQkLfFTZlJ4ig==",
       "dev": true,
       "requires": {
-        "@typescript-eslint/scope-manager": "5.15.0",
-        "@typescript-eslint/types": "5.15.0",
-        "@typescript-eslint/typescript-estree": "5.15.0",
+        "@typescript-eslint/scope-manager": "5.17.0",
+        "@typescript-eslint/types": "5.17.0",
+        "@typescript-eslint/typescript-estree": "5.17.0",
         "debug": "^4.3.2"
       }
     },
     "@typescript-eslint/scope-manager": {
-      "version": "5.15.0",
-      "resolved": "https://registry.npmjs.org/@typescript-eslint/scope-manager/-/scope-manager-5.15.0.tgz",
-      "integrity": "sha512-EFiZcSKrHh4kWk0pZaa+YNJosvKE50EnmN4IfgjkA3bTHElPtYcd2U37QQkNTqwMCS7LXeDeZzEqnsOH8chjSg==",
+      "version": "5.17.0",
+      "resolved": "https://registry.npmjs.org/@typescript-eslint/scope-manager/-/scope-manager-5.17.0.tgz",
+      "integrity": "sha512-062iCYQF/doQ9T2WWfJohQKKN1zmmXVfAcS3xaiialiw8ZUGy05Em6QVNYJGO34/sU1a7a+90U3dUNfqUDHr3w==",
       "dev": true,
       "requires": {
-        "@typescript-eslint/types": "5.15.0",
-        "@typescript-eslint/visitor-keys": "5.15.0"
+        "@typescript-eslint/types": "5.17.0",
+        "@typescript-eslint/visitor-keys": "5.17.0"
       }
     },
     "@typescript-eslint/type-utils": {
-      "version": "5.15.0",
-      "resolved": "https://registry.npmjs.org/@typescript-eslint/type-utils/-/type-utils-5.15.0.tgz",
-      "integrity": "sha512-KGeDoEQ7gHieLydujGEFLyLofipe9PIzfvA/41urz4hv+xVxPEbmMQonKSynZ0Ks2xDhJQ4VYjB3DnRiywvKDA==",
+      "version": "5.17.0",
+      "resolved": "https://registry.npmjs.org/@typescript-eslint/type-utils/-/type-utils-5.17.0.tgz",
+      "integrity": "sha512-3hU0RynUIlEuqMJA7dragb0/75gZmwNwFf/QJokWzPehTZousP/MNifVSgjxNcDCkM5HI2K22TjQWUmmHUINSg==",
       "dev": true,
       "requires": {
-        "@typescript-eslint/utils": "5.15.0",
+        "@typescript-eslint/utils": "5.17.0",
         "debug": "^4.3.2",
         "tsutils": "^3.21.0"
       }
     },
     "@typescript-eslint/types": {
-      "version": "5.15.0",
-      "resolved": "https://registry.npmjs.org/@typescript-eslint/types/-/types-5.15.0.tgz",
-      "integrity": "sha512-yEiTN4MDy23vvsIksrShjNwQl2vl6kJeG9YkVJXjXZnkJElzVK8nfPsWKYxcsGWG8GhurYXP4/KGj3aZAxbeOA==",
+      "version": "5.17.0",
+      "resolved": "https://registry.npmjs.org/@typescript-eslint/types/-/types-5.17.0.tgz",
+      "integrity": "sha512-AgQ4rWzmCxOZLioFEjlzOI3Ch8giDWx8aUDxyNw9iOeCvD3GEYAB7dxWGQy4T/rPVe8iPmu73jPHuaSqcjKvxw==",
       "dev": true
     },
     "@typescript-eslint/typescript-estree": {
-      "version": "5.15.0",
-      "resolved": "https://registry.npmjs.org/@typescript-eslint/typescript-estree/-/typescript-estree-5.15.0.tgz",
-      "integrity": "sha512-Hb0e3dGc35b75xLzixM3cSbG1sSbrTBQDfIScqdyvrfJZVEi4XWAT+UL/HMxEdrJNB8Yk28SKxPLtAhfCbBInA==",
+      "version": "5.17.0",
+      "resolved": "https://registry.npmjs.org/@typescript-eslint/typescript-estree/-/typescript-estree-5.17.0.tgz",
+      "integrity": "sha512-X1gtjEcmM7Je+qJRhq7ZAAaNXYhTgqMkR10euC4Si6PIjb+kwEQHSxGazXUQXFyqfEXdkGf6JijUu5R0uceQzg==",
       "dev": true,
       "requires": {
-        "@typescript-eslint/types": "5.15.0",
-        "@typescript-eslint/visitor-keys": "5.15.0",
+        "@typescript-eslint/types": "5.17.0",
+        "@typescript-eslint/visitor-keys": "5.17.0",
         "debug": "^4.3.2",
         "globby": "^11.0.4",
         "is-glob": "^4.0.3",
@@ -1699,33 +1734,33 @@
       }
     },
     "@typescript-eslint/utils": {
-      "version": "5.15.0",
-      "resolved": "https://registry.npmjs.org/@typescript-eslint/utils/-/utils-5.15.0.tgz",
-      "integrity": "sha512-081rWu2IPKOgTOhHUk/QfxuFog8m4wxW43sXNOMSCdh578tGJ1PAaWPsj42LOa7pguh173tNlMigsbrHvh/mtA==",
+      "version": "5.17.0",
+      "resolved": "https://registry.npmjs.org/@typescript-eslint/utils/-/utils-5.17.0.tgz",
+      "integrity": "sha512-DVvndq1QoxQH+hFv+MUQHrrWZ7gQ5KcJzyjhzcqB1Y2Xes1UQQkTRPUfRpqhS8mhTWsSb2+iyvDW1Lef5DD7vA==",
       "dev": true,
       "requires": {
         "@types/json-schema": "^7.0.9",
-        "@typescript-eslint/scope-manager": "5.15.0",
-        "@typescript-eslint/types": "5.15.0",
-        "@typescript-eslint/typescript-estree": "5.15.0",
+        "@typescript-eslint/scope-manager": "5.17.0",
+        "@typescript-eslint/types": "5.17.0",
+        "@typescript-eslint/typescript-estree": "5.17.0",
         "eslint-scope": "^5.1.1",
         "eslint-utils": "^3.0.0"
       }
     },
     "@typescript-eslint/visitor-keys": {
-      "version": "5.15.0",
-      "resolved": "https://registry.npmjs.org/@typescript-eslint/visitor-keys/-/visitor-keys-5.15.0.tgz",
-      "integrity": "sha512-+vX5FKtgvyHbmIJdxMJ2jKm9z2BIlXJiuewI8dsDYMp5LzPUcuTT78Ya5iwvQg3VqSVdmxyM8Anj1Jeq7733ZQ==",
+      "version": "5.17.0",
+      "resolved": "https://registry.npmjs.org/@typescript-eslint/visitor-keys/-/visitor-keys-5.17.0.tgz",
+      "integrity": "sha512-6K/zlc4OfCagUu7Am/BD5k8PSWQOgh34Nrv9Rxe2tBzlJ7uOeJ/h7ugCGDCeEZHT6k2CJBhbk9IsbkPI0uvUkA==",
       "dev": true,
       "requires": {
-        "@typescript-eslint/types": "5.15.0",
+        "@typescript-eslint/types": "5.17.0",
         "eslint-visitor-keys": "^3.0.0"
       }
     },
     "@victorradael/protospack": {
-      "version": "1.3.1",
-      "resolved": "https://registry.npmjs.org/@victorradael/protospack/-/protospack-1.3.1.tgz",
-      "integrity": "sha512-upx7LfkoWZ+by2FoymE0g/zJwNj0C1H53BMSrSc+vGHzsc4W57h547KcSvYSphVhKfsr/g53tPFmVRcnvkhWtQ==",
+      "version": "1.3.9",
+      "resolved": "https://registry.npmjs.org/@victorradael/protospack/-/protospack-1.3.9.tgz",
+      "integrity": "sha512-UDhTCw7UY1MjFTYB739zj2fzXnk9bR9K+703dTwetAk+tOkIOr+28C4QctZ8R+wve1dESkki7j76rlEM2qmAuA==",
       "requires": {
         "rxjs": "^7.5.5"
       }
@@ -3124,9 +3159,9 @@
       }
     },
     "eslint": {
-      "version": "8.11.0",
-      "resolved": "https://registry.npmjs.org/eslint/-/eslint-8.11.0.tgz",
-      "integrity": "sha512-/KRpd9mIRg2raGxHRGwW9ZywYNAClZrHjdueHcrVDuO3a6bj83eoTirCCk0M0yPwOjWYKHwRVRid+xK4F/GHgA==",
+      "version": "8.12.0",
+      "resolved": "https://registry.npmjs.org/eslint/-/eslint-8.12.0.tgz",
+      "integrity": "sha512-it1oBL9alZg1S8UycLm5YDMAkIhtH6FtAzuZs6YvoGVldWjbS08BkAdb/ymP9LlAyq8koANu32U7Ib/w+UNh8Q==",
       "dev": true,
       "requires": {
         "@eslint/eslintrc": "^1.2.1",
@@ -5847,9 +5882,9 @@
       "dev": true
     },
     "prettier": {
-      "version": "2.5.1",
-      "resolved": "https://registry.npmjs.org/prettier/-/prettier-2.5.1.tgz",
-      "integrity": "sha512-vBZcPRUR5MZJwoyi3ZoyQlc1rXeEck8KgeC9AwwOn+exuxLxq5toTRDTSaVrXHxelDMHy9zlicw8u66yxoSUFg==",
+      "version": "2.6.1",
+      "resolved": "https://registry.npmjs.org/prettier/-/prettier-2.6.1.tgz",
+      "integrity": "sha512-8UVbTBYGwN37Bs9LERmxCPjdvPxlEowx2urIL6urHzdb3SDq4B/Z6xLFCblrSnE4iKWcS6ziJ3aOYrc1kz/E2A==",
       "dev": true
     },
     "prettier-linter-helpers": {
@@ -6742,9 +6777,9 @@
       "dev": true
     },
     "ts-jest": {
-      "version": "27.1.3",
-      "resolved": "https://registry.npmjs.org/ts-jest/-/ts-jest-27.1.3.tgz",
-      "integrity": "sha512-6Nlura7s6uM9BVUAoqLH7JHyMXjz8gluryjpPXxr3IxZdAXnU6FhjvVLHFtfd1vsE1p8zD1OJfskkc0jhTSnkA==",
+      "version": "27.1.4",
+      "resolved": "https://registry.npmjs.org/ts-jest/-/ts-jest-27.1.4.tgz",
+      "integrity": "sha512-qjkZlVPWVctAezwsOD1OPzbZ+k7zA5z3oxII4dGdZo5ggX/PL7kvwTM0pXTr10fAtbiVpJaL3bWd502zAhpgSQ==",
       "dev": true,
       "requires": {
         "bs-logger": "0.x",
@@ -6811,14 +6846,14 @@
       }
     },
     "tsconfig-paths": {
-      "version": "3.14.0",
-      "resolved": "https://registry.npmjs.org/tsconfig-paths/-/tsconfig-paths-3.14.0.tgz",
-      "integrity": "sha512-cg/1jAZoL57R39+wiw4u/SCC6Ic9Q5NqjBOb+9xISedOYurfog9ZNmKJSxAnb2m/5Bq4lE9lhUcau33Ml8DM0g==",
+      "version": "3.14.1",
+      "resolved": "https://registry.npmjs.org/tsconfig-paths/-/tsconfig-paths-3.14.1.tgz",
+      "integrity": "sha512-fxDhWnFSLt3VuTwtvJt5fpwxBHg5AdKWMsgcPOOIilyjymcYVZoCQF8fvFRezCNfblEXmi+PcM1eYHeOAgXCOQ==",
       "dev": true,
       "requires": {
         "@types/json5": "^0.0.29",
         "json5": "^1.0.1",
-        "minimist": "^1.2.0",
+        "minimist": "^1.2.6",
         "strip-bom": "^3.0.0"
       },
       "dependencies": {
@@ -6935,9 +6970,9 @@
       }
     },
     "typescript": {
-      "version": "4.6.2",
-      "resolved": "https://registry.npmjs.org/typescript/-/typescript-4.6.2.tgz",
-      "integrity": "sha512-HM/hFigTBHZhLXshn9sN37H085+hQGeJHJ/X7LpBWLID/fbc2acUMfU+lGD98X81sKP+pFa9f0DZmCwB9GnbAg==",
+      "version": "4.6.3",
+      "resolved": "https://registry.npmjs.org/typescript/-/typescript-4.6.3.tgz",
+      "integrity": "sha512-yNIatDa5iaofVozS/uQJEl3JRWLKKGJKh6Yaiv0GLGSuhpFJe7P3SbHZ8/yjAHRQwKRoA6YZqlfjXWmVzoVSMw==",
       "dev": true
     },
     "universalify": {

package.json

@@ -21,16 +21,16 @@
     "test:e2e": "jest --config ./test/jest-e2e.json"
   },
   "dependencies": {
-    "@grpc/grpc-js": "^1.5.7",
+    "@grpc/grpc-js": "^1.5.10",
     "@grpc/proto-loader": "^0.6.9",
-    "@nestjs/common": "^8.4.0",
+    "@nestjs/common": "^8.4.3",
     "@nestjs/config": "^1.2.1",
-    "@nestjs/core": "^8.4.0",
+    "@nestjs/core": "^8.4.3",
     "@nestjs/mapped-types": "*",
-    "@nestjs/microservices": "^8.4.0",
-    "@nestjs/platform-express": "^8.4.0",
-    "@nestjs/swagger": "^5.1.5",
-    "@victorradael/protospack": "^1.3.1",
+    "@nestjs/microservices": "^8.4.3",
+    "@nestjs/platform-express": "^8.4.3",
+    "@nestjs/swagger": "^5.2.1",
+    "@victorradael/protospack": "^1.3.9",
     "axios": "^0.25.0",
     "dotenv": "^14.2.0",
     "grpc": "^1.24.11",
@@ -42,29 +42,29 @@
     "swagger-ui-express": "^4.3.0"
   },
   "devDependencies": {
-    "@nestjs/cli": "^8.2.2",
+    "@nestjs/cli": "^8.2.4",
     "@nestjs/schematics": "^8.0.8",
-    "@nestjs/testing": "^8.4.0",
+    "@nestjs/testing": "^8.4.3",
     "@types/express": "^4.17.13",
     "@types/jest": "27.0.2",
     "@types/jsonwebtoken": "^8.5.8",
     "@types/jwk-to-pem": "^2.0.1",
     "@types/node": "^16.11.26",
-    "@types/supertest": "^2.0.11",
-    "@typescript-eslint/eslint-plugin": "^5.14.0",
-    "@typescript-eslint/parser": "^5.14.0",
-    "eslint": "^8.10.0",
+    "@types/supertest": "^2.0.12",
+    "@typescript-eslint/eslint-plugin": "^5.17.0",
+    "@typescript-eslint/parser": "^5.17.0",
+    "eslint": "^8.12.0",
     "eslint-config-prettier": "^8.5.0",
     "eslint-plugin-prettier": "^4.0.0",
     "jest": "^27.5.1",
-    "prettier": "^2.3.2",
+    "prettier": "^2.6.1",
     "source-map-support": "^0.5.20",
     "supertest": "^6.1.3",
-    "ts-jest": "^27.0.3",
+    "ts-jest": "^27.1.4",
     "ts-loader": "^9.2.7",
     "ts-node": "^10.7.0",
-    "tsconfig-paths": "^3.13.0",
-    "typescript": "^4.6.2"
+    "tsconfig-paths": "^3.14.1",
+    "typescript": "^4.6.3"
   },
   "jest": {
     "moduleFileExtensions": [

src/clients/inputs/client.service.ts

@@ -1,7 +1,16 @@
 import { OnModuleInit, Inject } from '@nestjs/common';
 import { ClientGrpc } from '@nestjs/microservices';
 import { InputService } from '@victorradael/protospack';
-import { IIdRequest, ITestConnectionRequest } from './interfaces';
+import {
+  objectCamelToSnake,
+  objectSnakeToCamel,
+} from 'src/utils/CaseConverter';
+import {
+  ICreateInputRequest,
+  IIdRequest,
+  ITestConnectionRequest,
+  UpdateInputRequest,
+} from './interfaces';
 
 export class InputsClientService implements OnModuleInit {
   private inputService: InputService;
@@ -14,13 +23,13 @@ export class InputsClientService implements OnModuleInit {
       this.grpcClient.getService<InputService>('InputService');
   }
 
-  async create(createInputDto) {
+  async create(createInputDto: ICreateInputRequest) {
     console.log('InputClientService', 'Create');
 
     const createInputResponse = await new Promise((resolve, reject) => {
-      this.inputService.Create(createInputDto).subscribe({
+      this.inputService.Create(objectSnakeToCamel(createInputDto)).subscribe({
         next(x) {
-          resolve(x);
+          resolve(objectCamelToSnake(x));
         },
         error(err) {
           console.log('Observable Error');
@@ -42,12 +51,10 @@ export class InputsClientService implements OnModuleInit {
   async findOne(data: IIdRequest) {
     console.log('InputClientService', 'FindOne');
 
-    const { id } = data;
-
     const findOneInputResponse = await new Promise((resolve, reject) => {
-      this.inputService.FindOne({ id }).subscribe({
+      this.inputService.FindOne(objectSnakeToCamel(data)).subscribe({
         next(x) {
-          resolve(x);
+          resolve(objectCamelToSnake(x));
         },
         error(err) {
           console.log('Observable Error');
@@ -66,13 +73,13 @@ export class InputsClientService implements OnModuleInit {
     return findOneInputResponse;
   }
 
-  async findAll({}) {
+  async findAll(data) {
     console.log('InputClientService', 'FindAll');
 
     const findAllInputResponse = await new Promise((resolve, reject) => {
-      this.inputService.FindAll({}).subscribe({
+      this.inputService.FindAll(objectSnakeToCamel(data)).subscribe({
         next(x) {
-          resolve(x);
+          resolve(objectCamelToSnake(x));
         },
         error(err) {
           console.log('Observable Error');
@@ -91,12 +98,12 @@ export class InputsClientService implements OnModuleInit {
     return findAllInputResponse;
   }
 
-  async update(updateInputDTO) {
+  async update(updateInputDTO: UpdateInputRequest) {
     console.log('InputClientService', 'Update');
     const updateInputResponse = await new Promise((resolve, reject) => {
-      this.inputService.Update(updateInputDTO).subscribe({
+      this.inputService.Update(objectSnakeToCamel(updateInputDTO)).subscribe({
         next(x) {
-          resolve(x);
+          resolve(objectCamelToSnake(x));
         },
         error(err) {
           console.log('Observable Error');
@@ -119,9 +126,9 @@ export class InputsClientService implements OnModuleInit {
     console.log('InputClientService', 'Remove');
 
     const removeInputResponse = await new Promise((resolve, reject) => {
-      this.inputService.Remove(idRequest).subscribe({
+      this.inputService.Remove(objectSnakeToCamel(idRequest)).subscribe({
         next(x) {
-          resolve(x);
+          resolve(objectCamelToSnake(x));
         },
         error(err) {
           console.log('Observable Error');
@@ -141,12 +148,11 @@ export class InputsClientService implements OnModuleInit {
   }
 
   async testConnection(data: ITestConnectionRequest) {
-    console.log('InputClientService', 'TestCOnnection');
-
+    console.log('InputClientService', 'TestConnection');
     const testConnectionResponse = await new Promise((resolve, reject) => {
-      this.inputService.TestConnection(data).subscribe({
+      this.inputService.TestConnection(objectSnakeToCamel(data)).subscribe({
         next(x) {
-          resolve(x);
+          resolve(objectCamelToSnake(x));
         },
         error(err) {
           console.log('Observable Error');

src/clients/inputs/interfaces.d.ts

@@ -28,24 +28,32 @@ interface Cron {
   week_days_resourse_value: number;
 }
 
+export interface Info {
+  costumer_id: string;
+  user_id: string;
+}
+
 export interface ICreateInputRequest {
   cron: string;
   name: string;
   plugin: string;
   values: Values;
   operation: string;
+  info: Info;
 }
 export interface IIdRequest {
   id: string;
+  info: Info;
 }
 
-interface UpdateInputRequest {
+export interface UpdateInputRequest {
   id: string;
   cron: string;
   name: string;
   plugin: string;
   values: Values;
   operation: string;
+  info: Info;
 }
 
 export interface ITestConnectionRequest {

src/clients/outputs/client.config.ts

@@ -19,4 +19,4 @@ export class OutputsClientConfiguration {
       },
     };
   }
-};
+}

src/clients/outputs/client.service.ts

@@ -1,7 +1,10 @@
 import { Controller, Inject, OnModuleInit } from '@nestjs/common';
 import { ClientGrpc, Payload } from '@nestjs/microservices';
 import { OutputsServiceInterface } from '@victorradael/protospack';
-import { objectCamelToSnake } from 'src/utils/CaseConverter';
+import {
+  objectCamelToSnake,
+  objectSnakeToCamel,
+} from 'src/utils/CaseConverter';
 import {
   ICreateOutputRequest,
   IIdRequest,
@@ -24,7 +27,7 @@ export class OutputsClientService implements OnModuleInit {
     console.log('OutputClientService', 'Create');
 
     const createOutputResponse = await new Promise((resolve, reject) => {
-      this.outputService.Create(createOutputDto).subscribe({
+      this.outputService.Create(objectSnakeToCamel(createOutputDto)).subscribe({
         next(x) {
           resolve(x);
         },
@@ -47,11 +50,11 @@ export class OutputsClientService implements OnModuleInit {
     return createOutputResponse;
   }
 
-  async findAll() {
+  async findAll(data) {
     console.log('OutputClientService', 'FindAll');
 
     const findAllOutputResponse = await new Promise((resolve, reject) => {
-      this.outputService.FindAll({}).subscribe({
+      this.outputService.FindAll(objectSnakeToCamel(data)).subscribe({
         next(x) {
           resolve(x);
         },
@@ -76,11 +79,11 @@ export class OutputsClientService implements OnModuleInit {
     return { outputs: convertedOutputs };
   }
 
-  async findOne({ id }: IIdRequest) {
+  async findOne(data: IIdRequest) {
     console.log('OutputClientService', 'FindOne');
 
     const findOneOutputResponse = await new Promise((resolve, reject) => {
-      this.outputService.FindOne({ id }).subscribe({
+      this.outputService.FindOne(objectSnakeToCamel(data)).subscribe({
         next(x) {
           resolve(x);
         },
@@ -105,7 +108,7 @@ export class OutputsClientService implements OnModuleInit {
     console.log('OutputClientService', 'Update');
 
     const updateOutputResponse = await new Promise((resolve, reject) => {
-      this.outputService.Update(updateOutPutDTO).subscribe({
+      this.outputService.Update(objectSnakeToCamel(updateOutPutDTO)).subscribe({
         next(x) {
           resolve(x);
         },
@@ -126,13 +129,13 @@ export class OutputsClientService implements OnModuleInit {
     return objectCamelToSnake(updateOutputResponse);
   }
 
-  async remove({ id }: IIdRequest) {
+  async remove(data: IIdRequest) {
     console.log('OutputClientService', 'Remove');
 
     const removeOutputResponse = await new Promise((resolve, reject) => {
-      this.outputService.Remove({ id }).subscribe({
+      this.outputService.Remove(objectSnakeToCamel(data)).subscribe({
         next(x) {
-          resolve(x);
+          resolve(objectCamelToSnake(x));
         },
         error(err) {
           console.log('Observable Error');

src/clients/outputs/interfaces.d.ts

@@ -9,8 +9,14 @@ export interface Values {
   prefix: string;
 }
 
+interface Info {
+  user_id: string;
+  customer_id: string;
+}
+
 export interface IIdRequest {
   id: string;
+  info: Info;
 }
 
 export interface IOutputUpdateRequest {
@@ -19,4 +25,5 @@ export interface IOutputUpdateRequest {
   values: Values;
   plugin: string;
   name: string;
+  info: Info;
 }

src/clients/pipelines/client.service.ts

@@ -1,10 +1,15 @@
 import { Inject, OnModuleInit } from '@nestjs/common';
 import { ClientGrpc, Payload } from '@nestjs/microservices';
 import { PipelinesServiceInterface } from '@victorradael/protospack';
+import {
+  objectCamelToSnake,
+  objectSnakeToCamel,
+} from 'src/utils/CaseConverter';
 import {
   ICreatePipelineDto,
   IdRequest,
   IGetPipelineLogsRequest,
+  IIdRequest,
   IUpdatePipelineRequest,
 } from './interfaces';
 
@@ -23,18 +28,20 @@ export class PipelinesClientService implements OnModuleInit {
     console.log('PipelinesClientService', 'Create');
 
     const createPipelineResponse = await new Promise((resolve, reject) => {
-      this.pipelineService.create(createPipelineDto).subscribe({
-        next(x) {
-          resolve(x);
-        },
-        error(err) {
-          console.log('Observable Error');
-          reject(err);
-        },
-        complete() {
-          console.log('done');
-        },
-      });
+      this.pipelineService
+        .create(objectSnakeToCamel(createPipelineDto))
+        .subscribe({
+          next(x) {
+            resolve(x);
+          },
+          error(err) {
+            console.log('Observable Error');
+            reject(err);
+          },
+          complete() {
+            console.log('done');
+          },
+        });
     })
       .then((res) => res)
       .catch((err) => {
@@ -44,11 +51,11 @@ export class PipelinesClientService implements OnModuleInit {
     return createPipelineResponse;
   }
 
-  async findAll() {
+  async findAll(data: IIdRequest) {
     console.log('PipelinesClientService', 'FindAll');
 
     const findAllPipelineResponse = await new Promise((resolve, reject) => {
-      this.pipelineService.findAll({}).subscribe({
+      this.pipelineService.findAll(objectSnakeToCamel(data)).subscribe({
         next(x) {
           resolve(x);
         },
@@ -69,11 +76,11 @@ export class PipelinesClientService implements OnModuleInit {
     return findAllPipelineResponse;
   }
 
-  async findOne({ id }: IdRequest) {
+  async findOne(data: IIdRequest) {
     console.log('PipelinesClientService', 'FindOne');
 
     const findOnePipelineResponse = await new Promise((resolve, reject) => {
-      this.pipelineService.findOne({ id }).subscribe({
+      this.pipelineService.findOne(objectSnakeToCamel(data)).subscribe({
         next(x) {
           resolve(x);
         },
@@ -98,18 +105,20 @@ export class PipelinesClientService implements OnModuleInit {
     console.log('PipelinesClientService', 'Update');
 
     const updatePipelineResponse = await new Promise((resolve, reject) => {
-      this.pipelineService.update(UpdatePipelineRequest).subscribe({
-        next(x) {
-          resolve(x);
-        },
-        error(err) {
-          console.log('Observable Error');
-          reject(err);
-        },
-        complete() {
-          console.log('done');
-        },
-      });
+      this.pipelineService
+        .update(objectSnakeToCamel(UpdatePipelineRequest))
+        .subscribe({
+          next(x) {
+            resolve(x);
+          },
+          error(err) {
+            console.log('Observable Error');
+            reject(err);
+          },
+          complete() {
+            console.log('done');
+          },
+        });
     })
       .then((res) => res)
       .catch((err) => {
@@ -119,13 +128,13 @@ export class PipelinesClientService implements OnModuleInit {
     return updatePipelineResponse;
   }
 
-  async remove({ id }: IdRequest) {
+  async remove(data: IIdRequest) {
     console.log('PipelinesClientService', 'Remove');
 
     const removePipelineResponse = await new Promise((resolve, reject) => {
-      this.pipelineService.remove({ id }).subscribe({
+      this.pipelineService.remove(objectSnakeToCamel(data)).subscribe({
         next(x) {
-          resolve(x);
+          resolve(objectCamelToSnake(x));
         },
         error(err) {
           console.log('Observable Error');

src/clients/pipelines/interfaces.d.ts

@@ -5,12 +5,23 @@ export interface ICreatePipelineDto {
   tags: string[];
   name: string;
   description: string;
+  info: Info;
+}
+
+export interface Info {
+  customer_id: sting;
+  user_id: string;
 }
 
 export interface IdRequest {
   id: string;
 }
 
+export interface IIdRequest {
+  id: string;
+  info: Info;
+}
+
 export interface IUpdatePipelineRequest {
   input: IdRequest;
   transformations: IdRequest[];
@@ -19,6 +30,7 @@ export interface IUpdatePipelineRequest {
   name: string;
   description: string;
   id: string;
+  info: Info;
 }
 
 export interface IGetPipelineLogsRequest {

src/clients/transformations/client.service.ts

@@ -1,8 +1,11 @@
 import { Controller, Inject, OnModuleInit, Post } from '@nestjs/common';
 import { ClientGrpc } from '@nestjs/microservices';
 import { TransformationsServiceInterface } from '@victorradael/protospack';
-import { objectCamelToSnake } from 'src/utils/CaseConverter';
-import { ICreateTransformationsRequest, IdRequest } from './interfaces';
+import {
+  objectCamelToSnake,
+  objectSnakeToCamel,
+} from 'src/utils/CaseConverter';
+import { ICreateTransformationsRequest, IIdRequest } from './interfaces';
 
 @Controller('transformation')
 export class TransformationsClientService implements OnModuleInit {
@@ -24,18 +27,20 @@ export class TransformationsClientService implements OnModuleInit {
 
     const createTransformationResponse = await new Promise(
       (resolve, reject) => {
-        this.transformationService.create(createTransformationsDto).subscribe({
-          next(x) {
-            resolve(x);
-          },
-          error(err) {
-            console.log('Observable Error');
-            reject(err);
-          },
-          complete() {
-            console.log('done');
-          },
-        });
+        this.transformationService
+          .create(objectSnakeToCamel(createTransformationsDto))
+          .subscribe({
+            next(x) {
+              resolve(x);
+            },
+            error(err) {
+              console.log('Observable Error');
+              reject(err);
+            },
+            complete() {
+              console.log('done');
+            },
+          });
       },
     )
       .then((res) => res)
@@ -52,12 +57,12 @@ export class TransformationsClientService implements OnModuleInit {
     return { transformations: convertedTransforms };
   }
 
-  async findAll() {
+  async findAll(data) {
     console.log('TransformationClientService', 'FindAll');
 
     const findAllTransformationResponse = await new Promise(
       (resolve, reject) => {
-        this.transformationService.findAll({}).subscribe({
+        this.transformationService.findAll(objectSnakeToCamel(data)).subscribe({
           next(x) {
             resolve(x);
           },
@@ -83,12 +88,12 @@ export class TransformationsClientService implements OnModuleInit {
     return { transformations: convertedTransforms };
   }
 
-  async findOne({ id }: IdRequest) {
+  async findOne(data: IIdRequest) {
     console.log('TransformationClientService', 'FindOne');
 
     const findOneTransformationResponse = await new Promise(
       (resolve, reject) => {
-        this.transformationService.findOne({ id }).subscribe({
+        this.transformationService.findOne(objectSnakeToCamel(data)).subscribe({
           next(x) {
             resolve(x);
           },
@@ -115,18 +120,20 @@ export class TransformationsClientService implements OnModuleInit {
 
     const updateTransformationResponse = await new Promise(
       (resolve, reject) => {
-        this.transformationService.update(updateTransformationDTO).subscribe({
-          next(x) {
-            resolve(x);
-          },
-          error(err) {
-            console.log('Observable Error');
-            reject(err);
-          },
-          complete() {
-            console.log('done');
-          },
-        });
+        this.transformationService
+          .update(objectSnakeToCamel(updateTransformationDTO))
+          .subscribe({
+            next(x) {
+              resolve(x);
+            },
+            error(err) {
+              console.log('Observable Error');
+              reject(err);
+            },
+            complete() {
+              console.log('done');
+            },
+          });
       },
     )
       .then((res) => res)
@@ -137,12 +144,12 @@ export class TransformationsClientService implements OnModuleInit {
     return objectCamelToSnake(updateTransformationResponse);
   }
 
-  async remove({ id }: IdRequest) {
+  async remove(data: IIdRequest) {
     console.log('TransformationClientService', 'Remove');
 
     const removeTransformationResponse = await new Promise(
       (resolve, reject) => {
-        this.transformationService.remove({ id }).subscribe({
+        this.transformationService.remove(objectSnakeToCamel(data)).subscribe({
           next(x) {
             resolve(x);
           },

src/clients/transformations/interfaces.d.ts

@@ -1,5 +1,6 @@
 export interface ICreateTransformationsRequest {
   transformations: Transformation[];
+  info: Info;
 }
 interface Param {
   base_column: string;
@@ -9,6 +10,12 @@ interface Param {
   randbelow: number;
   const: string;
 }
+
+export interface Info {
+  customer_id: string;
+  user_id: string;
+}
+
 interface Transformation {
   created_at: string;
   id: string;
@@ -19,10 +26,12 @@ interface Transformation {
   table: string;
 }
 
-export interface IdRequest {
+export interface IIdRequest {
   id: string;
+  info: Info;
 }
 
 export interface IUpdateTransformationRequest {
   transformation: Transformation;
+  info: Info;
 }

src/main.ts

@@ -5,7 +5,14 @@ import { writeFileSync } from 'fs';
 import { AppModule } from './app.module';
 
 async function bootstrap() {
-  const app = await NestFactory.create(AppModule);
+  const app = await NestFactory.create(AppModule, {
+    cors: {
+      origin: '*',
+      methods: 'GET,HEAD,PUT,PATCH,POST,DELETE',
+      preflightContinue: false,
+      optionsSuccessStatus: 204,
+    },
+  });
 
   const config = new DocumentBuilder()
     .setTitle('Maestro Grpc Documentation')

src/middlewares/authentication.ts

@@ -14,7 +14,8 @@ import { HttpExceptionFilter } from 'src/error/http-exception.filter';
 @UseFilters(new HttpExceptionFilter())
 export class LoggerMiddleware implements NestMiddleware {
   use = async (request: Request, response: Response, next: NextFunction) => {
-    const idToken = request.get('User-Agent');
+    console.log('Middle', new Date());
+    const idToken = request.get('Dadosfera-User');
     const accessToken = request.get('Authorization');
     const privateKey = process.env.JWT_PRIVATE_KEY;
 
@@ -27,7 +28,7 @@ export class LoggerMiddleware implements NestMiddleware {
       }
     });
     const jwtDecoded: any = decode(idToken);
-    console.log(jwtDecoded);
+
     const permissions = jwtDecoded.user.permissions;
     const clienId = jwtDecoded.user.customerId;
     const userId = jwtDecoded.user.id;
@@ -46,8 +47,11 @@ export class LoggerMiddleware implements NestMiddleware {
     });
 
     if (havePermission) {
-      request.body.client_id = clienId;
-      request.body.user_id = userId;
+      request.body.info = {
+        customer_id: clienId,
+        user_id: userId,
+      };
+
       next();
     } else {
       throw new ForbiddenException();
@@ -91,29 +95,31 @@ const verifyToken = async (accessToken: string) => {
 
   try {
     await setUp(awsRegion, awsPoolId);
-    if (accessToken) {
-      const user: any = decode(accessToken, { complete: true });
-
-      if (user === null) {
-        throw new UnauthorizedException();
-      }
-
-      const { kid } = user.header;
-      const pem = pems.filter((item: any) => item[kid]);
-      const pemValue: any = pem[0][kid];
-
-      if (!pem) {
-        throw new UnauthorizedException();
-      }
-
-      verify(accessToken, pemValue, (err: any) => {
-        if (err) {
-          throw new UnauthorizedException();
-        }
-
-        return;
-      });
+    if (!accessToken) {
+      throw new UnauthorizedException();
     }
+
+    const user: any = decode(accessToken, { complete: true });
+
+    if (user === null) {
+      throw new UnauthorizedException();
+    }
+
+    const { kid } = user.header;
+    const pem = pems.filter((item: any) => item[kid]);
+    const pemValue: any = pem[0][kid];
+
+    if (!pem) {
+      throw new UnauthorizedException();
+    }
+
+    verify(accessToken, pemValue, (err: any) => {
+      if (err) {
+        throw new UnauthorizedException();
+      }
+
+      return;
+    });
   } catch (error) {
     throw new UnauthorizedException();
   }

src/modules/inputs/inputs.controller.ts

@@ -9,20 +9,18 @@ import {
 } from '@nestjs/common';
 import { InputsService } from './inputs.service';
 import { InputsClientService } from 'src/clients/inputs/client.service';
-import { Payload } from '@nestjs/microservices';
+import {
+  ICreateInputRequest,
+  UpdateInputRequest,
+} from 'src/clients/inputs/interfaces';
 
 @Controller('inputs')
 export class InputsController {
   constructor(private inputsClientService: InputsClientService) {}
 
-  @Get('/test-connection')
+  @Post('/test-connection')
   async testConnection(@Body() data) {
-    console.log(
-      process.env.DEV_URL + `/test-connection`,
-      'ON TEST CONNECTION ROUTE',
-    );
-
-    console.log(data);
+    console.log(`/test-connection`, 'ON TEST CONNECTION ROUTE');
 
     const inputService = new InputsService(this.inputsClientService);
     const response = await inputService.testConnection(data);
@@ -31,8 +29,8 @@ export class InputsController {
   }
 
   @Post()
-  async create(@Body() createInputDto) {
-    console.log(process.env.DEV_URL + `/input`, 'ON CREATE ROUTE');
+  async create(@Body() createInputDto: ICreateInputRequest) {
+    console.log(`/input`, 'ON CREATE ROUTE');
 
     const inputService = new InputsService(this.inputsClientService);
     const response = await inputService.create(createInputDto);
@@ -41,48 +39,50 @@ export class InputsController {
   }
 
   @Get()
-  async findAll() {
-    console.log(process.env.DEV_URL + `/input`, 'ON FIND ALL ROUTE');
+  async findAll(@Body() body) {
+    console.log(`/input`, 'ON FIND ALL ROUTE');
 
     const inputService = new InputsService(this.inputsClientService);
 
-    const response = await inputService.findAll();
+    const response = await inputService.findAll(body);
 
     return response;
   }
 
   @Get('/:id')
-  async findOne(@Param() params) {
+  async findOne(@Body() body, @Param() params) {
     const { id } = params;
-    console.log(process.env.DEV_URL + `/input/${id}`, 'ON FIND ONE ROUTE');
+    console.log(`/input/${id}`, 'ON FIND ONE ROUTE');
     const inputService = new InputsService(this.inputsClientService);
 
-    const response = await inputService.findOne(id);
+    const response = await inputService.findOne({ id, ...body });
 
     return response;
   }
 
   @Put(':id')
-  async update(@Payload() updateInputDto, @Param() params) {
+  async update(@Body() updateInputDto: UpdateInputRequest, @Param() params) {
     const { id } = params;
+    const { info } = updateInputDto;
+    delete updateInputDto.info;
 
-    console.log(process.env.DEV_URL + `/input/${id}`, 'ON UPDATE ROUTE');
+    console.log(`/input/${id}`, 'ON UPDATE ROUTE');
     const inputService = new InputsService(this.inputsClientService);
 
-    const response = await inputService.update(id, updateInputDto);
+    const response = await inputService.update(id, updateInputDto, info);
 
     return response;
   }
 
   @Delete(':id')
-  async delete(@Param() params) {
+  async delete(@Body() data, @Param() params) {
     const { id } = params;
 
-    console.log(process.env.DEV_URL + `/input/${id}`, 'ON DELETE ROUTE');
+    console.log(`/input/${id}`, 'ON DELETE ROUTE');
 
     const inputService = new InputsService(this.inputsClientService);
 
-    const response = await inputService.remove(id);
+    const response = await inputService.remove({ id, ...data });
 
     return response;
   }

src/modules/inputs/inputs.service.ts

@@ -1,11 +1,16 @@
-import { HttpException, HttpStatus, Injectable } from '@nestjs/common';
+import { Body, HttpException, HttpStatus, Injectable } from '@nestjs/common';
 import { InputsClientService } from 'src/clients/inputs/client.service';
+import {
+  ICreateInputRequest,
+  IIdRequest,
+  Info,
+} from 'src/clients/inputs/interfaces';
 
 @Injectable()
 export class InputsService {
   constructor(private inputClient: InputsClientService) {}
 
-  async create(data) {
+  async create(@Body() data: ICreateInputRequest) {
     try {
       const createInputResponse = await this.inputClient.create(data);
 
@@ -15,9 +20,9 @@ export class InputsService {
     }
   }
 
-  async findAll() {
+  async findAll(body) {
     try {
-      const findAllInputResponse = await this.inputClient.findAll({});
+      const findAllInputResponse = await this.inputClient.findAll(body);
 
       return findAllInputResponse;
     } catch (err) {
@@ -25,19 +30,20 @@ export class InputsService {
     }
   }
 
-  async findOne(id: string) {
+  async findOne(idRequest: IIdRequest) {
     try {
-      const findOneInputResponse = await this.inputClient.findOne({ id });
+      const findOneInputResponse = await this.inputClient.findOne(idRequest);
       return findOneInputResponse;
     } catch (err) {
       throw new HttpException(err.message, HttpStatus.NOT_FOUND);
     }
   }
 
-  async update(id: string, data) {
+  async update(id: string, data, info: Info) {
     try {
       const updateInputResponse = await this.inputClient.update({
         id,
+        info,
         ...data,
       });
 
@@ -47,9 +53,9 @@ export class InputsService {
     }
   }
 
-  async remove(id: string) {
+  async remove(idRequest: IIdRequest) {
     try {
-      const removeInputResponse = await this.inputClient.remove({ id });
+      const removeInputResponse = await this.inputClient.remove(idRequest);
 
       return removeInputResponse;
     } catch (err) {

src/modules/outputs/outputs.controllers.ts

@@ -6,7 +6,6 @@ import {
   Param,
   Post,
   Put,
-  Redirect,
 } from '@nestjs/common';
 import { Payload } from '@nestjs/microservices';
 import { OutputsClientService } from 'src/clients/outputs/client.service';
@@ -14,63 +13,60 @@ import { OutputsService } from './outputs.service';
 
 @Controller('outputs')
 export class OutputsController {
-
-  constructor( private outputsClientService:OutputsClientService){}
+  constructor(private outputsClientService: OutputsClientService) {}
 
   @Post()
   async create(@Body() createOutputDto) {
     console.log(process.env.DEV_URL + `/output`, 'ON CREATE ROUTE');
 
-    const outputService = new OutputsService(this.outputsClientService)
-    const response = await outputService.create(createOutputDto)
+    const outputService = new OutputsService(this.outputsClientService);
+    const response = await outputService.create(createOutputDto);
 
     return response;
   }
 
   @Get()
-  async findAll() {
+  async findAll(@Body() data) {
     console.log(process.env.DEV_URL + `/output`, 'ON Find All ROUTE');
 
-    const outputService = new OutputsService(this.outputsClientService)
-    const response = await outputService.findAll()
+    const outputService = new OutputsService(this.outputsClientService);
+    const response = await outputService.findAll(data);
 
     return response;
-
   }
 
   @Get('/:id')
-  async findOne(@Param() params) {
-    const {id} = params;
+  async findOne(@Body() data, @Param() params) {
+    const { id } = params;
     console.log(process.env.DEV_URL + `/output/${id}`, 'ON Find One ROUTE');
-    
-    const outputService = new OutputsService(this.outputsClientService)
-    const response = await outputService.findOne(id)
+
+    const outputService = new OutputsService(this.outputsClientService);
+    const response = await outputService.findOne({ id, ...data });
 
     return response;
   }
 
   @Put(':id')
-  async update(
-    @Payload() updateOutputDto,
-    @Param() params,
-  ) {
-    const {id} = params;
+  async update(@Payload() updateOutputDto, @Param() params) {
+    const { id } = params;
+    const { info } = updateOutputDto;
+    delete updateOutputDto.info;
+
     console.log(process.env.DEV_URL + `/output/${id}`, 'ON UPDATE ROUTE');
 
-    const outputService = new OutputsService(this.outputsClientService)
-    const response = await outputService.update(id,updateOutputDto)
+    const outputService = new OutputsService(this.outputsClientService);
+    const response = await outputService.update(id, updateOutputDto, info);
 
     return response;
-
   }
 
   @Delete(':id')
-  async delete(@Param() params) {
-    const {id} = params;
+  async delete(@Body() data, @Param() params) {
+    const { id } = params;
     console.log(process.env.DEV_URL + `/output/${id}`, 'ON DELETE ROUTE');
 
-    const outputService = new OutputsService(this.outputsClientService)
-    const response = await outputService.remove(id)
+    const outputService = new OutputsService(this.outputsClientService);
+    const response = await outputService.remove({ id, ...data });
 
     return response;
   }

src/modules/outputs/outputs.service.ts

@@ -1,69 +1,63 @@
 import { HttpException, HttpStatus, Injectable } from '@nestjs/common';
+import { IIdRequest, Info } from 'src/clients/outputs/interfaces';
 import { OutputsClientService } from 'src/clients/outputs/client.service';
 
 @Injectable()
 export class OutputsService {
+  constructor(private outputClient: OutputsClientService) {}
 
-  constructor( private outputClient: OutputsClientService){}
+  async create(createOutputDto) {
+    try {
+      const createOutputResponse = await this.outputClient.create(
+        createOutputDto,
+      );
 
-  async create(createOutputDto){
-    try{
-      const createOutputResponse = await this.outputClient.create(createOutputDto);
-  
-      return createOutputResponse
-
-    }catch(err){
-      throw new HttpException(err.message,HttpStatus.NOT_FOUND)
-    }
-
-  }
-
-  async findOne(id:string){
-    
-    try{
-      const findOneOutputResponse = await this.outputClient.findOne({id});
-      return findOneOutputResponse
-    }catch(err){
-      throw new HttpException(err.message,HttpStatus.NOT_FOUND)
-    }
-
-  }
-
-  async findAll(){
-    
-    try{
-      const findAllOutputResponse = await this.outputClient.findAll();
-  
-      return findAllOutputResponse
-
-    }catch(err){
-      throw new HttpException(err.message,HttpStatus.NOT_FOUND)
+      return createOutputResponse;
+    } catch (err) {
+      throw new HttpException(err.message, HttpStatus.NOT_FOUND);
     }
   }
 
-  async update(id:string, data){
-
-    try{    
-
-      const updateOutputResponse = await this.outputClient.update({id,...data});
-  
-      return updateOutputResponse
-
-    }catch(err){
-      throw new HttpException(err.message,HttpStatus.NOT_FOUND)
+  async findOne(data: IIdRequest) {
+    try {
+      const findOneOutputResponse = await this.outputClient.findOne(data);
+      return findOneOutputResponse;
+    } catch (err) {
+      throw new HttpException(err.message, HttpStatus.NOT_FOUND);
     }
   }
 
-  async remove(id:string){
+  async findAll(data) {
+    try {
+      const findAllOutputResponse = await this.outputClient.findAll(data);
 
-    try{    
+      return findAllOutputResponse;
+    } catch (err) {
+      throw new HttpException(err.message, HttpStatus.NOT_FOUND);
+    }
+  }
 
-      const removeOutputResponse = await this.outputClient.remove({id});
-  
-      return removeOutputResponse
+  async update(id: string, data, info: Info) {
+    try {
+      const updateOutputResponse = await this.outputClient.update({
+        id,
+        info,
+        ...data,
+      });
 
-    }catch(err){
-      throw new HttpException(err.message,HttpStatus.NOT_FOUND)
+      return updateOutputResponse;
+    } catch (err) {
+      throw new HttpException(err.message, HttpStatus.NOT_FOUND);
+    }
+  }
+
+  async remove(data: IIdRequest) {
+    try {
+      const removeOutputResponse = await this.outputClient.remove(data);
+
+      return removeOutputResponse;
+    } catch (err) {
+      throw new HttpException(err.message, HttpStatus.NOT_FOUND);
     }
   }
 }

src/modules/pipelines/pipelines.controller.ts

@@ -7,7 +7,6 @@ import {
   Post,
   Put,
 } from '@nestjs/common';
-import { Payload } from '@nestjs/microservices';
 import { PipelinesClientService } from 'src/clients/pipelines/client.service';
 import { PipelinesService } from './pipelines.service';
 
@@ -54,44 +53,47 @@ export class PipelinesController {
   }
 
   @Get()
-  async findAll() {
+  async findAll(@Body() data) {
     console.log(process.env.DEV_URL + `/pipeline`, 'ON Find All ROUTE');
 
     const pipelineService = new PipelinesService(this.pipelinesClientService);
-    const response = await pipelineService.findAll();
+    const response = await pipelineService.findAll(data);
 
     return response;
   }
 
   @Get('/:id')
-  async findOne(@Param() params) {
+  async findOne(@Body() data, @Param() params) {
     const { id } = params;
     console.log(process.env.DEV_URL + `/pipeline/${id}`, 'ON Find One ROUTE');
 
     const pipelineService = new PipelinesService(this.pipelinesClientService);
-    const response = await pipelineService.findOne(id);
+    const response = await pipelineService.findOne({ id, ...data });
 
     return response;
   }
 
   @Put(':id')
-  async update(@Payload() updatePipelineDto, @Param() params) {
+  async update(@Body() updatePipelineDto, @Param() params) {
     const { id } = params;
+    const { info } = updatePipelineDto;
+    delete updatePipelineDto.info;
+
     console.log(process.env.DEV_URL + `/pipeline/${id}`, 'ON UPDATE ROUTE');
 
     const pipelineService = new PipelinesService(this.pipelinesClientService);
-    const response = await pipelineService.update(id, updatePipelineDto);
+    const response = await pipelineService.update(id, updatePipelineDto, info);
 
     return response;
   }
 
   @Delete(':id')
-  async delete(@Param() params) {
+  async delete(@Body() data, @Param() params) {
     const { id } = params;
     console.log(process.env.DEV_URL + `/pipeline/${id}`, 'ON DELETE ROUTE');
 
     const pipelineService = new PipelinesService(this.pipelinesClientService);
-    const response = await pipelineService.remove(id);
+    const response = await pipelineService.remove({ id, ...data });
 
     return response;
   }

src/modules/pipelines/pipelines.service.ts

@@ -1,5 +1,6 @@
 import { HttpException, HttpStatus, Injectable } from '@nestjs/common';
 import { PipelinesClientService } from 'src/clients/pipelines/client.service';
+import { IIdRequest, Info } from 'src/clients/pipelines/interfaces';
 import { objectCamelToSnake } from 'src/utils/CaseConverter';
 
 @Injectable()
@@ -19,18 +20,18 @@ export class PipelinesService {
     }
   }
 
-  async findOne(id: string) {
+  async findOne(data: IIdRequest) {
     try {
-      const findOnePipelineResponse = await this.pipelineClient.findOne({ id });
+      const findOnePipelineResponse = await this.pipelineClient.findOne(data);
       return objectCamelToSnake(findOnePipelineResponse);
     } catch (err) {
       throw new HttpException(err.message, HttpStatus.NOT_FOUND);
     }
   }
 
-  async findAll() {
+  async findAll(data) {
     try {
-      const findAllPipelineResponse = await this.pipelineClient.findAll();
+      const findAllPipelineResponse = await this.pipelineClient.findAll(data);
 
       return objectCamelToSnake(findAllPipelineResponse);
     } catch (err) {
@@ -38,10 +39,11 @@ export class PipelinesService {
     }
   }
 
-  async update(id: string, data) {
+  async update(id: string, data, info: Info) {
     try {
       const updatePipelineResponse = await this.pipelineClient.update({
         id,
+        info,
         ...data,
       });
 
@@ -51,9 +53,9 @@ export class PipelinesService {
     }
   }
 
-  async remove(id: string) {
+  async remove(data: IIdRequest) {
     try {
-      const removePipelineResponse = await this.pipelineClient.remove({ id });
+      const removePipelineResponse = await this.pipelineClient.remove(data);
 
       return removePipelineResponse;
     } catch (err) {

src/modules/transformations/transformations.controller.ts

@@ -9,6 +9,7 @@ import {
 } from '@nestjs/common';
 import { Payload } from '@nestjs/microservices';
 import { TransformationsClientService } from 'src/clients/transformations/client.service';
+import { IIdRequest } from 'src/clients/transformations/interfaces';
 import { TransformationsService } from './transformations.service';
 
 @Controller('transformations')
@@ -32,19 +33,19 @@ export class TransformationsController {
   }
 
   @Get()
-  async findAll() {
+  async findAll(@Body() data: IIdRequest) {
     console.log(process.env.DEV_URL + `/transformation`, 'ON Find All ROUTE');
 
     const transformationService = new TransformationsService(
       this.transformationsClientService,
     );
-    const response = await transformationService.findAll();
+    const response = await transformationService.findAll(data);
 
     return response;
   }
 
   @Get('/:id')
-  async findOne(@Param() params) {
+  async findOne(@Body() data, @Param() params) {
     const { id } = params;
     console.log(
       process.env.DEV_URL + `/transformation/${id}`,
@@ -54,7 +55,7 @@ export class TransformationsController {
     const transformationService = new TransformationsService(
       this.transformationsClientService,
     );
-    const response = await transformationService.findOne(id);
+    const response = await transformationService.findOne({ id, ...data });
 
     return response;
   }
@@ -79,7 +80,7 @@ export class TransformationsController {
   }
 
   @Delete(':id')
-  async delete(@Param() params) {
+  async delete(@Body() data, @Param() params) {
     const { id } = params;
     console.log(
       process.env.DEV_URL + `/transformation/${id}`,
@@ -89,7 +90,7 @@ export class TransformationsController {
     const transformationService = new TransformationsService(
       this.transformationsClientService,
     );
-    const response = await transformationService.remove(id);
+    const response = await transformationService.remove({ id, ...data });
 
     return response;
   }

src/modules/transformations/transformations.service.ts

@@ -1,6 +1,9 @@
 import { HttpException, HttpStatus, Injectable } from '@nestjs/common';
 import { TransformationsClientService } from 'src/clients/transformations/client.service';
-import { ICreateTransformationsRequest } from 'src/clients/transformations/interfaces';
+import {
+  ICreateTransformationsRequest,
+  IIdRequest,
+} from 'src/clients/transformations/interfaces';
 import { trSnakeToCamel } from 'src/utils/CaseConverter';
 
 @Injectable()
@@ -16,6 +19,7 @@ export class TransformationsService {
       const createTransformationResponse =
         await this.transformationClient.create({
           transformations: convertedDTO,
+          info: createTransformationDto.info,
         });
 
       return createTransformationResponse;
@@ -24,20 +28,20 @@ export class TransformationsService {
     }
   }
 
-  async findOne(id: string) {
+  async findOne(data: IIdRequest) {
     try {
       const findOneTransformationResponse =
-        await this.transformationClient.findOne({ id });
+        await this.transformationClient.findOne(data);
       return findOneTransformationResponse;
     } catch (err) {
       throw new HttpException(err.message, HttpStatus.NOT_FOUND);
     }
   }
 
-  async findAll() {
+  async findAll(data) {
     try {
       const findAllTransformationResponse =
-        await this.transformationClient.findAll();
+        await this.transformationClient.findAll(data);
 
       return findAllTransformationResponse;
     } catch (err) {
@@ -57,10 +61,10 @@ export class TransformationsService {
     }
   }
 
-  async remove(id: string) {
+  async remove(data: IIdRequest) {
     try {
       const removeTransformationResponse =
-        await this.transformationClient.remove({ id });
+        await this.transformationClient.remove(data);
 
       return removeTransformationResponse;
     } catch (err) {

src/utils/CaseConverter.ts

@@ -41,8 +41,8 @@ export const objectSnakeToCamel = (object) => {
       delete object[key];
     }
   });
-
   objectValues.forEach((value) => {
+    if (value == null) return;
     if (typeof value === 'object') {
       objectSnakeToCamel(value);
     }

swagger.json

@@ -1 +1 @@
-{"openapi":"3.0.0","paths":{"/inputs/test-connection":{"get":{"operationId":"InputsController_testConnection","parameters":[],"responses":{"200":{"description":""}}}},"/inputs":{"post":{"operationId":"InputsController_create","parameters":[],"responses":{"201":{"description":""}}},"get":{"operationId":"InputsController_findAll","parameters":[],"responses":{"200":{"description":""}}}},"/inputs/{id}":{"get":{"operationId":"InputsController_findOne","parameters":[],"responses":{"200":{"description":""}}},"put":{"operationId":"InputsController_update","parameters":[],"responses":{"200":{"description":""}}},"delete":{"operationId":"InputsController_delete","parameters":[],"responses":{"200":{"description":""}}}},"/transformations":{"post":{"operationId":"TransformationsController_create","parameters":[],"responses":{"201":{"description":""}}},"get":{"operationId":"TransformationsController_findAll","parameters":[],"responses":{"200":{"description":""}}}},"/transformations/{id}":{"get":{"operationId":"TransformationsController_findOne","parameters":[],"responses":{"200":{"description":""}}},"put":{"operationId":"TransformationsController_update","parameters":[],"responses":{"200":{"description":""}}},"delete":{"operationId":"TransformationsController_delete","parameters":[],"responses":{"200":{"description":""}}}},"/outputs":{"post":{"operationId":"OutputsController_create","parameters":[],"responses":{"201":{"description":""}}},"get":{"operationId":"OutputsController_findAll","parameters":[],"responses":{"200":{"description":""}}}},"/outputs/{id}":{"get":{"operationId":"OutputsController_findOne","parameters":[],"responses":{"200":{"description":""}}},"put":{"operationId":"OutputsController_update","parameters":[],"responses":{"200":{"description":""}}},"delete":{"operationId":"OutputsController_delete","parameters":[],"responses":{"200":{"description":""}}}},"/pipelines/{id}/status":{"get":{"operationId":"PipelinesController_getPipelineStatus","parameters":[],"responses":{"200":{"description":""}}}},"/pipelines/{id}/{details}":{"get":{"operationId":"PipelinesController_getPipelineLogs","parameters":[],"responses":{"200":{"description":""}}}},"/pipelines":{"post":{"operationId":"PipelinesController_create","parameters":[],"responses":{"201":{"description":""}}},"get":{"operationId":"PipelinesController_findAll","parameters":[],"responses":{"200":{"description":""}}}},"/pipelines/{id}":{"get":{"operationId":"PipelinesController_findOne","parameters":[],"responses":{"200":{"description":""}}},"put":{"operationId":"PipelinesController_update","parameters":[],"responses":{"200":{"description":""}}},"delete":{"operationId":"PipelinesController_delete","parameters":[],"responses":{"200":{"description":""}}}},"/auth":{"post":{"operationId":"AuthController_signIn","parameters":[],"responses":{"201":{"description":""}}}},"/health":{"get":{"operationId":"HealthController_check","parameters":[],"responses":{"200":{"description":""}}}}},"info":{"title":"Maestro Grpc Documentation","description":"Documentation for Maestro gateway","version":"1.0","contact":{}},"tags":[],"servers":[],"components":{"securitySchemes":{"bearer":{"scheme":"bearer","bearerFormat":"JWT","type":"http"}},"schemas":{}}}
+{"openapi":"3.0.0","paths":{"/inputs/test-connection":{"post":{"operationId":"InputsController_testConnection","parameters":[],"responses":{"201":{"description":""}}}},"/inputs":{"post":{"operationId":"InputsController_create","parameters":[],"responses":{"201":{"description":""}}},"get":{"operationId":"InputsController_findAll","parameters":[],"responses":{"200":{"description":""}}}},"/inputs/{id}":{"get":{"operationId":"InputsController_findOne","parameters":[],"responses":{"200":{"description":""}}},"put":{"operationId":"InputsController_update","parameters":[],"responses":{"200":{"description":""}}},"delete":{"operationId":"InputsController_delete","parameters":[],"responses":{"200":{"description":""}}}},"/transformations":{"post":{"operationId":"TransformationsController_create","parameters":[],"responses":{"201":{"description":""}}},"get":{"operationId":"TransformationsController_findAll","parameters":[],"responses":{"200":{"description":""}}}},"/transformations/{id}":{"get":{"operationId":"TransformationsController_findOne","parameters":[],"responses":{"200":{"description":""}}},"put":{"operationId":"TransformationsController_update","parameters":[],"responses":{"200":{"description":""}}},"delete":{"operationId":"TransformationsController_delete","parameters":[],"responses":{"200":{"description":""}}}},"/outputs":{"post":{"operationId":"OutputsController_create","parameters":[],"responses":{"201":{"description":""}}},"get":{"operationId":"OutputsController_findAll","parameters":[],"responses":{"200":{"description":""}}}},"/outputs/{id}":{"get":{"operationId":"OutputsController_findOne","parameters":[],"responses":{"200":{"description":""}}},"put":{"operationId":"OutputsController_update","parameters":[],"responses":{"200":{"description":""}}},"delete":{"operationId":"OutputsController_delete","parameters":[],"responses":{"200":{"description":""}}}},"/pipelines/{id}/status":{"get":{"operationId":"PipelinesController_getPipelineStatus","parameters":[],"responses":{"200":{"description":""}}}},"/pipelines/{id}/{details}":{"get":{"operationId":"PipelinesController_getPipelineLogs","parameters":[],"responses":{"200":{"description":""}}}},"/pipelines":{"post":{"operationId":"PipelinesController_create","parameters":[],"responses":{"201":{"description":""}}},"get":{"operationId":"PipelinesController_findAll","parameters":[],"responses":{"200":{"description":""}}}},"/pipelines/{id}":{"get":{"operationId":"PipelinesController_findOne","parameters":[],"responses":{"200":{"description":""}}},"put":{"operationId":"PipelinesController_update","parameters":[],"responses":{"200":{"description":""}}},"delete":{"operationId":"PipelinesController_delete","parameters":[],"responses":{"200":{"description":""}}}},"/auth":{"post":{"operationId":"AuthController_signIn","parameters":[],"responses":{"201":{"description":""}}}},"/health":{"get":{"operationId":"HealthController_check","parameters":[],"responses":{"200":{"description":""}}}}},"info":{"title":"Maestro Grpc Documentation","description":"Documentation for Maestro gateway","version":"1.0","contact":{}},"tags":[],"servers":[],"components":{"securitySchemes":{"bearer":{"scheme":"bearer","bearerFormat":"JWT","type":"http"}},"schemas":{}}}