aboutsummaryrefslogtreecommitdiff
path: root/src/server/hub.rs
diff options
context:
space:
mode:
authorFuwn <[email protected]>2021-04-30 17:59:18 +0000
committerFuwn <[email protected]>2021-04-30 17:59:18 +0000
commit5ec0a47413d8623660156dc4049f98dffee7b35b (patch)
treeb1f5d5b860ffd48ad9c36fdc8b378bb1326d855e /src/server/hub.rs
parentfeat(hub): *implement* new commands; subscribe room, subscribe distance, tele... (diff)
downloadwhirl-5ec0a47413d8623660156dc4049f98dffee7b35b.tar.xz
whirl-5ec0a47413d8623660156dc4049f98dffee7b35b.zip
refactor(cmds): more orphan module functions to methods within struct
The rest of the current commands will also receive this refactor... when I have time.
Diffstat (limited to 'src/server/hub.rs')
-rw-r--r--src/server/hub.rs12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/server/hub.rs b/src/server/hub.rs
index 8c982ad..7d0bb0a 100644
--- a/src/server/hub.rs
+++ b/src/server/hub.rs
@@ -28,7 +28,7 @@ use crate::{
subscribe_distance::parse::parse_subscribe_distance,
subscribe_room::parse::parse_subscribe_room,
teleport::parse::parse_teleport,
- text::{create::create_text, parse::parse_text, structure::Text},
+ text::Text,
},
constants::*,
},
@@ -87,10 +87,10 @@ impl Server for Hub {
trace!("received property set from {}", username);
peer.bytes.get_mut()
- .write_all(&create_text(Text {
+ .write_all(&Text {
sender: Config::get()?.whirlsplash.worldsmaster_username,
content: Config::get()?.distributor.worldsmaster_greeting,
- })).await?;
+ }.create()).await?;
peer.bytes.get_mut()
.write_all(&create_action()).await?;
trace!("sent text to {}", username);
@@ -111,14 +111,14 @@ impl Server for Hub {
trace!("received session exit from {}", username); break;
}
TEXT => {
- let text = parse_text(msg.to_vec(), &username);
+ let text = Text::parse(msg.to_vec(), &username);
trace!("received text from {}:{}", username, text.content);
{
- state.lock().await.broadcast(&create_text(Text {
+ state.lock().await.broadcast(&Text {
sender: username.clone(),
content: text.content,
- })).await;
+ }.create()).await;
}
trace!("broadcasted text to hub");
}