crates/api-grub/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "api-grub"
-version = "1.0.2"
+version = "1.0.1"
 edition = "2021"
 
 [dependencies]

crates/api-grub/src/logger.rs

@@ -33,7 +33,7 @@ pub async fn setup_logger() -> Result<()> {
                 record.args(),
             )
         })
-        .filter(None, LevelFilter::Info)
+        .filter(None, LevelFilter::Debug)
         .target(env_logger::Target::Stdout)
         .init();
 

crates/api-grub/src/monitoring.rs

@@ -40,26 +40,19 @@ use std::collections::HashMap;
 /// 
 pub async fn get_metrics_from_monitoring(duration: usize, delay: usize) -> anyhow::Result<()> {
     let timer = tokio::time::Instant::now();
-    let mut a = MonitoringImporter::new().await;
     'outer: loop {
-        // let mut a = MonitoringImporter::new().await;
+        let mut a = MonitoringImporter::new().await;
         a.start_session().await?;
-        info!("Started a new CM session");
-
         let vec = Arc::new(a.get_metrics_list().await.unwrap_or_else(|_| vec![]));
 
         'inner: loop {
             if duration != 0 && timer.elapsed() >= tokio::time::Duration::from_secs(duration as u64) {
                 break 'outer;
             }
-            if vec.len() == 0 || a.get_measure_info(vec.clone()).await.is_err() {
+            if let Err(_) = a.get_measure_info(vec.clone()).await {
                 warn!("Session dropped, creating new ...");
                 break 'inner;
             }
-            // if let Err(_) = a.get_measure_info(vec.clone()).await {
-            //     warn!("Session dropped, creating new ...");
-            //     break 'inner;
-            // }
             tokio::time::sleep(tokio::time::Duration::from_secs(delay as u64)).await
         }
     }
@@ -242,15 +235,14 @@ impl MonitoringImporter {
         for event in jh_vec {
             match event.await {
                 Ok(val) => {
-                    match crate::export::Exporter::export_extended_metrics(val?).await {
-                        Ok(bytes) => {info!("Successfully transmitted {} bytes to the Prometehus exporter", bytes)},
-                        Err(er) => error!("Cannot export data to the Prometehus exporter due to : `{}`", er),
+                    if let Ok(val) = val {
+                        match crate::export::Exporter::export_extended_metrics(val).await {
+                            Ok(bytes) => {info!("Successfully transmitted {} bytes to the Prometehus exporter", bytes)},
+                            Err(er) => error!("Cannot export data to the Prometehus exporter due to : `{}`", er),
+                        }
                     }
                 },
-                Err(er) => {
-                    println!("Fatal error on async task: {}", er);
-                    return Err(anyhow::Error::msg(format!("Fatal error on async task: {}", er)))
-                },
+                Err(er) => println!("Fatal error on async task: {}", er),
             }
         }
         Ok(())