fmt

.gitignore

@@ -1,3 +1,3 @@
 Cargo.lock
 /target
-
+./ircart/

src/main.rs

@@ -1,13 +1,9 @@
-use tokio::io::{split, AsyncRead, AsyncWrite, AsyncReadExt, AsyncWriteExt, BufReader, AsyncBufReadExt};
+use colored::*;
-use tokio::net::TcpStream;
-use tokio_native_tls::native_tls::TlsConnector as NTlsConnector;
-use tokio_native_tls::TlsConnector;
-use tokio::sync::mpsc;
 use serde::Deserialize;
 use std::fs;
 use std::sync::atomic::{AtomicBool, Ordering};
-use colored::*;
+use tokio::io::{AsyncBufReadExt, AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt};
-use tokio_socks::tcp::Socks5Stream;
+use tokio::net::TcpStream;
 
 #[derive(Deserialize, Clone)]
 struct Config {
@@ -32,25 +28,25 @@ struct Config {
 }
 
 mod mods {
-    pub mod proxy;
+    pub mod ascii;
-    pub mod tls;
+    pub mod drugs;
     pub mod handler;
+    pub mod proxy;
     pub mod sasl;
     pub mod sed;
-    pub mod ascii;
+    pub mod tls;
     pub mod vomit;
-    pub mod drugs;
+    //    pub mod invade;
-//    pub mod invade;
 }
 
-use mods::proxy::proxy_exec;
-use mods::tls::tls_exec;
-use mods::handler::handler;
-use mods::sasl::{start_sasl_auth, handle_sasl_messages};
-use mods::sed::{SedCommand, MessageBuffer};
 use mods::ascii::handle_ascii_command;
-use mods::vomit::handle_vomit_command;
 use mods::drugs::Drugs;
+use mods::handler::handler;
+use mods::proxy::proxy_exec;
+use mods::sasl::{handle_sasl_messages, start_sasl_auth};
+use mods::sed::{MessageBuffer, SedCommand};
+use mods::tls::tls_exec;
+use mods::vomit::handle_vomit_command;
 //use mods::invade::{handle_invade_command};
 
 #[tokio::main(flavor = "multi_thread", worker_threads = 12)]
@@ -98,13 +94,15 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                 handler(tcp_stream, config).await.unwrap();
             }
             Ok::<(), Box<dyn std::error::Error + Send>>(())
