LomMessageProcessor.hpp

Go to the documentation of this file.

#ifndef IV_SRC_COMMS_CAN_LOMMESSAGEPROCESSOR_HPP
#define IV_SRC_COMMS_CAN_LOMMESSAGEPROCESSOR_HPP
 
#include "AbstractMessageProcessor.hpp"
#include "comms/can/CMessageCan.hpp"
 
#include <threads/Thread.hpp>
 
namespace iv::comms::can
{
 
class LomCommunicationController;
 
class LomMessageProcessor final : public iv::comms::can::AbstractMessageProcessor,
                                  public std::enable_shared_from_this<LomMessageProcessor>
{
    friend class LomMessageProcessorFrame;
 
public:
    explicit LomMessageProcessor(const std::shared_ptr<iv::comms::can::LomCommunicationController> &controller,
                                 iv::comms::eLomLine line);
    LomMessageProcessor(const LomMessageProcessor &other) = delete;
    LomMessageProcessor(LomMessageProcessor &&other) = delete;
    ~LomMessageProcessor() override;
 
    LomMessageProcessor &operator=(const LomMessageProcessor &other) = delete;
    LomMessageProcessor &operator=(LomMessageProcessor &&other) = delete;
 
    void initialize();
 
    void processDigitalInput(const std::shared_ptr<CMessageCan> &message, uint16_t offset) const;
    void processAlarm(const std::shared_ptr<CMessageCan> &message) const;
    void processAnalogInput(const std::shared_ptr<CMessageCan> &message) const;
    void proccessHeartbeat(const std::shared_ptr<CMessageCan> &message) const;
    void processCommand(const std::shared_ptr<CMessageCan> &message) const;
    void processAlarmTimestamp(const std::shared_ptr<CMessageCan> &message) const;
    static void processAlarmGroupsStatus(const std::shared_ptr<CMessageCan> &message);
 
private:
    [[nodiscard]] bool frameProcess() const;
    std::shared_ptr<iv::comms::can::LomCommunicationController> m_controller;
    std::unique_ptr<iv::threads::Thread> m_thread;
    iv::comms::eLomLine m_line;
};
 
}// namespace iv::comms::can
 
#endif//IV_SRC_COMMS_CAN_LOMMESSAGEPROCESSOR_HPP