Struct OpenApiServer

pub struct OpenApiServer {
    pub spec_location: OpenApiSpecLocation,
    pub registry: Arc<ToolRegistry>,
    pub http_client: HttpClient,
    pub base_url: Option<Url>,
}

Fields

spec_location: OpenApiSpecLocation

registry: Arc<ToolRegistry>

http_client: HttpClient

base_url: Option<Url>

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 async fn load_openapi_spec(&mut self) -> Result<(), OpenApiError>

Load the OpenAPI specification from the configured location

Errors

Returns an error if the spec cannot be loaded or registered

pub fn register_spec(&mut self, spec: OpenApiSpec) -> Result<(), OpenApiError>

Register a spec into the registry. This requires exclusive access to the server.

Errors

Returns an error if the registry is already shared or if spec registration fails

pub fn tool_count(&self) -> usize

Get the number of registered 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_registry_stats(&self) -> ToolRegistryStats

Get registry statistics

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

Validate the registry integrity

Errors

Returns an error if the registry validation fails

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