|
1 | | -import { |
2 | | - K8sResourceCommon, |
3 | | - Selector, |
4 | | - useFlag, |
5 | | -} from '@openshift-console/dynamic-plugin-sdk'; |
6 | | -import { uniqBy } from 'lodash'; |
| 1 | +import { Selector, useFlag } from '@openshift-console/dynamic-plugin-sdk'; |
7 | 2 | import { useEffect, useState } from 'react'; |
8 | | -import { |
9 | | - FLAG_PIPELINE_TEKTON_RESULT_INSTALLED, |
10 | | - RepositoryFields, |
11 | | - RepositoryLabels, |
12 | | - TektonResourceLabel, |
13 | | -} from '../../consts'; |
14 | | -import { |
15 | | - FLAGS, |
16 | | - PipelineRunKind, |
17 | | - RecordsList, |
18 | | - TaskRunKind, |
19 | | - TektonResultsOptions, |
20 | | -} from '../../types'; |
21 | | -import { |
22 | | - getPipelineRuns, |
23 | | - getTaskRunLog, |
24 | | - getTaskRuns, |
25 | | -} from '../utils/tekton-results'; |
26 | | -import { usePipelineRuns, useTaskRuns } from './useTaskRuns'; |
| 3 | +import { RepositoryFields, RepositoryLabels } from '../../consts'; |
| 4 | +import { FLAGS, PipelineRunKind } from '../../types'; |
| 5 | +import { getTaskRunLog } from '../utils/tekton-results'; |
| 6 | +import { usePipelineRuns } from './useTaskRuns'; |
27 | 7 |
|
28 | 8 | export type GetNextPage = () => void | undefined; |
29 | 9 |
|
30 | | -const useTRRuns = <Kind extends K8sResourceCommon>( |
31 | | - getRuns: ( |
32 | | - namespace: string, |
33 | | - options?: TektonResultsOptions, |
34 | | - nextPageToken?: string, |
35 | | - cacheKey?: string, |
36 | | - isDevConsoleProxyAvailable?: boolean, |
37 | | - ) => Promise<[Kind[], RecordsList, boolean?]>, |
38 | | - namespace: string, |
39 | | - options?: TektonResultsOptions, |
40 | | - cacheKey?: string, |
41 | | -): [Kind[], boolean, unknown, GetNextPage] => { |
42 | | - const isDevConsoleProxyAvailable = useFlag(FLAGS.DEVCONSOLE_PROXY); |
43 | | - const [nextPageToken, setNextPageToken] = useState<string>(null); |
44 | | - const [localCacheKey, setLocalCacheKey] = useState(cacheKey); |
45 | | - |
46 | | - if (cacheKey !== localCacheKey) { |
47 | | - // force update local cache key |
48 | | - setLocalCacheKey(cacheKey); |
49 | | - } |
50 | | - |
51 | | - const [result, setResult] = useState<[Kind[], boolean, unknown, GetNextPage]>( |
52 | | - [[], false, undefined, undefined], |
53 | | - ); |
54 | | - |
55 | | - // reset token if namespace or options change |
56 | | - useEffect(() => { |
57 | | - setNextPageToken(null); |
58 | | - }, [namespace, options, cacheKey]); |
59 | | - |
60 | | - // eslint-disable-next-line consistent-return |
61 | | - useEffect(() => { |
62 | | - let disposed = false; |
63 | | - (async () => { |
64 | | - try { |
65 | | - const tkPipelineRuns = await getRuns( |
66 | | - namespace, |
67 | | - options, |
68 | | - nextPageToken, |
69 | | - localCacheKey, |
70 | | - isDevConsoleProxyAvailable, |
71 | | - ); |
72 | | - if (!disposed) { |
73 | | - const token = tkPipelineRuns[1].nextPageToken; |
74 | | - const callInflight = !!tkPipelineRuns?.[2]; |
75 | | - const loaded = !callInflight; |
76 | | - if (!callInflight) { |
77 | | - setResult((cur) => [ |
78 | | - nextPageToken |
79 | | - ? [...cur[0], ...tkPipelineRuns[0]] |
80 | | - : tkPipelineRuns[0], |
81 | | - loaded, |
82 | | - undefined, |
83 | | - token |
84 | | - ? (() => { |
85 | | - // ensure we can only call this once |
86 | | - let executed = false; |
87 | | - return () => { |
88 | | - if (!disposed && !executed) { |
89 | | - executed = true; |
90 | | - // trigger the update |
91 | | - setNextPageToken(token); |
92 | | - return true; |
93 | | - } |
94 | | - return false; |
95 | | - }; |
96 | | - })() |
97 | | - : undefined, |
98 | | - ]); |
99 | | - } |
100 | | - } |
101 | | - } catch (e) { |
102 | | - if (!disposed) { |
103 | | - if (nextPageToken) { |
104 | | - setResult((cur) => [cur[0], cur[1], e, undefined]); |
105 | | - } else { |
106 | | - setResult([[], false, e, undefined]); |
107 | | - } |
108 | | - } |
109 | | - } |
110 | | - })(); |
111 | | - return () => { |
112 | | - disposed = true; |
113 | | - }; |
114 | | - }, [namespace, options, nextPageToken, localCacheKey, getRuns]); |
115 | | - return result; |
116 | | -}; |
117 | | - |
118 | | -export const useTRPipelineRuns = ( |
119 | | - namespace: string, |
120 | | - options?: TektonResultsOptions, |
121 | | - cacheKey?: string, |
122 | | -): [PipelineRunKind[], boolean, unknown, GetNextPage] => |
123 | | - useTRRuns<PipelineRunKind>(getPipelineRuns, namespace, options, cacheKey); |
124 | | - |
125 | | -export const useTRTaskRuns = ( |
126 | | - namespace: string, |
127 | | - options?: TektonResultsOptions, |
128 | | - cacheKey?: string, |
129 | | -): [TaskRunKind[], boolean, unknown, GetNextPage] => |
130 | | - useTRRuns<TaskRunKind>(getTaskRuns, namespace, options, cacheKey); |
131 | | - |
132 | 10 | export const useGetPipelineRuns = ( |
133 | 11 | ns: string, |
134 | 12 | options?: { name: string; kind: string }, |
@@ -161,56 +39,6 @@ export const useGetPipelineRuns = ( |
161 | 39 | ); |
162 | 40 | }; |
163 | 41 |
|
164 | | -export const useGetTaskRuns = ( |
165 | | - ns: string, |
166 | | - pipelineRunName?: string, |
167 | | -): [TaskRunKind[], boolean, unknown, GetNextPage] => { |
168 | | - let selector: Selector; |
169 | | - const isTektonResultEnabled = useFlag(FLAG_PIPELINE_TEKTON_RESULT_INSTALLED); |
170 | | - |
171 | | - if (pipelineRunName) { |
172 | | - selector = { |
173 | | - matchLabels: { |
174 | | - [TektonResourceLabel.pipelinerun]: pipelineRunName, |
175 | | - }, |
176 | | - }; |
177 | | - } |
178 | | - const [ |
179 | | - k8sTaskRuns, |
180 | | - k8sTaskRunsK8sLoaded, |
181 | | - k8sTaskRunsTrLoaded, |
182 | | - k8sTaskRunsLoadError, |
183 | | - ] = useTaskRuns(ns, pipelineRunName); |
184 | | - |
185 | | - /* this needs decoupling */ |
186 | | - |
187 | | - const k8sTaskRunsLoaded = k8sTaskRunsK8sLoaded && k8sTaskRunsTrLoaded; |
188 | | - const [ |
189 | | - resultTaskRuns, |
190 | | - resultTaskRunsLoaded, |
191 | | - resultTaskRunsLoadError, |
192 | | - getNextPage, |
193 | | - ] = isTektonResultEnabled |
194 | | - ? useTRTaskRuns( |
195 | | - ns, |
196 | | - pipelineRunName && { |
197 | | - selector, |
198 | | - }, |
199 | | - ) |
200 | | - : [[], true, undefined, undefined]; |
201 | | - |
202 | | - const mergedTaskRuns = |
203 | | - resultTaskRunsLoaded || k8sTaskRunsLoaded |
204 | | - ? uniqBy([...k8sTaskRuns, ...resultTaskRuns], (r) => r.metadata.uid) |
205 | | - : []; |
206 | | - return [ |
207 | | - mergedTaskRuns, |
208 | | - resultTaskRunsLoaded || k8sTaskRunsLoaded, |
209 | | - k8sTaskRunsLoadError || resultTaskRunsLoadError, |
210 | | - getNextPage, |
211 | | - ]; |
212 | | -}; |
213 | | - |
214 | 42 | export const useTRTaskRunLog = ( |
215 | 43 | namespace: string, |
216 | 44 | taskRunName: string, |
|
0 commit comments