pub mod cli;
pub mod logger;
use crate::cli_shared::cli::{Config, ConfigPath, find_config_path};
use crate::networks::NetworkChain;
use crate::utils::io::read_toml;
use std::path::PathBuf;
cfg_if::cfg_if! {
if #[cfg(feature = "rustalloc")] {
} else if #[cfg(feature = "jemalloc")] {
pub use tikv_jemallocator;
}
}
pub const FOREST_DATA_DIR_ENV: &str = "FOREST_PATH";
pub fn chain_path(config: &Config) -> PathBuf {
PathBuf::from(&config.client.data_dir).join(config.chain().to_string())
}
pub fn read_config(
config_path_opt: Option<&PathBuf>,
chain_opt: Option<NetworkChain>,
) -> anyhow::Result<(Option<ConfigPath>, Config)> {
let (path, mut config) = match find_config_path(config_path_opt) {
Some(path) => {
let toml = std::fs::read_to_string(path.to_path_buf())?;
(Some(path), read_toml(&toml)?)
}
None => (None, Config::default()),
};
if let Some(chain) = chain_opt {
config.chain = chain;
}
if let Some(data_dir) = data_dir_from_env() {
config.client.data_dir = data_dir;
}
Ok((path, config))
}
fn data_dir_from_env() -> Option<PathBuf> {
match std::env::var(FOREST_DATA_DIR_ENV) {
Ok(s) if !s.trim().is_empty() => Some(PathBuf::from(s)),
_ => None,
}
}
pub fn default_data_dir() -> PathBuf {
data_dir_from_env().unwrap_or_else(|| crate::cli_shared::cli::Client::default().data_dir)
}
pub fn default_token_path() -> PathBuf {
default_data_dir().join(crate::cli_shared::cli::Client::RPC_TOKEN_FILENAME)
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn read_config_default() {
let (config_path, config) = read_config(None, None).unwrap();
assert!(config_path.is_none());
assert_eq!(config.chain(), &NetworkChain::Mainnet);
}
#[test]
fn read_config_calibnet_override() {
let (config_path, config) = read_config(None, Some(NetworkChain::Calibnet)).unwrap();
assert!(config_path.is_none());
assert_eq!(config.chain(), &NetworkChain::Calibnet);
}
#[test]
fn read_config_butterflynet_override() {
let (config_path, config) = read_config(None, Some(NetworkChain::Butterflynet)).unwrap();
assert!(config_path.is_none());
assert_eq!(config.chain(), &NetworkChain::Butterflynet);
}
fn with_data_dir_env<T>(value: &str, f: impl FnOnce() -> T) -> T {
unsafe { std::env::set_var(FOREST_DATA_DIR_ENV, value) };
let result = f();
unsafe { std::env::remove_var(FOREST_DATA_DIR_ENV) };
result
}
#[test]
#[serial_test::serial]
fn read_config_data_dir_env_override() {
let data_dir = "/tmp/forest-path-env-override-test";
let (_, config) = with_data_dir_env(data_dir, || read_config(None, None).unwrap());
assert_eq!(config.client.data_dir, std::path::Path::new(data_dir));
}
#[test]
#[serial_test::serial]
fn default_data_dir_honors_env_override() {
let data_dir = "/tmp/forest-path-default-data-dir-test";
let resolved = with_data_dir_env(data_dir, default_data_dir);
assert_eq!(resolved, std::path::Path::new(data_dir));
assert_eq!(default_data_dir(), Config::default().client.data_dir);
}
#[test]
#[serial_test::serial]
fn read_config_data_dir_env_empty_is_ignored() {
let (_, config) = with_data_dir_env("", || read_config(None, None).unwrap());
assert_eq!(config.client.data_dir, Config::default().client.data_dir);
}
#[test]
#[serial_test::serial]
fn read_config_with_path() {
let default_config = Config::default();
let temp_dir = tempfile::tempdir().expect("couldn't create temp dir");
let config_file = temp_dir.path().join("config.toml");
let serialized_config = toml::to_string(&default_config).unwrap();
std::fs::write(&config_file, serialized_config).unwrap();
let (config_path, config) = read_config(Some(&config_file), None).unwrap();
assert_eq!(config_path.unwrap(), ConfigPath::Cli(config_file));
assert_eq!(config.chain(), &NetworkChain::Mainnet);
assert_eq!(config, default_config);
}
}
pub mod snapshot;