FIX: send all metadata

FIX: correct env

helmfiles/prd.yaml

@@ -15,8 +15,8 @@ charts:
       - name: maestro.tr_factory_url
         value: in-factory.dadosfera.ai
       - name: maestro.open_customer_id
-        value: f239718a-a271-4ef9-ae7e-02a2f0f3aa6e
+        value: b3e3dfe5-b992-4586-a73c-c0b0c00f615d
       - name: maestro.open_group_id
-        value: 401573bb-334f-44b2-b30e-88d4cea31ae9
+        value: c0afdcce-c5be-40d0-9d1d-2d271121f14a
       - name: replicaCount
         value: 2

helmfiles/stg.yaml

@@ -9,11 +9,11 @@ charts:
       - name: hostname
         value: maestro.stg.dadosfera.ai
       - name: maestro.pi_factory_url
-        value: pi-factory.dadosfera.ai
+        value: pi-factory.stg.dadosfera.ai
       - name: maestro.in_factory_url
-        value: in-factory.dadosfera.ai
+        value: in-factory.stg.dadosfera.ai
       - name: maestro.tr_factory_url
-        value: in-factory.dadosfera.ai
+        value: in-factory.stg.dadosfera.ai
       - name: maestro.open_customer_id
         value: b3e3dfe5-b992-4586-a73c-c0b0c00f615d
       - name: maestro.open_group_id

package-lock.json

@@ -12,7 +12,7 @@
         "@aws-sdk/client-secrets-manager": "^3.414.0",
         "@dadosfera/dadosfera-logs": "^1.0.0-beta.4",
         "@dadosfera/protospack": "2.5.3",
-        "@dadosfera/protospack-v2": "3.37.0-alpha.18",
+        "@dadosfera/protospack-v2": "3.37.0-alpha.19",
         "@grpc/grpc-js": "^1.9.3",
         "@grpc/proto-loader": "^0.7.9",
         "@nestjs/cli": "^9.5.0",
