From 38e3b847f5f3e1bd40fa6261c3b313f4bab7af85 Mon Sep 17 00:00:00 2001 From: pennae Date: Mon, 25 Jul 2022 20:36:15 +0200 Subject: add support for smtp authentication --- src/lib.rs | 8 +++++++- src/mailer.rs | 27 +++++++++++++++++---------- 2 files changed, 24 insertions(+), 11 deletions(-) (limited to 'src') diff --git a/src/lib.rs b/src/lib.rs index d783c6d..c739b19 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -7,7 +7,7 @@ use std::{ use anyhow::Context; use db::Db; use futures::Future; -use lettre::message::Mailbox; +use lettre::{message::Mailbox, transport::smtp::authentication::Credentials}; use mailer::Mailer; use push::PushClient; use rocket::{ @@ -71,6 +71,8 @@ struct Config { mail_from: Mailbox, mail_host: Option, mail_port: Option, + mail_user: Option, + mail_password: Option, #[serde(default)] mail_starttls: bool, @@ -253,6 +255,10 @@ pub async fn build( config.mail_host.as_deref().unwrap_or("localhost"), config.mail_port.unwrap_or(25), config.mail_starttls, + match (config.mail_user.clone(), config.mail_password.clone()) { + (Some(user), Some(pw)) => Some(Credentials::new(user, pw)), + _ => None, + }, config.location.clone(), ) .context("setting up mail notifications")?, diff --git a/src/mailer.rs b/src/mailer.rs index 7f7ad9f..8e48db0 100644 --- a/src/mailer.rs +++ b/src/mailer.rs @@ -2,7 +2,10 @@ use std::time::Duration; use lettre::{ message::Mailbox, - transport::smtp::client::{Tls, TlsParameters}, + transport::smtp::{ + authentication::Credentials, + client::{Tls, TlsParameters}, + }, AsyncSmtpTransport, Message, Tokio1Executor, }; use rocket::http::uri::Absolute; @@ -22,20 +25,24 @@ impl Mailer { host: &str, port: u16, starttls: bool, + credentials: Option, verify_base: Absolute<'static>, ) -> anyhow::Result { + let transport = AsyncSmtpTransport::::builder_dangerous(host) + .port(port) + .tls(if starttls { + Tls::Required(TlsParameters::new(host.to_string())?) + } else { + Tls::None + }) + .timeout(Some(Duration::from_secs(5))); Ok(Mailer { from, verify_base, - transport: AsyncSmtpTransport::::builder_dangerous(host) - .port(port) - .tls(if starttls { - Tls::Required(TlsParameters::new(host.to_string())?) - } else { - Tls::None - }) - .timeout(Some(Duration::from_secs(5))) - .build(), + transport: match credentials { + None => transport.build(), + Some(c) => transport.credentials(c).build(), + }, }) } -- cgit v1.2.3