http_client.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2024, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include "internal/core/messaging_client.h"
#include "internal/http/http_types.h"
#include "internal/http/http_parser.h"
#include "kcenon/network/detail/utils/result_types.h"
#include <string>
#include <map>
#include <vector>
#include <memory>
#include <chrono>
#include <optional>
 
namespace kcenon::network::core
{
    struct http_url
    {
        std::string scheme;      // http or https
        std::string host;        // hostname or IP
        unsigned short port = 0; // port number (0 = default)
        std::string path;        // URI path
        std::map<std::string, std::string> query; // query parameters
 
        static auto parse(const std::string& url) -> Result<http_url>;
 
        auto get_default_port() const -> unsigned short;
    };
 
    class http_client : public std::enable_shared_from_this<http_client>
    {
    public:
        http_client();
 
        explicit http_client(std::chrono::milliseconds timeout_ms);
 
        ~http_client() = default;
 
        auto get(const std::string& url,
                 const std::map<std::string, std::string>& query = {},
                 const std::map<std::string, std::string>& headers = {})
            -> Result<internal::http_response>;
 
        auto post(const std::string& url,
                  const std::string& body,
                  const std::map<std::string, std::string>& headers = {})
            -> Result<internal::http_response>;
 
        auto post(const std::string& url,
                  const std::vector<uint8_t>& body,
                  const std::map<std::string, std::string>& headers = {})
            -> Result<internal::http_response>;
 
        auto put(const std::string& url,
                 const std::string& body,
                 const std::map<std::string, std::string>& headers = {})
            -> Result<internal::http_response>;
 
        auto del(const std::string& url,
                 const std::map<std::string, std::string>& headers = {})
            -> Result<internal::http_response>;
 
        auto head(const std::string& url,
                  const std::map<std::string, std::string>& headers = {})
            -> Result<internal::http_response>;
 
        auto patch(const std::string& url,
                   const std::string& body,
                   const std::map<std::string, std::string>& headers = {})
            -> Result<internal::http_response>;
 
        auto set_timeout(std::chrono::milliseconds timeout_ms) -> void;
 
        auto get_timeout() const -> std::chrono::milliseconds;
 
    private:
        auto request(internal::http_method method,
                     const std::string& url,
                     const std::vector<uint8_t>& body,
                     const std::map<std::string, std::string>& headers,
                     const std::map<std::string, std::string>& query)
            -> Result<internal::http_response>;
 
        auto build_request(internal::http_method method,
                           const http_url& url_info,
                           const std::vector<uint8_t>& body,
                           const std::map<std::string, std::string>& headers)
            -> internal::http_request;
 
        std::chrono::milliseconds timeout_;
    };
 
} // namespace kcenon::network::core