Rework dataset filtering in with new reducer based hook state

elastic · Jul 13, 2020 · 0ec814e · 0ec814e
1 parent cc546d3
commit 0ec814e
Showing 1 changed file with 22 additions and 2 deletions.
diff --git a/x-pack/plugins/infra/public/pages/logs/log_entry_rate/use_log_entry_anomalies_results.ts b/x-pack/plugins/infra/public/pages/logs/log_entry_rate/use_log_entry_anomalies_results.ts
@@ -42,6 +42,7 @@ interface ReducerState {
     start: number;
     end: number;
   };
+  filteredDatasets?: string[];
 }
 
 type ReducerStateDefaults = Pick<
@@ -56,7 +57,8 @@ type ReducerAction =
   | { type: 'fetchPreviousPage' }
   | { type: 'changeHasNextPage'; payload: { hasNextPage: boolean } }
   | { type: 'changeLastReceivedCursors'; payload: { lastReceivedCursors: PaginationCursors } }
-  | { type: 'changeTimeRange'; payload: { timeRange: { start: number; end: number } } };
+  | { type: 'changeTimeRange'; payload: { timeRange: { start: number; end: number } } }
+  | { type: 'changeFilteredDatasets'; payload: { filteredDatasets?: string[] } };
 
 const stateReducer = (state: ReducerState, action: ReducerAction): ReducerState => {
   const resetPagination = {
@@ -108,6 +110,12 @@ const stateReducer = (state: ReducerState, action: ReducerAction): ReducerState
         ...resetPagination,
         ...action.payload,
       };
+    case 'changeFilteredDatasets':
+      return {
+        ...state,
+        ...resetPagination,
+        ...action.payload,
+      };
     default:
       return state;
   }
@@ -145,6 +153,7 @@ export const useLogEntryAnomaliesResults = ({
       ...stateDefaults,
       paginationOptions: defaultPaginationOptions,
       sortOptions: defaultSortOptions,
+      filteredDatasets,
       timeRange: {
         start: startTime,
         end: endTime,
@@ -165,6 +174,7 @@ export const useLogEntryAnomaliesResults = ({
           sortOptions,
           paginationOptions,
           paginationCursor,
+          filteredDatasets: queryFilteredDatasets,
         } = reducerState;
         return await callGetLogEntryAnomaliesAPI(
           sourceId,
@@ -174,7 +184,8 @@ export const useLogEntryAnomaliesResults = ({
           {
             ...paginationOptions,
             cursor: paginationCursor,
-          }
+          },
+          queryFilteredDatasets
         );
       },
       onResolve: ({ data: { anomalies, paginationCursors: requestCursors, hasMoreEntries } }) => {
@@ -203,6 +214,7 @@ export const useLogEntryAnomaliesResults = ({
       reducerState.sortOptions,
       reducerState.paginationOptions,
       reducerState.paginationCursor,
+      reducerState.filteredDatasets,
     ]
   );
 
@@ -231,6 +243,14 @@ export const useLogEntryAnomaliesResults = ({
     });
   }, [startTime, endTime]);
 
+  // Selected datasets have changed
+  useEffect(() => {
+    dispatch({
+      type: 'changeFilteredDatasets',
+      payload: { filteredDatasets },
+    });
+  }, [filteredDatasets]);
+
   useEffect(() => {
     getLogEntryAnomalies();
   }, [getLogEntryAnomalies]);