codetether-agent 4.7.0-a-002.4

A2A-native AI coding agent for the CodeTether ecosystem
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

//! Hot-load MCP plugin servers at runtime.

use anyhow::Result;
use std::path::Path;
use std::process::Command;

/// A hot-loaded plugin instance.
#[derive(Debug)]
pub struct LoadedPlugin {
    pub name: String,
    pub pid: u32,
    pub endpoint: String,
    pub capabilities: Vec<String>,
}

/// Start a plugin MCP server subprocess.
pub fn start_plugin(name: &str, binary_path: &Path, port: u16) -> Result<LoadedPlugin> {
    let child = Command::new(binary_path)
        .env("MCP_PORT", port.to_string())
        .env("PLUGIN_NAME", name)
        .spawn()?;
    let pid = child.id();
    tracing::info!(name, pid, port, "Plugin MCP server started");
    Ok(LoadedPlugin {
        name: name.to_string(),
        pid,
        endpoint: format!("http://127.0.0.1:{port}"),
        capabilities: Vec::new(),
    })
}

/// Stop a running plugin.
pub fn stop_plugin(plugin: &LoadedPlugin) -> Result<()> {
    tracing::info!(name = %plugin.name, pid = %plugin.pid, "Stopping plugin");
    #[cfg(unix)]
    {
        if plugin.pid > i32::MAX as u32 {
            anyhow::bail!("Invalid PID: {}", plugin.pid);
        }
        let ret = unsafe { libc::kill(plugin.pid as i32, libc::SIGTERM) };
        if ret != 0 {
            anyhow::bail!(
                "Failed to send SIGTERM to plugin {}: errno {}",
                plugin.name,
                ret
            );
        }
    }
    Ok(())
}