如何等待findOneAndUpdate完成后再继续async.series

Question

我有一个种子文件设置来填充我的mongodb。我正在设置一个计数器，这样我可以在向数据库添加新配方时自动增加一个值。现在我正在使用async.series在种子文件中运行不同的任务。在我所包含的内容中，您可以看到我设置的recipe_id等于此方法的返回值getNextSequence（计数器，“recipeid”）

getNextSequence使用Counter模型来查询（findOneAndUpdate）db。我相信findOneAndUpdate的回调从来不会被调用，因为首先调用了async.series的回调函数。这是一个有趣的问题，因为我需要确保getNextSequence在继续前成功返回。不确定最好的方式去做这件事。

//seed.js //不全

 var getNextSequence = require('./utils/getNextSequence').getNextSequence; 

     recipes = new mongo.Collection(db, "recipes"); 
     counters = new mongo.Collection(db, "counters"); 

     async.series([ 
      function(callback){ 
       //initiate counter 
       counters.insert(
       { 
        _id: "recipeid", 
        seq: 0 
       },function(err, rec){ 
         callback(err, rec); 
       }) 

      }, 
      function(callback){ 
       //add test recipes 

       recipes.insert([{ 
        recipe_id: getNextSequence(counters, "recipeid"), 
        title:'title 1', 
        body:'body 1', 
        author: [seedUsers[1]._id], 
        categories: [ seedCategories[0]._id, seedCategories[1]._id ], 
        create_at: new Date() 
       },{ 
        recipe_id: getNextSequence(counters, "recipeid"), 
        title:'title 2', 
        body:'body 2', 
        author: [seedUsers[1]._id], 
        categories: [ seedCategories[1]._id ], 
        create_at: new Date() 
       }], function(err, rec){ 
        callback(err, rec); 
       }) 
      } 
     ], 
     // optional callback 
     function(err, results){ 
      //console.log('\n', results); 
      db.close(); 
     }); 

//getNextSequence.js

var Counter = require('../counter').Counter; 

exports.getNextSequence = function(counters, name) { 

Counter.findOne({ '_id': 'recipeid' }, function (err, counter) { 
    //if (err) return handleError(err); 
    //never called 
    console.log('---counter seq=', counter.seq); 
}) 

Counter.findOneAndUpdate({ _id: name }, { $inc: { seq: 1 } }, { new: true }, function(err, counter){ 
//never called 
    console.log('counter.seq', counter.seq); 
    return counter.seq; 
    } 
) 

}

Answer 1

我不知道你使用的异步库，让我们假设它是这样的https://github.com/caolan/async

你可能想先运行getNextSequence，然后我插入收据。稍微更改getNextSequence，以便async知道何时完成findOneAndUpdate过程。我也改为使用waterfall，所以从一个任务的结果传递到下一个

var Counter = require('../counter').Counter; 

exports.getNextSequence = function (counters, name, callback) { 

    Counter.findOne({'_id': 'recipeid'}, function (err, counter) { 
    //if (err) return handleError(err); 
    //never called 
    console.log('---counter seq=', counter.seq); 
    }) 

    Counter.findOneAndUpdate({_id: name}, {$inc: {seq: 1}}, {new: true}, function (err, counter) { 
     //never called 
     console.log('counter.seq', counter.seq); 
     callback(null, counter.seq); 
    } 
) 
} 

播种

var getNextSequence = require('./utils/getNextSequence').getNextSequence; 

recipes = new mongo.Collection(db, "recipes"); 
counters = new mongo.Collection(db, "counters"); 

async.waterfall([ 
    function (callback) { 
     //initiate counter 
     counters.insert(
     { 
      _id: "recipeid", 
      seq: 0 
     }, function (err, rec) { 
      callback(err, rec); 
     }) 

    }, 
    function (callback) { 
     getNextSequence(counters, "recipeid", callback); 
    }, 
    function (seq, callback) { 
     //add test recipes 
     recipes.insert({ 
     recipe_id: seq, 
     title: 'title 1', 
     body: 'body 1', 
     author: [seedUsers[1]._id], 
     categories: [seedCategories[0]._id, seedCategories[1]._id], 
     create_at: new Date() 
     }, function (err, rec) { 
     callback(err, rec); 
     }) 
    }, 
    function (callback) { 
     getNextSequence(counters, "recipeid", callback); 
    }, 
    function (seq, callback) { 
     //add test recipes 
     recipes.insert({ 
     recipe_id: seq, 
     title: 'title 2', 
     body: 'body 2', 
     author: [seedUsers[1]._id], 
     categories: [seedCategories[1]._id], 
     create_at: new Date() 
     }, function (err, rec) { 
     callback(err, rec); 
     }) 
    } 
    ], 
    // optional callback 
    function (err, results) { 
    //console.log('\n', results); 
    db.close(); 
    });