Add an option for not dropping Encoding response header, close AsyncHttpClient#723

Author: Stephane Landelle

providers/netty/src/main/java/org/asynchttpclient/providers/netty/NettyAsyncHttpProviderConfig.java

@@ -169,6 +169,8 @@ public NettyWebSocket newNettyWebSocket(Channel channel, NettyAsyncHttpProviderC
 
     private int webSocketMaxFrameSize = 10 * 1024;
 
+    private boolean keepEncodingHeader = false;
+
     public EventLoopGroup getEventLoopGroup() {
         return eventLoopGroup;
     }
@@ -311,4 +313,12 @@ public int getWebSocketMaxFrameSize() {
     public void setWebSocketMaxFrameSize(int webSocketMaxFrameSize) {
         this.webSocketMaxFrameSize = webSocketMaxFrameSize;
     }
+
+    public boolean isKeepEncodingHeader() {
+        return keepEncodingHeader;
+    }
+
+    public void setKeepEncodingHeader(boolean keepEncodingHeader) {
+        this.keepEncodingHeader = keepEncodingHeader;
+    }
 }

providers/netty/src/main/java/org/asynchttpclient/providers/netty/channel/ChannelManager.java

@@ -187,7 +187,7 @@ public void configureBootstraps(NettyRequestSender requestSender, AtomicBoolean
             protected void initChannel(Channel ch) throws Exception {
                 ch.pipeline()//
                         .addLast(HTTP_HANDLER, newHttpClientCodec())//
-                        .addLast(INFLATER_HANDLER, new HttpContentDecompressor())//
+                        .addLast(INFLATER_HANDLER, newHttpContentDecompressor())//
                         .addLast(CHUNKED_WRITER_HANDLER, new ChunkedWriteHandler())//
                         .addLast(HTTP_PROCESSOR, httpProcessor);
 
@@ -215,7 +215,7 @@ protected void initChannel(Channel ch) throws Exception {
                 ch.pipeline()//
                         .addLast(SSL_HANDLER, new SslInitializer(ChannelManager.this))//
                         .addLast(HTTP_HANDLER, newHttpClientCodec())//
-                        .addLast(INFLATER_HANDLER, new HttpContentDecompressor())//
+                        .addLast(INFLATER_HANDLER, newHttpContentDecompressor())//
                         .addLast(CHUNKED_WRITER_HANDLER, new ChunkedWriteHandler())//
                         .addLast(HTTP_PROCESSOR, httpProcessor);
 
@@ -239,6 +239,18 @@ protected void initChannel(Channel ch) throws Exception {
         });
     }
 
+    private HttpContentDecompressor newHttpContentDecompressor() {
+        if (nettyConfig.isKeepEncodingHeader())
+            return new HttpContentDecompressor() {
+                @Override
+                protected String getTargetContentEncoding(String contentEncoding) throws Exception {
+                    return contentEncoding;
+                }
+            };
+        else
+            return new HttpContentDecompressor();
+    }
+
     public final void tryToOfferChannelToPool(Channel channel, boolean keepAlive, String partitionId) {
         if (channel.isActive() && keepAlive && channel.isActive()) {
             LOGGER.debug("Adding key: {} for channel {}", partitionId, channel);