From ec397fc9ad71e3249b066ba606058f5f59080fc5 Mon Sep 17 00:00:00 2001 From: ghassmo Date: Fri, 17 Jun 2022 02:57:47 +0300 Subject: [PATCH] bin/ircd: clean up functions parameters --- bin/ircd/src/main.rs | 14 +++++++++----- bin/ircd/src/server.rs | 14 +++++++++----- 2 files changed, 18 insertions(+), 10 deletions(-) diff --git a/bin/ircd/src/main.rs b/bin/ircd/src/main.rs index b6fd738e7..e6c2c53ab 100644 --- a/bin/ircd/src/main.rs +++ b/bin/ircd/src/main.rs @@ -81,13 +81,17 @@ async fn broadcast_msg( } async fn process( - p2p_receiver: Receiver, + // server stream: TcpStream, peer_addr: SocketAddr, - p2p: net::P2pPtr, + // msg ids seen_msg_ids: SeenMsgIds, + // channels autojoin_chans: Vec, configured_chans: FxHashMap, + // p2p + p2p: net::P2pPtr, + p2p_receiver: Receiver, ) -> Result<()> { let (reader, writer) = stream.split(); @@ -95,9 +99,9 @@ async fn process( let mut conn = IrcServerConnection::new( writer, seen_msg_ids.clone(), - p2p.clone(), autojoin_chans, configured_chans, + p2p.clone(), ); loop { @@ -211,13 +215,13 @@ async fn realmain(settings: Args, executor: Arc>) -> Result<()> { executor_cloned .spawn(process( - p2p_recv_channel.clone(), stream, peer_addr, - p2p.clone(), seen_msg_ids.clone(), settings.autojoin.clone(), configured_chans.clone(), + p2p.clone(), + p2p_recv_channel.clone(), )) .detach(); } diff --git a/bin/ircd/src/server.rs b/bin/ircd/src/server.rs index 0c53d59c1..4225fd7e7 100644 --- a/bin/ircd/src/server.rs +++ b/bin/ircd/src/server.rs @@ -18,35 +18,39 @@ const RPL_NOTOPIC: u32 = 331; const RPL_TOPIC: u32 = 332; pub struct IrcServerConnection { + // server stream write_stream: WriteHalf, + // msg ids + seen_msg_ids: SeenMsgIds, + // user & channels is_nick_init: bool, is_user_init: bool, is_registered: bool, nickname: String, - seen_msg_ids: SeenMsgIds, - p2p: P2pPtr, auto_channels: Vec, pub configured_chans: FxHashMap, + // p2p + p2p: P2pPtr, } impl IrcServerConnection { pub fn new( write_stream: WriteHalf, seen_msg_ids: SeenMsgIds, - p2p: P2pPtr, auto_channels: Vec, configured_chans: FxHashMap, + p2p: P2pPtr, ) -> Self { Self { write_stream, + seen_msg_ids, is_nick_init: false, is_user_init: false, is_registered: false, nickname: "anon".to_string(), - seen_msg_ids, - p2p, auto_channels, configured_chans, + p2p, } }