mailbridge 0.1.0

Provider-neutral transactional email library for Rust services
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

pub type Result<T> = std::result::Result<T, MailError>;

#[derive(Debug, Clone, PartialEq, thiserror::Error)]
pub enum MailError {
    #[error("configuration error: {0}")]
    Config(String),

    #[error("invalid email message: {0}")]
    Validation(String),

    #[error("sender domain is not allowed: {domain}")]
    SenderDomainNotAllowed { domain: String },

    #[error("request rate limited")]
    RateLimited,

    #[error("relay authentication failed")]
    Authentication,

    #[error("relay rejected request: status={status}, message={message}")]
    RelayRejected { status: u16, message: String },

    #[error("temporary delivery failure: {0}")]
    Temporary(String),

    #[error("queue error: {0}")]
    Queue(String),
}

impl MailError {
    #[must_use]
    pub const fn is_retryable(&self) -> bool {
        match self {
            Self::RateLimited | Self::Temporary(_) => true,
            Self::RelayRejected { status, .. } => *status == 429 || *status >= 500,
            Self::Config(_)
            | Self::Validation(_)
            | Self::SenderDomainNotAllowed { .. }
            | Self::Authentication
            | Self::Queue(_) => false,
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn retry_classification_marks_temporary_errors_retryable() {
        let error = MailError::Temporary("timeout".to_owned());

        assert!(error.is_retryable());
    }

    #[test]
    fn retry_classification_marks_validation_errors_permanent() {
        let error = MailError::Validation("missing body".to_owned());

        assert!(!error.is_retryable());
    }
}