mcp4k-runtime/sh.ondr.mcp4k.runtime/McpComponent

McpComponent

abstract class McpComponent(transport: Transport, logIncoming: suspend (String) -> Unit = {}, logOutgoing: suspend (String) -> Unit = {}, coroutineContext: CoroutineContext = Dispatchers.Default)

Base component for MCP clients/servers. Handles request/response & notification routing, serialization, and connection lifecycle.

Inheritors

Constructors

constructor(transport: Transport, logIncoming: suspend (String) -> Unit = {}, logOutgoing: suspend (String) -> Unit = {}, coroutineContext: CoroutineContext = Dispatchers.Default)

Functions

handleCallToolRequest

open suspend fun handleCallToolRequest(params: CallToolRequest.CallToolParams): CallToolResult

handleCompleteRequest

open suspend fun handleCompleteRequest(params: CompleteRequest.CompleteParams): CompleteResult

handleCreateMessageRequest

open suspend fun handleCreateMessageRequest(params: CreateMessageRequest.CreateMessageParams): CreateMessageResult

handleGetPromptRequest

open suspend fun handleGetPromptRequest(params: GetPromptRequest.GetPromptParams): GetPromptResult

handleInitializeRequest

open suspend fun handleInitializeRequest(params: InitializeRequest.InitializeParams): InitializeResult

handleListPromptsRequest

open suspend fun handleListPromptsRequest(params: ListPromptsRequest.ListPromptsParams?): ListPromptsResult

handleListResourcesRequest

open suspend fun handleListResourcesRequest(params: ListResourcesRequest.ListResourcesParams?): ListResourcesResult

handleListResourceTemplatesRequest

open suspend fun handleListResourceTemplatesRequest(params: ListResourceTemplatesRequest.ListResourceTemplatesParams?): ListResourceTemplatesResult

handleListRootsRequest

open suspend fun handleListRootsRequest(): ListRootsResult

handleListToolsRequest

open suspend fun handleListToolsRequest(params: ListToolsRequest.ListToolsParams?): ListToolsResult

handlePingRequest

open suspend fun handlePingRequest(params: PingRequest.PingParams?): EmptyResult

handleReadResourceRequest

open suspend fun handleReadResourceRequest(params: ReadResourceRequest.ReadResourceParams): ReadResourceResult

handleSetLoggingLevelRequest

open suspend fun handleSetLoggingLevelRequest(params: SetLoggingLevelRequest.SetLoggingLevelParams): EmptyResult

handleSubscribeRequest

open suspend fun handleSubscribeRequest(params: SubscribeRequest.SubscribeParams): EmptyResult

handleUnsubscribeRequest

open suspend fun handleUnsubscribeRequest(params: UnsubscribeRequest.UnsubscribeParams): EmptyResult

sendNotification

suspend fun sendNotification(notification: JsonRpcNotification)

Sends a notification (fire-and-forget).

suspend fun sendRequest(builder: (id: String) -> JsonRpcRequest): JsonRpcResponse

Sends a request and suspends until a corresponding response is received or this coroutine is cancelled.

suspend fun start()

Starts reading/writing from the given transport.