Struct RequestContext 

pub struct RequestContext {
    pub request_id: String,
    pub user_id: Option<String>,
    pub session_id: Option<String>,
    pub client_id: Option<String>,
    pub timestamp: Timestamp,
    pub start_time: Instant,
    pub metadata: Arc<HashMap<String, Value>>,
    pub cancellation_token: Option<Arc<CancellationToken>>,
    /* private fields */
}

Context information for request processing

Fields

request_id: String

Unique request identifier

user_id: Option<String>

User identifier (if authenticated)

session_id: Option<String>

Session identifier

client_id: Option<String>

Client identifier

timestamp: Timestamp

Request timestamp

start_time: Instant

Request start time for performance tracking

metadata: Arc<HashMap<String, Value>>

Custom metadata

cancellation_token: Option<Arc<CancellationToken>>

Cancellation token

Implementations

impl RequestContext

pub fn new() -> RequestContext

Create a new request context

Examples

use turbomcp_core::RequestContext;

let ctx = RequestContext::new();
assert!(!ctx.request_id.is_empty());
assert!(ctx.user_id.is_none());
assert!(ctx.session_id.is_none());
assert!(ctx.metadata.is_empty());

pub fn is_authenticated(&self) -> bool

Return true if the request is authenticated according to context metadata

Examples

use turbomcp_core::RequestContext;

let ctx = RequestContext::new()
    .with_metadata("authenticated", true);
assert!(ctx.is_authenticated());

let unauth_ctx = RequestContext::new();
assert!(!unauth_ctx.is_authenticated());

pub fn user(&self) -> Option<&str>

Return user id if present

pub fn roles(&self) -> Vec<String>

Return roles from auth.roles metadata, if present

pub fn has_any_role<S>(&self, required: &[S]) -> bool

where S: AsRef<str>,

Return true if the user has any of the required roles

pub fn with_id(id: impl Into<String>) -> RequestContext

Create a request context with specific ID

pub fn with_user_id(self, user_id: impl Into<String>) -> RequestContext

Set the user ID

pub fn with_session_id(self, session_id: impl Into<String>) -> RequestContext

Set the session ID

pub fn with_client_id(self, client_id: impl Into<String>) -> RequestContext

Set the client ID

pub fn with_metadata( self, key: impl Into<String>, value: impl Into<Value>, ) -> RequestContext

Add metadata

pub fn with_cancellation_token( self, token: Arc<CancellationToken>, ) -> RequestContext

Set cancellation token

pub fn elapsed(&self) -> Duration

Get elapsed time since request started

pub fn is_cancelled(&self) -> bool

Check if request is cancelled

pub fn get_metadata(&self, key: &str) -> Option<&Value>

Get metadata value

pub fn derive(&self) -> RequestContext

Clone with new request ID (for sub-requests)

pub fn with_elicitation_context( self, context: ElicitationContext, ) -> RequestContext

Add elicitation context for server-initiated user input

pub fn elicitation_context(&self) -> Option<ElicitationContext>

Get elicitation context if present

pub fn with_completion_context( self, context: CompletionContext, ) -> RequestContext

Add completion context for autocompletion requests

pub fn completion_context(&self) -> Option<CompletionContext>

Get completion context if present

pub fn with_resource_template_context( self, context: ResourceTemplateContext, ) -> RequestContext

Add resource template context for parameterized resources

pub fn resource_template_context(&self) -> Option<ResourceTemplateContext>

Get resource template context if present

pub fn with_ping_context(self, context: PingContext) -> RequestContext

Add ping context for health monitoring

pub fn ping_context(&self) -> Option<PingContext>

Get ping context if present

pub fn with_bidirectional_context( self, context: BidirectionalContext, ) -> RequestContext

Add bidirectional communication context

pub fn bidirectional_context(&self) -> Option<BidirectionalContext>

Get bidirectional context if present

pub fn is_server_initiated(&self) -> bool

Check if this is a server-initiated request

pub fn is_client_initiated(&self) -> bool

Check if this is a client-initiated request (default/traditional)

pub fn communication_direction(&self) -> CommunicationDirection

Get communication direction

pub fn for_elicitation(schema: Value, prompt: Option<String>) -> RequestContext

Create context for server-initiated elicitation request

pub fn for_completion(completion_ref: CompletionReference) -> RequestContext

Create context for completion request

pub fn for_resource_template( template_name: String, uri_template: String, ) -> RequestContext

Create context for resource template operation

pub fn for_ping(origin: PingOrigin) -> RequestContext

Create context for ping request

Trait Implementations

impl Clone for RequestContext

fn clone(&self) -> RequestContext

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RequestContext

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

Formats the value using the given formatter.

impl Default for RequestContext

fn default() -> RequestContext

Returns the “default value” for a type.

impl RequestContextExt for RequestContext

fn with_enhanced_client_id(self, client_id: ClientId) -> RequestContext

Set client ID using ClientId enum

fn extract_client_id( self, extractor: &ClientIdExtractor, headers: Option<&HashMap<String, String>>, query_params: Option<&HashMap<String, String>>, ) -> RequestContext

Extract and set client ID from headers and query params

fn get_enhanced_client_id(&self) -> Option<ClientId>

Get the enhanced client ID

impl SamplingExt for RequestContext

fn create_message<'life0, 'async_trait>( &'life0 self, request: CreateMessageRequest, ) -> Pin<Box<dyn Future<Output = ServerResult<CreateMessageResult>> + Send + 'async_trait>>

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

Send a sampling/createMessage request to the client

fn elicit<'life0, 'async_trait>( &'life0 self, request: ElicitRequest, ) -> Pin<Box<dyn Future<Output = ServerResult<ElicitResult>> + Send + 'async_trait>>

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

Send an elicitation request to the client for user input

fn list_roots<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ServerResult<ListRootsResult>> + Send + 'async_trait>>

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

List client’s root capabilities