diff --git a/src/admin/query/resolver.rs b/src/admin/query/resolver.rs index 5880d449f..d651e5bff 100644 --- a/src/admin/query/resolver.rs +++ b/src/admin/query/resolver.rs @@ -50,7 +50,7 @@ async fn destinations_cache(&self, server_name: Option) -> Resu while let Some((name, CachedDest { dest, host, expire })) = destinations.next().await { if let Some(server_name) = server_name.as_ref() { - if name != server_name { + if name != *server_name { continue; } } @@ -76,7 +76,7 @@ async fn overrides_cache(&self, server_name: Option) -> Result { overrides.next().await { if let Some(server_name) = server_name.as_ref() { - if name != server_name { + if name != *server_name { continue; } } diff --git a/src/admin/query/room_alias.rs b/src/admin/query/room_alias.rs index 0dc1833ae..5187e5fe4 100644 --- a/src/admin/query/room_alias.rs +++ b/src/admin/query/room_alias.rs @@ -41,7 +41,6 @@ pub(super) async fn process(subcommand: RoomAliasCommand, context: &Context<'_>) .rooms .alias .local_aliases_for_room(&room_id) - .map(ToOwned::to_owned) .collect() .await; let query_time = timer.elapsed(); diff --git a/src/admin/query/room_state_cache.rs b/src/admin/query/room_state_cache.rs index 798792d7f..b66ac5103 100644 --- a/src/admin/query/room_state_cache.rs +++ b/src/admin/query/room_state_cache.rs @@ -101,7 +101,6 @@ pub(super) async fn process(subcommand: RoomStateCacheCommand, context: &Context .rooms .state_cache .room_servers(&room_id) - .map(ToOwned::to_owned) .collect() .await; let query_time = timer.elapsed(); @@ -118,7 +117,6 @@ pub(super) async fn process(subcommand: RoomStateCacheCommand, context: &Context .rooms .state_cache .server_rooms(&server) - .map(ToOwned::to_owned) .collect() .await; let query_time = timer.elapsed(); @@ -135,7 +133,6 @@ pub(super) async fn process(subcommand: RoomStateCacheCommand, context: &Context .rooms .state_cache .room_members(&room_id) - .map(ToOwned::to_owned) .collect() .await; let query_time = timer.elapsed(); @@ -152,7 +149,6 @@ pub(super) async fn process(subcommand: RoomStateCacheCommand, context: &Context .rooms .state_cache .local_users_in_room(&room_id) - .map(ToOwned::to_owned) .collect() .await; let query_time = timer.elapsed(); @@ -169,7 +165,6 @@ pub(super) async fn process(subcommand: RoomStateCacheCommand, context: &Context .rooms .state_cache .active_local_users_in_room(&room_id) - .map(ToOwned::to_owned) .collect() .await; let query_time = timer.elapsed(); @@ -212,7 +207,6 @@ pub(super) async fn process(subcommand: RoomStateCacheCommand, context: &Context .rooms .state_cache .room_useroncejoined(&room_id) - .map(ToOwned::to_owned) .collect() .await; let query_time = timer.elapsed(); @@ -229,7 +223,6 @@ pub(super) async fn process(subcommand: RoomStateCacheCommand, context: &Context .rooms .state_cache .room_members_invited(&room_id) - .map(ToOwned::to_owned) .collect() .await; let query_time = timer.elapsed(); @@ -276,7 +269,6 @@ pub(super) async fn process(subcommand: RoomStateCacheCommand, context: &Context .rooms .state_cache .rooms_joined(&user_id) - .map(ToOwned::to_owned) .collect() .await; let query_time = timer.elapsed(); diff --git a/src/admin/query/users.rs b/src/admin/query/users.rs index 2b5b3481f..497a4f528 100644 --- a/src/admin/query/users.rs +++ b/src/admin/query/users.rs @@ -104,7 +104,6 @@ async fn get_shared_rooms(&self, user_a: OwnedUserId, user_b: OwnedUserId) -> Re .rooms .state_cache .get_shared_rooms(&user_a, &user_b) - .map(ToOwned::to_owned) .collect() .await; let query_time = timer.elapsed(); @@ -217,8 +216,7 @@ async fn iter_users2(&self) -> Result { let result: Vec<_> = self.services.users.stream().collect().await; let result: Vec<_> = result .into_iter() - .map(ruma::UserId::as_bytes) - .map(String::from_utf8_lossy) + .map(|user_id| String::from_utf8_lossy(user_id.as_bytes()).into_owned()) .collect(); let query_time = timer.elapsed(); @@ -254,7 +252,6 @@ async fn list_devices(&self, user_id: OwnedUserId) -> Result { .services .users .all_device_ids(&user_id) - .map(ToOwned::to_owned) .collect::>() .await;