X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/5cc899fc13465c57f16adf69a593a4354e6e0eb3..d9ee24d0f78a21603e2276d0d3142d4db40a831b:/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 902a5c9c4e..8bdbe4f297 100644 --- a/src/store/process-panel/process-panel-actions.ts +++ b/src/store/process-panel/process-panel-actions.ts @@ -5,25 +5,54 @@ 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({ - INIT_PROCESS_PANEL_FILTERS: ofType(), +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.INIT_PROCESS_PANEL_FILTERS([ - 'Queued', - 'Complete', - 'Active', - 'Failed' +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, + ProcessStatus.RUNNING, + ProcessStatus.LOCKED, + ProcessStatus.CANCELLED ]);