kasl-cli 1.0.2

#[cfg(test)]
mod tests {
    use kasl::libs::daemon;
    use kasl::libs::data_storage::DataStorage;
    use serial_test::serial;
    use std::fs;
    use std::process::Command;
    use std::thread;
    use std::time::Duration;
    use tempfile::TempDir;
    use test_context::{TestContext, test_context};

    struct DaemonTestContext {
        _temp_dir: TempDir,
        pid_file: String,
    }

    impl TestContext for DaemonTestContext {
        fn setup() -> Self {
            let temp_dir = tempfile::tempdir().unwrap();
            // SAFETY: tests touching the env are #[serial] or single-threaded setup
            unsafe {
                std::env::set_var("HOME", temp_dir.path());
            }
            // SAFETY: tests touching the env are #[serial] or single-threaded setup
            unsafe {
                std::env::set_var("LOCALAPPDATA", temp_dir.path());
            }
            DaemonTestContext {
                _temp_dir: temp_dir,
                pid_file: "kasl-watch.pid".to_string(),
            }
        }
    }

    #[test_context(DaemonTestContext)]
    #[serial]
    #[test]
    fn test_pid_file_path_resolution(ctx: &mut DaemonTestContext) {
        let data_storage = DataStorage::new();
        let pid_path = data_storage.get_path(&ctx.pid_file);

        assert!(pid_path.is_ok());
        let path = pid_path.unwrap();
        assert!(path.to_string_lossy().contains(&ctx.pid_file));
    }

    #[test_context(DaemonTestContext)]
    #[serial]
    #[test]
    fn test_stop_when_no_daemon_running(ctx: &mut DaemonTestContext) {
        // Ensure no PID file exists
        let data_storage = DataStorage::new();
        let pid_path = data_storage.get_path(&ctx.pid_file).unwrap();
        let _ = fs::remove_file(&pid_path);

        // Stop should succeed even when no daemon is running
        let result = daemon::stop();
        assert!(result.is_ok());
    }

    #[test_context(DaemonTestContext)]
    #[serial]
    #[test]
    fn test_stop_with_invalid_pid_file(ctx: &mut DaemonTestContext) {
        let data_storage = DataStorage::new();
        let pid_path = data_storage.get_path(&ctx.pid_file).unwrap();

        // Create parent directory
        if let Some(parent) = pid_path.parent() {
            fs::create_dir_all(parent).unwrap();
        }

        // Create invalid PID file
        fs::write(&pid_path, "not_a_number").unwrap();

        // Stop should handle invalid PID gracefully
        let result = daemon::stop();
        // The result depends on internal implementation,
        // but it shouldn't panic
        assert!(!pid_path.exists() || result.is_ok() || result.is_err());
    }

    #[test_context(DaemonTestContext)]
    #[serial]
    #[test]
    fn test_stop_with_nonexistent_process(ctx: &mut DaemonTestContext) {
        let data_storage = DataStorage::new();
        let pid_path = data_storage.get_path(&ctx.pid_file).unwrap();

        // Create parent directory
        if let Some(parent) = pid_path.parent() {
            fs::create_dir_all(parent).unwrap();
        }

        // Create PID file with nonexistent process ID
        fs::write(&pid_path, "99999").unwrap();

        // Stop should handle nonexistent process gracefully
        // Note: The actual daemon::stop() function might behave differently
        // depending on the internal implementation
        let result = daemon::stop();

        // The result might be Ok or Err depending on implementation
        // but it should not panic
        match result {
            Ok(_) => {
                // PID file may or may not be cleaned up depending on
                // the platform implementation; either outcome is fine here.
            }
            Err(_) => {
                // If error, that's also acceptable for nonexistent process
                // Clean up manually for test consistency
                let _ = fs::remove_file(&pid_path);
            }
        }
    }

    #[test_context(DaemonTestContext)]
    #[serial]
    #[test]
    fn test_spawn_cleanup_existing_daemon(ctx: &mut DaemonTestContext) {
        let data_storage = DataStorage::new();
        let pid_path = data_storage.get_path(&ctx.pid_file).unwrap();

        // Create parent directory
        if let Some(parent) = pid_path.parent() {
            fs::create_dir_all(parent).unwrap();
        }

        // Create fake existing PID file
        fs::write(&pid_path, "88888").unwrap();

        // Note: spawn() would normally start a real daemon process
        // For testing, we can't easily do this without complex setup
        // This test verifies the PID file cleanup logic
        assert!(pid_path.exists());
    }

