blob: 4e47721276c0c621874c34c0d2a2ae514726a728 [file] [log] [blame]
Wludzik, Jozef1477fe62021-01-02 11:56:10 +01001#pragma once
2
Szymon Dompkeb7b7e1b2022-05-19 10:15:48 +02003#include "interfaces/clock.hpp"
Wludzik, Jozef1477fe62021-01-02 11:56:10 +01004#include "interfaces/sensor.hpp"
5#include "interfaces/sensor_listener.hpp"
6#include "interfaces/threshold.hpp"
7#include "interfaces/trigger_action.hpp"
Krzysztof Grobelny51f0fd52021-12-28 16:32:08 +01008#include "types/duration_types.hpp"
Krzysztof Grobelnydcc4e192021-03-08 09:09:34 +00009#include "types/trigger_types.hpp"
Szymon Dompke94f71c52021-12-10 07:16:33 +010010#include "utils/threshold_operations.hpp"
Wludzik, Jozef1477fe62021-01-02 11:56:10 +010011
12#include <boost/asio/steady_timer.hpp>
13
14#include <chrono>
Szymon Dompke94f71c52021-12-10 07:16:33 +010015#include <map>
Wludzik, Jozef1477fe62021-01-02 11:56:10 +010016#include <memory>
17#include <vector>
18
19class NumericThreshold :
20 public interfaces::Threshold,
21 public interfaces::SensorListener,
22 public std::enable_shared_from_this<NumericThreshold>
23{
24 public:
25 NumericThreshold(
Szymon Dompkeb7b7e1b2022-05-19 10:15:48 +020026 boost::asio::io_context& ioc, const std::string& triggerId,
27 Sensors sensors,
Wludzik, Jozef1477fe62021-01-02 11:56:10 +010028 std::vector<std::unique_ptr<interfaces::TriggerAction>> actions,
Krzysztof Grobelnydcc4e192021-03-08 09:09:34 +000029 Milliseconds dwellTime, numeric::Direction direction,
Szymon Dompkeb7b7e1b2022-05-19 10:15:48 +020030 double thresholdValue, numeric::Type type,
31 std::unique_ptr<interfaces::Clock> clock);
Krzysztof Grobelny41fa80d2022-06-09 13:27:16 +020032 NumericThreshold(const NumericThreshold&) = delete;
33 NumericThreshold(NumericThreshold&&) = delete;
Wludzik, Jozef1477fe62021-01-02 11:56:10 +010034
35 void initialize() override;
Krzysztof Grobelny51f0fd52021-12-28 16:32:08 +010036 void sensorUpdated(interfaces::Sensor&, Milliseconds, double) override;
Szymon Dompke94f71c52021-12-10 07:16:33 +010037 LabeledThresholdParam getThresholdParam() const override;
38 void updateSensors(Sensors newSensors) override;
Wludzik, Jozef1477fe62021-01-02 11:56:10 +010039
40 private:
41 boost::asio::io_context& ioc;
Szymon Dompkeb7b7e1b2022-05-19 10:15:48 +020042 const std::string& triggerId;
Wludzik, Jozef1477fe62021-01-02 11:56:10 +010043 const std::vector<std::unique_ptr<interfaces::TriggerAction>> actions;
Krzysztof Grobelnydcc4e192021-03-08 09:09:34 +000044 const Milliseconds dwellTime;
Wludzik, Jozef1477fe62021-01-02 11:56:10 +010045 const numeric::Direction direction;
46 const double thresholdValue;
Szymon Dompke94f71c52021-12-10 07:16:33 +010047 const numeric::Type type;
48 bool initialized = false;
Szymon Dompkeb7b7e1b2022-05-19 10:15:48 +020049 std::unique_ptr<interfaces::Clock> clock;
Wludzik, Jozef1477fe62021-01-02 11:56:10 +010050
51 struct ThresholdDetail
52 {
53 std::string sensorName;
54 double prevValue;
55 bool dwell;
56 boost::asio::steady_timer timer;
57
58 ThresholdDetail(const std::string& name, double prevValue, bool dwell,
59 boost::asio::io_context& ioc) :
60 sensorName(name),
61 prevValue(prevValue), dwell(dwell), timer(ioc)
62 {}
Krzysztof Grobelny41fa80d2022-06-09 13:27:16 +020063 ThresholdDetail(const ThresholdDetail&) = delete;
64 ThresholdDetail(ThresholdDetail&&) = delete;
Wludzik, Jozef1477fe62021-01-02 11:56:10 +010065 };
Szymon Dompke94f71c52021-12-10 07:16:33 +010066 using SensorDetails =
67 std::unordered_map<std::shared_ptr<interfaces::Sensor>,
68 std::shared_ptr<ThresholdDetail>>;
69 SensorDetails sensorDetails;
Wludzik, Jozef1477fe62021-01-02 11:56:10 +010070
Szymon Dompke94f71c52021-12-10 07:16:33 +010071 friend ThresholdOperations;
72
Szymon Dompkeb7b7e1b2022-05-19 10:15:48 +020073 void startTimer(ThresholdDetail&, double);
74 void commit(const std::string&, double);
Szymon Dompke94f71c52021-12-10 07:16:33 +010075 ThresholdDetail& getDetails(const interfaces::Sensor& sensor);
76 std::shared_ptr<ThresholdDetail> makeDetails(const std::string& sensorName);
Wludzik, Jozef1477fe62021-01-02 11:56:10 +010077};