Merge pull request #294 from dadosfera/feature/logs_dashboard

Feature/logs dashboard

docsfera.json

@@ -20,14 +20,6 @@
                 ],
                 "type": "string"
               }
-            },
-            {
-              "name": "origin",
-              "required": true,
-              "in": "header",
-              "schema": {
-                "type": "string"
-              }
             }
           ],
           "requestBody": {
@@ -72,14 +64,6 @@
                 ],
                 "type": "string"
               }
-            },
-            {
-              "name": "origin",
-              "required": true,
-              "in": "header",
-              "schema": {
-                "type": "string"
-              }
             }
           ],
           "requestBody": {
@@ -265,14 +249,6 @@
                 ],
                 "type": "string"
               }
-            },
-            {
-              "name": "origin",
-              "required": true,
-              "in": "header",
-              "schema": {
-                "type": "string"
-              }
             }
           ],
           "responses": {
@@ -5473,57 +5449,6 @@
           ]
         }
       },
-      "/customers/{id}/mfa": {
-        "post": {
-          "operationId": "CustomersController_enableMfaEnforce",
-          "parameters": [
-            {
-              "name": "id",
-              "required": true,
-              "in": "path",
-              "schema": {
-                "type": "string"
-              }
-            }
-          ],
-          "requestBody": {
-            "required": true,
-            "content": {
-              "application/json": {
-                "schema": {
-                  "$ref": "#/components/schemas/EnforceMfa"
-                }
-              }
-            }
-          },
-          "responses": {
-            "201": {
-              "description": "",
-              "content": {
-                "application/json": {
-                  "schema": {
-                    "type": "object"
-                  }
-                }
-              }
-            }
-          },
-          "tags": [
-            "Customers"
-          ],
-          "security": [
-            {
-              "access-token": []
-            },
-            {
-              "access-token": []
-            },
-            {
-              "access-token": []
-            }
-          ]
-        }
-      },
       "/customers/{id}/links": {
         "get": {
           "operationId": "CustomersController_getCustomerLinks",
@@ -5671,34 +5596,6 @@
             "Customers"
           ],
           "security": [
-            {
-              "access-token": []
-            },
-            {
-              "access-token": []
-            },
-            {
-              "access-token": []
-            }
-          ]
-        }
-      },
-      "/customers/access-dashboard": {
-        "get": {
-          "operationId": "CustomersController_getAccessDashboard",
-          "parameters": [],
-          "responses": {
-            "200": {
-              "description": ""
-            }
-          },
-          "tags": [
-            "Customers"
-          ],
-          "security": [
-            {
-              "access-token": []
-            },
             {
               "access-token": []
             },
@@ -5840,96 +5737,6 @@
             "Health"
           ]
         }
-      },
-      "/network-policy": {
-        "get": {
-          "operationId": "NetworkPolicyController_getNetworks",
-          "parameters": [],
-          "responses": {
-            "200": {
-              "description": "",
-              "content": {
-                "application/json": {
-                  "schema": {
-                    "$ref": "#/components/schemas/NetworkPoliciesDTO"
-                  }
-                }
-              }
-            }
-          },
-          "security": [
-            {
-              "access-token": []
-            },
-            {
-              "access-token": []
-            }
-          ]
-        },
-        "post": {
-          "operationId": "NetworkPolicyController_applyNetworkPolicies",
-          "parameters": [],
-          "requestBody": {
-            "required": true,
-            "content": {
-              "application/json": {
-                "schema": {
-                  "$ref": "#/components/schemas/NetworkPoliciesDTO"
-                }
-              }
-            }
-          },
-          "responses": {
-            "200": {
-              "description": ""
-            },
-            "201": {
-              "description": "",
-              "content": {
-                "application/json": {
-                  "schema": {
-                    "type": "object"
-                  }
-                }
-              }
-            }
-          },
-          "security": [
-            {
-              "access-token": []
-            },
-            {
-              "access-token": []
-            }
-          ]
-        },
-        "delete": {
-          "operationId": "NetworkPolicyController_removeNetworkPolicies",
-          "parameters": [],
-          "requestBody": {
-            "required": true,
-            "content": {
-              "application/json": {
-                "schema": {
-                  "$ref": "#/components/schemas/NetworkPoliciesDTO"
-                }
-              }
-            }
-          },
-          "responses": {
-            "200": {
-              "description": ""
-            }
-          },
-          "security": [
-            {
-              "access-token": []
-            },
-            {
-              "access-token": []
-            }
-          ]
-        }
       }
     },
     "info": {
@@ -6000,9 +5807,6 @@
             },
             "themeEnabled": {
               "type": "boolean"
-            },
-            "enforceMfa": {
-              "type": "boolean"
             }
           },
           "required": [
@@ -6013,8 +5817,7 @@
             "tier",
             "scheduleLimit",
             "links",
-            "themeEnabled",
-            "enforceMfa"
+            "themeEnabled"
           ]
         },
         "AuthUser": {
@@ -8683,17 +8486,6 @@
             "tags"
           ]
         },
