adam/cards
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

fix chat

Browse source
This commit is contained in:
Adam 2024-12-02 23:08:56 -05:00
parent a2af394bb9
commit 30e6091749
1 changed files with 9 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
server/src/incoming_message_handler.rs
View file

@ -1,10 +1,11 @@
use crate::user_handler::*; use crate::user_handler::*;
use crate::AppState; use crate::AppState;
use crate::GameHandlerMessage::*; use crate::GameHandlerMessage::*;
use crate::OutgoingMessageHandlerMessage::*;
use crate::UserHandlerMessage::*; use crate::UserHandlerMessage::*;
use axum::extract::ws::{CloseFrame, Message}; use axum::extract::ws::{CloseFrame, Message};
use lib::*; use lib::*;
use serde_json::{from_str, to_string}; use serde_json::from_str;
use std::{net::SocketAddr, sync::Arc}; use std::{net::SocketAddr, sync::Arc};
/// Handles incoming messages /// Handles incoming messages
@ -33,12 +34,14 @@ impl IncomingMessageHandler {
} }
// Broadcast incoming chat message // Broadcast incoming chat message
let broadcast_message = Message::Text( let msg = ChatMessage { text: msg };
to_string::<ChatMessage>(&ChatMessage { text: msg }).unwrap(), let tx = self.state.tx_outgoing_message_handler.clone();
); let btx = self.state.tx_broadcast.clone();
let tx = self.state.tx_broadcast.clone();
tokio::spawn(async move { tokio::spawn(async move {
if let Err(e) = tx.send(broadcast_message) { if let Err(e) = tx
.send(Broadcast((btx, ServerToClientMessage::ChatMessage(msg))))
.await
{
tracing::error!("Error broadcasting Chat message: {}", e) tracing::error!("Error broadcasting Chat message: {}", e)
} }
}); });