#![expect(clippy::await_holding_lock)] #[cfg(target_os = "wasi")] compile_error!("Compiling for WASI targets is not supported!"); use mio::net::TcpListener; use mio::{Events, Interest, Poll, Token}; use std::collections::HashMap; use std::io::{self}; use client::{interrupted, Client}; use server::Server; // Setup some tokens to allow us to identify which event is for which socket. pub mod client; pub mod commands; pub mod entity; pub mod proxy; pub mod rcon; pub mod server; pub mod util; pub mod world; fn main() -> io::Result<()> { use std::sync::{Arc, Mutex}; use entity::player::Player; use pumpkin_config::{ADVANCED_CONFIG, BASIC_CONFIG}; use pumpkin_core::text::{color::NamedColor, TextComponent}; use rcon::RCONServer; simple_logger::SimpleLogger::new() .with_level(log::LevelFilter::Info) .init() .unwrap(); let rt = tokio::runtime::Builder::new_multi_thread() .enable_all() .build() .unwrap(); ctrlc::set_handler(|| { log::warn!( "{}", TextComponent::text("Stopping Server") .color_named(NamedColor::Red) .to_pretty_console() ); std::process::exit(0); }) .unwrap(); // ensure rayon is built outside of tokio scope rayon::ThreadPoolBuilder::new().build_global().unwrap(); rt.block_on(async { const SERVER: Token = Token(0); use std::time::Instant; let time = Instant::now(); // Create a poll instance. let mut poll = Poll::new()?; // Create storage for events. let mut events = Events::with_capacity(128); // Setup the TCP server socket. let addr = BASIC_CONFIG.server_address; let mut listener = TcpListener::bind(addr)?; // Register the server with poll we can receive events for it. poll.registry() .register(&mut listener, SERVER, Interest::READABLE)?; // Unique token for each incoming connection. let mut unique_token = Token(SERVER.0 + 1); let use_console = ADVANCED_CONFIG.commands.use_console; let rcon = ADVANCED_CONFIG.rcon.clone(); let mut clients: HashMap = HashMap::new(); let mut players: HashMap>> = HashMap::new(); let server = Arc::new(Server::new()); log::info!("Started Server took {}ms", time.elapsed().as_millis()); log::info!("You now can connect to the server, Listening on {}", addr); if use_console { let server = server.clone(); tokio::spawn(async move { let stdin = std::io::stdin(); loop { let mut out = String::new(); stdin .read_line(&mut out) .expect("Failed to read console line"); if !out.is_empty() { let dispatcher = server.command_dispatcher.clone(); dispatcher.handle_command( &mut commands::CommandSender::Console, &server, &out, ); } } }); } if rcon.enabled { let server = server.clone(); tokio::spawn(async move { RCONServer::new(&rcon, server).await.unwrap(); }); } loop { if let Err(err) = poll.poll(&mut events, None) { if interrupted(&err) { continue; } return Err(err); } for event in events.iter() { match event.token() { SERVER => loop { // Received an event for the TCP server socket, which // indicates we can accept an connection. let (mut connection, address) = match listener.accept() { Ok((connection, address)) => (connection, address), Err(e) if e.kind() == io::ErrorKind::WouldBlock => { // If we get a `WouldBlock` error we know our // listener has no more incoming connections queued, // so we can return to polling and wait for some // more. break; } Err(e) => { // If it was any other kind of error, something went // wrong and we terminate with an error. return Err(e); } }; if let Err(e) = connection.set_nodelay(true) { log::warn!("failed to set TCP_NODELAY {e}"); } log::info!("Accepted connection from: {}", address); let token = next(&mut unique_token); poll.registry().register( &mut connection, token, Interest::READABLE.add(Interest::WRITABLE), )?; let client = Client::new(token, connection, addr); clients.insert(token, client); }, token => { // Poll Players if let Some(player) = players.get_mut(&token) { let mut player = player.lock().unwrap(); player.client.poll(event).await; if !player.client.closed { player.process_packets(&server).await; } if player.client.closed { drop(player); if let Some(player) = players.remove(&token) { let mut player = player.lock().unwrap(); player.remove().await; poll.registry().deregister(&mut player.client.connection)?; } } }; // Poll current Clients (non players) // Maybe received an event for a TCP connection. let (done, make_player) = if let Some(client) = clients.get_mut(&token) { client.poll(event).await; if !client.closed { client.process_packets(&server).await; } (client.closed, client.make_player) } else { // Sporadic events happen, we can safely ignore them. (false, false) }; if done || make_player { if let Some(mut client) = clients.remove(&token) { if done { poll.registry().deregister(&mut client.connection)?; } else if make_player { let token = client.token; let (player, world) = server.add_player(token, client).await; players.insert(token, player.clone()); let mut world = world.lock().await; world.spawn_player(&BASIC_CONFIG, player).await; } } } } } } } }) } fn next(current: &mut Token) -> Token { let next = current.0; current.0 += 1; Token(next) }