modo/email/

mailer.rs

use crate::email::cache::CachedSource;
use crate::email::layout;
use crate::email::markdown;
use crate::email::message::{RenderedEmail, SendEmail};
use crate::email::render;
use crate::email::source::{FileSource, TemplateSource};
use crate::{Error, Result};
use lettre::message::{MultiPart, SinglePart, header::ContentType};
use lettre::{AsyncSmtpTransport, AsyncTransport, Message, Tokio1Executor};
use std::collections::HashMap;
use std::sync::Arc;

use crate::email::config::{EmailConfig, SmtpSecurity};

enum Transport {
    Smtp(AsyncSmtpTransport<Tokio1Executor>),
    #[cfg(any(test, feature = "test-helpers"))]
    Stub(lettre::transport::stub::AsyncStubTransport),
}

struct Inner {
    source: Arc<dyn TemplateSource>,
    transport: Transport,
    config: EmailConfig,
    layouts: HashMap<String, String>,
}

/// The primary entry point for sending transactional email.
///
/// `Mailer` loads Markdown templates, performs variable substitution, renders
/// HTML and plain-text bodies, applies a layout, and delivers the resulting
/// message over SMTP.
///
/// Cloning is cheap (`Arc`-based) and shares the SMTP connection, template
/// source, and preloaded layouts.
///
/// # Construction
///
/// - [`Mailer::new`] — uses a [`FileSource`] (optionally cached) derived from
///   `EmailConfig::templates_path`.
/// - [`Mailer::with_source`] — accepts any custom [`TemplateSource`].
/// - `Mailer::with_stub_transport` — in-memory stub for tests
///   (requires feature `"test-helpers"` or `#[cfg(test)]`).
#[derive(Clone)]
pub struct Mailer {
    inner: Arc<Inner>,
}

impl Mailer {
    /// Create a new `Mailer` with the default [`FileSource`].
    ///
    /// If `config.cache_templates` is `true`, the file source is wrapped in a
    /// [`CachedSource`] with `config.template_cache_size` capacity.
    ///
    /// # Errors
    ///
    /// Returns an error if the SMTP transport cannot be built (e.g., invalid
    /// host, mismatched credentials) or if the layouts directory cannot be
    /// read.
    pub fn new(config: &EmailConfig) -> Result<Self> {
        let file_source = FileSource::new(&config.templates_path);
        let source: Arc<dyn TemplateSource> = if config.cache_templates {
            Arc::new(CachedSource::new(file_source, config.template_cache_size))
        } else {
            Arc::new(file_source)
        };

        let transport = Self::build_smtp_transport(config)?;
        let layouts = layout::load_layouts(&config.layouts_path)?;

        Ok(Self {
            inner: Arc::new(Inner {
                source,
                transport: Transport::Smtp(transport),
                config: config.clone(),
                layouts,
            }),
        })
    }

    /// Create a new `Mailer` with a custom [`TemplateSource`].
    ///
    /// Use this to supply an in-memory source, a database-backed source, or
    /// any other custom implementation.
    ///
    /// # Errors
    ///
    /// Returns an error if the SMTP transport cannot be built or if the
    /// layouts directory cannot be read.
    pub fn with_source(config: &EmailConfig, source: Arc<dyn TemplateSource>) -> Result<Self> {
        let transport = Self::build_smtp_transport(config)?;
        let layouts = layout::load_layouts(&config.layouts_path)?;

        Ok(Self {
            inner: Arc::new(Inner {
                source,
                transport: Transport::Smtp(transport),
                config: config.clone(),
                layouts,
            }),
        })
    }

