symbi-runtime 1.10.0

Agent Runtime System for the Symbi platform
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

//! Composio integration error types

use thiserror::Error;

/// Errors that can occur during Composio MCP integration operations
#[derive(Error, Debug)]
pub enum ComposioError {
    #[error("Configuration error: {reason}")]
    ConfigError { reason: String },

    #[error("SSE transport error: {reason}")]
    TransportError { reason: String },

    #[error("Tool discovery failed for server '{server}': {reason}")]
    DiscoveryError { server: String, reason: String },

    #[error("JSON-RPC error (code {code}): {message}")]
    JsonRpcError { code: i64, message: String },

    #[error("Connection timeout to server '{server}'")]
    Timeout { server: String },

    #[error("IO error: {source}")]
    Io {
        #[from]
        source: std::io::Error,
    },

    #[error("HTTP error: {source}")]
    Http {
        #[from]
        source: reqwest::Error,
    },

    #[error("JSON serialization error: {source}")]
    Json {
        #[from]
        source: serde_json::Error,
    },
}

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

    #[test]
    fn test_config_error_display() {
        let err = ComposioError::ConfigError {
            reason: "missing API key".to_string(),
        };
        assert_eq!(err.to_string(), "Configuration error: missing API key");
    }

    #[test]
    fn test_transport_error_display() {
        let err = ComposioError::TransportError {
            reason: "connection refused".to_string(),
        };
        assert_eq!(err.to_string(), "SSE transport error: connection refused");
    }

    #[test]
    fn test_discovery_error_display() {
        let err = ComposioError::DiscoveryError {
            server: "github".to_string(),
            reason: "not found".to_string(),
        };
        assert_eq!(
            err.to_string(),
            "Tool discovery failed for server 'github': not found"
        );
    }

    #[test]
    fn test_jsonrpc_error_display() {
        let err = ComposioError::JsonRpcError {
            code: -32600,
            message: "Invalid Request".to_string(),
        };
        assert_eq!(
            err.to_string(),
            "JSON-RPC error (code -32600): Invalid Request"
        );
    }

    #[test]
    fn test_timeout_error_display() {
        let err = ComposioError::Timeout {
            server: "slack".to_string(),
        };
        assert_eq!(err.to_string(), "Connection timeout to server 'slack'");
    }
}