我有一种读取目录和记录统计信息的功能性方式，如何以功能性方式递归获取所有文件夹树统计信息？

Question

我能够制作下面的代码，它只读取一个目录，然后记录一个 Stats 列表。 现在我想知道如何遍历目录树并检索具有统计信息和文件路径的对象列表。

import fs from 'fs'
import {Task, traverse,concat,compose,chain,map, prop, List, filter } from './shared/functional.js';

// readDir :: String -> Task Error (List String)
const readDir = path => new Task((reject, result) => {
  fs.readdir(path, (err, data) => (err ? reject(err) : result(new List(data))));
});

// readDir :: String -> Task Error (Stat)
const readStat = filename => new Task((reject, result) => {
  fs.stat(filename, (err, data) => (err ? reject(err) : result(data)));
});

const dirList = dir => chain(traverse(Task.of, compose(readStat, concat(dir))), readDir(dir),);

dirList('./shared/').fork(console.error, map(compose(console.log, prop('mtimeMs'))));

我猜我需要使用 isDirectory 来检查我是否应该进入树的内部。但我的问题是如何构造对象以及如何返回非嵌套列表？

编辑：我现在没有使用任何库，只是遵循 https://mostly-adequate.gitbooks.io/mostly-adequate-guide/ 的类型和助手

EDIT2：我想出了以下内容：

import fs from 'fs'
import {Task, traverse,concat,compose,chain,map, prop, List, filter, Maybe,identity,Either,curry } from './shared/functional.js';

// readDir :: String -> Task Error (List String)
const readDir = path => new Task((reject, result) => {
  fs.readdir(path, (err, data) => (err ? reject(err) : result(new List(data))));
});

// readDir :: String -> Task Error (Stat)
const readStat = filename => new Task((reject, result) => {
  fs.stat(filename, (err, data) => (err ? reject(err) : result(data)));
});

const isDir = curry((dir, stat) => {
  return stat.isDirectory()
    // eslint-disable-next-line no-use-before-define
    ? dirListAll(dir)
    : stat;
});

const dirListAll = dir => chain(traverse(Task.of, compose(map(isDir(dir)),readStat, concat(dir))), readDir(dir),);

现在我有了我解释的场景，在这个示例中，我有一个目录，其中包含 6 个项目，即 2 个文件夹。所以我得到了一个包含 4 个统计数据和 2 个任务的列表。

Task {fork: ƒ} 0 (6) [Task, Stats, Stats, Stats, Task, Stats]

后面可以包含列表，我现在需要的是删除外部函子，我正在尝试可能再次使用遍历链。但还没有成功。 再次感谢。

Answer 1

您可能已经注意到回调和循环不能很好地结合在一起。为了解决这个问题，我推荐使用util.promisify。完成后，您可以轻松编写如下异步函数：

async function traverse(names, callback) {
  for (let name of names) {
    let s = await stat(name);
    if (s.isDirectory())
      await traverse( (await readdir(name)).map(x => path.join(name, x)) , callback );
    else
      callback(name);
  }
}