Dreaded_X/automation_rs
1
0
Fork 0
Code Issues 2 Pull Requests Actions Packages Projects Releases Wiki Activity

Small change to how on presence changes the state for IkeaOutlet

Browse Source
This commit is contained in:
Dreaded_X 2023-01-10 00:41:41 +01:00
parent 220c68cd65
commit 9d6488183f
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/devices/ikea_outlet.rs
View File

@ -2,7 +2,7 @@ use std::time::Duration;
use async_trait::async_trait; use async_trait::async_trait;
use google_home::errors::ErrorCode; use google_home::errors::ErrorCode;
use google_home::{GoogleHomeDevice, device, types::Type, traits}; use google_home::{GoogleHomeDevice, device, types::Type, traits::{self, OnOff}};
use rumqttc::{AsyncClient, Publish, matches}; use rumqttc::{AsyncClient, Publish, matches};
use tracing::{debug, trace, error}; use tracing::{debug, trace, error};
use tokio::task::JoinHandle; use tokio::task::JoinHandle;
@ -101,9 +101,10 @@ impl OnMqtt for IkeaOutlet {
tokio::spawn(async move { tokio::spawn(async move {
debug!(id, "Starting timeout ({timeout:?}) for kettle..."); debug!(id, "Starting timeout ({timeout:?}) for kettle...");
tokio::time::sleep(timeout).await; tokio::time::sleep(timeout).await;
// @TODO We need to call set_on(false) in order to turn the device off
// again, how are we going to do this?
debug!(id, "Turning kettle off!"); debug!(id, "Turning kettle off!");
// @TODO Idealy we would call self.set_on(false), however since we want to do
// it after a timeout we have to put it in a seperate task.
// I don't think we can really get around calling outside function
set_on(client, topic, false).await; set_on(client, topic, false).await;
}) })
); );
@ -117,7 +118,7 @@ impl OnPresence for IkeaOutlet {
// Turn off the outlet when we leave the house // Turn off the outlet when we leave the house
if !presence { if !presence {
debug!(id = self.identifier, "Turning device off"); debug!(id = self.identifier, "Turning device off");
set_on(self.client.clone(), self.mqtt.topic.clone(), false).await; self.set_on(false).ok();
} }
} }
} }