X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/7f1fc8720518f4f712d49def31b76b6af1b6ceab..cd89fd24a8cdf7512a4352f1fc17101b225e32c4:/src/views/process-panel/process-panel-root.tsx diff --git a/src/views/process-panel/process-panel-root.tsx b/src/views/process-panel/process-panel-root.tsx index 950418fb..11b31ae0 100644 --- a/src/views/process-panel/process-panel-root.tsx +++ b/src/views/process-panel/process-panel-root.tsx @@ -2,7 +2,7 @@ // // SPDX-License-Identifier: AGPL-3.0 -import React, { useState } from 'react'; +import React from 'react'; import { Grid, StyleRulesCallback, WithStyles, withStyles } from '@material-ui/core'; import { DefaultView } from 'components/default-view/default-view'; import { ProcessIcon } from 'components/icon/icon'; @@ -12,15 +12,18 @@ import { SubprocessFilterDataProps } from 'components/subprocess-filter/subproce import { MPVContainer, MPVPanelContent, MPVPanelState } from 'components/multi-panel-view/multi-panel-view'; import { ArvadosTheme } from 'common/custom-theme'; import { ProcessDetailsCard } from './process-details-card'; -import { getInputDisplayValue, ProcessIOCard, ProcessIOParameter } from './process-io-card'; - +import { ProcessIOCard, ProcessIOCardType, ProcessIOParameter } from './process-io-card'; +import { ProcessResourceCard } from './process-resource-card'; import { getProcessPanelLogs, ProcessLogsPanel } from 'store/process-logs-panel/process-logs-panel'; import { ProcessLogsCard } from './process-log-card'; import { FilterOption } from 'views/process-panel/process-log-form'; -import { getInputs, getOutputParameters } from 'store/processes/processes-actions'; -import { CommandInputParameter, getIOParamId } from 'models/workflow'; +import { getInputCollectionMounts } from 'store/processes/processes-actions'; +import { WorkflowInputsData } from 'models/workflow'; import { CommandOutputParameter } from 'cwlts/mappings/v1.0/CommandOutputParameter'; import { AuthState } from 'store/auth/auth-reducer'; +import { ProcessCmdCard } from './process-cmd-card'; +import { ContainerRequestResource } from 'models/container-request'; +import { OutputDetails, NodeInstanceType } from 'store/process-panel/process-panel'; type CssRules = 'root'; @@ -36,141 +39,149 @@ export interface ProcessPanelRootDataProps { filters: Array; processLogsPanel: ProcessLogsPanel; auth: AuthState; + inputRaw: WorkflowInputsData | null; + inputParams: ProcessIOParameter[] | null; + outputRaw: OutputDetails | null; + outputDefinitions: CommandOutputParameter[]; + outputParams: ProcessIOParameter[] | null; + nodeInfo: NodeInstanceType | null; } export interface ProcessPanelRootActionProps { onContextMenu: (event: React.MouseEvent, process: Process) => void; onToggle: (status: string) => void; cancelProcess: (uuid: string) => void; + startProcess: (uuid: string) => void; onLogFilterChange: (filter: FilterOption) => void; navigateToLog: (uuid: string) => void; - onLogCopyToClipboard: (uuid: string) => void; - fetchOutputs: (uuid: string, fetchOutputs) => void; + onCopyToClipboard: (uuid: string) => void; + loadInputs: (containerRequest: ContainerRequestResource) => void; + loadOutputs: (containerRequest: ContainerRequestResource) => void; + loadNodeJson: (containerRequest: ContainerRequestResource) => void; + loadOutputDefinitions: (containerRequest: ContainerRequestResource) => void; + updateOutputParams: () => void; } export type ProcessPanelRootProps = ProcessPanelRootDataProps & ProcessPanelRootActionProps & WithStyles; -type OutputDetails = { - rawOutputs?: any; - pdh?: string; -} - const panelsData: MPVPanelState[] = [ - {name: "Details"}, - {name: "Logs", visible: true}, - {name: "Inputs"}, - {name: "Outputs"}, - {name: "Subprocesses"}, + { name: "Details" }, + { name: "Command" }, + { name: "Logs", visible: true }, + { name: "Inputs" }, + { name: "Outputs" }, + { name: "Resources" }, + { name: "Subprocesses" }, ]; export const ProcessPanelRoot = withStyles(styles)( - ({ process, auth, processLogsPanel, fetchOutputs, ...props }: ProcessPanelRootProps) => { - - const [outputDetails, setOutputs] = useState({}); - const [rawInputs, setInputs] = useState([]); - - - const [processedOutputs, setProcessedOutputs] = useState([]); - const [processedInputs, setProcessedInputs] = useState([]); - - const outputUuid = process?.containerRequest.outputUuid; - const requestUuid = process?.containerRequest.uuid; - - React.useEffect(() => { - if (outputUuid) { - fetchOutputs(outputUuid, setOutputs); - } - }, [outputUuid, fetchOutputs]); - - React.useEffect(() => { - if (outputDetails.rawOutputs && process) { - const outputDefinitions = getOutputParameters(process.containerRequest); - setProcessedOutputs(formatOutputData(outputDefinitions, outputDetails.rawOutputs, outputDetails.pdh, auth)); - } else { - setProcessedOutputs([]); - } - }, [outputDetails, auth, process]); - - React.useEffect(() => { - if (process) { - const rawInputs = getInputs(process.containerRequest); - setInputs(rawInputs); - setProcessedInputs(formatInputData(rawInputs, auth)); - } - }, [requestUuid, auth, process]); - - return process - ? - - props.onContextMenu(event, process)} - cancelProcess={props.cancelProcess} - /> - - - ({ label: filter, value: filter }) - )} - onLogFilterChange={props.onLogFilterChange} - navigateToLog={props.navigateToLog} - /> - - - - - - - - - - - - : - - ; + ({ + process, + auth, + processLogsPanel, + inputRaw, + inputParams, + outputRaw, + outputDefinitions, + outputParams, + nodeInfo, + loadInputs, + loadOutputs, + loadNodeJson, + loadOutputDefinitions, + updateOutputParams, + ...props + }: ProcessPanelRootProps) => { + + const outputUuid = process?.containerRequest.outputUuid; + const containerRequest = process?.containerRequest; + const inputMounts = getInputCollectionMounts(process?.containerRequest); + + React.useEffect(() => { + if (containerRequest) { + // Load inputs from mounts or props + loadInputs(containerRequest); + // Fetch raw output (loads from props or keep) + loadOutputs(containerRequest); + // Loads output definitions from mounts into store + loadOutputDefinitions(containerRequest); + // load the assigned instance type from node.json in + // the log collection + loadNodeJson(containerRequest); + } + }, [containerRequest, loadInputs, loadOutputs, loadOutputDefinitions, loadNodeJson]); + + // Trigger processing output params when raw or definitions change + React.useEffect(() => { + updateOutputParams(); + }, [outputRaw, outputDefinitions, updateOutputParams]); + + return process + ? + + props.onContextMenu(event, process)} + cancelProcess={props.cancelProcess} + startProcess={props.startProcess} + /> + + + + + + ({ label: filter, value: filter }) + )} + onLogFilterChange={props.onLogFilterChange} + navigateToLog={props.navigateToLog} + /> + + + + + + + + + + + + + + + : + + ; } ); - -const formatInputData = (inputs: CommandInputParameter[], auth: AuthState): ProcessIOParameter[] => { - return inputs.map(input => { - const doc = Array.isArray(input.doc) ? input.doc.join(', ') : input.doc; - return { - id: getIOParamId(input), - doc: input.label || doc || "", - value: getInputDisplayValue(auth, input) - }; - }); -}; - -const formatOutputData = (definitions: CommandOutputParameter[], values: any, pdh: string | undefined, auth: AuthState): ProcessIOParameter[] => { - return definitions.map(output => { - const doc = Array.isArray(output.doc) ? output.doc.join(', ') : output.doc; - return { - id: getIOParamId(output), - doc: output.label || doc || "", - value: getInputDisplayValue(auth, Object.assign(output, { value: values[getIOParamId(output)] }), pdh) - }; - }); -};