samotop-smime 0.13.0

A samotop extensions for server side S/MIME encrypted mail.
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79

use log::error;
use samotop_core::{
    common::{ready, S2Fut},
    mail::{
        AcceptsGuard, AddRecipientFailure, AddRecipientResult, Certificate, MailGuard, MailSetup,
        StartMailResult,
    },
    smtp::SmtpSession,
};
use std::path::PathBuf;

#[derive(Debug, Clone)]
pub struct Accounts {
    accounts_dir: PathBuf,
}

impl Accounts {
    pub fn new(accounts_dir: PathBuf) -> Self {
        Self { accounts_dir }
    }
}

impl<T: AcceptsGuard> MailSetup<T> for Accounts {
    fn setup(self, config: &mut T) {
        config.add_last_guard(self)
    }
}

impl MailGuard for Accounts {
    fn add_recipient<'a, 's, 'f>(
        &'a self,
        _session: &'s mut SmtpSession,
        mut rcpt: samotop_core::mail::Recipient,
    ) -> S2Fut<'f, AddRecipientResult>
    where
        'a: 'f,
        's: 'f,
    {
        if rcpt.certificate.is_some() {
            return Box::pin(ready(AddRecipientResult::Inconclusive(rcpt)));
        }
        let mut path = async_std::path::PathBuf::from(&self.accounts_dir);
        // TODO: hash the value for privacy
        path.push(rcpt.address.address().to_lowercase());
        path.push("certificate");

        Box::pin(async move {
            if path.exists().await {
                match path.to_str() {
                    Some(cert) => {
                        rcpt.certificate = Some(Certificate::File(cert.to_owned()));
                        AddRecipientResult::Inconclusive(rcpt)
                    }
                    None => {
                        error!("Invalid recipient cert path {:?}", path);
                        AddRecipientResult::Failed(
                            AddRecipientFailure::FailedTemporarily,
                            "Not ready".to_owned(),
                        )
                    }
                }
            } else {
                error!("Recipient cert missing {:?}", path);
                AddRecipientResult::Failed(
                    AddRecipientFailure::FailedTemporarily,
                    "Not ready".to_owned(),
                )
            }
        })
    }

    fn start_mail<'a, 's, 'f>(&'a self, _session: &'s mut SmtpSession) -> S2Fut<'f, StartMailResult>
    where
        'a: 'f,
        's: 'f,
    {
        Box::pin(ready(StartMailResult::Accepted))
    }
}