Struct McpToolContext 

#[non_exhaustive]
pub struct McpToolContext {
    pub auth: AuthContext,
    pub request: RequestMetadata,
    /* private fields */
}

Context for MCP tool execution.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

auth: AuthContext

request: RequestMetadata

Implementations

impl McpToolContext

pub fn new(db_pool: PgPool, auth: AuthContext, request: RequestMetadata) -> Self

Create a new MCP tool context.

pub fn with_dispatch( db_pool: PgPool, auth: AuthContext, request: RequestMetadata, job_dispatch: Option<Arc<dyn JobDispatch>>, workflow_dispatch: Option<Arc<dyn WorkflowDispatch>>, ) -> Self

Create a context with dispatch capabilities.

pub fn with_env( db_pool: PgPool, auth: AuthContext, request: RequestMetadata, job_dispatch: Option<Arc<dyn JobDispatch>>, workflow_dispatch: Option<Arc<dyn WorkflowDispatch>>, env_provider: Arc<dyn EnvProvider>, ) -> Self

Create a context with a custom environment provider.

pub fn with_http_client(self, client: CircuitBreakerClient) -> Self

Set the HTTP client. Called by the runtime to inject the shared client.

pub fn set_kv(&mut self, kv: Arc<dyn KvHandle>)

Attach a KV store handle. Called by the runtime before handing the context to the handler.

pub fn kv(&self) -> Result<&dyn KvHandle>

Access the KV store.

pub fn db(&self) -> ForgeDb

pub fn db_conn(&self) -> DbConn<'_>

Get a DbConn for use in shared helper functions.

pub async fn conn(&self) -> Result<ForgeConn<'static>>

Acquire a connection compatible with sqlx compile-time checked macros.

pub fn http(&self) -> HttpClient

Get the HTTP client for external requests.

pub fn raw_http(&self) -> &Client

Get the raw reqwest client, bypassing circuit breaker execution.

pub fn set_http_timeout(&mut self, timeout: Option<Duration>)

Set the default timeout for outbound HTTP requests.

pub fn user_id(&self) -> Result<Uuid>

Get the authenticated user’s UUID. Returns 401 if not authenticated.

pub fn tenant_id(&self) -> Option<Uuid>

Get the tenant ID from JWT claims, if present.

pub async fn dispatch_job<T: Serialize>( &self, job_type: &str, args: T, ) -> Result<Uuid>

Dispatch a background job.

pub async fn dispatch<J: ForgeJob>(&self, args: J::Args) -> Result<Uuid>

Type-safe dispatch: resolves the job name from the type’s ForgeJob impl and serializes the args at the call site.

pub async fn cancel_job( &self, job_id: Uuid, reason: Option<String>, ) -> Result<bool>

Request cancellation for a job.

pub async fn start_workflow<T: Serialize>( &self, workflow_name: &str, input: T, ) -> Result<Uuid>

Start a workflow.

pub async fn start<W: ForgeWorkflow>(&self, input: W::Input) -> Result<Uuid>

Type-safe workflow start.

Trait Implementations

impl AuthenticatedContext for McpToolContext

fn user_id(&self) -> Result<Uuid>

Returns the authenticated user’s UUID, or Unauthorized if the request is not authenticated or the subject is not a UUID.

fn tenant_id(&self) -> Option<Uuid>

Returns the tenant ID from the tenant_id JWT claim, if present.

impl EnvAccess for McpToolContext

fn env_provider(&self) -> &dyn EnvProvider

fn env(&self, key: &str) -> Option<String>

fn env_or(&self, key: &str, default: &str) -> String

fn env_require(&self, key: &str) -> Result<String>

fn env_parse<T: FromStr>(&self, key: &str) -> Result<T>

where T::Err: Display,

fn env_parse_or<T: FromStr>(&self, key: &str, default: T) -> Result<T>

where T::Err: Display,

Returns the default when unset; errors only if the variable is set but unparseable.

fn env_contains(&self, key: &str) -> bool

impl HandlerContext for McpToolContext

fn db(&self) -> ForgeDb

Database handle with automatic db.query tracing spans.

fn db_conn(&self) -> DbConn<'_>

Unified connection handle for shared helper functions.