raisfast 0.2.23

The last backend you'll ever need. Rust-powered headless CMS with built-in blog, ecommerce, wallet, payment and 4 plugin engines.
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126

//! Notification module
//!
//! Generic email/SMS sending abstraction layer, with implementation selected via env config:
//!
//! - Email: `log` (log placeholder) | `smtp` (lettre)
//! - SMS: `log` (log placeholder) | `aliyun` (Alibaba Cloud SMS) | `twilio`

pub mod email;
pub mod sms;

/// HTTP request timeout for notification service calls (seconds)
const NOTIFICATION_TIMEOUT_SECS: u64 = 10;

/// Build a reqwest client with notification-appropriate timeout
pub(crate) fn http_client() -> reqwest::Client {
    reqwest::Client::builder()
        .timeout(std::time::Duration::from_secs(NOTIFICATION_TIMEOUT_SECS))
        .build()
        .unwrap_or_else(|_| reqwest::Client::new())
}

use std::sync::Arc;

use serde_json::Value;

/// Email message
#[derive(Debug, Clone)]
pub struct EmailMessage {
    pub to: String,
    pub subject: String,
    pub html_body: String,
    pub text_body: Option<String>,
}

/// SMS message
#[derive(Debug, Clone)]
pub struct SmsMessage {
    pub to: String,
    pub content: String,
    pub template_id: Option<String>,
    pub template_params: Option<Value>,
}

/// Email sender trait
#[async_trait::async_trait]
pub trait EmailSender: Send + Sync {
    async fn send(&self, msg: &EmailMessage) -> anyhow::Result<()>;
    fn name(&self) -> &'static str;
}

/// SMS sender trait
#[async_trait::async_trait]
pub trait SmsSender: Send + Sync {
    async fn send(&self, msg: &SmsMessage) -> anyhow::Result<()>;
    fn name(&self) -> &'static str;
}

/// Build an email sender based on configuration
pub fn build_email_sender(config: &crate::config::app::AppConfig) -> Arc<dyn EmailSender> {
    match config.email_provider.as_str() {
        "smtp" => Arc::new(email::SmtpSender::new(
            config.email_smtp_host.as_deref().unwrap_or(""),
            config.email_smtp_port,
            config.email_smtp_user.as_deref().unwrap_or(""),
            config.email_smtp_pass.as_deref().unwrap_or(""),
        )),
        "sendgrid" => Arc::new(email::SendGridSender::new(
            config.email_sendgrid_api_key.clone().unwrap_or_default(),
            config.email_from.clone().unwrap_or_default(),
            config.email_from_name.clone(),
        )),
        "resend" => Arc::new(email::ResendSender::new(
            config.email_resend_api_key.clone().unwrap_or_default(),
            config.email_from.clone().unwrap_or_default(),
            config.email_from_name.clone(),
        )),
        "aliyun" => Arc::new(email::AliyunDirectMailSender::new(
            config
                .email_aliyun_access_key_id
                .clone()
                .unwrap_or_default(),
            config
                .email_aliyun_access_key_secret
                .clone()
                .unwrap_or_default(),
            config.email_from.clone().unwrap_or_default(),
            config.email_from_name.clone(),
            config
                .email_aliyun_region
                .clone()
                .unwrap_or_else(|| "cn-hangzhou".into()),
        )),
        "tencent" => Arc::new(email::TencentSesSender::new(
            config.email_tencent_secret_id.clone().unwrap_or_default(),
            config.email_tencent_secret_key.clone().unwrap_or_default(),
            config.email_from.clone().unwrap_or_default(),
            config.email_from_name.clone(),
            config
                .email_tencent_region
                .clone()
                .unwrap_or_else(|| "ap-guangzhou".into()),
        )),
        _ => Arc::new(email::LogSender),
    }
}

/// Build an SMS sender based on configuration
pub fn build_sms_sender(config: &crate::config::app::AppConfig) -> Arc<dyn SmsSender> {
    match config.sms_provider.as_str() {
        "aliyun" => Arc::new(sms::AliyunSender::new(
            config.sms_aliyun_access_key_id.clone().unwrap_or_default(),
            config
                .sms_aliyun_access_key_secret
                .clone()
                .unwrap_or_default(),
            config.sms_aliyun_sign_name.clone().unwrap_or_default(),
            config.sms_aliyun_template_code.clone().unwrap_or_default(),
        )),
        "twilio" => Arc::new(sms::TwilioSender::new(
            config.sms_twilio_account_sid.clone().unwrap_or_default(),
            config.sms_twilio_auth_token.clone().unwrap_or_default(),
            config.sms_twilio_from.clone().unwrap_or_default(),
        )),
        _ => Arc::new(sms::LogSender),
    }
}