From c85cd37f3ab38e7dc5b6f06cd28a8d2e71d051fa Mon Sep 17 00:00:00 2001
From: Anderson Feitosa <andersonmfjr@gmail.com>
Date: Thu, 22 Dec 2022 13:08:08 -0300
Subject: [PATCH] FEAT: add new api route to get pipeline objects

---
 docsfera.json                                 | 23 ++++++++++++++++++-
 package-lock.json                             | 14 +++++------
 package.json                                  |  2 +-
 .../pipelinesV2/pipelines.controller.ts       | 14 +++++++++++
 src/modules/pipelinesV2/pipelines.service.ts  | 11 +++++++++
 5 files changed, 55 insertions(+), 9 deletions(-)

diff --git a/docsfera.json b/docsfera.json
index fef3b5a..9c65de9 100644
--- a/docsfera.json
+++ b/docsfera.json
@@ -2334,6 +2334,27 @@
           ]
         }
       },
+      "/pipelinesV2/{id}/objects": {
+        "get": {
+          "operationId": "PipelinesController_getPipelineObjects",
+          "parameters": [],
+          "responses": {
+            "200": {
+              "description": "",
+              "content": {
+                "application/json": {
+                  "schema": {
+                    "type": "object"
+                  }
+                }
+              }
+            }
+          },
+          "tags": [
+            "PipelinesV2"
+          ]
+        }
+      },
       "/pipelinesV2/{id}": {
         "get": {
           "operationId": "PipelinesController_findOne",
@@ -3297,7 +3318,7 @@
       }
     },
     "info": {
-      "title": "Maestro - fix/refresh-token",
+      "title": "Maestro - feature/pipeline-object-to-data-asset",
       "description": "Documentation for Maestro gateway",
       "version": "1.0.0",
       "contact": {}
diff --git a/package-lock.json b/package-lock.json
index 2ddafe8..d964f22 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -12,7 +12,7 @@
       "dependencies": {
         "@aws-sdk/client-secrets-manager": "^3.112.0",
         "@dadosfera/dadosfera-logs": "^1.0.0-beta.4",
-        "@dadosfera/protospack-v2": "3.24.0",
+        "@dadosfera/protospack-v2": "^3.26.0-beta.1",
         "@grpc/grpc-js": "^1.6.7",
         "@grpc/proto-loader": "^0.6.13",
         "@nestjs/common": "^8.4.7",
@@ -1727,9 +1727,9 @@
       }
     },
     "node_modules/@dadosfera/protospack-v2": {
-      "version": "3.24.0",
-      "resolved": "https://dadosfera-611330257153.d.codeartifact.us-east-1.amazonaws.com:443/npm/dadosfera-npm/@dadosfera/protospack-v2/-/protospack-v2-3.24.0.tgz",
-      "integrity": "sha512-CZmRK2shS8y7t6F2e1PSe8T+GgQJVXQPNYmcBqeWfb/ZmfL9zS2dDCACqbJpzBg2nmEneznYtpTw4nfH8n3utw==",
+      "version": "3.26.0-beta.1",
+      "resolved": "https://dadosfera-611330257153.d.codeartifact.us-east-1.amazonaws.com:443/npm/dadosfera-npm/@dadosfera/protospack-v2/-/protospack-v2-3.26.0-beta.1.tgz",
+      "integrity": "sha512-7DQdvTq8Z7N1xH4ZDdLBzFu8y9qMZHjkJjMEzXOj1wL1YbfHvtLrXu+FUdwQ2d/tNNeQRrswMewGoB/XM1Y9qQ==",
       "dependencies": {
         "@grpc/grpc-js": "^1.6.7",
         "rxjs": "^7.5.5",
@@ -12324,9 +12324,9 @@
       }
     },
     "@dadosfera/protospack-v2": {
-      "version": "3.24.0",
-      "resolved": "https://dadosfera-611330257153.d.codeartifact.us-east-1.amazonaws.com:443/npm/dadosfera-npm/@dadosfera/protospack-v2/-/protospack-v2-3.24.0.tgz",
-      "integrity": "sha512-CZmRK2shS8y7t6F2e1PSe8T+GgQJVXQPNYmcBqeWfb/ZmfL9zS2dDCACqbJpzBg2nmEneznYtpTw4nfH8n3utw==",
+      "version": "3.26.0-beta.1",
+      "resolved": "https://dadosfera-611330257153.d.codeartifact.us-east-1.amazonaws.com:443/npm/dadosfera-npm/@dadosfera/protospack-v2/-/protospack-v2-3.26.0-beta.1.tgz",
+      "integrity": "sha512-7DQdvTq8Z7N1xH4ZDdLBzFu8y9qMZHjkJjMEzXOj1wL1YbfHvtLrXu+FUdwQ2d/tNNeQRrswMewGoB/XM1Y9qQ==",
       "requires": {
         "@grpc/grpc-js": "^1.6.7",
         "rxjs": "^7.5.5",
diff --git a/package.json b/package.json
index 2267d06..9cd07b6 100644
--- a/package.json
+++ b/package.json
@@ -28,7 +28,7 @@
   "dependencies": {
     "@aws-sdk/client-secrets-manager": "^3.112.0",
     "@dadosfera/dadosfera-logs": "^1.0.0-beta.4",
-    "@dadosfera/protospack-v2": "3.24.0",
+    "@dadosfera/protospack-v2": "^3.26.0-beta.1",
     "@grpc/grpc-js": "^1.6.7",
     "@grpc/proto-loader": "^0.6.13",
     "@nestjs/common": "^8.4.7",
diff --git a/src/modules/pipelinesV2/pipelines.controller.ts b/src/modules/pipelinesV2/pipelines.controller.ts
index 6f71afc..ba4d5f7 100644
--- a/src/modules/pipelinesV2/pipelines.controller.ts
+++ b/src/modules/pipelinesV2/pipelines.controller.ts
@@ -147,6 +147,20 @@ export class PipelinesController {
     return this.pipelinesClientService.findOneProperties(id, metadata);
   }
 
+  @Get(':id/objects')
+  async getPipelineObjects(
+    @Headers('Dadosfera-Lang') language,
+    @User() user: RequestUser,
+    @Param('id') id,
+  ) {
+    this.logger.info('PipelinesController - getPipelineObjects', { user });
+    const metadata = PackTheMetadata({
+      ...user,
+      language: language || 'pt-br',
+    });
+    return this.pipelinesClientService.findOneObjects(id, metadata);
+  }
+
   @Get('/:id')
   async findOne(
     @Headers('Dadosfera-Lang') language,
diff --git a/src/modules/pipelinesV2/pipelines.service.ts b/src/modules/pipelinesV2/pipelines.service.ts
index 042a06b..c220d16 100644
--- a/src/modules/pipelinesV2/pipelines.service.ts
+++ b/src/modules/pipelinesV2/pipelines.service.ts
@@ -250,6 +250,17 @@ export class PipelinesService implements OnModuleInit {
     };
   }
 
+  async findOneObjects(id: string, metadata: Metadata) {
+    this.logger.info('PipelinesClientService - FindOneObjects');
+
+    const findOnePipelineResponse = await lastValueFrom(
+      this.pipelineReadService.PipelineV2FindObjects({ id }, metadata),
+    );
+    this.logger.info('Done');
+
+    return findOnePipelineResponse;
+  }
+
   async uploadFile(uploadFile, metadata) {
     const body: Messages.PipelineV2UploadFileRequest = {
       file: {