keelrun 0.1.1

Keel as a Rust front end: #[keel::wrap] plus a reqwest-middleware adapter, routing calls through the keel-core Engine chain (cache/rate/breaker/timeout/retry) from one `keel.toml`. No import hook (Rust has none to hang off of) — call `keel::init()` once from your own `main`. Published as `keelrun` (plain `keel` is taken on crates.io); add it as `cargo add keelrun --rename keel` so `#[keel::wrap]` resolves — see README.md.
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

use keel_core_api::{ErrorCode, KeelError};
use std::path::Path;

/// Load `<dir>/keel.toml` as JSON (per `contracts/policy.schema.json`), or
/// Level 0 defaults (an empty policy — `Engine::configure` treats an absent
/// `[target]` table as "nothing wrapped yet", the same fallback
/// `python/keel`'s `load_policy`/`node/keel`'s `loadPolicy` use) if the file
/// is absent.
pub(crate) fn load(dir: &Path) -> Result<serde_json::Value, KeelError> {
    let path = dir.join("keel.toml");
    if !path.is_file() {
        return Ok(serde_json::json!({}));
    }
    let contents = std::fs::read_to_string(&path).map_err(|err| KeelError {
        code: ErrorCode::PolicyInvalid,
        message: format!(
            "keel.toml at {} is present but could not be read: {err}. Fix the file's \
             permissions/path, or remove it to fall back to Level 0 defaults.",
            path.display()
        ),
    })?;
    toml::from_str(&contents).map_err(|err| KeelError {
        code: ErrorCode::PolicyInvalid,
        message: format!("keel.toml at {} is not valid TOML: {err}", path.display()),
    })
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn missing_file_is_level0_defaults() {
        let dir = tempfile::tempdir().unwrap();
        let policy = load(dir.path()).expect("defaults never fail");
        assert_eq!(policy, serde_json::json!({}));
    }

    #[test]
    fn valid_toml_parses_to_json() {
        let dir = tempfile::tempdir().unwrap();
        std::fs::write(
            dir.path().join("keel.toml"),
            "[target.\"orders-api\"]\nretry = { attempts = 3 }\n",
        )
        .unwrap();
        let policy = load(dir.path()).expect("valid toml parses");
        assert_eq!(
            policy["target"]["orders-api"]["retry"]["attempts"],
            serde_json::json!(3)
        );
    }

    #[test]
    fn invalid_toml_is_keel_e001() {
        let dir = tempfile::tempdir().unwrap();
        std::fs::write(dir.path().join("keel.toml"), "not = [valid").unwrap();
        let err = load(dir.path()).unwrap_err();
        assert_eq!(err.code, ErrorCode::PolicyInvalid);
    }
}