PROBLEMA
Tu función middleware que maneja la ruta no está trabajando correctamente con el código asíncrono.
app.get('/mascotas', (req, res)=>{
console.log(datos)
res.send(datos)
});
Llamar a la función que obtiene los datos de esta forma no es conveniente, ya que se ejecutará 1 sola vez al iniciarse el programa y luego nunca más.
const datos = getData()
app.get('/mascotas', (req, res)=>{
...
});
SOLUCIÓN
La solución dependerá de cómo desees trabajar con el método asíncrono. Por ejemplo si deseas usar async / await
en el middleware que maneja la ruta, podrías hacerlo así:
app.get('/mascotas', async (req, res)=>{
try {
const datos = await getData();
console.log(datos);
return res.send(datos);
}
catch(e) {
console.error(e.message);
return res.status(500).json({
message: 'Algo fue mal con la consulta!'
});
}
});
Cuando trabajamos con async / await
debemos siempre usar try ... catch
para poder capturar cualquier excepción o Promesa rechazada.
Si deseas usar then()
y catch()
podrías hacerlo de esta manera:
app.get('/mascotas', (req, res)=>{
getData()
.then(data => {
console.log(data);
res.send(data);
})
.catch(e => {
console.error(e.message);
res.status(500).json({
message: 'Algo fue mal con la consulta!'
});
});
});
De esta forma, cada vez que alguien accede a la ruta '/mascotas'
simepre obtendrá los datos al realizar la llamada a MongoDB.
Si bien esta sería una forma de solucionar el problema, tienes otro aún mayor, y es que cada vez que alguien accede a dicha ruta, estás abriendo una conexión nueva a la base de datos, y no la estás cerrando.
Aquí entras en escenarios de debate. Hay quienes opinan dejar la conexión abierta, es decir, que al iniciar tu aplicación se realice una conexión a MongoDB y se reutlice la misma en toda la aplicación o por el contrario, que por cada petición se realice una nueva conexión.
Todo esto va a depender de tu necesidad. Pero si deseas cerrar la conexión una vez se tiene la información solicitada basta con modificar la fucnión getData
de la siguiente forma:
async function getData() {
const client = new MongoClient(uri, { useNewUrlParser: true, useUnifiedTopology: true });
await client.connect(); // <- se abre la conexión
const cursor = await client.db(dbname)
.collection(coleccion)
.find({});
const result = await cursor.toArray();
await client.close(); // <- se cierra la conexión
return result;
}
Por último, si bien hacerlo así es suficiente, lo recomendable es no cerrar la conexión.
Si deseas usar la misma conexión a lo largo de toda la vida de tu aplicación, todo cambiaría de la siguiente forma:
const { MongoClient } = require('mongodb');
const express = require('express');
const app = express();
const dbname = xxxx;
const coleccion = xxxx;
const uri = xxxx;
const puerto = 5500;
const client = new MongoClient(uri, { useNewUrlParser: true, useUnifiedTopology: true });
client.connect()
.then(() => {
async function getData() {
const cursor = await client.db(dbname)
.collection(coleccion)
.find({});
const result = await cursor.toArray();
return result;
}
app.get('/mascotas', async (req, res)=>{
try {
const datos = await getData();
console.log(datos);
return res.send(datos);
}
catch(e) {
console.error(e.message);
return res.status(500).json({
message: 'Algo fue mal con la consulta!'
});
}
});
app.listen(puerto, () => {
console.log(`Puerto ${puerto}. Escuchando`);
});
})
.catch(e => {
console.log('Error de conexión a la base de datos');
console.error(e.message);
process.exit(1);
});
Como observas, el servidor de Express es levantado dentro de la función callback pasada a then()
. Esta es una forma de hacerlo, existen otras. Pero la idea general es crear la conexión y reutilizarla siempre en la aplicación.
Si la conexión con MongoDB fallara, la aplicación tal vez no tendría sentido, por lo tanto el programa sale con un estado de error distinto de cero.
Además, y aunque parezca una nimiedad, todas las sentencias de mi código llevan ;
al final. Es algo de buenas prácticas.
Espero que esto te ayude a resolver el problema.