@@ -6,6 +6,7 @@ package controllers
6
6
import (
7
7
"context"
8
8
"errors"
9
+ "fmt"
9
10
"time"
10
11
11
12
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -91,8 +92,8 @@ func (r *VaultConnectionReconciler) Reconcile(ctx context.Context, req ctrl.Requ
91
92
newConditionNow (o , "VaultClient" ,
92
93
consts .ReasonVaultClientConfigError ,
93
94
metav1 .ConditionFalse ,
94
- "Failed to setup Vault client, address=%s, errs =%s" ,
95
- o .Spec .Address , errs ),
95
+ "Failed to setup Vault client, address=%s, err =%s" ,
96
+ o .Spec .Address , err ),
96
97
)
97
98
98
99
errs = errors .Join (errs , err )
@@ -115,7 +116,7 @@ func (r *VaultConnectionReconciler) Reconcile(ctx context.Context, req ctrl.Requ
115
116
} else {
116
117
o .Status .Valid = ptr .To (true )
117
118
o .Status .Conditions = append (o .Status .Conditions ,
118
- newConditionNow (o , "VaultPing" , consts .ReasonInvalidConfiguration ,
119
+ newConditionNow (o , "VaultPing" , consts .ReasonAccepted ,
119
120
metav1 .ConditionTrue , "Vault ping, address=%s" ,
120
121
o .Spec .Address ),
121
122
)
@@ -136,11 +137,16 @@ func (r *VaultConnectionReconciler) Reconcile(ctx context.Context, req ctrl.Requ
136
137
errs = errors .Join (errs , err )
137
138
}
138
139
139
- // TODO: cleanup error reporting
140
140
var horizon time.Duration
141
- if errs != nil || ! * o .Status .Valid {
141
+
142
+ isValid := ptr .Deref (o .Status .Valid , false )
143
+ if ! isValid {
144
+ errs = errors .Join (errs , fmt .Errorf ("invalid VaultConnection %s" , client .ObjectKeyFromObject (o )))
145
+ }
146
+
147
+ if errs != nil {
142
148
logger .Error (errs , "Resource validation failed" )
143
- r .Recorder .Event (o , corev1 .EventTypeWarning , consts .ReasonAccepted , "VaultConnection invalid" )
149
+ r .Recorder .Event (o , corev1 .EventTypeWarning , consts .ReasonInvalidConfiguration , "VaultConnection invalid" )
144
150
horizon = computeHorizonWithJitter (requeueDurationOnError )
145
151
o .Status .Conditions = append (o .Status .Conditions ,
146
152
newConditionNow (o , consts .TypeResourceValidation , consts .ReasonInvalidConfiguration ,
@@ -152,8 +158,7 @@ func (r *VaultConnectionReconciler) Reconcile(ctx context.Context, req ctrl.Requ
152
158
}
153
159
154
160
if err := r .updateStatus (ctx , o ); err != nil {
155
- errs = errors .Join (errs , err )
156
- return ctrl.Result {}, errs
161
+ return ctrl.Result {}, errors .Join (errs , err )
157
162
}
158
163
159
164
return ctrl.Result {
0 commit comments