"""Add pending_registrations table for deferred user creation.

Revision ID: 006
Revises: 005
Create Date: 2025-03-18

Signup creates pending_registrations row instead of users.
On first successful magic link verify, pending is promoted to user + workspace.
"""
from typing import Sequence, Union

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

revision: str = "006"
down_revision: Union[str, None] = "005"
branch_labels: Union[str, Sequence[str], None] = None
depends_on: Union[str, Sequence[str], None] = None


def upgrade() -> None:
    op.create_table(
        "pending_registrations",
        sa.Column("id", postgresql.UUID(as_uuid=True), primary_key=True, server_default=sa.text("gen_random_uuid()")),
        sa.Column("email", sa.String(255), unique=True, nullable=False),
        sa.Column("first_name", sa.String(100)),
        sa.Column("last_name", sa.String(100)),
        sa.Column("phone", sa.String(50)),
        sa.Column("company", sa.String(255)),
        sa.Column("workspace_name", sa.String(255)),
        sa.Column("plan_slug", sa.String(50)),
        sa.Column("magic_link_sent_at", sa.TIMESTAMP(timezone=True)),
        sa.Column("created_at", sa.TIMESTAMP(timezone=True), server_default=sa.func.now()),
        sa.Column("updated_at", sa.TIMESTAMP(timezone=True), server_default=sa.func.now()),
        sa.Column("expires_at", sa.TIMESTAMP(timezone=True), nullable=False, server_default=sa.text("now() + interval '24 hours'")),
    )
    op.create_index("idx_pending_registrations_email", "pending_registrations", ["email"])
    op.create_index("idx_pending_registrations_expires", "pending_registrations", ["expires_at"])


def downgrade() -> None:
    op.drop_index("idx_pending_registrations_expires", table_name="pending_registrations")
    op.drop_index("idx_pending_registrations_email", table_name="pending_registrations")
    op.drop_table("pending_registrations")