@@ -20,14 +20,12 @@ package controller
20
20
import (
21
21
"context"
22
22
"errors"
23
- "fmt"
24
23
"os"
25
24
"time"
26
25
27
26
"github.com/go-logr/logr"
28
27
corev1 "k8s.io/api/core/v1"
29
28
apierrs "k8s.io/apimachinery/pkg/api/errors"
30
- metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
31
29
"k8s.io/apimachinery/pkg/runtime"
32
30
ktypes "k8s.io/apimachinery/pkg/types"
33
31
"sigs.k8s.io/cluster-api/util/patch"
@@ -36,11 +34,9 @@ import (
36
34
37
35
"github.com/validator-labs/validator-plugin-azure/api/v1alpha1"
38
36
"github.com/validator-labs/validator-plugin-azure/pkg/azure"
39
- "github.com/validator-labs/validator-plugin-azure/pkg/constants"
40
37
utils "github.com/validator-labs/validator-plugin-azure/pkg/utils/azure"
41
38
vapi "github.com/validator-labs/validator/api/v1alpha1"
42
39
"github.com/validator-labs/validator/pkg/types"
43
- "github.com/validator-labs/validator/pkg/util"
44
40
vres "github.com/validator-labs/validator/pkg/validationresult"
45
41
)
46
42
@@ -91,16 +87,16 @@ func (r *AzureValidatorReconciler) Reconcile(ctx context.Context, req ctrl.Reque
91
87
return ctrl.Result {}, err
92
88
}
93
89
nn := ktypes.NamespacedName {
94
- Name : validationResultName (validator ),
90
+ Name : vres . Name (validator ),
95
91
Namespace : req .Namespace ,
96
92
}
97
93
if err := r .Get (ctx , nn , vr ); err == nil {
98
- vres .HandleExistingValidationResult (vr , r .Log )
94
+ vres .HandleExisting (vr , r .Log )
99
95
} else {
100
96
if ! apierrs .IsNotFound (err ) {
101
97
l .Error (err , "unexpected error getting ValidationResult" )
102
98
}
103
- if err := vres .HandleNewValidationResult (ctx , r .Client , p , buildValidationResult (validator ), r .Log ); err != nil {
99
+ if err := vres .HandleNew (ctx , r .Client , p , vres . Build (validator ), r .Log ); err != nil {
104
100
return ctrl.Result {}, err
105
101
}
106
102
return ctrl.Result {RequeueAfter : time .Millisecond }, nil
@@ -152,7 +148,7 @@ func (r *AzureValidatorReconciler) Reconcile(ctx context.Context, req ctrl.Reque
152
148
}
153
149
154
150
// Patch the ValidationResult with the latest ValidationRuleResults
155
- if err := vres .SafeUpdateValidationResult (ctx , p , vr , resp , r .Log ); err != nil {
151
+ if err := vres .SafeUpdate (ctx , p , vr , resp , r .Log ); err != nil {
156
152
return ctrl.Result {}, err
157
153
}
158
154
@@ -185,29 +181,3 @@ func (r *AzureValidatorReconciler) SetupWithManager(mgr ctrl.Manager) error {
185
181
For (& v1alpha1.AzureValidator {}).
186
182
Complete (r )
187
183
}
188
-
189
- func buildValidationResult (validator * v1alpha1.AzureValidator ) * vapi.ValidationResult {
190
- return & vapi.ValidationResult {
191
- ObjectMeta : metav1.ObjectMeta {
192
- Name : validationResultName (validator ),
193
- Namespace : validator .Namespace ,
194
- OwnerReferences : []metav1.OwnerReference {
195
- {
196
- APIVersion : validator .APIVersion ,
197
- Kind : validator .Kind ,
198
- Name : validator .Name ,
199
- UID : validator .UID ,
200
- Controller : util .Ptr (true ),
201
- },
202
- },
203
- },
204
- Spec : vapi.ValidationResultSpec {
205
- Plugin : constants .PluginCode ,
206
- ExpectedResults : validator .Spec .ResultCount (),
207
- },
208
- }
209
- }
210
-
211
- func validationResultName (validator * v1alpha1.AzureValidator ) string {
212
- return fmt .Sprintf ("validator-plugin-azure-%s" , validator .Name )
213
- }
0 commit comments