Блог

Я получаю объект, у которого есть список идентификаторов продуктов и ссылка на его базу данных, поэтому я должен искать каждый продукт в своей базе данных, чтобы получить его цену, я пробовал что-то вроде этого

 const functions = require('firebase-functions');
const cors = require('cors')({
    origin: true
});
const admin = require('firebase-admin');
var request = require('request');
admin.initializeApp();
exports.GeraPagSeguro = functions.https.onRequest((req, res) => {
    cors(req, res, () => {
            if (req.method === 'POST') {
                var xml;
                req.body.map((product) => {
                    admin.database().ref(product.refitem).once('value', (snapshot) => {
                        const value = snapshot.val();
                        const price = value.price;
                        xml  = price;
                        //rest of code building the xml i want
                    })
                })
                //rest of code sending the xml via POST to other server
            })
    })
})
  

Проблема в том, что остальная часть кода не wait выполняет все обещания map .

Чтобы дождаться завершения нескольких асинхронных операций, используйте Promise.all() :

 var xml;
var promises = [];
req.body.map((product) => {
    promises.push(admin.database().ref(product.refitem).once('value', (snapshot) => {
        const value = snapshot.val();
        const price = value.price;
        return price;
    })
})
Promise.all(promises).then((prices) => {
    prices.forEach((price) => {
        ...
    });
    //rest of code sending the xml via POST to other server
});
  

Поскольку функция базы данных firebase возвращает Promise , вы можете превратить свою функцию в асинхронную функцию и вызвать await ее. Вот так:

 exports.GeraPagSeguro = functions.https.onRequest(async (req, res) => {
    cors(req, res, () => {
            if (req.method === 'POST') {
                var xml;
                req.body.map((product) => {
                    const snapshot = await admin.database().ref(product.refitem).once('value')
                    const value = snapshot.val();
                    const price = value.price;
                    xml  = price;
                    //rest of code building the xml i want
                })
                //rest of code sending the xml via POST to other server
            })
    })
})
  

Затем вы можете выполнить другой код, как будто они «ждали» операции firebase

Примечание: Асинхронные функции не включены в настройках Firebase functions по умолчанию, вам необходимо указать emcaVersion значение 2017 или 8 (по умолчанию 7) в .eslintrc.json файле, чтобы убедиться, что связанные с асинхронностью функции работают. Это должно выглядеть так:

 {
    "parserOptions": {
        "ecmaVersion": 2017 //or 8
    }
}
  

Кроме того, вам также нужно добавить promise в качестве плагина, вот так:

 "plugins": [
    "promise"
 ]
  

Если у вас есть что-либо в, .eslintrc.json что указывает es6 на использование, измените это на es7 .