X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/6149700b801fc2cdb83b0e700bbb319850ed471d..1d0297e01e0196d63b4fb42573e5bd6d1e1a31b9:/src/views/process-panel/process-panel.tsx diff --git a/src/views/process-panel/process-panel.tsx b/src/views/process-panel/process-panel.tsx index f416f7b2..d853fd09 100644 --- a/src/views/process-panel/process-panel.tsx +++ b/src/views/process-panel/process-panel.tsx @@ -2,18 +2,85 @@ // // SPDX-License-Identifier: AGPL-3.0 -import * as React from 'react'; -import { ProcessInformationCard } from '~/views-components/process-information-card/process-information-card'; -import { Grid } from '@material-ui/core'; +import { RootState } from 'store/store'; +import { connect } from 'react-redux'; +import { getProcess, getSubprocesses, Process, getProcessStatus } from 'store/processes/process'; +import { Dispatch } from 'redux'; +import { openProcessContextMenu } from 'store/context-menu/context-menu-actions'; +import { + ProcessPanelRootDataProps, + ProcessPanelRootActionProps, + ProcessPanelRoot +} from './process-panel-root'; +import { + getProcessPanelCurrentUuid, + ProcessPanel as ProcessPanelState +} from 'store/process-panel/process-panel'; +import { groupBy } from 'lodash'; +import { + loadInputs, + loadOutputDefinitions, + loadOutputs, + toggleProcessPanelFilter, + updateOutputParams, + loadNodeJson +} from 'store/process-panel/process-panel-actions'; +import { cancelRunningWorkflow } from 'store/processes/processes-actions'; +import { navigateToLogCollection, setProcessLogsPanelFilter } from 'store/process-logs-panel/process-logs-panel-actions'; +import { snackbarActions, SnackbarKind } from 'store/snackbar/snackbar-actions'; -export class ProcessPanel extends React.Component { - render() { - return
- - - - - -
; - } -} \ No newline at end of file +const mapStateToProps = ({ router, auth, resources, processPanel, processLogsPanel }: RootState): ProcessPanelRootDataProps => { + const uuid = getProcessPanelCurrentUuid(router) || ''; + const subprocesses = getSubprocesses(uuid)(resources); + return { + process: getProcess(uuid)(resources), + subprocesses: subprocesses.filter(subprocess => processPanel.filters[getProcessStatus(subprocess)]), + filters: getFilters(processPanel, subprocesses), + processLogsPanel: processLogsPanel, + auth: auth, + inputRaw: processPanel.inputRaw, + inputParams: processPanel.inputParams, + outputRaw: processPanel.outputRaw, + outputDefinitions: processPanel.outputDefinitions, + outputParams: processPanel.outputParams, + nodeInfo: processPanel.nodeInfo, + }; +}; + +const mapDispatchToProps = (dispatch: Dispatch): ProcessPanelRootActionProps => ({ + onCopyToClipboard: (message: string) => { + dispatch(snackbarActions.OPEN_SNACKBAR({ + message, + hideDuration: 2000, + kind: SnackbarKind.SUCCESS, + })); + }, + onContextMenu: (event, process) => { + dispatch(openProcessContextMenu(event, process)); + }, + onToggle: status => { + dispatch(toggleProcessPanelFilter(status)); + }, + cancelProcess: (uuid) => dispatch(cancelRunningWorkflow(uuid)), + onLogFilterChange: (filter) => dispatch(setProcessLogsPanelFilter(filter.value)), + navigateToLog: (uuid) => dispatch(navigateToLogCollection(uuid)), + loadInputs: (containerRequest) => dispatch(loadInputs(containerRequest)), + loadOutputs: (containerRequest) => dispatch(loadOutputs(containerRequest)), + loadOutputDefinitions: (containerRequest) => dispatch(loadOutputDefinitions(containerRequest)), + updateOutputParams: () => dispatch(updateOutputParams()), + loadNodeJson: (containerRequest) => dispatch(loadNodeJson(containerRequest)), +}); + +const getFilters = (processPanel: ProcessPanelState, processes: Process[]) => { + const grouppedProcesses = groupBy(processes, getProcessStatus); + return Object + .keys(processPanel.filters) + .map(filter => ({ + label: filter, + value: (grouppedProcesses[filter] || []).length, + checked: processPanel.filters[filter], + key: filter, + })); +}; + +export const ProcessPanel = connect(mapStateToProps, mapDispatchToProps)(ProcessPanelRoot);