获取对象数组promise，然后遍历对象

Question

我正在尝试创建一个名为 pw_array 的数组，将 pw_subscribers 的内容分配给该数组，然后将 pw_array 中的每个对象附加到第二个承诺中的新键值对。我对承诺很陌生，并且在完成这项工作时遇到了很多麻烦。现在，当我在 getCustomers 函数中的第二个承诺中 console.log(pw_customer) 时，它正在返回我想要的。但是当我稍后 console.log(pw_array) 时它是原始数组。

var pw_array = [];
//first promise is working correctly
var getPaywhirlSubscribers = new Promise(function(resolve, reject) {

paywhirl.Subscriptions.getsubscribers({limit:100}, function(error, pw_subscribers) {
        Promise.all(JSON.parse(pw_subscribers).forEach(function(pw_subscriber) {
             pw_array.push(pw_subscriber);
        }))
        // console.log(pw_array);
        return resolve(pw_array);
    });
});

var getGatewayReferences = function(pw_array) {
    return new Promise(function(resolve, reject) {
        Promise.all(pw_array.forEach(function(pw_customer) {
            paywhirl.Customers.getCustomer(pw_customer.customer_id, function(error, customer) {
                pw_customer.phone = customer.phone;
                pw_customer.address = customer.address;
                pw_customer.gateway_reference = customer.gateway_reference;
                // this console.log is returning what I want
                // console.log(pw_customer);
            }); 
        }));
        resolve(pw_array);
        // console.log(pw_array);
    });
};

还有承诺链...

getPaywhirlSubscribers.then(getGatewayReferences).then(function(pw_array) {
  // this console.log is returning the original pw_array with pw_subscribers but not with the appended pw_customer keys
  console.log(pw_array);
});

Answer 1

您的所有代码都可以简化为

var getPaywhirlSubscribers = function() {
  return new Promise(function(res, rej) {
    paywhirl.Subscriptions.getSubscribers({limit:100}, function(err, subs) {
      if (err) {
        rej(err);
      } else {
        res(JSON.parse(subs));
      }
    });
  });
};

var gatewayRefs = function(promiseOfArray) {
  return promiseOfArray.then(function(subs) {
    return Promise.all(subs.map(function(sub) {
      return new Promise(function(res, rej) {
        paywhirl.Customers.getCustomer(sub.customer_id, function(err, customer) {
          if (err) {
            rej(err);
          } else {
            res(Object.assign({}, sub, customer);
          }
        });
      });
    });
  });
};

gatewayRefs(getPaywhirlSubscribers()).then(function(arrayOfCustomers) {
  // do something with the customer array
});

请注意，如果您使用众多实用程序之一，可以自动将 node.js 样式的错误优先回调 API 转换为基于 Promise 的回调 API，则可以使此过程更短/更简单。搜索“promise denodeify”。

您还可以想象将一些步骤拉出到 .then 链中以减少嵌套，但恕我直言，这既美观又实用。