Fix chunked request body handling with HTTPS proxy, close AsyncHttpClient#1571

Motivation:

Sending a chunked request body (hence not direct) cause AHC to crash.

Motivation:

Fix SslHandler position that should be before the ChunkedWriteHandler.

Result:

Chunked request works with HTTPS proxy.

Author: slandelle

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

@@ -345,7 +345,7 @@ public Future<Channel> updatePipelineForHttpTunneling(ChannelPipeline pipeline,
       if (!isSslHandlerConfigured(pipeline)) {
         SslHandler sslHandler = createSslHandler(requestUri.getHost(), requestUri.getExplicitPort());
         whenHanshaked = sslHandler.handshakeFuture();
-        pipeline.addBefore(AHC_HTTP_HANDLER, SSL_HANDLER, sslHandler);
+        pipeline.addBefore(CHUNKED_WRITER_HANDLER, SSL_HANDLER, sslHandler);
       }
       pipeline.addAfter(SSL_HANDLER, HTTP_CLIENT_CODEC, newHttpClientCodec());
 
@@ -380,10 +380,11 @@ public SslHandler addSslHandler(ChannelPipeline pipeline, Uri uri, String virtua
     }
 
     SslHandler sslHandler = createSslHandler(peerHost, peerPort);
-    if (hasSocksProxyHandler)
+    if (hasSocksProxyHandler) {
       pipeline.addAfter(SOCKS_HANDLER, SSL_HANDLER, sslHandler);
-    else
+    } else {
       pipeline.addFirst(SSL_HANDLER, sslHandler);
+    }
     return sslHandler;
   }
 

client/src/test/java/org/asynchttpclient/proxy/HttpsProxyTest.java

@@ -13,6 +13,7 @@
 package org.asynchttpclient.proxy;
 
 import org.asynchttpclient.*;
+import org.asynchttpclient.request.body.generator.ByteArrayBodyGenerator;
 import org.asynchttpclient.test.EchoHandler;
 import org.eclipse.jetty.proxy.ConnectHandler;
 import org.eclipse.jetty.server.Server;
@@ -23,6 +24,7 @@
 import org.testng.annotations.Test;
 
 import static org.asynchttpclient.Dsl.*;
+import static org.asynchttpclient.test.TestUtils.LARGE_IMAGE_BYTES;
 import static org.asynchttpclient.test.TestUtils.addHttpConnector;
 import static org.asynchttpclient.test.TestUtils.addHttpsConnector;
 import static org.testng.Assert.assertEquals;
@@ -84,6 +86,19 @@ public void testConfigProxy() throws Exception {
     }
   }
 
+  @Test
+  public void testNoDirectRequestBodyWithProxy() throws Exception {
+    AsyncHttpClientConfig config = config()
+      .setFollowRedirect(true)
+      .setProxyServer(proxyServer("localhost", port1).build())
+      .setUseInsecureTrustManager(true)
+      .build();
+    try (AsyncHttpClient asyncHttpClient = asyncHttpClient(config)) {
+      Response r = asyncHttpClient.executeRequest(post(getTargetUrl2()).setBody(new ByteArrayBodyGenerator(LARGE_IMAGE_BYTES))).get();
+      assertEquals(r.getStatusCode(), 200);
+    }
+  }
+
   @Test
   public void testPooledConnectionsWithProxy() throws Exception {