Merge pull request #119 from dadosfera/fix/error-handling

FIX: added exception filter to catch unhandled errors

.eslintrc.js

@@ -6,6 +6,7 @@ module.exports = {
   },
   plugins: ['@typescript-eslint/eslint-plugin'],
   extends: [
+    'eslint:recommended',
     'plugin:@typescript-eslint/recommended',
     'plugin:prettier/recommended',
   ],

.github/workflows/deploy-manually.yml

@@ -35,9 +35,7 @@ jobs:
   semantic_release:
     runs-on: ubuntu-latest
     outputs:
-      #new_release_published: ${{ steps.semantic.outputs.last_release_version != steps.semantic.outputs.new_release_version }}
       new_release_published: ${{ steps.semantic.outputs.new_release_published }}
-      #new_release_version: ${{ steps.semantic.outputs.new_release_version }}
       new_release_version: ${{ (steps.semantic.outputs.new_release_published == 'true' && steps.semantic.outputs.new_release_version) || (github.event_name == 'workflow_dispatch' && '0.0.0') }}
     steps:
       - name: Checkout
@@ -57,7 +55,6 @@ jobs:
             ]
         env:
           GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
-          NPM_TOKEN: ${{ secrets.NPM_TOKEN }}
 
   deploy:
     if: ${{ github.event_name == 'workflow_dispatch' || needs.semantic_release.outputs.new_release_published == 'true' }}
@@ -107,9 +104,8 @@ jobs:
           ENV: ${{ needs.extract_environment.outputs.environment }}
           IMAGE_TAG: ${{ needs.semantic_release.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}
+          docker-compose -f build.docker-compose.yml build
           docker-compose -f build.docker-compose.yml push
 
       - name: Create ZIP file to Deploy AWS Beanstalk

.github/workflows/test.yml

@@ -2,8 +2,6 @@ name: Test
 on:
   pull_request:
     branches:
-      - alpha
-      - beta
       - main
 
 jobs:
@@ -21,23 +19,22 @@ jobs:
         env:
           ENV: test
           IMAGE_TAG: test
-          NPM_TOKEN: ${{ secrets.NPM_TOKEN }}
         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}
+          docker-compose -f build.docker-compose.yml build
 
       - name: Run Test
         env:
           ENV: test
           IMAGE_TAG: test
           ACCOUNT_ID: test
-          NPM_TOKEN: ${{ secrets.NPM_TOKEN }}
+          APP_NAME: ${{ github.event.repository.name }}
         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 --rm --entrypoint="npm run test" $APP_NAME
 
       - name: Remove Docker's Trash
         if: always()

.npmrc

@@ -1 +0,0 @@
-//registry.npmjs.org/:_authToken=${NPM_TOKEN}

.releaserc.json

@@ -26,7 +26,6 @@
         "preset": "eslint"
       }
     ],
-    "@semantic-release/npm",
     "@semantic-release/github"
   ]
 }

Dockerfile

@@ -1,17 +1,16 @@
 FROM node:18.3.0-alpine3.15 as packages
 WORKDIR /packages
-ARG NPM_TOKEN
 COPY package.json .
 COPY package-lock.json .
-COPY .npmrc .
-RUN npm install
-RUN rm -f ./.npmrc 
+RUN apk update \
+ && apk add --no-cache aws-cli \
+ && aws codeartifact login --tool npm --repository dadosfera-npm --domain dadosfera --domain-owner 611330257153 --region us-east-1 \
+ && npm install
 
-FROM node:14.15.4-alpine3.12
+FROM node:18.3.0-alpine3.15
 WORKDIR /app
 COPY . /app/
-ARG NPM_TOKEN
 COPY --from=packages /packages/node_modules /app/node_modules
 RUN npm run build
 EXPOSE 3333
-ENTRYPOINT npm run start
+ENTRYPOINT npm run start

README.md

@@ -1,50 +1,301 @@
-# Maestro
 <p align="center">
   <image src="./assets/maestro.svg" style="width:10rem">
-  <h1 align="center">Maestro</h1>  
 </p> 
-This is the Dadosfera´s gateway repository, it´s responsable for the communication between frontend application and Dadosfera´s mirosservices.
 
-## 💻 Requirements
+# Maestro
+Maestro is the Dadosfera's gateway, it's responsible for the communication between the frontend application and Dadosfera's microservices.
 
-Before you start, make sure you have done the following steps:
+## 🚀 Starting
+These instructions will allow you to get a working copy of the project on your local machine for development and testing purposes.
 