@@ -1397,9 +1397,9 @@
       }
     },
     "node_modules/@dadosfera/protospack-v2": {
-      "version": "3.37.0-alpha.18",
-      "resolved": "https://dadosfera-611330257153.d.codeartifact.us-east-1.amazonaws.com/npm/dadosfera-npm/@dadosfera/protospack-v2/-/protospack-v2-3.37.0-alpha.18.tgz",
-      "integrity": "sha512-hhcskw1DT9jtmJcQXrFwgUnTti6ZALZM04YevJgqQNR6yS+C6040UZf3c/6vcjRm5/9h9OMiJJApzivPTBK46g==",
+      "version": "3.37.0-alpha.19",
+      "resolved": "https://dadosfera-611330257153.d.codeartifact.us-east-1.amazonaws.com/npm/dadosfera-npm/@dadosfera/protospack-v2/-/protospack-v2-3.37.0-alpha.19.tgz",
+      "integrity": "sha512-+F2sMJszfXRqWuN5ae+v7MqHhJyg7TgVvnuFBKUOwHvBoWCfAUnIm9XGEA/YjPpRUa1gM0nnKL8SpBFf43Q1aA==",
       "license": "ISC",
       "dependencies": {
         "@grpc/grpc-js": "^1.9.3",

package.json

@@ -30,7 +30,7 @@
     "@aws-sdk/client-secrets-manager": "^3.414.0",
     "@dadosfera/dadosfera-logs": "^1.0.0-beta.4",
     "@dadosfera/protospack": "2.5.3",
-    "@dadosfera/protospack-v2": "3.37.0-alpha.18",
+    "@dadosfera/protospack-v2": "3.37.0-alpha.19",
     "@grpc/grpc-js": "^1.9.3",
     "@grpc/proto-loader": "^0.7.9",
     "@nestjs/cli": "^9.5.0",

src/modules/auth/auth.controller.ts

@@ -43,6 +43,7 @@ import {
   AuthRefreshAccessTokenRes,
   AuthSignInReq,
   AuthSignInRes,
+  BulkEditRequest,
 } from './dtos/login';
 import { PackTheMetadata } from 'src/utils/ PackTheMetadata';
 import { AuthGuard } from '@nestjs/passport';
@@ -52,9 +53,7 @@ import jwt from 'jsonwebtoken';
 import { LanguageEnum } from 'src/utils/languages.enum';
 import { Language } from 'src/decorators/language.decorator';
 import { ApiInternalOnlyEndpoint } from 'src/decorators/swagger.decorator';
-import { Metadata } from '@grpc/grpc-js';
-import { lastValueFrom } from 'rxjs';
-import { UserOneResponse } from '@dadosfera/protospack-v2/dist/lib/Duc/interfaces/messages';
+
 
 @ApiTags('Auth')
 @ApiHeaders([{ name: 'dadosfera-lang', enum: LanguageEnum, required: false }])
@@ -356,14 +355,12 @@ export class AuthController {
   async blockUsers(
     @Language() language: LanguageEnum,
     @User() user: RequestUser,
+    @Body() body: BulkEditRequest
   ) {
     this.logger.info('blockUsers - Starting request');
-    
+  
     try {
-      const metadata = PackTheMetadata({
-        customer_id: user.customer_id,
-        language,
-      });
+      const metadata = PackTheMetadata(user);
 
       this.logger.debug('Calling blockUsers service', {
         metadata: {
@@ -372,7 +369,7 @@ export class AuthController {
         }
       });
 
-      const result = await this.authClient.blockUsers(metadata);
+      const result = await this.authClient.blockUsers(body.users, metadata);
       this.logger.info('blockUsers - Success', { result });
       return result;
     } catch (error) {
@@ -391,14 +388,12 @@ export class AuthController {
   async unblockUsers(
     @Language() language: LanguageEnum,
     @User() user: RequestUser,
+    @Body() body: BulkEditRequest
   ) {
     this.logger.info('unblockUsers');
-    const metadata = PackTheMetadata({
-      customer_id: user.customer_id,
-      language,
-    });
+    const metadata = PackTheMetadata(user);
 
-    return this.authClient.unblockUsers(metadata);
+    return this.authClient.unblockUsers(body.users, metadata);
   }
 
   @ApiInternalOnlyEndpoint()
@@ -408,13 +403,11 @@ export class AuthController {
   async resetUsers(
     @Language() language: LanguageEnum,
     @User() user: RequestUser,
+    @Body() body: BulkEditRequest
   ) {
     this.logger.info('resetUsers');
-    const metadata = PackTheMetadata({
-      access_token: user.access_token,
-      language,
-    });
+    const metadata = PackTheMetadata(user);
 
-    return this.authClient.resetUsers( metadata);
+    return this.authClient.resetUsers(body.users,  metadata);
   }
 }

src/modules/auth/auth.service.ts

@@ -20,7 +20,7 @@ import {
 } from '@dadosfera/protospack-v2/dist/lib/Duc/interfaces/messages';
 import { DucClient } from '../duc/client.config';
 import { Metadata } from '@grpc/grpc-js';
-import { UserActionRequest, UserActionResponse } from './dtos/login';
+import { BulkEditResponse } from './dtos/login';
 
 @Injectable()
 export class AuthClientService implements OnModuleInit {
@@ -170,7 +170,7 @@ export class AuthClientService implements OnModuleInit {
     );
   }
 
-  async blockUsers(metadata: Metadata): Promise<UserActionResponse> {
+  async blockUsers(users: string[],metadata: Metadata): Promise<BulkEditResponse> {
     this.logger.info('blockUsers - Service starting');
     
     try {
@@ -181,8 +181,8 @@ export class AuthClientService implements OnModuleInit {
         }
       });
 
-      const response = await lastValueFrom<UserActionResponse>(
-        this.authService.BlockUser({}, metadata),
+      const response = await lastValueFrom<BulkEditResponse>(
+        this.authService.BlockUser({ users }, metadata),
       );
 
       this.logger.info('blockUsers - Service success', { response });
@@ -196,14 +196,14 @@ export class AuthClientService implements OnModuleInit {
     }
   }
 
-  async unblockUsers(metadata: Metadata): Promise<UserActionResponse> {
+  async unblockUsers(users: string[],metadata: Metadata): Promise<BulkEditResponse> {
     this.logger.info('unblockUsers');
     return await lastValueFrom(
-      this.authService.UnblockUser({}, metadata),
+      this.authService.UnblockUser({ users }, metadata),
     );
   }
 
-  async resetUsers(metadata: Metadata): Promise<UserActionResponse> {
+  async resetUsers(users: string[], metadata: Metadata): Promise<BulkEditResponse> {
     this.logger.info('resetUsers');
     
     try {
@@ -214,8 +214,8 @@ export class AuthClientService implements OnModuleInit {
         }
       });
 
-      const response = await lastValueFrom<UserActionResponse>(
-        this.authService.ResetUser({}, metadata)
+      const response = await lastValueFrom<BulkEditResponse>(
+        this.authService.ResetUser({ users }, metadata)
       );
 
       this.logger.info('resetUsers - Success', { response });

src/modules/auth/dtos/login.ts

@@ -129,14 +129,11 @@ export class AuthRefreshAccessTokenRes {
   accessToken: string;
 }
 
-export interface UserActionRequest {
-  users: {
-    userIds: string[];
-  };
-  defaultPassword?: string;
+export interface BulkEditRequest {
+  users: string[];
 }
 
-export interface UserActionResponse {
+export interface BulkEditResponse {
   message: string;
   successfulUsers: string[];
   failedUsers: string[];