src/store/processes/process-copy-actions.ts

   1 // Copyright (C) The Arvados Authors. All rights reserved.
   2 //
   3 // SPDX-License-Identifier: AGPL-3.0
   4
   5 import { Dispatch } from 'redux';
   6 import { dialogActions } from 'store/dialog/dialog-actions';
   7 import { initialize, startSubmit } from 'redux-form';
   8 import { resetPickerProjectTree } from 'store/project-tree-picker/project-tree-picker-actions';
   9 import { RootState } from 'store/store';
  10 import { ServiceRepository } from 'services/services';
  11 import { CopyFormDialogData } from 'store/copy-dialog/copy-dialog';
  12 import { getProcess } from 'store/processes/process';
  13 import { snackbarActions, SnackbarKind } from 'store/snackbar/snackbar-actions';
  14 import { initProjectsTreePicker } from 'store/tree-picker/tree-picker-actions';
  15 import { ContainerRequestState } from 'models/container-request';
  16
  17 export const PROCESS_COPY_FORM_NAME = 'processCopyFormName';
  18
  19 export const openCopyProcessDialog = (resource: { name: string; uuid: string }) => (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => {
  20     console.log(resource);
  21     const process = getProcess(resource.uuid)(getState().resources);
  22     if (process) {
  23         dispatch<any>(resetPickerProjectTree());
  24         dispatch<any>(initProjectsTreePicker(PROCESS_COPY_FORM_NAME));
  25         const initialData: CopyFormDialogData = { name: `Copy of: ${resource.name}`, uuid: resource.uuid, ownerUuid: '' };
  26         dispatch<any>(initialize(PROCESS_COPY_FORM_NAME, initialData));
  27         dispatch(dialogActions.OPEN_DIALOG({ id: PROCESS_COPY_FORM_NAME, data: {} }));
  28     } else {
  29         dispatch(snackbarActions.OPEN_SNACKBAR({ message: 'Process not found', hideDuration: 2000, kind: SnackbarKind.ERROR }));
  30     }
  31 };
  32
  33 export const copyProcess = (resource: CopyFormDialogData) => async (dispatch: Dispatch, getState: () => RootState, services: ServiceRepository) => {
  34     dispatch(startSubmit(PROCESS_COPY_FORM_NAME));
  35     try {
  36         const process = await services.containerRequestService.get(resource.uuid);
  37         const {
  38             command,
  39             containerCountMax,
  40             containerImage,
  41             cwd,
  42             description,
  43             environment,
  44             kind,
  45             mounts,
  46             outputName,
  47             outputPath,
  48             outputProperties,
  49             outputStorageClasses,
  50             outputTtl,
  51             properties,
  52             runtimeConstraints,
  53             schedulingParameters,
  54             useExisting,
  55         } = process;
  56         const newProcess = await services.containerRequestService.create({
  57             command,
  58             containerCountMax,
  59             containerImage,
  60             cwd,
  61             description,
  62             environment,
  63             kind,
  64             mounts,
  65             name: resource.name,
  66             outputName,
  67             outputPath,
  68             outputProperties,
  69             outputStorageClasses,
  70             outputTtl,
  71             ownerUuid: resource.ownerUuid,
  72             priority: 500,
  73             properties,
  74             runtimeConstraints,
  75             schedulingParameters,
  76             state: ContainerRequestState.UNCOMMITTED,
  77             useExisting,
  78         });
  79         dispatch(dialogActions.CLOSE_DIALOG({ id: PROCESS_COPY_FORM_NAME }));
  80         return newProcess;
  81     } catch (e) {
  82         dispatch(dialogActions.CLOSE_DIALOG({ id: PROCESS_COPY_FORM_NAME }));
  83         throw new Error('Could not copy the process.');
  84     }
  85 };