src/main.rs

@@ -1374,9 +1374,11 @@ async fn handle_websocket(socket: WebSocket, state: Arc<AppState>) {
                         }
 
                         let users = recv_state.users.read().await;
-                        if let Some(recipient_tx) = users.get(&chat_msg.to_user) {
-                            let message_json = serde_json::to_string(&chat_msg).unwrap();
-                            let _ = recipient_tx.send(Message::Text(message_json));
+                        if chat_msg.to_user != chat_msg.from_user {
+                            if let Some(recipient_tx) = users.get(&chat_msg.to_user) {
+                                let message_json = serde_json::to_string(&chat_msg).unwrap();
+                                let _ = recipient_tx.send(Message::Text(message_json));
+                            }
                         }
 
                         if let Some(sender_tx) = users.get(&username) {