Struct MCPServer

pub struct MCPServer { /* private fields */ }

Main MCP server implementation

Implementations

impl MCPServer

pub fn new(config: MCPServerConfig) -> Self

Create a new MCP server

pub fn with_dht(self, dht: Arc<RwLock<DHT>>) -> Self

Create MCP server with DHT integration

pub async fn start(&self) -> Result<()>

Start the MCP server

pub async fn register_tool(&self, tool: Tool) -> Result<()>

Register a tool

pub async fn call_tool( &self, tool_name: &str, arguments: Value, context: MCPCallContext, ) -> Result<Value>

Call a tool by name

pub async fn list_tools( &self, _cursor: Option<String>, ) -> Result<(Vec<MCPTool>, Option<String>)>

List available tools

pub async fn get_stats(&self) -> MCPServerStats

Get server statistics

pub async fn discover_remote_services(&self) -> Result<Vec<MCPService>>

Discover remote services in the network

pub async fn call_remote_tool( &self, peer_id: &PeerId, tool_name: &str, arguments: Value, context: MCPCallContext, ) -> Result<Value>

Call a tool on a remote node

pub async fn handle_p2p_message( &self, message_data: &[u8], source_peer: &PeerId, ) -> Result<Option<Vec<u8>>>

Handle incoming P2P MCP message

pub async fn generate_auth_token( &self, peer_id: &PeerId, permissions: Vec<MCPPermission>, ttl: Duration, ) -> Result<String>

Generate authentication token for peer

pub async fn verify_auth_token(&self, token: &str) -> Result<TokenPayload>

Verify authentication token

pub async fn check_permission( &self, peer_id: &PeerId, permission: &MCPPermission, ) -> Result<bool>

Check if peer has permission for operation

pub async fn check_rate_limit(&self, peer_id: &PeerId) -> Result<bool>

Check rate limit for peer

pub async fn grant_permission( &self, peer_id: &PeerId, permission: MCPPermission, ) -> Result<()>

Grant permission to peer

pub async fn revoke_permission( &self, peer_id: &PeerId, permission: &MCPPermission, ) -> Result<()>

Revoke permission from peer

pub async fn add_trusted_peer(&self, peer_id: PeerId) -> Result<()>

Add trusted peer

pub async fn is_trusted_peer(&self, peer_id: &PeerId) -> bool

Check if peer is trusted

pub async fn set_tool_security_policy( &self, tool_name: String, level: SecurityLevel, ) -> Result<()>

Set security policy for tool

pub async fn get_tool_security_policy(&self, tool_name: &str) -> SecurityLevel

Get security policy for tool

pub async fn get_peer_security_stats(&self, peer_id: &PeerId) -> Option<PeerACL>

Get peer security statistics

pub async fn get_security_audit( &self, limit: Option<usize>, ) -> Vec<SecurityAuditEntry>

Get recent security audit entries

pub async fn security_cleanup(&self) -> Result<()>

Perform security housekeeping

pub async fn shutdown(&self) -> Result<()>

Shutdown the server