rust/hedgewars-server/src/server/handlers/lobby.rs
author alfadur <mail@none>
Sat, 02 Feb 2019 15:06:39 +0300
changeset 14692 455865ccd36c
parent 14525 6cc0fce249f9
child 14693 6e6632068a33
permissions -rw-r--r--
Server action refactoring part 2 of N
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
12147
03ccb89820f3 Room creation halfplemented
unc0rr
parents:
diff changeset
     1
use mio;
03ccb89820f3 Room creation halfplemented
unc0rr
parents:
diff changeset
     2
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
     3
use super::common::rnd_reply;
13666
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
     4
use crate::{
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
     5
    protocol::messages::{HWProtocolMessage, HWServerMessage::*},
13666
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
     6
    server::{
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
     7
        actions::{Action, Action::*},
14395
e5db279308d7 dispose of server mods
alfadur
parents: 13810
diff changeset
     8
        core::HWServer,
13666
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
     9
        coretypes::ClientId,
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
    10
    },
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    11
    utils::is_name_illegal,
13416
cdf69667593b partial room implementation
alfadur
parents: 13119
diff changeset
    12
};
13810
0463a4221327 cleanup crate imports
alfadur
parents: 13666
diff changeset
    13
use log::*;
12147
03ccb89820f3 Room creation halfplemented
unc0rr
parents:
diff changeset
    14
