fix: publish topic and prepare to deploy production environment

Author: timzaak

agent/.gitignore

@@ -1,2 +1,3 @@
 /target
-.idea
+.idea
+config.prod.yml

agent/examples/publish_command.rs

@@ -16,6 +16,9 @@ async fn main() -> anyhow::Result<()> {
     };
 
     let config_path:PathBuf = "./config.yml".parse().unwrap();
+    let publish_client_id = "test_web";
+    let password:Option<String> = None;
+    let username:Option<String> = None;
 
     let is_terminal = std::io::stdout().is_terminal();
 
@@ -24,8 +27,11 @@ async fn main() -> anyhow::Result<()> {
 
     let config = mproxy::config::Config::new(Some(config_path)).unwrap();
 
-    let mqtt_url = format!("{}?client_id={}", &config.server, "test_web");
-    let options = MqttOptions::parse_url(&mqtt_url).unwrap();
+    let mqtt_url = format!("{}?client_id={}", &config.server, publish_client_id);
+    let mut options = MqttOptions::parse_url(&mqtt_url).unwrap();
+    if matches!(password, Some(_)) && matches!(username, Some(_)) {
+        options.set_credentials(username.unwrap(), password.unwrap());
+    }
     let (client, mut eventloop) = AsyncClient::new(options,20);
 
     let topic = config.get_response_command_topic();

agent/src/config.rs

@@ -14,6 +14,7 @@ pub struct Config {
     pub client_id: String,
     pub username: Option<String>,
     pub password: Option<String>,
+
 }
 
 impl Config {
@@ -40,11 +41,11 @@ impl Config {
     }
 
     pub fn get_command_topic(&self) -> String {
-        self.command_topic.clone().unwrap_or_else(||format!("{}/cmd", self.client_id))
+        self.command_topic.clone().unwrap_or_else(||format!("cmd/{}", self.client_id))
 
     }
     pub fn get_response_command_topic(&self) ->  String {
-        self.command_topic.clone().unwrap_or_else(||format!("{}/cmd/resp",  self.client_id))
+        self.command_topic.clone().unwrap_or_else(||format!("cmd/{}/resp",  self.client_id))
     }
 }
 

shell/prod/rmqtt/rmqtt.toml

@@ -58,7 +58,7 @@ node.busy.handshaking = 0
 # Value: off | file | console | both
 log.to = "file"
 # Value: trace, debug, info, warn, error
-log.level = "debug"
+log.level = "info"
 log.dir = "/var/log/rmqtt"
 log.file = "rmqtt.log"