pupoxide 0.2.3

A high-performance, memory-safe, declarative configuration management tool inspired by Puppet.
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

use crate::application::engine::{ExecutionContext, ModuleHandle};
use crate::domain::resource::{Ensure, Resource};
use rhai::{Dynamic, Map};
use tracing::warn;

// Helper to lock a mutex safely or log warning
pub fn lock_or_warn<'a, T>(
    mutex: &'a std::sync::Mutex<T>,
    label: &str,
) -> Option<std::sync::MutexGuard<'a, T>> {
    mutex
        .lock()
        .map_err(|e| {
            warn!("Failed to lock {}: {}", label, e);
        })
        .ok()
}

pub struct DslUtils;

impl DslUtils {
    pub fn extract_ensure(params: &Map) -> Ensure {
        params
            .get("ensure")
            .and_then(|v| {
                v.clone()
                    .try_cast::<String>()
                    .map(|s| match s.as_str() {
                        "absent" => Ensure::Absent,
                        _ => Ensure::Present,
                    })
                    .or_else(|| v.clone().try_cast::<Ensure>())
            })
            .unwrap_or(Ensure::Present)
    }

    pub fn extract_dependencies(
        params: &Map,
        ctx: &ExecutionContext,
        source: Option<&str>,
    ) -> Vec<String> {
        let mut dependencies = Vec::new();

        // 1. Parent attribution based on Rhai source
        if let Some(src) = source {
            let s_map = ctx
                .source_map
                .lock()
                // SAFETY: Lock failure indicates a poisoned mutex, which is a fatal error.
                .expect("Failed to lock source map");

            // Try specific source mapping, then fallback to current module stack
            if let Some(marker_id) = s_map.get(src) {
                dependencies.push(marker_id.clone());
            } else if let Some(stack_guard) = lock_or_warn(&ctx.module_stack, "module_stack")
                && let Some((inc_type, curr_mod)) = stack_guard.last()
            {
                dependencies.push(format!("{:?}Start[{}]", inc_type, curr_mod));
            }
        } else if let Some(stack_guard) = lock_or_warn(&ctx.module_stack, "module_stack") {
            // General fallback if no source provided
            if let Some((inc_type, curr_mod)) = stack_guard.last() {
                dependencies.push(format!("{:?}Start[{}]", inc_type, curr_mod));
            }
        }

        // 2. Add explicit dependencies from params
        if let Some(req) = params.get("require") {
            Self::push_dependency(&mut dependencies, req.clone());
        }

        dependencies
    }

    pub fn push_dependency(dependencies: &mut Vec<String>, req: Dynamic) {
        // Try to extract dependency in order of specificity
        if let Some(m_h) = req.clone().try_cast::<ModuleHandle>() {
            dependencies.push(m_h.end_id);
        } else if let Some(dep_res) = req.clone().try_cast::<Resource>() {
            dependencies.push(dep_res.id().to_string());
        } else if let Some(dep_id) = req.clone().try_cast::<String>() {
            dependencies.push(dep_id);
        } else if let Some(m) = req.clone().try_cast::<rhai::Shared<rhai::Module>>() {
            if let Some(m_h) = m
                .get_var("module_handle")
                .and_then(|v| v.try_cast::<ModuleHandle>())
            {
                dependencies.push(m_h.end_id);
            }
        } else if let Some(arr) = req.try_cast::<rhai::Array>() {
            for item in arr {
                Self::push_dependency(dependencies, item);
            }
        }
    }

    pub fn extract_string(params: &Map, key: &str) -> Option<String> {
        params.get(key).and_then(|v| v.clone().try_cast::<String>())
    }

    pub fn extract_bool(params: &Map, key: &str, default: bool) -> bool {
        params
            .get(key)
            .and_then(|v| v.clone().try_cast::<bool>())
            .unwrap_or(default)
    }
}