Reimplement to also fix #73

config.toml

@@ -1,5 +1,5 @@
 inverter_host = "192.168.4.182"
-coop_mode = false
+update_interval = 30500
 
 [home_assistant]
 host = "192.168.178.250"

src/main.rs

@@ -21,13 +21,12 @@ use log::{error, info};
 #[derive(Debug, Deserialize)]
 struct Config {
     inverter_host: String,
-    coop_mode: Option<bool>,
+    update_interval: Option<u64>,
     home_assistant: Option<MqttConfig>,
     simple_mqtt: Option<MqttConfig>,
 }
 
 static REQUEST_DELAY_DEFAULT: u64 = 30_500;
-static REQUEST_DELAY_COOP_MODE: u64 = 60_500;
 
 fn main() {
     logging::init_logger();
@@ -55,6 +54,21 @@ fn main() {
     let contents = fs::read_to_string(path).expect("Could not read config.toml");
     let config: Config = toml::from_str(&contents).expect("toml config unparsable");
 
+    if config
+        .update_interval
+        .is_some_and(|value| value > REQUEST_DELAY_DEFAULT)
+    {
+        info!(
+            "using non-default update interval of {:.2}s",
+            (config.update_interval.unwrap() as f64 / 1000.)
+        )
+    } else {
+        info!(
+            "using default update interval of {:.2}s",
+            (REQUEST_DELAY_DEFAULT as f64 / 1000.)
+        )
+    }
+
     info!("inverter host: {}", config.inverter_host);
     let mut inverter = Inverter::new(&config.inverter_host);
 
@@ -75,12 +89,13 @@ fn main() {
                 channel.publish(&r);
             })
         }
-        
+
         // TODO: the sleep has to move into the Inverter struct in an async implementation
-        if config.coop_mode.is_some_and(|value| value) {
-            // In coop mode, the inverter is updated approximately once a minute. This is sparse
-            // enough for the cloud to get updated, too.   
-            thread::sleep(Duration::from_millis(REQUEST_DELAY_COOP_MODE));
+        if config
+            .update_interval
+            .is_some_and(|value| value > REQUEST_DELAY_DEFAULT)
+        {
+            thread::sleep(Duration::from_millis(config.update_interval.unwrap()));
         } else {
             thread::sleep(Duration::from_millis(REQUEST_DELAY_DEFAULT));
         }