Merge pull request #16 from PDOK/jd/simulate-k8s-validation

Get configmap names

Author: jelledijkstra97

go.mod

@@ -7,14 +7,15 @@ toolchain go1.24.2
 godebug default=go1.23
 
 require (
+	github.com/google/go-cmp v0.7.0
 	github.com/onsi/ginkgo/v2 v2.22.1
 	github.com/onsi/gomega v1.36.2
 	github.com/pkg/errors v0.9.1
+	k8s.io/api v0.32.3
 	k8s.io/apiextensions-apiserver v0.32.3
 	k8s.io/apimachinery v0.32.3
 	k8s.io/apiserver v0.32.3
 	k8s.io/client-go v0.32.3
-	k8s.io/kube-openapi v0.0.0-20241212222426-2c72e554b1e7
 	sigs.k8s.io/controller-runtime v0.20.4
 	sigs.k8s.io/kustomize/api v0.19.0
 	sigs.k8s.io/kustomize/kyaml v0.19.0
@@ -51,7 +52,6 @@ require (
 	github.com/google/btree v1.1.3 // indirect
 	github.com/google/cel-go v0.22.1 // indirect
 	github.com/google/gnostic-models v0.6.9 // indirect
-	github.com/google/go-cmp v0.7.0 // indirect
 	github.com/google/gofuzz v1.2.0 // indirect
 	github.com/google/pprof v0.0.0-20241210010833-40e02aabc2ad // indirect
 	github.com/google/uuid v1.6.0 // indirect
@@ -100,9 +100,9 @@ require (
 	gopkg.in/evanphx/json-patch.v4 v4.12.0 // indirect
 	gopkg.in/inf.v0 v0.9.1 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
-	k8s.io/api v0.32.3 // indirect
 	k8s.io/component-base v0.32.3 // indirect
 	k8s.io/klog/v2 v2.130.1 // indirect
+	k8s.io/kube-openapi v0.0.0-20241212222426-2c72e554b1e7 // indirect
 	k8s.io/utils v0.0.0-20241210054802-24370beab758 // indirect
 	sigs.k8s.io/apiserver-network-proxy/konnectivity-client v0.31.1 // indirect
 	sigs.k8s.io/json v0.0.0-20241014173422-cfa47c3a1cc8 // indirect

pkg/k8s/clientset.go

@@ -0,0 +1,53 @@
+package k8s
+
+import (
+	"context"
+	"errors"
+	v1 "k8s.io/api/core/v1"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+	"strings"
+)
+
+func GetConfigMap(k8sClient client.Client, namespace, prefix string, labels map[string]string) (*v1.ConfigMap, error) {
+	if !strings.HasSuffix(prefix, "-") {
+		prefix += "-"
+	}
+
+	configMapList := &v1.ConfigMapList{}
+	err := k8sClient.List(context.TODO(), configMapList, client.InNamespace(namespace), client.MatchingLabels(labels))
+	if err != nil {
+		return nil, err
+	}
+
+	for _, configMap := range configMapList.Items {
+		// If the name contains "-" after the prefix, it means that the prefix is longer
+		// Example 'blobs' and 'blobs-premium'
+		if strings.HasPrefix(configMap.Name, prefix) && !strings.Contains(configMap.Name[len(prefix):], "-") {
+			return &configMap, nil
+		}
+	}
+
+	return nil, errors.New("no configmap found with prefix " + prefix)
+}
+
+func GetSecret(k8sClient client.Client, namespace, prefix string, labels map[string]string) (*v1.Secret, error) {
+	if !strings.HasSuffix(prefix, "-") {
+		prefix += "-"
+	}
+
+	secretList := &v1.SecretList{}
+	err := k8sClient.List(context.TODO(), secretList, client.InNamespace(namespace), client.MatchingLabels(labels))
+	if err != nil {
+		return nil, err
+	}
+
+	for _, secret := range secretList.Items {
+		// If the name contains "-" after the prefix, it means that the prefix is longer
+		// Example 'blobs' and 'blobs-premium'
+		if strings.HasPrefix(secret.Name, prefix) && !strings.Contains(secret.Name[len(prefix):], "-") {
+			return &secret, nil
+		}
+	}
+
+	return nil, errors.New("no secret found with prefix " + prefix)
+}

pkg/k8s/diff.go

@@ -0,0 +1,26 @@
+package k8s
+
+import (
+	"context"
+	"github.com/google/go-cmp/cmp"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+	"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
+	"sigs.k8s.io/controller-runtime/pkg/log"
+)
+
+func ShowDiff(ctx context.Context, k8sClient client.Client, obj client.Object, f controllerutil.MutateFn) {
+	lgr := log.FromContext(ctx)
+
+	err := k8sClient.Get(ctx, client.ObjectKeyFromObject(obj), obj)
+	if err != nil {
+		// Object not found, not able to show diff
+		return
+	}
+
+	current := obj.DeepCopyObject().(client.Object)
+	_ = f()
+
+	if diff := cmp.Diff(current, obj); diff != "" {
+		lgr.Info(diff)
+	}
+}