Merge pull request #411 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

@@ -128,14 +128,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
-

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,