use std::thread::sleep; use std::time::Duration; use std::path::Path; pub mod server; pub mod gameserver; pub mod room; pub mod util; pub mod controls; use self::gameserver::{GameServer, Action}; use self::server::unixserver::UnixServer; use self::server::tcpserver::TcpServer; use self::server::Server; use serde_json; fn main() { let addr = Path::new("\0rustifarm"); let unixserver = UnixServer::new(&addr).expect("binding unix server failed"); let addr = "127.0.0.1:1234".parse().unwrap(); let inetserver = TcpServer::new(&addr).expect("binding inet server failed"); let servers: Vec> = vec![Box::new(unixserver), Box::new(inetserver)]; let mut gameserver = GameServer::new(servers); let mut room = room::Room::new((32, 32)); loop { let actions = gameserver.update(); for action in actions { match action { Action::Join(name) => {room.add_player(&name);} Action::Leave(name) => {room.remove_player(&name);} Action::Input(name, control) => {room.control(name, control);} } } room.update(); let (field, mapping) = room.view(); let updatemsg = create_update_message(room.get_size(), field, mapping); gameserver.broadcast(updatemsg.as_str()); sleep(Duration::from_millis(100)); } } fn create_update_message((width, height): (i32, i32), field: Vec, mapping: Vec>) -> String { let updatemsg= serde_json::json!([ "world", [ [ "field", { "width": width, "height": height, "field": field, "mapping": mapping } ] ] ]); updatemsg.to_string() }