chore: cargo fmt

Author: NathanFlurry

packages/common/api-helper/build/src/macro_util.rs

@@ -237,7 +237,7 @@ pub fn __deserialize_query<T: DeserializeOwned + Send>(route: &Url) -> GlobalRes
 }
 
 #[doc(hidden)]
-#[tracing::instrument(skip_all, name="setup_ctx")]
+#[tracing::instrument(skip_all, name = "setup_ctx")]
 pub async fn __with_ctx<
 	A: auth::ApiAuth + Send,
 	DB: chirp_workflow::db::Database + Sync + 'static,

packages/common/clickhouse-inserter/src/error.rs

@@ -2,15 +2,15 @@ use thiserror::Error;
 
 #[derive(Debug, Error)]
 pub enum Error {
-    #[error("failed to send event to ClickHouse inserter")]
-    ChannelSendError,
+	#[error("failed to send event to ClickHouse inserter")]
+	ChannelSendError,
 
-    #[error("serialization error: {0}")]
-    SerializationError(#[source] serde_json::Error),
+	#[error("serialization error: {0}")]
+	SerializationError(#[source] serde_json::Error),
 
-    #[error("failed to build reqwest client: {0}")]
-    ReqwestBuildError(#[source] reqwest::Error),
+	#[error("failed to build reqwest client: {0}")]
+	ReqwestBuildError(#[source] reqwest::Error),
 
-    #[error("failed to spawn background task")]
-    TaskSpawnError,
-}
+	#[error("failed to spawn background task")]
+	TaskSpawnError,
+}

packages/common/config/src/config/server/rivet/mod.rs

@@ -177,7 +177,7 @@ impl Rivet {
 	}
 }
 
-impl Rivet {	
+impl Rivet {
 	pub fn default_cluster_id(&self) -> GlobalResult<Uuid> {
 		if let Some(default_cluster_id) = self.default_cluster_id {
 			ensure!(
@@ -190,7 +190,9 @@ impl Rivet {
 				// Return default development clusters
 				AccessKind::Development => Ok(default_dev_cluster::CLUSTER_ID),
 				// No cluster configured
-				AccessKind::Public | AccessKind::Private => bail!("`default_cluster_id` not configured"),
+				AccessKind::Public | AccessKind::Private => {
+					bail!("`default_cluster_id` not configured")
+				}
 			}
 		}
 	}

packages/common/pools/src/db/redis.rs

@@ -65,4 +65,4 @@ pub async fn setup(config: Config) -> Result<HashMap<String, RedisPool>, Error>
 	tracing::debug!("redis connected");
 
 	Ok(redis)
-}
+}

packages/common/pools/src/error.rs

@@ -74,7 +74,7 @@ pub enum Error {
 }
 
 impl From<global_error::GlobalError> for Error {
-    fn from(err: global_error::GlobalError) -> Self {
-        Error::Global(err)
-    }
+	fn from(err: global_error::GlobalError) -> Self {
+		Error::Global(err)
+	}
 }

packages/common/pools/src/pools.rs

@@ -46,8 +46,9 @@ impl Pools {
 		let clickhouse_inserter = if let Some(vector_http) =
 			config.server.as_ref().and_then(|x| x.vector_http.as_ref())
 		{
-			let inserter = clickhouse_inserter::create_inserter(&vector_http.host, vector_http.port)
-				.map_err(Error::BuildClickHouseInserter)?;
+			let inserter =
+				clickhouse_inserter::create_inserter(&vector_http.host, vector_http.port)
+					.map_err(Error::BuildClickHouseInserter)?;
 			Some(inserter)
 		} else {
 			None

packages/common/pools/src/prelude.rs

@@ -4,7 +4,7 @@ pub use redis;
 pub use sqlx;
 
 pub use crate::{
-	ClickHouseInserterHandle, ClickHousePool, CrdbPool, FdbPool, NatsPool, RedisPool, SqlitePool, __sql_query,
-	__sql_query_as, __sql_query_as_raw, sql_execute, sql_fetch, sql_fetch_all, sql_fetch_many,
-	sql_fetch_one, sql_fetch_optional,
+	ClickHouseInserterHandle, ClickHousePool, CrdbPool, FdbPool, NatsPool, RedisPool, SqlitePool,
+	__sql_query, __sql_query_as, __sql_query_as_raw, sql_execute, sql_fetch, sql_fetch_all,
+	sql_fetch_many, sql_fetch_one, sql_fetch_optional,
 };

packages/common/util/core/src/format.rs

@@ -162,7 +162,7 @@ pub fn duration(ms: i64, relative: bool) -> String {
 		let hours = (ms % 86_400_000) / 3_600_000;
 		let minutes = (ms % 3_600_000) / 60_000;
 		let seconds = (ms % 60_000) / 1_000;
-	
+
 		if days > 0 {
 			parts.push(format!("{days}d"));
 		}
@@ -181,5 +181,5 @@ pub fn duration(ms: i64, relative: bool) -> String {
 		parts.push("ago".to_string());
 	}
 
-    parts.join(" ")
+	parts.join(" ")
 }

packages/core/api/actor/src/route/builds.rs

@@ -517,13 +517,9 @@ pub async fn complete_build(
 						..Default::default()
 					};
 
-					edge_intercom_pegboard_prewarm_image(
-						&config,
-						&build_id.to_string(),
-						json!({}),
-					)
-					.await
-					.map_err(Into::<GlobalError>::into)
+					edge_intercom_pegboard_prewarm_image(&config, &build_id.to_string(), json!({}))
+						.await
+						.map_err(Into::<GlobalError>::into)
 				}
 			})
 			.buffer_unordered(16)

packages/core/api/provision/src/route/datacenters.rs

@@ -59,11 +59,7 @@ pub async fn servers(
 	let servers_res = ctx
 		.op(cluster::ops::datacenter::server_discovery::Input {
 			datacenter_id,
-			pool_types: query
-				.pools
-				.into_iter()
-				.map(ApiInto::api_into)
-				.collect(),
+			pool_types: query.pools.into_iter().map(ApiInto::api_into).collect(),
 		})
 		.await?;