CMessageCan.hpp

Go to the documentation of this file.

#ifndef LIBS_CAN_CMESSAGECAN_HPP_
#define LIBS_CAN_CMESSAGECAN_HPP_
 
#include "comms/IMessageComm.hpp"
#include "comms/can/enums.hpp"
#include "core/CEnumCommon.hpp"
#include "streams/IInputStream.hpp"
#include "streams/OutputStreamMemory.hpp"
#include "structs.hpp"
#include <linux/can.h>
 
class CMessageCan final : public iv::comms::IMessageComm
{
public:
    void getValuesDataMessageAlarm(iv::types::indexChannel *indexChannelOpt, uint8_t *idGroupForLomsOpt,
                                   uint8_t *typeAlarmOpt, float *valueAlarmOpt) const;
    void getValuesDataMessageAlarmTimestamp(iv::types::indexChannel *indexChannelOpt, uint16_t *numDaysSince1984Opt,
                                            uint32_t *millisecondsOpt) const;
    void getValuesDataMessageTimestamp(uint16_t *numDaysSince1984Opt, uint32_t *numMilliseconds1984Opt) const;
    void getValuesDataMessageAnalogInput(iv::types::unitId *idUnitOpt, iv::types::indexChannel *indexChannelOpt,
                                         uint8_t *typeDataOpt, uint32_t *valueOpt) const;
    void getValuesDataMessageText(iv::types::unitId *idUnitOpt, iv::types::indexChannel *indexChannelOpt,
                                  std::string *valueStringOpt, uint8_t *segmentPositionOpt, bool *isFirstSegmentOpt,
                                  bool *isLastSegmentOpt) const;
    void getValuesDataMessageCommand(iv::types::unitId *idUnitLocalDestOpt, iv::types::indexChannel *indexChannelOpt,
                                     uint8_t *commandOpt, uint32_t *valueOpt) const;
    void getValuesDataMessageCommandBool(iv::types::unitId *idUnitLocalDestOpt,
                                         iv::types::indexChannel *indexChannelOpt, uint8_t *commandOpt,
                                         bool *valueOpt) const;
    void getValuesDataMessageCommandChar(iv::types::unitId *idUnitLocalDestOpt,
                                         iv::types::indexChannel *indexChannelOpt, uint8_t *commandOpt,
                                         uint8_t *valueOpt) const;
    void getValuesDataMessageGmtSync(iv::types::unitId *idUnitStationOpt, int8_t *offsetGMTOpt,
                                     uint32_t *timeUTCOpt) const;
    void getValuesDataMessageHeartbeat(iv::comms::eHeartbeatState *heartbeatStateOpt, uint8_t *heartbeatTypeOpt) const;
    void getValuesDataMessageHistorySync(uint32_t *idStationOpt, iv::types::indexChannel *indexChannelOpt,
                                         uint8_t *typeAlarmAndStatusOpt, iv::types::timestamp *timeOpt) const;
 
 
    CMessageCan() = default;
    CMessageCan(std::string_view source, uint32_t msgId, const uint8_t bytes_[8], uint32_t timeStamp,
                uint32_t lengthData, bool isRTR, iv::types::subnetwork idSubnetwork, uint32_t lengthDataExtra,
                uint8_t **bytesDataExtra, bool isExtended);
    CMessageCan(const CMessageCan &other) = default;
    CMessageCan(CMessageCan &&other) = default;
    ~CMessageCan() override;
 
    CMessageCan &operator=(const CMessageCan &other) = delete;
    CMessageCan &operator=(CMessageCan &&other) = delete;
 
    [[nodiscard]] uint64_t lengthMessage() const;
    [[nodiscard]] iv::comms::IMessageComm *clone() const;
 
    [[nodiscard]] const std::string &getMessageSource() const;
    [[nodiscard]] iv::comms::can::eMessageType getMessageType() const;
 
    void getData(uint8_t *bytes_, uint32_t *lengthData) const;
    const uint8_t *getDataExtra(uint32_t *lengthDataExtra) const;
    [[nodiscard]] uint32_t getId() const;
    [[nodiscard]] uint32_t getIdUnit() const;
    [[nodiscard]] uint16_t getIdUnitLocal() const;
    [[nodiscard]] uint16_t getIdSubnetwork() const;
    [[nodiscard]] std::shared_ptr<iv::streams::IInputStream> getInputData() const;
    [[nodiscard]] std::shared_ptr<iv::streams::IInputStream> getInputStream() const;
    [[nodiscard]] uint32_t getLengthData() const;
    [[nodiscard]] bool getRtr() const;
    [[nodiscard]] bool getIsExtended() const;
    [[nodiscard]] uint32_t getTimeStamp() const;
    bool getTextInfo(bool &isInit, bool &isFinish, uint8_t &position) const;
 
    [[nodiscard]] bool isCan() const;
    [[nodiscard]] bool isCommand() const;
    [[nodiscard]] bool isCommandAck() const;
    bool isEqual(const iv::comms::IMessageComm *message) const;
    [[nodiscard]] bool isOkMessage() const;
 
    [[nodiscard]] std::vector<std::byte> toPcanGatewayPacket() const;
    bool deserialize(const std::vector<std::byte> &buffer) override;
    [[nodiscard]] std::vector<std::byte> serialize() const override
    {
        return {};
    };
    bool fromCanFrame(can_frame canFrame);
    [[nodiscard]] std::string toString() const;
 
    void getDigitalInputs(std::vector<bool> &inputs, uint32_t numBytes = 8) const;
 
    std::string m_sourceRef;
    iv::comms::can::CanDataMessage *m_messageDataCan {};
};
 
#endif /* LIBS_CAN_CMESSAGECAN_HPP_ */