Migrate communication to test proxy (Azure#25736)

* Migrate communication to test proxy

* alignment

* fix

Author: JoshLove-msft

sdk/communication/Azure.Communication.CallingServer/tests/Infrastructure/CallingServerLiveTestBase.cs

@@ -83,7 +83,7 @@ protected string GetGroupId()
             return GROUP_IDENTIFIER;
         }
 
-        public CallingServerLiveTestBase(bool isAsync) : base(isAsync, useLegacyTransport: true)
+        public CallingServerLiveTestBase(bool isAsync) : base(isAsync)
             => Sanitizer = new CallingServerRecordedTestSanitizer();
 
         public bool SkipCallingServerInteractionLiveTests

sdk/communication/Azure.Communication.CallingServer/tests/Infrastructure/CallingServerRecordedTestSanitizer.cs

@@ -2,17 +2,17 @@
 // Licensed under the MIT License.
 
 using Azure.Communication.Pipeline;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text.RegularExpressions;
+using Azure.Core.TestFramework.Models;
 
 namespace Azure.Communication.CallingServer.Tests
 {
     public class CallingServerRecordedTestSanitizer : CommunicationRecordedTestSanitizer
     {
-        private static readonly Regex _phoneNumberRegEx = new Regex(@"\\u002B[0-9]{11,15}", RegexOptions.Compiled);
+        private const string PhoneNumberRegEx = @"\\u002B[0-9]{11,15}";
 
-        public override string SanitizeTextBody(string contentType, string body)
-            => base.SanitizeTextBody(contentType, _phoneNumberRegEx.Replace(body, SanitizeValue));
+        public CallingServerRecordedTestSanitizer()
+        {
+            BodyRegexSanitizers.Add(new BodyRegexSanitizer(PhoneNumberRegEx, SanitizeValue));
+        }
     }
 }

sdk/communication/Azure.Communication.Chat/tests/Infrastructure/ChatLiveTestBase.cs

