-
Notifications
You must be signed in to change notification settings - Fork 66
/
util.go
118 lines (97 loc) · 3.81 KB
/
util.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
/*
Copyright 2021 The cert-manager Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package bundle
import (
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
trustapi "github.com/cert-manager/trust-manager/pkg/apis/trust/v1alpha1"
)
// bundleHasCondition returns true if the bundle has an exact matching condition.
// The given condition will have the ObservedGeneration set to the bundle Generation.
// The LastTransitionTime is ignored.
func bundleHasCondition(
existingConditions []trustapi.BundleCondition,
searchCondition trustapi.BundleCondition,
) bool {
for _, existingCondition := range existingConditions {
if existingCondition.Type == searchCondition.Type {
// Compare all fields except LastTransitionTime
// We ignore the LastTransitionTime as this is set by the controller
return existingCondition.Status == searchCondition.Status &&
existingCondition.Reason == searchCondition.Reason &&
existingCondition.Message == searchCondition.Message &&
existingCondition.ObservedGeneration == searchCondition.ObservedGeneration
}
}
return false
}
// setBundleCondition updates the bundle with the given condition.
// Will overwrite any existing condition of the same type.
// LastTransitionTime will not be updated if an existing condition of the same
// Type and Status already exists.
func (b *bundle) setBundleCondition(
existingConditions []trustapi.BundleCondition,
patchConditions *[]trustapi.BundleCondition,
newCondition trustapi.BundleCondition,
) trustapi.BundleCondition {
newCondition.LastTransitionTime = metav1.Time{Time: b.clock.Now()}
// Reset the LastTransitionTime if the status hasn't changed
for _, cond := range existingConditions {
if cond.Type != newCondition.Type {
continue
}
// If this update doesn't contain a state transition, we don't update
// the conditions LastTransitionTime to Now()
if cond.Status == newCondition.Status {
newCondition.LastTransitionTime = cond.LastTransitionTime
}
}
// Search through existing conditions
for idx, cond := range *patchConditions {
// Skip unrelated conditions
if cond.Type != newCondition.Type {
continue
}
// Overwrite the existing condition
(*patchConditions)[idx] = newCondition
return newCondition
}
// If we've not found an existing condition of this type, we simply insert
// the new condition into the slice.
*patchConditions = append(*patchConditions, newCondition)
return newCondition
}
// setBundleStatusDefaultCAVersion ensures that the given Bundle's Status correctly
// reflects the defaultCAVersion represented by requiredID.
// Returns true if the bundle status needs updating.
func (b *bundle) setBundleStatusDefaultCAVersion(
bundleStatus *trustapi.BundleStatus,
requiredID string,
) bool {
currentVersion := bundleStatus.DefaultCAPackageVersion
// If both are empty, we don't need to update
if len(requiredID) == 0 && currentVersion == nil {
return false
}
// If requiredID is empty, we need to update if currentVersion is not
if len(requiredID) == 0 && currentVersion != nil {
bundleStatus.DefaultCAPackageVersion = nil
return true
}
// If requiredID is not empty, we need to update if currentVersion is empty or
// if currentVersion is not equal to requiredID
if currentVersion == nil || *currentVersion != requiredID {
bundleStatus.DefaultCAPackageVersion = &requiredID
return true
}
return false
}