rust/hedgewars-server/src/handlers/inanteroom.rs
author alfadur
Tue, 28 May 2019 19:04:18 +0300
changeset 15074 c5a6e8566425
parent 14870 rust/hedgewars-server/src/server/handlers/loggingin.rs@ce98c37826a7
child 15075 e935b1ad23f3
permissions -rw-r--r--
shuffle server files
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
13666
09f4a30e50cc Rust 2018 conversion
alfadur
parents: 13478
diff changeset
     3
use crate::{
15074
c5a6e8566425 shuffle server files
alfadur
parents: 14870
diff changeset
     4
    protocol::messages::{
c5a6e8566425 shuffle server files
alfadur
parents: 14870
diff changeset
     5
        HWProtocolMessage::LoadRoom,
c5a6e8566425 shuffle server files
alfadur
parents: 14870
diff changeset
     6
        HWProtocolMessage,
c5a6e8566425 shuffle server files
alfadur
parents: 14870
diff changeset
     7
        HWServerMessage::*},
c5a6e8566425 shuffle server files
alfadur
parents: 14870
diff changeset
     8
    core::{
c5a6e8566425 shuffle server files
alfadur
parents: 14870
diff changeset
     9
        client::HWClient,
c5a6e8566425 shuffle server files
alfadur
parents: 14870
diff changeset
    10
        server::{HWServer, HWAnteClient, HWAnteroom},
c5a6e8566425 shuffle server files
alfadur
parents: 14870
diff changeset
    11
        types::ClientId
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    12
    },
15074
c5a6e8566425 shuffle server files
alfadur
parents: 14870
diff changeset
    13
    utils::is_name_illegal
13419
81e0ed105f5d implementation of team related messages
alfadur
parents: 13416
diff changeset
    14
};
15074
c5a6e8566425 shuffle server files
alfadur
parents: 14870
diff changeset
    15
14457
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14415
diff changeset
    16
use log::*;
13800
0118b7412570 use openssl for password message handling
alfadur
parents: 13798
diff changeset
    17
#[cfg(feature = "official-server")]
0118b7412570 use openssl for password message handling
alfadur
parents: 13798
diff changeset
    18
