synaptic-tools 0.4.0

Tool registry and execution: ToolRegistry, SerialToolExecutor, ParallelToolExecutor
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

use serde_json::json;
use synaptic_core::{SynapticError, Tool};
use synaptic_macros::tool;
use synaptic_tools::HandleErrorTool;

/// Always fails
#[tool(name = "failing")]
async fn fail_tool() -> Result<String, SynapticError> {
    Err(SynapticError::Tool("something went wrong".to_string()))
}

/// Always succeeds
#[tool(name = "succeeding")]
async fn succeed_tool() -> Result<serde_json::Value, SynapticError> {
    Ok(json!({"ok": true}))
}

#[tokio::test]
async fn default_handler_returns_error_string() {
    let inner = fail_tool();
    let wrapper = HandleErrorTool::new(inner);

    let result = wrapper.call(json!({})).await.unwrap();
    assert_eq!(result, json!("tool error: something went wrong"));
}

#[tokio::test]
async fn custom_handler_transforms_error() {
    let inner = fail_tool();
    let wrapper = HandleErrorTool::with_handler(inner, |err| format!("CUSTOM: {}", err));

    let result = wrapper.call(json!({})).await.unwrap();
    assert_eq!(result, json!("CUSTOM: tool error: something went wrong"));
}

#[tokio::test]
async fn success_passes_through() {
    let inner = succeed_tool();
    let wrapper = HandleErrorTool::new(inner);

    let result = wrapper.call(json!({})).await.unwrap();
    assert_eq!(result, json!({"ok": true}));
}

#[tokio::test]
async fn delegates_name_and_description() {
    let inner = fail_tool();
    let wrapper = HandleErrorTool::new(inner);

    assert_eq!(wrapper.name(), "failing");
    assert_eq!(wrapper.description(), "Always fails");
}