white magic

Author: Amoki

lib/helpers/child-process.js

@@ -47,12 +47,20 @@ process.on('message', function(task) {
      */
     function downloadFile(cb) {
       if(task.file_path) {
+        var stream = fs.createWriteStream(path);
+
+        var binaryParser = function binaryParser(res, cb) {
+          stream.on('end', cb);
+          res.pipe(stream);
+        };
+
         // Download the file
         var apiUrl = url.parse(task.file_path, false, true);
         request(apiUrl.protocol + "//" + apiUrl.host)
           .get(apiUrl.path)
           .expect(200)
-          .end(function(err, res) {
+          .parse(binaryParser)
+          .end(function(err) {
             if(err) {
               if(err.toString().match(/410/)) {
                 err.skip = true;
@@ -62,7 +70,8 @@ process.on('message', function(task) {
               }
               return cb(err);
             }
-            fs.writeFile(path, res.text, {encoding: 'binary'}, cb);
+            stream.end();
+            cb();
           });
       }
       else {