client.h

Go to the documentation of this file.

// Copyright (C) 2018-2024 Internet Systems Consortium, Inc. ("ISC")
//
// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at http://mozilla.org/MPL/2.0/.
 
#ifndef HTTP_CLIENT_H
#define HTTP_CLIENT_H
 
#include <asiolink/io_service.h>
#include <asiolink/tls_socket.h>
#include <exceptions/exceptions.h>
#include <http/url.h>
#include <http/request.h>
#include <http/response.h>
#include <boost/shared_ptr.hpp>
#include <functional>
#include <string>
#include <thread>
#include <vector>
 
namespace isc {
namespace http {
 
class HttpClientError : public Exception {
public:
    HttpClientError(const char* file, size_t line, const char* what) :
        isc::Exception(file, line, what) { };
};
 
class HttpClientImpl;
 
class HttpClient {
public:
    struct RequestTimeout {
        explicit RequestTimeout(long value)
            : value_(value) {
        }
        long value_; 
    };
 
    typedef std::function<void(const boost::system::error_code&,
                               const HttpResponsePtr&,
                               const std::string&)> RequestHandler;
 
    typedef std::function<bool(const boost::system::error_code&, const int)> ConnectHandler;
 
    typedef std::function<bool(const boost::system::error_code&, const int)> HandshakeHandler;
 
    typedef std::function<void(const int)> CloseHandler;
 
    explicit HttpClient(const asiolink::IOServicePtr& io_service,
                        bool multi_threading_enabled,
                        size_t thread_pool_size = 0,
                        bool defer_thread_start = false);
 
    ~HttpClient();
 
    void asyncSendRequest(const Url& url,
                          const asiolink::TlsContextPtr& tls_context,
                          const HttpRequestPtr& request,
                          const HttpResponsePtr& response,
                          const RequestHandler& request_callback,
                          const RequestTimeout& request_timeout =
                          RequestTimeout(10000),
                          const ConnectHandler& connect_callback =
                          ConnectHandler(),
                          const HandshakeHandler& handshake_callback =
                          HandshakeHandler(),
                          const CloseHandler& close_callback =
                          CloseHandler());
 
    void checkPermissions();
 
    void start();
 
    void pause();
 
    void resume();
 
    void stop();
 
    void closeIfOutOfBand(int socket_fd);
 
    const asiolink::IOServicePtr getThreadIOService() const;
 
    uint16_t getThreadPoolSize() const;
 
    uint16_t getThreadCount() const;
 
    bool isRunning();
 
    bool isStopped();
 
    bool isPaused();
 
private:
 
    boost::shared_ptr<HttpClientImpl> impl_;
};
 
typedef boost::shared_ptr<HttpClient> HttpClientPtr;
 
} // end of namespace isc::http
} // end of namespace isc
 
#endif