handler.hpp

Go to the documentation of this file.

// Copyright (c) 2025 [caomengxuan666]
 
#pragma once
 
 
#include <utility>
 
#include "cxxmcp/client/client.hpp"
 
namespace mcp::client {
 
inline core::Error handler_method_not_found(std::string_view message) {
  return core::Error{
      static_cast<int>(protocol::ErrorCode::MethodNotFound),
      std::string(message),
      {},
  };
}
 
struct ClientHandlerInterface {
  using InitializedHandler = Client::InitializedHandler;
  using CancelledHandler = Client::CancelledHandler;
  using LoggingMessageHandler = Client::LoggingMessageHandler;
  using ChangedHandler = Client::ListChangedHandler;
  using ResourceUpdatedHandler = Client::ResourceUpdatedHandler;
  using ProgressHandler = Client::ProgressHandler;
  using ElicitationCompleteHandler = Client::ElicitationCompleteHandler;
  using TaskStatusHandler = Client::TaskStatusHandler;
  using RootsListRequestHandler = Client::RootsListRequestHandler;
  using SamplingRequestHandler = Client::SamplingRequestHandler;
  using ElicitationRequestHandler = Client::ElicitationRequestHandler;
  using CustomRequestHandler = Client::CustomRequestHandler;
  using RawNotificationHandler = Client::RawNotificationHandler;
 
  virtual ~ClientHandlerInterface() = default;
 
  virtual void on_initialized() const {}
  virtual void on_cancelled(const protocol::RequestId&,
                            std::string_view) const {}
  virtual void on_logging_message(std::string_view, std::string_view) const {}
  virtual void on_tool_list_changed() const {}
  virtual void on_prompt_list_changed() const {}
  virtual void on_resource_list_changed() const {}
  virtual void on_resource_updated(const std::string&) const {}
  virtual void on_progress(const protocol::ProgressNotificationParams&) const {}
  virtual void on_elicitation_complete(std::string_view) const {}
  virtual void on_task_status(const protocol::Task&) const {}
  virtual void on_roots_list_changed() const {}
  virtual std::optional<core::Result<protocol::RootsListResult>>
  on_list_roots_request() const {
    return std::nullopt;
  }
  virtual std::optional<core::Result<protocol::RootsListResult>>
  on_list_roots_request(CancellationToken cancellation) const {
    (void)cancellation;
    return on_list_roots_request();
  }
  virtual std::optional<core::Result<protocol::CreateMessageResult>>
  on_create_message_request(const protocol::CreateMessageParams&) const {
    return std::nullopt;
  }
  virtual std::optional<core::Result<protocol::CreateMessageResult>>
  on_create_message_request(const protocol::CreateMessageParams& params,
                            CancellationToken cancellation) const {
    (void)cancellation;
    return on_create_message_request(params);
  }
  virtual std::optional<core::Result<protocol::CreateElicitationResult>>
  on_create_elicitation_request(
      const protocol::CreateElicitationRequestParam&) const {
    return std::nullopt;
  }
  virtual std::optional<core::Result<protocol::CreateElicitationResult>>
  on_create_elicitation_request(
      const protocol::CreateElicitationRequestParam& params,
      CancellationToken cancellation) const {
    (void)cancellation;
    return on_create_elicitation_request(params);
  }
  virtual std::optional<core::Result<protocol::Json>> on_custom_request(
      const protocol::JsonRpcRequest&) const {
    return std::nullopt;
  }
  virtual std::optional<core::Result<protocol::Json>> on_custom_request(
      const protocol::JsonRpcRequest& request,
      CancellationToken cancellation) const {
    (void)cancellation;
    return on_custom_request(request);
  }
  virtual void on_raw_notification(const protocol::JsonRpcNotification&) const {
  }
};
 
struct ClientHandler {
  using InitializedHandler = Client::InitializedHandler;
  using CancelledHandler = Client::CancelledHandler;
  using LoggingMessageHandler = Client::LoggingMessageHandler;
  using ChangedHandler = Client::ListChangedHandler;
  using ResourceUpdatedHandler = Client::ResourceUpdatedHandler;
  using ProgressHandler = Client::ProgressHandler;
  using ElicitationCompleteHandler = Client::ElicitationCompleteHandler;
  using TaskStatusHandler = Client::TaskStatusHandler;
  using RootsListRequestHandler = Client::RootsListRequestHandler;
  using SamplingRequestHandler = Client::SamplingRequestHandler;
  using ElicitationRequestHandler = Client::ElicitationRequestHandler;
  using CustomRequestHandler = Client::CustomRequestHandler;
  using RawNotificationHandler = Client::RawNotificationHandler;
 
