Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-11-03 20:45:58 +01:00
Code Issues Packages Projects Releases Wiki Activity

refactor user.create

Browse Source 
dont fire filter:user.create if there userData is invalid
This commit is contained in:
barisusakli
2014-10-28 18:28:26 -04:00
parent bce96d04c7
commit 5be1c17aa7
2 changed files with 165 additions and 134 deletions
Download Patch File Download Diff File Expand all files Collapse all files

228
src/user/create.js
View File

@@ -13,12 +13,23 @@ var async = require('async'),
module.exports = function(User) {
User.create = function(data, callback) {
data.username = data.username.trim();
data.userslug = utils.slugify(data.username);
if (data.email !== undefined) {
data.email = validator.escape(data.email.trim());
}
isDataValid(data, function(err) {
if (err) {
return callback(err);
}
var gravatar = User.createGravatarURLFromEmail(data.email);
var timestamp = Date.now();
var password = data.password;
var userData = {
'username': data.username.trim(),
'userslug': data.userslug,
'email': data.email,
'joindate': timestamp,
'picture': gravatar,
@@ -37,70 +48,9 @@ module.exports = function(User) {
'status': 'online'
};
userData.userslug = utils.slugify(userData.username);
if (userData.email !== undefined) {
userData.email = userData.email.trim();
userData.email = validator.escape(userData.email);
}
async.parallel({
emailValid: function(next) {
if (userData.email) {
next(!utils.isEmailValid(userData.email) ? new Error('[[error:invalid-email]]') : null);
} else {
next();
}
},
userNameValid: function(next) {
next((!utils.isUserNameValid(userData.username) || !userData.userslug) ? new Error('[[error:invalid-username]]') : null);
},
passwordValid: function(next) {
if (password) {
next(!utils.isPasswordValid(password) ? new Error('[[error:invalid-password]]') : null);
} else {
next();
}
},
renamedUsername: function(next) {
meta.userOrGroupExists(userData.userslug, function(err, exists) {
if (err) {
return next(err);
}
if (exists) {
var newUsername = '';
async.forever(function(next) {
newUsername = userData.username + (Math.floor(Math.random() * 255) + 1);
User.exists(newUsername, function(err, exists) {
if (err) {
return callback(err);
}
if (!exists) {
next(newUsername);
} else {
next();
}
});
}, function(username) {
next(null, username);
});
} else {
next();
}
});
},
emailAvailable: function(next) {
if (userData.email) {
User.email.available(userData.email, function(err, available) {
if (err) {
return next(err);
}
next(!available ? new Error('[[error:email-taken]]') : null);
});
} else {
next();
}
renameUsername(userData, next);
},
customFields: function(next) {
plugins.fireHook('filter:user.custom_fields', [], next);
@@ -129,64 +79,132 @@ module.exports = function(User) {
userData.userslug = utils.slugify(results.renamedUsername);
}
db.incrObjectField('global', 'nextUid', function(err, uid) {
if (err) {
return callback(err);
}
async.waterfall([
function(next) {
db.incrObjectField('global', 'nextUid', next);
},
function(uid, next) {
userData.uid = uid;
db.setObject('user:' + uid, userData, function(err) {
db.setObject('user:' + uid, userData, next);
}
], function(err) {
if (err) {
return callback(err);
}
db.setObjectField('username:uid', userData.username, uid);
db.setObjectField('userslug:uid', userData.userslug, uid);
async.parallel([
function(next) {
db.incrObjectField('global', 'userCount', next);
},
function(next) {
db.setObjectField('username:uid', userData.username, userData.uid, next);
},
function(next) {
db.setObjectField('userslug:uid', userData.userslug, userData.uid, next);
},
function(next) {
db.sortedSetAdd('users:joindate', timestamp, userData.uid, next);
},
function(next) {
db.sortedSetsAdd(['users:postcount', 'users:reputation'], 0, userData.uid, next);
},
function(next) {
groups.join('registered-users', userData.uid, next);
},
function(next) {
if (userData.email !== undefined) {
db.setObjectField('email:uid', userData.email.toLowerCase(), uid);
if (parseInt(uid, 10) !== 1 && parseInt(meta.config.requireEmailConfirmation, 10) === 1) {
User.email.verify(uid, userData.email);
db.setObjectField('email:uid', userData.email.toLowerCase(), userData.uid, next);
if (parseInt(userData.uid, 10) !== 1 && parseInt(meta.config.requireEmailConfirmation, 10) === 1) {
User.email.verify(userData.uid, userData.email);
}
} else {
next();
}
},
function(next) {
if (!data.password) {
return next();
}
User.hashPassword(data.password, function(err, hash) {
if (err) {
return next(err);
}
plugins.fireHook('action:user.create', userData);
db.incrObjectField('global', 'userCount');
db.sortedSetAdd('users:joindate', timestamp, uid);
db.sortedSetAdd('users:postcount', 0, uid);
db.sortedSetAdd('users:reputation', 0, uid);
groups.join('registered-users', uid);
if (userNameChanged) {
notifications.create({
bodyShort: '[[user:username_taken_workaround, ' + userData.username + ']]',
image: 'brand:logo',
nid: 'username_taken:' + uid,
datetime: Date.now()
}, function(err, notification) {
if (!err && notification) {
notifications.push(notification, uid);
}
User.setUserField(userData.uid, 'password', hash, next);
});
}
if (password) {
User.hashPassword(password, function(err, hash) {
if(err) {
], function(err) {
if (err) {
return callback(err);
}
User.setUserField(uid, 'password', hash);
callback(null, uid);
});
} else {
callback(null, uid);
if (userNameChanged) {
User.notifications.sendNameChangeNotification(userData.uid, userData.username);
}
plugins.fireHook('action:user.create', userData);
callback(null, userData.uid);
});
});
});
});
};
function isDataValid(userData, callback) {
async.parallel({
emailValid: function(next) {
if (userData.email) {
next(!utils.isEmailValid(userData.email) ? new Error('[[error:invalid-email]]') : null);
} else {
next();
}
},
userNameValid: function(next) {
next((!utils.isUserNameValid(userData.username) || !userData.userslug) ? new Error('[[error:invalid-username]]') : null);
},
passwordValid: function(next) {
if (userData.password) {
next(!utils.isPasswordValid(userData.password) ? new Error('[[error:invalid-password]]') : null);
} else {
next();
}
},
emailAvailable: function(next) {
if (userData.email) {
User.email.available(userData.email, function(err, available) {
if (err) {
return next(err);
}
next(!available ? new Error('[[error:email-taken]]') : null);
});
} else {
next();
}
}
}, callback);
}
function renameUsername(userData, callback) {
meta.userOrGroupExists(userData.userslug, function(err, exists) {
if (err || !exists) {
return callback(err);
}
var newUsername = '';
async.forever(function(next) {
newUsername = userData.username + (Math.floor(Math.random() * 255) + 1);
User.exists(newUsername, function(err, exists) {
if (err) {
return callback(err);
}
if (!exists) {
next(newUsername);
} else {
next();
}
});
}, function(username) {
callback(null, username);
});
});
}
};

13
src/user/notifications.js
View File

@@ -280,6 +280,19 @@ var async = require('async'),
});
};
UserNotifications.sendNameChangeNotification = function(uid, username) {
notifications.create({
bodyShort: '[[user:username_taken_workaround, ' + username + ']]',
image: 'brand:logo',
nid: 'username_taken:' + uid,
datetime: Date.now()
}, function(err, notification) {
if (!err && notification) {
notifications.push(notification, uid);
}
});
};
UserNotifications.pushCount = function(uid) {
var websockets = require('./../socket.io');
UserNotifications.getUnreadCount(uid, function(err, count) {