HttpServer.h

#pragma once

#include <atomic>
#include <condition_variable>
#include <cstdint>
#include <mutex>
#include <string>
#include <thread>
#include <vector>

class HttpServer 
{
public:
    explicit HttpServer(int port);
    ~HttpServer();

    HttpServer(const HttpServer&) = delete;
    HttpServer& operator=(const HttpServer&) = delete;
    bool start();
    void stop();
    void pushFrame(std::vector<uint8_t> jpegData);

    int clientCount() const { return clientCount_.load(); }

private:
    void acceptLoop();
    void handleClient(int clientFd);
    bool sendAll(int fd, const char* data, size_t len);

    int port_;
    int listenFd_ = -1;
    std::atomic<bool> running_{false};
    std::thread acceptThread_;

    std::mutex frameMutex_;
    std::condition_variable frameCv_;
    std::vector<uint8_t> latestFrame_;
    uint64_t frameId_ = 0;

    std::atomic<int> clientCount_{0};
};