From 1a09eb0f0235a1dfe7c51f525f656cffad62b60d Mon Sep 17 00:00:00 2001 From: Jason Volk Date: Sun, 13 Oct 2024 00:57:08 +0000 Subject: [PATCH] use string::EMPTY; minor formatting and misc cleanups Signed-off-by: Jason Volk --- src/admin/debug/commands.rs | 12 ++++++++---- src/api/client/membership.rs | 11 +++++++---- 2 files changed, 15 insertions(+), 8 deletions(-) diff --git a/src/admin/debug/commands.rs b/src/admin/debug/commands.rs index 350e08c6..fd8c39f7 100644 --- a/src/admin/debug/commands.rs +++ b/src/admin/debug/commands.rs @@ -6,7 +6,7 @@ use std::{ }; use api::client::validate_and_add_event_id; -use conduit::{debug, debug_error, err, info, trace, utils, warn, Error, PduEvent, Result}; +use conduit::{debug, debug_error, err, info, trace, utils, utils::string::EMPTY, warn, Error, PduEvent, Result}; use futures::StreamExt; use ruma::{ api::{client::error::ErrorKind, federation::event::get_room_state}, @@ -57,7 +57,9 @@ pub(super) async fn get_auth_chain(&self, event_id: Box) -> Result Result { - if self.body.len() < 2 || !self.body[0].trim().starts_with("```") || self.body.last().unwrap_or(&"").trim() != "```" + if self.body.len() < 2 + || !self.body[0].trim().starts_with("```") + || self.body.last().unwrap_or(&EMPTY).trim() != "```" { return Ok(RoomMessageEventContent::text_plain( "Expected code block in command body. Add --help for details.", @@ -134,7 +136,9 @@ pub(super) async fn get_remote_pdu_list( )); } - if self.body.len() < 2 || !self.body[0].trim().starts_with("```") || self.body.last().unwrap_or(&"").trim() != "```" + if self.body.len() < 2 + || !self.body[0].trim().starts_with("```") + || self.body.last().unwrap_or(&EMPTY).trim() != "```" { return Ok(RoomMessageEventContent::text_plain( "Expected code block in command body. Add --help for details.", @@ -843,7 +847,7 @@ pub(super) async fn database_stats( &self, property: Option, map: Option, ) -> Result { let property = property.unwrap_or_else(|| "rocksdb.stats".to_owned()); - let map_name = map.as_ref().map_or(utils::string::EMPTY, String::as_str); + let map_name = map.as_ref().map_or(EMPTY, String::as_str); let mut out = String::new(); for (name, map) in self.services.db.iter_maps() { diff --git a/src/api/client/membership.rs b/src/api/client/membership.rs index 06035592..a7a5b166 100644 --- a/src/api/client/membership.rs +++ b/src/api/client/membership.rs @@ -658,13 +658,16 @@ pub async fn join_room_by_id_helper( }); } - if services + let server_in_room = services .rooms .state_cache .server_in_room(services.globals.server_name(), room_id) - .await || servers.is_empty() - || (servers.len() == 1 && services.globals.server_is_ours(&servers[0])) - { + .await; + + let local_join = + server_in_room || servers.is_empty() || (servers.len() == 1 && services.globals.server_is_ours(&servers[0])); + + if local_join { join_room_by_id_helper_local(services, sender_user, room_id, reason, servers, third_party_signed, state_lock) .boxed() .await