|
12147
|
1 |
use mio;
|
|
|
2 |
|
|
13666
|
3 |
use crate::{
|
|
|
4 |
server::{
|
|
13774
|
5 |
client::HWClient,
|
|
13666
|
6 |
server::HWServer,
|
|
|
7 |
coretypes::ClientId,
|
|
|
8 |
actions::{Action, Action::*}
|
|
|
9 |
},
|
|
|
10 |
protocol::messages::{
|
|
|
11 |
HWProtocolMessage, HWServerMessage::*
|
|
|
12 |
},
|
|
|
13 |
utils::is_name_illegal
|
|
13419
|
14 |
};
|
|
13774
|
15 |
#[cfg(feature = "official-server")]
|
|
|
16 |
use openssl::sha::sha1;
|
|
|
17 |
use std::fmt::{Formatter, LowerHex};
|
|
|
18 |
|
|
|
19 |
#[derive(PartialEq)]
|
|
|
20 |
struct Sha1Digest([u8; 20]);
|
|
|
21 |
|
|
|
22 |
impl LowerHex for Sha1Digest {
|
|
|
23 |
fn fmt(&self, f: &mut Formatter) -> Result<(), std::fmt::Error> {
|
|
|
24 |
for byte in &self.0 {
|
|
|
25 |
write!(f, "{:02x}", byte)?;
|
|
|
26 |
}
|
|
|
27 |
Ok(())
|
|
|
28 |
}
|
|
|
29 |
}
|
|
|
30 |
|
|
|
31 |
#[cfg(feature = "official-server")]
|
|
|
32 |
fn get_hash(client: &HWClient, salt1: &str, salt2: &str) -> Sha1Digest {
|
|
|
33 |
let s = format!("{}{}{}{}{}", salt1, salt2,
|
|
|
34 |
client.web_password, client.protocol_number, "!hedgewars");
|
|
|
35 |
Sha1Digest(sha1(s.as_bytes()))
|
|
|
36 |
}
|
|
12147
|
37 |
|
|
13419
|
38 |
pub fn handle(server: & mut HWServer, client_id: ClientId, message: HWProtocolMessage) {
|
|
12147
|
39 |
match message {
|
|
13416
|
40 |
HWProtocolMessage::Nick(nick) => {
|
|
13666
|
41 |
let client = &mut server.clients[client_id];
|
|
|
42 |
debug!("{} {}", nick, is_name_illegal(&nick));
|
|
|
43 |
let actions = if client.room_id != None {
|
|
|
44 |
unreachable!()
|
|
|
45 |
}
|
|
|
46 |
else if !client.nick.is_empty() {
|
|
|
47 |
vec![ProtocolError("Nickname already provided.".to_string())]
|
|
13416
|
48 |
}
|
|
13774
|
49 |
else if is_name_illegal(&nick) {
|
|
13666
|
50 |
vec![ByeClient("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())]
|
|
|
51 |
}
|
|
|
52 |
else {
|
|
|
53 |
client.nick = nick.clone();
|
|
|
54 |
vec![Nick(nick).send_self().action(),
|
|
|
55 |
CheckRegistered]
|
|
|
56 |
};
|
|
|
57 |
|
|
13419
|
58 |
server.react(client_id, actions);
|
|
13771
|
59 |
}
|
|
12147
|
60 |
HWProtocolMessage::Proto(proto) => {
|
|
13666
|
61 |
let client = &mut server.clients[client_id];
|
|
|
62 |
let actions = if client.protocol_number != 0 {
|
|
|
63 |
vec![ProtocolError("Protocol already known.".to_string())]
|
|
13416
|
64 |
}
|
|
13666
|
65 |
else if proto == 0 {
|
|
|
66 |
vec![ProtocolError("Bad number.".to_string())]
|
|
|
67 |
}
|
|
|
68 |
else {
|
|
|
69 |
client.protocol_number = proto;
|
|
|
70 |
vec![Proto(proto).send_self().action(),
|
|
|
71 |
CheckRegistered]
|
|
|
72 |
};
|
|
13419
|
73 |
server.react(client_id, actions);
|
|
13771
|
74 |
}
|
|
|
75 |
#[cfg(feature = "official-server")]
|
|
13774
|
76 |
HWProtocolMessage::Password(hash, salt) => {
|
|
|
77 |
let c = &server.clients[client_id];
|
|
|
78 |
|
|
|
79 |
let client_hash = get_hash(c, &salt, &c.server_salt);
|
|
|
80 |
let server_hash = get_hash(c, &c.server_salt, &salt);
|
|
|
81 |
let actions = if client_hash == server_hash {
|
|
|
82 |
vec![ServerAuth(format!("{:x}", server_hash)).send_self().action(),
|
|
|
83 |
JoinLobby]
|
|
|
84 |
} else {
|
|
|
85 |
vec![ByeClient("Authentication failed".to_string())]
|
|
|
86 |
};
|
|
|
87 |
server.react(client_id, actions);
|
|
|
88 |
}
|
|
|
89 |
#[cfg(feature = "official-server")]
|
|
13771
|
90 |
HWProtocolMessage::Checker(protocol, nick, password) => {
|
|
|
91 |
let c = &mut server.clients[client_id];
|
|
|
92 |
c.nick = nick;
|
|
|
93 |
c.web_password = password;
|
|
|
94 |
c.set_is_checker(true);
|
|
|
95 |
}
|
|
12147
|
96 |
_ => warn!("Incorrect command in logging-in state"),
|
|
|
97 |
}
|
|
|
98 |
}
|