// Copyright (C) The Arvados Authors. All rights reserved. // // SPDX-License-Identifier: AGPL-3.0 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, getOutputParameters } from 'store/processes/processes-actions'; import { CommandInputParameter, getIOParamId } 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; 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 & 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([]); 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} /> : ; } ); 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) }; }); };