nodebb/src/user/email.js

'use strict';

var async = require('async'),
	nconf = require('nconf'),
	winston = require('winston'),

	user = require('../user'),
	utils = require('../../public/src/utils'),
	translator = require('../../public/src/modules/translator'),
	plugins = require('../plugins'),
	db = require('../database'),
	meta = require('../meta'),
	emailer = require('../emailer');

(function(UserEmail) {

	UserEmail.exists = function(email, callback) {
		user.getUidByEmail(email.toLowerCase(), function(err, exists) {
			callback(err, !!exists);
		});
	};

	UserEmail.available = function(email, callback) {
		db.isObjectField('email:uid', email.toLowerCase(), function(err, exists) {
			callback(err, !exists);
		});
	};

	UserEmail.verify = function(uid, email, callback) {
		callback = callback || function() {};
		var confirm_code = utils.generateUUID(),
			confirm_link = nconf.get('url') + '/confirm/' + confirm_code;

		plugins.fireHook('filter:user.verify.code', confirm_code, function(err, confirm_code) {
			if (err) {
				return callback(err);
			}

			async.series([
				function(next) {
					db.setObject('confirm:' + confirm_code, {
						email: email.toLowerCase(),
						uid: uid
					}, next);
				},
				function(next) {
					db.expireAt('confirm:' + confirm_code, Math.floor(Date.now() / 1000 + 60 * 60 * 2), next);
				}
			], function(err) {
				if (err) {
					return callback(err);
				}
				user.getUserField(uid, 'username', function(err, username) {
					if (err) {
						return winston.error(err.stack);
					}

					var title = meta.config.title || meta.config.browserTitle || 'NodeBB';
					translator.translate('[[email:welcome-to, ' + title + ']]', meta.config.defaultLang, function(subject) {
						var data = {
							site_title: title,
							username: username,
							confirm_link: confirm_link,
							confirm_code: confirm_code,

							subject: subject,
							template: 'welcome',
							uid: uid
						};

						if (plugins.hasListeners('action:user.verify')) {
							plugins.fireHook('action:user.verify', {uid: uid, data: data});
							callback();
						} else if (plugins.hasListeners('action:email.send')) {
							emailer.send('welcome', uid, data, callback);
						} else {
							winston.warn('No emailer to send verification email!');
							callback();
						}
					});
				});
			});
		});
	};

	UserEmail.confirm = function(code, callback) {
		db.getObject('confirm:' + code, function(err, confirmObj) {
			if (err) {
				return callback(new Error('[[error:parse-error]]'));
			}

			if (confirmObj && confirmObj.uid && confirmObj.email) {
				async.series([
					async.apply(user.setUserField, confirmObj.uid, 'email:confirmed', 1),
					async.apply(db.delete, 'confirm:' + code)
				], function(err) {
					callback(err ? new Error('[[error:email-confirm-failed]]') : null);
				});
			} else {
				callback(new Error('[[error:invalid-data]]'));
			}
		});
	};

}(exports));