# HG changeset patch
# User unc0rr
# Date 1483298015 -10800
# Node ID 4348997e502b5760b3eb858e94a08821a165b2b6
# Parent  858bf4d04c541c76d5d4bff5a0445af41c404b3a
Refactor code to add more structure to it

diff -r 858bf4d04c54 -r 4348997e502b .hgignore
--- a/.hgignore	Sat Dec 31 23:56:29 2016 +0300
+++ b/.hgignore	Sun Jan 01 22:13:35 2017 +0300
@@ -78,3 +78,8 @@
 glob:xcuserdata
 glob:*.mode1v3
 glob:*.mode2v3
+glob:gameServer2/target
+glob:gameServer2/Cargo.lock
+glob:gameServer2/gameServer2.iml
+glob:.idea
+
diff -r 858bf4d04c54 -r 4348997e502b gameServer2/Cargo.toml
--- a/gameServer2/Cargo.toml	Sat Dec 31 23:56:29 2016 +0300
+++ b/gameServer2/Cargo.toml	Sun Jan 01 22:13:35 2017 +0300
@@ -7,4 +7,4 @@
 [dependencies]
 rand = "0.3"
 mio = "0.6"
-
+slab = "0.3"
diff -r 858bf4d04c54 -r 4348997e502b gameServer2/src/main.rs
--- a/gameServer2/src/main.rs	Sat Dec 31 23:56:29 2016 +0300
+++ b/gameServer2/src/main.rs	Sun Jan 01 22:13:35 2017 +0300
@@ -1,27 +1,25 @@
 extern crate rand;
 extern crate mio;
+extern crate slab;
 
-use std::io::*;
+//use std::io::*;
 //use rand::Rng;
 //use std::cmp::Ordering;
 use mio::tcp::*;
 use mio::*;
 
 mod utils;
-
-const SERVER: mio::Token = mio::Token(0);
-
-
+mod server;
 
 fn main() {
     println!("Hedgewars game server, protocol {}", utils::PROTOCOL_VERSION);
 
     let address = "0.0.0.0:46631".parse().unwrap();
-    let server = TcpListener::bind(&address).unwrap();
+    let listener = TcpListener::bind(&address).unwrap();
+    let mut server = server::HWServer::new(listener, 1024, 512);
 
     let poll = Poll::new().unwrap();
-    poll.register(&server, SERVER, Ready::readable(),
-               PollOpt::edge()).unwrap();
+    server.register(&poll).unwrap();
 
     let mut events = Events::with_capacity(1024);
 
@@ -30,17 +28,7 @@
 
         for event in events.iter() {
             match event.token() {
-                SERVER => match server.accept() {
-                    Ok((mut client_stream, addr)) => {
-                        println!("Connected: {}", addr);
-                        client_stream.write_all(
-                            format!("CONNECTED\nHedgewars server http://www.hedgewars.org/\n{}\n\n"
-                                    , utils::PROTOCOL_VERSION).as_bytes()
-                        );
-                    },
-                    _ => unreachable!()
-                },
-
+                utils::SERVER => server.accept(&poll).unwrap(),
                 _ => unreachable!(),
             }
         }
diff -r 858bf4d04c54 -r 4348997e502b gameServer2/src/server.rs
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/gameServer2/src/server.rs	Sun Jan 01 22:13:35 2017 +0300
@@ -0,0 +1,71 @@
+use slab::*;
+use mio::tcp::*;
+use mio::*;
+use mio;
+use std::io::Write;
+use std::io;
+
+use utils;
+
+pub struct HWServer {
+    listener: TcpListener,
+    clients: Slab<HWClient>,
+    rooms: Slab<HWRoom>
+}
+
+impl HWServer {
+    pub fn new(listener: TcpListener, clients_limit: usize, rooms_limit: usize) -> HWServer {
+        HWServer {
+            listener: listener,
+            clients: Slab::with_capacity(clients_limit),
+            rooms: Slab::with_capacity(rooms_limit),
+        }
+    }
+
+    pub fn register(&self, poll: &Poll) -> io::Result<()> {
+        poll.register(&self.listener, utils::SERVER, Ready::readable(),
+                      PollOpt::edge())
+    }
+
+    pub fn accept(&mut self, poll: &Poll) -> io::Result<()> {
+        let (sock, addr) = self.listener.accept().unwrap();
+        println!("Connected: {}", addr);
+
+        let client = HWClient::new(sock);
+        let token = self.clients.insert(client)
+            .ok().expect("could not add connection to slab");
+
+        self.clients[token].send_raw_msg(
+            format!("CONNECTED\nHedgewars server http://www.hedgewars.org/\n{}\n\n"
+            , utils::PROTOCOL_VERSION).as_bytes());
+
+        self.clients[token].uid = Some(token);
+        poll.register(&self.clients[token].sock, mio::Token(token), Ready::readable(),
+                      PollOpt::edge() | PollOpt::oneshot())
+            .ok().expect("could not register socket with event loop");
+
+        Ok(())
+    }
+}
+
+struct HWClient {
+    sock: TcpStream,
+    uid: Option<usize>
+}
+
+impl HWClient {
+    fn new(sock: TcpStream) -> HWClient {
+        HWClient {
+            sock: sock,
+            uid: None
+        }
+    }
+
+    fn send_raw_msg(&mut self, msg: &[u8]) {
+        self.sock.write_all(msg).unwrap();
+    }
+}
+
+struct HWRoom {
+    name: String
+}
diff -r 858bf4d04c54 -r 4348997e502b gameServer2/src/utils.rs
--- a/gameServer2/src/utils.rs	Sat Dec 31 23:56:29 2016 +0300
+++ b/gameServer2/src/utils.rs	Sun Jan 01 22:13:35 2017 +0300
@@ -1,1 +1,4 @@
+use mio;
+
 pub const PROTOCOL_VERSION : i32 = 3;
+pub const SERVER: mio::Token = mio::Token(1000000000 + 0);