wip for web devlop

Author: timzaak

agent/src/config.rs

@@ -2,6 +2,7 @@ use anyhow::bail;
 use etcetera::BaseStrategy;
 use serde::{Deserialize, Serialize};
 use std::path::PathBuf;
+use tracing::info;
 
 pub const APP_NAME: &str = "mproxy";
 
@@ -21,7 +22,7 @@ impl Config {
         if !config_path.is_file() {
             bail!("config file not found: {:?}", config_path);
         }
-
+        info!("load config from {:?}", config_path);
         let config = std::fs::read_to_string(config_path)?;
         let config: Config = serde_yml::from_str(&config)?;
         Ok(config)

agent/src/connection.rs

@@ -4,7 +4,7 @@ use anyhow::{bail, Context};
 use rumqttc::v5::{MqttOptions, AsyncClient, EventLoop, Event, Incoming, ClientError};
 use rumqttc::v5::mqttbytes::QoS;
 use tokio::sync::broadcast;
-use tracing::{debug, error, warn};
+use tracing::{debug, error, info, warn};
 
 use crate::config::Config;
 use crate::handler::{RequestMessage, ResponseMessage};
@@ -17,6 +17,7 @@ pub struct Connection {
 
 impl Connection {
     pub async fn connect(config:Arc<Config>) -> anyhow::Result<(Self, EventLoop)>{
+      info!("begin to connect mqtt server: {}", &config.server);
       let mqtt_url = format!("{}?client_id={}", &config.server, &config.client_id);
       let mut options = MqttOptions::parse_url(&mqtt_url).with_context(|| format!("parser mqtt url fail: {:?}", &mqtt_url))?;
 
@@ -31,6 +32,7 @@ impl Connection {
       let (client, eventloop) = AsyncClient::new(options, 20);
       let topic = config.get_command_topic();
       let _ = client.subscribe(topic, QoS::ExactlyOnce).await?;
+      info!("connect mqtt server successful");
       Ok((Connection {
           client,
       }, eventloop))