mirror of
https://github.com/esphome/esphome.git
synced 2026-02-18 15:35:59 -07:00
aa5092bdc2
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> Co-authored-by: pre-commit-ci-lite[bot] <117423508+pre-commit-ci-lite[bot]@users.noreply.github.com>
35 lines
1.3 KiB
C++
35 lines
1.3 KiB
C++
#include "custom_mqtt_device.h"
|
|
|
|
#ifdef USE_MQTT
|
|
|
|
#include "esphome/core/log.h"
|
|
|
|
namespace esphome::mqtt {
|
|
|
|
static const char *const TAG = "mqtt.custom";
|
|
|
|
bool CustomMQTTDevice::publish(const std::string &topic, const std::string &payload, uint8_t qos, bool retain) {
|
|
return global_mqtt_client->publish(topic, payload, qos, retain);
|
|
}
|
|
bool CustomMQTTDevice::publish(const std::string &topic, float value, int8_t number_decimals) {
|
|
char buf[VALUE_ACCURACY_MAX_LEN];
|
|
size_t len = value_accuracy_to_buf(buf, value, number_decimals);
|
|
return global_mqtt_client->publish(topic, buf, len);
|
|
}
|
|
bool CustomMQTTDevice::publish(const std::string &topic, int value) {
|
|
char buffer[24];
|
|
size_t len = buf_append_printf(buffer, sizeof(buffer), 0, "%d", value);
|
|
return global_mqtt_client->publish(topic, buffer, len);
|
|
}
|
|
bool CustomMQTTDevice::publish_json(const std::string &topic, const json::json_build_t &f, uint8_t qos, bool retain) {
|
|
return global_mqtt_client->publish_json(topic, f, qos, retain);
|
|
}
|
|
bool CustomMQTTDevice::publish_json(const std::string &topic, const json::json_build_t &f) {
|
|
return this->publish_json(topic, f, 0, false);
|
|
}
|
|
bool CustomMQTTDevice::is_connected() { return global_mqtt_client != nullptr && global_mqtt_client->is_connected(); }
|
|
|
|
} // namespace esphome::mqtt
|
|
|
|
#endif // USE_MQTT
|