約束と再帰でのファイルディレクトリの反復

Question

私は次の関数の早い段階で返ってくることを知っています。再帰的約束を私の結果にどのようにつなげることができますか？

私の目標は、ディレクトリとそのすべてのサブディレクトリのファイルのリストの配列を取得することです。配列は単一次元ですが、この例ではconcatを使用しています。

function iterate(body) { 
    return new Promise(function(resolve, reject){ 
     var list = []; 
     fs.readdir(body.path, function(error, list){ 
      list.forEach(function(file){ 
       file = path.resolve(body.path, file); 
       fs.stat(file, function(error, stat){ 
        console.log(file, stat.isDirectory()); 
        if(stat.isDirectory()) { 
         return iterate({path: file}) 
          .then(function(result){ 
           list.concat(result); 
          }) 
          .catch(reject); 
        } else { 
         list.push(file); 
        } 
       }) 
      }); 
      resolve(list); 
     }); 
    }); 
}; 

Answer 1

コードに間違いが多数あります。部分的なリスト：

1. .concat()のでそれだけでlist.concat(result)が実際に何もしない、新しい配列を返します。

2. resolve()を同期して呼び出し、すべての非同期操作が完了するのを待っていません。

3. いくつかのネストされた非同期コールバックの深い部分から再帰的に戻ろうとしています。あなたはそれをすることはできません。結果はどこにも戻ってこない。

fsモジュールの有名なバージョンを使用すると、このトンが使いやすくなります。私はそれを作成するために、ブルーバードを使用して、あなたはこれを行うことができます。

const path = require('path'); 
var Promise = require('bluebird'); 
const fs = Promise.promisifyAll(require('fs')); 

function iterate(dir) { 
    return fs.readdirAsync(dir).map(function(file) { 
     file = path.resolve(dir, file); 
     return fs.statAsync(file).then(function(stat) { 
      if (stat.isDirectory()) { 
       return iterate(file); 
      } else { 
       return file; 
      } 
     }) 
    }).then(function(results) { 
     // flatten the array of arrays 
     return Array.prototype.concat.apply([], results); 
    }); 
} 

注：私はそれがより一般的に便利ですので、ちょうど最初のパスを取るためにiterate()を変更しました。あなたは最初にbody.pathを渡すことができます。

const path = require('path'); 
const fs = require('fs'); 

fs.readdirAsync = function(dir) { 
    return new Promise(function(resolve, reject) { 
     fs.readdir(dir, function(err, list) { 
      if (err) { 
       reject(err); 
      } else { 
       resolve(list); 
      } 
     }); 
    }); 
} 

fs.statAsync = function(file) { 
    return new Promise(function(resolve, reject) { 
     fs.stat(file, function(err, stat) { 
      if (err) { 
       reject(err); 
      } else { 
       resolve(stat); 
      } 
     }); 
    }); 
} 


function iterate2(dir) { 
    return fs.readdirAsync(dir).then(function(list) { 
     return Promise.all(list.map(function(file) { 
      file = path.resolve(dir, file); 
      return fs.statAsync(file).then(function(stat) { 
       if (stat.isDirectory()) { 
        return iterate2(file); 
       } else { 
        return file; 
       } 
      }); 
     })); 
    }).then(function(results) { 
     // flatten the array of arrays 
     return Array.prototype.concat.apply([], results); 
    }); 
} 

iterate2(".").then(function(results) { 
    console.log(results); 
}); 

---

ここでカスタマイズ可能なフィルタ機能を追加したバージョンがあります：

function iterate2(dir, filterFn) { 
    // default filter function accepts all files 
    filterFn = filterFn || function() {return true;} 
    return fs.readdirAsync(dir).then(function(list) { 
     return Promise.all(list.map(function(file) { 
      file = path.resolve(dir, file); 
      return fs.statAsync(file).then(function(stat) { 
       if (stat.isDirectory()) { 
        return iterate2(file, filterFn); 
       } else { 
        return filterFn(file)? file : ""; 
       } 
      }); 
     })).then(function(results) { 
      return results.filter(function(f) { 
       return !!f; 
      }); 
     }); 
    }).then(function(results) { 
     // flatten the array of arrays 
     return Array.prototype.concat.apply([], results); 
    }); 
} 

// example usage 
iterate2(".", function(f) { 
    // filter out 
    return !(/(^|\/)\.[^\/\.]/g).test(f); 
}).then(function(results) { 
    console.log(results); 
});