EonaCat.NotificationSystem 1.0.0

EonaCat.NotificationSystem

EonaCat Real-time notification system

NotificationService:

• WebSocket connection management
• Real-time message delivery
• User presence tracking
• Group-based notifications
• Multi-channel delivery (WebSocket, Email, SMS, Push)

User Management:

• Connection tracking with metadata
• Presence status (Online, Away, Busy, Offline)
• User preferences for notification channels
• Quiet hours support
• Automatic cleanup of inactive connections

Notification System:

• Priority-based notifications (Low to Emergency)
• Acknowledgment support
• Expiration handling
• Tag-based categorization
• Metadata support for custom data

Group Management:

• Create and manage notification groups
• Add/remove users from groups
• Administrator roles
• Group-wide notifications

Advanced Features:

• Pluggable Delivery Channels: Easy to add Email, SMS, Push notifications
• Filtering System: Quiet hours, priority filtering, custom filters
• Event System: Real-time events for monitoring
• Storage Interface: Persistent notification storage
• Concurrent Delivery: Efficient message delivery with semaphore limiting
• WebSocket Message Processing: Handles acknowledgments, status updates, pings

// Initialize the service
var notificationService = new NotificationService();

// Connect a user via WebSocket
string connectionId = await notificationService.ConnectUserAsync("user123", webSocket);

// Create a notification group
await notificationService.CreateGroupAsync(new NotificationGroup
{
    Id = "team-alerts",
    Name = "Team Alerts",
    Members = new[] { "user123", "user456" }
});

// Send a notification
var notification = new Notification
{
    Type = "alert",
    Title = "System Alert",
    Message = "Server maintenance scheduled",
    Priority = NotificationPriority.High,
    Groups = new[] { "team-alerts" },
    RequiresAcknowledgment = true
};

var results = await notificationService.SendNotificationAsync(notification);

// Update user preferences
await notificationService.UpdateUserPreferencesAsync("user123", new NotificationPreferences
{
    EnableEmail = true,
    EnableSMS = false,
    RespectQuietHours = true,
    QuietHoursStart = TimeSpan.FromHours(22),
    QuietHoursEnd = TimeSpan.FromHours(7)
});

// Register custom delivery channel
notificationService.RegisterDeliveryChannel(new EmailDeliveryChannel());

// Register custom filter
notificationService.RegisterFilter(new QuietHoursFilter());