souschef 0.2.3

CLI utility to interact with Chef Server.
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

use crate::chef::search::search_nodes;
use crate::config::KnifeConfig;
use std::error::Error;
use std::sync::Arc;
use tokio::sync::Mutex;

pub async fn ssh_nodes(
    config: &KnifeConfig,
    query: &str,
    command: &str,
    user: Option<String>,
) -> Result<(), Box<dyn Error>> {
    match search_nodes(config, query).await {
        Ok(nodes) => {
            // let nodes: Vec<String> = nodes.rrows.iter().map(|n| n.ipaddress.clone()).collect();
            let nodes: Vec<String> = nodes.iter().map(|n| n.ipaddress.clone()).collect();

            match call_ssh(nodes, command, user).await {
                Ok(()) => Ok(()),
                Err(e) => Err(format!("ssh: {}", e).into()),
            }
        }
        Err(e) => Err(format!("Problems during search. {}", e).into()),
    }
}

/// call_ssh - Creation of parallel tasks to be executed for SSH connections
pub async fn call_ssh(
    nodes: Vec<String>,
    command: &str,
    user: Option<String>,
) -> Result<(), Box<dyn Error + Send + Sync>> {
    let results = Arc::new(Mutex::new(Vec::new()));

    let mut handles = Vec::new();

    for node in nodes {
        let results = Arc::clone(&results);
        let node = node.clone();
        let command = command.to_string();
        let user = user.clone();

        // Spawn a new task for each of the nodes
        let handle = tokio::task::spawn(async move {
            let result = execute_ssh_command(node.clone(), command, user.clone()).await;
            results.lock().await.push((node.clone(), result));
        });

        handles.push(handle);
    }

    for h in handles {
        let _ = h.await;
    }

    Ok(())
}

/// execute_ssh_command - create a SSH session using `openssh` crate and execute the command.
pub async fn execute_ssh_command(
    host: String,
    command: String,
    user: Option<String>,
) -> Result<(), Box<dyn Error + Send + Sync>> {
    let connection_string = match user {
        Some(u) => format!("{}@{}", u, host),
        None => host.to_string(),
    };

    match openssh::Session::connect(connection_string, openssh::KnownHosts::Accept).await {
        Ok(session) => match session.raw_command(command).output().await {
            Ok(output) => {
                if output.status.success() {
                    if let Ok(stdout) = String::from_utf8(output.stdout) {
                        println!("{}: {}", host, stdout);
                    }
                } else {
                    let stderr = String::from_utf8_lossy(&output.stderr);
                    println!("{}:Failure {}", host, stderr);
                }
            }
            Err(e) => eprintln!("{}: Command execution error: {}", host, e),
        },
        Err(e) => eprintln!("Failed to connect to {}: {}", host, e),
    }
    Ok(())
}