live 0.3.3

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

/* tests/loader_tests.rs */

#![cfg(all(feature = "loader", feature = "json", feature = "validate"))]

use live::loader::{DynLoader, LoadResult, MemorySource, format::AnyFormat};
use serde::Deserialize;
use validator::Validate;

#[derive(Deserialize, Debug, PartialEq, Validate)]
struct Config {
	#[validate(length(min = 1))]
	foo: String,
}

impl live::loader::PreProcess for Config {}

#[tokio::test]
async fn test_dyn_loader_json() {
	let mut source = MemorySource::new();
	source.insert("test.json", b"{\"foo\": \"bar\"}".to_vec());

	let loader = DynLoader::builder()
		.source(source)
		.format(AnyFormat::Json)
		.build()
		.unwrap();

	let res = loader.load::<Config>("test").await;
	match res {
		LoadResult::Ok { value, .. } => assert_eq!(value.foo, "bar"),
		_ => panic!("Load failed"),
	}
}

#[tokio::test]
async fn test_dyn_loader_not_found() {
	let source = MemorySource::new();
	let loader = DynLoader::builder()
		.source(source)
		.format(AnyFormat::Json)
		.build()
		.unwrap();

	let res = loader.load::<Config>("missing").await;
	match res {
		LoadResult::NotFound => (),
		_ => panic!("Expected NotFound"),
	}
}