agent-code-lib 0.16.1

Agent engine library: LLM providers, tools, query loop, memory
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

//! SendMessage tool: communicate between agents.
//!
//! Allows one agent to send a message to another running agent
//! by ID or name. Used for coordination in multi-agent workflows.

use async_trait::async_trait;
use serde_json::json;

use super::{Tool, ToolContext, ToolResult};
use crate::error::ToolError;

pub struct SendMessageTool;

#[async_trait]
impl Tool for SendMessageTool {
    fn name(&self) -> &'static str {
        "SendMessage"
    }

    fn description(&self) -> &'static str {
        "Send a message to another running agent by ID or name. \
         Used for inter-agent coordination in multi-agent workflows."
    }

    fn input_schema(&self) -> serde_json::Value {
        json!({
            "type": "object",
            "required": ["to", "content"],
            "properties": {
                "to": {
                    "type": "string",
                    "description": "Target agent ID or name"
                },
                "content": {
                    "type": "string",
                    "description": "Message content to send"
                }
            }
        })
    }

    fn is_read_only(&self) -> bool {
        false
    }

    fn is_concurrency_safe(&self) -> bool {
        true
    }

    async fn call(
        &self,
        input: serde_json::Value,
        _ctx: &ToolContext,
    ) -> Result<ToolResult, ToolError> {
        let to = input
            .get("to")
            .and_then(|v| v.as_str())
            .ok_or_else(|| ToolError::InvalidInput("'to' is required".into()))?;

        let content = input
            .get("content")
            .and_then(|v| v.as_str())
            .ok_or_else(|| ToolError::InvalidInput("'content' is required".into()))?;

        // In a full implementation, this would route through the coordinator
        // to find the target agent and inject the message into its conversation.
        // For now, return a placeholder indicating the message was queued.
        Ok(ToolResult::success(format!(
            "Message queued for agent '{to}': {content}"
        )))
    }
}