Compare commits

...

4 Commits

Author SHA1 Message Date
ad158f2c22 feat: Reduced visibility of config structs
All checks were successful
Build and deploy / build (push) Successful in 9m0s
Build and deploy / Deploy container (push) Successful in 49s
2025-10-22 04:13:54 +02:00
f36adf2f19 feat: Implement useful traits to simplify code 2025-10-22 04:09:01 +02:00
5947098bfb chore: Fix config type annotations
All checks were successful
Build and deploy / build (push) Successful in 12m30s
Build and deploy / Deploy container (push) Has been skipped
2025-10-22 03:59:59 +02:00
8a3143a3ea feat: Added type alias for setup and schedule types 2025-10-22 03:59:40 +02:00
21 changed files with 120 additions and 45 deletions

View File

@@ -1,5 +1,6 @@
local ntfy = require("config.ntfy") local ntfy = require("config.ntfy")
--- @class BatteryModule: Module
local module = {} local module = {}
--- @type {[string]: number} --- @type {[string]: number}
@@ -17,7 +18,7 @@ function module.callback(device, battery)
end end
end end
function module.notify_low_battery() local function notify_low_battery()
-- Don't send notifications if there are now devices with low battery -- Don't send notifications if there are now devices with low battery
if next(low_battery) == nil then if next(low_battery) == nil then
print("No devices with low battery") print("No devices with low battery")
@@ -38,8 +39,9 @@ function module.notify_low_battery()
}) })
end end
--- @type Schedule
module.schedule = { module.schedule = {
["0 0 21 */1 * *"] = module.notify_low_battery, ["0 0 21 */1 * *"] = notify_low_battery,
} }
return module return module

View File

@@ -4,6 +4,7 @@ local presence = require("config.presence")
local utils = require("automation:utils") local utils = require("automation:utils")
local variables = require("automation:variables") local variables = require("automation:variables")
--- @class DebugModule: Module
local module = {} local module = {}
if variables.debug == "true" then if variables.debug == "true" then

View File

@@ -1,6 +1,7 @@
local debug = require("config.debug") local debug = require("config.debug")
local utils = require("automation:utils") local utils = require("automation:utils")
--- @class HallwayAutomationModule: Module
local module = {} local module = {}
local timeout = utils.Timeout.new() local timeout = utils.Timeout.new()

View File

@@ -1,5 +1,6 @@
local utils = require("automation:utils") local utils = require("automation:utils")
--- @class HelperModule: Module
local module = {} local module = {}
--- @param topic string --- @param topic string

View File

@@ -3,6 +3,7 @@ local light = require("config.light")
local presence = require("config.presence") local presence = require("config.presence")
local secrets = require("automation:secrets") local secrets = require("automation:secrets")
--- @class HueBridgeModule: Module
local module = {} local module = {}
module.ip = "10.0.0.102" module.ip = "10.0.0.102"

View File

@@ -1,6 +1,7 @@
local devices = require("automation:devices") local devices = require("automation:devices")
local helper = require("config.helper") local helper = require("config.helper")
--- @class LightModule: Module
local module = {} local module = {}
--- @class OnPresence --- @class OnPresence
@@ -34,6 +35,7 @@ function module.setup(mqtt_client)
callback = callback, callback = callback,
}) })
--- @type Module
return { return {
module.device, module.device,
} }

View File

@@ -1,6 +1,7 @@
local devices = require("automation:devices") local devices = require("automation:devices")
local secrets = require("automation:secrets") local secrets = require("automation:secrets")
--- @class NtfyModule: Module
local module = {} local module = {}
local ntfy_topic = secrets.ntfy_topic local ntfy_topic = secrets.ntfy_topic
@@ -24,6 +25,7 @@ function module.setup()
topic = ntfy_topic, topic = ntfy_topic,
}) })
--- @type Module
return { return {
ntfy, ntfy,
} }

View File

@@ -2,6 +2,7 @@ local devices = require("automation:devices")
local helper = require("config.helper") local helper = require("config.helper")
local ntfy = require("config.ntfy") local ntfy = require("config.ntfy")
--- @class PresenceModule: Module
local module = {} local module = {}
--- @class OnPresence --- @class OnPresence
@@ -61,6 +62,7 @@ function module.setup(mqtt_client)
}) })
end) end)
--- @type Module
return { return {
presence, presence,
} }

View File

