mirror of
https://github.com/maxdorninger/MediaManager.git
synced 2026-07-31 00:56:16 -04:00
41 lines
1.8 KiB
Python
41 lines
1.8 KiB
Python
from media_manager.notification.manager import notification_manager
|
|
from media_manager.notification.repository import NotificationRepository
|
|
from media_manager.notification.schemas import Notification, NotificationId
|
|
|
|
|
|
class NotificationService:
|
|
def __init__(
|
|
self,
|
|
notification_repository: NotificationRepository,
|
|
) -> None:
|
|
self.notification_repository = notification_repository
|
|
self.notification_manager = notification_manager
|
|
|
|
async def get_notification(self, nid: NotificationId) -> Notification:
|
|
return await self.notification_repository.get_notification(nid=nid)
|
|
|
|
async def get_unread_notifications(self) -> list[Notification]:
|
|
return await self.notification_repository.get_unread_notifications()
|
|
|
|
async def get_all_notifications(self) -> list[Notification]:
|
|
return await self.notification_repository.get_all_notifications()
|
|
|
|
async def save_notification(self, notification: Notification) -> None:
|
|
return await self.notification_repository.save_notification(notification)
|
|
|
|
async def mark_notification_as_read(self, nid: NotificationId) -> None:
|
|
return await self.notification_repository.mark_notification_as_read(nid=nid)
|
|
|
|
async def mark_notification_as_unread(self, nid: NotificationId) -> None:
|
|
return await self.notification_repository.mark_notification_as_unread(nid=nid)
|
|
|
|
async def delete_notification(self, nid: NotificationId) -> None:
|
|
return await self.notification_repository.delete_notification(nid=nid)
|
|
|
|
async def send_notification_to_all_providers(self, title: str, message: str) -> None:
|
|
await self.notification_manager.send_notification(title, message)
|
|
|
|
internal_notification = Notification(message=f"{title}: {message}", read=False)
|
|
await self.save_notification(internal_notification)
|
|
return
|