12 #if defined(USE_ESP32) 14 #elif defined(USE_ESP8266) 16 #elif defined(USE_LIBRETINY) 19 #include "lwip/ip_addr.h" 35 using mqtt_callback_t = std::function<void(const std::string &, const std::string &)>;
103 void disable_last_will();
108 void disable_birth_message();
111 void disable_shutdown_message();
114 void set_keep_alive(uint16_t keep_alive_s);
129 void disable_discovery();
130 bool is_discovery_enabled()
const;
132 #if ASYNC_TCP_SSL_ENABLED 145 void add_ssl_fingerprint(
const std::array<uint8_t, SHA1_SIZE> &fingerprint);
150 void set_cl_key(
const char *key) { this->mqtt_backend_.set_cl_key(key); }
163 void set_topic_prefix(
const std::string &topic_prefix);
165 const std::string &get_topic_prefix()
const;
168 void set_log_message_template(
MQTTMessage &&message);
169 void set_log_level(
int level);
171 void disable_log_message();
172 bool is_log_message_enabled()
const;
200 void unsubscribe(
const std::string &topic);
214 bool publish(
const std::string &topic,
const std::string &payload, uint8_t
qos = 0,
bool retain =
false);
216 bool publish(
const std::string &topic,
const char *payload,
size_t payload_length, uint8_t
qos = 0,
217 bool retain =
false);
225 bool publish_json(
const std::string &topic,
const json::json_build_t &f, uint8_t
qos = 0,
bool retain =
false);
228 void setup()
override;
229 void dump_config()
override;
231 void loop()
override;
233 float get_setup_priority()
const override;
235 void on_message(
const std::string &topic,
const std::string &payload);
237 bool can_proceed()
override;
239 void check_connected();
241 void set_reboot_timeout(uint32_t reboot_timeout);
247 void on_shutdown()
override;
251 void set_username(
const std::string &username) { this->credentials_.username = username; }
252 void set_password(
const std::string &password) { this->credentials_.password = password; }
253 void set_client_id(
const std::string &client_id) { this->credentials_.client_id = client_id; }
258 void send_device_info_();
261 void start_connect_();
262 void start_dnslookup_();
263 void check_dnslookup_();
264 #if defined(USE_ESP8266) && LWIP_VERSION_MAJOR == 1 265 static void dns_found_callback(
const char *
name,
ip_addr_t *ipaddr,
void *callback_arg);
267 static void dns_found_callback(
const char *name,
const ip_addr_t *ipaddr,
void *callback_arg);
271 void recalculate_availability_();
273 bool subscribe_(
const char *topic, uint8_t
qos);
275 void resubscribe_subscriptions_();
284 bool sent_birth_message_{
false};
291 .
prefix =
"homeassistant",
297 std::string topic_prefix_{};
300 int log_level_{ESPHOME_LOG_LEVEL};
303 #if defined(USE_ESP32) 305 #elif defined(USE_ESP8266) 307 #elif defined(USE_LIBRETINY) 313 bool dns_resolved_{
false};
314 bool dns_resolve_error_{
false};
316 uint32_t reboot_timeout_{300000};
318 uint32_t last_connected_{0};
328 void set_qos(uint8_t
qos);
329 void set_payload(
const std::string &payload);
330 void setup()
override;
331 void dump_config()
override;
332 float get_setup_priority()
const override;
344 topic, [
this](
const std::string &topic, JsonObject root) { this->trigger(root); },
qos);
351 client->
set_on_connect([
this](
bool session_present) { this->trigger(); });
365 TEMPLATABLE_VALUE(std::string,
topic)
366 TEMPLATABLE_VALUE(std::string, payload)
367 TEMPLATABLE_VALUE(uint8_t,
qos)
368 TEMPLATABLE_VALUE(
bool, retain)
370 void play(Ts...
x)
override {
371 this->parent_->publish(this->topic_.value(
x...), this->payload_.value(
x...), this->qos_.value(
x...),
372 this->retain_.value(
x...));
382 TEMPLATABLE_VALUE(std::string,
topic)
383 TEMPLATABLE_VALUE(uint8_t,
qos)
384 TEMPLATABLE_VALUE(
bool, retain)
386 void set_payload(
std::function<
void(Ts..., JsonObject)> payload) { this->payload_ = payload; }
390 auto topic = this->topic_.value(
x...);
391 auto qos = this->qos_.value(
x...);
392 auto retain = this->retain_.value(
x...);
393 this->parent_->publish_json(
topic, f,
qos, retain);
397 void encode_(Ts...
x, JsonObject root) { this->payload_(
x..., root); }
405 bool check(Ts...
x)
override {
return this->parent_->is_connected(); }
uint32_t resubscribe_timeout
MQTTConnectedCondition(MQTTClientComponent *parent)
MQTTClientComponent * parent_
std::function< void(Ts..., JsonObject)> payload_
optional< std::string > payload_
void set_client_id(const std::string &client_id)
MQTTPublishAction(MQTTClientComponent *parent)
std::string topic
Empty means disabled.
MQTTDiscoveryUniqueIdGenerator unique_id_generator
Internal struct for MQTT Home Assistant discovery.
void set_cl_certificate(const char *cert)
std::function< void(const std::string &, const std::string &)> mqtt_callback_t
Callback for MQTT subscriptions.
std::string client_id
The client ID. Will automatically be truncated to 23 characters.
void set_broker_port(uint16_t port)
internal struct for MQTT messages.
std::vector< MQTTComponent * > children_
void encode_(Ts... x, JsonObject root)
MQTTMessage last_will_
The last will message.
std::string payload_available
std::string prefix
The Home Assistant discovery prefix. Empty means disabled.
std::function< MQTTBackend::on_connect_callback_t > mqtt_on_connect_callback_t
Callback for MQTT events.
bool is_connected()
Return whether the node is connected to the network (through wifi, eth, ...)
void set_skip_cert_cn_check(bool skip_check)
void set_on_connect(mqtt_on_connect_callback_t &&callback)
void set_password(const std::string &password)
MQTTBackendESP32 mqtt_backend_
void set_broker_address(const std::string &address)
MQTTClientComponent * global_mqtt_client
void play(Ts... x) override
Base class for all automation conditions.
MQTTJsonMessageTrigger(const std::string &topic, uint8_t qos)
MQTTBackendESP8266 mqtt_backend_
uint16_t port
The port number of the server.
MQTTDiscoveryUniqueIdGenerator
available discovery unique_id generators
std::function< void(JsonObject)> json_build_t
Callback function typedef for building JsonObjects.
bool check(Ts... x) override
MQTTPublishJsonAction(MQTTClientComponent *parent)
void set_ca_certificate(const char *cert)
MQTTDiscoveryObjectIdGenerator
available discovery object_id generators
internal struct for MQTT subscriptions.
MQTTBackendLibreTiny mqtt_backend_
MQTTClientDisconnectReason
std::string address
The address of the server without port number.
MQTTCredentials credentials_
MQTTMessage shutdown_message_
Simple data struct for Home Assistant component availability.
std::function< MQTTBackend::on_disconnect_callback_t > mqtt_on_disconnect_callback_t
MQTTMessage birth_message_
The birth message (e.g.
This is a workaround until we can figure out a way to get the tflite-micro idf component code availab...
std::string payload_not_available
MQTTConnectTrigger(MQTTClientComponent *&client)
std::vector< MQTTSubscription > subscriptions_
MQTTDiscoveryObjectIdGenerator object_id_generator
void set_cl_key(const char *key)
void set_username(const std::string &username)
void subscribe_json(const std::string &topic, const mqtt_json_callback_t &callback, uint8_t qos=0)
Subscribe to a MQTT topic and automatically parse JSON payload.
std::string payload_buffer_
internal struct for MQTT credentials.
MQTTDisconnectTrigger(MQTTClientComponent *&client)
void set_on_disconnect(mqtt_on_disconnect_callback_t &&callback)
MQTTClientComponent * parent_
bool retain
Whether to retain discovery messages.
std::function< void(const std::string &, JsonObject)> mqtt_json_callback_t
MQTTComponent is the base class for all components that interact with MQTT to expose certain function...