greentic-runner-host 1.1.7

Host runtime shim for Greentic runner: config, pack loading, activity handling
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110

//! Per-pack `runtime://` URI resolution for the C5 runtime-refs channel.
//!
//! `pack-config.v1.runtime_refs` binds opaque keys to `runtime://<env>/...`
//! URIs whose values live in the env-pack-emitted `runtime.json`
//! ([`EnvironmentRuntime`]). The producer (greentic-start) owns the
//! `EnvironmentRuntime` snapshot + hot-reload watcher and exposes lookups
//! through [`RuntimeRefResolver`].
//!
//! Runner-host stays unaware of URI shapes: the per-pack `refs` map carries
//! opaque URI strings, and the resolver opaquely returns the current value.
//! This shape preserves hot-reload — every host-import call re-enters the
//! resolver, which reads from start's `ArcSwap` snapshot.
//!
//! [`EnvironmentRuntime`]: greentic-deploy-spec::EnvironmentRuntime

use serde_json::Value;
use std::collections::BTreeMap;
use std::fmt::Debug;
use std::sync::Arc;
use thiserror::Error;

/// Errors a [`RuntimeRefResolver`] can return. Mapped onto
/// `greentic:runtime-config@1.0.0::ConfigError` by the host import. The
/// "not bound in the current snapshot" case is signalled by `Ok(None)`
/// from [`RuntimeRefResolver::resolve`], not by an error.
#[derive(Debug, Error)]
pub enum RuntimeRefResolverError {
    /// URI shape was rejected by the resolver (parse / env mismatch).
    #[error("runtime-ref invalid: {0}")]
    Invalid(String),
    /// Resolver was unable to complete the lookup (snapshot read failure,
    /// store error, etc.). Treated by the host import as `Internal`.
    #[error("runtime-ref internal error: {0}")]
    Internal(String),
}

/// Trait implemented by greentic-start to resolve `runtime://` URIs against
/// the live [`EnvironmentRuntime`] snapshot. Implementations MUST be cheap
/// to call (they are invoked on every `greentic:runtime-config/get`).
///
/// [`EnvironmentRuntime`]: greentic-deploy-spec::EnvironmentRuntime
pub trait RuntimeRefResolver: Debug + Send + Sync {
    /// Resolve a single `runtime://` URI. Returns `Ok(None)` when the URI
    /// parses cleanly but is not bound in the current snapshot — the host
    /// import maps this to `ConfigError::NotFound`.
    fn resolve(&self, runtime_ref: &str) -> Result<Option<Value>, RuntimeRefResolverError>;
}

/// Per-pack runtime-refs injection: the `key → URI` map from
/// `pack-config.v1.runtime_refs` plus the env-wide resolver. The resolver
/// is shared across every pack in the env (one `ArcSwap` snapshot owner);
/// the `refs` map is per-pack.
#[derive(Clone, Debug)]
pub struct RuntimeRefsInjection {
    /// `key → "runtime://<env>/discovered/<path>"`. Keys are what the WASM
    /// component asks for; URIs are opaque to runner-host and forwarded to
    /// the resolver verbatim.
    pub refs: Arc<BTreeMap<String, String>>,
    /// Env-shared resolver. Reads start's `EnvironmentRuntime` snapshot on
    /// every call so hot-reloads land immediately.
    pub resolver: Arc<dyn RuntimeRefResolver>,
}

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

    /// Test resolver that returns a fixed value for one URI.
    #[derive(Debug)]
    struct FixedResolver {
        uri: String,
        value: Value,
    }

    impl RuntimeRefResolver for FixedResolver {
        fn resolve(&self, runtime_ref: &str) -> Result<Option<Value>, RuntimeRefResolverError> {
            if runtime_ref == self.uri {
                Ok(Some(self.value.clone()))
            } else {
                Ok(None)
            }
        }
    }

    #[test]
    fn resolver_returns_value_for_bound_uri() {
        let resolver = FixedResolver {
            uri: "runtime://local/discovered/alb_dns".into(),
            value: Value::String("alb.example.com".into()),
        };
        let value = resolver
            .resolve("runtime://local/discovered/alb_dns")
            .unwrap();
        assert_eq!(value, Some(Value::String("alb.example.com".into())));
    }

    #[test]
    fn resolver_returns_none_for_unbound_uri() {
        let resolver = FixedResolver {
            uri: "runtime://local/discovered/alb_dns".into(),
            value: Value::String("alb.example.com".into()),
        };
        assert_eq!(
            resolver
                .resolve("runtime://local/discovered/other")
                .unwrap(),
            None,
        );
    }
}