"""Модель для идемпотентной обработки webhook-событий LiveKit."""

from datetime import datetime

from sqlalchemy import DateTime, String, func
from sqlalchemy.orm import Mapped, mapped_column

from models.base import Base


class LivekitWebhookEvent(Base):
    """Журнал полученных webhook-событий LiveKit.

    `event_id` — первичный ключ; повторная доставка того же события
    (`INSERT ... ON CONFLICT DO NOTHING`) отклоняется на уровне БД в одной
    транзакции с эффектами обработчика (см. `api/livekit_webhook.py`).
    """

    __tablename__ = "livekit_webhook_events"

    event_id: Mapped[str] = mapped_column(String(255), primary_key=True)
    event_type: Mapped[str] = mapped_column(String(64), nullable=False)
    received_at: Mapped[datetime] = mapped_column(
        DateTime(timezone=True), nullable=False, server_default=func.now()
    )