look at that player count is dynamic wowowowowowowwow

Author: SubAt0m1c

server/src/network/internal_packets.rs

@@ -4,9 +4,7 @@ use crate::types::status::StatusUpdate;
 use bytes::Bytes;
 
 pub enum NetworkThreadMessage {
-    UpdateStatus {
-        update: StatusUpdate
-    },
+    UpdateStatus(StatusUpdate),
 
     SendPackets {
         client_id: ClientId,

server/src/network/network.rs

@@ -66,7 +66,7 @@ async fn run_network_thread(
                 // we can just discard main thread -> network thread messages with a disconnected client_id
                 // as the main thread either already has or will be be informed shortly of this issue
                 match msg { 
-                    NetworkThreadMessage::UpdateStatus { update } => status.set(update),
+                    NetworkThreadMessage::UpdateStatus(update) => status.set(update),
                     NetworkThreadMessage::SendPackets { client_id, buffer } => {
                         if let Some(client_tx) = clients.get(&client_id) {
                             if let Err(e) = client_tx.send(ClientHandlerMessage::Send(buffer)) {

server/src/world/world.rs

@@ -1,3 +1,4 @@
+use crate::block::metadata::u3;
 use crate::constants::Particle;
 use crate::entity::entity::{Entity, EntityId, EntityImpl};
 use crate::entity::entity_metadata::EntityMetadata;
@@ -7,6 +8,7 @@ use crate::network::internal_packets::{MainThreadMessage, NetworkThreadMessage};
 use crate::network::packets::packet::ProcessPacket;
 use crate::network::protocol::play::clientbound::{DestroyEntites, JoinGame, Particles, PlayerData, PlayerListItem, PositionLook};
 use crate::player::player::{ClientId, GameProfile, Player, PlayerExtension};
+use crate::types::status::StatusUpdate;
 use crate::world::chunk::chunk_grid::ChunkGrid;
 use crate::world::chunk::get_chunk_position;
 use enumset::EnumSet;
@@ -287,7 +289,8 @@ impl<E : WorldExtension> World<E> {
         match event {
             MainThreadMessage::NewPlayer { client_id, profile } => {
                 println!("new player");
-                E::on_player_join(self, profile, client_id)
+                E::on_player_join(self, profile, client_id);
+                let _ = self.network_tx.send(NetworkThreadMessage::UpdateStatus(StatusUpdate::Players(self.players.len() as u32)));
             }
             MainThreadMessage::PacketReceived { client_id, packet } => {
                 if let Some(index) = self.player_map.get(&client_id) {
@@ -297,6 +300,7 @@ impl<E : WorldExtension> World<E> {
             }
             MainThreadMessage::ClientDisconnected { client_id } => {
                 self.remove_player(client_id);
+                let _ = self.network_tx.send(NetworkThreadMessage::UpdateStatus(StatusUpdate::Players(self.players.len() as u32)));
             }
         }
     }

src/main.rs

@@ -85,7 +85,7 @@ async fn main() -> anyhow::Result<()> {
         .append(ChatComponent::new(" version ").color(MCColors::Gray))
         .append(ChatComponent::new(env!("CARGO_PKG_VERSION")).color(MCColors::Green));
 
-    let status = Status::new(1, 0, text, get_assets().icon_data);
+    let status = Status::new(0, 1, text, get_assets().icon_data);
     let (tx, mut rx) = start_network("127.0.0.1:4972", status);
 
     let mut world = initialize_world(tx)?;