1 use mio;

     2 use std::io::Write;

     3 use std::io;

     4 

     5 use super::server::HWServer;

     6 use super::actions::Action;

     7 use super::actions::Action::*;

     8 use protocol::messages::HWProtocolMessage;

     9 use protocol::messages::HWServerMessage::*;

    10 

    11 pub fn handle(server: &mut HWServer, token: mio::Token, poll: &mio::Poll, action: Action) {

    12     match action {

    13         SendMe(msg) => server.send(token, &msg),

    14         ByeClient(msg) => {

    15             server.react(token, poll, vec![

    16                 SendMe(Bye(&msg).to_raw_protocol()),

    17                 RemoveClient,

    18                 ]);

    19         },

    20         RemoveClient => {

    21             server.clients[token].deregister(poll);

    22             server.clients.remove(token);

    23         },

    24         ReactProtocolMessage(msg) => match msg {

    25             HWProtocolMessage::Ping =>

    26                 server.react(token, poll, vec![SendMe(Pong.to_raw_protocol())]),

    27             HWProtocolMessage::Quit(Some(msg)) =>

    28                 server.react(token, poll, vec![ByeClient("User quit: ".to_string() + &msg)]),

    29             HWProtocolMessage::Quit(None) =>

    30                 server.react(token, poll, vec![ByeClient("User quit".to_string())]),

    31             HWProtocolMessage::Nick(nick) =>

    32                 if server.clients[token].nick.len() == 0 {

    33                 server.react(token, poll, vec![SendMe(Nick(&nick).to_raw_protocol())]);

    34                 server.clients[token].nick = nick;

    35             },

    36             HWProtocolMessage::Malformed => warn!("Malformed/unknown message"),

    37             HWProtocolMessage::Empty => warn!("Empty message"),

    38             _ => unimplemented!(),

    39         }

    40         //_ => unimplemented!(),

    41     }

    42 }