mongodb関数の非同期コールバック

Question

私はこの関数を適切なコールバックにしたいと考えています。書かれているように、コールバックは2回呼び出されます.1回は同期 'if'ステートメントと1つは非同期 'test2.save'ステートメントです。私は、私が試した例のようにカウンタコードを入れています。ボトムif文が同期しているので動作しません。私はすでにこのコードの何が間違っているか知っていますが、私はそれをより良くする方法については考えていません。

var postMatches = function(user1, userResults, callback) { 
    User.find({}, {username: 1, testResults: 1}, (err, users) => { 
    var counter = 0; 
    users.forEach(function(user2){ 
     counter++; 
     if(user1 !== user2.username && user2.testResults !== undefined) { 
     var test1 = new Test({ 
      username: user1, 
      match: user2.username, 
      compatability: mbti[userResults][user2.testResults], 
      alreadyMatches: false 
     }); 

     test1.save(() => { 
      var test2 = new Test({ 
      username: user2.username, 
      match: user1, 
      compatability: mbti[user2.testResults][userResults], 
      alreadyMatches: false 
      }); 

      test2.save(() => { 
      if(counter === users.length) { 
       callback(); 
      } 
      }); 
     }) 
     } else { 

     if(counter === users.length) { 
      callback(); 
     } 
     } 
    }) 
    }) 
}; 

Answer 1

コメントと質問から、ここでコードを編集しました。非同期モジュールとforEach関数を使用して、ユーザーリストを反復処理し、完了したらコールバックを返します。 asyncとforEachについて読む。これがあなたのユースケースのために働くかどうか私に教えてください。

var async = require('async') 
var postMatches = function(user1, userResults, callback) { 
    User.find({}, {username: 1, testResults: 1}, (err, users) => { 
    var counter = 0; 
    async.forEach(users,function(user2,iterate_callback){ 
     if(user1 !== user2.username && user2.testResults !== undefined) { 
     var test1 = new Test({ 
      username: user1, 
      match: user2.username, 
      compatability: mbti[userResults][user2.testResults], 
      alreadyMatches: false 
     }); 

     test1.save(() => { 
      var test2 = new Test({ 
      username: user2.username, 
      match: user1, 
      compatability: mbti[user2.testResults][userResults], 
      alreadyMatches: false 
      }); 

      test2.save(() => { 
      iterate_callback(); 
      }); 
     }) 
     } else { 
     iterate_callback(); 
     } 
    },function(err){ 
     console.log("Done iterating"); 
     return callback(); 
    }); 
    }) 
};