"""

Revision ID: 0360_remove_sched_notifications
Revises: 0359_more_permissions
Create Date: 2021-06-07 09:09:06.376862

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

revision = "0360_remove_sched_notifications"
down_revision = "0359_more_permissions"


def upgrade():
    # drop index concurrently will drop the index without locking out concurrent
    # selects, inserts, updates, and deletes on the index's table namely on notifications
    # First we need to issue a commit to clear the transaction block.
    op.execute("COMMIT")
    op.execute("DROP INDEX CONCURRENTLY ix_scheduled_notifications_notification_id")
    op.drop_table("scheduled_notifications")


def downgrade():
    # I've intentionally removed adding the index back from the downgrade method
    op.create_table(
        "scheduled_notifications",
        sa.Column("id", postgresql.UUID(), autoincrement=False, nullable=False),
        sa.Column("notification_id", postgresql.UUID(), autoincrement=False, nullable=False),
        sa.Column("scheduled_for", postgresql.TIMESTAMP(), autoincrement=False, nullable=False),
        sa.Column("pending", sa.BOOLEAN(), autoincrement=False, nullable=False),
        sa.ForeignKeyConstraint(
            ["notification_id"], ["notifications.id"], name="scheduled_notifications_notification_id_fkey"
        ),
        sa.PrimaryKeyConstraint("id", name="scheduled_notifications_pkey"),
    )
