studio/tuwunel
2
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Fix missed rustfmt let due to comment in chain.

Browse Source 
Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
Jason Volk
2025-07-29 22:40:59 +00:00
parent 95e49d3cb8
commit 80015a6a30
1 changed files with 16 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/service/rooms/timeline/append.rs
View File

@@ -190,16 +190,23 @@ where
.await .await
.unwrap_or_default(); .unwrap_or_default();
// Don't notify the sender of their own events, and dont send from ignored users
let mut push_target: HashSet<_> = self let mut push_target: HashSet<_> = self
.services .services
.state_cache .state_cache
.active_local_users_in_room(pdu.room_id()) .active_local_users_in_room(pdu.room_id())
.map(ToOwned::to_owned) .map(ToOwned::to_owned)
// Don't notify the sender of their own events, and dont send from ignored users .ready_filter(|user| *user != pdu.sender())
.ready_filter(|user| *user != pdu.sender()) .filter_map(async |recipient_user| {
.filter_map(async |recipient_user| self.services.users.user_is_ignored(pdu.sender(), &recipient_user).await.eq(&false).then_some(recipient_user)) self.services
.collect() .users
.await; .user_is_ignored(pdu.sender(), &recipient_user)
.await
.eq(&false)
.then_some(recipient_user)
})
.collect()
.await;
let mut notifies = Vec::with_capacity(push_target.len().saturating_add(1)); let mut notifies = Vec::with_capacity(push_target.len().saturating_add(1));
let mut highlights = Vec::with_capacity(push_target.len().saturating_add(1)); let mut highlights = Vec::with_capacity(push_target.len().saturating_add(1));