r"""Напоминания: журнал отправленного (ТЗ 3.21, 0.89).
Таблица push_deliveries — память планировщика о том, что уже отправлено. Тик
каждые 15 минут, а правила дневные, поэтому без журнала одна и та же просрочка
приходила бы сотню раз. Уникальность (user_id, kind, ref_key) держит база, а не
память процесса: перезапуск API не рассылает отправленное заново.
Вставка идёт до отправки, поэтому возможен пропуск (упали между вставкой и
отправкой), но не дубль — для напоминания это правильный размен.
Revision ID: d2e3f4a5b6c7
Revises: c1d2e3f4a5b6
Create Date: 2026-10-10
"""
from collections.abc import Sequence
import sqlalchemy as sa
from alembic import op
revision: str = "d2e3f4a5b6c7"
down_revision: str | Sequence[str] | None = "c1d2e3f4a5b6"
branch_labels: str | Sequence[str] | None = None
depends_on: str | Sequence[str] | None = None
def upgrade() -> None:
op.create_table(
"push_deliveries",
sa.Column("id", sa.Integer(), primary_key=True),
sa.Column(
"user_id",
sa.String(64),
sa.ForeignKey("users.id", ondelete="CASCADE"),
nullable=False,
),
sa.Column("kind", sa.String(40), nullable=False),
sa.Column("ref_key", sa.String(120), nullable=False),
sa.Column(
"created_at",
sa.DateTime(timezone=True),
nullable=False,
server_default=sa.text("now()"),
),
sa.UniqueConstraint("user_id", "kind", "ref_key", name="uq_push_deliveries_ref"),
)
op.create_index("ix_push_deliveries_user_id", "push_deliveries", ["user_id"])
def downgrade() -> None:
op.drop_index("ix_push_deliveries_user_id", table_name="push_deliveries")
op.drop_table("push_deliveries")