diff --git a/apps/labrinth/src/routes/internal/statuses.rs b/apps/labrinth/src/routes/internal/statuses.rs index 9a589e5013..a79ff3828e 100644 --- a/apps/labrinth/src/routes/internal/statuses.rs +++ b/apps/labrinth/src/routes/internal/statuses.rs @@ -130,23 +130,25 @@ pub async fn ws_init( )?) .await; - let unread_server_invites = DBNotification::get_many_user_exposed_on_site( - user_id.into(), - &**pool, - &redis, - ) - .await? - .into_iter() - .filter(|notification| { - !notification.read - && matches!( - ¬ification.body, - NotificationBody::ServerInvite { .. } - ) - }) - .map(Notification::from); + let unread_launcher_invites = + DBNotification::get_many_user_exposed_on_site( + user_id.into(), + &**pool, + &redis, + ) + .await? + .into_iter() + .filter(|notification| { + !notification.read + && matches!( + ¬ification.body, + NotificationBody::ServerInvite { .. } + | NotificationBody::SharedInstanceInvite { .. } + ) + }) + .map(Notification::from); - for notification in unread_server_invites { + for notification in unread_launcher_invites { let _ = session.text(serde_json::to_string(¬ification)?).await; }