aiot 0.10.0

Rust Link SDK (Aliyun IoT) based on Alink Protocol.
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

use aiot::remote_config;
use aiot::{MqttClient, ThreeTuple};
use anyhow::Result;
use log::*;
use remote_config::recv::RemoteConfigRecv;

#[tokio::main]
async fn main() -> Result<()> {
    env_logger::init();
    let host = "iot-as-mqtt.cn-shanghai.aliyuncs.com";
    let three = ThreeTuple::from_env();

    let mut conn = MqttClient::new_public_tls(host, &three)?.connect();
    let mut remote_config = conn.remote_config()?;

    remote_config.get(true).await?;

    loop {
        tokio::select! {
            Ok(notification) = conn.poll() => {
                // 主循环的 poll 是必须的
                info!("Received = {:?}", notification);
            }
            Ok(recv) = remote_config.poll() => {
               match recv {
                 RemoteConfigRecv::RemoteConfigGetReply(response) => {
                    if let Some(config_info) = response.data{
                       let data = remote_config.download_config(&config_info).await?;
                       debug!("config: {}", String::from_utf8_lossy(&data));
                    }

                 },
                 RemoteConfigRecv::RemoteConfigPush(response)=>{
                    if let Some(config_info) = response.data{
                       let data = remote_config.download_config(&config_info).await?;
                       debug!("config: {}", String::from_utf8_lossy(&data));
                    }
                 },
              }
            }
        }
    }
}