Skip to content

Commit 7dc744f

Browse files
committed
fix:issue-5041
Signed-off-by: cndoit18 <[email protected]>
1 parent 2781cf8 commit 7dc744f

File tree

3 files changed

+38
-6
lines changed

3 files changed

+38
-6
lines changed

Diff for: changelog/fragments/helm-deepequals.yaml

+4
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
entries:
2+
- description: >
3+
For Helm-based operators, fixed a bug where getting a new helm release revision for every reconciliation, even there are no changes at all.
4+
kind: bugfix

Diff for: internal/helm/release/manager.go

+17-3
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,6 @@ import (
3232
"helm.sh/helm/v3/pkg/storage/driver"
3333
apiextv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
3434
apiextv1beta1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1"
35-
apiequality "k8s.io/apimachinery/pkg/api/equality"
3635
apierrors "k8s.io/apimachinery/pkg/api/errors"
3736
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
3837
"k8s.io/apimachinery/pkg/runtime"
@@ -44,6 +43,7 @@ import (
4443

4544
"github.com/operator-framework/operator-sdk/internal/helm/internal/types"
4645
"github.com/operator-framework/operator-sdk/internal/helm/manifestutil"
46+
"k8s.io/apimachinery/pkg/conversion"
4747
)
4848

4949
// Manager manages a Helm release. It can install, upgrade, reconcile,
@@ -135,6 +135,19 @@ func notFoundErr(err error) bool {
135135
return err != nil && strings.Contains(err.Error(), "not found")
136136
}
137137

138+
var equalities = conversion.EqualitiesOrDie(func(a, b *cpb.Chart) bool {
139+
if a == nil || b == nil {
140+
return a == nil && b == nil
141+
}
142+
aencode := &bytes.Buffer{}
143+
bencode := &bytes.Buffer{}
144+
145+
_ = json.NewEncoder(aencode).Encode(a)
146+
_ = json.NewEncoder(bencode).Encode(b)
147+
148+
return aencode.String() == bencode.String()
149+
})
150+
138151
func (m manager) isUpgrade(deployedRelease *rpb.Release) bool {
139152
if deployedRelease == nil {
140153
return false
@@ -143,8 +156,9 @@ func (m manager) isUpgrade(deployedRelease *rpb.Release) bool {
143156
// Judging whether to skip updates
144157
skip := m.namespace == deployedRelease.Namespace
145158
skip = skip && m.releaseName == deployedRelease.Name
146-
skip = skip && apiequality.Semantic.DeepEqual(m.chart, deployedRelease.Chart)
147-
skip = skip && apiequality.Semantic.DeepEqual(m.values, deployedRelease.Config)
159+
160+
skip = skip && equalities.DeepEqual(m.chart, deployedRelease.Chart)
161+
skip = skip && equalities.DeepEqual(m.values, deployedRelease.Config)
148162

149163
return !skip
150164
}

Diff for: internal/helm/release/manager_test.go

+17-3
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,8 @@
1515
package release
1616

1717
import (
18+
"bytes"
19+
"encoding/json"
1820
"testing"
1921

2022
"github.com/stretchr/testify/assert"
@@ -247,11 +249,20 @@ func TestManagerisUpgrade(t *testing.T) {
247249
name: "different values",
248250
releaseName: "deployed",
249251
releaseNs: "deployed-ns",
250-
values: map[string]interface{}{"key": "1"},
252+
values: map[string]interface{}{"key": "1", "int": int32(1)},
251253
chart: newTestChart(t, "./testdata/simple"),
252-
deployedRelease: newTestRelease(newTestChart(t, "./testdata/simple"), map[string]interface{}{"key": ""}, "deployed", "deployed-ns"),
254+
deployedRelease: newTestRelease(newTestChart(t, "./testdata/simple"), map[string]interface{}{"key": "", "int": int64(1)}, "deployed", "deployed-ns"),
253255
want: true,
254256
},
257+
{
258+
name: "nil values",
259+
releaseName: "deployed",
260+
releaseNs: "deployed-ns",
261+
values: nil,
262+
chart: newTestChart(t, "./testdata/simple"),
263+
deployedRelease: newTestRelease(newTestChart(t, "./testdata/simple"), map[string]interface{}{}, "deployed", "deployed-ns"),
264+
want: false,
265+
},
255266
}
256267
for _, test := range tests {
257268
t.Run(test.name, func(t *testing.T) {
@@ -277,9 +288,12 @@ func newTestRelease(chart *cpb.Chart, values map[string]interface{}, name, names
277288
release := rpb.Mock(&rpb.MockReleaseOptions{
278289
Name: name,
279290
Namespace: namespace,
280-
Chart: chart,
281291
Version: 1,
282292
})
293+
294+
buffer := &bytes.Buffer{}
295+
_ = json.NewEncoder(buffer).Encode(chart)
296+
_ = json.NewDecoder(buffer).Decode(release.Chart)
283297
release.Config = values
284298
return release
285299
}

0 commit comments

Comments
 (0)