如何从 then 子句返回 Promise 数组

Question

我看到了一个类似的问题here，它没有解决我的问题。我试图每 10 小时运行一次 cron 作业，让我首先获取类别，然后根据类别，我找到每个类别的信息。我怎样才能简化下面的承诺。我没有使用 Bluebird 或 Q，这是原生 JS 的承诺。老实说，下面的代码看起来就像 Promise 应该避免的回调地狱，任何建议

flipkart.getAllOffers = function () {
    interval(43200, () => {
        flipkart.findAllCategories()
            .then((categories) => {
                flipkart.save('flipkart_categories.json', categories)
                if (categories) {
                    for (let item of categories) {
                        flipkart.findAllForCategory(item.category, item.top)
                            .then((items) => {
                                flipkart.save('flipkart_top_' + item.category + '.json', items)
                            }).catch((error) => {
                                console.log(error)
                            })
                    }
                }
            })
            .catch((error) => {
                console.log(error)
            })
    })
}

function interval(seconds, callback) {
    callback();
    return setInterval(callback, seconds * 1000);
}

Answer 1

如果您停止为 .then() 使用额外的缩进级别，那么您的结构非常简单。

一个 .then() 处理程序包含 if() 声明 包含一个 for 循环 包含另一个异步操作

在这个修改后的版本中，一半的缩进来自你的if 和for，这与promise 无关。其余的对我来说似乎很合乎逻辑，根本不像回调地狱。这是实现您展示的逻辑所必需的。

flipkart.getAllOffers = function () {
    interval(43200, () => {
        flipkart.findAllCategories().then((categories) => {
            flipkart.save('flipkart_categories.json', categories)
            if (categories) {
                for (let item of categories) {
                    flipkart.findAllForCategory(item.category, item.top).then((items) => {
                        flipkart.save('flipkart_top_' + item.category + '.json', items)
                    }).catch((error) => {
                        console.log(error)
                        throw error;     // don't eat error, rethrow it after logging
                    });
                }
            }
        }).catch((error) => {
            console.log(error)
        })
    })
}

如果flipkart.save() 也是异步的并返回一个promise，那么您可能也希望将它们挂钩到promise 链中。

---

您始终可以创建一个可以改善外观的辅助函数，如下所示：

flipkart.getAllOffers = function () {
    interval(43200, () => {
        flipkart.findAllCategories().then(iterateCategories).catch((error) => {
            console.log(error);
        })
    })
}

function iterateCategories(categories) {
    flipkart.save('flipkart_categories.json', categories);
    if (categories) {
        for (let item of categories) {
            flipkart.findAllForCategory(item.category, item.top).then((items) => {
                flipkart.save('flipkart_top_' + item.category + '.json', items);
            }).catch((error) => {
                console.log(error);
            });
        }
    }    
}

如果您尝试收集所有结果（您的标题暗示了这一点，但您的问题实际上并未提及），那么您可以这样做：

flipkart.getAllOffers = function () {
    interval(43200, () => {
        flipkart.findAllCategories().then(iterateCategories).then((results) => {
            // all results here
        }).catch((error) => {
            console.log(error);
        });
    })
}

function iterateCategories(categories) {
    flipkart.save('flipkart_categories.json', categories);
    let promises = [];
    if (categories) {
        for (let item of categories) {
            let p = flipkart.findAllForCategory(item.category, item.top).then((items) => {
                flipkart.save('flipkart_top_' + item.category + '.json', items);
            }).catch((error) => {
                console.log(error);
            });
            promises.push(p);
        }
    }
    // return promise here that collects all the other promises
    return Promise.all(promises);
}