rust/hedgewars-server/src/server/actions.rs
author Wuzzy <Wuzzy2@mail.ru>
Mon, 29 Apr 2019 21:24:42 +0200
changeset 14870 24df603fbcd2
parent 14809 6dea1ca64992
permissions -rw-r--r--
Match key names in sdlkeys with SDL-pretty printed names (for localization)
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
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
}