FEAT: add endpoint and logic to update data asset certification status

FIX: pin npm version to 10.8.2 in Dockerfile for consistency
FEAT: rename documentation_status to certification_status in docs and update package.json for protospack versioning
2026-09-02 20:54:49 +00:00 · 2026-07-17 09:55:17 -03:00 · 2026-07-16 17:05:10 -03:00 · 2026-07-16 09:08:11 -03:00 · 2026-07-13 08:42:37 -03:00 · 2026-07-13 08:33:35 -03:00
14 changed files with 146 additions and 374 deletions
@@ -71,6 +71,11 @@ jobs:
          sudo mv helmfile /usr/local/bin/
          helmfile --version

+      - name: Install Helm Diff plugin
+        run: |
+          helm plugin install https://github.com/databus23/helm-diff --version v3.9.3
+          helm diff version
+
      - name: Debug Helm env
        run: |
          helm env
@@ -102,4 +107,5 @@ jobs:
      - name: Run Helmfile Diff
        env:
          ENV: ${{ needs.extract_environment.outputs.environment }}
+          HELM_PLUGINS: /home/runner/.local/share/helm/plugins
        run: helmfile -f deploy/helmfiles/${ENV}.yaml diff
@@ -900,9 +900,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -952,9 +949,6 @@
            "connections"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -1003,9 +997,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -1042,9 +1033,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -1078,9 +1066,6 @@
            "connections"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -2418,9 +2403,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -2504,9 +2486,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -2546,9 +2525,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -2588,9 +2564,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -2628,9 +2601,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -2670,9 +2640,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -2714,9 +2681,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -2758,9 +2722,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3110,9 +3071,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3162,9 +3120,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3235,9 +3190,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3278,9 +3230,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3321,9 +3270,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3364,9 +3310,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3407,9 +3350,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3457,9 +3397,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3505,9 +3442,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3556,9 +3490,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3597,9 +3528,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3658,9 +3586,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3709,9 +3634,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3752,9 +3674,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3797,9 +3716,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3849,9 +3765,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3901,9 +3814,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -3951,9 +3861,6 @@
            "PipelinesV2"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4124,9 +4031,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4152,9 +4056,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4191,9 +4092,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4228,9 +4126,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4265,9 +4160,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4295,9 +4187,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4325,9 +4214,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4355,9 +4241,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4394,9 +4277,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4433,9 +4313,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4463,9 +4340,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4493,9 +4367,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4533,9 +4404,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4572,9 +4440,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4619,9 +4484,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4658,9 +4520,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4707,7 +4566,60 @@
          "security": [
            {
              "access-token": []
+            }
+          ]
+        }
+      },
+      "/platform/pipelines/{pipelineId}/pipeline_run/{runId}/jobs": {
+        "get": {
+          "operationId": "PlatformApiController_getPipelineRunJobs",
+          "summary": "Get pipeline run jobs",
+          "description": "Proxies platform-api DB-backed job runs and returns `{ jobs: [...] }`.",
+          "parameters": [
+            {
+              "name": "pipelineId",
+              "required": true,
+              "in": "path",
+              "schema": {
+                "type": "string"
+              }
            },
+            {
+              "name": "runId",
+              "required": true,
+              "in": "path",
+              "schema": {
+                "type": "string"
+              }
+            }
+          ],
+          "responses": {
+            "200": {
+              "description": "DB-backed job runs for the selected pipeline run.",
+              "content": {
+                "application/json": {
+                  "schema": {
+                    "type": "object",
+                    "properties": {
+                      "jobs": {
+                        "type": "array",
+                        "items": {
+                          "type": "object"
+                        }
+                      }
+                    },
+                    "required": [
+                      "jobs"
+                    ]
+                  }
+                }
+              }
+            }
+          },
+          "tags": [
+            "Platform API"
+          ],
+          "security": [
            {
              "access-token": []
            }
@@ -4744,9 +4656,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4781,9 +4690,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4820,9 +4726,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4859,9 +4762,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4899,9 +4799,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4929,9 +4826,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -4959,9 +4853,6 @@
            "Platform API"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -5373,9 +5264,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -5419,9 +5307,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -5531,9 +5416,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -5566,9 +5448,6 @@
            "Catalog"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -5611,9 +5490,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -5707,9 +5583,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -5768,9 +5641,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -5819,9 +5689,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -5915,9 +5782,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -5968,9 +5832,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -6029,9 +5890,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -6088,9 +5946,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -6151,9 +6006,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -6194,9 +6046,6 @@
            "Catalog"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -6237,9 +6086,6 @@
            "Catalog"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -6300,9 +6146,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -6361,9 +6204,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -6740,9 +6580,6 @@
            {
              "access-token": []
            },
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -7196,9 +7033,6 @@
            "Connection Test"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -7235,9 +7069,6 @@
            "Connection Test"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -7274,9 +7105,6 @@
            "Connection Test"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -7313,9 +7141,6 @@
            "Connection Test"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -7352,9 +7177,6 @@
            "Connection Test"
          ],
          "security": [
-            {
-              "access-token": []
-            },
            {
              "access-token": []
            }
@@ -722,8 +722,6 @@ export const DADOSFERA_MODULES_KEYS = {
  PII: 'pii',
  EMBED: 'embedded-analytics',
  EMBED_ASSIGNED: 'embed-assigned',
-  CATALOG: 'catalog',
-  COLLECT: 'collect',
 }

 export const DADOSFERA_MODULES: Array<DadosferaModule> = [
@@ -85,9 +85,6 @@ export class CatalogController {
    PERMISSIONS_GROUPS.CATALOG.permissions.GET,
    PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async searchCatalog(
    @User() user: RequestUser,
    @Query() query: ICatalogAllRequest,
@@ -127,9 +124,6 @@ export class CatalogController {
    PERMISSIONS_GROUPS.CATALOG.permissions.GET,
    PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async dowloadAsserts(
    @User() user: RequestUser,
    @Query() query: ICatalogAllRequest,
@@ -173,9 +167,6 @@ export class CatalogController {

  @ApiInternalOnlyEndpoint()
  @Get('data-asset')
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async findByPipelineAndObject(@User() user: RequestUser, @Query() query) {
    const { username, user_id, customer_id, customer_name, permissions } = user;
    const { pipeline, object } = query;
@@ -234,9 +225,6 @@ export class CatalogController {
    PERMISSIONS_GROUPS.CATALOG.permissions.GET,
    PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async findAllTags(@Body() body) {
    this.logger.info(`/catalog - ON FIND ALL TAGS ROUTE`, {
      user: body.info.user_id,
@@ -288,9 +276,6 @@ export class CatalogController {
    PERMISSIONS_GROUPS.CATALOG.permissions.GET,
    PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async getDataAsset(
    @User() user: RequestUser,
    @Param('id') id: string,
@@ -402,9 +387,6 @@ export class CatalogController {
    PERMISSIONS_GROUPS.CATALOG.permissions.GET,
    PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async getDataAssetColumnsMetadata(
    @User() user: RequestUser,
    @Language() language: LanguageEnum,
@@ -436,9 +418,6 @@ export class CatalogController {
    PERMISSIONS_GROUPS.CATALOG.permissions.GET,
    PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async getDataAssetPreview(
    @User() user: RequestUser,
    @Language() language: LanguageEnum,
@@ -470,9 +449,6 @@ export class CatalogController {
    PERMISSIONS_GROUPS.CATALOG.permissions.GET,
    PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async getDataAssetDocs(
    @User() user: RequestUser,
    @Language() language: LanguageEnum,
@@ -504,9 +480,6 @@ export class CatalogController {
    PERMISSIONS_GROUPS.CATALOG.permissions.UPDATE,
    PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async updateDataAsset(
    @User() user: RequestUser,
    @Language() language: LanguageEnum,
@@ -542,9 +515,6 @@ export class CatalogController {
    PERMISSIONS_GROUPS.CATALOG.permissions.CERTIFY,
    PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async updateDataAssetCertificationStatus(
    @User() user: RequestUser,
    @Language() language: LanguageEnum,
@@ -572,9 +542,6 @@ export class CatalogController {
    PERMISSIONS_GROUPS.CATALOG.permissions.UPDATE,
    PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async manageDataAssetDocs(
    @User() user: RequestUser,
    @Headers() headers,
@@ -612,9 +579,6 @@ export class CatalogController {

  @ApiInternalOnlyEndpoint()
  @Put('data-asset/:id/manage-permissions')
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async manageDataAssetPermissions(
    @Param('id') id: string,
    @User() user: RequestUser,
@@ -637,9 +601,6 @@ export class CatalogController {

  @ApiInternalOnlyEndpoint()
  @Put('data-asset/:id/revoke-permissions')
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async revokeDataAssetPermissions(
    @Param('id') id: string,
    @User() user: RequestUser,
@@ -665,9 +626,6 @@ export class CatalogController {
    PERMISSIONS_GROUPS.CATALOG.permissions.CREATE,
    PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async createDataAsset(
    @User() user: RequestUser,
    @Body() body: ICreateDataAsset,
@@ -692,9 +650,6 @@ export class CatalogController {
    PERMISSIONS_GROUPS.CATALOG.permissions.UPDATE,
    PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async commentOnDataAsset(
    @Param('id') id: string,
    @User() user: RequestUser,
@@ -721,9 +676,6 @@ export class CatalogController {
    PERMISSIONS_GROUPS.CATALOG.permissions.DELETE,
    PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async deleteDataAsset(@Param('id') id: string, @User() user: RequestUser) {
    const { customer_id, customer_name, user_id, username } = user;
    const metadata = PackTheMetadata({
@@ -745,9 +697,6 @@ export class CatalogController {
    PERMISSIONS_GROUPS.CATALOG.permissions.UPDATE,
    PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async deleteComment(
    @Param('id') id: string,
    @User() user: RequestUser,
@@ -901,9 +850,6 @@ export class CatalogController {

  @Get('nimbus-dashboards')
  @RequireAllPermissions(PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER)
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.CATALOG
-  )
  async getNimbusDashboards(
    @User() user: RequestUser,
    @Body() body: GetNimbusDashboardsRequest,
@@ -24,19 +24,15 @@ import {
  GetTableMetadataReq,
 } from './dto/connection-test';
 import { DadosferaLogger } from '@dadosfera/dadosfera-logs';
-import { Authenticated, RequireModule } from 'src/decorators/authentication.decorator';
+import { Authenticated } from 'src/decorators/authentication.decorator';
 import { GrpcToHttpExceptionFilter } from 'src/error/grpc-to-http-exception.filter';
 import { ApiInternalOnlyController } from 'src/decorators/swagger.decorator';
-import { DADOSFERA_MODULES_KEYS } from 'src/authentication/permissions.enum';

@ApiInternalOnlyController()
@ApiTags('Connection Test')
@Controller('connection-test')
@UseFilters(new GrpcToHttpExceptionFilter())
@Authenticated()
-@RequireModule(
-  DADOSFERA_MODULES_KEYS.COLLECT
-)
 export class ConnectionTestController {
  logger: any;
  constructor(
@@ -16,9 +16,8 @@ import { DadosferaLogger } from '@dadosfera/dadosfera-logs';
 import {
  Authenticated,
  RequireAllPermissions,
-  RequireModule,
 } from 'src/decorators/authentication.decorator';
-import { DADOSFERA_MODULES_KEYS, PERMISSIONS_GROUPS } from 'src/authentication/permissions.enum';
+import { PERMISSIONS_GROUPS } from 'src/authentication/permissions.enum';
 import { RequestUser, User } from 'src/decorators/user.decorator';
 import { ValidationPipe } from '../../pipes/object-validation.pipe';
 import {
@@ -40,9 +39,6 @@ const connectionPermissions = PERMISSIONS_GROUPS.CONNECTION.permissions;
@ApiTags('connections')
@Authenticated()
@Controller('connections')
-@RequireModule(
-  DADOSFERA_MODULES_KEYS.COLLECT
-)
 export class ConnectionController {
  logger: any;
  constructor(
@@ -25,10 +25,9 @@ import { DadosferaLogger } from '@dadosfera/dadosfera-logs';
 import {
  Authenticated,
  RequireAllPermissions,
-  RequireModule,
  RequireSomePermission,
 } from 'src/decorators/authentication.decorator';
-import { DADOSFERA_MODULES_KEYS, PERMISSIONS_GROUPS } from 'src/authentication/permissions.enum';
+import { PERMISSIONS_GROUPS } from 'src/authentication/permissions.enum';
 import { Language } from 'src/decorators/language.decorator';
 import { LanguageEnum } from 'src/utils/languages.enum';
 import { ApiInternalOnlyController } from 'src/decorators/swagger.decorator';
@@ -100,9 +99,6 @@ export class ConnectorController {
    PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE,
    PERMISSIONS_GROUPS.PIPELINE.permissions.DELETE,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.COLLECT
-  )
  async getAllConnectors(
    @Language() language: LanguageEnum,
    @Query() queries: GetAllDto,
@@ -135,9 +131,6 @@ export class ConnectorController {
    PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE,
    PERMISSIONS_GROUPS.PIPELINE.permissions.DELETE,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.COLLECT
-  )
  async getConnectorsTags() {
    return await this.connectorClientService.getConnectorsTags();
  }
@@ -150,9 +143,6 @@ export class ConnectorController {
    PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE,
    PERMISSIONS_GROUPS.PIPELINE.permissions.DELETE,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.COLLECT
-  )
  async getConnector(
    @Language() language: LanguageEnum,
    @Param('plugin') plugin: string,
@@ -181,9 +171,6 @@ export class ConnectorController {
    PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE,
    PERMISSIONS_GROUPS.PIPELINE.permissions.DELETE,
  )
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.COLLECT
-  )
  async getConnectorDetails(
    @Language() language: LanguageEnum,
    @Param('plugin') plugin: string,
@@ -206,9 +193,6 @@ export class ConnectorController {
  @Put('/:plugin')
  @RequireAllPermissions(PERMISSIONS_GROUPS.CONNECTORS.permissions.UPDATE)
  @ApiConsumes('multipart/form-data')
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.COLLECT
-  )
  async updateConnector(
    @Param('plugin') plugin: string,
    @Body() body: UpdateDto,
@@ -230,9 +214,6 @@ export class ConnectorController {

  @Put('/:plugin/add-tag')
  @RequireAllPermissions(PERMISSIONS_GROUPS.CONNECTORS.permissions.UPDATE)
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.COLLECT
-  )
  async addTagOnConnector(
    @Param('plugin') plugin: string,
    @Body() body: AddTagDto,
@@ -260,9 +241,6 @@ export class ConnectorController {

  @Put('/:plugin/remove-tag')
  @RequireAllPermissions(PERMISSIONS_GROUPS.CONNECTORS.permissions.UPDATE)
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.COLLECT
-  )
  async removeTagOnConnector(
    @Param('plugin') plugin: string,
    @Body() body: RemoveTagDto,
@@ -291,9 +269,6 @@ export class ConnectorController {

  @Delete('/:plugin')
  @RequireAllPermissions(PERMISSIONS_GROUPS.CONNECTORS.permissions.DELETE)
-  @RequireModule(
-    DADOSFERA_MODULES_KEYS.COLLECT
-  )
  async deleteConnector(
    @Param('plugin') plugin: string,
    @Query('version') version: string,
@@ -23,7 +23,6 @@ import {
 } from '@dadosfera/protospack-v2/dist/lib/Input/interfaces/messages';
 import { Info } from '@dadosfera/protospack-v2/dist/lib/Input/interfaces/entities';
 import { CreateInputReq } from './dtos/input.model';
-import { Metadata } from '@grpc/grpc-js';

@Injectable()

@@ -74,10 +73,10 @@ export class InputsService {
      objectCamelToSnake(createInputResponse);
      return createInputResponse;
    },
-    update: async (updateInputDTO: UpdateInputRequest, metadata: Metadata): Promise<InputUpdateResponse> => {
+    update: async (updateInputDTO: UpdateInputRequest): Promise<InputUpdateResponse> => {
      this.logger.info('InputClientService - Update' + JSON.stringify(updateInputDTO));
      const updateInputResponse = await lastValueFrom(
-        this.inputWriteService.InputUpdate(updateInputDTO, metadata),
+        this.inputWriteService.InputUpdate(updateInputDTO),
      );

      return updateInputResponse;
@@ -207,7 +206,7 @@ export class InputsService {
    return findOneInputResponse;
  }

-  async update(id: string, data, info: Info, metadata?: Metadata) {
+  async update(id: string, data, info: Info) {
    // this.validateCron({ ...data, info });
    try {
      const {
@@ -218,7 +217,7 @@ export class InputsService {
        id,
        ...data,
        info,
-      }, metadata);
+      });

      const updateInputResponse = this.adjustInputPayload(
        input,
@@ -15,6 +15,7 @@ import {
  HttpException,
  BadRequestException,
  UseGuards,
+  Res,
 } from '@nestjs/common';
 import {
  ApiCreatedResponse,
@@ -25,10 +26,9 @@ import {
 } from '@nestjs/swagger';
 import {
  RequireAllPermissions,
-  RequireModule,
  RequireSomePermission,
 } from 'src/decorators/authentication.decorator';
-import { DADOSFERA_MODULES_KEYS, PERMISSIONS_GROUPS } from '../../authentication/permissions.enum';
+import { PERMISSIONS_GROUPS } from '../../authentication/permissions.enum';
 import { PipelinesService } from './pipelines.service';
 import { DadosferaLogger } from '@dadosfera/dadosfera-logs';
 import { Messages } from '@dadosfera/protospack-v2/dist/lib/PipelineV2';
@@ -58,9 +58,6 @@ type PipelineTablesConfig = { input_id?: string; tables: PipelineTable[] };
@ApiHeaders([{ name: 'dadosfera-lang', enum: LanguageEnum, required: false }])
@UseFilters(new GrpcToHttpExceptionFilter())
@Controller('pipelinesV2')
-@RequireModule(
-  DADOSFERA_MODULES_KEYS.COLLECT
-)
 export class PipelinesController {
  logger: DadosferaLogger;
  constructor(
@@ -321,6 +318,7 @@ export class PipelinesController {
  ) {
    this.logger.info('PipelinesController - update', { user });

+    const { customer_id, customer_name, user_id, username } = user;
    const info: Info = {
      user_id: user.user_id,
      customer: user.customer_name,
@@ -328,7 +326,13 @@ export class PipelinesController {
      pipeline_id: pipelineId
    };

-    const metadata = PackTheMetadata(user);
+    const metadata = PackTheMetadata({
+      customer_id,
+      customer_name,
+      user_id,
+      username,
+      language,
+    });

    const response = await this.pipelinesClientService.updatePipelineInput(
      pipelineId,
@@ -383,8 +383,7 @@ export class PipelinesService implements OnModuleInit {
    const updateInputResponse = await this.inputsService.update(
      inputId,
      updateInputDTO,
-      info,
-      metadata
+      info
    );

    const inputRollback = () => {
@@ -405,36 +404,34 @@ export class PipelinesService implements OnModuleInit {

    const nimbusUpdates = updateInputResponse?.tablesUpdate || [];

-    if (user.customer_modules.includes('catalog')) {
-      nimbusUpdates.forEach(update => {
-        const nimbusRollback = () => {
-          return this.nimbusService.renameTable(
-            info.customer,
-            update.database,
-            {
-              table_name: update.table_name,
-              table_schema: update.table_schema
-            },
-            {
-              table_name: update.old_table_name,
-              table_schema: update.old_table_schema
-            }
-          );
-        }
-        rollback.push(nimbusRollback);
-      });
-  
-      try {
-        await this.updateNimbus(info.customer, nimbusUpdates);
-      } catch (error) {
-        this.logger.error(error);
-        if (error instanceof AxiosError) {
-          this.logger.error(JSON.stringify(error.response.data));
-        }
-        await this.executeRenameRollback(rollback);
-  
-        throw new Error("Error Nimbus updating tables");
+    nimbusUpdates.forEach(update => {
+      const nimbusRollback = () => {
+        return this.nimbusService.renameTable(
+          info.customer,
+          update.database,
+          {
+            table_name: update.table_name,
+            table_schema: update.table_schema
+          },
+          {
+            table_name: update.old_table_name,
+            table_schema: update.old_table_schema
+          }
+        );
      }
+      rollback.push(nimbusRollback);
+    });
+
+    try {
+      await this.updateNimbus(info.customer, nimbusUpdates);
+    } catch (error) {
+      this.logger.error(error);
+      if (error instanceof AxiosError) {
+        this.logger.error(JSON.stringify(error.response.data));
+      }
+      await this.executeRenameRollback(rollback);
+
+      throw new Error("Error Nimbus updating tables");
    }

    try {
@@ -14,17 +14,16 @@ import {
  NotFoundException,
  UseGuards,
 } from '@nestjs/common';
-import { ApiTags, ApiOperation } from '@nestjs/swagger';
+import { ApiTags, ApiOperation, ApiOkResponse } from '@nestjs/swagger';
 import { DadosferaLogger } from '@dadosfera/dadosfera-logs';

 import {
  Authenticated,
  RequireAllPermissions,
-  RequireModule,
 } from '../../decorators/authentication.decorator';
 import { User, RequestUser } from '../../decorators/user.decorator';
 import { PlatformApiService } from './platform-api.service';
-import { DADOSFERA_MODULES_KEYS, PERMISSIONS_GROUPS } from '../../authentication/permissions.enum';
+import { PERMISSIONS_GROUPS } from '../../authentication/permissions.enum';
 import { ElasticsearchService } from '../../services/elasticsearch';
 import { DynamoDBService, ReferenceColumn } from '../../services/dynamodb';
 import { CustomersService } from '../customers/customers.service';
@@ -50,7 +49,6 @@ type RenameTablesBody = {

@ApiTags('Platform API')
@Controller('platform')
-@RequireModule(DADOSFERA_MODULES_KEYS.COLLECT)
 export class PlatformApiController {
  private logger: any;

@@ -74,6 +72,10 @@ export class PlatformApiController {
    return id?.replace(/-/g, '_') || '';
  }

+  private decodePathParam(value: string): string {
+    return value ? decodeURIComponent(value) : '';
+  }
+
  /**
   * Denormalize ID back to UUID format (replace _ with -).
   * Used when we receive a normalized ID but need the original UUID.
@@ -834,6 +836,40 @@ export class PlatformApiController {
    );
  }

+  @Get('pipelines/:pipelineId/pipeline_run/:runId/jobs')
+  @ApiOperation({
+    summary: 'Get pipeline run jobs',
+    description: 'Proxies platform-api DB-backed job runs and returns `{ jobs: [...] }`.',
+  })
+  @ApiOkResponse({
+    description: 'DB-backed job runs for the selected pipeline run.',
+    schema: {
+      type: 'object',
+      properties: {
+        jobs: {
+          type: 'array',
+          items: { type: 'object' },
+        },
+      },
+      required: ['jobs'],
+    },
+  })
+  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.GET)
+  async getPipelineRunJobs(
+    @Param('pipelineId') pipelineId: string,
+    @Param('runId') runId: string,
+    @User() user: RequestUser,
+  ) {
+    const normalizedPipelineId = this.normalizePipelineId(pipelineId);
+    const decodedRunId = this.decodePathParam(runId);
+
+    return this.platformApiService.proxy(
+      'GET',
+      `/pipeline/${normalizedPipelineId}/pipeline_run/${decodedRunId}/jobs`,
+      user,
+    );
+  }
+
  // ==================== JOBS - COLUMN EDITING ROUTES ====================

  @Put('jobs/:jobId/input')
@@ -1,7 +1,6 @@
 import { Test, TestingModule } from '@nestjs/testing';
 import { ReleaseNoteController } from './release_note.controller';
 import { ReleaseNoteService } from './release_note.service';
-import DadosferaLogger from '@dadosfera/dadosfera-logs';

 describe('ReleaseNoteController', () => {
  let controller: ReleaseNoteController;
@@ -9,7 +8,7 @@ describe('ReleaseNoteController', () => {
  beforeEach(async () => {
    const module: TestingModule = await Test.createTestingModule({
      controllers: [ReleaseNoteController],
-      providers: [ReleaseNoteService, DadosferaLogger],
+      providers: [ReleaseNoteService],
    }).compile();

    controller = module.get<ReleaseNoteController>(ReleaseNoteController);
@@ -1,13 +1,12 @@
 import { Test, TestingModule } from '@nestjs/testing';
 import { ReleaseNoteService } from './release_note.service';
-import DadosferaLogger from '@dadosfera/dadosfera-logs';

 describe('ReleaseNoteService', () => {
  let service: ReleaseNoteService;

  beforeEach(async () => {
    const module: TestingModule = await Test.createTestingModule({
-      providers: [ReleaseNoteService, DadosferaLogger],
+      providers: [ReleaseNoteService],
    }).compile();

    service = module.get<ReleaseNoteService>(ReleaseNoteService);
@@ -9,7 +9,6 @@ interface IMetadata {
  details?: string;
  sensitive?: string;
  roles?: string[];
-  customer_modules?: string[];
  is_data_manager?: boolean;
  access_token?: string;
  host?: string;
Author	SHA1	Message	Date
viniciusgadea	8eb7fd0169	FEAT: add endpoint and logic to update data asset certification status	2026-07-17 09:55:17 -03:00
viniciusgadea	8a9d6c2f9c	FIX: pin npm version to 10.8.2 in Dockerfile for consistency	2026-07-16 17:05:10 -03:00
viniciusgadea	2e181e70af	FEAT: rename documentation_status to certification_status in docs and update package.json for protospack versioning	2026-07-16 09:08:11 -03:00
vinicius gadea	ef615adb8e	Merge branch 'beta' into feat/documentation-status	2026-07-13 08:42:37 -03:00
viniciusgadea	e03900811b	FEAT: add documentation status enum and property to data asset	2026-07-13 08:33:35 -03:00
yuri.rodrigues	5bc5fb0977	Merge pull request #494 from dadosfera/feat/pipeline-run-jobs feat: add endpoint to retrieve pipeline run jobs	2026-06-23 13:38:55 -03:00
iruy-fr	011032e3d4	FEAT: update API title in docsfera.json to reflect project name	2026-06-23 11:58:28 -03:00
iruy-fr	17363e74f4	FEAT: simplify pipeline run jobs handling and normalize run ID usage	2026-06-23 11:54:59 -03:00
iruy-fr	63efff6adf	FEAT: enhance pipeline run jobs endpoint with error handling and response structure	2026-06-22 20:25:16 -03:00
iruy-fr	b5f569e522	Merge branch 'beta' into feat/pipeline-run-jobs # Conflicts: # docsfera.json	2026-06-19 17:08:34 -03:00
iruy-fr	5c77577992	feat: add endpoint to retrieve pipeline run jobs	2026-06-19 17:04:42 -03:00
marcos.rodrigues	4b9e113185	Merge pull request #493 from dadosfera/chore/remove-deprecated-lib FEAT: remove deprecated protospack lib	2026-06-14 15:10:22 -03:00
marcos.rodrigues	06d505c50a	FEAT: remove deprecated protospack lib	2026-06-13 21:07:14 -03:00
Marcos Rodrigues Silva	2177f6725c	Merge pull request #491 from dadosfera/hotfix/release-notes Hotfix/release notes	2026-05-25 14:10:46 -03:00
marcos-silva-rodrigues	65ab16236f	FEAT: update deployment to include firebase base url	2026-05-25 14:09:16 -03:00
marcos-silva-rodrigues	b4cc8151d7	FIX: release note endpoint	2026-05-25 14:01:00 -03:00
yuri.rodrigues	e8b982998f	Merge pull request #490 from dadosfera/feat/platform-job-rout Feat/platform job rout	2026-05-21 16:48:38 -03:00
iruy-fr	ccd4159c59	fix: validate workflow	2026-05-21 16:43:37 -03:00
iruy-fr	9e49abb40d	fix: validate workflow	2026-05-21 16:37:47 -03:00
iruy-fr	21a82b64f3	fix: validate workflow	2026-05-21 16:31:45 -03:00
iruy-fr	2414fcf21e	fix: validate workflow	2026-05-21 16:23:45 -03:00
iruy-fr	94fbdb2226	fix: validate workflow	2026-05-21 16:21:30 -03:00
iruy-fr	985170d7ae	chore: exposure from route pipeline run jobs to maestro	2026-05-21 16:12:35 -03:00
iruy-fr	b38b8f51e2	FEAT: Add endpoint to fetch pipeline run jobs	2026-05-20 15:34:49 -03:00
Marcos Rodrigues Silva	ea16e62d6b	Merge pull request #489 from dadosfera/feature/pipeline-upgrade FEAT: pipeline upgrade route	2026-05-11 12:58:06 -03:00
marcos-silva-rodrigues	6182705410	FEAT: pipeline upgrade route	2026-05-11 12:52:07 -03:00