X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/e63198a93d7b537ffbb68b8210c99f76041fd112..33c03ae3c79936cc1a69129f07fba33fe2d28fd8:/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 be4b645c..c9a06fe6 100644 --- a/src/store/favorite-panel/favorite-panel-middleware-service.ts +++ b/src/store/favorite-panel/favorite-panel-middleware-service.ts @@ -2,69 +2,133 @@ // // 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 { LinkResource } from "../../models/link"; -import { checkPresenceInFavorites } from "../favorites/favorites-actions"; +import { getUserUuid } from "~/common/getuser"; +import { DataColumns } from "~/components/data-table/data-table"; +import { ServiceRepository } from "~/services/services"; +import { SortDirection } from "~/components/data-table/data-column"; +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"; +import { LinkClass } from "~/models/link"; 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 responseLinks = await this.services.linkService.list({ + filters: new FilterBuilder() + .addEqual("link_class", LinkClass.STAR) + .addEqual('tail_uuid', getUserUuid(api.getState())) + .addEqual('tail_kind', ResourceKind.USER) + .getFilters() + }).then(results => results); + const uuids = responseLinks.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 + });