Support Cloudstack multiple endpoint for preflight checks

internal/test/cleanup/cleanup.go

@@ -99,12 +99,12 @@ func CleanUpCloudstackTestResources(ctx context.Context, clusterName string, dry
 	if err != nil {
 		return fmt.Errorf("building cmk executable: %v", err)
 	}
-	cmk := executableBuilder.BuildCmkExecutable(tmpWriter, *execConfig)
+	cmk := executableBuilder.BuildCmkExecutable(tmpWriter, execConfig.Profiles)
 	defer cmk.Close(ctx)
-
-	if err := cmk.ValidateCloudStackConnection(ctx); err != nil {
-		return fmt.Errorf("validating cloudstack connection with cloudmonkey: %v", err)
+	for _, profile := range execConfig.Profiles {
+		if err := cmk.CleanupVms(ctx, profile.Name, clusterName, dryRun); err != nil {
+			cmk.Close(ctx)
+		}
 	}
-
-	return cmk.CleanupVms(ctx, clusterName, dryRun)
+	return nil
 }

pkg/dependencies/factory.go

@@ -267,6 +267,7 @@ func (f *Factory) WithProvider(clusterConfigFile string, clusterConfig *v1alpha1
 				return fmt.Errorf("unable to get machine config from file %s: %v", clusterConfigFile, err)
 			}
 
+			// map[string]*executables.Cmk and map[string]ProviderCmkClient are not compatible so we convert the map manually
 			f.dependencies.Provider = cloudstack.NewProvider(
 				datacenterConfig,
 				machineConfigs,
@@ -418,12 +419,13 @@ func (f *Factory) WithCmk() *Factory {
 		if f.dependencies.Cmk != nil {
 			return nil
 		}
+
 		execConfig, err := decoder.ParseCloudStackSecret()
 		if err != nil {
 			return fmt.Errorf("building cmk executable: %v", err)
 		}
 
-		f.dependencies.Cmk = f.executableBuilder.BuildCmkExecutable(f.dependencies.Writer, *execConfig)
+		f.dependencies.Cmk = f.executableBuilder.BuildCmkExecutable(f.dependencies.Writer, execConfig.Profiles)
 		f.dependencies.closers = append(f.dependencies.closers, f.dependencies.Cmk)
 
 		return nil

pkg/dependencies/factory_test.go

@@ -2,6 +2,7 @@ package dependencies_test
 
 import (
 	"context"
+	"encoding/base64"
 	"os"
 	"testing"
 
@@ -13,6 +14,7 @@ import (
 	"github.com/aws/eks-anywhere/pkg/cluster"
 	"github.com/aws/eks-anywhere/pkg/config"
 	"github.com/aws/eks-anywhere/pkg/dependencies"
+	"github.com/aws/eks-anywhere/pkg/providers/cloudstack/decoder"
 	"github.com/aws/eks-anywhere/pkg/version"
 	"github.com/aws/eks-anywhere/release/api/v1alpha1"
 )
@@ -107,6 +109,10 @@ func TestFactoryBuildWithClusterManagerWithoutCliConfig(t *testing.T) {
 }
 
 func TestFactoryBuildWithMultipleDependencies(t *testing.T) {
+	configString := test.ReadFile(t, "testdata/cloudstack_config_multiple_profiles.ini")
+	encodedConfig := base64.StdEncoding.EncodeToString([]byte(configString))
+	t.Setenv(decoder.EksacloudStackCloudConfigB64SecretKey, encodedConfig)
+
 	tt := newTest(t, vsphere)
 	deps, err := dependencies.NewFactory().
 		UseExecutableImage("image:1").
@@ -125,6 +131,7 @@ func TestFactoryBuildWithMultipleDependencies(t *testing.T) {
 		WithCAPIManager().
 		WithManifestReader().
 		WithUnAuthKubeClient().
+		WithCmk().
 		Build(context.Background())
 
 	tt.Expect(err).To(BeNil())

pkg/dependencies/testdata/cloudstack_config_multiple_profiles.ini

@@ -0,0 +1,11 @@
+[Global]
+verify-ssl = false
+api-key = test-key1
+secret-key = test-secret1
+api-url = http://127.16.0.1:8080/client/api
+
+[Instance2]
+verify-ssl = true
+api-key = test-key2
+secret-key = test-secret2
+api-url = http://127.16.0.2:8080/client/api

pkg/executables/builder.go

@@ -41,8 +41,8 @@ func (b *ExecutableBuilder) BuildGovcExecutable(writer filewriter.FileWriter, op
 	return NewGovc(b.buildExecutable(govcPath), writer, opts...)
 }
 
-func (b *ExecutableBuilder) BuildCmkExecutable(writer filewriter.FileWriter, execConfig decoder.CloudStackExecConfig) *Cmk {
-	return NewCmk(b.buildExecutable(cmkPath), writer, execConfig)
+func (b *ExecutableBuilder) BuildCmkExecutable(writer filewriter.FileWriter, configs []decoder.CloudStackProfileConfig) *Cmk {
+	return NewCmk(b.buildExecutable(cmkPath), writer, configs)
 }
 
 func (b *ExecutableBuilder) BuildAwsCli() *AwsCli {