Added more logging

Author: Hamid Tavakoli

connect/connectEmailServer.js

@@ -46,8 +46,8 @@ emailServer
     emailServer.start()
   })
   .catch((e) => {
-    console.log('Error occurred in starting email server:', e);
-    console.log(e)
+    logger.error('Error occurred in starting email server:', e);
+    process.exit(1);
   }); // eslint-disable-line no-console
 
 // if no need to init database, then directly start the server:

connect/service.js

@@ -51,7 +51,13 @@ const sendEmail = async (templateId, message) => { // send email
     };
   }
   logger.info(`Sending email with templateId: ${templateId} and message: ${JSON.stringify(msg)}`);
-  return sgMail.send(msg)
+  try {
+    const result = await sgMail.send(msg)
+    return result
+  } catch (err) {
+    logger.error(`Error occurred in sendgrid api calling: ${err}`);
+    throw err
+  }
 }
 module.exports = {
   sendEmail,

index.js

@@ -9,6 +9,7 @@ const schedule = require('node-schedule');
 const helper = require('./src/common/helper');
 const logger = require('./src/common/logger');
 const errors = require('./src/common/errors');
+const models = require('./src/models');
 const { initServer, retryEmail } = require('./src/init');
 
 config.TEMPLATE_MAP = JSON.parse(config.TEMPLATE_MAP);
@@ -154,6 +155,9 @@ function start() {
     app.listen(app.get('port'), () => {
       logger.info(`Express server listening on port ${app.get('port')}`);
     });
+  }).catch((err) => {
+    logger.error(err);
+    process.exit(1);
   })
 }
 
@@ -164,7 +168,6 @@ function start() {
 async function initDatabase() {
   // load models only after config is set
   logger.info('Initializing database...');
-  const models = require('./src/models');
   await models.init(true);
 }
 

package-lock.json

@@ -28,15 +28,15 @@
     "cors": "^2.8.5",
     "dotenv": "^16.0.2",
     "express": "^4.18.1",
-    "joi": "^17.6.0",
+    "joi": "^17.6.1",
     "jwks-rsa": "^2.1.4",
     "kafkajs": "^2.2.0",
     "lodash": "^4.17.21",
     "node-schedule": "^2.1.0",
     "pg": "^8.8.0",
-    "sequelize": "^6.21.4",
+    "sequelize": "^6.23.1",
     "superagent": "^8.0.0",
     "tc-core-library-js": "^2.4.1",
     "winston": "^3.8.1"
   }
-}
+}

package.json

@@ -25,7 +25,7 @@ function _createError(name, statusCode) {
     this.cause = cause;
     this.httpStatus = statusCode;
   }
-
+  //TODO: upgrade to ES6
   util.inherits(ErrorCtor, Error);
   ErrorCtor.prototype.name = name;
   return ErrorCtor;