matc 0.1.2

Matter protocol library (controller side)
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
45
46
47
48
49
50
51
52
53
54
55

use matc::{clusters, devman::{DeviceManager, ManagerConfig}};
use anyhow::Result;



#[tokio::main]
async fn main() -> Result<()> {
    env_logger::Builder::new()
        .parse_default_env()
        .target(env_logger::Target::Stdout)
        .filter_level(log::LevelFilter::Trace)
        .format_timestamp(Some(env_logger::TimestampPrecision::Millis))
        .init();

    const FABRIC_ID: u64 = 100;
    const CONTROLLER_ID: u64 = 200;
    const NODE_ID: u64 = 300;
    const NAME: &str = "My Device";
    const LOCAL_ADDRESS: &str = "0.0.0.0:5555";
    const DATA_DIR: &str = "./matter-data";

    let devman = {
        let devman = DeviceManager::load(DATA_DIR).await;
        if devman.is_ok() {
            devman
        } else {
            println!("No existing config found, performing first-time setup...");
            let config = ManagerConfig {
                fabric_id: FABRIC_ID,
                controller_id: CONTROLLER_ID,
                local_address: LOCAL_ADDRESS.to_string(),
            };
            DeviceManager::create(DATA_DIR, config).await
        }
    }?;

    let conn = devman.commission("192.168.1.21:5540", 123456, NODE_ID, NAME).await?;
    let res = conn.read_request2(0, clusters::defs::CLUSTER_ID_DESCRIPTOR,
                                    clusters::defs::CLUSTER_DESCRIPTOR_ATTR_ID_SERVERLIST).await?;
    let endpoints = matc::clusters::codec::descriptor_cluster::decode_parts_list(&res).unwrap();
    println!("Endpoints: {:?}", endpoints);

    // drop connection - just to demonstrate how we can connect to the same device after it is commissioned
    drop(conn);
    tokio::time::sleep(std::time::Duration::from_secs(1)).await; // wait for the connection to be fully cleaned up

    println!("Reconnecting to device by name...");   
    let conn = devman.connect_by_name(NAME).await?;
    let res = conn.read_request2(0, clusters::defs::CLUSTER_ID_DESCRIPTOR,
                                    clusters::defs::CLUSTER_DESCRIPTOR_ATTR_ID_SERVERLIST).await?;
    let endpoints = matc::clusters::codec::descriptor_cluster::decode_parts_list(&res).unwrap();
    println!("Endpoints : {:?}", endpoints);

    Ok(())
}