ApiCommunicationController.hpp

Go to the documentation of this file.

#ifndef APICOMMUNICATIONCONTROLLER_HPP
#define APICOMMUNICATIONCONTROLLER_HPP
 
#include "comms/ICommunicationController.hpp"
#include "comms/apis/IApiQueryParamsBuilder.hpp"
#include "comms/apis/structs.hpp"
 
namespace iv::comms::api
{
 
class ApiCommunicationController final : public iv::comms::ICommunicationController,
                                         public std::enable_shared_from_this<ApiCommunicationController>
{
    friend class ApiCommunicationControllerFrame;
 
public:
    ApiCommunicationController() = delete;
    ApiCommunicationController(const std::shared_ptr<iv::comms::ICommunicationDriver> &driver,
                               const std::shared_ptr<iv::model::comms::NetworkData> &networkData);
    ApiCommunicationController(const ApiCommunicationController &other) = delete;
    ApiCommunicationController(ApiCommunicationController &&other) = delete;
    ~ApiCommunicationController() override = default;
 
    ApiCommunicationController &operator=(const ApiCommunicationController &other) = delete;
    ApiCommunicationController &operator=(ApiCommunicationController &&other) = delete;
 
    void registerDataLog(const std::shared_ptr<iv::comms::api::ILoggerMessage> &message) const;
    void registerEventLog(const std::shared_ptr<iv::comms::api::ILoggerMessage> &message) const;
    void registerHistoryLog(const std::shared_ptr<iv::comms::api::ILoggerMessage> &message) const;
 
    iv::comms::api::ApiResponse requestDataLog(const IApiQueryParamsBuilder &queryParams) const;
    iv::comms::api::ApiResponse requestEventLog(const IApiQueryParamsBuilder &queryParams) const;
    iv::comms::api::ApiResponse requestHistoryLog(const IApiQueryParamsBuilder &queryParams) const;
 
    iv::comms::api::ApiDeleteResponse deleteDataLogs(const IApiQueryParamsBuilder &queryParams) const;
    iv::comms::api::ApiDeleteResponse deleteEventLogs(const IApiQueryParamsBuilder &queryParams) const;
    iv::comms::api::ApiDeleteResponse deleteHistoryLogs(const IApiQueryParamsBuilder &queryParams) const;
 
    iv::comms::api::ApiPingResponse ping() const;
    bool wipe() const;
 
private:
    void addChannel(const std::shared_ptr<iv::channels::AbstractChannel> &channel) override;
    bool frame() override;
    void initialize() override;
 
    static bool shouldSendToCloud(const std::shared_ptr<iv::model::comms::NetworkData> &networkData);
 
    std::shared_ptr<iv::comms::ICommunicationProtocol> m_dataLoggerProtocol;
    std::shared_ptr<iv::comms::ICommunicationProtocol> m_eventLoggerProtocol;
    std::shared_ptr<iv::comms::ICommunicationProtocol> m_historyLoggerProtocol;
 
    mutable std::mutex m_commControllerMutex;
};
 
}// namespace iv::comms::api
 
#endif//APICOMMUNICATIONCONTROLLER_HPP