hedgewars-draft: rust/hedgewars-server/src/server/actions.rs@6dea1ca64992 (annotated)

13416 cdf69667593b partial room implementation alfadur parents: 13119 diff changeset	1	use super::{
14478 98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	2	client::HWClient,
14395 e5db279308d7 dispose of server mods alfadur parents: 14371 diff changeset	3	core::HWServer,
14478 98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	4	coretypes::{ClientId, GameCfg, RoomId, VoteType},
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	5	handlers,
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	6	room::HWRoom,
13494 8c5dd562c9f7 Add room flags alfadur parents: 13486 diff changeset	7	room::{GameInfo, RoomFlags},
13416 cdf69667593b partial room implementation alfadur parents: 13119 diff changeset	8	};
13666 09f4a30e50cc Rust 2018 conversion alfadur parents: 13521 diff changeset	9	use crate::{
14478 98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	10	protocol::messages::{server_chat, HWProtocolMessage, HWServerMessage, HWServerMessage::*},
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	11	utils::to_engine_msg,
13416 cdf69667593b partial room implementation alfadur parents: 13119 diff changeset	12	};
14478 98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	13	use rand::{distributions::Uniform, thread_rng, Rng};
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	14	use std::{io, io::Write, iter::once, mem::replace};
12138 e0bf51609062 Introduce actions, just like in the old server unc0rr parents: diff changeset	15
14477 a077aac9df01 Start database interaction implementation unc0rr parents: 14436 diff changeset	16	#[cfg(feature = "official-server")]
a077aac9df01 Start database interaction implementation unc0rr parents: 14436 diff changeset	17	use super::database;
a077aac9df01 Start database interaction implementation unc0rr parents: 14436 diff changeset	18
14809 6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	19	pub enum DestinationGroup {
14715 25c564f77b7d remove lobby room alfadur <mail@none> parents: 14711 diff changeset	20	All,
25c564f77b7d remove lobby room alfadur <mail@none> parents: 14711 diff changeset	21	Lobby,
25c564f77b7d remove lobby room alfadur <mail@none> parents: 14711 diff changeset	22	Room(RoomId),
14809 6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	23	Protocol(u16),
14715 25c564f77b7d remove lobby room alfadur <mail@none> parents: 14711 diff changeset	24	}
25c564f77b7d remove lobby room alfadur <mail@none> parents: 14711 diff changeset	25
13419 81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	26	pub enum Destination {
13426 f091f69d59e4 Additional round cleanup alfadur parents: 13424 diff changeset	27	ToId(ClientId),
14809 6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	28	ToIds(Vec<ClientId>),
13419 81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	29	ToSelf,
13423 87a6cad20c90 Implement game start & engine messages alfadur parents: 13422 diff changeset	30	ToAll {
14809 6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	31	group: DestinationGroup,
14478 98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	32	skip_self: bool,
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	33	},
13419 81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	34	}
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	35
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	36	pub struct PendingMessage {
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	37	pub destination: Destination,
14478 98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	38	pub message: HWServerMessage,
13419 81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	39	}
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	40
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	41	impl PendingMessage {
13426 f091f69d59e4 Additional round cleanup alfadur parents: 13424 diff changeset	42	pub fn send(message: HWServerMessage, client_id: ClientId) -> PendingMessage {
14478 98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	43	PendingMessage {
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	44	destination: Destination::ToId(client_id),
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	45	message,
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	46	}
13426 f091f69d59e4 Additional round cleanup alfadur parents: 13424 diff changeset	47	}
f091f69d59e4 Additional round cleanup alfadur parents: 13424 diff changeset	48
14809 6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	49	pub fn send_many(message: HWServerMessage, client_ids: Vec<ClientId>) -> PendingMessage {
6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	50	PendingMessage {
6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	51	destination: Destination::ToIds(client_ids),
6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	52	message,
6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	53	}
6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	54	}
6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	55
13419 81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	56	pub fn send_self(message: HWServerMessage) -> PendingMessage {
14478 98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	57	PendingMessage {
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	58	destination: Destination::ToSelf,
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	59	message,
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	60	}
13419 81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	61	}
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	62
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	63	pub fn send_all(message: HWServerMessage) -> PendingMessage {
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	64	let destination = Destination::ToAll {
14809 6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	65	group: DestinationGroup::All,
13419 81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	66	skip_self: false,
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	67	};
14478 98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	68	PendingMessage {
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	69	destination,
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	70	message,
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	71	}
13419 81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	72	}
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	73
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	74	pub fn in_room(mut self, clients_room_id: RoomId) -> PendingMessage {
14809 6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	75	if let Destination::ToAll { ref mut group, .. } = self.destination {
6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	76	*group = DestinationGroup::Room(clients_room_id)
14715 25c564f77b7d remove lobby room alfadur <mail@none> parents: 14711 diff changeset	77	}
25c564f77b7d remove lobby room alfadur <mail@none> parents: 14711 diff changeset	78	self
25c564f77b7d remove lobby room alfadur <mail@none> parents: 14711 diff changeset	79	}
25c564f77b7d remove lobby room alfadur <mail@none> parents: 14711 diff changeset	80
25c564f77b7d remove lobby room alfadur <mail@none> parents: 14711 diff changeset	81	pub fn in_lobby(mut self) -> PendingMessage {
14809 6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	82	if let Destination::ToAll { ref mut group, .. } = self.destination {
6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	83	*group = DestinationGroup::Lobby
13419 81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	84	}
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	85	self
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	86	}
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	87
13486 1ee192f13456 Better packing for clients alfadur parents: 13460 diff changeset	88	pub fn with_protocol(mut self, protocol_number: u16) -> PendingMessage {
14809 6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	89	if let Destination::ToAll { ref mut group, .. } = self.destination {
6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	90	*group = DestinationGroup::Protocol(protocol_number)
13419 81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	91	}
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	92	self
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	93	}
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	94
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	95	pub fn but_self(mut self) -> PendingMessage {
14478 98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	96	if let Destination::ToAll {
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	97	ref mut skip_self, ..
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	98	} = self.destination
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	99	{
13419 81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	100	*skip_self = true
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	101	}
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	102	self
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	103	}
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	104	}
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	105
81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	106	impl HWServerMessage {
14478 98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	107	pub fn send(self, client_id: ClientId) -> PendingMessage {
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	108	PendingMessage::send(self, client_id)
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	109	}
14809 6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	110	pub fn send_many(self, client_ids: Vec<ClientId>) -> PendingMessage {
6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	111	PendingMessage::send_many(self, client_ids)
6dea1ca64992 implement maxteams and teamchat messages alfadur parents: 14715 diff changeset	112	}
14478 98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	113	pub fn send_self(self) -> PendingMessage {
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	114	PendingMessage::send_self(self)
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	115	}
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	116	pub fn send_all(self) -> PendingMessage {
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	117	PendingMessage::send_all(self)
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14477 diff changeset	118	}
13419 81e0ed105f5d implementation of team related messages alfadur parents: 13416 diff changeset	119	}

author	alfadur
	Thu, 11 Apr 2019 19:30:22 +0300
changeset 14809	6dea1ca64992
parent 14715	25c564f77b7d
permissions	-rw-r--r--