-* Installed Nodejs version 16.14.2
-* Installed latest NPM version
+### 📋 Requirements
+- [NodeJS v18.3.0 LTS / NPM v8.11](https://nodejs.org/pt-br/download/) (you can opt to use [NVM](https://github.com/nvm-sh/nvm) to easily manage node versions)
+- Request access to AWS Console dev account for **all services** (avoid gradually asking for each needed service. it will slow down your development cycle)
+    - Create your Access Key on the "Security credentials" menu
+    - Set the Access Key on your local development machine
+- Request access to the dev, stg and prd VPNs
 
+### 🔧 Installation<a id="installation"></a>
+- Clone the repository
+    - SSH
+        ```
+        git clone git@github.com:dadosfera/maestro.git
+        ```
+        or
 
+    - HTTPS
+        ```
+        git clone https://github.com/dadosfera/maestro.git
+        ```
 
-## 🚀 Installing Maestro
+- Select the correct node version (optional, only if using [NVM](https://github.com/nvm-sh/nvm)):
+    ```sh
+    nvm use
+    ```
 
-First of all clone the repository:
- * SSH:
-```
-git clone git@github.com:dadosfera/maestro.git
-```
- * HTTPS:
-```
-git clone git@github.com:dadosfera/maestro.git
+- Install the project dependencies:
+    ```sh
+    npm i
+    ```
+
+- Setup the following enviroment variables:
+    ```
+    ENV=
+    DUC_URL=
+    INFACTORY_URL=
+    OTFACTORY_URL=
+    PIFACTORY_URL=
+    SM_OAUTH_PATH=
+    ```
+
+- Start the server:
+    ```sh
+    # dev mode
+    npm run start:dev
+
+    # or in debug mode
+    npm run start:debug
+    ```
+    The service should start successfully.
+
+## Authentication decorators
+Maestro have utilities to ease the user authentication on every controller and route. The following decorators are available:
+
+### `@Authenticated`
+If the user must be authenticated to make request, we can use the `@Authenticated` decorator in the controller or route, as needed.
+
+```ts
+import { Authenticated } from '../../authentication/authentication.decorator';
+
+@Controller('foo')
+@Authenticated()
+class FooController {
+  /* ... */
+
+  @Get('bar')
+  async getBar() {
+    this.logger.info('user is authenticated!');
+
+    return { authenticated: true };
+  }
+}
 ```
 
-## Enviroment variables
+```ts
+import { Authenticated } from '../../authentication/authentication.decorator';
 
-Here is a list of enviroment variables needed in order to run the application correctly.
+@Controller('foo')
+class FooController {
+  /* ... */
 
-```
-ENV=
-DUC_URL=
-INFACTORY_URL=
-TRFACTORY_URL=
-OTFACTORY_URL=
-PIFACTORY_URL=
-JWT_PRIVATE_KEY=
-AWS_IDENTITY_POOL_ID=
+  @Get('bar')
+  @Authenticated()
+  async getBar() {
+    this.logger.info('user is authenticated!');
+
+    return { authenticated: true };
+  }
+
+  @Post('bar')
+  async postBar() {
+    this.logger.info('user is NOT authenticated!');
+
+    return { authenticated: false };
+  }
+}
 ```
 
-## Running Maestro
+### `@RequireAllPermissions`
+This decorator requires that **all permissions** listed are granted to the requesting user.
 
-In order to run Maestro just run the following command:
+```ts
+import { RequireAllPermissions } from '../../authentication/authentication.decorator';
+import { Permissions } from '../../authentication/permissions.enum';
+
+@Controller('foo')
+class FooController {
+  /* ... */
+
+  @Get('bar')
+  @RequireAllPermissions(Permissions.BAR.MANAGE, Permissions.BAR.CREATE)
+  async getBar() {
+    /* ... */
+  }
+}
 ```
-npm run start:dev
+
+### `@RequireSomePermission`
+In the following case, the user is required to have **at least one** listed permission.
+
+```ts
+import { RequireSomePermission } from '../../authentication/authentication.decorator';
+import { Permissions } from '../../authentication/permissions.enum';
+
+@Controller('foo')
+@RequireSomePermission(Permissions.FOO.MANAGE, Permissions.FOO.CREATE)
+class FooController {
+  /* ... */
+
+  @Get('bar')
+  async getBar() {
+    /* ... */
+  }
+}
 ```
-If everything is fine the Maestro will start and be ready to receive HTTP requests
+
+### `@AuthenticateCondition`
+If a more complicated authentication check needs to be done, we can use the `@AuthenticateCondition` decorator to define it. The custom function must return `true` to authenticate the request.
+
+In the following example:
+- all routes on the `FooController` controller can only be requested from localhost
+- `POST /foo/bar` can only be requested from localhost **and** by users from customer id `111...eef`
+
+```ts
+import { AuthenticateCondition } from '../../authentication/authentication.decorator';
+
+@Controller('foo')
+// allow requests only from localhost
+@AuthenticateCondition((request: Request) => request.ip === '::ffff:127.0.0.1')
+class FooController {
+  /* ... */
+
+  @Get('bar')
+  async getBar() {
+    /* ... */
+  }
+
+  @Post('bar')
+  // allow requests only from a specific customer
+  @AuthenticateCondition((request: Request, user: RequestUser) => user.customer_id === '1113e943-2187-4fdd-9c2c-54338fedaeef')
+  async postBar() {
+    /* ... */
+  }
+}
+```
+
+### Note on authentication decorators
+- The old authentication method placed the user data in the `request.body.info` field, this imposes certain issues regarding the request body because this data should be from the frontend without any modification by Maestro. Now this usage is ⚠️ **DEPRECATED** ⚠️. We are working to migrate to the `@User` parameter decorator. The old method is working while the migration is in progress.
+
+- Authentication decorators can be used together and all of them **must** pass to the request be authenticated, but in the general case you don't need to (*and wouldn't like to...*) use all of them together, as you can code all of the authentication logic in the `@AuthenticateCondition` decorator.
+
+    ```ts
+    import {
+      RequireAllPermissions,
+      RequireSomePermission,
+      AuthenticateCondition,
+    } from '../../authentication/authentication.decorator';
+    import { Permissions } from '../../authentication/permissions.enum';
+    import { Waa, Baz } from './authenticationFunctions'
+
+    @Controller('foo')
+    @RequireAllPermissions(Permissions.FOO.USE, Permissions.FOO.REQUEST)
+    @RequireSomePermission(Permissions.FOO.MANAGE, Permissions.FOO.ADMIN)
+    @AuthenticateCondition(Waa)
+    @AuthenticateCondition(Baz)
+    class FooController {
+      /* ... */
+
+      @Get('bar')
+      async getBar() {
+        /* ... */
+      }
+
+      @Post('bar')
+      @RequireAllPermissions(Permissions.BAR.MANAGE, Permissions.BAR.USE, Permissions.BAR.REQUEST)
+      async postBar() {
+        /* ... */
+      }
+    }
+    ```
+
+- If `@RequireAllPermissions` and `@RequireSomePermission` are used with **only a single permission**, they present the **exactly same behavior**.
+
+    ```ts
+    // same behavior
+    @RequireAllPermissions(Permissions.BAR.MANAGE)
+    @RequireSomePermission(Permissions.BAR.MANAGE)
+    ```
+
+
+
+## `@User` parameter decorator
+The requesting user data can be obtained using the @User parameter decorator, like in the following snippet:
+
+```ts
+import { User, RequestUser } from '../../authentication/user.decorator';
+
+@Controller('foo')
+class FooController {
+  /* ... */
+
+  @Get('bar')
+  async getBar(@User() user: RequestUser) {
+    this.logger.info(user);
+
+    return { user };
+  }
+}
+```
+
+If the user is required to be logged in, set `required` to `true`, as you would want in the `change-password` operation:
+
+```ts
+import { User, RequestUser } from '../../authentication/user.decorator';
+
+@Controller('user')
+class UserController {
+  /* ... */
+
+  @Post('change-password')
+  @HttpCode(HttpStatus.OK)
+  async changePassword(
+    @User({ required: true }) user: RequestUser,
+    @Body() body: AuthChangePasswordRequest,
+  ) {
+    const { oldPassword, newPassword } = body;
+
+    return this.authClient.changePassword({
+      userId: user.user_id,
+      oldPassword,
+      newPassword,
+    });
+  }
+}
+```
+
+## 📦 Development
+### ⌨️ Coding Style
+By default, we use [ESLint](https://eslint.org/) + [Prettier](https://prettier.io/) with default settings.
+
+**We recommend using Visual Studio Code and installing the recommended extensions to ease the development process.**
+
+### Commits pattern
+Our workflow pipeline follows the conventional commits specs ([cheat sheets](https://cheatography.com/albelop/cheat-sheets/conventional-commits/)) to release versions accordingly.
+
+Format: `<type>[optional scope]: <description>`
+
+Example: `FIX: ensure Range headers adhere more closely to RFC 2616`
+
+### Branching naming convention
+- **Feature**: Any code changes for a new module or use case should be done on a feature branch. This branch is created based on the `main` branch. When all changes are done, a Pull Request/Merge Request is needed to put all of these changes back to the `main` branch. Examples: `feature/integrate-swagger`, `feature/JIRA-1234`, `feature/JIRA-1234_support-dark-theme`.
+
+  **It is recommended to use all lower caps letters and hyphen (-) to separate words unless it is a specific item name or ID. Underscore (_) could be used to separate the ID and description.**
+
+- **Bug Fix**: If the code changes made from the feature branch were rejected after a release, sprint or demo, any necessary fixes after that should be done on the bugfix branch. Examples: `bugfix/more-gray-shades`,  `bugfix/JIRA-1444_gray-on-blur-fix`.
+
+- **Hot Fix**: If there is a need to fix a blocker, do a temporary patch, apply a critical framework or configuration change that should be handled immediately, it should be created as a Hotfix. Examples: `hotfix/disable-endpoint-zero-day-exploit`, `hotfix/increase-scaling-threshold`.
+
+- **Experimental**: A branch for playing around. Any new feature or idea that is not part of a release or a sprint. Example: `experimental/dark-theme-support`.
+
+### Making a Pull Request
+1. Commit your changes
+2. Open the Pull Request on GitHub
+3. Send Pull Request link in microsfera Google Chat Group for review and possible approval
+
+## 🛠️ Built with
+Some technologies used in this project:
+
+- [NestJS](https://docs.nestjs.com) - Framework for building efficient and scalable NodeJS server-side applications
+
+## ⚙️ Back-end Architecture
+The architecture can be found at [this link](https://sites.google.com/dadosfera.ai/wikidoproduto/time/back-end).

package.json

@@ -36,11 +36,11 @@
     "@nestjs/platform-express": "^8.4.7",
     "@nestjs/schedule": "^1.1.0",
     "@nestjs/swagger": "^5.2.1",
-    "@victorradael/protospack": "2.5.0",
-    "@victorradael/protospack-v2": "1.1.1",
     "axios": "^0.25.0",
     "cron-parser": "^4.4.0",
+    "dadosfera-logs": "^1.0.0-alpha.10",
     "dotenv": "^14.3.2",
+    "elastic-apm-node": "^3.36.0",
     "helmet": "^5.1.0",
     "jsonwebtoken": "^8.5.1",
     "jwk-to-pem": "^2.0.5",
@@ -50,6 +50,8 @@
     "passport-google-oauth20": "^2.0.0",
     "passport-hubspot-oauth2": "^1.0.3",
     "passport-mailchimp": "^1.1.0",
+    "protospack": "2.5.1",
+    "protospack-v2": "3.0.0",
     "reflect-metadata": "^0.1.13",
     "rimraf": "^3.0.2",
     "rxjs": "^7.5.5",

src/app.module.ts

@@ -1,12 +1,12 @@
 import { Module } from '@nestjs/common';
 import { ClientsModule } from '@nestjs/microservices';
 import { ConfigModule } from '@nestjs/config';
+import { DadosferaLogger } from 'dadosfera-logs';
 
 import { InputsController } from './modules/inputs/inputs.controller';
 import { TransformationsController } from './modules/transformations/transformations.controller';
 import { OutputsController } from './modules/outputs/outputs.controllers';
 import { PipelinesController } from './modules/pipelines/pipelines.controller';
-import { AuthController } from './modules/auth/auth.controller';
 import { HealthController } from './modules/health/health.controller';
 
 import { InputsService } from './modules/inputs/inputs.service';
@@ -15,16 +15,15 @@ import { OutputsService } from './modules/outputs/outputs.service';
 import { PipelinesService } from './modules/pipelines/pipelines.service';
 import { HealthService } from './modules/health/health.service';
 
-import { AuthClientService } from './clients/auth/client.service';
+import { AuthModule } from './modules/auth/auth.module';
 import { InputsClientService } from './clients/inputs/client.service';
 import { TransformationsClientService } from './clients/transformations/client.service';
 import { OutputsClientService } from './clients/outputs/client.service';
 import { PipelinesClientService } from './clients/pipelines/client.service';
-import { PermissionsClientService } from './clients/permissions/client.service';
+import { PermissionsModule } from './modules/permissions/permissions.module';
 
 import { OutputsClientConfiguration } from './clients/outputs/client.config';
 import { TransformationsClientConfiguration } from './clients/transformations/client.config';
-import { DucClient } from './clients/duc/client.config';
 import { InputsClientConfiguration } from './clients/inputs/client.config';
 import { PipelinesClientConfiguration } from './clients/pipelines/client.config';
 import { CatalogController } from './modules/catalog/catalog.controller';
@@ -42,7 +41,6 @@ import { ConnectorClientConfiguration } from './clients/connector/client.config'
 import { ConnectorController } from './modules/connector/connector.controller';
 import { ConnectorClientService } from './clients/connector/client.service';
 
-const ducClient = new DucClient();
 const inputClient = new InputsClientConfiguration();
 const outputClient = new OutputsClientConfiguration();
 const pipelineClient = new PipelinesClientConfiguration();
@@ -55,13 +53,13 @@ const connectorClient = new ConnectorClientConfiguration();
     TransformationsController,
     OutputsController,
     PipelinesController,
-    AuthController,
     HealthController,
     CatalogController,
     OauthController,
     ConnectorController,
   ],
   providers: [
+    DadosferaLogger,
     { provide: 'OAUTH_SECRETS', useValue: getOauthSecrets() },
     InputsService,
     TransformationsService,
@@ -73,8 +71,6 @@ const connectorClient = new ConnectorClientConfiguration();
     TransformationsClientService,
     OutputsClientService,
     PipelinesClientService,
-    AuthClientService,
-    PermissionsClientService,
     CatalogService,
     HubspotStrategy,
     FacebookStrategy,
@@ -90,6 +86,8 @@ const connectorClient = new ConnectorClientConfiguration();
     ConfigModule.forRoot({
       isGlobal: true,
     }),
+    AuthModule,
+    PermissionsModule,
 
     ClientsModule.register([
       {
@@ -104,10 +102,6 @@ const connectorClient = new ConnectorClientConfiguration();
         name: 'OUTPUTS_PACKAGE',
         ...outputClient.config(),
       },
-      {
-        name: 'DUC_PACKAGE',
-        ...ducClient.config(),
-      },
       {
         name: 'PIPELINES_PACKAGE',
         ...pipelineClient.config(),

src/authentication/authentication.decorator.ts

@@ -1,28 +1,52 @@
-import { SetMetadata, applyDecorators } from '@nestjs/common';
 import { Request } from 'express';
+import { CustomDecorator } from '@nestjs/common';
 import { Permission } from './permissions.enum';
+import { RequestUser } from './user.decorator';
 
-export const PERMISSIONS_KEY = '__PERMISSIONS__';
-export const MUST_BE_AUTHENTICATED_KEY = '__MUST_BE_AUTHENTICATED__';
-export const CUSTOM_AUTHENTICATION_FUNCTION_KEY =
-  '__CUSTOM_AUTHENTICATION_FUNCTION__';
+export const AUTH_FUNCTION_KEY = '__AUTH_FUNCTION__';
 
 export type AuthenticationFunction = (req: Request, user: any) => boolean;
 
-export function RequirePermissions(...permissions: Permission[]) {
-  return applyDecorators(
-    SetMetadata(PERMISSIONS_KEY, permissions),
-    SetMetadata(MUST_BE_AUTHENTICATED_KEY, true),
+// implementation copied from SetMetadata, but tweaked to get existing values
+// of the metadataKey and accumulate it with the new metadataValue
+function SetMultipleMetadata(metadataKey, metadataValue): CustomDecorator {
+  const decoratorFactory = (target, key, descriptor) => {
+    // .start: tweak
+    // descriptor?.value = function decorator; target = class decorator
+    const accumulatedVal =
+      Reflect.getMetadata(metadataKey, descriptor?.value ?? target) ?? [];
+    accumulatedVal.push(metadataValue);
+    // .end: tweak
+
+    if (descriptor) {
+      Reflect.defineMetadata(metadataKey, accumulatedVal, descriptor.value);
+      return descriptor;
+    }
+
+    Reflect.defineMetadata(metadataKey, accumulatedVal, target);
+    return target;
+  };
+
+  decoratorFactory.KEY = metadataKey;
+  return decoratorFactory as any;
+}
+
+export function RequireAllPermissions(...permissions: Permission[]) {
+  return SetMultipleMetadata(AUTH_FUNCTION_KEY, (req, user: RequestUser) =>
+    permissions.every(({ seqid }) => user.permissions.includes(seqid)),
+  );
+}
+
+export function RequireSomePermission(...permissions: Permission[]) {
+  return SetMultipleMetadata(AUTH_FUNCTION_KEY, (req, user: RequestUser) =>
+    permissions.some(({ seqid }) => user.permissions.includes(seqid)),
   );
 }
 
 export function AuthenticateCondition(func: AuthenticationFunction) {
-  return applyDecorators(
-    SetMetadata(CUSTOM_AUTHENTICATION_FUNCTION_KEY, func),
-    SetMetadata(MUST_BE_AUTHENTICATED_KEY, true),
-  );
+  return SetMultipleMetadata(AUTH_FUNCTION_KEY, func);
 }
 
 export function Authenticated() {
-  return SetMetadata(MUST_BE_AUTHENTICATED_KEY, true);
+  return SetMultipleMetadata(AUTH_FUNCTION_KEY, () => true);
 }

src/authentication/authentication.guard.spec.ts

@@ -0,0 +1,447 @@
+import request from 'supertest';
+import { Test } from '@nestjs/testing';
+import { HttpStatus, INestApplication } from '@nestjs/common';
+import { APP_GUARD } from '@nestjs/core';
+import jwt from 'jsonwebtoken';
+
+import { Body, Controller, Get } from '@nestjs/common';
+import { DadosferaLogger } from 'dadosfera-logs';
+import {
+  AuthenticateCondition,
+  Authenticated,
+  RequireAllPermissions,
+  RequireSomePermission,
+} from './authentication.decorator';
+import { AuthenticationGuard } from './authentication.guard';
+import { Permissions } from './permissions.enum';
+import { AuthClientService } from '../modules/auth/auth.service';
+
+import ErrorCodes from '../utils/errorCodes';
+
+@Controller('no-class-auth')
+class NoClassAuthController {
+  @Get('body')
+  async getBody(@Body() body) {
+    return { body };
+  }
+
+  @Get('authenticated')
+  @Authenticated()
+  async mustBeAuthenticated(@Body() body) {
+    return { body };
+  }
+
+  @Get('required-permission')
+  @RequireSomePermission(Permissions.ZENDESK.OPEN)
+  async requiredPermission(@Body() body) {
+    return { body };
+  }
+
+  @Get('has-all-permissions')
+  @RequireAllPermissions(Permissions.ZENDESK.OPEN, Permissions.METABASE.OPEN)
+  async hasAllPermissions(@Body() body) {
+    return { body };
+  }
+
+  @Get('has-some-permission')
+  @RequireSomePermission(Permissions.ZENDESK.OPEN, Permissions.METABASE.OPEN)
+  async hasSomePermission(@Body() body) {
+    return { body };
+  }
+}
+
+@Controller('class-auth-condition')
+@AuthenticateCondition((req) => req.get('x-on-class') === 'ok')
+@RequireSomePermission(Permissions.METABASE.OPEN)
+class ClassAuthConditionController {
+  @Get('body')
+  async getBody(@Body() body) {
+    return { body };
+  }
+
+  @Get('authenticated')
+  @Authenticated()
+  async mustBeAuthenticated(@Body() body) {
+    return { body };
+  }
+
+  @Get('required-permission')
+  @AuthenticateCondition((req) => req.get('x-on-route') === 'ok')
+  @RequireSomePermission(Permissions.ZENDESK.OPEN)
+  async requiredPermission(@Body() body) {
+    return { body };
+  }
+}
+
+describe('authentication.guard', () => {
+  let app: INestApplication;
+  const jwtSecretA = {
+    kid: 'token-a-testing-shared-key',
+    pem: '$tr0ng-SH4Red-secr3t!!!~gl0ba1~]',
+  };
+  const jwtSecretB = {
+    kid: 'token-b',
+    pem: 'another-shared-token',
+  };
+  const fakeUserPayload = {
+    user_id: 'd50d33c7-6c2b-463c-861f-e21667e7c125',
+    username: 'super.admin',
+    customer_id: '9d18e8ae-24b9-41a3-9e8f-a25ce57555b11',
+    customer_name: 'dadosfera',
+    customer_tier: 'BASIC',
+  };
+
+  beforeAll(async () => {
+    const moduleRef = await Test.createTestingModule({
+      providers: [
+        {
+          provide: AuthClientService,
+          useValue: {
+            getPublicKeys: async () => ({
+              keys: [jwtSecretA, jwtSecretB],
+            }),
+          },
+        },
+        {
+          provide: DadosferaLogger,
+          useValue: { logger: console },
+        },
+        {
+          provide: APP_GUARD,
+          useClass: AuthenticationGuard,
+        },
+      ],
+      controllers: [NoClassAuthController, ClassAuthConditionController],
+    }).compile();
+
+    app = moduleRef.createNestApplication();
+    await app.init();
+  });
+
+  afterAll(async () => {
+    await app.close();
+  });
+
+  function AssertBodyNoAuth(res: request.Response) {
+    expect(res.statusCode).toBe(HttpStatus.OK);
+    expect(res.body).toStrictEqual({ body: {} });
+  }
+
+  function AssertBodyWithAuth(res: request.Response) {
+    expect(res.statusCode).toBe(HttpStatus.OK);
+    expect(res.body).toStrictEqual({
+      body: {
+        info: {
+          customer: 'dadosfera',
+          customer_id: '9d18e8ae-24b9-41a3-9e8f-a25ce57555b11',
+          customer_tier: 'BASIC',
+          user_id: 'd50d33c7-6c2b-463c-861f-e21667e7c125',
+        },
+      },
+    });
+  }
+
+  function AssertUnauthorized(res: request.Response) {
+    expect(res.statusCode).toBe(HttpStatus.UNAUTHORIZED);
+    expect(res.body).toStrictEqual({
+      code: ErrorCodes.AUTH.UNAUTHORIZED,
+      error: 'Não autenticado',
+      message: 'É necessário estar logado para realizar essa operação',
+      statusCode: HttpStatus.UNAUTHORIZED,
+    });
+  }
+
+  function AssertForbidden(res: request.Response) {
+    expect(res.statusCode).toBe(HttpStatus.FORBIDDEN);
+    expect(res.body).toStrictEqual({
+      code: ErrorCodes.AUTH.FORBIDDEN,
+      error: 'Não autorizado',
+      message:
+        'Você não tem permissões suficientes para realizar essa operação',
+      statusCode: HttpStatus.FORBIDDEN,
+    });
+  }
+
+  function NoClassAuthTest(accessToken: string, tokenName: string[]) {
+    const route = '/no-class-auth';
+
+    describe(`${route}, ${tokenName?.length ? tokenName : 'none'} auth`, () => {
+      it('should GET /body with user data (if available)', async () => {
+        const res = await request(app.getHttpServer())
+          .get(`${route}/body`)
+          .set({ Authorization: accessToken });
+
+        if (tokenName?.length) {
+          AssertBodyWithAuth(res);
+        } else {
+          AssertBodyNoAuth(res);
+        }
+      });
+
+      it('should GET /authenticated if authenticated', async () => {
+        const res = await request(app.getHttpServer())
+          .get(`${route}/authenticated`)
+          .set({ Authorization: accessToken });
+
+        if (tokenName?.length) {
+          AssertBodyWithAuth(res);
+        } else {
+          AssertUnauthorized(res);
+        }
+      });
+
+      it('should GET /required-permission if authenticated', async () => {
+        const res = await request(app.getHttpServer())
+          .get(`${route}/required-permission`)
+          .set({ Authorization: accessToken });
+
+        // zendesk required
+        if (tokenName?.includes('zendesk')) {
+          AssertBodyWithAuth(res);
+        } else if (tokenName?.length) {
+          AssertForbidden(res);
+        } else {
+          AssertUnauthorized(res);
+        }
+      });
+
+      it('should GET /has-all-permissions if authenticated', async () => {
+        const res = await request(app.getHttpServer())
+          .get(`${route}/has-all-permissions`)
+          .set({ Authorization: accessToken });
+
+        // zendesk and metabase
+        if (tokenName?.includes('zendesk') && tokenName?.includes('metabase')) {
+          AssertBodyWithAuth(res);
+        } else if (tokenName?.length) {
+          AssertForbidden(res);
+        } else {
+          AssertUnauthorized(res);
+        }
+      });
+
+      it('should GET /has-some-permission if authenticated', async () => {
+        const res = await request(app.getHttpServer())
+          .get(`${route}/has-some-permission`)
+          .set({ Authorization: accessToken });
+
+        // zendesk or metabase
+        if (tokenName?.includes('zendesk') || tokenName?.includes('metabase')) {
+          AssertBodyWithAuth(res);
+        } else if (tokenName?.length) {
+          AssertForbidden(res);
+        } else {
+          AssertUnauthorized(res);
+        }
+      });
+    });
+  }
+
+  function ClassAuthConditionTest(accessToken: string, tokenName: string[]) {
+    const route = '/class-auth-condition';
+
+    describe(`${route}, ${tokenName?.length ? tokenName : 'none'} auth`, () => {
+      describe('GET /body', () => {
+        it('should GET /body if authenticated and with correct headers', async () => {
+          const res = await request(app.getHttpServer())
+            .get(`${route}/body`)
+            .set({
+              'x-on-class': 'ok',
+              Authorization: accessToken,
+            });
+
+          // metabase required
+          if (tokenName?.includes('metabase')) {
+            AssertBodyWithAuth(res);
+          } else if (tokenName?.length) {
+            AssertForbidden(res);
+          } else {
+            AssertUnauthorized(res);
+          }
+        });
+
+        it('should not GET /body without correct headers', async () => {
+          const res = await request(app.getHttpServer())
+            .get(`${route}/body`)
+            .set({ Authorization: accessToken });
+
+          if (tokenName?.length) {
+            AssertForbidden(res);
+          } else {
+            AssertUnauthorized(res);
+          }
+        });
+      });
+
+      describe('GET /authenticated', () => {
+        it('should GET /authenticated if authenticated and with correct headers', async () => {
+          const res = await request(app.getHttpServer())
+            .get(`${route}/authenticated`)
+            .set({
+              'x-on-class': 'ok',
+              Authorization: accessToken,
+            });
+
+          // metabase required
+          if (tokenName?.includes('metabase')) {
+            AssertBodyWithAuth(res);
+          } else if (tokenName?.length) {
+            AssertForbidden(res);
+          } else {
+            AssertUnauthorized(res);
+          }
+        });
+
+        it('should not GET /authenticated without correct class headers', async () => {
+          const res = await request(app.getHttpServer())
+            .get(`${route}/authenticated`)
+            .set({ Authorization: accessToken });
+
+          if (tokenName?.length) {
+            AssertForbidden(res);
+          } else {
+            AssertUnauthorized(res);
+          }
+        });
+      });
+
+      describe('GET /required-permission', () => {
+        it('should GET /required-permission if authenticated and with correct headers', async () => {
+          const res = await request(app.getHttpServer())
+            .get(`${route}/required-permission`)
+            .set({
+              'x-on-class': 'ok',
+              'x-on-route': 'ok',
+              Authorization: accessToken,
+            });
+
+          // zendesk and metabase
+          if (
+            tokenName?.includes('zendesk') &&
+            tokenName?.includes('metabase')
+          ) {
+            AssertBodyWithAuth(res);
+          } else if (tokenName?.length) {
+            AssertForbidden(res);
+          } else {
+            AssertUnauthorized(res);
+          }
+        });
+
+        it('should not GET /required-permission without correct route headers', async () => {
+          const res = await request(app.getHttpServer())
+            .get(`${route}/required-permission`)
+            .set({
+              'x-on-class': 'ok',
+              Authorization: accessToken,
+            });
+
+          if (tokenName?.length) {
+            AssertForbidden(res);
+          } else {
+            AssertUnauthorized(res);
+          }
+        });
+
+        it('should not GET /required-permission without correct class headers', async () => {
+          const res = await request(app.getHttpServer())
+            .get(`${route}/required-permission`)
+            .set({
+              'x-on-route': 'ok',
+              Authorization: accessToken,
+            });
+
+          if (tokenName?.length) {
+            AssertForbidden(res);
+          } else {
+            AssertUnauthorized(res);
+          }
+        });
+      });
+    });
+  }
+
+  describe('token validation', () => {
+    it('should accept token kid A', async () => {
+      const Authorization = CreateToken([], {
+        jwt: {
+          kid: jwtSecretA.kid,
+          pem: jwtSecretA.pem,
+        },
+      });
+
+      const res = await request(app.getHttpServer())
+        .get('/no-class-auth/authenticated')
+        .set({
+          Authorization,
+        });
+
+      AssertBodyWithAuth(res);
+    });
+
+    it('should accept token kid B', async () => {
+      const Authorization = CreateToken([], {
+        jwt: {
+          kid: jwtSecretB.kid,
+          pem: jwtSecretB.pem,
+        },
+      });
+
+      const res = await request(app.getHttpServer())
+        .get('/no-class-auth/authenticated')
+        .set({
+          Authorization,
+        });
+
+      AssertBodyWithAuth(res);
+    });
+
+    it('should not accept unknown kid', async () => {
+      const Authorization = CreateToken([], {
+        jwt: {
+          kid: 'unknown-key-id',
+          pem: jwtSecretA.pem,
+        },
+      });
+
+      const res = await request(app.getHttpServer())
+        .get('/no-class-auth/authenticated')
+        .set({
+          Authorization,
+        });
+
+      AssertUnauthorized(res);
+    });
+  });
+
+  function CreateToken(permissions, overrides?: { user?: any; jwt?: any }) {
+    const tokenPayload = {
+      ...fakeUserPayload,
+      permissions: permissions.map(({ seqid }) => seqid),
+      token_use: 'access',
+      ...overrides?.user,
+    };
+
+    return jwt.sign(tokenPayload, overrides?.jwt?.pem ?? jwtSecretA.pem, {
+      keyid: overrides?.jwt?.kid ?? jwtSecretA.kid,
+    });
+  }
+
+  NoClassAuthTest(null, null);
+  ClassAuthConditionTest(null, null);
+
+  const tokenZ = CreateToken([Permissions.ZENDESK.OPEN]);
+  NoClassAuthTest(tokenZ, ['zendesk']);
+  ClassAuthConditionTest(tokenZ, ['zendesk']);
+
+  const tokenM = CreateToken([Permissions.METABASE.OPEN]);
+  NoClassAuthTest(tokenM, ['metabase']);
+  ClassAuthConditionTest(tokenM, ['metabase']);
+
+  const tokenZM = CreateToken([
+    Permissions.ZENDESK.OPEN,
+    Permissions.METABASE.OPEN,
+  ]);
+  NoClassAuthTest(tokenZM, ['zendesk', 'metabase']);
+  ClassAuthConditionTest(tokenZM, ['zendesk', 'metabase']);
+});

src/authentication/authentication.guard.ts

@@ -4,19 +4,18 @@ import {
   OnApplicationBootstrap,
   ExecutionContext,
   Logger,
+  Inject,
 } from '@nestjs/common';
 import { Reflector } from '@nestjs/core';
 import assert from 'assert';
 import jwt from 'jsonwebtoken';
-
-import { AuthClientService } from '../clients/auth/client.service';
-import { Permission } from './permissions.enum';
+import { DadosferaLogger } from 'dadosfera-logs';
+import { AuthClientService } from '../modules/auth/auth.service';
 import {
   AuthenticationFunction,
-  PERMISSIONS_KEY,
-  CUSTOM_AUTHENTICATION_FUNCTION_KEY,
-  MUST_BE_AUTHENTICATED_KEY,
+  AUTH_FUNCTION_KEY,
 } from './authentication.decorator';
+import { RequestUser } from './user.decorator';
 import ErrorBuilder from '../utils/ErrorBuilder';
 import ErrorCodes from '../utils/errorCodes';
 
@@ -24,22 +23,25 @@ import ErrorCodes from '../utils/errorCodes';
 export class AuthenticationGuard
   implements CanActivate, OnApplicationBootstrap
 {
-  private readonly logger = new Logger(AuthenticationGuard.name);
+  logger: any;
 
   pems: Map<string, string>;
 
   constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
     private reflector: Reflector,
     private authClient: AuthClientService,
   ) {
     this.pems = new Map();
+    this.logger = dadosferaLogger.logger;
   }
 
   async onApplicationBootstrap() {
     return this.loadDucJWKS();
   }
 
-  async loadDucJWKS() {
+  private async loadDucJWKS() {
     const { keys } = await this.authClient.getPublicKeys();
 
     keys.forEach((key) => {
@@ -48,57 +50,38 @@ export class AuthenticationGuard
   }
 
   canActivate(ctx: ExecutionContext): boolean {
-    const requiredPermissions = this.reflector.getAllAndOverride<Permission[]>(
-      PERMISSIONS_KEY,
-      [ctx.getHandler(), ctx.getClass()],
-    );
-    const customAuthenticationFunction =
-      this.reflector.getAllAndOverride<AuthenticationFunction>(
-        CUSTOM_AUTHENTICATION_FUNCTION_KEY,
-        [ctx.getHandler(), ctx.getClass()],
-      );
-    const mustBeAuthenticated = this.reflector.getAllAndOverride<boolean>(
-      MUST_BE_AUTHENTICATED_KEY,
-      [ctx.getHandler(), ctx.getClass()],
-    );
+    const authFunctions = this.reflector.getAllAndMerge<
+      AuthenticationFunction[]
+    >(AUTH_FUNCTION_KEY, [ctx.getClass(), ctx.getHandler()]);
+    const mustBeAuthenticated = authFunctions.length > 0;
 
     const request = ctx.switchToHttp().getRequest();
-    const accessToken = this.verifyToken(request, mustBeAuthenticated);
+    const accessToken = this.validateToken(request, mustBeAuthenticated);
+
+    if (!mustBeAuthenticated) {
+      // no need to be authenticated
+      return true;
+    }
 
     if (!accessToken) {
       // couldn't load valid token
-
-      if (!mustBeAuthenticated) {
-        // no need to be authenticated
-        return true;
-      }
-
       throw new ErrorBuilder(ErrorCodes.AUTH.UNAUTHORIZED);
     }
 
-    if (
-      typeof customAuthenticationFunction === 'function' &&
-      !customAuthenticationFunction(request, request.user)
-    ) {
-      // custom authentication function forbidden this request
-      throw new ErrorBuilder(ErrorCodes.AUTH.FORBIDDEN);
-    }
-
-    if (
-      Array.isArray(requiredPermissions) &&
-      requiredPermissions.length > 0 &&
-      !this.matchPermissions(requiredPermissions, accessToken.permissions)
-    ) {
-      // couldn't match permissions
+    // every authentication function must return true to authenticate
+    if (!authFunctions.every((func) => func(request, accessToken))) {
       throw new ErrorBuilder(ErrorCodes.AUTH.FORBIDDEN);
     }
 
     return true;
   }
 
-  private verifyToken(request, mustBeAuthenticated: boolean) {
+  private validateToken(
+    request,
+    mustBeAuthenticated: boolean,
+  ): RequestUser | false {
     const accessToken = request.get('Authorization');
-    let accessTokenPayload;
+    let accessTokenPayload: RequestUser;
 
     // If the user isn't authenticated, an error will occurr anywhere here.
     // Fancy error avoidance isn't performed by purpose, such as avoiding to access null values.
@@ -125,7 +108,7 @@ export class AuthenticationGuard
     } catch (err) {
       // log errors if authentication is required
       if (mustBeAuthenticated) {
-        this.logger.log('Unable to verify duc access token\n' + err.stack);
+        this.logger.error('Unable to verify duc access token\n' + err.stack);
       }
 
       return false;
@@ -150,13 +133,4 @@ export class AuthenticationGuard
 
     return accessTokenPayload;
   }
-
-  private matchPermissions(
-    requiredPermissions: Permission[],
-    userPermissions: number[],
-  ) {
-    return requiredPermissions.some((permission) =>
-      userPermissions.includes(permission.seqid),
-    );
-  }
 }

src/authentication/user.decorator.spec.ts

@@ -0,0 +1,174 @@
+import request from 'supertest';
+import { Test } from '@nestjs/testing';
+import { HttpStatus, INestApplication } from '@nestjs/common';
+import { APP_GUARD } from '@nestjs/core';
+import jwt from 'jsonwebtoken';
+
+import { Controller, Get } from '@nestjs/common';
+import { DadosferaLogger } from 'dadosfera-logs';
+import { AuthenticationGuard } from './authentication.guard';
+import { AuthClientService } from '../modules/auth/auth.service';
+
+import ErrorCodes from '../utils/errorCodes';
+import { User } from './user.decorator';
+import { Permissions } from './permissions.enum';
+
+@Controller('user')
+class UserController {
+  @Get()
+  public getUser(@User() user) {
+    return { user };
+  }
+
+  @Get('options')
+  public getUserWithOptions(@User({}) user) {
+    return { user };
+  }
+
+  @Get('not-required')
+  public getUserNotRequired(@User({ required: false }) user) {
+    return { user };
+  }
+
+  @Get('required')
+  public getUserRequired(@User({ required: true }) user) {
+    return { user };
+  }
+}
+
+describe('user.decorator', () => {
+  let app: INestApplication;
+  const jwt_secret = {
+    kid: 'token-testing-shared-key',
+    pem: '$tr0ng-SH4Red-secr3t!!!~gl0ba1~]',
+  };
+  const fakeUserPayload = {
+    user_id: 'd50d33c7-6c2b-463c-861f-e21667e7c125',
+    username: 'super.admin',
+    permissions: [Permissions.METABASE.OPEN].map(({ seqid }) => seqid),
+    customer_id: '9d18e8ae-24b9-41a3-9e8f-a25ce57555b11',
+    customer_name: 'dadosfera',
+    customer_tier: 'BASIC',
+  };
+
+  beforeAll(async () => {
+    const moduleRef = await Test.createTestingModule({
+      providers: [
+        {
+          provide: AuthClientService,
+          useValue: {
+            getPublicKeys: async () => ({
+              keys: [jwt_secret],
+            }),
+          },
+        },
+        {
+          provide: DadosferaLogger,
+          useValue: { logger: console },
+        },
+        {
+          provide: APP_GUARD,
+          useClass: AuthenticationGuard,
+        },
+      ],
+      controllers: [UserController],
+    }).compile();
+
+    app = moduleRef.createNestApplication();
+    await app.init();
+  });
+
+  afterAll(async () => {
+    await app.close();
+  });
+
+  function AssertNoAuth(res: request.Response) {
+    expect(res.statusCode).toBe(HttpStatus.OK);
+    expect(res.body).toStrictEqual({});
+  }
+
+  function AssertWithAuth(res: request.Response) {
+    expect(res.statusCode).toBe(HttpStatus.OK);
+    expect(res.body).toStrictEqual({ user: fakeUserPayload });
+  }
+
+  function AssertRequiredNoAuth(res: request.Response) {
+    expect(res.statusCode).toBe(HttpStatus.UNAUTHORIZED);
+    expect(res.body).toStrictEqual({
+      code: ErrorCodes.AUTH.UNAUTHORIZED,
+      error: 'Não autenticado',
+      message: 'É necessário estar logado para realizar essa operação',
+      statusCode: HttpStatus.UNAUTHORIZED,
+    });
+  }
+
+  function UserTest(accessToken: string) {
+    describe(`with${accessToken ? '' : 'out'} token`, () => {
+      it('should GET /user', async () => {
+        const res = await request(app.getHttpServer())
+          .get('/user')
+          .set({ Authorization: accessToken });
+
+        if (accessToken) {
+          AssertWithAuth(res);
+        } else {
+          AssertNoAuth(res);
+        }
+      });
+
+      it('should GET /user/options', async () => {
+        const res = await request(app.getHttpServer())
+          .get('/user/options')
+          .set({ Authorization: accessToken });
+
+        if (accessToken) {
+          AssertWithAuth(res);
+        } else {
+          AssertNoAuth(res);
+        }
+      });
+
+      it('should GET /user/not-required', async () => {
+        const res = await request(app.getHttpServer())
+          .get('/user/not-required')
+          .set({ Authorization: accessToken });
+
+        if (accessToken) {
+          AssertWithAuth(res);
+        } else {
+          AssertNoAuth(res);
+        }
+      });
+
+      it('should GET /user/required if logged', async () => {
+        const res = await request(app.getHttpServer())
+          .get('/user/required')
+          .set({ Authorization: accessToken });
+
+        if (accessToken) {
+          AssertWithAuth(res);
+        } else {
+          AssertRequiredNoAuth(res);
+        }
+      });
+    });
+  }
+
+  function CreateToken(overrides?) {
+    const tokenPayload = {
+      ...fakeUserPayload,
+      token_use: 'access',
+      ...overrides?.user,
+    };
+
+    return jwt.sign(tokenPayload, jwt_secret.pem, {
+      keyid: jwt_secret.kid,
+      ...overrides?.jwt,
+    });
+  }
+
+  UserTest(null);
+
+  const token = CreateToken();
+  UserTest(token);
+});

src/authentication/user.decorator.ts

@@ -6,18 +6,19 @@ import ErrorCodes from '../utils/errorCodes';
 export interface RequestUser {
   user_id: string;
   username: string;
-  permissions: string;
+  permissions: number[];
   customer_id: string;
   customer_name: string;
   customer_tier: string;
 }
 
-export const User = createParamDecorator((data: any, ctx: ExecutionContext) => {
-  const request = ctx.switchToHttp().getRequest();
+export const User: (options?: { required?: boolean }) => ParameterDecorator =
+  createParamDecorator((options: any, ctx: ExecutionContext) => {
+    const request = ctx.switchToHttp().getRequest();
 
-  if (!request.user && data?.required) {
-    throw new ErrorBuilder(ErrorCodes.AUTH.UNAUTHORIZED);
-  }
+    if (!request.user && options?.required) {
+      throw new ErrorBuilder(ErrorCodes.AUTH.UNAUTHORIZED);
+    }
 
-  return request.user;
-});
+    return request.user;
+  });

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

@@ -4,16 +4,22 @@ import {
   HttpException,
   HttpStatus,
 } from '@nestjs/common';
+import { DadosferaLogger } from 'dadosfera-logs';
 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 {
   private connectorServiceRead: ConnectorManager.ReadService.ConnectorManagerReadServices;
   private connectorServiceWrite: ConnectorManager.WriteService.ConnectorManagerWriteServices;
+  logger: any;
   constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
     @Inject('CONNECTOR_PACKAGE') private readonly grpcClient: ClientGrpc,
-  ) {}
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   onModuleInit() {
     this.connectorServiceWrite =
@@ -49,22 +55,27 @@ export class ConnectorClientService implements OnModuleInit {
           resolve(x);
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          //console.log('done');
         },
       });
-    }).catch((err) => {
-      console.log(err.details);
-      throw new HttpException(
-        err.details,
-        err.code === 6 ? HttpStatus.CONFLICT : 400,
-      );
-    });
+    })
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
+      .catch((err) => {
+        this.logger.error(err.details);
+        this.logger.error(err);
+        throw new HttpException(
+          err.details,
+          err.code === 6 ? HttpStatus.CONFLICT : 400,
+        );
+      });
 
-    console.log('ConnectorClientService', 'Upload');
+    this.logger.info('ConnectorClientService - Upload');
 
     return result;
   }
@@ -86,22 +97,27 @@ export class ConnectorClientService implements OnModuleInit {
           resolve(x);
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          //console.log('done');
         },
       });
-    }).catch((err) => {
-      console.log(err.details);
-      throw new HttpException(
-        err.details,
-        err.code === 6 ? HttpStatus.CONFLICT : 400,
-      );
-    });
+    })
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
+      .catch((err) => {
+        this.logger.error(err.details);
+        this.logger.error(err);
+        throw new HttpException(
+          err.details,
+          err.code === 6 ? HttpStatus.CONFLICT : 400,
+        );
+      });
 
-    console.log('ConnectorClientService', 'Upload');
+    this.logger.info('ConnectorClientService - Upload');
 
     return result;
   }
@@ -119,21 +135,26 @@ export class ConnectorClientService implements OnModuleInit {
           resolve(x);
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          //console.log('done');
         },
       });
-    }).catch((err) => {
-      throw new HttpException(
-        err.details,
-        err.code === 6 ? HttpStatus.CONFLICT : 400,
-      );
-    });
+    })
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
+      .catch((err) => {
+        this.logger.error(err);
+        throw new HttpException(
+          err.details,
+          err.code === 6 ? HttpStatus.CONFLICT : 400,
+        );
+      });
 
