Merge pull request #405 from dadosfera/fix/redis-tls-configurable

Fix/redis tls configurable

README.md

@@ -2,6 +2,8 @@
   <image src="./assets/maestro.svg" style="width:10rem">
 </p>
 
+
+
 # Maestro
 
 Maestro é a API principal da Dadosfera. É responsável pela comunicação do Frontend com nossos microsserviços.

deploy/helm-chart/templates/deployment.yaml

@@ -106,8 +106,6 @@ spec:
               value: "{{ .Values.maestro.redis_port }}"
             - name: REDIS_TLS
               value: "{{ .Values.maestro.redis_tls }}"
-            - name: PLATFORM_API_URL
-              value: {{ .Values.maestro.platform_api_url }}
             - name: JWT_PRIVATE_KEY
               valueFrom:
                 secretKeyRef:
@@ -128,14 +126,3 @@ spec:
                 secretKeyRef:
                   name: prd-{{ .Values.app_name }}
                   key: AWS_DEFAULT_REGION
-            # Elasticsearch
-            - name: ELASTICSEARCH_URL
-              valueFrom:
-                secretKeyRef:
-                  name: prd-{{ .Values.app_name }}
-                  key: ELASTICSEARCH_URL
-            - name: ELASTICSEARCH_API_KEY
-              valueFrom:
-                secretKeyRef:
-                  name: prd-{{ .Values.app_name }}
-                  key: ELASTICSEARCH_API_KEY

deploy/helm-chart/templates/secret.yaml

@@ -38,15 +38,3 @@ spec:
       version: "AWSCURRENT"
       property: token
 
-  - secretKey: ELASTICSEARCH_URL
-    remoteRef:
-      key: {{ .Values.maestro.env }}/microservices/elasticsearch
-      version: "AWSCURRENT"
-      property: ELASTICSEARCH_URL
-
-  - secretKey: ELASTICSEARCH_API_KEY
-    remoteRef:
-      key: {{ .Values.maestro.env }}/microservices/elasticsearch
-      version: "AWSCURRENT"
-      property: ELASTICSEARCH_API_KEY
-

deploy/helm-chart/values-stg.yaml

@@ -8,7 +8,6 @@ maestro:
   open_group_id: e3f98a2f-7748-4981-8505-7695c8ca8218
   cookie_secret: "ff7bc13823edb2ae50d248e5780bddc9d4b31c36"
   redis_database: "1"
-  platform_api_url: https://xs2hkhq07k.execute-api.us-east-1.amazonaws.com
 
 hostname: maestro.stg.dadosfera.ai
 

deploy/helm-chart/values.yaml

@@ -43,7 +43,6 @@ maestro:
   upload_file_agent_connection: cbc2f881-58c4-4d60-8003-0979b0b5b911
   open_customer_id: f239718a-a271-4ef9-ae7e-02a2f0f3aa6e
   open_group_id: 401573bb-334f-44b2-b30e-88d4cea31ae9
-  platform_api_url: https://oz8v2zid1e.execute-api.us-east-1.amazonaws.com
   dedicated_proxy: ""
   restricted_ip: ""
   redis_host: "aaapzppmlyamkocqwstpo7zvopczyyiyuy6xzm2g6c5k4mq3a66be4a-0.redis.sa-saopaulo-1.oci.oraclecloud.com"

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

@@ -490,7 +490,6 @@ export class PlatformApiController {
           cron: body.cron,
           tables: inputId,
           properties,
-          type: this.mapConnectorToDynamoType(connectorType),
         },
         connector,
       );
@@ -692,6 +691,18 @@ export class PlatformApiController {
 
   // ==================== PIPELINE RUN ROUTES ====================
 
+  @Post('pipeline/pipeline_run')
+  @ApiOperation({ summary: 'Create a pipeline run' })
+  @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.UPDATE)
+  async createPipelineRun(@Body() body: any, @User() user: RequestUser) {
+    return this.platformApiService.proxy(
+      'POST',
+      '/pipeline/pipeline_run',
+      user,
+      body,
+    );
+  }
+
   @Get('pipeline/:pipelineId/pipeline_run')
   @ApiOperation({ summary: 'Get pipeline runs for a pipeline' })
   @RequireAllPermissions(PERMISSIONS_GROUPS.PIPELINE.permissions.GET)
@@ -700,10 +711,9 @@ export class PlatformApiController {
     @User() user: RequestUser,
     @Query() query: Record<string, string>,
   ) {
-    const normalizedId = this.normalizePipelineId(pipelineId);
     return this.platformApiService.proxy(
       'GET',
-      `/pipeline/${normalizedId}/pipeline_run`,
+      `/pipeline/${pipelineId}/pipeline_run`,
       user,
       undefined,
       query,
@@ -718,11 +728,9 @@ export class PlatformApiController {
     @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}`,
+      `/pipeline/${pipelineId}/pipeline_run/${runId}`,
       user,
     );
   }
@@ -735,10 +743,9 @@ export class PlatformApiController {
     @User() user: RequestUser,
     @Query() query: Record<string, string>,
   ) {
-    const normalizedRunId = this.normalizePipelineId(runId);
     return this.platformApiService.proxy(
       'GET',
-      `/pipeline/pipeline_run/${normalizedRunId}/logs`,
+      `/pipeline/pipeline_run/${runId}/logs`,
       user,
       undefined,
       query,