X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/1832d4a40997469ae0c2d3e6f2e5a552b834118b..73e8a8225a4a702e3392da9ac9bb50ff479377c0:/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 2aa914af..2111afdb 100644 --- a/src/store/process-panel/process-panel-actions.ts +++ b/src/store/process-panel/process-panel-actions.ts @@ -2,46 +2,198 @@ // // SPDX-License-Identifier: AGPL-3.0 -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 { navigateToCollection } from '~/store/navigation/navigation-action'; -import { snackbarActions } from '~/store/snackbar/snackbar-actions'; -import { SnackbarKind } from '../snackbar/snackbar-actions'; - -export const procesPanelActions = unionize({ +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 { ServiceRepository } from "services/services"; +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 { 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<{}>(), + SET_PROCESS_PANEL_CONTAINER_REQUEST_UUID: ofType(), SET_PROCESS_PANEL_FILTERS: ofType(), TOGGLE_PROCESS_PANEL_FILTER: ofType(), + SET_INPUT_RAW: ofType(), + SET_INPUT_PARAMS: ofType(), + SET_OUTPUT_RAW: ofType(), + SET_OUTPUT_DEFINITIONS: ofType(), + SET_OUTPUT_PARAMS: ofType(), + SET_NODE_INFO: ofType(), }); -export type ProcessPanelAction = UnionOf; +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 toggleProcessPanelFilter = procesPanelActions.TOGGLE_PROCESS_PANEL_FILTER; +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 loadProcessPanel = (uuid: string) => - (dispatch: Dispatch) => { - dispatch(loadProcess(uuid)); - dispatch(initProcessPanelFilters); +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 navigateToOutput = (uuid: string) => - 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({ uuid: containerRequest.uuid, outputRaw: noOutputs })); + return; + } try { - await services.collectionService.get(uuid); - dispatch(navigateToCollection(uuid)); + const propsOutputs = getRawOutputs(containerRequest); + const filesPromise = services.collectionService.files(containerRequest.outputUuid); + const collectionPromise = services.collectionService.get(containerRequest.outputUuid); + const [files, collection] = await Promise.all([filesPromise, collectionPromise]); + + // If has propsOutput, skip fetching cwl.output.json + if (propsOutputs !== undefined) { + 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; + let outputData = outputFile ? await services.collectionService.getFileContents(outputFile) : undefined; + if (outputData && (outputData = JSON.parse(outputData)) && collection.portableDataHash) { + dispatch( + processPanelActions.SET_OUTPUT_RAW({ + uuid: containerRequest.uuid, + outputRaw: { rawOutputs: outputData, pdh: collection.portableDataHash }, + }) + ); + } else { + dispatch(processPanelActions.SET_OUTPUT_RAW({ uuid: containerRequest.uuid, outputRaw: noOutputs })); + } + } } catch { - dispatch(snackbarActions.OPEN_SNACKBAR({ message: 'This collection does not exists!', hideDuration: 2000, kind: SnackbarKind.ERROR })); + dispatch(processPanelActions.SET_OUTPUT_RAW({ uuid: containerRequest.uuid, outputRaw: noOutputs })); } }; -export const initProcessPanelFilters = procesPanelActions.SET_PROCESS_PANEL_FILTERS([ +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; + let nodeData = nodeFile ? await services.collectionService.getFileContents(nodeFile) : undefined; + if (nodeData && (nodeData = JSON.parse(nodeData))) { + dispatch( + processPanelActions.SET_NODE_INFO({ + nodeInfo: nodeData as NodeInstanceType, + }) + ); + } else { + dispatch(processPanelActions.SET_NODE_INFO(noLog)); + } + } catch { + dispatch(processPanelActions.SET_NODE_INFO(noLog)); + } + }; + +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; + + 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(navigateTo(uuid)); +}; + +export const initProcessPanelFilters = processPanelActions.SET_PROCESS_PANEL_FILTERS([ ProcessStatus.QUEUED, ProcessStatus.COMPLETED, ProcessStatus.FAILED, ProcessStatus.RUNNING, - ProcessStatus.LOCKED, - ProcessStatus.CANCELLED + ProcessStatus.ONHOLD, + ProcessStatus.FAILING, + ProcessStatus.WARNING, + ProcessStatus.CANCELLED, ]); + +export const formatInputData = (inputs: CommandInputParameter[], auth: AuthState): ProcessIOParameter[] => { + return inputs.map(input => { + return { + id: getIOParamId(input), + label: input.label || "", + value: getIOParamDisplayValue(auth, input), + }; + }); +}; + +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), + }; + }); +};