Struct McpAuthMiddleware

pub struct McpAuthMiddleware { /* private fields */ }

MCP Authentication Middleware

Implementations

impl McpAuthMiddleware

pub fn new( auth_manager: Arc<AuthenticationManager>, config: McpAuthConfig, ) -> Self

Create a new MCP authentication middleware

pub fn with_security_validator( auth_manager: Arc<AuthenticationManager>, config: McpAuthConfig, security_validator: Arc<RequestSecurityValidator>, ) -> Self

Create with custom security validator

pub fn with_default_config(auth_manager: Arc<AuthenticationManager>) -> Self

Create middleware with default configuration

pub fn security_validator(&self) -> &RequestSecurityValidator

Get access to the security validator for monitoring violations

pub async fn process_request( &self, request: Request, headers: Option<&HashMap<String, String>>, ) -> Result<(Request, McpRequestContext), McpError>

Process an incoming MCP request

pub async fn process_response( &self, response: Response, _context: &McpRequestContext, ) -> Result<Response, McpError>

Process an outgoing MCP response

Trait Implementations

impl McpMiddleware for McpAuthMiddleware

fn process_request<'life0, 'life1, 'async_trait>( &'life0 self, request: Request, _context: &'life1 McpRequestContext, ) -> Pin<Box<dyn Future<Output = Result<Request, McpError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Process an incoming request

fn process_response<'life0, 'life1, 'async_trait>( &'life0 self, response: Response, context: &'life1 McpRequestContext, ) -> Pin<Box<dyn Future<Output = Result<Response, McpError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Process an outgoing response