#ifndef TCPSERVERPLUGIN_H
#define TCPSERVERPLUGIN_H

#include "PluginInterface.h"
#include "IPC.h"
#include <nlohmann/json.hpp>
#include <memory>
#include <TcpServer.h>
#include <glog/logging.h>

class TcpServerPlugin : public IPlugin {
public:
    TcpServerPlugin(IPC *ipc);
    ~TcpServerPlugin();

    void handleMessage(const Command& cmd) override;
    void updateConfig(const nlohmann::json& config) override;
    const std::string getPluginName() override;

    void onClientConnect(sockets::ClientHandle client);
    void onClientDisconnect(sockets::ClientHandle client, const sockets::SocketRet& ret);
    void onReceiveClientData(sockets::ClientHandle client, const char* data, size_t size);

    const std::string plugin_name = "TcpServer";

private:
    void startServer();
    void stopServer();

    IPC *ipc;
    nlohmann::json config;
    bool running;
    std::unique_ptr<sockets::TcpServer<TcpServerPlugin>> server;
};

extern "C" IPlugin* create(IPC * ipc);

#endif // TCPSERVERPLUGIN_H