Process: skip file if not exist

hexojs · Mar 3, 2013 · 2515be5 · 2515be5
1 parent 970a938
commit 2515be5
Showing 1 changed file with 30 additions and 27 deletions.
diff --git a/lib/process.js b/lib/process.js
@@ -65,37 +65,40 @@ module.exports = function(files, callback){
         type = 'update';
     }
 
-    var tasks = getProcessor(path);
-    if (!tasks.length) return next();
-
     var source = sourceDir + path;
 
-    var obj = {
-      source: source,
-      path: path,
-      type: type,
-      read: function(){
-        var args = _.toArray(arguments),
-          callback = args.pop(),
-          encoding = args[0] ? args[0] : 'utf8';
+    fs.exists(source, function(exist){
+      if (!exist) return next();
+      var tasks = getProcessor(path);
+      if (!tasks.length) return next();
 
-        fs.readFile(source, function(err, content){
-          if (err) return callback(err);
-          if (encoding !== 'buffer'){
-            content = content.toString('utf8');
-            if (EOL !== '\n') content = content.replace(EOLre, '\n');
-          }
-          callback(err, content);
-        });
-      },
-      stat: function(callback){
-        fs.stat(source, callback);
-      }
-    };
+      var obj = {
+        source: source,
+        path: path,
+        type: type,
+        read: function(){
+          var args = _.toArray(arguments),
+            callback = args.pop(),
+            encoding = args[0] ? args[0] : 'utf8';
+
+          fs.readFile(source, function(err, content){
+            if (err) return callback(err);
+            if (encoding !== 'buffer'){
+              content = content.toString('utf8');
+              if (EOL !== '\n') content = content.replace(EOLre, '\n');
+            }
+            callback(err, content);
+          });
+        },
+        stat: function(callback){
+          fs.stat(source, callback);
+        }
+      };
 
-    async.forEach(tasks, function(task, next){
-      task.fn(_.extend(obj, {params: task.params}), next);
-    }, next);
+      async.forEach(tasks, function(task, next){
+        task.fn(_.extend(obj, {params: task.params}), next);
+      }, next);
+    });
   }, function(){
     hexo.emit('processAfter');
     callback();