sqry-cli 14.0.3

//! History management for query tracking.
//!
//! The `HistoryManager` provides a high-level API for recording, retrieving,
//! and managing query history with optional secret redaction.

use std::sync::Arc;
use std::time::Duration;

use chrono::{DateTime, Utc};
use regex::Regex;

use crate::persistence::index::UserMetadataIndex;
use crate::persistence::types::{HistoryEntry, StorageScope};

/// Patterns for detecting secrets in command arguments.
///
/// These patterns are intentionally targeted to minimize false positives
/// while catching common secret formats. We avoid generic hex patterns
/// that would match git SHAs, checksums, and other benign values.
static SECRET_PATTERNS: std::sync::LazyLock<Vec<Regex>> = std::sync::LazyLock::new(|| {
    vec![
        // API keys and tokens (common formats with key-name anchors)
        Regex::new(r#"(?i)(api[_-]?key|api[_-]?token|access[_-]?token|auth[_-]?token|bearer)\s*[=:]\s*['"]?[a-zA-Z0-9_-]{16,}['"]?"#).unwrap(),
        // AWS access keys (AKIA prefix)
        Regex::new(r"(?i)AKIA[0-9A-Z]{16}").unwrap(),
        // AWS secret keys (often 40 chars base64-ish, with key anchor)
        Regex::new(r#"(?i)(aws[_-]?secret|secret[_-]?access[_-]?key)\s*[=:]\s*['"]?[a-zA-Z0-9/+=]{40}['"]?"#).unwrap(),
        // Generic secret patterns (password, secret, private_key with value)
        Regex::new(r#"(?i)(password|passwd|pwd|secret|private[_-]?key)\s*[=:]\s*['"]?[^\s'"]{8,}['"]?"#).unwrap(),
        // JWT tokens (three base64url segments)
        Regex::new(r"eyJ[a-zA-Z0-9_-]*\.eyJ[a-zA-Z0-9_-]*\.[a-zA-Z0-9_-]*").unwrap(),
        // GitHub tokens (personal, oauth, app tokens)
        Regex::new(r"gh[pousr]_[A-Za-z0-9_]{36,}").unwrap(),
        // GitHub fine-grained tokens
        Regex::new(r"github_pat_[A-Za-z0-9_]{22,}").unwrap(),
        // Slack tokens
        Regex::new(r"xox[baprs]-[0-9]+-[0-9]+-[a-zA-Z0-9]+").unwrap(),
        // Discord tokens
        Regex::new(r"[MN][A-Za-z\d]{23,}\.[\w-]{6}\.[\w-]{27}").unwrap(),
        // OpenAI API keys
        Regex::new(r"sk-[a-zA-Z0-9]{20,}").unwrap(),
        // Anthropic API keys
        Regex::new(r"sk-ant-[a-zA-Z0-9]{20,}").unwrap(),
        // Google Cloud service account keys (long base64 in JSON context)
        Regex::new(r#""private_key"\s*:\s*"-----BEGIN"#).unwrap(),
        // npm tokens
        Regex::new(r"npm_[a-zA-Z0-9]{36}").unwrap(),
        // Stripe API keys
        Regex::new(r"sk_live_[a-zA-Z0-9]{24,}").unwrap(),
        Regex::new(r"sk_test_[a-zA-Z0-9]{24,}").unwrap(),
        // SendGrid API keys
        Regex::new(r"SG\.[a-zA-Z0-9_-]{22}\.[a-zA-Z0-9_-]{43}").unwrap(),
        // Twilio tokens
        Regex::new(r"SK[a-f0-9]{32}").unwrap(),
    ]
});

/// Placeholder for redacted secrets.
pub const REDACTED_PLACEHOLDER: &str = "[REDACTED]";

/// Error type for history operations.
#[derive(Debug)]
pub enum HistoryError {
    /// History recording is disabled.
    Disabled,
    /// Entry not found.
    NotFound { id: u64 },
    /// Storage operation failed.
    Storage(anyhow::Error),
}

impl std::fmt::Display for HistoryError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            Self::Disabled => write!(f, "history recording is disabled"),
            Self::NotFound { id } => write!(f, "history entry {id} not found"),
            Self::Storage(e) => write!(f, "storage error: {e}"),
        }
    }
}

impl std::error::Error for HistoryError {
    fn source(&self) -> Option<&(dyn std::error::Error + 'static)> {
        match self {
            Self::Storage(e) => e.source(),
            _ => None,
        }
    }
}

impl From<anyhow::Error> for HistoryError {
    fn from(e: anyhow::Error) -> Self {
        Self::Storage(e)
    }
}

/// Manager for query history.
///
/// Provides operations for recording and querying command history.
/// History is stored in global storage only (not per-project).
#[derive(Debug, Clone)]
pub struct HistoryManager {
    index: Arc<UserMetadataIndex>,
}

impl HistoryManager {
    /// Create a new history manager.
    #[must_use]
    pub fn new(index: Arc<UserMetadataIndex>) -> Self {
        Self { index }
    }

    /// Record a command execution in history.
    ///
    /// # Arguments
    ///
    /// * `command` - The command that was executed
    /// * `args` - Command arguments
    /// * `working_dir` - Working directory when command was run
    /// * `success` - Whether the command succeeded
    /// * `duration` - How long the command took
    ///
    /// # Errors
    ///
    /// Returns an error if history is disabled or storage fails.
    pub fn record(
        &self,
        command: &str,
        args: &[String],
        working_dir: &std::path::Path,
        success: bool,
        duration: Option<Duration>,
    ) -> Result<u64, HistoryError> {
        let config = self.index.config();

        // Check if history is enabled
        if !config.history_enabled {
            return Err(HistoryError::Disabled);
        }

        // Optionally redact secrets
        let processed_args = if config.redact_secrets {
            redact_secrets(args)
        } else {
            args.to_vec()
        };

        let mut entry_id = 0u64;

        self.index.update(StorageScope::Global, |metadata| {
            // Assign next ID
            entry_id = metadata.history.next_id;
            metadata.history.next_id += 1;

            // Create the entry
            let entry = HistoryEntry {
                id: entry_id,
                timestamp: Utc::now(),
                command: command.to_string(),
                args: processed_args.clone(),
                working_dir: working_dir.to_path_buf(),
                success,
                duration_ms: duration.map(|d| u64::try_from(d.as_millis()).unwrap_or(u64::MAX)),
            };

            // Add to history
            metadata.history.entries.push(entry);

            // Enforce max entries limit
            let max_entries = config.max_history_entries;
            if metadata.history.entries.len() > max_entries {
                let excess = metadata.history.entries.len() - max_entries;
                metadata.history.entries.drain(0..excess);
            }

            Ok(())
        })?;

        Ok(entry_id)
    }

    /// Get a history entry by ID.
    ///
    /// # Errors
    ///
    /// Returns an error if the entry is not found or storage fails.
    pub fn get(&self, id: u64) -> Result<HistoryEntry, HistoryError> {
        let metadata = self.index.load(StorageScope::Global)?;
        metadata
            .history
            .entries
            .iter()
            .find(|e| e.id == id)
            .cloned()
            .ok_or(HistoryError::NotFound { id })
    }

    /// Get the most recent history entry.
    ///
    /// # Errors
    ///
    /// Returns an error if history is empty or storage fails.
    pub fn last(&self) -> Result<Option<HistoryEntry>, HistoryError> {
        let metadata = self.index.load(StorageScope::Global)?;
        Ok(metadata.history.entries.last().cloned())
    }

    /// List recent history entries.
    ///
    /// Returns entries in reverse chronological order (most recent first).
    ///
    /// # Arguments
    ///
    /// * `limit` - Maximum number of entries to return
    ///
    /// # Errors
    ///
    /// Returns an error if storage fails.
    pub fn list(&self, limit: usize) -> Result<Vec<HistoryEntry>, HistoryError> {
        let metadata = self.index.load(StorageScope::Global)?;
        let entries: Vec<_> = metadata
            .history
            .entries
            .iter()
            .rev()
            .take(limit)
            .cloned()
            .collect();
        Ok(entries)
    }

    /// Search history entries by pattern.
    ///
    /// Searches in command name and arguments.
    ///
    /// # Arguments
    ///
    /// * `pattern` - Search pattern (substring match)
    /// * `limit` - Maximum results to return
    ///
    /// # Errors
    ///
    /// Returns an error if storage fails.
    pub fn search(&self, pattern: &str, limit: usize) -> Result<Vec<HistoryEntry>, HistoryError> {
        let metadata = self.index.load(StorageScope::Global)?;
        let pattern_lower = pattern.to_lowercase();

        let entries: Vec<_> = metadata
            .history
            .entries
            .iter()
            .rev()
            .filter(|e| {
                e.command.to_lowercase().contains(&pattern_lower)
                    || e.args
                        .iter()
                        .any(|a| a.to_lowercase().contains(&pattern_lower))
            })
            .take(limit)
            .cloned()
            .collect();

        Ok(entries)
    }

    /// Clear all history entries.
    ///
    /// # Errors
    ///
    /// Returns an error if storage fails.
    pub fn clear(&self) -> Result<usize, HistoryError> {
        let mut count = 0;
        self.index.update(StorageScope::Global, |metadata| {
            count = metadata.history.entries.len();
            metadata.history.entries.clear();
            // Keep next_id to avoid ID reuse
            Ok(())
        })?;
        Ok(count)
    }

    /// Clear history entries older than a specified duration.
    ///
    /// # Arguments
    ///
    /// * `older_than` - Clear entries older than this duration
    ///
    /// # Errors
    ///
    /// Returns an error if storage fails.
    pub fn clear_older_than_duration(&self, older_than: Duration) -> Result<usize, HistoryError> {
        let cutoff = Utc::now() - chrono::Duration::from_std(older_than).unwrap_or_default();
        self.clear_older_than(cutoff)
    }

    /// Clear history entries older than a specified cutoff time.
    ///
    /// # Arguments
    ///
    /// * `cutoff` - Clear entries with timestamps before this time
    ///
    /// # Errors
    ///
    /// Returns an error if storage fails.
    pub fn clear_older_than(&self, cutoff: DateTime<Utc>) -> Result<usize, HistoryError> {
        let mut count = 0;

        self.index.update(StorageScope::Global, |metadata| {
            let before_len = metadata.history.entries.len();
            metadata.history.entries.retain(|e| e.timestamp >= cutoff);
            count = before_len - metadata.history.entries.len();
            Ok(())
        })?;

        Ok(count)
    }

    /// Get the total count of history entries.
    ///
    /// # Errors
    ///
    /// Returns an error if storage fails.
    pub fn count(&self) -> Result<usize, HistoryError> {
        let metadata = self.index.load(StorageScope::Global)?;
        Ok(metadata.history.entries.len())
    }

    /// Get history entries for a specific working directory.
    ///
    /// # Errors
    ///
    /// Returns an error if storage fails.
    pub fn for_directory(
        &self,
        dir: &std::path::Path,
        limit: usize,
    ) -> Result<Vec<HistoryEntry>, HistoryError> {
        let metadata = self.index.load(StorageScope::Global)?;
        let entries: Vec<_> = metadata
            .history
            .entries
            .iter()
            .rev()
            .filter(|e| e.working_dir == dir)
            .take(limit)
            .cloned()
            .collect();
        Ok(entries)
    }

    /// Get the entry at a specific offset from the most recent.
    ///
    /// Offset 1 is the most recent entry, 2 is the second most recent, etc.
    ///
    /// # Errors
    ///
    /// Returns an error if the offset is out of range or storage fails.
    pub fn at_offset(&self, offset: usize) -> Result<HistoryEntry, HistoryError> {
        if offset == 0 {
            return Err(HistoryError::NotFound { id: 0 });
        }

        let metadata = self.index.load(StorageScope::Global)?;
        let entries = &metadata.history.entries;

        if offset > entries.len() {
            return Err(HistoryError::NotFound { id: offset as u64 });
        }

        Ok(entries[entries.len() - offset].clone())
    }

    /// Check if history recording is enabled.
    #[must_use]
    pub fn is_enabled(&self) -> bool {
        self.index.config().history_enabled
    }

    /// Get statistics about history.
    ///
    /// # Errors
    ///
    /// Returns an error if storage fails.
    pub fn stats(&self) -> Result<HistoryStats, HistoryError> {
        let metadata = self.index.load(StorageScope::Global)?;
        let entries = &metadata.history.entries;

        let total_entries = entries.len();
        let successful = entries.iter().filter(|e| e.success).count();
        let failed = total_entries - successful;

        let oldest = entries.first().map(|e| e.timestamp);
        let newest = entries.last().map(|e| e.timestamp);

        // Count commands
        let mut command_counts = std::collections::HashMap::new();
        for entry in entries {
            *command_counts.entry(entry.command.clone()).or_insert(0) += 1;
        }

        Ok(HistoryStats {
            total_entries,
            success_count: successful,
            failure_count: failed,
            oldest_entry: oldest,
            newest_entry: newest,
            command_counts,
        })
    }
}

/// Statistics about the command history.
#[derive(Debug, Clone)]
pub struct HistoryStats {
    /// Total number of entries.
    pub total_entries: usize,
    /// Number of successful commands.
    pub success_count: usize,
    /// Number of failed commands.
    pub failure_count: usize,
    /// Timestamp of oldest entry.
    pub oldest_entry: Option<DateTime<Utc>>,
    /// Timestamp of newest entry.
    pub newest_entry: Option<DateTime<Utc>>,
    /// Count of each command type.
    pub command_counts: std::collections::HashMap<String, usize>,
}

/// Redact potential secrets from command arguments.
///
/// Uses pattern matching to identify and replace secret-like values
/// with a placeholder.
#[must_use]
pub fn redact_secrets(args: &[String]) -> Vec<String> {
    args.iter()
        .map(|arg| {
            let mut result = arg.clone();
            for pattern in SECRET_PATTERNS.iter() {
                if pattern.is_match(&result) {
                    result = pattern
                        .replace_all(&result, REDACTED_PLACEHOLDER)
                        .to_string();
                }
            }
            result
        })
        .collect()
}

/// Check if a string contains potential secrets.
#[must_use]
pub fn contains_secrets(text: &str) -> bool {
    SECRET_PATTERNS.iter().any(|p| p.is_match(text))
}

/// Parse a duration string like "30d", "1w", "24h".
///
/// Supported units:
/// - `s` - seconds
/// - `m` - minutes
/// - `h` - hours
/// - `d` - days
/// - `w` - weeks
///
/// # Errors
///
/// Returns an error if the format is invalid.
pub fn parse_duration(s: &str) -> Result<Duration, String> {
    let s = s.trim();
    if s.is_empty() {
        return Err("empty duration string".to_string());
    }

    let (num_str, unit) = s.split_at(s.len() - 1);
    let num: u64 = num_str
        .parse()
        .map_err(|_| format!("invalid number in duration: {num_str}"))?;

    let seconds = match unit.to_lowercase().as_str() {
        "s" => num,
        "m" => num * 60,
        "h" => num * 60 * 60,
        "d" => num * 60 * 60 * 24,
        "w" => num * 60 * 60 * 24 * 7,
        _ => return Err(format!("unknown duration unit: {unit}")),
    };

    Ok(Duration::from_secs(seconds))
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::persistence::config::PersistenceConfig;
    use tempfile::TempDir;

    fn setup() -> (TempDir, Arc<UserMetadataIndex>) {
        let dir = TempDir::new().unwrap();
        let config = PersistenceConfig {
            global_dir_override: Some(dir.path().join("global")),
            history_enabled: true,
            max_history_entries: 100,
            ..Default::default()
        };
        let index = Arc::new(UserMetadataIndex::open(Some(dir.path()), config).unwrap());
        (dir, index)
    }

    #[test]
    fn test_record_and_get() {
        let (_dir, index) = setup();
        let manager = HistoryManager::new(index);

        let id = manager
            .record(
                "search",
                &["main".to_string()],
                std::path::Path::new("/project"),
                true,
                Some(Duration::from_millis(100)),
            )
            .unwrap();

        let entry = manager.get(id).unwrap();
        assert_eq!(entry.command, "search");
        assert_eq!(entry.args, vec!["main"]);
        assert!(entry.success);
        assert_eq!(entry.duration_ms, Some(100));
    }

    #[test]
    fn test_list_recent() {
        let (_dir, index) = setup();
        let manager = HistoryManager::new(index);

        for i in 0..5 {
            manager
                .record(
                    "query",
                    &[format!("arg{i}")],
                    std::path::Path::new("/project"),
                    true,
                    None,
                )
                .unwrap();
        }

        let recent = manager.list(3).unwrap();
        assert_eq!(recent.len(), 3);
        // Most recent first
        assert_eq!(recent[0].args, vec!["arg4"]);
        assert_eq!(recent[1].args, vec!["arg3"]);
        assert_eq!(recent[2].args, vec!["arg2"]);
    }

    #[test]
    fn test_search_history() {
        let (_dir, index) = setup();
        let manager = HistoryManager::new(index);

        manager
            .record(
                "search",
                &["function".to_string()],
                std::path::Path::new("/p"),
                true,
                None,
            )
            .unwrap();
        manager
            .record(
                "query",
                &["class".to_string()],
                std::path::Path::new("/p"),
                true,
                None,
            )
            .unwrap();
        manager
            .record(
                "search",
                &["method".to_string()],
                std::path::Path::new("/p"),
                true,
                None,
            )
            .unwrap();

        let results = manager.search("search", 10).unwrap();
        assert_eq!(results.len(), 2);

        let results = manager.search("class", 10).unwrap();
        assert_eq!(results.len(), 1);
    }

    #[test]
    fn test_clear_history() {
        let (_dir, index) = setup();
        let manager = HistoryManager::new(index);

        for _ in 0..3 {
            manager
                .record("cmd", &[], std::path::Path::new("/p"), true, None)
                .unwrap();
        }

        assert_eq!(manager.count().unwrap(), 3);

        let cleared = manager.clear().unwrap();
        assert_eq!(cleared, 3);
        assert_eq!(manager.count().unwrap(), 0);
    }

    #[test]
    fn test_at_offset() {
        let (_dir, index) = setup();
        let manager = HistoryManager::new(index);

        for i in 0..3 {
            manager
                .record(
                    "cmd",
                    &[format!("{i}")],
                    std::path::Path::new("/p"),
                    true,
                    None,
                )
                .unwrap();
        }

        let entry = manager.at_offset(1).unwrap();
        assert_eq!(entry.args, vec!["2"]); // Most recent

        let entry = manager.at_offset(3).unwrap();
        assert_eq!(entry.args, vec!["0"]); // Oldest
    }

    #[test]
    fn test_history_disabled() {
        let dir = TempDir::new().unwrap();
        let config = PersistenceConfig {
            global_dir_override: Some(dir.path().join("global")),
            history_enabled: false,
            ..Default::default()
        };
        let index = Arc::new(UserMetadataIndex::open(Some(dir.path()), config).unwrap());
        let manager = HistoryManager::new(index);

        let result = manager.record("cmd", &[], std::path::Path::new("/p"), true, None);
        assert!(matches!(result, Err(HistoryError::Disabled)));
    }

    #[test]
    fn test_max_entries_limit() {
        let dir = TempDir::new().unwrap();
        let config = PersistenceConfig {
            global_dir_override: Some(dir.path().join("global")),
            history_enabled: true,
            max_history_entries: 5,
            ..Default::default()
        };
        let index = Arc::new(UserMetadataIndex::open(Some(dir.path()), config).unwrap());
        let manager = HistoryManager::new(index);

        for i in 0..10 {
            manager
                .record(
                    "cmd",
                    &[format!("{i}")],
                    std::path::Path::new("/p"),
                    true,
                    None,
                )
                .unwrap();
        }

        assert_eq!(manager.count().unwrap(), 5);

        // Should have entries 5-9, not 0-4
        let entries = manager.list(10).unwrap();
        assert_eq!(entries[0].args, vec!["9"]);
        assert_eq!(entries[4].args, vec!["5"]);
    }

    #[test]
    fn test_redact_secrets() {
        let args = vec![
            "normal_arg".to_string(),
            ["api_key=", "sk_live_", "abc123def456ghi789"].concat(),
            "password=mysecret123".to_string(),
            "--flag".to_string(),
        ];

        let redacted = redact_secrets(&args);
        assert_eq!(redacted[0], "normal_arg");
        assert!(redacted[1].contains(REDACTED_PLACEHOLDER));
        assert!(redacted[2].contains(REDACTED_PLACEHOLDER));
        assert_eq!(redacted[3], "--flag");
    }

    #[test]
    fn test_contains_secrets() {
        // Should detect secrets
        assert!(contains_secrets("api_key=abc123def456ghi789jkl"));
        // Avoid embedding full token literals in source: slopscan scans `src/**` and treats
        // token-like strings as critical findings. Construct test tokens via concatenation.
        let aws_key = ["AKIA", "IOSFODNN7EXAMPLE"].concat();
        assert!(contains_secrets(&aws_key));
        assert!(contains_secrets("password=mysecret123"));
        let github_token = ["ghp_", "1234567890abcdefghijABCDEFGHIJKLMNOP"].concat();
        assert!(contains_secrets(&github_token));
        // OpenAI API key format: sk-<20+ alphanumeric>
        let openai_key = ["sk-", "abc123def456ghi789jklmno"].concat();
        assert!(contains_secrets(&openai_key));

        // Should NOT detect git SHAs, checksums, or common values
        assert!(!contains_secrets("normal text here"));
        assert!(!contains_secrets("--kind function"));
        // Git SHA (40 hex chars) - should NOT be redacted
        assert!(!contains_secrets(
            "e58f019f1234567890abcdef1234567890abcdef"
        ));
        // Short git SHA - should NOT be redacted
        assert!(!contains_secrets("e58f019"));
        // MD5 checksum (32 hex chars) - should NOT be redacted
        assert!(!contains_secrets("d41d8cd98f00b204e9800998ecf8427e"));
        // SHA256 checksum (64 hex chars) - should NOT be redacted
        assert!(!contains_secrets(
            "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855"
        ));
    }

    #[test]
    fn test_parse_duration() {
        assert_eq!(parse_duration("30s").unwrap(), Duration::from_secs(30));
        assert_eq!(parse_duration("5m").unwrap(), Duration::from_secs(300));
        assert_eq!(parse_duration("2h").unwrap(), Duration::from_secs(7200));
        assert_eq!(parse_duration("1d").unwrap(), Duration::from_secs(86400));
        assert_eq!(parse_duration("1w").unwrap(), Duration::from_secs(604_800));

        assert!(parse_duration("").is_err());
        assert!(parse_duration("abc").is_err());
        assert!(parse_duration("10x").is_err());
    }

    #[test]
    fn test_stats() {
        let (_dir, index) = setup();
        let manager = HistoryManager::new(index);

        manager
            .record("search", &[], std::path::Path::new("/p"), true, None)
            .unwrap();
        manager
            .record("query", &[], std::path::Path::new("/p"), false, None)
            .unwrap();
        manager
            .record("search", &[], std::path::Path::new("/p"), true, None)
            .unwrap();

        let stats = manager.stats().unwrap();
        assert_eq!(stats.total_entries, 3);
        assert_eq!(stats.success_count, 2);
        assert_eq!(stats.failure_count, 1);
        assert_eq!(stats.command_counts.len(), 2);
    }

    #[test]
    fn test_redact_secrets_with_config() {
        let dir = TempDir::new().unwrap();
        let config = PersistenceConfig {
            global_dir_override: Some(dir.path().join("global")),
            history_enabled: true,
            redact_secrets: true,
            ..Default::default()
        };
        let index = Arc::new(UserMetadataIndex::open(Some(dir.path()), config).unwrap());
        let manager = HistoryManager::new(index);

        let id = manager
            .record(
                "search",
                &["api_key=sk_live_abc123def456ghi789".to_string()],
                std::path::Path::new("/p"),
                true,
                None,
            )
            .unwrap();

        let entry = manager.get(id).unwrap();
        assert!(entry.args[0].contains(REDACTED_PLACEHOLDER));
    }

    #[test]
    fn test_error_display() {
        let err = HistoryError::Disabled;
        assert_eq!(err.to_string(), "history recording is disabled");

        let err = HistoryError::NotFound { id: 42 };
        assert_eq!(err.to_string(), "history entry 42 not found");
    }

    #[test]
    fn test_for_directory() {
        let (_dir, index) = setup();
        let manager = HistoryManager::new(index);

        manager
            .record(
                "cmd",
                &["a".to_string()],
                std::path::Path::new("/project1"),
                true,
                None,
            )
            .unwrap();
        manager
            .record(
                "cmd",
                &["b".to_string()],
                std::path::Path::new("/project2"),
                true,
                None,
            )
            .unwrap();
        manager
            .record(
                "cmd",
                &["c".to_string()],
                std::path::Path::new("/project1"),
                true,
                None,
            )
            .unwrap();

        let entries = manager
            .for_directory(std::path::Path::new("/project1"), 10)
            .unwrap();
        assert_eq!(entries.len(), 2);
        assert_eq!(entries[0].args, vec!["c"]);
        assert_eq!(entries[1].args, vec!["a"]);
    }
}