juglans 0.2.13

Compiler and runtime for Juglans Workflow Language
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

// src/builtins/testing.rs
//
// Builtin tools for the `juglans test` framework.
// - `config`: Stores test configuration into context
// - `mock`: Execute a workflow with injected node outputs

use anyhow::{anyhow, Result};
use async_trait::async_trait;
use serde_json::Value;
use std::collections::HashMap;
use std::sync::Weak;
use tracing::info;

use super::Tool;
use crate::core::context::WorkflowContext;

/// `config` builtin — stores test configuration into context.
///
/// Parameters are stored as-is into the `_test_config` namespace in context.
/// Known keys: agent, budget, mock, timeout
pub struct Config;

#[async_trait]
impl Tool for Config {
    fn name(&self) -> &str {
        "config"
    }

    async fn execute(
        &self,
        params: &HashMap<String, String>,
        _context: &WorkflowContext,
    ) -> Result<Option<Value>> {
        // Return params as JSON value — the test runner reads this
        Ok(Some(serde_json::to_value(params)?))
    }
}

/// `mock` builtin — execute a workflow with injected node outputs.
///
/// Usage: mock(workflow="main.jg", inject={"node_id": value, ...})
///
/// Nodes listed in `inject` are skipped during execution and their output
/// is set to the injected value. All other nodes execute normally.
pub struct Mock {
    builtin_registry: Option<Weak<super::BuiltinRegistry>>,
}

impl Default for Mock {
    fn default() -> Self {
        Self::new()
    }
}

impl Mock {
    pub fn new() -> Self {
        Self {
            builtin_registry: None,
        }
    }

    pub fn set_registry(&mut self, registry: Weak<super::BuiltinRegistry>) {
        self.builtin_registry = Some(registry);
    }
}

#[async_trait]
impl Tool for Mock {
    fn name(&self) -> &str {
        "mock"
    }

    async fn execute(
        &self,
        params: &HashMap<String, String>,
        context: &WorkflowContext,
    ) -> Result<Option<Value>> {
        let workflow_path = params
            .get("workflow")
            .ok_or_else(|| anyhow!("mock: Missing 'workflow' parameter"))?;

        // Parse inject map: {"node_id": value, ...}
        if let Some(inject_str) = params.get("inject") {
            let inject_val: Value =
                serde_json::from_str(inject_str).unwrap_or(Value::String(inject_str.clone()));

            if let Value::Object(map) = inject_val {
                for (node_id, value) in map {
                    info!("  🎭 Mock inject [{}]", node_id);
                    context.set(format!("_mocks.{}", node_id), value)?;
                }
            } else {
                return Err(anyhow!("mock: 'inject' must be a JSON object"));
            }
        }

        let registry = self
            .builtin_registry
            .as_ref()
            .and_then(|w| w.upgrade())
            .ok_or_else(|| anyhow!("mock: BuiltinRegistry not available"))?;

        let base_dir = std::env::current_dir().unwrap_or_else(|_| std::path::PathBuf::from("."));
        let identifier = format!("mock:{}", workflow_path);

        info!("  🎭 mock: executing {}", workflow_path);
        let output = registry
            .execute_nested_workflow(workflow_path, &base_dir, context, identifier)
            .await?;
        Ok(Some(output))
    }
}