Cooperative Mode for S-Miles cloud with parameter to enable / disable it. Will pause polling the inverter at appropriate times

config.toml

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

src/bin/hms-mqtt-publish/main.rs

@@ -14,14 +14,15 @@ use rumqttc_wrapper::RumqttcWrapper;
 use serde_derive::Deserialize;
 use std::fs;
 use std::thread;
-use std::time::Duration;
+use std::time::{Duration, SystemTime, UNIX_EPOCH};
 
 use log::{error, info};
 
 #[derive(Debug, Deserialize)]
 struct Config {
     inverter_host: String,
     update_interval: Option<u64>,
+    smiles_cooperation: bool,
     home_assistant: Option<MqttConfig>,
     simple_mqtt: Option<MqttConfig>,
 }
@@ -83,7 +84,30 @@ fn main() {
         output_channels.push(Box::new(SimpleMqtt::<RumqttcWrapper>::new(&config)));
     }
 
+    if config.smiles_cooperation {
+        info!("S-Miles cloud cooperative mode enabled");
+    }
+
     loop {
+        // Do not query the inverter when the S-Miles cloud is about to update
+        if config.smiles_cooperation {
+            let now = SystemTime::now();
+            let duration_since_epoch = now.duration_since(UNIX_EPOCH).unwrap();
+            let seconds_since_epoch = duration_since_epoch.as_secs();
+
+            let seconds_in_current_minute = seconds_since_epoch % 60;
+            let minutes_since_epoch = seconds_since_epoch / 60;
+            let minutes_in_current_hour = minutes_since_epoch % 60;
+
+            // This is the time at which the S-Miles update seems to take place
+            // Adding some extra time before and after, in which we dont publish
+            if minutes_in_current_hour % 15 == 14 {
+                thread::sleep(Duration::from_millis(
+                    (15 + 60 - seconds_in_current_minute) * 1000,
+                ));
+            }
+        }
+
         if let Some(r) = inverter.update_state() {
             output_channels.iter_mut().for_each(|channel| {
                 channel.publish(&r);