system_info.h

Go to the documentation of this file.

#ifndef SENSESP_SENSORS_SYSTEM_INFO_H_
#define SENSESP_SENSORS_SYSTEM_INFO_H_
 
#include <Arduino.h>
#include <elapsedMillis.h>
#include <memory>
 
#include "sensesp/signalk/signalk_output.h"
#include "sensesp_base_app.h"
#include "sensor.h"
 
namespace sensesp {

template <typename T>
void connect_system_info_sensor(std::shared_ptr<ValueProducer<T>>& sensor,
                                const String& prefix, const String& name) {
  auto hostname_obs = SensESPBaseApp::get()->get_hostname_observable();
  String hostname = hostname_obs->get();
  String path = prefix + hostname + "." + name;
 
  auto sk_output = std::make_shared<SKOutput<T>>(path);
 
  // connect an observer to hostname to change the output path
  // if the hostname is changed
  auto update_output_sk_path = [hostname_obs, sk_output, prefix, name]() {
    String path = prefix + hostname_obs->get() + "." + name;
    sk_output->set_sk_path(path);
  };
  update_output_sk_path();
 
  hostname_obs->attach(update_output_sk_path);
 
  // connect the sensor to the output
  sensor->connect_to(sk_output);
}

class SystemHz : public ValueProducer<float> {
 public:
  SystemHz() {
    elapsed_millis_ = 0;
    repeat_event_ = event_loop()->onRepeat(1000, [this]() { this->update(); });
  }
  virtual ~SystemHz() {
    if (repeat_event_ != nullptr) {
      repeat_event_->remove(event_loop());
    }
  }
  String get_value_name() { return "systemhz"; }
 
 protected:
  uint32_t last_tick_count_ = 0;
  elapsedMillis elapsed_millis_;
  reactesp::RepeatEvent* repeat_event_ = nullptr;
  void update();
};

class FreeMem : public ValueProducer<uint32_t> {
 public:
  FreeMem() {
    repeat_event_ = event_loop()->onRepeat(1000, [this]() { this->update(); });
  }
  virtual ~FreeMem() {
    if (repeat_event_ != nullptr) {
      repeat_event_->remove(event_loop());
    }
  }
  String get_value_name() { return "freemem"; }
 
 protected:
  reactesp::RepeatEvent* repeat_event_ = nullptr;
  void update();
};

class Uptime : public ValueProducer<float> {
 public:
  Uptime() {
    repeat_event_ = event_loop()->onRepeat(1000, [this]() { this->update(); });
  }
  virtual ~Uptime() {
    if (repeat_event_ != nullptr) {
      repeat_event_->remove(event_loop());
    }
  }
  String get_value_name() { return "uptime"; }
 
 protected:
  reactesp::RepeatEvent* repeat_event_ = nullptr;
  void update();
};

class IPAddrDev : public ValueProducer<String> {
 public:
  IPAddrDev() {
    repeat_event_ = event_loop()->onRepeat(10000, [this]() { this->update(); });
  }
  virtual ~IPAddrDev() {
    if (repeat_event_ != nullptr) {
      repeat_event_->remove(event_loop());
    }
  }
  String get_value_name() { return "ipaddr"; }
 
 protected:
  reactesp::RepeatEvent* repeat_event_ = nullptr;
  void update();
};

class WiFiSignal : public ValueProducer<int> {
 public:
  WiFiSignal() {
    repeat_event_ = event_loop()->onRepeat(3000, [this]() { this->update(); });
  }
  virtual ~WiFiSignal() {
    if (repeat_event_ != nullptr) {
      repeat_event_->remove(event_loop());
    }
  }
  String get_value_name() { return "wifisignal"; }
 
 protected:
  reactesp::RepeatEvent* repeat_event_ = nullptr;
  void update();
};
 
}  // namespace sensesp
 
#endif