ApiDataLoggerCommunicationProtocol.hpp

Go to the documentation of this file.

#ifndef APIDATALOGGERPROTOCOL_HPP
#define APIDATALOGGERPROTOCOL_HPP
 
#include "comms/ICommunicationProtocol.hpp"
#include "comms/apis/ApiCommunicationDriver.hpp"
#include "comms/apis/IApiCommunicationProtocol.hpp"
#include "comms/apis/structs.hpp"
 
#include <memory>
#include <unordered_map>
 
namespace iv::comms::api::dataLogger
{
 
struct LoggerChannelInfo
{
    iv::types::channelId channelId;
    iv::types::channelValue value;
    iv::types::timestamp timestamp;
};
 
class ApiDataLoggerCommunicationProtocol final : public iv::comms::ICommunicationProtocol,
                                                 public iv::comms::api::IApiCommunicationProtocol
{
public:
    ApiDataLoggerCommunicationProtocol() = delete;
    ApiDataLoggerCommunicationProtocol(
            const std::shared_ptr<iv::comms::ICommunicationDriver> &driver,
            const std::shared_ptr<iv::model::comms::NetworkData> &networkData,
            const std::weak_ptr<iv::channels::AbstractChannel> &heartbeatChannel,
            const std::weak_ptr<iv::diamar::AppFailuresLoggerManager> &appFailuresLoggerManager, bool sendToCloud);
    ~ApiDataLoggerCommunicationProtocol() override = default;
 
    void registerValue(const std::shared_ptr<iv::comms::api::ILoggerMessage> &message) override;
    bool sendValues() override;
 
    iv::comms::api::ApiResponse getValues(const IApiQueryParamsBuilder &queryParams) const override;
 
    iv::comms::api::ApiDeleteResponse deleteValues(const IApiQueryParamsBuilder &queryParams) const override;
 
    bool sendUnitFile(const std::string &unitFileContent) const;
 
private:
    [[nodiscard]] bool isOnline() override
    {
        return m_driver->isOnline();
    }
 
    bool shouldSendValue(const std::string &channelId,
                         const iv::comms::api::dataLogger::DataLoggerMessage &channelValue) const;
 
    std::mutex m_channelsValuesMutex;
    mutable std::mutex m_httpRequestMutex;
    std::map<iv::types::channelId, LoggerChannelInfo> m_lastSentChannelsValues;
 
    std::map<iv::types::channelId, iv::comms::api::dataLogger::DataLoggerMessage> m_channelsValues;
 
    struct ValuesApi
    {
        static constexpr std::string_view route {"/data"};
 
        struct Fields
        {
            static constexpr std::string_view timestamp {"timestamp"};
            static constexpr std::string_view value {"value"};
            static constexpr std::string_view alarmPriority {"alarmPriority"};
            static constexpr std::string_view alarmState {"alarmState"};
            static constexpr std::string_view alarmType {"alarmType"};
            static constexpr std::string_view cloud {"cloud"};
        };
    };
    struct DataProjectApi
    {
        static constexpr std::string_view route {"/project/unit"};
        struct Fields
        {
            static constexpr std::string_view project {"unit"};
        };
    };
};
 
}// namespace iv::comms::api::dataLogger
 
#endif//APIDATALOGGERPROTOCOL_HPP