1 // Copyright (C) The Arvados Authors. All rights reserved.
3 // SPDX-License-Identifier: AGPL-3.0
5 import { ServiceRepository } from 'services/services';
6 import { MiddlewareAPI, Dispatch } from 'redux';
7 import { DataExplorerMiddlewareService } from 'store/data-explorer/data-explorer-middleware-service';
8 import { RootState } from 'store/store';
9 import { getUserUuid } from "common/getuser";
10 import { snackbarActions, SnackbarKind } from 'store/snackbar/snackbar-actions';
11 import { DataExplorer, getDataExplorer } from 'store/data-explorer/data-explorer-reducer';
12 import { resourcesActions } from 'store/resources/resources-actions';
13 import { FilterBuilder } from 'services/api/filter-builder';
14 import { SortDirection } from 'components/data-table/data-column';
15 import { OrderDirection, OrderBuilder } from 'services/api/order-builder';
16 import { getSortColumn } from "store/data-explorer/data-explorer-reducer";
17 import { progressIndicatorActions } from 'store/progress-indicator/progress-indicator-actions';
18 import { collectionsContentAddressActions } from './collections-content-address-panel-actions';
19 import { navigateTo } from 'store/navigation/navigation-action';
20 import { updateFavorites } from 'store/favorites/favorites-actions';
21 import { updatePublicFavorites } from 'store/public-favorites/public-favorites-actions';
22 import { setBreadcrumbs } from '../breadcrumbs/breadcrumbs-actions';
23 import { ResourceKind, extractUuidKind } from 'models/resource';
24 import { ownerNameActions } from 'store/owner-name/owner-name-actions';
25 import { getUserDisplayName } from 'models/user';
26 import { CollectionResource } from 'models/collection';
28 export class CollectionsWithSameContentAddressMiddlewareService extends DataExplorerMiddlewareService {
29 constructor(private services: ServiceRepository, id: string) {
33 async requestItems(api: MiddlewareAPI<Dispatch, RootState>) {
34 const dataExplorer = getDataExplorer(api.getState().dataExplorer, this.getId());
36 api.dispatch(collectionPanelDataExplorerIsNotSet());
39 api.dispatch(progressIndicatorActions.START_WORKING(this.getId()));
40 const userUuid = getUserUuid(api.getState());
41 const pathname = api.getState().router.location!.pathname;
42 const contentAddress = pathname.split('/')[2];
43 const response = await this.services.collectionService.list({
44 limit: dataExplorer.rowsPerPage,
45 offset: dataExplorer.page * dataExplorer.rowsPerPage,
46 filters: new FilterBuilder()
47 .addEqual('portable_data_hash', contentAddress)
48 .addILike("name", dataExplorer.searchValue)
50 includeOldVersions: true,
51 order: getOrder(dataExplorer)
53 const userUuids = response.items.map(it => {
54 if (extractUuidKind(it.ownerUuid) === ResourceKind.USER) {
61 const groupUuids = response.items.map(it => {
62 if (extractUuidKind(it.ownerUuid) === ResourceKind.GROUP) {
68 const responseUsers = await this.services.userService.list({
69 filters: new FilterBuilder()
70 .addIn('uuid', userUuids)
74 const responseGroups = await this.services.groupsService.list({
75 filters: new FilterBuilder()
76 .addIn('uuid', groupUuids)
80 responseUsers.items.forEach(it => {
81 api.dispatch<any>(ownerNameActions.SET_OWNER_NAME({
82 name: it.uuid === userUuid
84 : `User: ${getUserDisplayName(it)}`,
88 responseGroups.items.forEach(it => {
89 api.dispatch<any>(ownerNameActions.SET_OWNER_NAME({ name: `Project: ${it.name}`, uuid: it.uuid }));
91 api.dispatch<any>(setBreadcrumbs([{ label: 'Projects', uuid: userUuid }]));
92 api.dispatch<any>(updateFavorites(response.items.map(item => item.uuid)));
93 api.dispatch<any>(updatePublicFavorites(response.items.map(item => item.uuid)));
94 if (response.itemsAvailable === 1) {
95 api.dispatch<any>(navigateTo(response.items[0].uuid));
96 api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId()));
98 api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId()));
99 api.dispatch(resourcesActions.SET_RESOURCES(response.items));
100 api.dispatch(collectionsContentAddressActions.SET_ITEMS({
101 items: response.items.map((resource: any) => resource.uuid),
102 itemsAvailable: response.itemsAvailable,
103 page: Math.floor(response.offset / response.limit),
104 rowsPerPage: response.limit
108 api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId()));
109 api.dispatch(collectionsContentAddressActions.SET_ITEMS({
113 rowsPerPage: dataExplorer.rowsPerPage
115 api.dispatch(couldNotFetchCollections());
121 const getOrder = (dataExplorer: DataExplorer) => {
122 const sortColumn = getSortColumn<CollectionResource>(dataExplorer);
123 const order = new OrderBuilder<CollectionResource>();
124 if (sortColumn && sortColumn.sort) {
125 const sortDirection = sortColumn.sort.direction === SortDirection.ASC
127 : OrderDirection.DESC;
130 .addOrder(sortDirection, sortColumn.sort.field)
133 return order.getOrder();
137 const collectionPanelDataExplorerIsNotSet = () =>
138 snackbarActions.OPEN_SNACKBAR({
139 message: 'Collection panel is not ready.',
140 kind: SnackbarKind.ERROR
143 const couldNotFetchCollections = () =>
144 snackbarActions.OPEN_SNACKBAR({
145 message: 'Could not fetch collection with this content address.',
146 kind: SnackbarKind.ERROR