fetch_request.h

Go to the documentation of this file.

#pragma once
 
#include "fl/task/promise.h"
#include "fl/net/http/fetch.h"  // Includes response class  // IWYU pragma: keep
#include "fl/stl/string.h"
#include "fl/stl/url.h"
#include "fl/stl/int.h"
#include "fl/stl/noexcept.h"
 
// Forward declaration for hostent (platform-specific type)
struct hostent;
 
namespace fl {
namespace net {
namespace http {

class FetchRequest {
public:
    enum State {
        DNS_LOOKUP,      
        CONNECTING,      
        SENDING,         
        RECEIVING,       
        COMPLETED,       
        FAILED           
    };

    FetchRequest(const fl::string& url, const FetchOptions& opts, fl::task::Promise<Response> promise);

    ~FetchRequest() FL_NOEXCEPT;

    void update();

    bool is_done() const { return mState == COMPLETED || mState == FAILED; }

    State get_state() const { return mState; }
 
private:
    State mState;
    fl::task::Promise<Response> mPromise;
 
    // Parsed URL
    fl::url mParsedUrl;
    fl::string mHostname;
    int mPort;
    fl::string mPath;
 
    // Socket state
    int mSocketFd;
    ::hostent* mDnsResult;  // Use global namespace to avoid conflict
 
    // Send/receive buffers
    fl::string mRequestBuffer;
    fl::string mResponseBuffer;
    size_t mBytesSent;
 
    // Timeouts
    u32 mStateStartTime;
 
    // State handlers
    void handle_dns_lookup();
    void handle_connecting();
    void handle_sending();
    void handle_receiving();
 
    // Completion helpers
    void complete_success(const Response& resp);
    void complete_error(const char* message);
 
    // Utilities
    Response parse_http_response(const fl::string& raw);
    void close_socket();
};
 
} // namespace http
} // namespace net
} // namespace fl