-    console.log('ConnectorClientService', 'getAllConnectors');
+    this.logger.info('ConnectorClientService - getAllConnectors');
 
     return result;
   }
@@ -150,21 +171,26 @@ export class ConnectorClientService implements OnModuleInit {
           resolve(x);
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          //console.log('done');
         },
       });
-    }).catch((err) => {
-      throw new HttpException(
-        err.details,
-        err.code === 6 ? HttpStatus.CONFLICT : 400,
-      );
-    });
+    })
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
+      .catch((err) => {
+        this.logger.error(err);
+        throw new HttpException(
+          err.details,
+          err.code === 6 ? HttpStatus.CONFLICT : 400,
+        );
+      });
 
-    console.log('ConnectorClientService', 'getAllConnectors');
+    this.logger.info('ConnectorClientService - getAllConnectors');
 
     return result;
   }
@@ -181,21 +207,26 @@ export class ConnectorClientService implements OnModuleInit {
           resolve(x);
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          //console.log('done');
         },
       });
-    }).catch((err) => {
-      throw new HttpException(
-        err.details,
-        err.code === 6 ? HttpStatus.CONFLICT : 400,
-      );
-    });
+    })
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
+      .catch((err) => {
+        this.logger.error(err);
+        throw new HttpException(
+          err.details,
+          err.code === 6 ? HttpStatus.CONFLICT : 400,
+        );
+      });
 
