src/store/all-processes-panel/all-processes-panel-middleware-service.ts

   1 // Copyright (C) The Arvados Authors. All rights reserved.
   2 //
   3 // SPDX-License-Identifier: AGPL-3.0
   4
   5 import { DataExplorerMiddlewareService, dataExplorerToListParams, getDataExplorerColumnFilters } from "~/store/data-explorer/data-explorer-middleware-service";
   6 import { RootState } from "../store";
   7 import { ServiceRepository } from "~/services/services";
   8 import { FilterBuilder, joinFilters } from "~/services/api/filter-builder";
   9 import { allProcessesPanelActions } from "./all-processes-panel-action";
  10 import { Dispatch, MiddlewareAPI } from "redux";
  11 import { resourcesActions } from "~/store/resources/resources-actions";
  12 import { snackbarActions, SnackbarKind } from '~/store/snackbar/snackbar-actions';
  13 import { progressIndicatorActions } from '~/store/progress-indicator/progress-indicator-actions.ts';
  14 import { getDataExplorer, DataExplorer } from "~/store/data-explorer/data-explorer-reducer";
  15 import { loadMissingProcessesInformation } from "~/store/project-panel/project-panel-middleware-service";
  16 import { DataColumns } from "~/components/data-table/data-table";
  17 import { ProcessStatusFilter, buildProcessStatusFilters } from "../resource-type-filters/resource-type-filters";
  18
  19 export class AllProcessesPanelMiddlewareService extends DataExplorerMiddlewareService {
  20     constructor(private services: ServiceRepository, id: string) {
  21         super(id);
  22     }
  23
  24     async requestItems(api: MiddlewareAPI<Dispatch, RootState>) {
  25         const dataExplorer = getDataExplorer(api.getState().dataExplorer, this.getId());
  26         if (!dataExplorer) {
  27             api.dispatch(allProcessesPanelDataExplorerIsNotSet());
  28         } else {
  29             try {
  30                 api.dispatch(progressIndicatorActions.START_WORKING(this.getId()));
  31                 const processItems = await this.services.containerRequestService.list(
  32                     { ...getParams(dataExplorer) });
  33
  34                 api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId()));
  35                 api.dispatch(resourcesActions.SET_RESOURCES(processItems.items));
  36                 await api.dispatch<any>(loadMissingProcessesInformation(processItems.items));
  37                 api.dispatch(allProcessesPanelActions.SET_ITEMS({
  38                     items: processItems.items.map((resource: any) => resource.uuid),
  39                     itemsAvailable: processItems.itemsAvailable,
  40                     page: Math.floor(processItems.offset / processItems.limit),
  41                     rowsPerPage: processItems.limit
  42                 }));
  43             } catch {
  44                 api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId()));
  45                 api.dispatch(allProcessesPanelActions.SET_ITEMS({
  46                     items: [],
  47                     itemsAvailable: 0,
  48                     page: 0,
  49                     rowsPerPage: dataExplorer.rowsPerPage
  50                 }));
  51                 api.dispatch(couldNotFetchAllProcessesListing());
  52             }
  53         }
  54     }
  55 }
  56
  57 const getParams = ( dataExplorer: DataExplorer ) => ({
  58     ...dataExplorerToListParams(dataExplorer),
  59     filters: getFilters(dataExplorer)
  60 });
  61
  62 const getFilters = ( dataExplorer: DataExplorer ) => {
  63     const columns = dataExplorer.columns as DataColumns<string>;
  64     const statusColumnFilters = getDataExplorerColumnFilters(columns, 'Status');
  65     const activeStatusFilter = Object.keys(statusColumnFilters).find(
  66         filterName => statusColumnFilters[filterName].selected
  67     ) || ProcessStatusFilter.ALL;
  68
  69     const nameFilter = new FilterBuilder().addILike("name", dataExplorer.searchValue).getFilters();
  70     const statusFilter = buildProcessStatusFilters(new FilterBuilder(), activeStatusFilter).getFilters();
  71
  72     return joinFilters(
  73         nameFilter,
  74         statusFilter
  75     );
  76 };
  77
  78 const allProcessesPanelDataExplorerIsNotSet = () =>
  79     snackbarActions.OPEN_SNACKBAR({
  80         message: 'All Processes panel is not ready.',
  81         kind: SnackbarKind.ERROR
  82     });
  83
  84 const couldNotFetchAllProcessesListing = () =>
  85     snackbarActions.OPEN_SNACKBAR({
  86         message: 'Could not fetch All Processes listing.',
  87         kind: SnackbarKind.ERROR
  88     });