"""add_connectors_and_delphi_tables_revision

Revision ID: aa73d2c4378d
Revises: c10d0f3d7b9e
Create Date: 2023-04-17 11:08:52.435060

"""
from alembic import op
import sqlalchemy as sa
from sqlalchemy.dialects import postgresql

# revision identifiers, used by Alembic.
revision = 'aa73d2c4378d'
down_revision = 'c10d0f3d7b9e'
branch_labels = None
depends_on = None


def upgrade():
    op.create_table('Connector',
    sa.Column('id', sa.BigInteger(), nullable=False),
    sa.Column('external_id', sa.String(), nullable=False),
    sa.Column('name', sa.String(), nullable=False),
    sa.Column('platform', sa.String(), nullable=False),
    sa.Column('status', sa.Integer(), nullable=False),
    sa.Column('created_at', sa.TIMESTAMP(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=False),
    sa.Column('updated_at', sa.TIMESTAMP(timezone=True), server_default=sa.text('CURRENT_TIMESTAMP'), nullable=False),
    sa.Column('last_synced_at', sa.TIMESTAMP(timezone=True), nullable=True),
    sa.Column('owner_id', sa.Integer(), nullable=False),
    sa.Column('label_id', sa.Integer(), nullable=False),
    sa.UniqueConstraint('external_id', name=op.f('uq_Connector_external_id')),
    sa.ForeignKeyConstraint(['label_id'], ['Label.id'], name=op.f('fk_Connector_label_id_Label')),
    sa.ForeignKeyConstraint(['owner_id'], ['User.id'], name=op.f('fk_Connector_owner_id_User')),
    sa.PrimaryKeyConstraint('id', name=op.f('pk_Connector'))
    )
    op.create_table('AdAccount',
    sa.Column('id', sa.BigInteger(), nullable=False),
    sa.Column('ad_account_id', sa.Integer(), nullable=False),
    sa.Column('connector_id', sa.Integer(), nullable=False),
    sa.ForeignKeyConstraint(['connector_id'], ['Connector.id'], name=op.f('fk_AdAccount_connector_id_Connector'), ondelete='CASCADE'),
    sa.PrimaryKeyConstraint('id', name=op.f('pk_AdAccount'))
    )
    op.add_column('User', sa.Column('manager_id', sa.Integer(), nullable=True))
    op.create_foreign_key(op.f('fk_User_manager_id_User'), 'User', 'User', ['manager_id'], ['id'])


def downgrade():
    op.drop_constraint(op.f('fk_User_manager_id_User'), 'User', type_='foreignkey')
    op.drop_column('User', 'manager_id')
    op.drop_table('AdAccount')
    op.drop_table('Connector')