Add scalablity test with fakeIPA

Signed-off-by: Mohammed Boukhalfa <[email protected]>

Author: mboukhalfa

scripts/ci-e2e.sh

@@ -20,8 +20,8 @@ source "${REPO_ROOT}/scripts/environment.sh"
 # Clone dev-env repo
 sudo mkdir -p ${WORKING_DIR}
 sudo chown "${USER}":"${USER}" ${WORKING_DIR}
-M3_DEV_ENV_REPO="https://github.com/metal3-io/metal3-dev-env.git"
-M3_DEV_ENV_BRANCH=main
+M3_DEV_ENV_REPO="https://github.com/Nordix/metal3-dev-env.git"
+M3_DEV_ENV_BRANCH=Integrate-fakeIPA/mohammed
 M3_DEV_ENV_PATH="${M3_DEV_ENV_PATH:-${WORKING_DIR}/metal3-dev-env}"
 clone_repo "${M3_DEV_ENV_REPO}" "${M3_DEV_ENV_BRANCH}" "${M3_DEV_ENV_PATH}"
 
@@ -33,6 +33,8 @@ export NUM_NODES=${NUM_NODES:-"4"}
 export KUBERNETES_VERSION=${KUBERNETES_VERSION}
 export IMAGE_OS=${IMAGE_OS}
 export FORCE_REPO_UPDATE="false"
+export VM_PLATFORM="fake"
+export FAKE_IPA_I="192.168.111.1:5000/localimages/fake-ipa"
 EOF
 if [[ ${GINKGO_FOCUS:-} == "features" ]]; then
     mkdir -p "$CAPI_CONFIG_FOLDER"
@@ -65,6 +67,8 @@ source "${M3_DEV_ENV_PATH}/lib/releases.sh"
 source "${M3_DEV_ENV_PATH}/lib/ironic_basic_auth.sh"
 # shellcheck disable=SC1091,SC1090
 source "${M3_DEV_ENV_PATH}/lib/ironic_tls_setup.sh"
+# shellcheck disable=SC1091,SC1090
+source "/tmp/vars_cluster.sh"
 
 # image for live iso testing
 export LIVE_ISO_IMAGE="https://artifactory.nordix.org/artifactory/metal3/images/iso/minimal_linux_live-v2.iso"

test/e2e/pivoting_based_feature_test.go

@@ -13,6 +13,9 @@ import (
 	"sigs.k8s.io/cluster-api/test/framework"
 	"sigs.k8s.io/cluster-api/test/framework/clusterctl"
 	"sigs.k8s.io/controller-runtime/pkg/client"
+	clusterv1 "sigs.k8s.io/cluster-api/api/v1beta1"
+	infrav1 "github.com/metal3-io/cluster-api-provider-metal3/api/v1beta1"
+	"net/http"
 )
 
 var (
@@ -192,6 +195,27 @@ func createTargetCluster(k8sVersion string) (framework.ClusterProxy, *clusterctl
 			ControlPlaneMachineCount: &controlPlaneMachineCount,
 			WorkerMachineCount:       &workerMachineCount,
 		},
+		PreWaitForCluster: func () {
+			// get bmh
+			// get m3m
+			// waiting machine
+			By("Waiting for all Machines to be provisioning")
+			WaitForNumMachinesInState(ctx, clusterv1.MachinePhaseProvisioning, WaitForNumInput{
+				Client:    bootstrapClusterProxy.GetClient(),
+				Options:   []client.ListOption{client.InNamespace(namespace)},
+				Replicas:  1,
+				Intervals:  e2eConfig.GetIntervals(specName, "wait-machine-remediation"),
+			})
+
+			metal3Machines := infrav1.Metal3MachineList{}
+			bootstrapClusterProxy.GetClient().List(ctx, &metal3Machines, []client.ListOption{client.InNamespace(namespace)}...)
+			for _, m3machine := range metal3Machines.Items {
+				providerID:="metal3://metal3/"+Metal3MachineToBmhName(m3machine)+"/"+m3machine.GetName()
+				machine, _ := Metal3MachineToMachineName(m3machine)
+				resp, err :=http.Get("http://localhost:3333/updateNode?resource=metal3/test1&nodeName="+machine+"&providerID="+providerID)
+				Logf("resp : %v err: %v", resp, err)
+			}
+		},
 		WaitForClusterIntervals:      e2eConfig.GetIntervals(specName, "wait-cluster"),
 		WaitForControlPlaneIntervals: e2eConfig.GetIntervals(specName, "wait-control-plane"),
 		WaitForMachineDeployments:    e2eConfig.GetIntervals(specName, "wait-worker-nodes"),