add leveled logging

app.js

@@ -2,9 +2,9 @@
 const cors = require('koa2-cors');
 const helmet = require('koa-helmet');
 const Koa = require('koa');
-const logger = require('koa-pino-logger');
 const bodyParser = require('koa-bodyparser');
 const mongoose = require('mongoose');
+const { requestLogger, logger } = require('./middleware/logger');
 const { responseTime, cache } = require('./middleware');
 const { v4 } = require('./services');
 
@@ -16,14 +16,22 @@ mongoose.connect(process.env.SPACEX_MONGO, {
   useUnifiedTopology: true,
   useCreateIndex: true,
 });
+
 const db = mongoose.connection;
+
 db.on('error', (err) => {
-  console.error(err);
+  logger.error(err);
 });
-db.once('open', () => {
-  console.log('Mongo ready');
+db.once('connected', () => {
+  logger.info('Mongo connected');
   app.emit('ready');
 });
+db.on('reconnected', () => {
+  logger.info('Mongo re-connected');
+});
+db.on('disconnected', () => {
+  logger.info('Mongo disconnected');
+});
 
 // disable console.errors for pino
 app.silent = true;
@@ -44,14 +52,12 @@ app.use(cors({
 // Set header with API response time
 app.use(responseTime);
 
-// Only use Redis + minified logs in prodcution
+// Request logging
+app.use(requestLogger);
+
+// Only use Redis in production
 if (process.env.NODE_ENV === 'production') {
   app.use(cache.middleware());
-  app.use(logger());
-} else {
-  app.use(logger({
-    prettyPrint: true,
-  }));
 }
 
 // V4 routes

middleware/cache.js

@@ -1,6 +1,7 @@
 
 const Redis = require('ioredis');
 const crypto = require('crypto');
+const { logger } = require('./logger');
 
 let redis;
 let redisAvailable = false;
@@ -17,9 +18,12 @@ redis.on('error', () => {
 redis.on('end', () => {
   redisAvailable = false;
 });
-redis.on('connect', () => {
+redis.on('ready', () => {
   redisAvailable = true;
-  console.log('Redis ready');
+  logger.info('Redis connected');
+});
+redis.on('reconnecting', () => {
+  logger.info('Redis re-connecting');
 });
 
 /**

middleware/index.js

@@ -4,3 +4,4 @@
 module.exports.auth = require('./auth');
 module.exports.cache = require('./cache');
 module.exports.responseTime = require('./response-time');
+module.exports.logger = require('./logger');

middleware/logger.js

@@ -0,0 +1,21 @@
+
+const koaPino = require('koa-pino-logger');
+const pino = require('pino');
+
+const devOpts = {
+  prettyPrint: true,
+};
+
+let requestLog;
+let logger;
+
+if (process.env.NODE_ENV === 'production') {
+  requestLog = koaPino();
+  logger = pino();
+} else {
+  requestLog = koaPino(devOpts);
+  logger = pino(devOpts);
+}
+
+module.exports.requestLogger = requestLog;
+module.exports.logger = logger;

server.js

@@ -1,6 +1,7 @@
 
 const http = require('http');
 const mongoose = require('mongoose');
+const { logger } = require('./middleware/logger');
 const app = require('./app');
 
 const PORT = process.env.PORT || 6673;
@@ -9,16 +10,16 @@ const SERVER = http.createServer(app.callback());
 // Gracefully close Mongo connection
 const gracefulShutdown = () => {
   mongoose.connection.close(false, () => {
-    console.log('Mongo closed');
+    logger.info('Mongo closed');
     SERVER.close(() => {
-      console.log('Shutting down...');
+      logger.info('Shutting down...');
     });
   });
 };
 
 // Server start
 SERVER.listen(PORT, '0.0.0.0', () => {
-  console.log(`Running on port: ${PORT}`);
+  logger.info(`Running on port: ${PORT}`);
 
   // Handle kill commands
   process.on('SIGTERM', gracefulShutdown);