Q 承诺不能在 lodash reduce 函数中工作

Question

我正在尝试将文件返回到具有最早修改日期的目录中。这种方法在 createFileDateMap 函数中似乎失败了。我想减少一组文件路径并使用文件名和修改日期创建一个对象。 getModDate 函数是一个异步 fs.lstat 调用。我似乎无法将减速器的 acc 设置为 .then() 块中的值。当值依赖于异步调用时，我不确定如何实现减少

var _ = require('lodash'),
    fs = require('fs'),
    path = require('path'),
    Q = require('q');

function checkDir(dir) {
    // Check if given path is valid directory
    var deferred = Q.defer();
    fs.lstat(dir, deferred.makeNodeResolver());
    return deferred.promise.invoke('isDirectory');
}

function getFiles(dir) {
    // Get all files within a directory
    var deferred = Q.defer();
    fs.readdir(dir, deferred.makeNodeResolver());
    return deferred.promise;
}

function makeFullPathFileArr(dir, files) {
    // Return array of full paths
    return _.map(files, function(file) {
        return path.join(dir, file);
    });
}

function getModDate(file) {
    // Return modification date of file
    var deferred = Q.defer();
    fs.stat(file, deferred.makeNodeResolver());
    return deferred.promise.get('mtime');
}

function createFileDateMap(filesArr) {
    // Return an obj of file paths and modification dates as Date objects
    // {{ file1: Date, file2: Date }}
    var fileDateMap = _.reduce(filesArr, function(acc, file) {
        getModDate(file)
            .then(function(modDate) {
                acc[file] = moment(modDate);
            });
        return acc;
    }, {});
    return fileDateMap;
}

function getMinDateFile(mapObj) {
    // return the file name which has the earliest modification date
    var dates = _.transform(mapObj, function(result, date, key) {
        result[key] = new Date(date);
    });
    var minDate = new Date(Math.min.apply(null, _.values(dates)));
    var invertedMapObj = _.invert(mapObj);

    return invertedMapObj[minDate];
}

var dir = '../reports';
checkDir(dir)
    .then(function(exist) {
        if(exist) {
            getFiles(dir)
                .then(function(fileNames) {
                    return makeFullPathFileArr(dir, fileNames);
                })
                .then(function(fullpathsArr) {
                    return createFileDateMap(fullpathsArr);
                })
                .then(function(fileAndDatesObj) {
                    console.log(getMinDateFile(fileAndDatesObj));
                });
        }
    })
    .catch(function(err) {
        console.log(err);
    });

Answer 1

感谢@BenjaminGruenbaum 的帮助。 :)

function createFileDateMap(filesArr) {
    // Return an obj of file paths and modification dates as Date objects
    // {{ file1: Date, file2: Date

    return Q.all(_.map(filesArr, getModDate))
        .then(function(modDates) {
           return _.zipObject(filesArr, modDates);
        });
}

Answer 2

问题在于reduce 是同步的，并且不知道您在其回调中使用的承诺。您将返回 fileDateMap，它是一个空对象。这个问题有两种解决方案：

• 并行调用所有 getModDates，使用 Q.all 获取日期数组的承诺，并在 then 回调中减少它。

  function createFileDateMap(filesArr) {
      // Return an obj of file paths and modification dates as Date objects
      // {{ file1: Date, file2: Date }}
      return Q.all(_.map(filesArr, function(file) {
          return getModDate(file).then(function(date) {
              return {name:file, date:date};
          });
      })).then(function(fileAndDateArr) {
          return _.reduce(fileAndDateArr, function(acc, o) {
              acc[o.file] = moment(o.date);
              return acc;
          }, {});
      });
  }
  

• 使accumlutor 成为地图对象的承诺，并通过链接大量then 调用来“异步”减少数组。

  function createFileDateMap(filesArr) {
      // Return an obj of file paths and modification dates as Date objects
      // {{ file1: Date, file2: Date }}
      return _.reduce(filesArr, function(acc, file) {
          return acc.then(function(fileDateMap) {
              return getModDate(file).then(function(modDate) {
                  fileDateMap[file] = moment(modDate);
                  return fileDateMap;
              });
          });
      }, Q({}));
  }