feat: avoid kyverno dependency in tests

Author: cheina97

pkg/liqoctl/test/network/client/k8s.go

@@ -95,7 +95,7 @@ func initConfigAndClient(ctx context.Context, kubeconfig string, cl *Client, cfg
 	sname := string(name)
 
 	cfg[sname] = cfgtmp
-	if cl.ConsumerName == "" {
+	if kubeconfig == "" {
 		cl.ConsumerName = sname
 		cl.Consumer = cltmp
 		cl.ConsumerDynamic = cldyntmp

pkg/liqoctl/test/network/setup/kyverno.go

@@ -32,6 +32,23 @@ var KyvernoPolicyGroupVersionResource = schema.GroupVersionResource{Group: "kyve
 // KyvernoPolicyKind is the kind of the Kyverno policy.
 const KyvernoPolicyKind = "Policy"
 
+// IsKyvernoAvailable checks if Kyverno is available.
+func IsKyvernoAvailable(ctx context.Context, cl *client.Client) bool {
+	_, err := cl.ConsumerDynamic.Resource(KyvernoPolicyGroupVersionResource).
+		Namespace(NamespaceName).List(ctx, metav1.ListOptions{})
+	if err != nil {
+		return false
+	}
+	for k := range cl.Providers {
+		_, err := cl.ProvidersDynamic[k].Resource(KyvernoPolicyGroupVersionResource).
+			Namespace(NamespaceName).List(ctx, metav1.ListOptions{})
+		if err != nil {
+			return false
+		}
+	}
+	return true
+}
+
 // CreatePolicy creates the Kyverno policies.
 func CreatePolicy(ctx context.Context, cl *client.Client) error {
 	policy := ForgeKyvernoPodAntiaffinityPolicy(cl.ConsumerName, false)

pkg/liqoctl/test/network/setup/setup.go

@@ -25,6 +25,8 @@ import (
 
 // MakeInfrastructure sets up the infrastructure for the network tests.
 func MakeInfrastructure(ctx context.Context, cl *client.Client, opts *flags.Options) (totreplicas int32, err error) {
+	printer := opts.Topts.LocalFactory.Printer
+
 	if err := AddConsumerNodeLabels(ctx, cl); err != nil {
 		return 0, fmt.Errorf("error adding consumer node labels: %w", err)
 	}
@@ -37,8 +39,14 @@ func MakeInfrastructure(ctx context.Context, cl *client.Client, opts *flags.Opti
 		return 0, fmt.Errorf("error offloading namespace: %w", err)
 	}
 
-	if err := CreatePolicy(ctx, cl); err != nil {
-		return 0, fmt.Errorf("error creating policy: %w", err)
+	if IsKyvernoAvailable(ctx, cl) {
+		if err := CreatePolicy(ctx, cl); err != nil {
+			return 0, fmt.Errorf("error creating policy: %w", err)
+		}
+	} else {
+		printer.Logger.Warn("Kyverno not available on all clusters, skipping policy creation. " +
+			"Pods may not be scheduled on every node. Install Kyverno on all clusters for comprehensive tests. " +
+			"See https://kyverno.io/docs/installation/methods/#standalone-installation")
 	}
 
 	if totreplicas, err = CreateAllDeployments(ctx, cl); err != nil {