Struct AuthMiddleware 

pub struct AuthMiddleware { /* private fields */ }

Authentication middleware that adds auth headers.

Examples

use pmcp::shared::{AuthMiddleware, Middleware};
use pmcp::types::{JSONRPCRequest, RequestId};

// Create auth middleware with API token
let auth_middleware = AuthMiddleware::new("Bearer api-token-12345".to_string());

let mut request = JSONRPCRequest {
    jsonrpc: "2.0".to_string(),
    method: "resources.read".to_string(),
    params: Some(serde_json::json!({"uri": "file:///secure/data.txt"})),
    id: RequestId::from(789i64),
};

// Process request and add authentication
auth_middleware.on_request(&mut request).await?;

// In a real implementation, the middleware would modify the request
// to include authentication information

Implementations

impl AuthMiddleware

pub fn new(auth_token: String) -> Self

Create a new auth middleware with the given token.

Trait Implementations

impl Debug for AuthMiddleware

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Middleware for AuthMiddleware

fn on_request<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 mut JSONRPCRequest, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called before a request is sent.

fn on_response<'life0, 'life1, 'async_trait>( &'life0 self, response: &'life1 mut JSONRPCResponse, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called after a response is received.

fn on_send<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 TransportMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called when a message is sent (any type).

fn on_receive<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 TransportMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called when a message is received (any type).

fn on_notification<'life0, 'life1, 'async_trait>( &'life0 self, notification: &'life1 mut JSONRPCNotification, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called when an unsolicited notification is received.