kubi/kubi-server/src/server.rs

use shipyard::{AllStoragesView, Unique, UniqueView, UniqueViewMut};
use kubi_shared::networking::messages::{ClientToServerMessage, ServerToClientMessage};
use uflow::server::Server;
use std::time::Duration;
use crate::config::ConfigTable;

#[derive(Unique)]
#[repr(transparent)]
pub struct UdpServer(pub Server<ServerToClientMessage, ClientToServerMessage>);

#[derive(Unique, Default)]
pub struct ServerEvents(pub Vec<ServerEvent<ClientToServerMessage>>);

pub fn bind_server(
  storages: AllStoragesView,
) {
  log::info!("Creating server...");
  let config = storages.borrow::<UniqueView<ConfigTable>>().unwrap();
  let server: Server<ServerToClientMessage, ClientToServerMessage> = Server::bind(
    config.server.address, 
    ServerConfig { 
      max_clients: config.server.max_clients,
      client_timeout: Duration::from_millis(config.server.timeout_ms),
      ..Default::default()
    }
  ).unwrap();
  storages.add_unique(UdpServer(server));
  storages.add_unique(ServerEvents::default());
}

pub fn update_server(
  mut server: UniqueViewMut<UdpServer>
) {
  if let Err(error) = server.0.update() {
    log::error!("Server error: {error:?}")
  }
}

pub fn update_server_events(
  mut server: UniqueViewMut<UdpServer>,
  mut events: UniqueViewMut<ServerEvents>,
) {
  //drop current events
  events.0.clear();
  //fetch new ones
  events.0.extend(server.0.process_events().rev());
}