Fixed gzip/deflate as reported in #1

lib/nodejs/request.js

@@ -17,6 +17,21 @@ module.exports = function(resource, encoding, done) {
   populate(resource, encoding, done);
 };
 
+/**
+ * Creates a callback for a decoded request.
+ * @param {string} address
+ * @param {string} encoding
+ * @param {function(Error, string=)}done
+ */
+function createRequestCallback(address, encoding, done) {
+  return function (err, buffer) {
+    if (err) return done(err);
+    var data = buffer.toString(encoding || 'utf8');
+    if (!data) return done(new Error('No data: ' + address));
+    done(err, data);
+  };
+}
+
 /**
  * Retrieves the keys containing a function.
  * @private
@@ -61,20 +76,21 @@ function request(address, encoding, done, n) {
   var options = url.parse(address);
   options.headers = {'User-Agent': agent};
   http.get(options, function(res) {
-    var data = '';
-    var resEncoding = res.headers['content-encoding'];
-    res.setEncoding(encoding || 'utf8');
-    if (resEncoding === 'gzip') {
-      res.pipe(zlib.createGunzip());
-    } else if (resEncoding === 'deflate') {
-      res.pipe(zlib.createInflate());
-    }
+    var chunks = [];
     res.on('data', function(chunk) {
-      data += chunk;
+      chunks.push(chunk);
     });
     res.on('end', function() {
-      if (!data) return done(new Error('No data: ' + address));
-      done(undefined, data);
+      var buffer = Buffer.concat(chunks);
+      var compression = res.headers['content-encoding'];
+      var callback = createRequestCallback(address, encoding, done);
+      if (compression == 'gzip') {
+        return zlib.gunzip(buffer, callback);
+      } else if (compression === 'deflate') {
+        return zlib.inflateRaw(buffer, callback);
+      } else {
+        callback(undefined, buffer);
+      }
     });
   }).on('error', function(err) {
     if (n < maximum) return request(address, encoding, done, n + 1 || 1);