initial commit to emailer system overhaul

src/emailer.js

@@ -0,0 +1,69 @@
+var	User = require('./user'),
+	Plugins = require('./plugins'),
+
+	Handlebars = require('handlebars'),
+	fs = require('fs'),
+	async = require('async'),
+	path = require('path'),
+
+	Emailer = {},
+	templates = {};
+
+var	prepareTemplate = function(template, callback) {
+	if (templates[template] === undefined) {
+		var	templatePath = path.join(__dirname, '../public/templates/emails/' + template + '.hbs');
+
+		fs.exists(templatePath, function(exists) {
+			if (exists) {
+				fs.readFile(templatePath, function(err, fileStream) {
+					if (!err) {
+						templates[template] = Handlebars.compile(fileStream.toString());
+					} else {
+						templates[template] = null;
+					}
+
+					callback();
+				});
+			} else {
+				templates[template] = null;
+				callback();
+			}
+		});
+	} else {
+		// Template loaded already
+		callback();
+	}
+}
+
+var	render = function(template, params, callback) {
+	prepareTemplate(template, function() {
+		if (templates[template] !== null) {
+			callback(null, templates[template](params));
+		} else {
+			callback(null, null);
+		}
+	});
+}
+
+Emailer.send = function(template, uid, params) {
+	async.parallel({
+		html: function(next) {
+			render(template, params, next);
+		},
+		plaintext: function(next) {
+			render(template + '_plaintext', params, next);
+		}
+	}, function(err, results) {
+		User.getUserField(uid, 'email', function(err, email) {
+			if (!err) {
+				Plugins.fireHook('action:email.send', {
+					email: email,
+					html: results.html,
+					plaintext: results.plaintext
+				});
+			}
+		});
+	});
+};
+
+module.exports = Emailer;