FEAT: add endpoint to retrieve jobs for a specific pipeline run

deploy/helm-chart/templates/deployment.yaml

@@ -113,8 +113,6 @@ spec:
               value: {{ .Values.maestro.platform_api_url }}
             - name: STORAGE_EXPLORER_API_URL
               value: {{ .Values.maestro.storage_explorer_api_url | quote }}
-            - name: FIREBASE_BASE_URL
-              value: {{ .Values.maestro.firebase_base_url }}
             - name: JWT_PRIVATE_KEY
               valueFrom:
                 secretKeyRef:

deploy/helm-chart/values-stg.yaml

@@ -10,7 +10,6 @@ maestro:
   redis_database: "1"
   platform_api_url: https://xs2hkhq07k.execute-api.us-east-1.amazonaws.com
   storage_explorer_api_url: "http://storage-explorer-{customer}.data-apps.svc.cluster.local:8000/api"
-  firebase_base_url: https://feature-flag-25bf6-default-rtdb.firebaseio.com/stg
 
 hostname: maestro.stg.dadosfera.ai
 

deploy/helm-chart/values.yaml

@@ -55,7 +55,6 @@ maestro:
   redis_database: "0"
   redis_tls: "true"
   cookie_secret: "13cc5e136d3074bcc05bec8697092ec1f5f376bf"
-  firebase_base_url: https://feature-flag-25bf6-default-rtdb.firebaseio.com/prd
 autoscaling:
   enabled: false
   minReplicas: 1

docsfera.json

@@ -3580,10 +3580,7 @@
               "content": {
                 "application/json": {
                   "schema": {
-                    "type": "array",
-                    "items": {
-                      "type": "object"
-                    }
+                    "type": "string"
                   }
                 }
               }
@@ -8596,29 +8593,6 @@
             "Health"
           ]
         }
-      },
-      "/release_note": {
-        "get": {
-          "operationId": "ReleaseNoteController_getLatestReleaseNote",
-          "parameters": [],
-          "responses": {
-            "200": {
-              "description": "",
-              "content": {
-                "application/json": {
-                  "schema": {
-                    "type": "object"
-                  }
-                }
-              }
-            }
-          },
-          "security": [
-            {
-              "access-token": []
-            }
-          ]
-        }
       }
     },
     "info": {

src/app.module.ts

@@ -35,8 +35,6 @@ import { ShareMetadataModule } from './modules/share-metadata/share-metadata.mod
 import { ApiKeyModule } from './modules/api-key/api-key.module';
 import { PlatformApiModule } from './modules/platform-api/platform-api.module';
 import { StorageExplorerModule } from './modules/storage-explorer/storage-explorer.module';
-import { ReleaseNoteModule } from './modules/release_note/release_note.module';
-
 
 @Module({
   providers: [
@@ -81,7 +79,6 @@ import { ReleaseNoteModule } from './modules/release_note/release_note.module';
     StorageExplorerModule,
     //Always leave HealthModule last, so it is on the bottom of swagger
     HealthModule,
-    ReleaseNoteModule,
   ],
 })
 export class AppModule {}

src/modules/platform-api/platform-api.controller.ts

@@ -786,6 +786,23 @@ export class PlatformApiController {
     );
   }
 
+  @Get('pipelines/:pipelineId/pipeline_run/:runId/jobs')
+  @ApiOperation({ summary: 'Get pipeline run 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 normalizedRunId = this.normalizePipelineId(runId);
+    return this.platformApiService.proxy(
+      'GET',
+      `/pipeline/${normalizedPipelineId}/pipeline_run/${normalizedRunId}/jobs`,
+      user,
+    );
+  }
+
   @Get('pipelines/pipeline_run/:runId/logs')
   @ApiOperation({ summary: 'Get pipeline run logs' })
   @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.GET)

src/modules/release_note/dto/release_note.dto.ts

@@ -1,14 +0,0 @@
-export type ReleaseNoteDTO = {
-    id: string;
-    date: string;
-    tag: string;
-    title: string;
-    visible: boolean;
-    expiryDate: string;
-    content: string;
-    showEmojis: boolean;
-    image?: string;
-    link?: string;
-    linkText?: string;
-  };
-  

src/modules/release_note/release_note.controller.spec.ts

