setting nodes on flow\

src/redux/flow/reducer.ts

@@ -1,15 +1,17 @@
 import { createReducer } from '~/utils/reducer';
-import { INode, UUID } from '../types';
+import { INode, IError } from '../types';
 import { FLOW_HANDLERS } from './handlers';
 
 export type IFlowState = Readonly<{
   is_loading: boolean;
-  nodes: Record<UUID, INode>;
+  nodes: INode[];
+  error: IError;
 }>;
 
 const INITIAL_STATE: IFlowState = {
-  nodes: {},
+  nodes: [],
   is_loading: false,
+  error: null,
 };
 
 export default createReducer(INITIAL_STATE, FLOW_HANDLERS);

src/redux/flow/sagas.ts

@@ -1,23 +1,25 @@
-import { takeLatest, call } from 'redux-saga/effects';
+import { takeLatest, call, put } from 'redux-saga/effects';
 import { REHYDRATE } from 'redux-persist';
 import { FLOW_ACTIONS } from './constants';
 import { getNodes } from '../node/api';
 import { flowSetNodes } from './actions';
+import { objFromArray } from '~/utils/fn';
+import { IResultWithStatus, INode } from '../types';
 
 function* onGetFlow() {
   const {
     data: { nodes = null },
     error,
-  } = yield call(getNodes, {});
+  }: IResultWithStatus<{ nodes: INode[] }> = yield call(getNodes, {});
 
-  if (!nodes) {
+  if (!nodes || !nodes.length) {
     // todo: set error empty response
   }
 
   // todo: write nodes
-  // yield put(flowSetNodes());
+  yield put(flowSetNodes(nodes));
 
-  console.log('flow', { nodes, error });
+  // console.log('flow', { nodes, error });
 }
 
 export default function* nodeSaga() {

src/redux/types.ts

@@ -114,4 +114,5 @@ export interface INode {
 }
 
 export type IUploadProgressHandler = (progress: ProgressEvent) => void;
-export type IValidationErrors = Record<string, ValueOf<typeof ERRORS>>;
+export type IError = ValueOf<typeof ERRORS>;
+export type IValidationErrors = Record<string, IError>;

src/utils/fn.ts

@@ -4,3 +4,5 @@ import nth from 'ramda/es/nth';
 import remove from 'ramda/es/remove';
 
 export const moveArrItem = curry((at, to, list) => insert(to, nth(at, list), remove(at, 1, list)));
+export const objFromArray = (array: any[], key: string) =>
+  array.reduce((obj, el) => (key && el[key] ? { ...obj, [el[key]]: el } : obj), {});