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>>,
}

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() -> Self

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: AsRef<str>>(&self, required: &[S]) -> bool

Return true if the user has any of the required roles

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

Create a request context with specific ID

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

Set the user ID

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

Set the session ID

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

Set the client ID

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

Add metadata

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

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) -> Self

Clone with new request ID (for sub-requests)

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

Formats the value using the given formatter.

impl Default for RequestContext

fn default() -> Self

Returns the “default value” for a type.

impl RequestContextExt for RequestContext

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

Set client ID using ClientId enum

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

Extract and set client ID from headers and query params

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

Get the enhanced client ID