FIX: new route for synchronizing connections with platform

src/modules/users/users.controller.ts

@@ -22,7 +22,7 @@ import {
 } from '@nestjs/swagger';
 import { DadosferaLogger } from '@dadosfera/dadosfera-logs';
 import { RequireAllPermissions } from 'src/authentication/authentication.decorator';
-import { PERMISSIONS } from 'src/authentication/permissions.enum';
+import { PERMISSIONS_GROUPS } from 'src/authentication/permissions.enum';
 import { RequestUser, User } from 'src/authentication/user.decorator';
 import { GrpcToHttpExceptionFilter } from 'src/error/grpc-to-http-exception.filter';
 import { LanguageEnum } from 'src/utils/languages.enum';
@@ -68,7 +68,7 @@ export class UsersController {
   }
 
   @Get()
-  @RequireAllPermissions(PERMISSIONS.USERS.permissions.ADMIN)
+  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
   @ApiOkResponse({
     type: GetAllUsersByCustomerIdRes,
     description: 'List of users of a customer',
@@ -83,7 +83,7 @@ export class UsersController {
   }
 
   @Get('hierarchies')
-  @RequireAllPermissions(PERMISSIONS.USERS.permissions.ADMIN)
+  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
   @ApiOkResponse({ type: GetAllHierarchiesRes })
   async getAllHierarchies(
     @User() user: RequestUser,
@@ -95,7 +95,7 @@ export class UsersController {
   }
 
   @Get('departments')
-  @RequireAllPermissions(PERMISSIONS.USERS.permissions.ADMIN)
+  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
   @ApiOkResponse({ type: GetAllDepartmentsRes })
   async getAllDepartments(
     @User() user: RequestUser,
@@ -107,7 +107,7 @@ export class UsersController {
   }
 
   @Get('jobTitles')
-  @RequireAllPermissions(PERMISSIONS.USERS.permissions.ADMIN)
+  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
   @ApiOkResponse({ type: GetAllDepartmentsRes })
   async getAllJobTitles(
     @User() user: RequestUser,
@@ -119,7 +119,7 @@ export class UsersController {
   }
 
   @Get(':id')
-  @RequireAllPermissions(PERMISSIONS.USERS.permissions.ADMIN)
+  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
   @ApiOkResponse({
     type: UserByCustomer,
   })
@@ -134,7 +134,7 @@ export class UsersController {
   }
 
   @Post()
-  @RequireAllPermissions(PERMISSIONS.USERS.permissions.ADMIN)
+  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
   @ApiCreatedResponse({ type: CreateUserRes })
   async createUser(
     @User() user: RequestUser,
@@ -147,7 +147,7 @@ export class UsersController {
   }
 
   @Post('batch')
-  @RequireAllPermissions(PERMISSIONS.USERS.permissions.ADMIN)
+  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
   @ApiCreatedResponse({ type: BatchCreateUserRes })
   async batchCreateUser(
     @User() user: RequestUser,
@@ -160,7 +160,7 @@ export class UsersController {
   }
 
   @Post(':id/resend-invite')
-  @RequireAllPermissions(PERMISSIONS.USERS.permissions.ADMIN)
+  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
   @HttpCode(HttpStatus.OK)
   async resendInvite(
     @User() user: RequestUser,
@@ -173,7 +173,7 @@ export class UsersController {
   }
 
   @Delete('role')
-  @RequireAllPermissions(PERMISSIONS.USERS.permissions.ADMIN)
+  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
   async unassignRoleToUser(
     @User() user: RequestUser,
     @Query() request: UnassignRoleToUserReq,
@@ -185,7 +185,7 @@ export class UsersController {
   }
 
   @Delete(':id')
-  @RequireAllPermissions(PERMISSIONS.USERS.permissions.ADMIN)
+  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
   @ApiOkResponse({ type: DeleteUserRes })
   async deleteUser(
     @User() user: RequestUser,
@@ -198,7 +198,7 @@ export class UsersController {
   }
 
   @Patch('roles')
-  @RequireAllPermissions(PERMISSIONS.USERS.permissions.ADMIN)
+  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
   @ApiOkResponse({ type: SetUserRolesRes })
   async setUserRoles(
     @User() user: RequestUser,
@@ -211,7 +211,7 @@ export class UsersController {
   }
 
   @Put('role')
-  @RequireAllPermissions(PERMISSIONS.USERS.permissions.ADMIN)
+  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
   async assignRoleToUser(
     @User() user: RequestUser,
     @Body() body: AssignRoleToUserReq,
@@ -223,7 +223,7 @@ export class UsersController {
   }
 
   @Patch(':id')
-  @RequireAllPermissions(PERMISSIONS.USERS.permissions.ADMIN)
+  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
   @ApiOkResponse({ type: UpdateUserRes })
   async updateUser(
     @User() user: RequestUser,

src/modules/users/users.module.ts

@@ -17,5 +17,6 @@ const client = new DucClient();
   ],
   controllers: [UsersController],
   providers: [UsersService, DadosferaLogger],
+  exports: [UsersService],
 })
 export class UsersModule {}

src/modules/users/users.service.ts

@@ -3,7 +3,10 @@ import { ClientGrpc } from '@nestjs/microservices';
 import { DadosferaLogger } from '@dadosfera/dadosfera-logs';
 
 import { ProtoServices } from '@dadosfera/protospack-v2/dist/lib/Duc';
-import { UsersProtoService } from '@dadosfera/protospack-v2/dist/lib/Duc/interfaces/write-service';
+import {
+  CustomersProtoService,
+  UsersProtoService,
+} from '@dadosfera/protospack-v2/dist/lib/Duc/interfaces/write-service';
 import {
   AssignRoleToUserRequest,
   IdRequest,
@@ -31,6 +34,7 @@ export class UsersService implements OnModuleInit {
   language: LanguageEnum = LanguageEnum.ptbr;
 
   private usersClientService: UsersProtoService;
+  private customersClientService: CustomersProtoService;
   constructor(
     @Inject(DadosferaLogger)
     dadosferaLogger: DadosferaLogger,
@@ -41,9 +45,12 @@ export class UsersService implements OnModuleInit {
   }
 
   onModuleInit() {
-    this.usersClientService = this.grpcClient.getService<UsersProtoService>(
+    this.usersClientService = this.grpcClient.getService(
       ProtoServices.UsersProtoService,
     );
+    this.customersClientService = this.grpcClient.getService(
+      ProtoServices.CustomersProtoService,
+    );
   }
 
   setLanguage(l: LanguageEnum = LanguageEnum.ptbr) {
@@ -200,4 +207,8 @@ export class UsersService implements OnModuleInit {
       };
     });
   }
+
+  async findaAllCustomers() {
+    return await lastValueFrom(this.customersClientService.CustomerFindAll({}));
+  }
 }