PROBLEMA
Tu problema es de asincronía. Ya que en tu función reductora, haces el llamado a un método asíncrono: findOneAndUpdate()
de Mongoose.
El método reduce
no es asíncrono y por lo tanto no esperará por el resultado de cada llamado a findOneAndUpdate
.
Podemos ver este ejemplo:
const lista = [1, 2, 3, 4]
const reductorSync = (acumulador, valorActual) => {
console.log(`acc: ${acumulador}, cur: ${valorActual}`);
return acumulador + valorActual;
}
const reductor = (acumulador, valorActual) => {
console.log(`acc: ${acumulador}, cur: ${valorActual}`);
//emulamos un proceso asíncrono con un Timeout
return setTimeout(() => {
console.log(acumulador + valorActual);
return acumulador + valorActual;
}, 0);
}
console.log(`Resultado Sync: ${lista.reduce(reductorSync)}`);
console.log(`Resultado Async: ${lista.reduce(reductor)}`);
.as-console-wrapper { max-height: 100% !important; top: 0; }
¿Qué sucedió? Simplemente la operación de reducción en el caso asíncrono se llevo a cabo en un momento diferente al esperado. Y eso es lo que sucede con tu código.
Otro problema que veo en tu código es que tu función reductora devuelve el resultado de una actualización sobre un documento de una colección. No sé el porqué querrías usar específicamente reduce()
para llevar a cabo la tarea, cuando podrías hacerlo con cualquier otro método tal vez más apropiado, por ejemplo: forEach()
.
Por último, de lo que puedo deducir del código que has expuesto, lo que deseas hacer es actualizar diferentes documentos de la colección de usuarios con valores que se encuentran en la lista que recibe tu función como argumento. Dices que la lista es un arreglo o array
de objetos. Pero tienes esta línea:
"_id": lista._id
Evidentemente lista._id
será siempre undefined
, ya que un tipo Array
no posee dicha propiedad o atributo. Así que, asumiendo que te refieres al campo _id
de cada objeto de tu lista, lo correcto sería:
"_id": elemento._id
o tal vez:
"_id": elemento.previo._id
dependerá de la estructura de tus objetos.
SOLUCIÓN
Si tengo una lista de objetos que tienen los valores a actualizar en la colección de usuarios, debemos hallar una forma iterativa de actualizar todos los documentos afectados con los valores presentes en la lista.
Ninguno de los métodos de los tipo Array
nos sirven para este propósito, ya que no son asíncronos.
Una posible solución es usar Promise.all()
.
Supongamos que la estructura de cada objeto en la lista es la siguiente:
[
{
_id: <ObjectId>,
previo: {
pasarela: <String>,
fecha_fin: <Date>,
dispositivos: <Array>,
estado_token: <String>
}
},
{ ... },
...
{ ... }
]
Podemos observar que cada elemento de la lista es un objeto con 2 campos: _id
y previo
, y este último es el que contiene los valores a actualizar en nuestro documento.
Dado que buscaremos documentos por el campo _id
que es único para cada documento, en vez de usar findOneAndUpdate
usaremos directamente findByIdAndUpdate()
.
La consulta quedaría escrita de la siguiente forma:
User.findByIdAndUpdate(
element._id,
{ $set: {
pasarela: element.previo.pasarela,
fecha_fin: element.previo.fecha_fin,
dispositivos: element.previo.dispositivos,
estado_token: element.previo.estado_token
}
},
{ new: true }) // <- esto devuelve el documento actualizado
// si no lo estableces, devolverá el documento encontrado
// antes de la actualización, y pensarás que no se actualizó
Ahora necesitamos construir un iterable
cuyos elementos sean promesas. De la documentación de Mongoose sabemos que las consultas o Queries no son Promesas, por lo tanto debemos envolver la misma dentro de una Promesa.
Por ejemplo:
const updatedUser = new Promise((resolve, reject) => {
User.findByIdAndUpdate(...)
.then(user => {
console.log('User updated.');
resolve(user);
})
.catch(error => {
console.error(error.message);
reject(error);
});
});
Hasta aquí se parece un poco a lo que ya tenías implementado. Pero necesitamos una forma de que cada updatedUser
sea parte de un iterable, y además debemos asegurarnos que cada uno de ellos se actualiza de acuerdo a los elementos de la lista.
De entre los métodos del tipo Array
que podríamos usar para recorrer la lista, vamos a escoger map()
, ya que el mismo se adapta a lo que necesitamos, es decir, crea un nuevo Array
(entiéndase iterable) con el resultado de la función callback
que le pasamos como argumento, y dicha función recibe a su vez entre sus argumentos el elemento de la lista que estamos iterando.
Podríamos escribir lo siguiente:
lista.map(element => {
return new Promise((resolve, reject) => {
const update = {
$set: {
pasarela = element.previo.pasarela,
fecha_fin = element.previo.fecha_fin,
dispositivos = element.previo.dispositivos,
estado_token = element.previo.estado_token
}
};
User.findByIdAndUpdate(element._id, update, {new: true})
.then(user => {
console.log('User updated.');
resolve(user);
})
.catch(error => {
console.error(error.message);
reject(error);
});
});
});
Muy bien, con esto, lista.map()
representa un iterable de promesas, podemos pasar este iterable como argumento de Promise.all()
.
Cabe destacar que Promise.all()
devuelve una promesa, por lo tanto no hace falta declarar tu función como tipo async
.
Tu método finalmente podría quedar parecido al siguiente:
function actualizarProceso(lista) {
return Promise.all(lista.map(element => {
const update = {
$set: {
pasarela = element.previo.pasarela,
fecha_fin = element.previo.fecha_fin,
dispositivos = element.previo.dispositivos,
estado_token = element.previo.estado_token
}
};
User.findByIdAndUpdate(element._id, update, {new: true})
.then(resolve); // <= Gracias a la programación funcional
})
.catch(reject); // <= Gracias a la programación funcional
});
}));
}
Ahora sólo debes usar tu función actualizarProceso()
bien con then()
y catch()
, por ejemplo:
// ...
actualizarProceso(lista)
.then((updatedUsers) => {
console.log(updatedUsers);
//...
})
.catch(console.error); // <= Gracias a la programación funcional.
O bien dentro de una función tipo async
con await
:
// dentro de una función o método async puedo usar await, siempre dentro de un
// bloque try catch
try {
const updatedUsers = await actualizarProceso(lista);
console.log(updatedUsers);
// ...
} catch (error) {
console.error(error.message);
//...
}
Espero que con esto aclares las dudas sobre cómo realizar la actualización de elementos de una lista con NodeJS y Mongoose.