@@ -23,10 +23,12 @@ import (
23
23
"github.com/percona/percona-server-mongodb-operator/pkg/psmdb/mongo"
24
24
)
25
25
26
- func getInternalSecretData (secret * corev1.Secret ) map [string ][]byte {
26
+ func getInternalSecretData (cr * api. PerconaServerMongoDB , secret * corev1.Secret ) map [string ][]byte {
27
27
m := secret .DeepCopy ().Data
28
- for k , v := range secret .Data {
29
- m [k + "_ESCAPED" ] = []byte (url .QueryEscape (string (v )))
28
+ if cr .CompareVersion ("1.19.0" ) >= 0 {
29
+ for k , v := range secret .Data {
30
+ m [k + "_ESCAPED" ] = []byte (url .QueryEscape (string (v )))
31
+ }
30
32
}
31
33
return m
32
34
}
@@ -78,7 +80,7 @@ func (r *ReconcilePerconaServerMongoDB) reconcileUsers(ctx context.Context, cr *
78
80
internalSysUsersSecret .Labels = nil
79
81
}
80
82
if cr .CompareVersion ("1.19.0" ) >= 0 {
81
- internalSysUsersSecret .Data = getInternalSecretData (& sysUsersSecretObj )
83
+ internalSysUsersSecret .Data = getInternalSecretData (cr , & sysUsersSecretObj )
82
84
}
83
85
err = r .client .Create (ctx , internalSysUsersSecret )
84
86
if err != nil {
@@ -92,7 +94,7 @@ func (r *ReconcilePerconaServerMongoDB) reconcileUsers(ctx context.Context, cr *
92
94
return nil
93
95
}
94
96
95
- dataChanged , err := sysUsersSecretDataChanged (& sysUsersSecretObj , & internalSysSecretObj )
97
+ dataChanged , err := sysUsersSecretDataChanged (cr , & sysUsersSecretObj , & internalSysSecretObj )
96
98
if err != nil {
97
99
return errors .Wrap (err , "check sys users data changes" )
98
100
}
@@ -142,7 +144,7 @@ func (r *ReconcilePerconaServerMongoDB) reconcileUsers(ctx context.Context, cr *
142
144
143
145
internalSysSecretObj .Data = sysUsersSecretObj .Data
144
146
if cr .CompareVersion ("1.19.0" ) >= 0 {
145
- internalSysSecretObj .Data = getInternalSecretData (& sysUsersSecretObj )
147
+ internalSysSecretObj .Data = getInternalSecretData (cr , & sysUsersSecretObj )
146
148
}
147
149
err = r .client .Update (ctx , & internalSysSecretObj )
148
150
if err != nil {
@@ -350,8 +352,8 @@ func (u *systemUser) updateMongo(ctx context.Context, c mongo.Client) error {
350
352
return errors .Wrapf (err , "update user %s -> %s" , u .currName , u .name )
351
353
}
352
354
353
- func sysUsersSecretDataChanged (usersSecret * corev1.Secret , internalSecret * corev1.Secret ) (bool , error ) {
354
- newData := getInternalSecretData (usersSecret )
355
+ func sysUsersSecretDataChanged (cr * api. PerconaServerMongoDB , usersSecret * corev1.Secret , internalSecret * corev1.Secret ) (bool , error ) {
356
+ newData := getInternalSecretData (cr , usersSecret )
355
357
newDataJSON , err := json .Marshal (newData )
356
358
if err != nil {
357
359
return false , err
0 commit comments