From a56ae94894fab89bc0ebc34f9b69cfccf3cb239a Mon Sep 17 00:00:00 2001
From: yawnt <yawn.localhost@gmail.com>
Date: Mon, 24 Jun 2013 11:16:23 +0200
Subject: [PATCH 01/14] [fix] refactor

---
 lib/node-http-proxy/http-proxy.js | 12 +++++-------
 1 file changed, 5 insertions(+), 7 deletions(-)

diff --git a/lib/node-http-proxy/http-proxy.js b/lib/node-http-proxy/http-proxy.js
index 0efb2fa3c..f481ccfcc 100644
--- a/lib/node-http-proxy/http-proxy.js
+++ b/lib/node-http-proxy/http-proxy.js
@@ -66,7 +66,7 @@ var HttpProxy = exports.HttpProxy = function (options) {
   //
   this.forward  = options.forward;
   this.target   = options.target;
-  this.timeout = options.timeout;
+  this.timeout  = options.timeout;
 
   //
   // Setup the necessary instances instance variables for
@@ -207,12 +207,10 @@ HttpProxy.prototype.proxyRequest = function (req, res, buffer) {
       // This NODE_ENV=production behavior is mimics Express and
       // Connect.
       //
-      if (process.env.NODE_ENV === 'production') {
-        res.write('Internal Server Error');
-      }
-      else {
-        res.write('An error has occurred: ' + JSON.stringify(err));
-      }
+      res.write(process.env.NODE_ENV === 'production' 
+        ? 'Internal Server Error'
+        : 'An error has occurred: ' + JSON.stringify(err)
+      );
     }
 
     try { res.end() }

From c8d9e0f139d0a4b501bfdbb1ec48b636f0b7d086 Mon Sep 17 00:00:00 2001
From: yawnt <yawn.localhost@gmail.com>
Date: Mon, 24 Jun 2013 12:01:28 +0200
Subject: [PATCH 02/14] [refactor] start working on forwardStream

---
 lib/node-http-proxy.js                 |  8 +--
 lib/node-http-proxy/http-proxy.js      | 86 ++++++++++----------------
 lib/node-http-proxy/streams/forward.js | 43 +++++++++++++
 3 files changed, 79 insertions(+), 58 deletions(-)
 create mode 100644 lib/node-http-proxy/streams/forward.js

diff --git a/lib/node-http-proxy.js b/lib/node-http-proxy.js
index 956a5f3d3..d71c589fe 100644
--- a/lib/node-http-proxy.js
+++ b/lib/node-http-proxy.js
@@ -24,10 +24,10 @@
 
 */
 
-var util = require('util'),
-    http = require('http'),
-    https = require('https'),
-    events = require('events'),
+var util       = require('util'),
+    http       = require('http'),
+    https      = require('https'),
+    events     = require('events'),
     maxSockets = 100;
 
 //
diff --git a/lib/node-http-proxy/http-proxy.js b/lib/node-http-proxy/http-proxy.js
index f481ccfcc..d76691916 100644
--- a/lib/node-http-proxy/http-proxy.js
+++ b/lib/node-http-proxy/http-proxy.js
@@ -24,10 +24,10 @@
 
 */
 
-var events = require('events'),
-    http = require('http'),
-    util = require('util'),
-    url = require('url'),
+var events    = require('events'),
+    http      = require('http'),
+    util      = require('util'),
+    url       = require('url'),
     httpProxy = require('../node-http-proxy');
 
 //
@@ -91,10 +91,12 @@ var HttpProxy = exports.HttpProxy = function (options) {
   //
   // Setup opt-in features
   //
-  this.enable          = options.enable || {};
-  this.enable.xforward = typeof this.enable.xforward === 'boolean'
-    ? this.enable.xforward
-    : true;
+  this.enable = options.enable || {};
+  
+  if(typeof this.enable.xforward !== 'boolean') {
+    this.enable.xforward = true;
+  }
+
 
   //
   // Setup additional options for WebSocket proxying. When forcing
@@ -140,29 +142,17 @@ HttpProxy.prototype.proxyRequest = function (req, res, buffer) {
   // * `x-forwarded-port`: Port of the original request.
   //
   if (this.enable.xforward && req.connection && req.socket) {
-    if (req.headers['x-forwarded-for']) {
-      var addressToAppend = "," + req.connection.remoteAddress || req.socket.remoteAddress;
-      req.headers['x-forwarded-for'] += addressToAppend;
-    }
-    else {
-      req.headers['x-forwarded-for'] = req.connection.remoteAddress || req.socket.remoteAddress;
-    }
-
-    if (req.headers['x-forwarded-port']) {
-      var portToAppend = "," + req.connection.remotePort || req.socket.remotePort;
-      req.headers['x-forwarded-port'] += portToAppend;
-    }
-    else {
-      req.headers['x-forwarded-port'] = req.connection.remotePort || req.socket.remotePort;
-    }
-
-    if (req.headers['x-forwarded-proto']) {
-      var protoToAppend = "," + getProto(req);
-      req.headers['x-forwarded-proto'] += protoToAppend;
-    }
-    else {
-      req.headers['x-forwarded-proto'] = getProto(req);
-    }
+    req.headers['x-forwarded-for'] = (req.headers['x-forwarded-for'] || '') +
+                                     (req.headers['x-forwarded-for'] ? ',' : '') + 
+                                     (req.connection.remoteAddress || socket.remoteAddress);
+    
+    req.headers['x-forwarded-port'] = (req.headers['x-forwarded-port'] || '') +
+                                      (req.headers['x-forwarded-port'] ? ',' : '') +
+                                      (req.connection.remotePort || socket.remotePort);
+
+    req.headers['x-forwarded-proto'] = (req.headers['x-forwarded-proto'] || '') +
+                                       (req.headers['x-forwarded-proto'] ? ',' : '') +
+                                       getProto(req);
   }
 
   if (this.timeout) {
@@ -469,29 +459,17 @@ HttpProxy.prototype.proxyWebSocketRequest = function (req, socket, upgradeHead,
   // * `x-forwarded-port`: Port of the original request.
   //
   if (this.enable.xforward && req.connection) {
-    if (req.headers['x-forwarded-for']) {
-      var addressToAppend = "," + req.connection.remoteAddress || socket.remoteAddress;
-      req.headers['x-forwarded-for'] += addressToAppend;
-    }
-    else {
-      req.headers['x-forwarded-for'] = req.connection.remoteAddress || socket.remoteAddress;
-    }
-
-    if (req.headers['x-forwarded-port']) {
-      var portToAppend = "," + req.connection.remotePort || socket.remotePort;
-      req.headers['x-forwarded-port'] += portToAppend;
-    }
-    else {
-      req.headers['x-forwarded-port'] = req.connection.remotePort || socket.remotePort;
-    }
-
-    if (req.headers['x-forwarded-proto']) {
-      var protoToAppend = "," + (req.connection.pair ? 'wss' : 'ws');
-      req.headers['x-forwarded-proto'] += protoToAppend;
-    }
-    else {
-      req.headers['x-forwarded-proto'] = req.connection.pair ? 'wss' : 'ws';
-    }
+    req.headers['x-forwarded-for'] = (req.headers['x-forwarded-for'] || '') +
+                                     (req.headers['x-forwarded-for'] ? ',' : '') + 
+                                     (req.connection.remoteAddress || socket.remoteAddress);
+    
+    req.headers['x-forwarded-port'] = (req.headers['x-forwarded-port'] || '') +
+                                      (req.headers['x-forwarded-port'] ? ',' : '') +
+                                      (req.connection.remotePort || socket.remotePort);
+
+    req.headers['x-forwarded-proto'] = (req.headers['x-forwarded-proto'] || '') +
+                                       (req.headers['x-forwarded-proto'] ? ',' : '') +
+                                       (req.connection.pair ? 'wss' : 'ws');
   }
 
   self.emit('websocket:start', req, socket, head, this.target);
diff --git a/lib/node-http-proxy/streams/forward.js b/lib/node-http-proxy/streams/forward.js
new file mode 100644
index 000000000..55f50d9bd
--- /dev/null
+++ b/lib/node-http-proxy/streams/forward.js
@@ -0,0 +1,43 @@
+var Writable = require('stream').Writable,
+    http     = require('http'),
+    https    = require('https'),
+    util     = require('util');
+
+var ForwardStream = module.exports = function ForwardStream(options) {
+  Writable.call(this);
+
+  var self = this;
+
+  this.once('pipe', function(req) {
+    self.outgoing =  options.https ? https : http;
+
+    [
+      'host', 
+      'hostname', 
+      'port', 
+      'socketPath', 
+      'agent'
+    ].forEach(function(elem) {
+      outgoing[elem] = target[elem];
+    });
+
+    [
+      'method', 
+      'path', 
+      'headers'
+    ].forEach(function(elem) {
+      outgoing[elem] = req[elem];
+    });
+    
+  });
+
+}
+
+ForwardStream.prototype._write = function() {
+
+
+
+}
+
+util.inherits(ForwardStream, Writable);
+

From bd62a68017436485427a69b009ef72611bb320db Mon Sep 17 00:00:00 2001
From: yawnt <yawn.localhost@gmail.com>
Date: Mon, 24 Jun 2013 12:09:55 +0200
Subject: [PATCH 03/14] [fix] now you can pipe()

---
 lib/node-http-proxy/streams/forward.js | 19 ++++++++++---------
 1 file changed, 10 insertions(+), 9 deletions(-)

diff --git a/lib/node-http-proxy/streams/forward.js b/lib/node-http-proxy/streams/forward.js
index 55f50d9bd..ff494e448 100644
--- a/lib/node-http-proxy/streams/forward.js
+++ b/lib/node-http-proxy/streams/forward.js
@@ -1,4 +1,5 @@
 var Writable = require('stream').Writable,
+    proxy    = require('../../node-http-proxy');
     http     = require('http'),
     https    = require('https'),
     util     = require('util');
@@ -9,7 +10,8 @@ var ForwardStream = module.exports = function ForwardStream(options) {
   var self = this;
 
   this.once('pipe', function(req) {
-    self.outgoing =  options.https ? https : http;
+    var protocol = options.https ? https : http,
+        outgoing = proxy._getBase(options);
 
     [
       'host', 
@@ -18,7 +20,7 @@ var ForwardStream = module.exports = function ForwardStream(options) {
       'socketPath', 
       'agent'
     ].forEach(function(elem) {
-      outgoing[elem] = target[elem];
+      outgoing[elem] = options[elem];
     });
 
     [
@@ -28,16 +30,15 @@ var ForwardStream = module.exports = function ForwardStream(options) {
     ].forEach(function(elem) {
       outgoing[elem] = req[elem];
     });
-    
-  });
-
-}
-
-ForwardStream.prototype._write = function() {
 
+    self.request = protocol.request(outgoing)
+  });
 
+};
 
-}
+ForwardStream.prototype._write = function(chunk, encoding, callback) {
+  this.request.write(chunk, encoding, callback);
+};
 
 util.inherits(ForwardStream, Writable);
 

From 492134f830678f071a0e4915421b48fd4703d89f Mon Sep 17 00:00:00 2001
From: yawnt <yawn.localhost@gmail.com>
Date: Mon, 24 Jun 2013 12:17:52 +0200
Subject: [PATCH 04/14] [fix] typo

---
 lib/node-http-proxy/http-proxy.js      | 14 +++++++-------
 lib/node-http-proxy/streams/forward.js |  3 ++-
 2 files changed, 9 insertions(+), 8 deletions(-)

diff --git a/lib/node-http-proxy/http-proxy.js b/lib/node-http-proxy/http-proxy.js
index d76691916..8b9ef4a8f 100644
--- a/lib/node-http-proxy/http-proxy.js
+++ b/lib/node-http-proxy/http-proxy.js
@@ -24,11 +24,12 @@
 
 */
 
-var events    = require('events'),
-    http      = require('http'),
-    util      = require('util'),
-    url       = require('url'),
-    httpProxy = require('../node-http-proxy');
+var events        = require('events'),
+    http          = require('http'),
+    util          = require('util'),
+    url           = require('url'),
+    ForwardStream = require('./streams/forward'),
+    httpProxy     = require('../node-http-proxy');
 
 //
 // ### function HttpProxy (options)
@@ -97,7 +98,6 @@ var HttpProxy = exports.HttpProxy = function (options) {
     this.enable.xforward = true;
   }
 
-
   //
   // Setup additional options for WebSocket proxying. When forcing
   // the WebSocket handshake to change the `sec-websocket-location`
@@ -170,7 +170,7 @@ HttpProxy.prototype.proxyRequest = function (req, res, buffer) {
   //
   if (this.forward) {
     this.emit('forward', req, res, this.forward);
-    this._forwardRequest(req);
+    req.pipe(new ForwardStream(this.forward));
   }
 
   //
diff --git a/lib/node-http-proxy/streams/forward.js b/lib/node-http-proxy/streams/forward.js
index ff494e448..c29251730 100644
--- a/lib/node-http-proxy/streams/forward.js
+++ b/lib/node-http-proxy/streams/forward.js
@@ -31,7 +31,8 @@ var ForwardStream = module.exports = function ForwardStream(options) {
       outgoing[elem] = req[elem];
     });
 
-    self.request = protocol.request(outgoing)
+    // pipe throw-safe? do we need to add a ` on 'error' ` handler?
+    self.request = protocol.request(outgoing, function() {});
   });
 
 };

From ab4a2419b3b7299336c19ede15e81988d3df7e5d Mon Sep 17 00:00:00 2001
From: yawnt <yawn.localhost@gmail.com>
Date: Mon, 24 Jun 2013 13:11:01 +0200
Subject: [PATCH 05/14] [api] first draft of ProxyStream

---
 lib/node-http-proxy.js                 | 20 +++++++++++
 lib/node-http-proxy/http-proxy.js      | 19 ++++------
 lib/node-http-proxy/streams/forward.js | 18 +---------
 lib/node-http-proxy/streams/proxy.js   | 48 ++++++++++++++++++++++++++
 4 files changed, 75 insertions(+), 30 deletions(-)
 create mode 100644 lib/node-http-proxy/streams/proxy.js

diff --git a/lib/node-http-proxy.js b/lib/node-http-proxy.js
index d71c589fe..922c6d8f0 100644
--- a/lib/node-http-proxy.js
+++ b/lib/node-http-proxy.js
@@ -392,3 +392,23 @@ exports._getBase = function _getBase (options) {
 
   return result;
 };
+
+exports._setupOutgoing = function(outgoing, options, req) {
+  [
+    'host', 
+    'hostname', 
+    'port', 
+    'socketPath', 
+    'agent'
+  ].forEach(function(elem) {
+    outgoing[elem] = options[elem];
+  });
+
+  [
+    'method', 
+    'path', 
+    'headers'
+  ].forEach(function(elem) {
+    outgoing[elem] = req[elem];
+  });
+};
\ No newline at end of file
diff --git a/lib/node-http-proxy/http-proxy.js b/lib/node-http-proxy/http-proxy.js
index 8b9ef4a8f..db4be1cc7 100644
--- a/lib/node-http-proxy/http-proxy.js
+++ b/lib/node-http-proxy/http-proxy.js
@@ -128,8 +128,8 @@ HttpProxy.prototype.proxyRequest = function (req, res, buffer) {
 
   // If this is a DELETE request then set the "content-length"
   // header (if it is not already set)
-  if (req.method === 'DELETE') {
-    req.headers['content-length'] = req.headers['content-length'] || '0';
+  if (req.method === 'DELETE' && !req.headers['content-length']) {
+    req.headers['content-length'] = '0';
   }
 
   //
@@ -210,14 +210,7 @@ HttpProxy.prototype.proxyRequest = function (req, res, buffer) {
   //
   // Setup outgoing proxy with relevant properties.
   //
-  outgoing.host       = this.target.host;
-  outgoing.hostname   = this.target.hostname;
-  outgoing.port       = this.target.port;
-  outgoing.socketPath = this.target.socketPath;
-  outgoing.agent      = this.target.agent;
-  outgoing.method     = req.method;
-  outgoing.path       = req.url;
-  outgoing.headers    = req.headers;
+  httpProxy._setupOutgoing(outgoing, this.target, req);
 
   //
   // If the changeOrigin option is specified, change the
@@ -238,14 +231,14 @@ HttpProxy.prototype.proxyRequest = function (req, res, buffer) {
     //
     if (req.httpVersion === '1.0') {
       if (req.headers.connection) {
-        response.headers.connection = req.headers.connection
+        response.headers.connection = req.headers.connection;
       } else {
-        response.headers.connection = 'close'
+        response.headers.connection = 'close';
       }
     } else if (!response.headers.connection) {
       if (req.headers.connection) { response.headers.connection = req.headers.connection }
       else {
-        response.headers.connection = 'keep-alive'
+        response.headers.connection = 'keep-alive';
       }
     }
 
diff --git a/lib/node-http-proxy/streams/forward.js b/lib/node-http-proxy/streams/forward.js
index c29251730..de49bf6af 100644
--- a/lib/node-http-proxy/streams/forward.js
+++ b/lib/node-http-proxy/streams/forward.js
@@ -13,23 +13,7 @@ var ForwardStream = module.exports = function ForwardStream(options) {
     var protocol = options.https ? https : http,
         outgoing = proxy._getBase(options);
 
-    [
-      'host', 
-      'hostname', 
-      'port', 
-      'socketPath', 
-      'agent'
-    ].forEach(function(elem) {
-      outgoing[elem] = options[elem];
-    });
-
-    [
-      'method', 
-      'path', 
-      'headers'
-    ].forEach(function(elem) {
-      outgoing[elem] = req[elem];
-    });
+    proxy._setupOutgoing(outgoing, options, req);
 
     // pipe throw-safe? do we need to add a ` on 'error' ` handler?
     self.request = protocol.request(outgoing, function() {});
diff --git a/lib/node-http-proxy/streams/proxy.js b/lib/node-http-proxy/streams/proxy.js
new file mode 100644
index 000000000..7dd9c26f7
--- /dev/null
+++ b/lib/node-http-proxy/streams/proxy.js
@@ -0,0 +1,48 @@
+var Duplex = require('stream').Duplex,
+    proxy  = require('../../node-http-proxy');
+    http   = require('http'),
+    https  = require('https'),
+    url    = require('url'),
+    util   = require('util');
+
+var ProxyStream = module.exports = function ProxyStream(target, changeOrigin) {
+  Duplex.call(this);
+
+  var self = this;
+
+  this.once('pipe', function(req) {
+    var protocol = target.https ? https : http,
+        outgoing = proxy._getBase(target);
+
+    proxy._setupOutgoing(outgoing, target, req);
+
+    if (changeOrigin) {
+      outgoing.headers.host = target.host + ':' + target.port;
+    }
+
+    self.request = protocol.request(outgoing, function(res) {
+      if(req.httpVersion === '1.0') {
+        res.headers.connection = req.headers.connection || 'close';
+      }
+      else if(!res.headers.connection) {
+        res.headers.connection = req.headers.connection || 'keep-alive';
+      }
+
+      if(req.httpVersion === '1.0' || (req.method === 'DELETE' && !req.headers['content-length'])) {
+        delete response.headers['transfer-encoding'];
+      }
+
+      if(~[301,302].indexOf(res.statusCode) && typeof response.headers.location !== 'undefined') {
+        location = url.parse(response.headers.location);
+      }
+
+    });
+  });
+
+};
+
+ForwardStream.prototype._write = function(chunk, encoding, callback) {
+  this.request.write(chunk, encoding, callback);
+};
+
+util.inherits(ForwardStream, Duplex);

From 445add091c3b754526a18269b6e332a9a0f5e10e Mon Sep 17 00:00:00 2001
From: yawnt <yawn.localhost@gmail.com>
Date: Mon, 24 Jun 2013 15:10:33 +0200
Subject: [PATCH 06/14] [api] proxystream

---
 lib/node-http-proxy/http-proxy.js    | 240 +--------------------------
 lib/node-http-proxy/streams/proxy.js |  90 +++++++++-
 2 files changed, 85 insertions(+), 245 deletions(-)

diff --git a/lib/node-http-proxy/http-proxy.js b/lib/node-http-proxy/http-proxy.js
index db4be1cc7..f76187889 100644
--- a/lib/node-http-proxy/http-proxy.js
+++ b/lib/node-http-proxy/http-proxy.js
@@ -29,6 +29,7 @@ var events        = require('events'),
     util          = require('util'),
     url           = require('url'),
     ForwardStream = require('./streams/forward'),
+    ProxyStream   = require('./streams/proxy'),
     httpProxy     = require('../node-http-proxy');
 
 //
@@ -163,6 +164,7 @@ HttpProxy.prototype.proxyRequest = function (req, res, buffer) {
   // Emit the `start` event indicating that we have begun the proxy operation.
   //
   this.emit('start', req, res, this.target);
+  req.pipe(new ProxyStream(res, options)).pipe(res);
 
   //
   // If forwarding is enabled for this instance, foward proxy the
@@ -172,244 +174,6 @@ HttpProxy.prototype.proxyRequest = function (req, res, buffer) {
     this.emit('forward', req, res, this.forward);
     req.pipe(new ForwardStream(this.forward));
   }
-
-  //
-  // #### function proxyError (err)
-  // #### @err {Error} Error contacting the proxy target
-  // Short-circuits `res` in the event of any error when
-  // contacting the proxy target at `host` / `port`.
-  //
-  function proxyError(err) {
-    errState = true;
-
-    //
-    // Emit an `error` event, allowing the application to use custom
-    // error handling. The error handler should end the response.
-    //
-    if (self.emit('proxyError', err, req, res)) {
-      return;
-    }
-
-    res.writeHead(500, { 'Content-Type': 'text/plain' });
-
-    if (req.method !== 'HEAD') {
-      //
-      // This NODE_ENV=production behavior is mimics Express and
-      // Connect.
-      //
-      res.write(process.env.NODE_ENV === 'production' 
-        ? 'Internal Server Error'
-        : 'An error has occurred: ' + JSON.stringify(err)
-      );
-    }
-
-    try { res.end() }
-    catch (ex) { console.error("res.end error: %s", ex.message) }
-  }
-
-  //
-  // Setup outgoing proxy with relevant properties.
-  //
-  httpProxy._setupOutgoing(outgoing, this.target, req);
-
-  //
-  // If the changeOrigin option is specified, change the
-  // origin of the host header to the target URL! Please
-  // don't revert this without documenting it!
-  //
-  if (this.changeOrigin) {
-    outgoing.headers.host = this.target.host + ':' + this.target.port;
-  }
-
-  //
-  // Open new HTTP request to internal resource with will act
-  // as a reverse proxy pass
-  //
-  reverseProxy = this.target.protocol.request(outgoing, function (response) {
-    //
-    // Process the `reverseProxy` `response` when it's received.
-    //
-    if (req.httpVersion === '1.0') {
-      if (req.headers.connection) {
-        response.headers.connection = req.headers.connection;
-      } else {
-        response.headers.connection = 'close';
-      }
-    } else if (!response.headers.connection) {
-      if (req.headers.connection) { response.headers.connection = req.headers.connection }
-      else {
-        response.headers.connection = 'keep-alive';
-      }
-    }
-
-    // Remove `Transfer-Encoding` header if client's protocol is HTTP/1.0
-    // or if this is a DELETE request with no content-length header.
-    // See: https://github.com/nodejitsu/node-http-proxy/pull/373
-    if (req.httpVersion === '1.0' || (req.method === 'DELETE'
-      && !req.headers['content-length'])) {
-      delete response.headers['transfer-encoding'];
-    }
-
-    if ((response.statusCode === 301 || response.statusCode === 302)
-      && typeof response.headers.location !== 'undefined') {
-      location = url.parse(response.headers.location);
-      if (location.host === req.headers.host) {
-        if (self.source.https && !self.target.https) {
-          response.headers.location = response.headers.location.replace(/^http\:/, 'https:');
-        }
-        if (self.target.https && !self.source.https) {
-          response.headers.location = response.headers.location.replace(/^https\:/, 'http:');
-        }
-      }
-    }
-
-    //
-    // When the `reverseProxy` `response` ends, end the
-    // corresponding outgoing `res` unless we have entered
-    // an error state. In which case, assume `res.end()` has
-    // already been called and the 'error' event listener
-    // removed.
-    //
-    var ended = false;
-    response.on('close', function () {
-      if (!ended) { response.emit('end') }
-    });
-
-    //
-    // After reading a chunked response, the underlying socket
-    // will hit EOF and emit a 'end' event, which will abort
-    // the request. If the socket was paused at that time,
-    // pending data gets discarded, truncating the response.
-    // This code makes sure that we flush pending data.
-    //
-    response.connection.on('end', function () {
-      if (response.readable && response.resume) {
-        response.resume();
-      }
-    });
-
-    response.on('end', function () {
-      ended = true;
-      if (!errState) {
-        try { res.end() }
-        catch (ex) { console.error("res.end error: %s", ex.message) }
-
-        // Emit the `end` event now that we have completed proxying
-        self.emit('end', req, res, response);
-      }
-    });
-
-    // Allow observer to modify headers or abort response
-    try { self.emit('proxyResponse', req, res, response) }
-    catch (ex) {
-      errState = true;
-      return;
-    }
-
-    // Set the headers of the client response
-    Object.keys(response.headers).forEach(function (key) {
-      res.setHeader(key, response.headers[key]);
-    });
-    res.writeHead(response.statusCode);
-
-    function ondata(chunk) {
-      if (res.writable) {
-        // Only pause if the underlying buffers are full,
-        // *and* the connection is not in 'closing' state.
-        // Otherwise, the pause will cause pending data to
-        // be discarded and silently lost.
-        if (false === res.write(chunk) && response.pause
-            && response.connection.readable) {
-          response.pause();
-        }
-      }
-    }
-
-    response.on('data', ondata);
-
-    function ondrain() {
-      if (response.readable && response.resume) {
-        response.resume();
-      }
-    }
-
-    res.on('drain', ondrain);
-  });
-
-  //
-  // Handle 'error' events from the `reverseProxy`. Setup timeout override if needed
-  //
-  reverseProxy.once('error', proxyError);
-
-  // Set a timeout on the socket if `this.timeout` is specified.
-  reverseProxy.once('socket', function (socket) {
-    if (self.timeout) {
-      socket.setTimeout(self.timeout);
-    }
-  });
-
-  //
-  // Handle 'error' events from the `req` (e.g. `Parse Error`).
-  //
-  req.on('error', proxyError);
-
-  //
-  // If `req` is aborted, we abort our `reverseProxy` request as well.
-  //
-  req.on('aborted', function () {
-    reverseProxy.abort();
-  });
-
-  //
-  // For each data `chunk` received from the incoming
-  // `req` write it to the `reverseProxy` request.
-  //
-  req.on('data', function (chunk) {
-    if (!errState) {
-      var flushed = reverseProxy.write(chunk);
-      if (!flushed) {
-        req.pause();
-        reverseProxy.once('drain', function () {
-          try { req.resume() }
-          catch (er) { console.error("req.resume error: %s", er.message) }
-        });
-
-        //
-        // Force the `drain` event in 100ms if it hasn't
-        // happened on its own.
-        //
-        setTimeout(function () {
-          reverseProxy.emit('drain');
-        }, 100);
-      }
-    }
-  });
-
-  //
-  // When the incoming `req` ends, end the corresponding `reverseProxy`
-  // request unless we have entered an error state.
-  //
-  req.on('end', function () {
-    if (!errState) {
-      reverseProxy.end();
-    }
-  });
-
-  //Aborts reverseProxy if client aborts the connection.
-  req.on('close', function () {
-    if (!errState) {
-      reverseProxy.abort();
-    }
-  });
-
-  //
-  // If we have been passed buffered data, resume it.
-  //
-  if (buffer) {
-    return !errState
-      ? buffer.resume()
-      : buffer.destroy();
-  }
 };
 
 //
diff --git a/lib/node-http-proxy/streams/proxy.js b/lib/node-http-proxy/streams/proxy.js
index 7dd9c26f7..08dc2fdb7 100644
--- a/lib/node-http-proxy/streams/proxy.js
+++ b/lib/node-http-proxy/streams/proxy.js
@@ -5,18 +5,20 @@ var Duplex = require('stream').Duplex,
     url    = require('url'),
     util   = require('util');
 
-var ProxyStream = module.exports = function ProxyStream(target, changeOrigin) {
+var ProxyStream = module.exports = function ProxyStream(response, options) {
   Duplex.call(this);
 
-  var self = this;
-
+  var self   = this,
+      target = options.target,
+      source = options.source;
+ 
   this.once('pipe', function(req) {
     var protocol = target.https ? https : http,
         outgoing = proxy._getBase(target);
 
     proxy._setupOutgoing(outgoing, target, req);
 
-    if (changeOrigin) {
+    if (options.changeOrigin) {
       outgoing.headers.host = target.host + ':' + target.port;
     }
 
@@ -29,14 +31,81 @@ var ProxyStream = module.exports = function ProxyStream(target, changeOrigin) {
       }
 
       if(req.httpVersion === '1.0' || (req.method === 'DELETE' && !req.headers['content-length'])) {
-        delete response.headers['transfer-encoding'];
+        delete res.headers['transfer-encoding'];
       }
 
-      if(~[301,302].indexOf(res.statusCode) && typeof response.headers.location !== 'undefined') {
-        location = url.parse(response.headers.location);
+      if(~[301,302].indexOf(res.statusCode) && typeof res.headers.location !== 'undefined') {
+        var location = url.parse(res.headers.location);
+        if (
+          location.host === req.headers.host &&
+          ( 
+            source.https && !target.https ||
+            target.https && !source.https
+          )
+        ) {
+          res.headers.location = res.headers.location.replace(/^https\:/, 'http:');
+        }
       }
 
+      try { 
+        self.emit('proxyResponse', req, response, res); 
+      } catch (e) {}
+
+      Object.keys(res.headers).forEach(function (key) {
+        response.setHeader(key, res.headers[key]);
+      });
+      response.writeHead(response.statusCode);
     });
+    
+    /*
+    //
+    // Handle 'error' events from the `reverseProxy`. Setup timeout override if needed
+    //
+    self.request.once('error', proxyError);
+
+    // Set a timeout on the socket if `this.timeout` is specified.
+    reverseProxy.once('socket', function (socket) {
+      if (self.timeout) {
+        socket.setTimeout(self.timeout);
+      }
+    }); */
+
+/*
+
+  //
+  // #### function proxyError (err)
+  // #### @err {Error} Error contacting the proxy target
+  // Short-circuits `res` in the event of any error when
+  // contacting the proxy target at `host` / `port`.
+  //
+  function proxyError(err) {
+    errState = true;
+
+    //
+    // Emit an `error` event, allowing the application to use custom
+    // error handling. The error handler should end the response.
+    //
+    if (self.emit('proxyError', err, req, res)) {
+      return;
+    }
+
+    res.writeHead(500, { 'Content-Type': 'text/plain' });
+
+    if (req.method !== 'HEAD') {
+      //
+      // This NODE_ENV=production behavior is mimics Express and
+      // Connect.
+      //
+      res.write(process.env.NODE_ENV === 'production' 
+        ? 'Internal Server Error'
+        : 'An error has occurred: ' + JSON.stringify(err)
+      );
+    }
+
+    try { res.end() }
+    catch (ex) { console.error("res.end error: %s", ex.message) }
+  }
+  */
   });
 
 };
@@ -45,4 +114,11 @@ ForwardStream.prototype._write = function(chunk, encoding, callback) {
   this.request.write(chunk, encoding, callback);
 };
 
+ForwardStream.prototype._read = function(size) {
+  var chunk = self.request.read();
+  if(chunk !== null) {
+    this.push(chunk);
+  }
+};
+
 util.inherits(ForwardStream, Duplex);

From 08293f96bc319f3c9850a279d5e4a1e11b3c62ac Mon Sep 17 00:00:00 2001
From: cronopio <aristizabal.daniel@gmail.com>
Date: Wed, 10 Jul 2013 12:25:15 -0500
Subject: [PATCH 07/14] [fix] use correct name, make example tests runnable

---
 lib/node-http-proxy/streams/proxy.js | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/lib/node-http-proxy/streams/proxy.js b/lib/node-http-proxy/streams/proxy.js
index 08dc2fdb7..aa5573c1a 100644
--- a/lib/node-http-proxy/streams/proxy.js
+++ b/lib/node-http-proxy/streams/proxy.js
@@ -110,15 +110,15 @@ var ProxyStream = module.exports = function ProxyStream(response, options) {
 
 };
 
-ForwardStream.prototype._write = function(chunk, encoding, callback) {
+ProxyStream.prototype._write = function(chunk, encoding, callback) {
   this.request.write(chunk, encoding, callback);
 };
 
-ForwardStream.prototype._read = function(size) {
+ProxyStream.prototype._read = function(size) {
   var chunk = self.request.read();
   if(chunk !== null) {
     this.push(chunk);
   }
 };
 
-util.inherits(ForwardStream, Duplex);
+util.inherits(ProxyStream, Duplex);

From 64b4e07ffbcd5581b3f6d7f7839f0d28d9c742d7 Mon Sep 17 00:00:00 2001
From: cronopio <aristizabal.daniel@gmail.com>
Date: Thu, 11 Jul 2013 14:07:38 -0500
Subject: [PATCH 08/14] [fix] maybe another typo

---
 lib/node-http-proxy/http-proxy.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/node-http-proxy/http-proxy.js b/lib/node-http-proxy/http-proxy.js
index f76187889..379e9dddb 100644
--- a/lib/node-http-proxy/http-proxy.js
+++ b/lib/node-http-proxy/http-proxy.js
@@ -164,7 +164,7 @@ HttpProxy.prototype.proxyRequest = function (req, res, buffer) {
   // Emit the `start` event indicating that we have begun the proxy operation.
   //
   this.emit('start', req, res, this.target);
-  req.pipe(new ProxyStream(res, options)).pipe(res);
+  req.pipe(new ProxyStream(res, this)).pipe(res);
 
   //
   // If forwarding is enabled for this instance, foward proxy the

From 1a4da5d76e746209d086ee464552aadc60c4fde8 Mon Sep 17 00:00:00 2001
From: yawnt <yawn.localhost@gmail.com>
Date: Thu, 25 Jul 2013 21:19:15 +0200
Subject: [PATCH 09/14] [fix] started fixing stuff

---
 lib/node-http-proxy/streams/proxy.js | 33 ++++++++++++++++++----------
 1 file changed, 21 insertions(+), 12 deletions(-)

diff --git a/lib/node-http-proxy/streams/proxy.js b/lib/node-http-proxy/streams/proxy.js
index aa5573c1a..8235e9537 100644
--- a/lib/node-http-proxy/streams/proxy.js
+++ b/lib/node-http-proxy/streams/proxy.js
@@ -8,9 +8,11 @@ var Duplex = require('stream').Duplex,
 var ProxyStream = module.exports = function ProxyStream(response, options) {
   Duplex.call(this);
 
-  var self   = this,
-      target = options.target,
-      source = options.source;
+  var self    = this,
+      target  = options.target,
+      source  = options.source;
+      
+  self.origRes = response;
  
   this.once('pipe', function(req) {
     var protocol = target.https ? https : http,
@@ -21,8 +23,13 @@ var ProxyStream = module.exports = function ProxyStream(response, options) {
     if (options.changeOrigin) {
       outgoing.headers.host = target.host + ':' + target.port;
     }
-
-    self.request = protocol.request(outgoing, function(res) {
+    
+    self.request = protocol.request(outgoing);
+    self.request.end();
+    
+    self.request.on('response', function (res) {
+      console.log('yarr yarr');
+      self.response = res;
       if(req.httpVersion === '1.0') {
         res.headers.connection = req.headers.connection || 'close';
       }
@@ -56,7 +63,8 @@ var ProxyStream = module.exports = function ProxyStream(response, options) {
       });
       response.writeHead(response.statusCode);
     });
-    
+
+
     /*
     //
     // Handle 'error' events from the `reverseProxy`. Setup timeout override if needed
@@ -110,15 +118,16 @@ var ProxyStream = module.exports = function ProxyStream(response, options) {
 
 };
 
+ProxyStream.prototype = Object.create(
+  Duplex.prototype, { constructor:  { value: ProxyStream } }
+);
+
 ProxyStream.prototype._write = function(chunk, encoding, callback) {
   this.request.write(chunk, encoding, callback);
 };
 
 ProxyStream.prototype._read = function(size) {
-  var chunk = self.request.read();
-  if(chunk !== null) {
-    this.push(chunk);
-  }
+  var chunk = this.response ? this.response.read(size) : '';
+  console.log(chunk.toString());
+  this.push(chunk);
 };
-
-util.inherits(ProxyStream, Duplex);

From 10c218b8042f61c6b68401cf4217808ba9b9bfdf Mon Sep 17 00:00:00 2001
From: yawnt <yawn.localhost@gmail.com>
Date: Thu, 25 Jul 2013 22:22:20 +0200
Subject: [PATCH 10/14] [fix] fixed that f..reaking bug

---
 lib/node-http-proxy/.http-proxy.js.swp | Bin 0 -> 36864 bytes
 lib/node-http-proxy/streams/proxy.js   |  18 +++++++++++++-----
 2 files changed, 13 insertions(+), 5 deletions(-)
 create mode 100644 lib/node-http-proxy/.http-proxy.js.swp

diff --git a/lib/node-http-proxy/.http-proxy.js.swp b/lib/node-http-proxy/.http-proxy.js.swp
new file mode 100644
index 0000000000000000000000000000000000000000..f3ed579f8917a029332031333a814c80584e9569
GIT binary patch
literal 36864
zcmeI54|HT#ec#6<U~m9K0yvzc<n9`nku1$>ajA{gTcg!VmatY58m-qG+wnY&o}}@P
zX2$d0tR&VlB%G8c5KaS0)7Ay&lt2Q<BysJS1A%}OQ%<0zp`|IL)J~elhLRY}IVA2m
zK>PXq?!E8NXjZ#%&gn^-nX})WdGFo7zx%uQ{{G#km9d*<Pnc`UR~Puas8BfbmZ#o$
z$wz*x@LzTdg`Hrl8O!|(eBwsXXw@!|h{tzpfrlnrt6_Ag-Dz#_9BR~84mG(R-H7A%
zsJ)l|EZ-4bxYR+40R;vWxF7|(@!IIMFDP97n!{s~_R50?%n$wG$qQy1Bp6U&K!E`T
z1{4@jU_gNZ1qKutP+&lT|9>bDw=XTcneIHxb*bULFX{RIes>+X@6Dd)&vw^$xbM&R
zJb#Y6zRP`I>niZ|T<Y#O-S>k%&!6k=zukQwbPe|Tzt7$G*B|bA?j8@m1{4@jU_gNZ
z1qKutP+&lT0R;vW7*Jq9fdK^u6!?2dfnc>z_y_d-Yoa*g|M&X;cP}p#{s8<(unX=2
z{}6oZg@wX>U=17qUw%QM@Cop7a1Oi<;ASlR<?{=L`@s$v15f-wp>Qv_4crP&gPXx&
z@O<#ZWrf1;fu9EfD1%Wj44wnN@Vr9do!}U_9$W=V;1%F9@O2CXUj&~4{}#L(+y&ZT
z4b;FecsBTLj13<F4}o6*?*?xMcY_^p6L=$d3HWyyE*=K&1$Tkd;AT((F9&~&;o}kT
zN$_TH4R{P=$sd7_gSUbkz~$fvz-8cD7%RR49tNKP9|s=+{~G)fxDzzNb>K(972svy
z#o+VUHGUS%fM<ax88;cbuX@AB`MB7aLx&3TpIO;4tKnL`S&!?jX4%~f4Z#;@>#O0a
zX?0Az5t>#z>;#g;Y}FeLvli4F{E9bB&@|Onr@mfqn$3E&8N{`Xsx2jGu9|8T)<(C&
zm8exa6UL)9VbyGe!D`rv$k~=MqjJ>hc4}eO3=f|;Sy>()wk1f#r^1zrW;PoX7;OY+
zLKC-4jjMHjk)o##f={%et`(Iq?zT;^x~d%v8uUb~G;8!MEnI_5>dp1CIkgcs<zbC0
zZAO9rcY&d{dQ=XZ!Ac`6Z<Ayz=&YKfChl~@BP6J=mExUt*jnqK@W9cdrnu5-HNv1-
z95Uy~!M{wI6y@n*D=~N7WzOwN(SEdSZ%8!?z1PAZ?sme+KIebi%1C;=C;>I4qHAPv
z$hOavv^sa!wjrB54m#^$EU7c4HP&u96YktrUJ0Vm$mgh$pd78Cd^_on@t_oiE}d3o
zOmba@v~jD}YV65J3Ho54yuo_djQiC&ArE>ou63I=Wzn=trbN?iKRpSDjdtYR!pa?C
zE#5WKdehPiWvmWV4b7Ht0WII&felQp)r<q?2tR}7j&?tyhjGlE$W5AINp3rOPUv%&
z{1@$-$yO&c64gZflG$vnb{opTo5IMQ@Xl@+#gR^>q#WC6E##Kywz770*XWnDa3wU|
zh?&XEmC-cyW)ug_T4?hZbXM<^fK1F8JJMCU!z6Y5P&L(!Ruqr7Tb;N{pEp<PO`S@X
z!%Rh|l4Ng&wJ?f;&Q4N!+6;3x=+tG3L^6xCIl@iKcyWC*Y;_sXl+)cU;ZK`HS<vK?
z=&dA$Yi%}#yOo_O!^U>eBm=#WnfTI);o*q6IIQEg4J~cOZuTY}(+-$n>5ESHzQqOp
zu?<=?rTW?^j54H|Z3&imuwK2E@|BzJ<2D`tLpz;0(m5fAPQ>smydIUO<ZEiP9>-y)
zTnicvoy^&}8gF!3TMW*Ynd)>}ol@~wixt{0vTm^b5|eNM>?wR$?}V%6bfGxl(#aa+
zf0u0@nNQNt8NUk9*l=68CMsv|CG)Z5%94ysLv|hg>?Xft>GF5wk(4!VUN<&&ICopQ
z(-dWeZ^-ZBNanE{pmD9kRzR`Y6q$0zG8v88w_MxjY_Yx*Q`^C2o7tR<qU{?EF`Gd%
zU`t%r$=0Z^g`>5dnj~E_QOpXnDbG3#Y=_0iE;G#NndRlhWKAeb6DQdm*<NZfWhUg5
z3S^M|#E+!dl<@2bZL-ywf>Okle9Y_pX!d2_o@K;lO6yCDP6m>KWl}@Bga_p6sOO|o
zv0UyA<+QwI49ouZPDQEEljV@5jSB}Y4viF~&}lpKT#jrNNqRT-K1a9Hkc{q=$-#pp
zO^gJSe6neH;1fyjk~G=g$pc9w)4)zopDa_7eIUsS!%D7Gv&%DPd1lH~7N(a^O)O2B
zg(bZ{S<#;hJX<oyrzYlR=WnQ(+4)>zS>G3?&E&%T^3ufQ@`zbpSX!16G~21!%G8LN
zSemVn*Gw-hoER|+CwV?CNhpeZ^HY<{vkUW-GdDYNY;MX-^JrrJw3(cnm?i!3i4zky
zOjVLHHQDUk?DFXmb82QvTSrL~{PP9PFU-%*PcKpD)QPG2<+9W?zhI_r;=)vBCg$d}
z4-+SsXBL*U<jIA_(@V2A%q*Lkg}LKX+&nf#i%v`}P0mcrFHanE6;97C&rek<wvA?S
zVrhAH^5opal36^tw73AlCgzWmZ|dg7B}pcoJh3=8J9T`7HcZZ)JT7!N1_kC9mg&fe
z+2yI@kW8Bc?U$%)R{A<kA-OS`t(e87g_~xNlm6fY!%#U$_Zd1Nr^|U-=qi-Ead!SV
z<BRautTnnKFe8|;HnV-U>uiBc)u_878+2Sp_>_fB1YVi3vIkXKYcbo3?%m5=2P>_!
zq2%2`q~3^;8{&G6+w9UhNs+>lvLlhh-6JGoYFi2I9viX|H5#ogSzZuYtk4_D{-QZ!
z`HG}|<cO_})@H5|24P~Y+iBLL4f;Wf)s~4`Bhmp8mAFGWt92%6eWe?R`k+Dcni0Qg
z;vwm5nCW}IkDA67BASE90gXD_nN=%<8ro-V8}iGDl3_$druy0r-yyQ;h-r6M8Z=Or
zhJ&7Z2Zu(qxgivW{8_@PWF=LxD$;J14@cZ!K_p5Ev>rPk5Fm0RqBIX86qh>k;3~AJ
zbvN07ZEM%+BHyq9hm^3G4hjWqgq;x4Y`w#fhpQuItrP0HkH(@MfUY7#+JQjubb_Uf
z-()iGrP`2r&Dh~FGfA#SJv2+L6{N9f#GI&~k!~)v))`4IgHCY9RCN31ayndP5N4aJ
z-MG0UMfQZ#BZH3Xnr$~75nH@$S~xUZ5dHsA^!o1s(f_>~Dc52H7<>j47*Jq9fdK^u
z6c|uoK!E`T1{4@jU_gNZ1qKutP~h)61$I^c7d8JkMDa)e4_ue-=VlD92iJik;0o|n
zeEv^>{|O!hTVM$MIX?fdfnNi^2zJ3qFaZvOG4K>|0G|bK13v+N9GnKr;AP-T!~why
zycY!EmEi06{vQXw27Vk!EWiix_x}o52LA_t{;z@$fMxJqeD<FKzXyI7+y~wYvi|*H
zu3rV7#(yvV{ZE5WfxE#`a4k3pzKJjYVekp?G4N6F5QxDM@K^ZqKLOqXj({QXYVhyz
z(?1B_4!Yo0a11<&zy4wHKJahAd%zkv29ARN#Tfi4cnHXN{5t6Q7(VLORG;6nI0KzW
zQA~Ll2r~|D_W+ZS%Tr%7C2p2CLu_%YM!nNFOf471;Uo8*kG|Y(W6HvN8Mo$ITVZEX
zoV`OfdE(f2?rd!f-UBhfRb9UEB$0Rf(*)9_u6NfmoTJ?+#><ZZR12UnRjhv6I;@MD
zO-x$yafQziM^F}PX-Qh^JkK~KxWHO3K9XbIwY9KQ%BF9G&GmRANqp##6p$@ZY>C0y
zR(%yZ#F+fV+KRolA@(~HHG&nhqNPUG4~xZ7tZbMOJ7Nu#&*akFwEcz4|JKf}O*~ch
zI_z{R*bs4~A0>#Qftk}iz^F-G5)^S1pTED0<#N3x#$4MS>%O-hDfP#zizIa#N*&g5
zI8sQwHr4?zkqPo^dncj%lJ!1IOT6b?I0Cz_23(9}X)@yaoVxI;Vvu$o!Kyl|u!CYx
z+>A_+8C|Us7nu(qfwnTbK1#zx?XXr~t7BnZ*-711mcXg+b}5XyjTl=hChKbAb1K_p
z(&(XTnpubcoS1u?>$^sHM93<pPN|vh+y42vqHVWcGWXzIGmOg>CBiNydI?=gvUi)5
z*3hVcth+9)oyM4Rm9T?v&k=ZcZ=J$oN*P~yIt2a4C_gaL!(>FLniW=j-!}e(29(?N
zc32YrpUyhZ^3fk|2Iw$`*x}P?kr5${{D(zZA45BFerpa{H*z;MlEqK`bT}zOVjHBV
zLUtl>C@+#;+rT2GO*LCil@72j%&rNkr8Z%EmN6R&v+4$b8{X}SX}zT`dCOu{q9w=@
zkt4xk>TiUKu1iBhmPXvrUS+6&v!;V<xt9jc_nnO~5NEu0uBv&e))hztSL+gkMEm27
zAU0c}UDZ~?^{(|!*cK;~LOgpih}jXetXL+<WZ4EyxVdjH@+0A5C}eIXWta<p2;G4;
zaZBfq^y{KNlG<+$w-mQW-DriY68jLhinp2TO>v}X#!ZoJ;VLcmf?1B*y-4_)x!S*2
z_9a`Q7J1>eYC~~?5v(Fhc)1g9w&HLR51edqj=t$lHytjr-2N@4?7wFJZH|4rZ<8dw
zmj)It+)7gPC%}Z8h`ls$_b-+V=Vt>LqL&D^!RO@yn`1vB*c2HWB&$$wINqyYt+PKJ
zcjNBZ0hc-A1RxfhVN=a9Fr==I8)XsaptTW;INWHwEN6DA?#U>eFFAb#*m-hm)xDYN
z8(C);jUSo)GTRc`tWYA7*mVTYB8w?Yk%ndl?RKc{;$+RW;YAWR7Mvw+QvyT$s%#6e
zOB=ph*|c!sTfeP+R(HW)G!6-8a}!y}K5#R@m*nWfyt0cP%khq>1x-tB{!cfjWbQCX
zB43SKi43MeS{f_LN+iQ8?Bc|~qY^rKd}?lLd8#Pmc_7D1y~X%3c44LxjV07^B5}|l
z{$_QD-o`dQ%l20`7Li<REq=IVb#F>iUFHwwYdR>at$e&N<JV9Z*s~}b&mKum<<kCw
zoRpOah#C1X5%4Z3+bx|>q|=Shic6^oXN8`>k*r0zskEbUN8zqn@KUQvNWM)70$ZIr
zqOb6e2z;wS9Kb$a1R_d_VNFZZ`L>HQ8@7|Zw6`#2L!Y@ve)4q+6FEV~bzY^VE-^mk
zdJ|WDJ&sC=q&(tcd2*q4EQlhO*u+)>wShgkR89g@F~Y_sFW8{yG}1A5o25*}e_<KT
zWFw%<BHM}zu=gIkK_(Z+Wz+R!7WUzj)@aMLcO~<=K9O!N*6!Ldg9s`9|0_{4pAcOW
z{r?W9aQ-Q}{$oI51HKII0k?q?xDq^$&i_Hs24}z#@E7R#{}NmWt^rS=)4vOhgVzB$
z1MttlB)A^@WAHun`R{_K!N<XSz+GSqEP&U79|l)|XMsOK=l^Z+0N4UYz|~+B3;{V4
za3%N-wt&9^kAnXWz69P6{wa7XSOnLASAfgFcd!TiCHOXY68r{u6Ntbe@Ez;{Pl6AD
z4KNQz!B?>Zh<#uU+yqX7Y4AMoXV?P%5Zn*8zzVnt%z<mbmEh&z#o&41x!@A;DQpGr
z06z`Jz$?LLu@Bq>-U=$<0FW_ze6Nk5$7G<FjwAFdCW!YO%bkWI>Wan0urrRRd{KQ6
zoFYPBQ2Ol>ZgcDGtJnlBqK`|()ehSba&xLo+J)HHwr?HnfRLY3M);5&;J{j=E3rt~
za%3%Zx8d|`D|B%w$)b`eM#9j`R=Y_I5#zptD&(gfmxUs|O2{yx`^bncS4qiAwt{r6
zZyry&Ruj6=B5Fz${Bo<AERb2%TU)N;i4#y%AJRRYty_A>X6d)vYNqE^FU)FtSga<9
zFG?&2y2`R^%ZidwL{*g*#Y_uw(a){`yRYpgolVC*{Y4~L7zeeD?3khS)HX~h+|CYI
zHcR%m1m~K=V`E7zLQMJWOHezMmeqQ4W>lr~v0y@2TayxaLj@+bBWT2KU|L&x492I>
zG}9ahaaJj<I@R=~2Ut9;gs~As&0<_gvub_0>y)TIl_y#Uq9I{5B`Cd&6hQp;!OS4L
zSt#;Bt21t16%mw(u(m02`0HVQZc5R1UhgfSXBuCC+!r^qi7r$f+pY$Crm_|1`b}mV
z@SaZReTTm9{I&;8_RMh4{a%f?D_P%}>`3KC$qJr*Rslbwr4@3z!LxX_=jWO2i3Ib^
zXM2_~eW$x$(yUOGneKLp_REI0w(n$j{m0@-1gIBe-3EX@kxuh$hcgd!z0Nk%5-6F8
zt>#H<NEX39r7r=UDeKrQ-jpPZ6LYiEYIB|hvC&CgG?XQ70qc=7>Q=2#Cdus?89&%|
z#ii?-MHaQ&?W2-UAt$$V74daek|Qn&L2HCxat6tfA}Pu)Wqv{P->{>f1a%H+aMY_4
zhug7d9+s#Z!>~QksGki>Qu&BU*S`>Juqr+mU4-XBuUr{EF7v)M$yoJC=ZllaXM8i|
zCY{a}Jl{GVHi8}PfLnvp(!90G_A43wUdrdn*JV<N^)+R&SUOEq^{#|oG=gzITsF%v
zs3^Z0_pF9^v;(K5&V&st&8Y~2ZY`y#EiTJTw!Iv;X`s}n$8Y*d3psnB&FB{rmC_T#
zAT3P!KuEUFN3~m4dvBa-2lb8^&bFdRO=nw?KQ6IPA^wpTmT1*Ei^jktH!#VqijDSf
zlSwYW&JT=mvIF|_hyQPkaI(q!t%CRO$DP)W?C_%hqpBBPjy@^+zkfg9ze2}<2Y5TU
z8%%-&;3eQGbp6kQkAM$@_k(wVw}5RRHh~t{09S)&gYQwv<KWZaCxOHTTn;{lU7!wX
zU<KR?t^@_}zp)Q|4!j5a9C!zK19&O89J~-*3O<Kj-~n(SxEsj(1KtR31aAN@0bju;
z@QYv$%zzt!yhGq6;BoZ-{{j94d<FahI0lY_mx4b+|Njt>cLQt#u?Z}IHvq8>Tn0Xm
zE#R}@_rW9J9`MgW3(SBK@FMUn>;iuP9t017v!Dyw;5u+A_%=3xZ-V~>9s<7w-UWUJ
zTnofz@FMUuc7bn#Z-D#3hrxZ|SHWp;Irt>w`X<l?r@;;2YVb<%W8f7)#{P#v?xQ<&
zf&I-&hO*aij)ecY=S72Y$57VdiQ!G`<>RPxcgmft(3hyzXz=HF=A|#^N#~rj_|o+R
z4m#`bFyi74=X9NKu_nT-N{wO_OuX6t9JboHMMC#7Zz?CM1c?A4nlK0P&xjBrWpF9M
z5^*QM-mxmjb2$F3&U_>e*AY603T?f4n6<f$!NMxls$n+}Q9G(bS{Glf(TX^nZz7@#
ztYZ>SG}kx-5lG00tmiG8RqCjY@FD}19o;!yp>EaNNHx7zYAnV0-%1;Kp{1f_EXtBH
zC8{DC5GtedW@e=qraMJYh!f%bFqSjxfjoD^V}F<}PBq!nV`|D}B<kuDagUGNwIts?
zTPxkw+fC$Q!>P72atsR(fl?9aUK*?KcxZ%jYTOp6KNxE{ZeEt0%VaDiQYFf)lTLH&
zmFq#0SXoACf{CId>Ncf&)=Nb(&qr14MZLtdLnA|LtpOR4Qp*yxL=JapX9ziva0MA@
z1~^rDFdjI+v8|u~#i*4{;tjx7v`pThfDJ$=RmpRL9YcRr#t@)yOE_xum(11VnG+8w
znL@n(HkYCua9Es=O~Fyw+*9X?;b~E#gmTaJt5;4u+EO#Za#`-?ijX7Ndy~msN#;lC
zgueX)g8FWy(_gwJ3yw|A|8{a@I$L(HDN(DTzNle7*bL28rZ|4+P?2xz3!ZUx%9523
zs_fb)v=J||Pb8|6_A6`L&vVwKeN&02zc`~@Q!#9&o`30lS~eHX2jEyh>%U5k^(Q-Z
zp^1Eij9l7_qedM1+_5ck4h2c#4pOU`Chd4n1?qS}15poz>LBt<1DAw7{TORq`K<a#
z)_6ZmC}$d^V_#iSl|!(49r+u{#Ax$66nj{nb(d3<)t>W;1QtoL<_5Q9GKaMT_AIFq
zMN~W)0#8-lHfr`Q9<0+oTEsSw|2<!*2qe@oqXzGXxERMo1JkaL3qQz1OKD98-$-iw
zDA$h3?POtbWH%*w?p7pUOFHe7P0t$x#9E|F$$5;!ld{aX#W}k;^eqTW%taKVOQ2oU
zutN8*-dn4()%WJxTU&1~=;KMf*HWA<F1J?WO7&rI87sNAg!zyVT$g>RKp9RMM7Q=#
z?t*>nec9D40jo|>F-m<62*R*#&DmmAaCzPKs8?)`{TvCF4ov4XW=`gLvZKPeX^aqw
zz1_IUYdX9zp#hILTzHd&oHJJ1Ae7kJ_tGxgkv*KS4>5BCbOB<fq;L^U>8SM3H5Fkp
zW7?O#l9A!k{C0AjM<(>sLl(oc;hf`#ecdPtz4s+fZ-IN6c)|Itv#fuCRyvATT1=;;
z85vq=)X@dH;fLm;^6zc6&z^5}whet6nam~c#ZhS}JELr@WtO5&FwK;#%d^hEUc(!L
z;rY49F;TDl>Dgj0(|aFD#<7$pPJglD^m8d?8tfbeef&oV<=%9e&?Z@D;9Wj$wec4S
zs}gE+Ue6JeA6w=#@*DYyVyj9ebbIZo(a&R)9j`shgLULu>9ns4N%VhI=)z;p|KD^<
zpv3=+-oFEG1vi4%g2P}8Tm|GDz`Y;_qVJc$pP|$LF?cWdC2$%nfvdq4;M?f+-vCbn
zi4S-mxE&bqa_}^b`4spV_$YV~oCP<6Y4Bq374-Rs!3Tky3%D1A;8t)6_zQIUPl9{F
z-QXa&0=x`7hCcsa!5@PE0DczCg6Dxp(Bt0&<eh+b0{%2YVG+Cxyc9fz{(e9BO>hph
z!K=X+(b<0=+ymYX-Ua>%I0xi?fX@ZrMPGjayc4X0qu^CQeE$CpJzdTVoC3381{?te
z@F;ru7r?KBcYqzx0_$KI%z_sHIXfU@_-H;Jz_L${kzvwe@?yOrEREJej2N$iDx|5+
zlCH&88TEUC=(<j`v%1?#SQ96{C_I_G?x*M3XEuXvJ%7I@uj}&#=d2$l`A&j4oQ&5u
za>EsTajsp~6Ia$Ax31_u{hYe_2n|<TU*~P^nOBgmGLc3?cpXQ#mw@O)pMb4JbZVQ~
zvDbOzvy`*@7(kHOq@td{j^5dks47V$Xd?4CH7++(PFb@E?Za!y+hW8HC2#L(wwlC8
z`#Wke>feuKld%ydu7Bwsr)@@l({H4Ub|aABo2_UZ`Cr^e<5|a1QkqgxBj})=Sg$mn
zscuD8`yNkz@zdF8w0)5n6IL*Zc|)4@gyy<Cn++AUrfadLb-K-_7}li13MWUby~}x0
z)91<HCCwC`Qb{`(4kr<xde<w%qN^sRAH)R-Bs{8L<w)L0R63@9!Sc#Z9M0)+pOR%N
zJJ{ttM}QIqbDnWp%#D*5#PfvLmpXMyV~&Z4(+@fX!|1`EtMvTOP$JG{^w<7H%Z%~G
zOJ6u^RngNcsYsbnh{7}^2#o>GS`(w=YKwOwg`-lp8WdOvL}&I)*28xCE~!?YA<L#D
z9ZyoafuRtX)bmPF)a{~jbJ0$QqVNlAjJ$46CZrlS+l{&pfgwKzQ<<ztt>Usx=A-zz
z5zFlBGDY>i<{!y<7CkG`3`1*H)?O@NCp^Q63Y)#Nxz^<cQ$GH=Ca=|WCv?iQ3n*#4
zBGv@5jcp`-@B^66A-|IFB2%<A4jgcXtjP{lD#{!x4wdiV%vH%A++q}6Nyglku1Ure
zE4<n^u|AJZ)M{ZHbGJ1lWz_zp&)(>EOELda+(2^{Z%eA7?8(G4JZ@avL~?}8@F}{R
z<B;4PXUad9nRn=L`7rTGhfRg|ZPhkpLM}R*N14<qHEwZDkXe`$B-1|N43E2!{Ly9`
zSKqgznM4dNEwC0bX?T{8-QtlH&Z`lV!pS5r0FzNk2FbOKBHS;TH)-pOYLv8<$h%50
zv$kVi)@p}Xv!uIOCR8U8_tS>hC_+_<a&)kJrrmj9l_aN7tD=VYyzNid+HgCp@wzmf
z2MNEVQ^8rd95J%hN&j7ZfC^?<vofd8Y%84Ejox`JAqljhQDUmJ?JD0c*1QuoT1+;>
z^pRVqe1t~!5y!uLgiJDYOlq7Z(jA7TnoXUnLk()#-lV!B?nd5#Y1gNfFy0C!tdT_`
z-jestNyuqbw$2h8wO`*9!y1kURwErony|>K#C!8JpUsn;(92dzN7X8<tJX>=Z>dho
zuw3L<g_QTiWyKq*6J8V&%f~U2ee5pmvuus!l#8r$D@!=v>NHKVdKO)YZh=j!FWL=P
zCr+*+VPO{n)x(RJw6f!3qgD2BCe%~M7xve-y1`hWWf&Yeop|C2xYC06WIM3_9)@5R
zUx$0GHm;nwNEBpdpgfasE;j24gNnTE&{Pnj+;Kf!<<%u;-z=^wbJuy~up-p)py@Pl
z6Ght`W2dvnIIKD%YnwF$rzek{u}zLJig{0X3!TNkC)ryDtzA1YBFoNFuXQ==YhQ-!
zZ5}XS?v=;|9ajFg{F4sXxM{LOS-wa(#vbU+jb6$Ec^{~!_r<sy9YuQmifPeR*8<mz
zw3XFFI*<|f-W2u!i^?c^r1<~e?)3l9q2J#Jeg(V_NIbwPFb{qN{1A8ncs{rk{AYCk
z&w~#Di3j*)PzASu>wugOkXV2b@D1z$4}f=qw}EMJJvacqgAL$O@Fnm?@M-WN@B#3C
z@XO#15Q3B7^`Hb^2rdJcg6Dwm17F8hAa;a%z`p=Z@LC}81M>F<#C{-uZ{VlFE|4<^
zcY-F^1b2WV;Ct8&9sxfE-V7vu;I-iS;A!jza?ape;CH}B!Ow#_cs=+ra0z$}`@y5&
z%ivzH3nZ3c2pj~T!Hy7up8)dr1x|q_@T1@g@HK1*zXRkQ1aAXkU-(I|0LowpJR5uo
zd%`2&e(+Nu1V0LX5WE<Oz2OVk6&?T|0`iW6b#OCS0(0O-FbyPr;3@dx&w>2ifrr3v
z0{PpD_kni<<s0D{v6`xb1$Hjiqe`0tS6SbZMy#dVTiJ)d^*Eo{nvy*>cUo24zV^to
z+r5~;auyi*W_yQM^t*Ufsa=*yYcx%Ya&|pkQd!8NxYgE`PYi`}Fv-n9o#SRAC&9{e
zae9nPH6l{4Y(@5<ekR(~@5p|O*<+l{H(HNi_gE$`V3pJ!7(Vo3A8RB}r=Ni(lF}i8
ze0)#jx3}c<w?5u^@p0<jSmCoUDxOj~!dRip5+*Bir9!0)bIv>=0&K5oB5#(+)nJVi
zwT*7`jIxtw8_}S0TdPfy3mg!J=;0gWHgvOkv!LTLDa9&#<@tsP6eb1sHZ9Z!3uq1@
zdaikv0BU5*wZ;Z9xWVzv%n0enmEgn5R$HN*P2fH4I8@xeu@r6woiiLgU2me#v4g4`
z)f)4hAwb<~1>NhkGja+vNZf46mYdFGB0KCW{%x#{&C36tgB-`gk+yaYXYxXY?Kg#;
z*3dZKe5>4Q<}R){LMbFxA~4BcvTz<L5hJvE!hPu~?^_o`dsnOu(mQRe_REThiI|m`
zb3A=y>^KZ6@`&v}@`Y5#>+pGnzlKh-@)WIK&KFG$*%89_pg{oc-udG-vh3@dl$Xl_
z-m?r(1gt@-TG@J0c!__ZR_L~X&p}^pqShR@2&rJkVcJepk1D%^fBFYnM5@x9!dHH$
z_qr%87iM>2f~dDiii-^gk^D9|B$wUFRY@3wCyn0DB~+)n*^^Liixic#N1gq9)5&cq
z&+|WuAAj$~=W^szLUh7LcviFsh8(Vmc|Er!sbA%?Ln=keCn+d%Y}fZi{*Flg1uT{i
z`oDYSc9(6*X(U;HHZ&AApbreNgh6E439Fo+pgK3<4w1w~Qs>R$QW|~o+@$AWr|o7)
zoR%a?Ua(T7nyPS$-1cXd)8|sRJrPX0XL=0x_1KWk%4v;cv+eD-Z2d#h)%*tTmwx}9
zE*W+ptX7h4?e?zDUK{u1{KnBO!V$NXq4ty<PfOb2PCTT$1}RKQO$cNVOIDx4d}`TH
z>`H+xGLz0eza=|d?v*LlRN1c`nq4x^pph@Cz{0J#rElobkOXFB+H6Vb7$a=7n)a_s
z$QZIv`QR2Eb@l(k9N5R47R^e+FZ=#-odPoO6A~mAxxr5B(TYpifhkxLkGnVj?2QY&
z-amo)^nj@5aDv|fc(o#LI^w2KFFkvn&Q)w4>AO)_)nt`J{IW^;A^WeWvQm1Ycgk$F
zOyX)%dQRzqIZhtR#PuSIb2i!3p0RRT*zIC5#O&v!NNK37g<{*1Z)YgB!9kuEas^n?
zLDIS+bRE)#`sSN&wxOmB6l?hoM>rWioxBlmzi-e{rb&I9j>3Er_=F0byhJK3ryd{S
zDN8;Hg=baLIb^BgHzZlb_4O1<jr=Jt)KI@vbfoN7Q}$Du!Y_Fxy$%<Xeu9Ign95{j
z(C+B^;4BNHN{+-9ked5kX1)?f1#Pg>wu?JW2S#b5J)*i9mM^>_MP1B_?pRkYR+3e!
z6qeV^rn(r&A4t)`t!9Gdazmg3{@=99v|}#hOxethsTW=}7NnvUs`JHlB)YfD>X_Z|
yq3g&z^7kFoGN1TSlVBj3omporeB<MSl-gRB`{lVgQM6KG%lTWsef>3C{C@$3gS&|U

literal 0
HcmV?d00001

diff --git a/lib/node-http-proxy/streams/proxy.js b/lib/node-http-proxy/streams/proxy.js
index 8235e9537..f8d12bb3e 100644
--- a/lib/node-http-proxy/streams/proxy.js
+++ b/lib/node-http-proxy/streams/proxy.js
@@ -11,8 +11,6 @@ var ProxyStream = module.exports = function ProxyStream(response, options) {
   var self    = this,
       target  = options.target,
       source  = options.source;
-      
-  self.origRes = response;
  
   this.once('pipe', function(req) {
     var protocol = target.https ? https : http,
@@ -25,10 +23,11 @@ var ProxyStream = module.exports = function ProxyStream(response, options) {
     }
     
     self.request = protocol.request(outgoing);
-    self.request.end();
+    self.on('finish', function() {
+      self.request.end();
+    });
     
     self.request.on('response', function (res) {
-      console.log('yarr yarr');
       self.response = res;
       if(req.httpVersion === '1.0') {
         res.headers.connection = req.headers.connection || 'close';
@@ -62,6 +61,15 @@ var ProxyStream = module.exports = function ProxyStream(response, options) {
         response.setHeader(key, res.headers[key]);
       });
       response.writeHead(response.statusCode);
+      
+      res.on('readable', function() {
+        self.read(0);
+      });
+
+      res.on('end', function() {
+        self.push(null);
+      });
+      self.emit('readable');
     });
 
 
@@ -128,6 +136,6 @@ ProxyStream.prototype._write = function(chunk, encoding, callback) {
 
 ProxyStream.prototype._read = function(size) {
   var chunk = this.response ? this.response.read(size) : '';
-  console.log(chunk.toString());
+  if(chunk == null) { chunk = '' }
   this.push(chunk);
 };

From 3553b1ec8a7e60f4a9cdabaf6d94e66c11bfd4e3 Mon Sep 17 00:00:00 2001
From: yawnt <yawn.localhost@gmail.com>
Date: Mon, 29 Jul 2013 18:09:06 +0200
Subject: [PATCH 11/14] [fix] error

---
 .gitignore                             |   1 +
 lib/node-http-proxy/.http-proxy.js.swp | Bin 36864 -> 0 bytes
 lib/node-http-proxy/streams/forward.js |   7 ++++++-
 test/http/http-test.js                 |  10 +++++-----
 4 files changed, 12 insertions(+), 6 deletions(-)
 delete mode 100644 lib/node-http-proxy/.http-proxy.js.swp

diff --git a/.gitignore b/.gitignore
index 468b525c9..967876b80 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,3 +1,4 @@
 config.json
 node_modules/
 npm-debug.log
+*.swp
diff --git a/lib/node-http-proxy/.http-proxy.js.swp b/lib/node-http-proxy/.http-proxy.js.swp
deleted file mode 100644
index f3ed579f8917a029332031333a814c80584e9569..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 36864
zcmeI54|HT#ec#6<U~m9K0yvzc<n9`nku1$>ajA{gTcg!VmatY58m-qG+wnY&o}}@P
zX2$d0tR&VlB%G8c5KaS0)7Ay&lt2Q<BysJS1A%}OQ%<0zp`|IL)J~elhLRY}IVA2m
zK>PXq?!E8NXjZ#%&gn^-nX})WdGFo7zx%uQ{{G#km9d*<Pnc`UR~Puas8BfbmZ#o$
z$wz*x@LzTdg`Hrl8O!|(eBwsXXw@!|h{tzpfrlnrt6_Ag-Dz#_9BR~84mG(R-H7A%
zsJ)l|EZ-4bxYR+40R;vWxF7|(@!IIMFDP97n!{s~_R50?%n$wG$qQy1Bp6U&K!E`T
z1{4@jU_gNZ1qKutP+&lT|9>bDw=XTcneIHxb*bULFX{RIes>+X@6Dd)&vw^$xbM&R
zJb#Y6zRP`I>niZ|T<Y#O-S>k%&!6k=zukQwbPe|Tzt7$G*B|bA?j8@m1{4@jU_gNZ
z1qKutP+&lT0R;vW7*Jq9fdK^u6!?2dfnc>z_y_d-Yoa*g|M&X;cP}p#{s8<(unX=2
z{}6oZg@wX>U=17qUw%QM@Cop7a1Oi<;ASlR<?{=L`@s$v15f-wp>Qv_4crP&gPXx&
z@O<#ZWrf1;fu9EfD1%Wj44wnN@Vr9do!}U_9$W=V;1%F9@O2CXUj&~4{}#L(+y&ZT
z4b;FecsBTLj13<F4}o6*?*?xMcY_^p6L=$d3HWyyE*=K&1$Tkd;AT((F9&~&;o}kT
zN$_TH4R{P=$sd7_gSUbkz~$fvz-8cD7%RR49tNKP9|s=+{~G)fxDzzNb>K(972svy
z#o+VUHGUS%fM<ax88;cbuX@AB`MB7aLx&3TpIO;4tKnL`S&!?jX4%~f4Z#;@>#O0a
zX?0Az5t>#z>;#g;Y}FeLvli4F{E9bB&@|Onr@mfqn$3E&8N{`Xsx2jGu9|8T)<(C&
zm8exa6UL)9VbyGe!D`rv$k~=MqjJ>hc4}eO3=f|;Sy>()wk1f#r^1zrW;PoX7;OY+
zLKC-4jjMHjk)o##f={%et`(Iq?zT;^x~d%v8uUb~G;8!MEnI_5>dp1CIkgcs<zbC0
zZAO9rcY&d{dQ=XZ!Ac`6Z<Ayz=&YKfChl~@BP6J=mExUt*jnqK@W9cdrnu5-HNv1-
z95Uy~!M{wI6y@n*D=~N7WzOwN(SEdSZ%8!?z1PAZ?sme+KIebi%1C;=C;>I4qHAPv
z$hOavv^sa!wjrB54m#^$EU7c4HP&u96YktrUJ0Vm$mgh$pd78Cd^_on@t_oiE}d3o
zOmba@v~jD}YV65J3Ho54yuo_djQiC&ArE>ou63I=Wzn=trbN?iKRpSDjdtYR!pa?C
zE#5WKdehPiWvmWV4b7Ht0WII&felQp)r<q?2tR}7j&?tyhjGlE$W5AINp3rOPUv%&
z{1@$-$yO&c64gZflG$vnb{opTo5IMQ@Xl@+#gR^>q#WC6E##Kywz770*XWnDa3wU|
zh?&XEmC-cyW)ug_T4?hZbXM<^fK1F8JJMCU!z6Y5P&L(!Ruqr7Tb;N{pEp<PO`S@X
z!%Rh|l4Ng&wJ?f;&Q4N!+6;3x=+tG3L^6xCIl@iKcyWC*Y;_sXl+)cU;ZK`HS<vK?
z=&dA$Yi%}#yOo_O!^U>eBm=#WnfTI);o*q6IIQEg4J~cOZuTY}(+-$n>5ESHzQqOp
zu?<=?rTW?^j54H|Z3&imuwK2E@|BzJ<2D`tLpz;0(m5fAPQ>smydIUO<ZEiP9>-y)
zTnicvoy^&}8gF!3TMW*Ynd)>}ol@~wixt{0vTm^b5|eNM>?wR$?}V%6bfGxl(#aa+
zf0u0@nNQNt8NUk9*l=68CMsv|CG)Z5%94ysLv|hg>?Xft>GF5wk(4!VUN<&&ICopQ
z(-dWeZ^-ZBNanE{pmD9kRzR`Y6q$0zG8v88w_MxjY_Yx*Q`^C2o7tR<qU{?EF`Gd%
zU`t%r$=0Z^g`>5dnj~E_QOpXnDbG3#Y=_0iE;G#NndRlhWKAeb6DQdm*<NZfWhUg5
z3S^M|#E+!dl<@2bZL-ywf>Okle9Y_pX!d2_o@K;lO6yCDP6m>KWl}@Bga_p6sOO|o
zv0UyA<+QwI49ouZPDQEEljV@5jSB}Y4viF~&}lpKT#jrNNqRT-K1a9Hkc{q=$-#pp
zO^gJSe6neH;1fyjk~G=g$pc9w)4)zopDa_7eIUsS!%D7Gv&%DPd1lH~7N(a^O)O2B
zg(bZ{S<#;hJX<oyrzYlR=WnQ(+4)>zS>G3?&E&%T^3ufQ@`zbpSX!16G~21!%G8LN
zSemVn*Gw-hoER|+CwV?CNhpeZ^HY<{vkUW-GdDYNY;MX-^JrrJw3(cnm?i!3i4zky
zOjVLHHQDUk?DFXmb82QvTSrL~{PP9PFU-%*PcKpD)QPG2<+9W?zhI_r;=)vBCg$d}
z4-+SsXBL*U<jIA_(@V2A%q*Lkg}LKX+&nf#i%v`}P0mcrFHanE6;97C&rek<wvA?S
zVrhAH^5opal36^tw73AlCgzWmZ|dg7B}pcoJh3=8J9T`7HcZZ)JT7!N1_kC9mg&fe
z+2yI@kW8Bc?U$%)R{A<kA-OS`t(e87g_~xNlm6fY!%#U$_Zd1Nr^|U-=qi-Ead!SV
z<BRautTnnKFe8|;HnV-U>uiBc)u_878+2Sp_>_fB1YVi3vIkXKYcbo3?%m5=2P>_!
zq2%2`q~3^;8{&G6+w9UhNs+>lvLlhh-6JGoYFi2I9viX|H5#ogSzZuYtk4_D{-QZ!
z`HG}|<cO_})@H5|24P~Y+iBLL4f;Wf)s~4`Bhmp8mAFGWt92%6eWe?R`k+Dcni0Qg
z;vwm5nCW}IkDA67BASE90gXD_nN=%<8ro-V8}iGDl3_$druy0r-yyQ;h-r6M8Z=Or
zhJ&7Z2Zu(qxgivW{8_@PWF=LxD$;J14@cZ!K_p5Ev>rPk5Fm0RqBIX86qh>k;3~AJ
zbvN07ZEM%+BHyq9hm^3G4hjWqgq;x4Y`w#fhpQuItrP0HkH(@MfUY7#+JQjubb_Uf
z-()iGrP`2r&Dh~FGfA#SJv2+L6{N9f#GI&~k!~)v))`4IgHCY9RCN31ayndP5N4aJ
z-MG0UMfQZ#BZH3Xnr$~75nH@$S~xUZ5dHsA^!o1s(f_>~Dc52H7<>j47*Jq9fdK^u
z6c|uoK!E`T1{4@jU_gNZ1qKutP~h)61$I^c7d8JkMDa)e4_ue-=VlD92iJik;0o|n
zeEv^>{|O!hTVM$MIX?fdfnNi^2zJ3qFaZvOG4K>|0G|bK13v+N9GnKr;AP-T!~why
zycY!EmEi06{vQXw27Vk!EWiix_x}o52LA_t{;z@$fMxJqeD<FKzXyI7+y~wYvi|*H
zu3rV7#(yvV{ZE5WfxE#`a4k3pzKJjYVekp?G4N6F5QxDM@K^ZqKLOqXj({QXYVhyz
z(?1B_4!Yo0a11<&zy4wHKJahAd%zkv29ARN#Tfi4cnHXN{5t6Q7(VLORG;6nI0KzW
zQA~Ll2r~|D_W+ZS%Tr%7C2p2CLu_%YM!nNFOf471;Uo8*kG|Y(W6HvN8Mo$ITVZEX
zoV`OfdE(f2?rd!f-UBhfRb9UEB$0Rf(*)9_u6NfmoTJ?+#><ZZR12UnRjhv6I;@MD
zO-x$yafQziM^F}PX-Qh^JkK~KxWHO3K9XbIwY9KQ%BF9G&GmRANqp##6p$@ZY>C0y
zR(%yZ#F+fV+KRolA@(~HHG&nhqNPUG4~xZ7tZbMOJ7Nu#&*akFwEcz4|JKf}O*~ch
zI_z{R*bs4~A0>#Qftk}iz^F-G5)^S1pTED0<#N3x#$4MS>%O-hDfP#zizIa#N*&g5
zI8sQwHr4?zkqPo^dncj%lJ!1IOT6b?I0Cz_23(9}X)@yaoVxI;Vvu$o!Kyl|u!CYx
z+>A_+8C|Us7nu(qfwnTbK1#zx?XXr~t7BnZ*-711mcXg+b}5XyjTl=hChKbAb1K_p
z(&(XTnpubcoS1u?>$^sHM93<pPN|vh+y42vqHVWcGWXzIGmOg>CBiNydI?=gvUi)5
z*3hVcth+9)oyM4Rm9T?v&k=ZcZ=J$oN*P~yIt2a4C_gaL!(>FLniW=j-!}e(29(?N
zc32YrpUyhZ^3fk|2Iw$`*x}P?kr5${{D(zZA45BFerpa{H*z;MlEqK`bT}zOVjHBV
zLUtl>C@+#;+rT2GO*LCil@72j%&rNkr8Z%EmN6R&v+4$b8{X}SX}zT`dCOu{q9w=@
zkt4xk>TiUKu1iBhmPXvrUS+6&v!;V<xt9jc_nnO~5NEu0uBv&e))hztSL+gkMEm27
zAU0c}UDZ~?^{(|!*cK;~LOgpih}jXetXL+<WZ4EyxVdjH@+0A5C}eIXWta<p2;G4;
zaZBfq^y{KNlG<+$w-mQW-DriY68jLhinp2TO>v}X#!ZoJ;VLcmf?1B*y-4_)x!S*2
z_9a`Q7J1>eYC~~?5v(Fhc)1g9w&HLR51edqj=t$lHytjr-2N@4?7wFJZH|4rZ<8dw
zmj)It+)7gPC%}Z8h`ls$_b-+V=Vt>LqL&D^!RO@yn`1vB*c2HWB&$$wINqyYt+PKJ
zcjNBZ0hc-A1RxfhVN=a9Fr==I8)XsaptTW;INWHwEN6DA?#U>eFFAb#*m-hm)xDYN
z8(C);jUSo)GTRc`tWYA7*mVTYB8w?Yk%ndl?RKc{;$+RW;YAWR7Mvw+QvyT$s%#6e
zOB=ph*|c!sTfeP+R(HW)G!6-8a}!y}K5#R@m*nWfyt0cP%khq>1x-tB{!cfjWbQCX
zB43SKi43MeS{f_LN+iQ8?Bc|~qY^rKd}?lLd8#Pmc_7D1y~X%3c44LxjV07^B5}|l
z{$_QD-o`dQ%l20`7Li<REq=IVb#F>iUFHwwYdR>at$e&N<JV9Z*s~}b&mKum<<kCw
zoRpOah#C1X5%4Z3+bx|>q|=Shic6^oXN8`>k*r0zskEbUN8zqn@KUQvNWM)70$ZIr
zqOb6e2z;wS9Kb$a1R_d_VNFZZ`L>HQ8@7|Zw6`#2L!Y@ve)4q+6FEV~bzY^VE-^mk
zdJ|WDJ&sC=q&(tcd2*q4EQlhO*u+)>wShgkR89g@F~Y_sFW8{yG}1A5o25*}e_<KT
zWFw%<BHM}zu=gIkK_(Z+Wz+R!7WUzj)@aMLcO~<=K9O!N*6!Ldg9s`9|0_{4pAcOW
z{r?W9aQ-Q}{$oI51HKII0k?q?xDq^$&i_Hs24}z#@E7R#{}NmWt^rS=)4vOhgVzB$
z1MttlB)A^@WAHun`R{_K!N<XSz+GSqEP&U79|l)|XMsOK=l^Z+0N4UYz|~+B3;{V4
za3%N-wt&9^kAnXWz69P6{wa7XSOnLASAfgFcd!TiCHOXY68r{u6Ntbe@Ez;{Pl6AD
z4KNQz!B?>Zh<#uU+yqX7Y4AMoXV?P%5Zn*8zzVnt%z<mbmEh&z#o&41x!@A;DQpGr
z06z`Jz$?LLu@Bq>-U=$<0FW_ze6Nk5$7G<FjwAFdCW!YO%bkWI>Wan0urrRRd{KQ6
zoFYPBQ2Ol>ZgcDGtJnlBqK`|()ehSba&xLo+J)HHwr?HnfRLY3M);5&;J{j=E3rt~
za%3%Zx8d|`D|B%w$)b`eM#9j`R=Y_I5#zptD&(gfmxUs|O2{yx`^bncS4qiAwt{r6
zZyry&Ruj6=B5Fz${Bo<AERb2%TU)N;i4#y%AJRRYty_A>X6d)vYNqE^FU)FtSga<9
zFG?&2y2`R^%ZidwL{*g*#Y_uw(a){`yRYpgolVC*{Y4~L7zeeD?3khS)HX~h+|CYI
zHcR%m1m~K=V`E7zLQMJWOHezMmeqQ4W>lr~v0y@2TayxaLj@+bBWT2KU|L&x492I>
zG}9ahaaJj<I@R=~2Ut9;gs~As&0<_gvub_0>y)TIl_y#Uq9I{5B`Cd&6hQp;!OS4L
zSt#;Bt21t16%mw(u(m02`0HVQZc5R1UhgfSXBuCC+!r^qi7r$f+pY$Crm_|1`b}mV
z@SaZReTTm9{I&;8_RMh4{a%f?D_P%}>`3KC$qJr*Rslbwr4@3z!LxX_=jWO2i3Ib^
zXM2_~eW$x$(yUOGneKLp_REI0w(n$j{m0@-1gIBe-3EX@kxuh$hcgd!z0Nk%5-6F8
zt>#H<NEX39r7r=UDeKrQ-jpPZ6LYiEYIB|hvC&CgG?XQ70qc=7>Q=2#Cdus?89&%|
z#ii?-MHaQ&?W2-UAt$$V74daek|Qn&L2HCxat6tfA}Pu)Wqv{P->{>f1a%H+aMY_4
zhug7d9+s#Z!>~QksGki>Qu&BU*S`>Juqr+mU4-XBuUr{EF7v)M$yoJC=ZllaXM8i|
zCY{a}Jl{GVHi8}PfLnvp(!90G_A43wUdrdn*JV<N^)+R&SUOEq^{#|oG=gzITsF%v
zs3^Z0_pF9^v;(K5&V&st&8Y~2ZY`y#EiTJTw!Iv;X`s}n$8Y*d3psnB&FB{rmC_T#
zAT3P!KuEUFN3~m4dvBa-2lb8^&bFdRO=nw?KQ6IPA^wpTmT1*Ei^jktH!#VqijDSf
zlSwYW&JT=mvIF|_hyQPkaI(q!t%CRO$DP)W?C_%hqpBBPjy@^+zkfg9ze2}<2Y5TU
z8%%-&;3eQGbp6kQkAM$@_k(wVw}5RRHh~t{09S)&gYQwv<KWZaCxOHTTn;{lU7!wX
zU<KR?t^@_}zp)Q|4!j5a9C!zK19&O89J~-*3O<Kj-~n(SxEsj(1KtR31aAN@0bju;
z@QYv$%zzt!yhGq6;BoZ-{{j94d<FahI0lY_mx4b+|Njt>cLQt#u?Z}IHvq8>Tn0Xm
zE#R}@_rW9J9`MgW3(SBK@FMUn>;iuP9t017v!Dyw;5u+A_%=3xZ-V~>9s<7w-UWUJ
zTnofz@FMUuc7bn#Z-D#3hrxZ|SHWp;Irt>w`X<l?r@;;2YVb<%W8f7)#{P#v?xQ<&
zf&I-&hO*aij)ecY=S72Y$57VdiQ!G`<>RPxcgmft(3hyzXz=HF=A|#^N#~rj_|o+R
z4m#`bFyi74=X9NKu_nT-N{wO_OuX6t9JboHMMC#7Zz?CM1c?A4nlK0P&xjBrWpF9M
z5^*QM-mxmjb2$F3&U_>e*AY603T?f4n6<f$!NMxls$n+}Q9G(bS{Glf(TX^nZz7@#
ztYZ>SG}kx-5lG00tmiG8RqCjY@FD}19o;!yp>EaNNHx7zYAnV0-%1;Kp{1f_EXtBH
zC8{DC5GtedW@e=qraMJYh!f%bFqSjxfjoD^V}F<}PBq!nV`|D}B<kuDagUGNwIts?
zTPxkw+fC$Q!>P72atsR(fl?9aUK*?KcxZ%jYTOp6KNxE{ZeEt0%VaDiQYFf)lTLH&
zmFq#0SXoACf{CId>Ncf&)=Nb(&qr14MZLtdLnA|LtpOR4Qp*yxL=JapX9ziva0MA@
z1~^rDFdjI+v8|u~#i*4{;tjx7v`pThfDJ$=RmpRL9YcRr#t@)yOE_xum(11VnG+8w
znL@n(HkYCua9Es=O~Fyw+*9X?;b~E#gmTaJt5;4u+EO#Za#`-?ijX7Ndy~msN#;lC
zgueX)g8FWy(_gwJ3yw|A|8{a@I$L(HDN(DTzNle7*bL28rZ|4+P?2xz3!ZUx%9523
zs_fb)v=J||Pb8|6_A6`L&vVwKeN&02zc`~@Q!#9&o`30lS~eHX2jEyh>%U5k^(Q-Z
zp^1Eij9l7_qedM1+_5ck4h2c#4pOU`Chd4n1?qS}15poz>LBt<1DAw7{TORq`K<a#
z)_6ZmC}$d^V_#iSl|!(49r+u{#Ax$66nj{nb(d3<)t>W;1QtoL<_5Q9GKaMT_AIFq
zMN~W)0#8-lHfr`Q9<0+oTEsSw|2<!*2qe@oqXzGXxERMo1JkaL3qQz1OKD98-$-iw
zDA$h3?POtbWH%*w?p7pUOFHe7P0t$x#9E|F$$5;!ld{aX#W}k;^eqTW%taKVOQ2oU
zutN8*-dn4()%WJxTU&1~=;KMf*HWA<F1J?WO7&rI87sNAg!zyVT$g>RKp9RMM7Q=#
z?t*>nec9D40jo|>F-m<62*R*#&DmmAaCzPKs8?)`{TvCF4ov4XW=`gLvZKPeX^aqw
zz1_IUYdX9zp#hILTzHd&oHJJ1Ae7kJ_tGxgkv*KS4>5BCbOB<fq;L^U>8SM3H5Fkp
zW7?O#l9A!k{C0AjM<(>sLl(oc;hf`#ecdPtz4s+fZ-IN6c)|Itv#fuCRyvATT1=;;
z85vq=)X@dH;fLm;^6zc6&z^5}whet6nam~c#ZhS}JELr@WtO5&FwK;#%d^hEUc(!L
z;rY49F;TDl>Dgj0(|aFD#<7$pPJglD^m8d?8tfbeef&oV<=%9e&?Z@D;9Wj$wec4S
zs}gE+Ue6JeA6w=#@*DYyVyj9ebbIZo(a&R)9j`shgLULu>9ns4N%VhI=)z;p|KD^<
zpv3=+-oFEG1vi4%g2P}8Tm|GDz`Y;_qVJc$pP|$LF?cWdC2$%nfvdq4;M?f+-vCbn
zi4S-mxE&bqa_}^b`4spV_$YV~oCP<6Y4Bq374-Rs!3Tky3%D1A;8t)6_zQIUPl9{F
z-QXa&0=x`7hCcsa!5@PE0DczCg6Dxp(Bt0&<eh+b0{%2YVG+Cxyc9fz{(e9BO>hph
z!K=X+(b<0=+ymYX-Ua>%I0xi?fX@ZrMPGjayc4X0qu^CQeE$CpJzdTVoC3381{?te
z@F;ru7r?KBcYqzx0_$KI%z_sHIXfU@_-H;Jz_L${kzvwe@?yOrEREJej2N$iDx|5+
zlCH&88TEUC=(<j`v%1?#SQ96{C_I_G?x*M3XEuXvJ%7I@uj}&#=d2$l`A&j4oQ&5u
za>EsTajsp~6Ia$Ax31_u{hYe_2n|<TU*~P^nOBgmGLc3?cpXQ#mw@O)pMb4JbZVQ~
zvDbOzvy`*@7(kHOq@td{j^5dks47V$Xd?4CH7++(PFb@E?Za!y+hW8HC2#L(wwlC8
z`#Wke>feuKld%ydu7Bwsr)@@l({H4Ub|aABo2_UZ`Cr^e<5|a1QkqgxBj})=Sg$mn
zscuD8`yNkz@zdF8w0)5n6IL*Zc|)4@gyy<Cn++AUrfadLb-K-_7}li13MWUby~}x0
z)91<HCCwC`Qb{`(4kr<xde<w%qN^sRAH)R-Bs{8L<w)L0R63@9!Sc#Z9M0)+pOR%N
zJJ{ttM}QIqbDnWp%#D*5#PfvLmpXMyV~&Z4(+@fX!|1`EtMvTOP$JG{^w<7H%Z%~G
zOJ6u^RngNcsYsbnh{7}^2#o>GS`(w=YKwOwg`-lp8WdOvL}&I)*28xCE~!?YA<L#D
z9ZyoafuRtX)bmPF)a{~jbJ0$QqVNlAjJ$46CZrlS+l{&pfgwKzQ<<ztt>Usx=A-zz
z5zFlBGDY>i<{!y<7CkG`3`1*H)?O@NCp^Q63Y)#Nxz^<cQ$GH=Ca=|WCv?iQ3n*#4
zBGv@5jcp`-@B^66A-|IFB2%<A4jgcXtjP{lD#{!x4wdiV%vH%A++q}6Nyglku1Ure
zE4<n^u|AJZ)M{ZHbGJ1lWz_zp&)(>EOELda+(2^{Z%eA7?8(G4JZ@avL~?}8@F}{R
z<B;4PXUad9nRn=L`7rTGhfRg|ZPhkpLM}R*N14<qHEwZDkXe`$B-1|N43E2!{Ly9`
zSKqgznM4dNEwC0bX?T{8-QtlH&Z`lV!pS5r0FzNk2FbOKBHS;TH)-pOYLv8<$h%50
zv$kVi)@p}Xv!uIOCR8U8_tS>hC_+_<a&)kJrrmj9l_aN7tD=VYyzNid+HgCp@wzmf
z2MNEVQ^8rd95J%hN&j7ZfC^?<vofd8Y%84Ejox`JAqljhQDUmJ?JD0c*1QuoT1+;>
z^pRVqe1t~!5y!uLgiJDYOlq7Z(jA7TnoXUnLk()#-lV!B?nd5#Y1gNfFy0C!tdT_`
z-jestNyuqbw$2h8wO`*9!y1kURwErony|>K#C!8JpUsn;(92dzN7X8<tJX>=Z>dho
zuw3L<g_QTiWyKq*6J8V&%f~U2ee5pmvuus!l#8r$D@!=v>NHKVdKO)YZh=j!FWL=P
zCr+*+VPO{n)x(RJw6f!3qgD2BCe%~M7xve-y1`hWWf&Yeop|C2xYC06WIM3_9)@5R
zUx$0GHm;nwNEBpdpgfasE;j24gNnTE&{Pnj+;Kf!<<%u;-z=^wbJuy~up-p)py@Pl
z6Ght`W2dvnIIKD%YnwF$rzek{u}zLJig{0X3!TNkC)ryDtzA1YBFoNFuXQ==YhQ-!
zZ5}XS?v=;|9ajFg{F4sXxM{LOS-wa(#vbU+jb6$Ec^{~!_r<sy9YuQmifPeR*8<mz
zw3XFFI*<|f-W2u!i^?c^r1<~e?)3l9q2J#Jeg(V_NIbwPFb{qN{1A8ncs{rk{AYCk
z&w~#Di3j*)PzASu>wugOkXV2b@D1z$4}f=qw}EMJJvacqgAL$O@Fnm?@M-WN@B#3C
z@XO#15Q3B7^`Hb^2rdJcg6Dwm17F8hAa;a%z`p=Z@LC}81M>F<#C{-uZ{VlFE|4<^
zcY-F^1b2WV;Ct8&9sxfE-V7vu;I-iS;A!jza?ape;CH}B!Ow#_cs=+ra0z$}`@y5&
z%ivzH3nZ3c2pj~T!Hy7up8)dr1x|q_@T1@g@HK1*zXRkQ1aAXkU-(I|0LowpJR5uo
zd%`2&e(+Nu1V0LX5WE<Oz2OVk6&?T|0`iW6b#OCS0(0O-FbyPr;3@dx&w>2ifrr3v
z0{PpD_kni<<s0D{v6`xb1$Hjiqe`0tS6SbZMy#dVTiJ)d^*Eo{nvy*>cUo24zV^to
z+r5~;auyi*W_yQM^t*Ufsa=*yYcx%Ya&|pkQd!8NxYgE`PYi`}Fv-n9o#SRAC&9{e
zae9nPH6l{4Y(@5<ekR(~@5p|O*<+l{H(HNi_gE$`V3pJ!7(Vo3A8RB}r=Ni(lF}i8
ze0)#jx3}c<w?5u^@p0<jSmCoUDxOj~!dRip5+*Bir9!0)bIv>=0&K5oB5#(+)nJVi
zwT*7`jIxtw8_}S0TdPfy3mg!J=;0gWHgvOkv!LTLDa9&#<@tsP6eb1sHZ9Z!3uq1@
zdaikv0BU5*wZ;Z9xWVzv%n0enmEgn5R$HN*P2fH4I8@xeu@r6woiiLgU2me#v4g4`
z)f)4hAwb<~1>NhkGja+vNZf46mYdFGB0KCW{%x#{&C36tgB-`gk+yaYXYxXY?Kg#;
z*3dZKe5>4Q<}R){LMbFxA~4BcvTz<L5hJvE!hPu~?^_o`dsnOu(mQRe_REThiI|m`
zb3A=y>^KZ6@`&v}@`Y5#>+pGnzlKh-@)WIK&KFG$*%89_pg{oc-udG-vh3@dl$Xl_
z-m?r(1gt@-TG@J0c!__ZR_L~X&p}^pqShR@2&rJkVcJepk1D%^fBFYnM5@x9!dHH$
z_qr%87iM>2f~dDiii-^gk^D9|B$wUFRY@3wCyn0DB~+)n*^^Liixic#N1gq9)5&cq
z&+|WuAAj$~=W^szLUh7LcviFsh8(Vmc|Er!sbA%?Ln=keCn+d%Y}fZi{*Flg1uT{i
z`oDYSc9(6*X(U;HHZ&AApbreNgh6E439Fo+pgK3<4w1w~Qs>R$QW|~o+@$AWr|o7)
zoR%a?Ua(T7nyPS$-1cXd)8|sRJrPX0XL=0x_1KWk%4v;cv+eD-Z2d#h)%*tTmwx}9
zE*W+ptX7h4?e?zDUK{u1{KnBO!V$NXq4ty<PfOb2PCTT$1}RKQO$cNVOIDx4d}`TH
z>`H+xGLz0eza=|d?v*LlRN1c`nq4x^pph@Cz{0J#rElobkOXFB+H6Vb7$a=7n)a_s
z$QZIv`QR2Eb@l(k9N5R47R^e+FZ=#-odPoO6A~mAxxr5B(TYpifhkxLkGnVj?2QY&
z-amo)^nj@5aDv|fc(o#LI^w2KFFkvn&Q)w4>AO)_)nt`J{IW^;A^WeWvQm1Ycgk$F
zOyX)%dQRzqIZhtR#PuSIb2i!3p0RRT*zIC5#O&v!NNK37g<{*1Z)YgB!9kuEas^n?
zLDIS+bRE)#`sSN&wxOmB6l?hoM>rWioxBlmzi-e{rb&I9j>3Er_=F0byhJK3ryd{S
zDN8;Hg=baLIb^BgHzZlb_4O1<jr=Jt)KI@vbfoN7Q}$Du!Y_Fxy$%<Xeu9Ign95{j
z(C+B^;4BNHN{+-9ked5kX1)?f1#Pg>wu?JW2S#b5J)*i9mM^>_MP1B_?pRkYR+3e!
z6qeV^rn(r&A4t)`t!9Gdazmg3{@=99v|}#hOxethsTW=}7NnvUs`JHlB)YfD>X_Z|
yq3g&z^7kFoGN1TSlVBj3omporeB<MSl-gRB`{lVgQM6KG%lTWsef>3C{C@$3gS&|U

diff --git a/lib/node-http-proxy/streams/forward.js b/lib/node-http-proxy/streams/forward.js
index de49bf6af..c771a8902 100644
--- a/lib/node-http-proxy/streams/forward.js
+++ b/lib/node-http-proxy/streams/forward.js
@@ -14,9 +14,14 @@ var ForwardStream = module.exports = function ForwardStream(options) {
         outgoing = proxy._getBase(options);
 
     proxy._setupOutgoing(outgoing, options, req);
-
+     
     // pipe throw-safe? do we need to add a ` on 'error' ` handler?
     self.request = protocol.request(outgoing, function() {});
+    self.request.on('error', function() { });
+    
+    self.on('finish', function() {
+      self.request.end();
+    });
   });
 
 };
diff --git a/test/http/http-test.js b/test/http/http-test.js
index 81f8726a7..65aacba38 100644
--- a/test/http/http-test.js
+++ b/test/http/http-test.js
@@ -38,7 +38,7 @@ var routeFile = path.join(__dirname, 'config.json');
 vows.describe(helpers.describe()).addBatch({
   "With a valid target server": {
     "and no latency": {
-      "and no headers": macros.http.assertProxied(),
+      /*"and no headers": macros.http.assertProxied(),
       "and headers": macros.http.assertProxied({
         request: { headers: { host: 'unknown.com' } }
       }),
@@ -73,8 +73,8 @@ vows.describe(helpers.describe()).addBatch({
       "and no connection header": macros.http.assertProxied({
         request: { headers: { connection: "" } }, // Must explicitly set to "" because otherwise node will automatically add a "connection: keep-alive" header
         outputHeaders: { connection: "keep-alive" }
-      }),
-      "and forwarding enabled": macros.http.assertForwardProxied()
+      }),*/
+      "and forwarding enabled": macros.http.assertForwardProxied() /*
     },
     "and latency": {
       "and no headers": macros.http.assertProxied({
@@ -92,11 +92,11 @@ vows.describe(helpers.describe()).addBatch({
       timeout: 2000,
       requestLatency: 4000
     })
-  },
+  */}/*,
   "With a no valid target server": {
     "and no latency": macros.http.assertInvalidProxy(),
     "and latency": macros.http.assertInvalidProxy({
       latency: 2000
-    })
+    })*/
   }
 }).export(module);

From 605a6b494857524b01139f2d58c6bd51ddad0b16 Mon Sep 17 00:00:00 2001
From: yawnt <yawn.localhost@gmail.com>
Date: Mon, 29 Jul 2013 18:11:58 +0200
Subject: [PATCH 12/14] [minor] remove comments

---
 test/http/http-test.js | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/test/http/http-test.js b/test/http/http-test.js
index 65aacba38..81f8726a7 100644
--- a/test/http/http-test.js
+++ b/test/http/http-test.js
@@ -38,7 +38,7 @@ var routeFile = path.join(__dirname, 'config.json');
 vows.describe(helpers.describe()).addBatch({
   "With a valid target server": {
     "and no latency": {
-      /*"and no headers": macros.http.assertProxied(),
+      "and no headers": macros.http.assertProxied(),
       "and headers": macros.http.assertProxied({
         request: { headers: { host: 'unknown.com' } }
       }),
@@ -73,8 +73,8 @@ vows.describe(helpers.describe()).addBatch({
       "and no connection header": macros.http.assertProxied({
         request: { headers: { connection: "" } }, // Must explicitly set to "" because otherwise node will automatically add a "connection: keep-alive" header
         outputHeaders: { connection: "keep-alive" }
-      }),*/
-      "and forwarding enabled": macros.http.assertForwardProxied() /*
+      }),
+      "and forwarding enabled": macros.http.assertForwardProxied()
     },
     "and latency": {
       "and no headers": macros.http.assertProxied({
@@ -92,11 +92,11 @@ vows.describe(helpers.describe()).addBatch({
       timeout: 2000,
       requestLatency: 4000
     })
-  */}/*,
+  },
   "With a no valid target server": {
     "and no latency": macros.http.assertInvalidProxy(),
     "and latency": macros.http.assertInvalidProxy({
       latency: 2000
-    })*/
+    })
   }
 }).export(module);

From 52defcb3f26258be6e85ec1a90bfc161a4fa8967 Mon Sep 17 00:00:00 2001
From: cronopio <aristizabal.daniel@gmail.com>
Date: Mon, 29 Jul 2013 16:32:27 -0500
Subject: [PATCH 13/14] [fix] hack to call .end() explicitly, enable error
 handler, at this point the test/http/http-test.js all passed

---
 lib/node-http-proxy/streams/proxy.js | 27 ++++++++++++---------------
 1 file changed, 12 insertions(+), 15 deletions(-)

diff --git a/lib/node-http-proxy/streams/proxy.js b/lib/node-http-proxy/streams/proxy.js
index f8d12bb3e..8f0e0227e 100644
--- a/lib/node-http-proxy/streams/proxy.js
+++ b/lib/node-http-proxy/streams/proxy.js
@@ -72,13 +72,16 @@ var ProxyStream = module.exports = function ProxyStream(response, options) {
       self.emit('readable');
     });
 
+    // HACK: please fix it
+    // Should we call end() splicity?
+    self.end();
 
-    /*
+    
     //
     // Handle 'error' events from the `reverseProxy`. Setup timeout override if needed
     //
     self.request.once('error', proxyError);
-
+/*
     // Set a timeout on the socket if `this.timeout` is specified.
     reverseProxy.once('socket', function (socket) {
       if (self.timeout) {
@@ -86,8 +89,6 @@ var ProxyStream = module.exports = function ProxyStream(response, options) {
       }
     }); */
 
-/*
-
   //
   // #### function proxyError (err)
   // #### @err {Error} Error contacting the proxy target
@@ -95,33 +96,29 @@ var ProxyStream = module.exports = function ProxyStream(response, options) {
   // contacting the proxy target at `host` / `port`.
   //
   function proxyError(err) {
-    errState = true;
-
     //
     // Emit an `error` event, allowing the application to use custom
     // error handling. The error handler should end the response.
     //
-    if (self.emit('proxyError', err, req, res)) {
-      return;
-    }
-
-    res.writeHead(500, { 'Content-Type': 'text/plain' });
+    // if (self.emit('proxyError', err, req, res)) {
+    //   return;
+    // }
 
-    if (req.method !== 'HEAD') {
+    response.writeHead(500, { 'Content-Type': 'text/plain' });
+    if (self.request.method !== 'HEAD') {
       //
       // This NODE_ENV=production behavior is mimics Express and
       // Connect.
       //
-      res.write(process.env.NODE_ENV === 'production' 
+      response.write(process.env.NODE_ENV === 'production' 
         ? 'Internal Server Error'
         : 'An error has occurred: ' + JSON.stringify(err)
       );
     }
 
-    try { res.end() }
+    try { response.end() }
     catch (ex) { console.error("res.end error: %s", ex.message) }
   }
-  */
   });
 
 };

From 77f3723bb9bf40f61c074acf88d19016257495b2 Mon Sep 17 00:00:00 2001
From: cronopio <aristizabal.daniel@gmail.com>
Date: Mon, 29 Jul 2013 17:11:14 -0500
Subject: [PATCH 14/14] [fix] getting rid of try..catch, as @mmalecki suggested

---
 lib/node-http-proxy/streams/proxy.js | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/lib/node-http-proxy/streams/proxy.js b/lib/node-http-proxy/streams/proxy.js
index 8f0e0227e..63b6a9c1d 100644
--- a/lib/node-http-proxy/streams/proxy.js
+++ b/lib/node-http-proxy/streams/proxy.js
@@ -53,9 +53,7 @@ var ProxyStream = module.exports = function ProxyStream(response, options) {
         }
       }
 
-      try { 
-        self.emit('proxyResponse', req, response, res); 
-      } catch (e) {}
+      self.emit('proxyResponse', req, response, res);
 
       Object.keys(res.headers).forEach(function (key) {
         response.setHeader(key, res.headers[key]);