fix: fmt

api/src/api_docs.rs

@@ -1,6 +1,7 @@
-use crate::{dto::ValidatorBondRecord, handlers::{
-    bonds, docs
-}};
+use crate::{
+    dto::ValidatorBondRecord,
+    handlers::{bonds, docs},
+};
 use utoipa::OpenApi;
 
 #[derive(OpenApi)]
@@ -13,13 +14,7 @@ use utoipa::OpenApi;
             url = "https://www.apache.org/licenses/LICENSE-2.0"
         )
     ),
-    components(
-        schemas(ValidatorBondRecord),
-        schemas(bonds::BondsResponse),
-    ),
-    paths(
-        docs::handler,
-        bonds::handler,
-    )
+    components(schemas(ValidatorBondRecord), schemas(bonds::BondsResponse),),
+    paths(docs::handler, bonds::handler,)
 )]
 pub struct ApiDoc;

api/src/bin/api.rs

@@ -30,9 +30,7 @@ async fn main() -> anyhow::Result<()> {
         }
     });
 
-    let context = Arc::new(RwLock::new(Context::new(
-        psql_client,
-    )?));
+    let context = Arc::new(RwLock::new(Context::new(psql_client)?));
 
     let cors = warp::cors()
         .allow_any_origin()

api/src/context.rs

@@ -7,12 +7,8 @@ pub struct Context {
 }
 
 impl Context {
-    pub fn new(
-        psql_client: Client,
-    ) -> anyhow::Result<Self> {
-        Ok(Self {
-            psql_client,
-        })
+    pub fn new(psql_client: Client) -> anyhow::Result<Self> {
+        Ok(Self { psql_client })
     }
 }
 

api/src/data/data.rs

@@ -3,9 +3,7 @@ use tokio_postgres::Client;
 
 use crate::dto::ValidatorBondRecord;
 
-pub async fn get_bonds(
-    psql_client: &Client,
-) -> anyhow::Result<Vec<ValidatorBondRecord>> {
+pub async fn get_bonds(psql_client: &Client) -> anyhow::Result<Vec<ValidatorBondRecord>> {
     let rows = psql_client
         .query(
             "
@@ -29,4 +27,4 @@ pub async fn get_bonds(
     }
 
     Ok(bonds)
-}
+}

api/src/data/mod.rs

@@ -1 +1 @@
-pub mod data;
+pub mod data;

api/src/dto.rs

@@ -8,4 +8,4 @@ pub struct ValidatorBondRecord {
     pub authority: String,
     pub revenue_share: Decimal,
     pub epoch: u64,
-}
+}

api/src/handlers/bonds.rs

@@ -1,6 +1,9 @@
 use crate::{context::WrappedContext, data::data::get_bonds, dto::ValidatorBondRecord};
 use serde::{Deserialize, Serialize};
-use warp::{reject::Reject, reply::{json, Reply}};
+use warp::{
+    reject::Reject,
+    reply::{json, Reply},
+};
 
 #[derive(Serialize, Debug, utoipa::ToSchema)]
 pub struct BondsResponse {
@@ -9,8 +12,7 @@ pub struct BondsResponse {
 
 #[derive(Deserialize, Serialize, Debug, utoipa::IntoParams)]
 #[into_params(parameter_in = Query)]
-pub struct QueryParams {
-}
+pub struct QueryParams {}
 
 #[derive(Debug)]
 struct CustomError {
@@ -33,11 +35,9 @@ pub async fn handler(
     context: WrappedContext,
 ) -> Result<impl Reply, warp::Rejection> {
     match get_bonds(&context.read().await.psql_client).await {
-        Ok(bonds) => {
-            Ok(json(&BondsResponse { bonds }))
-        },
-        Err(_) => {
-            Err(warp::reject::custom(CustomError { message: "Failed to fetch bonds".into() }))
-        }
+        Ok(bonds) => Ok(json(&BondsResponse { bonds })),
+        Err(_) => Err(warp::reject::custom(CustomError {
+            message: "Failed to fetch bonds".into(),
+        })),
     }
 }

api/src/handlers/mod.rs

@@ -1,2 +1,2 @@
 pub mod bonds;
-pub mod docs;
+pub mod docs;

api/src/lib.rs

@@ -1,5 +1,5 @@
-pub mod handlers;
+pub mod api_docs;
 pub mod context;
 pub mod data;
-pub mod api_docs;
-pub mod dto;
+pub mod dto;
+pub mod handlers;

store/src/commands/bonds.rs

@@ -11,9 +11,7 @@ use super::common::CommonStoreOptions;
 
 const DEFAULT_CHUNK_SIZE: usize = 500;
 
-pub async fn store_bonds(
-    options: CommonStoreOptions,
-) -> anyhow::Result<()> {
+pub async fn store_bonds(options: CommonStoreOptions) -> anyhow::Result<()> {
     let (mut psql_client, psql_conn) =
         tokio_postgres::connect(&options.postgres_url, NoTls).await?;