Add decompression support to netty exec factory (#817)

Fixes problem with gzip encoded streams (e.g. copy file from container)
testcontainers · Aug 5, 2018 · 9d6d6bb · 9d6d6bb
1 parent 834b19f
commit 9d6d6bb
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...in/java/org/testcontainers/dockerclient/transport/TestcontainersDockerCmdExecFactory.java b/...in/java/org/testcontainers/dockerclient/transport/TestcontainersDockerCmdExecFactory.java
@@ -19,6 +19,7 @@
 import io.netty.channel.unix.DomainSocketAddress;
 import io.netty.channel.unix.UnixChannel;
 import io.netty.handler.codec.http.HttpClientCodec;
+import io.netty.handler.codec.http.HttpContentDecompressor;
 import io.netty.handler.ssl.SslHandler;
 import io.netty.handler.timeout.IdleState;
 import io.netty.handler.timeout.IdleStateEvent;
@@ -135,6 +136,7 @@ public EventLoopGroup epollGroup() {
                 @Override
                 protected void initChannel(final UnixChannel channel) throws Exception {
                     channel.pipeline().addLast(new HttpClientCodec());
+                    channel.pipeline().addLast(new HttpContentDecompressor());
                 }
             });
             return epollEventLoopGroup;
@@ -148,6 +150,7 @@ public EventLoopGroup kqueueGroup() {
                         @Override
                         protected void initChannel(final KQueueDomainSocketChannel channel) throws Exception {
                             channel.pipeline().addLast(new HttpClientCodec());
+                            channel.pipeline().addLast(new HttpContentDecompressor());
                         }
                     });
 
@@ -175,6 +178,7 @@ public EventLoopGroup init(Bootstrap bootstrap, final DockerClientConfig dockerC
                         @Override
                         protected void initChannel(final SocketChannel channel) throws Exception {
                             channel.pipeline().addLast(new HttpClientCodec());
+                            channel.pipeline().addLast(new HttpContentDecompressor());
                         }
                     });