X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/571f9757f7bce4b151921368b4a4d4e97d22d055..7131c732cffb1383099b5e1593b3ee4b48635df5:/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 5fe09fbc..35c3c3d3 100644 --- a/src/store/collection-panel/collection-panel-action.ts +++ b/src/store/collection-panel/collection-panel-action.ts @@ -2,85 +2,100 @@ // // 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 { loadCollectionFiles, COLLECTION_PANEL_LOAD_FILES_THRESHOLD } from "./collection-panel-files/collection-panel-files-actions"; +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 { createTree } from "~/models/tree"; +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"; export const collectionPanelActions = unionize({ - LOAD_COLLECTION: ofType<{ uuid: string, kind: ResourceKind }>(), + SET_COLLECTION: ofType(), + LOAD_COLLECTION: ofType<{ uuid: string }>(), 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 })); +export const loadCollectionPanel = (uuid: string) => + async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { + dispatch(collectionPanelActions.LOAD_COLLECTION({ uuid })); dispatch(collectionPanelFilesAction.SET_COLLECTION_FILES({ files: createTree() })); - return services.collectionService - .get(uuid) - .then(item => { - dispatch(collectionPanelActions.LOAD_COLLECTION_SUCCESS({ item })); - services.collectionService.files(item.uuid).then(console.log); - return services.collectionFilesService.getFiles(item.uuid); - }) - .then(files => { - dispatch(collectionPanelFilesAction.SET_COLLECTION_FILES(files)); - }); + const collection = 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) { + dispatch(loadCollectionFiles(collection.uuid)); + } + return collection; }; -export const loadCollectionTags = (uuid: string) => - (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 })); - }); +export const createCollectionTag = (data: TagProperty) => + async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { + const item = getState().collectionPanel.item; + if (!item) { return; } + + const properties = Object.assign({}, item.properties); + try { + const key = data.keyID || data.key; + const value = data.valueID || data.value; + const updatedCollection = await services.collectionService.update( + item.uuid, { + properties: addProperty(properties, key, value) + } + ); + dispatch(collectionPanelActions.SET_COLLECTION(updatedCollection)); + dispatch(resourcesActions.SET_RESOURCES([updatedCollection])); + dispatch(snackbarActions.OPEN_SNACKBAR({ message: "Tag has been successfully added.", hideDuration: 2000, kind: SnackbarKind.SUCCESS })); + return updatedCollection; + } catch (e) { + dispatch(snackbarActions.OPEN_SNACKBAR({ message: e.errors[0], hideDuration: 2000, kind: SnackbarKind.ERROR })); + return; + } }; +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) => - (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { - dispatch(collectionPanelActions.CREATE_COLLECTION_TAG({ data })); +export const deleteCollectionTag = (key: string, value: string) => + async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { 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 - })); - }); - }; \ No newline at end of file + const properties = Object.assign({}, item.properties); + try { + const updatedCollection = await services.collectionService.update( + item.uuid, { + properties: deleteProperty(properties, key, value) + } + ); + 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 })); + return updatedCollection; + } catch (e) { + dispatch(snackbarActions.OPEN_SNACKBAR({ message: e.errors[0], hideDuration: 2000, kind: SnackbarKind.ERROR })); + return; + } + };