Reactor.hpp

Go to the documentation of this file.

#pragma once
 
#include "AEventHandler.hpp"
#include "http/Router.hpp"
#include "http/HttpResponse.hpp"
#include <sys/types.h>
#include <vector>
 
namespace network {
 
enum RequestState { READING_HEADERS, READING_BODY, REQUEST_READY };
enum ResponseState { NOT_READY, SENDING, SENT };

class Reactor : public AEventHandler {
public:
    Reactor(int clientFd, int port, http::Router const &);
    ~Reactor();
 
    virtual void handleEvent(uint32_t events);
    virtual int getHandle() const;
 
private:
    Reactor(const Reactor &);
    Reactor &operator=(const Reactor &);
 
    // --- Core Connection State ---
    int clientFd_;
    int port_;
    http::Router const &router_;
    http::HttpResponse response_; 
 
    // --- Request State ---
    RequestState requestState_; 
    std::string requestBuffer_; 
    size_t bodyStart_;          
    size_t contentLength_;      
 
    // --- Response State ---
    std::vector<char> responseBuffer_; 
    ResponseState responseState_;      
    size_t sentResponseBytes_;         
 
    // --- Constants ---
    static const size_t IO_BUFFER_SIZE = 8192; 
 
    // --- Private Methods ---
    void handleRead();
    void handleWrite();
    void tryParseHeaders();
    void generateResponse();
    bool sendResponseBuffer();
    void clearResponseBuffer();
    void resetForNewRequest();
    void closeConnection();
};
 
} // namespace network