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