1 // Copyright (C) The Arvados Authors. All rights reserved.
3 // SPDX-License-Identifier: AGPL-3.0
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";
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";
27 export class AllProcessesPanelMiddlewareService extends DataExplorerMiddlewareService {
28 constructor(private services: ServiceRepository, id: string) {
32 async requestItems(api: MiddlewareAPI<Dispatch, RootState>) {
33 const dataExplorer = getDataExplorer(api.getState().dataExplorer, this.getId());
35 api.dispatch(allProcessesPanelDataExplorerIsNotSet());
38 api.dispatch(progressIndicatorActions.START_WORKING(this.getId()));
39 const processItems = await this.services.containerRequestService.list(
41 ...getParams(dataExplorer),
42 // Omit mounts when viewing all process panel
43 select: containerRequestFieldsNoMounts,
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
56 api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId()));
57 api.dispatch(allProcessesPanelActions.SET_ITEMS({
61 rowsPerPage: dataExplorer.rowsPerPage
63 api.dispatch(couldNotFetchAllProcessesListing());
69 // Until the api supports unselecting fields, we need a list of all other fields to omit mounts
70 export const containerRequestFieldsNoMounts = [
72 "container_count_max",
87 "modified_by_client_uuid",
88 "modified_by_user_uuid",
93 "output_storage_classes",
99 "requesting_container_uuid",
100 "runtime_constraints",
101 "scheduling_parameters",
107 const getParams = ( dataExplorer: DataExplorer ) => ({
108 ...dataExplorerToListParams(dataExplorer),
109 order: getOrder(dataExplorer),
110 filters: getFilters(dataExplorer)
113 const getFilters = ( dataExplorer: DataExplorer ) => {
114 const columns = dataExplorer.columns as DataColumns<string>;
115 const statusColumnFilters = getDataExplorerColumnFilters(columns, 'Status');
116 const activeStatusFilter = Object.keys(statusColumnFilters).find(
117 filterName => statusColumnFilters[filterName].selected
118 ) || ProcessStatusFilter.ALL;
120 const nameFilter = new FilterBuilder().addILike("name", dataExplorer.searchValue).getFilters();
121 const statusFilter = buildProcessStatusFilters(new FilterBuilder(), activeStatusFilter).getFilters();
122 const typeFilters = serializeOnlyProcessTypeFilters(getDataExplorerColumnFilters(columns, AllProcessesPanelColumnNames.TYPE));
131 const getOrder = (dataExplorer: DataExplorer) => {
132 const sortColumn = getSortColumn(dataExplorer);
133 const order = new OrderBuilder<ProcessResource>();
135 const sortDirection = sortColumn && sortColumn.sortDirection === SortDirection.ASC
137 : OrderDirection.DESC;
139 const columnName = sortColumn && sortColumn.name === AllProcessesPanelColumnNames.NAME ? "name" : "createdAt";
141 .addOrder(sortDirection, columnName)
144 return order.getOrder();
148 const allProcessesPanelDataExplorerIsNotSet = () =>
149 snackbarActions.OPEN_SNACKBAR({
150 message: 'All Processes panel is not ready.',
151 kind: SnackbarKind.ERROR
154 const couldNotFetchAllProcessesListing = () =>
155 snackbarActions.OPEN_SNACKBAR({
156 message: 'Could not fetch All Processes listing.',
157 kind: SnackbarKind.ERROR