fix: clean and format

graphops · Sep 19, 2023 · fc4424a · fc4424a
1 parent cf9143d
commit fc4424a
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 10 deletions.
diff --git a/src/config.rs b/src/config.rs
@@ -251,7 +251,7 @@ pub struct Config {
         long,
         value_name = "MAX_STORAGE",
         env = "MAX_STORAGE",
-        default_value = "3000",
+        default_value = "3000"
     )]
     pub max_storage: i32,
     #[clap(

diff --git a/src/db/resolver.rs b/src/db/resolver.rs
@@ -155,11 +155,7 @@ RETURNING id, message as "message: Json<T>"
 /// Function to automatically prune older messages and keep the `max_storage` newest messages
 /// We prune from the smallest id by the automcatic ascending behavior
 /// Return the number of messages deleted
-pub async fn retain_max_storage(
-    pool: &PgPool,
-    max_storage: usize,
-) -> Result<i64, anyhow::Error>
-{
+pub async fn retain_max_storage(pool: &PgPool, max_storage: usize) -> Result<i64, anyhow::Error> {
     // find out the IDs of the top `max_storage` newest messages.
     let top_ids: Vec<i64> = sqlx::query_as!(
         MessageID,

diff --git a/src/metrics/mod.rs b/src/metrics/mod.rs
@@ -116,8 +116,7 @@ pub static PRUNED_MESSAGES: Lazy<IntGauge> = Lazy::new(|| {
             .subsystem("listener_radio"),
     )
     .expect("Failed to create pruned_messages gauge");
-    prometheus::register(Box::new(m.clone()))
-        .expect("Failed to register pruned_messages gauge");
+    prometheus::register(Box::new(m.clone())).expect("Failed to register pruned_messages gauge");
     m
 });
 

diff --git a/src/operator/mod.rs b/src/operator/mod.rs
@@ -17,7 +17,7 @@ use graphcast_sdk::graphcast_agent::{
 };
 
 use crate::db::resolver::retain_max_storage;
-use crate::metrics::{CONNECTED_PEERS, GOSSIP_PEERS, RECEIVED_MESSAGES, PRUNED_MESSAGES};
+use crate::metrics::{CONNECTED_PEERS, GOSSIP_PEERS, PRUNED_MESSAGES, RECEIVED_MESSAGES};
 use crate::{
     config::Config,
     db::resolver::{add_message, list_messages},
@@ -182,7 +182,7 @@ impl RadioOperator {
                     }
 
                     // Prune old messages
-                    let num_pruned = 
+                    let num_pruned =
                         match timeout(update_timeout,
                             retain_max_storage(&self.db, self.config.max_storage.try_into().unwrap())
                         ).await {