X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/7a8fafa13f5f94945cf0a4c5965db273f3435823..7be9038d988e4dd566536be646769f720b1ae04c:/src/store/process-panel/process-panel-actions.ts diff --git a/src/store/process-panel/process-panel-actions.ts b/src/store/process-panel/process-panel-actions.ts index 832d4d51..8bdbe4f2 100644 --- a/src/store/process-panel/process-panel-actions.ts +++ b/src/store/process-panel/process-panel-actions.ts @@ -6,23 +6,49 @@ import { unionize, ofType, UnionOf } from "~/common/unionize"; import { loadProcess } from '~/store/processes/processes-actions'; import { Dispatch } from 'redux'; import { ProcessStatus } from '~/store/processes/process'; +import { RootState } from '~/store/store'; +import { ServiceRepository } from "~/services/services"; +import { navigateTo, navigateToWorkflows } from '~/store/navigation/navigation-action'; +import { snackbarActions } from '~/store/snackbar/snackbar-actions'; +import { SnackbarKind } from '../snackbar/snackbar-actions'; +import { showWorkflowDetails } from '~/store/workflow-panel/workflow-panel-actions'; +import { loadSubprocessPanel } from "../subprocess-panel/subprocess-panel-actions"; -export const procesPanelActions = unionize({ +export const processPanelActions = unionize({ + SET_PROCESS_PANEL_CONTAINER_REQUEST_UUID: ofType(), SET_PROCESS_PANEL_FILTERS: ofType(), TOGGLE_PROCESS_PANEL_FILTER: ofType(), }); -export type ProcessPanelAction = UnionOf; +export type ProcessPanelAction = UnionOf; -export const toggleProcessPanelFilter = procesPanelActions.TOGGLE_PROCESS_PANEL_FILTER; +export const toggleProcessPanelFilter = processPanelActions.TOGGLE_PROCESS_PANEL_FILTER; export const loadProcessPanel = (uuid: string) => (dispatch: Dispatch) => { + dispatch(processPanelActions.SET_PROCESS_PANEL_CONTAINER_REQUEST_UUID(uuid)); dispatch(loadProcess(uuid)); dispatch(initProcessPanelFilters); + dispatch(loadSubprocessPanel()); }; -export const initProcessPanelFilters = procesPanelActions.SET_PROCESS_PANEL_FILTERS([ +export const navigateToOutput = (uuid: string) => + async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { + try { + await services.collectionService.get(uuid); + dispatch(navigateTo(uuid)); + } catch { + dispatch(snackbarActions.OPEN_SNACKBAR({ message: 'This collection does not exists!', hideDuration: 2000, kind: SnackbarKind.ERROR })); + } + }; + +export const openWorkflow = (uuid: string) => + (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { + dispatch(navigateToWorkflows); + dispatch(showWorkflowDetails(uuid)); + }; + +export const initProcessPanelFilters = processPanelActions.SET_PROCESS_PANEL_FILTERS([ ProcessStatus.QUEUED, ProcessStatus.COMPLETED, ProcessStatus.FAILED,