#ifndef IPC_H
#define IPC_H

#include <msgpack.h>
#include <optional>
#include <queue>
#include <mutex>
#include <condition_variable>
#include "Command.h"
#include "PluginInterface.h"

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

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

#endif // IPC_H