githubmirror/afterburn

src/cli/mod.rs
327 строк10 KB
Luca BRUNO
providers: setup network kernel arguments in initrd
12 май 2020, 18:13
12 май 2020, 18:13bd6e461
//! Command-line arguments parsing.

use crate::errors::*;
use clap::{crate_version, App, Arg, ArgMatches, SubCommand};
use error_chain::bail;
use slog_scope::trace;

mod exp;
mod multi;

/// Path to kernel command-line (requires procfs mount).
const CMDLINE_PATH: &str = "/proc/cmdline";

/// CLI sub-commands configuration.
#[derive(Debug)]
pub(crate) enum CliConfig {
    Multi(multi::CliMulti),
    Exp(exp::CliExp),
}

impl CliConfig {
    /// Parse CLI sub-commands into configuration.
    pub fn parse_subcommands(app_matches: ArgMatches) -> Result<Self> {
        let cfg = match app_matches.subcommand() {
            ("multi", Some(matches)) => multi::CliMulti::parse(matches)?,
            ("exp", Some(matches)) => exp::CliExp::parse(matches)?,
            (x, _) => unreachable!("unrecognized subcommand '{}'", x),
        };

        Ok(cfg)
    }

    /// Run the relevant CLI sub-command.
    pub fn run(self) -> Result<()> {
        match self {
            CliConfig::Multi(cmd) => cmd.run(),
            CliConfig::Exp(cmd) => cmd.run(),
        }
    }
}

/// Parse command-line arguments into CLI configuration.
pub(crate) fn parse_args(argv: impl IntoIterator<Item = String>) -> Result<CliConfig> {
    let args = translate_legacy_args(argv);
    let matches = cli_setup().get_matches_from_safe(args)?;

    let cfg = CliConfig::parse_subcommands(matches)?;
    trace!("cli configuration - {:?}", cfg);
    Ok(cfg)
}

/// Parse provider ID from flag or kargs.
fn parse_provider(matches: &clap::ArgMatches) -> Result<String> {
    let provider = match (matches.value_of("provider"), matches.is_present("cmdline")) {
        (Some(provider), false) => String::from(provider),
        (None, true) => crate::util::get_platform(CMDLINE_PATH)?,
        (None, false) => bail!("must set either --provider or --cmdline"),
        (Some(_), true) => bail!("cannot process both --provider and --cmdline"),
    };

    Ok(provider)
}

/// CLI setup, covering all sub-commands and arguments.
fn cli_setup<'a, 'b>() -> App<'a, 'b> {
    // NOTE(lucab): due to legacy translation there can't be global arguments
    //  here, i.e. a sub-command is always expected first.
    App::new("Afterburn")
        .version(crate_version!())
        .subcommand(
            SubCommand::with_name("multi")
                .about("Perform multiple tasks in a single call")
                .arg(
                    Arg::with_name("legacy-cli")
                        .long("legacy-cli")
                        .help("Whether this command was translated from legacy CLI args")
                        .hidden(true),
                )
                .arg(
                    Arg::with_name("provider")
                        .long("provider")
                        .help("The name of the cloud provider")
                        .global(true)
                        .takes_value(true),
                )
                .arg(
                    Arg::with_name("cmdline")
                        .long("cmdline")
                        .global(true)
                        .help("Read the cloud provider from the kernel cmdline"),
                )
                .arg(
                    Arg::with_name("attributes")
                        .long("attributes")
                        .help("The file into which the metadata attributes are written")
                        .takes_value(true),
                )
                .arg(
                    Arg::with_name("check-in")
                        .long("check-in")
                        .help("Check-in this instance boot with the cloud provider"),
                )
                .arg(
                    Arg::with_name("hostname")
                        .long("hostname")
                        .help("The file into which the hostname should be written")
                        .takes_value(true),
                )
                .arg(
                    Arg::with_name("network-units")
                        .long("network-units")
                        .help("The directory into which network units are written")
                        .takes_value(true),
                )
                .arg(
                    Arg::with_name("ssh-keys")
                        .long("ssh-keys")
                        .help("Update SSH keys for the given user")
                        .takes_value(true),
                ),
        )
        .subcommand(
            SubCommand::with_name("exp")
                .about("experimental subcommands")
                .subcommand(
                    SubCommand::with_name("rd-network-kargs")
                        .about("Supplement initrd with network configuration kargs")
                        .arg(
                            Arg::with_name("cmdline")
                                .long("cmdline")
                                .global(true)
                                .help("Read the cloud provider from the kernel cmdline"),
                        )
                        .arg(
                            Arg::with_name("provider")
                                .long("provider")
                                .help("The name of the cloud provider")
                                .global(true)
                                .takes_value(true),
                        )
                        .arg(
                            Arg::with_name("default-value")
                                .long("default-value")
                                .help("Default value for network kargs fallback")
                                .required(true)
                                .takes_value(true)
                                .empty_values(true),
                        ),
                ),
        )
}

