http_transport.hpp

Go to the documentation of this file.

// Copyright (c) 2025 [caomengxuan666]
 
#pragma once
 
 
#include <chrono>
#include <functional>
#include <memory>
#include <optional>
#include <string>
#include <unordered_map>
 
#include "cxxmcp/client/client.hpp"
 
namespace mcp::client {
 
struct HttpAuthChallenge {
  int status_code = 0;
  std::string method;
  std::unordered_map<std::string, std::string> headers;
  std::optional<std::string> www_authenticate;
};
 
struct HttpTransportOptions {
  std::string uri;
 
  std::string host;
 
  int port = 80;
 
  std::string path = "/";
 
  std::unordered_map<std::string, std::string> headers;
 
  std::optional<std::string> auth_header;
 
  HttpAuthRefreshHandler auth_refresh_handler;
 
  std::chrono::milliseconds timeout{30000};
};
 
class HttpTransport final : public Transport {
 public:
  explicit HttpTransport(HttpTransportOptions options);
 
  ~HttpTransport() override;
 
  core::Result<protocol::JsonRpcResponse> send(
      const protocol::JsonRpcRequest& request) override;
 
  core::Result<core::Unit> send_notification(
      const protocol::JsonRpcNotification& notification) override;
 
  core::Result<core::Unit> start(
      TransportRequestHandler request_handler,
      TransportNotificationHandler notification_handler = {}) override;
 
  void stop() noexcept override;
 
  void set_negotiated_protocol_version(std::string version);
 
 private:
  struct Impl;
  std::unique_ptr<Impl> impl_;
};
 
}  // namespace mcp::client