Fix + test for piped into request bumped into redirect. #321

main.js

@@ -577,6 +577,7 @@ Request.prototype.start = function () {
       )
       if (self.followAllRedirects) self.method = 'GET'
       // self.method = 'GET'; // Force all redirects to use GET || commented out fixes #215
+      delete self.src
       delete self.req
       delete self.agent
       delete self._started

tests/run.js

@@ -21,16 +21,17 @@ var tests = [
   , 'test-pool.js'
   , 'test-protocol-changing-redirect.js'
   , 'test-proxy.js'
+  , 'test-piped-redirect.js'
   , 'test-qs.js'
   , 'test-redirect.js'
   , 'test-timeout.js'
   , 'test-toJSON.js'
   , 'test-tunnel.js'
-] 
+]
 
 var next = function () {
   if (tests.length === 0) process.exit(exitCode);
-  
+
   var file = tests.shift()
   console.log(file)
   var proc = spawn('node', [ 'tests/' + file ])

tests/test-piped-redirect.js

@@ -0,0 +1,52 @@
+var http = require('http')
+  , assert = require('assert')
+  , request = require('../main.js')
+  ;
+
+var portOne = 8968
+  , portTwo = 8969
+  ;
+
+
+// server one
+var s1 = http.createServer(function (req, resp)
+{
+  if (req.url == '/original')
+  {
+    resp.writeHeader(302, {'location': '/redirected'})
+    resp.end()
+  }
+  else if (req.url == '/redirected')
+  {
+    resp.writeHeader(200, {'content-type': 'text/plain'})
+    resp.write('OK')
+    resp.end()
+  }
+
+}).listen(portOne);
+
+
+// server two
+var s2 = http.createServer(function (req, resp)
+{
+
+  var x = request('http://localhost:'+portOne+'/original')
+  req.pipe(x)
+  x.pipe(resp)
+
+}).listen(portTwo, function()
+{
+
+  var r = request('http://localhost:'+portTwo+'/original', function (err, res, body) {
+
+    assert.equal(body, 'OK')
+
+    s1.close()
+    s2.close()
+
+  });
+
+  // it hangs, so wait a second :)
+  r.timeout = 1000;
+
+});