#pragma once
// Project Includes
#include "file_descriptor.hpp"
#include "http.hpp"
#include "server.hpp"
#include "uring_context.hpp"
// Standard Library Includes
#include <cassert>
#include <cstddef>
#include <vector>
// Third-Party Library Includes
#include <exec/repeat_effect_until.hpp>
#include <exec/static_thread_pool.hpp>
#include <exec/task.hpp>

struct Client
{
    FileDescriptor m_fd;
    UringContext &m_uring_ctx;
    std::vector<std::byte> m_buffer;
    RequestList m_completed_requests;
    HttpRequestParser m_parser;
    bool m_disconnect_requested;

    Client() = delete;

    Client(FileDescriptor fd, UringContext &uring_ctx)
        : m_fd(std::move(fd)), m_uring_ctx(uring_ctx), m_buffer(std::vector<std::byte>(4096)),
          m_disconnect_requested(false)
    {
    }
};

/**
 * @brief Asynchronously handles a client connection.
 *
 * @param client_fd
 * @param ctx
 * @param uring_ctx
 * @return kev::task<void>
 */
kev::task<void> handle_connection_coroutine(FileDescriptor client_fd, ServerContext &ctx, UringContext &uring_ctx);