process_stdio_transport.hpp

Go to the documentation of this file.

// Copyright (c) 2025 [caomengxuan666]
 
#pragma once
 
 
#include <chrono>
#include <memory>
#include <optional>
#include <string>
#include <unordered_map>
#include <vector>
 
#include "cxxmcp/client/client.hpp"
 
namespace mcp::client {
 
struct ProcessStdioTransportOptions {
  std::string command;
 
  std::vector<std::string> args;
 
  std::string cwd;
 
  std::unordered_map<std::string, std::string> env;
 
  std::optional<std::chrono::milliseconds> request_timeout =
      std::chrono::seconds(30);
};
 
class ProcessStdioTransport final : public Transport {
 public:
  explicit ProcessStdioTransport(ProcessStdioTransportOptions options);
 
  ~ProcessStdioTransport() override;
 
  ProcessStdioTransport(const ProcessStdioTransport&) = delete;
  ProcessStdioTransport& operator=(const ProcessStdioTransport&) = delete;
 
  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;
 
 private:
  class Impl;
 
  ProcessStdioTransportOptions options_;
  std::unique_ptr<Impl> impl_;
};
 
}  // namespace mcp::client