From 5424a064c63345a28b333ca9ac3051843cfea73c Mon Sep 17 00:00:00 2001 From: Francesco Esposito <33671357+frab1t@users.noreply.github.com> Date: Fri, 22 Feb 2019 10:12:24 +0100 Subject: [PATCH] implements db events --- server.js | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 1 deletion(-) diff --git a/server.js b/server.js index efd4099..9d0d1dd 100644 --- a/server.js +++ b/server.js @@ -15,6 +15,8 @@ const connectionString = `${db.prefix}${db.user}:${db.password}@${db.host}/${db. mongoose.connect(connectionString, { useNewUrlParser: true }); mongoose.set('useFindAndModify', false); +const mongodb = mongoose.connection; + app.use((err, req, res, next) => { logger.logError(err); res.status(500); @@ -33,12 +35,24 @@ app.listen(port, () => { logger.logConsole('Server started.'); }); +mongodb.on('connected', () => { + logger.logInfo('DB connected'); +}); + +mongodb.on('disconnected', () => { + logger.logInfo('DB disconnected'); +}); + +mongodb.on('error', (err) => { + logger.logError(`DB error:' ${err}`); +}); + process.on('uncaughtException', (err) => { logger.logError(err); }); process.on('SIGINT', () => { - mongoose.connection.close(); + mongoose.disconnect(); logger.logInfo('Server stopped'); logger.logConsole('Server stopped'); process.exit(0);