CurlHttpClient.h

 
#pragma once
 
#include <aws/core/Core_EXPORTS.h>
#include <aws/core/http/HttpClient.h>
#include <aws/core/http/curl/CurlHandleContainer.h>
#include <aws/core/client/ClientConfiguration.h>
#include <aws/core/utils/memory/stl/AWSString.h>
#include <atomic>
 
namespace Aws
{
namespace Http
{
namespace Standard
{
    class StandardHttpResponse;
}
 
//Curl implementation of an http client. Right now it is only synchronous.
class AWS_CORE_API CurlHttpClient: public HttpClient
{
public:
 
    using Base = HttpClient;
 
    //Creates client, initializes curl handle if it hasn't been created already.
    CurlHttpClient(const Aws::Client::ClientConfiguration& clientConfig);
 
    //Makes request and receives response synchronously
    std::shared_ptr<HttpResponse> MakeRequest(const std::shared_ptr<HttpRequest>& request,
        Aws::Utils::RateLimits::RateLimiterInterface* readLimiter = nullptr,
        Aws::Utils::RateLimits::RateLimiterInterface* writeLimiter = nullptr) const override;
 
    static void InitGlobalState();
    static void CleanupGlobalState();
 
protected:
    virtual void OverrideOptionsOnConnectionHandle(CURL*) const {}
 
private:
    mutable CurlHandleContainer m_curlHandleContainer;
    bool m_isAllowSystemProxy = false;
    bool m_isUsingProxy = false;
    Aws::String m_proxyUserName;
    Aws::String m_proxyPassword;
    Aws::String m_proxyScheme;
    Aws::String m_proxyHost;
    Aws::String m_proxySSLCertPath;
    Aws::String m_proxySSLCertType;
    Aws::String m_proxySSLKeyPath;
    Aws::String m_proxySSLKeyType;
    Aws::String m_proxyKeyPasswd;
    unsigned m_proxyPort = 0;
    Aws::String m_nonProxyHosts;
    bool m_verifySSL = true;
    Aws::String m_caPath;
    Aws::String m_caFile;
    Aws::String m_proxyCaPath;
    Aws::String m_proxyCaFile;
    bool m_disableExpectHeader = false;
    bool m_allowRedirects = false;
    bool m_enableHttpClientTrace = false;
    Aws::Http::TransferLibPerformanceMode m_perfMode = TransferLibPerformanceMode::LOW_LATENCY;
    static std::atomic<bool> isInit;
    std::shared_ptr<smithy::components::tracing::TelemetryProvider> m_telemetryProvider;
 
#if LIBCURL_VERSION_NUM >= 0x072000 // 7.32.0
    static int CurlProgressCallback(void *userdata, curl_off_t, curl_off_t, curl_off_t, curl_off_t);
#else
    static int CurlProgressCallback(void *userdata, double, double, double, double);
#endif
};
 
using PlatformHttpClient = CurlHttpClient;
 
} // namespace Http
} // namespace Aws