migrate form recognizer (Azure#25879)

Author: JoshLove-msft

sdk/core/Azure.Core.TestFramework/src/ProxyTransport.cs

@@ -21,7 +21,9 @@ public class ProxyTransport : HttpPipelineTransport
         private static readonly RemoteCertificateValidationCallback ServerCertificateCustomValidationCallback =
             (_, certificate, _, _) => certificate.Issuer == TestProxy.DevCertIssuer;
 
-        public ProxyTransport(TestProxy proxy, HttpPipelineTransport transport, TestRecording recording)
+        private readonly Func<EntryRecordModel> _filter;
+
+        public ProxyTransport(TestProxy proxy, HttpPipelineTransport transport, TestRecording recording, Func<EntryRecordModel> filter)
         {
             if (transport is HttpClientTransport)
             {
@@ -39,6 +41,7 @@ public ProxyTransport(TestProxy proxy, HttpPipelineTransport transport, TestReco
             }
             _recording = recording;
             _proxy = proxy;
+            _filter = filter;
         }
 
         public override void Process(HttpMessage message)
@@ -59,15 +62,15 @@ private async Task ProcessResponseAsync(HttpMessage message, bool async)
         {
             if (message.Response.Headers.Contains("x-request-mismatch"))
             {
-                var streamreader = new StreamReader(message.Response.ContentStream);
+                var streamReader = new StreamReader(message.Response.ContentStream);
                 string response;
                 if (async)
                 {
-                    response = await streamreader.ReadToEndAsync();
+                    response = await streamReader.ReadToEndAsync();
                 }
                 else
                 {
-                    response = streamreader.ReadToEnd();
+                    response = streamReader.ReadToEnd();
                 }
                 throw new TestRecordingMismatchException(response);
             }
@@ -106,6 +109,27 @@ public override Request CreateRequest()
         // copied from https://github.com/Azure/azure-sdk-for-net/blob/main/common/Perf/Azure.Test.Perf/TestProxyPolicy.cs
         private void RedirectToTestProxy(HttpMessage message)
         {
+            if (_recording.Mode == RecordedTestMode.Record)
+            {
+                switch (_filter())
+                {
+                    case EntryRecordModel.Record:
+                        break;
+                    case EntryRecordModel.RecordWithoutRequestBody:
+                        message.Request.Content = null;
+                        break;
+                    case EntryRecordModel.DoNotRecord:
+                        return;
+                }
+            }
+            else if (_recording.Mode == RecordedTestMode.Playback)
+            {
+                if (_filter() == EntryRecordModel.RecordWithoutRequestBody)
+                {
+                    message.Request.Content = null;
+                }
+            }
+
             var request = message.Request;
             request.Headers.SetValue("x-recording-id", _recording.RecordingId);
             request.Headers.SetValue("x-recording-mode", _recording.Mode.ToString().ToLower());

sdk/core/Azure.Core.TestFramework/src/TestRecording.cs

@@ -329,7 +329,7 @@ public HttpPipelineTransport CreateTransport(HttpPipelineTransport currentTransp
         {
             if (!_useLegacyTransport && Mode != RecordedTestMode.Live)
             {
-                return new ProxyTransport(_proxy, currentTransport, this);
+                return new ProxyTransport(_proxy, currentTransport, this, () => _disableRecording.Value);
             }
             return Mode switch
             {

sdk/formrecognizer/Azure.AI.FormRecognizer/tests/Infrastructure/DocumentAnalysisLiveTestBase.cs

@@ -19,7 +19,7 @@ public class DocumentAnalysisLiveTestBase : RecordedTestBase<DocumentAnalysisTes
         private readonly DocumentAnalysisClientOptions.ServiceVersion _serviceVersion;
 
         public DocumentAnalysisLiveTestBase(bool isAsync, DocumentAnalysisClientOptions.ServiceVersion serviceVersion)
-            : base(isAsync, useLegacyTransport: true)
+            : base(isAsync)
         {
             _serviceVersion = serviceVersion;
             Sanitizer = new DocumentAnalysisRecordedTestSanitizer();

sdk/formrecognizer/Azure.AI.FormRecognizer/tests/Infrastructure/FormRecognizerLiveTestBase.cs

@@ -24,7 +24,7 @@ public class FormRecognizerLiveTestBase : RecordedTestBase<FormRecognizerTestEnv
         private readonly FormRecognizerClientOptions.ServiceVersion _serviceVersion;
 
         public FormRecognizerLiveTestBase(bool isAsync, FormRecognizerClientOptions.ServiceVersion serviceVersion)
-            : base(isAsync, useLegacyTransport: true)
+            : base(isAsync)
         {
             _serviceVersion = serviceVersion;
             Sanitizer = new FormRecognizerRecordedTestSanitizer();