0
407
VistasCómo estructurar una función recursiva async/await para firestore en node.js
Lo que estoy tratando de hacer:
Estoy tratando de recuperar todos los comentarios y sus respuestas de firestore (base de datos firebase) usando un método recursivo. Esta es la estructura de los datos:
¿Cuál es el problema? La función asíncrona principal no espera a que se complete la función asíncrona anidada.
getThread = async (req, res) => { // Getting comments belonging to thread const thread_document = await db.doc(`/Threads/${req.params.threadid}`).get() threadData = thread_document.data() threadData.threadid = thread_document.id const comment_query = await db.collection('Comments').where('threadid', '==', threadData.threadid).get() // Getting replies belonging to comments for (document of comment_query){ let commentData = await getReplies(document.id) threadData.comments.push(commentData ) } return res.json(threadData) } //Recursive function to retrieve replies getReplies = async (id) => { let comment = await db.doc(`/Comments/${id}`).get() let commentData = comment.data() commentData.comment_replies = commentData.replies.map(idx => { // The parent async function does not wait for the the async function here to finish. // Placing a await keyword here will raise the error 'await is only valid in async functions and the top level bodies of modules' return getReplies(idx) }) console.log(commentData) return commentData } Dado el siguiente ejemplo,
Dado que la función asíncrona principal no espera a la función asíncrona anidada, el orden de ejecución ahora es A -> B -> a, y a no se asigna a commentData y commentData para el comentario A terminaría vacío. Por lo tanto, quiero programar para hacer A -> a -> B. Para hacerlo, me gustaría colocar una palabra clave en espera justo antes de getReplies como
return await getReplies(idx)pero levantará el error,
await is only valid in async functions and the top level bodies of modules. Lo cual es confuso ya que getReplies ya es una función asíncrona. He buscado otras soluciones en stackoverflow pero no puedo hacer que funcione la función recursiva. Cualquier idea sería apreciada, gracias.
1 Respuestas
Responde la pregunta0
commentData.comment_replies = commentData.replies.map(idx => { // ... return getReplies(idx) })Esta declaración de mapa creará una serie de promesas, pero no espere a que finalicen. Debe usar Promise.all para combinarlos en una sola promesa y luego esperar esa promesa para obtener la variedad de respuestas de comentarios:
const promises = commentData.replies.map(idx => { return getReplies(idx); }); commentData.comment_replies = await Promise.all(promises);Lo cual es confuso ya que getReplies ya es una función asíncrona.
Estaba recibiendo ese error porque la función que está dentro es idx => { return getReplies(idx) } , que no es una función asíncrona. Pero poner una espera allí no es una solución a su problema de todos modos.