feat: frequency annotation helper

hauler-manifest.yaml

@@ -57,4 +57,4 @@ metadata:
 spec:
   files:
     - name: validatorctl
-      path: https://github.com/validator-labs/validatorctl/releases/download/v0.2.1/validator-linux-ARCH
+      path: https://github.com/validator-labs/validatorctl/releases/download/v0.2.2/validator-linux-ARCH

pkg/constants/constants.go

@@ -7,4 +7,7 @@ const (
 
 	// ValidatorConfig is the name of the default validator config.
 	ValidatorConfig string = "validator-config"
+
+	// ReconciliationFrequencyAnnotation is the annotation key for reconciliation frequency.
+	ReconciliationFrequencyAnnotation = "validation.validator.labs/reconciliation-frequency"
 )

pkg/plugins/plugin_frequency.go

@@ -0,0 +1,31 @@
+package plugins
+
+import (
+	"strconv"
+	"time"
+
+	"github.com/go-logr/logr"
+	"github.com/validator-labs/validator/pkg/constants"
+	ctrl "sigs.k8s.io/controller-runtime"
+)
+
+// FrequencyFromAnnotations calculates reconciliation frequency from annotations of the plugin custom resource.
+// Defaults to 120 seconds if annotation is not found.
+func FrequencyFromAnnotations(l logr.Logger, annotations map[string]string) ctrl.Result {
+	var frequency time.Duration
+	if secondsString, ok := annotations[constants.ReconciliationFrequencyAnnotation]; ok {
+		seconds, err := strconv.Atoi(secondsString)
+		if err != nil {
+			l.Error(err, "Failed to convert frequency annotation", "rescheduleSeconds", 120)
+			frequency = time.Second * 120
+		} else {
+			l.Info("Reconciliation frequency annotation found", "rescheduleSeconds", seconds)
+			frequency = time.Second * time.Duration(seconds)
+		}
+	} else {
+		l.Info("Frequency annotation not found: defaulting to 120 seconds")
+		frequency = time.Second * 120
+	}
+
+	return ctrl.Result{RequeueAfter: frequency}
+}

pkg/plugins/plugin_frequency_test.go

@@ -0,0 +1,55 @@
+package plugins
+
+import (
+	"testing"
+	"time"
+
+	ctrl "sigs.k8s.io/controller-runtime"
+)
+
+func TestFrequencyFromAnnotations(t *testing.T) {
+
+	logger := ctrl.Log.WithName("TestFrequencyAnnotation")
+
+	testCases := []struct {
+		name        string
+		annotations map[string]string
+		result      ctrl.Result
+	}{
+		{
+			name: "CorrectAnnotationValue",
+			annotations: map[string]string{
+				"validation.validator.labs/reconciliation-frequency": "20",
+			},
+			result: ctrl.Result{
+				RequeueAfter: time.Duration(time.Second * 20),
+			},
+		},
+		{
+			name: "IncorrectAnnotationValue",
+			annotations: map[string]string{
+				"validation.validator.labs/reconciliation-frequency": "nonint",
+			},
+			result: ctrl.Result{
+				RequeueAfter: time.Duration(time.Second * 120),
+			},
+		},
+		{
+			name:        "NoAnnotation",
+			annotations: map[string]string{},
+			result: ctrl.Result{
+				RequeueAfter: time.Duration(time.Second * 120),
+			},
+		},
+	}
+
+	for _, testCase := range testCases {
+		t.Run(testCase.name, func(t *testing.T) {
+			actual := FrequencyFromAnnotations(logger, testCase.annotations)
+			if actual != testCase.result {
+				t.Errorf("expected %v, got %v", testCase.result, actual)
+			}
+		})
+	}
+
+}