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';
  14 import { getDataExplorer, DataExplorer, getSortColumn } 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 {
  18     ProcessStatusFilter,
  19     buildProcessStatusFilters,
  20     serializeOnlyProcessTypeFilters
  21 } from "../resource-type-filters/resource-type-filters";
  22 import { AllProcessesPanelColumnNames } from "views/all-processes-panel/all-processes-panel";
  23 import { OrderBuilder, OrderDirection } from "services/api/order-builder";
  24 import { ProcessResource } from "models/process";
  25 import { SortDirection } from "components/data-table/data-column";
  26
  27 export class AllProcessesPanelMiddlewareService extends DataExplorerMiddlewareService {
  28     constructor(private services: ServiceRepository, id: string) {
  29         super(id);
  30     }
  31
  32     async requestItems(api: MiddlewareAPI<Dispatch, RootState>) {
  33         const dataExplorer = getDataExplorer(api.getState().dataExplorer, this.getId());
  34         if (!dataExplorer) {
  35             api.dispatch(allProcessesPanelDataExplorerIsNotSet());
  36         } else {
  37             try {
  38                 api.dispatch(progressIndicatorActions.START_WORKING(this.getId()));
  39                 const processItems = await this.services.containerRequestService.list(
  40                     { ...getParams(dataExplorer) });
  41
  42                 api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId()));
  43                 api.dispatch(resourcesActions.SET_RESOURCES(processItems.items));
  44                 await api.dispatch<any>(loadMissingProcessesInformation(processItems.items));
  45                 api.dispatch(allProcessesPanelActions.SET_ITEMS({
  46                     items: processItems.items.map((resource: any) => resource.uuid),
  47                     itemsAvailable: processItems.itemsAvailable,
  48                     page: Math.floor(processItems.offset / processItems.limit),
  49                     rowsPerPage: processItems.limit
  50                 }));
  51             } catch {
  52                 api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId()));
  53                 api.dispatch(allProcessesPanelActions.SET_ITEMS({
  54                     items: [],
  55                     itemsAvailable: 0,
  56                     page: 0,
  57                     rowsPerPage: dataExplorer.rowsPerPage
  58                 }));
  59                 api.dispatch(couldNotFetchAllProcessesListing());
  60             }
  61         }
  62     }
  63 }
  64
  65 const getParams = ( dataExplorer: DataExplorer ) => ({
  66     ...dataExplorerToListParams(dataExplorer),
  67     order: getOrder(dataExplorer),
  68     filters: getFilters(dataExplorer)
  69 });
  70
  71 const getFilters = ( dataExplorer: DataExplorer ) => {
  72     const columns = dataExplorer.columns as DataColumns<string>;
  73     const statusColumnFilters = getDataExplorerColumnFilters(columns, 'Status');
  74     const activeStatusFilter = Object.keys(statusColumnFilters).find(
  75         filterName => statusColumnFilters[filterName].selected
  76     ) || ProcessStatusFilter.ALL;
  77
  78     const nameFilter = new FilterBuilder().addILike("name", dataExplorer.searchValue).getFilters();
  79     const statusFilter = buildProcessStatusFilters(new FilterBuilder(), activeStatusFilter).getFilters();
  80     const typeFilters = serializeOnlyProcessTypeFilters(getDataExplorerColumnFilters(columns, AllProcessesPanelColumnNames.TYPE));
  81
  82     return joinFilters(
  83         nameFilter,
  84         statusFilter,
  85         typeFilters
  86     );
  87 };
  88
  89 const getOrder = (dataExplorer: DataExplorer) => {
  90     const sortColumn = getSortColumn(dataExplorer);
  91     const order = new OrderBuilder<ProcessResource>();
  92     if (sortColumn) {
  93         const sortDirection = sortColumn && sortColumn.sortDirection === SortDirection.ASC
  94             ? OrderDirection.ASC
  95             : OrderDirection.DESC;
  96
  97         const columnName = sortColumn && sortColumn.name === AllProcessesPanelColumnNames.NAME ? "name" : "createdAt";
  98         return order
  99             .addOrder(sortDirection, columnName)
 100             .getOrder();
 101     } else {
 102         return order.getOrder();
 103     }
 104 };
 105
 106 const allProcessesPanelDataExplorerIsNotSet = () =>
 107     snackbarActions.OPEN_SNACKBAR({
 108         message: 'All Processes panel is not ready.',
 109         kind: SnackbarKind.ERROR
 110     });
 111
 112 const couldNotFetchAllProcessesListing = () =>
 113     snackbarActions.OPEN_SNACKBAR({
 114         message: 'Could not fetch All Processes listing.',
 115         kind: SnackbarKind.ERROR
 116     });