-        "EnforceMfa": {
-          "type": "object",
-          "properties": {
-            "enabled": {
-              "type": "boolean"
-            }
-          },
-          "required": [
-            "enabled"
-          ]
-        },
         "CustomerLink": {
           "type": "object",
           "properties": {
@@ -8796,20 +8588,6 @@
           "required": [
             "theme"
           ]
-        },
-        "NetworkPoliciesDTO": {
-          "type": "object",
-          "properties": {
-            "policies": {
-              "type": "array",
-              "items": {
-                "type": "string"
-              }
-            }
-          },
-          "required": [
-            "policies"
-          ]
         }
       }
     }

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-beta.22",
+        "@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-beta.22",
-      "resolved": "https://dadosfera-611330257153.d.codeartifact.us-east-1.amazonaws.com/npm/dadosfera-npm/@dadosfera/protospack-v2/-/protospack-v2-3.37.0-beta.22.tgz",
-      "integrity": "sha512-SOu+Z5qc3ms6JjtWpHFYEgYq7Q8Y2GHBewDQj5/Evv4yxpzuANw9Eecd6zzCttV47ceM75A8rnomTj9gGkoTTg==",
+      "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-beta.22",
+    "@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/app.module.ts

@@ -28,7 +28,6 @@ import { MixpanelModule } from './modules/mixpanel/mixpanel.module';
 import { CustomersModule } from './modules/customers/customers.module';
 import { OpenDataModule } from './modules/open-data/open-data.module';
 import { ThemeModule } from './modules/theme/theme.module';
-import { NetworkPolicyModule } from './modules/network-policy/network-policy.module';
 
 @Module({
   providers: [
@@ -63,8 +62,7 @@ import { NetworkPolicyModule } from './modules/network-policy/network-policy.mod
     OpenDataModule,
     ThemeModule,
     //Always leave HealthModule last, so it is on the bottom of swagger
-    HealthModule,
-    NetworkPolicyModule
+    HealthModule
   ],
 })
 export class AppModule {}

src/authentication/permissions.enum.ts

