Add HTTP proxy tunnel support

tests/standalone/io/http_proxy_test.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 import "package:expect/expect.dart";
 import "dart:async";
 import 'dart:crypto';
 import "dart:io";
 import "dart:uri";
 import 'dart:utf';
@@ skipping 16 matching lines @@
     return f.then((s) {
       server = s;
       x.complete(this);
       server.listen((request) {
         var response = request.response;
         requestCount++;
         // Check whether a proxy or direct connection is expected.
         bool direct = directRequestPaths.fold(
             false,
             (prev, path) => prev ? prev : path == request.uri.path);
-        if (!direct && proxyHops > 0) {
+        if (!secure && !direct && proxyHops > 0) {
           Expect.isNotNull(request.headers[HttpHeaders.VIA]);
           Expect.equals(1, request.headers[HttpHeaders.VIA].length);
           Expect.equals(
               proxyHops,
               request.headers[HttpHeaders.VIA][0].split(",").length);
         } else {
           Expect.isNull(request.headers[HttpHeaders.VIA]);
         }
         var body = new StringBuffer();
         request.listen(
@@ skipping 67 matching lines @@
             Expect.equals("Basic", tokens[0]);
             String auth =
                 CryptoUtils.bytesToBase64(encodeUtf8("$username:$password"));
             if (auth != tokens[1]) {
               authenticationRequired(request);
               return;
             }
           }
         }
         // Open the connection from the proxy.
-        client.openUrl(request.method, request.uri)
-          .then((HttpClientRequest clientRequest) {
-            // Forward all headers.
-            request.headers.forEach((String name, List<String> values) {
-              values.forEach((String value) {
-                if (name != "content-length" && name != "via") {
-                  clientRequest.headers.add(name, value);
-                }
+        if (request.method == "CONNECT") {
+          var tmp = request.uri.toString().split(":");
+          Socket.connect(tmp[0], int.parse(tmp[1]))
+              .then((socket) {
+                request.response.reasonPhrase = "Connection established";
+                request.response.detachSocket()
+                    .then((detached) {
+                      socket.pipe(detached);
+                      detached.pipe(socket);
+                    });
               });
+        } else {
+          client.openUrl(request.method, request.uri)
+            .then((HttpClientRequest clientRequest) {
+              // Forward all headers.
+              request.headers.forEach((String name, List<String> values) {
+                values.forEach((String value) {
+                  if (name != "content-length" && name != "via") {
+                    clientRequest.headers.add(name, value);
+                  }
+                });
+              });
+              // Special handling of Content-Length and Via.
+              clientRequest.contentLength = request.contentLength;
+              List<String> via = request.headers[HttpHeaders.VIA];
+              String viaPrefix = via == null ? "" : "${via[0]}, ";
+              clientRequest.headers.add(
+                  HttpHeaders.VIA, "${viaPrefix}1.1 localhost:$port");
+              // Copy all content.
+              return request.pipe(clientRequest);
+            })
+            .then((HttpClientResponse clientResponse) {
+              clientResponse.pipe(request.response);
             });
-            // Special handling of Content-Length and Via.
-            clientRequest.contentLength = request.contentLength;
-            List<String> via = request.headers[HttpHeaders.VIA];
-            String viaPrefix = via == null ? "" : "${via[0]}, ";
-            clientRequest.headers.add(
-                HttpHeaders.VIA, "${viaPrefix}1.1 localhost:$port");
-            // Copy all content.
-            return request.pipe(clientRequest);
-          })
-          .then((HttpClientResponse clientResponse) {
-            clientResponse.pipe(request.response);
-          });
+        }
       });
     });
     return x.future;
   }
 
   void shutdown() {
     server.close();
     client.close();
   }
 
@@ skipping 265 matching lines @@
             ? "https://localhost:${secureServer.port}/$i"
             : "http://localhost:${server.port}/$i";
 
         client.postUrl(Uri.parse(url))
           .then((HttpClientRequest clientRequest) {
             String content = "$i$i$i";
             clientRequest.write(content);
             return clientRequest.close();
           })
           .then((HttpClientResponse response) {
-            response.listen((_) {}, onDone: () {
-              testProxyAuthenticateCount++;
-              Expect.equals(HttpStatus.PROXY_AUTHENTICATION_REQUIRED,
-                            response.statusCode);
-              if (testProxyAuthenticateCount == loopCount * 2) {
-                Expect.equals(0, server.requestCount);
-                Expect.equals(0, secureServer.requestCount);
-                step1.complete(null);
-              }
-            });
-          });
+            Expect.fail("No response expected");
+          }).
+          catchError((e) {
+            testProxyAuthenticateCount++;
+            if (testProxyAuthenticateCount == loopCount * 2) {
+              Expect.equals(0, server.requestCount);
+              Expect.equals(0, secureServer.requestCount);
+              step1.complete(null);
+            }
+        });
       }
 
       test(false);
       test(true);
     }
-
     step1.future.then((_) {
       testProxyAuthenticateCount = 0;
       client.findProxy = (Uri uri) {
         return "PROXY test:test@localhost:${proxyServer.port}";
       };
 
       for (int i = 0; i < loopCount; i++) {
         test(bool secure) {
           String url = secure
               ? "https://localhost:${secureServer.port}/$i"
@@ skipping 168 matching lines @@
   testDirectProxy();
   testProxy();
   testProxyChain();
   testProxyFromEnviroment();
   testProxyAuthenticate();
   // This test is not normally run. It can be used for locally testing
   // with a real proxy server (e.g. Apache).
   //testRealProxy();
   //testRealProxyAuth();
 }