Using Pipeline Credentials instead of DefaultAzureCredentials (#41248)

* Using Pipeline Credentials instead of DefaultAzureCredentials

* Removing an duplicate if condition

Author: rajuanitha88

sdk/communication/azure-communication-identity/src/test/java/com/azure/communication/identity/CommunicationIdentityClientTestBase.java

@@ -8,6 +8,7 @@
 import com.azure.communication.identity.models.CommunicationTokenScope;
 import com.azure.core.credential.AccessToken;
 import com.azure.core.credential.AzureKeyCredential;
+import com.azure.core.credential.TokenCredential;
 import com.azure.core.http.HttpClient;
 import com.azure.core.http.HttpPipelineNextPolicy;
 import com.azure.core.http.HttpResponse;
@@ -19,9 +20,10 @@
 import com.azure.core.test.models.TestProxySanitizerType;
 import com.azure.core.test.utils.MockTokenCredential;
 import com.azure.core.util.Configuration;
+import com.azure.core.util.CoreUtils;
 import com.azure.core.util.logging.ClientLogger;
 import com.azure.core.util.logging.LogLevel;
-import com.azure.identity.DefaultAzureCredentialBuilder;
+import com.azure.identity.*;
 import reactor.core.publisher.Mono;
 
 import java.util.ArrayList;
@@ -97,15 +99,10 @@ protected CommunicationIdentityClientBuilder createClientBuilderUsingManagedIden
             .endpoint(communicationEndpoint)
             .httpClient(httpClient);
 
-        if (interceptorManager.isPlaybackMode()) {
-            builder.credential(new MockTokenCredential());
-        } else {
-            builder.credential(new DefaultAzureCredentialBuilder().build());
-            if (interceptorManager.isRecordMode()) {
-                builder.addPolicy(interceptorManager.getRecordPolicy());
-            }
+        builder.credential(getIdentityTestCredential(interceptorManager));
+        if (interceptorManager.isRecordMode()) {
+            builder.addPolicy(interceptorManager.getRecordPolicy());
         }
-
         addTestProxyTestSanitizersAndMatchers(interceptorManager);
         return builder;
     }
@@ -182,4 +179,39 @@ protected void verifyUserNotEmpty(CommunicationUserIdentifier userIdentifier) {
         assertFalse(userIdentifier.getId().isEmpty());
     }
 
+    public static TokenCredential getIdentityTestCredential(InterceptorManager interceptorManager) {
+        if (interceptorManager.isPlaybackMode()) {
+            return  new MockTokenCredential();
+        }
+
+        Configuration config = Configuration.getGlobalConfiguration();
+
+        ChainedTokenCredentialBuilder builder = new ChainedTokenCredentialBuilder()
+            .addLast(new EnvironmentCredentialBuilder().build())
+            .addLast(new AzureCliCredentialBuilder().build())
+            .addLast(new AzureDeveloperCliCredentialBuilder().build());
+
+
+        String serviceConnectionId = config.get("AZURESUBSCRIPTION_SERVICE_CONNECTION_ID");
+        String clientId = config.get("AZURESUBSCRIPTION_CLIENT_ID");
+        String tenantId = config.get("AZURESUBSCRIPTION_TENANT_ID");
+        String systemAccessToken = config.get("SYSTEM_ACCESSTOKEN");
+
+        if (!CoreUtils.isNullOrEmpty(serviceConnectionId)
+            && !CoreUtils.isNullOrEmpty(clientId)
+            && !CoreUtils.isNullOrEmpty(tenantId)
+            && !CoreUtils.isNullOrEmpty(systemAccessToken)) {
+
+            builder.addLast(new AzurePipelinesCredentialBuilder()
+                .systemAccessToken(systemAccessToken)
+                .clientId(clientId)
+                .tenantId(tenantId)
+                .serviceConnectionId(serviceConnectionId)
+                .build());
+        }
+
+        builder.addLast(new AzurePowerShellCredentialBuilder().build());
+        return builder.build();
+    }
+
 }