zsmtp 0.1.0

A zero-knowledge SMTP mail transfer agent prototype
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

use anyhow::Result;
use tracing::info;
use zsmtp::cli;

#[tokio::main(flavor = "current_thread")]
async fn main() -> Result<()> {
    let action = cli::start()?;

    info!("starting zsmtp execution");

    let output = match action {
        cli::actions::Action::Serve {
            config_path,
            verbose,
        } => {
            info!(action = "serve", verbose, "executing serve action");
            cli::actions::serve::execute(config_path.as_deref())?
        }
        cli::actions::Action::Submit {
            config_path,
            verbose,
            envelope_from,
            recipients,
            source,
        } => {
            info!(
                action = "submit",
                verbose,
                recipient_count = recipients.len(),
                "executing submit action"
            );
            cli::actions::submit::execute(
                config_path.as_deref(),
                &envelope_from,
                &recipients,
                &source,
            )?
        }
        cli::actions::Action::ConfigShow {
            config_path,
            verbose,
        } => {
            info!(action = "config-show", verbose, "executing config show");
            cli::actions::config::execute_show(config_path.as_deref())?
        }
        cli::actions::Action::ConfigValidate {
            config_path,
            verbose,
        } => {
            info!(
                action = "config-validate",
                verbose, "executing config validate"
            );
            cli::actions::config::execute_validate(config_path.as_deref())?
        }
        cli::actions::Action::Doctor {
            config_path,
            verbose,
        } => {
            info!(action = "doctor", verbose, "executing doctor action");
            cli::actions::doctor::execute(config_path.as_deref())?
        }
    };

    if !output.stdout.is_empty() {
        println!("{}", output.stdout);
    }

    cli::telemetry::shutdown_tracer();
    tokio::time::sleep(std::time::Duration::from_millis(50)).await;

    Ok(())
}