    #[test_context(DaemonTestContext)]
    #[serial]
    #[test]
    fn test_pid_file_creation_and_cleanup(ctx: &mut DaemonTestContext) {
        let data_storage = DataStorage::new();
        let pid_path = data_storage.get_path(&ctx.pid_file).unwrap();

        // Create parent directory
        if let Some(parent) = pid_path.parent() {
            fs::create_dir_all(parent).unwrap();
        }

        // Simulate PID file creation
        let test_pid = "12345";
        fs::write(&pid_path, test_pid).unwrap();

        // Verify file was created
        assert!(pid_path.exists());
        let content = fs::read_to_string(&pid_path).unwrap();
        assert_eq!(content, test_pid);

        // Clean up
        fs::remove_file(&pid_path).unwrap();
        assert!(!pid_path.exists());
    }

    #[test_context(DaemonTestContext)]
    #[serial]
    #[test]
    fn test_current_executable_detection(_ctx: &mut DaemonTestContext) {
        // Test that we can detect current executable path
        let current_exe = std::env::current_exe();
        assert!(current_exe.is_ok());

        let exe_path = current_exe.unwrap();
        assert!(exe_path.exists());
        assert!(exe_path.is_file());
    }

    #[cfg(windows)]
    #[test_context(DaemonTestContext)]
    #[serial]
    #[test]
    fn test_windows_process_creation_flags(_ctx: &mut DaemonTestContext) {
        use std::os::windows::process::CommandExt;

        // Test Windows-specific process creation flags
        const CREATE_NO_WINDOW: u32 = 0x08000000;

        // Create a command with Windows flags
        let mut cmd = Command::new("cmd");
        cmd.args(["/C", "echo test"]);
        cmd.creation_flags(CREATE_NO_WINDOW);

        // This should not fail on Windows
        let result = cmd.output();
        assert!(result.is_ok());
    }

    #[cfg(unix)]
    #[test_context(DaemonTestContext)]
    #[serial]
    #[test]
    fn test_unix_process_session_creation(_ctx: &mut DaemonTestContext) {
        // Test Unix session creation capability
        // Note: This is a limited test as we can't actually call setsid in tests

        // Verify that the nix crate functions are available
        use nix::unistd::{getpid, getppid};

        let pid = getpid();
        let ppid = getppid();

        assert!(pid.as_raw() > 0);
        assert!(ppid.as_raw() >= 0);
    }

    #[test_context(DaemonTestContext)]
    #[serial]
    #[test]
    fn test_process_termination_by_pid(_ctx: &mut DaemonTestContext) {
        // Test process termination logic with a safe target

        // On Windows, test with a command that will exit quickly
        #[cfg(windows)]
        {
            let mut child = Command::new("cmd").args(["/C", "ping 127.0.0.1 -n 2"]).spawn().unwrap();

            let _pid = child.id();

            // Give process time to start
            thread::sleep(Duration::from_millis(100));

            // Test termination (implementation depends on platform)
            // Note: We can't easily test the actual kill_process function
            // without making it public or creating a test interface
            let _ = child.wait();
        }

        // On Unix, test with a sleep command
        #[cfg(unix)]
        {
            let mut child = Command::new("sleep").arg("10").spawn().unwrap();

            let pid = child.id();

            // Give process time to start
            thread::sleep(Duration::from_millis(100));

            // Test that we can query the process
            let output = Command::new("ps").arg("-p").arg(pid.to_string()).output().unwrap();

            // Process should exist initially
            assert!(output.status.success());

            // Kill the process manually for cleanup
            let _ = Command::new("kill").arg(pid.to_string()).output();
            let _ = child.wait();
        }
    }

    #[test_context(DaemonTestContext)]
    #[serial]
    #[test]
    fn test_daemon_directory_permissions(ctx: &mut DaemonTestContext) {
        let data_storage = DataStorage::new();
        let pid_path = data_storage.get_path(&ctx.pid_file).unwrap();

        // Verify we can create the daemon directory structure
        if let Some(parent) = pid_path.parent() {
            let result = fs::create_dir_all(parent);
            assert!(result.is_ok());
            assert!(parent.exists());
            assert!(parent.is_dir());
        }
    }

    #[test_context(DaemonTestContext)]
    #[serial]
    #[test]
    fn test_multiple_daemon_prevention(ctx: &mut DaemonTestContext) {
        let data_storage = DataStorage::new();
        let pid_path = data_storage.get_path(&ctx.pid_file).unwrap();

        // Create parent directory
        if let Some(parent) = pid_path.parent() {
            fs::create_dir_all(parent).unwrap();
        }

        // Simulate first daemon creating PID file
        fs::write(&pid_path, "11111").unwrap();
        assert!(pid_path.exists());

        // Second daemon attempt should detect existing PID file
        // Note: Full testing would require actual process spawning
        // This tests the file detection logic
        let existing_pid = fs::read_to_string(&pid_path).unwrap();
        assert_eq!(existing_pid.trim(), "11111");
    }
}