[Test-Proxy] During recording, re-use existing request body

tools/test-proxy/Azure.Sdk.Tools.TestProxy.Tests/RecordingHandlerTests.cs

@@ -618,7 +618,7 @@ public async Task CreateEntryUsesAbsoluteUri()
             request.Path = uri.PathAndQuery;
             request.Headers["x-recording-upstream-base-uri"] = uri.AbsoluteUri;
 
-            var entry = await RecordingHandler.CreateEntryAsync(request);
+            var entry = (await RecordingHandler.CreateEntryAsync(request)).Item1;
             Assert.Equal(uri.AbsoluteUri, entry.RequestUri);
         }
 

tools/test-proxy/Azure.Sdk.Tools.TestProxy/RecordingHandler.cs

@@ -194,9 +194,10 @@ public async Task HandleRecordRequestAsync(string recordingId, HttpRequest incom
                 throw new HttpException(HttpStatusCode.BadRequest, $"There is no active recording session under id {recordingId}.");
             }
 
-            var entry = await CreateEntryAsync(incomingRequest).ConfigureAwait(false);
+            var entryTuple = await CreateEntryAsync(incomingRequest).ConfigureAwait(false);
+            var entry = entryTuple.Item1;
 
-            var upstreamRequest = CreateUpstreamRequest(incomingRequest, CompressionUtilities.CompressBody(entry.Request.Body, entry.Request.Headers));
+            var upstreamRequest = CreateUpstreamRequest(incomingRequest, entryTuple.Item2);
 
             HttpResponseMessage upstreamResponse = null;
 
@@ -432,7 +433,7 @@ public async Task HandlePlaybackRequest(string recordingId, HttpRequest incoming
                 throw new HttpException(HttpStatusCode.BadRequest, $"There is no active playback session under recording id {recordingId}.");
             }
 
-            var entry = await CreateEntryAsync(incomingRequest).ConfigureAwait(false);
+            var entry = (await CreateEntryAsync(incomingRequest).ConfigureAwait(false)).Item1;
 
             // If request contains "x-recording-remove: false", then request is not removed from session after playback.
             // Used by perf tests to play back the same request multiple times.
@@ -470,7 +471,7 @@ public async Task HandlePlaybackRequest(string recordingId, HttpRequest incoming
             }
         }
 
-        public static async Task<RecordEntry> CreateEntryAsync(HttpRequest request)
+        public static async Task<Tuple<RecordEntry, byte[]>> CreateEntryAsync(HttpRequest request)
         {
             var entry = new RecordEntry();
             entry.RequestUri = GetRequestUri(request).AbsoluteUri;
@@ -487,7 +488,7 @@ public static async Task<RecordEntry> CreateEntryAsync(HttpRequest request)
             byte[] bytes = await ReadAllBytes(request.Body).ConfigureAwait(false);
 
             entry.Request.Body = CompressionUtilities.DecompressBody(bytes, request.Headers);
-            return entry;
+            return new Tuple<RecordEntry, byte[]>(entry, bytes);
         }
 
         #endregion