added configurable interval for user rate send events (#134)

settings.tpl.toml

@@ -29,6 +29,8 @@ min_payment_amount = 100
 expiration_hours = 24
 # Expiration of pending orders
 expiration_seconds = 900
+# User rate events scheduled time interval
+user_rates_sent_interval_seconds = 3600
 
 [database]
 url = "sqlite://mostro.db"

src/cli/settings.rs

@@ -97,6 +97,7 @@ pub struct Mostro {
     pub min_payment_amount: u32,
     pub expiration_hours: u32,
     pub expiration_seconds: u32,
+    pub user_rates_sent_interval_seconds: u32,
 }
 
 impl TryFrom<Settings> for Mostro {

src/scheduler.rs

@@ -23,6 +23,8 @@ pub async fn start_scheduler(rate_list: Arc<Mutex<Vec<Event>>>, client: &Client)
 async fn job_update_rate_events(client: Client, rate_list: Arc<Mutex<Vec<Event>>>) {
     // Clone for closure owning with Arc
     let inner_list = rate_list.clone();
+    let mostro_settings = Settings::get_mostro();
+    let user_rates_sent_seconds = mostro_settings.user_rates_sent_interval_seconds as u64;
 
     tokio::spawn(async move {
         loop {
@@ -44,13 +46,15 @@ async fn job_update_rate_events(client: Client, rate_list: Arc<Mutex<Vec<Event>>
             inner_list.lock().await.clear();
 
             let now = Utc::now();
-            let next_tick = now.checked_add_signed(Duration::hours(1)).unwrap();
+            let next_tick = now
+                .checked_add_signed(Duration::seconds(user_rates_sent_seconds as i64))
+                .unwrap();
             info!(
                 "Next tick for update users rating is {}",
                 next_tick.format("%a %b %e %T %Y")
             );
 
-            tokio::time::sleep(tokio::time::Duration::from_secs(3600)).await;
+            tokio::time::sleep(tokio::time::Duration::from_secs(user_rates_sent_seconds)).await;
         }
     });
 }