src/store/shared-with-me-panel/shared-with-me-middleware-service.ts

   1 // Copyright (C) The Arvados Authors. All rights reserved.
   2 //
   3 // SPDX-License-Identifier: AGPL-3.0
   4
   5 import { DataExplorerMiddlewareService, listResultsToDataExplorerItemsMeta, dataExplorerToListParams } from '../data-explorer/data-explorer-middleware-service';
   6 import { ServiceRepository } from 'services/services';
   7 import { MiddlewareAPI, Dispatch } from 'redux';
   8 import { RootState } from 'store/store';
   9 import { getDataExplorer, DataExplorer } from 'store/data-explorer/data-explorer-reducer';
  10 import { updateFavorites } from 'store/favorites/favorites-actions';
  11 import { updateResources } from 'store/resources/resources-actions';
  12 import { loadMissingProcessesInformation, getFilters } from 'store/project-panel/project-panel-middleware-service';
  13 import { snackbarActions, SnackbarKind } from 'store/snackbar/snackbar-actions';
  14 import { sharedWithMePanelActions } from './shared-with-me-panel-actions';
  15 import { ListResults } from 'services/common-service/common-service';
  16 import { GroupContentsResource, GroupContentsResourcePrefix } from 'services/groups-service/groups-service';
  17 import { SortDirection } from 'components/data-table/data-column';
  18 import { OrderBuilder, OrderDirection } from 'services/api/order-builder';
  19 import { ProjectResource } from 'models/project';
  20 import { getSortColumn } from "store/data-explorer/data-explorer-reducer";
  21 import { updatePublicFavorites } from 'store/public-favorites/public-favorites-actions';
  22 import { FilterBuilder, joinFilters } from 'services/api/filter-builder';
  23 import { progressIndicatorActions } from 'store/progress-indicator/progress-indicator-actions';
  24 import { AuthState } from 'store/auth/auth-reducer';
  25
  26 export class SharedWithMeMiddlewareService extends DataExplorerMiddlewareService {
  27     constructor(private services: ServiceRepository, id: string) {
  28         super(id);
  29     }
  30
  31     async requestItems(api: MiddlewareAPI<Dispatch, RootState>) {
  32         const state = api.getState();
  33         const dataExplorer = getDataExplorer(state.dataExplorer, this.getId());
  34         try {
  35             api.dispatch(progressIndicatorActions.START_WORKING(this.getId()));
  36             const response = await this.services.groupsService
  37                 .contents('', getParams(dataExplorer, state.auth));
  38             api.dispatch<any>(updateFavorites(response.items.map(item => item.uuid)));
  39             api.dispatch<any>(updatePublicFavorites(response.items.map(item => item.uuid)));
  40             api.dispatch(updateResources(response.items));
  41             await api.dispatch<any>(loadMissingProcessesInformation(response.items));
  42             api.dispatch(setItems(response));
  43         } catch (e) {
  44             api.dispatch(couldNotFetchSharedItems());
  45         } finally {
  46             api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId()));
  47         }
  48     }
  49 }
  50
  51 export const getParams = (dataExplorer: DataExplorer, authState: AuthState) => ({
  52     ...dataExplorerToListParams(dataExplorer),
  53     order: getOrder(dataExplorer),
  54     filters: joinFilters(
  55         getFilters(dataExplorer),
  56         new FilterBuilder().addDistinct('uuid', `${authState.config.uuidPrefix}-j7d0g-publicfavorites`).getFilters(),
  57     ),
  58     excludeHomeProject: true,
  59 });
  60
  61 const getOrder = (dataExplorer: DataExplorer) => {
  62     const sortColumn = getSortColumn<ProjectResource>(dataExplorer);
  63     const order = new OrderBuilder<ProjectResource>();
  64     if (sortColumn && sortColumn.sort) {
  65         const sortDirection = sortColumn.sort.direction === SortDirection.ASC
  66             ? OrderDirection.ASC
  67             : OrderDirection.DESC;
  68
  69         // Use createdAt as a secondary sort column so we break ties consistently.
  70         return order
  71             .addOrder(sortDirection, sortColumn.sort.field, GroupContentsResourcePrefix.COLLECTION)
  72             .addOrder(sortDirection, sortColumn.sort.field, GroupContentsResourcePrefix.PROCESS)
  73             .addOrder(sortDirection, sortColumn.sort.field, GroupContentsResourcePrefix.PROJECT)
  74             .addOrder(OrderDirection.DESC, "createdAt", GroupContentsResourcePrefix.PROCESS)
  75             .getOrder();
  76     } else {
  77         return order.getOrder();
  78     }
  79 };
  80
  81 export const setItems = (listResults: ListResults<GroupContentsResource>) =>
  82     sharedWithMePanelActions.SET_ITEMS({
  83         ...listResultsToDataExplorerItemsMeta(listResults),
  84         items: listResults.items.map(resource => resource.uuid),
  85     });
  86
  87 const couldNotFetchSharedItems = () =>
  88     snackbarActions.OPEN_SNACKBAR({
  89         message: 'Could not fetch shared items.',
  90         kind: SnackbarKind.ERROR
  91     });