fix: resolve PV name before comparing to KName

internal/controllers/vgmanager/devices.go

@@ -206,7 +206,7 @@ func isDeviceAlreadyPartOfVG(nodeStatus *lvmv1alpha1.LVMVolumeGroupNodeStatus, d
 	for _, vgStatus := range nodeStatus.Spec.LVMVGStatus {
 		if vgStatus.Name == volumeGroup.Name {
 			for _, pv := range vgStatus.Devices {
-				if pv == diskName {
+				if resolvedPV, _ := evalSymlinks(pv); resolvedPV == diskName {
 					return true
 				}
 			}

internal/controllers/vgmanager/filter/filter.go

@@ -19,6 +19,7 @@ package filter
 import (
 	"errors"
 	"fmt"
+	"path/filepath"
 	"strings"
 
 	lvmv1alpha1 "github.com/openshift/lvm-operator/api/v1alpha1"
@@ -55,6 +56,9 @@ var (
 	}
 )
 
+// evalSymlinks redefined to be able to override in tests
+var evalSymlinks = filepath.EvalSymlinks
+
 type Filter func(lsblk.BlockDevice, []lvm.PhysicalVolume, lsblk.BlockDeviceInfos) error
 
 type Filters map[string]Filter
@@ -102,7 +106,11 @@ func DefaultFilters(vg *lvmv1alpha1.LVMVolumeGroup) Filters {
 			if dev.FSType == FSTypeLVM2Member {
 				var foundPV *lvm.PhysicalVolume
 				for _, pv := range pvs {
-					if pv.PvName == dev.KName {
+					resolvedPVPath, err := evalSymlinks(pv.PvName)
+					if err != nil {
+						return fmt.Errorf("the pv %s could not be resolved via symlink: %w", pv, err)
+					}
+					if resolvedPVPath == dev.KName {
 						foundPV = &pv
 						break
 					}

internal/controllers/vgmanager/filter/filter_test.go

@@ -188,6 +188,9 @@ func TestOnlyValidFilesystemSignatures(t *testing.T) {
 			lvmExpect: []lvm.PhysicalVolume{{PvName: "dev1", VgName: "vg1"}},
 		},
 	}
+	evalSymlinks = func(path string) (string, error) {
+		return path, nil
+	}
 	for _, tc := range testcases {
 		t.Run(tc.label, func(t *testing.T) {
 			vg := &lvmv1alpha1.LVMVolumeGroup{}