gameServer2/src/server/handlers.rs
author unc0rr
Tue, 24 Jan 2017 20:28:16 +0300
changeset 12143 7e874846afe3
child 12144 589a2d7d3dc5
permissions -rw-r--r--
Toss code around

use mio;
use std::io::Write;
use std::io;

use super::server::HWServer;
use super::actions::Action;
use super::actions::Action::*;
use protocol::messages::HWProtocolMessage;
use protocol::messages::HWServerMessage::*;

pub fn handle(server: &mut HWServer, token: mio::Token, poll: &mio::Poll, action: Action) {
    match action {
        SendMe(msg) => server.send(token, &msg),
        ByeClient(msg) => {
            server.react(token, poll, vec![
                SendMe(Bye(&msg).to_raw_protocol()),
                RemoveClient,
                ]);
        },
        RemoveClient => {
            server.clients[token].deregister(poll);
            server.clients.remove(token);
        },
        ReactProtocolMessage(msg) => match msg {
            HWProtocolMessage::Ping =>
                server.react(token, poll, vec![SendMe(Pong.to_raw_protocol())]),
            HWProtocolMessage::Quit(Some(msg)) =>
                server.react(token, poll, vec![ByeClient("User quit: ".to_string() + &msg)]),
            HWProtocolMessage::Quit(None) =>
                server.react(token, poll, vec![ByeClient("User quit".to_string())]),
            HWProtocolMessage::Nick(nick) =>
                if server.clients[token].nick.len() == 0 {
                server.react(token, poll, vec![SendMe(Nick(&nick).to_raw_protocol())]);
                server.clients[token].nick = nick;
            },
            HWProtocolMessage::Malformed => warn!("Malformed/unknown message"),
            HWProtocolMessage::Empty => warn!("Empty message"),
            _ => unimplemented!(),
        }
        //_ => unimplemented!(),
    }
}