#ifndef IPC_H
#define IPC_H

#include <queue>
#include <mutex>
#include <condition_variable>
#include <memory>
#include <optional>
#include "tser/tser.hpp"
#include "Serialize.h"
#include "PluginInterface.h"  // Include your IPlugin interface header
#include "Command.h"  // Include your Command structure header
#include <glog/logging.h>

class IPC
{
public:
    IPC();
    ~IPC();

    void registerHandler(std::shared_ptr<IPlugin> handler);
    void sendMessage(const Command &cmd);
    std::optional<Command> receiveMessage();

private:
    std::queue<std::string> messageQueue;
    std::vector<std::shared_ptr<IPlugin>> handlers;
    std::mutex queueMutex;
    std::condition_variable queueCondVar;
};

#endif // IPC_H