fix: Modified the code for default azure credential

Author: Prajwal-Microsoft

Services/src/esg-ai-doc-analysis/CFS.SK.Sustainability.AI/Services/Queue/AzureStorageQueueService.cs

@@ -84,7 +84,8 @@ public static Uri GetQueueUriFromConnectionString(string connectionString, strin
 
         public AzureStorageQueueService(Uri storageQueueUri, ILogger<AzureStorageQueueService> log)
         {
-            this._clientBuilder = queueName => new QueueClient(storageQueueUri, new DefaultAzureCredential(DefaultAzureCredential.DefaultEnvironmentVariableName));
+            DefaultAzureCredential credential = new(DefaultAzureCredential.DefaultEnvironmentVariableName);
+            this._clientBuilder = queueName => new QueueClient(storageQueueUri, credential);
             this._log = log;
         }
 

Services/src/esg-ai-doc-analysis/CFS.SK.Sustainability.AI/Utils/StorageAccessUtil.cs

@@ -16,7 +16,8 @@ static public BlobServiceClient GetBlobClientFromConnectionString(string Connect
             var DefaultEndpointSuffix = "core.windows.net";
             var storageAccountName = ConnectionString.Split(';').FirstOrDefault(x => x.Contains("AccountName")).Split('=')[1];
             var storageAccountUri = new Uri($"https://{storageAccountName}.blob.{DefaultEndpointSuffix}");
-            return new BlobServiceClient(storageAccountUri, new DefaultAzureCredential(DefaultAzureCredential.DefaultEnvironmentVariableName));
+            DefaultAzureCredential credential = new(DefaultAzureCredential.DefaultEnvironmentVariableName);
+            return new BlobServiceClient(storageAccountUri, credential);
         }
 
         static public Stream GetReportResultBlob(string FileName, string ConnectionString)

Services/src/kernel-memory/extensions/AzureAIDocIntel/AzureAIDocIntelEngine.cs

@@ -36,7 +36,8 @@ public AzureAIDocIntelEngine(
         switch (config.Auth)
         {
             case AzureAIDocIntelConfig.AuthTypes.AzureIdentity:
-                this._recognizerClient = new DocumentAnalysisClient(new Uri(config.Endpoint), new DefaultAzureCredential(DefaultAzureCredential.DefaultEnvironmentVariableName));
+                DefaultAzureCredential credential = new(DefaultAzureCredential.DefaultEnvironmentVariableName);
+                this._recognizerClient = new DocumentAnalysisClient(new Uri(config.Endpoint), credential);
                 break;
 
             case AzureAIDocIntelConfig.AuthTypes.APIKey:

Services/src/kernel-memory/extensions/AzureAISearch/AzureAISearch/AzureAISearchMemory.cs

@@ -67,9 +67,10 @@ public AzureAISearchMemory(
         switch (config.Auth)
         {
             case AzureAISearchConfig.AuthTypes.AzureIdentity:
+                DefaultAzureCredential credential = new(DefaultAzureCredential.DefaultEnvironmentVariableName);
                 this._adminClient = new SearchIndexClient(
                     new Uri(config.Endpoint),
-                    new DefaultAzureCredential(DefaultAzureCredential.DefaultEnvironmentVariableName),
+                    credential,
                     GetClientOptions());
                 break;
 

Services/src/kernel-memory/extensions/AzureBlobs/AzureBlobsStorage.cs

@@ -55,7 +55,8 @@ public AzureBlobsStorage(
             {
                 this.ValidateAccountName(config.Account);
                 var suffix = this.ValidateEndpointSuffix(config.EndpointSuffix);
-                client = new BlobServiceClient(new Uri($"https://{config.Account}.blob.{suffix}"), new DefaultAzureCredential(DefaultAzureCredential.DefaultEnvironmentVariableName));
+                DefaultAzureCredential credential = new(DefaultAzureCredential.DefaultEnvironmentVariableName);
+                client = new BlobServiceClient(new Uri($"https://{config.Account}.blob.{suffix}"), credential);
                 break;
             }
 

Services/src/kernel-memory/extensions/AzureOpenAI/AzureOpenAITextEmbeddingGenerator.cs

@@ -71,11 +71,12 @@ public AzureOpenAITextEmbeddingGenerator(
         switch (config.Auth)
         {
             case AzureOpenAIConfig.AuthTypes.AzureIdentity:
+                DefaultAzureCredential credential = new(DefaultAzureCredential.DefaultEnvironmentVariableName);
                 this._client = new AzureOpenAITextEmbeddingGenerationService(
                     deploymentName: config.Deployment,
                     modelId: config.Deployment,
                     endpoint: config.Endpoint,
-                    credential: new DefaultAzureCredential(DefaultAzureCredential.DefaultEnvironmentVariableName),
+                    credential: credential,
                     httpClient: httpClient);
                 break;
 

Services/src/kernel-memory/extensions/AzureOpenAI/AzureOpenAITextGenerator.cs

@@ -114,7 +114,8 @@ public AzureOpenAITextGenerator(
         switch (config.Auth)
         {
             case AzureOpenAIConfig.AuthTypes.AzureIdentity:
-                this._client = new OpenAIClient(new Uri(config.Endpoint), new DefaultAzureCredential(DefaultAzureCredential.DefaultEnvironmentVariableName), options);
+                DefaultAzureCredential credential = new(DefaultAzureCredential.DefaultEnvironmentVariableName);
+                this._client = new OpenAIClient(new Uri(config.Endpoint), credential, options);
                 break;
 
             case AzureOpenAIConfig.AuthTypes.ManualTokenCredential:

Services/src/kernel-memory/extensions/AzureQueues/AzureQueuesPipeline.cs

@@ -100,9 +100,10 @@ public AzureQueuesPipeline(
 
             case AzureQueuesConfig.AuthTypes.AzureIdentity:
             {
+                DefaultAzureCredential credential = new(DefaultAzureCredential.DefaultEnvironmentVariableName);
                 this.ValidateAccountName(config.Account);
                 var suffix = this.ValidateEndpointSuffix(config.EndpointSuffix);
-                this._clientBuilder = queueName => new QueueClient(new($"https://{config.Account}.queue.{suffix}/{queueName}"), new DefaultAzureCredential(DefaultAzureCredential.DefaultEnvironmentVariableName));
+                this._clientBuilder = queueName => new QueueClient(new($"https://{config.Account}.queue.{suffix}/{queueName}"), credential);
                 break;
             }