@@ -8,7 +8,7 @@ namespace Azure.Communication.Chat.Tests
 {
     public class ChatLiveTestBase : RecordedTestBase<ChatTestEnvironment>
     {
-        public ChatLiveTestBase(bool isAsync) : base(isAsync, useLegacyTransport: true)
+        public ChatLiveTestBase(bool isAsync) : base(isAsync)
             => Sanitizer = new ChatRecordedTestSanitizer();
 
         /// <summary>

sdk/communication/Azure.Communication.Chat/tests/Infrastructure/ChatRecordedTestSanitizer.cs

@@ -1,10 +1,8 @@
 // Copyright (c) Microsoft Corporation. All rights reserved.
 // Licensed under the MIT License.
 
-using System.Collections.Generic;
-using System.Linq;
 using Azure.Communication.Pipeline;
-using Azure.Core;
+using Azure.Core.TestFramework;
 
 namespace Azure.Communication.Chat.Tests
 {
@@ -14,13 +12,5 @@ public class ChatRecordedTestSanitizer : CommunicationRecordedTestSanitizer
 
         public ChatRecordedTestSanitizer() : base()
             => AddJsonPathSanitizer("$..token");
-
-        protected override void SanitizeAuthenticationHeader(IDictionary<string, string[]> headers)
-        {
-            if (headers.ContainsKey(HttpHeader.Names.UserAgent) && headers[HttpHeader.Names.UserAgent].Any(x => x.Contains("Communication.Chat")))
-                headers[HttpHeader.Names.Authorization] = new[] { SanitizedUnsignedUserTokenValue };
-            else
-                base.SanitizeAuthenticationHeader(headers);
-        }
     }
 }

sdk/communication/Azure.Communication.Chat/tests/SessionRecords/ChatClientsLiveTests/ReadReceipt_GS.json

@@ -1,45 +1,15 @@
 // Copyright (c) Microsoft Corporation. All rights reserved.
 // Licensed under the MIT License.
 
-using System.Collections.Generic;
-using Azure.Communication.Tests;
-using Azure.Core;
 using Azure.Core.TestFramework;
 
 namespace Azure.Communication.Pipeline
 {
     public class CommunicationRecordedTestSanitizer : RecordedTestSanitizer
     {
-        protected virtual void SanitizeAuthenticationHeader(IDictionary<string, string[]> headers)
+        public CommunicationRecordedTestSanitizer()
         {
-            if (headers.ContainsKey(HttpHeader.Names.Authorization))
-                headers[HttpHeader.Names.Authorization] = new[] { SanitizeValue };
-        }
-
-        public override void SanitizeHeaders(IDictionary<string, string[]> headers)
-        {
-            SanitizeAuthenticationHeader(headers);
-            if (headers.ContainsKey("x-ms-content-sha256"))
-                headers["x-ms-content-sha256"] = new[] { SanitizeValue };
-        }
-
-        public override string SanitizeVariable(string variableName, string environmentVariableValue)
-            => variableName switch
-            {
-                CommunicationTestEnvironment.LiveTestDynamicConnectionStringEnvironmentVariableName => SanitizeConnectionString(environmentVariableValue),
-                CommunicationTestEnvironment.LiveTestStaticConnectionStringEnvironmentVariableName => SanitizeConnectionString(environmentVariableValue),
-                _ => base.SanitizeVariable(variableName, environmentVariableValue)
-            };
-
-        protected static string SanitizeConnectionString(string connectionString)
-        {
-            const string accessKey = "accesskey";
-            const string someBase64String = "Kg==";
-
-            var parsed = ConnectionString.Parse(connectionString, allowEmptyValues: true);
-            parsed.Replace(accessKey, someBase64String);
-
-            return parsed.ToString();
+            SanitizedHeaders.Add("x-ms-content-sha256");
         }
     }
 }

sdk/communication/Azure.Communication.Chat/tests/SessionRecords/ChatClientsLiveTests/ReadReceipt_GSAsync.json

@@ -14,19 +14,23 @@ public class CommunicationTestEnvironment : TestEnvironment
         private const string SkipIntSmsTestEnvironmentVariableName = "SKIP_INT_SMS_TEST";
         private const string SkipIntPhoneNumbersTestEnvironmentVariableName = "SKIP_INT_PHONENUMBERS_TEST";
 
-        public string LiveTestDynamicConnectionString => GetRecordedVariable(LiveTestDynamicConnectionStringEnvironmentVariableName);
+        public string LiveTestDynamicConnectionString => GetRecordedVariable(
+            LiveTestDynamicConnectionStringEnvironmentVariableName,
+            options => options.HasSecretConnectionStringParameter("accessKey", SanitizedValue.Base64));
 
         public Uri LiveTestDynamicEndpoint => new Uri(Core.ConnectionString.Parse(LiveTestDynamicConnectionString).GetRequired("endpoint"));
 
         public string LiveTestDynamicAccessKey => Core.ConnectionString.Parse(LiveTestDynamicConnectionString).GetRequired("accesskey");
 
-        public string LiveTestStaticConnectionString => GetRecordedVariable(LiveTestStaticConnectionStringEnvironmentVariableName);
+        public string LiveTestStaticConnectionString => GetRecordedVariable(
+                LiveTestStaticConnectionStringEnvironmentVariableName,
+                options => options.HasSecretConnectionStringParameter("accessKey", SanitizedValue.Base64));
 
         public Uri LiveTestStaticEndpoint => new Uri(Core.ConnectionString.Parse(LiveTestStaticConnectionString).GetRequired("endpoint"));
 
         public string LiveTestStaticAccessKey => Core.ConnectionString.Parse(LiveTestStaticConnectionString).GetRequired("accesskey");
 
-        public string CommunicationTestPhoneNumber => GetVariable(AzurePhoneNumber);
+        public string CommunicationTestPhoneNumber => GetRecordedVariable(AzurePhoneNumber, options => options.IsSecret("+14255550123"));
 
         public string SkipSmsTest => GetOptionalVariable(SkipIntSmsTestEnvironmentVariableName) ?? "False";