#RI-5750 - update get template endpoint

Author: AmirAllayarovSofteq

redisinsight/ui/src/constants/api.ts

@@ -148,7 +148,8 @@ enum ApiEndpoints {
   RDI_DEPLOY_PIPELINE = 'pipeline/deploy',
   RDI_TEST_CONNECTIONS = 'pipeline/test-connections',
   RDI_PIPELINE_STRATEGIES = 'pipeline/strategies',
-  RDI_PIPELINE_TEMPLATE = 'pipeline/template',
+  RDI_JOB_TEMPLATE = 'pipeline/job/template',
+  RDI_CONFIG_TEMPLATE = 'pipeline/config/template',
   RDI_PIPELINE_JOB_FUNCTIONS = 'pipeline/job-functions',
   RDI_STATISTICS = 'statistics',
   RDI_PIPELINE_STATUS = 'pipeline/status',

redisinsight/ui/src/pages/rdi/pipeline-management/components/template-form/TemplateForm.tsx

@@ -13,7 +13,12 @@ import { useDispatch, useSelector } from 'react-redux'
 import { useParams } from 'react-router-dom'
 import cx from 'classnames'
 
-import { fetchPipelineStrategies, fetchPipelineTemplate, rdiPipelineStrategiesSelector } from 'uiSrc/slices/rdi/pipeline'
+import {
+  fetchPipelineStrategies,
+  fetchJobTemplate,
+  fetchConfigTemplate,
+  rdiPipelineStrategiesSelector,
+} from 'uiSrc/slices/rdi/pipeline'
 import { RdiPipelineTabs } from 'uiSrc/slices/interfaces/rdi'
 import { sendEventTelemetry, TelemetryEvent } from 'uiSrc/telemetry'
 import { NO_TEMPLATE_VALUE, NO_OPTIONS, INGEST_OPTION } from './constants'
@@ -69,11 +74,12 @@ const TemplateForm = (props: Props) => {
   }
 
   const handleApply = () => {
-    const values = source === RdiPipelineTabs.Config
-      ? { dbType: selectedDbType, pipelineType: selectedPipelineType }
-      : { pipelineType: selectedPipelineType }
-
-    dispatch(fetchPipelineTemplate(rdiInstanceId, values, onSuccess))
+    if (source === RdiPipelineTabs.Config) {
+      dispatch(fetchConfigTemplate(rdiInstanceId, selectedPipelineType, selectedDbType, onSuccess))
+    }
+    if (source === RdiPipelineTabs.Jobs) {
+      dispatch(fetchJobTemplate(rdiInstanceId, selectedPipelineType, onSuccess))
+    }
     sendEventTelemetry({
       event: TelemetryEvent.RDI_TEMPLATE_CLICKED,
       eventData: {

redisinsight/ui/src/slices/rdi/pipeline.ts

@@ -232,18 +232,42 @@ export function fetchPipelineStrategies(
   }
 }
 
-export function fetchPipelineTemplate(
+export function fetchJobTemplate(
   rdiInstanceId: string,
-  // TODO add interface
-  options: any,
+  pipelineType: string,
   onSuccessAction?: (template: string) => void,
   onFailAction?: () => void,
 ) {
   return async (dispatch: AppDispatch) => {
     try {
       const { status, data } = await apiService.get(
-        getRdiUrl(rdiInstanceId, ApiEndpoints.RDI_PIPELINE_TEMPLATE),
-        { params: options },
+        getRdiUrl(rdiInstanceId, ApiEndpoints.RDI_JOB_TEMPLATE, pipelineType),
+      )
+
+      if (isStatusSuccessful(status)) {
+        onSuccessAction?.(data.template)
+      }
+    } catch (_err) {
+      const error = _err as AxiosError
+      const parsedError = getAxiosError(error as EnhancedAxiosError)
+
+      dispatch(addErrorNotification(parsedError))
+      onFailAction?.()
+    }
+  }
+}
+
+export function fetchConfigTemplate(
+  rdiInstanceId: string,
+  pipelineType: string,
+  dbType: string,
+  onSuccessAction?: (template: string) => void,
+  onFailAction?: () => void,
+) {
+  return async (dispatch: AppDispatch) => {
+    try {
+      const { status, data } = await apiService.get(
+        getRdiUrl(rdiInstanceId, ApiEndpoints.RDI_CONFIG_TEMPLATE, pipelineType, dbType),
       )
 
       if (isStatusSuccessful(status)) {