refactor(global): even more modules becoming crates

I did multiple checks and **yes**, everything still works perfectly fine.

1 files changed, 0 insertions, 163 deletions

diff --git a/src/server/hub.rs b/src/server/hub.rs
deleted file mode 100644
index 99ba600..0000000
--- a/src/server/hub.rs
+++ /dev/null
@@ -1,163 +0,0 @@
-// Copyleft (ɔ) 2021-2021 The Whirlsplash Collective
-// SPDX-License-Identifier: GPL-3.0-only
-
-//! The hub functions as a
-//! [RoomServer](http://dev.worlds.net/private/GammaDocs/WorldServer.html#AutoServer).
-//!
-//! The RoomServer is responsible for handling just about every request from the
-//! client after they have been redirected to a room (hub).
-
-use std::{error::Error, net::SocketAddr, sync::Arc};
-
-use tokio::{io::AsyncWriteExt, net::TcpStream, sync::Mutex};
-use tokio_stream::StreamExt;
-use tokio_util::codec::{BytesCodec, Decoder};
-use whirl_config::Config;
-
-use crate::server::{
-  cmd::{
-    commands::{
-      action::create_action,
-      buddy_list::BuddyList,
-      property::{
-        create::{create_property_request_as_hub, create_property_update_as_hub},
-        parse::find_property_in_property_list,
-      },
-      subscribe_distance::SubscribeDistance,
-      subscribe_room::SubscribeRoom,
-      teleport::Teleport,
-      text::Text,
-    },
-    constants::*,
-    extendable::{Creatable, Parsable, ParsableWithArguments},
-  },
-  interaction::{peer::Peer, shared::Shared},
-  net::{constants::VAR_USERNAME, property_parser::parse_network_property},
-  packet_parser::parse_commands_from_packet,
-  Server,
-};
-
-pub struct Hub;
-#[async_trait]
-impl Server for Hub {
-  async fn handle(
-    state: Arc<Mutex<Shared>>,
-    stream: TcpStream,
-    _address: SocketAddr,
-    count: usize,
-  ) -> Result<(), Box<dyn Error>> {
-    let bytes = BytesCodec::new().framed(stream);
-    let mut peer = Peer::new(state.clone(), bytes, count.to_string()).await?;
-    // let mut room_ids = vec![];
-    let mut username = String::from("unknown");
-
-    loop {
-      tokio::select! {
-        Some(msg) = peer.rx.recv() => {
-          // dbg!("got peer activity: {:?}", &msg);
-          peer.bytes.get_mut().write_all(&msg).await?;
-        }
-        result = peer.bytes.next() => match result {
-          Some(Ok(msg)) => {
-            // dbg!("got some bytes: {:?}", &msg);
-            for msg in parse_commands_from_packet(msg) {
-              match msg.get(2).unwrap().to_owned() as i32 {
-                PROPREQ => {
-                  trace!("received property request from client");
-
-                  peer.bytes.get_mut()
-                    .write_all(&create_property_update_as_hub()).await?;
-                  trace!("sent property update to client");
-                }
-                SESSINIT => {
-                  username = find_property_in_property_list(
-                    &parse_network_property(msg[3..].to_vec()),
-                    VAR_USERNAME,
-                  ).value.clone();
-
-                  trace!("received session initialization from {}", username);
-
-                  peer.bytes.get_mut()
-                    .write_all(&create_property_request_as_hub()).await?;
-                  trace!("sent property request to {}", username);
-                }
-                PROPSET => {
-                  trace!("received property set from {}", username);
-
-                  peer.bytes.get_mut()
-                    .write_all(&Text {
-                    sender: Config::get().whirlsplash.worldsmaster_username,
-                    content: Config::get().distributor.worldsmaster_greeting,
-                  }.create()).await?;
-                  peer.bytes.get_mut()
-                    .write_all(&create_action()).await?;
-                  trace!("sent text to {}", username);
-                }
-                BUDDYLISTUPDATE => {
-                  let buddy = BuddyList::parse(msg.to_vec());
-                  trace!("received buddy list update from {}: {}", username, buddy.buddy);
-                  peer.bytes.get_mut().write_all(&BuddyList {
-                    ..buddy.clone()
-                  }.create()).await?;
-                  trace!("sent buddy list notify to {}: {}", username, buddy.buddy);
-                }
-                // TODO: Figure out if this is actually even needed.
-                // ROOMIDRQ => {
-                //   let room = RoomIdRequest::parse(msg.to_vec());
-                //   trace!("received room id request from {}: {}", username, room.room_name);
-                //   debug!("{:?}", create_room_id_request(&room.room_name, 0x00));
-                // }
-                SESSEXIT => {
-                  trace!("received session exit from {}", username); break;
-                }
-                TEXT => {
-                  let text = Text::parse(msg.to_vec(), &[&username]);
-                  trace!("received text from {}:{}", username, text.content);
-
-                  {
-                    state.lock().await.broadcast(&Text {
-                      sender: username.clone(),
-                      content: text.content,
-                    }.create()).await;
-                  }
-                  trace!("broadcasted text to hub");
-                }
-                SUBSCRIB => {
-                  let subscribe_room = SubscribeRoom::parse(msg[3..].to_vec());
-                  trace!("received subscribe room from {}: {:?}",
-                    username, subscribe_room);
-                }
-                SUB_DIST => {
-                  let subscribe_distance = SubscribeDistance::parse(msg[3..].to_vec());
-                  trace!("received subscribe distance from {}: {:?}",
-                    username, subscribe_distance);
-                }
-                TELEPORT => {
-                  let teleport = Teleport::parse(msg[3..].to_vec());
-                  trace!("received teleport from {}: {:?}",
-                    username, teleport);
-                }
-                _ => (),
-              }
-            }
-          }
-          Some(Err(e)) => {
-            error!("error while processing message (s): {}", e); break;
-          }
-          None => {
-            debug!("nothing"); break;
-          },
-        }
-      }
-    }
-
-    // Deregister client
-    trace!("de-registering client");
-    {
-      state.lock().await.peers.remove(&count.to_string());
-    }
-    trace!("de-registered client");
-
-    Ok(())
-  }
-}