带有 API 和数据库查询的 Node.js Promise Chain

Question

我对整个承诺业务很陌生，正在与他们一起尝试我的项目。
不，我需要查询一个外部 API，在响应中执行几个项目，用它们对我自己的数据库进行其他检查，当所有这些都完成后，需要自己解决整个承诺。
我还需要在标记点再次调用我的数据库并做出另一个承诺。这些是相互独立的，但“父”承诺只有在两者都解决时才会解决。
我在这里遇到了困难，可能需要一些关于将多个承诺与多个项目链接起来的一般解释。
也许我只是在这里理解了一些普遍错误的东西...... 到目前为止，这是我的代码（缩写为 ...）：

'use strict';

import rp from 'request-promise';
import _ from 'lodash';

var Import = {
  init: function(user, options) {
    return new Promise((resolve, reject) => {
      rp.get("...") // call to external API
        .then((res) => {
          ...
          resolve();
        });
      ...
    });
  },
  run: function() {
    return new Promise((resolve, reject) => {
      ...

      rp.get(...) // call to external API
        .then((res) => {
          var events = JSON.parse(res).data;
          var promises = [];

          for (var i = 0; i < events.length; i++) {

            promises.push(new Promise((resolve, reject) => {
              ...

              Location.findOneAndUpdateAsync(...)
                .then((loc) => {
                  events[i].location = loc._id;
                  resolve();
                })
                .catch((err) => {
                  console.error(err);
                  reject();
                });

              // I need even another call to my database here later with another promise
            }));
          }
          return Promise.all(promises)
            .then(() => {
              console.log("all promises resolved");
              resolve(events);
            });
        })
        .catch((err) => {
          console.error(err);
          reject(err);
        });
    });
  }
};

Answer 1

您可以通过不违反Promise constructor anti-pattern 来显着简化您的代码 - 您调用的函数已经返回承诺，因此您应该利用这些承诺。

然后，用Array.prototype.map 消除for / push 循环：

var promises = events.map(function(event) {
    return Location.findOneAndUpdateAsync(...)
            .then((loc) => event.location = loc._id);
});

你说你有两组调用，但由于它们是独立的，你不妨使用另一个.map调用：

var promises2 = events.map(function(event) {
    return ...
});

然后您只需要等待所有这些并返回您的 events 对象：

return Promise.all(promises.concat(promises2)).then(() => events);

不需要所有 .catch 块 - 您应该让错误向上传播。

如果（根据您的 cmets）这两个内部调用有依赖关系，您可以试试这个：

var promises = events.map(function(event) {
    return Location.findOneAndUpdateAsync(...)
           .then((loc) => {
               event.location = loc._id;
               if (condition) {
                   return XXXOtherFunctionReturningPromise();
               }
           });
});

[然后显然消除上面的.concat调用]