Fixed bug and restructured

src/cosmetics.rs

@@ -1,9 +1,8 @@
 use std::sync::Arc;
 
 use sqlx::SqlitePool;
-use tokio::sync::Mutex;
 
-use crate::user::get_put;
+use crate::{types::UUID, user::get_put};
 
 pub const CLOAKS: &[&str] = &[
     "mercedes_flow",
@@ -26,7 +25,7 @@ pub enum CosmeticKind {
 // Buy a cosmetic
 pub async fn buy(
     kind: CosmeticKind,
-    uuid: Arc<Mutex<String>>,
+    uuid: UUID,
     item_id: String,
     pool: Arc<SqlitePool>,
 ) -> Result<String, String> {
@@ -65,7 +64,7 @@ pub async fn buy(
 // Equip a cosmetic
 pub async fn equip(
     kind: CosmeticKind,
-    uuid: Arc<Mutex<String>>,
+    uuid: UUID,
     item_id: String,
     pool: Arc<SqlitePool>,
 ) -> Result<String, String> {

src/main.rs

@@ -1,21 +1,18 @@
 mod cosmetics;
 mod methods;
+mod types;
 mod user;
 
-use std::{
+use std::{collections::HashMap, pin::Pin, sync::Arc};
-    collections::{HashMap, HashSet},
-    pin::Pin,
-    sync::Arc,
-};
 
-use serde::{Deserialize, Serialize};
 use session_rs::{server::SessionServer, session::Session};
 use sqlx::SqlitePool;
 use tokio::sync::Mutex;
 
-use crate::user::User;
+use crate::{
-
+    types::{SessionMap, UUID},
-type SessionMap = Arc<Mutex<HashMap<String, HashSet<Session>>>>;
+    user::User,
+};
 
 #[tokio::main(flavor = "current_thread")]
 async fn main() -> session_rs::Result<()> {
@@ -33,7 +30,7 @@ async fn main() -> session_rs::Result<()> {
 
                 Box::pin(async move {
                     println!("Connected");
-                    let uuid: Arc<Mutex<String>> = Arc::new(Mutex::new(String::new()));
+                    let uuid = Arc::new(Mutex::new(String::new()));
 
                     session
                         .on_close({
@@ -202,10 +199,10 @@ async fn main() -> session_rs::Result<()> {
 
 async fn send_emote(
     sessions: SessionMap,
-    uuid: Arc<Mutex<String>>,
+    uuid: UUID,
-    emote: methods::ClientEmote,
+    emote: types::EmoteRequest,
 ) -> Result<String, String> {
-    let emote_event = methods::EventEmote {
+    let emote_event = types::EventEmote {
         from: uuid.lock().await.clone(),
         emote: emote.emote,
     };
@@ -213,28 +210,30 @@ async fn send_emote(
     for i in emote.targets {
         if let Some(sessions) = sessions.lock().await.get_mut(&i) {
             let emote_event = emote_event.clone();
-            sessions.retain(|s| {
+            let mut bad_sessions = Vec::new();
-                let notify_result = tokio::runtime::Handle::current()
-                    .block_on(s.notify::<methods::EmoteEvent>(emote_event.clone()));
 
-                notify_result.is_ok()
+            for s in sessions.iter() {
-            });
+                if s.notify::<methods::EmoteEvent>(emote_event.clone())
+                    .await
+                    .is_err()
+                {
+                    bad_sessions.push(s.clone());
+                }
+            }
+
+            for s in bad_sessions {
+                sessions.remove(&s);
+            }
         }
     }
 
     Ok(format!("Cool"))
 }
 
-#[derive(Debug, Deserialize, Serialize)]
-struct MinecraftAuthResponse {
-    pub id: String,
-    pub name: String,
-}
-
 async fn authenticate(
     sessions: SessionMap,
     session: Session,
-    uuid: Arc<Mutex<String>>,
+    uuid: UUID,
     session_token: String,
     pool: Arc<SqlitePool>,
 ) -> Result<User, String> {
@@ -258,7 +257,7 @@ async fn authenticate(
         ));
     }
 
-    let auth: MinecraftAuthResponse = response
+    let auth: types::MinecraftAuthResponse = response
         .json()
         .await
         .map_err(|_| "Unable to parse auth response".to_string())?;

src/methods.rs

@@ -1,7 +1,10 @@
 use serde::{Deserialize, Serialize};
 use session_rs::Method;
 
-use crate::user::User;
+use crate::{
+    types::{EmoteRequest, EventEmote},
+    user::User,
+};
 
 #[derive(Debug, Serialize, Deserialize)]
 pub struct Auth;
@@ -53,24 +56,12 @@ impl Method for BuyHat {
     type Error = String;
 }
 
-#[derive(Debug, Serialize, Deserialize)]
-pub struct ClientEmote {
-    pub emote: String,
-    pub targets: Vec<String>,
-}
-
-#[derive(Debug, Clone, Serialize, Deserialize)]
-pub struct EventEmote {
-    pub emote: String,
-    pub from: String,
-}
-
 #[derive(Debug, Serialize, Deserialize)]
 pub struct Emote;
 
 impl Method for Emote {
     const NAME: &'static str = "emote";
-    type Request = ClientEmote;
+    type Request = EmoteRequest;
     type Response = String;
     type Error = String;
 }

src/types.rs

@@ -0,0 +1,31 @@
+use serde::{Deserialize, Serialize};
+use session_rs::session::Session;
+use tokio::sync::Mutex;
+
+use std::{
+    collections::{HashMap, HashSet},
+    sync::Arc,
+};
+
+pub type SessionMap = Arc<Mutex<HashMap<String, HashSet<Session>>>>;
+pub type UUID = Arc<Mutex<String>>;
+
+#[derive(Debug, Deserialize, Serialize)]
+pub struct MinecraftAuthResponse {
+    pub id: String,
+    pub name: String,
+}
+
+#[derive(Debug, Serialize, Deserialize)]
+/// Received from the client to send to the targets
+pub struct EmoteRequest {
+    pub emote: String,
+    pub targets: Vec<String>,
+}
+
+/// To send to the targets
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct EventEmote {
+    pub emote: String,
+    pub from: String,
+}