FIX: sending metadata on creation of users

src/modules/users/users.controller.ts

@@ -45,6 +45,7 @@ import {
   UserByCustomer,
 } from './dtos/entities';
 import { UsersService } from './users.service';
+import { Metadata } from '@grpc/grpc-js';
 
 // TODO GET de hierarquias e do PATCH em usuário
 @ApiTags('Users')
@@ -141,9 +142,12 @@ export class UsersController {
     @Body() body: CreateUserReq,
     @Headers('dadosfera-lang') language,
   ) {
+    const meta = new Metadata();
+    meta.add('access_token', user.access_token);
     this.logger.info('createUser', { user });
     this.userService.setLanguage(language);
-    return await this.userService.createUser(body);
+
+    return await this.userService.createUser(body, meta);
   }
 
   @Post('batch')
@@ -154,9 +158,11 @@ export class UsersController {
     @Body() body: BatchCreateUserReq,
     @Headers('dadosfera-lang') language,
   ) {
+    const meta = new Metadata();
+    meta.add('access_token', user.access_token);
     this.logger.info('batchCreateUser', { user });
     this.userService.setLanguage(language);
-    return await this.userService.batchCreateUser(body);
+    return await this.userService.batchCreateUser(body, meta);
   }
 
   @Post(':id/resend-invite')

src/modules/users/users.service.ts

@@ -27,6 +27,7 @@ import { LanguageEnum } from 'src/utils/languages.enum';
 import { UserByCustomer } from '@dadosfera/protospack-v2/dist/lib/Duc/interfaces/entities';
 import { EnrichErrorCode } from 'src/utils/ErrorBuilder';
 import { DucClient } from '../duc/client.config';
+import { Metadata } from '@grpc/grpc-js';
 
 @Injectable()
 export class UsersService implements OnModuleInit {
@@ -83,18 +84,21 @@ export class UsersService implements OnModuleInit {
     return { user: this.adjustUsersPayload([user])[0] };
   }
 
-  async createUser(req: CreateUserReq) {
+  async createUser(req: CreateUserReq, meta?: Metadata) {
     const { email, department, hierarchy, jobTitle, name, roleNames } = req;
     const { user } = await lastValueFrom(
-      this.usersClientService.UserCreate({
-        email,
-        hierarchy,
-        name,
-        roleIds: [],
-        department,
-        jobTitle,
-        roleNames,
-      }),
+      this.usersClientService.UserCreate(
+        {
+          email,
+          hierarchy,
+          name,
+          roleIds: [],
+          department,
+          jobTitle,
+          roleNames,
+        },
+        meta,
+      ),
     );
     return { user: this.adjustUsersPayload([user])[0] };
   }
@@ -134,7 +138,8 @@ export class UsersService implements OnModuleInit {
     return { user: this.adjustUsersPayload([user])[0] };
   }
 
-  async batchCreateUser({ users }: BatchCreateUserReq) {
+  async batchCreateUser(req: BatchCreateUserReq, meta?: Metadata) {
+    const { users } = req;
     const usersToCreate: UserCreateRequest[] = users.map(
       ({ roleNames, email, department, hierarchy, jobTitle, name }) => ({
         roleNames,
@@ -147,14 +152,16 @@ export class UsersService implements OnModuleInit {
       }),
     );
     const { errorUsers, usersCreated } = await lastValueFrom(
-      this.usersClientService.UserBatchCreate({
-        users: usersToCreate,
-      }),
+      this.usersClientService.UserBatchCreate(
+        {
+          users: usersToCreate,
+        },
+        meta,
+      ),
     );
 
     return {
       usersCreated: this.adjustUsersPayload(usersCreated),
-      // mapping error code to message
       errorUsers: errorUsers.map(({ user, error }) => ({
         user,
         error: EnrichErrorCode(error).message,