Merge pull request #161 from dadosfera/ft/delete-data-assets

Ft/delete data assets

src/modules/pipelinesV2/pipelines.controller.ts

@@ -184,7 +184,12 @@ export class PipelinesController {
     const { id } = params;
     this.logger.info('PipelinesController - findOne', { user });
 
-    const response = await this.pipelinesClientService.remove({ id, ...data });
+    const metadata = PackTheMetadata({ ...user });
+
+    const response = await this.pipelinesClientService.remove(
+      { id, ...data },
+      metadata,
+    );
 
     return response;
   }

src/modules/pipelinesV2/pipelines.service.ts

@@ -1,5 +1,6 @@
 import {
   BadRequestException,
+  HttpException,
   Inject,
   InternalServerErrorException,
   OnModuleInit,
@@ -155,11 +156,11 @@ export class PipelinesService implements OnModuleInit {
     return updatePipelineResponse;
   }
 
-  async remove(data: Messages.PipelineV2RemoveRequest) {
+  async remove(data: Messages.PipelineV2RemoveRequest, metadata: Metadata) {
     this.logger.info('PipelinesClientService - Remove');
 
     const removePipelineResponse = await lastValueFrom(
-      this.pipelineWriteService.PipelineV2Remove(data),
+      this.pipelineWriteService.PipelineV2Remove(data, metadata),
     )
       .then((res) => {
         this.logger.info('Done');
@@ -167,7 +168,11 @@ export class PipelinesService implements OnModuleInit {
       })
       .catch((err) => {
         this.logger.error(err.message);
-        throw new Error(err);
+        console.log(err);
+        throw new HttpException(
+          err.details,
+          err.details === 'Erro ao pausar pipeline na plataforma.' ? 409 : 500,
+        );
       });
 
     return removePipelineResponse;