http_client.h

Go to the documentation of this file.

 
#pragma once
 
#include <neograph/api.h>
 
#include <asio/awaitable.hpp>
#include <asio/any_io_executor.hpp>
 
#include <chrono>
#include <cstddef>
#include <functional>
#include <string>
#include <string_view>
#include <utility>
#include <vector>
 
namespace neograph::async {
 
struct NEOGRAPH_API HttpResponse {
    int         status = 0;
    std::string body;
 
    std::string retry_after;
 
    std::string location;
 
    std::vector<std::pair<std::string, std::string>> headers;
 
    std::string_view get_header(std::string_view name) const noexcept;
};
 
struct RequestOptions {
    std::chrono::milliseconds timeout{0};
 
    std::chrono::milliseconds connect_timeout{0};
 
    bool allow_replay = false;
 
    int max_redirects = 0;
 
    std::size_t max_response_header_bytes = 64 * 1024;
 
    std::size_t max_response_body_bytes = 16 * 1024 * 1024;
 
    std::size_t max_response_chunk_bytes = 1024 * 1024;
};
 
NEOGRAPH_API asio::awaitable<HttpResponse> async_post(
    asio::any_io_executor ex,
    std::string_view host,
    std::string_view port,
    std::string_view path,
    std::string_view body,
    std::vector<std::pair<std::string, std::string>> headers = {},
    bool tls = false,
    RequestOptions opts = {});
 
NEOGRAPH_API asio::awaitable<HttpResponse> async_get(
    asio::any_io_executor ex,
    std::string_view host,
    std::string_view port,
    std::string_view path,
    std::vector<std::pair<std::string, std::string>> headers = {},
    bool tls = false,
    RequestOptions opts = {});
 
struct HttpStreamResponse {
    int status = 0;
};
 
NEOGRAPH_API asio::awaitable<HttpStreamResponse> async_post_stream(
    asio::any_io_executor ex,
    std::string_view host,
    std::string_view port,
    std::string_view path,
    std::string_view body,
    std::vector<std::pair<std::string, std::string>> headers,
    bool tls,
    std::function<void(std::string_view chunk)> on_chunk,
    RequestOptions opts = {});
 
struct NEOGRAPH_API HttpResponseHead {
    int status = 0;
    std::vector<std::pair<std::string, std::string>> headers;
 
    std::string_view get_header(std::string_view name) const noexcept;
};
 
NEOGRAPH_API asio::awaitable<HttpStreamResponse> async_request_stream(
    asio::any_io_executor ex,
    std::string_view method,
    std::string_view host,
    std::string_view port,
    std::string_view target,
    std::string_view body,
    std::vector<std::pair<std::string, std::string>> headers,
    bool tls,
    std::function<void(const HttpResponseHead&)> on_head,
    std::function<void(std::string_view chunk)> on_chunk,
    RequestOptions opts = {});
 
} // namespace neograph::async