在节点中按特定顺序调用模块

Question

我使用下面的代码调用了两个模块，但是调用操作是在验证文件之前调用的（我在调试中看到过）。我应该做些什么来验证validateFile 在appHandler.invokeAction 之前被调用？我应该使用承诺吗？

var validator = require('../uti/valid').validateFile();
var appHandler = require('../contr/Handler');
appHandler.invokeAction(req, res);

更新

这是验证文件代码

var called = false;
var glob = require('glob'),
    fs = require('fs');
module.exports = {

    validateFile: function () {

        glob("myfolder/*.json", function (err, files) {
            var stack = [];
            files.forEach(function (file) {
                fs.readFile(file, 'utf8', function (err, data) { // Read each file
                    if (err) {
                        console.log("cannot read the file", err);
                    }
                    var obj = JSON.parse(data);
                    obj.action.forEach(function (crud) {
                        for (var k in crud) {
                            if (_inArray(crud[k].path, stack)) {

                                console.log("duplicate founded!" + crud[k].path);

                                break;
                            }
                            stack.push(crud[k].path);
                        }
                    })
                });
            });
        });
    }
};

Answer 1

由于fs.fileRead 是async，您应该将要在validateFile 之后执行的代码放到它的callback 中。

来源可能是：

var validator = require('../uti/valid').validateFile();
var appHandler = require('../contr/Handler');
// create a new function that when execute, will call appHandler.invokeAction with req and res given to its arguments.
validator.validateFile(appHandler.invokeAction.bind(null, req, res));

验证器部分应该是：

var called = false;
var glob = require('glob'),
    fs = require('fs');
module.exports = {
    validateFile: function (callback) {

        glob("myfolder/*.json", function (err, files) {
            var stack = [];
            // Use it to decide whether all files processed or not.
            var filesToLoad = files.length;
            files.forEach(function (file) {
                fs.readFile(file, 'utf8', function (err, data) { // Read each file
                    --filesToLoad;
                    if (err) {
                        console.log("cannot read the file", err);
                        // If the invoke action doesn't depend on the result. You may want to call it here too.
                    }
                    var obj = JSON.parse(data);
                    obj.action.forEach(function (crud) {
                        for (var k in crud) {
                            if (_inArray(crud[k].path, stack)) {

                                console.log("duplicate founded!" + crud[k].path);

                                break;
                            }
                            stack.push(crud[k].path);
                        }
                    })

                    // Only called the callback after all files processed.
                    if (filesToLoad === 0) {
                      callback();
                    }

                });
            });
        });
    }
};

编辑：感谢Bergi的提醒，文件是一个数组，当所有文件都处理完后你必须调用回调，所以我们必须进一步使用一个变量来决定有多少文件还没有处理。

Answer 2

因为glob 和fs.readFile 是异步函数，并且appHandler.invokeAction 在磁盘i/o 期间被调用。

Promise 是解决这个问题的好方法，但老派的回调可以解决这个问题。

validator.validateFile().then(function() {
  appHandler.invokeAction(req, res);
});

用于验证

var Promise = require("bluebird"), // not required if you are using iojs or running node with `--harmony`
    glob = require('mz/glob'),
    fs = require('mz/fs');

module.exports = {
  validateFile: function () {
    return glob("myfolder/*.json").then(function(files) {
      return Promise.all(files.map(function(file) {
        // will return an array of promises, if any of them
        // is rejected, validateFile promise will be rejected
        return fs.readFile(file).then(function (content) {
          // throw new Error(''); if content is not valid
        });
      }));
    })
  }
};

如果您想使用 Promise mz 可能会有所帮助:)