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

#[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 log_post = conn.log_post()?;

    log_post.get_default().await?;
    loop {
        tokio::select! {
            Ok(event) = conn.poll() => {
                info!("{:?}", event);
            }
            Ok(log_config) = log_post.poll() => {
                info!("云端推送日志配置 {:?}", log_config);
            }
        }
    }
}