#RI-5133 - update pipeline endpoint

redisinsight/api/src/modules/rdi/client/api.rdi.client.ts

@@ -19,7 +19,8 @@ export class ApiRdiClient extends RdiClient {
   }
 
   async getPipeline(): Promise<RdiPipeline> {
-    return null;
+    const response = await this.client.get(RdiUrl.GetPipeline);
+    return response.data;
   }
 
   async deploy(pipeline: RdiPipeline): Promise<RdiPipeline> {

redisinsight/api/src/modules/rdi/constants/index.ts

@@ -1,3 +1,4 @@
 export enum RdiUrl {
   GetSchema = '/schema',
+  GetPipeline = '/pipeline',
 }

redisinsight/api/src/modules/rdi/rdi-pipeline.controller.ts

@@ -1,7 +1,7 @@
 import {
   ClassSerializerInterceptor, Controller, Get, UseInterceptors, UsePipes, ValidationPipe,
 } from '@nestjs/common';
-import { Rdi, RdiClientMetadata } from 'src/modules/rdi/models';
+import { Rdi, RdiPipeline, RdiClientMetadata } from 'src/modules/rdi/models';
 import { ApiTags } from '@nestjs/swagger';
 import { ApiEndpoint } from 'src/decorators/api-endpoint.decorator';
 import { RdiPipelineService } from 'src/modules/rdi/rdi-pipeline.service';
@@ -26,4 +26,15 @@ export class RdiPipelineController {
   ): Promise<object> {
     return this.rdiPipelineService.getSchema(rdiClientMetadata);
   }
+
+  @Get('/')
+  @ApiEndpoint({
+    description: 'Get pipeline',
+    responses: [{ status: 200, type: RdiPipeline }],
+  })
+  async getPipeline(
+    @RequestRdiClientMetadata() rdiClientMetadata: RdiClientMetadata,
+  ): Promise<object> {
+    return this.rdiPipelineService.getPipeline(rdiClientMetadata);
+  }
 }

redisinsight/api/src/modules/rdi/rdi-pipeline.service.ts

@@ -11,10 +11,12 @@ export class RdiPipelineService {
   async getSchema(rdiClientMetadata: RdiClientMetadata): Promise<object> {
     const client = await this.rdiClientProvider.getOrCreate(rdiClientMetadata);
 
-    const schema = await client.getSchema();
+    return await client.getSchema();
+  }
 
-    // todo: process somehow
+  async getPipeline(rdiClientMetadata: RdiClientMetadata): Promise<object> {
+    const client = await this.rdiClientProvider.getOrCreate(rdiClientMetadata);
 
-    return schema;
+    return await client.getPipeline();
   }
 }