  InitializedHandler on_initialized;
  CancelledHandler on_cancelled;
  LoggingMessageHandler on_logging_message;
  ChangedHandler on_tool_list_changed;
  ChangedHandler on_prompt_list_changed;
  ChangedHandler on_resource_list_changed;
  ResourceUpdatedHandler on_resource_updated;
  ProgressHandler on_progress;
  ElicitationCompleteHandler on_elicitation_complete;
  TaskStatusHandler on_task_status;
  ChangedHandler on_roots_list_changed;
  RootsListRequestHandler on_list_roots_request;
  Client::RootsListRequestCancellationHandler
      on_list_roots_request_with_cancellation;
  SamplingRequestHandler on_create_message_request;
  Client::SamplingRequestCancellationHandler
      on_create_message_request_with_cancellation;
  ElicitationRequestHandler on_create_elicitation_request;
  Client::ElicitationRequestCancellationHandler
      on_create_elicitation_request_with_cancellation;
  CustomRequestHandler on_custom_request;
  Client::CustomRequestCancellationHandler on_custom_request_with_cancellation;
  RootsListRequestHandler on_roots_list_request;
  Client::RootsListRequestCancellationHandler
      on_roots_list_request_with_cancellation;
  SamplingRequestHandler on_sampling_request;
  Client::SamplingRequestCancellationHandler
      on_sampling_request_with_cancellation;
  ElicitationRequestHandler on_elicitation_request;
  Client::ElicitationRequestCancellationHandler
      on_elicitation_request_with_cancellation;
  RawNotificationHandler on_raw_notification;
  RawNotificationHandler on_custom_notification;
 
