use gonfig::{ConfigBuilder, Gonfig, MergeStrategy};
use serde::{Deserialize, Serialize};
#[derive(Debug, Serialize, Deserialize, Gonfig)]
#[Gonfig(allow_cli, env_prefix = "MDR")]
struct Madara {
#[gonfig(env_name = "MADARA_MONGO")]
mongo: MongoConfig,
#[gonfig(env_name = "MADARA_SERVER")]
server: ServerConfig,
#[skip]
#[serde(skip)]
_internal: Option<String>,
}
#[derive(Debug, Serialize, Deserialize, Gonfig)]
#[Gonfig(env_prefix = "MONGO")]
struct MongoConfig {
uri: String,
#[gonfig(env_name = "MONGO_DATABASE")]
database: String,
connection_timeout: Option<u64>,
max_pool_size: Option<u32>,
}
#[derive(Debug, Serialize, Deserialize, Gonfig)]
#[Gonfig(allow_cli, env_prefix = "SERVER")]
struct ServerConfig {
host: String,
port: u16,
#[gonfig(env_name = "WORKERS")]
worker_threads: Option<usize>,
enable_cors: Option<bool>,
}
fn main() -> gonfig::Result<()> {
println!("=== Madara Configuration Management Demo ===\n");
setup_environment_variables();
println!("1. Loading with derive macro (simple approach):");
match Madara::from_gonfig() {
Ok(config) => {
println!("✅ Loaded config from environment:");
print_madara_config(&config);
}
Err(e) => println!("❌ Error: {e}"),
}
println!("\n2. Loading with custom builder (advanced approach):");
let builder = ConfigBuilder::new()
.with_merge_strategy(MergeStrategy::Deep)
.with_env("MDR")
.with_cli()
.validate_with(|value| {
if let Some(server) = value.get("server") {
if let Some(port) = server.get("port") {
if let Some(port_num) = port.as_u64() {
if port_num > 65535 {
return Err(gonfig::Error::Validation("Port must be <= 65535".into()));
}
}
}
}
if let Some(mongo) = value.get("mongo") {
if let Some(uri) = mongo.get("uri") {
if let Some(uri_str) = uri.as_str() {
if !uri_str.starts_with("mongodb://")
&& !uri_str.starts_with("mongodb+srv://")
{
return Err(gonfig::Error::Validation(
"MongoDB URI must start with mongodb:// or mongodb+srv://".into(),
));
}
}
}
}
Ok(())
});
match builder.build::<Madara>() {
Ok(config) => {
println!("✅ Validated config:");
print_madara_config(&config);
println!("\n3. Individual component access:");
println!("MongoDB Connection: {}", config.mongo.uri);
println!("Database: {}", config.mongo.database);
println!(
"Server Address: {}:{}",
config.server.host, config.server.port
);
if let Some(workers) = config.server.worker_threads {
println!("Worker Threads: {workers}");
}
if let Some(timeout) = config.mongo.connection_timeout {
println!("Connection Timeout: {timeout}s");
}
}
Err(e) => println!("❌ Validation failed: {e}"),
}
println!("\n4. Testing different environment variable patterns:");
test_environment_patterns();
Ok(())
}
fn setup_environment_variables() {
println!("Setting up environment variables with Madara pattern:");
std::env::set_var("MADARA_MONGO_URI", "mongodb://localhost:27017");
std::env::set_var("MADARA_MONGO_DATABASE", "madara_production");
std::env::set_var("MADARA_MONGO_CONNECTION_TIMEOUT", "30");
std::env::set_var("MADARA_MONGO_MAX_POOL_SIZE", "10");
std::env::set_var("MADARA_SERVER_HOST", "0.0.0.0");
std::env::set_var("MADARA_SERVER_PORT", "8080");
std::env::set_var("WORKERS", "4"); std::env::set_var("MADARA_SERVER_ENABLE_CORS", "true");
println!(" MADARA_MONGO_URI=mongodb://localhost:27017");
println!(" MADARA_MONGO_DATABASE=madara_production");
println!(" MADARA_MONGO_CONNECTION_TIMEOUT=30");
println!(" MADARA_SERVER_HOST=0.0.0.0");
println!(" MADARA_SERVER_PORT=8080");
println!(" WORKERS=4 # (field override)");
println!();
}
fn print_madara_config(config: &Madara) {
println!("📋 Madara Configuration:");
println!(" 🗄️ MongoDB:");
println!(" URI: {}", config.mongo.uri);
println!(" Database: {}", config.mongo.database);
if let Some(timeout) = config.mongo.connection_timeout {
println!(" Timeout: {timeout}s");
}
if let Some(pool_size) = config.mongo.max_pool_size {
println!(" Pool Size: {pool_size}");
}
println!(" 🌐 Server:");
println!(" Host: {}", config.server.host);
println!(" Port: {}", config.server.port);
if let Some(workers) = config.server.worker_threads {
println!(" Workers: {workers}");
}
if let Some(cors) = config.server.enable_cors {
println!(" CORS: {cors}");
}
}
fn test_environment_patterns() {
println!("Testing different prefix patterns:");
std::env::set_var("TEST_MADARA_MONGO_URI", "mongodb://test1:27017");
println!(" TEST_MADARA_MONGO_URI → hierarchical structure");
std::env::set_var("CUSTOM_MONGO_URI", "mongodb://test2:27017");
println!(" CUSTOM_MONGO_URI → field name override");
std::env::set_var("APP_DATABASE_CONFIG_HOST", "test.db.com");
println!(" APP_DATABASE_CONFIG_HOST → nested configuration");
println!("\nPrefix resolution examples:");
println!(" With prefix 'MDR' and struct 'Madara':");
println!(" field 'mongo.uri' → MDR_MADARA_MONGO_URI");
println!(" field with env_name='CUSTOM' → CUSTOM");
println!(" nested field 'mongo.connection_timeout' → MDR_MADARA_MONGO_CONNECTION_TIMEOUT");
}