feat: configurable refresh intervals (#44)

rm-config/defaults/config.toml

@@ -21,4 +21,7 @@ url = "http://CHANGE_ME:9091/transmission/rpc" # REQUIRED!
 # username = "CHANGE_ME"
 # password = "CHANGE_ME"
 
-
+# Refresh timings (in seconds)
+torrents_refresh = 5
+stats_refresh = 10
+free_space_refresh = 10

rm-config/src/lib.rs

@@ -42,6 +42,12 @@ pub struct Connection {
     pub username: Option<String>,
     pub password: Option<String>,
     pub url: String,
+    #[serde(default)]
+    pub torrents_refresh: u64,
+    #[serde(default)]
+    pub stats_refresh: u64,
+    #[serde(default)]
+    pub free_space_refresh: u64,
 }
 
 const DEFAULT_CONFIG: &str = include_str!("../defaults/config.toml");

rm-main/src/transmission/fetchers.rs

@@ -23,7 +23,7 @@ pub async fn stats(ctx: app::Ctx, stats: Arc<Mutex<Option<SessionStats>>>) {
             .arguments;
         *stats.lock().unwrap() = Some(new_stats);
         ctx.send_action(Action::Render);
-        tokio::time::sleep(Duration::from_secs(5)).await;
+        tokio::time::sleep(Duration::from_secs(ctx.config.connection.stats_refresh)).await;
     }
 }
 
@@ -50,7 +50,10 @@ pub async fn free_space(ctx: app::Ctx, free_space: Arc<Mutex<Option<FreeSpace>>>
             .arguments;
         *free_space.lock().unwrap() = Some(new_free_space);
         ctx.send_action(Action::Render);
-        tokio::time::sleep(Duration::from_secs(10)).await;
+        tokio::time::sleep(Duration::from_secs(
+            ctx.config.connection.free_space_refresh,
+        ))
+        .await;
     }
 }
 
@@ -85,6 +88,6 @@ pub async fn torrents(ctx: app::Ctx, table_manager: Arc<Mutex<TableManager>>) {
                 .set_new_rows(new_torrents.iter().map(RustmissionTorrent::from).collect());
         }
         ctx.send_action(Action::Render);
-        tokio::time::sleep(Duration::from_secs(5)).await;
+        tokio::time::sleep(Duration::from_secs(ctx.config.connection.torrents_refresh)).await;
     }
 }