client.h

Go to the documentation of this file.

// Copyright (C) 2018-2021 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 <http/http_thread_pool.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(asiolink::IOService& io_service, 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 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