Merge pull request #240 from timoxley/bug/pipe-unzip

unzip does not work when using pipe

.gitignore

@@ -7,3 +7,4 @@ node_modules
 test.js
 components
 test/node/fixtures/tmp.json
+test/node/fixtures/temp.txt

lib/node/index.js

@@ -383,7 +383,11 @@ Request.prototype.write = function(data, encoding){
 Request.prototype.pipe = function(stream, options){
   this.buffer(false);
   this.end().req.on('response', function(res){
-    res.pipe(stream, options);
+
+    if (/^(deflate|gzip)$/.test(res.headers['content-encoding'])) {
+      res.pipe(require('zlib').createUnzip())
+      .pipe(stream, options)
+    } else res.pipe(stream, options);
   });
   return stream;
 };

test/node/inflate.js

@@ -1,6 +1,7 @@
 
 var request = require('../../')
   , express = require('express')
+  , fs = require('fs')
   , zlib
 
 /**
@@ -43,6 +44,22 @@ if (zlib) {
           done();
         });
     });
+    describe('with pipe', function() {
+      beforeEach(function(done) {
+        fs.unlink(__dirname + '/fixtures/temp.txt', function() {done()})
+      })
+      it('should deflate during pipe', function(done) {
+          var writeStream = fs.createWriteStream(__dirname + '/fixtures/temp.txt')
+          var req = request
+            .get('http://localhost:3080/binary')
+
+          req.on('end', function() {
+            fs.readFileSync(__dirname + '/fixtures/temp.txt', 'utf8').should.be.equal(subject)
+            done()
+          })
+          req.pipe(writeStream)
+      })
+    })
 
     describe('without encoding set', function(){
       it('should emit buffers', function(done){