1 files changed, 28 insertions, 8 deletions

diff --git a/server/src/state.rs b/server/src/state.rs
index 2209fc5d..b4a8ce1f 100644
--- a/server/src/state.rs
+++ b/server/src/state.rs
@@ -25,7 +25,7 @@ impl Server {
         if self.start_pause_timer > 0. {
             self.start_pause_timer -= dt
         }
-        let should_pause = self.start_pause_timer > 0. || self.connections.iter().all(|c| c.1 .1);
+        let should_pause = self.start_pause_timer > 0. || self.connections.values().all(|c| c.idle);
         if should_pause != self.paused {
             info!("Game paused: {should_pause}");
             self.paused = should_pause;
@@ -66,7 +66,13 @@ impl Server {
         packet: PacketS,
     ) -> Result<Vec<PacketC>, TrError> {
         if let Some(p) = get_packet_player(&packet) {
-            if !self.connections.entry(conn).or_default().0.contains(&p) {
+            if !self
+                .connections
+                .entry(conn)
+                .or_default()
+                .players
+                .contains(&p)
+            {
                 return Err(tre!("s.error.packet_sender_invalid"));
             }
         }
@@ -88,12 +94,21 @@ impl Server {
                     }
                 }
             }
-            PacketS::Idle { paused } => self.connections.entry(conn).or_default().1 = *paused,
+            PacketS::Ready => {
+                self.connections.entry(conn).or_default().ready = true;
+            }
+            PacketS::Idle { paused } => {
+                self.connections.entry(conn).or_default().idle = *paused;
+            }
             PacketS::Leave { player } => {
-                self.connections.entry(conn).or_default().0.remove(player);
+                self.connections
+                    .entry(conn)
+                    .or_default()
+                    .players
+                    .remove(player);
             }
             PacketS::Join { .. } => {
-                if self.connections.entry(conn).or_default().0.len() > 8 {
+                if self.connections.entry(conn).or_default().players.len() > 8 {
                     return Err(tre!("s.error.conn_too_many_players"));
                 }
             }
@@ -103,7 +118,11 @@ impl Server {
 
         for p in &replies {
             if let PacketC::Joined { id } = p {
-                self.connections.entry(conn).or_default().0.insert(*id);
+                self.connections
+                    .entry(conn)
+                    .or_default()
+                    .players
+                    .insert(*id);
             }
         }
 
@@ -125,8 +144,8 @@ impl Server {
     }
 
     pub async fn disconnect(&mut self, conn: ConnectionID) {
-        if let Some((players, _)) = self.connections.get(&conn) {
-            for player in players.clone() {
+        if let Some(cd) = self.connections.get(&conn) {
+            for player in cd.players.clone() {
                 let _ = self.packet_in_outer(conn, PacketS::Leave { player }).await;
             }
         }
@@ -144,6 +163,7 @@ fn get_packet_player(packet: &PacketS) -> Option<PlayerID> {
         PacketS::Communicate { player, .. } => Some(*player),
         PacketS::ReplaceHand { player, .. } => Some(*player),
         PacketS::Effect { player, .. } => Some(*player),
+        PacketS::Ready => None,
         PacketS::ApplyScore(_) => None,
         PacketS::ReplayTick { .. } => None,
     }