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, getOrder } 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 { 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 { progressIndicatorActions } from 'store/progress-indicator/progress-indicator-actions';
15 import { collectionsContentAddressActions } from './collections-content-address-panel-actions';
16 import { navigateTo } from 'store/navigation/navigation-action';
17 import { updateFavorites } from 'store/favorites/favorites-actions';
18 import { updatePublicFavorites } from 'store/public-favorites/public-favorites-actions';
19 import { setBreadcrumbs } from '../breadcrumbs/breadcrumbs-actions';
20 import { ResourceKind, extractUuidKind } from 'models/resource';
21 import { ownerNameActions } from 'store/owner-name/owner-name-actions';
22 import { getUserDisplayName } from 'models/user';
23 import { CollectionResource } from 'models/collection';
24 import { replace } from "react-router-redux";
25 import { getNavUrl } from 'routes/routes';
27 export class CollectionsWithSameContentAddressMiddlewareService 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(collectionPanelDataExplorerIsNotSet());
38 api.dispatch(progressIndicatorActions.START_WORKING(this.getId()));
39 const userUuid = getUserUuid(api.getState());
40 const pathname = api.getState().router.location!.pathname;
41 const contentAddress = pathname.split('/')[2];
42 const response = await this.services.collectionService.list({
43 limit: dataExplorer.rowsPerPage,
44 offset: dataExplorer.page * dataExplorer.rowsPerPage,
45 filters: new FilterBuilder()
46 .addEqual('portable_data_hash', contentAddress)
47 .addILike("name", dataExplorer.searchValue)
49 includeOldVersions: true,
50 order: getOrder<CollectionResource>(dataExplorer)
52 const userUuids = response.items.map(it => {
53 if (extractUuidKind(it.ownerUuid) === ResourceKind.USER) {
60 const groupUuids = response.items.map(it => {
61 if (extractUuidKind(it.ownerUuid) === ResourceKind.GROUP) {
67 const responseUsers = await this.services.userService.list({
68 filters: new FilterBuilder()
69 .addIn('uuid', userUuids)
73 const responseGroups = await this.services.groupsService.list({
74 filters: new FilterBuilder()
75 .addIn('uuid', groupUuids)
79 responseUsers.items.forEach(it => {
80 api.dispatch<any>(ownerNameActions.SET_OWNER_NAME({
81 name: it.uuid === userUuid
83 : `User: ${getUserDisplayName(it)}`,
87 responseGroups.items.forEach(it => {
88 api.dispatch<any>(ownerNameActions.SET_OWNER_NAME({ name: `Project: ${it.name}`, uuid: it.uuid }));
90 api.dispatch<any>(setBreadcrumbs([{ label: 'Projects', uuid: userUuid }]));
91 api.dispatch<any>(updateFavorites(response.items.map(item => item.uuid)));
92 api.dispatch<any>(updatePublicFavorites(response.items.map(item => item.uuid)));
93 if (response.itemsAvailable === 1) {
94 api.dispatch<any>(replace(getNavUrl(response.items[0].uuid, api.getState().auth)));
95 api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId()));
97 api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId()));
98 api.dispatch(resourcesActions.SET_RESOURCES(response.items));
99 api.dispatch(collectionsContentAddressActions.SET_ITEMS({
100 items: response.items.map((resource: any) => resource.uuid),
101 itemsAvailable: response.itemsAvailable,
102 page: Math.floor(response.offset / response.limit),
103 rowsPerPage: response.limit
107 api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId()));
108 api.dispatch(collectionsContentAddressActions.SET_ITEMS({
112 rowsPerPage: dataExplorer.rowsPerPage
114 api.dispatch(couldNotFetchCollections());
120 const collectionPanelDataExplorerIsNotSet = () =>
121 snackbarActions.OPEN_SNACKBAR({
122 message: 'Collection panel is not ready.',
123 kind: SnackbarKind.ERROR
126 const couldNotFetchCollections = () =>
127 snackbarActions.OPEN_SNACKBAR({
128 message: 'Could not fetch collection with this content address.',
129 kind: SnackbarKind.ERROR