command-stream 0.10.0

Modern shell command execution library with streaming, async iteration, and event support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

//! Virtual `mkdir` command implementation

use crate::commands::CommandContext;
use crate::utils::{trace_lazy, CommandResult, VirtualUtils};
use std::fs;

/// Execute the mkdir command
///
/// Creates directories.
pub async fn mkdir(ctx: CommandContext) -> CommandResult {
    if ctx.args.is_empty() {
        return VirtualUtils::missing_operand_error("mkdir");
    }

    // Check for -p flag
    let mut create_parents = false;
    let mut dirs = Vec::new();

    for arg in &ctx.args {
        if arg == "-p" {
            create_parents = true;
        } else if arg.starts_with('-') {
            // Skip other flags
        } else {
            dirs.push(arg.clone());
        }
    }

    if dirs.is_empty() {
        return VirtualUtils::missing_operand_error("mkdir");
    }

    let cwd = ctx.get_cwd();

    for dir in dirs {
        let resolved_path = VirtualUtils::resolve_path(&dir, Some(&cwd));

        trace_lazy("VirtualCommand", || {
            format!(
                "mkdir: creating directory {:?}, parents: {}",
                resolved_path, create_parents
            )
        });

        let result = if create_parents {
            fs::create_dir_all(&resolved_path)
        } else {
            fs::create_dir(&resolved_path)
        };

        if let Err(e) = result {
            return CommandResult::error(format!(
                "mkdir: cannot create directory '{}': {}\n",
                dir, e
            ));
        }
    }

    CommandResult::success_empty()
}

#[cfg(test)]
mod tests {
    use super::*;
    use tempfile::tempdir;

    #[tokio::test]
    async fn test_mkdir_simple() {
        let temp = tempdir().unwrap();
        let new_dir = temp.path().join("new_directory");

        let ctx = CommandContext::new(vec![new_dir.to_string_lossy().to_string()]);
        let result = mkdir(ctx).await;

        assert!(result.is_success());
        assert!(new_dir.exists());
    }

    #[tokio::test]
    async fn test_mkdir_with_parents() {
        let temp = tempdir().unwrap();
        let nested_dir = temp.path().join("a/b/c/d");

        let ctx = CommandContext::new(vec![
            "-p".to_string(),
            nested_dir.to_string_lossy().to_string(),
        ]);
        let result = mkdir(ctx).await;

        assert!(result.is_success());
        assert!(nested_dir.exists());
    }

    #[tokio::test]
    async fn test_mkdir_missing_operand() {
        let ctx = CommandContext::new(vec![]);
        let result = mkdir(ctx).await;

        assert!(!result.is_success());
        assert!(result.stderr.contains("missing operand"));
    }
}