X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/876e5e2f31a218255845977489ea70aacc0211cd..0a6c8db48aedafaa558934b3ea85847a0f178405:/src/store/favorite-panel/favorite-panel-middleware-service.ts diff --git a/src/store/favorite-panel/favorite-panel-middleware-service.ts b/src/store/favorite-panel/favorite-panel-middleware-service.ts index 653184104c..e518482b50 100644 --- a/src/store/favorite-panel/favorite-panel-middleware-service.ts +++ b/src/store/favorite-panel/favorite-panel-middleware-service.ts @@ -2,68 +2,131 @@ // // SPDX-License-Identifier: AGPL-3.0 -import { DataExplorerMiddlewareService } from "../data-explorer/data-explorer-middleware-service"; -import { FavoritePanelFilter, FavoritePanelColumnNames } from "~/views/favorite-panel/favorite-panel"; +import { DataExplorerMiddlewareService } from "~/store/data-explorer/data-explorer-middleware-service"; +import { FavoritePanelColumnNames } from "~/views/favorite-panel/favorite-panel"; import { RootState } from "../store"; import { DataColumns } from "~/components/data-table/data-table"; -import { FavoritePanelItem, resourceToDataItem } from "~/views/favorite-panel/favorite-panel-item"; -import { FavoriteOrderBuilder } from "~/services/favorite-service/favorite-order-builder"; import { ServiceRepository } from "~/services/services"; import { SortDirection } from "~/components/data-table/data-column"; -import { FilterBuilder } from "~/common/api/filter-builder"; -import { checkPresenceInFavorites } from "../favorites/favorites-actions"; +import { FilterBuilder } from "~/services/api/filter-builder"; +import { updateFavorites } from "../favorites/favorites-actions"; import { favoritePanelActions } from "./favorite-panel-action"; import { Dispatch, MiddlewareAPI } from "redux"; +import { OrderBuilder, OrderDirection } from "~/services/api/order-builder"; +import { LinkResource } from "~/models/link"; +import { GroupContentsResource, GroupContentsResourcePrefix } from "~/services/groups-service/groups-service"; +import { resourcesActions } from "~/store/resources/resources-actions"; +import { snackbarActions, SnackbarKind } from '~/store/snackbar/snackbar-actions'; +import { progressIndicatorActions } from '~/store/progress-indicator/progress-indicator-actions.ts'; +import { getDataExplorer } from "~/store/data-explorer/data-explorer-reducer"; +import { loadMissingProcessesInformation } from "~/store/project-panel/project-panel-middleware-service"; +import { getSortColumn } from "~/store/data-explorer/data-explorer-reducer"; +import { getDataExplorerColumnFilters } from '~/store/data-explorer/data-explorer-middleware-service'; +import { serializeSimpleObjectTypeFilters } from '../resource-type-filters/resource-type-filters'; +import { ResourceKind } from "~/models/resource"; export class FavoritePanelMiddlewareService extends DataExplorerMiddlewareService { constructor(private services: ServiceRepository, id: string) { super(id); } - requestItems(api: MiddlewareAPI) { - const dataExplorer = api.getState().dataExplorer[this.getId()]; - const columns = dataExplorer.columns as DataColumns; - const sortColumn = dataExplorer.columns.find( - ({ sortDirection }) => sortDirection !== undefined && sortDirection !== "none" - ); - const typeFilters = getColumnFilters(columns, FavoritePanelColumnNames.TYPE); - const order = FavoriteOrderBuilder.create(); - if (typeFilters.length > 0) { - this.services.favoriteService - .list(this.services.authService.getUuid()!, { - limit: dataExplorer.rowsPerPage, - offset: dataExplorer.page * dataExplorer.rowsPerPage, - order: sortColumn!.name === FavoritePanelColumnNames.NAME - ? sortColumn!.sortDirection === SortDirection.ASC - ? order.addDesc("name") - : order.addAsc("name") - : order, - filters: FilterBuilder - .create() - .addIsA("headUuid", typeFilters.map(filter => filter.type)) + async requestItems(api: MiddlewareAPI) { + const dataExplorer = getDataExplorer(api.getState().dataExplorer, this.getId()); + if (!dataExplorer) { + api.dispatch(favoritesPanelDataExplorerIsNotSet()); + } else { + const columns = dataExplorer.columns as DataColumns; + const sortColumn = getSortColumn(dataExplorer); + const typeFilters = serializeSimpleObjectTypeFilters(getDataExplorerColumnFilters(columns, FavoritePanelColumnNames.TYPE)); + + + const linkOrder = new OrderBuilder(); + const contentOrder = new OrderBuilder(); + + if (sortColumn && sortColumn.name === FavoritePanelColumnNames.NAME) { + const direction = sortColumn.sortDirection === SortDirection.ASC + ? OrderDirection.ASC + : OrderDirection.DESC; + + linkOrder.addOrder(direction, "name"); + contentOrder + .addOrder(direction, "name", GroupContentsResourcePrefix.COLLECTION) + .addOrder(direction, "name", GroupContentsResourcePrefix.PROCESS) + .addOrder(direction, "name", GroupContentsResourcePrefix.PROJECT); + } + try { + api.dispatch(progressIndicatorActions.START_WORKING(this.getId())); + const resp1 = await this.services.linkService.list({ + filters: new FilterBuilder() + .addEqual("linkClass", 'star') + .addEqual('tailUuid', this.services.authService.getUuid()!) + .addEqual('tailKind', ResourceKind.USER) + .getFilters() + }).then(results => results); + const uuids = resp1.items.map(it => it.headUuid); + const groupItems: any = await this.services.groupsService.list({ + filters: new FilterBuilder() + .addIn("uuid", uuids) .addILike("name", dataExplorer.searchValue) - }) - .then(response => { - api.dispatch(favoritePanelActions.SET_ITEMS({ - items: response.items.map(resourceToDataItem), - itemsAvailable: response.itemsAvailable, - page: Math.floor(response.offset / response.limit), - rowsPerPage: response.limit - })); - api.dispatch(checkPresenceInFavorites(response.items.map(item => item.uuid))); + .addIsA("uuid", typeFilters) + .getFilters() }); - } else { - api.dispatch(favoritePanelActions.SET_ITEMS({ - items: [], - itemsAvailable: 0, - page: 0, - rowsPerPage: dataExplorer.rowsPerPage - })); + const collectionItems: any = await this.services.collectionService.list({ + filters: new FilterBuilder() + .addIn("uuid", uuids) + .addILike("name", dataExplorer.searchValue) + .addIsA("uuid", typeFilters) + .getFilters() + }); + const processItems: any = await this.services.containerRequestService.list({ + filters: new FilterBuilder() + .addIn("uuid", uuids) + .addILike("name", dataExplorer.searchValue) + .addIsA("uuid", typeFilters) + .getFilters() + }); + const response = groupItems; + collectionItems.items.map((it: any) => { + response.itemsAvailable++; + response.items.push(it); + }); + processItems.items.map((it: any) => { + response.itemsAvailable++; + response.items.push(it); + }); + + api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId())); + api.dispatch(resourcesActions.SET_RESOURCES(response.items)); + await api.dispatch(loadMissingProcessesInformation(response.items)); + api.dispatch(favoritePanelActions.SET_ITEMS({ + items: response.items.map((resource: any) => resource.uuid), + itemsAvailable: response.itemsAvailable, + page: Math.floor(response.offset / response.limit), + rowsPerPage: response.limit + })); + api.dispatch(updateFavorites(response.items.map((item: any) => item.uuid))); + } catch (e) { + api.dispatch(progressIndicatorActions.PERSIST_STOP_WORKING(this.getId())); + api.dispatch(favoritePanelActions.SET_ITEMS({ + items: [], + itemsAvailable: 0, + page: 0, + rowsPerPage: dataExplorer.rowsPerPage + })); + api.dispatch(couldNotFetchFavoritesContents()); + } } } } -const getColumnFilters = (columns: DataColumns, columnName: string) => { - const column = columns.find(c => c.name === columnName); - return column && column.filters ? column.filters.filter(f => f.selected) : []; -}; +const favoritesPanelDataExplorerIsNotSet = () => + snackbarActions.OPEN_SNACKBAR({ + message: 'Favorites panel is not ready.', + kind: SnackbarKind.ERROR + }); + +const couldNotFetchFavoritesContents = () => + snackbarActions.OPEN_SNACKBAR({ + message: 'Could not fetch favorites contents.', + kind: SnackbarKind.ERROR + });