MRMCPGatewayMlTransport.h

Go to the documentation of this file.

#pragma once
 
#include "MRMcp/MRFastmcpp.h"
 
#pragma warning(push)
#pragma warning(disable: 4127) 
#pragma warning(disable: 4800) 
#include <httplib.h>
#pragma warning(pop)
 
#include <atomic>
#include <condition_variable>
#include <mutex>
#include <string>
 
namespace MR::McpGateway
{

class MLClientTransport final : public fastmcpp::client::ITransport
{
public:
    MLClientTransport( const std::string& targetUrl,
                       const std::string& ssePath,
                       const std::string& messagesPath );
    ~MLClientTransport() override;
 
    fastmcpp::Json request( const std::string& route, const fastmcpp::Json& payload ) override;
 
private:
    struct HostPort { std::string host; int port = 80; };
    static HostPort parseHostPort( const std::string& url );

    MLClientTransport( const HostPort& hp,
                       const std::string& ssePath,
                       const std::string& messagesPath );
 
private:
    httplib::Client httpForSse_;
    httplib::sse::SSEClient sse_;
    httplib::Client httpForPost_;
 
    std::string messagesPath_;
    mutable std::mutex sessionMutex_;
    std::condition_variable sessionCv_;
    std::string sessionId_;
    std::atomic<int64_t> nextId_{ 1 };
};
 
}