@@ -612,8 +612,7 @@ export interface DadosferaModule {
 
 export const DADOSFERA_MODULES_KEYS = {
   LOG_DASHBOARD: 'logs-dashboard',
-  ACCESS_DASHBOARD: 'access-dashboard',
-  DANGER_ZONE: 'danger-zone'
+  ACCESS_DASHBOARD: 'access-dashboard'
 }
 
 export const DADOSFERA_MODULES: Array<DadosferaModule> = [

src/modules/auth/auth.controller.ts

@@ -54,6 +54,7 @@ import { LanguageEnum } from 'src/utils/languages.enum';
 import { Language } from 'src/decorators/language.decorator';
 import { ApiInternalOnlyEndpoint } from 'src/decorators/swagger.decorator';
 
+
 @ApiTags('Auth')
 @ApiHeaders([{ name: 'dadosfera-lang', enum: LanguageEnum, required: false }])
 @UseFilters(new GrpcToHttpExceptionFilter())
@@ -62,6 +63,7 @@ export class AuthController {
   logger: DadosferaLogger;
   redirectUrl: string;
 
+
   constructor(
     @Inject(DadosferaLogger)
     dadosferaLogger: DadosferaLogger,
@@ -86,12 +88,9 @@ export class AuthController {
   async signIn(
     @Body() { username, password, totp }: AuthSignInReq,
     @Language() language: LanguageEnum,
-    @Headers('origin') origin: string,
   ): Promise<AuthSignInRes> {
     this.logger.info('/auth - SignIn');
-    const frontHost = origin.replace(/^https?:\/\//, '');
-    const metadata = PackTheMetadata({ language, custom_host: frontHost });
-    this.logger.info('metadata: ' + JSON.stringify(metadata.toJSON()));
+    const metadata = PackTheMetadata({ language });
     return this.authClient.signIn({ username, password, totp }, metadata);
   }
 
@@ -101,15 +100,13 @@ export class AuthController {
   async refreshAccessToken(
     @Body() body: AuthRefreshAccessTokenReq,
     @Language() language: LanguageEnum,
-    @Headers('origin') origin: string,
   ) {
     this.logger.info('/auth - RefreshAccessToken');
     const { refreshToken, customerName: customer_name } = body;
-    const frontHost = origin.replace(/^https?:\/\//, '');
+
     const metadata = PackTheMetadata({
-      language,
       customer_name,
-      custom_host: frontHost,
+      language,
     });
 
     return this.authClient.refreshAccessToken({ refreshToken }, metadata);
@@ -183,23 +180,16 @@ export class AuthController {
   @ApiInternalOnlyEndpoint()
   @Post('confirm-reset-password')
   @HttpCode(HttpStatus.OK)
-  async confirmResetPassword(
-    @Body() body: AuthConfirmResetPasswordRequest,
-    @Headers('origin') origin: string,
-  ) {
+  async confirmResetPassword(@Body() body: AuthConfirmResetPasswordRequest) {
     this.logger.info('/auth - confirm-reset-password');
-    const frontHost = origin.replace(/^https?:\/\//, '');
-    const metadata = PackTheMetadata({ custom_host: frontHost });
+
     const { username, code, newPassword } = body;
 
-    return this.authClient.confirmResetPassword(
-      {
-        username,
-        code,
-        newPassword,
-      },
-      metadata,
-    );
+    return this.authClient.confirmResetPassword({
+      username,
+      code,
+      newPassword,
+    });
   }
 
   @ApiInternalOnlyEndpoint()
@@ -365,18 +355,18 @@ export class AuthController {
   async blockUsers(
     @Language() language: LanguageEnum,
     @User() user: RequestUser,
-    @Body() body: BulkEditRequest,
+    @Body() body: BulkEditRequest
   ) {
     this.logger.info('blockUsers - Starting request');
-
+  
     try {
       const metadata = PackTheMetadata(user);
 
       this.logger.debug('Calling blockUsers service', {
         metadata: {
           access_token: metadata.get('access_token'),
-          language: metadata.get('language'),
-        },
+          language: metadata.get('language')
+        }
       });
 
       const result = await this.authClient.blockUsers(body.users, metadata);
@@ -385,7 +375,7 @@ export class AuthController {
     } catch (error) {
       this.logger.error('blockUsers - Error', {
         error: error.message,
-        stack: error.stack,
+        stack: error.stack
       });
       throw error;
     }
@@ -398,7 +388,7 @@ export class AuthController {
   async unblockUsers(
     @Language() language: LanguageEnum,
     @User() user: RequestUser,
-    @Body() body: BulkEditRequest,
+    @Body() body: BulkEditRequest
   ) {
     this.logger.info('unblockUsers');
     const metadata = PackTheMetadata(user);
@@ -413,11 +403,11 @@ export class AuthController {
   async resetUsers(
     @Language() language: LanguageEnum,
     @User() user: RequestUser,
-    @Body() body: BulkEditRequest,
+    @Body() body: BulkEditRequest
   ) {
     this.logger.info('resetUsers');
     const metadata = PackTheMetadata(user);
 
-    return this.authClient.resetUsers(body.users, metadata);
+    return this.authClient.resetUsers(body.users,  metadata);
   }
 }

src/modules/auth/auth.service.ts

@@ -113,21 +113,19 @@ export class AuthClientService implements OnModuleInit {
     );
   }
 
-  async confirmResetPassword(
-    { username, code, newPassword }: AuthConfirmResetPasswordRequest,
-    metadata: Metadata,
-  ) {
+  async confirmResetPassword({
+    username,
+    code,
+    newPassword,
+  }: AuthConfirmResetPasswordRequest) {
     this.logger.info('confirmResetPassword');
 
     return lastValueFrom(
-      this.authService.AuthConfirmResetPassword(
-        {
-          username,
-          code,
-          newPassword,
-        },
-        metadata,
-      ),
+      this.authService.AuthConfirmResetPassword({
+        username,
+        code,
+        newPassword,
+      }),
     );
   }
 
@@ -172,18 +170,15 @@ export class AuthClientService implements OnModuleInit {
     );
   }
 
-  async blockUsers(
-    users: string[],
-    metadata: Metadata,
-  ): Promise<BulkEditResponse> {
+  async blockUsers(users: string[],metadata: Metadata): Promise<BulkEditResponse> {
     this.logger.info('blockUsers - Service starting');
-
+    
     try {
       this.logger.debug('Calling BlockUser gRPC method', {
         metadata: {
           access_token: metadata.get('access_token'),
-          language: metadata.get('language'),
-        },
+          language: metadata.get('language')
+        }
       });
 
       const response = await lastValueFrom<BulkEditResponse>(
@@ -201,32 +196,26 @@ export class AuthClientService implements OnModuleInit {
     }
   }
 
-  async unblockUsers(
-    users: string[],
-    metadata: Metadata,
-  ): Promise<BulkEditResponse> {
+  async unblockUsers(users: string[],metadata: Metadata): Promise<BulkEditResponse> {
     this.logger.info('unblockUsers');
     return await lastValueFrom(
       this.authService.UnblockUser({ users }, metadata),
     );
   }
 
-  async resetUsers(
-    users: string[],
-    metadata: Metadata,
-  ): Promise<BulkEditResponse> {
+  async resetUsers(users: string[], metadata: Metadata): Promise<BulkEditResponse> {
     this.logger.info('resetUsers');
-
+    
     try {
       this.logger.debug('Calling ResetUser gRPC method', {
         metadata: {
           access_token: metadata.get('access_token'),
-          language: metadata.get('language'),
-        },
+          language: metadata.get('language')
+        }
       });
 
       const response = await lastValueFrom<BulkEditResponse>(
-        this.authService.ResetUser({ users }, metadata),
+        this.authService.ResetUser({ users }, metadata)
       );
 
       this.logger.info('resetUsers - Success', { response });
@@ -234,7 +223,7 @@ export class AuthClientService implements OnModuleInit {
     } catch (error) {
       this.logger.error('resetUsers - Error', {
         error: error.message,
-        stack: error.stack,
+        stack: error.stack
       });
       throw error;
     }

src/modules/auth/dtos/login.ts

@@ -87,8 +87,6 @@ export class AuthCustomer {
 
   @ApiProperty()
   themeEnabled: boolean;
-  @ApiProperty()
-  enforceMfa: boolean;
 }
 
 export class AuthSignInReq implements AuthSignInRequest {

src/modules/customers/customers.controller.ts

@@ -7,7 +7,6 @@ import {
   HttpStatus,
   Inject,
   Param,
-  Post,
   Put,
   Query,
   UseFilters,
@@ -18,7 +17,6 @@ import {
   Authenticated,
   RequireAllPermissions,
   RequireModule,
-  RequireSomePermission,
 } from 'src/decorators/authentication.decorator';
 import { GrpcToHttpExceptionFilter } from 'src/error/grpc-to-http-exception.filter';
 import { CustomersService } from './customers.service';
@@ -26,7 +24,6 @@ import { CustomerLinkRequest, CustomerLinksResponse } from './dtos/customers';
 import { RequestUser, User } from 'src/decorators/user.decorator';
 import type { StringValue } from 'ms';
 import { PackTheMetadata } from 'src/utils/ PackTheMetadata';
-import { EnforceMfa } from './dtos/enforce-mfa';
 
 @ApiTags('Customers')
 @Controller('customers')
@@ -42,15 +39,6 @@ export class CustomersController {
     this.logger = dadosferaLogger.logger;
   }
 
-  @Post(':id/mfa')
-  @Authenticated()
-  @RequireSomePermission(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
-  @RequireModule(DADOSFERA_MODULES_KEYS.DANGER_ZONE)
-  async enableMfaEnforce(@Param('id') id: string, @Body() data: EnforceMfa) {
-    this.logger.info('enableMfaEnforce', { id });
-    return await this.customersService.enableEnforceMfa(id, data.enabled);
-  }
-
   @Get(':id/links')
   @Authenticated()
   @ApiOkResponse({ type: CustomerLinksResponse })

src/modules/customers/customers.service.ts

@@ -34,7 +34,6 @@ import DadosferaLogger from '@dadosfera/dadosfera-logs';
 // This function will accept any string, which may result in a bug.
 @Injectable()
 export class CustomersService implements OnModuleInit {
-
   private customerService: CustomersProtoService;
   private logger: DadosferaLogger;
   private pipelineReadService: ReadService.PipelineV2ReadService;
@@ -204,13 +203,4 @@ export class CustomersService implements OnModuleInit {
       )
     );
   }
-
-  async enableEnforceMfa(id: string, enabled: boolean) {
-    return await lastValueFrom(
-      this.customerService.CustomerUpdateEnforceMfa({
-        customerId: id,
-        enforceMfa: enabled
-      })
-    )
-  }
 }

src/modules/customers/dtos/enforce-mfa.ts

@@ -1,6 +0,0 @@
-import { ApiProperty } from "@nestjs/swagger";
-
-export class EnforceMfa {
-    @ApiProperty()
-    enabled: boolean
-}

src/modules/network-policy/dto/network-policy.dto.ts

@@ -1,6 +0,0 @@
-import { ApiProperty } from "@nestjs/swagger";
-
-export class NetworkPoliciesDTO {
-    @ApiProperty()
-    policies: string []
-}

src/modules/network-policy/network-policy.controller.ts

@@ -1,64 +0,0 @@
-import { Body, Controller, Delete, Get, HttpCode, HttpStatus, Post } from '@nestjs/common';
-import { ApiOkResponse } from '@nestjs/swagger';
-import { PERMISSIONS_GROUPS } from 'src/authentication/permissions.enum';
-import {
-  Authenticated,
-  RequireAllPermissions,
-} from 'src/decorators/authentication.decorator';
-import { NetworkPoliciesDTO } from './dto/network-policy.dto';
-import { RequestUser, User } from 'src/decorators/user.decorator';
-import { NetworkPolicyService } from './network-policy.service';
-import { PackTheMetadata } from 'src/utils/ PackTheMetadata';
-
-@Controller('network-policy')
-export class NetworkPolicyController {
-  constructor(private networkPolicyService: NetworkPolicyService) {}
-
-  @Get()
-  @Authenticated()
-  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
-  @HttpCode(HttpStatus.OK)
-  async getNetworks(
-    @User() user: RequestUser,
-  ) {
-    return await this.networkPolicyService.getByCustomer(
-      user.customer_id
-    );
-  }
-
-  @Post()
-  @Authenticated()
-  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
-  @ApiOkResponse()
-  @HttpCode(HttpStatus.CREATED)
-  async applyNetworkPolicies(
-    @User() user: RequestUser,
-    @Body() data: NetworkPoliciesDTO,
-  ) {
-    const metadata = PackTheMetadata(user);
-
-    return await this.networkPolicyService.apply(
-      data.policies,
-      user.customer_id,
-      metadata,
-    );
-  }
-
-  @Delete()
-  @Authenticated()
-  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
-  @ApiOkResponse()
-  @HttpCode(HttpStatus.OK)
-  async removeNetworkPolicies(
-    @User() user: RequestUser,
-    @Body() data: NetworkPoliciesDTO,
-  ) {
-    const metadata = PackTheMetadata(user);
-
-    return await this.networkPolicyService.delete(
-      data.policies,
-      user.customer_id,
-      metadata,
-    );
-  }
-}

src/modules/network-policy/network-policy.module.ts

@@ -1,19 +0,0 @@
-import { Module } from '@nestjs/common';
-import { NetworkPolicyController } from './network-policy.controller';
-import { NetworkPolicyService } from './network-policy.service';
-import { ClientsModule } from '@nestjs/microservices';
-import { DucClient } from '../duc/client.config';
-import DadosferaLogger from '@dadosfera/dadosfera-logs';
-
-const ducClient = new DucClient();
-
-@Module({
-  imports: [
-    ClientsModule.register([
-      ducClient.providerOptions
-    ]),
-  ],
-  controllers: [NetworkPolicyController],
-  providers: [NetworkPolicyService, DadosferaLogger]
-})
-export class NetworkPolicyModule {}

src/modules/network-policy/network-policy.service.ts

@@ -1,74 +0,0 @@
-import { Inject, Injectable } from '@nestjs/common';
-import { DucClient } from '../duc/client.config';
-import { ClientGrpc } from '@nestjs/microservices';
-import DadosferaLogger from '@dadosfera/dadosfera-logs';
-import { CustomersProtoService } from '@dadosfera/protospack-v2/dist/lib/Duc/interfaces/write-service';
-import { ProtoServices } from '@dadosfera/protospack-v2/dist/lib/Duc';
-import { Metadata } from '@grpc/grpc-js';
-import { lastValueFrom } from 'rxjs';
-import { NetworkPoliciesDTO } from './dto/network-policy.dto';
-
-
-@Injectable()
-export class NetworkPolicyService {
-  private customerService: CustomersProtoService;
-  private logger: DadosferaLogger;
-
-  constructor(
-    @Inject(DucClient.name) private readonly grpcClient: ClientGrpc,
-    @Inject(DadosferaLogger)
-    dadosferaLogger: DadosferaLogger,
-  ) {
-    this.logger = dadosferaLogger.logger;
-  }
-
-  onModuleInit() {
-    this.customerService = this.grpcClient.getService<CustomersProtoService>(
-      ProtoServices.CustomersProtoService,
-    );
-  }
-
-  async getByCustomer(id: string): Promise<NetworkPoliciesDTO> {
-    const {
-      customer
-    } = await lastValueFrom(this.customerService.CustomerFindOneById({
-      id
-    }));
-
-    return {
-      policies: customer.networkPolicies
-    }
-  }
-
-  async apply(
-    networkPolicies: string[],
-    customerId: string,
-    metadata: Metadata,
-  ) {
-    return await lastValueFrom(
-      this.customerService.CustomerCreateNetworkPolicy(
-        {
-          customerId,
-          networkPolicies,
-        },
-        metadata,
-      ),
-    );
-  }
-
-  async delete(
-    networkPolicies: string[],
-    customerId: string,
-    metadata: Metadata,
-  ) {
-    return await lastValueFrom(
-      this.customerService.CustomerRemoveNetworkPolicy(
-        {
-          customerId,
-          networkPolicies,
-        },
-        metadata,
-      ),
-    );
-  }
-}

src/utils/ PackTheMetadata.ts

@@ -11,9 +11,6 @@ interface IMetadata {
   roles?: string[];
   is_data_manager?: boolean;
   access_token?: string;
-  host?: string;
-  origin?: string;
-  custom_host?: string;
 }
 
 export function PackTheMetadata(info: IMetadata): Metadata {