users.object.js

db.users = Meteor.users;

db.users.allow({
    // Allow user update own profile
    update: function (userId, doc, fields, modifier) {
        if (userId === doc._id) {
            return true;
        }
    }
});

db.users.helpers({
    spaces: function () {
        var spaces, sus;
        spaces = [];
        sus = db.space_users.find({
            user: this._id
        }, {
                fields: {
                    space: 1
                }
            });
        sus.forEach(function (su) {
            return spaces.push(su.space);
        });
        return spaces;
    },
    displayName: function () {
        if (this.name) {
            return this.name;
        } else if (this.username) {
            return this.username;
        } else if (this.emails && this.emails[0]) {
            return this.emails[0].address;
        }
    }
});

if (Meteor.isServer) {
    db.users.create_secret = function (userId, name) {
        var hashedToken, secretToken, u;
        secretToken = Accounts._generateStampedLoginToken();
        secretToken.token = userId + "-" + secretToken.token;
        hashedToken = Accounts._hashLoginToken(secretToken.token);
        secretToken.hashedToken = hashedToken;
        secretToken.name = name;
        u = db.users.findOne({
            _id: userId,
            "secrets.name": name
        });
        if (!u) {
            return db.users.update({
                _id: userId
            }, {
                    $push: {
                        secrets: secretToken
                    }
                });
        }
    };
    db.users.checkEmailValid = function (email) {
        var existed;
        existed = db.users.find({
            "emails.address": email
        });
        if (existed.count() > 0) {
            throw new Meteor.Error(400, "users_error_email_exists");
        }
    };
    db.users.checkUsernameValid = function (username) {
        var existed;
        existed = db.users.find({
            "username": username
        });
        if (existed.count() > 0) {
            throw new Meteor.Error(400, "users_error_username_exists");
        }
    };
    db.users.validateUsername = function (username, userId) {
        var nameValidation, ref, ref1, ref2, ref3, user;
        user = db.users.findOne({
            username: {
                $regex: new RegExp("^" + Meteor._escapeRegExp(username).trim() + "$", "i")
            },
            _id: {
                $ne: userId
            }
        });
        if (user) {
            throw new Meteor.Error('username-unavailable', 'username-unavailable');
        }
        if (!((ref = Meteor.settings.public) != null ? (ref1 = ref.accounts) != null ? ref1.is_username_skip_minrequiredlength : void 0 : void 0)) {
            if (username.length < 6) {
                throw new Meteor.Error('username-minrequiredlength', "username-minrequiredlength");
            }
        }
        try {
            if ((ref2 = Meteor.settings.public) != null ? (ref3 = ref2.accounts) != null ? ref3.UTF8_Names_Validation : void 0 : void 0) {
                nameValidation = new RegExp('^' + Meteor.settings.public.accounts.UTF8_Names_Validation + '$');
            } else {
                nameValidation = new RegExp('^[A-Za-z0-9-_.\u00C0-\u017F\u4e00-\u9fa5]+$');
            }
        } catch (error) {
            nameValidation = new RegExp('^[A-Za-z0-9-_.\u00C0-\u017F\u4e00-\u9fa5]+$');
        }
        if (!nameValidation.test(username)) {
            throw new Meteor.Error('username-invalid', "username-invalid");
        }
    };
    db.users.validatePhone = function (userId, doc, modifier) {
        modifier.$set = modifier.$set || {};
        if (doc._id !== userId && modifier.$set["phone.number"]) {
            if (doc["phone.verified"] === true && doc["phone.number"] !== modifier.$set["phone.number"]) {
                throw new Meteor.Error(400, "用户已验证手机，不能修改");
            }
        }
    };
    db.users.before.insert(function (userId, doc) {
        var ref, ref1, ref2, ref3, ref4, ref5, space, space_registered;
        space_registered = (ref = doc.profile) != null ? ref.space_registered : void 0;
        // # 从工作区特定的注册界面注册的用户，需要先判断下工作区是否存在
        if (space_registered) {
            space = db.spaces.findOne(space_registered);
            if (!space) {
                throw new Meteor.Error(400, "space_users_error_space_not_found");
            }
        }
        if (doc.username) {
            db.users.validateUsername(doc.username, doc._id);
        }
        doc.created = new Date();
        doc.is_deleted = false;
        if (userId) {
            doc.created_by = userId;
        }
        if ((ref1 = doc.services) != null ? ref1.google : void 0) {
            if (doc.services.google.email && !doc.emails) {
                doc.emails = [
                    {
                        address: doc.services.google.email,
                        verified: true
                    }
                ];
            }
            if (doc.services.google.picture) {
                doc.avatarUrl = doc.services.google.picture;
            }
        }
        if ((ref2 = doc.services) != null ? ref2.facebook : void 0) {
            if (doc.services.facebook.email && !doc.emails) {
                doc.emails = [
                    {
                        address: doc.services.facebook.email,
                        verified: true
                    }
                ];
            }
        }
        if (doc.emails && !doc.steedos_id) {
            if (doc.emails.length > 0) {
                doc.steedos_id = doc.emails[0].address;
            }
        }
        if (((ref3 = doc.profile) != null ? ref3.name : void 0) && !doc.name) {
            doc.name = doc.profile.name;
        }
        if (((ref4 = doc.profile) != null ? ref4.locale : void 0) && !doc.locale) {
            doc.locale = doc.profile.locale;
        }
        if (((ref5 = doc.profile) != null ? ref5.mobile : void 0) && !doc.mobile) {
            doc.mobile = doc.profile.mobile;
        }
        if (!doc.steedos_id && doc.username) {
            doc.steedos_id = doc.username;
        }
        if (!doc.name) {
            doc.name = doc.steedos_id.split('@')[0];
        }
        if (!doc.type) {
            doc.type = "user";
        }
        if (!doc.active) {
            doc.active = true;
        }
        if (!doc.roles) {
            doc.roles = ["user"];
        }
        if (!doc.utcOffset) {
            doc.utcOffset = 8;
        }
        return _.each(doc.emails, function (obj) {
            return db.users.checkEmailValid(obj.address);
        });
    });
    db.users.after.insert(function (userId, doc) {
        var content, e, email, enrollAccountUrl, greeting, locale, newId, now, ref, ref1, ref2, rootOrg, space_name, space_registered, subject, token, tokenRecord, url, user_email;
        space_registered = (ref = doc.profile) != null ? ref.space_registered : void 0;
        if (space_registered) {
            // 从工作区特定的注册界面注册的用户，需要自动加入到工作区中
            user_email = doc.emails[0].address;
            rootOrg = db.organizations.findOne({
                space: space_registered,
                parent: null
            }, {
                    fields: {
                        _id: 1
                    }
                });
            db.space_users.insert({
                email: user_email,
                user: doc._id,
                name: doc.name,
                organizations: [rootOrg._id],
                space: space_registered,
                user_accepted: true,
                is_registered_from_space: true
            });
        }
        if (!space_registered && !(((ref1 = doc.spaces_invited) != null ? ref1.length : void 0) > 0)) {
            // 不是从工作区特定的注册界面注册的用户，也不是邀请的用户
            // 即普通的注册用户，则为其新建一个自己的工作区
            space_name = doc.company || ((ref2 = doc.profile) != null ? ref2.company : void 0);
            if (!space_name) {
                space_name = doc.name + " " + t("space");
            }
            newId = db.spaces._makeNewID();
            db.spaces.insert({
                _id: newId,
                name: space_name,
                owner: doc._id,
                admins: [doc._id],
                space: newId
            });
        }
        try {
            if (!doc.services || !doc.services.password || !doc.services.password.bcrypt) {
                // 发送让用户设置密码的邮件
                // Accounts.sendEnrollmentEmail(doc._id, doc.emails[0].address)
                if (doc.emails) {
                    token = Random.secret();
                    email = doc.emails[0].address;
                    now = new Date();
                    tokenRecord = {
                        token: token,
                        email: email,
                        when: now
                    };
                    db.users.update(doc._id, {
                        $set: {
                            "services.password.reset": tokenRecord
                        }
                    });
                    Meteor._ensure(doc, 'services', 'password').reset = tokenRecord;
                    enrollAccountUrl = Accounts.urls.enrollAccount(token);
                    url = Accounts.urls.enrollAccount(token);
                    locale = Steedos.locale(doc._id, true);
                    subject = TAPi18n.__("users_email_create_account", {}, locale);
                    greeting = TAPi18n.__('users_email_hello', {}, locale) + "&nbsp;" + doc.name + ",";
                    content = greeting + "</br>" + TAPi18n.__('users_email_start_service', {}, locale) + "</br>" + url + "</br>" + TAPi18n.__("users_email_thanks", {}, locale) + "</br>";
                    return MailQueue.send({
                        to: email,
                        from: Meteor.settings.email.from,
                        subject: subject,
                        html: content
                    });
                }
            }
        } catch (error) {
            e = error;
            return console.log("after insert user: sendEnrollmentEmail, id: " + doc._id + ", " + e);
        }
    });
    db.users.before.update(function (userId, doc, fieldNames, modifier, options) {
        var newNumber;
        db.users.validatePhone(userId, doc, modifier);
        if (modifier.$unset && modifier.$unset.steedos_id === "") {
            throw new Meteor.Error(400, "users_error_steedos_id_required");
        }
        modifier.$set = modifier.$set || {};
        if (modifier.$set.username) {
            db.users.validateUsername(modifier.$set.username, doc._id);
        }
        // if doc.steedos_id && modifier.$set.steedos_id
        // 	if modifier.$set.steedos_id != doc.steedos_id
        // 		throw new Meteor.Error(400, "users_error_steedos_id_readonly");
        if (userId) {
            modifier.$set.modified_by = userId;
        }
        if (modifier.$set['phone.verified'] === true) {
            newNumber = modifier.$set['phone.mobile'];
            if (!newNumber) {
                newNumber = doc.phone.mobile;
            }
            modifier.$set.mobile = newNumber;
        }
        return modifier.$set.modified = new Date();
    });
    db.users.after.update(function (userId, doc, fieldNames, modifier, options) {
        var newNumber, user_set, user_unset;
        modifier.$set = modifier.$set || {};
        modifier.$unset = modifier.$unset || {};
        if (modifier.$set['phone.verified'] === true) {
            // db.users.before.update中对modifier.$set.mobile的修改这里识别不到，所以只能重新设置其值
            newNumber = modifier.$set['phone.mobile'];
            if (!newNumber) {
                newNumber = doc.phone.mobile;
            }
            modifier.$set.mobile = newNumber;
        }
        user_set = {};
        user_unset = {};
        if (modifier.$set.name !== void 0) {
            user_set.name = modifier.$set.name;
        }
        if (modifier.$set.mobile !== void 0) {
            user_set.mobile = modifier.$set.mobile;
        }
        if (modifier.$unset.name !== void 0) {
            user_unset.name = modifier.$unset.name;
        }
        if (modifier.$unset.mobile !== void 0) {
            user_unset.mobile = modifier.$unset.mobile;
        }
        // 更新users表中的相关字段，所有工作区信息同步
        if (!_.isEmpty(user_set)) {
            db.space_users.direct.update({
                user: doc._id
            }, {
                    $set: user_set
                }, {
                    multi: true
                });
        }
        if (!_.isEmpty(user_unset)) {
            return db.space_users.direct.update({
                user: doc._id
            }, {
                    $unset: user_unset
                }, {
                    multi: true
                });
        }
    });
    db.users.before.remove(function (userId, doc) {
        throw new Meteor.Error(400, "users_error_cloud_admin_required");
    });
    Meteor.publish('userData', function () {
        if (!this.userId) {
            return this.ready();
        }
        return db.users.find(this.userId, {
            fields: {
                steedos_id: 1,
                name: 1,
                mobile: 1,
                locale: 1,
                username: 1,
                utcOffset: 1,
                settings: 1,
                is_cloudadmin: 1,
                email_notification: 1,
                avatar: 1,
                "secrets.name": 1,
                "secrets.token": 1
            }
        });
    });
}

if (Meteor.isServer) {
    db.users._ensureIndex({
        "is_deleted": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "email": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "is_deleted": 1,
        "email": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "_id": 1,
        "created": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "_id": 1,
        "created": 1,
        "modified": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "primary_email_verified": 1,
        "locale": 1,
        "name": 1,
        "_id": 1,
        "mobile": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "primary_email_verified": 1,
        "locale": 1,
        "name": 1,
        "_id": 1,
        "mobile": 1,
        "created": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "primary_email_verified": 1,
        "locale": 1,
        "name": 1,
        "_id": 1,
        "mobile": 1,
        "created": 1,
        "last_logon": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "imo_uid": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "qq_open_id": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "created": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "last_logon": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "created": 1,
        "modified": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "name": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "lastLogin": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "status": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "active": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "type": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "steedos_id": 1
    }, {
            background: true
        });
    db.users._ensureIndex({
        "services.weixin.openid.appid": 1,
        "services.weixin.openid._id": 1
    }, {
            background: true
        });
}