ThermometerService.h

Go to the documentation of this file.

#pragma once

#include "PrfThermometer.h"
#include "JsonUtils.h"
#include "IService.h"
#include "IMessaging.h"
#include <string>
#include <map>
#include <memory>

class IDaemon;
class IMessaging;
class ISerializer;

class ThermometerService : public IService
{
public:
  ThermometerService() = delete;
  ThermometerService(const std::string& name);
  virtual ~ThermometerService();

  void updateConfiguration(const rapidjson::Value& cfg);

  void setDaemon(IDaemon* daemon) override;
  void setSerializer(ISerializer* serializer) override;
  void setMessaging(IMessaging* messaging) override;
  const std::string& getName() const override {
    return m_name;
  }

  void update(const rapidjson::Value& cfg) override;
  void start() override;
  void stop() override;

private:
  void handleMsgFromMessaging(const IMessaging::ustring& msg);
  void handleTaskFromScheduler(const std::string& task);
  void processThermometersRead();
  void scheduleReading();

  std::string m_name;
  uint16_t m_readPeriod = 60;
  int m_timeout = 1000;

  IMessaging* m_messaging;
  IDaemon* m_daemon;

  struct Val {
    double value = -273.15;
    double valid = false;
  };

  std::map<int,Val> m_thermometers;
  IScheduler::TaskHandle m_schdTaskHandle = IScheduler::TASK_HANDLE_INVALID;
  std::mutex m_mtx;
};