feat(adapters): Extract common functionalites for reconcilation of na…

…tive policies

Signed-off-by: Anurag Rajawat <[email protected]>

pkg/adapter/common/common.go

@@ -0,0 +1,9 @@
+// SPDX-License-Identifier: Apache-2.0
+// Copyright 2023 Authors of Nimbus
+
+package common
+
+type Request struct {
+	Name      string
+	Namespace string
+}

pkg/adapter/k8s/client.go

@@ -16,6 +16,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/client"
 )
 
+// Deprecated: Use NewOrDie
 // New returns a new Kubernetes client.
 func New(scheme *runtime.Scheme) (client.Client, error) {
 	config, err := rest.InClusterConfig()
@@ -35,6 +36,7 @@ func New(scheme *runtime.Scheme) (client.Client, error) {
 	return k8sClient, nil
 }
 
+// Deprecated: Use NewDynamicClientOrDie
 // NewDynamicClient returns a Dynamic Kubernetes client.
 func NewDynamicClient() dynamic.Interface {
 	config, err := rest.InClusterConfig()
@@ -51,3 +53,41 @@ func NewDynamicClient() dynamic.Interface {
 	}
 	return clientSet
 }
+
+// NewOrDie returns a new Kubernetes client and panics if there is an error in
+// the config.
+func NewOrDie(scheme *runtime.Scheme) client.Client {
+	config, err := rest.InClusterConfig()
+	if err != nil && errors.Is(err, rest.ErrNotInCluster) {
+		kubeconfig := filepath.Join(os.Getenv("HOME"), ".kube", "config")
+		config, err = clientcmd.BuildConfigFromFlags("", kubeconfig)
+		if err != nil {
+			panic(fmt.Sprintf("failed to load kubeconfig '%v', error: %v\n", kubeconfig, err))
+		}
+	}
+	k8sClient, err := client.New(config, client.Options{
+		Scheme: scheme,
+	})
+	if err != nil {
+		panic(fmt.Sprintf("failed to create client, error: %v", err))
+	}
+	return k8sClient
+}
+
+// NewDynamicClientOrDie returns a Dynamic Kubernetes client and panics if there is an
+// error in the config.
+func NewDynamicClientOrDie() dynamic.Interface {
+	config, err := rest.InClusterConfig()
+	if err != nil && errors.Is(err, rest.ErrNotInCluster) {
+		kubeconfig := filepath.Join(os.Getenv("HOME"), ".kube", "config")
+		config, err = clientcmd.BuildConfigFromFlags("", kubeconfig)
+		if err != nil {
+			panic(err)
+		}
+	}
+	clientSet, err := dynamic.NewForConfig(config)
+	if err != nil {
+		panic(err)
+	}
+	return clientSet
+}

pkg/adapter/util/nimbuspolicy_util.go

@@ -0,0 +1,13 @@
+// SPDX-License-Identifier: Apache-2.0
+// Copyright 2023 Authors of Nimbus
+
+package util
+
+import (
+	"strings"
+)
+
+func ExtractNpName(kspName string) string {
+	words := strings.Split(kspName, "-")
+	return strings.Join(words[:len(words)-1], "-")
+}

pkg/adapter/util/watcher_util.go

@@ -0,0 +1,12 @@
+// SPDX-License-Identifier: Apache-2.0
+// Copyright 2023 Authors of Nimbus
+
+package util
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+func IsOrphan(ownerRefs []metav1.OwnerReference, ownerKind string) bool {
+	return len(ownerRefs) == 0 || ownerRefs[0].Kind != ownerKind
+}