"""Модель EmailDelivery — факт отправки письма. Идемпотентность рассылки саммари (`kind='summary'`): уникальный частичный индекс `(session_id, recipient_email)` не даёт повторной отправке того же письма тому же адресату. Приглашения (`kind='invitation'`) — только журнал, без unique (изменение расписания обязано переслать обновление). """ import uuid from datetime import datetime from sqlalchemy import CheckConstraint, DateTime, ForeignKey, Index, String, func, text from sqlalchemy.dialects.postgresql import UUID from sqlalchemy.orm import Mapped, mapped_column from models.base import Base class EmailDelivery(Base): """Запись об отправленном письме: саммари (`session_id`) либо приглашение (`conference_id`).""" __tablename__ = "email_deliveries" __table_args__ = ( CheckConstraint("kind IN ('summary', 'invitation')", name="ck_email_deliveries_kind"), CheckConstraint( "(kind = 'summary') = (session_id IS NOT NULL)", name="ck_email_deliveries_summary_has_session", ), CheckConstraint( "(kind = 'invitation') = (conference_id IS NOT NULL)", name="ck_email_deliveries_invitation_has_conference", ), Index( "uq_email_deliveries_summary", "session_id", "recipient_email", unique=True, postgresql_where=text("kind = 'summary'"), ), Index("ix_email_deliveries_conference", "conference_id"), ) id: Mapped[uuid.UUID] = mapped_column( UUID(as_uuid=True), primary_key=True, server_default=text("gen_random_uuid()") ) session_id: Mapped[uuid.UUID | None] = mapped_column( UUID(as_uuid=True), ForeignKey("conference_sessions.id", ondelete="CASCADE"), nullable=True, ) conference_id: Mapped[uuid.UUID | None] = mapped_column( UUID(as_uuid=True), ForeignKey("conferences.id", ondelete="CASCADE"), nullable=True ) # Хранится в lower() (нормализация — на уровне сервиса-отправителя). recipient_email: Mapped[str] = mapped_column(String(320), nullable=False) kind: Mapped[str] = mapped_column(String(16), nullable=False) sent_at: Mapped[datetime] = mapped_column( DateTime(timezone=True), nullable=False, server_default=func.now() )