@@ -3,9 +3,9 @@ local devices = require("automation:devices")
local helper = require("config.helper") local helper = require("config.helper")
local ntfy = require("config.ntfy") local ntfy = require("config.ntfy")
--- @type Module
local module = {} local module = {}
--- @type SetupFunction
function module.setup(mqtt_client) function module.setup(mqtt_client)
local light = devices.LightOnOff.new({ local light = devices.LightOnOff.new({
name = "Light", name = "Light",
@@ -30,6 +30,7 @@ function module.setup(mqtt_client)
end, end,
}) })
--- @type Module
return { return {
light, light,
washer, washer,

View File

@@ -4,12 +4,12 @@ local helper = require("config.helper")
local hue_bridge = require("config.hue_bridge") local hue_bridge = require("config.hue_bridge")
local windows = require("config.windows") local windows = require("config.windows")
--- @type Module
local module = {} local module = {}
--- @type AirFilter? --- @type AirFilter?
local air_filter = nil local air_filter = nil
--- @type SetupFunction
function module.setup(mqtt_client) function module.setup(mqtt_client)
local lights = devices.HueGroup.new({ local lights = devices.HueGroup.new({
identifier = "bedroom_lights", identifier = "bedroom_lights",
@@ -55,6 +55,7 @@ function module.setup(mqtt_client)
}) })
windows.add(window) windows.add(window)
--- @type Module
return { return {
devices = { devices = {
lights, lights,

View File

@@ -4,9 +4,9 @@ local helper = require("config.helper")
local presence = require("config.presence") local presence = require("config.presence")
local windows = require("config.windows") local windows = require("config.windows")
--- @type Module
local module = {} local module = {}
--- @type SetupFunction
function module.setup(mqtt_client) function module.setup(mqtt_client)
local light = devices.LightOnOff.new({ local light = devices.LightOnOff.new({
name = "Light", name = "Light",
@@ -25,6 +25,7 @@ function module.setup(mqtt_client)
}) })
windows.add(window) windows.add(window)
--- @type Module
return { return {
light, light,
window, window,

View File

@@ -8,9 +8,9 @@ local presence = require("config.presence")
local utils = require("automation:utils") local utils = require("automation:utils")
local windows = require("config.windows") local windows = require("config.windows")
--- @type Module
local module = {} local module = {}
--- @type SetupFunction
function module.setup(mqtt_client) function module.setup(mqtt_client)
local main_light = devices.HueGroup.new({ local main_light = devices.HueGroup.new({
identifier = "hallway_main_light", identifier = "hallway_main_light",
@@ -97,6 +97,7 @@ function module.setup(mqtt_client)
windows.add(frontdoor) windows.add(frontdoor)
hallway_automation.set_door(frontdoor) hallway_automation.set_door(frontdoor)
--- @type Module
return { return {
main_light, main_light,
storage_light, storage_light,

View File

@@ -3,9 +3,9 @@ local devices = require("automation:devices")
local helper = require("config.helper") local helper = require("config.helper")
local hue_bridge = require("config.hue_bridge") local hue_bridge = require("config.hue_bridge")
--- @type Module
local module = {} local module = {}
--- @type SetupFunction
function module.setup(mqtt_client) function module.setup(mqtt_client)
local light = devices.HueGroup.new({ local light = devices.HueGroup.new({
identifier = "hallway_top_light", identifier = "hallway_top_light",
@@ -37,6 +37,7 @@ function module.setup(mqtt_client)
battery_callback = battery.callback, battery_callback = battery.callback,
}) })
--- @type Module
return { return {
light, light,
top_switch, top_switch,

View File

@@ -4,6 +4,7 @@ local helper = require("config.helper")
local hue_bridge = require("config.hue_bridge") local hue_bridge = require("config.hue_bridge")
local presence = require("config.presence") local presence = require("config.presence")
--- @class KitchenModule: Module
local module = {} local module = {}
--- @type HueGroup? --- @type HueGroup?

View File

@@ -5,9 +5,9 @@ local hue_bridge = require("config.hue_bridge")
local presence = require("config.presence") local presence = require("config.presence")
local windows = require("config.windows") local windows = require("config.windows")
--- @type Module
local module = {} local module = {}
--- @type SetupFunction
function module.setup(mqtt_client) function module.setup(mqtt_client)
local lights = devices.HueGroup.new({ local lights = devices.HueGroup.new({
identifier = "living_lights", identifier = "living_lights",
@@ -109,6 +109,7 @@ function module.setup(mqtt_client)
}) })
windows.add(window) windows.add(window)
--- @type Module
return { return {
lights, lights,
lights_relax, lights_relax,

View File

@@ -3,9 +3,9 @@ local devices = require("automation:devices")
local helper = require("config.helper") local helper = require("config.helper")
local presence = require("config.presence") local presence = require("config.presence")
--- @type Module
local module = {} local module = {}
--- @type SetupFunction
function module.setup(mqtt_client) function module.setup(mqtt_client)
local light = devices.LightBrightness.new({ local light = devices.LightBrightness.new({
name = "Light", name = "Light",
@@ -31,6 +31,7 @@ function module.setup(mqtt_client)
battery_callback = battery.callback, battery_callback = battery.callback,
}) })
--- @type Module
return { return {
light, light,
door, door,

View File

@@ -5,9 +5,9 @@ local helper = require("config.helper")
local presence = require("config.presence") local presence = require("config.presence")
local utils = require("automation:utils") local utils = require("automation:utils")
--- @type Module
local module = {} local module = {}
--- @type SetupFunction
function module.setup(mqtt_client) function module.setup(mqtt_client)
local charger = devices.OutletOnOff.new({ local charger = devices.OutletOnOff.new({
name = "Charger", name = "Charger",
@@ -57,6 +57,7 @@ function module.setup(mqtt_client)
battery_callback = battery.callback, battery_callback = battery.callback,
}) })
--- @type Module
return { return {
charger, charger,
outlets, outlets,

View File

@@ -1,6 +1,7 @@
local ntfy = require("config.ntfy") local ntfy = require("config.ntfy")
local presence = require("config.presence") local presence = require("config.presence")
--- @class WindowsModule: Module
local module = {} local module = {}
--- @class OnPresence --- @class OnPresence

View File

@@ -13,10 +13,14 @@ local FulfillmentConfig
---@field mqtt MqttConfig ---@field mqtt MqttConfig
local Config local Config
---@alias SetupFunction fun(mqtt_client: AsyncClient): Module | DeviceInterface[] | nil
---@alias Schedule table<string, fun() | fun()[]>
---@class Module ---@class Module
---@field setup (fun(mqtt_client: AsyncClient): Module | DeviceInterface[] | nil)? ---@field setup (SetupFunction)?
---@field devices (DeviceInterface)[]? ---@field devices (DeviceInterface)[]?
---@field schedule table<string, fun() | fun()[]>? ---@field schedule Schedule?
---@field [number] (Module)[]? ---@field [number] (Module)[]?
local Module local Module

View File

@@ -1,10 +1,8 @@
use std::fs::{self, File}; use std::fs::{self, File};
use std::io::Write; use std::io::Write;
use automation::config::{Config, FulfillmentConfig, Module as ConfigModule}; use automation::config::generate_definitions;
use automation_lib::Module; use automation_lib::Module;
use automation_lib::mqtt::{MqttConfig, WrappedAsyncClient};
use lua_typed::Typed;
use tracing::{info, warn}; use tracing::{info, warn};
extern crate automation_devices; extern crate automation_devices;
@@ -27,24 +25,6 @@ fn write_definitions(filename: &str, definitions: &str) -> std::io::Result<()> {
Ok(()) Ok(())
} }
fn config_definitions() -> String {
let mut output = "---@meta\n\n".to_string();
output +=
&FulfillmentConfig::generate_full().expect("FulfillmentConfig should have a definition");
output += "\n";
output += &Config::generate_full().expect("Config should have a definition");
output += "\n";
output += &ConfigModule::generate_full().expect("Module should have a definition");
output += "\n";
output += &MqttConfig::generate_full().expect("MqttConfig should have a definition");
output += "\n";
output +=
&WrappedAsyncClient::generate_full().expect("WrappedAsyncClient should have a definition");
output
}
fn main() -> std::io::Result<()> { fn main() -> std::io::Result<()> {
tracing_subscriber::fmt::init(); tracing_subscriber::fmt::init();
@@ -59,7 +39,7 @@ fn main() -> std::io::Result<()> {
} }
} }
write_definitions("config.lua", &config_definitions())?; write_definitions("config.lua", &generate_definitions())?;
Ok(()) Ok(())
} }

View File

@@ -1,5 +1,6 @@
use std::collections::{HashMap, VecDeque}; use std::collections::{HashMap, VecDeque};
use std::net::{Ipv4Addr, SocketAddr}; use std::net::{Ipv4Addr, SocketAddr};
use std::ops::Deref;
use automation_lib::action_callback::ActionCallback; use automation_lib::action_callback::ActionCallback;
use automation_lib::device::Device; use automation_lib::device::Device;
@@ -37,15 +38,20 @@ pub struct FulfillmentConfig {
} }
#[derive(Debug)] #[derive(Debug)]
pub struct SetupFunction(mlua::Function); struct SetupFunction(mlua::Function);
impl Typed for SetupFunction { impl Typed for SetupFunction {
fn type_name() -> String { fn type_name() -> String {
format!( "SetupFunction".into()
"fun(mqtt_client: {}): {} | DeviceInterface[] | nil", }
fn generate_header() -> Option<String> {
Some(format!(
"---@alias {} fun(mqtt_client: {}): {} | DeviceInterface[] | nil\n",
Self::type_name(),
WrappedAsyncClient::type_name(), WrappedAsyncClient::type_name(),
Module::type_name() Module::type_name()
) ))
} }
} }
@@ -55,12 +61,53 @@ impl FromLua for SetupFunction {
} }
} }
impl Deref for SetupFunction {
type Target = mlua::Function;
fn deref(&self) -> &Self::Target {
&self.0
}
}
#[derive(Debug, Default)] #[derive(Debug, Default)]
pub struct Module { struct Schedule(HashMap<String, ActionCallback<()>>);
pub setup: Option<SetupFunction>,
pub devices: Vec<Box<dyn Device>>, impl Typed for Schedule {
pub schedule: HashMap<String, ActionCallback<()>>, fn type_name() -> String {
pub modules: Vec<Module>, "Schedule".into()
}
fn generate_header() -> Option<String> {
Some(format!(
"---@alias {} {}\n",
Self::type_name(),
HashMap::<String, ActionCallback<()>>::type_name(),
))
}
}
impl FromLua for Schedule {
fn from_lua(value: mlua::Value, lua: &mlua::Lua) -> mlua::Result<Self> {
Ok(Self(FromLua::from_lua(value, lua)?))
}
}
impl IntoIterator for Schedule {
type Item = <HashMap<String, ActionCallback<()>> as IntoIterator>::Item;
type IntoIter = <HashMap<String, ActionCallback<()>> as IntoIterator>::IntoIter;
fn into_iter(self) -> Self::IntoIter {
self.0.into_iter()
}
}
#[derive(Debug, Default)]
struct Module {
setup: Option<SetupFunction>,
devices: Vec<Box<dyn Device>>,
schedule: Schedule,
modules: Vec<Module>,
} }
// TODO: Add option to typed to rename field // TODO: Add option to typed to rename field
@@ -82,7 +129,7 @@ impl Typed for Module {
"#, "#,
Option::<SetupFunction>::type_name(), Option::<SetupFunction>::type_name(),
Vec::<Box<dyn Device>>::type_name(), Vec::<Box<dyn Device>>::type_name(),
HashMap::<String, ActionCallback<()>>::type_name(), Schedule::type_name(),
Vec::<Module>::type_name(), Vec::<Module>::type_name(),
)) ))
} }
@@ -161,7 +208,7 @@ impl Modules {
modules.extend(module.modules); modules.extend(module.modules);
if let Some(setup) = module.setup { if let Some(setup) = module.setup {
let result: mlua::Value = setup.0.call_async(client.clone()).await?; let result: mlua::Value = setup.call_async(client.clone()).await?;
if result.is_nil() { if result.is_nil() {
// We ignore nil results // We ignore nil results
@@ -217,3 +264,25 @@ fn default_fulfillment_ip() -> Ipv4Addr {
fn default_fulfillment_port() -> u16 { fn default_fulfillment_port() -> u16 {
7878 7878
} }
pub fn generate_definitions() -> String {
let mut output = "---@meta\n\n".to_string();
output +=
&FulfillmentConfig::generate_full().expect("FulfillmentConfig should have a definition");
output += "\n";
output += &Config::generate_full().expect("Config should have a definition");
output += "\n";
output += &SetupFunction::generate_full().expect("SetupFunction should have a definition");
output += "\n";
output += &Schedule::generate_full().expect("Schedule should have a definition");
output += "\n";
output += &Module::generate_full().expect("Module should have a definition");
output += "\n";
output += &MqttConfig::generate_full().expect("MqttConfig should have a definition");
output += "\n";
output +=
&WrappedAsyncClient::generate_full().expect("WrappedAsyncClient should have a definition");
output
}