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                     {
  41                         ...getParams(dataExplorer),
  42                         // Omit mounts when viewing all process panel
  43                         select: containerRequestFieldsNoMounts,
  44                     });
  45
  46                 api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId()));
  47                 api.dispatch(resourcesActions.SET_RESOURCES(processItems.items));
  48                 await api.dispatch<any>(loadMissingProcessesInformation(processItems.items));
  49                 api.dispatch(allProcessesPanelActions.SET_ITEMS({
  50                     items: processItems.items.map((resource: any) => resource.uuid),
  51                     itemsAvailable: processItems.itemsAvailable,
  52                     page: Math.floor(processItems.offset / processItems.limit),
  53                     rowsPerPage: processItems.limit
  54                 }));
  55             } catch {
  56                 api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId()));
  57                 api.dispatch(allProcessesPanelActions.SET_ITEMS({
  58                     items: [],
  59                     itemsAvailable: 0,
  60                     page: 0,
  61                     rowsPerPage: dataExplorer.rowsPerPage
  62                 }));
  63                 api.dispatch(couldNotFetchAllProcessesListing());
  64             }
  65         }
  66     }
  67 }
  68
  69 export const containerRequestFieldsNoMounts = [
  70     "command",
  71     "container_count_max",
  72     "container_count",
  73     "container_image",
  74     "container_uuid",
  75     "created_at",
  76     "cwd",
  77     "description",
  78     "environment",
  79     "etag",
  80     "expires_at",
  81     "filters",
  82     "href",
  83     "kind",
  84     "log_uuid",
  85     "modified_at",
  86     "modified_by_client_uuid",
  87     "modified_by_user_uuid",
  88     "name",
  89     "output_name",
  90     "output_path",
  91     "output_properties",
  92     "output_storage_classes",
  93     "output_ttl",
  94     "output_uuid",
  95     "owner_uuid",
  96     "priority",
  97     "properties",
  98     "requesting_container_uuid",
  99     "runtime_constraints",
 100     "scheduling_parameters",
 101     "state",
 102     "use_existing",
 103     "uuid",
 104 ];
 105
 106 const getParams = ( dataExplorer: DataExplorer ) => ({
 107     ...dataExplorerToListParams(dataExplorer),
 108     order: getOrder(dataExplorer),
 109     filters: getFilters(dataExplorer)
 110 });
 111
 112 const getFilters = ( dataExplorer: DataExplorer ) => {
 113     const columns = dataExplorer.columns as DataColumns<string>;
 114     const statusColumnFilters = getDataExplorerColumnFilters(columns, 'Status');
 115     const activeStatusFilter = Object.keys(statusColumnFilters).find(
 116         filterName => statusColumnFilters[filterName].selected
 117     ) || ProcessStatusFilter.ALL;
 118
 119     const nameFilter = new FilterBuilder().addILike("name", dataExplorer.searchValue).getFilters();
 120     const statusFilter = buildProcessStatusFilters(new FilterBuilder(), activeStatusFilter).getFilters();
 121     const typeFilters = serializeOnlyProcessTypeFilters(getDataExplorerColumnFilters(columns, AllProcessesPanelColumnNames.TYPE));
 122
 123     return joinFilters(
 124         nameFilter,
 125         statusFilter,
 126         typeFilters
 127     );
 128 };
 129
 130 const getOrder = (dataExplorer: DataExplorer) => {
 131     const sortColumn = getSortColumn(dataExplorer);
 132     const order = new OrderBuilder<ProcessResource>();
 133     if (sortColumn) {
 134         const sortDirection = sortColumn && sortColumn.sortDirection === SortDirection.ASC
 135             ? OrderDirection.ASC
 136             : OrderDirection.DESC;
 137
 138         const columnName = sortColumn && sortColumn.name === AllProcessesPanelColumnNames.NAME ? "name" : "createdAt";
 139         return order
 140             .addOrder(sortDirection, columnName)
 141             .getOrder();
 142     } else {
 143         return order.getOrder();
 144     }
 145 };
 146
 147 const allProcessesPanelDataExplorerIsNotSet = () =>
 148     snackbarActions.OPEN_SNACKBAR({
 149         message: 'All Processes panel is not ready.',
 150         kind: SnackbarKind.ERROR
 151     });
 152
 153 const couldNotFetchAllProcessesListing = () =>
 154     snackbarActions.OPEN_SNACKBAR({
 155         message: 'Could not fetch All Processes listing.',
 156         kind: SnackbarKind.ERROR
 157     });