VCC/vcs-common
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

added extra logging

Browse source
This commit is contained in:
Nickiel12 2024-08-24 20:10:19 +00:00
parent 11f3745adb
commit 69c9664eb5
1 changed files with 30 additions and 25 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

55
src/lib.rs
View file

@ -86,34 +86,39 @@ pub async fn send_to_wc_task(
mut sender: SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, tokio_tungstenite::tungstenite::Message> mut sender: SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, tokio_tungstenite::tungstenite::Message>
) { ) {
info!("From app is closed: {:?}", from_app.is_closed()); info!("From app is closed: {:?}", from_app.is_closed());
while let Ok(msg) = from_app.recv().await { loop {
#[cfg(debug_assertions)] match from_app.recv().await {
{ Ok(msg) => {
info!("Sending message to socket!"); #[cfg(debug_assertions)]
// serialized message {
match serde_json::to_string(&msg) { info!("Sending message to socket!");
Err(e) => error!("Could not serialize ApplicationMessage to JSON! {e}"), // serialized message
Ok(msg) => { match serde_json::to_string(&msg) {
if let Err(e) = sender.send(Message::text(msg)).await { Err(e) => error!("Could not serialize ApplicationMessage to JSON! {e}"),
error!("Could not send text ApplicationMessage to websocket! Closing websocket\n{e}"); Ok(msg) => {
break; if let Err(e) = sender.send(Message::text(msg)).await {
} error!("Could not send text ApplicationMessage to websocket! Closing websocket\n{e}");
} break;
} }
}
} }
#[cfg(not(debug_assertions))] }
{
match bincode::serialize(&msg) { #[cfg(not(debug_assertions))]
Err(e) => error!("Could not serialize ApplicationMessage into binary! {e}"), {
Ok(e) => { match bincode::serialize(&msg) {
if let Err(e) = sender.send(Message::binary(msg)).await { Err(e) => error!("Could not serialize ApplicationMessage into binary! {e}"),
error!("Could not send binary ApplicationMessage to websocket! Closing websocket\n{e}"); Ok(e) => {
break; if let Err(e) = sender.send(Message::binary(msg)).await {
error!("Could not send binary ApplicationMessage to websocket! Closing websocket\n{e}");
break;
}
}
} }
} }
} }
Err(e) => error!("Send to WC had a recv error! {e}"),
} }
} }