Codebase list python-faraday / 78dcaf8 faraday / migrations / versions / f8a44acd0e41_add_new_user_role.py
78dcaf8

Tree @78dcaf8 (Download .tar.gz)

f8a44acd0e41_add_new_user_role.py @78dcaf8raw · history · blame

"""add new user role

Revision ID: f8a44acd0e41
Revises: 526aa91cac98
Create Date: 2019-10-01 14:04:02.769564+00:00

"""
from alembic import op
import sqlalchemy as sa


revision = 'f8a44acd0e41'
down_revision = '526aa91cac98'
branch_labels = None
depends_on = None

ROLES = ['admin', 'pentester', 'client']


def upgrade():
    old_type = sa.Enum(*ROLES, name='user_roles')

    new_types = list(set(ROLES + ['asset_owner']))
    new_options = sorted(new_types)
    new_type = sa.Enum(*new_options, name='user_roles')

    tmp_type = sa.Enum(*new_options, name='_user_roles')

    tmp_type.create(op.get_bind(), checkfirst=False)
    op.execute('ALTER TABLE faraday_user ALTER COLUMN role TYPE _user_roles'
               ' USING role::text::_user_roles')
    old_type.drop(op.get_bind(), checkfirst=False)
    # Create and convert to the "new" status type
    new_type.create(op.get_bind(), checkfirst=False)
    op.execute('ALTER TABLE faraday_user ALTER COLUMN role TYPE user_roles'
               ' USING role::text::user_roles')
    tmp_type.drop(op.get_bind(), checkfirst=False)


def downgrade():
    new_types = list(set(ROLES + ['asset_owner']))
    new_options = sorted(new_types)
    new_type = sa.Enum(*new_options, name='user_roles')

    tmp_type = sa.Enum(*new_options, name='_user_roles')

    tcr = sa.sql.table('faraday_user',
                       sa.Column('role', new_type, nullable=False))

    old_type = sa.Enum(*ROLES, name='user_roles')

    # Convert 'asset_owner' status into 'client'
    op.execute(tcr.update().where(tcr.c.role == 'asset_owner')
               .values(status='client'))
    # Create a temporary "_role" type, convert and drop the "new" type
    tmp_type.create(op.get_bind(), checkfirst=False)
    op.execute('ALTER TABLE faraday_user ALTER COLUMN status TYPE _user_roles'
               ' USING role::text::_user_roles')
    new_type.drop(op.get_bind(), checkfirst=False)
    # Create and convert to the "old" role type
    old_type.create(op.get_bind(), checkfirst=False)
    op.execute('ALTER TABLE faraday_user ALTER COLUMN role TYPE user_roles'
               ' USING role::text::user_roles')
    tmp_type.drop(op.get_bind(), checkfirst=False)