猫鼬承诺链接不返回承诺

Question

我的 express 应用程序中有一个方法，它使用 mongoose findOneAndRemove() 从 mongoDB 中删除照片。一切都很好，在我的承诺中，我调用了一个帮助函数来更新数据库中的另一个文档。 我希望这个辅助函数在完成更新时返回一个承诺。但现在它在 Category.updateMany({name:category}, { $set: { "count" : count } }); updateMany 工作它只是没有通过链上的承诺。如何让我的 updateCategories() 方法从 Category.updateMany() 返回一个承诺。

exports.deletePhoto = (req, res, next)=>{
  Photo.findOneAndRemove({_id:req.body.id})
  .then(photo => {
    S3.deleteS3File(photo.photo);
    updateCategories( photo.category ).then((result)=>{
      res.send(photo);
    });
  })
}


// helper method Updates categories with count number of photos.

function updateCategories( category ){
  return Photo.find({category:category.toLowerCase()})
  .then( results =>{
    var count = results.length;
    return Category.updateMany({name:category}, { $set: { "count" : count } } );
  })
}

更新说明： 我想保持我的 updateCategories() 方法分开，因为我在 deletePhoto() 等其他方法中重用它。根据承诺的工作方式，你可以链接它们。所以我试图链接它们，以便我从 Category.updateMany() 得到的最后一个承诺从 updateCategories() 函数返回。

我只想能够从多个函数中调用下面的 updateCategories() 辅助方法，并让它从 updateCategories 内的 Category.updateMany() 返回一个承诺

updateCategories().then(result =>{
  // result 
)} 

最后更新 我只能通过一种方法来实现我的所有承诺。我不得不放弃第二种方法的想法。这意味着重复代码，但似乎无法使其正常工作。只是为了表明它与 S3 deleteS3File 方法无关。 下面的代码基本上是 realseanp 建议的。

exports.deletePhoto = (req, res, next)=>{
  let photo;
  Photo.findOneAndRemove({_id:req.body.id})
  .then(p => {
    photo = p;
    S3.deleteS3File(photo.photo);
    return Photo.find({ category: p.category.toLowerCase() });
  })
  .then(results => {
     return Category.updateMany({ name: photo.category }, { $set: { "count": results.length } });
  }).then(() => {
     res.send(photo);
  }).catch(e => {
     console.log("ERROR COULD NOT DELETE PHOTO = ", e );
  });
}

Answer 1

你有一些承诺反模式正在发生。将您的代码更新为以下内容即可

exports.deletePhoto = (req, res, next) => {
  let photo;
  Photo.findOneAndRemove({ _id: req.body.id })
    .then(p => {
      photo = p;
      S3.deleteS3File(photo.photo);
      return Photo.find({ category: photo.category.toLowerCase() });
    })
    .then(results => {
      const count = results.length;
      return Category.updateMany({ name: category }, { $set: { "count": count } });
    }).then(() => {
      res.send(photo);
    }).catch(e => { /* do something */ });
};

或者，如果您使用的是支持异步等待的节点版本，则可以使用以下

exports.deletePhoto = async (req, res, next) => {
  try {
    const photo = await Photo.findOneAndRemove({ _id: req.body.id });

    S3.deleteS3File(photo.photo);

    const catResults = await Photo.find({ category: photo.category.toLowerCase() });
    const count = catResults.length;

    await Category.updateMany({ name: category }, { $set: { "count": count } });

    return res.send(photo);
  } catch (e) {
    // There was an error - do something
  }
};

更新：

看起来 updateMany 方法返回一个查询 - 而不是一个承诺。您必须执行查询才能获得承诺：

注意更新后的 updateCategories 函数现在使用 exec()

exports.deletePhoto = (req, res, next) => {
  let photo;
  Photo.findOneAndRemove({ _id: req.body.id })
    .then(p => {
      photo = p;
      S3.deleteS3File(photo.photo);
      return updateCategories(photo.category.toLowercase());
    }).then(() => {
      res.send(photo);
    }).catch(e => { /* do something */ });
};

function updateCategories(category) {
  return Photo.find({ category })
    .then(results => Category.updateMany({ name: category }, { $set: { "count": results.length } }).exec());
}