Compare commits

...

2 Commits

Author SHA1 Message Date
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 79 additions and 19 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,7 +1,9 @@
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::{
Config, FulfillmentConfig, Module as ConfigModule, Schedule, SetupFunction,
};
use automation_lib::Module; use automation_lib::Module;
use automation_lib::mqtt::{MqttConfig, WrappedAsyncClient}; use automation_lib::mqtt::{MqttConfig, WrappedAsyncClient};
use lua_typed::Typed; use lua_typed::Typed;
@@ -35,6 +37,10 @@ fn config_definitions() -> String {
output += "\n"; output += "\n";
output += &Config::generate_full().expect("Config should have a definition"); output += &Config::generate_full().expect("Config should have a definition");
output += "\n"; 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 += &ConfigModule::generate_full().expect("Module should have a definition"); output += &ConfigModule::generate_full().expect("Module should have a definition");
output += "\n"; output += "\n";
output += &MqttConfig::generate_full().expect("MqttConfig should have a definition"); output += &MqttConfig::generate_full().expect("MqttConfig should have a definition");

View File

@@ -41,11 +41,16 @@ pub 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,11 +60,34 @@ impl FromLua for SetupFunction {
} }
} }
#[derive(Debug, Default)]
pub struct Schedule(HashMap<String, ActionCallback<()>>);
impl Typed for Schedule {
fn type_name() -> String {
"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)?))
}
}
#[derive(Debug, Default)] #[derive(Debug, Default)]
pub struct Module { pub struct Module {
pub setup: Option<SetupFunction>, pub setup: Option<SetupFunction>,
pub devices: Vec<Box<dyn Device>>, pub devices: Vec<Box<dyn Device>>,
pub schedule: HashMap<String, ActionCallback<()>>, pub schedule: Schedule,
pub modules: Vec<Module>, pub modules: Vec<Module>,
} }
@@ -82,7 +110,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(),
)) ))
} }
@@ -181,7 +209,7 @@ impl Modules {
} }
devices.extend(module.devices); devices.extend(module.devices);
for (cron, f) in module.schedule { for (cron, f) in module.schedule.0 {
scheduler.add_job(cron, f); scheduler.add_job(cron, f);
} }
} }