Example for emitting messages from application logic about socketioxide HOT 3 CLOSED

let debug_timer = every(5).seconds()
    .perform(|| async {
        //perform dead socket garbage collection
        SOCKS.write().unwrap().retain(|_, v| v.upgrade().is_some());
            
        for (k,v) in SOCKS.read().unwrap().iter() {
            if let Some(socket) = v.upgrade() {
                println!("send to socket {}", socket.sid);
                socket.emit("log", format!("timer for {}", socket.sid)).ok();
            } else {
                println!("socket {} is dead",k);
            }
        }
    });
spawn(debug_timer);

#[derive(Deserialize)]
struct Auth {
    pub mqtt_id: String,
}
use once_cell::sync::Lazy;

static SOCKS: Lazy<RwLock<HashMap<String, Weak<Socket<LocalAdapter>>>>> =
    Lazy::new(|| RwLock::new(HashMap::new()));

pub async fn handler(socket: Arc<Socket<LocalAdapter>>) {
    info!("Socket connected on / with id: {}", socket.sid);
    if let Ok(data) = socket.handshake.data::<Auth>() {
        info!("mqtt id: {:?}", &data.mqtt_id);
        SOCKS
            .write()
            .unwrap()
            .insert(data.mqtt_id, Arc::downgrade(&socket.clone()));
    } else {
        info!("No mqtt_id provided, disconnecting...");
        socket.disconnect().ok();
        return;
    }

#[derive(Deserialize)]
struct Auth {
    pub mqtt_id: String,
}
use once_cell::sync::Lazy;

static SOCKS: Lazy<RwLock<HashMap<String, Arc<Socket<LocalAdapter>>>>> =
    Lazy::new(|| RwLock::new(HashMap::new()));

pub async fn handler(socket: Arc<Socket<LocalAdapter>>) {
    info!("Socket connected on / with id: {}", socket.sid);
    if let Ok(data) = socket.handshake.data::<Auth>() {
        info!("mqtt id: {:?}", &data.mqtt_id);
        SOCKS
            .write()
            .unwrap()
            .insert(data.mqtt_id, socket.clone());
    } else {
        info!("No mqtt_id provided, disconnecting...");
        socket.disconnect().ok();
        return;
    }

    socket.on_disconnect(|socket, reason| {
        info!("socket disconnected, reason: {reason}");
        SOCKS.write().unwrap().remove(socket.sid);
    })
}