#RI-5750 - update rdi with latest changes

Author: AmirAllayarovSofteq

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

@@ -213,17 +213,17 @@ interface IErrorDetail {
   message: string;
 }
 
-interface ISourceDetail {
+interface ITargetDetail {
   status: TestConnectionStatus;
   error?: IErrorDetail;
 }
 
-export interface ISources {
-  [key: string]: ISourceDetail;
+export interface ITargets {
+  [key: string]: ITargetDetail;
 }
 
 export interface TestConnectionsResponse {
-  sources: ISources
+  targets: ITargets
 }
 
 export interface IRdiConnectionResult {

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

@@ -88,7 +88,7 @@ export function testConnectionsAction(
       testConnectionsController = null
 
       if (isStatusSuccessful(status)) {
-        dispatch(testConnectionsSuccess(transformConnectionResults(data?.sources)))
+        dispatch(testConnectionsSuccess(transformConnectionResults(data?.targets)))
         onSuccessAction?.()
       }
     } catch (_err) {

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

@@ -26,7 +26,8 @@ import reducer, {
   deployPipelineAction,
   fetchRdiPipelineSchema,
   fetchPipelineStrategies,
-  fetchPipelineTemplate,
+  fetchConfigTemplate,
+  fetchJobTemplate,
   setJobFunctions,
   fetchRdiPipelineJobFunctions,
   getPipelineStatusAction,
@@ -689,9 +690,8 @@ describe('rdi pipe slice', () => {
       })
     })
 
-    describe('fetchPipelineTemplate', () => {
+    describe('fetchJobTemplate', () => {
       it('failed to fetch data', async () => {
-        const mockOptions = { dbType: 'db type' }
         const errorMessage = 'Something was wrong!'
         const responsePayload = {
           response: {
@@ -704,7 +704,33 @@ describe('rdi pipe slice', () => {
 
         // Act
         await store.dispatch<any>(
-          fetchPipelineTemplate('123', mockOptions)
+          fetchJobTemplate('123', 'db_type')
+        )
+
+        // Assert
+        const expectedActions = [
+          addErrorNotification(responsePayload as AxiosError),
+        ]
+
+        expect(store.getActions()).toEqual(expectedActions)
+      })
+    })
+
+    describe('fetchConfigTemplate', () => {
+      it('failed to fetch data', async () => {
+        const errorMessage = 'Something was wrong!'
+        const responsePayload = {
+          response: {
+            status: 500,
+            data: { message: errorMessage },
+          },
+        }
+
+        apiService.get = jest.fn().mockRejectedValue(responsePayload)
+
+        // Act
+        await store.dispatch<any>(
+          fetchConfigTemplate('123', 'ingest','db_type')
         )
 
         // Assert

redisinsight/ui/src/slices/tests/rdi/testConnections.spec.ts

@@ -13,7 +13,7 @@ import { apiService } from 'uiSrc/services'
 import { addErrorNotification } from 'uiSrc/slices/app/notifications'
 
 const mockData = {
-  sources: {
+  targets: {
     target: {
       status: 'success',
     }
@@ -54,14 +54,15 @@ describe('rdi test connections slice', () => {
   describe('testConnectionsSuccess', () => {
     it('should properly set state', () => {
       // Arrange
+      const data = { success: [{ target: 'target' }], fail: [] }
       const state = {
         ...initialState,
-        results: mockData,
+        results: data,
         loading: false,
       }
 
       // Act
-      const nextState = reducer(initialState, testConnectionsSuccess(mockData))
+      const nextState = reducer(initialState, testConnectionsSuccess(data))
 
       // Assert
       const rootState = Object.assign(initialStateDefault, {

redisinsight/ui/src/utils/transformers/transformRdiPipeline.ts

@@ -19,7 +19,7 @@ export const pipelineToJson = ({ config, jobs }: IPipeline): IPipelineJSON => <I
 
 export const transformConnectionResults = (sources: ISources): TransformResult => {
   const result: TransformResult = { success: [], fail: [] }
-
+  console.log(sources)
   if (!sources) {
     return result
   }