diff --git a/pm2Start.js b/pm2Start.js index 3b9ec6b74bb..b0755e4b348 100644 --- a/pm2Start.js +++ b/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 }) + }); + }); + }); +} diff --git a/server/middlewares/keymetrics.js b/server/middlewares/keymetrics.js index 0902d6caab7..183f6708628 100644 --- a/server/middlewares/keymetrics.js +++ b/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)); + }; }