rust/hedgewars-server/src/handlers/inanteroom.rs
author alfadur <mail@none>
Sat, 04 Jan 2020 01:39:13 +0300
changeset 15558 a798e6441a36
parent 15554 f1205f33bf5b
child 15562 479911540e17
permissions -rw-r--r--
simplify team handling
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
15554
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
     3
use super::strings::*;
13666
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13450
diff changeset
     4
use crate::{
15095
c5a6e8566425 shuffle server files
alfadur
parents: 14891
diff changeset
     5
    core::{
15542
fd3a20e9d095 move the anteroom out of the server
alfadur <mail@none>
parents: 15124
diff changeset
     6
        anteroom::{HwAnteroom, HwAnteroomClient},
15096
e935b1ad23f3 normalize type names
alfadur
parents: 15095
diff changeset
     7
        client::HwClient,
15542
fd3a20e9d095 move the anteroom out of the server
alfadur <mail@none>
parents: 15124
diff changeset
     8
        server::HwServer,
15096
e935b1ad23f3 normalize type names
alfadur
parents: 15095
diff changeset
     9
        types::ClientId,
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    10
    },
15096
e935b1ad23f3 normalize type names
alfadur
parents: 15095
diff changeset
    11
    protocol::messages::{HwProtocolMessage, HwProtocolMessage::LoadRoom, HwServerMessage::*},
e935b1ad23f3 normalize type names
alfadur
parents: 15095
diff changeset
    12
    utils::is_name_illegal,
13419
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
    13
};
15095
c5a6e8566425 shuffle server files
alfadur
parents: 14891
diff changeset
    14
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    15
use log::*;
13774
0118b7412570 use openssl for password message handling
alfadur
parents: 13771
diff changeset
    16
#[cfg(feature = "official-server")]
0118b7412570 use openssl for password message handling
alfadur
parents: 13771
diff changeset
    17
use openssl::sha::sha1;
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    18
use std::{
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    19
    fmt::{Formatter, LowerHex},
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    20
    num::NonZeroU16,
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    21
};
13774
0118b7412570 use openssl for password message handling
alfadur
parents: 13771
diff changeset
    22
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    23
pub enum LoginResult {
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    24
    Unchanged,
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    25
    Complete,
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    26
    Exit,
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    27
}
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    28
14802
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    29
fn completion_result<'a, I>(
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    30
    mut other_clients: I,
15542
fd3a20e9d095 move the anteroom out of the server
alfadur <mail@none>
parents: 15124
diff changeset
    31
    client: &mut HwAnteroomClient,
14802
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    32
    response: &mut super::Response,
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    33
) -> LoginResult
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    34
where
15542
fd3a20e9d095 move the anteroom out of the server
alfadur <mail@none>
parents: 15124
diff changeset
    35
    I: Iterator<Item = &'a HwClient>,
14802
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    36
{
15554
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
    37
    let has_nick_clash = other_clients.any(|c| c.nick == *client.nick.as_ref().unwrap());
14800
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14717
diff changeset
    38
14802
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    39
    if has_nick_clash {
15554
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
    40
        client.nick = None;
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
    41
        response.add(Notice("NickAlreadyInUse".to_string()).send_self());
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
    42
        LoginResult::Unchanged
14802
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    43
    } else {
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    44
        #[cfg(feature = "official-server")]
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    45
        {
15124
823052e66611 check for account existence before asking passwords
alfadur
parents: 15096
diff changeset
    46
            response.request_io(super::IoTask::CheckRegistered {
823052e66611 check for account existence before asking passwords
alfadur
parents: 15096
diff changeset
    47
                nick: client.nick.as_ref().unwrap().clone(),
823052e66611 check for account existence before asking passwords
alfadur
parents: 15096
diff changeset
    48
            });
14802
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    49
            LoginResult::Unchanged
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    50
        }
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    51
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    52
        #[cfg(not(feature = "official-server"))]
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    53
        {
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    54
            LoginResult::Complete
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    55
        }
14800
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14717
diff changeset
    56
    }
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14717
diff changeset
    57
}
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14717
diff changeset
    58
