From 942546d579be76068a7811e77f12c3f72cd3bcd0 Mon Sep 17 00:00:00 2001 From: homycdev Date: Sun, 5 May 2024 19:30:47 +0300 Subject: [PATCH] mr comments fix --- crates/projection-irc/src/lib.rs | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/crates/projection-irc/src/lib.rs b/crates/projection-irc/src/lib.rs index 7a2ec63..a18e5fc 100644 --- a/crates/projection-irc/src/lib.rs +++ b/crates/projection-irc/src/lib.rs @@ -81,7 +81,7 @@ async fn handle_socket( match registered_user { Ok(user) => { log::debug!("User registered"); - handle_registered_socket(config, core.players, core.rooms, &mut reader, &mut writer, user, &mut storage).await?; + handle_registered_socket(config, core.players, core.rooms, &mut reader, &mut writer, user).await?; } Err(err) => { log::debug!("Registration failed: {err}"); @@ -425,7 +425,6 @@ async fn handle_registered_socket<'a>( reader: &mut BufReader>, writer: &mut BufWriter>, user: RegisteredUser, - storage: &mut Storage, ) -> Result<()> { let mut buffer = vec![]; log::info!("Handling registered user: {user:?}"); @@ -505,7 +504,7 @@ async fn handle_registered_socket<'a>( len }; let incoming = std::str::from_utf8(&buffer[0..len-2])?; - if let HandleResult::Leave = handle_incoming_message(incoming, &config, &user, &rooms, &mut connection, writer, storage.clone()).await? { + if let HandleResult::Leave = handle_incoming_message(incoming, &config, &user, &rooms, &mut connection, writer).await? { break; } buffer.clear(); @@ -697,7 +696,6 @@ async fn handle_incoming_message( rooms: &RoomRegistry, user_handle: &mut PlayerConnection, writer: &mut (impl AsyncWrite + Unpin), - mut storage: Storage, ) -> Result { log::debug!("Incoming raw IRC message: '{buffer}'"); let parsed = client_message(buffer);