Enable gzip response compression in node file handlers

js/foam/node/handlers/FileHandler.js

@@ -25,6 +25,14 @@ CLASS({
       name: 'path',
       hidden: true,
     },
+    {
+      name: 'zlib',
+      factory: function() { return require('zlib'); }
+    },
+    {
+      name: 'stream',
+      factory: function() { return require('stream'); }
+    },
     {
       model_: 'foam.node.NodeRequireProperty',
       name: 'fs',
@@ -47,10 +55,23 @@ CLASS({
       if ( this.url.parse(req.url).pathname !== this.pathname ) return false;
 
       this.fs.readFile(this.file, function(err, data) {
-	if ( err ) {
-	  this.send(res, 404, 'File not found.');
-	} else {
-	  this.send(res, 200, data.toString());
+        if ( err ) {
+          this.send(res, 404, 'File not found.');
+        } else {
+          res.statusCode = 200;
+
+          if ( req.headers["accept-encoding"] &&
+               req.headers["accept-encoding"].indexOf("gzip") !== -1 ) {
+            res.setHeader('Content-encoding', 'gzip');
+            var src = new this.stream.Readable();
+            src._read = function noop() {}
+            src.push(data.toString());
+            src.push(null);
+            //src.write( 'utf8');
+            src.pipe(this.zlib.createGzip()).pipe(res);
+          } else {
+            this.send(res, 200, data.toString());
+          }
         }
       }.bind(this));
 

js/foam/node/handlers/StaticFileHandler.js

@@ -27,6 +27,10 @@ CLASS({
       name: 'fs',
       factory: function() { return require('fs'); }
     },
+    {
+      name: 'zlib',
+      factory: function() { return require('zlib'); }
+    },
     {
       name: 'dir',
       documentation: 'Directory under which to serve files.',
@@ -123,7 +127,6 @@ CLASS({
         body += '</ul></body></html>';
         res.setHeader('Content-type', 'text/html');
         res.statusCode = 200;
-        res.write(body, 'utf8');
         res.end();
         this.log('200 OK (dir) ' + target);
       } else {
@@ -138,7 +141,14 @@ CLASS({
         // Open the file as a stream.
         this.log('200 OK ' + target);
         var stream = this.fs.createReadStream(target);
-        stream.pipe(res);
+
+        if ( req.headers["accept-encoding"] &&
+             req.headers["accept-encoding"].indexOf("gzip") !== -1 ) {
+          res.setHeader('Content-encoding', 'gzip');
+          stream.pipe(this.zlib.createGzip()).pipe(res);
+        } else {
+          stream.pipe(res);
+        }
       }
       return true;
     }