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 { SortDirection } from "components/data-table/data-column";
25 import { containerRequestFieldsNoMounts, ContainerRequestResource } from "models/container-request";
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 const getParams = ( dataExplorer: DataExplorer ) => ({
70 ...dataExplorerToListParams(dataExplorer),
71 order: getOrder(dataExplorer),
72 filters: getFilters(dataExplorer)
75 const getFilters = ( dataExplorer: DataExplorer ) => {
76 const columns = dataExplorer.columns as DataColumns<string, ContainerRequestResource>;
77 const statusColumnFilters = getDataExplorerColumnFilters(columns, 'Status');
78 const activeStatusFilter = Object.keys(statusColumnFilters).find(
79 filterName => statusColumnFilters[filterName].selected
80 ) || ProcessStatusFilter.ALL;
82 const nameFilter = new FilterBuilder().addILike("name", dataExplorer.searchValue).getFilters();
83 const statusFilter = buildProcessStatusFilters(new FilterBuilder(), activeStatusFilter).getFilters();
84 const typeFilters = serializeOnlyProcessTypeFilters(getDataExplorerColumnFilters(columns, AllProcessesPanelColumnNames.TYPE));
93 const getOrder = (dataExplorer: DataExplorer) => {
94 const sortColumn = getSortColumn<ContainerRequestResource>(dataExplorer);
95 const order = new OrderBuilder<ContainerRequestResource>();
96 if (sortColumn && sortColumn.sort) {
97 const sortDirection = sortColumn.sort.direction === SortDirection.ASC
99 : OrderDirection.DESC;
102 .addOrder(sortDirection, sortColumn.sort.field)
105 return order.getOrder();
109 const allProcessesPanelDataExplorerIsNotSet = () =>
110 snackbarActions.OPEN_SNACKBAR({
111 message: 'All Processes panel is not ready.',
112 kind: SnackbarKind.ERROR
115 const couldNotFetchAllProcessesListing = () =>
116 snackbarActions.OPEN_SNACKBAR({
117 message: 'Could not fetch All Processes listing.',
118 kind: SnackbarKind.ERROR