Estoy intentando completar una matriz de respuesta con una instantánea de Firestore y, dentro de cada instantánea, crear un enlace de descarga de archivos almacenados. Probé soluciones con Promises pero siempre la matriz de respuesta era nula.
docRef.get().then(async (snapshot: any) => { await snapshot.docs.forEach(async (attachment: any) => { await downloadFile(attachment.data()["paths"]).then((urls: any) => { attachmentList.push({ "id": attachment.id, "created_at": attachment.data()["created_at"], "paths": urls, "content_types": attachment.data()["content_types"] }) }).catch(error => { res.status(400).send({ "code": "ERROR", "message": error }); }) }) }) res.send({ "code": "ok", "message": attachmentList });Este es un caso clásico para Promise.all . prueba de esta manera
const snapshot = await docRef.get(); const results = await Promise.all( snapshot.docs.map( attachment => downloadFile(attachment.data()["paths"]) ) ); console.log(results);Si limpiamos su sangría, puede ver rápidamente por qué no está recibiendo nada por "mensaje", independientemente de lo que estaba intentando allí: devuelve la respuesta antes de que se ejecute cualquiera de las cosas asincrónicas:
docRef.get() .then(async (snapshot: any) => { // <-- this line won't run /* ... removed for conciseness */ }); res.send({ "code": "ok", "message": attachmentList }); // <-- before this line (and the response is sent already!)Lo que está buscando hacer es ensamblar su conjunto de archivos adjuntos y luego devolverlos:
docRef.get() .then((snapshot) => { return Promise.all( snapshot.docs.map(async (attachmentDocSnapshot) => { const { paths, created_at, content_types } = attachmentDocSnapshot.data(); const urls = await downloadFile(paths); return { content_types, created_at, id: attachmentDocSnapshot.id, paths: urls }; }) ); }) .then((attachmentInfoList) => { res.json({ // .json() is more semantic "code": "OK", // for consistency, capitalized "message": attachmentInfoList }); }) .catch((err) => { console.error(`Failed to collect information about the attachments for Doc #${docRef.id}: `, error); res.status(500).json({ // 500 Internal Server Error "code": "ERROR", "message": error.code || error.message // Send back as little information about the error as possible }); });Si bien el código anterior funciona, no es bonito. Así que volvamos a trabajar en una función secundaria:
async function getAttachmentInfoFromSnapshot(attachmentDocSnapshot) { const { paths, created_at, content_types } = attachmentDocSnapshot.data(); const urls = await downloadFile(paths); return { content_types, created_at, id: attachmentDocSnapshot.id, paths: urls }; } docRef.get() .then((snapshot) => Promise.all( snapshot.docs.map(getAttachmentInfoFromSnapshot) )) .then((attachmentInfoList) => { res.json({ // .json() is more semantic "code": "OK", // for consistency, capitalized "message": attachmentInfoList }); }) .catch((err) => { console.error(`Failed to collect information about the attachments for Doc #${docRef.id}: `, error); res.status(500).json({ // 500 Internal Server Error "code": "ERROR", "message": error.code || error.message // Send back as little information about the error as possible }); }); Nota: puede volver a escribir lo anterior para usar la sintaxis async / await en el siguiente nivel, pero si lo hace, asegúrese de envolverlo todo en un bloque try / catch para manejar cualquier error en el camino.