refactor: extract AsOwnerInfo

internal/dao/pod.go

@@ -332,34 +332,13 @@ func (p *Pod) Scan(ctx context.Context, gvr client.GVR, fqn string, wait bool) (
 
 // GetOwners returns the owners of the resource.
 func (p *Pod) GetOwners(path string) ([]OwnerInfo, error) {
-	var owners []OwnerInfo
-
 	pod, err := p.GetInstance(path)
 	if err != nil {
 		return nil, err
 	}
 	ownerRefs := pod.GetObjectMeta().GetOwnerReferences()
 
-	for _, ownerRef := range ownerRefs {
-		gvr, namespaced, err := GVRForKind(ownerRef.APIVersion, ownerRef.Kind)
-		if err != nil {
-			return nil, err
-		}
-
-		var ownerFQN string
-		if namespaced {
-			ownerFQN = FQN(pod.Namespace, ownerRef.Name)
-		} else {
-			ownerFQN = ownerRef.Name
-		}
-
-		owners = append(owners, OwnerInfo{
-			GVR: gvr,
-			FQN: ownerFQN,
-		})
-	}
-
-	return owners, nil
+	return AsOwnerInfo(ownerRefs, pod.Namespace)
 }
 
 // ----------------------------------------------------------------------------

internal/dao/rs.go

@@ -130,34 +130,13 @@ func (r *ReplicaSet) Rollback(fqn string) error {
 
 // GetOwners returns the owners of the resource.
 func (r *ReplicaSet) GetOwners(path string) ([]OwnerInfo, error) {
-	var owners []OwnerInfo
-
 	rs, err := r.GetInstance(path)
 	if err != nil {
 		return nil, err
 	}
 	ownerRefs := rs.GetObjectMeta().GetOwnerReferences()
 
-	for _, ownerRef := range ownerRefs {
-		gvr, namespaced, err := GVRForKind(ownerRef.APIVersion, ownerRef.Kind)
-		if err != nil {
-			return nil, err
-		}
-
-		var ownerFQN string
-		if namespaced {
-			ownerFQN = FQN(rs.Namespace, ownerRef.Name)
-		} else {
-			ownerFQN = ownerRef.Name
-		}
-
-		owners = append(owners, OwnerInfo{
-			GVR: gvr,
-			FQN: ownerFQN,
-		})
-	}
-
-	return owners, nil
+	return AsOwnerInfo(ownerRefs, rs.Namespace)
 }
 
 func (r *ReplicaSet) GetInstance(fqn string) (*appsv1.ReplicaSet, error) {

internal/dao/types.go

@@ -188,3 +188,29 @@ type Owned interface {
 	// GetOwners returns the owners of the resource.
 	GetOwners(path string) ([]OwnerInfo, error)
 }
+
+// AsOwnerInfo converts metav1.OwnerReference entries to gvr and fqn owner information.
+func AsOwnerInfo(ownerRefs []metav1.OwnerReference, namespace string) ([]OwnerInfo, error) {
+	var owners []OwnerInfo
+
+	for _, ownerRef := range ownerRefs {
+		gvr, namespaced, err := GVRForKind(ownerRef.APIVersion, ownerRef.Kind)
+		if err != nil {
+			return nil, err
+		}
+
+		var ownerFQN string
+		if namespaced {
+			ownerFQN = FQN(namespace, ownerRef.Name)
+		} else {
+			ownerFQN = ownerRef.Name
+		}
+
+		owners = append(owners, OwnerInfo{
+			GVR: gvr,
+			FQN: ownerFQN,
+		})
+	}
+
+	return owners, nil
+}