FIX: Revoke Permissions

src/modules/catalog/catalog.controller.ts

@@ -70,6 +70,27 @@ export class CatalogController {
     return { data_asset: JSON.parse(response.data_asset) };
   }
 
+  @Put('revoke_permissions/:id')
+  async revokeDataAssetPermissions(
+    @Param('id') id: string,
+    @User() user: RequestUser,
+    @Body() body,
+  ) {
+    const { customer_id, customer_name, user_id, username } = user;
+    const metadata = PackTheMetadata({
+      customer_id,
+      customer_name,
+      user_id,
+      username,
+    });
+    const response = await this.catalogService.revokePermissions(
+      { ...body, id },
+      metadata,
+    );
+
+    return { message: response.message };
+  }
+
   @Get('all')
   async catalogAll(@User() user: RequestUser, @Body() body, @Query() params) {
     const { user_id, customer_name, customer_id, username } = user;

src/modules/catalog/catalog.service.ts

@@ -67,6 +67,20 @@ class CatalogService implements OnModuleInit {
     });
   }
 
+  async revokePermissions(data: Messages.RevokePermissionRequest, metadata) {
+    this.logger.info('CatalogService - Manage Data assets permissions');
+
+    return lastValueFrom(
+      this.catalogWriteService.RevokePermission(data, metadata),
+    ).catch((err) => {
+      console.log(err.details);
+      throw new HttpException(
+        err.details,
+        err.code === 6 ? HttpStatus.CONFLICT : 404,
+      );
+    });
+  }
+
   async catalogAll(body) {
     const nimbusUrl = this._getNimbusUrl(body);
     const { data } = await axios.get(`${nimbusUrl}/api/catalog/all/`);