ORIONIS API REFERENCE

THE ORIONIS API

Build with clarity.

Explore the building blocks of an async-first Python framework. Every module, class, and method — connected, searchable, and ready to build with.

Explore modules View classes

orionis.mcp.transport.http.McpHttpTransport

class documentation

class McpHttpTransport: (source)

Constructor: McpHttpTransport(app, compiled, config, bus)

View In Hierarchy

Serve a registered endpoint without owning routes, sessions or identities.

Method __init__ Retain immutable server metadata and one shared protocol dispatcher.
Method _error Encode a sanitized protocol error with its required HTTP status.
Method _params Decode method parameters and validate compiled tool parameter headers.
Async Method _read Bound the native body stream before allocating the complete message.
Method _release Release a single request or response-stream admission slot.
Method _validateHttp Reject origins and unsupported media types before reading a body.
Async Method handle Validate HTTP metadata, dispatch once, and return native response objects.
Class Variable __slots__ Undocumented
Instance Variable _active Undocumented
Instance Variable _compiled Undocumented
Instance Variable _config Undocumented
Instance Variable _dispatcher Undocumented
Instance Variable _origins Undocumented
def __init__(self, app: IApplication, compiled: CompiledMcpServer, config: McpConfig, bus: IMcpEventBus): (source)

Retain immutable server metadata and one shared protocol dispatcher.

Parameters
app:IApplicationApplication container supplying configuration and dependencies.
compiled:CompiledMcpServerPrecompiled metadata shared by request executions.
config:McpConfigValidated configuration controlling this component.
bus:IMcpEventBusValue supplied for bus.
Returns
NoneComplete the documented operation without returning a value.
def _error(self, exception: McpProtocolException, request_id: str | int | msgspec.UnsetType) -> Response: (source)

Encode a sanitized protocol error with its required HTTP status.

Parameters
exception:McpProtocolExceptionException being inspected or reported.
request_id:str | int | msgspec.UnsetTypeValue supplied for request_id.
Returns
ResponseResult of the operation described above.
def _params(self, request: Request, envelope: JsonRpcRequest) -> RequestParams: (source)

Decode method parameters and validate compiled tool parameter headers.

Parameters
request:RequestCurrent request and its trusted execution context.
envelope:JsonRpcRequestValue supplied for envelope.
Returns
RequestParamsResult of the operation described above.
async def _read(self, request: Request) -> bytes: (source)

Bound the native body stream before allocating the complete message.

Parameters
request:RequestCurrent request and its trusted execution context.
Returns
bytesResult of the operation described above.
def _release(self): (source)

Release a single request or response-stream admission slot.

Returns
NoneComplete the documented operation without returning a value.
def _validateHttp(self, request: Request): (source)

Reject origins and unsupported media types before reading a body.

Parameters
request:RequestCurrent request and its trusted execution context.
Returns
NoneComplete the documented operation without returning a value.
async def handle(self, request: Request) -> Response: (source)

Validate HTTP metadata, dispatch once, and return native response objects.

Parameters
request:RequestCurrent request and its trusted execution context.
Returns
ResponseResult of the operation described above.
__slots__: tuple[str, ...] = (source)

Undocumented

_active: int = (source)

Undocumented

_compiled = (source)

Undocumented

_config = (source)

Undocumented

_dispatcher = (source)

Undocumented

_origins = (source)

Undocumented