mycelium-api 8.3.1-rc.1

Provide API ports to the mycelium project.
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
111
112
113
114
115
116
117
118
119
120

mod http_engine;
mod javascript_engine;
mod python_engine;

pub(crate) use http_engine::*;
pub(crate) use javascript_engine::*;
pub(crate) use python_engine::*;

// -----------------------------------------------------------------------------
// OPTIONAL: RHAI ENGINE
// -----------------------------------------------------------------------------
#[cfg(feature = "rhai")]
mod rhai_engine;
#[cfg(feature = "rhai")]
pub(crate) use rhai_engine::*;

// -----------------------------------------------------------------------------
// HELPER: Convert Callbacks to CallbackExecutors
// -----------------------------------------------------------------------------
use myc_core::domain::dtos::{
    callback::{Callback, CallbackError, CallbackExecutor, CallbackType},
    http::HttpMethod,
};
use std::sync::Arc;

/// Create a callback engine from a callback configuration
///
/// This function creates a callback engine from a callback configuration.
///
/// Returns a callback executor.
///
/// Errors:
/// - CallbackError: If the callback configuration is invalid.
///
/// Example:
///
/// ```rust
/// let callback = Callback::new("my_callback", CallbackType::Http, "http://example.com");
/// let engine = create_engine_from_callback(&callback)?;
/// ```
///
pub(crate) fn create_engine_from_callback(
    callback: &Callback,
) -> Result<Arc<dyn CallbackExecutor>, CallbackError> {
    match callback.callback_type {
        CallbackType::Http => {
            let url = callback.url.clone().ok_or_else(|| {
                CallbackError::ConfigError(format!(
                    "HTTP callback '{}' missing URL",
                    callback.name
                ))
            })?;

            let config = http_engine::HttpCallbackConfig {
                url,
                method: callback
                    .method
                    .clone()
                    .unwrap_or(HttpMethod::Post)
                    .to_string(),
                timeout_ms: callback.timeout_ms,
                retry_count: callback.retry_count,
                retry_interval_ms: callback.retry_interval_ms,
            };

            Ok(Arc::new(HttpCallback::new(config)))
        }
        CallbackType::Javascript => {
            let script_path =
                callback.script_path.clone().ok_or_else(|| {
                    CallbackError::ConfigError(format!(
                        "JavaScript callback '{}' missing script_path",
                        callback.name
                    ))
                })?;

            let engine = JavaScriptCallback::new(
                script_path,
                callback.node_path.clone(),
                Some(callback.timeout_ms),
            )?;

            Ok(Arc::new(engine))
        }
        CallbackType::Python => {
            let script_path =
                callback.script_path.clone().ok_or_else(|| {
                    CallbackError::ConfigError(format!(
                        "Python callback '{}' missing script_path",
                        callback.name
                    ))
                })?;

            let engine = PythonCallback::new(
                script_path,
                callback.python_path.clone(),
                Some(callback.timeout_ms),
            )?;

            Ok(Arc::new(engine))
        }
        #[cfg(feature = "rhai")]
        CallbackType::Rhai => {
            let script = callback.script.clone().ok_or_else(|| {
                CallbackError::ConfigError(format!(
                    "Rhai callback '{}' missing script",
                    callback.name
                ))
            })?;

            let engine = RhaiCallback::new(&script, callback.name.clone())?;
            Ok(Arc::new(engine))
        }
        #[cfg(not(feature = "rhai"))]
        CallbackType::Rhai => Err(CallbackError::ConfigError(
            "Rhai callbacks are not supported (feature not enabled)"
                .to_string(),
        )),
    }
}