|
|
|
|
@ -24,248 +24,802 @@
|
|
|
|
|
*
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
use super::cfgerr::{ConfigError, ERR_CONFLICT};
|
|
|
|
|
use super::{
|
|
|
|
|
BGSave, ConfigurationSet, IpAddr, PortConfig, SnapshotConfig, SnapshotPref, SslOpts,
|
|
|
|
|
DEFAULT_IPV4, DEFAULT_PORT, MAXIMUM_CONNECTION_LIMIT,
|
|
|
|
|
};
|
|
|
|
|
use clap::{load_yaml, App};
|
|
|
|
|
use super::{BGSave, Configset, PortConfig, SnapshotConfig, SnapshotPref, SslOpts, DEFAULT_IPV4};
|
|
|
|
|
|
|
|
|
|
pub(super) use libsky::TResult;
|
|
|
|
|
use std::fs;
|
|
|
|
|
use std::net::Ipv6Addr;
|
|
|
|
|
|
|
|
|
|
// server tests
|
|
|
|
|
// TCP
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_toml_okayport() {
|
|
|
|
|
let file = r#"
|
|
|
|
|
[server]
|
|
|
|
|
host = "127.0.0.1"
|
|
|
|
|
port = 2003
|
|
|
|
|
"#
|
|
|
|
|
.to_owned();
|
|
|
|
|
let cfg = ConfigurationSet::new_from_toml_str(file).unwrap();
|
|
|
|
|
assert_eq!(cfg, ConfigurationSet::default(),);
|
|
|
|
|
}
|
|
|
|
|
/// Gets a `toml` file from `WORKSPACEROOT/examples/config-files`
|
|
|
|
|
fn get_toml_from_examples_dir(filename: String) -> TResult<String> {
|
|
|
|
|
use std::path;
|
|
|
|
|
let curdir = std::env::current_dir().unwrap();
|
|
|
|
|
let workspaceroot = curdir.ancestors().nth(1).unwrap();
|
|
|
|
|
let mut fileloc = path::PathBuf::from(workspaceroot);
|
|
|
|
|
fileloc.push("examples");
|
|
|
|
|
fileloc.push("config-files");
|
|
|
|
|
fileloc.push(filename);
|
|
|
|
|
Ok(fs::read_to_string(fileloc)?)
|
|
|
|
|
fn server_tcp() {
|
|
|
|
|
let mut cfgset = Configset::new_env();
|
|
|
|
|
cfgset.server_tcp(
|
|
|
|
|
Some("127.0.0.1"),
|
|
|
|
|
"SKY_SERVER_HOST",
|
|
|
|
|
Some("2004"),
|
|
|
|
|
"SKY_SERVER_PORT",
|
|
|
|
|
);
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfgset.cfg.ports,
|
|
|
|
|
PortConfig::new_insecure_only(DEFAULT_IPV4, 2004)
|
|
|
|
|
);
|
|
|
|
|
assert!(cfgset.is_mutated());
|
|
|
|
|
assert!(cfgset.is_okay());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_toml_badport() {
|
|
|
|
|
let file = r#"
|
|
|
|
|
[server]
|
|
|
|
|
port = 20033002
|
|
|
|
|
"#
|
|
|
|
|
.to_owned();
|
|
|
|
|
let cfg = ConfigurationSet::new_from_toml_str(file);
|
|
|
|
|
assert!(cfg.is_err());
|
|
|
|
|
fn server_tcp_fail_host() {
|
|
|
|
|
let mut cfgset = Configset::new_env();
|
|
|
|
|
cfgset.server_tcp(
|
|
|
|
|
Some("?127.0.0.1"),
|
|
|
|
|
"SKY_SERVER_HOST",
|
|
|
|
|
Some("2004"),
|
|
|
|
|
"SKY_SERVER_PORT",
|
|
|
|
|
);
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfgset.cfg.ports,
|
|
|
|
|
PortConfig::new_insecure_only(DEFAULT_IPV4, 2004)
|
|
|
|
|
);
|
|
|
|
|
assert!(cfgset.is_mutated());
|
|
|
|
|
assert!(!cfgset.is_okay());
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfgset.estack[0],
|
|
|
|
|
"Bad value for `SKY_SERVER_HOST`. Expected an IPv4/IPv6 address"
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_ok() {
|
|
|
|
|
let file = get_toml_from_examples_dir("skyd.toml".to_owned()).unwrap();
|
|
|
|
|
let cfg = ConfigurationSet::new_from_toml_str(file).unwrap();
|
|
|
|
|
assert_eq!(cfg, ConfigurationSet::default());
|
|
|
|
|
fn server_tcp_fail_port() {
|
|
|
|
|
let mut cfgset = Configset::new_env();
|
|
|
|
|
cfgset.server_tcp(
|
|
|
|
|
Some("127.0.0.1"),
|
|
|
|
|
"SKY_SERVER_HOST",
|
|
|
|
|
Some("65537"),
|
|
|
|
|
"SKY_SERVER_PORT",
|
|
|
|
|
);
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfgset.cfg.ports,
|
|
|
|
|
PortConfig::new_insecure_only(DEFAULT_IPV4, 2003)
|
|
|
|
|
);
|
|
|
|
|
assert!(cfgset.is_mutated());
|
|
|
|
|
assert!(!cfgset.is_okay());
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfgset.estack[0],
|
|
|
|
|
"Bad value for `SKY_SERVER_PORT`. Expected a 16-bit positive integer"
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_err() {
|
|
|
|
|
let file = get_toml_from_examples_dir("skyd.toml".to_owned()).unwrap();
|
|
|
|
|
let cfg = ConfigurationSet::new_from_file(file);
|
|
|
|
|
assert!(cfg.is_err());
|
|
|
|
|
fn server_tcp_fail_both() {
|
|
|
|
|
let mut cfgset = Configset::new_env();
|
|
|
|
|
cfgset.server_tcp(
|
|
|
|
|
Some("?127.0.0.1"),
|
|
|
|
|
"SKY_SERVER_HOST",
|
|
|
|
|
Some("65537"),
|
|
|
|
|
"SKY_SERVER_PORT",
|
|
|
|
|
);
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfgset.cfg.ports,
|
|
|
|
|
PortConfig::new_insecure_only(DEFAULT_IPV4, 2003)
|
|
|
|
|
);
|
|
|
|
|
assert!(cfgset.is_mutated());
|
|
|
|
|
assert!(!cfgset.is_okay());
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfgset.estack[0],
|
|
|
|
|
"Bad value for `SKY_SERVER_HOST`. Expected an IPv4/IPv6 address"
|
|
|
|
|
);
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfgset.estack[1],
|
|
|
|
|
"Bad value for `SKY_SERVER_PORT`. Expected a 16-bit positive integer"
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// noart
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_args() {
|
|
|
|
|
let cmdlineargs = vec!["skyd", "--withconfig", "../examples/config-files/skyd.toml"];
|
|
|
|
|
let cfg_layout = load_yaml!("../cli.yml");
|
|
|
|
|
let matches = App::from_yaml(cfg_layout).get_matches_from(cmdlineargs);
|
|
|
|
|
let filename = matches.value_of("config").unwrap();
|
|
|
|
|
assert_eq!("../examples/config-files/skyd.toml", filename);
|
|
|
|
|
let cfg =
|
|
|
|
|
ConfigurationSet::new_from_toml_str(std::fs::read_to_string(filename).unwrap()).unwrap();
|
|
|
|
|
assert_eq!(cfg, ConfigurationSet::default());
|
|
|
|
|
fn server_noart_okay() {
|
|
|
|
|
let mut cfgset = Configset::new_env();
|
|
|
|
|
cfgset.server_noart(Some("true"), "SKY_SYSTEM_NOART");
|
|
|
|
|
assert!(!cfgset.cfg.is_artful());
|
|
|
|
|
assert!(cfgset.is_okay());
|
|
|
|
|
assert!(cfgset.is_mutated());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_noart() {
|
|
|
|
|
let file = get_toml_from_examples_dir("secure-noart.toml".to_owned()).unwrap();
|
|
|
|
|
let cfg = ConfigurationSet::new_from_toml_str(file).unwrap();
|
|
|
|
|
fn server_noart_fail() {
|
|
|
|
|
let mut cfgset = Configset::new_env();
|
|
|
|
|
cfgset.server_noart(Some("truee"), "SKY_SYSTEM_NOART");
|
|
|
|
|
assert!(cfgset.cfg.is_artful());
|
|
|
|
|
assert!(!cfgset.is_okay());
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfg,
|
|
|
|
|
ConfigurationSet {
|
|
|
|
|
noart: true,
|
|
|
|
|
bgsave: BGSave::default(),
|
|
|
|
|
snapshot: SnapshotConfig::default(),
|
|
|
|
|
ports: PortConfig::default(),
|
|
|
|
|
maxcon: MAXIMUM_CONNECTION_LIMIT
|
|
|
|
|
}
|
|
|
|
|
cfgset.estack[0],
|
|
|
|
|
"Bad value for `SKY_SYSTEM_NOART`. Expected true/false"
|
|
|
|
|
);
|
|
|
|
|
assert!(cfgset.is_mutated());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_ipv6() {
|
|
|
|
|
let file = get_toml_from_examples_dir("ipv6.toml".to_owned()).unwrap();
|
|
|
|
|
let cfg = ConfigurationSet::new_from_toml_str(file).unwrap();
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfg,
|
|
|
|
|
ConfigurationSet {
|
|
|
|
|
noart: false,
|
|
|
|
|
bgsave: BGSave::default(),
|
|
|
|
|
snapshot: SnapshotConfig::default(),
|
|
|
|
|
ports: PortConfig::new_insecure_only(
|
|
|
|
|
IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 0, 0, 0, 0x1)),
|
|
|
|
|
DEFAULT_PORT
|
|
|
|
|
),
|
|
|
|
|
maxcon: MAXIMUM_CONNECTION_LIMIT
|
|
|
|
|
}
|
|
|
|
|
);
|
|
|
|
|
fn server_maxcon_okay() {
|
|
|
|
|
let mut cfgset = Configset::new_env();
|
|
|
|
|
cfgset.server_maxcon(Some("12345"), "SKY_SYSTEM_MAXCON");
|
|
|
|
|
assert!(cfgset.is_mutated());
|
|
|
|
|
assert!(cfgset.is_okay());
|
|
|
|
|
assert_eq!(cfgset.cfg.maxcon, 12345);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_template() {
|
|
|
|
|
let file = get_toml_from_examples_dir("template.toml".to_owned()).unwrap();
|
|
|
|
|
let cfg = ConfigurationSet::new_from_toml_str(file).unwrap();
|
|
|
|
|
fn server_maxcon_fail() {
|
|
|
|
|
let mut cfgset = Configset::new_env();
|
|
|
|
|
cfgset.server_maxcon(Some("12345A"), "SKY_SYSTEM_MAXCON");
|
|
|
|
|
assert!(cfgset.is_mutated());
|
|
|
|
|
assert!(!cfgset.is_okay());
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfg,
|
|
|
|
|
ConfigurationSet::new(
|
|
|
|
|
false,
|
|
|
|
|
BGSave::default(),
|
|
|
|
|
SnapshotConfig::Enabled(SnapshotPref::new(3600, 4, true)),
|
|
|
|
|
PortConfig::new_secure_only(
|
|
|
|
|
DEFAULT_IPV4,
|
|
|
|
|
SslOpts::new(
|
|
|
|
|
"/path/to/keyfile.pem".into(),
|
|
|
|
|
"/path/to/chain.pem".into(),
|
|
|
|
|
2004,
|
|
|
|
|
Some("/path/to/cert/passphrase.txt".to_owned())
|
|
|
|
|
)
|
|
|
|
|
),
|
|
|
|
|
MAXIMUM_CONNECTION_LIMIT
|
|
|
|
|
)
|
|
|
|
|
cfgset.estack[0],
|
|
|
|
|
"Bad value for `SKY_SYSTEM_MAXCON`. Expected a positive integer greater than zero"
|
|
|
|
|
);
|
|
|
|
|
assert_eq!(cfgset.cfg.maxcon, 50000);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// bgsave settings
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_bad_bgsave_section() {
|
|
|
|
|
let file = get_toml_from_examples_dir("badcfg2.toml".to_owned()).unwrap();
|
|
|
|
|
let cfg = ConfigurationSet::new_from_toml_str(file);
|
|
|
|
|
assert!(cfg.is_err());
|
|
|
|
|
fn bgsave_okay() {
|
|
|
|
|
let mut cfgset = Configset::new_env();
|
|
|
|
|
cfgset.bgsave_settings(
|
|
|
|
|
Some("true"),
|
|
|
|
|
"SKY_BGSAVE_ENABLED",
|
|
|
|
|
Some("128"),
|
|
|
|
|
"SKY_BGSAVE_DURATION",
|
|
|
|
|
);
|
|
|
|
|
assert!(cfgset.is_mutated());
|
|
|
|
|
assert!(cfgset.is_okay());
|
|
|
|
|
assert_eq!(cfgset.cfg.bgsave, BGSave::Enabled(128));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_custom_bgsave() {
|
|
|
|
|
let file = get_toml_from_examples_dir("withcustombgsave.toml".to_owned()).unwrap();
|
|
|
|
|
let cfg = ConfigurationSet::new_from_toml_str(file).unwrap();
|
|
|
|
|
fn bgsave_fail() {
|
|
|
|
|
let mut cfgset = Configset::new_env();
|
|
|
|
|
cfgset.bgsave_settings(
|
|
|
|
|
Some("truee"),
|
|
|
|
|
"SKY_BGSAVE_ENABLED",
|
|
|
|
|
Some("128"),
|
|
|
|
|
"SKY_BGSAVE_DURATION",
|
|
|
|
|
);
|
|
|
|
|
assert!(cfgset.is_mutated());
|
|
|
|
|
assert!(!cfgset.is_okay());
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfg,
|
|
|
|
|
ConfigurationSet {
|
|
|
|
|
noart: false,
|
|
|
|
|
bgsave: BGSave::new(true, 600),
|
|
|
|
|
snapshot: SnapshotConfig::default(),
|
|
|
|
|
ports: PortConfig::default(),
|
|
|
|
|
maxcon: MAXIMUM_CONNECTION_LIMIT
|
|
|
|
|
}
|
|
|
|
|
cfgset.estack[0],
|
|
|
|
|
"Bad value for `SKY_BGSAVE_ENABLED`. Expected true/false"
|
|
|
|
|
);
|
|
|
|
|
assert_eq!(cfgset.cfg.bgsave, BGSave::Enabled(128));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// snapshot settings
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_bgsave_enabled_only() {
|
|
|
|
|
/*
|
|
|
|
|
* This test demonstrates a case where the user just said that BGSAVE is enabled.
|
|
|
|
|
* In that case, we will default to the 120 second duration
|
|
|
|
|
*/
|
|
|
|
|
let file = get_toml_from_examples_dir("bgsave-justenabled.toml".to_owned()).unwrap();
|
|
|
|
|
let cfg = ConfigurationSet::new_from_toml_str(file).unwrap();
|
|
|
|
|
fn snapshot_okay() {
|
|
|
|
|
let mut cfgset = Configset::new_env();
|
|
|
|
|
cfgset.snapshot_settings(
|
|
|
|
|
Some("3600"),
|
|
|
|
|
"SKY_SNAPSHOT_EVERY",
|
|
|
|
|
Some("0"),
|
|
|
|
|
"SKY_SNAPSHOT_ATMOST",
|
|
|
|
|
Some("false"),
|
|
|
|
|
"SKY_SNAPSHOT_FAILSAFE",
|
|
|
|
|
);
|
|
|
|
|
assert!(cfgset.is_mutated());
|
|
|
|
|
assert!(cfgset.is_okay());
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfg,
|
|
|
|
|
ConfigurationSet {
|
|
|
|
|
noart: false,
|
|
|
|
|
bgsave: BGSave::default(),
|
|
|
|
|
snapshot: SnapshotConfig::default(),
|
|
|
|
|
ports: PortConfig::default(),
|
|
|
|
|
maxcon: MAXIMUM_CONNECTION_LIMIT
|
|
|
|
|
}
|
|
|
|
|
)
|
|
|
|
|
cfgset.cfg.snapshot,
|
|
|
|
|
SnapshotConfig::Enabled(SnapshotPref::new(3600, 0, false))
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_bgsave_every_only() {
|
|
|
|
|
/*
|
|
|
|
|
* This test demonstrates a case where the user just gave the value for every
|
|
|
|
|
* In that case, it means BGSAVE is enabled and set to `every` seconds
|
|
|
|
|
*/
|
|
|
|
|
let file = get_toml_from_examples_dir("bgsave-justevery.toml".to_owned()).unwrap();
|
|
|
|
|
let cfg = ConfigurationSet::new_from_toml_str(file).unwrap();
|
|
|
|
|
fn snapshot_fail() {
|
|
|
|
|
let mut cfgset = Configset::new_env();
|
|
|
|
|
cfgset.snapshot_settings(
|
|
|
|
|
Some("3600"),
|
|
|
|
|
"SKY_SNAPSHOT_EVERY",
|
|
|
|
|
Some("0"),
|
|
|
|
|
"SKY_SNAPSHOT_ATMOST",
|
|
|
|
|
Some("falsee"),
|
|
|
|
|
"SKY_SNAPSHOT_FAILSAFE",
|
|
|
|
|
);
|
|
|
|
|
assert!(cfgset.is_mutated());
|
|
|
|
|
assert!(!cfgset.is_okay());
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfg,
|
|
|
|
|
ConfigurationSet {
|
|
|
|
|
noart: false,
|
|
|
|
|
bgsave: BGSave::new(true, 600),
|
|
|
|
|
snapshot: SnapshotConfig::default(),
|
|
|
|
|
ports: PortConfig::default(),
|
|
|
|
|
maxcon: MAXIMUM_CONNECTION_LIMIT
|
|
|
|
|
}
|
|
|
|
|
)
|
|
|
|
|
cfgset.estack[0],
|
|
|
|
|
"Bad value for `SKY_SNAPSHOT_FAILSAFE`. Expected true/false"
|
|
|
|
|
);
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfgset.cfg.snapshot,
|
|
|
|
|
SnapshotConfig::Enabled(SnapshotPref::new(3600, 0, true))
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_snapshot() {
|
|
|
|
|
let file = get_toml_from_examples_dir("snapshot.toml".to_owned()).unwrap();
|
|
|
|
|
let cfg = ConfigurationSet::new_from_toml_str(file).unwrap();
|
|
|
|
|
fn snapshot_fail_with_missing_required_values() {
|
|
|
|
|
let mut cfgset = Configset::new_env();
|
|
|
|
|
cfgset.snapshot_settings(
|
|
|
|
|
Some("3600"),
|
|
|
|
|
"SKY_SNAPSHOT_EVERY",
|
|
|
|
|
None,
|
|
|
|
|
"SKY_SNAPSHOT_ATMOST",
|
|
|
|
|
None,
|
|
|
|
|
"SKY_SNAPSHOT_FAILSAFE",
|
|
|
|
|
);
|
|
|
|
|
assert!(cfgset.is_mutated());
|
|
|
|
|
assert!(!cfgset.is_okay());
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfg,
|
|
|
|
|
ConfigurationSet {
|
|
|
|
|
snapshot: SnapshotConfig::Enabled(SnapshotPref::new(3600, 4, true)),
|
|
|
|
|
bgsave: BGSave::default(),
|
|
|
|
|
noart: false,
|
|
|
|
|
ports: PortConfig::default(),
|
|
|
|
|
maxcon: MAXIMUM_CONNECTION_LIMIT
|
|
|
|
|
}
|
|
|
|
|
cfgset.estack[0],
|
|
|
|
|
"To use snapshots, pass values for both `SKY_SNAPSHOT_EVERY` and `SKY_SNAPSHOT_ATMOST`"
|
|
|
|
|
);
|
|
|
|
|
assert_eq!(cfgset.cfg.snapshot, SnapshotConfig::Disabled);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// TLS settings
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_cli_args_conflict() {
|
|
|
|
|
let cfg_layout = load_yaml!("../cli.yml");
|
|
|
|
|
let cli_args = ["skyd", "--nosave", "-c config.toml"];
|
|
|
|
|
let matches = App::from_yaml(cfg_layout).get_matches_from(&cli_args);
|
|
|
|
|
let err = super::get_config_file_or_return_cfg_from_matches(matches).unwrap_err();
|
|
|
|
|
assert_eq!(err, ConfigError::CfgError(ERR_CONFLICT));
|
|
|
|
|
fn tls_settings_okay() {
|
|
|
|
|
let mut cfg = Configset::new_env();
|
|
|
|
|
cfg.tls_settings(
|
|
|
|
|
Some("key.pem"),
|
|
|
|
|
"SKY_TLS_KEY",
|
|
|
|
|
Some("cert.pem"),
|
|
|
|
|
"SKY_TLS_CERT",
|
|
|
|
|
Some("2005"),
|
|
|
|
|
"SKY_TLS_PORT",
|
|
|
|
|
Some("false"),
|
|
|
|
|
"SKY_TLS_ONLY",
|
|
|
|
|
None,
|
|
|
|
|
"SKY_TLS_PASSIN",
|
|
|
|
|
);
|
|
|
|
|
assert!(cfg.is_mutated());
|
|
|
|
|
assert!(cfg.is_okay());
|
|
|
|
|
assert_eq!(cfg.cfg.ports, {
|
|
|
|
|
let mut pf = PortConfig::default();
|
|
|
|
|
pf.upgrade_to_tls(SslOpts::new(
|
|
|
|
|
"key.pem".to_owned(),
|
|
|
|
|
"cert.pem".to_owned(),
|
|
|
|
|
2005,
|
|
|
|
|
None,
|
|
|
|
|
));
|
|
|
|
|
pf
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_cli_args_conflict_with_restore_file_okay() {
|
|
|
|
|
let cfg_layout = load_yaml!("../cli.yml");
|
|
|
|
|
let cli_args = ["skyd", "--restore", "somedir", "-c", "config.toml"];
|
|
|
|
|
let matches = App::from_yaml(cfg_layout).get_matches_from(&cli_args);
|
|
|
|
|
let ret = super::get_config_file_or_return_cfg_from_matches(matches).unwrap_err();
|
|
|
|
|
// this should only compain about the missing dir but not about conflict
|
|
|
|
|
assert_eq!(
|
|
|
|
|
ret,
|
|
|
|
|
ConfigError::OSError(std::io::Error::from(std::io::ErrorKind::NotFound))
|
|
|
|
|
fn tls_settings_fail() {
|
|
|
|
|
let mut cfg = Configset::new_env();
|
|
|
|
|
cfg.tls_settings(
|
|
|
|
|
Some("key.pem"),
|
|
|
|
|
"SKY_TLS_KEY",
|
|
|
|
|
Some("cert.pem"),
|
|
|
|
|
"SKY_TLS_CERT",
|
|
|
|
|
Some("A2005"),
|
|
|
|
|
"SKY_TLS_PORT",
|
|
|
|
|
Some("false"),
|
|
|
|
|
"SKY_TLS_ONLY",
|
|
|
|
|
None,
|
|
|
|
|
"SKY_TLS_PASSIN",
|
|
|
|
|
);
|
|
|
|
|
assert!(cfg.is_mutated());
|
|
|
|
|
assert!(!cfg.is_okay());
|
|
|
|
|
assert_eq!(cfg.cfg.ports, {
|
|
|
|
|
let mut pf = PortConfig::default();
|
|
|
|
|
pf.upgrade_to_tls(SslOpts::new(
|
|
|
|
|
"key.pem".to_owned(),
|
|
|
|
|
"cert.pem".to_owned(),
|
|
|
|
|
2004,
|
|
|
|
|
None,
|
|
|
|
|
));
|
|
|
|
|
pf
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_cli_args_conflict_with_restore_file_fail() {
|
|
|
|
|
let cfg_layout = load_yaml!("../cli.yml");
|
|
|
|
|
let cli_args = [
|
|
|
|
|
"skyd",
|
|
|
|
|
"--restore",
|
|
|
|
|
"somedir",
|
|
|
|
|
"-c",
|
|
|
|
|
"config.toml",
|
|
|
|
|
"--nosave",
|
|
|
|
|
];
|
|
|
|
|
let matches = App::from_yaml(cfg_layout).get_matches_from(&cli_args);
|
|
|
|
|
let ret = super::get_config_file_or_return_cfg_from_matches(matches).unwrap_err();
|
|
|
|
|
// this should only compain about the missing dir but not about conflict
|
|
|
|
|
assert_eq!(ret, ConfigError::CfgError(ERR_CONFLICT));
|
|
|
|
|
fn tls_settings_fail_with_missing_required_values() {
|
|
|
|
|
let mut cfg = Configset::new_env();
|
|
|
|
|
cfg.tls_settings(
|
|
|
|
|
Some("key.pem"),
|
|
|
|
|
"SKY_TLS_KEY",
|
|
|
|
|
None,
|
|
|
|
|
"SKY_TLS_CERT",
|
|
|
|
|
Some("2005"),
|
|
|
|
|
"SKY_TLS_PORT",
|
|
|
|
|
Some("false"),
|
|
|
|
|
"SKY_TLS_ONLY",
|
|
|
|
|
None,
|
|
|
|
|
"SKY_TLS_PASSIN",
|
|
|
|
|
);
|
|
|
|
|
assert!(cfg.is_mutated());
|
|
|
|
|
assert!(!cfg.is_okay());
|
|
|
|
|
assert_eq!(cfg.cfg.ports, PortConfig::default());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/// Gets a `toml` file from `WORKSPACEROOT/examples/config-files`
|
|
|
|
|
fn get_toml_from_examples_dir(filename: &str) -> TResult<String> {
|
|
|
|
|
use std::path;
|
|
|
|
|
let curdir = path::Path::new(env!("CARGO_MANIFEST_DIR"));
|
|
|
|
|
let workspaceroot = curdir.ancestors().nth(1).unwrap();
|
|
|
|
|
let mut fileloc = path::PathBuf::from(workspaceroot);
|
|
|
|
|
fileloc.push("examples");
|
|
|
|
|
fileloc.push("config-files");
|
|
|
|
|
fileloc.push(filename);
|
|
|
|
|
Ok(fs::read_to_string(fileloc)?)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
mod cfg_file_tests {
|
|
|
|
|
use super::get_toml_from_examples_dir;
|
|
|
|
|
use crate::config::{
|
|
|
|
|
cfgfile, BGSave, Configset, ConfigurationSet, Modeset, PortConfig, SnapshotConfig,
|
|
|
|
|
SnapshotPref, SslOpts, DEFAULT_IPV4, DEFAULT_PORT,
|
|
|
|
|
};
|
|
|
|
|
use crate::dbnet::MAXIMUM_CONNECTION_LIMIT;
|
|
|
|
|
use std::net::{IpAddr, Ipv6Addr};
|
|
|
|
|
|
|
|
|
|
fn cfgset_from_toml_str(file: String) -> Result<Configset, toml::de::Error> {
|
|
|
|
|
let toml = toml::from_str(&file)?;
|
|
|
|
|
Ok(cfgfile::from_file(toml))
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn config_file_okay() {
|
|
|
|
|
let file = get_toml_from_examples_dir("template.toml").unwrap();
|
|
|
|
|
let toml = toml::from_str(&file).unwrap();
|
|
|
|
|
let cfg_from_file = cfgfile::from_file(toml);
|
|
|
|
|
assert!(cfg_from_file.is_mutated());
|
|
|
|
|
assert!(cfg_from_file.is_okay());
|
|
|
|
|
// expected
|
|
|
|
|
let mut expected = ConfigurationSet::default();
|
|
|
|
|
expected.snapshot = SnapshotConfig::Enabled(SnapshotPref::new(3600, 4, true));
|
|
|
|
|
expected.ports = PortConfig::new_secure_only(
|
|
|
|
|
crate::config::DEFAULT_IPV4,
|
|
|
|
|
SslOpts::new(
|
|
|
|
|
"/path/to/keyfile.pem".to_owned(),
|
|
|
|
|
"/path/to/chain.pem".to_owned(),
|
|
|
|
|
2004,
|
|
|
|
|
Some("/path/to/cert/passphrase.txt".to_owned()),
|
|
|
|
|
),
|
|
|
|
|
);
|
|
|
|
|
// check
|
|
|
|
|
assert_eq!(cfg_from_file.cfg, expected);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_ok() {
|
|
|
|
|
let file = get_toml_from_examples_dir("skyd.toml").unwrap();
|
|
|
|
|
let cfg = cfgset_from_toml_str(file).unwrap();
|
|
|
|
|
assert_eq!(cfg.cfg, ConfigurationSet::default());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_noart() {
|
|
|
|
|
let file = get_toml_from_examples_dir("secure-noart.toml").unwrap();
|
|
|
|
|
let cfg = cfgset_from_toml_str(file).unwrap();
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfg.cfg,
|
|
|
|
|
ConfigurationSet {
|
|
|
|
|
noart: true,
|
|
|
|
|
bgsave: BGSave::default(),
|
|
|
|
|
snapshot: SnapshotConfig::default(),
|
|
|
|
|
ports: PortConfig::default(),
|
|
|
|
|
maxcon: MAXIMUM_CONNECTION_LIMIT,
|
|
|
|
|
mode: Modeset::Dev
|
|
|
|
|
}
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_ipv6() {
|
|
|
|
|
let file = get_toml_from_examples_dir("ipv6.toml").unwrap();
|
|
|
|
|
let cfg = cfgset_from_toml_str(file).unwrap();
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfg.cfg,
|
|
|
|
|
ConfigurationSet {
|
|
|
|
|
noart: false,
|
|
|
|
|
bgsave: BGSave::default(),
|
|
|
|
|
snapshot: SnapshotConfig::default(),
|
|
|
|
|
ports: PortConfig::new_insecure_only(
|
|
|
|
|
IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 0, 0, 0, 0x1)),
|
|
|
|
|
DEFAULT_PORT
|
|
|
|
|
),
|
|
|
|
|
maxcon: MAXIMUM_CONNECTION_LIMIT,
|
|
|
|
|
mode: Modeset::Dev
|
|
|
|
|
}
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_template() {
|
|
|
|
|
let file = get_toml_from_examples_dir("template.toml").unwrap();
|
|
|
|
|
let cfg = cfgset_from_toml_str(file).unwrap();
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfg.cfg,
|
|
|
|
|
ConfigurationSet::new(
|
|
|
|
|
false,
|
|
|
|
|
BGSave::default(),
|
|
|
|
|
SnapshotConfig::Enabled(SnapshotPref::new(3600, 4, true)),
|
|
|
|
|
PortConfig::new_secure_only(
|
|
|
|
|
DEFAULT_IPV4,
|
|
|
|
|
SslOpts::new(
|
|
|
|
|
"/path/to/keyfile.pem".into(),
|
|
|
|
|
"/path/to/chain.pem".into(),
|
|
|
|
|
2004,
|
|
|
|
|
Some("/path/to/cert/passphrase.txt".to_owned())
|
|
|
|
|
)
|
|
|
|
|
),
|
|
|
|
|
MAXIMUM_CONNECTION_LIMIT,
|
|
|
|
|
Modeset::Dev,
|
|
|
|
|
)
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_bad_bgsave_section() {
|
|
|
|
|
let file = get_toml_from_examples_dir("badcfg2.toml").unwrap();
|
|
|
|
|
let cfg = cfgset_from_toml_str(file);
|
|
|
|
|
assert!(cfg.is_err());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_custom_bgsave() {
|
|
|
|
|
let file = get_toml_from_examples_dir("withcustombgsave.toml").unwrap();
|
|
|
|
|
let cfg = cfgset_from_toml_str(file).unwrap();
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfg.cfg,
|
|
|
|
|
ConfigurationSet {
|
|
|
|
|
noart: false,
|
|
|
|
|
bgsave: BGSave::new(true, 600),
|
|
|
|
|
snapshot: SnapshotConfig::default(),
|
|
|
|
|
ports: PortConfig::default(),
|
|
|
|
|
maxcon: MAXIMUM_CONNECTION_LIMIT,
|
|
|
|
|
mode: Modeset::Dev
|
|
|
|
|
}
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_bgsave_enabled_only() {
|
|
|
|
|
/*
|
|
|
|
|
* This test demonstrates a case where the user just said that BGSAVE is enabled.
|
|
|
|
|
* In that case, we will default to the 120 second duration
|
|
|
|
|
*/
|
|
|
|
|
let file = get_toml_from_examples_dir("bgsave-justenabled.toml").unwrap();
|
|
|
|
|
let cfg = cfgset_from_toml_str(file).unwrap();
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfg.cfg,
|
|
|
|
|
ConfigurationSet {
|
|
|
|
|
noart: false,
|
|
|
|
|
bgsave: BGSave::default(),
|
|
|
|
|
snapshot: SnapshotConfig::default(),
|
|
|
|
|
ports: PortConfig::default(),
|
|
|
|
|
maxcon: MAXIMUM_CONNECTION_LIMIT,
|
|
|
|
|
mode: Modeset::Dev
|
|
|
|
|
}
|
|
|
|
|
)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_bgsave_every_only() {
|
|
|
|
|
/*
|
|
|
|
|
* This test demonstrates a case where the user just gave the value for every
|
|
|
|
|
* In that case, it means BGSAVE is enabled and set to `every` seconds
|
|
|
|
|
*/
|
|
|
|
|
let file = get_toml_from_examples_dir("bgsave-justevery.toml").unwrap();
|
|
|
|
|
let cfg = cfgset_from_toml_str(file).unwrap();
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfg.cfg,
|
|
|
|
|
ConfigurationSet {
|
|
|
|
|
noart: false,
|
|
|
|
|
bgsave: BGSave::new(true, 600),
|
|
|
|
|
snapshot: SnapshotConfig::default(),
|
|
|
|
|
ports: PortConfig::default(),
|
|
|
|
|
maxcon: MAXIMUM_CONNECTION_LIMIT,
|
|
|
|
|
mode: Modeset::Dev
|
|
|
|
|
}
|
|
|
|
|
)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn test_config_file_snapshot() {
|
|
|
|
|
let file = get_toml_from_examples_dir("snapshot.toml").unwrap();
|
|
|
|
|
let cfg = cfgset_from_toml_str(file).unwrap();
|
|
|
|
|
assert_eq!(
|
|
|
|
|
cfg.cfg,
|
|
|
|
|
ConfigurationSet {
|
|
|
|
|
snapshot: SnapshotConfig::Enabled(SnapshotPref::new(3600, 4, true)),
|
|
|
|
|
bgsave: BGSave::default(),
|
|
|
|
|
noart: false,
|
|
|
|
|
ports: PortConfig::default(),
|
|
|
|
|
maxcon: MAXIMUM_CONNECTION_LIMIT,
|
|
|
|
|
mode: Modeset::Dev
|
|
|
|
|
}
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
mod cli_arg_tests {
|
|
|
|
|
use crate::config::{cfgcli, PortConfig};
|
|
|
|
|
use clap::{load_yaml, App};
|
|
|
|
|
#[test]
|
|
|
|
|
fn cli_args_okay() {
|
|
|
|
|
let cfg_layout = load_yaml!("../cli.yml");
|
|
|
|
|
let cli_args = ["skyd", "--host", "127.0.0.2"];
|
|
|
|
|
let matches = App::from_yaml(cfg_layout).get_matches_from(&cli_args);
|
|
|
|
|
let ret = cfgcli::parse_cli_args(matches);
|
|
|
|
|
assert_eq!(
|
|
|
|
|
ret.cfg.ports,
|
|
|
|
|
PortConfig::new_insecure_only("127.0.0.2".parse().unwrap(), 2003)
|
|
|
|
|
);
|
|
|
|
|
assert!(ret.is_mutated());
|
|
|
|
|
assert!(ret.is_okay());
|
|
|
|
|
}
|
|
|
|
|
#[test]
|
|
|
|
|
fn cli_args_okay_no_mut() {
|
|
|
|
|
let cfg_layout = load_yaml!("../cli.yml");
|
|
|
|
|
let cli_args = ["skyd", "--restore", "/some/restore/path"];
|
|
|
|
|
let matches = App::from_yaml(cfg_layout).get_matches_from(&cli_args);
|
|
|
|
|
let ret = cfgcli::parse_cli_args(matches);
|
|
|
|
|
assert!(!ret.is_mutated());
|
|
|
|
|
assert!(ret.is_okay());
|
|
|
|
|
}
|
|
|
|
|
#[test]
|
|
|
|
|
fn cli_args_fail() {
|
|
|
|
|
let cfg_layout = load_yaml!("../cli.yml");
|
|
|
|
|
let cli_args = ["skyd", "--port", "port2003"];
|
|
|
|
|
let matches = App::from_yaml(cfg_layout).get_matches_from(&cli_args);
|
|
|
|
|
let ret = cfgcli::parse_cli_args(matches);
|
|
|
|
|
assert!(ret.is_mutated());
|
|
|
|
|
assert!(!ret.is_okay());
|
|
|
|
|
assert_eq!(
|
|
|
|
|
ret.estack[0],
|
|
|
|
|
"Bad value for `--port`. Expected a 16-bit positive integer"
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
mod try_from_config_source_impls {
|
|
|
|
|
use crate::config::{cfgcli::Flag, cfgfile::Optional, TryFromConfigSource, DEFAULT_IPV4};
|
|
|
|
|
use std::env::{set_var, var};
|
|
|
|
|
use std::fmt::Debug;
|
|
|
|
|
|
|
|
|
|
const EXPECT_TRUE: bool = true;
|
|
|
|
|
const EXPECT_FALSE: bool = false;
|
|
|
|
|
const MUTATED: bool = true;
|
|
|
|
|
const NOT_MUTATED: bool = false;
|
|
|
|
|
const IS_PRESENT: bool = true;
|
|
|
|
|
const IS_ABSENT: bool = false;
|
|
|
|
|
const MUTATION_FAILURE: bool = true;
|
|
|
|
|
const NO_MUTATION_FAILURE: bool = false;
|
|
|
|
|
|
|
|
|
|
fn _mut_base_test_expected<T: Default + PartialEq + Debug>(
|
|
|
|
|
new: impl TryFromConfigSource<T>,
|
|
|
|
|
expected: T,
|
|
|
|
|
is_present: bool,
|
|
|
|
|
mutate_failed: bool,
|
|
|
|
|
has_mutated: bool,
|
|
|
|
|
) {
|
|
|
|
|
let mut default = Default::default();
|
|
|
|
|
let mut mutated = false;
|
|
|
|
|
assert_eq!(new.is_present(), is_present);
|
|
|
|
|
assert_eq!(new.mutate_failed(&mut default, &mut mutated), mutate_failed);
|
|
|
|
|
assert_eq!(mutated, has_mutated);
|
|
|
|
|
assert_eq!(default, expected);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
fn _mut_base_test<T>(
|
|
|
|
|
new: impl TryFromConfigSource<T>,
|
|
|
|
|
mut default: T,
|
|
|
|
|
is_present: bool,
|
|
|
|
|
mutate_failed: bool,
|
|
|
|
|
has_mutated: bool,
|
|
|
|
|
) {
|
|
|
|
|
let mut mutated = false;
|
|
|
|
|
dbg!(new.is_present(), is_present);
|
|
|
|
|
assert_eq!(new.is_present(), is_present);
|
|
|
|
|
assert_eq!(new.mutate_failed(&mut default, &mut mutated), mutate_failed);
|
|
|
|
|
assert_eq!(mutated, has_mutated);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
fn mut_test_pass<T>(new: impl TryFromConfigSource<T>, default: T) {
|
|
|
|
|
_mut_base_test(new, default, IS_PRESENT, NO_MUTATION_FAILURE, MUTATED)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
fn mut_test_fail<T>(new: impl TryFromConfigSource<T>, default: T) {
|
|
|
|
|
_mut_base_test(new, default, IS_PRESENT, MUTATION_FAILURE, MUTATED)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
mod env_var {
|
|
|
|
|
use super::*;
|
|
|
|
|
|
|
|
|
|
// test for Result<String, VarError>
|
|
|
|
|
#[test]
|
|
|
|
|
fn env_okay_ipv4() {
|
|
|
|
|
set_var("TEST_SKY_SYSTEM_HOST", "127.0.0.1");
|
|
|
|
|
mut_test_pass(var("TEST_SKY_SYSTEM_HOST"), DEFAULT_IPV4);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn env_fail_ipv4() {
|
|
|
|
|
set_var("TEST_SKY_SYSTEM_HOST2", "127.0.0.1A");
|
|
|
|
|
mut_test_fail(var("TEST_SKY_SYSTEM_HOST2"), DEFAULT_IPV4);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
mod option_str {
|
|
|
|
|
use super::*;
|
|
|
|
|
|
|
|
|
|
// test for Option<&str> (as in CLI)
|
|
|
|
|
#[test]
|
|
|
|
|
fn option_str_okay_ipv4() {
|
|
|
|
|
let ip = Some("127.0.0.1");
|
|
|
|
|
mut_test_pass(ip, DEFAULT_IPV4);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn option_str_fail_ipv4() {
|
|
|
|
|
let ip = Some("127.0.0.1A");
|
|
|
|
|
mut_test_fail(ip, DEFAULT_IPV4);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn option_str_nomut() {
|
|
|
|
|
let ip = None;
|
|
|
|
|
_mut_base_test(
|
|
|
|
|
ip,
|
|
|
|
|
DEFAULT_IPV4,
|
|
|
|
|
IS_ABSENT,
|
|
|
|
|
NO_MUTATION_FAILURE,
|
|
|
|
|
NOT_MUTATED,
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
mod cfgcli_flag {
|
|
|
|
|
use super::*;
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn flag_true_if_set_okay_set() {
|
|
|
|
|
// this is true if flag is present
|
|
|
|
|
let flag = Flag::<true>::new(true);
|
|
|
|
|
// we expect true
|
|
|
|
|
_mut_base_test_expected(flag, EXPECT_TRUE, IS_PRESENT, NO_MUTATION_FAILURE, MUTATED);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn flag_true_if_set_okay_unset() {
|
|
|
|
|
// this is true if flag is present, but the flag here is not present
|
|
|
|
|
let flag = Flag::<true>::new(false);
|
|
|
|
|
// we expect no mutation because the flag was not set
|
|
|
|
|
_mut_base_test(
|
|
|
|
|
flag,
|
|
|
|
|
EXPECT_FALSE,
|
|
|
|
|
IS_ABSENT,
|
|
|
|
|
NO_MUTATION_FAILURE,
|
|
|
|
|
NOT_MUTATED,
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn flag_false_if_set_okay_set() {
|
|
|
|
|
// this is false if flag is present
|
|
|
|
|
let flag = Flag::<false>::new(true);
|
|
|
|
|
// expect mutation to have happened
|
|
|
|
|
_mut_base_test_expected(flag, EXPECT_FALSE, IS_PRESENT, NO_MUTATION_FAILURE, MUTATED);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn flag_false_if_set_okay_unset() {
|
|
|
|
|
// this is false if flag is present, but the flag is absent
|
|
|
|
|
let flag = Flag::<true>::new(false);
|
|
|
|
|
// expect no mutation
|
|
|
|
|
_mut_base_test(
|
|
|
|
|
flag,
|
|
|
|
|
EXPECT_FALSE,
|
|
|
|
|
IS_ABSENT,
|
|
|
|
|
NO_MUTATION_FAILURE,
|
|
|
|
|
NOT_MUTATED,
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
mod optional {
|
|
|
|
|
use super::*;
|
|
|
|
|
|
|
|
|
|
// test for cfg file scenario
|
|
|
|
|
#[test]
|
|
|
|
|
fn optional_okay_ipv4() {
|
|
|
|
|
let ip = Optional::some(DEFAULT_IPV4);
|
|
|
|
|
mut_test_pass(ip, DEFAULT_IPV4);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn optional_okay_ipv4_none() {
|
|
|
|
|
let ip = Optional::from(None);
|
|
|
|
|
_mut_base_test(
|
|
|
|
|
ip,
|
|
|
|
|
DEFAULT_IPV4,
|
|
|
|
|
IS_ABSENT,
|
|
|
|
|
NO_MUTATION_FAILURE,
|
|
|
|
|
NOT_MUTATED,
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
mod cfgfile_nonull {
|
|
|
|
|
use super::*;
|
|
|
|
|
use crate::config::cfgfile::NonNull;
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn nonnull_okay() {
|
|
|
|
|
let port = NonNull::from(2100);
|
|
|
|
|
_mut_base_test_expected(port, 2100, IS_PRESENT, NO_MUTATION_FAILURE, MUTATED);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
mod optstring {
|
|
|
|
|
use super::*;
|
|
|
|
|
use crate::config::OptString;
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn optstring_okay() {
|
|
|
|
|
let pass = OptString::from(Some("tlspass.txt".to_owned()));
|
|
|
|
|
_mut_base_test_expected(
|
|
|
|
|
pass,
|
|
|
|
|
OptString::from(Some("tlspass.txt".to_owned())),
|
|
|
|
|
IS_PRESENT,
|
|
|
|
|
NO_MUTATION_FAILURE,
|
|
|
|
|
MUTATED,
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn optstring_null_okay() {
|
|
|
|
|
let pass = OptString::from(None);
|
|
|
|
|
_mut_base_test_expected(
|
|
|
|
|
pass,
|
|
|
|
|
OptString::new_null(),
|
|
|
|
|
IS_ABSENT,
|
|
|
|
|
NO_MUTATION_FAILURE,
|
|
|
|
|
NOT_MUTATED,
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
mod modeset_de {
|
|
|
|
|
use crate::config::Modeset;
|
|
|
|
|
use serde::Deserialize;
|
|
|
|
|
|
|
|
|
|
#[derive(Deserialize, Debug)]
|
|
|
|
|
struct Example {
|
|
|
|
|
mode: Modeset,
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn deserialize_modeset_prod_okay() {
|
|
|
|
|
#[derive(Deserialize, Debug)]
|
|
|
|
|
struct Example {
|
|
|
|
|
mode: Modeset,
|
|
|
|
|
}
|
|
|
|
|
let toml = r#"mode="prod""#;
|
|
|
|
|
let x: Example = toml::from_str(toml).unwrap();
|
|
|
|
|
assert_eq!(x.mode, Modeset::Prod);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn deserialize_modeset_user_okay() {
|
|
|
|
|
let toml = r#"mode="dev""#;
|
|
|
|
|
let x: Example = toml::from_str(toml).unwrap();
|
|
|
|
|
assert_eq!(x.mode, Modeset::Dev);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#[test]
|
|
|
|
|
fn deserialize_modeset_fail() {
|
|
|
|
|
let toml = r#"mode="superuser""#;
|
|
|
|
|
let e = toml::from_str::<Example>(toml).unwrap_err();
|
|
|
|
|
assert_eq!(
|
|
|
|
|
e.to_string(),
|
|
|
|
|
"Bad value `superuser` for modeset for key `mode` at line 1 column 6"
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
Glydr
3 years ago
committed by
GitHub