[RSDK-8187] config cache changes

micro-rdk/src/common/config_monitor.rs

@@ -1,19 +1,39 @@
 use super::app_client::{AppClient, AppClientError, PeriodicAppClientTask};
+#[cfg(feature = "provisioning")]
+use crate::common::{
+    grpc::ServerError,
+    provisioning::storage::{RobotConfigurationStorage, WifiCredentialStorage},
+};
 use crate::proto::app::v1::ConfigResponse;
 use futures_lite::Future;
+use std::fmt::Debug;
 use std::pin::Pin;
 use std::time::Duration;
 
-pub struct ConfigMonitor<'a> {
-    restart_hook: Option<Box<dyn FnOnce() + 'a>>,
+pub struct ConfigMonitor<'a, S>
+where
+    S: RobotConfigurationStorage + WifiCredentialStorage + Clone + 'static,
+    <S as RobotConfigurationStorage>::Error: Debug,
+    ServerError: From<<S as RobotConfigurationStorage>::Error>,
+    <S as WifiCredentialStorage>::Error: Sync + Send + 'static,
+{
     curr_config: ConfigResponse, //config for robot gotten from last robot startup, aka inputted from entry
+    storage: S,
+    restart_hook: Option<Box<dyn FnOnce() + 'a>>,
 }
 
-impl<'a> ConfigMonitor<'a> {
-    pub fn new(restart_hook: impl FnOnce() + 'a, curr_config: ConfigResponse) -> Self {
+impl<'a, S> ConfigMonitor<'a, S>
+where
+    S: RobotConfigurationStorage + WifiCredentialStorage + Clone + 'static,
+    <S as RobotConfigurationStorage>::Error: Debug,
+    ServerError: From<<S as RobotConfigurationStorage>::Error>,
+    <S as WifiCredentialStorage>::Error: Sync + Send + 'static,
+{
+    pub fn new(curr_config: ConfigResponse, storage: S, restart_hook: impl FnOnce() + 'a) -> Self {
         Self {
-            restart_hook: Some(Box::new(restart_hook)),
             curr_config,
+            storage,
+            restart_hook: Some(Box::new(restart_hook)),
         }
     }
 
@@ -23,7 +43,13 @@ impl<'a> ConfigMonitor<'a> {
         unreachable!();
     }
 }
-impl<'a> PeriodicAppClientTask for ConfigMonitor<'a> {
+impl<'a, S> PeriodicAppClientTask for ConfigMonitor<'a, S>
+where
+    S: RobotConfigurationStorage + WifiCredentialStorage + Clone + 'static,
+    <S as RobotConfigurationStorage>::Error: Debug,
+    ServerError: From<<S as RobotConfigurationStorage>::Error>,
+    <S as WifiCredentialStorage>::Error: Sync + Send + 'static,
+{
     fn name(&self) -> &str {
         "ConfigMonitor"
     }
@@ -43,7 +69,12 @@ impl<'a> PeriodicAppClientTask for ConfigMonitor<'a> {
                 app_client.clone().get_config(None).await
             {
                 if self.curr_config != *new_config {
-                    self.restart()
+                    if let Some(config) = new_config.config {
+                        if let Err(e) = self.storage.store_robot_configuration(config) {
+                            log::warn!("Failed to store new robot configuration from app: {}", e);
+                        }
+                    }
+                    self.restart();
                 }
             }
             Ok(Some(self.get_default_period()))

micro-rdk/src/esp32/entry.rs

@@ -161,8 +161,9 @@ pub async fn serve_web_inner<S>(
         crate::esp32::esp_idf_svc::sys::esp_restart()
     })))
     .with_periodic_app_client_task(Box::new(ConfigMonitor::new(
-        || unsafe { crate::esp32::esp_idf_svc::sys::esp_restart() },
         *(cfg_response.clone()),
+        storage.clone(),
+        || unsafe { crate::esp32::esp_idf_svc::sys::esp_restart() },
     )))
     .build(&cfg_response)
     .unwrap();

micro-rdk/src/native/entry.rs

@@ -129,8 +129,9 @@ pub async fn serve_web_inner<S>(
             .with_app_client(app_client)
             .with_periodic_app_client_task(Box::new(RestartMonitor::new(|| std::process::exit(0))))
             .with_periodic_app_client_task(Box::new(ConfigMonitor::new(
-                || std::process::exit(0),
                 *(cfg_response.clone()),
+                storage.clone(),
+                || std::process::exit(0),
             )))
             .build(&cfg_response)
             .unwrap();