emontx.h

Go to the documentation of this file.

#pragma once
 
#include "esphome/core/component.h"
#include "esphome/core/defines.h"
#include "esphome/core/helpers.h"
#include "esphome/core/string_ref.h"
#include "esphome/components/uart/uart.h"
#include "esphome/components/json/json_util.h"
 
#include <array>
 
#ifdef USE_SENSOR
#include "esphome/components/sensor/sensor.h"
#endif
 
namespace esphome::emontx {
 
static constexpr size_t MAX_LINE_LENGTH = 1024;
 
class EmonTx final : public Component, public uart::UARTDevice {
 public:
  EmonTx() = default;
 
  void loop() override;
  void setup() override;
  void dump_config() override;
 
  template<typename F> void add_on_json_callback(F &&callback) { this->json_callbacks_.add(std::forward<F>(callback)); }
 
  template<typename F> void add_on_data_callback(F &&callback) { this->data_callbacks_.add(std::forward<F>(callback)); }
 
  // Send command to emonTx via UART
  void send_command(const char *command);
  void send_command(const std::string &command) { this->send_command(command.c_str()); }
 
#ifdef USE_SENSOR
  void init_sensors(size_t count) { this->sensors_.init(count); }
  void register_sensor(const char *tag_name, sensor::Sensor *sensor);
#endif
 
 protected:
  void parse_json_(const char *data, size_t len);
 
#ifdef USE_SENSOR
  FixedVector<std::pair<const char *, sensor::Sensor *>> sensors_{};
#endif
  LazyCallbackManager<void(JsonObject, StringRef)> json_callbacks_;
  LazyCallbackManager<void(StringRef)> data_callbacks_;
  uint16_t buffer_pos_{0};
  std::array<char, MAX_LINE_LENGTH + 1> buffer_{};
};
 
}  // namespace esphome::emontx