live 0.4.4

A modular configuration framework with live reloading and atomic, format-agnostic updates.
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

/* tests/format_agnostic_subdirs.rs */

#![cfg(feature = "full")]

use live::controller::{KeyPattern, LiveDir, ScanMode};
use live::holder::Store;
use live::loader::{DynLoader, FileSource, PreProcess, format::AnyFormat};
use serde::Deserialize;
use std::sync::Arc;

#[derive(Debug, Clone, Deserialize, PartialEq, validator::Validate)]
struct TestConfig {
	val: i32,
}

impl PreProcess for TestConfig {}

#[tokio::test]
async fn test_subdirs_format_agnostic() -> Result<(), Box<dyn std::error::Error>> {
	let dir = tempfile::tempdir()?;
	let dir_path = dir.path();

	// Create subdirectory structure
	// [tcp]/config.json
	// [udp]/config.toml
	tokio::fs::create_dir(dir_path.join("[tcp]")).await?;
	tokio::fs::create_dir(dir_path.join("[udp]")).await?;

	tokio::fs::write(dir_path.join("[tcp]").join("config.json"), b"{\"val\": 1}").await?;

	tokio::fs::write(dir_path.join("[udp]").join("config.toml"), b"val = 2").await?;

	let store = Arc::new(Store::<TestConfig>::new());
	let source = FileSource::new(dir_path);
	let loader = DynLoader::builder()
		.source(source)
		.format(AnyFormat::Json)
		.format(AnyFormat::Toml)
		.build()
		.unwrap();

	// Use "config" without extension
	let live_dir = LiveDir::builder()
		.store(store)
		.loader(loader)
		.path(dir_path)
		.pattern(KeyPattern::Bracketed)
		.scan_mode(ScanMode::Subdirs {
			config_file: "config".to_string(),
		})
		.build()?;

	let result = live_dir.load().await?;

	assert_eq!(result.loaded().count(), 2);
	assert!(result.failed.is_empty());

	assert_eq!(live_dir.get("tcp").unwrap().val, 1);
	assert_eq!(live_dir.get("udp").unwrap().val, 2);

	Ok(())
}