From 25940439d0cb1f77a1458bbc25fca08985a027e4 Mon Sep 17 00:00:00 2001 From: Titouan Rigoudy Date: Sun, 21 Feb 2016 18:44:35 +0100 Subject: [PATCH] Sort response structs by alphabetical order. --- src/proto/server.rs | 202 ++++++++++++++++++++++---------------------- 1 file changed, 101 insertions(+), 101 deletions(-) diff --git a/src/proto/server.rs b/src/proto/server.rs index aee2df1..17af646 100644 --- a/src/proto/server.rs +++ b/src/proto/server.rs @@ -67,16 +67,16 @@ impl ServerResponse { pub fn from_packet(mut packet: Packet) -> io::Result { let code = try!(packet.read_uint()); let resp = match code { - CODE_LOGIN => - ServerResponse::LoginResponse( - try!(LoginResponse::from_packet(&mut packet)) - ), - CODE_CONNECT_TO_PEER => ServerResponse::ConnectToPeerResponse( try!(ConnectToPeerResponse::from_packet(&mut packet)) ), + CODE_LOGIN => + ServerResponse::LoginResponse( + try!(LoginResponse::from_packet(&mut packet)) + ), + CODE_PRIVILEGED_USERS => ServerResponse::PrivilegedUsersResponse( try!(PrivilegedUsersResponse::from_packet(&mut packet)) @@ -119,6 +119,47 @@ fn md5_str(string: &str) -> String { hasher.result_str() } +/*=================* + * CONNECT TO PEER * + *=================*/ + +#[derive(Debug)] +pub struct ConnectToPeerResponse { + pub username: String, + pub connection_type: String, + pub ip: net::Ipv4Addr, + pub port: u16, + pub token: u32, + pub is_privileged: bool, +} + +impl ConnectToPeerResponse { + fn from_packet(packet: &mut Packet) -> io::Result { + let username = try!(packet.read_str()); + let connection_type = try!(packet.read_str()); + + let ip = net::Ipv4Addr::from(try!(packet.read_uint())); + + let port = try!(packet.read_uint()); + if port > MAX_PORT { + return Err( + io::Error::new(io::ErrorKind::Other, "Invalid port number")); + } + + let token = try!(packet.read_uint()); + let is_privileged = try!(packet.read_bool()); + + Ok(ConnectToPeerResponse { + username: username, + connection_type: connection_type, + ip: ip, + port: port as u16, + token: token, + is_privileged: is_privileged, + }) + } +} + /*=======* * LOGIN * *=======*/ @@ -198,6 +239,61 @@ impl LoginResponse { } } +/*==================* + * PARENT MIN SPEED * + *==================*/ + +#[derive(Debug)] +pub struct ParentMinSpeedResponse { + pub value: u32, +} + +impl ParentMinSpeedResponse { + fn from_packet(packet: &mut Packet) -> io::Result { + let value = try!(packet.read_uint()); + Ok(ParentMinSpeedResponse { + value: value, + }) + } +} + +/*====================* + * PARENT SPEED RATIO * + *====================*/ + +#[derive(Debug)] +pub struct ParentSpeedRatioResponse { + pub value: u32, +} + +impl ParentSpeedRatioResponse { + fn from_packet(packet: &mut Packet) -> io::Result { + let value = try!(packet.read_uint()); + Ok(ParentSpeedRatioResponse { + value: value, + }) + } +} + +/*==================* + * PRIVILEGED USERS * + *==================*/ + +#[derive(Debug)] +pub struct PrivilegedUsersResponse { + pub users: Vec, +} + +impl PrivilegedUsersResponse { + fn from_packet(packet: &mut Packet) -> io::Result { + let mut response = PrivilegedUsersResponse { + users: Vec::new(), + }; + try!(packet.read_array_with(Packet::read_str, &mut response.users)); + Ok(response) + } +} + /*===========* * ROOM LIST * *===========*/ @@ -286,42 +382,6 @@ impl RoomListResponse { } } -/*==================* - * PARENT MIN SPEED * - *==================*/ - -#[derive(Debug)] -pub struct ParentMinSpeedResponse { - pub value: u32, -} - -impl ParentMinSpeedResponse { - fn from_packet(packet: &mut Packet) -> io::Result { - let value = try!(packet.read_uint()); - Ok(ParentMinSpeedResponse { - value: value, - }) - } -} - -/*====================* - * PARENT SPEED RATIO * - *====================*/ - -#[derive(Debug)] -pub struct ParentSpeedRatioResponse { - pub value: u32, -} - -impl ParentSpeedRatioResponse { - fn from_packet(packet: &mut Packet) -> io::Result { - let value = try!(packet.read_uint()); - Ok(ParentSpeedRatioResponse { - value: value, - }) - } -} - /*===================* * WISHLIST INTERVAL * *===================*/ @@ -339,63 +399,3 @@ impl WishlistIntervalResponse { }) } } - -/*==================* - * PRIVILEGED USERS * - *==================*/ - -#[derive(Debug)] -pub struct PrivilegedUsersResponse { - pub users: Vec, -} - -impl PrivilegedUsersResponse { - fn from_packet(packet: &mut Packet) -> io::Result { - let mut response = PrivilegedUsersResponse { - users: Vec::new(), - }; - try!(packet.read_array_with(Packet::read_str, &mut response.users)); - Ok(response) - } -} - -/*=================* - * CONNECT TO PEER * - *=================*/ - -#[derive(Debug)] -pub struct ConnectToPeerResponse { - pub username: String, - pub connection_type: String, - pub ip: net::Ipv4Addr, - pub port: u16, - pub token: u32, - pub is_privileged: bool, -} - -impl ConnectToPeerResponse { - fn from_packet(packet: &mut Packet) -> io::Result { - let username = try!(packet.read_str()); - let connection_type = try!(packet.read_str()); - - let ip = net::Ipv4Addr::from(try!(packet.read_uint())); - - let port = try!(packet.read_uint()); - if port > MAX_PORT { - return Err( - io::Error::new(io::ErrorKind::Other, "Invalid port number")); - } - - let token = try!(packet.read_uint()); - let is_privileged = try!(packet.read_bool()); - - Ok(ConnectToPeerResponse { - username: username, - connection_type: connection_type, - ip: ip, - port: port as u16, - token: token, - is_privileged: is_privileged, - }) - } -}