asio_http.hpp

#ifndef NOOS_CLOUD_ASIO_HTTP
#define NOOS_CLOUD_ASIO_HTTP
/*
 * LICENSE HERE
 */
#include "includes.ihh"
#include <boost/asio.hpp>
#include <noos/cloud/asio/asio_handler.hpp>
namespace noos {
namespace cloud {
class asio_http 
: public asio_handler<http_socket, asio_http>
{
public:
    asio_http(
                std::function<void(std::string)> cloud_callback,
                std::function<void(error_code)> error_callback,
                boost::asio::io_service & io_service,
                const bool keep_alive,
                boost::asio::streambuf & request
             );

    void begin(
                boost::asio::ip::tcp::resolver::query & query,
                boost::asio::ip::tcp::resolver & resolver,
                unsigned int timeout
              );

    void send(
                boost::asio::ip::tcp::resolver::query & query,
                boost::asio::ip::tcp::resolver & resolver,
                unsigned int timeout,
                boost::asio::streambuf & request
             );

    void shutdown(boost::system::error_code);

    void stop_timeout();

    bool is_connected() const;

private:
    friend asio_handler<http_socket,asio_http>;

    // resolve endpoint/hostname
    void resolve(
                   boost::system::error_code  err,
                   boost::asio::ip::tcp::resolver::iterator endpoint_iterator
                );

    // begin connection
    void connect(
                   const boost::system::error_code err,
                   boost::asio::ip::tcp::resolver::iterator endpoint_iterator
                );

    // check if we have timed out
    void time_check(const boost::system::error_code & ec);

    // members
    std::function<void(boost::system::error_code)> error_;
    std::function<void(std::string)> callback_;
    std::shared_ptr<http_socket> socket_;
    boost::asio::streambuf & request_;
    std::shared_ptr<boost::asio::deadline_timer> deadline_;
    std::atomic<bool> connected_ = { false };
};
}
}
#endif