Dreaded_X
ba818c6b60
Moves the application config out of automation_lib and sets up the config return type for further expansion.
52 lines
1.3 KiB
Rust
52 lines
1.3 KiB
Rust
use std::time::Duration;
|
|
|
|
use lua_typed::Typed;
|
|
use rumqttc::{MqttOptions, Transport};
|
|
use serde::Deserialize;
|
|
|
|
#[derive(Debug, Clone, Deserialize, Typed)]
|
|
pub struct MqttConfig {
|
|
pub host: String,
|
|
pub port: u16,
|
|
pub client_name: String,
|
|
pub username: String,
|
|
pub password: String,
|
|
#[serde(default)]
|
|
pub tls: bool,
|
|
}
|
|
|
|
impl From<MqttConfig> for MqttOptions {
|
|
fn from(value: MqttConfig) -> Self {
|
|
let mut mqtt_options = MqttOptions::new(value.client_name, value.host, value.port);
|
|
mqtt_options.set_credentials(value.username, value.password);
|
|
mqtt_options.set_keep_alive(Duration::from_secs(5));
|
|
|
|
if value.tls {
|
|
mqtt_options.set_transport(Transport::tls_with_default_config());
|
|
}
|
|
|
|
mqtt_options
|
|
}
|
|
}
|
|
|
|
#[derive(Debug, Clone, Deserialize, Typed)]
|
|
pub struct InfoConfig {
|
|
pub name: String,
|
|
pub room: Option<String>,
|
|
}
|
|
|
|
impl InfoConfig {
|
|
pub fn identifier(&self) -> String {
|
|
(if let Some(room) = &self.room {
|
|
room.to_ascii_lowercase().replace(' ', "_") + "_"
|
|
} else {
|
|
String::new()
|
|
}) + &self.name.to_ascii_lowercase().replace(' ', "_")
|
|
}
|
|
}
|
|
|
|
#[derive(Debug, Clone, Deserialize, Typed)]
|
|
pub struct MqttDeviceConfig {
|
|
pub topic: String,
|
|
}
|