12 #if defined(USE_ESP32) 14 #elif defined(USE_ESP8266) 17 #include "lwip/ip_addr.h" 33 using mqtt_callback_t = std::function<void(const std::string &, const std::string &)>;
101 void disable_last_will();
106 void disable_birth_message();
109 void disable_shutdown_message();
112 void set_keep_alive(uint16_t keep_alive_s);
127 void disable_discovery();
128 bool is_discovery_enabled()
const;
130 #if ASYNC_TCP_SSL_ENABLED 143 void add_ssl_fingerprint(
const std::array<uint8_t, SHA1_SIZE> &fingerprint);
159 void set_topic_prefix(
const std::string &topic_prefix);
161 const std::string &get_topic_prefix()
const;
164 void set_log_message_template(
MQTTMessage &&message);
165 void set_log_level(
int level);
167 void disable_log_message();
168 bool is_log_message_enabled()
const;
196 void unsubscribe(
const std::string &topic);
210 bool publish(
const std::string &topic,
const std::string &payload, uint8_t
qos = 0,
bool retain =
false);
212 bool publish(
const std::string &topic,
const char *payload,
size_t payload_length, uint8_t
qos = 0,
213 bool retain =
false);
221 bool publish_json(
const std::string &topic,
const json::json_build_t &f, uint8_t
qos = 0,
bool retain =
false);
224 void setup()
override;
225 void dump_config()
override;
227 void loop()
override;
229 float get_setup_priority()
const override;
231 void on_message(
const std::string &topic,
const std::string &payload);
233 bool can_proceed()
override;
235 void check_connected();
237 void set_reboot_timeout(uint32_t reboot_timeout);
243 void on_shutdown()
override;
247 void set_username(
const std::string &username) { this->credentials_.username = username; }
248 void set_password(
const std::string &password) { this->credentials_.password = password; }
249 void set_client_id(
const std::string &client_id) { this->credentials_.client_id = client_id; }
254 void send_device_info_();
257 void start_connect_();
258 void start_dnslookup_();
259 void check_dnslookup_();
260 #if defined(USE_ESP8266) && LWIP_VERSION_MAJOR == 1 261 static void dns_found_callback(
const char *
name, ip_addr_t *ipaddr,
void *callback_arg);
263 static void dns_found_callback(
const char *name,
const ip_addr_t *ipaddr,
void *callback_arg);
267 void recalculate_availability_();
269 bool subscribe_(
const char *topic, uint8_t
qos);
271 void resubscribe_subscriptions_();
280 bool sent_birth_message_{
false};
287 .
prefix =
"homeassistant",
293 std::string topic_prefix_{};
296 int log_level_{ESPHOME_LOG_LEVEL};
299 #if defined(USE_ESP32) 301 #elif defined(USE_ESP8266) 307 bool dns_resolved_{
false};
308 bool dns_resolve_error_{
false};
310 uint32_t reboot_timeout_{300000};
312 uint32_t last_connected_{0};
322 void set_qos(uint8_t
qos);
323 void set_payload(
const std::string &payload);
324 void setup()
override;
325 void dump_config()
override;
326 float get_setup_priority()
const override;
338 topic, [
this](
const std::string &topic, JsonObject root) { this->trigger(root); },
qos);
345 client->
set_on_connect([
this](
bool session_present) { this->trigger(); });
359 TEMPLATABLE_VALUE(std::string,
topic)
360 TEMPLATABLE_VALUE(std::string, payload)
361 TEMPLATABLE_VALUE(uint8_t,
qos)
362 TEMPLATABLE_VALUE(
bool, retain)
364 void play(Ts...
x)
override {
365 this->parent_->publish(this->topic_.value(
x...), this->payload_.value(
x...), this->qos_.value(
x...),
366 this->retain_.value(
x...));
376 TEMPLATABLE_VALUE(std::string,
topic)
377 TEMPLATABLE_VALUE(uint8_t,
qos)
378 TEMPLATABLE_VALUE(
bool, retain)
380 void set_payload(
std::function<
void(Ts..., JsonObject)> payload) { this->payload_ = payload; }
384 auto topic = this->topic_.value(
x...);
385 auto qos = this->qos_.value(
x...);
386 auto retain = this->retain_.value(
x...);
387 this->parent_->publish_json(
topic, f,
qos, retain);
391 void encode_(Ts...
x, JsonObject root) { this->payload_(
x..., root); }
399 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.
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.
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.
std::string payload_not_available
MQTTConnectTrigger(MQTTClientComponent *&client)
std::vector< MQTTSubscription > subscriptions_
MQTTDiscoveryObjectIdGenerator object_id_generator
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...