X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/f5c0cb11102a006cda59711f29458b7569b9a21f..134cf300692c9f09f1a79d02295e1d6b7242f32d:/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 f808b97e..f88f7b91 100644 --- a/src/store/favorite-panel/favorite-panel-middleware-service.ts +++ b/src/store/favorite-panel/favorite-panel-middleware-service.ts @@ -2,37 +2,45 @@ // // SPDX-License-Identifier: AGPL-3.0 -import { DataExplorerMiddlewareService } from "../data-explorer/data-explorer-middleware-service"; -import { FavoritePanelColumnNames, FavoritePanelFilter } 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 { ServiceRepository } from "~/services/services"; -import { SortDirection } from "~/components/data-table/data-column"; -import { FilterBuilder } from "~/services/api/filter-builder"; +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 } from '~/store/snackbar/snackbar-actions'; -import { getDataExplorer } from "~/store/data-explorer/data-explorer-reducer"; +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'; +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) { + async requestItems(api: MiddlewareAPI) { const dataExplorer = getDataExplorer(api.getState().dataExplorer, this.getId()); if (!dataExplorer) { api.dispatch(favoritesPanelDataExplorerIsNotSet()); - } else { + } else { + const columns = dataExplorer.columns as DataColumns; + const sortColumn = getSortColumn(dataExplorer); + const typeFilters = serializeSimpleObjectTypeFilters(getDataExplorerColumnFilters(columns, FavoritePanelColumnNames.TYPE)); - const columns = dataExplorer.columns as DataColumns; - const sortColumn = dataExplorer.columns.find(c => c.sortDirection !== SortDirection.NONE); - const typeFilters = this.getColumnFilters(columns, FavoritePanelColumnNames.TYPE); const linkOrder = new OrderBuilder(); const contentOrder = new OrderBuilder(); @@ -48,41 +56,79 @@ export class FavoritePanelMiddlewareService extends DataExplorerMiddlewareServic .addOrder(direction, "name", GroupContentsResourcePrefix.PROCESS) .addOrder(direction, "name", GroupContentsResourcePrefix.PROJECT); } - - this.services.favoriteService - .list(this.services.authService.getUuid()!, { - limit: dataExplorer.rowsPerPage, - offset: dataExplorer.page * dataExplorer.rowsPerPage, - linkOrder: linkOrder.getOrder(), - contentOrder: contentOrder.getOrder(), + 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) + .addIsA("uuid", typeFilters) + .getFilters() + }); + 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() - .addIsA("headUuid", typeFilters.map(filter => filter.type)) + .addIn("uuid", uuids) .addILike("name", dataExplorer.searchValue) + .addIsA("uuid", typeFilters) .getFilters() - }) - .then(response => { - api.dispatch(resourcesActions.SET_RESOURCES(response.items)); - api.dispatch(favoritePanelActions.SET_ITEMS({ - items: response.items.map(resource => resource.uuid), - itemsAvailable: response.itemsAvailable, - page: Math.floor(response.offset / response.limit), - rowsPerPage: response.limit - })); - api.dispatch(updateFavorites(response.items.map(item => item.uuid))); - }) - .catch(() => { - api.dispatch(favoritePanelActions.SET_ITEMS({ - items: [], - itemsAvailable: 0, - page: 0, - rowsPerPage: dataExplorer.rowsPerPage - })); }); + const response = groupItems; + collectionItems.items.forEach((it: any) => { + response.itemsAvailable++; + response.items.push(it); + }); + processItems.items.forEach((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 favoritesPanelDataExplorerIsNotSet = () => snackbarActions.OPEN_SNACKBAR({ - message: 'Favorites panel is not ready.' + message: 'Favorites panel is not ready.', + kind: SnackbarKind.ERROR + }); + +const couldNotFetchFavoritesContents = () => + snackbarActions.OPEN_SNACKBAR({ + message: 'Could not fetch favorites contents.', + kind: SnackbarKind.ERROR });