to broadcast

src/server/mod.rs

@@ -507,12 +507,9 @@ impl Server {
                 }
 
                 info!("Disconnecting client {}...", id);
-                for client in &self.clients {
+                self.broadcast(Packet::Notification(NotificationPacket::player_left( // broadcast left message
-                    if client.id == i as u8 {continue}
-                    client.queue_packet(Packet::Notification(NotificationPacket::left(
                     self.clients[i].info.as_ref().unwrap().username.clone()
-                    ))).await;
+                )), Some(i as u8)).await;
-                }
 
                 if i == self.clients.len() - 1 {
                     self.clients.remove(i);
@@ -810,12 +807,9 @@ impl Server {
                             ))))
                             .await;
 
-                        for client in &self.clients { // welcome the player
+                        self.broadcast(Packet::Notification(NotificationPacket::player_welcome( // welcome the player
-                            if client.id == client_idx as u8 {continue}
-                            client.queue_packet(Packet::Notification(NotificationPacket::welcome(
                             self.clients[client_idx].info.as_ref().unwrap().username.clone()
-                            ))).await;
+                        )), Some(client_idx as u8)).await;
-                        }
 
                         // TODO: Sync all existing cars on server (this code is broken)
                         for client in &self.clients {

src/server/packet.rs

@@ -54,10 +54,10 @@ impl NotificationPacket {
     pub fn new<S: Into<String>>(msg: S) -> Self {
         Self(format!("J{}", msg.into()))
     }
-    pub fn welcome<S: Into<String>>(msg: S) -> Self {
+    pub fn player_welcome<S: Into<String>>(msg: S) -> Self {
         Self(format!("JWelcome {}!", msg.into()))
     }
-    pub fn left<S: Into<String>>(msg: S) -> Self {
+    pub fn player_left<S: Into<String>>(msg: S) -> Self {
         Self(format!("L{} left the server!", msg.into()))
     }
 }