Merge pull request #6430 from FreeCodeCamp/feature/add-exception-emailing

Add emailing on server exceptions

pm2Start.js

@@ -1,8 +1,22 @@
 require('dotenv').load();
 var pm2 = require('pm2');
+var nodemailer = require('nodemailer');
+var moment = require('moment-timezone');
+var _ = require('lodash');
+
 var instances = process.env.INSTANCES || 1;
 var serverName = process.env.SERVER_NAME || 'server';
 var maxMemory = process.env.MAX_MEMORY || '390M';
+var transportOptions = {
+  type: 'smtp',
+  service: 'Mandrill',
+  auth: {
+    user: process.env.MANDRILL_USER || false,
+    pass: process.env.MANDRILL_PASSWORD
+  }
+};
+
+var mailReceiver = process.env.MAIL_RECEIVER || false;
 
 pm2.connect(function() {
   pm2.start({
@@ -22,3 +36,46 @@ pm2.connect(function() {
     pm2.disconnect();
   });
 });
+
+
+if (transportOptions.auth.user && mailReceiver) {
+  console.log('setting up mailer');
+  var transporter = nodemailer.createTransport(transportOptions);
+  var compiled = _.template(
+    'An error has occurred on server ' +
+    '<% name %>\n' +
+    'Stack Trace:\n\n\n<%= stack %>\n\n\n' +
+    'Context:\n\n<%= text %>'
+  );
+
+  pm2.launchBus(function(err, bus) {
+    if (err) {
+      return console.error(err);
+    }
+    console.log('event bus connected');
+
+    bus.on('process:exception', function(data) {
+      var text;
+      var stack;
+      var name;
+      try {
+        data.date = moment(data.at || new Date())
+          .tz('America/Los_Angeles')
+          .format('MMMM Do YYYY, h:mm:ss a z');
+
+        text = JSON.stringify(data, null, 2);
+        stack = data.data.stack;
+        name = data.process.name;
+      } catch (e) {
+        return e;
+      }
+
+      transporter.sendMail({
+        to: mailReceiver,
+        from: 'team@freecodecamp.com',
+        subject: 'Server exception',
+        text: compiled({ name: name, text: text, stack: stack })
+      });
+    });
+  });
+}

server/middlewares/keymetrics.js

@@ -4,5 +4,17 @@ export default function keymetrics() {
   if (process.env.NODE_ENV !== 'production') {
     return (err, req, res, next) => next(err);
   }
-  return pmx.expressErrorHandler();
+  return (err, req, res, next) => {
+    if (res.statusCode < 400) { res.statusCode = 500; }
+
+    err.url = req.url;
+    err.component = req.url;
+    err.action = req.method;
+    err.params = req.body;
+    err.session = req.session;
+    err.username = req.user ? req.user.username : 'anonymous';
+    err.userId = req.user ? req.user.id : 'anonymous';
+
+    return next(pmx.notify(err));
+  };
 }