Skip to content

Commit 4cbc17a

Browse files
authored
CLOUDP-94119: Do not mark the CR as failed on secret absence, it could be deleted at later stage after when scram is set (#622)
1 parent eb097e4 commit 4cbc17a

File tree

2 files changed

+9
-5
lines changed

2 files changed

+9
-5
lines changed

api/v1/mongodbcommunity_types.go

-4
Original file line numberDiff line numberDiff line change
@@ -558,10 +558,6 @@ func (m MongoDBCommunity) NamespacedName() types.NamespacedName {
558558
return types.NamespacedName{Name: m.Name, Namespace: m.Namespace}
559559
}
560560

561-
func (m MongoDBCommunity) GetAgentScramCredentialsNamespacedName() types.NamespacedName {
562-
return types.NamespacedName{Name: fmt.Sprintf("%s-agent-scram-credentials", m.Name), Namespace: m.Namespace}
563-
}
564-
565561
func (m MongoDBCommunity) DesiredReplicas() int {
566562
return m.Spec.Members
567563
}

controllers/mongodb_users.go

+9-1
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,15 @@ func (r ReplicaSetReconciler) ensureUserResources(mdb mdbv1.MongoDBCommunity) er
1616
secretNamespacedName := types.NamespacedName{Name: user.PasswordSecretName, Namespace: mdb.Namespace}
1717
if _, err := secret.ReadKey(r.client, user.PasswordSecretKey, secretNamespacedName); err != nil {
1818
if apiErrors.IsNotFound(err) {
19-
return fmt.Errorf(`user password secret "%s" not found: %s`, secretNamespacedName, err)
19+
// check for SCRAM secret as well
20+
21+
scramSecretName := types.NamespacedName{Name: user.ScramCredentialsSecretName, Namespace: mdb.Namespace}
22+
_, err = r.client.GetSecret(scramSecretName)
23+
if apiErrors.IsNotFound(err) {
24+
return fmt.Errorf(`user password secret: %s and scram secret: %s not found`, secretNamespacedName, scramSecretName)
25+
}
26+
r.log.Errorf(`user password secret "%s" not found: %s`, secretNamespacedName, err)
27+
continue
2028
}
2129
return err
2230
}

0 commit comments

Comments
 (0)