#pragma once #include "interfaces/sensor.hpp" #include "interfaces/sensor_listener.hpp" #include "interfaces/threshold.hpp" #include "interfaces/trigger_action.hpp" #include "types/duration_types.hpp" #include "types/trigger_types.hpp" #include "utils/threshold_operations.hpp" #include #include #include #include #include class NumericThreshold : public interfaces::Threshold, public interfaces::SensorListener, public std::enable_shared_from_this { public: NumericThreshold( boost::asio::io_context& ioc, Sensors sensors, std::vector> actions, Milliseconds dwellTime, numeric::Direction direction, double thresholdValue, numeric::Type type); ~NumericThreshold() {} void initialize() override; void sensorUpdated(interfaces::Sensor&, Milliseconds, double) override; LabeledThresholdParam getThresholdParam() const override; void updateSensors(Sensors newSensors) override; private: boost::asio::io_context& ioc; const std::vector> actions; const Milliseconds dwellTime; const numeric::Direction direction; const double thresholdValue; const numeric::Type type; bool initialized = false; struct ThresholdDetail { std::string sensorName; double prevValue; bool dwell; boost::asio::steady_timer timer; ThresholdDetail(const std::string& name, double prevValue, bool dwell, boost::asio::io_context& ioc) : sensorName(name), prevValue(prevValue), dwell(dwell), timer(ioc) {} }; using SensorDetails = std::unordered_map, std::shared_ptr>; SensorDetails sensorDetails; friend ThresholdOperations; void startTimer(ThresholdDetail&, Milliseconds, double); void commit(const std::string&, Milliseconds, double); ThresholdDetail& getDetails(const interfaces::Sensor& sensor); std::shared_ptr makeDetails(const std::string& sensorName); };