From: Ruben Beltran del Rio Date: Sat, 25 Jan 2025 10:02:47 +0000 (+0100) Subject: Address more clippy X-Git-Tag: 1.0.0~6 X-Git-Url: https://git.r.bdr.sh/rbdr/olden-mail/commitdiff_plain/494920f168bccf5e4dd0b38d9d19c0f5e25c127c?ds=sidebyside;hp=2fdda21d13ed742bdb52ec3ba74538af83de2bf4 Address more clippy --- diff --git a/src/configuration.rs b/src/configuration.rs index 49cd991..bd0a17f 100644 --- a/src/configuration.rs +++ b/src/configuration.rs @@ -9,7 +9,7 @@ use std::sync::Arc; use thiserror::Error; #[derive(Error, Debug)] -pub enum ConfigurationError { +pub enum Error { #[error("Environment variable {0} not set.")] MissingEnvVar(String), #[error("Failed to parse {0}.")] @@ -35,7 +35,7 @@ pub struct Configuration { impl Configuration { /// Creates a new configuration object by reading the environment /// variables. Exits if the right ones aren't found. - pub fn new() -> Result { + pub fn new() -> Result { Ok(Configuration { imap_configuration: Arc::new(Proxy { local_port: get_env_number("LOCAL_IMAP_PORT", 143)?, @@ -56,23 +56,23 @@ impl Configuration { } /// Get an environment variable or return an error. -fn get_env_var(name: &str, default: Option) -> Result { +fn get_env_var(name: &str, default: Option) -> Result { match env::var(name) { Ok(value) => Ok(value), Err(_) => match default { Some(default_value) => Ok(default_value), - None => Err(ConfigurationError::MissingEnvVar(name.to_string())), + None => Err(Error::MissingEnvVar(name.to_string())), }, } } /// Get an environment variable and parse it as a number. Return a default /// if not set. -fn get_env_number(name: &str, default: u16) -> Result { +fn get_env_number(name: &str, default: u16) -> Result { match env::var(name) { Ok(value) => value .parse() - .map_err(|_| ConfigurationError::ParseError(name.to_string())), + .map_err(|_| Error::ParseError(name.to_string())), Err(_) => Ok(default), } } diff --git a/src/proxy.rs b/src/proxy.rs index a2f62e4..8348325 100644 --- a/src/proxy.rs +++ b/src/proxy.rs @@ -72,7 +72,7 @@ impl Server { let running_clone = Arc::clone(&running); let thread_handle = spawn(move || { - run_proxy(configuration, running_clone); + run_proxy(&configuration, &running_clone); }); Server { @@ -93,7 +93,7 @@ impl Server { /// The main loop that listens for incoming (plaintext) connections on /// `configuration.bind_address:configuration.local_port`. -fn run_proxy(configuration: Arc, running: Arc) { +fn run_proxy(configuration: &Arc, running: &Arc) { let listener = match TcpListener::bind(format!( "{}:{}", configuration.bind_address, configuration.local_port @@ -121,7 +121,7 @@ fn run_proxy(configuration: Arc, running: Arc) { let configuration_clone = Arc::clone(&configuration); let handle = spawn(move || { - handle_client(stream, configuration_clone); + handle_client(stream, &configuration_clone); }); active_threads.push(handle); } @@ -152,7 +152,7 @@ fn run_proxy(configuration: Arc, running: Arc) { } /// Handles a single client connection by bridging it (plaintext) to a TLS connection. -fn handle_client(client_stream: TcpStream, configuration: Arc) { +fn handle_client(client_stream: TcpStream, configuration: &Arc) { if let Err(e) = client_stream.set_nonblocking(true) { error!("Failed to set client stream to nonblocking: {}", e); return;