homie-controller 0.11.0

A library for creating controllers to talk to devices implementing the Homie convention for MQTT.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

//! Example to discover all Homie devices, and log whenever a property value changes.

use homie_controller::{Event, HomieController, PollError};
use rumqttc::MqttOptions;
use std::time::Duration;

#[tokio::main]
async fn main() -> Result<(), PollError> {
    pretty_env_logger::init();

    let mut mqttoptions = MqttOptions::new("homie_controller", "test.mosquitto.org", 1883);
    mqttoptions.set_keep_alive(Duration::from_secs(5));

    let (controller, mut event_loop) = HomieController::new(mqttoptions, "homie");
    loop {
        match controller.poll(&mut event_loop).await {
            Ok(events) => {
                for event in events {
                    if let Event::PropertyValueChanged {
                        device_id,
                        node_id,
                        property_id,
                        value,
                        fresh,
                    } = event
                    {
                        println!("{device_id}/{node_id}/{property_id} = {value} ({fresh})");
                    } else {
                        println!("Event: {event:?}");
                        println!("Devices:");
                        for device in controller.devices().values() {
                            if device.has_required_attributes() {
                                println!(" * {device:?}");
                            } else {
                                println!(" * {} not ready.", device.id);
                            }
                        }
                    }
                }
            }
            Err(e) => log::error!("Error: {e:?}"),
        }
    }
}