alemi/mumble-stats-api
1
0
Fork 0
mirror of https://git.alemi.dev/mumble-stats-api.git synced 2024-11-22 16:04:49 +01:00
Code Issues Projects Releases Packages Wiki Activity

fix: actually update users

Browse source
This commit is contained in:
əlemi 2024-02-21 18:50:56 +01:00
parent 7f0516dd1e
commit 6cb230d75c
1 changed files with 12 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
src/session.rs
View file

@ -104,7 +104,8 @@ impl Session {
let (ready, sync) = watch::channel(false); let (ready, sync) = watch::channel(false);
let s = Arc::new(Session { let s = Arc::new(Session {
username, drop, sync, drop, sync,
username: username.clone(),
users : RwLock::new(HashMap::new()), users : RwLock::new(HashMap::new()),
host: host.to_string(), host: host.to_string(),
}); });
@ -122,14 +123,19 @@ impl Session {
Err(e) => break tracing::warn!("disconnected from server: {}", e), Err(e) => break tracing::warn!("disconnected from server: {}", e),
// Ok(tcp::proto::Packet::TextMessage(msg)) => tracing::info!("{}", msg.message), // Ok(tcp::proto::Packet::TextMessage(msg)) => tracing::info!("{}", msg.message),
// Ok(tcp::proto::Packet::ChannelState(channel)) => tracing::info!("discovered channel: {:?}", channel.name), // Ok(tcp::proto::Packet::ChannelState(channel)) => tracing::info!("discovered channel: {:?}", channel.name),
Ok(proto::Packet::ServerSync(_sync)) => ready_tx.send(true).unwrap(), Ok(proto::Packet::ServerSync(_sync)) => {
tracing::info!("synched: {:?}", _sync);
ready.send(true).unwrap();
},
Ok(proto::Packet::UserState(user)) => { Ok(proto::Packet::UserState(user)) => {
tracing::info!("user state: {:#?}", user); tracing::info!("user state: {:?}", user);
if user.name.as_ref().is_some_and(|n| n != &username) { let mut users = session.users.write().await;
session.users.write().await.insert(user.user_id(), User::from(user)); match users.get_mut(&user.session()) {
Some(u) => u.update(user),
None => { users.insert(user.session(), User::from(user)); },
} }
}, },
Ok(pkt) => tracing::debug!("ignoring packet {:#?}", pkt), Ok(pkt) => tracing::info!("ignoring packet {:?}", pkt),
} }
} }
}); });