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"
#include "platforms/is_platform.h"
 
// Forward declaration for hostent (platform-specific type)
struct hostent;
 
namespace fl {
namespace net {
namespace http {
 
namespace detail {
bool build_http_request(const RequestOptions& options, const fl::string& path,
                        const fl::string& host, fl::string* out) FL_NO_EXCEPT;
}  // namespace detail

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) FL_NO_EXCEPT;

    ~FetchRequest() FL_NO_EXCEPT;

    void update() FL_NO_EXCEPT;

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

    State get_state() const FL_NO_EXCEPT { return mState; }
 
private:
    State mState;
    fl::task::Promise<Response> mPromise;
    RequestOptions mOptions;  // method, headers and body to send
 
    // Parsed URL
    fl::url mParsedUrl;
    fl::string mHostname;
    int mPort;
    fl::string mPath;
 
    // Socket state
#ifdef FL_IS_WIN
    // Winsock's SOCKET is UINT_PTR. Holding it in an int truncated the handle
    // on 64-bit Windows and made the `< 0` failure check always false.
    using SocketHandle = fl::uptr;
#else
    using SocketHandle = int;
#endif
    SocketHandle 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() FL_NO_EXCEPT;
    void handle_connecting() FL_NO_EXCEPT;
    void handle_sending() FL_NO_EXCEPT;
    void handle_receiving() FL_NO_EXCEPT;
 
    // Completion helpers
    void complete_success(const Response& resp) FL_NO_EXCEPT;
    void complete_error(const char* message) FL_NO_EXCEPT;
 
    // Utilities
    Response parse_http_response(const fl::string& raw) FL_NO_EXCEPT;
    void close_socket() FL_NO_EXCEPT;
};
 
} // namespace http
} // namespace net
} // namespace fl