author | alfadur |
Mon, 03 Jun 2019 01:15:57 +0300 | |
changeset 15108 | 823052e66611 |
parent 15080 | e935b1ad23f3 |
child 15444 | a158ff8f84ef |
permissions | -rw-r--r-- |
12152 | 1 |
use mio; |
2 |
||
14462 | 3 |
use super::common::rnd_reply; |
13671 | 4 |
use crate::{ |
15080 | 5 |
core::{ |
6 |
client::HwClient, |
|
7 |
server::HwServer, |
|
8 |
types::{ClientId, ServerVar}, |
|
14787 | 9 |
}, |
15080 | 10 |
protocol::messages::{ |
11 |
add_flags, remove_flags, server_chat, HwProtocolMessage, HwServerMessage::*, |
|
12 |
ProtocolFlags as Flags, |
|
14788 | 13 |
}, |
14462 | 14 |
utils::is_name_illegal, |
13421 | 15 |
}; |
13810 | 16 |
use log::*; |
14794 | 17 |
use std::{collections::HashSet, convert::identity}; |
12152 | 18 |
|
14676
455865ccd36c
Server action refactoring part 2 of N
alfadur <mail@none>
parents:
14509
diff
changeset
|
19 |
pub fn handle( |
15080 | 20 |
server: &mut HwServer, |
14676
455865ccd36c
Server action refactoring part 2 of N
alfadur <mail@none>
parents:
14509
diff
changeset
|
21 |
client_id: ClientId, |
455865ccd36c
Server action refactoring part 2 of N
alfadur <mail@none>
parents:
14509
diff
changeset
|
22 |
response: &mut super::Response, |
15080 | 23 |
message: HwProtocolMessage, |
14676
455865ccd36c
Server action refactoring part 2 of N
alfadur <mail@none>
parents:
14509
diff
changeset
|
24 |
) { |
15080 | 25 |
use crate::protocol::messages::HwProtocolMessage::*; |
12152 | 26 |
match message { |
13421 | 27 |
CreateRoom(name, password) => { |
14677
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
28 |
if is_name_illegal(&name) { |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
29 |
response.add(Warning("Illegal room name! A room name 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()); |
14462 | 30 |
} else if server.has_room(&name) { |
14677
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
31 |
response.add( |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
32 |
Warning("A room with the same name already exists.".to_string()).send_self(), |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
33 |
); |
14462 | 34 |
} else { |
35 |
let flags_msg = ClientFlags( |
|
14787 | 36 |
add_flags(&[Flags::RoomMaster, Flags::Ready]), |
14462 | 37 |
vec![server.clients[client_id].nick.clone()], |
38 |
); |
|
14509
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14462
diff
changeset
|
39 |
|
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14462
diff
changeset
|
40 |
let room_id = server.create_room(client_id, name, password); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14462
diff
changeset
|
41 |
let room = &server.rooms[room_id]; |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14462
diff
changeset
|
42 |
let client = &server.clients[client_id]; |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14462
diff
changeset
|
43 |
|
14676
455865ccd36c
Server action refactoring part 2 of N
alfadur <mail@none>
parents:
14509
diff
changeset
|
44 |
response.add( |
14509
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14462
diff
changeset
|
45 |
RoomAdd(room.info(Some(&client))) |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14462
diff
changeset
|
46 |
.send_all() |
14676
455865ccd36c
Server action refactoring part 2 of N
alfadur <mail@none>
parents:
14509
diff
changeset
|
47 |
.with_protocol(room.protocol_number), |
455865ccd36c
Server action refactoring part 2 of N
alfadur <mail@none>
parents:
14509
diff
changeset
|
48 |
); |
14802 | 49 |
response.add(RoomJoined(vec![client.nick.clone()]).send_self()); |
14676
455865ccd36c
Server action refactoring part 2 of N
alfadur <mail@none>
parents:
14509
diff
changeset
|
50 |
response.add(flags_msg.send_self()); |
455865ccd36c
Server action refactoring part 2 of N
alfadur <mail@none>
parents:
14509
diff
changeset
|
51 |
|
14787 | 52 |
response.add( |
53 |
ClientFlags(add_flags(&[Flags::InRoom]), vec![client.nick.clone()]).send_self(), |
|
54 |
); |
|
14462 | 55 |
}; |
56 |
} |
|
13124
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12857
diff
changeset
|
57 |
Chat(msg) => { |
14677
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
58 |
response.add( |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
59 |
ChatMsg { |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
60 |
nick: server.clients[client_id].nick.clone(), |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
61 |
msg, |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
62 |
} |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
63 |
.send_all() |
14699 | 64 |
.in_lobby() |
14677
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
65 |
.but_self(), |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
66 |
); |
14462 | 67 |
} |
13671 | 68 |
JoinRoom(name, _password) => { |
69 |
let room = server.rooms.iter().find(|(_, r)| r.name == name); |
|
70 |
let room_id = room.map(|(_, r)| r.id); |
|
14790
a1077e8d26f4
implement watch message apart from replay deserializing
alfadur
parents:
14788
diff
changeset
|
71 |
|
14691
9f98086de1b6
Server action refactoring part 9 of N
alfadur <mail@none>
parents:
14677
diff
changeset
|
72 |
let client = &mut server.clients[client_id]; |
13432 | 73 |
|
14691
9f98086de1b6
Server action refactoring part 9 of N
alfadur <mail@none>
parents:
14677
diff
changeset
|
74 |
if let Some((_, room)) = room { |
9f98086de1b6
Server action refactoring part 9 of N
alfadur <mail@none>
parents:
14677
diff
changeset
|
75 |
if client.protocol_number != room.protocol_number { |
14677
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
76 |
response.add( |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
77 |
Warning("Room version incompatible to your Hedgewars version!".to_string()) |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
78 |
.send_self(), |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
79 |
); |
14691
9f98086de1b6
Server action refactoring part 9 of N
alfadur <mail@none>
parents:
14677
diff
changeset
|
80 |
} else if room.is_join_restricted() { |
14677
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
81 |
response.add( |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
82 |
Warning( |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
83 |
"Access denied. This room currently doesn't allow joining.".to_string(), |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
84 |
) |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
85 |
.send_self(), |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
86 |
); |
14691
9f98086de1b6
Server action refactoring part 9 of N
alfadur <mail@none>
parents:
14677
diff
changeset
|
87 |
} else if room.players_number == u8::max_value() { |
14677
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
88 |
response.add(Warning("This room is already full".to_string()).send_self()); |
14676
455865ccd36c
Server action refactoring part 2 of N
alfadur <mail@none>
parents:
14509
diff
changeset
|
89 |
} else if let Some(room_id) = room_id { |
14792 | 90 |
super::common::enter_room(server, client_id, room_id, response); |
13671 | 91 |
} |
92 |
} else { |
|
14677
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
93 |
response.add(Warning("No such room.".to_string()).send_self()); |
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
94 |
} |
14462 | 95 |
} |
14792 | 96 |
Follow(nick) => { |
15080 | 97 |
if let Some(HwClient { |
14792 | 98 |
room_id: Some(room_id), |
99 |
.. |
|
100 |
}) = server.find_client(&nick) |
|
101 |
{ |
|
102 |
let room = &server.rooms[*room_id]; |
|
103 |
response.add(Joining(room.name.clone()).send_self()); |
|
104 |
super::common::enter_room(server, client_id, *room_id, response); |
|
105 |
} |
|
106 |
} |
|
14788 | 107 |
SetServerVar(var) => { |
108 |
if !server.clients[client_id].is_admin() { |
|
109 |
response.add(Warning("Access denied.".to_string()).send_self()); |
|
110 |
} else { |
|
111 |
match var { |
|
112 |
ServerVar::MOTDNew(msg) => server.greetings.for_latest_protocol = msg, |
|
113 |
ServerVar::MOTDOld(msg) => server.greetings.for_old_protocols = msg, |
|
114 |
ServerVar::LatestProto(n) => server.latest_protocol = n, |
|
115 |
} |
|
116 |
} |
|
117 |
} |
|
118 |
GetServerVar => { |
|
119 |
if !server.clients[client_id].is_admin() { |
|
120 |
response.add(Warning("Access denied.".to_string()).send_self()); |
|
121 |
} else { |
|
122 |
let vars: Vec<_> = [ |
|
123 |
ServerVar::MOTDNew(server.greetings.for_latest_protocol.clone()), |
|
124 |
ServerVar::MOTDOld(server.greetings.for_old_protocols.clone()), |
|
125 |
ServerVar::LatestProto(server.latest_protocol), |
|
126 |
] |
|
127 |
.iter() |
|
128 |
.flat_map(|v| v.to_protocol()) |
|
129 |
.collect(); |
|
130 |
response.add(ServerVars(vars).send_self()); |
|
131 |
} |
|
132 |
} |
|
13450
d3c86ade3d4d
Send the rnd reply to the room only.
Marcin Mielniczuk <marmistrz.dev@zoho.eu>
parents:
13449
diff
changeset
|
133 |
Rnd(v) => { |
14677
6e6632068a33
Server action refactoring part 3 of N
alfadur <mail@none>
parents:
14676
diff
changeset
|
134 |
response.add(rnd_reply(&v).send_self()); |
14462 | 135 |
} |
14794 | 136 |
Stats => { |
137 |
let mut protocols: HashSet<_> = server |
|
138 |
.clients |
|
139 |
.iter() |
|
140 |
.map(|(_, c)| c.protocol_number) |
|
141 |
.chain(server.rooms.iter().map(|(_, r)| r.protocol_number)) |
|
142 |
.collect(); |
|
143 |
let mut protocols: Vec<_> = protocols.drain().collect(); |
|
144 |
protocols.sort(); |
|
145 |
||
146 |
let mut html = Vec::with_capacity(protocols.len() + 2); |
|
147 |
||
148 |
html.push("<table>".to_string()); |
|
149 |
for protocol in protocols { |
|
150 |
html.push(format!( |
|
151 |
"<tr><td>{}</td><td>{}</td><td>{}</td></tr>", |
|
152 |
super::utils::protocol_version_string(protocol), |
|
153 |
server.protocol_clients(protocol).count(), |
|
154 |
server.protocol_rooms(protocol).count() |
|
155 |
)); |
|
156 |
} |
|
157 |
html.push("</table>".to_string()); |
|
158 |
||
159 |
response.add(Warning(html.join("")).send_self()); |
|
160 |
} |
|
13124
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12857
diff
changeset
|
161 |
List => warn!("Deprecated LIST message received"), |
12152 | 162 |
_ => warn!("Incorrect command in lobby state"), |
163 |
} |
|
164 |
} |