sync_user_email.py

from indico.core.db import db
from indico.modules.users import User
from indico.modules.users.models.emails import UserEmail
from indico.web.flask.app import make_app


def sync_user_email(user):
    identity = user._get_synced_identity(refresh=True)
    if identity is None:
        return
    email = identity.data.get('email')
    if not email:
        return
    email = email.lower()
    if email in user.secondary_emails:
        user.make_email_primary(email)
    elif UserEmail.query.filter_by(is_user_deleted=False, email=email).join(User).filter(~User.is_pending).has_rows():
        print 'Email used by another user!'
        return
    else:
        user.secondary_emails.add(email)
        user.make_email_primary(email)
    db.session.flush()

        
with make_app().app_context():
    for user in User.query.filter_by(is_deleted=False):
        sync_user_email(user)
    db.session.commit()