fix e2e tests

Signed-off-by: Jorge Turrado <jorge_turrado@hotmail.es>

tests/scalers/azure/azure_blob_aad_wi/azure_blob_aad_wi_test.go

@@ -18,6 +18,7 @@ import (
 	"k8s.io/client-go/kubernetes"
 
 	. "github.com/kedacore/keda/v2/tests/helper"
+	azurehelper "github.com/kedacore/keda/v2/tests/scalers/azure/helper"
 )
 
 // Load environment variables from .env file
@@ -139,6 +140,7 @@ func TestScaler(t *testing.T) {
 	ctx := context.Background()
 	t.Log("--- setting up ---")
 	require.NotEmpty(t, connectionString, "TF_AZURE_STORAGE_CONNECTION_STRING env variable is required for azure blob test")
+	accountName = azurehelper.GetAccountFromStorageConnectionString(connectionString)
 
 	blobClient, err := azblob.NewClientFromConnectionString(connectionString, nil)
 	assert.NoErrorf(t, err, "cannot create the queue client - %s", err)

tests/scalers/azure/azure_event_hub_aad_wi/azure_event_hub_aad_wi_test.go

@@ -150,6 +150,7 @@ func TestScaler(t *testing.T) {
 	ctx := context.Background()
 	t.Log("--- setting up ---")
 	require.NotEmpty(t, storageConnectionString, "TF_AZURE_STORAGE_CONNECTION_STRING env variable is required for azure eventhub test")
+	accountName = azurehelper.GetAccountFromStorageConnectionString(storageConnectionString)
 
 	eventHubHelper := azurehelper.NewEventHubHelper(t)
 	eventHubHelper.CreateEventHub(ctx, t)

tests/scalers/azure/azure_queue_aad_wi/azure_queue_aad_wi_test.go

@@ -17,6 +17,7 @@ import (
 	"k8s.io/client-go/kubernetes"
 
 	. "github.com/kedacore/keda/v2/tests/helper"
+	azurehelper "github.com/kedacore/keda/v2/tests/scalers/azure/helper"
 )
 
 // Load environment variables from .env file
@@ -128,6 +129,7 @@ func TestScaler(t *testing.T) {
 	ctx := context.Background()
 	t.Log("--- setting up ---")
 	require.NotEmpty(t, connectionString, "TF_AZURE_STORAGE_CONNECTION_STRING env variable is required for azure queue test")
+	accountName = azurehelper.GetAccountFromStorageConnectionString(connectionString)
 
 	queueClient, err := azqueue.NewQueueClientFromConnectionString(connectionString, queueName, nil)
 	assert.NoErrorf(t, err, "cannot create the queue client - %s", err)

tests/scalers/azure/helper/StorageHelper.go

@@ -0,0 +1,27 @@
+//go:build e2e
+// +build e2e
+
+package helper
+
+import (
+	"strings"
+)
+
+func GetAccountFromStorageConnectionString(connection string) string {
+	parts := strings.Split(connection, ";")
+
+	getValue := func(pair string) string {
+		parts := strings.SplitN(pair, "=", 2)
+		if len(parts) == 2 {
+			return parts[1]
+		}
+		return ""
+	}
+	for _, v := range parts {
+		switch {
+		case strings.HasPrefix(v, "AccountName"):
+			return getValue(v)
+		}
+	}
+	return ""
+}