Struct NotificationUseCases 

pub struct NotificationUseCases { /* private fields */ }

Implementations

impl NotificationUseCases

pub fn new( notification_repository: Arc<dyn NotificationRepository>, preference_repository: Arc<dyn NotificationPreferenceRepository>, ) -> Self

pub async fn create_notification( &self, organization_id: Uuid, request: CreateNotificationRequest, ) -> Result<NotificationResponse, String>

Create a new notification

pub async fn get_notification( &self, id: Uuid, ) -> Result<Option<NotificationResponse>, String>

Get a notification by ID

pub async fn list_user_notifications( &self, user_id: Uuid, ) -> Result<Vec<NotificationResponse>, String>

List all notifications for a user

pub async fn list_unread_notifications( &self, user_id: Uuid, ) -> Result<Vec<NotificationResponse>, String>

List unread in-app notifications for a user

pub async fn mark_as_read( &self, id: Uuid, ) -> Result<NotificationResponse, String>

Mark an in-app notification as read

pub async fn mark_all_read(&self, user_id: Uuid) -> Result<i64, String>

Mark all in-app notifications as read for a user

pub async fn delete_notification(&self, id: Uuid) -> Result<bool, String>

Delete a notification

pub async fn get_user_stats( &self, user_id: Uuid, ) -> Result<NotificationStats, String>

Get notification statistics for a user

pub async fn get_user_preferences( &self, user_id: Uuid, ) -> Result<Vec<NotificationPreferenceResponse>, String>

Get user’s notification preferences

pub async fn get_preference( &self, user_id: Uuid, notification_type: NotificationType, ) -> Result<Option<NotificationPreferenceResponse>, String>

Get user’s preference for a specific notification type

pub async fn update_preference( &self, user_id: Uuid, notification_type: NotificationType, request: UpdatePreferenceRequest, ) -> Result<NotificationPreferenceResponse, String>

Update user’s notification preference for a specific notification type

pub async fn get_pending_notifications( &self, ) -> Result<Vec<NotificationResponse>, String>

Get all pending notifications (for background processing)

pub async fn get_failed_notifications( &self, ) -> Result<Vec<NotificationResponse>, String>

Get all failed notifications (for retry)

pub async fn mark_as_sent( &self, id: Uuid, ) -> Result<NotificationResponse, String>

Mark notification as sent

pub async fn mark_as_failed( &self, id: Uuid, error_message: String, ) -> Result<NotificationResponse, String>

Mark notification as failed

pub async fn retry_notification( &self, id: Uuid, ) -> Result<NotificationResponse, String>

Retry a failed notification

pub async fn cleanup_old_notifications(&self, days: i64) -> Result<i64, String>

Delete old notifications (cleanup)