transport.hpp

Go to the documentation of this file.

// Copyright (c) 2025 [caomengxuan666]
 
#pragma once
 
 
#include <optional>
#include <string_view>
 
#include "cxxmcp/core/result.hpp"
#include "cxxmcp/protocol/types.hpp"
#include "cxxmcp/roles.hpp"
 
namespace mcp::transport {
 
template <class Role>
struct MessageTraits {
  using TxMessage = protocol::JsonRpcMessage;
  using RxMessage = protocol::JsonRpcMessage;
};
 
template <class Role>
class Transport {
 public:
  using TxMessage = typename MessageTraits<Role>::TxMessage;
  using RxMessage = typename MessageTraits<Role>::RxMessage;
 
  virtual ~Transport() = default;
 
  virtual std::string_view name() const noexcept = 0;
 
  virtual protocol::Json diagnostics() const {
    return protocol::Json::object();
  }
 
  virtual core::Result<core::Unit> send(TxMessage message) = 0;
 
  virtual core::Result<std::optional<RxMessage>> receive() = 0;
 
  virtual core::Result<std::optional<RxMessage>> receive_response(
      const protocol::RequestId& id) {
    (void)id;
    return mcp::core::unexpected(
        core::Error{static_cast<int>(protocol::ErrorCode::MethodNotFound),
                    "transport does not route reverse responses directly",
                    {}});
  }
 
  virtual void publish_subscription_notification(std::string_view method,
                                                 protocol::Json params) {
    (void)method;
    (void)params;
  }
 
  virtual core::Result<core::Unit> close() = 0;
 
  virtual void wait_until_ready() {}
};
 
using ClientTransport = Transport<RoleClient>;
using ServerTransport = Transport<RoleServer>;
 
}  // namespace mcp::transport