@@ -1,20 +0,0 @@
-import { Test, TestingModule } from '@nestjs/testing';
-import { ReleaseNoteController } from './release_note.controller';
-import { ReleaseNoteService } from './release_note.service';
-
-describe('ReleaseNoteController', () => {
-  let controller: ReleaseNoteController;
-
-  beforeEach(async () => {
-    const module: TestingModule = await Test.createTestingModule({
-      controllers: [ReleaseNoteController],
-      providers: [ReleaseNoteService],
-    }).compile();
-
-    controller = module.get<ReleaseNoteController>(ReleaseNoteController);
-  });
-
-  it('should be defined', () => {
-    expect(controller).toBeDefined();
-  });
-});

src/modules/release_note/release_note.controller.ts

@@ -1,26 +0,0 @@
-import { Controller, Get, Inject } from '@nestjs/common';
-import { ReleaseNoteService } from './release_note.service';
-import { Authenticated } from 'src/decorators/authentication.decorator';
-import { Language } from 'src/decorators/language.decorator';
-import { LanguageEnum } from 'src/utils/languages.enum';
-import DadosferaLogger from '@dadosfera/dadosfera-logs';
-
-@Controller('release_note')
-@Authenticated()
-export class ReleaseNoteController {
-  logger: DadosferaLogger;
-
-  constructor(
-    @Inject(DadosferaLogger)
-    dadosferaLogger: DadosferaLogger,
-    private readonly releaseNoteService: ReleaseNoteService,
-  ) {
-    this.logger = dadosferaLogger.logger;
-  }
-
-  @Get()
-  async getLatestReleaseNote(@Language() language: LanguageEnum) {
-    this.logger.info(`Fetching latest release note for language: ${language}`);
-    return await this.releaseNoteService.getLatestReleaseNote(language);
-  }
-}

src/modules/release_note/release_note.module.ts

@@ -1,10 +0,0 @@
-import { Module } from '@nestjs/common';
-import { ReleaseNoteService } from './release_note.service';
-import { ReleaseNoteController } from './release_note.controller';
-import DadosferaLogger from '@dadosfera/dadosfera-logs';
-
-@Module({
-  controllers: [ReleaseNoteController],
-  providers: [ReleaseNoteService, DadosferaLogger]
-})
-export class ReleaseNoteModule {}

src/modules/release_note/release_note.service.spec.ts

@@ -1,18 +0,0 @@
-import { Test, TestingModule } from '@nestjs/testing';
-import { ReleaseNoteService } from './release_note.service';
-
-describe('ReleaseNoteService', () => {
-  let service: ReleaseNoteService;
-
-  beforeEach(async () => {
-    const module: TestingModule = await Test.createTestingModule({
-      providers: [ReleaseNoteService],
-    }).compile();
-
-    service = module.get<ReleaseNoteService>(ReleaseNoteService);
-  });
-
-  it('should be defined', () => {
-    expect(service).toBeDefined();
-  });
-});

src/modules/release_note/release_note.service.ts

@@ -1,46 +0,0 @@
-import { Inject, Injectable } from '@nestjs/common';
-import axios, { AxiosInstance } from 'axios';
-import { LanguageEnum } from 'src/utils/languages.enum';
-import { ReleaseNoteDTO } from './dto/release_note.dto';
-import DadosferaLogger from '@dadosfera/dadosfera-logs';
-
-@Injectable()
-export class ReleaseNoteService {
-  client: AxiosInstance;
-    logger: DadosferaLogger;
-
-  constructor(
-        @Inject(DadosferaLogger)
-        dadosferaLogger: DadosferaLogger,
-  ) {
-    this.logger = dadosferaLogger.logger;
-      this.client = axios.create({
-          baseURL: process.env.FIREBASE_BASE_URL,
-      });
-  }
-
-  async getLatestReleaseNote(lang: LanguageEnum) {
-    try {
-      const lng = lang.split('-');
-      const language = lng[0] + '-' + lng[1].toUpperCase();
-
-      const endpoint = `/release_note/${language}.json`;
-      const {
-        data,
-        status,
-        config
-      } = await this.client.get<ReleaseNoteDTO>(endpoint)
-      this.logger.info(`Fetched release note for language: ${lang} with status: ${status}`);
-      this.logger.info(`Request URL: ${config.baseURL}/${config.url}`);
-
-      return data;
-    } catch (error) {
-      this.logger.error(`Error fetching release note: ${error.message}`);
-
-      if (axios.isAxiosError(error)) {
-        this.logger.error(`Axios error details: ${error.toJSON()}`);
-      }
-    }
-
-  }
-}