1 #pragma once 2 3 #include "interfaces/sensor.hpp" 4 #include "interfaces/sensor_listener.hpp" 5 #include "interfaces/threshold.hpp" 6 #include "interfaces/trigger_action.hpp" 7 #include "types/duration_types.hpp" 8 #include "types/trigger_types.hpp" 9 #include "utils/threshold_operations.hpp" 10 11 #include <boost/asio/steady_timer.hpp> 12 13 #include <chrono> 14 #include <map> 15 #include <memory> 16 #include <vector> 17 18 class DiscreteThreshold : 19 public interfaces::Threshold, 20 public interfaces::SensorListener, 21 public std::enable_shared_from_this<DiscreteThreshold> 22 { 23 public: 24 DiscreteThreshold( 25 boost::asio::io_context& ioc, Sensors sensors, 26 std::vector<std::unique_ptr<interfaces::TriggerAction>> actions, 27 Milliseconds dwellTime, double thresholdValue, const std::string& name, 28 const discrete::Severity severity); 29 DiscreteThreshold(const DiscreteThreshold&) = delete; 30 DiscreteThreshold(DiscreteThreshold&&) = delete; 31 32 void initialize() override; 33 void sensorUpdated(interfaces::Sensor&, Milliseconds, double) override; 34 LabeledThresholdParam getThresholdParam() const override; 35 void updateSensors(Sensors newSensors) override; 36 37 private: 38 boost::asio::io_context& ioc; 39 const std::vector<std::unique_ptr<interfaces::TriggerAction>> actions; 40 const Milliseconds dwellTime; 41 const double thresholdValue; 42 const std::string name; 43 const discrete::Severity severity; 44 bool initialized = false; 45 46 struct ThresholdDetail 47 { 48 std::string sensorName; 49 bool dwell; 50 boost::asio::steady_timer timer; 51 52 ThresholdDetail(const std::string& name, bool dwell, 53 boost::asio::io_context& ioc) : 54 sensorName(name), 55 dwell(dwell), timer(ioc) 56 {} 57 }; 58 using SensorDetails = 59 std::unordered_map<std::shared_ptr<interfaces::Sensor>, 60 std::shared_ptr<ThresholdDetail>>; 61 SensorDetails sensorDetails; 62 63 friend ThresholdOperations; 64 65 void startTimer(ThresholdDetail&, Milliseconds, double); 66 void commit(const std::string&, Milliseconds, double); 67 ThresholdDetail& getDetails(const interfaces::Sensor& sensor); 68 std::shared_ptr<ThresholdDetail> makeDetails(const std::string& sensorName); 69 }; 70