Compare commits
6 Commits
a2e65c2d1a
...
2f181e35f3
| Author | SHA1 | Date | |
|---|---|---|---|
|
2f181e35f3
|
|||
|
613fd63895
|
|||
|
cfa482aa03
|
|||
|
379d840158
|
|||
|
0c428d1d9b
|
|||
|
56275811f7
|
@@ -28,13 +28,7 @@ impl mlua::UserData for WrappedAsyncClient {
|
||||
methods.add_async_method(
|
||||
"send_message",
|
||||
async |_lua, this, (topic, message): (String, mlua::Value)| {
|
||||
// serde_json converts nil => "null", but we actually want nil to send an empty
|
||||
// message
|
||||
let message = if message.is_nil() {
|
||||
"".into()
|
||||
} else {
|
||||
serde_json::to_string(&message).unwrap()
|
||||
};
|
||||
let message = serde_json::to_string(&message).unwrap();
|
||||
|
||||
debug!("message = {message}");
|
||||
|
||||
|
||||
59
config.lua
59
config.lua
@@ -425,15 +425,12 @@ device_manager:add(HueSwitch.new({
|
||||
local hallway_light_automation = {
|
||||
timeout = Timeout.new(),
|
||||
forced = false,
|
||||
switch_callback = function(self)
|
||||
return function(_, on)
|
||||
switch_callback = function(self, on)
|
||||
self.timeout:cancel()
|
||||
self.group.set_on(on)
|
||||
self.forced = on
|
||||
end
|
||||
end,
|
||||
door_callback = function(self)
|
||||
return function(_, open)
|
||||
door_callback = function(self, open)
|
||||
if open then
|
||||
self.timeout:cancel()
|
||||
|
||||
@@ -445,10 +442,8 @@ local hallway_light_automation = {
|
||||
end
|
||||
end)
|
||||
end
|
||||
end
|
||||
end,
|
||||
trash_callback = function(self)
|
||||
return function(_, open)
|
||||
trash_callback = function(self, open)
|
||||
if open then
|
||||
self.group.set_on(true)
|
||||
else
|
||||
@@ -460,23 +455,20 @@ local hallway_light_automation = {
|
||||
self.group.set_on(false)
|
||||
end
|
||||
end
|
||||
end
|
||||
end,
|
||||
light_callback = function(self)
|
||||
return function(_, state)
|
||||
light_callback = function(self, on)
|
||||
if
|
||||
state.on
|
||||
on
|
||||
and (self.trash == nil or self.trash:open_percent()) == 0
|
||||
and (self.door == nil or self.door:open_percent() == 0)
|
||||
then
|
||||
-- If the door and trash are not open, that means the light got turned on manually
|
||||
self.timeout:cancel()
|
||||
self.forced = true
|
||||
elseif not state.on then
|
||||
elseif not on then
|
||||
-- The light is never forced when it is off
|
||||
self.forced = false
|
||||
end
|
||||
end
|
||||
end,
|
||||
}
|
||||
|
||||
@@ -485,7 +477,9 @@ local hallway_storage = LightBrightness.new({
|
||||
room = "Hallway",
|
||||
topic = mqtt_z2m("hallway/storage"),
|
||||
client = mqtt_client,
|
||||
callback = hallway_light_automation:light_callback(),
|
||||
callback = function(_, state)
|
||||
hallway_light_automation:light_callback(state.state)
|
||||
end,
|
||||
})
|
||||
turn_off_when_away(hallway_storage)
|
||||
device_manager:add(hallway_storage)
|
||||
@@ -510,12 +504,13 @@ hallway_light_automation.group = {
|
||||
end,
|
||||
}
|
||||
|
||||
local function presence(duration)
|
||||
local timeout = Timeout.new()
|
||||
|
||||
return function(_, open)
|
||||
local frontdoor_presence = {
|
||||
timeout = Timeout.new(),
|
||||
}
|
||||
setmetatable(frontdoor_presence, {
|
||||
__call = function(self, open)
|
||||
if open then
|
||||
timeout:cancel()
|
||||
self.timeout:cancel()
|
||||
|
||||
if not presence_system:overall_presence() then
|
||||
mqtt_client:send_message(mqtt_automation("presence/contact/frontdoor"), {
|
||||
@@ -524,19 +519,21 @@ local function presence(duration)
|
||||
})
|
||||
end
|
||||
else
|
||||
timeout:start(duration, function()
|
||||
mqtt_client:send_message(mqtt_automation("presence/contact/frontdoor"), nil)
|
||||
self.timeout:start(debug and 10 or 15 * 60, function()
|
||||
mqtt_client:send_message(mqtt_automation("presence/contact/frontdoor"), {})
|
||||
end)
|
||||
end
|
||||
end
|
||||
end
|
||||
end,
|
||||
})
|
||||
|
||||
device_manager:add(IkeaRemote.new({
|
||||
name = "Remote",
|
||||
room = "Hallway",
|
||||
client = mqtt_client,
|
||||
topic = mqtt_z2m("hallway/remote"),
|
||||
callback = hallway_light_automation:switch_callback(),
|
||||
callback = function(_, on)
|
||||
hallway_light_automation:switch_callback(on)
|
||||
end,
|
||||
battery_callback = check_battery,
|
||||
}))
|
||||
local hallway_frontdoor = ContactSensor.new({
|
||||
@@ -549,10 +546,10 @@ local hallway_frontdoor = ContactSensor.new({
|
||||
topic = mqtt_automation("presence/contact/frontdoor"),
|
||||
timeout = debug and 10 or 15 * 60,
|
||||
},
|
||||
callback = {
|
||||
presence(debug and 10 or 15 * 60),
|
||||
hallway_light_automation:door_callback(),
|
||||
},
|
||||
callback = function(_, open)
|
||||
hallway_light_automation:door_callback(open)
|
||||
frontdoor_presence(open)
|
||||
end,
|
||||
battery_callback = check_battery,
|
||||
})
|
||||
device_manager:add(hallway_frontdoor)
|
||||
@@ -564,7 +561,9 @@ local hallway_trash = ContactSensor.new({
|
||||
sensor_type = "Drawer",
|
||||
topic = mqtt_z2m("hallway/trash"),
|
||||
client = mqtt_client,
|
||||
callback = hallway_light_automation:trash_callback(),
|
||||
callback = function(_, open)
|
||||
hallway_light_automation:trash_callback(open)
|
||||
end,
|
||||
battery_callback = check_battery,
|
||||
})
|
||||
device_manager:add(hallway_trash)
|
||||
|
||||
Reference in New Issue
Block a user