modify setOwnerReference to accept unstructred.Unstructured

Signed-off-by: varshaprasad96 <[email protected]>

Author: varshaprasad96

internal/controller/controller.go

@@ -159,7 +159,7 @@ func watchDependentResources(mgr manager.Manager, r *HelmOperatorReconciler, c c
 				}
 
 				restMapper := mgr.GetRESTMapper()
-				useOwnerRef, err := controllerutil.SupportsOwnerReference(restMapper, owner, dependent)
+				useOwnerRef, err := controllerutil.SupportsOwnerReference(restMapper, owner, unstructuredObj)
 				if err != nil {
 					return err
 				}

pkg/client/actionclient.go

@@ -322,7 +322,7 @@ func (pr *ownerPostRenderer) Run(in *bytes.Buffer) (*bytes.Buffer, error) {
 			return err
 		}
 		u := &unstructured.Unstructured{Object: objMap}
-		useOwnerRef, err := controllerutil.SupportsOwnerReference(pr.rm, pr.owner, u)
+		useOwnerRef, err := controllerutil.SupportsOwnerReference(pr.rm, pr.owner.(*unstructured.Unstructured), u)
 		if err != nil {
 			return err
 		}

pkg/sdk/controllerutil/controllerutil.go

@@ -23,7 +23,7 @@ import (
 	apierrors "k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/apimachinery/pkg/api/meta"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	"k8s.io/apimachinery/pkg/runtime"
+	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 	"k8s.io/apimachinery/pkg/util/wait"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
@@ -57,34 +57,24 @@ func WaitForDeletion(ctx context.Context, cl client.Reader, o client.Object) err
 	}, ctx.Done())
 }
 
-func SupportsOwnerReference(restMapper meta.RESTMapper, owner, dependent runtime.Object) (bool, error) {
+func SupportsOwnerReference(restMapper meta.RESTMapper, owner, dependent *unstructured.Unstructured) (bool, error) {
 	ownerGVK := owner.GetObjectKind().GroupVersionKind()
 	ownerMapping, err := restMapper.RESTMapping(ownerGVK.GroupKind(), ownerGVK.Version)
 	if err != nil {
 		return false, err
 	}
 
-	mOwner, err := meta.Accessor(owner)
-	if err != nil {
-		return false, err
-	}
-
 	depGVK := dependent.GetObjectKind().GroupVersionKind()
 	depMapping, err := restMapper.RESTMapping(depGVK.GroupKind(), depGVK.Version)
 	if err != nil {
 		return false, err
 	}
 
-	mDep, err := meta.Accessor(dependent)
-	if err != nil {
-		return false, err
-	}
-
 	ownerClusterScoped := ownerMapping.Scope.Name() == meta.RESTScopeNameRoot
-	ownerNamespace := mOwner.GetNamespace()
+	ownerNamespace := owner.GetNamespace()
 	depClusterScoped := depMapping.Scope.Name() == meta.RESTScopeNameRoot
 
-	depNamespace := mDep.GetNamespace()
+	depNamespace := dependent.GetNamespace()
 
 	if ownerClusterScoped {
 		return true, nil

pkg/sdk/controllerutil/controllerutil_test.go

@@ -74,8 +74,8 @@ var _ = Describe("Controllerutil", func() {
 	Describe("SupportsOwnerReference", func() {
 		var (
 			rm              *meta.DefaultRESTMapper
-			owner           client.Object
-			dependent       client.Object
+			owner           *unstructured.Unstructured
+			dependent       *unstructured.Unstructured
 			clusterScoped   = schema.GroupVersionKind{Group: "example.com", Version: "v1", Kind: "ClusterScoped"}
 			namespaceScoped = schema.GroupVersionKind{Group: "example.com", Version: "v1", Kind: "NamespaceScoped"}
 		)