feat: service connectors (#361)

Author: talhainvenxion

src/api/connectors/getConnectorComponentsApi.ts

@@ -0,0 +1,45 @@
+import { fetchApiWithAuthRequest } from '../fetchApi';
+import { endpoints } from '../endpoints';
+import { httpMethods } from '../constants';
+import { apiUrl } from '../apiUrl';
+
+const getConnectorComponentsApi = ({
+  connector_id,
+  workspace,
+  sort_by,
+  logical_operator,
+  page,
+  size,
+  name,
+  filtersParam,
+  // id,
+  authenticationToken,
+}: {
+  connector_id?: string;
+  workspace: string;
+  sort_by: string;
+  logical_operator: string;
+  page: number;
+  size: number;
+  name?: string;
+  filtersParam?: object;
+  // id?: any;
+  authenticationToken: string;
+}): Promise<any> =>
+  fetchApiWithAuthRequest({
+    url: apiUrl(endpoints.Connectors.connectorComponents),
+    params: {
+      connector_id,
+      sort_by,
+      logical_operator,
+      page,
+      size,
+      name,
+      ...filtersParam,
+      // id,
+    },
+    method: httpMethods.get,
+    authenticationToken,
+  });
+
+export default getConnectorComponentsApi;

src/api/connectors/getConnectorsTypesApi.ts

@@ -10,7 +10,7 @@ const getConnectorsTypesApi = ({
   logical_operator,
   page,
   size,
-  name,
+  connector_type,
   filtersParam,
   // id,
   authenticationToken,
@@ -21,7 +21,7 @@ const getConnectorsTypesApi = ({
   logical_operator: string;
   page: number;
   size: number;
-  name?: string;
+  connector_type?: string;
   filtersParam?: object;
   // id?: any;
   authenticationToken: string;
@@ -34,7 +34,7 @@ const getConnectorsTypesApi = ({
       logical_operator,
       page,
       size,
-      name,
+      connector_type,
       ...filtersParam,
       // id,
     },

src/api/endpoints.ts

@@ -91,5 +91,6 @@ export const endpoints = {
       `/workspaces/${workspace}/service_connectors`,
     get: (connectorId: TId): string => `/service_connectors/${connectorId}`,
     connectorsTypes: `/service_connector_types`,
+    connectorComponents: `/components`,
   },
 };

src/redux/actionTypes/connectors.ts

@@ -8,7 +8,10 @@ export const connectorActionTypes = {
   getConnectorForId: generateApiActionsTypes(
     actionTypes.CONNECTORS_GET_CONNECTOR_FOR_ID,
   ),
-  ConnectorsTypes: generateApiActionsTypes(
+  connectorsTypes: generateApiActionsTypes(
     actionTypes.CONNECTORS_GET_CONNECTORS_TYPES,
   ),
+  getConnectorComponents: generateApiActionsTypes(
+    actionTypes.CONNECTORS_GET_CONNECTORCOMPONENTS_TYPES,
+  ),
 };

src/redux/actionTypes/constants.ts

@@ -61,6 +61,8 @@ const connectorActionTypes = {
   CONNECTORS_GET_MY_CONNECTORS: 'CONNECTORS_GET_MY_CONNECTORS',
   CONNECTORS_GET_CONNECTOR_FOR_ID: 'CONNECTORS_GET_CONNECTOR_FOR_ID',
   CONNECTORS_GET_CONNECTORS_TYPES: 'CONNECTORS_GET_CONNECTORS_TYPES',
+  CONNECTORS_GET_CONNECTORCOMPONENTS_TYPES:
+    'CONNECTORS_GET_CONNECTORCOMPONENTS_TYPES',
 };
 
 const rolesActionTypes = {

src/redux/actions/connectors/getConnectorComponentAction.ts

@@ -0,0 +1,48 @@
+import { connectorActionTypes } from '../../actionTypes';
+import getConnectorComponentsApi from '../../../api/connectors/getConnectorComponentsApi';
+
+export const getConnectorComponentAction = ({
+  connector_id,
+  workspace,
+  page,
+  size,
+  type,
+  name,
+  sort_by,
+  logical_operator,
+  filtersParam,
+  onSuccess,
+  onFailure,
+}: {
+  connector_id?: any;
+  workspace?: any;
+  page?: number;
+  size?: number;
+  type?: string;
+  name?: string;
+  logical_operator?: any;
+  filtersParam?: any;
+  sort_by?: string;
+  onSuccess?: (res: any) => void;
+  onFailure?: () => void;
+}): TRequestAction => ({
+  type: connectorActionTypes.getConnectorComponents.request,
+  payload: {
+    apiMethod: getConnectorComponentsApi,
+    isAuthenticated: true,
+    failureActionType: connectorActionTypes.getConnectorComponents.failure,
+    successActionType: connectorActionTypes.getConnectorComponents.success,
+    params: {
+      type,
+      page,
+      size,
+      name,
+      sort_by,
+      filtersParam,
+      connector_id,
+      logical_operator,
+    },
+    onSuccess,
+    onFailure,
+  },
+});

src/redux/actions/connectors/getConnectorsTypesAction.ts

@@ -5,30 +5,30 @@ export const getConnectorsTypesAction = ({
   page,
   size,
   type,
-  name,
+  connector_type,
   sort_by,
   onSuccess,
   onFailure,
 }: {
   page?: number;
   size?: number;
   type?: string;
-  name?: string;
+  connector_type?: string;
   sort_by?: string;
   onSuccess?: (res: any) => void;
   onFailure?: () => void;
 }): TRequestAction => ({
-  type: connectorActionTypes.ConnectorsTypes.request,
+  type: connectorActionTypes.connectorsTypes.request,
   payload: {
     apiMethod: getConnectorsTypesApi,
     isAuthenticated: true,
-    failureActionType: connectorActionTypes.ConnectorsTypes.failure,
-    successActionType: connectorActionTypes.ConnectorsTypes.success,
+    failureActionType: connectorActionTypes.connectorsTypes.failure,
+    successActionType: connectorActionTypes.connectorsTypes.success,
     params: {
       type,
       page,
       size,
-      name,
+      connector_type,
       sort_by,
     },
     onSuccess,

src/redux/actions/connectors/index.ts

@@ -1,9 +1,10 @@
 import { getMyConnectorsAction } from './getMyConnectorsAction';
 import { getConnectorByIdAction } from './getConnectorByIdAction';
 import { getConnectorsTypesAction } from './getConnectorsTypesAction';
-
+import { getConnectorComponentAction } from './getConnectorComponentAction';
 export const connectorsActions = {
   getMy: getMyConnectorsAction,
   connectorForId: getConnectorByIdAction,
   getConnectorsTypes: getConnectorsTypesAction,
+  getConnectorComponent: getConnectorComponentAction,
 };

src/redux/reducers/connectorsReducer.ts

@@ -6,6 +6,9 @@ export interface State {
   ids: TId[];
   byId: Record<TId, any>;
   myConnectorIds: TId[];
+  connectorComponentsIds: TId[];
+  connectorTypes: any[];
+  // connectorTypeIds: TId[];
   paginated: any;
 }
 
@@ -24,6 +27,9 @@ export const initialState: State = {
   ids: [],
   byId: {},
   myConnectorIds: [],
+  connectorComponentsIds: [],
+  connectorTypes: [],
+  // connectorTypeIds: [],
   paginated: {},
 };
 
@@ -53,6 +59,20 @@ const connectorsReducer = (
 
       return { ...newState(state, connectors, action.payload), myConnectorIds };
     }
+    case connectorActionTypes.getConnectorComponents.success: {
+      const connectorComponents: any[] = camelCaseArray(
+        action.payload.items as ConnectorsPayload,
+      );
+      // debugger;
+      const connectorComponentsIds: TId[] = connectorComponents.map(
+        (stack: any) => stack.id,
+      );
+
+      return {
+        ...newState(state, connectorComponents, action.payload),
+        connectorComponentsIds,
+      };
+    }
 
     case connectorActionTypes.getConnectorForId.success: {
       const payload: ConnectorPayload = action.payload;
@@ -62,15 +82,18 @@ const connectorsReducer = (
       return { ...state, ...newState(state, [connector]) };
     }
 
-    case connectorActionTypes.ConnectorsTypes.success: {
-      const connectorsTypes: any[] = camelCaseArray(
-        action.payload.items as ConnectorsTypesPayload,
+    case connectorActionTypes.connectorsTypes.success: {
+      const connectorTypes: any[] = camelCaseArray(
+        action.payload as ConnectorsTypesPayload,
       );
 
-      // const connectorIds: TId[] = connectorsTypes.map(
+      // const connectorTypeIds: TId[] = connectorsTypes.map(
       //   (connector: any) => connector.id,
       // );
-      return { ...newState(state, connectorsTypes, action.payload) };
+      return {
+        ...state,
+        connectorTypes,
+      };
 
       // return { ...state, ...newState(state, connectorsTypes) };
     }

src/redux/sagas/actionTypesHandledByRequestSaga.ts

@@ -55,7 +55,8 @@ export const actionTypesHandledByRequestSaga: string[] = [
 
   connectorActionTypes.getMyConnectors.request,
   connectorActionTypes.getConnectorForId.request,
-  connectorActionTypes.ConnectorsTypes.request,
+  connectorActionTypes.connectorsTypes.request,
+  connectorActionTypes.getConnectorComponents.request,
 
   runActionTypes.getArtifact.request,
   runActionTypes.getStep.request,