cedros-login-server 0.0.45

Authentication server for cedros-login with email/password, Google OAuth, and Solana wallet sign-in
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

//! Notification event handlers for the outbox worker

use crate::errors::AppError;
use crate::repositories::OutboxEvent;
use crate::services::{AdminNotification, NotificationService, NotificationSeverity};

/// Process a notification event
pub async fn process_notification_event(
    event: &OutboxEvent,
    notification_service: &dyn NotificationService,
) -> Result<(), AppError> {
    // REL-008: Return error for unknown severity values to prevent silent downgrade
    let severity = match event.payload["severity"].as_str() {
        Some("critical") => NotificationSeverity::Critical,
        Some("warn") => NotificationSeverity::Warn,
        Some("info") | None => NotificationSeverity::Info,
        Some(unknown) => {
            return Err(AppError::Internal(anyhow::anyhow!(
                "Unknown notification severity: {}",
                unknown
            )));
        }
    };

    let title = event.payload["title"]
        .as_str()
        .unwrap_or("Alert")
        .to_string();

    let body = event.payload["body"].as_str().unwrap_or("").to_string();

    let mut notification = AdminNotification::new(severity, &title, &body);

    if let Some(metadata) = event.payload.get("metadata") {
        notification = notification.with_metadata(metadata.clone());
    }

    if let Some(org_slug) = event.payload["org_slug"].as_str() {
        notification = notification.with_org(org_slug);
    }

    if let Some(correlation_id) = &event.correlation_id {
        notification = notification.with_correlation_id(correlation_id);
    }

    notification_service.notify(notification).await
}