Add test helpers to check if cluster capabilities are enabled and skip accordingly

Author: alebedev87

test/extended/util/framework.go

@@ -2404,6 +2404,27 @@ func IsCapabilityEnabled(oc *CLI, cap configv1.ClusterVersionCapability) (bool,
 	return false, nil
 }
 
+// AllCapabilitiesEnabled returns true if all of the given capabilities are enabled on the cluster.
+func AllCapabilitiesEnabled(oc *CLI, caps ...configv1.ClusterVersionCapability) (bool, error) {
+	cv, err := oc.AdminConfigClient().ConfigV1().ClusterVersions().Get(context.Background(), "version", metav1.GetOptions{})
+	if err != nil {
+		return false, err
+	}
+
+	enabledCaps := make(map[configv1.ClusterVersionCapability]struct{}, len(cv.Status.Capabilities.EnabledCapabilities))
+	for _, c := range cv.Status.Capabilities.EnabledCapabilities {
+		enabledCaps[c] = struct{}{}
+	}
+
+	for _, c := range caps {
+		if _, found := enabledCaps[c]; !found {
+			return false, nil
+		}
+	}
+
+	return true, nil
+}
+
 // SkipIfNotPlatform skip the test if supported platforms are not matched
 func SkipIfNotPlatform(oc *CLI, platforms ...configv1.PlatformType) {
 	var match bool
@@ -2420,6 +2441,15 @@ func SkipIfNotPlatform(oc *CLI, platforms ...configv1.PlatformType) {
 	}
 }
 
+// SkipIfMissingCapabilities skips the test if any of the given cluster capabilities is not enabled.
+func SkipIfMissingCapabilities(oc *CLI, caps ...configv1.ClusterVersionCapability) {
+	enabled, err := AllCapabilitiesEnabled(oc, caps...)
+	o.Expect(err).NotTo(o.HaveOccurred())
+	if !enabled {
+		g.Skip(fmt.Sprintf("Skip this test scenario because not all of the following capabilities are enabled: %v", caps))
+	}
+}
+
 // GetClusterRegion get the cluster's region
 func GetClusterRegion(oc *CLI) string {
 	region, err := oc.AsAdmin().WithoutNamespace().Run("get").Args("node", `-ojsonpath={.items[].metadata.labels.topology\.kubernetes\.io/region}`).Output()