src/views/process-panel/process-panel.tsx

   1 // Copyright (C) The Arvados Authors. All rights reserved.
   2 //
   3 // SPDX-License-Identifier: AGPL-3.0
   4
   5 import { RootState } from "store/store";
   6 import { connect } from "react-redux";
   7 import { getProcess, getSubprocesses, Process, getProcessStatus } from "store/processes/process";
   8 import { Dispatch } from "redux";
   9 import { openProcessContextMenu, openRunningProcessContextMenu } from "store/context-menu/context-menu-actions";
  10 import { ProcessPanelRootDataProps, ProcessPanelRootActionProps, ProcessPanelRoot } from "./process-panel-root";
  11 import { getProcessPanelCurrentUuid, ProcessPanel as ProcessPanelState } from "store/process-panel/process-panel";
  12 import { groupBy } from "lodash";
  13 import {
  14     loadInputs,
  15     loadOutputDefinitions,
  16     loadOutputs,
  17     toggleProcessPanelFilter,
  18     updateOutputParams,
  19     loadNodeJson,
  20 } from "store/process-panel/process-panel-actions";
  21 import { cancelRunningWorkflow, resumeOnHoldWorkflow, startWorkflow } from "store/processes/processes-actions";
  22 import { navigateToLogCollection, setProcessLogsPanelFilter } from "store/process-logs-panel/process-logs-panel-actions";
  23 import { snackbarActions, SnackbarKind } from "store/snackbar/snackbar-actions";
  24 import { isProcessCancelable } from "store/processes/process";
  25
  26 const mapStateToProps = ({ router, auth, resources, processPanel, processLogsPanel }: RootState): ProcessPanelRootDataProps => {
  27     const uuid = getProcessPanelCurrentUuid(router) || "";
  28     const subprocesses = getSubprocesses(uuid)(resources);
  29     return {
  30         process: getProcess(uuid)(resources),
  31         subprocesses: subprocesses.filter(subprocess => processPanel.filters[getProcessStatus(subprocess)]),
  32         filters: getFilters(processPanel, subprocesses),
  33         processLogsPanel: processLogsPanel,
  34         auth: auth,
  35         inputRaw: processPanel.inputRaw,
  36         inputParams: processPanel.inputParams,
  37         outputRaw: processPanel.outputRaw,
  38         outputDefinitions: processPanel.outputDefinitions,
  39         outputParams: processPanel.outputParams,
  40         nodeInfo: processPanel.nodeInfo,
  41     };
  42 };
  43
  44 const mapDispatchToProps = (dispatch: Dispatch): ProcessPanelRootActionProps => ({
  45     onCopyToClipboard: (message: string) => {
  46         dispatch<any>(
  47             snackbarActions.OPEN_SNACKBAR({
  48                 message,
  49                 hideDuration: 2000,
  50                 kind: SnackbarKind.SUCCESS,
  51             })
  52         );
  53     },
  54     onContextMenu: (event, process) => {
  55         // dispatch<any>(openProcessContextMenu(event, process));
  56         if (process && isProcessCancelable(process)) {
  57             dispatch<any>(openRunningProcessContextMenu(event, process));
  58         } else if (process) {
  59             dispatch<any>(openProcessContextMenu(event, process));
  60         }
  61     },
  62     onToggle: status => {
  63         dispatch<any>(toggleProcessPanelFilter(status));
  64     },
  65     cancelProcess: uuid => dispatch<any>(cancelRunningWorkflow(uuid)),
  66     startProcess: uuid => dispatch<any>(startWorkflow(uuid)),
  67     resumeOnHoldWorkflow: uuid => dispatch<any>(resumeOnHoldWorkflow(uuid)),
  68     onLogFilterChange: filter => dispatch(setProcessLogsPanelFilter(filter.value)),
  69     navigateToLog: uuid => dispatch<any>(navigateToLogCollection(uuid)),
  70     loadInputs: containerRequest => dispatch<any>(loadInputs(containerRequest)),
  71     loadOutputs: containerRequest => dispatch<any>(loadOutputs(containerRequest)),
  72     loadOutputDefinitions: containerRequest => dispatch<any>(loadOutputDefinitions(containerRequest)),
  73     updateOutputParams: () => dispatch<any>(updateOutputParams()),
  74     loadNodeJson: containerRequest => dispatch<any>(loadNodeJson(containerRequest)),
  75 });
  76
  77 const getFilters = (processPanel: ProcessPanelState, processes: Process[]) => {
  78     const grouppedProcesses = groupBy(processes, getProcessStatus);
  79     return Object.keys(processPanel.filters).map(filter => ({
  80         label: filter,
  81         value: (grouppedProcesses[filter] || []).length,
  82         checked: processPanel.filters[filter],
  83         key: filter,
  84     }));
  85 };
  86
  87 export const ProcessPanel = connect(mapStateToProps, mapDispatchToProps)(ProcessPanelRoot);