/// Translate command-line arguments from legacy mode.
///
/// In legacy mode there are no sub-commands, and single-dash (Golang-style)
/// arguments are allowed too.
fn translate_legacy_args(cli: impl IntoIterator<Item = String>) -> impl Iterator<Item = String> {
    // Process the first two arguments and check whether there is a sub-command (normal mode)
    // or not (legacy mode).
    let mut argv = cli.into_iter();
    let argv_0 = argv.next().unwrap_or_else(|| "afterburn".to_string());
    let argv_1 = argv.next();
    let legacy_mode = match argv_1 {
        Some(ref arg) => arg.starts_with('-'),
        None => true,
    };

    // Inject back the first two arguments, plus the `multi` sub-command with a legacy marker.
    let mut new_argv = vec![argv_0];
    if let Some(arg) = argv_1 {
        new_argv.push(arg);
    }
    if legacy_mode {
        new_argv.insert(1, "multi".to_string());
        new_argv.insert(2, "--legacy-cli".to_string());
    }
    let argv = new_argv.into_iter().chain(argv);

    // Do some pre-processing on the command line arguments so that legacy
    // Go-style arguments are supported for backwards compatibility.
    argv.map(move |arg| {
        if legacy_mode && arg.starts_with('-') && !arg.starts_with("--") && arg.len() > 2 {
            format!("-{}", arg)
        } else {
            arg
        }
    })
}

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

    #[test]
    fn test_translate_legacy_args() {
        let legacy: Vec<_> = ["afterburn", "-ssh-keys"]
            .iter()
            .map(ToString::to_string)
            .collect();

        let translated: Vec<_> = translate_legacy_args(legacy).collect();
        assert_eq!(translated[0], "afterburn".to_string());
        assert_eq!(translated[1], "multi".to_string());
        assert_eq!(translated[2], "--legacy-cli".to_string());
        assert_eq!(translated[3], "--ssh-keys".to_string());
        assert_eq!(translated.len(), 4);
    }

    #[test]
    fn test_legacy_no_action() {
        let legacy: Vec<_> = ["afterburn", "--provider", "azure"]
            .iter()
            .map(ToString::to_string)
            .collect();

        let cmd = parse_args(legacy).unwrap();
        match cmd {
            CliConfig::Multi(_) => {}
            x => panic!("unexpected cmd: {:?}", x),
        };
    }

    #[test]
    fn test_no_args() {
        let args = vec!["afterburn".to_string()];
        parse_args(args).unwrap_err();
    }

    #[test]
    fn test_basic_cli_args() {
        let args: Vec<_> = ["afterburn", "--provider", "azure", "--check-in"]
            .iter()
            .map(ToString::to_string)
            .collect();

        let cmd = parse_args(args).unwrap();
        match cmd {
            CliConfig::Multi(_) => {}
            x => panic!("unexpected cmd: {:?}", x),
        };
    }

    #[test]
    fn test_multi_cmd() {
        let args: Vec<_> = ["afterburn", "multi", "--provider", "azure", "--check-in"]
            .iter()
            .map(ToString::to_string)
            .collect();

        let cmd = parse_args(args).unwrap();
        match cmd {
            CliConfig::Multi(_) => {}
            x => panic!("unexpected cmd: {:?}", x),
        };
    }

    #[test]
    fn test_exp_cmd() {
        let args: Vec<_> = [
            "afterburn",
            "exp",
            "rd-network-kargs",
            "--provider",
            "gcp",
            "--default-value",
            "ip=dhcp",
        ]
        .iter()
        .map(ToString::to_string)
        .collect();

        let cmd = parse_args(args).unwrap();
        let subcmd = match cmd {
            CliConfig::Exp(v) => v,
            x => panic!("unexpected cmd: {:?}", x),
        };

        match subcmd {
            exp::CliExp::RdNetworkKargs(_) => {}
            #[allow(unreachable_patterns)]
            x => panic!("unexpected 'exp' sub-command: {:?}", x),
        };
    }

    #[test]
    fn test_default_net_kargs() {
        // Missing flag.
        let t1: Vec<_> = ["afterburn", "exp", "rd-network-kargs", "--provider", "gcp"]
            .iter()
            .map(ToString::to_string)
            .collect();

        // Missing flag value.
        let t2: Vec<_> = [
            "afterburn",
            "exp",
            "rd-network-kargs",
            "--provider",
            "gcp",
            "--default-value",
        ]
        .iter()
        .map(ToString::to_string)
        .collect();

        for args in vec![t1, t2] {
            let input = format!("{:?}", args);
            parse_args(args).expect_err(&input);
        }

        // Empty flag value.
        let t3: Vec<_> = [
            "afterburn",
            "exp",
            "rd-network-kargs",
            "--provider",
            "gcp",
            "--default-value",
            "",
        ]
        .iter()
        .map(ToString::to_string)
        .collect();

        parse_args(t3).unwrap();
    }
}