http_request.hpp

Go to the documentation of this file.

#pragma once
#ifndef HTTP_REQUEST_HPP
#define HTTP_REQUEST_HPP

#include "settings.hpp"
#include <server/http/request_parser.hpp>
#include <array>

class HttpServer;
class Tile;
class RequestManager;

class HttpRequest : public boost::enable_shared_from_this<HttpRequest>, private boost::noncopyable
{
    friend class HttpRequestParser;
public:
    
    struct Header {
        std::string name;
        std::string value;
    };
    
    struct RequestData {
        std::string method;
        std::string uri;
        int http_version_major;
        int http_version_minor;
        std::vector<Header> headers;
    };
    
    class Reply
    {
    public:
        enum StatusType {
            ok = 200,
            created = 201,
            accepted = 202,
            no_content = 204,
            multiple_choices = 300,
            moved_permanently = 301,
            moved_temporarily = 302,
            not_modified = 304,
            bad_request = 400,
            unauthorized = 401,
            forbidden = 403,
            not_found = 404,
            internal_server_error = 500,
            not_implemented = 501,
            bad_gateway = 502,
            service_unavailable = 503,
        };
        StatusType status;
        std::vector<Header> headers;
        std::string content;
        shared_ptr<Tile> tile;
        std::vector<boost::asio::const_buffer> toBuffers();
    };
    
public:
    explicit HttpRequest ( boost::asio::io_service &ioService, const shared_ptr<HttpServer>& server, const shared_ptr<RequestManager> &manager );

    TESTABLE const string& getURL() const;

    TESTABLE void answer ( const  shared_ptr<Tile>& tile, Reply::StatusType status = Reply::ok );
    TESTABLE void answer ( Reply::StatusType status );
    void startCollectingData();

    void close();

    boost::asio::ip::tcp::socket &getSocket();
private:
    void handleRead ( const boost::system::error_code &e, std::size_t bytes_transferred );

    void handleWrite ( const boost::system::error_code &e );

    void answer();
    bool checkifAnswered();
    void readSome();
    
protected:
    bool answered;
    Reply reply;
    RequestData data;
private:
    
    boost::asio::ip::tcp::socket socket;
    std::array<char, 8192> buffer;
    HttpRequestParser parser;
    
    weak_ptr<RequestManager> manager;
    weak_ptr<HttpServer> server;
};


#endif