javascript - 无法解析 javascript 中的内部 promise

Question

无法解决或超出内部 promise ，因此我可以将数据发送回客户端。

代码:

function getAmazonData(url, isRatings) {
    var parsedData;
    var ItemLookup;
    var ratingsURL;

    return new Promise(function (resolve, reject) {

        request(url, function (err, response, body) {
            if (err) return reject(err);
            parseXML(body, function (err, parsedData) {
                if (err) return reject(err);
                ItemLookup = parsedData['ItemLookupResponse'];

                if (ItemLookup && ItemLookup.Items && ItemLookup.Items.length > 0) {
                    // Request Error
                    if (ItemLookup.Items[0].Request && ItemLookup.Items[0].Request.length > 0 && ItemLookup.Items[0].Request[0].Errors) {
                        return reject(ItemLookup.Items[0].Request[0].Errors);
                    } else if (ItemLookup.Items[0].Item) {
                        ratingsURL = ItemLookup.Items[0].Item[0].CustomerReviews[0].IFrameURL[0];
                        if (isRatings) {
                            console.log('getting ratings...');
                            return new Promise(function (resolve2, reject2) {
                                request(ratingsURL, { json: true }, function (ratingsError, ratingBody) {
                                    if (ratingsError) {
                                        return reject2('Error in getting ratings');
                                    }
                                    ItemLookup.Items[0].Item[0].CustomerReviews.push({ Ratings: ratingBody });
                                    resolve2(ItemLookup.Items[0].Item[0].CustomerReviews);
                                });
                            });
                        }
                        console.log('Resolved: ', ItemLookup.Items[0].Item);
                        resolve(ItemLookup.Items[0].Item);
                    }
                }
            });
        });
    });
}

amazon_router.get('/getDetails', function (req, res, next) {
    var amazonApi = decodeURIComponent(req.query.url);
    var amzonApiUrl = amazonApi.replace(/\+/g, '%2B');
    var isRatings = decodeURIComponent(req.query.ratings);
    console.log('');
    console.log('amazon api url ', amzonApiUrl);
    console.log('');

    getAmazonData(amzonApiUrl, isRatings).then(function (err, response) {
        if (err) res.send(err);
        res.send(response);
    });
});

在第 10 行解决 promise 后，数据永远不会发送: res.send(response); 内部 promise 有问题，但我不确定是否要修复它？

Answer 1

看起来您正在混合回调和 promise 。我建议包装所有对 Promises 的调用。

从表面上看，您不需要内部 Promise，因为 request 需要回调，这样您就可以轻松解析外部 Promise。

您还有一些不调用resolve或reject的if语句分支(在下面的代码中用注释标记)。您必须在所有分支中调用resolve/reject，否则 Promise 在到达分支时“可能什么也不做”。

function getAmazonData(url, isRatings) {
  var parsedData;
  var ItemLookup;
  var ratingsURL;

  return new Promise(function (resolve, reject) {
    request(url, function (err, response, body) {
      if (err) return reject(err);
      parseXML(body, function (err, parsedData) {
        if (err) return reject(err);
        ItemLookup = parsedData['ItemLookupResponse'];

        if (ItemLookup && ItemLookup.Items && ItemLookup.Items.length > 0) {
          // Request Error
          if (ItemLookup.Items[0].Request && ItemLookup.Items[0].Request.length > 0 && ItemLookup.Items[0].Request[0].Errors) {
            reject(ItemLookup.Items[0].Request[0].Errors);
          } else if (ItemLookup.Items[0].Item) {
            ratingsURL = ItemLookup.Items[0].Item[0].CustomerReviews[0].IFrameURL[0];
            if (isRatings) {
              console.log('getting ratings...');
              request(ratingsURL, { json: true }, function (ratingsError, ratingBody) {
                if (ratingsError) {
                  reject(new Error('Error in getting ratings'));
                  return;
                }
                ItemLookup.Items[0].Item[0].CustomerReviews.push({ Ratings: ratingBody });
                resolve(ItemLookup.Items[0].Item[0].CustomerReviews);
              });
            } else {
              console.log('Resolved: ', ItemLookup.Items[0].Item);
              resolve(ItemLookup.Items[0].Item);
            }
          } else {
            // resolve or reject here
          }
        } else {
          // resolve or reject here
        }
      });
    });
  });
}

包装对 Promise 的调用:

function requestAsPromised(url) {
  return new Promise(function (resolve, reject) {
    request(url, function (err, response, body) {
      if (err) {
        reject(err);
      } else {
        resolve(body)
      }
    });
  })
}