#pragma once

#include <napi.h>

#include "./zmq_inc.h"
#include "closable.h"

#ifdef ZMQ_HAS_STEERABLE_PROXY

namespace zmq {
class Module;

class Proxy : public Napi::ObjectWrap<Proxy>, public Closable {
public:
    static void Initialize(Module& module, Napi::Object& exports);

    explicit Proxy(const Napi::CallbackInfo& info);

    Proxy(const Proxy&) = delete;
    Proxy(Proxy&&) = delete;
    Proxy& operator=(const Proxy&) = delete;
    Proxy& operator=(Proxy&&) = delete;
    ~Proxy() override;

    void Close() override;

protected:
    inline Napi::Value Run(const Napi::CallbackInfo& info);

    inline void Pause(const Napi::CallbackInfo& info);
    inline void Resume(const Napi::CallbackInfo& info);
    inline void Terminate(const Napi::CallbackInfo& info);

    inline Napi::Value GetFrontEnd(const Napi::CallbackInfo& info);
    inline Napi::Value GetBackEnd(const Napi::CallbackInfo& info);

private:
    inline void SendCommand(const char* command);

    Napi::AsyncContext async_context;
    Napi::ObjectReference front_ref;
    Napi::ObjectReference back_ref;
    Napi::ObjectReference capture_ref;

    Module& module;
    void* control_sub = nullptr;
    void* control_pub = nullptr;
};
}  // namespace zmq

static_assert(!std::is_copy_constructible_v<zmq::Proxy>, "not copyable");
static_assert(!std::is_move_constructible_v<zmq::Proxy>, "not movable");

#endif