14692
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14478
diff changeset
    59
pub fn handle(
15542
fd3a20e9d095 move the anteroom out of the server
alfadur <mail@none>
parents: 15124
diff changeset
    60
    server_state: &mut super::ServerState,
14692
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14478
diff changeset
    61
    client_id: ClientId,
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14478
diff changeset
    62
    response: &mut super::Response,
15096
e935b1ad23f3 normalize type names
alfadur
parents: 15095
diff changeset
    63
    message: HwProtocolMessage,
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    64
) -> LoginResult {
12147
03ccb89820f3 Room creation halfplemented
unc0rr
parents:
diff changeset
    65
    match message {
15096
e935b1ad23f3 normalize type names
alfadur
parents: 15095
diff changeset
    66
        HwProtocolMessage::Quit(_) => {
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    67
            response.add(Bye("User quit".to_string()).send_self());
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    68
            LoginResult::Exit
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    69
        }
15096
e935b1ad23f3 normalize type names
alfadur
parents: 15095
diff changeset
    70
        HwProtocolMessage::Nick(nick) => {
15542
fd3a20e9d095 move the anteroom out of the server
alfadur <mail@none>
parents: 15124
diff changeset
    71
            let client = &mut server_state.anteroom.clients[client_id];
14891
ce98c37826a7 fix accepting on wrong server socket
alfadur
parents: 14802
diff changeset
    72
14802
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
    73
            if client.nick.is_some() {
15554
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
    74
                response.error(NICKNAME_PROVIDED);
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    75
                LoginResult::Unchanged
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    76
            } else if is_name_illegal(&nick) {
15554
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
    77
                response.add(Bye(ILLEGAL_CLIENT_NAME.to_string()).send_self());
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    78
                LoginResult::Exit
14478
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14436
diff changeset
    79
            } else {
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    80
                client.nick = Some(nick.clone());
14693
6e6632068a33 Server action refactoring part 3 of N
alfadur <mail@none>
parents: 14692
diff changeset
    81
                response.add(Nick(nick).send_self());
14694
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14693
diff changeset
    82
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    83
                if client.protocol_number.is_some() {
15542
fd3a20e9d095 move the anteroom out of the server
alfadur <mail@none>
parents: 15124
diff changeset
    84
                    completion_result(server_state.server.iter_clients(), client, response)
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    85
                } else {
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    86
                    LoginResult::Unchanged
14694
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14693
diff changeset
    87
                }
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14693
diff changeset
    88
            }
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14693
diff changeset
    89
        }
15096
e935b1ad23f3 normalize type names
alfadur
parents: 15095
diff changeset
    90
        HwProtocolMessage::Proto(proto) => {
15542
fd3a20e9d095 move the anteroom out of the server
alfadur <mail@none>
parents: 15124
diff changeset
    91
            let client = &mut server_state.anteroom.clients[client_id];
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    92
            if client.protocol_number.is_some() {
15554
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
    93
                response.error(PROTOCOL_PROVIDED);
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    94
                LoginResult::Unchanged
15558
a798e6441a36 simplify team handling
alfadur <mail@none>
parents: 15554
diff changeset
    95
            } else if proto < 51 {
15554
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
    96
                response.add(Bye(PROTOCOL_TOO_OLD.to_string()).send_self());
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
    97
                LoginResult::Exit
14694
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14693
diff changeset
    98
            } else {
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
    99
                client.protocol_number = NonZeroU16::new(proto);
14694
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14693
diff changeset
   100
                response.add(Proto(proto).send_self());
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14693
diff changeset
   101
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
   102
                if client.nick.is_some() {
15542
fd3a20e9d095 move the anteroom out of the server
alfadur <mail@none>
parents: 15124
diff changeset
   103
                    completion_result(server_state.server.iter_clients(), client, response)
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
   104
                } else {
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
   105
                    LoginResult::Unchanged
14694
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14693
diff changeset
   106
                }
14693
6e6632068a33 Server action refactoring part 3 of N
alfadur <mail@none>
parents: 14692
diff changeset
   107
            }
13771
4664da990556 Add official server feature to cargo
alfadur
parents: 13666
diff changeset
   108
        }
4664da990556 Add official server feature to cargo
alfadur
parents: 13666
diff changeset
   109
        #[cfg(feature = "official-server")]
15096
e935b1ad23f3 normalize type names
alfadur
parents: 15095
diff changeset
   110
        HwProtocolMessage::Password(hash, salt) => {
15542
fd3a20e9d095 move the anteroom out of the server
alfadur <mail@none>
parents: 15124
diff changeset
   111
            let client = &server_state.anteroom.clients[client_id];
13774
0118b7412570 use openssl for password message handling
alfadur
parents: 13771
diff changeset
   112
14800
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14717
diff changeset
   113
            if let (Some(nick), Some(protocol)) = (client.nick.as_ref(), client.protocol_number) {
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14717
diff changeset
   114
                response.request_io(super::IoTask::GetAccount {
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14717
diff changeset
   115
                    nick: nick.clone(),
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14717
diff changeset
   116
                    protocol: protocol.get(),
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14717
diff changeset
   117
                    server_salt: client.server_salt.clone(),
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14717
diff changeset
   118
                    client_salt: salt,
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14717
diff changeset
   119
                    password_hash: hash,
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14717
diff changeset
   120
                });
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14717
diff changeset
   121
            };
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14717
diff changeset
   122
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14717
diff changeset
   123
            LoginResult::Unchanged
14693
6e6632068a33 Server action refactoring part 3 of N
alfadur <mail@none>
parents: 14692
diff changeset
   124
        }
13774
0118b7412570 use openssl for password message handling
alfadur
parents: 13771
diff changeset
   125
        #[cfg(feature = "official-server")]
15096
e935b1ad23f3 normalize type names
alfadur
parents: 15095
diff changeset
   126
        HwProtocolMessage::Checker(protocol, nick, password) => {
15542
fd3a20e9d095 move the anteroom out of the server
alfadur <mail@none>
parents: 15124
diff changeset
   127
            let client = &mut server_state.anteroom.clients[client_id];
14802
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
   128
            if protocol == 0 {
15554
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   129
                response.error("Bad number.");
14802
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
   130
                LoginResult::Unchanged
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
   131
            } else {
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
   132
                client.protocol_number = NonZeroU16::new(protocol);
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
   133
                client.is_checker = true;
15554
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   134
                #[cfg(not(feature = "official-server"))]
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   135
                {
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   136
                    response.request_io(super::IoTask::GetCheckerAccount {
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   137
                        nick: nick,
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   138
                        password: password,
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   139
                    });
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   140
                    LoginResult::Unchanged
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   141
                }
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   142
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   143
                #[cfg(feature = "official-server")]
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   144
                {
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   145
                    response.add(LogonPassed.send_self());
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   146
                    LoginResult::Complete
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   147
                }
14802
01f8ab45f806 fix lobby joining
alfadur
parents: 14800
diff changeset
   148
            }
13771
4664da990556 Add official server feature to cargo
alfadur
parents: 13666
diff changeset
   149
        }
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
   150
        _ => {
15554
f1205f33bf5b complete checker login handling
alfadur <mail@none>
parents: 15542
diff changeset
   151
            warn!("Incorrect command in anteroom");
14714
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
   152
            LoginResult::Unchanged
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14711
diff changeset
   153
        }
12147
03ccb89820f3 Room creation halfplemented
unc0rr
parents:
diff changeset
   154
    }
03ccb89820f3 Room creation halfplemented
unc0rr
parents:
diff changeset
   155
}