mirror of
https://github.com/vale981/Vulcan
synced 2025-03-06 10:01:40 -05:00
52 lines
No EOL
1.6 KiB
JavaScript
52 lines
No EOL
1.6 KiB
JavaScript
import Users from '../collection.js';
|
|
import { runCallbacks, runCallbacksAsync, Utils } from 'meteor/vulcan:lib'; // import from vulcan:lib because vulcan:core isn't loaded yet
|
|
|
|
function onCreateUserCallback (options, user) {
|
|
|
|
const schema = Users.simpleSchema()._schema;
|
|
|
|
delete options.password; // we don't need to store the password digest
|
|
delete options.username; // username is already in user object
|
|
|
|
options = runCallbacks(`users.new.validate.before`, options);
|
|
|
|
// validate options since they can't be trusted
|
|
Users.simpleSchema().validate(options);
|
|
|
|
// check that the current user has permission to insert each option field
|
|
_.keys(options).forEach(fieldName => {
|
|
var field = schema[fieldName];
|
|
if (!field || !Users.canInsertField (user, field)) {
|
|
throw new Error(Utils.encodeIntlError({id: 'app.disallowed_property_detected', value: fieldName}));
|
|
}
|
|
});
|
|
|
|
// extend user with options
|
|
user = Object.assign(user, options);
|
|
|
|
// run validation callbacks
|
|
user = runCallbacks(`users.new.validate`, user);
|
|
|
|
// run onInsert step
|
|
_.keys(schema).forEach(fieldName => {
|
|
if (!user[fieldName] && schema[fieldName].onInsert) {
|
|
const autoValue = schema[fieldName].onInsert(user, options);
|
|
if (autoValue) {
|
|
user[fieldName] = autoValue;
|
|
}
|
|
}
|
|
});
|
|
|
|
user = runCallbacks("users.new.sync", user);
|
|
|
|
runCallbacksAsync("users.new.async", user);
|
|
|
|
// check if all required fields have been filled in. If so, run profile completion callbacks
|
|
if (Users.hasCompletedProfile(user)) {
|
|
runCallbacksAsync("users.profileCompleted.async", user);
|
|
}
|
|
|
|
return user;
|
|
}
|
|
|
|
Accounts.onCreateUser(onCreateUserCallback); |