src/store/processes/process.ts

   1 // Copyright (C) The Arvados Authors. All rights reserved.
   2 //
   3 // SPDX-License-Identifier: AGPL-3.0
   4
   5 import { ContainerRequestResource } from '../../models/container-request';
   6 import { ContainerResource } from '../../models/container';
   7 import { ResourcesState, getResource } from '~/store/resources/resources';
   8 import { filterResources } from '../resources/resources';
   9 import { ResourceKind, Resource } from '~/models/resource';
  10
  11 export interface Process {
  12     containerRequest: ContainerRequestResource;
  13     container?: ContainerResource;
  14 }
  15
  16 export const getProcess = (uuid: string) => (resources: ResourcesState): Process | undefined => {
  17     const containerRequest = getResource<ContainerRequestResource>(uuid)(resources);
  18     if (containerRequest) {
  19         if (containerRequest.containerUuid) {
  20             const container = getResource<ContainerResource>(containerRequest.containerUuid)(resources);
  21             if (container) {
  22                 return { containerRequest, container };
  23             }
  24         }
  25         return { containerRequest };
  26     }
  27     return;
  28 };
  29
  30 export const getSubprocesses = (uuid: string) => (resources: ResourcesState) => {
  31     const process = getProcess(uuid)(resources);
  32     if (process && process.container) {
  33         const containerRequests = filterResources(isSubprocess(process.container.uuid))(resources) as ContainerRequestResource[];
  34         return containerRequests.reduce((subprocesses, { uuid }) => {
  35             const process = getProcess(uuid)(resources);
  36             return process
  37                 ? [...subprocesses, process]
  38                 : subprocesses;
  39         }, []);
  40     }
  41     return [];
  42 };
  43
  44 export const getProcessStatus = (process: Process) =>
  45     process.container
  46         ? process.container.state
  47         : process.containerRequest.state;
  48
  49 const isSubprocess = (containerUuid: string) => (resource: Resource) =>
  50     resource.kind === ResourceKind.CONTAINER_REQUEST
  51     && (resource as ContainerRequestResource).requestingContainerUuid === containerUuid;