Merge branch 'feature/async' of github.com:BlackbirdHQ/rustot into fi…

…x/ensure_one_sub_on_topic

src/shadows/mod.rs

@@ -232,7 +232,7 @@ where
         }
     }
 
-    pub async fn delete_shadow(&mut self) -> Result<(), Error> {
+    pub async fn delete_shadow(&self) -> Result<(), Error> {
         let _delete_request = self.delete_requested.lock().await;
 
         // Wait for mqtt to connect
@@ -460,7 +460,7 @@ where
     }
 
     /// Get an immutable reference to the internal local state.
-    pub async fn try_get(&mut self) -> Result<S, Error> {
+    pub async fn try_get(&self) -> Result<S, Error> {
         self.dao.lock().await.read().await
     }
 
@@ -481,6 +481,14 @@ where
         Ok(state)
     }
 
+    /// Report the state of the shadow.
+    pub async fn report(&self) -> Result<(), Error> {
+        let state = self.dao.lock().await.read().await?;
+
+        self.handler.report(&state).await?;
+        Ok(())
+    }
+
     /// Update the state of the shadow.
     ///
     /// This function will update the desired state of the shadow in the cloud,
@@ -507,7 +515,7 @@ where
         Ok(())
     }
 
-    pub async fn delete_shadow(&mut self) -> Result<(), Error> {
+    pub async fn delete_shadow(&self) -> Result<(), Error> {
         self.handler.delete_shadow().await?;
         self.dao.lock().await.write(&S::default()).await?;
         Ok(())