reformat

refactor

Author: LeoPatOZ

src/callback/mod.rs

@@ -1,10 +1,10 @@
 use alloy::rpc::types::Log;
 use async_trait::async_trait;
 
+pub mod strategy;
+
 #[async_trait]
 pub trait EventCallback {
     /// Called when a matching log is found.
     async fn on_event(&self, log: &Log) -> anyhow::Result<()>;
 }
-
-pub mod strategy;

src/callback/strategy/fixed_retry.rs

@@ -8,15 +8,15 @@ use crate::callback::EventCallback;
 
 use super::CallbackStrategy;
 
+pub const BACK_OFF_MAX_RETRIES: u64 = 5;
+pub const BACK_OFF_MAX_DELAY_MS: u64 = 200;
+
 #[derive(Clone, Copy, Debug)]
 pub struct FixedRetryConfig {
     pub max_attempts: u64,
     pub delay_ms: u64,
 }
 
-pub const BACK_OFF_MAX_RETRIES: u64 = 5;
-pub const BACK_OFF_MAX_DELAY_MS: u64 = 200;
-
 impl Default for FixedRetryConfig {
     fn default() -> Self {
         Self { max_attempts: BACK_OFF_MAX_RETRIES, delay_ms: BACK_OFF_MAX_DELAY_MS }

src/callback/strategy/mod.rs

@@ -5,6 +5,12 @@ use async_trait::async_trait;
 
 use crate::callback::EventCallback;
 
+pub mod fixed_retry;
+pub mod state_sync_aware;
+
+pub use fixed_retry::{BACK_OFF_MAX_RETRIES, FixedRetryConfig, FixedRetryStrategy};
+pub use state_sync_aware::{StateSyncAwareStrategy, StateSyncConfig};
+
 #[async_trait]
 pub trait CallbackStrategy: Send + Sync {
     async fn execute(
@@ -13,9 +19,3 @@ pub trait CallbackStrategy: Send + Sync {
         log: &Log,
     ) -> anyhow::Result<()>;
 }
-
-pub mod fixed_retry;
-pub mod state_sync_aware;
-
-pub use fixed_retry::{BACK_OFF_MAX_RETRIES, FixedRetryConfig, FixedRetryStrategy};
-pub use state_sync_aware::{StateSyncAwareStrategy, StateSyncConfig};

src/callback/strategy/state_sync_aware.rs

@@ -8,6 +8,11 @@ use crate::{FixedRetryConfig, callback::EventCallback};
 
 use super::{CallbackStrategy, fixed_retry::FixedRetryStrategy};
 
+pub const STATE_SYNC_RETRY_INTERVAL: Duration = Duration::from_secs(30);
+pub const STATE_SYNC_RETRY_MAX_INTERVAL: Duration = Duration::from_secs(120);
+pub const STATE_SYNC_RETRY_MAX_ELAPSED: Duration = Duration::from_secs(600);
+pub const STATE_SYNC_RETRY_MULTIPLIER: f64 = 1.5;
+
 #[derive(Clone, Copy, Debug)]
 pub struct StateSyncConfig {
     pub initial_interval: Duration,
@@ -16,11 +21,6 @@ pub struct StateSyncConfig {
     pub multiplier: f64,
 }
 
-pub const STATE_SYNC_RETRY_INTERVAL: Duration = Duration::from_secs(30);
-pub const STATE_SYNC_RETRY_MAX_INTERVAL: Duration = Duration::from_secs(120);
-pub const STATE_SYNC_RETRY_MAX_ELAPSED: Duration = Duration::from_secs(600);
-pub const STATE_SYNC_RETRY_MULTIPLIER: f64 = 1.5;
-
 impl Default for StateSyncConfig {
     fn default() -> Self {
         Self {