@@ -29,8 +29,6 @@ Tracing.initialize()
29
29
werft = new Werft ( "delete-preview-environment-cron" ) ;
30
30
} )
31
31
. then ( ( ) => deletePreviewEnvironments ( ) )
32
- . then ( ( ) => cleanLoadbalancer ( ) )
33
- . then ( ( ) => removeOrphanCertificates ( ) )
34
32
. catch ( ( err ) => {
35
33
werft . rootSpan . setStatus ( {
36
34
code : SpanStatusCode . ERROR ,
@@ -228,93 +226,6 @@ async function removePreviewEnvironment(previewEnvironment: PreviewEnvironment)
228
226
}
229
227
}
230
228
231
- async function removeOrphanCertificates ( ) {
232
- const certificatesNamespace = "certs" ;
233
- werft . phase ( SLICES . DELETING_ORPHAN_CERTIFICATES ) ;
234
-
235
- const certificates = exec (
236
- `kubectl --kubeconfig ${ CORE_DEV_KUBECONFIG_PATH } get certificates -n ${ certificatesNamespace } -o=custom-columns=:metadata.name | grep harvester-` ,
237
- { slice : SLICES . DELETING_ORPHAN_CERTIFICATES , silent : true , async : false } ,
238
- )
239
- . stdout . trim ( )
240
- . split ( "\n" ) ;
241
-
242
- const previews = exec (
243
- `kubectl --kubeconfig ${ HARVESTER_KUBECONFIG_PATH } get ns -o=custom-columns=:metadata.name | grep preview-` ,
244
- { slice : SLICES . DELETING_ORPHAN_CERTIFICATES , silent : true , async : false } ,
245
- )
246
- . stdout . trim ( )
247
- . replace ( / p r e v i e w - / g, "" )
248
- . split ( "\n" ) ;
249
-
250
- certificates . forEach ( ( certificate ) => {
251
- const owner = exec (
252
- `kubectl --kubeconfig ${ CORE_DEV_KUBECONFIG_PATH } get certificates ${ certificate } -n ${ certificatesNamespace } -o=custom-columns=:metadata.annotations.preview/owner` ,
253
- { slice : SLICES . DELETING_ORPHAN_CERTIFICATES , silent : true , async : false } ,
254
- ) . stdout . trim ( ) ;
255
-
256
- if ( DRY_RUN ) {
257
- if ( ! previews . includes ( owner ) ) {
258
- werft . log ( SLICES . DELETING_ORPHAN_CERTIFICATES , `Certificate ${ certificate } would have been deleted` ) ;
259
- } else {
260
- werft . log (
261
- SLICES . DELETING_ORPHAN_CERTIFICATES ,
262
- `Certificate ${ certificate } would NOT have been deleted` ,
263
- ) ;
264
- }
265
- }
266
-
267
- if ( ! previews . includes ( owner ) && ! DRY_RUN ) {
268
- exec (
269
- `kubectl --kubeconfig ${ CORE_DEV_KUBECONFIG_PATH } -n ${ certificatesNamespace } delete --ignore-not-found=true cert ${ certificate } ` ,
270
- { slice : SLICES . DELETING_ORPHAN_CERTIFICATES , async : true , silent : true } ,
271
- ) ;
272
- }
273
- } ) ;
274
-
275
- werft . done ( SLICES . DELETING_ORPHAN_CERTIFICATES ) ;
276
- }
277
-
278
- async function cleanLoadbalancer ( ) {
279
- const fetchPhase = "fetching unuse loadbalancer" ;
280
- const deletionPhase = "deleting unused load balancers" ;
281
-
282
- werft . phase ( fetchPhase ) ;
283
- let lbsToDelete : string [ ] ;
284
- try {
285
- // get all loadbalancer
286
- let lbs : string [ ] = exec (
287
- `kubectl --kubeconfig ${ CORE_DEV_KUBECONFIG_PATH } get deployment -n loadbalancers -o=jsonpath="{.items[*].metadata.labels['gitpod\\.io\\/lbName']}"` ,
288
- { silent : true } ,
289
- )
290
- . stdout . trim ( )
291
- . split ( " " ) ;
292
- let previews = exec (
293
- `kubectl --kubeconfig ${ HARVESTER_KUBECONFIG_PATH } get namespaces -o go-template --template '{{range .items}}{{.metadata.name}}{{"\\n"}}{{end}}' | awk '/(preview-.*)/ { print $1 }'` ,
294
- { silent : true } ,
295
- )
296
- . stdout . trim ( )
297
- . split ( "\n" ) ;
298
- let previewSet = new Set ( previews ) ;
299
- lbsToDelete = lbs . filter ( ( lb ) => ! previewSet . has ( "preview-" + lb ) ) ;
300
- lbsToDelete . forEach ( ( lb ) => werft . log ( fetchPhase , "will delete " + lb ) ) ;
301
- } catch ( err ) {
302
- werft . fail ( fetchPhase , err ) ;
303
- }
304
-
305
- werft . phase ( deletionPhase ) ;
306
- try {
307
- lbsToDelete . forEach ( ( lb ) => {
308
- werft . log ( deletionPhase , "deleteing " + lb ) ;
309
- exec ( `kubectl --kubeconfig ${ CORE_DEV_KUBECONFIG_PATH } -n loadbalancers delete deployment lb-${ lb } ` ) ;
310
- exec ( `kubectl --kubeconfig ${ CORE_DEV_KUBECONFIG_PATH } -n loadbalancers delete service lb-${ lb } ` ) ;
311
- } ) ;
312
- } catch ( err ) {
313
- werft . fail ( deletionPhase , err ) ;
314
- }
315
- werft . done ( deletionPhase ) ;
316
- }
317
-
318
229
function getAllBranches ( ) : string [ ] {
319
230
return exec (
320
231
`git branch -r | grep -v '\\->' | sed "s,\\x1B\\[[0-9;]*[a-zA-Z],,g" | while read remote; do echo "\${remote#origin/}"; done` ,
0 commit comments