14692
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    15
pub fn handle(
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    16
    server: &mut HWServer,
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    17
    client_id: ClientId,
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    18
    response: &mut super::Response,
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    19
    message: HWProtocolMessage,
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    20
) {
13666
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
    21
    use crate::protocol::messages::HWProtocolMessage::*;
12147
03ccb89820f3 Room creation halfplemented
unc0rr
parents:
diff changeset
    22
    match message {
13416
cdf69667593b partial room implementation
alfadur
parents: 13119
diff changeset
    23
        CreateRoom(name, password) => {
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    24
            let actions = if is_name_illegal(&name) {
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    25
                vec![Warn("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())]
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    26
            } else if server.has_room(&name) {
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    27
                vec![Warn(
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    28
                    "A room with the same name already exists.".to_string(),
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    29
                )]
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    30
            } else {
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    31
                let flags_msg = ClientFlags(
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    32
                    "+hr".to_string(),
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    33
                    vec![server.clients[client_id].nick.clone()],
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    34
                );
14525
6cc0fce249f9 Server action refactoring part 1 of N
alfadur <mail@none>
parents: 14478
diff changeset
    35
6cc0fce249f9 Server action refactoring part 1 of N
alfadur <mail@none>
parents: 14478
diff changeset
    36
                let room_id = server.create_room(client_id, name, password);
6cc0fce249f9 Server action refactoring part 1 of N
alfadur <mail@none>
parents: 14478
diff changeset
    37
                let room = &server.rooms[room_id];
6cc0fce249f9 Server action refactoring part 1 of N
alfadur <mail@none>
parents: 14478
diff changeset
    38
                let client = &server.clients[client_id];
6cc0fce249f9 Server action refactoring part 1 of N
alfadur <mail@none>
parents: 14478
diff changeset
    39
14692
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    40
                response.add(
14525
6cc0fce249f9 Server action refactoring part 1 of N
alfadur <mail@none>
parents: 14478
diff changeset
    41
                    RoomAdd(room.info(Some(&client)))
6cc0fce249f9 Server action refactoring part 1 of N
alfadur <mail@none>
parents: 14478
diff changeset
    42
                        .send_all()
14692
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    43
                        .with_protocol(room.protocol_number),
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    44
                );
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    45
                response.add(flags_msg.send_self());
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    46
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    47
                response.add(ClientFlags("+i".to_string(), vec![client.nick.clone()]).send_self());
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    48
                vec![]
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    49
            };
14692
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    50
            server.react(client_id, actions);
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    51
        }
13119
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12852
diff changeset
    52
        Chat(msg) => {
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    53
            let actions = vec![ChatMsg {
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    54
                nick: server.clients[client_id].nick.clone(),
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    55
                msg,
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    56
            }
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    57
            .send_all()
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    58
            .in_room(server.lobby_id)
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    59
            .but_self()
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    60
            .action()];
13492
ba5211dddb21 Assorted chat fixes
alfadur
parents: 13450
diff changeset
    61
            server.react(client_id, actions);
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    62
        }
13666
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
    63
        JoinRoom(name, _password) => {
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
    64
            let room = server.rooms.iter().find(|(_, r)| r.name == name);
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
    65
            let room_id = room.map(|(_, r)| r.id);
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    66
            let nicks = server
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    67
                .clients
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    68
                .iter()
13666
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
    69
                .filter(|(_, c)| c.room_id == room_id)
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
    70
                .map(|(_, c)| c.nick.clone())
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
    71
                .collect();
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
    72
            let c = &mut server.clients[client_id];
13427
6f6a866c86a2 Send more data on room joining
alfadur
parents: 13419
diff changeset
    73
13666
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
    74
            let actions = if let Some((_, r)) = room {
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
    75
                if c.protocol_number != r.protocol_number {
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    76
                    vec![Warn(
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    77
                        "Room version incompatible to your Hedgewars version!".to_string(),
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    78
                    )]
13666
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
    79
                } else if r.is_join_restricted() {
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    80
                    vec![Warn(
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    81
                        "Access denied. This room currently doesn't allow joining.".to_string(),
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    82
                    )]
13666
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
    83
                } else if r.players_number == u8::max_value() {
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
    84
                    vec![Warn("This room is already full".to_string())]
14692
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    85
                } else if let Some(room_id) = room_id {
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    86
                    let nick = c.nick.clone();
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    87
                    server.move_to_room(client_id, room_id);
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    88
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    89
                    response.add(RoomJoined(vec![nick.clone()]).send_all().in_room(room_id));
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    90
                    response.add(ClientFlags("+i".to_string(), vec![nick]).send_all());
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    91
                    response.add(RoomJoined(nicks).send_self());
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    92
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    93
                    let room = &server.rooms[room_id];
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    94
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    95
                    if !room.greeting.is_empty() {
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    96
                        response.add(
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    97
                            ChatMsg {
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    98
                                nick: "[greeting]".to_string(),
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
    99
                                msg: room.greeting.clone(),
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
   100
                            }
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
   101
                            .send_self(),
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
   102
                        );
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
   103
                    }
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
   104
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
   105
                    vec![]
13427
6f6a866c86a2 Send more data on room joining
alfadur
parents: 13419
diff changeset
   106
                } else {
14692
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14525
diff changeset
   107
                    vec![]
13666
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
   108
                }
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
   109
            } else {
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
   110
                vec![Warn("No such room.".to_string())]
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13494
diff changeset
   111
            };
13419
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
   112
            server.react(client_id, actions);
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
   113
        }
13445
d3c86ade3d4d Send the rnd reply to the room only.
Marcin Mielniczuk <marmistrz.dev@zoho.eu>
parents: 13444
diff changeset
   114
        Rnd(v) => {
13492
ba5211dddb21 Assorted chat fixes
alfadur
parents: 13450
diff changeset
   115
            server.react(client_id, vec![rnd_reply(&v).send_self().action()]);
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
   116
        }
13119
1e39b8749072 separated the server logic from all the async io mess.
alfadur
parents: 12852
diff changeset
   117
        List => warn!("Deprecated LIST message received"),
12147
03ccb89820f3 Room creation halfplemented
unc0rr
parents:
diff changeset
   118
        _ => warn!("Incorrect command in lobby state"),
03ccb89820f3 Room creation halfplemented
unc0rr
parents:
diff changeset
   119
    }
03ccb89820f3 Room creation halfplemented
unc0rr
parents:
diff changeset
   120
}