use mio;
use crate::{
core::{
anteroom::{HwAnteroom, HwAnteroomClient},
client::HwClient,
server::HwServer,
types::ClientId,
},
protocol::messages::{HwProtocolMessage, HwProtocolMessage::LoadRoom, HwServerMessage::*},
utils::is_name_illegal,
};
use log::*;
#[cfg(feature = "official-server")]
use openssl::sha::sha1;
use std::{
fmt::{Formatter, LowerHex},
num::NonZeroU16,
};
pub enum LoginResult {
Unchanged,
Complete,
Exit,
}
fn completion_result<'a, I>(
mut other_clients: I,
client: &mut HwAnteroomClient,
response: &mut super::Response,
) -> LoginResult
where
I: Iterator<Item = &'a HwClient>,
{
let has_nick_clash =
other_clients.any(|c| !c.is_checker() && c.nick == *client.nick.as_ref().unwrap());
if has_nick_clash {
if client.protocol_number.unwrap().get() < 38 {
response.add(Bye("User quit: Nickname is already in use".to_string()).send_self());
LoginResult::Exit
} else {
client.nick = None;
response.add(Notice("NickAlreadyInUse".to_string()).send_self());
LoginResult::Unchanged
}
} else {
#[cfg(feature = "official-server")]
{
response.request_io(super::IoTask::CheckRegistered {
nick: client.nick.as_ref().unwrap().clone(),
});
LoginResult::Unchanged
}
#[cfg(not(feature = "official-server"))]
{
LoginResult::Complete
}
}
}
pub fn handle(
server_state: &mut super::ServerState,
client_id: ClientId,
response: &mut super::Response,
message: HwProtocolMessage,
) -> LoginResult {
match message {
HwProtocolMessage::Quit(_) => {
response.add(Bye("User quit".to_string()).send_self());
LoginResult::Exit
}
HwProtocolMessage::Nick(nick) => {
let client = &mut server_state.anteroom.clients[client_id];
if client.nick.is_some() {
response.add(Error("Nickname already provided.".to_string()).send_self());
LoginResult::Unchanged
} else if is_name_illegal(&nick) {
response.add(Bye("Illegal nickname! Nicknames must be between 1-40 characters long, must not have a trailing or leading space and must not have any of these characters: $()*+?[]^{|}".to_string()).send_self());
LoginResult::Exit
} else {
client.nick = Some(nick.clone());
response.add(Nick(nick).send_self());
if client.protocol_number.is_some() {
completion_result(server_state.server.iter_clients(), client, response)
} else {
LoginResult::Unchanged
}
}
}
HwProtocolMessage::Proto(proto) => {
let client = &mut server_state.anteroom.clients[client_id];
if client.protocol_number.is_some() {
response.add(Error("Protocol already known.".to_string()).send_self());
LoginResult::Unchanged
} else if proto == 0 {
response.add(Error("Bad number.".to_string()).send_self());
LoginResult::Unchanged
} else {
client.protocol_number = NonZeroU16::new(proto);
response.add(Proto(proto).send_self());
if client.nick.is_some() {
completion_result(server_state.server.iter_clients(), client, response)
} else {
LoginResult::Unchanged
}
}
}
#[cfg(feature = "official-server")]
HwProtocolMessage::Password(hash, salt) => {
let client = &server_state.anteroom.clients[client_id];
if let (Some(nick), Some(protocol)) = (client.nick.as_ref(), client.protocol_number) {
response.request_io(super::IoTask::GetAccount {
nick: nick.clone(),
protocol: protocol.get(),
server_salt: client.server_salt.clone(),
client_salt: salt,
password_hash: hash,
});
};
LoginResult::Unchanged
}
#[cfg(feature = "official-server")]
HwProtocolMessage::Checker(protocol, nick, password) => {
let client = &mut server_state.anteroom.clients[client_id];
if protocol == 0 {
response.add(Error("Bad number.".to_string()).send_self());
LoginResult::Unchanged
} else {
client.protocol_number = NonZeroU16::new(protocol);
client.nick = Some(nick);
client.is_checker = true;
LoginResult::Complete
}
}
_ => {
warn!("Incorrect command in logging-in state");
LoginResult::Unchanged
}
}
}