aiot 0.10.0

use aiot::bootstrap::recv::BootstrapRecv;
use aiot::tag;
use aiot::tag::base::DeviceInfoKeyValue;
use aiot::{MqttClient, ThreeTuple};
use anyhow::Result;
use log::*;
use tag::recv::TagRecv;

#[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 tag = conn.tag()?;
    let mut bootstrap = conn.bootstrap()?;
    tag.update(
        vec![
            DeviceInfoKeyValue {
                attr_key: String::from("key1"),
                attr_value: String::from("key1_v"),
            },
            DeviceInfoKeyValue {
                attr_key: String::from("key2"),
                attr_value: String::from("key2_v"),
            },
        ],
        true,
    )
    .await?;

    loop {
        tokio::select! {
            Ok(notification) = conn.poll() => {
                // 主循环的 poll 是必须的
                info!("Received = {:?}", notification);
            }
            Ok(recv) = tag.poll() => {
                match recv {
                    TagRecv::DeviceInfoUpdateResponse(_) => {
                    },
                    TagRecv::DeviceInfoDeleteResponse(_) => {
                    },
                }
            }
            Ok(recv) = bootstrap.poll() => {
                match recv {
                    BootstrapRecv::BootstrapNotify(_) => {
                    },
                }
            }
        }
    }
}