  void apply_to(Client& client) const {
    if (on_initialized) {
      client.on_initialized(on_initialized);
    }
    if (on_cancelled) {
      client.on_cancelled(on_cancelled);
    }
    if (on_logging_message) {
      client.on_logging_message(on_logging_message);
    }
    if (on_tool_list_changed) {
      client.on_tool_list_changed(on_tool_list_changed);
    }
    if (on_prompt_list_changed) {
      client.on_prompt_list_changed(on_prompt_list_changed);
    }
    if (on_resource_list_changed) {
      client.on_resource_list_changed(on_resource_list_changed);
    }
    if (on_resource_updated) {
      client.on_resource_updated(on_resource_updated);
    }
    if (on_progress) {
      client.on_progress(on_progress);
    }
    if (on_elicitation_complete) {
      client.on_elicitation_complete(on_elicitation_complete);
    }
    if (on_task_status) {
      client.on_task_status(on_task_status);
    }
    if (on_roots_list_changed) {
      client.on_roots_list_changed(on_roots_list_changed);
    }
    if (on_list_roots_request) {
      client.on_list_roots_request(on_list_roots_request);
    }
    if (on_list_roots_request_with_cancellation) {
      client.on_list_roots_request(on_list_roots_request_with_cancellation);
    }
    if (on_create_message_request) {
      client.on_create_message_request(on_create_message_request);
    }
    if (on_create_message_request_with_cancellation) {
      client.on_create_message_request(
          on_create_message_request_with_cancellation);
    }
    if (on_create_elicitation_request) {
      client.on_create_elicitation_request(on_create_elicitation_request);
    }
    if (on_create_elicitation_request_with_cancellation) {
      client.on_create_elicitation_request(
          on_create_elicitation_request_with_cancellation);
    }
    if (on_custom_request) {
      client.on_custom_request(on_custom_request);
    }
    if (on_custom_request_with_cancellation) {
      client.on_custom_request(on_custom_request_with_cancellation);
    }
    if (on_roots_list_request) {
      client.on_roots_list_request(on_roots_list_request);
    }
    if (on_roots_list_request_with_cancellation) {
      client.on_roots_list_request(on_roots_list_request_with_cancellation);
    }
    if (on_sampling_request) {
      client.on_sampling_request(on_sampling_request);
    }
    if (on_sampling_request_with_cancellation) {
      client.on_sampling_request(on_sampling_request_with_cancellation);
    }
    if (on_elicitation_request) {
      client.on_elicitation_request(on_elicitation_request);
    }
    if (on_elicitation_request_with_cancellation) {
      client.on_elicitation_request(on_elicitation_request_with_cancellation);
    }
    if (on_raw_notification) {
      client.on_raw_notification(on_raw_notification);
    }
    if (on_custom_notification) {
      client.on_custom_notification(on_custom_notification);
    }
  }
};
 
inline Client& Client::set_handler(const ClientHandler& handler) {
  handler.apply_to(*this);
  return *this;
}
 
inline Client& Client::set_handler(const ClientHandlerInterface& handler) {
  on_initialized([&handler]() { handler.on_initialized(); });
  on_cancelled([&handler](const protocol::RequestId& request_id,
                          std::string_view reason) {
    handler.on_cancelled(request_id, reason);
  });
  on_logging_message(
      [&handler](std::string_view level, std::string_view message) {
        handler.on_logging_message(level, message);
      });
  on_tool_list_changed([&handler]() { handler.on_tool_list_changed(); });
  on_prompt_list_changed([&handler]() { handler.on_prompt_list_changed(); });
  on_resource_list_changed(
      [&handler]() { handler.on_resource_list_changed(); });
  on_resource_updated(
      [&handler](const std::string& uri) { handler.on_resource_updated(uri); });
  on_progress([&handler](const protocol::ProgressNotificationParams& params) {
    handler.on_progress(params);
  });
  on_elicitation_complete([&handler](std::string_view elicitation_id) {
    handler.on_elicitation_complete(elicitation_id);
  });
  on_task_status(
      [&handler](const protocol::Task& task) { handler.on_task_status(task); });
  on_roots_list_changed([&handler]() { handler.on_roots_list_changed(); });
  on_list_roots_request([&handler](CancellationToken cancellation)
                            -> core::Result<protocol::RootsListResult> {
    const auto response = handler.on_list_roots_request(cancellation);
    if (response.has_value()) {
      return std::move(*response);
    }
    return mcp::core::unexpected(
        handler_method_not_found("client handler does not handle list_roots"));
  });
  on_create_message_request(
      [&handler](const protocol::CreateMessageParams& params,
                 CancellationToken cancellation)
          -> core::Result<protocol::CreateMessageResult> {
        const auto response =
            handler.on_create_message_request(params, cancellation);
        if (response.has_value()) {
          return std::move(*response);
        }
        return mcp::core::unexpected(handler_method_not_found(
            "client handler does not handle create_message"));
      });
  on_create_elicitation_request(
      [&handler](const protocol::CreateElicitationRequestParam& params,
                 CancellationToken cancellation)
          -> core::Result<protocol::CreateElicitationResult> {
        const auto response =
            handler.on_create_elicitation_request(params, cancellation);
        if (response.has_value()) {
          return std::move(*response);
        }
        return mcp::core::unexpected(handler_method_not_found(
            "client handler does not handle elicitation"));
      });
  on_custom_request(
      [&handler](
          const protocol::JsonRpcRequest& request,
          CancellationToken cancellation) -> core::Result<protocol::Json> {
        const auto response = handler.on_custom_request(request, cancellation);
        if (response.has_value()) {
          return std::move(*response);
        }
        return mcp::core::unexpected(handler_method_not_found(
            "client handler does not handle custom request"));
      });
  on_raw_notification(
      [&handler](const protocol::JsonRpcNotification& notification) {
        handler.on_raw_notification(notification);
      });
  return *this;
}
 
}  // namespace mcp::client