Defining Your Home

// 🦆 says ⮞ i dont alwayz qwack i can listenz
async fn start_listening(&mut self) -> Result<(), Box> {
    let (mut client, mut connection) = Client::new(mqttoptions, 10);
    client.subscribe("zigbee2mqtt/#", QoS::AtMostOnce)?;
    
    loop {
        match connection.eventloop.poll().await {
            Ok(event) => {
                if let Event::Incoming(Incoming::Publish(publish)) = event {
                    let topic = publish.topic;
                    let payload = String::from_utf8_lossy(&publish.payload);
                    self.process_message(&topic, &payload).await?;
                }
            }
            Err(e) => {
                // 🦆 says ⮞ auto reconnect ..
                tokio::time::sleep(Duration::from_secs(5)).await;
                // 🦆 says ⮞ recreate connection & resubscribe
            }
        }
    }
}

async fn start_listening(&mut self) -> Result<(), Box> {
    let (mut client, mut connection) = Client::new(mqttoptions, 10);
    client.subscribe("zigbee2mqtt/#", QoS::AtMostOnce)?;
    
    loop {
        match connection.eventloop.poll().await {
            Ok(event) => {
                if let Event::Incoming(Incoming::Publish(publish)) = event {
                    let topic = publish.topic;
                    let payload = String::from_utf8_lossy(&publish.payload);
                    self.process_message(&topic, &payload).await?;
                }
            }
            Err(e) => {
                // Auto reconnect ...
                tokio::time::sleep(Duration::from_secs(5)).await;
                // Recreate connection & resubscribe
            }
        }
    }
}

// 🦆 says ⮞ letzz do diz! 
async fn process_message(&mut self, topic: &str, payload: &str) -> Result<(), Box> {
    let data: Value = serde_json::from_str(payload)?;
    let device_name = topic.strip_prefix("zigbee2mqtt/").unwrap_or(topic);
    
    // 🦆 says ⮞ update device statez from all dem fields
    self.update_device_state_from_data(device_name, &data)?;
    
    if let Some(device) = self.devices.get(device_name) {
        let room = &device.room;
        // 🦆 says ⮞ handle all dem sensor typez triggerz!
        match device.device_type.as_str() {
            "motion" => {     //🦆says⮞MOTION SENSORS }
            "contact" => {    //🦆says⮞DOOR/WINDOW SENSORS }
            "water_leak" => { //🦆says⮞WATER LEAK SENSORS }
            // 🦆says⮞ MORE? qwack qwack
        }
    }
}

async fn process_message(&mut self, topic: &str, payload: &str) -> Result<(), Box> {
    let data: Value = serde_json::from_str(payload)?;
    let device_name = topic.strip_prefix("zigbee2mqtt/").unwrap_or(topic);
    
    self.update_device_state_from_data(device_name, &data)?;
    
    if let Some(device) = self.devices.get(device_name) {
        let room = &device.room;
        match device.device_type.as_str() {
            "motion" => { ... }
            "contact" => { ... }
            "water_leak" => { ... }
            // ...
        }
    }
}

// 🦆 says ⮞ letz go yo!
fn handle_room_dimmer_action(
    &self, 
    action: &str, 
    device_name: &str, 
    room: &str,
    default_action: F
) -> Result<(), Box> 
{
    // 🦆 says ⮞any room configurationz?
    if let Some(room_actions) = self.automations.dimmer_actions.get(room) {
        let dimmer_action = match action {
            "on_press_release" => &room_actions.on_press_release,
            "on_hold_release" => &room_actions.on_hold_release,
            // ... 🦆 says ⮞ da rest actionz
        };
        
        // 🦆 says ⮞execute override actionz or default + extra actionz
        if !config.override_actions.is_empty() {
            for override_action in &config.override_actions {
                self.execute_automation_action(override_action, device_name, room)?;
            }
        } else {
            default_action(room)?;  // 🦆says⮞run da defaultz
            for extra_action in &config.extra_actions {
                self.execute_automation_action(extra_action, device_name, room)?;
            }
        }
    }
}

fn handle_room_dimmer_action(
    &self, 
    action: &str, 
    device_name: &str, 
    room: &str,
    default_action: F
) -> Result<(), Box> 
{
    if let Some(room_actions) = self.automations.dimmer_actions.get(room) {
        let dimmer_action = match action {
            "on_press_release" => &room_actions.on_press_release,
            "on_hold_release" => &room_actions.on_hold_release,
            // ...
        };
        
        if !config.override_actions.is_empty() {
            for override_action in &config.override_actions {
                self.execute_automation_action(override_action, device_name, room)?;
            }
        } else {
            default_action(room)?;
            for extra_action in &config.extra_actions {
                self.execute_automation_action(extra_action, device_name, room)?;
            }
        }
    }
}

async fn check_conditions(&self, conditions: &[Condition]) -> bool {
    for condition in conditions {
        if !self.check_condition(condition).await {
            return false;
        }
    }
    true
}

async fn check_condition(&self, condition: &Condition) -> bool {
    match condition.condition_type.as_str() {
        "dark_time" => self.is_dark_time(),
        "someone_home" => self.is_someone_home(),
        "room_occupied" => {
            if let Some(room) = &condition.room {
                self.is_motion_triggered(room) || self.has_recent_motion_in_room(room)
            } else { false }
        }
        _ => false,
    }
}

async fn check_conditions(&self, conditions: &[Condition]) -> bool {
    for condition in conditions {
        if !self.check_condition(condition).await {
            return false;
        }
    }
    true
}

async fn check_condition(&self, condition: &Condition) -> bool {
    match condition.condition_type.as_str() {
        "dark_time" => self.is_dark_time(),
        "someone_home" => self.is_someone_home(),
        "room_occupied" => {
            if let Some(room) = &condition.room {
                self.is_motion_triggered(room) || self.has_recent_motion_in_room(room)
            } else { false }
        }
        _ => false,
    }
}