Files
core/orm/notification.py

158 lines
5.2 KiB
Python
Raw Normal View History

2024-10-21 12:15:44 +03:00
import enum
2025-07-25 01:04:15 +03:00
from datetime import datetime
from enum import Enum, auto
2024-03-04 10:35:33 +03:00
2025-07-25 01:04:15 +03:00
from sqlalchemy import JSON, Column, DateTime, ForeignKey, Integer, String
from sqlalchemy import Enum as SQLAlchemyEnum
2024-04-19 18:22:07 +03:00
from sqlalchemy.orm import relationship
2024-03-04 10:35:33 +03:00
2025-07-25 01:18:50 +03:00
from auth.orm import Author
2025-07-25 01:04:15 +03:00
from orm.base import BaseModel as Base
from services.logger import root_logger as logger
class NotificationStatus(Enum):
"""Статусы уведомлений."""
UNREAD = auto()
READ = auto()
ARCHIVED = auto()
@classmethod
def from_string(cls, value: str) -> "NotificationStatus":
"""
Создает экземпляр статуса уведомления из строки.
Args:
value (str): Строковое представление статуса.
Returns:
NotificationStatus: Экземпляр статуса уведомления.
"""
try:
return cls[value.upper()]
except KeyError:
logger.error(f"Неверный статус уведомления: {value}")
raise ValueError("Неверный статус уведомления") # noqa: B904
class NotificationKind(Enum):
"""Типы уведомлений."""
COMMENT = auto()
MENTION = auto()
REACTION = auto()
FOLLOW = auto()
INVITE = auto()
@classmethod
def from_string(cls, value: str) -> "NotificationKind":
"""
Создает экземпляр типа уведомления из строки.
Args:
value (str): Строковое представление типа.
Returns:
NotificationKind: Экземпляр типа уведомления.
"""
try:
return cls[value.upper()]
except KeyError:
logger.error(f"Неверный тип уведомления: {value}")
raise ValueError("Неверный тип уведомления") # noqa: B904
2024-03-04 10:35:33 +03:00
2024-10-21 12:15:44 +03:00
class NotificationEntity(enum.Enum):
2025-07-25 01:04:15 +03:00
"""Сущности, связанные с уведомлениями."""
TOPIC = "topic"
COMMENT = "comment"
2024-04-17 18:32:23 +03:00
SHOUT = "shout"
2025-07-25 01:04:15 +03:00
AUTHOR = "author"
2024-10-21 12:15:44 +03:00
COMMUNITY = "community"
2024-03-04 10:35:33 +03:00
2024-10-21 12:15:44 +03:00
@classmethod
2025-07-25 01:04:15 +03:00
def from_string(cls, value: str) -> "NotificationEntity":
"""
Создает экземпляр сущности уведомления из строки.
Args:
value (str): Строковое представление сущности.
Returns:
NotificationEntity: Экземпляр сущности уведомления.
"""
try:
return cls(value)
except ValueError:
logger.error(f"Неверная сущность уведомления: {value}")
raise ValueError("Неверная сущность уведомления") # noqa: B904
2024-03-04 10:35:33 +03:00
2024-10-21 12:15:44 +03:00
class NotificationAction(enum.Enum):
2025-07-25 01:04:15 +03:00
"""Действия в уведомлениях."""
2024-04-17 18:32:23 +03:00
CREATE = "create"
UPDATE = "update"
DELETE = "delete"
2025-07-25 01:04:15 +03:00
MENTION = "mention"
REACT = "react"
2024-03-04 10:35:33 +03:00
2024-10-21 12:15:44 +03:00
@classmethod
2025-07-25 01:04:15 +03:00
def from_string(cls, value: str) -> "NotificationAction":
"""
Создает экземпляр действия уведомления из строки.
Args:
value (str): Строковое представление действия.
Returns:
NotificationAction: Экземпляр действия уведомления.
"""
try:
return cls(value)
except ValueError:
logger.error(f"Неверное действие уведомления: {value}")
raise ValueError("Неверное действие уведомления") # noqa: B904
2024-10-21 12:15:44 +03:00
2024-03-04 10:35:33 +03:00
class NotificationSeen(Base):
2024-04-17 18:32:23 +03:00
__tablename__ = "notification_seen"
2024-03-04 10:35:33 +03:00
2024-10-21 12:15:44 +03:00
viewer = Column(ForeignKey("author.id"), primary_key=True)
notification = Column(ForeignKey("notification.id"), primary_key=True)
2024-03-04 10:35:33 +03:00
class Notification(Base):
2024-04-17 18:32:23 +03:00
__tablename__ = "notification"
2024-03-04 10:35:33 +03:00
2025-07-25 01:04:15 +03:00
id = Column(Integer, primary_key=True, index=True)
created_at = Column(DateTime, default=datetime.utcnow)
updated_at = Column(DateTime, default=datetime.utcnow, onupdate=datetime.utcnow)
2024-03-04 10:35:33 +03:00
entity = Column(String, nullable=False)
action = Column(String, nullable=False)
payload = Column(JSON, nullable=True)
2025-07-25 01:04:15 +03:00
status = Column(SQLAlchemyEnum(NotificationStatus), default=NotificationStatus.UNREAD)
kind = Column(SQLAlchemyEnum(NotificationKind), nullable=False)
2024-10-21 12:15:44 +03:00
seen = relationship(Author, secondary="notification_seen")
def set_entity(self, entity: NotificationEntity):
2025-07-25 01:04:15 +03:00
"""Устанавливает сущность уведомления."""
self.entity = entity.value
2024-10-21 12:15:44 +03:00
def get_entity(self) -> NotificationEntity:
2025-07-25 01:04:15 +03:00
"""Возвращает сущность уведомления."""
2024-10-21 12:15:44 +03:00
return NotificationEntity.from_string(self.entity)
def set_action(self, action: NotificationAction):
2025-07-25 01:04:15 +03:00
"""Устанавливает действие уведомления."""
self.action = action.value
2024-10-21 12:15:44 +03:00
def get_action(self) -> NotificationAction:
2025-07-25 01:04:15 +03:00
"""Возвращает действие уведомления."""
2024-10-21 12:15:44 +03:00
return NotificationAction.from_string(self.action)