    /// Create a `Mailer` with a stub transport for testing.
    ///
    /// Requires feature `"test-helpers"` or `#[cfg(test)]`. The stub transport accepts messages
    /// without actually sending them over a network.
    ///
    /// # Errors
    ///
    /// Returns an error if the layouts directory cannot be read.
    #[cfg(any(test, feature = "test-helpers"))]
    pub fn with_stub_transport(
        config: &EmailConfig,
        stub: lettre::transport::stub::AsyncStubTransport,
    ) -> Result<Self> {
        let file_source = FileSource::new(&config.templates_path);
        let source: Arc<dyn TemplateSource> = if config.cache_templates {
            Arc::new(CachedSource::new(file_source, config.template_cache_size))
        } else {
            Arc::new(file_source)
        };
        let layouts = layout::load_layouts(&config.layouts_path)?;

        Ok(Self {
            inner: Arc::new(Inner {
                source,
                transport: Transport::Stub(stub),
                config: config.clone(),
                layouts,
            }),
        })
    }

    fn build_smtp_transport(config: &EmailConfig) -> Result<AsyncSmtpTransport<Tokio1Executor>> {
        // Validate SMTP auth: both set or both empty
        match (&config.smtp.username, &config.smtp.password) {
            (Some(_), None) | (None, Some(_)) => {
                return Err(Error::bad_request(
                    "SMTP username and password must both be set or both be empty",
                ));
            }
            _ => {}
        }

        let builder = match config.smtp.security {
            SmtpSecurity::Tls => AsyncSmtpTransport::<Tokio1Executor>::relay(&config.smtp.host)
                .map_err(|e| Error::internal(format!("SMTP relay error: {e}")))?,
            SmtpSecurity::StartTls => {
                AsyncSmtpTransport::<Tokio1Executor>::starttls_relay(&config.smtp.host)
                    .map_err(|e| Error::internal(format!("SMTP STARTTLS error: {e}")))?
            }
            SmtpSecurity::None => {
                AsyncSmtpTransport::<Tokio1Executor>::builder_dangerous(&config.smtp.host)
            }
        };

        let builder = builder.port(config.smtp.port);

        let builder = if let (Some(username), Some(password)) =
            (&config.smtp.username, &config.smtp.password)
        {
            builder.credentials(lettre::transport::smtp::authentication::Credentials::new(
                username.clone(),
                password.clone(),
            ))
        } else {
            builder
        };

        Ok(builder.build())
    }

    /// Render a template without sending.
    ///
    /// Performs variable substitution, parses the YAML frontmatter, converts
    /// the Markdown body to HTML (with button syntax support), applies the
    /// layout, and generates the plain-text fallback.
    ///
    /// Returns a [`RenderedEmail`] containing the subject, HTML, and text.
    ///
    /// # Errors
    ///
    /// Returns an error if the template cannot be loaded, the frontmatter is
    /// missing or malformed, or the requested layout is not found.
    pub fn render(&self, email: &SendEmail) -> Result<RenderedEmail> {
        let locale = email
            .locale
            .as_deref()
            .unwrap_or(&self.inner.config.default_locale);

        // Load raw template
        let raw =
            self.inner
                .source
                .load(&email.template, locale, &self.inner.config.default_locale)?;

        // Stage 1: Substitute variables
        let substituted = render::substitute(&raw, &email.vars);

        // Stage 2: Parse frontmatter
        let (frontmatter, body) = render::parse_frontmatter(&substituted)?;

        // Stage 3: Render markdown to HTML
        let brand_color = email.vars.get("brand_color").map(|s| s.as_str());
        let html_body = markdown::markdown_to_html(&body, brand_color);

        // Stage 4: Apply layout
        let layout_html = layout::resolve_layout(&frontmatter.layout, &self.inner.layouts)?;
        let html = layout::apply_layout(&layout_html, &html_body, &email.vars);

        // Stage 5: optional CSS-inliner pass.
        let html = if self.inner.config.inline_css {
            render::inline_css_pass(&html)?
        } else {
            html
        };

        // Stage 6: Plain text
        let text = markdown::markdown_to_text(&body);

        Ok(RenderedEmail {
            subject: frontmatter.subject,
            html,
            text,
        })
    }