use openssl::sha::sha1;
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    19
use std::{
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    20
    fmt::{Formatter, LowerHex},
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    21
    num::NonZeroU16,
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    22
};
13800
0118b7412570 use openssl for password message handling
alfadur
parents: 13798
diff changeset
    23
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    24
pub enum LoginResult {
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    25
    Unchanged,
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    26
    Complete,
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    27
    Exit,
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    28
}
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    29
14781
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    30
fn completion_result<'a, I>(
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    31
    mut other_clients: I,
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    32
    client: &mut HWAnteClient,
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    33
    response: &mut super::Response,
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    34
) -> LoginResult
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    35
where
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    36
    I: Iterator<Item = (ClientId, &'a HWClient)>,
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    37
{
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    38
    let has_nick_clash =
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    39
        other_clients.any(|(_, c)| !c.is_checker() && c.nick == *client.nick.as_ref().unwrap());
14779
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14696
diff changeset
    40
14781
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    41
    if has_nick_clash {
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    42
        if client.protocol_number.unwrap().get() < 38 {
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    43
            response.add(Bye("User quit: Nickname is already in use".to_string()).send_self());
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    44
            LoginResult::Exit
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    45
        } else {
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    46
            client.nick = None;
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    47
            response.add(Notice("NickAlreadyInUse".to_string()).send_self());
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    48
            LoginResult::Unchanged
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    49
        }
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    50
    } else {
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    51
        #[cfg(feature = "official-server")]
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    52
        {
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    53
            response.add(AskPassword(client.server_salt.clone()).send_self());
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    54
            LoginResult::Unchanged
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    55
        }
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    56
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    57
        #[cfg(not(feature = "official-server"))]
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    58
        {
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    59
            LoginResult::Complete
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    60
        }
14779
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14696
diff changeset
    61
    }
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14696
diff changeset
    62
}
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14696
diff changeset
    63
14671
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14457
diff changeset
    64
pub fn handle(
14781
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    65
    server: &mut HWServer,
14671
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14457
diff changeset
    66
    client_id: ClientId,
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14457
diff changeset
    67
    response: &mut super::Response,
455865ccd36c Server action refactoring part 2 of N
alfadur <mail@none>
parents: 14457
diff changeset
    68
    message: HWProtocolMessage,
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    69
) -> LoginResult {
12147
03ccb89820f3 Room creation halfplemented
unc0rr
parents:
diff changeset
    70
    match message {
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    71
        HWProtocolMessage::Quit(_) => {
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    72
            response.add(Bye("User quit".to_string()).send_self());
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    73
            LoginResult::Exit
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    74
        }
13416
cdf69667593b partial room implementation
alfadur
parents: 13119
diff changeset
    75
        HWProtocolMessage::Nick(nick) => {
14781
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    76
            let client = &mut server.anteroom.clients[client_id];
14870
ce98c37826a7 fix accepting on wrong server socket
alfadur
parents: 14781
diff changeset
    77
14781
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    78
            if client.nick.is_some() {
14672
6e6632068a33 Server action refactoring part 3 of N
alfadur <mail@none>
parents: 14671
diff changeset
    79
                response.add(Error("Nickname already provided.".to_string()).send_self());
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    80
                LoginResult::Unchanged
14457
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14415
diff changeset
    81
            } else if is_name_illegal(&nick) {
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    82
                response.add(Bye("Illegal nickname! Nicknames 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()).send_self());
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    83
                LoginResult::Exit
14457
98ef2913ec73 Apply rustfmt to all files
unc0rr
parents: 14415
diff changeset
    84
            } else {
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    85
                client.nick = Some(nick.clone());
14672
6e6632068a33 Server action refactoring part 3 of N
alfadur <mail@none>
parents: 14671
diff changeset
    86
                response.add(Nick(nick).send_self());
14673
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14672
diff changeset
    87
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    88
                if client.protocol_number.is_some() {
14781
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    89
                    completion_result(server.clients.iter(), client, response)
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    90
                } else {
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    91
                    LoginResult::Unchanged
14673
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14672
diff changeset
    92
                }
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14672
diff changeset
    93
            }
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14672
diff changeset
    94
        }
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14672
diff changeset
    95
        HWProtocolMessage::Proto(proto) => {
14781
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
    96
            let client = &mut server.anteroom.clients[client_id];
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    97
            if client.protocol_number.is_some() {
14673
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14672
diff changeset
    98
                response.add(Error("Protocol already known.".to_string()).send_self());
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
    99
                LoginResult::Unchanged
14673
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14672
diff changeset
   100
            } else if proto == 0 {
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14672
diff changeset
   101
                response.add(Error("Bad number.".to_string()).send_self());
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
   102
                LoginResult::Unchanged
14673
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14672
diff changeset
   103
            } else {
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
   104
                client.protocol_number = NonZeroU16::new(proto);
14673
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14672
diff changeset
   105
                response.add(Proto(proto).send_self());
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14672
diff changeset
   106
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
   107
                if client.nick.is_some() {
14781
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
   108
                    completion_result(server.clients.iter(), client, response)
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
   109
                } else {
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
   110
                    LoginResult::Unchanged
14673
08a8605bafaf Server action refactoring part 4 of N
alfadur <mail@none>
parents: 14672
diff changeset
   111
                }
14672
6e6632068a33 Server action refactoring part 3 of N
alfadur <mail@none>
parents: 14671
diff changeset
   112
            }
13798
4664da990556 Add official server feature to cargo
alfadur
parents: 13666
diff changeset
   113
        }
4664da990556 Add official server feature to cargo
alfadur
parents: 13666
diff changeset
   114
        #[cfg(feature = "official-server")]
13800
0118b7412570 use openssl for password message handling
alfadur
parents: 13798
diff changeset
   115
        HWProtocolMessage::Password(hash, salt) => {
14781
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
   116
            let client = &server.anteroom.clients[client_id];
13800
0118b7412570 use openssl for password message handling
alfadur
parents: 13798
diff changeset
   117
14779
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14696
diff changeset
   118
            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: 14696
diff changeset
   119
                response.request_io(super::IoTask::GetAccount {
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14696
diff changeset
   120
                    nick: nick.clone(),
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14696
diff changeset
   121
                    protocol: protocol.get(),
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14696
diff changeset
   122
                    server_salt: client.server_salt.clone(),
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14696
diff changeset
   123
                    client_salt: salt,
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14696
diff changeset
   124
                    password_hash: hash,
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14696
diff changeset
   125
                });
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14696
diff changeset
   126
            };
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14696
diff changeset
   127
f43ab2bd76ae add a thread for internal server IO and implement account checking with it
alfadur
parents: 14696
diff changeset
   128
            LoginResult::Unchanged
14672
6e6632068a33 Server action refactoring part 3 of N
alfadur <mail@none>
parents: 14671
diff changeset
   129
        }
13800
0118b7412570 use openssl for password message handling
alfadur
parents: 13798
diff changeset
   130
        #[cfg(feature = "official-server")]
13798
4664da990556 Add official server feature to cargo
alfadur
parents: 13666
diff changeset
   131
        HWProtocolMessage::Checker(protocol, nick, password) => {
14781
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
   132
            let client = &mut server.anteroom.clients[client_id];
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
   133
            if protocol == 0 {
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
   134
                response.add(Error("Bad number.".to_string()).send_self());
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
   135
                LoginResult::Unchanged
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
   136
            } else {
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
   137
                client.protocol_number = NonZeroU16::new(protocol);
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
   138
                client.nick = Some(nick);
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
   139
                client.is_checker = true;
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
   140
                LoginResult::Complete
01f8ab45f806 fix lobby joining
alfadur
parents: 14779
diff changeset
   141
            }
13798
4664da990556 Add official server feature to cargo
alfadur
parents: 13666
diff changeset
   142
        }
14693
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
   143
        _ => {
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
   144
            warn!("Incorrect command in logging-in state");
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
   145
            LoginResult::Unchanged
6a2e13e36b7f add server anteroom
alfadur <mail@none>
parents: 14690
diff changeset
   146
        }
12147
03ccb89820f3 Room creation halfplemented
unc0rr
parents:
diff changeset
   147
    }
03ccb89820f3 Room creation halfplemented
unc0rr
parents:
diff changeset
   148
}