-    console.log('ConnectorClientService', 'getAllConnectors');
+    this.logger.info('ConnectorClientService - getAllConnectors');
 
     return result;
   }
@@ -213,21 +244,26 @@ export class ConnectorClientService implements OnModuleInit {
           resolve(x);
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          //console.log('done');
         },
       });
-    }).catch((err) => {
-      throw new HttpException(
-        err.details,
-        err.code === 6 ? HttpStatus.CONFLICT : 400,
-      );
-    });
+    })
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
+      .catch((err) => {
+        this.logger.error(err);
+        throw new HttpException(
+          err.details,
+          err.code === 6 ? HttpStatus.CONFLICT : 400,
+        );
+      });
 
-    console.log('ConnectorClientService', 'getAllConnectors');
+    this.logger.info('ConnectorClientService - getAllConnectors');
 
     return result;
   }
@@ -245,21 +281,26 @@ export class ConnectorClientService implements OnModuleInit {
           resolve(x);
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          //console.log('done');
         },
       });
-    }).catch((err) => {
-      throw new HttpException(
-        err.details,
-        err.code === 6 ? HttpStatus.CONFLICT : 400,
-      );
-    });
+    })
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
+      .catch((err) => {
+        this.logger.error(err);
+        throw new HttpException(
+          err.details,
+          err.code === 6 ? HttpStatus.CONFLICT : 400,
+        );
+      });
 
-    console.log('ConnectorClientService', 'getAllConnectors');
+    this.logger.info('ConnectorClientService - getAllConnectors');
 
     return result;
   }

src/clients/duc/client.config.ts

