Lazy init started

client/bin/Cargo.toml

@@ -25,3 +25,4 @@ ping = "0.4.1"
 paho-mqtt = "0.12.3"
 # Ini File parser
 rust-ini = "0.21"
+lazy_static = "1.4"

client/bin/src/main.rs

@@ -29,6 +29,7 @@ use ini::Ini;
 // This declaration will look for a file named `straba.rs` and will
 // insert its contents inside a module named `straba` under this scope
 mod straba;
+use lazy_static::lazy_static;
 
 const IMAGE_SIZE_BYTE: usize = (IMAGE_WIDTH_BYTE * IMAGE_HEIGHT) as usize; /* one byte contains 8 LEDs, one in each bit */
 const IMAGE_WIDTH: u32 = 5 * 32;
@@ -297,11 +298,46 @@ type UserTopics = RwLock<Vec<String>>;
 
 /////////////////////////////////////////////////////////////////////////////
 
+// Define a struct to hold the INI configuration
+#[derive(Debug)]
+struct Config {
+    mqttPrefix: String,
+    mqttIPAddress: String,
+}
+
+
+// Function to read the INI file
+fn read_ini_file(filename: &str) -> Result<Config, std::io::Error> {
+    
+    let mut config = Config { mqttPrefix: "room/ledboard".to_string(),
+        mqttIPAddress: String::new() };
+    let i = Ini::load_from_file(filename).unwrap();
+    for (sec, prop) in i.iter() {
+        
+        for (k, v) in prop.iter()
+        {
+            println!("{:?} {}:{}", sec, k, v);
+            if (sec.is_some()) && (sec.unwrap() == "mqtt")
+            {
+                if k == "path"
+                {
+                    config.mqttPrefix = v.trim().to_string();
+                }
+                else if k == "server"
+                {
+                    config.mqttIPAddress = v.trim().to_string();
+                }
+            }
+        }
+    }
+    Ok(config)
+}
+
 // Callback for a successful connection to the broker.
 // We subscribe to the topic(s) we want here.
 fn mqtt_on_connect_success(cli: &paho_mqtt::AsyncClient, _msgid: u16) {
     println!("MQTT | Connection succeeded");
-    
+
     // Subscribe to the desired topic(s).
     cli.subscribe("room/ledboard", paho_mqtt::QOS_0);
 }
@@ -401,18 +437,19 @@ struct Message {
     string: Option<String>
 }
 
-fn main_function(ipaddress: String, mqtt: Option<String>, config: Option<String>) -> ExitCode {
+fn main_function(ipaddress: String, mqtt: Option<String>, inifile: Option<String>) -> ExitCode {
 
     // Read configuration file
-    if ( (config.is_some()) && (mqtt.is_some()) && (ipaddress == "--mode") )
+    if (inifile.is_some()) && (mqtt.is_some()) && (ipaddress == "--mode")
     {
-        let i = Ini::load_from_file(config.clone().unwrap()).unwrap();
+        // Lazy static to load the config file content
-        for (sec, prop) in i.iter() {
+        lazy_static! {
-            println!("Section: {:?}", sec);
+            static ref CONFIG: Config = {
-            for (k, v) in prop.iter() {
+                let filenameConfig: String = inifile.clone().unwrap();
-                println!("{}:{}", k, v);
+                read_ini_file(filenameConfig).expect("Failed to load config file")
-            }
+            };
         }
+       
         
         // FIXME stop here
         return ExitCode::SUCCESS;
@@ -473,7 +510,8 @@ fn main_function(ipaddress: String, mqtt: Option<String>, config: Option<String>
         });
 
         // Define the set of options for the connection
-        let lwt = paho_mqtt::Message::new("room/ledboard/lwt", "lost connection", 1);
+
+        let lwt = paho_mqtt::Message::new(&format!("{}/lwt", CONFIG.mqttPrefix), "lost connection", 1);
 
         // The connect options. Defaults to an MQTT v3.x connection.
         let conn_opts = paho_mqtt::ConnectOptionsBuilder::new()