"""Drop musehub_stream_rejections — dead MWP-era table.

The streaming wire protocol (MWP) has been removed.  The rejection audit
table it wrote to has never had any production traffic — no inserts, no
reads.  Drop it cleanly.

Revision ID: 0064
Revises: 0063
"""
from __future__ import annotations

from alembic import op


revision: str = "0064"
down_revision: str = "0063"
branch_labels = None
depends_on = None


def upgrade() -> None:
    op.drop_index("ix_stream_rejections_identity", table_name="musehub_stream_rejections")
    op.drop_index("ix_stream_rejections_repo", table_name="musehub_stream_rejections")
    op.drop_table("musehub_stream_rejections")


def downgrade() -> None:
    import sqlalchemy as sa

    op.create_table(
        "musehub_stream_rejections",
        sa.Column("rejection_id", sa.String(128), nullable=False),
        sa.Column("repo_id", sa.String(128), nullable=False),
        sa.Column("identity_id", sa.String(128), nullable=True),
        sa.Column("reason", sa.String(32), nullable=False),
        sa.Column("detail", sa.Text(), nullable=False),
        sa.Column("rejected_at", sa.DateTime(timezone=True), nullable=False),
        sa.ForeignKeyConstraint(["repo_id"], ["musehub_repos.repo_id"], ondelete="CASCADE"),
        sa.PrimaryKeyConstraint("rejection_id"),
    )
    op.create_index("ix_stream_rejections_repo", "musehub_stream_rejections", ["repo_id"], unique=False)
    op.create_index("ix_stream_rejections_identity", "musehub_stream_rejections", ["identity_id"], unique=False)