diff --git a/src/database/entities/user.rs b/src/database/entities/user.rs index ade3cb84..91001567 100644 --- a/src/database/entities/user.rs +++ b/src/database/entities/user.rs @@ -152,6 +152,17 @@ impl User { user.status = None; } + // If the user's status is `Presence::Invisible`, return it as `Presence::Offline` + if let Some(mut status) = user.status { + if let Some(presence) = status.presence { + if presence == Presence::Invisible { + status.presence = Some(Presence::Offline); + user.status = Some(status); + user.online = Some(False); + } + } + } + user.profile = None; user } diff --git a/src/notifications/websocket.rs b/src/notifications/websocket.rs index 65429239..64373cee 100644 --- a/src/notifications/websocket.rs +++ b/src/notifications/websocket.rs @@ -116,7 +116,13 @@ async fn accept(stream: TcpStream) { } } { if let Ok(user) = (Ref { id: id.clone() }).fetch_user().await { + let is_invisible = if let Some(status) = user.status { + if let Some(presence) = status.presence { + presence == Presence::Invisible + } + }; let was_online = is_online(&id); + { match USERS.write() { Ok(mut map) => { @@ -152,7 +158,7 @@ async fn accept(stream: TcpStream) { Ok(payload) => { send(payload); - if !was_online { + if !was_online && !is_invisible { ClientboundNotification::UserUpdate { id: id.clone(), data: json!({ diff --git a/src/routes/users/fetch_user.rs b/src/routes/users/fetch_user.rs index 831735f3..0876aeb4 100644 --- a/src/routes/users/fetch_user.rs +++ b/src/routes/users/fetch_user.rs @@ -5,7 +5,7 @@ use rocket::serde::json::Value; #[get("/")] pub async fn req(user: User, target: Ref) -> Result { - let target = target.fetch_user().await?; + let mut target = target.fetch_user().await?; let perm = permissions::PermissionCalculator::new(&user) .with_user(&target)