custom_mqtt_device.h

Go to the documentation of this file.

#pragma once
 
#include "esphome/core/defines.h"
#ifdef USE_MQTT
 
#include "esphome/core/component.h"
#include "mqtt_client.h"
 
namespace esphome::mqtt {
 
class CustomMQTTDevice {
 public:
  template<typename T>
  void subscribe(const std::string &topic, void (T::*callback)(const std::string &, const std::string &),
                 uint8_t qos = 0);
 
  template<typename T>
  void subscribe(const std::string &topic, void (T::*callback)(const std::string &), uint8_t qos = 0);
 
  template<typename T> void subscribe(const std::string &topic, void (T::*callback)(), uint8_t qos = 0);
 
  template<typename T>
  void subscribe_json(const std::string &topic, void (T::*callback)(const std::string &, JsonObject), uint8_t qos = 0);
 
  template<typename T> void subscribe_json(const std::string &topic, void (T::*callback)(JsonObject), uint8_t qos = 0);
 
  bool publish(const std::string &topic, const std::string &payload, uint8_t qos = 0, bool retain = false);
 
  bool publish(const std::string &topic, float value, int8_t number_decimals = 3);
 
  bool publish(const std::string &topic, int value);
 
  bool publish_json(const std::string &topic, const json::json_build_t &f, uint8_t qos, bool retain);
 
  bool publish_json(const std::string &topic, const json::json_build_t &f);
 
  bool is_connected();
};
 
template<typename T>
void CustomMQTTDevice::subscribe(const std::string &topic,
                                 void (T::*callback)(const std::string &, const std::string &), uint8_t qos) {
  auto *obj = static_cast<T *>(this);
  global_mqtt_client->subscribe(
      topic, [obj, callback](const std::string &t, const std::string &payload) { (obj->*callback)(t, payload); }, qos);
}
template<typename T>
void CustomMQTTDevice::subscribe(const std::string &topic, void (T::*callback)(const std::string &), uint8_t qos) {
  auto *obj = static_cast<T *>(this);
  global_mqtt_client->subscribe(
      topic, [obj, callback](const std::string &, const std::string &payload) { (obj->*callback)(payload); }, qos);
}
template<typename T> void CustomMQTTDevice::subscribe(const std::string &topic, void (T::*callback)(), uint8_t qos) {
  auto *obj = static_cast<T *>(this);
  global_mqtt_client->subscribe(
      topic, [obj, callback](const std::string &, const std::string &) { (obj->*callback)(); }, qos);
}
template<typename T>
void CustomMQTTDevice::subscribe_json(const std::string &topic, void (T::*callback)(const std::string &, JsonObject),
                                      uint8_t qos) {
  auto *obj = static_cast<T *>(this);
  global_mqtt_client->subscribe_json(
      topic, [obj, callback](const std::string &t, JsonObject root) { (obj->*callback)(t, root); }, qos);
}
template<typename T>
void CustomMQTTDevice::subscribe_json(const std::string &topic, void (T::*callback)(JsonObject), uint8_t qos) {
  auto *obj = static_cast<T *>(this);
  global_mqtt_client->subscribe_json(
      topic, [obj, callback](const std::string &, JsonObject root) { (obj->*callback)(root); }, qos);
}
 
}  // namespace esphome::mqtt
 
#endif  // USE_MQTT