正确的链式承诺语法

Question

我试图弄清楚如何使用 promises 更正重写我的函数。原始工作版本如下：

this.accountsAPI.find(filter, function(err,result){
    if (err || 0 == result.length) {
      return res.status(400).json({error: "Can't find the account."});
    }
    var workRequest = req.query.workRequest;
    // result has some records and we assume that _id is unique, so it must have one entry in the array
    var newJob = { jobId: workRequest, acceptedById: result[0]._id, dateCreated: new Date() };
    this.jobsAPI.create( newJob, function(jobErr, jobResult) {
      if (jobErr) { return res.status(400).json({error: "Can't create a new job."}); }
      res.status(200).json({newJob});
    });
});

我已将其重写为：

return new Promise(function ( fulfill, reject) {
    this.accountsAPI.find(filter)
      .then(function (result) {
        if (0 == result.length) { return res.status(400).json({error: "Can't create a new job."}); }
        var workRequest = req.query.workRequest;
        // result has some records and we assume that _id is unique, so it must have one entry in the array
        var newJob = { workRequestId: workRequest, acceptedById: result[0]._id, dateCreated: new Date() };
        this.jobsAPI.create( newJob, function(jobErr, jobResult) {
          if (jobErr) { return res.status(400).json({error: "Can't create a new job."}); }
          res.status(200).json({newJob});
        })
      })
      .catch((err) => {
        return res.status(400).json({
        error: "Can't create a job.",
        errorDetail: err.message
      });
});

不确定我是否正确编码了 promise 版本。但是，即使我这样做了，仍然存在链式异步请求，所以我的 Promise 版本只会让事情变得更复杂。

我应该为此类调用使用 promises 吗？有没有办法优雅地重写我的代码？

Answer 1

不，将所有内容包装在 Promise 构造函数中不会自动使其工作。

您应该从您在最低级别上使用的 promisifying the asynchronous functions 开始 - 也就是说，在您的情况下，accountsAPI.find 和 this.jobsAPI.create。为此，您将需要 Promise 构造函数：

function find(api, filter) {
    return new Promise(function(resolve, reject) {
        api.find(filter, function(err, result) {
            if (err) reject(err);
            else resolve(result);
        });
    });
}
function create(api, newJob) {
    return new Promise(function(resolve, reject) {
        api.create(newJob, function(err, result) {
            if (err) reject(err);
            else resolve(result);
        });
    });
}

如你所见，这有点重复，你可以为此编写一个辅助函数；但是如果你使用的 promise 库不仅仅是 ES6 polyfill，它可能已经提供了一个。

现在我们有两个函数，find 和 create，它们将 return 承诺。有了这些，你可以将你的函数重写为一个简单的

return find(this.accountsAPI, filter).then(function(result) {
    if (result.length == 0)
        throw new Error("Can't find the account.");
    return result;
}, function(err) {
    throw new Error("Can't find the account.");
}).then(function(result) {
    // result has some records and we assume that _id is unique, so it must have one entry in the array
    return create(this.jobsAPI, {
        jobId: req.query.workRequest,
        acceptedById: result[0]._id,
        dateCreated: new Date()
    }).catch(function(err) {
        throw new Error("Can't create a new job.");
    });
}.bind(this)).then(function(newJob) {
    res.status(200).json(newJob);
}, function(err) {
    res.status(400).json({error:err.message});
});

正确的链式承诺语法

Correct chained promise syntax

javascript

node.js

es6-promise