X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/3a9d4c4ccf13b791f12f3c7b99163d22d949c4ae..d7a29f892371764b1bff2e6ec64f8011c001b725:/src/store/tree-picker/tree-picker-actions.ts?ds=sidebyside diff --git a/src/store/tree-picker/tree-picker-actions.ts b/src/store/tree-picker/tree-picker-actions.ts index 3c3b052a..657d65b7 100644 --- a/src/store/tree-picker/tree-picker-actions.ts +++ b/src/store/tree-picker/tree-picker-actions.ts @@ -3,34 +3,80 @@ // SPDX-License-Identifier: AGPL-3.0 import { unionize, ofType, UnionOf } from "~/common/unionize"; -import { TreeNode, initTreeNode, getNodeDescendants, getNodeDescendantsIds, getNodeValue, TreeNodeStatus } from '~/models/tree'; +import { TreeNode, initTreeNode, getNodeDescendants, TreeNodeStatus, getNode, TreePickerId, Tree } from '~/models/tree'; import { Dispatch } from 'redux'; import { RootState } from '~/store/store'; import { ServiceRepository } from '~/services/services'; import { FilterBuilder } from '~/services/api/filter-builder'; -import { pipe } from 'lodash/fp'; +import { pipe, values } from 'lodash/fp'; import { ResourceKind } from '~/models/resource'; -import { GroupContentsResource } from '../../services/groups-service/groups-service'; -import { CollectionDirectory, CollectionFile } from '../../models/collection-file'; +import { GroupContentsResource } from '~/services/groups-service/groups-service'; +import { getTreePicker, TreePicker } from './tree-picker'; +import { ProjectsTreePickerItem } from '~/views-components/projects-tree-picker/generic-projects-tree-picker'; +import { OrderBuilder } from '~/services/api/order-builder'; +import { ProjectResource } from '~/models/project'; +import { mapTree } from '../../models/tree'; export const treePickerActions = unionize({ LOAD_TREE_PICKER_NODE: ofType<{ id: string, pickerId: string }>(), LOAD_TREE_PICKER_NODE_SUCCESS: ofType<{ id: string, nodes: Array>, pickerId: string }>(), + APPEND_TREE_PICKER_NODE_SUBTREE: ofType<{ id: string, subtree: Tree, pickerId: string }>(), TOGGLE_TREE_PICKER_NODE_COLLAPSE: ofType<{ id: string, pickerId: string }>(), - ACTIVATE_TREE_PICKER_NODE: ofType<{ id: string, pickerId: string }>(), + ACTIVATE_TREE_PICKER_NODE: ofType<{ id: string, pickerId: string, relatedTreePickers?: string[] }>(), + DEACTIVATE_TREE_PICKER_NODE: ofType<{ pickerId: string }>(), TOGGLE_TREE_PICKER_NODE_SELECTION: ofType<{ id: string, pickerId: string }>(), + SELECT_TREE_PICKER_NODE: ofType<{ id: string | string[], pickerId: string }>(), + DESELECT_TREE_PICKER_NODE: ofType<{ id: string | string[], pickerId: string }>(), EXPAND_TREE_PICKER_NODES: ofType<{ ids: string[], pickerId: string }>(), RESET_TREE_PICKER: ofType<{ pickerId: string }>() }); export type TreePickerAction = UnionOf; +export const getProjectsTreePickerIds = (pickerId: string) => ({ + home: `${pickerId}_home`, + shared: `${pickerId}_shared`, + favorites: `${pickerId}_favorites`, +}); + +export const getAllNodes = (pickerId: string, filter = (node: TreeNode) => true) => (state: TreePicker) => + pipe( + () => values(getProjectsTreePickerIds(pickerId)), + + ids => ids + .map(id => getTreePicker(id)(state)), + + trees => trees + .map(getNodeDescendants('')) + .reduce((allNodes, nodes) => allNodes.concat(nodes), []), + + allNodes => allNodes + .reduce((map, node) => + filter(node) + ? map.set(node.id, node) + : map, new Map>()) + .values(), + + uniqueNodes => Array.from(uniqueNodes), + )(); +export const getSelectedNodes = (pickerId: string) => (state: TreePicker) => + getAllNodes(pickerId, node => node.selected)(state); + +export const initProjectsTreePicker = (pickerId: string) => + async (dispatch: Dispatch, _: () => RootState, services: ServiceRepository) => { + const { home, shared, favorites } = getProjectsTreePickerIds(pickerId); + dispatch(initUserProject(home)); + dispatch(initSharedProject(shared)); + dispatch(initFavoritesProject(favorites)); + }; + interface ReceiveTreePickerDataParams { data: T[]; extractNodeData: (value: T) => { id: string, value: T, status?: TreeNodeStatus }; id: string; pickerId: string; } + export const receiveTreePickerData = (params: ReceiveTreePickerDataParams) => (dispatch: Dispatch) => { const { data, extractNodeData, id, pickerId, } = params; @@ -41,20 +87,28 @@ export const receiveTreePickerData = (params: ReceiveTreePickerDataParams) })); dispatch(treePickerActions.TOGGLE_TREE_PICKER_NODE_COLLAPSE({ id, pickerId })); }; -export const loadProject = (id: string, pickerId: string, includeCollections = false, includeFiles = false) => + +interface LoadProjectParams { + id: string; + pickerId: string; + includeCollections?: boolean; + includeFiles?: boolean; + loadShared?: boolean; +} +export const loadProject = (params: LoadProjectParams) => async (dispatch: Dispatch, _: () => RootState, services: ServiceRepository) => { + const { id, pickerId, includeCollections = false, includeFiles = false, loadShared = false } = params; dispatch(treePickerActions.LOAD_TREE_PICKER_NODE({ id, pickerId })); const filters = pipe( - (fb: FilterBuilder) => fb.addEqual('ownerUuid', id), - fb => includeCollections + (fb: FilterBuilder) => includeCollections ? fb.addIsA('uuid', [ResourceKind.PROJECT, ResourceKind.COLLECTION]) : fb.addIsA('uuid', [ResourceKind.PROJECT]), fb => fb.getFilters(), )(new FilterBuilder()); - const { items } = await services.groupsService.contents(id, { filters }); + const { items } = await services.groupsService.contents(loadShared ? '' : id, { filters, excludeHomeProject: loadShared || undefined }); dispatch(receiveTreePickerData({ id, @@ -73,22 +127,27 @@ export const loadProject = (id: string, pickerId: string, includeCollections = f }; export const loadCollection = (id: string, pickerId: string) => - async (dispatch: Dispatch, _: () => RootState, services: ServiceRepository) => { + async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { dispatch(treePickerActions.LOAD_TREE_PICKER_NODE({ id, pickerId })); - const files = await services.collectionService.files(id); - const data = getNodeDescendants('')(files).map(node => node.value); + const picker = getTreePicker(pickerId)(getState().treePicker); + if (picker) { - dispatch(receiveTreePickerData({ - id, - pickerId, - data, - extractNodeData: value => ({ - id: value.id, - status: TreeNodeStatus.LOADED, - value, - }), - })); + const node = getNode(id)(picker); + if (node && 'kind' in node.value && node.value.kind === ResourceKind.COLLECTION) { + + const filesTree = await services.collectionService.files(node.value.portableDataHash); + + dispatch( + treePickerActions.APPEND_TREE_PICKER_NODE_SUBTREE({ + id, + pickerId, + subtree: mapTree(node => ({ ...node, status: TreeNodeStatus.LOADED }))(filesTree) + })); + + dispatch(treePickerActions.TOGGLE_TREE_PICKER_NODE_COLLAPSE({ id, pickerId })); + } + } }; @@ -112,17 +171,32 @@ export const loadUserProject = (pickerId: string, includeCollections = false, in async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { const uuid = services.authService.getUuid(); if (uuid) { - dispatch(loadProject(uuid, pickerId, includeCollections, includeFiles)); + dispatch(loadProject({ id: uuid, pickerId, includeCollections, includeFiles })); } }; - +export const SHARED_PROJECT_ID = 'Shared with me'; export const initSharedProject = (pickerId: string) => async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { dispatch(receiveTreePickerData({ id: '', pickerId, - data: [{ uuid: 'Shared with me', name: 'Shared with me' }], + data: [{ uuid: SHARED_PROJECT_ID, name: SHARED_PROJECT_ID }], + extractNodeData: value => ({ + id: value.uuid, + status: TreeNodeStatus.INITIAL, + value, + }), + })); + }; + +export const FAVORITES_PROJECT_ID = 'Favorites'; +export const initFavoritesProject = (pickerId: string) => + async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { + dispatch(receiveTreePickerData({ + id: '', + pickerId, + data: [{ uuid: FAVORITES_PROJECT_ID, name: FAVORITES_PROJECT_ID }], extractNodeData: value => ({ id: value.uuid, status: TreeNodeStatus.INITIAL, @@ -130,3 +204,89 @@ export const initSharedProject = (pickerId: string) => }), })); }; + +interface LoadFavoritesProjectParams { + pickerId: string; + includeCollections?: boolean; + includeFiles?: boolean; +} + +export const loadFavoritesProject = (params: LoadFavoritesProjectParams) => + async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { + const { pickerId, includeCollections = false, includeFiles = false } = params; + const uuid = services.authService.getUuid(); + if (uuid) { + + const filters = pipe( + (fb: FilterBuilder) => includeCollections + ? fb.addIsA('headUuid', [ResourceKind.PROJECT, ResourceKind.COLLECTION]) + : fb.addIsA('headUuid', [ResourceKind.PROJECT]), + fb => fb.getFilters(), + )(new FilterBuilder()); + + const { items } = await services.favoriteService.list(uuid, { filters }); + + dispatch(receiveTreePickerData({ + id: 'Favorites', + pickerId, + data: items, + extractNodeData: item => ({ + id: item.uuid, + value: item, + status: item.kind === ResourceKind.PROJECT + ? TreeNodeStatus.INITIAL + : includeFiles + ? TreeNodeStatus.INITIAL + : TreeNodeStatus.LOADED + }), + })); + } + }; + +export const receiveTreePickerProjectsData = (id: string, projects: ProjectResource[], pickerId: string) => + (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { + dispatch(treePickerActions.LOAD_TREE_PICKER_NODE_SUCCESS({ + id, + nodes: projects.map(project => initTreeNode({ id: project.uuid, value: project })), + pickerId, + })); + + dispatch(treePickerActions.TOGGLE_TREE_PICKER_NODE_COLLAPSE({ id, pickerId })); + }; + +export const loadProjectTreePickerProjects = (id: string) => + async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { + dispatch(treePickerActions.LOAD_TREE_PICKER_NODE({ id, pickerId: TreePickerId.PROJECTS })); + + const ownerUuid = id.length === 0 ? services.authService.getUuid() || '' : id; + const { items } = await services.projectService.list(buildParams(ownerUuid)); + + dispatch(receiveTreePickerProjectsData(id, items, TreePickerId.PROJECTS)); + }; + +export const loadFavoriteTreePickerProjects = (id: string) => + async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { + const parentId = services.authService.getUuid() || ''; + + if (id === '') { + dispatch(treePickerActions.LOAD_TREE_PICKER_NODE({ id: parentId, pickerId: TreePickerId.FAVORITES })); + const { items } = await services.favoriteService.list(parentId); + dispatch(receiveTreePickerProjectsData(parentId, items as ProjectResource[], TreePickerId.FAVORITES)); + } else { + dispatch(treePickerActions.LOAD_TREE_PICKER_NODE({ id, pickerId: TreePickerId.FAVORITES })); + const { items } = await services.projectService.list(buildParams(id)); + dispatch(receiveTreePickerProjectsData(id, items, TreePickerId.FAVORITES)); + } + + }; + +const buildParams = (ownerUuid: string) => { + return { + filters: new FilterBuilder() + .addEqual('ownerUuid', ownerUuid) + .getFilters(), + order: new OrderBuilder() + .addAsc('name') + .getOrder() + }; +}; \ No newline at end of file