Node.js - 迭代地运行带有回调的函数

Question

我正在使用 node.js 在 javascript 中开发 API

我想要做的是调用一个函数，该函数触发一系列承诺，并在回调时返回一个包含一个产品信息的数组。

我想要做的是根据需要多次运行此函数，以形成 JSON 格式的产品列表。

但是这个产品列表需要在发回给用户之前创建，这是我苦苦挣扎的地方。

这是我的功能：

exports.findProduct = (ingredient, store, callback) => {
            products.getProductData(ingredient, store)
        .then( data => products.getProducts(data))
        .then( productList => products.filterProductData(productList))
        .then( selectedProduct => callback(null,selectedProduct))//get individual products and add to list
        .catch( err => callback(err))
}

我这样称呼它

products.findProduct(ingredient, 'Waitrose', (err, data) => {

    if (err) {
        //res.send(status.badRequest, {error: err.message})
    } else {
        res.send(data)
        res.end()
    }

})

res.send(data) 将回调中的数据发送回服务器，但如果我想再次运行此函数并更新数组，然后才将数组发送到服务器，该怎么办？

非常感谢任何提示帮助。

Answer 1

一种基于 promise 的可能实现，允许 getAllProducts 递归调用自身。

exports.findProduct = (ingredient, store) => {
    return new Promise((resolve, reject) => {
         products.getProductData(ingredient, store)
        .then( data => products.getProducts(data))
        .then( productList => products.filterProductData(productList))
        .then( selectedProduct => resolve(selectedProduct))
        .catch( err => reject(err))
    }
}



function getAllProducts(ingredientList, shopName) {  
    const allProducts = [];
    return new Promise((resolve, reject) => {
        products.findProducts(ingredientList, shopName)
        .then(product => {
            allProducts.push(...product);

            if(/*need more products*/) {
                getAllProducts(ingredientList, 'Tesco')
                .then(newProducts => {
                    allProducts.push(...newProducts);
                    resolve(allProducts);
                })
                .catch(err => reject(err));
            } else {
                resolve(allProducts);
            }
        })
        .catch(err => reject(err));
    }
}

这样称呼...

getAllProducts(ingredientList, 'Waitrose')
.then(products => {
    res.send(products);
    res.end();
}).catch(err => {
    res.send(status.badRequest, {error: err.message});
    res.end();
});

编辑：

如果需要根据上一次调用的结果来判断是否进行更多调用，上述方法是有效的。如果您事先知道需要拨打多个电话，例如如果您知道要查看 Tesco、Waitrose 和 Asda，那么使用 Promise.all 有一种更简单的方法

exports.findProduct = (ingredient, store) => {
    return new Promise((resolve, reject) => {
         products.getProductData(ingredient, store)
        .then( data => products.getProducts(data))
        .then( productList => products.filterProductData(productList))
        .then( selectedProduct => resolve(selectedProduct))
        .catch( err => reject(err))
    }
}

function makeMultipleCalls() {  
    const stores = ['Waitrose', 'Tesco', 'Asda'];
    const promises = [];

    for (var store in stores) {
        promises.push(product.findProduct(ingredientList, store);
    }

    Promise.all(promises)
    .then(results => {
        res.send(results.reduce((a,b) => a.concat(b)));
        res.end();
    })
    .catch(err => {
        //deal with error
    });
}