Spacing/formatting adjustments.

Signed-off-by: Jason Volk <jason@zemos.net>

src/service/admin/grant.rs

@@ -38,6 +38,7 @@ pub async fn make_user_admin(&self, user_id: &UserId) -> Result {
 	{
 		return Err!(debug_warn!("User is already joined in the admin room"));
 	}
+
 	if self
 		.services
 		.state_cache
@@ -132,6 +133,7 @@ pub async fn make_user_admin(&self, user_id: &UserId) -> Result {
 		.config
 		.admin_room_tag
 		.as_str();
+
 	if !room_tag.is_empty() {
 		if let Err(e) = self
 			.set_room_tag(&room_id, user_id, room_tag)

src/service/admin/mod.rs

@@ -428,6 +428,7 @@ impl Service {
 			.services
 			.write()
 			.expect("locked for writing");
+
 		let weak = services.map(Arc::downgrade);
 		*receiver = weak;
 	}

src/service/rooms/auth_chain/mod.rs

@@ -157,6 +157,7 @@ async fn get_auth_chain_outer(
 			let auth_chain = self
 				.get_auth_chain_inner(room_id, event_id)
 				.await?;
+
 			self.cache_auth_chain_vec(vec![shortid], auth_chain.as_slice());
 			debug!(
 				?event_id,

src/service/rooms/event_handler/mod.rs

@@ -90,6 +90,7 @@ impl crate::Service for Service {
 			.read()
 			.expect("locked for reading")
 			.len();
+
 		writeln!(out, "federation_handletime: {federation_handletime}")?;
 
 		Ok(())

src/service/rooms/state/mod.rs

@@ -225,6 +225,7 @@ impl Service {
 				} else {
 					(state_ids_compressed, Arc::new(CompressedState::new()))
 				};
+
 			self.services
 				.state_compressor
 				.save_state_from_diff(

src/service/rooms/timeline/create.rs

@@ -86,7 +86,6 @@ pub async fn create_hash_and_sign_event(
 		.saturating_add(uint!(1));
 
 	let mut unsigned = unsigned.unwrap_or_default();
-
 	if let Some(state_key) = &state_key {
 		if let Ok(prev_pdu) = self
 			.services

src/service/sending/sender.rs

@@ -184,6 +184,7 @@ impl Service {
 				.into_iter()
 				.map(|(_, event)| event)
 				.collect();
+
 			futures.push(self.send_events(dest.clone(), new_events_vec));
 		} else {
 			statuses.remove(dest);

src/service/services.rs

@@ -117,6 +117,7 @@ impl Services {
 
 		self.admin
 			.set_services(Some(Arc::clone(self)).as_ref());
+
 		super::migrations::migrations(self).await?;
 		self.manager
 			.lock()
@@ -137,6 +138,7 @@ impl Services {
 		}
 
 		debug_info!("Services startup complete.");
+
 		Ok(Arc::clone(self))
 	}