SimComHandler.h

 
#ifndef SIM_TO_DUT_INTERFACE_SIMCOMHANDLER_H
#define SIM_TO_DUT_INTERFACE_SIMCOMHANDLER_H
 
#include "../Events/SimEvent.h"
#include "../SystemConfig.h"
#include "../SimToDuTInterface.h"
#include <zmq.hpp>
 
namespace sim_interface {
    // Forward declaration to avoid looping
    class SimToDuTInterface;
 
    class SimComHandler {
    public:
 
        SimComHandler(SimToDuTInterface *interface, const SystemConfig &config);
 
        ~SimComHandler();
 
        void sendEventToSim(const SimEvent &simEvent);
 
        void receive();
 
        void getConfig();
 
        enum connectorType {
            RESTDummyConnector,
            CANConnector,
            V2XConnector,
            Invalid_Connector
        };
 
        connectorType resolveConnectorTypeForSwitch(std::string connectorTypeS);
 
        void run();
 
        void unbindPublisher();
 
        void disconnectSubscriber();
 
        void disconnectReceiveConfig();
 
        void close();
 
 
    private:
        void sendEventToInterface(const SimEvent &simEvent);
 
        zmq::socket_t socketSimSub_; 
        zmq::socket_t socketSimPub_; 
        zmq::socket_t socketSimSubConfig_; 
        std::string socketSimAddressSub; 
        std::string socketSimAddressPub; 
        std::string socketSimAddressReceiverConfig; 
        std::thread simComHandlerThread; 
        bool stopThread = true; 
        SimToDuTInterface *interface; 
    };
}
 
#endif //SIM_TO_DUT_INTERFACE_SIMCOMHANDLER_H