X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/ced486022308d18befcb1c83676c7d34ecc85f9d..HEAD:/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 d8042ba5..2111afdb 100644 --- a/src/store/process-panel/process-panel-actions.ts +++ b/src/store/process-panel/process-panel-actions.ts @@ -3,24 +3,24 @@ // SPDX-License-Identifier: AGPL-3.0 import { unionize, ofType, UnionOf } from "common/unionize"; -import { getInputs, getOutputParameters, getRawInputs, getRawOutputs, loadProcess } from 'store/processes/processes-actions'; -import { Dispatch } from 'redux'; -import { ProcessStatus } from 'store/processes/process'; -import { RootState } from 'store/store'; +import { getInputs, getOutputParameters, getRawInputs, getRawOutputs, 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 { navigateTo } from "store/navigation/navigation-action"; +import { snackbarActions } from "store/snackbar/snackbar-actions"; +import { SnackbarKind } from "../snackbar/snackbar-actions"; import { loadSubprocessPanel, subprocessPanelActions } from "../subprocess-panel/subprocess-panel-actions"; import { initProcessLogsPanel, processLogsPanelActions } from "store/process-logs-panel/process-logs-panel-actions"; import { CollectionFile } from "models/collection-file"; import { ContainerRequestResource } from "models/container-request"; -import { CommandOutputParameter } from 'cwlts/mappings/v1.0/CommandOutputParameter'; -import { CommandInputParameter, getIOParamId, WorkflowInputsData } from 'models/workflow'; +import { CommandOutputParameter } from "cwlts/mappings/v1.0/CommandOutputParameter"; +import { CommandInputParameter, getIOParamId, WorkflowInputsData } from "models/workflow"; import { getIOParamDisplayValue, ProcessIOParameter } from "views/process-panel/process-io-card"; import { OutputDetails, NodeInstanceType, NodeInfo } from "./process-panel"; import { AuthState } from "store/auth/auth-reducer"; +import { ContextMenuResource } from "store/context-menu/context-menu-actions"; export const processPanelActions = unionize({ RESET_PROCESS_PANEL: ofType<{}>(), @@ -39,45 +39,44 @@ export type ProcessPanelAction = UnionOf; export const toggleProcessPanelFilter = processPanelActions.TOGGLE_PROCESS_PANEL_FILTER; -export const loadProcessPanel = (uuid: string) => - async (dispatch: Dispatch, getState: () => RootState) => { - // Reset subprocess data explorer if navigating to new process - // Avoids resetting pagination when refreshing same process - if (getState().processPanel.containerRequestUuid !== uuid) { - dispatch(subprocessPanelActions.CLEAR()); - } - dispatch(processPanelActions.RESET_PROCESS_PANEL()); - dispatch(processLogsPanelActions.RESET_PROCESS_LOGS_PANEL()); - dispatch(processPanelActions.SET_PROCESS_PANEL_CONTAINER_REQUEST_UUID(uuid)); - await dispatch(loadProcess(uuid)); - dispatch(initProcessPanelFilters); - dispatch(initProcessLogsPanel(uuid)); - dispatch(loadSubprocessPanel()); - }; +export const loadProcessPanel = (uuid: string) => async (dispatch: Dispatch, getState: () => RootState) => { + // Reset subprocess data explorer if navigating to new process + // Avoids resetting pagination when refreshing same process + if (getState().processPanel.containerRequestUuid !== uuid) { + dispatch(subprocessPanelActions.CLEAR()); + } + dispatch(processPanelActions.RESET_PROCESS_PANEL()); + dispatch(processLogsPanelActions.RESET_PROCESS_LOGS_PANEL()); + dispatch(processPanelActions.SET_PROCESS_PANEL_CONTAINER_REQUEST_UUID(uuid)); + await dispatch(loadProcess(uuid)); + dispatch(initProcessPanelFilters); + dispatch(initProcessLogsPanel(uuid)); + dispatch(loadSubprocessPanel()); +}; -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 navigateToOutput = (resource: ContextMenuResource | ContainerRequestResource) => async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { + try { + await services.collectionService.get(resource.outputUuid || ''); + dispatch(navigateTo(resource.outputUuid || '')); + } catch { + dispatch(snackbarActions.OPEN_SNACKBAR({ message: "Output collection was trashed or deleted.", hideDuration: 4000, kind: SnackbarKind.WARNING })); + } +}; -export const loadInputs = (containerRequest: ContainerRequestResource) => - async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { +export const loadInputs = + (containerRequest: ContainerRequestResource) => async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { dispatch(processPanelActions.SET_INPUT_RAW(getRawInputs(containerRequest))); dispatch(processPanelActions.SET_INPUT_PARAMS(formatInputData(getInputs(containerRequest), getState().auth))); }; -export const loadOutputs = (containerRequest: ContainerRequestResource) => - async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { +export const loadOutputs = + (containerRequest: ContainerRequestResource) => async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { const noOutputs = { rawOutputs: {} }; + if (!containerRequest.outputUuid) { - dispatch(processPanelActions.SET_OUTPUT_RAW(noOutputs)); + dispatch(processPanelActions.SET_OUTPUT_RAW({ uuid: containerRequest.uuid, outputRaw: noOutputs })); return; - }; + } try { const propsOutputs = getRawOutputs(containerRequest); const filesPromise = services.collectionService.files(containerRequest.outputUuid); @@ -86,48 +85,53 @@ export const loadOutputs = (containerRequest: ContainerRequestResource) => // If has propsOutput, skip fetching cwl.output.json if (propsOutputs !== undefined) { - dispatch(processPanelActions.SET_OUTPUT_RAW({ - rawOutputs: propsOutputs, - pdh: collection.portableDataHash - })); + dispatch( + processPanelActions.SET_OUTPUT_RAW({ + rawOutputs: propsOutputs, + pdh: collection.portableDataHash, + }) + ); } else { // Fetch outputs from keep - const outputFile = files.find((file) => file.name === 'cwl.output.json') as CollectionFile | undefined; + const outputFile = files.find(file => file.name === "cwl.output.json") as CollectionFile | undefined; let outputData = outputFile ? await services.collectionService.getFileContents(outputFile) : undefined; if (outputData && (outputData = JSON.parse(outputData)) && collection.portableDataHash) { - dispatch(processPanelActions.SET_OUTPUT_RAW({ - rawOutputs: outputData, - pdh: collection.portableDataHash, - })); + dispatch( + processPanelActions.SET_OUTPUT_RAW({ + uuid: containerRequest.uuid, + outputRaw: { rawOutputs: outputData, pdh: collection.portableDataHash }, + }) + ); } else { - dispatch(processPanelActions.SET_OUTPUT_RAW(noOutputs)); + dispatch(processPanelActions.SET_OUTPUT_RAW({ uuid: containerRequest.uuid, outputRaw: noOutputs })); } } } catch { - dispatch(processPanelActions.SET_OUTPUT_RAW(noOutputs)); + dispatch(processPanelActions.SET_OUTPUT_RAW({ uuid: containerRequest.uuid, outputRaw: noOutputs })); } }; - -export const loadNodeJson = (containerRequest: ContainerRequestResource) => - async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { +export const loadNodeJson = + (containerRequest: ContainerRequestResource) => async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { const noLog = { nodeInfo: null }; if (!containerRequest.logUuid) { dispatch(processPanelActions.SET_NODE_INFO(noLog)); return; - }; + } try { const filesPromise = services.collectionService.files(containerRequest.logUuid); const collectionPromise = services.collectionService.get(containerRequest.logUuid); const [files] = await Promise.all([filesPromise, collectionPromise]); // Fetch node.json from keep - const nodeFile = files.find((file) => file.name === 'node.json') as CollectionFile | undefined; + const nodeFile = files.find(file => file.name === "node.json") as CollectionFile | undefined; let nodeData = nodeFile ? await services.collectionService.getFileContents(nodeFile) : undefined; if (nodeData && (nodeData = JSON.parse(nodeData))) { - dispatch(processPanelActions.SET_NODE_INFO({ - nodeInfo: nodeData as NodeInstanceType - })); + dispatch( + processPanelActions.SET_NODE_INFO({ + nodeInfo: nodeData as NodeInstanceType, + }) + ); } else { dispatch(processPanelActions.SET_NODE_INFO(noLog)); } @@ -136,28 +140,27 @@ export const loadNodeJson = (containerRequest: ContainerRequestResource) => } }; -export const loadOutputDefinitions = (containerRequest: ContainerRequestResource) => - async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { +export const loadOutputDefinitions = + (containerRequest: ContainerRequestResource) => async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { if (containerRequest && containerRequest.mounts) { dispatch(processPanelActions.SET_OUTPUT_DEFINITIONS(getOutputParameters(containerRequest))); } }; -export const updateOutputParams = () => - async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { - const outputDefinitions = getState().processPanel.outputDefinitions; - const outputRaw = getState().processPanel.outputRaw; +export const updateOutputParams = () => async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { + const outputDefinitions = getState().processPanel.outputDefinitions; + const outputRaw = getState().processPanel.outputRaw; - if (outputRaw !== null && outputRaw.rawOutputs) { - dispatch(processPanelActions.SET_OUTPUT_PARAMS(formatOutputData(outputDefinitions, outputRaw.rawOutputs, outputRaw.pdh, getState().auth))); - } - }; + if (outputRaw && outputRaw.rawOutputs) { + dispatch( + processPanelActions.SET_OUTPUT_PARAMS(formatOutputData(outputDefinitions, outputRaw.rawOutputs, outputRaw.pdh, getState().auth)) + ); + } +}; -export const openWorkflow = (uuid: string) => - (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { - dispatch(navigateToWorkflows); - dispatch(showWorkflowDetails(uuid)); - }; +export const openWorkflow = (uuid: string) => (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => { + dispatch(navigateTo(uuid)); +}; export const initProcessPanelFilters = processPanelActions.SET_PROCESS_PANEL_FILTERS([ ProcessStatus.QUEUED, @@ -167,7 +170,7 @@ export const initProcessPanelFilters = processPanelActions.SET_PROCESS_PANEL_FIL ProcessStatus.ONHOLD, ProcessStatus.FAILING, ProcessStatus.WARNING, - ProcessStatus.CANCELLED + ProcessStatus.CANCELLED, ]); export const formatInputData = (inputs: CommandInputParameter[], auth: AuthState): ProcessIOParameter[] => { @@ -175,17 +178,22 @@ export const formatInputData = (inputs: CommandInputParameter[], auth: AuthState return { id: getIOParamId(input), label: input.label || "", - value: getIOParamDisplayValue(auth, input) + value: getIOParamDisplayValue(auth, input), }; }); }; -export const formatOutputData = (definitions: CommandOutputParameter[], values: any, pdh: string | undefined, auth: AuthState): ProcessIOParameter[] => { +export const formatOutputData = ( + definitions: CommandOutputParameter[], + values: any, + pdh: string | undefined, + auth: AuthState +): ProcessIOParameter[] => { return definitions.map(output => { return { id: getIOParamId(output), label: output.label || "", - value: getIOParamDisplayValue(auth, Object.assign(output, { value: values[getIOParamId(output)] || [] }), pdh) + value: getIOParamDisplayValue(auth, Object.assign(output, { value: values[getIOParamId(output)] || [] }), pdh), }; }); };