Skip to content

Commit 15d15c2

Browse files
Fix cluster upgrade issues (#22)
Signed-off-by: RokibulHasan7 <mdrokibulhasan@appscode.com>
1 parent fa46965 commit 15d15c2

File tree

4 files changed

+19
-7
lines changed

4 files changed

+19
-7
lines changed

pkg/cluster_upgrade/upgrader.go

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@ package cluster_upgrade
1818

1919
import (
2020
"context"
21+
"errors"
2122
"fmt"
2223

2324
profilev1alpha1 "github.com/kluster-manager/cluster-profile/apis/profile/v1alpha1"
@@ -65,7 +66,14 @@ func UpgradeCluster(profileBinding *profilev1alpha1.ManagedClusterProfileBinding
6566
}
6667

6768
var overrideValues map[string]interface{}
68-
if overrideValues, err = InstallOpscenterFeaturesOnFakeServer(fakeServer, &profileBinding.Spec.ClusterMetadata, &chartRef); err != nil {
69+
if profileBinding.Spec.Features == nil || profileBinding.Spec.Features[hub.ChartOpscenterFeatures].Values == nil {
70+
return errors.New("no values found in profileBinding")
71+
}
72+
if err := json.Unmarshal(profileBinding.Spec.Features[hub.ChartOpscenterFeatures].Values.Raw, &overrideValues); err != nil {
73+
return fmt.Errorf("failed to unmarshal JSON: %w", err)
74+
}
75+
76+
if overrideValues, err = InstallOpscenterFeaturesOnFakeServer(fakeServer, overrideValues, &profileBinding.Spec.ClusterMetadata, &chartRef); err != nil {
6977
return err
7078
}
7179

pkg/cluster_upgrade/upgrader_helper.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -99,8 +99,7 @@ func createConfigMapInSpokeClusterNamespace(kc client.Client, ver, clusterName s
9999
return &cm, nil
100100
}
101101

102-
func InstallOpscenterFeaturesOnFakeServer(fakeServer *feature_installer.FakeServer, clusterMetadata *kmapi.ClusterInfo, chartRef *releasesapi.ChartSourceRef) (map[string]interface{}, error) {
103-
overrides := make(map[string]interface{})
102+
func InstallOpscenterFeaturesOnFakeServer(fakeServer *feature_installer.FakeServer, overrides map[string]interface{}, clusterMetadata *kmapi.ClusterInfo, chartRef *releasesapi.ChartSourceRef) (map[string]interface{}, error) {
104103
overrides, err := feature_installer.GetOverrideValues(overrides, clusterMetadata)
105104
if err != nil {
106105
return nil, err

pkg/feature_installer/opscenter_features.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,11 @@ func InstallOpscenterFeaturesOnFakeServer(fakeServer *FakeServer, profile *profi
6868

6969
if profileBinding != nil && profileBinding.Spec.Features != nil && profileBinding.Spec.Features["opscenter-features"].Values != nil {
7070
overrideValues = profileBinding.Spec.Features["opscenter-features"].Values.Raw
71+
72+
// Unmarshal overrideValues back into overrides
73+
if err := json.Unmarshal(overrideValues, &overrides); err != nil {
74+
return nil, err
75+
}
7176
}
7277

7378
if err := InstallOpscenterFeatures(overrideValues, fakeServer, chartRef); err != nil {

pkg/utils/client.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -65,10 +65,10 @@ func GetNewRuntimeClient(restConfig *rest.Config) (client.Client, error) {
6565
return client.New(restConfig, client.Options{
6666
Scheme: scheme,
6767
Mapper: mapper,
68-
WarningHandler: client.WarningHandlerOptions{
69-
SuppressWarnings: true,
70-
AllowDuplicateLogs: false,
71-
},
68+
//WarningHandler: client.WarningHandlerOptions{
69+
// SuppressWarnings: true,
70+
// AllowDuplicateLogs: false,
71+
//},
7272
})
7373
}
7474

0 commit comments

Comments
 (0)