    /// Render and send an email via SMTP.
    ///
    /// Calls [`Self::render`] internally, then builds a `multipart/alternative`
    /// MIME message (text/plain + text/html) and delivers it over the
    /// configured transport.
    ///
    /// # Errors
    ///
    /// Returns an error if the recipient list is empty, if any address is
    /// malformed, if the template cannot be rendered, or if the SMTP delivery
    /// fails.
    pub async fn send(&self, email: SendEmail) -> Result<()> {
        if email.to.is_empty() {
            return Err(Error::bad_request("email has no recipients"));
        }

        let rendered = self.render(&email)?;

        // Build sender
        let from_name = email
            .sender
            .as_ref()
            .map(|s| &s.from_name)
            .unwrap_or(&self.inner.config.default_from_name);
        let from_email = email
            .sender
            .as_ref()
            .map(|s| &s.from_email)
            .unwrap_or(&self.inner.config.default_from_email);
        let reply_to = email
            .sender
            .as_ref()
            .and_then(|s| s.reply_to.as_deref())
            .or(self.inner.config.default_reply_to.as_deref());

        let from = if from_name.is_empty() {
            from_email.parse()
        } else {
            format!("{from_name} <{from_email}>").parse()
        }
        .map_err(|e| Error::bad_request(format!("invalid from address: {e}")))?;

        let mut builder = Message::builder().from(from).subject(&rendered.subject);

        for to_addr in &email.to {
            builder = builder.to(to_addr
                .parse()
                .map_err(|e| Error::bad_request(format!("invalid to address '{to_addr}': {e}")))?);
        }

        for cc_addr in &email.cc {
            builder = builder.cc(cc_addr
                .parse()
                .map_err(|e| Error::bad_request(format!("invalid cc address '{cc_addr}': {e}")))?);
        }

        for bcc_addr in &email.bcc {
            builder = builder.bcc(bcc_addr.parse().map_err(|e| {
                Error::bad_request(format!("invalid bcc address '{bcc_addr}': {e}"))
            })?);
        }

        if let Some(reply_to_addr) = reply_to {
            builder = builder.reply_to(
                reply_to_addr
                    .parse()
                    .map_err(|e| Error::bad_request(format!("invalid reply-to address: {e}")))?,
            );
        }

        let message = builder
            .multipart(
                MultiPart::alternative()
                    .singlepart(
                        SinglePart::builder()
                            .header(ContentType::TEXT_PLAIN)
                            .body(rendered.text),
                    )
                    .singlepart(
                        SinglePart::builder()
                            .header(ContentType::TEXT_HTML)
                            .body(rendered.html),
                    ),
            )
            .map_err(|e| Error::internal(format!("failed to build email message: {e}")))?;

        match &self.inner.transport {
            Transport::Smtp(transport) => {
                transport
                    .send(message)
                    .await
                    .map_err(|e| Error::internal(format!("failed to send email: {e}")))?;
            }
            #[cfg(any(test, feature = "test-helpers"))]
            Transport::Stub(transport) => {
                transport
                    .send(message)
                    .await
                    .map_err(|e| Error::internal(format!("failed to send email (stub): {e}")))?;
            }
        }

        Ok(())
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::email::config::SmtpConfig;
    use crate::email::source::TemplateSource;

    fn test_email_config(smtp: SmtpConfig) -> EmailConfig {
        EmailConfig {
            templates_path: "/tmp/nonexistent".into(),
            layouts_path: "/tmp/nonexistent".into(),
            default_from_name: "Test".into(),
            default_from_email: "test@example.com".into(),
            default_reply_to: None,
            default_locale: "en".into(),
            cache_templates: false,
            template_cache_size: 10,
            inline_css: true,
            smtp,
        }
    }

    #[test]
    fn build_smtp_transport_username_without_password() {
        let config = test_email_config(SmtpConfig {
            host: "localhost".into(),
            port: 25,
            username: Some("user".into()),
            password: None,
            security: SmtpSecurity::None,
        });
        let result = Mailer::build_smtp_transport(&config);
        assert!(result.is_err());
    }

    #[test]
    fn build_smtp_transport_password_without_username() {
        let config = test_email_config(SmtpConfig {
            host: "localhost".into(),
            port: 25,
            username: None,
            password: Some("pass".into()),
            security: SmtpSecurity::None,
        });
        let result = Mailer::build_smtp_transport(&config);
        assert!(result.is_err());
    }

    #[test]
    fn with_source_creates_mailer() {
        struct MockSource;
        impl TemplateSource for MockSource {
            fn load(&self, _name: &str, _locale: &str, _default_locale: &str) -> Result<String> {
                Ok("---\nsubject: Test\n---\nBody".into())
            }
        }

        let config = test_email_config(SmtpConfig {
            host: "localhost".into(),
            port: 25,
            username: None,
            password: None,
            security: SmtpSecurity::None,
        });
        let source: Arc<dyn TemplateSource> = Arc::new(MockSource);
        let mailer = Mailer::with_source(&config, source).unwrap();

        let email = SendEmail::new("any", "user@example.com");
        let rendered = mailer.render(&email).unwrap();
        assert_eq!(rendered.subject, "Test");
    }

    #[test]
    fn render_inlines_css_by_default() {
        struct Src;
        impl TemplateSource for Src {
            fn load(&self, _: &str, _: &str, _: &str) -> Result<String> {
                Ok("---\nsubject: T\n---\n# Heading".into())
            }
        }
        let config = test_email_config(SmtpConfig {
            host: "localhost".into(),
            port: 25,
            username: None,
            password: None,
            security: SmtpSecurity::None,
        });
        let mailer = Mailer::with_source(&config, Arc::new(Src)).unwrap();
        let rendered = mailer.render(&SendEmail::new("x", "a@b.c")).unwrap();
        // Style block retained (dark-mode lives there).
        assert!(rendered.html.contains("prefers-color-scheme: dark"));
        // Inliner ran: `-webkit-text-size-adjust` from the <style> block was
        // copied as an inline style attribute on elements it targets (e.g. <body>).
        // We detect this by looking for the property *outside* the <style> block —
        // i.e. in an inline style="" attribute.
        let style_end = rendered.html.find("</style>").expect("has <style>");
        let after_style = &rendered.html[style_end..];
        assert!(
            after_style.contains("-webkit-text-size-adjust"),
            "inliner should copy -webkit-text-size-adjust into inline style, got: {after_style:.500}"
        );
    }

    #[test]
    fn render_skips_inliner_when_disabled() {
        struct Src;
        impl TemplateSource for Src {
            fn load(&self, _: &str, _: &str, _: &str) -> Result<String> {
                Ok("---\nsubject: T\n---\nBody".into())
            }
        }
        let mut config = test_email_config(SmtpConfig {
            host: "localhost".into(),
            port: 25,
            username: None,
            password: None,
            security: SmtpSecurity::None,
        });
        config.inline_css = false;
        let mailer = Mailer::with_source(&config, Arc::new(Src)).unwrap();
        let rendered = mailer.render(&SendEmail::new("x", "a@b.c")).unwrap();
        assert!(!rendered.html.is_empty());
        assert!(rendered.html.contains("prefers-color-scheme: dark"));
        // Inliner was NOT run: -webkit-text-size-adjust appears ONLY inside <style>,
        // not in inline attributes anywhere past </style>.
        let style_end = rendered.html.find("</style>").expect("has <style>");
        let after_style = &rendered.html[style_end..];
        assert!(
            !after_style.contains("-webkit-text-size-adjust"),
            "inliner should not run when disabled, got: {after_style:.500}"
        );
    }
}