Added Network checks

Author: harikrishna-patnala

test/e2e/config/cloudstack.yaml

@@ -102,7 +102,7 @@ providers:
       - sourcePath: "../data/infrastructure-cloudstack/v1beta3/cluster-template-kubernetes-version-upgrade-before.yaml"
       - sourcePath: "../data/infrastructure-cloudstack/v1beta3/cluster-template-kubernetes-version-upgrade-after.yaml"
       - sourcePath: "../data/infrastructure-cloudstack/v1beta3/cluster-template-k8s-cks.yaml"
-      - sourcePath: "../data/infrastructure-cloudstack/v1beta3/cluster-template-multiple-templates.yaml"
+      - sourcePath: "../data/infrastructure-cloudstack/v1beta3/cluster-template-multiple-networks.yaml"
       - sourcePath: "../data/shared/v1beta1_provider/metadata.yaml"
     versions:
       - name: v1.0.0

test/e2e/multiple_networks.go

@@ -128,7 +128,7 @@ func MultipleNetworksSpec(ctx context.Context, inputGetter func() CommonSpecInpu
 		Expect(len(cluster.Virtualmachines)).Should(Equal(2), "Expected 2 VMs in the cluster, found %d", len(cluster.Virtualmachines))
 
 		By("Verifying that each VM has two NICs")
-		CheckIfNodesHaveTwoNICs(cluster)
+		CheckIfNodesHaveTwoNICs(cluster, input)
 
 		By("PASSED!")
 	})
@@ -139,11 +139,36 @@ func MultipleNetworksSpec(ctx context.Context, inputGetter func() CommonSpecInpu
 	})
 }
 
-func CheckIfNodesHaveTwoNICs(cluster *cloudstack.KubernetesCluster) {
+func CheckIfNodesHaveTwoNICs(cluster *cloudstack.KubernetesCluster, input CommonSpecInput) {
+	requiredNetworks := map[string]bool{
+		input.E2EConfig.GetVariable("CLOUDSTACK_NETWORK_NAME"):     false,
+		input.E2EConfig.GetVariable("CLOUDSTACK_NEW_NETWORK_NAME"): false,
+	}
+
 	for _, vm := range cluster.Virtualmachines {
 		if len(vm.Nic) < 2 {
 			Fail(fmt.Sprintf("VM %q has fewer than 2 NICs. Found: %d", vm.Name, len(vm.Nic)))
 		}
-		By(fmt.Sprintf("VM %q has %d NICs", vm.Name, len(vm.Nic)))
+
+		found := make(map[string]bool)
+		for _, nic := range vm.Nic {
+			found[nic.Networkname] = true
+		}
+
+		for req := range requiredNetworks {
+			if !found[req] {
+				Fail(fmt.Sprintf("VM %q is missing required network %q", vm.Name, req))
+			}
+		}
+
+		By(fmt.Sprintf("VM %q has required NICs: %v", vm.Name, keys(found)))
+	}
+}
+
+func keys(m map[string]bool) []string {
+	var list []string
+	for k := range m {
+		list = append(list, k)
 	}
+	return list
 }