Update to explicit unbound http content decompressor, retain existing behavior of no arg constructor now that the no arg constructor is deprecated

Signed-off-by: Andre Kurait <[email protected]>

Author: AndreKurait

TrafficCapture/trafficReplayer/src/main/java/org/opensearch/migrations/replay/HttpByteBufFormatter.java

@@ -250,7 +250,7 @@ public static <T> T processHttpMessageFromBufs(HttpMessageType msgType,
                                                    ChannelHandler... handlers) {
         EmbeddedChannel channel = new EmbeddedChannel(
             msgType == HttpMessageType.REQUEST ? new HttpRequestDecoder() : new HttpResponseDecoder(),
-            new HttpContentDecompressor()
+            new HttpContentDecompressor(0)
         );
         for (var h : handlers) {
             channel.pipeline().addLast(h);

TrafficCapture/trafficReplayer/src/main/java/org/opensearch/migrations/replay/datahandlers/http/RequestPipelineOrchestrator.java

@@ -146,7 +146,7 @@ void addContentParsingHandlers(
         pipeline.addLast(new ReadMeteringHandler(httpTransactionContext::onPayloadBytesIn));
         // IN: Netty HttpRequest(1) + HttpJsonRequest(1) with headers + HttpContent(1) blocks (which may be compressed)
         // OUT: Netty HttpRequest(2) + HttpJsonRequest(1) with headers + HttpContent(2) uncompressed blocks
-        pipeline.addLast(new HttpContentDecompressor());
+        pipeline.addLast(new HttpContentDecompressor(0));
         pipeline.addLast(new ReadMeteringHandler(httpTransactionContext::onUncompressedBytesIn));
         if (transformer != null) {
             httpTransactionContext.onJsonPayloadParseRequired();

TrafficCapture/trafficReplayer/src/testFixtures/java/org/opensearch/migrations/replay/TestUtils.java

@@ -117,7 +117,7 @@ public static void verifyCapturedResponseMatchesExpectedPayload(
         AtomicReference<FullHttpRequest> fullHttpRequestAtomicReference = new AtomicReference<>();
         EmbeddedChannel unpackVerifier = new EmbeddedChannel(
             new HttpRequestDecoder(),
-            new HttpContentDecompressor(),
+            new HttpContentDecompressor(0),
             new HttpObjectAggregator(bytesCaptured.length * 2),
             new SimpleChannelInboundHandler<FullHttpRequest>() {
                 @Override