author | Wuzzy <Wuzzy2@mail.ru> |
Tue, 02 Apr 2019 22:40:46 +0200 | |
changeset 14745 | 7cc768094d66 |
parent 14697 | f64e21f164a5 |
child 14779 | f43ab2bd76ae |
permissions | -rw-r--r-- |
13416 | 1 |
use super::{ |
14457 | 2 |
client::HWClient, |
3 |
coretypes::{ClientId, RoomId}, |
|
14693 | 4 |
indexslab::IndexSlab, |
14392 | 5 |
io::HWServerIO, |
14457 | 6 |
room::HWRoom, |
13416 | 7 |
}; |
14696 | 8 |
use crate::utils; |
14693 | 9 |
|
13805 | 10 |
use log::*; |
14457 | 11 |
use slab; |
14693 | 12 |
use std::{borrow::BorrowMut, iter, num::NonZeroU16}; |
12126 | 13 |
|
12852 | 14 |
type Slab<T> = slab::Slab<T>; |
12127 | 15 |
|
14693 | 16 |
pub struct HWAnteClient { |
17 |
pub nick: Option<String>, |
|
18 |
pub protocol_number: Option<NonZeroU16>, |
|
14695 | 19 |
pub web_password: Option<String>, |
14693 | 20 |
pub server_salt: String, |
21 |
} |
|
22 |
||
23 |
pub struct HWAnteroom { |
|
24 |
pub clients: IndexSlab<HWAnteClient>, |
|
25 |
} |
|
26 |
||
27 |
impl HWAnteroom { |
|
28 |
pub fn new(clients_limit: usize) -> Self { |
|
29 |
let clients = IndexSlab::with_capacity(clients_limit); |
|
30 |
HWAnteroom { clients } |
|
31 |
} |
|
32 |
||
33 |
pub fn add_client(&mut self, client_id: ClientId, salt: String) { |
|
34 |
let client = HWAnteClient { |
|
35 |
nick: None, |
|
36 |
protocol_number: None, |
|
37 |
server_salt: salt, |
|
14695 | 38 |
web_password: None, |
14693 | 39 |
}; |
40 |
self.clients.insert(client_id, client); |
|
41 |
} |
|
42 |
||
43 |
pub fn remove_client(&mut self, client_id: ClientId) -> Option<HWAnteClient> { |
|
44 |
let mut client = self.clients.remove(client_id); |
|
14696 | 45 |
if let Some(HWAnteClient { |
46 |
web_password: Some(ref mut password), |
|
47 |
.. |
|
48 |
}) = client |
|
49 |
{ |
|
14695 | 50 |
password.replace_range(.., "🦔🦔🦔🦔🦔🦔🦔🦔"); |
14693 | 51 |
} |
52 |
client |
|
53 |
} |
|
54 |
} |
|
55 |
||
12126 | 56 |
pub struct HWServer { |
14693 | 57 |
pub clients: IndexSlab<HWClient>, |
12143 | 58 |
pub rooms: Slab<HWRoom>, |
14457 | 59 |
pub io: Box<dyn HWServerIO>, |
14693 | 60 |
pub anteroom: HWAnteroom, |
12126 | 61 |
} |
62 |
||
63 |
impl HWServer { |
|
14693 | 64 |
pub fn new(clients_limit: usize, rooms_limit: usize, io: Box<dyn HWServerIO>) -> Self { |
13119
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12852
diff
changeset
|
65 |
let rooms = Slab::with_capacity(rooms_limit); |
14693 | 66 |
let clients = IndexSlab::with_capacity(clients_limit); |
14694 | 67 |
Self { |
14457 | 68 |
clients, |
69 |
rooms, |
|
70 |
io, |
|
14693 | 71 |
anteroom: HWAnteroom::new(clients_limit), |
14694 | 72 |
} |
12126 | 73 |
} |
74 |
||
14693 | 75 |
pub fn add_client(&mut self, client_id: ClientId, data: HWAnteClient) { |
76 |
if let (Some(protocol), Some(nick)) = (data.protocol_number, data.nick) { |
|
77 |
let client = HWClient::new(client_id, protocol.get(), nick); |
|
78 |
self.clients.insert(client_id, client); |
|
13119
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12852
diff
changeset
|
79 |
} |
12126 | 80 |
} |
12127 | 81 |
|
14673
08a8605bafaf
Server action refactoring part 4 of N
alfadur <mail@none>
parents:
14672
diff
changeset
|
82 |
pub fn remove_client(&mut self, client_id: ClientId) { |
14696 | 83 |
self.clients.remove(client_id); |
12127 | 84 |
} |
85 |
||
14504
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
86 |
#[inline] |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
87 |
pub fn create_room( |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
88 |
&mut self, |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
89 |
creator_id: ClientId, |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
90 |
name: String, |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
91 |
password: Option<String>, |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
92 |
) -> RoomId { |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
93 |
create_room( |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
94 |
&mut self.clients[creator_id], |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
95 |
&mut self.rooms, |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
96 |
name, |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
97 |
password, |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
98 |
) |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
99 |
} |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
100 |
|
14671
455865ccd36c
Server action refactoring part 2 of N
alfadur <mail@none>
parents:
14504
diff
changeset
|
101 |
#[inline] |
455865ccd36c
Server action refactoring part 2 of N
alfadur <mail@none>
parents:
14504
diff
changeset
|
102 |
pub fn move_to_room(&mut self, client_id: ClientId, room_id: RoomId) { |
455865ccd36c
Server action refactoring part 2 of N
alfadur <mail@none>
parents:
14504
diff
changeset
|
103 |
move_to_room(&mut self.clients[client_id], &mut self.rooms[room_id]) |
455865ccd36c
Server action refactoring part 2 of N
alfadur <mail@none>
parents:
14504
diff
changeset
|
104 |
} |
455865ccd36c
Server action refactoring part 2 of N
alfadur <mail@none>
parents:
14504
diff
changeset
|
105 |
|
13416 | 106 |
pub fn has_room(&self, name: &str) -> bool { |
14697 | 107 |
self.find_room(name).is_some() |
13416 | 108 |
} |
109 |
||
110 |
pub fn find_room(&self, name: &str) -> Option<&HWRoom> { |
|
14457 | 111 |
self.rooms |
112 |
.iter() |
|
113 |
.find_map(|(_, r)| Some(r).filter(|r| r.name == name)) |
|
13416 | 114 |
} |
115 |
||
116 |
pub fn find_room_mut(&mut self, name: &str) -> Option<&mut HWRoom> { |
|
14457 | 117 |
self.rooms |
118 |
.iter_mut() |
|
119 |
.find_map(|(_, r)| Some(r).filter(|r| r.name == name)) |
|
13416 | 120 |
} |
121 |
||
13478 | 122 |
pub fn find_client(&self, nick: &str) -> Option<&HWClient> { |
14457 | 123 |
self.clients |
124 |
.iter() |
|
125 |
.find_map(|(_, c)| Some(c).filter(|c| c.nick == nick)) |
|
13478 | 126 |
} |
127 |
||
128 |
pub fn find_client_mut(&mut self, nick: &str) -> Option<&mut HWClient> { |
|
14457 | 129 |
self.clients |
130 |
.iter_mut() |
|
131 |
.find_map(|(_, c)| Some(c).filter(|c| c.nick == nick)) |
|
13478 | 132 |
} |
133 |
||
13416 | 134 |
pub fn select_clients<F>(&self, f: F) -> Vec<ClientId> |
14457 | 135 |
where |
136 |
F: Fn(&(usize, &HWClient)) -> bool, |
|
137 |
{ |
|
138 |
self.clients.iter().filter(f).map(|(_, c)| c.id).collect() |
|
13416 | 139 |
} |
140 |
||
14694 | 141 |
pub fn lobby_clients(&self) -> Vec<ClientId> { |
142 |
self.select_clients(|(_, c)| c.room_id == None) |
|
143 |
} |
|
144 |
||
13416 | 145 |
pub fn room_clients(&self, room_id: RoomId) -> Vec<ClientId> { |
146 |
self.select_clients(|(_, c)| c.room_id == Some(room_id)) |
|
147 |
} |
|
148 |
||
13520 | 149 |
pub fn protocol_clients(&self, protocol: u16) -> Vec<ClientId> { |
13416 | 150 |
self.select_clients(|(_, c)| c.protocol_number == protocol) |
151 |
} |
|
152 |
||
153 |
pub fn other_clients_in_room(&self, self_id: ClientId) -> Vec<ClientId> { |
|
154 |
let room_id = self.clients[self_id].room_id; |
|
14457 | 155 |
self.select_clients(|(id, c)| *id != self_id && c.room_id == room_id) |
13416 | 156 |
} |
13445
d3c86ade3d4d
Send the rnd reply to the room only.
Marcin Mielniczuk <marmistrz.dev@zoho.eu>
parents:
13442
diff
changeset
|
157 |
} |
14504
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
158 |
|
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
159 |
fn allocate_room(rooms: &mut Slab<HWRoom>) -> &mut HWRoom { |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
160 |
let entry = rooms.vacant_entry(); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
161 |
let room = HWRoom::new(entry.key()); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
162 |
entry.insert(room) |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
163 |
} |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
164 |
|
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
165 |
fn create_room( |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
166 |
client: &mut HWClient, |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
167 |
rooms: &mut Slab<HWRoom>, |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
168 |
name: String, |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
169 |
password: Option<String>, |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
170 |
) -> RoomId { |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
171 |
let room = allocate_room(rooms); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
172 |
|
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
173 |
room.master_id = Some(client.id); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
174 |
room.name = name; |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
175 |
room.password = password; |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
176 |
room.protocol_number = client.protocol_number; |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
177 |
|
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
178 |
room.players_number = 1; |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
179 |
room.ready_players_number = 1; |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
180 |
|
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
181 |
client.room_id = Some(room.id); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
182 |
client.set_is_master(true); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
183 |
client.set_is_ready(true); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
184 |
client.set_is_joined_mid_game(false); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
185 |
|
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
186 |
room.id |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
187 |
} |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
188 |
|
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
189 |
fn move_to_room(client: &mut HWClient, room: &mut HWRoom) { |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
190 |
debug_assert!(client.room_id != Some(room.id)); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
191 |
|
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
192 |
room.players_number += 1; |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
193 |
|
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
194 |
client.room_id = Some(room.id); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
195 |
client.set_is_joined_mid_game(room.game_info.is_some()); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
196 |
client.set_is_in_game(room.game_info.is_some()); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
197 |
|
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
198 |
if let Some(ref mut info) = room.game_info { |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
199 |
let teams = info.client_teams(client.id); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
200 |
client.teams_in_game = teams.clone().count() as u8; |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
201 |
client.clan = teams.clone().next().map(|t| t.color); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
202 |
let team_names: Vec<_> = teams.map(|t| t.name.clone()).collect(); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
203 |
|
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
204 |
if !team_names.is_empty() { |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
205 |
info.left_teams.retain(|name| !team_names.contains(&name)); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
206 |
info.teams_in_game += team_names.len() as u8; |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
207 |
room.teams = info |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
208 |
.teams_at_start |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
209 |
.iter() |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
210 |
.filter(|(_, t)| !team_names.contains(&t.name)) |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
211 |
.cloned() |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
212 |
.collect(); |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
213 |
} |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
214 |
} |
6cc0fce249f9
Server action refactoring part 1 of N
alfadur <mail@none>
parents:
14457
diff
changeset
|
215 |
} |