60 lines
2.6 KiB
Python
60 lines
2.6 KiB
Python
"""Модель 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()
|
||
)
|