-        }).await.unwrap();
+        })
+        .await
+        .unwrap();
 
         match connection_result {
             Ok(_) => {
                 println!("Connection established successfully!");
                 reconnect_attempts = 0;
-            },
+            }
             Err(e) => {
                 println!("Error handling connection: {}", e);
                 reconnect_attempts += 1;
@@ -122,14 +120,27 @@ fn loaded_config() -> Result<Config, Box<dyn std::error::Error>> {
     Ok(config)
 }
 
-async fn readmsg<S>(mut reader: tokio::io::ReadHalf<S>, tx: tokio::sync::mpsc::Sender<String>) where S: AsyncRead + Unpin {
+async fn readmsg<S>(mut reader: tokio::io::ReadHalf<S>, tx: tokio::sync::mpsc::Sender<String>)
+where
+    S: AsyncRead + Unpin,
+{
     let mut buf = vec![0; 4096];
     while let Ok(n) = reader.read(&mut buf).await {
-        if n == 0 { break; }
+        if n == 0 {
+            break;
+        }
         let msg_list = String::from_utf8_lossy(&buf[..n]).to_string();
         for lines in msg_list.lines() {
             let msg = lines.to_string();
-            println!("{}{}{} {}{} {}", "[".green().bold(), ">".yellow().bold(), "]".green().bold(), "DEBUG:".bold().yellow(), ":".bold().green(), msg.trim().purple());
+            println!(
+                "{}{}{} {}{} {}",
+                "[".green().bold(),
+                ">".yellow().bold(),
+                "]".green().bold(),
+                "DEBUG:".bold().yellow(),
+                ":".bold().green(),
+                msg.trim().purple()
+            );
             tx.send(msg).await.unwrap();
             if buf.len() == n {
                 buf.resize(buf.len() * 2, 0);
@@ -140,7 +151,14 @@ async fn readmsg<S>(mut reader: tokio::io::ReadHalf<S>, tx: tokio::sync::mpsc::S
 
 static SASL_AUTH: AtomicBool = AtomicBool::new(false);
 
-async fn writemsg<S>(mut writer: tokio::io::WriteHalf<S>, mut rx: tokio::sync::mpsc::Receiver<String>, config: &Config, mut message_buffer: MessageBuffer) where S: AsyncWrite + Unpin {
+async fn writemsg<S>(
+    mut writer: tokio::io::WriteHalf<S>,
+    mut rx: tokio::sync::mpsc::Receiver<String>,
+    config: &Config,
+    mut message_buffer: MessageBuffer,
+) where
+    S: AsyncWrite + Unpin,
+{
     let username = config.sasl_username.clone().unwrap();
     let password = config.sasl_password.clone().unwrap();
     let nickname = config.nickname.clone();
@@ -148,7 +166,9 @@ async fn writemsg<S>(mut writer: tokio::io::WriteHalf<S>, mut rx: tokio::sync::m
     if !password.is_empty() && !SASL_AUTH.load(Ordering::Relaxed) {
         let capabilities = config.capabilities.clone();
         println!("Starting SASL auth...");
-        start_sasl_auth(&mut writer, "PLAIN", &nickname, &realname, capabilities).await.unwrap();
+        start_sasl_auth(&mut writer, "PLAIN", &nickname, &realname, capabilities)
+            .await
+            .unwrap();
         writer.flush().await.unwrap();
         SASL_AUTH.store(true, Ordering::Relaxed);
     } else {
@@ -167,29 +187,51 @@ async fn writemsg<S>(mut writer: tokio::io::WriteHalf<S>, mut rx: tokio::sync::m
         let serv = parts.first().unwrap_or(&"");
         let cmd = parts.get(1).unwrap_or(&"");
 
-        println!("{} {} {} {} {}", "DEBUG:".bold().yellow(), "serv:".bold().green(), serv.purple(), "cmd:".bold().green(), cmd.purple());
+        println!(
+            "{} {} {} {} {}",
+            "DEBUG:".bold().yellow(),
+            "serv:".bold().green(),
+            serv.purple(),
+            "cmd:".bold().green(),
+            cmd.purple()
+        );
         if *serv == "PING" {
             let response = msg.replace("PING", "PONG") + "\r\n";
-            println!("{} {} {}","[%] PONG:".bold().green(), nickname.blue(), response.purple());
+            println!(
+                "{} {} {}",
+                "[%] PONG:".bold().green(),
+                nickname.blue(),
+                response.purple()
+            );
             writer.write_all(response.as_bytes()).await.unwrap();
             writer.flush().await.unwrap();
             continue;
         }
-        if (*cmd == "CAP" || msg.starts_with("AUTHENTICATE +") || *cmd == "903") && SASL_AUTH.load(Ordering::Relaxed) {
+        if (*cmd == "CAP" || msg.starts_with("AUTHENTICATE +") || *cmd == "903")
+            && SASL_AUTH.load(Ordering::Relaxed)
+        {
             println!("Handling SASL messages...");
-            handle_sasl_messages(&mut writer, msg.trim(), &username, &password, &nickname).await.unwrap();
+            handle_sasl_messages(&mut writer, msg.trim(), &username, &password, &nickname)
+                .await
+                .unwrap();
             writer.flush().await.unwrap();
         }
         if *cmd == "001" {
             println!("Setting mode");
-            writer.write_all(format!("MODE {} +B\r\n", nickname).as_bytes()).await.unwrap();
+            writer
+                .write_all(format!("MODE {} +B\r\n", nickname).as_bytes())
+                .await
+                .unwrap();
             writer.flush().await.unwrap();
         }
 
         if *cmd == "376" {
             println!("Joining channels");
             for channel in &config.channels {
-                writer.write_all(format!("JOIN {}\r\n", channel).as_bytes()).await.unwrap();
+                writer
+                    .write_all(format!("JOIN {}\r\n", channel).as_bytes())
+                    .await
+                    .unwrap();
                 writer.flush().await.unwrap();
             }
         }
@@ -197,13 +239,17 @@ async fn writemsg<S>(mut writer: tokio::io::WriteHalf<S>, mut rx: tokio::sync::m
             let channel = parts.get(2).unwrap_or(&"");
             let userme = parts.get(3).unwrap_or(&"");
             if *userme == nickname {
-                writer.write_all(format!("JOIN {}\r\n", channel).as_bytes()).await.unwrap();
+                writer
+                    .write_all(format!("JOIN {}\r\n", channel).as_bytes())
+                    .await
+                    .unwrap();
                 writer.flush().await.unwrap();
             }
         }
         if *cmd == "PRIVMSG" {
             let channel = &parts.get(2).to_owned().unwrap_or(&"");
-            let user = parts[0].strip_prefix(':')
+            let user = parts[0]
+                .strip_prefix(':')
                 .and_then(|user_with_host| user_with_host.split('!').next())
                 .unwrap_or("unknown_user");
             let host = parts[0].split('@').nth(1).unwrap_or("unknown_host");
@@ -218,12 +264,26 @@ async fn writemsg<S>(mut writer: tokio::io::WriteHalf<S>, mut rx: tokio::sync::m
             } else {
                 "".to_string()
             };
-            println!("{} {} {} {} {} {} {} {} {}", "DEBUG:".bold().yellow(), "channel:".bold().green(), channel.purple(), "user:".bold().green(), user.purple(), "host:".bold().green(), host.purple(), "msg:".bold().green(), msg_content.yellow());
+            println!(
+                "{} {} {} {} {} {} {} {} {}",
+                "DEBUG:".bold().yellow(),
+                "channel:".bold().green(),
+                channel.purple(),
+                "user:".bold().green(),
+                user.purple(),
+                "host:".bold().green(),
+                host.purple(),
+                "msg:".bold().green(),
+                msg_content.yellow()
+            );
 
             if msg_content.starts_with("s/") {
                 if let Some(sed_command) = SedCommand::parse(&msg_content.clone()) {
                     if let Some(response) = message_buffer.apply_sed_command(&sed_command) {
-                        writer.write_all(format!("PRIVMSG {} :{}\r\n", channel, response).as_bytes()).await.unwrap();
+                        writer
+                            .write_all(format!("PRIVMSG {} :{}\r\n", channel, response).as_bytes())
+                            .await
+                            .unwrap();
                         writer.flush().await.unwrap();
                     }
                 }
@@ -239,20 +299,33 @@ async fn writemsg<S>(mut writer: tokio::io::WriteHalf<S>, mut rx: tokio::sync::m
                 let _ = handle_vomit_command(&mut writer, config, &msg_content, channel).await;
             }
 
-            if ["%chug", "%smoke", "%toke", "%100", "%extendo", "%fatfuck", "%beer"].iter().any(|&prefix| msg_content.starts_with(prefix)) {
+            if [
-                drugs.handle_drugs_command(&mut writer, config, &msg_content, channel).await
+                "%chug", "%smoke", "%toke", "%100", "%extendo", "%fatfuck", "%beer",
+            ]
+            .iter()
+            .any(|&prefix| msg_content.starts_with(prefix))
+            {
+                drugs
+                    .handle_drugs_command(&mut writer, config, &msg_content, channel)
+                    .await
                     .unwrap_or_else(|e| eprintln!("Error handling drugs command: {}", e));
             }
-
         }
     }
 }
 
-async fn nickme<W: tokio::io::AsyncWriteExt + Unpin>(writer: &mut W, nickname: &str, realname: &str) -> Result<(), Box<dyn std::error::Error>> {
+async fn nickme<W: tokio::io::AsyncWriteExt + Unpin>(
-    writer.write_all(format!("NICK {}\r\n", nickname).as_bytes()).await?;
+    writer: &mut W,
+    nickname: &str,
+    realname: &str,
+) -> Result<(), Box<dyn std::error::Error>> {
+    writer
+        .write_all(format!("NICK {}\r\n", nickname).as_bytes())
+        .await?;
     writer.flush().await?;
-    writer.write_all(format!("USER {} 0 * :{}\r\n", nickname, realname).as_bytes()).await?;
+    writer
+        .write_all(format!("USER {} 0 * :{}\r\n", nickname, realname).as_bytes())
+        .await?;
     writer.flush().await?;
     Ok(())
 }
-

src/mods/ascii.rs

@@ -1,15 +1,21 @@
-use tokio::io::{AsyncWriteExt, BufReader};
+// mods/ascii.rs
-use tokio::fs::File;
-use tokio::time::{self, Duration};
-use std::fs;
-use rand::Rng;
-use tokio::io::AsyncBufReadExt;
-use std::error::Error;
 use crate::Config;
+use rand::Rng;
+use std::error::Error;
+use std::fs;
+use tokio::fs::File;
+use tokio::io::AsyncBufReadExt;
+use tokio::io::{AsyncWriteExt, BufReader};
+use tokio::time::{self, Duration};
 
 const CHUNK_SIZE: usize = 4096;
 
-async fn send_ansi_art<W: AsyncWriteExt + Unpin>(writer: &mut W, file_path: &str, pump_delay: u64, channel: &str) -> Result<(), Box<dyn Error>> {
+async fn send_ansi_art<W: AsyncWriteExt + Unpin>(
+    writer: &mut W,
+    file_path: &str,
+    pump_delay: u64,
+    channel: &str,
+) -> Result<(), Box<dyn Error>> {
     let file = File::open(file_path).await?;
     let reader = BufReader::new(file);
     let mut lines = reader.lines();
@@ -20,7 +26,7 @@ async fn send_ansi_art<W: AsyncWriteExt + Unpin>(writer: &mut W, file_path: &str
         line_count += 1;
     }
     let mut pump_delay = Duration::from_millis(pump_delay);
-    if line_count > 500 && pump_delay < Duration::from_millis(100){
+    if line_count > 500 && pump_delay < Duration::from_millis(100) {
         pump_delay = Duration::from_millis(100);
     }
     let file = File::open(file_path).await?;
@@ -28,16 +34,25 @@ async fn send_ansi_art<W: AsyncWriteExt + Unpin>(writer: &mut W, file_path: &str
     let mut lines = reader.lines();
 
     while let Some(line) = lines.next_line().await? {
-
         if line.len() > CHUNK_SIZE {
             for chunk in line.as_bytes().chunks(CHUNK_SIZE) {
-                writer.write_all(format!("PRIVMSG {} :{}\r\n", channel, String::from_utf8_lossy(chunk)).as_bytes()).await?;
+                writer
+                    .write_all(
+                        format!(
+                            "PRIVMSG {} :{}\r\n",
+                            channel,
+                            String::from_utf8_lossy(chunk)
+                        )
+                        .as_bytes(),
+                    )
+                    .await?;
                 writer.flush().await?;
                 time::sleep(pump_delay).await;
             }
         } else {
-
+            writer
-            writer.write_all(format!("PRIVMSG {} :{}\r\n", channel, line).as_bytes()).await?;
+                .write_all(format!("PRIVMSG {} :{}\r\n", channel, line).as_bytes())
+                .await?;
             writer.flush().await?;
             time::sleep(pump_delay).await;
         }
@@ -46,14 +61,17 @@ async fn send_ansi_art<W: AsyncWriteExt + Unpin>(writer: &mut W, file_path: &str
 }
 
 fn select_random_file(dir: &str) -> Option<String> {
-    let files = fs::read_dir(dir).ok()?.filter_map(|entry| {
+    let files = fs::read_dir(dir)
+        .ok()?
+        .filter_map(|entry| {
             let path = entry.ok()?.path();
             if path.is_file() {
                 path.to_str().map(ToString::to_string)
             } else {
                 None
             }
-    }).collect::<Vec<String>>();
+        })
+        .collect::<Vec<String>>();
 
     if files.is_empty() {
         None
@@ -75,7 +93,7 @@ pub async fn handle_ascii_command<W: AsyncWriteExt + Unpin>(
 
     if *command_type == "random" && parts.len() == 2 {
         handle_random(writer, config, channel).await?;
-    } else if *command_type == "list"{
+    } else if *command_type == "list" {
         handle_list(writer, config, channel, Some(parts.get(2).unwrap_or(&""))).await?;
     } else {
         handle_specific_file(writer, config, channel, &parts).await?;
@@ -93,7 +111,9 @@ async fn handle_random<W: AsyncWriteExt + Unpin>(
         if let Some(random_file) = select_random_file(dir) {
             send_ansi_art(writer, &random_file, config.pump_delay, channel).await?;
         } else {
-            writer.write_all(format!("PRIVMSG {} :No files found\r\n", channel).as_bytes()).await?;
+            writer
+                .write_all(format!("PRIVMSG {} :No files found\r\n", channel).as_bytes())
+                .await?;
         }
     }
     Ok(())
@@ -103,9 +123,12 @@ async fn handle_list<W: AsyncWriteExt + Unpin>(
     writer: &mut W,
     config: &Config,
     channel: &str,
-    parts: Option<&str>
+    parts: Option<&str>,
 ) -> Result<(), Box<dyn Error>> {
-    let base_dir = config.ascii_art.clone().unwrap_or_else(|| "ascii_art".to_string());
+    let base_dir = config
+        .ascii_art
+        .clone()
+        .unwrap_or_else(|| "ascii_art".to_string());
 
     let dir = if let Some(subdir) = parts {
         format!("{}/{}", base_dir, subdir)
@@ -118,20 +141,31 @@ async fn handle_list<W: AsyncWriteExt + Unpin>(
         .filter_map(|entry| entry.ok())
         .map(|entry| {
             let path = entry.path();
-            let display_name = path.file_name().unwrap_or_default().to_string_lossy().into_owned();
+            let display_name = path
+                .file_name()
+                .unwrap_or_default()
+                .to_string_lossy()
+                .into_owned();
             if path.is_dir() {
                 format!("{}/", display_name)
             } else {
-                display_name.strip_suffix(".txt").unwrap_or(&display_name).to_string()
+                display_name
+                    .strip_suffix(".txt")
+                    .unwrap_or(&display_name)
+                    .to_string()
             }
         })
         .collect::<Vec<String>>()
         .join(", ");
 
     if entries.is_empty() {
-        writer.write_all(format!("PRIVMSG {} :No files or directories found\r\n", channel).as_bytes()).await?;
+        writer
+            .write_all(format!("PRIVMSG {} :No files or directories found\r\n", channel).as_bytes())
+            .await?;
     } else {
-        writer.write_all(format!("PRIVMSG {} :{}\r\n", channel, entries).as_bytes()).await?;
+        writer
+            .write_all(format!("PRIVMSG {} :{}\r\n", channel, entries).as_bytes())
+            .await?;
     }
 
     Ok(())
@@ -151,10 +185,15 @@ async fn handle_specific_file<W: AsyncWriteExt + Unpin>(
     };
     println!("{:?}", file_name);
 
-    let file_path = format!("{}/{}.txt", config.ascii_art.clone().unwrap_or_else(|| "ascii_art".to_string()), file_name);
+    let file_path = format!(
+        "{}/{}.txt",
+        config
+            .ascii_art
+            .clone()
+            .unwrap_or_else(|| "ascii_art".to_string()),
+        file_name
+    );
     println!("{:?}", file_path);
 
     send_ansi_art(writer, &file_path, config.pump_delay, channel).await
 }
-
-

src/mods/drugs.rs

@@ -1,8 +1,8 @@
-use tokio::io::AsyncWriteExt;
+use crate::Config;
 use rand::prelude::*;
 use std::sync::Arc;
+use tokio::io::AsyncWriteExt;
 use tokio::sync::Mutex;
-use crate::Config;
 
 pub struct Drugs {
     pub fat: bool,
@@ -66,8 +66,16 @@ impl Drugs {
         let cigarette = Self::color(&"|".repeat(size), "15", Some("00")); // light_grey on white
         let cherry = format!(
             "{}{}",
-            Self::color("\u{259A}", Self::random_choice(&["04", "08", "07"]), Some("01")), // random color on black
+            Self::color(
-            Self::color("\u{259A}", Self::random_choice(&["04", "08", "07"]), Some("14")), // random color on grey
+                "\u{259A}",
+                Self::random_choice(&["04", "08", "07"]),
+                Some("01")
+            ), // random color on black
+            Self::color(
+                "\u{259A}",
+                Self::random_choice(&["04", "08", "07"]),
+                Some("14")
+            ), // random color on grey
         );
         let smoke_chars = ";:-.,_`~'";
         let smoke = Self::color(
@@ -87,8 +95,16 @@ impl Drugs {
         let joint = Self::color(&"/".repeat(size), "15", Some("00")); // light_grey on white
         let cherry = format!(
             "{}{}",
-            Self::color("\u{259A}", Self::random_choice(&["04", "08", "07"]), Some("01")), // random color on black
+            Self::color(
-            Self::color("\u{259A}", Self::random_choice(&["04", "08", "07"]), Some("14")), // random color on grey
+                "\u{259A}",
+                Self::random_choice(&["04", "08", "07"]),
+                Some("01")
+            ), // random color on black
+            Self::color(
+                "\u{259A}",
+                Self::random_choice(&["04", "08", "07"]),
+                Some("14")
+            ), // random color on grey
         );
         let smoke_chars = ";:-.,_`~'";
         let smoke = Self::color(
@@ -182,7 +198,9 @@ impl Drugs {
                     if self.fat {
                         for _ in 0..3 {
                             writer
-                                .write_all(format!("PRIVMSG {} :{}\r\n", channel, object).as_bytes())
+                                .write_all(
+                                    format!("PRIVMSG {} :{}\r\n", channel, object).as_bytes(),
+                                )
                                 .await?;
                         }
                     } else {
@@ -293,8 +311,14 @@ impl Drugs {
     }
 
     fn generate_beer(&self) -> (String, String) {
-        let beer_choice = ["bud", "modelo", "ultra"].choose(&mut thread_rng()).unwrap().to_string();
+        let beer_choice = ["bud", "modelo", "ultra"]
-        let beer_temp = ["a piss warm", "an ice cold", "an empty"].choose(&mut thread_rng()).unwrap().to_string();
+            .choose(&mut thread_rng())
+            .unwrap()
+            .to_string();
+        let beer_temp = ["a piss warm", "an ice cold", "an empty"]
+            .choose(&mut thread_rng())
+            .unwrap()
+            .to_string();
         (beer_choice, beer_temp)
     }
 
@@ -303,7 +327,11 @@ impl Drugs {
             "bud" => format!(
                 "{}{}{}",
                 Self::color(" ", "00", Some("00")),
-                Self::color(" BUD ", "00", Some(["02", "05"].choose(&mut thread_rng()).unwrap())),
+                Self::color(
+                    " BUD ",
+                    "00",
+                    Some(["02", "05"].choose(&mut thread_rng()).unwrap())
+                ),
                 Self::color("c", "14", Some("00"))
             ),
             "modelo" => format!(

src/mods/handler.rs

@@ -1,10 +1,13 @@
 // mods/handler.rs
-use tokio::io::{AsyncRead, AsyncWrite, split};
+use crate::{readmsg, writemsg, Config, MessageBuffer};
+use tokio::io::{split, AsyncRead, AsyncWrite};
 use tokio::sync::mpsc;
-use crate::{Config, readmsg, writemsg, MessageBuffer};
 
 /// Handle the connection to the server
-pub async fn handler<S>(stream: S, config: Config) -> Result<(), Box<dyn std::error::Error>> where S: AsyncRead + AsyncWrite + Unpin + Send + 'static {
+pub async fn handler<S>(stream: S, config: Config) -> Result<(), Box<dyn std::error::Error>>
+where
+    S: AsyncRead + AsyncWrite + Unpin + Send + 'static,
+{
     let (reader, writer) = split(stream);
     let (tx, rx) = mpsc::channel(1000);
 
@@ -19,6 +22,7 @@ pub async fn handler<S>(stream: S, config: Config) -> Result<(), Box<dyn std::er
     });
 
     //let _ = tokio::try_join!(read_task, write_task);
-    tokio::try_join!(read_task, write_task).map_err(|e| Box::new(e) as Box<dyn std::error::Error>)?;
+    tokio::try_join!(read_task, write_task)
+        .map_err(|e| Box::new(e) as Box<dyn std::error::Error>)?;
     Ok(())
 }

src/mods/proxy.rs

@@ -1,7 +1,7 @@
 // mods/proxy.rs
+use crate::Config;
 use tokio::net::TcpStream;
 use tokio_socks::tcp::Socks5Stream;
-use crate::Config;
 
 /// Establish a connection to the proxy
 pub async fn proxy_exec(config: &Config) -> Result<TcpStream, Box<dyn std::error::Error + Send>> {
@@ -16,11 +16,13 @@ pub async fn proxy_exec(config: &Config) -> Result<TcpStream, Box<dyn std::error
     let username = config.proxy_username.clone().unwrap();
     let password = config.proxy_password.clone().unwrap();
     let tcp_stream = if !&username.is_empty() && !password.is_empty() {
-        let tcp_stream = Socks5Stream::connect_with_password_and_socket(proxy_stream, server, &username, &password).await.unwrap();
+        Socks5Stream::connect_with_password_and_socket(proxy_stream, server, &username, &password)
-        tcp_stream
+            .await
+            .unwrap()
     } else {
-        let tcp_stream = Socks5Stream::connect_with_socket(proxy_stream, server).await.unwrap();
+        Socks5Stream::connect_with_socket(proxy_stream, server)
-        tcp_stream
+            .await
+            .unwrap()
     };
     let tcp_stream = tcp_stream.into_inner();
 

src/mods/sasl.rs

@@ -6,7 +6,8 @@ pub async fn start_sasl_auth<W: tokio::io::AsyncWriteExt + Unpin>(
     mechanism: &str,
     nickname: &str,
     realname: &str,
-    capabilities: Option<Vec<String>>) -> Result<(), Box<dyn std::error::Error>> {
+    capabilities: Option<Vec<String>>,
+) -> Result<(), Box<dyn std::error::Error>> {
     writer.write_all(b"CAP LS 302\r\n").await?;
 
     nickme(writer, nickname, realname).await?;
@@ -36,7 +37,9 @@ pub async fn handle_sasl_messages<W: tokio::io::AsyncWriteExt + Unpin>(
     } else if message.starts_with("AUTHENTICATE +") {
         let auth_string = format!("\0{}\0{}", username, password);
         let encoded = base64::engine::general_purpose::STANDARD.encode(auth_string);
-        writer.write_all(format!("AUTHENTICATE {}\r\n", encoded).as_bytes()).await?;
+        writer
+            .write_all(format!("AUTHENTICATE {}\r\n", encoded).as_bytes())
+            .await?;
     } else if message.contains("903 * :SASL authentication successful") {
         writer.write_all(b"CAP END\r\n").await?;
     }

src/mods/sed.rs

@@ -1,3 +1,4 @@
+// mods/sed.rs
 use regex::Regex;
 use std::collections::VecDeque;
 
@@ -30,9 +31,13 @@ impl SedCommand {
 
     pub fn apply_to(&self, message: &str) -> String {
         if self.global {
-            self.pattern.replace_all(message, self.replacement.as_str()).to_string()
+            self.pattern
+                .replace_all(message, self.replacement.as_str())
+                .to_string()
         } else {
-            self.pattern.replace(message, self.replacement.as_str()).to_string()
+            self.pattern
+                .replace(message, self.replacement.as_str())
+                .to_string()
         }
     }
 }
@@ -67,4 +72,3 @@ impl MessageBuffer {
         None
     }
 }
-

src/mods/tls.rs

@@ -1,12 +1,20 @@
 // mods/tls.rs
-use tokio::net::TcpStream;
-use tokio_native_tls::{TlsConnector, native_tls::TlsConnector as NTlsConnector};
 use crate::Config;
+use tokio::net::TcpStream;
+use tokio_native_tls::{native_tls::TlsConnector as NTlsConnector, TlsConnector};
 
 // Establish a TLS connection to the server
-pub async fn tls_exec(config: &Config, tcp_stream: TcpStream) -> Result<tokio_native_tls::TlsStream<TcpStream>, Box<dyn std::error::Error + Send>> {
+pub async fn tls_exec(
-    let tls_builder = NTlsConnector::builder().danger_accept_invalid_certs(true).build().unwrap();
+    config: &Config,
+    tcp_stream: TcpStream,
+) -> Result<tokio_native_tls::TlsStream<TcpStream>, Box<dyn std::error::Error + Send>> {
+    let tls_builder = NTlsConnector::builder()
+        .danger_accept_invalid_certs(true)
+        .build()
+        .unwrap();
     let tls_connector = TlsConnector::from(tls_builder);
-    Ok(tls_connector.connect(&config.server, tcp_stream).await.unwrap())
+    Ok(tls_connector
-
+        .connect(&config.server, tcp_stream)
+        .await
+        .unwrap())
 }

src/mods/vomit.rs

@@ -1,8 +1,8 @@
-
+// mods/vomit.rs
+use crate::Config;
 use rand::prelude::*;
 use tokio::io::AsyncWriteExt;
 use tokio::time;
-use crate::Config;
 
 async fn generate_random_unicode() -> char {
     let codepoint: u32 = thread_rng().gen_range(0..=0x10FFFF);
@@ -52,7 +52,6 @@ fn split_into_chunks(s: &str, max_chunk_size: usize) -> Vec<String> {
     chunks
 }
 
-
 const CHUNK_SIZE: usize = 400;
 // Function to handle the vomit command
 pub async fn handle_vomit_command<W: AsyncWriteExt + Unpin>(
@@ -68,7 +67,9 @@ pub async fn handle_vomit_command<W: AsyncWriteExt + Unpin>(
     let chunks = split_into_chunks(&vomit, CHUNK_SIZE); // Adjust if split_into_chunks is async
 
     for chunk in chunks {
-        writer.write_all(format!("PRIVMSG {} :{}\r\n", channel, chunk).as_bytes()).await?;
+        writer
+            .write_all(format!("PRIVMSG {} :{}\r\n", channel, chunk).as_bytes())
+            .await?;
         writer.flush().await?;
         time::sleep(tokio::time::Duration::from_secs(config.pump_delay)).await;
     }