diff options
| author | Fuwn <[email protected]> | 2021-04-30 17:59:18 +0000 |
|---|---|---|
| committer | Fuwn <[email protected]> | 2021-04-30 17:59:18 +0000 |
| commit | 5ec0a47413d8623660156dc4049f98dffee7b35b (patch) | |
| tree | b1f5d5b860ffd48ad9c36fdc8b378bb1326d855e /src/server/hub.rs | |
| parent | feat(hub): *implement* new commands; subscribe room, subscribe distance, tele... (diff) | |
| download | whirl-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.rs | 12 |
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"); } |