Communicator.h

#pragma once

#include <string>
#include <queue>
#include <map>
#include <iostream>
#include <fstream>

#include "messages/IMessage.h"
#include "sensors/ISensorManager.h"
#include "Hardware.h"
#include "Thread.h"
#include "hardwareinterface/IHardwareInterface.h"
#include "exceptions/DuplicateHardwareException.h"
#include <mutex>

class Communicator : public Thread {

public:
    Communicator(ISensorManager* sensorManager);

    ~Communicator();

    void registerHardware(Hardware hardware, IHardwareInterface* interface);

    void queueMessage(IMessage* message);

    void queueMessage(std::list<IMessage*>* messages);

    void* run() override;

private:
    ISensorManager* sensorManager;
    std::map<Hardware, IMessage*>* messageMap;
    std::map<Hardware, IHardwareInterface*>* hardwareInterfaceMap;
    std::list<IHardwareInterface*>* hardwareInterfaces;

    std::mutex m_lock;

    void write();

    void read();

};