chore: add more tests

chore: add more tests

crates/cli/.gitignore

@@ -0,0 +1 @@
+Superfile.hcl

crates/cli/src/config.rs

@@ -24,3 +24,35 @@ pub fn verify_if_config_file_is_present() -> Result<(String, String), Error> {
     let config = std::fs::read_to_string(current_dir.join(SUPERFILE_TOML))?;
     return Ok((config, String::from("toml")));
 }
+
+#[cfg(test)]
+pub mod tests {
+    use super::*;
+
+    pub const CONFIG_EXAMPLE: &str = r#"
+    project = "demo"
+
+    service "demo" {
+      type = "exec"
+      command = "ping $GITHUB_DOMAIN"
+      working_dir = "/tmp"
+      description = "Ping Service Example"
+      depends_on = []
+      env = {
+        "GITHUB_DOMAIN" = "github.com"
+      }
+      stdout = "/tmp/demo-stdout.log"
+      stderr = "/tmp/demo-stderr.log"
+    }    
+    "#;
+
+    #[test]
+    fn test_verify_if_config_file_is_present() {
+        // create a default config file
+        let current_dir = std::env::current_dir().unwrap();
+        let config_file = current_dir.join(SUPERFILE);
+        std::fs::write(config_file, CONFIG_EXAMPLE).unwrap();
+        let result = verify_if_config_file_is_present();
+        assert!(result.is_ok());
+    }
+}

crates/core/src/core.rs

@@ -35,7 +35,6 @@ use superviseur_types::{
     command::SuperviseurCommand,
     configuration::{ConfigurationData, Service},
     events::{ProcessEvent, SuperviseurEvent},
-    log::Log,
     process::{Process, State},
 };
 

crates/log/Cargo.toml

@@ -14,3 +14,6 @@ version = "0.1.0"
 [dependencies]
 superviseur-types = {path = "../types", version = "0.1.0"}
 tantivy = "0.19.2"
+
+[dev-dependencies]
+chrono = "0.4.23"

crates/log/src/log.rs

@@ -136,3 +136,33 @@ impl LogEngine {
             .collect())
     }
 }
+
+#[cfg(test)]
+pub mod tests {
+    use std::time::Duration;
+
+    #[test]
+    fn test_log_engine() {
+        use crate::log::LogEngine;
+        use superviseur_types::log::Log;
+
+        let log_engine = LogEngine::new();
+        let log = Log {
+            project: "demo_project".to_string(),
+            service: "demo_service".to_string(),
+            line: "demo_line".to_string(),
+            date: tantivy::DateTime::from_timestamp_secs(
+                chrono::DateTime::parse_from_rfc3339("2021-01-01T00:00:00Z")
+                    .unwrap()
+                    .timestamp(),
+            ),
+            output: "demo_output".to_string(),
+        };
+        log_engine.insert(&log).unwrap();
+        std::thread::sleep(Duration::from_secs(1));
+        let logs = log_engine.search("demo_line").unwrap();
+        assert_eq!(logs.len(), 1);
+        let logs = log_engine.search_in_service("demo_line").unwrap();
+        assert_eq!(logs.len(), 1);
+    }
+}

crates/util/src/lib.rs

@@ -31,3 +31,21 @@ pub fn read_lines(path: &str) -> Result<Vec<String>, Error> {
     }
     Ok(lines)
 }
+
+#[cfg(test)]
+pub mod tests {
+    #[test]
+    fn convert_dir_path_to_absolute_path() {
+        let current_dir = std::env::current_dir().unwrap();
+        let current_dir = current_dir.to_str().unwrap();
+        let dir = "./test";
+        let dir = super::convert_dir_path_to_absolute_path(dir, current_dir).unwrap();
+        assert_eq!(dir, format!("{}/test", current_dir));
+    }
+
+    #[test]
+    fn read_lines() {
+        let lines = super::read_lines("Cargo.toml").unwrap();
+        assert_eq!(lines[0], "[package]");
+    }
+}