commands_handler.h

#pragma once
 
#include "base_detection_module.h"
#include "control_status.h"
#include "remote_command.h"
#include "stream_broadcaster.h"
#include <cstddef>
#include <esp_http_server.h>
 
class CommandsWebSocketHandler
{
public:
    CommandsWebSocketHandler(httpd_handle_t server_handle, const char* uri, BaseDetectionModule* detection = nullptr,
                             const BaseStatusProvider* status = nullptr, remote::BaseRemoteSink* remote = nullptr,
                             const StreamBroadcaster* stream = nullptr);
 
    ~CommandsWebSocketHandler();
 
    void register_endpoint();
 
    void unregister_endpoint();
 
    static constexpr size_t kMaxMessage = 64;
 
    static esp_err_t pre_handshake(httpd_req_t* req);
 
    static esp_err_t post_handshake(httpd_req_t* req);
 
    static esp_err_t websocket_handler(httpd_req_t* req);
 
private:
    size_t build_reply(char* out, size_t size) const;
 
    httpd_handle_t _server_handle;
    const char* _uri;
    BaseDetectionModule* _detection_instance;
    const BaseStatusProvider* _status_provider;
    remote::BaseRemoteSink* _remote;
    const StreamBroadcaster* _stream;
};