http_server.h

Go to the documentation of this file.

 
#pragma once
 
#include <neograph/api.h>
#include <neograph/mcp/server.h>
 
#include <chrono>
#include <cstddef>
#include <functional>
#include <memory>
#include <optional>
#include <string>
#include <string_view>
#include <vector>
 
namespace neograph::mcp {
 
struct NEOGRAPH_API MCPHttpServerSession {
    std::unique_ptr<MCPServer> server;
 
    std::shared_ptr<void> owner;
};
 
struct NEOGRAPH_API MCPHttpServerConfig {
    using BearerAuthorizer = std::function<std::optional<std::string>(std::string_view token)>;
 
    std::string host     = "127.0.0.1";
    int         port     = 0;
    std::string endpoint = "/mcp";
 
    std::size_t               max_sessions        = 64;
    std::size_t               max_payload_bytes   = 1024 * 1024;
    std::size_t               http_threads        = 8;
    std::size_t               max_http_threads    = 64;
    std::size_t               max_queued_requests = 64;
    std::chrono::milliseconds response_timeout    = std::chrono::minutes(10);
    std::chrono::milliseconds session_idle_timeout = std::chrono::minutes(30);
 
    std::vector<std::string> allowed_origins;
 
    std::vector<std::string> allowed_hosts;
 
    BearerAuthorizer bearer_authorizer;
 
    json protected_resource_metadata;
};
 
class NEOGRAPH_API MCPHttpServer {
public:
    using ServerFactory = std::function<MCPHttpServerSession(std::string_view authorization_scope)>;
 
    MCPHttpServer(ServerFactory factory, MCPHttpServerConfig config = {});
    ~MCPHttpServer();
 
    MCPHttpServer(const MCPHttpServer&)            = delete;
    MCPHttpServer& operator=(const MCPHttpServer&) = delete;
 
    bool start();
 
    bool start_async();
 
    void stop();
 
    bool is_running() const;
    int  port() const;
 
private:
    struct Impl;
    std::unique_ptr<Impl> impl_;
};
 
}  // namespace neograph::mcp