rusmes-core 0.1.2

Mailet processing engine for RusMES — composable mail processing pipeline with matchers, mailets, DKIM/SPF/DMARC, spam filtering, and AI integration
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

//! Matcher for messages with specific header values

use crate::matcher::Matcher;
use async_trait::async_trait;
use rusmes_proto::{Mail, MailAddress};

/// Matches messages where a header contains a specific value
pub struct HeaderContainsMatcher {
    header_name: String,
    value: String,
}

impl HeaderContainsMatcher {
    /// Create a new HeaderContains matcher
    pub fn new(header_name: String, value: String) -> Self {
        Self { header_name, value }
    }
}

#[async_trait]
impl Matcher for HeaderContainsMatcher {
    async fn match_mail(&self, mail: &Mail) -> anyhow::Result<Vec<MailAddress>> {
        let headers = mail.message().headers();

        if let Some(header_values) = headers.get(&self.header_name) {
            for header_value in header_values {
                if header_value.contains(&self.value) {
                    return Ok(mail.recipients().to_vec());
                }
            }
        }

        Ok(Vec::new())
    }

    fn name(&self) -> &str {
        "HeaderContains"
    }
}