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/transport/transport.hpp"
 
namespace mcp::transport {
 
struct ProcessStdioClientTransportOptions {
  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 ProcessStdioClientTransport final : public ClientTransport {
 public:
  explicit ProcessStdioClientTransport(
      ProcessStdioClientTransportOptions options);
  ~ProcessStdioClientTransport() override;
 
  ProcessStdioClientTransport(const ProcessStdioClientTransport&) = delete;
  ProcessStdioClientTransport& operator=(const ProcessStdioClientTransport&) =
      delete;
 
  std::string_view name() const noexcept override;
  protocol::Json diagnostics() const override;
  core::Result<core::Unit> send(TxMessage message) override;
  core::Result<std::optional<RxMessage>> receive() override;
  core::Result<core::Unit> close() override;
 
 private:
  class Impl;
 
  std::unique_ptr<Impl> impl_;
};
 
}  // namespace mcp::transport