alertService.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_ALERTSERVICE_HPP
#define RTCTK_COMPONENTFRAMEWORK_ALERTSERVICE_HPP
 
#include <log4cplus/logger.h>
 
#include <rtctk/componentFramework/alertServiceIf.hpp>
#include <rtctk/componentFramework/eventDefinitions.hpp>
#include <rtctk/componentFramework/typedEventService.hpp>
 
namespace rtctk::componentFramework {
 
class AlertService : public AlertServiceIf {
public:
    explicit AlertService(log4cplus::Logger logger);
    ~AlertService() noexcept;
 
    boost::signals2::connection ConnectReducedStatus(ReducedStatusSignal::slot_type slot) override;
 
    [[nodiscard]] AlertSource MakeAlertSource(AlertDescription const& description) override;
 
    [[nodiscard]] ReducedStatus GetReducedStatus() const override;
    [[nodiscard]] std::vector<AlertStatus> GetAlertStatuses() const override;
 
private:
    struct Shadow {
        AlertStatus status;
        boost::signals2::connection connection;
    };
 
    void UpdateAlertStatus(std::string const& id, bool status, AlertSource::TimePoint since);
 
    void CollectGarbage();
 
    mutable std::recursive_mutex m_api_mtx;
 
    std::vector<Shadow> m_shadow = {};
    ReducedStatus m_reduced = false;
    ReducedStatusSignal m_reduced_signal;
 
    log4cplus::Logger m_logger;
};
 
class AlertLogger {
public:
    AlertLogger(log4cplus::Logger logger, AlertServiceIf& service);
 
private:
    void Slot(AlertServiceIf::ReducedStatus const& status,
              std::vector<AlertServiceIf::AlertStatus> const& active);
    log4cplus::Logger m_logger;
    boost::signals2::scoped_connection m_connection;
};
 
class AlertEventPublisher {
public:
    AlertEventPublisher(std::string name,
                        AlertStatusObserverIf& alert_service,
                        EventServiceIf& event_service,
                        log4cplus::Logger logger);
 
private:
    void Slot(AlertServiceIf::ReducedStatus const& status,
              std::vector<AlertStatusObserverIf::AlertStatus> const& active);
 
    std::string m_name;
    TypedEventService m_event_service;
    log4cplus::Logger m_logger;
    boost::signals2::scoped_connection m_connection;
 
    std::unique_ptr<TypedEventPublisher<AlertStatusEvent>> m_publisher;
};
 
}  // namespace rtctk::componentFramework
 
#endif  // RTCTK_COMPONENTFRAMEWORK_ALERTSERVICE_HPP