rust/hedgewars-server/src/server/actions.rs
author alfadur <mail@none>
Thu, 07 Feb 2019 17:02:24 +0300
changeset 14698 6a2e13e36b7f
parent 14695 f61ce544d436
child 14699 25c564f77b7d
permissions -rw-r--r--
add server anteroom
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
13421
cdf69667593b partial room implementation
alfadur
parents: 13124
diff changeset
     1
use super::{
14462
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
     2
    client::HWClient,
14379
e5db279308d7 dispose of server mods
alfadur
parents: 14355
diff changeset
     3
    core::HWServer,
14462
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
     4
    coretypes::{ClientId, GameCfg, RoomId, VoteType},
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
     5
    handlers,
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
     6
    room::HWRoom,
13528
8c5dd562c9f7 Add room flags
alfadur
parents: 13525
diff changeset
     7
    room::{GameInfo, RoomFlags},
13421
cdf69667593b partial room implementation
alfadur
parents: 13124
diff changeset
     8
};
13671
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13532
diff changeset
     9
use crate::{
14462
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    10
    protocol::messages::{server_chat, HWProtocolMessage, HWServerMessage, HWServerMessage::*},
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    11
    utils::to_engine_msg,
13421
cdf69667593b partial room implementation
alfadur
parents: 13124
diff changeset
    12
};
14462
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    13
use rand::{distributions::Uniform, thread_rng, Rng};
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    14
use std::{io, io::Write, iter::once, mem::replace};
12143
e0bf51609062 Introduce actions, just like in the old server
unc0rr
parents:
diff changeset
    15
14461
a077aac9df01 Start database interaction implementation
unc0rr
parents: 14420
diff changeset
    16
#[cfg(feature = "official-server")]
a077aac9df01 Start database interaction implementation
unc0rr
parents: 14420
diff changeset
    17
use super::database;
a077aac9df01 Start database interaction implementation
unc0rr
parents: 14420
diff changeset
    18
13424
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    19
pub enum Destination {
13431
f091f69d59e4 Additional round cleanup
alfadur
parents: 13429
diff changeset
    20
    ToId(ClientId),
13424
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    21
    ToSelf,
13428
87a6cad20c90 Implement game start & engine messages
alfadur
parents: 13427
diff changeset
    22
    ToAll {
13424
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    23
        room_id: Option<RoomId>,
13525
1ee192f13456 Better packing for clients
alfadur
parents: 13485
diff changeset
    24
        protocol: Option<u16>,
14462
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    25
        skip_self: bool,
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    26
    },
13424
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    27
}
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    28
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    29
pub struct PendingMessage {
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    30
    pub destination: Destination,
14462
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    31
    pub message: HWServerMessage,
13424
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    32
}
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    33
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    34
impl PendingMessage {
13431
f091f69d59e4 Additional round cleanup
alfadur
parents: 13429
diff changeset
    35
    pub fn send(message: HWServerMessage, client_id: ClientId) -> PendingMessage {
14462
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    36
        PendingMessage {
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    37
            destination: Destination::ToId(client_id),
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    38
            message,
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    39
        }
13431
f091f69d59e4 Additional round cleanup
alfadur
parents: 13429
diff changeset
    40
    }
f091f69d59e4 Additional round cleanup
alfadur
parents: 13429
diff changeset
    41
13424
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    42
    pub fn send_self(message: HWServerMessage) -> PendingMessage {
14462
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    43
        PendingMessage {
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    44
            destination: Destination::ToSelf,
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    45
            message,
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    46
        }
13424
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    47
    }
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    48
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    49
    pub fn send_all(message: HWServerMessage) -> PendingMessage {
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    50
        let destination = Destination::ToAll {
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    51
            room_id: None,
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    52
            protocol: None,
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    53
            skip_self: false,
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    54
        };
14462
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    55
        PendingMessage {
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    56
            destination,
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    57
            message,
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    58
        }
13424
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    59
    }
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    60
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    61
    pub fn in_room(mut self, clients_room_id: RoomId) -> PendingMessage {
14462
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    62
        if let Destination::ToAll {
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    63
            ref mut room_id, ..
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    64
        } = self.destination
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    65
        {
13424
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    66
            *room_id = Some(clients_room_id)
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    67
        }
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    68
        self
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    69
    }
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    70
13525
1ee192f13456 Better packing for clients
alfadur
parents: 13485
diff changeset
    71
    pub fn with_protocol(mut self, protocol_number: u16) -> PendingMessage {
14462
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    72
        if let Destination::ToAll {
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    73
            ref mut protocol, ..
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    74
        } = self.destination
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    75
        {
13424
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    76
            *protocol = Some(protocol_number)
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    77
        }
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    78
        self
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    79
    }
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    80
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    81
    pub fn but_self(mut self) -> PendingMessage {
14462
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    82
        if let Destination::ToAll {
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    83
            ref mut skip_self, ..
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    84
        } = self.destination
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    85
        {
13424
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    86
            *skip_self = true
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    87
        }
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    88
        self
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    89
    }
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    90
}
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    91
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
    92
impl HWServerMessage {
14462
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    93
    pub fn send(self, client_id: ClientId) -> PendingMessage {
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    94
        PendingMessage::send(self, client_id)
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    95
    }
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    96
    pub fn send_self(self) -> PendingMessage {
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    97
        PendingMessage::send_self(self)
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    98
    }
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
    99
    pub fn send_all(self) -> PendingMessage {
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
   100
        PendingMessage::send_all(self)
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14461
diff changeset
   101
    }
13424
81e0ed105f5d implementation of team related messages
alfadur
parents: 13421
diff changeset
   102
}