http_server.h

Go to the documentation of this file.

 
#pragma once
 
#include <neograph/api.h>
#include <neograph/acp/server.h>
 
#include <chrono>
#include <cstddef>
#include <functional>
#include <memory>
#include <optional>
#include <string>
#include <string_view>
#include <vector>
 
namespace neograph::acp {
 
struct NEOGRAPH_API ACPHttpConnection {
    std::shared_ptr<void> owner;
 
    std::unique_ptr<ACPServer> server;
};
 
struct NEOGRAPH_API ACPHttpConfig {
    using Authenticator =
        std::function<std::optional<std::string>(std::string_view authorization_header)>;
 
    std::string host = "127.0.0.1";
    int         port = 0;  
    std::string endpoint = "/acp";
 
    bool streamable_http = true;
    bool websocket = true;
 
    std::size_t max_connections = 16;
    std::size_t max_payload_bytes = 4 * 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 connection_idle_timeout = std::chrono::seconds(60);
    std::chrono::milliseconds keepalive_interval = std::chrono::seconds(15);
 
    std::vector<std::string> allowed_origins;
 
    std::vector<std::string> allowed_hosts;
 
    bool allow_client_mcp_servers = false;
 
    Authenticator authenticator;
};
 
class NEOGRAPH_API ACPHttpServer {
public:
    using ConnectionFactory = std::function<ACPHttpConnection(std::string_view principal)>;
 
    ACPHttpServer(ConnectionFactory factory, ACPHttpConfig config = {});
    ~ACPHttpServer();
 
    ACPHttpServer(const ACPHttpServer&)            = delete;
    ACPHttpServer& operator=(const ACPHttpServer&) = delete;
 
    bool start();
 
    bool start_async();
 
    void stop();
 
    bool is_running() const;
    int  port() const;
 
    std::size_t connection_count() const;
 
    std::shared_ptr<ACPClient> client();
 
    void attach_client(std::shared_ptr<ACPClient> client);
 
private:
    struct Impl;
    std::unique_ptr<Impl> impl_;
};
 
}  // namespace neograph::acp