nika-engine 0.38.0

Nika workflow engine — embeddable runtime, provider, DAG, and binding logic
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
121
122
123
124
125
126
127
128
129
130
131
132

//! Media tool error helpers (NIKA-290..297)
//!
//! These are errors specific to media TOOL operations (resize, OCR, SVG render, etc.),
//! distinct from the media PIPELINE errors (NIKA-251..259) in src/media/error.rs.

use crate::error::NikaError;

/// Create a generic media tool error (NIKA-290).
pub fn tool_error(tool: &str, reason: impl Into<String>) -> NikaError {
    NikaError::BuiltinToolError {
        tool: format!("nika:{tool}"),
        reason: format!("[NIKA-290] {}", reason.into()),
    }
}

/// Create an unsupported format error (NIKA-291).
pub fn unsupported_format(tool: &str, mime: &str) -> NikaError {
    NikaError::BuiltinToolError {
        tool: format!("nika:{tool}"),
        reason: format!("[NIKA-291] unsupported format '{mime}' for this tool"),
    }
}

/// Create a dependency missing error (NIKA-292).
#[allow(dead_code)]
pub fn dependency_missing(tool: &str, feature: &str) -> NikaError {
    NikaError::BuiltinToolError {
        tool: format!("nika:{tool}"),
        reason: format!(
            "[NIKA-292] feature '{feature}' is required but not enabled. \
       Rebuild with: cargo build --features {feature}"
        ),
    }
}

/// Create a timeout error (NIKA-293).
pub fn timeout_error(tool: &str) -> NikaError {
    NikaError::BuiltinToolError {
        tool: format!("nika:{tool}"),
        reason: "[NIKA-293] operation timed out".to_string(),
    }
}

/// Create an invalid args error (NIKA-294).
pub fn invalid_args(tool: &str, reason: impl Into<String>) -> NikaError {
    NikaError::BuiltinInvalidParams {
        tool: format!("nika:{tool}"),
        reason: format!("[NIKA-294] {}", reason.into()),
    }
}

/// Create a pipeline step failed error (NIKA-295).
#[allow(dead_code)]
pub fn pipeline_step_failed(step: usize, reason: impl Into<String>) -> NikaError {
    NikaError::BuiltinToolError {
        tool: "nika:pipeline".to_string(),
        reason: format!("[NIKA-295] step {step} failed: {}", reason.into()),
    }
}

/// Create a pipeline empty error (NIKA-296).
#[allow(dead_code)]
pub fn pipeline_empty() -> NikaError {
    NikaError::BuiltinToolError {
        tool: "nika:pipeline".to_string(),
        reason: "[NIKA-296] pipeline has no steps".to_string(),
    }
}

/// Create a security violation error (NIKA-297).
pub fn security_violation(tool: &str, reason: impl Into<String>) -> NikaError {
    NikaError::BuiltinToolError {
        tool: format!("nika:{tool}"),
        reason: format!("[NIKA-297] security violation: {}", reason.into()),
    }
}

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

    #[test]
    fn tool_error_contains_code() {
        let err = tool_error("thumbnail", "decode failed");
        assert!(err.to_string().contains("NIKA-290"));
        assert!(err.to_string().contains("decode failed"));
    }

    #[test]
    fn unsupported_format_contains_mime() {
        let err = unsupported_format("dimensions", "audio/wav");
        assert!(err.to_string().contains("NIKA-291"));
        assert!(err.to_string().contains("audio/wav"));
    }

    #[test]
    fn dependency_missing_shows_feature() {
        let err = dependency_missing("thumbnail", "media-thumbnail");
        assert!(err.to_string().contains("NIKA-292"));
        assert!(err.to_string().contains("media-thumbnail"));
    }

    #[test]
    fn timeout_error_code() {
        let err = timeout_error("optimize");
        assert!(err.to_string().contains("NIKA-293"));
    }

    #[test]
    fn invalid_args_code() {
        let err = invalid_args("thumbnail", "width must be > 0");
        assert!(err.to_string().contains("NIKA-294"));
        assert!(err.to_string().contains("width must be > 0"));
    }

    #[test]
    fn security_violation_code() {
        let err = security_violation("svg_render", "SVG contains <script>");
        assert!(err.to_string().contains("NIKA-297"));
        assert!(err.to_string().contains("<script>"));
    }

    #[test]
    fn pipeline_errors() {
        let err = pipeline_step_failed(2, "resize failed");
        assert!(err.to_string().contains("NIKA-295"));
        assert!(err.to_string().contains("step 2"));

        let err = pipeline_empty();
        assert!(err.to_string().contains("NIKA-296"));
    }
}