@@ -3,7 +3,7 @@ import { ClientOptions, Transport } from '@nestjs/microservices';
 import {
   ProtoPackages,
   ProtoPaths,
-} from '@victorradael/protospack-v2/dist/lib/Duc';
+} from 'protospack-v2/dist/lib/Duc';
 
 export class DucClient {
   config(): ClientOptions {

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';
@@ -24,16 +24,22 @@ import {
   objectSnakeToCamel,
 } from 'src/utils/CaseConverter';
 import { mustache } from 'src/utils/mustache';
+import { DadosferaLogger } from 'dadosfera-logs';
 import { OauthSecrets } from 'src/utils/OauthSecrets';
 import { URLSearchParams } from 'url';
 import { IIdRequest, UpdateInputRequest } from './interfaces';
 
 export class InputsClientService implements OnModuleInit {
   private inputService: InputService;
+  logger: any;
   constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
     @Inject('INPUTS_PACKAGE') private readonly grpcClient: ClientGrpc,
     @Inject('OAUTH_SECRETS') private readonly oauthSecrets: OauthSecrets,
-  ) {}
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   async onModuleInit() {
     this.inputService =
@@ -41,7 +47,7 @@ export class InputsClientService implements OnModuleInit {
   }
 
   async newCreate(createInputDto: InputNewCreateRequest) {
-    console.log('InputClientService', 'Create');
+    this.logger.info('InputClientService - Create');
 
     const input = await lastValueFrom(
       this.inputService.NewCreate(objectSnakeToCamel(createInputDto)),
@@ -51,7 +57,7 @@ export class InputsClientService implements OnModuleInit {
   }
 
   async createGeneric(createInputGeneric) {
-    console.log('InputClientService', 'Create');
+    this.logger.info('InputClientService - Create');
     const { info, ...data } = createInputGeneric;
     // data.credentials = await this.getInputTokens(data);
     if (data.options) delete data.options;
@@ -76,23 +82,24 @@ export class InputsClientService implements OnModuleInit {
   }
 
   async createS3Inputs(createInputDto: InputCreateS3Request) {
-    console.log('InputClientService', 'Create');
+    this.logger.info('InputClientService - Create');
     objectSnakeToCamel(createInputDto);
     const createInputResponse = await lastValueFrom(
       this.inputService.CreateS3(createInputDto),
     ).catch((e) => {
       throw new HttpException(e.details, 500);
     });
-    console.log('done');
+    this.logger.info('Done');
     objectCamelToSnake(createInputResponse);
     return createInputResponse;
   }
 
   async findOne(data: IIdRequest) {
-    console.log('InputClientService', 'FindOne');
+    this.logger.info('InputClientService - FindOne');
     const findOneInputResponse = await lastValueFrom(
       this.inputService.FindOne(objectSnakeToCamel(data)),
     ).catch((e) => {
+      this.logger.error(e.details);
       throw new HttpException(e.details, HttpStatus.INTERNAL_SERVER_ERROR);
     });
     objectCamelToSnake(findOneInputResponse);
@@ -100,10 +107,11 @@ export class InputsClientService implements OnModuleInit {
   }
 
   async findAll(data) {
-    console.log('InputClientService', 'FindAll');
+    this.logger.info('InputClientService - FindAll');
     const findAllInputResponse = await lastValueFrom(
       this.inputService.FindAll(objectSnakeToCamel(data)),
     ).catch((e) => {
+      this.logger.error(e.details);
       throw new HttpException(e.details, HttpStatus.INTERNAL_SERVER_ERROR);
     });
     findAllInputResponse.inputs.forEach((input) => objectCamelToSnake(input));
@@ -112,23 +120,26 @@ export class InputsClientService implements OnModuleInit {
   }
 
   async update(updateInputDTO: UpdateInputRequest) {
-    console.log('InputClientService', 'Update');
+    this.logger.info('InputClientService - Update');
     const updateInputResponse = await new Promise((resolve, reject) => {
       this.inputService.Update(objectSnakeToCamel(updateInputDTO)).subscribe({
         next(x) {
           resolve(objectCamelToSnake(x));
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          // console.log('done');
         },
       });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -136,7 +147,7 @@ export class InputsClientService implements OnModuleInit {
   }
 
   async remove(idRequest: IIdRequest) {
-    console.log('InputClientService', 'Remove');
+    this.logger.info('InputClientService - Remove');
 
     const removeInputResponse = await new Promise((resolve, reject) => {
       this.inputService.Remove(objectSnakeToCamel(idRequest)).subscribe({
@@ -144,16 +155,19 @@ export class InputsClientService implements OnModuleInit {
           resolve(objectCamelToSnake(x));
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          // console.log('done');
         },
       });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -161,23 +175,26 @@ export class InputsClientService implements OnModuleInit {
   }
 
   async testConnection(data: TestConnectionRequest) {
-    console.log('InputClientService', 'TestConnection');
+    this.logger.info('InputClientService - TestConnection');
     const testConnectionResponse = await new Promise((resolve, reject) => {
       this.inputService.NewTestConnection(objectSnakeToCamel(data)).subscribe({
         next(x) {
           resolve(objectCamelToSnake(x));
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          // console.log('done');
         },
       });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -185,23 +202,26 @@ export class InputsClientService implements OnModuleInit {
   }
 
   async getColumns(data: TestConnectionGetColumnsRequest) {
-    console.log('InputClientService', 'TestConnection/Get-Columns');
+    this.logger.info('InputClientService - TestConnection/Get-Columns');
     const getColumnsResponse = await new Promise((resolve, reject) => {
       this.inputService.GetColumns(objectSnakeToCamel(data)).subscribe({
         next(x) {
           resolve(objectCamelToSnake(x));
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          // console.log('done');
         },
       });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -260,7 +280,7 @@ export class InputsClientService implements OnModuleInit {
     };
 
     const { data } = await axios(axiosRequestConfig).catch((err) => {
-      console.log(err.response.data);
+      this.logger.error(err.response.data);
       throw new HttpException(err.response.data.message, err.response.status);
     });
     for (const key in get_tokens_set_response) {
@@ -273,12 +293,12 @@ export class InputsClientService implements OnModuleInit {
   }
 
   async getAvailableEntities(data) {
-    console.log('InputClientService', 'GetAvailableEntities');
+    this.logger.info('InputClientService - GetAvailableEntities');
     objectSnakeToCamel(data);
     const response = await lastValueFrom(
       this.inputService.GetAvailableEntities(data),
     ).catch((err) => {
-      console.log(err);
+      this.logger.info(err.details);
       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);

src/clients/inputs/interfaces.d.ts

@@ -29,8 +29,10 @@ interface Cron {
 }
 
 export interface Info {
-  costumer_id: string;
+  customer_id: string;
   user_id: string;
+  customer: string;
+  customer_tier: string;
 }
 
 export interface ICreateInputRequest {

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

@@ -1,9 +1,10 @@
 import { Controller, Inject, OnModuleInit } from '@nestjs/common';
 import { ClientGrpc, Payload } from '@nestjs/microservices';
+import { DadosferaLogger } from 'dadosfera-logs';
 import {
   OutputServicesNames,
   OutputsServiceInterface,
-} from '@victorradael/protospack';
+} from 'protospack';
 import {
   objectCamelToSnake,
   objectSnakeToCamel,
@@ -17,9 +18,14 @@ import {
 @Controller('output')
 export class OutputsClientService implements OnModuleInit {
   private outputService: OutputsServiceInterface;
+  logger: any;
   constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
     @Inject('OUTPUTS_PACKAGE') private readonly grpcClient: ClientGrpc,
-  ) {}
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   onModuleInit() {
     this.outputService = this.grpcClient.getService<OutputsServiceInterface>(
@@ -28,7 +34,7 @@ export class OutputsClientService implements OnModuleInit {
   }
 
   async create(@Payload() createOutputDto: ICreateOutputRequest) {
-    console.log('OutputClientService', 'Create');
+    this.logger.info('OutputClientService - Create');
 
     const createOutputResponse = await new Promise((resolve, reject) => {
       this.outputService.Create(objectSnakeToCamel(createOutputDto)).subscribe({
@@ -36,16 +42,19 @@ export class OutputsClientService implements OnModuleInit {
           resolve(x);
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          // console.log('done');
         },
       });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -55,7 +64,7 @@ export class OutputsClientService implements OnModuleInit {
   }
 
   async findAll(data) {
-    console.log('OutputClientService', 'FindAll');
+    this.logger.info('OutputClientService - FindAll');
 
     const findAllOutputResponse = await new Promise((resolve, reject) => {
       this.outputService.FindAll(objectSnakeToCamel(data)).subscribe({
@@ -63,16 +72,19 @@ export class OutputsClientService implements OnModuleInit {
           resolve(x);
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          // console.log('done');
         },
       });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -84,7 +96,7 @@ export class OutputsClientService implements OnModuleInit {
   }
 
   async findOne(data: IIdRequest) {
-    console.log('OutputClientService', 'FindOne');
+    this.logger.info('OutputClientService - FindOne');
 
     const findOneOutputResponse = await new Promise((resolve, reject) => {
       this.outputService.FindOne(objectSnakeToCamel(data)).subscribe({
@@ -92,16 +104,19 @@ export class OutputsClientService implements OnModuleInit {
           resolve(x);
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          // console.log('done');
         },
       });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -109,7 +124,7 @@ export class OutputsClientService implements OnModuleInit {
   }
 
   async update(updateOutPutDTO: IOutputUpdateRequest) {
-    console.log('OutputClientService', 'Update');
+    this.logger.info('OutputClientService - Update');
 
     const updateOutputResponse = await new Promise((resolve, reject) => {
       this.outputService.Update(objectSnakeToCamel(updateOutPutDTO)).subscribe({
@@ -117,16 +132,19 @@ export class OutputsClientService implements OnModuleInit {
           resolve(x);
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          // console.log('done');
         },
       });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -134,7 +152,7 @@ export class OutputsClientService implements OnModuleInit {
   }
 
   async remove(data: IIdRequest) {
-    console.log('OutputClientService', 'Remove');
+    this.logger.info('OutputClientService - Remove');
 
     const removeOutputResponse = await new Promise((resolve, reject) => {
       this.outputService.Remove(objectSnakeToCamel(data)).subscribe({
@@ -142,16 +160,19 @@ export class OutputsClientService implements OnModuleInit {
           resolve(objectCamelToSnake(x));
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          // console.log('done');
         },
       });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 

src/clients/permissions/client.service.ts

@@ -1,33 +0,0 @@
-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 {
-  Empty,
-  InjectPermissionsRequest,
-} from '@victorradael/protospack-v2/dist/lib/Duc/interfaces/messages';
-
-import grpcHandler from '../../utils/grpcHandler';
-
-export class PermissionsClientService implements OnModuleInit {
-  private readonly logger = new Logger(PermissionsClientService.name);
-
-  private permissionsService: PermissionsServiceInterface;
-  constructor(@Inject('DUC_PACKAGE') private readonly grpcClient: ClientGrpc) {}
-
-  onModuleInit() {
-    this.permissionsService =
-      this.grpcClient.getService<PermissionsServiceInterface>(
-        ProtoServices.PermissionsProtoService,
-      );
-  }
-
-  async injectPermissions({ permissions }: InjectPermissionsRequest) {
-    this.logger.log('InjectPermissions');
-
-    return grpcHandler<Empty>(
-      this.permissionsService.InjectPermissions({ permissions }),
-    );
-  }
-}

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

@@ -5,10 +5,7 @@ import {
   OnModuleInit,
 } from '@nestjs/common';
 import { ClientGrpc, Payload } from '@nestjs/microservices';
-import {
-  PipelineServicesNames,
-  PipelinesServiceInterface,
-} from '@victorradael/protospack';
+import { PipelineServicesNames, PipelinesServiceInterface } from 'protospack';
 import { lastValueFrom } from 'rxjs';
 import {
   objectCamelToSnake,
@@ -20,12 +17,18 @@ import {
   IIdRequest,
   IUpdatePipelineRequest,
 } from './interfaces';
+import { DadosferaLogger } from 'dadosfera-logs';
 
 export class PipelinesClientService implements OnModuleInit {
   private pipelineService: PipelinesServiceInterface;
+  logger: any;
   constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
     @Inject('PIPELINES_PACKAGE') private readonly grpcClient: ClientGrpc,
-  ) {}
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   onModuleInit() {
     this.pipelineService =
@@ -35,40 +38,47 @@ export class PipelinesClientService implements OnModuleInit {
   }
 
   async create(@Payload() createPipelineDto: ICreatePipelineDto) {
-    console.log('PipelinesClientService', 'Create');
+    this.logger.info('PipelinesClientService - Create');
     const createPipelineResponse = await lastValueFrom(
       this.pipelineService.Create(objectSnakeToCamel(createPipelineDto)),
-    ).catch((error: { details: string }) => {
-      if (error.details.includes('INVALID_REQUEST')) {
-        // eslint-disable-next-line @typescript-eslint/no-unused-vars
-        const [errorType, message] = error.details.split('|');
-        throw new BadRequestException(message);
-      }
-      throw new InternalServerErrorException(error.details);
-    });
+    )
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
+      .catch((error: { details: string }) => {
+        if (error.details.includes('INVALID_REQUEST')) {
+          // eslint-disable-next-line @typescript-eslint/no-unused-vars
+          const [errorType, message] = error.details.split('|');
+          throw new BadRequestException(message);
+        }
+        throw new InternalServerErrorException(error.details);
+      });
 
     return createPipelineResponse;
   }
 
   async findAll(data: IIdRequest) {
-    console.log('PipelinesClientService', 'FindAll');
-
+    this.logger.info('PipelinesClientService - FindAll');
     const findAllPipelineResponse = await new Promise((resolve, reject) => {
       this.pipelineService.FindAll(objectSnakeToCamel(data)).subscribe({
         next(x) {
           resolve(x.pipelines);
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          // console.log('done');
         },
       });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -76,7 +86,7 @@ export class PipelinesClientService implements OnModuleInit {
   }
 
   async findOne(data: IIdRequest) {
-    console.log('PipelinesClientService', 'FindOne');
+    this.logger.info('PipelinesClientService - FindOne');
 
     const findOnePipelineResponse = await new Promise((resolve, reject) => {
       this.pipelineService.FindOne(objectSnakeToCamel(data)).subscribe({
@@ -84,16 +94,19 @@ export class PipelinesClientService implements OnModuleInit {
           resolve(x);
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          // console.log('done');
         },
       });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -101,7 +114,7 @@ export class PipelinesClientService implements OnModuleInit {
   }
 
   async update(UpdatePipelineRequest: IUpdatePipelineRequest) {
-    console.log('PipelinesClientService', 'Update');
+    this.logger.info('PipelinesClientService - Update');
 
     const updatePipelineResponse = await new Promise((resolve, reject) => {
       this.pipelineService
@@ -111,16 +124,19 @@ export class PipelinesClientService implements OnModuleInit {
             resolve(x);
           },
           error(err) {
-            console.log('Observable Error');
             reject(err);
           },
           complete() {
-            console.log('done');
+            //console.log('done');
           },
         });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -128,7 +144,7 @@ export class PipelinesClientService implements OnModuleInit {
   }
 
   async remove(data: IIdRequest) {
-    console.log('PipelinesClientService', 'Remove');
+    this.logger.info('PipelinesClientService - Remove');
 
     const removePipelineResponse = await new Promise((resolve, reject) => {
       this.pipelineService.remove(objectSnakeToCamel(data)).subscribe({
@@ -136,16 +152,19 @@ export class PipelinesClientService implements OnModuleInit {
           resolve(objectCamelToSnake(x));
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          // this.logger.info('Done');
         },
       });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -153,7 +172,7 @@ export class PipelinesClientService implements OnModuleInit {
   }
 
   async getPipelineLogsMessages(data: IGetPipelineLogsRequest) {
-    console.log('PipelinesClientService', 'GetPipelineLogsMessages');
+    this.logger.info('PipelinesClientService - GetPipelineLogsMessages');
 
     const logsPipelineResponse = await new Promise((resolve, reject) => {
       this.pipelineService.getPipelineLogs(data).subscribe({
@@ -161,16 +180,19 @@ export class PipelinesClientService implements OnModuleInit {
           resolve(x);
         },
         error(err) {
-          console.log('Observable Error');
           reject(err);
         },
         complete() {
-          console.log('done');
+          // this.logger.info('Done');
         },
       });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -178,7 +200,7 @@ export class PipelinesClientService implements OnModuleInit {
   }
 
   async getPipelineStatus(data) {
-    console.log('PipelinesClientService', 'GetPipelineStatus');
+    this.logger.info('PipelinesClientService - GetPipelineStatus');
 
     const statusPipelineResponse = await new Promise((resolve, reject) => {
       this.pipelineService
@@ -195,16 +217,19 @@ export class PipelinesClientService implements OnModuleInit {
             resolve({ status: statusArray });
           },
           error(err) {
-            console.log('Observable Error');
             reject(err);
           },
           complete() {
-            console.log('done');
+            // this.logger.info('Done');
           },
         });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -212,7 +237,7 @@ export class PipelinesClientService implements OnModuleInit {
   }
 
   async runPipeline({ id, info }: IIdRequest) {
-    console.log('PipelinesClientService', 'RunPipeline');
+    this.logger.info('PipelinesClientService - RunPipeline');
     const statusPipelineResponse = await new Promise((resolve, reject) => {
       this.pipelineService
         .triggerPipeline(objectSnakeToCamel({ id, info }))
@@ -226,16 +251,20 @@ export class PipelinesClientService implements OnModuleInit {
             resolve(x);
           },
           error(err) {
-            console.log('Observable Error');
+            this.logger.error('Observable Error');
             reject(err);
           },
           complete() {
-            console.log('done');
+            this.logger.info('Done');
           },
         });
     })
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 

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,7 @@
 import { Controller, Inject, OnModuleInit, Post } from '@nestjs/common';
 import { ClientGrpc } from '@nestjs/microservices';
-import { TransformationsServiceInterface } from '@victorradael/protospack';
+import { TransformationsServiceInterface } from 'protospack';
+import { DadosferaLogger } from 'dadosfera-logs';
 import {
   objectCamelToSnake,
   objectSnakeToCamel,
@@ -10,9 +11,14 @@ import { ICreateTransformationsRequest, IIdRequest } from './interfaces';
 @Controller('transformation')
 export class TransformationsClientService implements OnModuleInit {
   private transformationService: TransformationsServiceInterface;
+  logger: any;
   constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
     @Inject('TRANSFORMATIONS_PACKAGE') private readonly grpcClient: ClientGrpc,
-  ) {}
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   onModuleInit() {
     this.transformationService =
@@ -23,7 +29,7 @@ export class TransformationsClientService implements OnModuleInit {
 
   @Post()
   async create(createTransformationsDto: ICreateTransformationsRequest) {
-    console.log('TransformationClientService', 'Create');
+    this.logger.info('TransformationClientService - Create');
 
     const createTransformationResponse = await new Promise(
       (resolve, reject) => {
@@ -34,17 +40,20 @@ export class TransformationsClientService implements OnModuleInit {
               resolve(x);
             },
             error(err) {
-              console.log('Observable Error');
               reject(err);
             },
             complete() {
-              console.log('done');
+              // console.log('done');
             },
           });
       },
     )
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -58,7 +67,7 @@ export class TransformationsClientService implements OnModuleInit {
   }
 
   async findAll(data) {
-    console.log('TransformationClientService', 'FindAll');
+    this.logger.info('TransformationClientService - FindAll');
 
     const findAllTransformationResponse = await new Promise(
       (resolve, reject) => {
@@ -67,17 +76,20 @@ export class TransformationsClientService implements OnModuleInit {
             resolve(x);
           },
           error(err) {
-            console.log('Observable Error');
             reject(err);
           },
           complete() {
-            console.log('done');
+            // console.log('done');
           },
         });
       },
     )
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
     const convertedTransforms = findAllTransformationResponse[
@@ -89,7 +101,7 @@ export class TransformationsClientService implements OnModuleInit {
   }
 
   async findOne(data: IIdRequest) {
-    console.log('TransformationClientService', 'FindOne');
+    this.logger.info('TransformationClientService - FindOne');
 
     const findOneTransformationResponse = await new Promise(
       (resolve, reject) => {
@@ -98,17 +110,20 @@ export class TransformationsClientService implements OnModuleInit {
             resolve(x);
           },
           error(err) {
-            console.log('Observable Error');
             reject(err);
           },
           complete() {
-            console.log('done');
+            // console.log('done');
           },
         });
       },
     )
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -116,7 +131,7 @@ export class TransformationsClientService implements OnModuleInit {
   }
 
   async update(updateTransformationDTO) {
-    console.log('TransformationClientService', 'Update');
+    this.logger.info('TransformationClientService - Update');
 
     const updateTransformationResponse = await new Promise(
       (resolve, reject) => {
@@ -127,17 +142,20 @@ export class TransformationsClientService implements OnModuleInit {
               resolve(x);
             },
             error(err) {
-              console.log('Observable Error');
               reject(err);
             },
             complete() {
-              console.log('done');
+              // console.log('done');
             },
           });
       },
     )
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 
@@ -145,7 +163,7 @@ export class TransformationsClientService implements OnModuleInit {
   }
 
   async remove(data: IIdRequest) {
-    console.log('TransformationClientService', 'Remove');
+    this.logger.info('TransformationClientService - Remove');
 
     const removeTransformationResponse = await new Promise(
       (resolve, reject) => {
@@ -154,17 +172,20 @@ export class TransformationsClientService implements OnModuleInit {
             resolve(x);
           },
           error(err) {
-            console.log('Observable Error');
             reject(err);
           },
           complete() {
-            console.log('done');
+            // console.log('done');
           },
         });
       },
     )
-      .then((res) => res)
+      .then((res) => {
+        this.logger.info('Done');
+        return res;
+      })
       .catch((err) => {
+        this.logger.error(err.message);
         throw new Error(err);
       });
 

src/error/grpc-to-http-exception.filter.ts

@@ -0,0 +1,22 @@
+import { ExceptionFilter, Catch, ArgumentsHost } from '@nestjs/common';
+import { Response } from 'express';
+
+import ErrorBuilder from '../utils/ErrorBuilder';
+
+@Catch(Error)
+export class GrpcToHttpExceptionFilter implements ExceptionFilter {
+  catch(exception: any, host: ArgumentsHost) {
+    const ctx = host.switchToHttp();
+    const response = ctx.getResponse<Response>();
+
+    // return this exception directly if is already of type ErrorBuilder,
+    // else transform it using the ErrorBuilder
+    const err =
+      exception.constructor.name === ErrorBuilder.name
+        ? exception
+        : new ErrorBuilder(exception.details);
+
+    const { statusCode } = err.response;
+    return response.status(statusCode).json(err.response);
+  }
+}

src/error/http-exception.filter.spec.ts

@@ -1,7 +0,0 @@
-import { HttpExceptionFilter } from './http-exception.filter';
-
-describe('HttpExceptionFilter', () => {
-  it('should be defined', () => {
-    expect(new HttpExceptionFilter()).toBeDefined();
-  });
-});

src/main.ts

@@ -1,13 +1,32 @@
+if (process.env.ENV !== 'local') require('elastic-apm-node/start');
 import { NestFactory } from '@nestjs/core';
 import { DocumentBuilder, SwaggerModule } from '@nestjs/swagger';
 import helmet from 'helmet';
+import { DadosferaLogger } from 'dadosfera-logs';
 
 import documentEmpty from '../swagger_empty.json';
 
 import { AppModule } from './app.module';
-
 async function bootstrap() {
+  DadosferaLogger.setupLogger({
+    serviceName: 'maestro',
+    serviceEnvironment: process.env.ENV,
+  });
+  const logger = new DadosferaLogger().logger;
+
+  const orginalWinstonLog = logger.log.bind(logger);
+  logger.log = function (...kwargs: any[]) {
+    if (kwargs[0] in logger.levels) {
+      if (kwargs[0] == 'error') {
+        orginalWinstonLog('error', kwargs[2]);
+      }
+    } else {
+      orginalWinstonLog('info', ...kwargs);
+    }
+  };
+
   const app = await NestFactory.create(AppModule, {
+    logger: logger,
     cors: {
       origin: '*',
       methods: 'GET,HEAD,PUT,PATCH,POST,DELETE',

src/modules/auth/auth.controller.ts

@@ -1,12 +1,12 @@
 import {
-  Logger,
   Body,
   Controller,
   Headers,
   Post,
   HttpCode,
   HttpStatus,
-  OnApplicationBootstrap,
+  Inject,
+  UseFilters,
 } from '@nestjs/common';
 import { ApiTags } from '@nestjs/swagger';
 import {
@@ -19,53 +19,30 @@ 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';
-import { Permissions } from '../../authentication/permissions.enum';
-
-import ErrorBuilder from '../../utils/ErrorBuilder';
-import { LoginDto } from './dtos/login';
+import { AuthClientService } from './auth.service';
+import { DadosferaLogger } from 'dadosfera-logs';
+import { GrpcToHttpExceptionFilter } from '../../error/grpc-to-http-exception.filter';
 
 @ApiTags('Auth')
+@UseFilters(new GrpcToHttpExceptionFilter())
 @Controller('auth')
-export class AuthController implements OnApplicationBootstrap {
-  private readonly logger = new Logger(AuthController.name);
+export class AuthController {
+  logger: any;
 
   constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
     private authClient: AuthClientService,
-    private permissionsClient: PermissionsClientService,
-  ) {}
-
-  // internally used to send permissions to duc on microservice startup
-  async onApplicationBootstrap() {
-    this.logger.log('sending permissions to DUC...');
-
-    const permissions = Object.values(Permissions).flatMap((namespace) =>
-      Object.values(namespace),
-    );
-
-    return this.permissionsClient
-      .injectPermissions({ permissions })
-      .catch((err: ErrorBuilder) => {
-        if (
-          err.code === 'No connection established' &&
-          process.env.LOCAL_ENV === 'true'
-        ) {
-          return this.logger.log(
-            "couldn't connect to DUC. suppresing in local env",
-          );
-        }
-
-        throw err;
-      });
+  ) {
+    this.logger = dadosferaLogger.logger;
   }
 
   @Post('sign-in')
   @HttpCode(HttpStatus.OK)
   async signIn(@Body() { username, password, totp }: AuthSignInRequest) {
-    this.logger.log(`/auth`, 'SignIn');
+    this.logger.info('/auth - SignIn');
 
     return this.authClient.signIn({ username, password, totp });
   }
@@ -75,7 +52,7 @@ export class AuthController implements OnApplicationBootstrap {
   async refreshAccessToken(
     @Body() { refreshToken }: AuthRefreshAccessTokenRequest,
   ) {
-    this.logger.log(`/auth`, 'RefreshAccessToken');
+    this.logger.info('/auth - RefreshAccessToken');
 
     return this.authClient.refreshAccessToken({ refreshToken });
   }
@@ -86,7 +63,7 @@ export class AuthController implements OnApplicationBootstrap {
     @Body() body: AuthChangePasswordRequest,
     @Headers() headers,
   ) {
-    this.logger.log(`/auth`, 'change-password');
+    this.logger.info('/auth - change-password');
 
     const { oldPassword, newPassword } = body;
     const { authorization: accessToken } = headers;
@@ -101,7 +78,7 @@ export class AuthController implements OnApplicationBootstrap {
   @Post('reset-password')
   @HttpCode(HttpStatus.OK)
   async resetPassword(@Body() body: AuthResetPasswordRequest) {
-    this.logger.log(`/auth`, 'reset-password');
+    this.logger.info('/auth - reset-password');
 
     const { username } = body;
 
@@ -113,7 +90,7 @@ export class AuthController implements OnApplicationBootstrap {
   async verifyResetPasswordCode(
     @Body() body: AuthVerifyResetPasswordCodeRequest,
   ) {
-    this.logger.log(`/auth`, 'verify-reset-password-code');
+    this.logger.info('/auth - verify-reset-password-code');
 
     const { username, code } = body;
 
@@ -123,7 +100,7 @@ export class AuthController implements OnApplicationBootstrap {
   @Post('confirm-reset-password')
   @HttpCode(HttpStatus.OK)
   async confirmResetPassword(@Body() body: AuthConfirmResetPasswordRequest) {
-    this.logger.log(`/auth`, 'confirm-reset-password');
+    this.logger.info('/auth - confirm-reset-password');
 
     const { username, code, newPassword } = body;
 
@@ -140,7 +117,7 @@ export class AuthController implements OnApplicationBootstrap {
     @Body() body: AuthEnableTotpMfaRequest,
     @Headers() headers,
   ) {
-    this.logger.log(`/auth`, 'enable-totp');
+    this.logger.info('/auth - enable-totp');
 
     const { password } = body;
     const { authorization: accessToken } = headers;
@@ -154,7 +131,7 @@ export class AuthController implements OnApplicationBootstrap {
     @Body() body: AuthDisableTotpMfaRequest,
     @Headers() headers,
   ) {
-    this.logger.log(`/auth`, 'disable-totp');
+    this.logger.info('/auth - disable-totp');
 
     const { password } = body;
     const { authorization: accessToken } = headers;
@@ -165,7 +142,7 @@ export class AuthController implements OnApplicationBootstrap {
   @Post('dismiss-totp')
   @HttpCode(HttpStatus.OK)
   async dismissTotpMFA(@Headers() headers) {
-    this.logger.log(`/auth`, 'disable-totp');
+    this.logger.info('/auth - disable-totp');
 
     const { authorization: accessToken } = headers;
 
@@ -175,7 +152,7 @@ export class AuthController implements OnApplicationBootstrap {
   @Post('verify-totp')
   @HttpCode(HttpStatus.OK)
   async verifyTotp(@Body() body: AuthVerifyTotpMfaRequest, @Headers() headers) {
-    this.logger.log(`/auth`, 'enable-totp');
+    this.logger.info('/auth - enable-totp');
 
     const { totp } = body;
     const { authorization: accessToken } = headers;

src/modules/auth/auth.module.ts

@@ -0,0 +1,24 @@
+import { Module } from '@nestjs/common';
+import { ClientsModule } from '@nestjs/microservices';
+import { DadosferaLogger } from 'dadosfera-logs';
+
+import { AuthController } from './auth.controller';
+import { AuthClientService } from './auth.service';
+
+import { DucClient } from '../../clients/duc/client.config';
+const ducClient = new DucClient();
+
+@Module({
+  imports: [
+    ClientsModule.register([
+      {
+        name: 'DUC_PACKAGE',
+        ...ducClient.config(),
+      },
+    ]),
+  ],
+  controllers: [AuthController],
+  providers: [AuthClientService, DadosferaLogger],
+  exports: [AuthClientService],
+})
+export class AuthModule {}

src/modules/auth/auth.service.ts

@@ -1,39 +1,35 @@
-import { Logger, OnModuleInit, Inject } from '@nestjs/common';
+import { OnModuleInit, Inject, Injectable } from '@nestjs/common';
 import { ClientGrpc } from '@nestjs/microservices';
+import { DadosferaLogger } from 'dadosfera-logs';
+import { lastValueFrom } from 'rxjs';
 
-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,
-  AuthSignInResponse,
   AuthRefreshAccessTokenRequest,
-  AuthRefreshAccessTokenResponse,
   AuthEnableTotpMfaRequest,
-  AuthEnableTotpMfaResponse,
   AuthDisableTotpMfaRequest,
-  AuthDisableTotpMfaResponse,
   AuthDismissTotpMfaRequest,
-  AuthDismissTotpMfaResponse,
   AuthVerifyTotpMfaRequest,
-  AuthVerifyTotpMfaResponse,
   AuthChangePasswordRequest,
-  AuthChangePasswordResponse,
   AuthResetPasswordRequest,
-  AuthResetPasswordResponse,
   AuthVerifyResetPasswordCodeRequest,
-  AuthVerifyResetPasswordCodeResponse,
   AuthConfirmResetPasswordRequest,
-  AuthConfirmResetPasswordResponse,
-} from '@victorradael/protospack-v2/dist/lib/Duc/interfaces/messages';
-
-import grpcHandler from '../../utils/grpcHandler';
+} from 'protospack-v2/dist/lib/Duc/interfaces/messages';
 
+@Injectable()
 export class AuthClientService implements OnModuleInit {
-  private readonly logger = new Logger(AuthClientService.name);
+  logger: any;
 
   private authService: AuthServiceInterface;
-  constructor(@Inject('DUC_PACKAGE') private readonly grpcClient: ClientGrpc) {}
+  constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
+    @Inject('DUC_PACKAGE') private readonly grpcClient: ClientGrpc,
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   onModuleInit() {
     this.authService = this.grpcClient.getService<AuthServiceInterface>(
@@ -42,25 +38,23 @@ export class AuthClientService implements OnModuleInit {
   }
 
   async getPublicKeys() {
-    this.logger.log('GetPublicKeys');
+    this.logger.info('GetPublicKeys');
 
-    return grpcHandler<AuthGetPublicKeysResponse>(
-      this.authService.AuthGetPublicKeys({}),
-    );
+    return lastValueFrom(this.authService.AuthGetPublicKeys({}));
   }
 
   async signIn({ username, password, totp }: AuthSignInRequest) {
-    this.logger.log('SignIn');
+    this.logger.info('SignIn');
 
-    return grpcHandler<AuthSignInResponse>(
+    return lastValueFrom(
       this.authService.AuthSignIn({ username, password, totp }),
     );
   }
 
   async refreshAccessToken({ refreshToken }: AuthRefreshAccessTokenRequest) {
-    this.logger.log('RefreshAccessToken');
+    this.logger.info('RefreshAccessToken');
 
-    return grpcHandler<AuthRefreshAccessTokenResponse>(
+    return lastValueFrom(
       this.authService.AuthRefreshAccessToken({ refreshToken }),
     );
   }
@@ -70,9 +64,9 @@ export class AuthClientService implements OnModuleInit {
     oldPassword,
     newPassword,
   }: AuthChangePasswordRequest) {
-    this.logger.log('ChangePassword');
+    this.logger.info('ChangePassword');
 
-    return grpcHandler<AuthChangePasswordResponse>(
+    return lastValueFrom(
       this.authService.AuthChangePassword({
         accessToken,
         oldPassword,
@@ -82,20 +76,18 @@ export class AuthClientService implements OnModuleInit {
   }
 
   async resetPassword({ username }: AuthResetPasswordRequest) {
-    this.logger.log('resetPassword');
+    this.logger.info('resetPassword');
 
-    return grpcHandler<AuthResetPasswordResponse>(
-      this.authService.AuthResetPassword({ username }),
-    );
+    return lastValueFrom(this.authService.AuthResetPassword({ username }));
   }
 
   async verifyResetPasswordCode({
     username,
     code,
   }: AuthVerifyResetPasswordCodeRequest) {
-    this.logger.log('verifyResetPasswordCode');
+    this.logger.info('verifyResetPasswordCode');
 
-    return grpcHandler<AuthVerifyResetPasswordCodeResponse>(
+    return lastValueFrom(
       this.authService.AuthVerifyResetPasswordCode({ username, code }),
     );
   }
@@ -105,9 +97,9 @@ export class AuthClientService implements OnModuleInit {
     code,
     newPassword,
   }: AuthConfirmResetPasswordRequest) {
-    this.logger.log('confirmResetPassword');
+    this.logger.info('confirmResetPassword');
 
-    return grpcHandler<AuthConfirmResetPasswordResponse>(
+    return lastValueFrom(
       this.authService.AuthConfirmResetPassword({
         username,
         code,
@@ -117,33 +109,31 @@ export class AuthClientService implements OnModuleInit {
   }
 
   async enableTotpMFA({ accessToken, password }: AuthEnableTotpMfaRequest) {
-    this.logger.log('enableTotpMFA');
+    this.logger.info('enableTotpMFA');
 
-    return grpcHandler<AuthEnableTotpMfaResponse>(
+    return lastValueFrom(
       this.authService.AuthEnableTotpMfa({ accessToken, password }),
     );
   }
 
   async disableTotpMFA({ accessToken, password }: AuthDisableTotpMfaRequest) {
-    this.logger.log('disableTotpMFA');
+    this.logger.info('disableTotpMFA');
 
-    return grpcHandler<AuthDisableTotpMfaResponse>(
+    return lastValueFrom(
       this.authService.AuthDisableTotpMfa({ accessToken, password }),
     );
   }
 
   async dismissTotpMFA({ accessToken }: AuthDismissTotpMfaRequest) {
-    this.logger.log('dismissTotpMFA');
+    this.logger.info('dismissTotpMFA');
 
-    return grpcHandler<AuthDismissTotpMfaResponse>(
-      this.authService.AuthDismissTotpMfa({ accessToken }),
-    );
+    return lastValueFrom(this.authService.AuthDismissTotpMfa({ accessToken }));
   }
 
   async verifyTotp({ accessToken, totp }: AuthVerifyTotpMfaRequest) {
-    this.logger.log('disableTotpMFA');
+    this.logger.info('disableTotpMFA');
 
-    return grpcHandler<AuthVerifyTotpMfaResponse>(
+    return lastValueFrom(
       this.authService.AuthVerifyTotpMfa({ accessToken, totp }),
     );
   }

src/modules/catalog/catalog.controller.ts

@@ -3,6 +3,7 @@ import {
   Controller,
   Delete,
   Get,
+  Inject,
   Param,
   Post,
   Query,
@@ -11,6 +12,7 @@ import { ApiTags } from '@nestjs/swagger';
 import { AuthenticateCondition } from '../../authentication/authentication.decorator';
 import { Permissions } from '../../authentication/permissions.enum';
 import { CatalogService } from './catalog.service';
+import { DadosferaLogger } from 'dadosfera-logs';
 
 @ApiTags('Catalog')
 @Controller('catalog')
@@ -33,11 +35,21 @@ import { CatalogService } from './catalog.service';
   return user.permissions.includes(Permissions.CATALOG[action].seqid);
 })
 export class CatalogController {
-  constructor(private catalogService: CatalogService) {}
+  logger: any;
+  constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
+    private catalogService: CatalogService,
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   @Get('all')
   async catalogAll(@Body() body) {
-    console.log(`/catalog`, 'ON CATALOG ALL ROUTE');
+    this.logger.info(`/catalog - ON CATALOG ALL ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.catalogAll(body);
 
@@ -46,7 +58,10 @@ export class CatalogController {
 
   @Get('data_apps')
   async dataAppsAll(@Body() body) {
-    console.log(`/catalog`, 'ON FIND ALL DATA APPS ROUTE');
+    this.logger.info(`/catalog - ON FIND ALL DATA APPS ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.dataAppsAll(body);
 
@@ -55,7 +70,10 @@ export class CatalogController {
 
   @Delete('data_apps/:id')
   async dataAppsOne(@Param() params, @Body() body) {
-    console.log(`/catalog`, 'ON FIND ONE DATA APP ROUTE');
+    this.logger.info(`/catalog - ON FIND ONE DATA APP ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
     const { id } = params;
 
     const res = await this.catalogService.dataAppsOne(id, body);
@@ -65,7 +83,10 @@ export class CatalogController {
 
   @Get('dashboard-metabase')
   async getAllDashboardMetabase(@Body() body) {
-    console.log(`/catalog`, 'ON GET ALL DASHBOARDS METABASE ROUTE');
+    this.logger.info(`/catalog - ON GET ALL DASHBOARDS METABASE ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.getAllDashboardMetabase(body);
 
@@ -75,7 +96,10 @@ export class CatalogController {
   @Get('dashboard-metabase/:id')
   async getOneDashboardMetabase(@Body() body, @Param() params) {
     const { id } = params;
-    console.log(`/catalog`, 'ON GET ONE DASHBOARD METABASE ROUTE');
+    this.logger.info(`/catalog - ON GET ONE DASHBOARD METABASE ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.getOneDashboardMetabase(id, body);
 
@@ -84,7 +108,10 @@ export class CatalogController {
 
   @Get('table-metadata')
   async getAllTableMetadata(@Body() body, @Query() query) {
-    console.log(`/catalog`, 'ON GET ALL TABLES METADATA ROUTE');
+    this.logger.info(`/catalog - ON GET ALL TABLES METADATA ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     if (!query) {
       const res = await this.catalogService.getAllTableMetadata(body);
@@ -98,7 +125,10 @@ export class CatalogController {
   @Delete('table-metadata/:id')
   async deleteOneTableMetadata(@Param() params, @Body() body) {
     const { id } = params;
-    console.log(`/catalog`, 'ON DELETE ONE TABLE METADATA ROUTE');
+    this.logger.info(`/catalog - ON DELETE ONE TABLE METADATA ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.deleteOneTableMetadata(id, body);
 
@@ -107,7 +137,10 @@ export class CatalogController {
 
   @Get('column-metadata')
   async getOneColumnMetadata(@Body() body, @Query() params) {
-    console.log(`/catalog`, 'ON GET ONE COLUMN METADATA ROUTE');
+    this.logger.info(`/catalog - ON GET ONE COLUMN METADATA ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.getOneColumnMetadata(body, params);
 
@@ -116,7 +149,10 @@ export class CatalogController {
 
   @Delete('column-metadata/:id')
   async deleteOneColumnMetadata(@Param() params, @Body() body) {
-    console.log(`/catalog`, 'ON DELETE ONE COLUMN METADATA ROUTE');
+    this.logger.info(`/catalog - ON DELETE ONE COLUMN METADATA ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
     const { id } = params;
 
     const res = await this.catalogService.deleteOneColumnMetadata(id, body);
@@ -126,7 +162,10 @@ export class CatalogController {
 
   @Get('data-preview')
   async getOneDataPreview(@Body() body, @Query() params) {
-    console.log(`/catalog`, 'ON GET ONE DATAPREVIEW ROUTE');
+    this.logger.info(`/catalog - ON GET ONE DATAPREVIEW ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.getOneDataPreview(body, params);
 
@@ -135,7 +174,10 @@ export class CatalogController {
 
   @Get('data-status')
   async getDataStatus(@Body() body) {
-    console.log(`/catalog`, 'ON GET DATA STATUS ROUTE');
+    this.logger.info(`/catalog - ON GET DATA STATUS ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.getDataStatus(body);
 
@@ -144,7 +186,10 @@ export class CatalogController {
 
   @Get('data-status')
   async createDataStatus(@Body() body) {
-    console.log(`/catalog`, 'ON CREATE DATA STATUS ROUTE');
+    this.logger.info(`/catalog - ON CREATE DATA STATUS ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.createDataStatus(body);
 
@@ -153,7 +198,10 @@ export class CatalogController {
 
   @Get('data-description')
   async getDataDescription(@Body() body) {
-    console.log(`/catalog`, 'ON GET DATA DESCRIPTION ROUTE');
+    this.logger.info(`/catalog - ON GET DATA DESCRIPTION ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.getDataDescription(body);
 
@@ -162,7 +210,10 @@ export class CatalogController {
 
   @Post('data-description')
   async createDataDescription(@Body() body) {
-    console.log(`/catalog`, 'ON CREATE DATA DESCRIPTION ROUTE');
+    this.logger.info(`/catalog - ON CREATE DATA DESCRIPTION ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.createDataDescription(body);
 
@@ -171,7 +222,10 @@ export class CatalogController {
 
   @Get('data-docs')
   async getDataDocs(@Body() body) {
-    console.log(`/catalog`, 'ON GET DATA DOCS ROUTE');
+    this.logger.info(`/catalog - ON GET DATA DOCS ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.getDataDocs(body);
 
@@ -180,7 +234,10 @@ export class CatalogController {
 
   @Post('data-docs')
   async createDataDocs(@Body() body) {
-    console.log(`/catalog`, 'ON CREATE DATA DOCS ROUTE');
+    this.logger.info(`/catalog - ON CREATE DATA DOCS ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.createDataDocs(body);
 
@@ -189,7 +246,10 @@ export class CatalogController {
 
   @Get('data-rating')
   async getDataRating(@Body() body) {
-    console.log(`/catalog`, 'ON GET DATA RATING ROUTE');
+    this.logger.info(`/catalog - ON GET DATA RATING ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.getDataRating(body);
 
@@ -198,7 +258,10 @@ export class CatalogController {
 
   @Post('data-rating')
   async createDataRating(@Body() body) {
-    console.log(`/catalog`, 'ON GET DATA RATING ROUTE');
+    this.logger.info(`/catalog - ON GET DATA RATING ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.createDataRating(body);
 
@@ -207,7 +270,7 @@ export class CatalogController {
 
   @Get('summary-rating/:id')
   async getSummaryRating() {
-    console.log(`/catalog`, 'ON GET SUMMARY RATING ROUTE');
+    this.logger.info(`/catalog - ON GET SUMMARY RATING ROUTE`);
     //const { id } = params;
 
     //
@@ -222,7 +285,10 @@ export class CatalogController {
 
   @Get('data-comment')
   async getDataComment(@Body() body) {
-    console.log(`/catalog`, 'ON GET DATA COMMENT ROUTE');
+    this.logger.info(`/catalog - ON GET DATA COMMENT ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.getDataComment(body);
 
@@ -231,7 +297,10 @@ export class CatalogController {
 
   @Post('data-comment')
   async createDataComment(@Body() body) {
-    console.log(`/catalog`, 'ON GET DATA COMMENT ROUTE');
+    this.logger.info(`/catalog - ON GET DATA COMMENT ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.createDataComment(body);
 
@@ -240,7 +309,10 @@ export class CatalogController {
 
   @Get('data-review')
   async getDataReview(@Body() body, @Query() params) {
-    console.log(`/catalog`, 'ON GET DATA REVIEW ROUTE');
+    this.logger.info(`/catalog - ON GET DATA REVIEW ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.getDataReview(body, params);
 
@@ -249,7 +321,10 @@ export class CatalogController {
 
   @Post('tags')
   async createTags(@Body() body) {
-    console.log(`/catalog`, 'ON CREATE TAG ROUTE');
+    this.logger.info(`/catalog - ON CREATE TAG ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.createTags(body);
 
@@ -258,7 +333,10 @@ export class CatalogController {
 
   @Get('tags')
   async findAllTags(@Body() body) {
-    console.log(`/catalog`, 'ON FIND ALL TAGS ROUTE');
+    this.logger.info(`/catalog - ON FIND ALL TAGS ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.findAllTags(body);
 
@@ -267,7 +345,10 @@ export class CatalogController {
 
   @Delete('tags/:id')
   async deleteTags(@Param() params, @Body() body) {
-    console.log(`/catalog`, 'ON DELETE TAG ROUTE');
+    this.logger.info(`/catalog - ON DELETE TAG ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
     const { id } = params;
 
     const res = await this.catalogService.deleteTags(id, body);
@@ -277,7 +358,10 @@ export class CatalogController {
 
   @Post('table-tags')
   async createTableTags(@Body() body) {
-    console.log(`/catalog`, 'ON CREATE TABLE TAG ROUTE');
+    this.logger.info(`/catalog - ON CREATE TABLE TAG ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.createTableTags(body);
 
@@ -286,7 +370,10 @@ export class CatalogController {
 
   @Get('table-tags')
   async getAllTableTags(@Body() body) {
-    console.log(`/catalog`, 'ON GET ALL TABLE TAGS ROUTE');
+    this.logger.info(`/catalog - ON GET ALL TABLE TAGS ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.findAllTableTags(body);
 
@@ -295,7 +382,10 @@ export class CatalogController {
 
   @Delete('table-tags/:id')
   async deleteTableTags(@Param() params, @Body() body) {
-    console.log(`/catalog`, 'ON CREATE TABLE TAGS ROUTE');
+    this.logger.info(`/catalog - ON CREATE TABLE TAGS ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
     const { id } = params;
 
     const res = await this.catalogService.deleteTableTags(id, body);
@@ -305,7 +395,10 @@ export class CatalogController {
 
   @Get('table-rules')
   async getTableRules(@Body() body) {
-    console.log(`/catalog`, 'ON GET TABLE RULES ROUTE');
+    this.logger.info(`/catalog - ON GET TABLE RULES ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const res = await this.catalogService.getTableRules(body);
 
@@ -314,7 +407,10 @@ export class CatalogController {
 
   @Delete('table-rules/:id')
   async deleteTableRules(@Param() params, @Body() body) {
-    console.log(`/catalog`, 'ON DELETE TABLE RULES ROUTE');
+    this.logger.info(`/catalog - ON DELETE TABLE RULES ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
     const { id } = params;
 
     const res = await this.catalogService.deleteTableRules(id, body);

src/modules/catalog/catalog.service.ts

@@ -46,7 +46,6 @@ class CatalogService {
     const { data } = await axios.get(
       `${nimbusUrl}/api/catalog/dashboard-metabase/${id}`,
     );
-    console.log(data);
 
     // const [, path] = data.iframe_url.split('.dadosfera');
     // const host = `httpss://metabase-${body.info.customer.toLowerCase()}.dadosfera.ai`;

src/modules/connector/connector.controller.ts

@@ -10,6 +10,7 @@ import {
   Query,
   UploadedFile,
   UseInterceptors,
+  Inject,
 } from '@nestjs/common';
 import { FileInterceptor } from '@nestjs/platform-express';
 import { ApiBearerAuth, ApiConsumes, ApiTags } from '@nestjs/swagger';
@@ -21,12 +22,20 @@ import { GetAllDto } from './dtos/get-all';
 import { RemoveTagDto } from './dtos/remove-tag';
 import { UpdateDto } from './dtos/update';
 import { UploadFileDto } from './dtos/upload-file';
+import { DadosferaLogger } from 'dadosfera-logs';
 
 @ApiTags('connectors')
 @ApiBearerAuth()
 @Controller('connectors')
 export class ConnectorController {
-  constructor(private connectorClientService: ConnectorClientService) {}
+  logger: any;
+  constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
+    private connectorClientService: ConnectorClientService,
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   @Post()
   @ApiConsumes('multipart/form-data')
@@ -35,7 +44,7 @@ export class ConnectorController {
     @UploadedFile() file,
     @Body() body: CreateConnectorDto,
   ) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const response = await this.connectorClientService.uploadConnector({
       file,
@@ -49,7 +58,7 @@ export class ConnectorController {
   @ApiConsumes('multipart/form-data')
   @UseInterceptors(FileInterceptor('file'))
   async uploadFile(@UploadedFile() file, @Body() { name }: UploadFileDto) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const response = await this.connectorClientService.uploadFile({
       file,
@@ -61,7 +70,7 @@ export class ConnectorController {
 
   @Get()
   async getAllConnectors(@Query() queries: GetAllDto) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const { search, ...filters } = queries;
 
@@ -83,7 +92,7 @@ export class ConnectorController {
     @Param('plugin') plugin: string,
     @Query('version') version: string,
   ) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const pluginId = `${plugin}-${version}`;
 
@@ -102,7 +111,7 @@ export class ConnectorController {
     @Param('plugin') plugin: string,
     @Query('version') version: string,
   ) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const pluginId = `${plugin}-${version}`;
 
@@ -122,7 +131,7 @@ export class ConnectorController {
     @Param('plugin') plugin: string,
     @Body() body: UpdateDto,
   ) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const changes = body;
 
@@ -142,7 +151,7 @@ export class ConnectorController {
     @Param('plugin') plugin: string,
     @Body() body: AddTagDto,
   ) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const { tags } = body;
 
@@ -168,7 +177,7 @@ export class ConnectorController {
     @Param('plugin') plugin: string,
     @Body() body: RemoveTagDto,
   ) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const { tags } = body;
     const remove = tags;
@@ -195,7 +204,7 @@ export class ConnectorController {
     @Param('plugin') plugin: string,
     @Body() { version }: DeleteConnectorDto,
   ) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const response: any = await this.connectorClientService.deleteConnector(
       plugin,

src/modules/health/health.controller.ts

@@ -1,15 +1,22 @@
-import { Controller, Get } from '@nestjs/common';
+import { Controller, Get, Inject } from '@nestjs/common';
 import { ApiTags } from '@nestjs/swagger';
 import { HealthService } from './health.service';
+import { DadosferaLogger } from 'dadosfera-logs';
 
 @ApiTags('Health')
 @Controller('health')
 export class HealthController {
-  constructor(private readonly healthService: HealthService) {}
+  logger: any;
+  constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
+    private readonly healthService: HealthService,
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   @Get()
   check() {
-    console.log(`/health`, 'check');
     return this.healthService.check();
   }
 }

src/modules/health/health.service.spec.ts

@@ -1,5 +0,0 @@
-describe('PipelinesGrpcServerService', () => {
-  it('should be defined', () => {
-    expect(2 + 2).toBe(4);
-  });
-});

src/modules/health/health.service.ts

@@ -1,9 +1,16 @@
-import { Injectable } from '@nestjs/common';
+import { Inject, Injectable } from '@nestjs/common';
+import { DadosferaLogger } from 'dadosfera-logs';
 
 @Injectable()
 export class HealthService {
+  logger: any;
+  constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
   check() {
-    console.log('HEALTH');
     return { message: 'Ok' };
   }
 }

src/modules/inputs/dtos/input.model.ts

@@ -1,4 +1,5 @@
 import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
+import { Info } from 'src/clients/inputs/interfaces';
 import { Method } from 'axios';
 
 export class InputModel {
@@ -149,6 +150,8 @@ export class TestConnectionGetColumnsReq {
   credentials: CredentialsJdbc;
   @ApiPropertyOptional()
   id: string;
+  @ApiPropertyOptional()
+  info: Info;
 }
 export class TestConnectionGetColumnsRes {
   @ApiProperty()
@@ -160,6 +163,8 @@ export class TestConnectionReq {
   plugin: string;
   @ApiProperty()
   credentials: CredentialsJdbc;
+  @ApiPropertyOptional()
+  info: Info;
 }
 export class TestConnectionRes {
   @ApiProperty()
@@ -182,6 +187,8 @@ export class CreateInputReq {
   name: string;
   @ApiPropertyOptional()
   options: InputOptions;
+  @ApiPropertyOptional()
+  info: Info;
 }
 
 export class Input {
@@ -203,4 +210,6 @@ export class Input {
   created_at: string;
   @ApiProperty()
   updated_at: string;
+  @ApiPropertyOptional()
+  info: Info;
 }

src/modules/inputs/inputs.controller.ts

@@ -3,11 +3,13 @@ import {
   Controller,
   Delete,
   Get,
+  Inject,
   Param,
   Patch,
   Post,
 } from '@nestjs/common';
 import { InputsService } from './inputs.service';
+import { DadosferaLogger } from 'dadosfera-logs';
 import { InputsClientService } from 'src/clients/inputs/client.service';
 import { UpdateInputRequest } from 'src/clients/inputs/interfaces';
 import { Permissions } from '../../authentication/permissions.enum';
@@ -27,7 +29,7 @@ import {
 @ApiTags('inputs')
 @Controller('inputs')
 @AuthenticateCondition((req, user) => {
-  let action;
+  let action: any;
 
   switch (req.method) {
     case 'POST':
@@ -57,7 +59,13 @@ import {
 })
 export class InputsController {
   inputService: InputsService;
-  constructor(private inputsClientService: InputsClientService) {
+  logger: any;
+  constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
+    private inputsClientService: InputsClientService,
+  ) {
+    this.logger = dadosferaLogger.logger;
     this.inputService = new InputsService(this.inputsClientService);
   }
 
@@ -75,7 +83,10 @@ export class InputsController {
   @Post('/test-connection')
   @ApiOkResponse({ type: TestConnectionRes })
   async testConnection(@Body() data: TestConnectionReq) {
-    console.log(`/test-connection`, 'ON TEST CONNECTION ROUTE');
+    this.logger.info(`/test-connection - ON TEST CONNECTION ROUTE`, {
+      user: data.info.user_id,
+      customer: data.info.customer,
+    });
 
     const response = await this.inputService.testConnection(data);
 
@@ -85,9 +96,12 @@ export class InputsController {
   @Post('/test-connection/get-columns')
   @ApiOkResponse({ type: TestConnectionGetColumnsRes })
   async getColumns(@Body() data: TestConnectionGetColumnsReq) {
-    console.log(
-      `/test-connection/get-columns`,
-      'ON TEST CONNECTION GET COLUMNS ROUTE',
+    this.logger.info(
+      `/test-connection/get-columns - ON TEST CONNECTION GET COLUMNS ROUTE`,
+      {
+        user: data.info.user_id,
+        customer: data.info.customer,
+      },
     );
 
     const response = await this.inputService.getColumns(data);
@@ -98,7 +112,10 @@ export class InputsController {
   @Post()
   @ApiOkResponse({ type: Input })
   async create(@Body() createInputDto: CreateInputReq) {
-    console.log(`/input`, 'ON CREATE ROUTE');
+    this.logger.info(`/input - ON CREATE ROUTE`, {
+      user: createInputDto.info.user_id,
+      customer: createInputDto.info.customer,
+    });
 
     const response = await this.inputService.create(createInputDto);
 
@@ -109,7 +126,7 @@ export class InputsController {
   @ApiOkResponse({ type: Input })
   async reCreate(@Param('id') id: string, @Body() input: CreateInputReq) {
     if (!input.id) input.id = id;
-    console.log(`POST /${input.id}`, 'ON RECREATE ROUTE');
+    this.logger.info(`POST /${id}`, 'ON RECREATE ROUTE');
 
     const response = await this.inputService.reCreate(input);
 
@@ -118,7 +135,10 @@ export class InputsController {
 
   @Get()
   async findAll(@Body() body) {
-    console.log(`/input`, 'ON FIND ALL ROUTE');
+    this.logger.info(`/input - ON FIND ALL ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const response = await this.inputService.findAll(body);
 
@@ -128,7 +148,10 @@ export class InputsController {
   @Get('/:id')
   async findOne(@Body() body, @Param() params) {
     const { id } = params;
-    console.log(`/input/${id}`, 'ON FIND ONE ROUTE');
+    this.logger.info(`/input/${id} - ON FIND ONE ROUTE`, {
+      user: body.info.user_id,
+      customer: body.info.customer,
+    });
 
     const response = await this.inputService.findOne({ id, ...body });
 
@@ -139,10 +162,12 @@ export class InputsController {
   async update(@Body() updateInputDto: UpdateInputRequest, @Param() params) {
     const { id } = params;
     const { info } = updateInputDto;
+    this.logger.info(`/input/${id} - ON UPDATE ROUTE`, {
+      user: info.user_id,
+      customer: info.customer_id,
+    });
     delete updateInputDto.info;
 
-    console.log(`/input/${id}`, 'ON UPDATE ROUTE');
-
     const response = await this.inputService.update(id, updateInputDto, info);
 
     return response;
@@ -152,7 +177,10 @@ export class InputsController {
   async delete(@Body() data, @Param() params) {
     const { id } = params;
 
-    console.log(`/input/${id}`, 'ON DELETE ROUTE');
+    this.logger.info(`/input/${id} - ON DELETE ROUTE`, {
+      user: data.info.user_id,
+      customer: data.info.customer,
+    });
 
     const response = await this.inputService.remove({ id, ...data });
 

src/modules/inputs/inputs.service.spec.ts

@@ -1,5 +0,0 @@
-describe('PipelinesGrpcServerService', () => {
-  it('should be defined', () => {
-    expect(2 + 2).toBe(4);
-  });
-});

src/modules/inputs/inputs.service.ts

@@ -1,13 +1,13 @@
 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';
 
 @Injectable()
 export class InputsService {
-  constructor(private inputClient: InputsClientService) {}
+  constructor(private inputClient: InputsClientService) { }
   secondsInADay = 60 * 60 * 24;
   secondsInAnHour = 60 * 60;
 

src/modules/oauth/passport-strategies/facebook-strategy.ts

@@ -1,12 +1,15 @@
 import {
   Profile,
   Strategy,
-  StrategyOptionWithRequest,
+  StrategyOption,
   VerifyFunction,
 } from 'passport-facebook';
 import { PassportStrategy } from '@nestjs/passport';
 import { Inject, Injectable } from '@nestjs/common';
 import { OauthSecrets } from 'src/utils/OauthSecrets';
+import { Request } from 'express';
+import { ParamsDictionary } from 'express-serve-static-core';
+import { ParsedQs } from 'qs';
 
 @Injectable()
 export class FacebookStrategy extends PassportStrategy(Strategy) {
@@ -14,19 +17,29 @@ export class FacebookStrategy extends PassportStrategy(Strategy) {
     @Inject('OAUTH_SECRETS')
     private readonly oauthSecrets: OauthSecrets,
   ) {
-    const options: StrategyOptionWithRequest = {
+    const options: StrategyOption = {
       clientID: oauthSecrets.facebook.client_id,
       clientSecret: oauthSecrets.facebook.client_secret,
       callbackURL: oauthSecrets.facebook.redirect_uri,
-      passReqToCallback: true,
     };
     const verify: VerifyFunction = (
       accessToken: string,
       refreshToken: string,
       profile: Profile,
       done: (error: any, user?: any, info?: any) => void,
-    ) => done(null, profile, { accessToken, refreshToken });
+    ) => {
+      return done(null, profile, { accessToken, refreshToken });
+    };
 
     super(options, verify);
   }
+  authenticate(
+    req: Request<ParamsDictionary, any, any, ParsedQs, Record<string, any>>,
+    options?: any,
+  ): void {
+    const { customer_id } = req.query;
+    options.state = customer_id;
+    options.scope = 'ads_read ads_management';
+    super.authenticate(req, options);
+  }
 }

src/modules/outputs/outputs.controllers.ts

@@ -3,6 +3,7 @@ import {
   Controller,
   Delete,
   Get,
+  Inject,
   Param,
   Post,
   Put,
@@ -13,6 +14,7 @@ import { OutputsClientService } from 'src/clients/outputs/client.service';
 import { AuthenticateCondition } from 'src/authentication/authentication.decorator';
 import { Permissions } from '../../authentication/permissions.enum';
 import { OutputsService } from './outputs.service';
+import { DadosferaLogger } from 'dadosfera-logs';
 
 @ApiTags('Outputs')
 @Controller('outputs')
@@ -35,11 +37,21 @@ import { OutputsService } from './outputs.service';
   return user.permissions.includes(Permissions.OUTPUT[action].seqid);
 })
 export class OutputsController {
-  constructor(private outputsClientService: OutputsClientService) { }
+  logger: any;
+  constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
+    private outputsClientService: OutputsClientService,
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   @Post()
   async create(@Body() createOutputDto) {
-    console.log(process.env.DEV_URL + `/output`, 'ON CREATE ROUTE');
+    this.logger.info(process.env.DEV_URL + `/output - ON CREATE ROUTE`, {
+      user: createOutputDto.info.user_id,
+      customer: createOutputDto.info.customer,
+    });
 
     const outputService = new OutputsService(this.outputsClientService);
     const response = await outputService.create(createOutputDto);
@@ -49,7 +61,10 @@ export class OutputsController {
 
   @Get()
   async findAll(@Body() data) {
-    console.log(process.env.DEV_URL + `/output`, 'ON Find All ROUTE');
+    this.logger.info(process.env.DEV_URL + `/output - ON Find All ROUTE`, {
+      user: data.info.user_id,
+      customer: data.info.customer,
+    });
 
     const outputService = new OutputsService(this.outputsClientService);
     const response = await outputService.findAll(data);
@@ -60,7 +75,13 @@ export class OutputsController {
   @Get('/:id')
   async findOne(@Body() data, @Param() params) {
     const { id } = params;
-    console.log(process.env.DEV_URL + `/output/${id}`, 'ON Find One ROUTE');
+    this.logger.info(
+      process.env.DEV_URL + `/output/${id} - ON Find One ROUTE`,
+      {
+        user: data.info.user_id,
+        customer: data.info.customer,
+      },
+    );
 
     const outputService = new OutputsService(this.outputsClientService);
     const response = await outputService.findOne({ id, ...data });
@@ -72,10 +93,12 @@ export class OutputsController {
   async update(@Payload() updateOutputDto, @Param() params) {
     const { id } = params;
     const { info } = updateOutputDto;
+    this.logger.info(process.env.DEV_URL + `/output/${id} - ON UPDATE ROUTE`, {
+      user: updateOutputDto.info.user_id,
+      customer: updateOutputDto.info.customer,
+    });
     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, info);
 
@@ -85,7 +108,10 @@ export class OutputsController {
   @Delete(':id')
   async delete(@Body() data, @Param() params) {
     const { id } = params;
-    console.log(process.env.DEV_URL + `/output/${id}`, 'ON DELETE ROUTE');
+    this.logger.info(process.env.DEV_URL + `/output/${id} - ON DELETE ROUTE`, {
+      user: data.info.user_id,
+      customer: data.info.customer,
+    });
 
     const outputService = new OutputsService(this.outputsClientService);
     const response = await outputService.remove({ id, ...data });

src/modules/outputs/outputs.service.spec.ts

@@ -1,5 +0,0 @@
-describe('PipelinesGrpcServerService', () => {
-  it('should be defined', () => {
-    expect(2 + 2).toBe(4);
-  });
-});

src/modules/permissions/permissions.module.ts

@@ -0,0 +1,21 @@
+import { Module } from '@nestjs/common';
+import { ClientsModule } from '@nestjs/microservices';
+import { DadosferaLogger } from 'dadosfera-logs';
+
+import { PermissionsClientService } from './permissions.service';
+
+import { DucClient } from '../../clients/duc/client.config';
+const ducClient = new DucClient();
+
+@Module({
+  imports: [
+    ClientsModule.register([
+      {
+        name: 'DUC_PACKAGE',
+        ...ducClient.config(),
+      },
+    ]),
+  ],
+  providers: [PermissionsClientService, DadosferaLogger],
+})
+export class PermissionsModule {}

src/modules/permissions/permissions.service.ts

@@ -0,0 +1,70 @@
+import {
+  OnApplicationBootstrap,
+  OnModuleInit,
+  Inject,
+  Injectable,
+} from '@nestjs/common';
+import { ClientGrpc } from '@nestjs/microservices';
+import { lastValueFrom } from 'rxjs';
+
+import { ProtoServices } from 'protospack-v2/dist/lib/Duc';
+import { PermissionsProtoService as PermissionsServiceInterface } from 'protospack-v2/dist/lib/Duc/interfaces/write-service';
+import { InjectPermissionsRequest } from 'protospack-v2/dist/lib/Duc/interfaces/messages';
+import { DadosferaLogger } from 'dadosfera-logs';
+import { Permissions } from '../../authentication/permissions.enum';
+import ErrorBuilder from '../../utils/ErrorBuilder';
+
+@Injectable()
+export class PermissionsClientService
+  implements OnModuleInit, OnApplicationBootstrap
+{
+  logger: any;
+
+  private permissionsService: PermissionsServiceInterface;
+  constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
+    @Inject('DUC_PACKAGE') private readonly grpcClient: ClientGrpc,
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
+
+  onModuleInit() {
+    this.permissionsService =
+      this.grpcClient.getService<PermissionsServiceInterface>(
+        ProtoServices.PermissionsProtoService,
+      );
+  }
+
+  // internally used to send permissions to duc on microservice startup
+  async onApplicationBootstrap() {
+    this.logger.info('sending permissions to DUC...');
+
+    const permissions = Object.values(Permissions).flatMap((namespace) =>
+      Object.values(namespace),
+    );
+
+    return this.injectPermissions({
+      permissions,
+    }).catch((err: ErrorBuilder) => {
+      if (
+        err.code === 'No connection established' &&
+        process.env.LOCAL_ENV === 'true'
+      ) {
+        return this.logger.info(
+          "couldn't connect to DUC. suppresing in local env",
+        );
+      }
+
+      throw err;
+    });
+  }
+
+  async injectPermissions({ permissions }: InjectPermissionsRequest) {
+    this.logger.info('InjectPermissions');
+
+    return lastValueFrom(
+      this.permissionsService.InjectPermissions({ permissions }),
+    );
+  }
+}

src/modules/pipelines/pipelines.controller.ts

@@ -3,6 +3,7 @@ import {
   Controller,
   Delete,
   Get,
+  Inject,
   Param,
   Post,
   Put,
@@ -12,6 +13,7 @@ import { PipelinesClientService } from 'src/clients/pipelines/client.service';
 import { AuthenticateCondition } from 'src/authentication/authentication.decorator';
 import { Permissions } from '../../authentication/permissions.enum';
 import { PipelinesService } from './pipelines.service';
+import { DadosferaLogger } from 'dadosfera-logs';
 
 @ApiTags('Pipelines')
 @Controller('pipelines')
@@ -34,16 +36,26 @@ import { PipelinesService } from './pipelines.service';
   return user.permissions.includes(Permissions.PIPELINE[action].seqid);
 })
 export class PipelinesController {
-  constructor(private pipelinesClientService: PipelinesClientService) {}
+  logger: any;
+  constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
+    private pipelinesClientService: PipelinesClientService,
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   @Post('start/:id')
   async activate(@Param() params, @Body() body) {
     const { id } = params;
     const { info } = body;
 
-    console.log(
-      process.env.DEV_URL + `/pipeline/start/${id}`,
-      'ON START PIPELINE ROUTE',
+    this.logger.info(
+      process.env.DEV_URL + `/pipeline/start/${id} - ON START PIPELINE ROUTE`,
+      {
+        user: body.info.user_id,
+        customer: body.info.customer,
+      },
     );
 
     const pipelineService = new PipelinesService(this.pipelinesClientService);
@@ -57,9 +69,12 @@ export class PipelinesController {
     const { id } = params;
     body.id = id;
 
-    console.log(
-      process.env.DEV_URL + `/pipeline/${id}`,
-      'ON GET PIPELINE STATUS ROUTE',
+    this.logger.info(
+      process.env.DEV_URL + `/pipeline/${id} - ON GET PIPELINE STATUS ROUTE`,
+      {
+        user: body.info.user_id,
+        customer: body.info.customer,
+      },
     );
 
     const pipelineService = new PipelinesService(this.pipelinesClientService);
@@ -71,9 +86,9 @@ export class PipelinesController {
   @Get(':id/:details')
   async getPipelineLogs(@Param() params) {
     const { id, details } = params;
-    console.log(
-      process.env.DEV_URL + `/pipeline/${id}`,
-      'ON GET PIPELINE LOGS ROUTE',
+    this.logger.info(
+      process.env.DEV_URL + `/pipeline/${id} - ON GET PIPELINE LOGS ROUTE`,
+      {},
     );
 
     const pipelineService = new PipelinesService(this.pipelinesClientService);
@@ -84,7 +99,7 @@ export class PipelinesController {
 
   @Post()
   async create(@Body() createPipelineDto) {
-    console.log(process.env.DEV_URL + `/pipelines`, 'ON CREATE ROUTE');
+    this.logger.info(process.env.DEV_URL + `/pipelines ON CREATE ROUTE`);
 
     const pipelineService = new PipelinesService(this.pipelinesClientService);
     const response = await pipelineService.create(createPipelineDto);
@@ -94,7 +109,10 @@ export class PipelinesController {
 
   @Get()
   async findAll(@Body() data) {
-    console.log(process.env.DEV_URL + `/pipeline`, 'ON Find All ROUTE');
+    this.logger.info(process.env.DEV_URL + `/pipeline ON Find All ROUTE`, {
+      user: data.info.user_id,
+      customer: data.info.customer,
+    });
 
     const pipelineService = new PipelinesService(this.pipelinesClientService);
     const response = await pipelineService.findAll(data);
@@ -105,7 +123,7 @@ export class PipelinesController {
   @Get('/:id')
   async findOne(@Body() data, @Param() params) {
     const { id } = params;
-    console.log(process.env.DEV_URL + `/pipeline/${id}`, 'ON Find One ROUTE');
+    this.logger.info(process.env.DEV_URL + `/pipeline/${id} ON Find One ROUTE`);
 
     const pipelineService = new PipelinesService(this.pipelinesClientService);
     const response = await pipelineService.findOne({ id, ...data });
@@ -119,7 +137,7 @@ export class PipelinesController {
     const { info } = updatePipelineDto;
     delete updatePipelineDto.info;
 
-    console.log(process.env.DEV_URL + `/pipeline/${id}`, 'ON UPDATE ROUTE');
+    this.logger.info(process.env.DEV_URL + `/pipeline/${id} ON UPDATE ROUTE`);
 
     const pipelineService = new PipelinesService(this.pipelinesClientService);
     const response = await pipelineService.update(id, updatePipelineDto, info);
@@ -130,7 +148,7 @@ export class PipelinesController {
   @Delete(':id')
   async delete(@Body() data, @Param() params) {
     const { id } = params;
-    console.log(process.env.DEV_URL + `/pipeline/${id}`, 'ON DELETE ROUTE');
+    this.logger.info(process.env.DEV_URL + `/pipeline/${id} ON DELETE ROUTE`);
 
     const pipelineService = new PipelinesService(this.pipelinesClientService);
     const response = await pipelineService.remove({ id, ...data });

src/modules/pipelines/pipelines.service.spec.ts

@@ -1,5 +0,0 @@
-describe('PipelinesGrpcServerService', () => {
-  it('should be defined', () => {
-    expect(2 + 2).toBe(4);
-  });
-});

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';

src/modules/transformations/transformations.controller.ts

@@ -3,6 +3,7 @@ import {
   Controller,
   Delete,
   Get,
+  Inject,
   Param,
   Post,
   Put,
@@ -14,6 +15,7 @@ import { IIdRequest } from 'src/clients/transformations/interfaces';
 import { AuthenticateCondition } from 'src/authentication/authentication.decorator';
 import { Permissions } from '../../authentication/permissions.enum';
 import { TransformationsService } from './transformations.service';
+import { DadosferaLogger } from 'dadosfera-logs';
 
 @ApiTags('Transformations')
 @Controller('transformations')
@@ -36,13 +38,24 @@ import { TransformationsService } from './transformations.service';
   return user.permissions.includes(Permissions.TRANSFORMATIONS[action].seqid);
 })
 export class TransformationsController {
+  logger: any;
   constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
     private transformationsClientService: TransformationsClientService,
-  ) {}
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   @Post()
   async create(@Body() createTransformationDto) {
-    console.log(process.env.DEV_URL + `/transformation`, 'ON CREATE ROUTE');
+    this.logger.info(
+      process.env.DEV_URL + `/transformation - ON CREATE ROUTE`,
+      {
+        user: createTransformationDto.info.user_id,
+        customer: createTransformationDto.info.customer,
+      },
+    );
 
     const transformationService = new TransformationsService(
       this.transformationsClientService,
@@ -56,7 +69,13 @@ export class TransformationsController {
 
   @Get()
   async findAll(@Body() data: IIdRequest) {
-    console.log(process.env.DEV_URL + `/transformation`, 'ON Find All ROUTE');
+    this.logger.info(
+      process.env.DEV_URL + `/transformation - ON Find All ROUTE`,
+      {
+        user: data.info.user_id,
+        customer: data.info.customer_id,
+      },
+    );
 
     const transformationService = new TransformationsService(
       this.transformationsClientService,
@@ -69,9 +88,12 @@ export class TransformationsController {
   @Get('/:id')
   async findOne(@Body() data, @Param() params) {
     const { id } = params;
-    console.log(
-      process.env.DEV_URL + `/transformation/${id}`,
-      'ON Find One ROUTE',
+    this.logger.info(
+      process.env.DEV_URL + `/transformation/${id} - ON Find One ROUTE`,
+      {
+        user: data.info.user_id,
+        customer: data.info.customer,
+      },
     );
 
     const transformationService = new TransformationsService(
@@ -85,9 +107,12 @@ export class TransformationsController {
   @Put(':id')
   async update(@Payload() updateTransformationDto, @Param() params) {
     const { id } = params;
-    console.log(
-      process.env.DEV_URL + `/transformation/${id}`,
-      'ON UPDATE ROUTE',
+    this.logger.info(
+      process.env.DEV_URL + `/transformation/${id} - ON UPDATE ROUTE`,
+      {
+        user: updateTransformationDto.info.user_id,
+        customer: updateTransformationDto.info.customer,
+      },
     );
 
     const transformationService = new TransformationsService(
@@ -104,9 +129,12 @@ export class TransformationsController {
   @Delete(':id')
   async delete(@Body() data, @Param() params) {
     const { id } = params;
-    console.log(
-      process.env.DEV_URL + `/transformation/${id}`,
-      'ON DELETE ROUTE',
+    this.logger.info(
+      process.env.DEV_URL + `/transformation/${id} - ON DELETE ROUTE`,
+      {
+        user: data.info.user_id,
+        customer: data.info.customer,
+      },
     );
 
     const transformationService = new TransformationsService(

src/modules/transformations/transformations.service.spec.ts

@@ -1,5 +0,0 @@
-describe('PipelinesGrpcServerService', () => {
-  it('should be defined', () => {
-    expect(2 + 2).toBe(4);
-  });
-});

src/utils/ErrorBuilder.ts

@@ -3,7 +3,7 @@ import { RpcException } from '@nestjs/microservices';
 
 import ErrorCodes from './errorCodes';
 
-function enrichErrorCode(code: string) {
+export function EnrichErrorCode(code: string) {
   switch (code) {
     case ErrorCodes.AUTH.WRONG_CREDENTIALS:
       return {
@@ -138,7 +138,7 @@ export default class ErrorBuilder extends HttpException {
       logger.log(code);
     }
 
-    const { statusCode, message, error, code: rCode } = enrichErrorCode(code);
+    const { statusCode, message, error, code: rCode } = EnrichErrorCode(code);
     super({ statusCode, message, error, code: rCode }, statusCode);
     this.code = code;
   }

src/utils/grpcHandler.ts

@@ -1,19 +0,0 @@
-import { Logger } from '@nestjs/common';
-import { RpcException } from '@nestjs/microservices';
-import { from } from 'rxjs';
-
-import ErrorBuilder from './ErrorBuilder';
-
-const logger = new Logger();
-
-export default async function grpcHandler<T>(method: Promise<T>) {
-  return new Promise<T>((resolve, reject) => {
-    from(method).subscribe({
-      next: resolve,
-      error: reject,
-      complete: () => logger.log('done'),
-    });
-  }).catch((err: RpcException) => {
-    throw new ErrorBuilder(err);
-  });
-}