refs #master Merge branch 'origin/master' into 14186-progress-indicator-store
[arvados-workbench2.git] / 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, ContainerRequestState } from '../../models/container-request';
6 import { ContainerResource, ContainerState } from '../../models/container';
7 import { ResourcesState, getResource } from '~/store/resources/resources';
8 import { filterResources } from '../resources/resources';
9 import { ResourceKind, Resource, extractUuidKind } from '~/models/resource';
10 import { getTimeDiff } from '~/common/formatters';
11 import { ArvadosTheme } from '~/common/custom-theme';
12
13 export interface Process {
14     containerRequest: ContainerRequestResource;
15     container?: ContainerResource;
16 }
17
18 export enum ProcessStatus {
19     CANCELLED = 'Cancelled',
20     COMPLETED = 'Completed',
21     DRAFT = 'Draft',
22     FAILED = 'Failed',
23     LOCKED = 'Locked',
24     QUEUED = 'Queued',
25     RUNNING = 'Running',
26     UNKNOWN = 'Unknown',
27 }
28
29 export const getProcess = (uuid: string) => (resources: ResourcesState): Process | undefined => {
30     if (extractUuidKind(uuid) === ResourceKind.CONTAINER_REQUEST) {
31         const containerRequest = getResource<ContainerRequestResource>(uuid)(resources);
32         if (containerRequest) {
33             if (containerRequest.containerUuid) {
34                 const container = getResource<ContainerResource>(containerRequest.containerUuid)(resources);
35                 if (container) {
36                     return { containerRequest, container };
37                 }
38             }
39             return { containerRequest };
40         }
41     }
42     return;
43 };
44
45 export const getSubprocesses = (uuid: string) => (resources: ResourcesState) => {
46     const process = getProcess(uuid)(resources);
47     if (process && process.container) {
48         const containerRequests = filterResources(isSubprocess(process.container.uuid))(resources) as ContainerRequestResource[];
49         return containerRequests.reduce((subprocesses, { uuid }) => {
50             const process = getProcess(uuid)(resources);
51             return process
52                 ? [...subprocesses, process]
53                 : subprocesses;
54         }, []);
55     }
56     return [];
57 };
58
59 export const getProcessRuntime = ({ container }: Process) =>
60     container
61         ? getTimeDiff(container.finishedAt || '', container.startedAt || '')
62         : 0;
63
64 export const getProcessStatusColor = (status: string, { customs, palette }: ArvadosTheme) => {
65     switch (status) {
66         case ProcessStatus.RUNNING:
67             return customs.colors.blue500;
68         case ProcessStatus.COMPLETED:
69             return customs.colors.green700;
70         case ProcessStatus.CANCELLED:
71         case ProcessStatus.FAILED:
72             return customs.colors.red900;
73         default:
74             return palette.grey["500"];
75     }
76 };
77
78 export const getProcessStatus = ({ containerRequest, container }: Process): ProcessStatus => {
79     switch (true) {
80         case containerRequest.state === ContainerRequestState.UNCOMMITTED:
81             return ProcessStatus.DRAFT;
82
83         case containerRequest.priority === 0:
84         case container && container.state === ContainerState.CANCELLED:
85             return ProcessStatus.CANCELLED;
86
87         case container && container.state === ContainerState.QUEUED:
88             return ProcessStatus.QUEUED;
89
90         case container && container.state === ContainerState.LOCKED:
91             return ProcessStatus.LOCKED;
92
93         case container && container.state === ContainerState.RUNNING:
94             return ProcessStatus.RUNNING;
95
96         case container && container.state === ContainerState.COMPLETE && container.exitCode === 0:
97             return ProcessStatus.COMPLETED;
98
99         case container && container.state === ContainerState.COMPLETE && container.exitCode !== 0:
100             return ProcessStatus.FAILED;
101
102         default:
103             return ProcessStatus.UNKNOWN;
104     }
105 };
106
107 const isSubprocess = (containerUuid: string) => (resource: Resource) =>
108     resource.kind === ResourceKind.CONTAINER_REQUEST
109     && (resource as ContainerRequestResource).requestingContainerUuid === containerUuid;