X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/be8de5acc35c47d0b191223e5ece96fcf452ea5d..62abdd5fbf51cde6c61350082a7924b3ebaf8526:/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 35842c7b..3447dc2a 100644 --- a/src/views/process-panel/process-panel-root.tsx +++ b/src/views/process-panel/process-panel-root.tsx @@ -2,49 +2,145 @@ // // SPDX-License-Identifier: AGPL-3.0 -import * as React from 'react'; -import { Grid } from '@material-ui/core'; -import { ProcessInformationCard } from './process-information-card'; -import { DefaultView } from '~/components/default-view/default-view'; -import { ProcessIcon } from '~/components/icon/icon'; -import { Process } from '~/store/processes/process'; -import { SubprocessPanel } from '~/views/subprocess-panel/subprocess-panel'; -import { SubprocessFilterDataProps } from '~/components/subprocess-filter/subprocess-filter'; +import React, { useState } 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'; +import { Process } from 'store/processes/process'; +import { SubprocessPanel } from 'views/subprocess-panel/subprocess-panel'; +import { SubprocessFilterDataProps } from 'components/subprocess-filter/subprocess-filter'; +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 { 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 } from 'store/processes/processes-actions'; +import { CommandInputParameter, getInputId } from 'models/workflow'; +import { CommandOutputParameter } from 'cwlts/mappings/v1.0/CommandOutputParameter'; +import { AuthState } from 'store/auth/auth-reducer'; + +type CssRules = 'root'; + +const styles: StyleRulesCallback = (theme: ArvadosTheme) => ({ + root: { + width: '100%', + }, +}); export interface ProcessPanelRootDataProps { process?: Process; subprocesses: Array; filters: Array; + processLogsPanel: ProcessLogsPanel; + auth: AuthState; } export interface ProcessPanelRootActionProps { onContextMenu: (event: React.MouseEvent, process: Process) => void; onToggle: (status: string) => void; - openProcessInputDialog: (uuid: string) => void; - navigateToOutput: (uuid: string) => void; - navigateToWorkflow: (uuid: string) => void; cancelProcess: (uuid: string) => void; + onLogFilterChange: (filter: FilterOption) => void; + navigateToLog: (uuid: string) => void; + onLogCopyToClipboard: (uuid: string) => void; + fetchOutputs: (uuid: string, fetchOutputs) => void; } -export type ProcessPanelRootProps = ProcessPanelRootDataProps & ProcessPanelRootActionProps; +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"}, +]; + +export const ProcessPanelRoot = withStyles(styles)( + ({ process, auth, processLogsPanel, fetchOutputs, ...props }: ProcessPanelRootProps) => { + + const [outputDetails, setOutputs] = useState({}); + const [rawInputs, setInputs] = useState([]); + -export const ProcessPanelRoot = ({ process, ...props }: ProcessPanelRootProps) => - process - ? - - ([]); + 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) { + setProcessedOutputs(formatOutputData(outputDetails.rawOutputs, outputDetails.pdh, auth)); + } else { + setProcessedOutputs([]); + } + }, [outputDetails, auth]); + + React.useEffect(() => { + if (process) { + const rawInputs = getInputs(process.containerRequest); + setInputs(rawInputs); + setProcessedInputs(formatInputData(rawInputs, auth)); + } + }, [requestUuid, auth, process]); + + return process + ? + + props.onContextMenu(event, process)} - openProcessInputDialog={props.openProcessInputDialog} - navigateToOutput={props.navigateToOutput} - openWorkflow={props.navigateToWorkflow} cancelProcess={props.cancelProcess} /> - - + + + ({ label: filter, value: filter }) + )} + onLogFilterChange={props.onLogFilterChange} + navigateToLog={props.navigateToLog} + /> + + + + + + + + - - + + : ; + } +); + +const formatInputData = (inputs: CommandInputParameter[], auth: AuthState): ProcessIOParameter[] => { + return inputs.map(input => { + return { + id: getInputId(input), + doc: input.label || "", + value: getInputDisplayValue(auth, input) + }; + }); +}; +const formatOutputData = (rawData: any, pdh: string | undefined, auth: AuthState): ProcessIOParameter[] => { + if (!rawData) { return []; } + return Object.keys(rawData).map((id): ProcessIOParameter => { + const multiple = rawData[id].length > 0; + const outputArray = multiple ? rawData[id] : [rawData[id]]; + return { + id, + doc: outputArray.map((outputParam: CommandOutputParameter) => (outputParam.doc)) + // Doc can be string or string[], concat conveniently works with both + .reduce((acc: string[], input: string | string[]) => (acc.concat(input)), []) + // Remove undefined and empty doc strings + .filter(str => str) + .join(", "), + value: outputArray.map(outputParam => getInputDisplayValue(auth, { + type: outputParam.class, + value: outputParam, + ...outputParam + }, pdh, outputParam.secondaryFiles)) + .reduce((acc: ProcessIOParameter[], params: ProcessIOParameter[]) => (acc.concat(params)), []) + }; + }); +};