services/workbench2/src/store/groups-panel/groups-panel-middleware-service.ts

   1 // Copyright (C) The Arvados Authors. All rights reserved.
   2 //
   3 // SPDX-License-Identifier: AGPL-3.0
   4
   5 import { Dispatch, MiddlewareAPI } from "redux";
   6 import { DataExplorerMiddlewareService, listResultsToDataExplorerItemsMeta, dataExplorerToListParams } from "store/data-explorer/data-explorer-middleware-service";
   7 import { RootState } from "store/store";
   8 import { ServiceRepository } from "services/services";
   9 import { snackbarActions, SnackbarKind } from 'store/snackbar/snackbar-actions';
  10 import { DataExplorer, getDataExplorer, getSortColumn } from "store/data-explorer/data-explorer-reducer";
  11 import { GroupsPanelActions } from 'store/groups-panel/groups-panel-actions';
  12 import { FilterBuilder } from 'services/api/filter-builder';
  13 import { updateResources } from 'store/resources/resources-actions';
  14 import { OrderBuilder, OrderDirection } from 'services/api/order-builder';
  15 import { GroupResource, GroupClass } from 'models/group';
  16 import { SortDirection } from 'components/data-table/data-column';
  17 import { progressIndicatorActions } from "store/progress-indicator/progress-indicator-actions";
  18 import { ListArguments, ListResults } from "services/common-service/common-service";
  19 import { couldNotFetchItemsAvailable } from "store/data-explorer/data-explorer-action";
  20
  21 export class GroupsPanelMiddlewareService extends DataExplorerMiddlewareService {
  22     constructor(private services: ServiceRepository, id: string) {
  23         super(id);
  24     }
  25
  26     getOrder = (dataExplorer: DataExplorer) => {
  27         const sortColumn = getSortColumn<GroupResource>(dataExplorer);
  28         const order = new OrderBuilder<GroupResource>();
  29         if (sortColumn && sortColumn.sort) {
  30             const sortDirection = sortColumn.sort.direction === SortDirection.ASC ? OrderDirection.ASC : OrderDirection.DESC;
  31
  32             // Use createdAt as a secondary sort column so we break ties consistently.
  33             return order
  34                 .addOrder(sortDirection, sortColumn.sort.field)
  35                 .addOrder(OrderDirection.DESC, "createdAt")
  36                 .getOrder();
  37         } else {
  38             return order.getOrder();
  39         }
  40     };
  41
  42     getFilters(dataExplorer: DataExplorer): string {
  43         return new FilterBuilder()
  44             .addEqual('group_class', GroupClass.ROLE)
  45             .addILike('name', dataExplorer.searchValue)
  46             .getFilters();
  47     }
  48
  49     getParams(dataExplorer: DataExplorer): ListArguments {
  50         return {
  51             ...dataExplorerToListParams(dataExplorer),
  52             filters: this.getFilters(dataExplorer),
  53             order: this.getOrder(dataExplorer),
  54             count: 'none',
  55         };
  56     }
  57
  58     getCountParams(dataExplorer: DataExplorer): ListArguments {
  59         return {
  60             filters: this.getFilters(dataExplorer),
  61             limit: 0,
  62             count: 'exact',
  63         };
  64     }
  65
  66     async requestItems(api: MiddlewareAPI<Dispatch, RootState>, criteriaChanged?: boolean, background?: boolean) {
  67         const dataExplorer = getDataExplorer(api.getState().dataExplorer, this.getId());
  68         if (!dataExplorer) {
  69             api.dispatch(groupsPanelDataExplorerIsNotSet());
  70         } else {
  71             try {
  72                 if (!background) { api.dispatch(progressIndicatorActions.START_WORKING(this.getId())); }
  73
  74                 // Get items
  75                 const groups = await this.services.groupsService.list(this.getParams(dataExplorer));
  76                 api.dispatch(updateResources(groups.items));
  77                 api.dispatch(GroupsPanelActions.SET_ITEMS({
  78                     ...listResultsToDataExplorerItemsMeta(groups),
  79                     items: groups.items.map(item => item.uuid),
  80                 }));
  81
  82                 // Get group member counts
  83                 groups.items.map(group => (
  84                     this.services.permissionService.list({
  85                         limit: 0,
  86                         filters: new FilterBuilder()
  87                             .addEqual('head_uuid', group.uuid)
  88                             .getFilters()
  89                     }).then(members => {
  90                         api.dispatch(updateResources([{
  91                             ...group,
  92                             memberCount: members.itemsAvailable,
  93                         } as GroupResource]));
  94                     }).catch(e => {
  95                         // In case of error, store null to stop spinners and show failure icon
  96                         api.dispatch(updateResources([{
  97                             ...group,
  98                             memberCount: null,
  99                         } as GroupResource]));
 100                     })
 101                 ));
 102             } catch (e) {
 103                 api.dispatch(couldNotFetchGroupList());
 104             } finally {
 105                 api.dispatch(progressIndicatorActions.STOP_WORKING(this.getId()));
 106             }
 107         }
 108     }
 109
 110     async requestCount(api: MiddlewareAPI<Dispatch, RootState>, criteriaChanged?: boolean, background?: boolean) {
 111         const state = api.getState();
 112         const dataExplorer = getDataExplorer(state.dataExplorer, this.getId());
 113
 114         if (criteriaChanged) {
 115             // Get itemsAvailable
 116             return this.services.groupsService.list(this.getCountParams(dataExplorer))
 117                 .then((results: ListResults<GroupResource>) => {
 118                     if (results.itemsAvailable !== undefined) {
 119                         api.dispatch<any>(GroupsPanelActions.SET_ITEMS_AVAILABLE(results.itemsAvailable));
 120                     } else {
 121                         couldNotFetchItemsAvailable();
 122                     }
 123                 });
 124         }
 125     }
 126 }
 127
 128 const groupsPanelDataExplorerIsNotSet = () =>
 129     snackbarActions.OPEN_SNACKBAR({
 130         message: 'Groups panel is not ready.',
 131         kind: SnackbarKind.ERROR
 132     });
 133
 134 const couldNotFetchGroupList = () =>
 135     snackbarActions.OPEN_SNACKBAR({
 136         message: 'Could not fetch groups.',
 137         kind: SnackbarKind.ERROR
 138     });