X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/37e43f4e19ad2bd27b15fe7f0d857218dad39055..394ebdfd13fe40a7096f484c46a353d2537f4c9a:/src/store/collection-panel/collection-panel-action.ts diff --git a/src/store/collection-panel/collection-panel-action.ts b/src/store/collection-panel/collection-panel-action.ts index 0772210c..ee476524 100644 --- a/src/store/collection-panel/collection-panel-action.ts +++ b/src/store/collection-panel/collection-panel-action.ts @@ -2,84 +2,111 @@ // // SPDX-License-Identifier: AGPL-3.0 -import { unionize, ofType, UnionOf } from "unionize"; import { Dispatch } from "redux"; -import { ResourceKind } from "~/models/resource"; -import { CollectionResource } from "~/models/collection"; -import { collectionPanelFilesAction } from "./collection-panel-files/collection-panel-files-actions"; -import { createTree } from "~/models/tree"; -import { RootState } from "../store"; -import { ServiceRepository } from "~/services/services"; -import { TagResource, TagProperty } from "~/models/tag"; +import { + COLLECTION_PANEL_LOAD_FILES_THRESHOLD +} from "./collection-panel-files/collection-panel-files-actions"; +import { CollectionResource } from 'models/collection'; +import { RootState } from "store/store"; +import { ServiceRepository } from "services/services"; +import { TagProperty } from "models/tag"; import { snackbarActions } from "../snackbar/snackbar-actions"; +import { resourcesActions } from "store/resources/resources-actions"; +import { unionize, ofType, UnionOf } from 'common/unionize'; +import { SnackbarKind } from 'store/snackbar/snackbar-actions'; +import { navigateTo } from 'store/navigation/navigation-action'; +import { loadDetailsPanel } from 'store/details-panel/details-panel-action'; +import { addProperty, deleteProperty } from "lib/resource-properties"; +import { getResource } from "store/resources/resources"; export const collectionPanelActions = unionize({ - LOAD_COLLECTION: ofType<{ uuid: string, kind: ResourceKind }>(), + SET_COLLECTION: ofType(), LOAD_COLLECTION_SUCCESS: ofType<{ item: CollectionResource }>(), - LOAD_COLLECTION_TAGS: ofType<{ uuid: string }>(), - LOAD_COLLECTION_TAGS_SUCCESS: ofType<{ tags: TagResource[] }>(), - CREATE_COLLECTION_TAG: ofType<{ data: any }>(), - CREATE_COLLECTION_TAG_SUCCESS: ofType<{ tag: TagResource }>(), - DELETE_COLLECTION_TAG: ofType<{ uuid: string }>(), - DELETE_COLLECTION_TAG_SUCCESS: ofType<{ uuid: string }>() -}, { tag: 'type', value: 'payload' }); + LOAD_BIG_COLLECTIONS: ofType(), +}); export type CollectionPanelAction = UnionOf; export const COLLECTION_TAG_FORM_NAME = 'collectionTagForm'; -export const loadCollection = (uuid: string, kind: ResourceKind) => - (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { - dispatch(collectionPanelActions.LOAD_COLLECTION({ uuid, kind })); - dispatch(collectionPanelFilesAction.SET_COLLECTION_FILES({ files: createTree() })); - return services.collectionService - .get(uuid) - .then(item => { - dispatch(collectionPanelActions.LOAD_COLLECTION_SUCCESS({ item })); - return services.collectionFilesService.getFiles(item.uuid); - }) - .then(files => { - dispatch(collectionPanelFilesAction.SET_COLLECTION_FILES(files)); - }); +export const loadCollectionPanel = (uuid: string, forceReload = false) => + async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { + const { collectionPanel: { item } } = getState(); + const collection = (item && item.uuid === uuid && !forceReload) + ? item + : await services.collectionService.get(uuid); + dispatch(loadDetailsPanel(collection.uuid)); + dispatch(collectionPanelActions.LOAD_COLLECTION_SUCCESS({ item: collection })); + dispatch(resourcesActions.SET_RESOURCES([collection])); + if (collection.fileCount <= COLLECTION_PANEL_LOAD_FILES_THRESHOLD && + !getState().collectionPanel.loadBigCollections) { + } + return collection; }; -export const loadCollectionTags = (uuid: string) => +export const createCollectionTag = (data: TagProperty) => (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { - dispatch(collectionPanelActions.LOAD_COLLECTION_TAGS({ uuid })); - return services.tagService - .list(uuid) - .then(tags => { - dispatch(collectionPanelActions.LOAD_COLLECTION_TAGS_SUCCESS({ tags })); - }); + const item = getState().collectionPanel.item; + if (!item) { return; } + + const properties = Object.assign({}, item.properties); + const key = data.keyID || data.key; + const value = data.valueID || data.value; + const cachedCollection = getResource(item.uuid)(getState().resources); + services.collectionService.update( + item.uuid, { + properties: addProperty(properties, key, value) + } + ).then(updatedCollection => { + updatedCollection = {...cachedCollection, ...updatedCollection}; + dispatch(collectionPanelActions.SET_COLLECTION(updatedCollection)); + dispatch(resourcesActions.SET_RESOURCES([updatedCollection])); + dispatch(snackbarActions.OPEN_SNACKBAR({ + message: "Property has been successfully added.", + hideDuration: 2000, + kind: SnackbarKind.SUCCESS })); + dispatch(loadDetailsPanel(updatedCollection.uuid)); + return updatedCollection; + }).catch (e => + dispatch(snackbarActions.OPEN_SNACKBAR({ + message: e.errors[0], + hideDuration: 2000, + kind: SnackbarKind.ERROR })) + ); }; +export const navigateToProcess = (uuid: string) => + async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { + try { + await services.containerRequestService.get(uuid); + dispatch(navigateTo(uuid)); + } catch { + dispatch(snackbarActions.OPEN_SNACKBAR({ message: 'This process does not exist!', hideDuration: 2000, kind: SnackbarKind.ERROR })); + } + }; -export const createCollectionTag = (data: TagProperty) => +export const deleteCollectionTag = (key: string, value: string) => (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { - dispatch(collectionPanelActions.CREATE_COLLECTION_TAG({ data })); const item = getState().collectionPanel.item; - const uuid = item ? item.uuid : ''; - return services.tagService - .create(uuid, data) - .then(tag => { - dispatch(collectionPanelActions.CREATE_COLLECTION_TAG_SUCCESS({ tag })); - dispatch(snackbarActions.OPEN_SNACKBAR({ - message: "Tag has been successfully added.", - hideDuration: 2000 - })); - }); - }; + if (!item) { return; } -export const deleteCollectionTag = (uuid: string) => - (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { - dispatch(collectionPanelActions.DELETE_COLLECTION_TAG({ uuid })); - return services.linkService - .delete(uuid) - .then(tag => { - dispatch(collectionPanelActions.DELETE_COLLECTION_TAG_SUCCESS({ uuid: tag.uuid })); - dispatch(snackbarActions.OPEN_SNACKBAR({ - message: "Tag has been successfully deleted.", - hideDuration: 2000 - })); - }); + const properties = Object.assign({}, item.properties); + const cachedCollection = getResource(item.uuid)(getState().resources); + services.collectionService.update( + item.uuid, { + properties: deleteProperty(properties, key, value) + } + ).then(updatedCollection => { + updatedCollection = {...cachedCollection, ...updatedCollection}; + dispatch(collectionPanelActions.SET_COLLECTION(updatedCollection)); + dispatch(resourcesActions.SET_RESOURCES([updatedCollection])); + dispatch(snackbarActions.OPEN_SNACKBAR({ message: "Tag has been successfully deleted.", hideDuration: 2000, kind: SnackbarKind.SUCCESS })); + dispatch(loadDetailsPanel(updatedCollection.uuid)); + return updatedCollection; + }).catch (e => { + dispatch(snackbarActions.OPEN_SNACKBAR({ + message: e.errors[0], + hideDuration: 2000, + kind: SnackbarKind.ERROR })); + }); };