From 97528b217cb48e86cea83761721f9632d13affd0 Mon Sep 17 00:00:00 2001 From: Paul-Christian Volkmer Date: Mon, 1 Apr 2024 12:17:02 +0200 Subject: [PATCH] refactor: rename websocket subscription message --- src/client.rs | 32 ++++++++++++++++---------------- 1 file changed, 16 insertions(+), 16 deletions(-) diff --git a/src/client.rs b/src/client.rs index 0982f9e..dd1b65e 100644 --- a/src/client.rs +++ b/src/client.rs @@ -81,18 +81,28 @@ impl Display for WsConnectMessage { } } -struct WsSubscribeMessage { +struct WsSubscribeFeedbackMessage { room_id: String, } -impl WsSubscribeMessage { - fn new(room_id: &str) -> WsSubscribeMessage { - WsSubscribeMessage { +impl WsSubscribeFeedbackMessage { + fn new(room_id: &str) -> WsSubscribeFeedbackMessage { + WsSubscribeFeedbackMessage { room_id: room_id.to_string(), } } } +impl Display for WsSubscribeFeedbackMessage { + fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { + let str = format!( + "SUBSCRIBE\nid:sub-6\ndestination:/topic/{}.feedback.stream\n\n\0", + self.room_id + ); + write!(f, "{}", str) + } +} + #[derive(Debug)] struct WsFeedbackMessage { body: WsFeedbackBody, @@ -164,16 +174,6 @@ impl Display for WsCreateFeedbackMessage { } } -impl Display for WsSubscribeMessage { - fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { - let str = format!( - "SUBSCRIBE\nid:sub-6\ndestination:/topic/{}.feedback.stream\n\n\0", - self.room_id - ); - write!(f, "{}", str) - } -} - #[derive(Debug)] pub struct RoomInfo { pub id: String, @@ -519,7 +519,7 @@ impl Client { { return match write .send(Message::Text( - WsSubscribeMessage::new(&room_info.id).to_string(), + WsSubscribeFeedbackMessage::new(&room_info.id).to_string(), )) .await { @@ -571,7 +571,7 @@ impl Client { { match write .send(Message::Text( - WsSubscribeMessage::new(&room_info.id).to_string(), + WsSubscribeFeedbackMessage::new(&room_info.id).to_string(), )) .await {