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 <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};
 
    int max_redirects = 0;
};
 
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 = {});
 
} // namespace neograph::async