From bcb82d0f4609c2333a0dea608d25a3438883855b Mon Sep 17 00:00:00 2001 From: Radical Date: Mon, 26 May 2025 21:32:43 +0200 Subject: [PATCH] fix: return message struct to websocket connection --- src/api/v1/servers/uuid/channels/uuid/socket.rs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/api/v1/servers/uuid/channels/uuid/socket.rs b/src/api/v1/servers/uuid/channels/uuid/socket.rs index c16efa7..744f017 100644 --- a/src/api/v1/servers/uuid/channels/uuid/socket.rs +++ b/src/api/v1/servers/uuid/channels/uuid/socket.rs @@ -83,13 +83,13 @@ pub async fn echo( Ok(AggregatedMessage::Text(text)) => { let mut conn = data.cache_pool.get_multiplexed_tokio_connection().await?; - redis::cmd("PUBLISH") - .arg(&[channel_uuid.to_string(), text.to_string()]) - .exec_async(&mut conn) + let message = channel + .new_message(&mut data.pool.get().await?, uuid, text.to_string()) .await?; - channel - .new_message(&mut data.pool.get().await.unwrap(), uuid, text.to_string()) + redis::cmd("PUBLISH") + .arg(&[channel_uuid.to_string(), serde_json::to_string(&message)?]) + .exec_async(&mut conn) .await?; }