MailLaser 2.0.0

An SMTP server that listens for incoming emails addressed to a specific recipient and forwards them as HTTP POST requests to a configured webhook.
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

pub mod config;
pub mod health;
pub mod smtp;
pub mod webhook;

use acton_reactive::prelude::*;
use anyhow::Result;
use log::{error, info};

pub async fn run() -> Result<()> {
    info!(
        "Starting {} v{}",
        env!("CARGO_PKG_NAME"),
        env!("CARGO_PKG_VERSION")
    );

    let config = match config::Config::from_env() {
        Ok(config) => config,
        Err(e) => {
            error!("Failed to load configuration: {}", e);
            return Err(e);
        }
    };

    let mut runtime = ActonApp::launch_async().await;

    // Create actors in dependency order
    let webhook_handle = webhook::WebhookState::create(&mut runtime, &config).await?;
    let _smtp_handle =
        smtp::SmtpListenerState::create(&mut runtime, &config, webhook_handle).await?;
    let _health_handle = health::HealthState::create(&mut runtime, &config).await?;

    // Wait for shutdown signal (SIGTERM/SIGINT)
    tokio::signal::ctrl_c().await?;
    info!("Shutdown signal received, draining in-flight work...");

    // Graceful shutdown: cancels accept loops (before_stop), finishes in-flight webhooks
    runtime.shutdown_all().await?;
    info!("Shutdown complete");

    Ok(())
}