Tengo problemas para descubrir por qué mi código nunca finaliza la ejecución y se atasca. Se registra done antes de hacer nada en el bloque async run() . El código simplemente se cuelga con una salida de:
done test test async function successfullyPaid(doc){ return await updateMongoDBStuff(); } async function run() { findMongoDBstuff(); await cursor.forEach(async (doc) => { //forEach being Mongo's cursor iterator, not the Native JS one console.log('test') if (doc.plan.nextPayment <= getUnixTimeSeconds()) { if (parseInt(doc.plan.remaining) >= 0){ allProds = client.db('ProductsDB').collection('allProds') let prod = await allProds.findOne({}) amount = prod.recurring.periods[doc.plan.period] let data = { "transaction": { "amount" : "1000", "payment_method_token": `visa_card`, "currency_code": "USD", "retain_on_success": true, "email" : doc.client.email}} let response = await superagent.post(`https://example.com`).send(data).set('accept', 'json').auth('xxxxxxxxxxxxxxxxxxxxxxxxx', 'xxxxxxxxxxxxxxxxxxxxxxxxxx'); if (response.body.transaction.succeeded == true){ await successfullyPaid(doc) } else{ console.log(response) } }}}); } run().catch((error)=>{console.log(error);}).then(console.log('done'));¿Algunas ideas?
De acuerdo con la documentación del controlador MongoDB NodeJS, los cursores ( heredados de AbstractCursor ) tienen un símbolo [asyncIterator] . Un objeto que tiene ese símbolo implementa una función que le permite usarlos en un bucle for await...of :
for await (const doc of cursor) { console.log(test); // ... await successfullyPaid(doc); // ... } console.log('done'); Un bucle for await...of obtendrá un elemento del cursor, ejecutará lo que esté en su cuerpo y luego repetirá hasta que el cursor se agote. Puede usar break , continue , try {} catch {} en el cuerpo, al igual que los bucles regulares.
Esto procesará todos los elementos uno tras otro en serie, lo que parece ser lo que estaba buscando.
Si desea ejecutar cosas en paralelo, use una biblioteca que pueda tomar AsyncIterator y convertirlo en lotes, luego procese (por ejemplo) 5 a la vez hasta que se agote. Pero hacerlo en serie probablemente sea lo suficientemente rápido, es más fácil y menos complejo.