revert LSO networkpolicy cases

Author: duanwei33

test/extended/storage/storage_networkpolicy.go

@@ -5,15 +5,12 @@ import (
 	"fmt"
 	"strings"
 
-	"github.com/blang/semver/v4"
 	g "github.com/onsi/ginkgo/v2"
 	o "github.com/onsi/gomega"
 	exutil "github.com/openshift/origin/test/extended/util"
-	operatorsv1alpha1 "github.com/operator-framework/api/pkg/operators/v1alpha1"
 	"k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	e2e "k8s.io/kubernetes/test/e2e/framework"
-	"sigs.k8s.io/controller-runtime/pkg/client"
 )
 
 // storage_networkpolicy.go contains tests for verifying network policy configurations
@@ -159,7 +156,6 @@ var _ = g.Describe("[sig-storage][OCPFeature:StorageNetworkPolicy] Storage Netwo
 	var (
 		oc              = exutil.NewCLI("storage-network-policy")
 		currentPlatform = e2e.TestContext.Provider
-		lsoInstallInfo  *lsoInfo // LSO installation information detected once per suite
 	)
 
 	g.BeforeEach(func() {
@@ -168,20 +164,6 @@ var _ = g.Describe("[sig-storage][OCPFeature:StorageNetworkPolicy] Storage Netwo
 		if isMicroShift {
 			g.Skip("Storage Network Policy tests are not supported on MicroShift")
 		}
-
-		// Detect LSO installation only once (cache the result)
-		if lsoInstallInfo == nil {
-			lsoInstallInfo, err = getLSOInfo(oc)
-			o.Expect(err).NotTo(o.HaveOccurred(), "Failed to detect LSO installation")
-
-			if lsoInstallInfo.Installed {
-				supported := isLSOVersionSupported(lsoInstallInfo.Version)
-				g.By(fmt.Sprintf("Detected LSO installed in namespace: %s, version: %s (network policy support: %v)",
-					lsoInstallInfo.Namespace, lsoInstallInfo.Version, supported))
-			} else {
-				g.By("LSO is not installed on this cluster")
-			}
-		}
 	})
 
 	g.It("should verify required labels for CSO related Operators", func() {
@@ -364,59 +346,6 @@ var _ = g.Describe("[sig-storage][OCPFeature:StorageNetworkPolicy] Storage Netwo
 		runResourceChecks(oc, CSIResourcesToCheck, currentPlatform)
 	})
 
-	g.It("should verify required labels for LSO related resources", func() {
-		// Skip if LSO is not installed or version is lower than 4.21.0
-		if !lsoInstallInfo.Installed {
-			g.Skip("LSO is not installed on this cluster")
-		}
-
-		if !isLSOVersionSupported(lsoInstallInfo.Version) {
-			g.Skip(fmt.Sprintf("LSO network policy support requires version >= 4.21.0, current version: %s", lsoInstallInfo.Version))
-		}
-
-		LSOResourcesToCheck := []resourceCheck{
-			{
-				ResourceType:   ResourceTypeDeployment,
-				Namespace:      lsoInstallInfo.Namespace,
-				Name:           "local-storage-operator",
-				Platform:       "all",
-				RequiredLabels: lsoOperatorRequiredLabels,
-			},
-			{
-				ResourceType:   ResourceTypeDaemonSet,
-				Namespace:      lsoInstallInfo.Namespace,
-				Name:           "diskmaker-manager",
-				Platform:       "all",
-				RequiredLabels: lsoDiskmakerRequiredLabels,
-			},
-			{
-				ResourceType:   ResourceTypeDaemonSet,
-				Namespace:      lsoInstallInfo.Namespace,
-				Name:           "diskmaker-discovery",
-				Platform:       "all",
-				RequiredLabels: lsoDiskmakerRequiredLabels,
-			},
-		}
-
-		runResourceChecks(oc, LSOResourcesToCheck, currentPlatform)
-	})
-
-	g.It("should ensure required NetworkPolicies exist with correct labels for LSO", func() {
-		// Skip if LSO is not installed or version is lower than 4.21.0
-		if !lsoInstallInfo.Installed {
-			g.Skip("LSO is not installed on this cluster")
-		}
-
-		if !isLSOVersionSupported(lsoInstallInfo.Version) {
-			g.Skip(fmt.Sprintf("LSO network policy support requires version >= 4.21.0, current version: %s", lsoInstallInfo.Version))
-		}
-
-		// Get LSO network policy check configuration
-		lsoCheck := getLSONetworkPolicyCheck(lsoInstallInfo)
-
-		verifyNetworkPolicyPodSelectors(oc, lsoCheck.Namespace, lsoCheck.RequiredPodSelectors)
-	})
-
 	g.It("should ensure required NetworkPolicies exist with correct labels", func() {
 		for _, c := range networkPolicyChecks {
 			_, err := oc.AdminKubeClient().CoreV1().Namespaces().Get(context.TODO(), c.Namespace, metav1.GetOptions{})
@@ -496,70 +425,6 @@ func runResourceChecks(oc *exutil.CLI, resources []resourceCheck, currentPlatfor
 	}
 }
 
-// isLSOVersionSupported checks if the LSO version is 4.21.0 or higher
-// Supported version formats: "4.21.0", "4.21.0-202511252120"
-func isLSOVersionSupported(versionStr string) bool {
-	// Minimum required version for LSO network policy support
-	minVersion := semver.MustParse("4.21.0")
-
-	// Parse the LSO version
-	// The version string may contain build metadata (e.g., "4.21.0-202511252120")
-	// semver.Parse handles this correctly
-	version, err := semver.Parse(versionStr)
-	if err != nil {
-		e2e.Logf("Failed to parse LSO version %q: %v", versionStr, err)
-		return false
-	}
-
-	// Compare versions: returns true if version >= minVersion
-	return version.GTE(minVersion)
-}
-
-// getLSOInfo detects if LSO is installed by searching for local-storage-operator CSV
-// across all namespaces and returns its namespace and version information
-func getLSOInfo(oc *exutil.CLI) (*lsoInfo, error) {
-	info := &lsoInfo{
-		Installed: false,
-	}
-
-	// Create controller-runtime client
-	clusterConfig := oc.AdminConfig()
-	clusterClient, err := client.New(clusterConfig, client.Options{})
-	if err != nil {
-		return info, fmt.Errorf("failed to create controller-runtime client: %v", err)
-	}
-
-	// Add operatorsv1alpha1 to scheme
-	err = operatorsv1alpha1.AddToScheme(clusterClient.Scheme())
-	if err != nil {
-		return info, fmt.Errorf("failed to add operators.coreos.com/v1alpha1 to scheme: %v", err)
-	}
-
-	// List all ClusterServiceVersions across all namespaces
-	csvList := &operatorsv1alpha1.ClusterServiceVersionList{}
-	err = clusterClient.List(context.TODO(), csvList)
-	if err != nil {
-		return info, fmt.Errorf("failed to list ClusterServiceVersions: %v", err)
-	}
-
-	// Search for local-storage-operator CSV
-	for _, csv := range csvList.Items {
-		// Match CSV name pattern: local-storage-operator.*
-		if strings.HasPrefix(csv.Name, "local-storage-operator") {
-			// Only consider CSVs in Succeeded phase
-			if csv.Status.Phase == operatorsv1alpha1.CSVPhaseSucceeded {
-				info.Installed = true
-				info.Namespace = csv.Namespace
-				info.Version = csv.Spec.Version.String()
-				return info, nil
-			}
-		}
-	}
-
-	// LSO not found or not in Succeeded phase
-	return info, nil
-}
-
 // podSelectorContainsLabels checks if actualLabels contains all key-value pairs from requiredLabels
 func podSelectorContainsLabels(actualLabels map[string]string, requiredLabels map[string]string) bool {
 	for key, value := range requiredLabels {