zagens-core 0.8.2

Core runtime boundaries for Zagens agent architecture
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

//! Tool execution port for parallel/sequential paths in the turn loop (P2 PR4).

use std::sync::Arc;

use async_trait::async_trait;
use serde_json::Value;
use tokio::sync::{RwLock, mpsc};
use zagens_tools::{ToolError, ToolResult};

use crate::events::Event;

use super::host::TurnLoopToolRegistry;

/// Cloned handles passed into `async move` tool tasks.
#[derive(Clone)]
pub struct TurnLoopToolExec {
    pub lock: Arc<RwLock<()>>,
    pub tx_event: mpsc::Sender<Event>,
}

/// Executes registry/MCP tools for the turn loop (implemented by TUI `Engine` L2).
#[async_trait]
pub trait TurnLoopToolExecutor: Send + Sync {
    type ToolRegistry: TurnLoopToolRegistry;

    #[allow(clippy::too_many_arguments)]
    async fn execute_with_lock(
        &self,
        exec: TurnLoopToolExec,
        supports_parallel: bool,
        interactive: bool,
        tool_name: String,
        tool_input: Value,
        registry: Option<&Self::ToolRegistry>,
        mcp_pool: Option<Arc<tokio::sync::Mutex<dyn McpPoolPort + Send + Sync>>>,
        tool_progress_id: Option<String>,
    ) -> Result<ToolResult, ToolError>;
}

/// Opaque MCP pool surface for the core turn loop.
#[async_trait]
pub trait McpPoolPort: Send + Sync {
    async fn execute_tool(&self, tool_name: &str, input: Value) -> Result<ToolResult, ToolError>;
}