Struct OpenApiServer

pub struct OpenApiServer {
    pub spec_location: OpenApiSpecLocation,
    pub tools: Vec<OpenApiTool>,
    pub base_url: Option<Url>,
    pub default_headers: Option<HeaderMap>,
    pub tag_filter: Option<Vec<String>>,
    pub method_filter: Option<Vec<Method>>,
}

Fields

spec_location: OpenApiSpecLocation

tools: Vec<OpenApiTool>

base_url: Option<Url>

default_headers: Option<HeaderMap>

tag_filter: Option<Vec<String>>

method_filter: Option<Vec<Method>>

Implementations

impl OpenApiServer

pub fn new(spec_location: OpenApiSpecLocation) -> Self

pub fn with_base_url( spec_location: OpenApiSpecLocation, base_url: Url, ) -> Result<Self, OpenApiError>

Create a new server with a base URL for API calls

Errors

Returns an error if the base URL is invalid

pub fn with_base_url_and_headers( spec_location: OpenApiSpecLocation, base_url: Url, default_headers: HeaderMap, ) -> Result<Self, OpenApiError>

Create a new server with both base URL and default headers

Errors

Returns an error if the base URL is invalid

pub fn with_default_headers( spec_location: OpenApiSpecLocation, default_headers: HeaderMap, ) -> Self

Create a new server with default headers but no base URL

pub async fn load_openapi_spec(&mut self) -> Result<(), OpenApiError>

Load the OpenAPI specification and convert to OpenApiTool instances

Errors

Returns an error if the spec cannot be loaded or tools cannot be generated

pub fn tool_count(&self) -> usize

Get the number of loaded tools

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

Get all tool names

pub fn has_tool(&self, name: &str) -> bool

Check if a specific tool exists

pub fn get_tool(&self, name: &str) -> Option<&OpenApiTool>

Get a tool by name

pub fn get_tool_metadata(&self, name: &str) -> Option<&ToolMetadata>

Get tool metadata by name

pub fn get_tool_stats(&self) -> String

Get basic tool statistics

pub fn with_tags(self, tags: Option<Vec<String>>) -> Self

Set tag filter for this server instance

pub fn with_methods(self, methods: Option<Vec<Method>>) -> Self

Set method filter for this server instance

pub fn validate_registry(&self) -> Result<(), OpenApiError>

Simple validation - check that tools are loaded

Errors

Returns an error if no tools are loaded

Trait Implementations

impl Clone for OpenApiServer

fn clone(&self) -> OpenApiServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ServerHandler for OpenApiServer

fn get_info(&self) -> InitializeResult

async fn list_tools( &self, _request: Option<PaginatedRequestParam>, _context: RequestContext<RoleServer>, ) -> Result<ListToolsResult, ErrorData>

async fn call_tool( &self, request: CallToolRequestParam, _context: RequestContext<RoleServer>, ) -> Result<CallToolResult, ErrorData>

fn ping( &self, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + Send

fn initialize( &self, request: InitializeRequestParam, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<InitializeResult, ErrorData>> + Send

fn complete( &self, request: CompleteRequestParam, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CompleteResult, ErrorData>> + Send

fn set_level( &self, request: SetLevelRequestParam, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + Send

fn get_prompt( &self, request: GetPromptRequestParam, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetPromptResult, ErrorData>> + Send

fn list_prompts( &self, request: Option<PaginatedRequestParam>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListPromptsResult, ErrorData>> + Send

fn list_resources( &self, request: Option<PaginatedRequestParam>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListResourcesResult, ErrorData>> + Send

fn list_resource_templates( &self, request: Option<PaginatedRequestParam>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListResourceTemplatesResult, ErrorData>> + Send

fn read_resource( &self, request: ReadResourceRequestParam, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ReadResourceResult, ErrorData>> + Send

fn subscribe( &self, request: SubscribeRequestParam, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + Send

fn unsubscribe( &self, request: UnsubscribeRequestParam, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + Send

fn on_cancelled( &self, notification: CancelledNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + Send

fn on_progress( &self, notification: ProgressNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + Send

fn on_initialized( &self, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + Send

fn on_roots_list_changed( &self, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + Send